D-Net

package eu.dnetlib.msro.workflows.nodes.mdstore;

import java.util.stream.Stream;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

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

import org.springframework.context.annotation.Scope;

import org.springframework.stereotype.Component;

import eu.dnetlib.data.mdstore.MDStoreService;

import eu.dnetlib.data.mdstore.MDStoreService.FeedMode;

import eu.dnetlib.msro.annotations.ProcessNode;

import eu.dnetlib.msro.workflows.Arc;

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

@Component

@Scope("prototype")

@ProcessNode("Store")

public class MDStoreFeederJobNode extends SimpleParallelProcessNode {

	private static final Log log = LogFactory.getLog(MDStoreFeederJobNode.class);

	@Autowired

	private MDStoreService mdstoreService;

	private String mdId;

	private Stream<String> inputStream;

	private FeedMode mode;

	@Override

	protected String execute() throws Exception {

		log.info("Start feeding mdstore " + mdId);

		mdstoreService.store(mdId, inputStream, mode);

		return Arc.DEFAULT_ARC;

	}

	public String getMdId() {

		return mdId;

	}

	public void setMdId(final String mdId) {

		this.mdId = mdId;

	}

	public Stream<String> getInputStream() {

		return inputStream;

	}

	public void setInputStream(final Stream<String> inputStream) {

		this.inputStream = inputStream;

	}

	public FeedMode getMode() {

		return mode;

	}

	public void setMode(final FeedMode mode) {

		this.mode = mode;

	}

}