import com.cloudant.client.api.CloudantClient; //导入依赖的package包/类
public static Application.Helper getHelper() throws Exception {
    if(systemProperties.containsKey("PROP_FILE")) {
        properties.load(new FileInputStream(systemProperties.get("PROP_FILE")));
    }

    CloudantClient cloudantClient = ClientBuilder
            .url(new URL(getProperty("cloudant.url")))
            .username(getProperty("cloudant.username"))
            .password(getProperty("cloudant.password"))
            .build();
    WolframRepository wolframRepository = new WolframRepository(getProperty("wolfram.apiKey"));
    return new Application.Helper(
            cloudantClient,
            wolframRepository,
            getProperty("cloudant.chatDB"),
            getProperty("cloudant.feedbackDB"),
            getProperty("cloudant.explorerDB"),
            getProperty("tmdb.apiKey")
    );
}
 

import com.cloudant.client.api.CloudantClient; //导入依赖的package包/类
@Profile("kubernetes")
@Bean
/*
 * Load the CloudantClient from the Kubernetes Secrets file.
 * This method is only loaded when the kubernetes profile is activated
 */
public CloudantClient client() throws IOException {

	String secrets = readKubeSecretsFiles();
	String secretsJson = StringUtils.newStringUtf8(Base64.decodeBase64(secrets));
	ObjectMapper mapper = new ObjectMapper();
	Map<String, Object> map = new HashMap<String, Object>();

	// convert JSON string to Map
	map = mapper.readValue(secretsJson, new TypeReference<Map<String, String>>(){});

	String username = (String) map.get("username");
	String password = (String) map.get("password");
	String url = "http://" + map.get("username") + ".cloudant.com";

	return ClientBuilder.url(new URL(url))
			.username(username)
			.password(password)
			.build();
}
 

import com.cloudant.client.api.CloudantClient; //导入依赖的package包/类
@Autowired
public Helper(final CloudantClient cloudantClient,
              WolframRepository wolframRepository,
              @Value("${cloudant.chatDB}") String chatDBName,
              @Value("${cloudant.feedbackDB}") String feedbackDBName,
              @Value("${cloudant.explorerDB}") String explorerDBName,
              @Value("${tmdb.apiKey}") String tmdbApiKey) {
    try {
        chatDB = cloudantClient.database(chatDBName, true);
        feedbackDB = cloudantClient.database(feedbackDBName, true);
        explorerDB = cloudantClient.database(explorerDBName, true);
    }
    catch(Exception e) {
        logger.info("ERROR HERE");
        e.printStackTrace();
    }
    finally {
        this.tmdbApiKey = tmdbApiKey;
        this.wolframRepository = wolframRepository;

        riveScriptBot = new RiveScriptBot();
        eliza = new ElizaMain();
        eliza.readScript(true, "src/main/resources/eliza/script");

        sparql = new SPARQL(explorerDB);
        languageTool = new JLanguageTool(new AmericanEnglish());
        for (Rule rule : languageTool.getAllActiveRules()) {
            if (rule instanceof SpellingCheckRule) {
                List<String> wordsToIgnore = Arrays.asList("nlp");
                ((SpellingCheckRule) rule).addIgnoreTokens(wordsToIgnore);
            }
        }
    }
}
 

import com.cloudant.client.api.CloudantClient; //导入依赖的package包/类
@Bean
public CloudantClient client() {
	ClientBuilder builder = ClientBuilder
		.url(config.getUrl())
		.username(config.getUsername())
		.password(config.getPassword());
	return builder.build();
}
 

import com.cloudant.client.api.CloudantClient; //导入依赖的package包/类
private static CloudantClient createClient() {
	
	String url;

	if (System.getenv("VCAP_SERVICES") != null) {
		// When running in Bluemix, the VCAP_SERVICES env var will have the credentials for all bound/connected services
		// Parse the VCAP JSON structure looking for cloudant.
		JsonObject cloudantCredentials = VCAPHelper.getCloudCredentials("cloudant");
		if(cloudantCredentials == null){
			System.out.println("No cloudant database service bound to this application");
			return null;
		}
		url = cloudantCredentials.get("url").getAsString();
	} else {
		System.out.println("Running locally. Looking for credentials in cloudant.properties");
		url = VCAPHelper.getLocalProperties("cloudant.properties").getProperty("cloudant_url");
		if(url == null || url.length()==0){
			System.out.println("To use a database, set the Cloudant url in src/main/resources/cloudant.properties");
			return null;
		}
	}

	try {
		System.out.println("Connecting to Cloudant");
		CloudantClient client = ClientBuilder.url(new URL(url)).build();
		return client;
	} catch (Exception e) {
		System.out.println("Unable to connect to database");
		//e.printStackTrace();
		return null;
	}
}
 

import com.cloudant.client.api.CloudantClient; //导入依赖的package包/类
@Test
public void clientBeanCreation() {
    when(mockBuilder.build()).thenReturn(mockClient);
    
    this.context.register(MockClientBuilderConfig.class);
    EnvironmentTestUtils.addEnvironment(this.context, "cloudant.url=http://cloudant.com");
    this.context.refresh();
    CloudantClient client = this.context.getBean(CloudantClient.class);
    assertEquals(mockClient, client);
}
 

import com.cloudant.client.api.CloudantClient; //导入依赖的package包/类
@Test
public void clientBeanCreation() {
    when(mockBuilder.build()).thenReturn(mockClient);
    
    this.context.register(MockClientBuilderConfig.class, CloudantAutoConfiguration.class);
    this.context.refresh();
    CloudantClient client = this.context.getBean(CloudantClient.class);
    assertEquals(mockClient, client);
}
 

