D-Net

package eu.dnetlib.msro.openaireplus.workflows.nodes.consistency;

import java.util.List;

import javax.annotation.Resource;

import org.springframework.beans.factory.annotation.Autowired;

import com.googlecode.sarasvati.Arc;

import com.googlecode.sarasvati.NodeToken;

import eu.dnetlib.data.mdstore.modular.MDStoreDescription;

import eu.dnetlib.data.mdstore.modular.MDStoreFeeder;

import eu.dnetlib.data.mdstore.modular.connector.MDStoreDao;

import eu.dnetlib.msro.workflows.nodes.SimpleJobNode;

import eu.dnetlib.msro.workflows.util.ProgressProvider;

public class VerifyMdStoreSizesJobNode extends SimpleJobNode implements ProgressProvider {

	private int current = 0;

	private int total = 0;

	@Autowired

	private MDStoreFeeder feeder;

	@Resource(name = "mongodbMDStoreDao")

	private MDStoreDao dao;

	@Override

	protected String execute(final NodeToken token) throws Exception {

		final List<MDStoreDescription> list = dao.listMDStores();

		total = list.size();

		current = 0;

		for (final MDStoreDescription mdstore : list) {

			current++;

			feeder.touchSize(mdstore.getId(), dao.getMDStore(mdstore.getId()).getSize());

		}

		return Arc.DEFAULT_ARC;

	}

	@Override

	public int getTotalValue() {

		return total;

	}

	@Override

	public int getCurrentValue() {

		return current;

	}

	@Override

	public boolean isInaccurate() {

		return false;

	}

}