D-Net

package eu.dnetlib.validator.service.impl;

import eu.dnetlib.api.functionality.ValidatorService;

import eu.dnetlib.api.functionality.ValidatorServiceException;

import eu.dnetlib.domain.ActionType;

import eu.dnetlib.domain.ResourceType;

import eu.dnetlib.domain.enabling.Notification;

import eu.dnetlib.domain.functionality.validator.JobForValidation;

import eu.dnetlib.domain.functionality.validator.RuleSet;

import eu.dnetlib.domain.functionality.validator.StoredJob;

import eu.dnetlib.enabling.tools.blackboard.BlackboardNotificationHandler;

import eu.dnetlib.enabling.tools.blackboard.BlackboardServerHandler;

import eu.dnetlib.validator.engine.ValidatorException;

import gr.uoa.di.driver.app.DriverServiceImpl;

import gr.uoa.di.driver.enabling.issn.NotificationListener;

import java.util.ArrayList;

import java.util.List;

import java.util.Map;

import org.apache.log4j.Logger;

public class ValidatorServiceImpl extends DriverServiceImpl implements

		ValidatorService {

	private BlackboardNotificationHandler<BlackboardServerHandler> blackboardNotificationHandler = null;

	private Logger logger = Logger.getLogger(ValidatorServiceImpl.class);

	private ValidatorManager valManager;

	// do NOT call directly. It will be called by the

	// InitializingServiceRegistrationManager

	// after it sets the service EPR and id.

	@Override

	public void init() {

		super.init();

		if (this.blackboardNotificationHandler != null) { 

			this.subscribe(ActionType.UPDATE,

				ResourceType.VALIDATORSERVICERESOURCETYPE, this.getServiceEPR()

						.getParameter("serviceId"),

				"RESOURCE_PROFILE/BODY/BLACKBOARD/LAST_REQUEST",

				new NotificationListener() {

					@Override

					public void processNotification(Notification notification) {

						blackboardNotificationHandler.notified(

								notification.getSubscriptionId(),

								notification.getTopic(),

								notification.getIsId(),

								notification.getMessage());

						logger.debug(notification.getSubscriptionId());

						logger.debug(notification.getTopic());

						logger.debug(notification.getIsId());

						logger.debug(notification.getMessage());

					}

				});

		}

	}

	@Override

	public StoredJob getStoredJob(int jobId, String groupBy)

			throws ValidatorServiceException {

		try {

			logger.debug("received request for job " + jobId);

			return valManager.getStoredJob(jobId, groupBy);

		} catch (ValidatorException e) {

			throw new ValidatorServiceException(e);

		}

	}

	@Override

	public List<StoredJob> getStoredJobs(String userMail)

			throws ValidatorServiceException {

		try {

			logger.debug("received request for jobs of user " + userMail);

			return valManager.getStoredJobs(userMail);

		} catch (ValidatorException e) {

			throw new ValidatorServiceException(e);

		}

	}

	@Override

	public List<RuleSet> getRuleSets() throws ValidatorServiceException {

		try {

			logger.debug("received request for rulesets ");

			return valManager.getRuleSets();

		} catch (ValidatorException e) {

			throw new ValidatorServiceException(e);

		}

	}

	@Override

	public void submitValidationJob(JobForValidation job)

			throws ValidatorServiceException {

		try {

			logger.debug("received request to submit job");

			this.valManager.submitJob(job);

		} catch (ValidatorException e) {

			throw new ValidatorServiceException(e);

		}

	}

	public BlackboardNotificationHandler<BlackboardServerHandler> getBlackboardNotificationHandler() {

		return blackboardNotificationHandler;

	}

	public ValidatorManager getValManager() {

		return valManager;

	}

	public void setValManager(ValidatorManager valManager) {

		this.valManager = valManager;

	}

	public void setBlackboardNotificationHandler(

			BlackboardNotificationHandler<BlackboardServerHandler> blackboardNotificationHandler) {

		this.blackboardNotificationHandler = blackboardNotificationHandler;

	}

	@Override

	public Map<String, ArrayList<StoredJob>> getValidationJobs(String userMail,

			boolean repoAdmin) {

		// TODO Auto-generated method stub

		return null;

	}

}