import com.cloudant.client.api.CloudantClient; //导入依赖的package包/类
/**
 * Create the connection to the Cloudant database that we'll use for this
 * service.
 */
private void connect() {
	CloudantClient cloudant = new CloudantClient(
			AppPropertiesReader.getStringProperty(Constants.CLOUDANT_ACCOUNT),
			AppPropertiesReader.getStringProperty(Constants.CLOUDANT_USERNAME),
			AppPropertiesReader.getStringProperty(Constants.CLOUDANT_PASSWORD));
	db = cloudant.database(AppPropertiesReader.getStringProperty(Constants.CLOUDANT_DB_NAME), true);
	
}
 

import com.cloudant.client.api.CloudantClient; //导入依赖的package包/类
public CloudantConnector(ICloudantSettings cs){
    cloudantSettings = cs;
    ConnectOptions connectOptions = new ConnectOptions()
            .setConnectionTimeout(cloudantSettings.getConnectionTimeout())
            .setMaxConnections(cloudantSettings.getMaxConnections());
    cloudantClient = new CloudantClient(cloudantSettings.getUrl(),cloudantSettings.getUsername(),cloudantSettings.getPassword(), connectOptions);
}
 

import com.cloudant.client.api.CloudantClient; //导入依赖的package包/类
@Override
public void afterPropertiesSet() throws Exception {
    ConnectOptions connectionOptions = new ConnectOptions()
            .setConnectionTimeout(connectionTimeout)
            .setMaxConnections(maxConnections);
    cloudantClient = new CloudantClient(account,username,password,connectionOptions);
    gsonBuilder = new GsonBuilder().registerTypeHierarchyAdapter(BaseDocument.class,new UnmappedDataAdapter());
    cloudantClient.setGsonBuilder(gsonBuilder);
}
 

import com.cloudant.client.api.CloudantClient; //导入依赖的package包/类
public CloudantLocationStore(){
	CloudantClient cloudant = createClient();
	if(cloudant!=null){
	 db = cloudant.database(databaseName, true);
	}
}
 

import com.cloudant.client.api.CloudantClient; //导入依赖的package包/类
@Bean
public Database hrsDb(CloudantClient cloudant) {
	return cloudant.database("hrs", true);
}
 

import com.cloudant.client.api.CloudantClient; //导入依赖的package包/类
@Bean
public Database database(CloudantClient client) {
	Database db = client.database(config.getDb(), true);
	return db;
}
 

import com.cloudant.client.api.CloudantClient; //导入依赖的package包/类
public CloudantVisitorStore(){
	CloudantClient cloudant = createClient();
	if(cloudant!=null){
	 db = cloudant.database(databaseName, true);
	}
}
 

import com.cloudant.client.api.CloudantClient; //导入依赖的package包/类
@Bean
public CloudantClient client(ClientBuilder builder) {
    return builder.build();
}
 

import com.cloudant.client.api.CloudantClient; //导入依赖的package包/类
@Bean
public CloudantClient client() {
    return mockClient;
}
 

import com.cloudant.client.api.CloudantClient; //导入依赖的package包/类
@Bean
@ConditionalOnMissingBean
public CloudantClient client(ClientBuilder builder) {
    return builder.build();
}
 

import com.cloudant.client.api.CloudantClient; //导入依赖的package包/类
@Bean
@ConditionalOnProperty(name = "cloudant.db")
public Database database(CloudantClient client) {
    Database db = client.database(config.getDb(), true);
    return db;
}
 

import com.cloudant.client.api.CloudantClient; //导入依赖的package包/类
@Bean
public Database account(CloudantClient cloudant) throws MalformedURLException {
	return cloudant.database("account", true);
}
 

import com.cloudant.client.api.CloudantClient; //导入依赖的package包/类
/**
 * Connect to Cloundant NoSQL DB based on the authentication credentials provided as
 * user inputs in the DMDeviceSample.properties file. 
 * 
 **/
@Override
public void prepare(String propertiesFile) {

	/**
	 * Load device properties file
	 */
	Properties props = new Properties();
	try {
		props.load(DeviceInitiatedHandlerSample.class.getResourceAsStream(propertiesFile));
	} catch (IOException e1) {
		System.err.println("Not able to read the properties file, exiting..");
		System.exit(-1);
	}
	
	/**
	 * Read individual parameter values from device properties file
	 */
		
	String username = trimedValue(props.getProperty("User-Name"));
	String password = trimedValue(props.getProperty("Password"));
	
	currentFirmwareVersion = (props.getProperty("DeviceInfo.fwVersion"));

	StringBuilder sb = new StringBuilder();
	sb.append("https://")
	.append(username)
	.append(":")
	.append(password)
	.append("@")
	.append(username)
	.append(".cloudant.com");
		
	System.out.println(sb);
	
	CloudantClient client = new CloudantClient(sb.toString(), username, password);
		
	System.out.println("Connected to Cloudant");
	System.out.println("Server Version: " + client.serverVersion());

	/**
	 * Pass the name of the Cloudant NoSQL Database to 'firmwareDB'
	 * To create the Cloudant NoSQL Database 'firmware_repository', replace 'false' with 'true'
	 */
	
	firmwareDB = client.database("firmware_repository", false);
	
	// Create update task
	updateTask = new DebianFirmwareUpdate(false);
	
	Thread t = new Thread(this);
	t.start();
}