D-Net

package eu.dnetlib;

import com.mongodb.MongoClient;

import com.mongodb.MongoClientOptions;

import com.mongodb.ServerAddress;

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

import org.apache.commons.dbcp2.BasicDataSource;

import org.apache.cxf.jaxws.JaxWsProxyFactoryBean;

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

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;

/**

 * Created by Alessia Bardi on 31/03/17.

 *

 * @author Alessia Bardi

 */

@Configuration

public class OpenaireExporterConfig {

	// POSTGRES

	@Value("${spring.datasource.driverClassName}")

	private String driverClassName;

	@Value("${openaire.exporter.jdbc.url}")

	private String jdbcUrl;

	@Value("${openaire.exporter.jdbc.user}")

	private String jdbcUser;

	@Value("${openaire.exporter.jdbc.pwd}")

	private String jdbcPwd;

	@Value("${openaire.exporter.jdbc.minIdle}")

	private int jdbcMinIdle;

	@Value("${openaire.exporter.jdbc.maxIdle}")

	private int jdbcMaxidle;

	// MONGODB

	@Value("${openaire.datasource.publisher.mongodb.host}")

	private String mongodbHost;

	@Value("${openaire.datasource.publisher.mongodb.port}")

	private int mongodbPort;

	@Value("${openaire.datasource.publisher.mongodb.connectionsPerHost}")

	private int connectionsPerHost;

	@Value("${services.is.lookup.url}")

	private String isLookupUrl;

	@Bean

	public ISLookUpService getLookUpService() {

		final JaxWsProxyFactoryBean jaxWsProxyFactory = new JaxWsProxyFactoryBean();

		jaxWsProxyFactory.setServiceClass(ISLookUpService.class);

		jaxWsProxyFactory.setAddress(isLookupUrl);

		return (ISLookUpService) jaxWsProxyFactory.create();

	}

	@Bean

	public BasicDataSource getProjectDataSource() {

		return getDatasource(driverClassName, jdbcUrl, jdbcUser, jdbcPwd, jdbcMinIdle, jdbcMaxidle);

	}

	private BasicDataSource getDatasource(String driverClassName, String jdbcUrl, String jdbcUser, String jdbcPwd, int jdbcMinIdle, int jdbcMaxIdle) {

		BasicDataSource d =  new BasicDataSource();

		d.setDriverClassName(driverClassName);

		d.setUrl(jdbcUrl);

		d.setUsername(jdbcUser);

		d.setPassword(jdbcPwd);

		d.setMinIdle(jdbcMinIdle);

		d.setMaxIdle(jdbcMaxIdle);

		return d;

	}

	@Bean

	public MongoClient getMongoClient() {

		return new MongoClient(

				new ServerAddress(mongodbHost, mongodbPort),

				MongoClientOptions.builder().connectionsPerHost(connectionsPerHost).build());

	}

}