D-Net

package eu.dnetlib.clients.msro;

import java.util.Map;

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

import org.springframework.context.annotation.Scope;

import org.springframework.stereotype.Component;

import org.springframework.web.client.RestTemplate;

import eu.dnetlib.clients.BaseServiceClient;

import eu.dnetlib.enabling.annotations.DnetServiceClient;

import eu.dnetlib.enabling.annotations.DnetServiceType;

import eu.dnetlib.msro.workflows.WorkflowInstance;

import eu.dnetlib.msro.workflows.WorkflowRef;

import eu.dnetlib.services.async.AsyncClientCallback;

import eu.dnetlib.services.async.AsyncClientUtils;

@Component

@Scope("prototype")

@DnetServiceClient(DnetServiceType.msroWorker)

public class MsroWorkerClient extends BaseServiceClient {

	@Autowired

	private AsyncClientUtils asyncClientUtils;

	public MsroWorkerRunningInstance getStatus() {

		return (new RestTemplate()).getForObject(getBaseUrl(), MsroWorkerRunningInstance.class);

	}

	public WorkflowRef execute(final WorkflowInstance wf, final String localBaseUrl, final AsyncClientCallback callback) {

		final Map<String, String> info = asyncClientUtils.invokeRemoteMethod(getBaseUrl(), "startWorkflow", localBaseUrl, wf, callback);

		return new WorkflowRef(info.get("procId"), getBaseUrl());

	}

}