D-Net

package eu.dnetlib.enabling.is;

import java.io.StringReader;

import java.util.List;

import java.util.UUID;

import javax.annotation.PostConstruct;

import javax.annotation.Resource;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

import org.dom4j.Document;

import org.dom4j.Element;

import org.dom4j.io.SAXReader;

import eu.dnetlib.enabling.is.dao.DnetServiceDao;

import eu.dnetlib.enabling.is.jdbc.DatabaseUtils;

import eu.dnetlib.enabling.is.lookup.rmi.ISLookUpService;

import eu.dnetlib.enabling.is.rmi.DnetService;

import eu.dnetlib.enabling.is.rmi.InformationService;

import eu.dnetlib.enabling.is.rmi.InformationServiceException;

import eu.dnetlib.enabling.locators.UniqueServiceLocator;

import eu.dnetlib.enabling.tools.AbstractBaseService;

public class InformationServiceImpl extends AbstractBaseService implements InformationService {

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

	@Resource

	private DnetServiceDao dnetServiceDao;

	@Resource

	private DatabaseUtils dbUtils;

	@Resource

	private UniqueServiceLocator serviceLocator;

	@PostConstruct

	public void init() throws Exception {

		log.info("Registering services...");

		final SAXReader reader = new SAXReader();

		final ISLookUpService lookup = serviceLocator.getService(ISLookUpService.class);

		final List<String> list = lookup.quickSearchProfile("for $x in collection('/db/DRIVER/ServiceResources') return $x");

		for (String s : list) {

			final Document doc = reader.read(new StringReader(s));

			final DnetService service = new DnetService();

			service.setName(doc.valueOf("//RESOURCE_TYPE/@value"));

			for (Object o : doc.selectNodes("//SERVICE_PROPERTIES/PROPERTY")) {

				final Element n = (Element) o;

				service.getProperties().put(n.valueOf("@key"), n.valueOf("@value"));

			}

			for (Object o : doc.selectNodes("//PROTOCOLS/PROTOCOL")) {

				final Element n = (Element) o;

				service.getProtocols().put(n.valueOf("@name"), n.valueOf("@address"));

			}

			registerService(service);

		}

		log.info("Done, total: " + list.size());

	}

	@Override

	public List<DnetService> listServices() throws InformationServiceException {

		return dnetServiceDao.list();

	}

	@Override

	public String registerService(final DnetService service) throws InformationServiceException {

		final String id = "service:" + UUID.randomUUID();

		service.setId(id);

		dnetServiceDao.save(service);

		log.info("Service " + service + " saved");

		return id;

	}

	@Override

	public List<String> search(final String sql) throws InformationServiceException {

		return dbUtils.search(sql);

	}

}