/**
 * ============LICENSE_START===================================================
 * SPARKY (AAI UI service)
 * ============================================================================
 * Copyright © 2017 AT&T Intellectual Property.
 * Copyright © 2017 Amdocs
 * All rights reserved.
 * ============================================================================
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 * ============LICENSE_END=====================================================
 *
 * ECOMP and OpenECOMP are trademarks
 * and service marks of AT&T Intellectual Property.
 */

package org.onap.aai.sparky.synchronizer;

/**
 * The Class SyncControllerBuilder.
 */
public class SyncControllerBuilder {


  /*
   * We'll have to revisit this class, as the sync controllers are wired up pretty differently now
   */

  /**
   * Test elastic search update api.
   */
  /*
   * public void testElasticSearchUpdateApi() { try {
   * 
   * RestClientBuilder clientBuilder = new RestClientBuilder(); clientBuilder.setUseHttps(false);
   * 
   * RestfulDataAccessor nonCachingRestProvider = new RestfulDataAccessor(clientBuilder);
   * 
   * ElasticSearchConfig esConfig = ElasticSearchConfig.getConfig(); ElasticSearchDataProvider
   * elasticSearchDataProvider = new ElasticSearchAdapter(nonCachingRestProvider, esConfig);
   * 
   * String payload =
   * "{ \"entityType\": \"complex\", \"pkey\": \"MORRISTOWN0075\", \"location\": { \"lat\": \"40.793414\", \"lon\": \"-74.480432\" }, \"selfLink\": \"https://aai-int1.test.att.com:8443/aai/v8/cloud-infrastructure/complexes/complex/MORRISTOWN0075?nodes-only\" }\n"
   * ;
   * 
   * String updateRequest = elasticSearchDataProvider.buildBulkImportOperationRequest(
   * "topographysearchindex-localhost", "default",
   * "1e2a6ba9e09d5e1bcb016b3a0b8d50273b42828e47957bd2a2f3ce1854744f5f", "6", payload);
   * 
   * OperationResult or = elasticSearchDataProvider.doBulkOperation("http://localhost:9200/_bulk",
   * updateRequest);
   * 
   * System.out.println(or.toString());
   * 
   * /* String BULK_IMPORT_INDEX_TEMPLATE =
   * "{\"index\":{\"_index\":\"%s\",\"_type\":\"%s\",\"_id\":\"%s\", \"_version\":\"%s\"}}\n";
   * 
   * StringBuilder updateRequestPayload = new StringBuilder(128);
   * updateRequestPayload.append(String.format(BULK_IMPORT_INDEX_TEMPLATE,
   * "topographysearchindex-localhost", "default",
   * "1e2a6ba9e09d5e1bcb016b3a0b8d50273b42828e47957bd2a2f3ce1854744f5f", "5"));
   * 
   * 
   * updateRequestPayload.append(payload);
   * 
   * OperationResult or = nonCachingRestProvider.doRestfulOperation(HttpMethod.PUT,
   * "http://localhost:9200/_bulk", updateRequestPayload.toString(),
   * RestfulDataAccessor.APPLICATION_X_WWW_FORM_URL_ENCODED, RestfulDataAccessor.APPLICATION_JSON);
   */


  /*
   * } catch (Exception exc) { exc.printStackTrace(); System.out.println(
   * "Error:  failed to sync with message = " + exc.getMessage()); } }
   * 
   * /** Do historical entity sync.
   *//*
     * public void doHistoricalEntitySync() { try { SyncController syncController = new
     * SyncControllerImpl("historicalEntityTestController");
     * 
     * ActiveInventoryAdapter aaiAdapter = new ActiveInventoryAdapter(new OxmModelLoader(), new
     * RestClientBuilder());
     * 
     * RestClientBuilder clientBuilder = new RestClientBuilder(); clientBuilder.setUseHttps(false);
     * 
     * RestfulDataAccessor nonCachingRestProvider = new RestfulDataAccessor(clientBuilder);
     * 
     * ElasticSearchConfig esConfig = ElasticSearchConfig.getConfig();
     * 
     * ElasticSearchAdapter esAdapter = new ElasticSearchAdapter(nonCachingRestProvider,esConfig);
     * 
     * 
     * IndexIntegrityValidator entityCounterHistoryValidator = new
     * IndexIntegrityValidator(nonCachingRestProvider, esConfig.getEntityCountHistoryIndex(),
     * esConfig.getType(), esConfig.getIpAddress(), esConfig.getHttpPort(),
     * esConfig.buildElasticSearchEntityCountHistoryTableConfig());
     * 
     * syncController.registerIndexValidator(entityCounterHistoryValidator);
     * 
     * 
     * //////
     * 
     * 
     * 
     * HistoricalEntitySummarizer historicalSummarizer = new
     * HistoricalEntitySummarizer(esConfig.getEntityCountHistoryIndex());
     * historicalSummarizer.setAaiDataProvider(aaiAdapter);
     * historicalSummarizer.setEsDataProvider(esAdapter);
     * syncController.registerEntitySynchronizer(historicalSummarizer);
     * 
     * ////
     * 
     * /* IndexIntegrityValidator entitySearchIndexValidator = new IndexIntegrityValidator(new
     * RestClientBuilder());
     * 
     * entitySearchIndexValidator.setIndexName("topographysearchindex-localhost");
     * entitySearchIndexValidator.setIndexType("default");
     * entitySearchIndexValidator.setIndexSettings("");
     * entitySearchIndexValidator.setIndexSettings("");
     * 
     * syncController.registerIndexValidator(entitySearchIndexValidator);
     */

  ////

  /*
   * IndexCleaner index1Cleaner = new ElasticSearchIndexCleaner(nonCachingRestProvider,
   * "topographysearchindex-localhost", "default", "127.0.0.1", "9200", 5, 5000);
   */

  // syncController.registerIndexCleaner(index1Cleaner);

  ///
  /*
   * for (int x = 0; x < 10; x++) {
   * 
   * syncController.performAction(SyncActions.SYNCHRONIZE);
   * 
   * while (syncController.getState() == SynchronizerState.PERFORMING_SYNCHRONIZATION) {
   * 
   * System.out.println("sync controller state = " + syncController.getState());
   * 
   * Thread.sleep(1000); } }
   * 
   * syncController.shutdown();
   * 
   * } catch (Exception exc) { exc.printStackTrace(); System.out.println(
   * "Error:  failed to sync with message = " + exc.getMessage()); } }
   * 
   * /** Do geo entity sync.
   *//*
     * public void doGeoEntitySync() { try {
     * 
     * ActiveInventoryAdapter aaiAdapter = new ActiveInventoryAdapter(new OxmModelLoader(), new
     * RestClientBuilder());
     * 
     * RestClientBuilder clientBuilder = new RestClientBuilder(); clientBuilder.setUseHttps(false);
     * 
     * RestfulDataAccessor nonCachingRestProvider = new RestfulDataAccessor(clientBuilder);
     * ElasticSearchConfig esConfig = ElasticSearchConfig.getConfig();
     * 
     * ElasticSearchAdapter esAdapter = new ElasticSearchAdapter(nonCachingRestProvider,esConfig);
     * 
     * IndexIntegrityValidator entitySearchIndexValidator = new
     * IndexIntegrityValidator(nonCachingRestProvider, esConfig.getIndexName(), esConfig.getType(),
     * esConfig.getIpAddress(), esConfig.getHttpPort(), esConfig.buildElasticSearchTableConfig());
     * 
     * SyncController syncController = new SyncControllerImpl("geoEntitySyncTestController");
     * syncController.registerIndexValidator(entitySearchIndexValidator);
     * 
     * 
     * //////
     * 
     * GeoSynchronizer geoSync = new GeoSynchronizer("topographysearchindex-localhost");
     * geoSync.setAaiDataProvider(aaiAdapter); geoSync.setEsDataProvider(esAdapter);
     * syncController.registerEntitySynchronizer(geoSync);
     * 
     * ////
     * 
     * /* IndexIntegrityValidator entitySearchIndexValidator = new IndexIntegrityValidator(new
     * RestClientBuilder());
     * 
     * entitySearchIndexValidator.setIndexName("topographysearchindex-localhost");
     * entitySearchIndexValidator.setIndexType("default");
     * entitySearchIndexValidator.setIndexSettings("");
     * entitySearchIndexValidator.setIndexSettings("");
     * 
     * syncController.registerIndexValidator(entitySearchIndexValidator);
     */

  ////

  /*
   * IndexCleaner index1Cleaner = new ElasticSearchIndexCleaner(nonCachingRestProvider,
   * "topographysearchindex-localhost", "default", "127.0.0.1", "9200", 5, 5000);
   */

  // syncController.registerIndexCleaner(index1Cleaner);

  ///
  /*
   * syncController.performAction(SyncActions.SYNCHRONIZE);
   * 
   * while (syncController.getState() == SynchronizerState.PERFORMING_SYNCHRONIZATION) {
   * Thread.sleep(1000); }
   * 
   * syncController.shutdown();
   * 
   * } catch (Exception exc) { exc.printStackTrace(); System.out.println(
   * "Error:  failed to sync with message = " + exc.getMessage()); } }
   * 
   * /** Do searchable entitysync.
   *//*
     * public void doSearchableEntitysync() { try {
     * 
     * 
     * ActiveInventoryAdapter aaiAdapter = new ActiveInventoryAdapter(new OxmModelLoader(), new
     * RestClientBuilder());
     * 
     * RestClientBuilder clientBuilder = new RestClientBuilder(); clientBuilder.setUseHttps(false);
     * 
     * RestfulDataAccessor nonCachingRestProvider = new RestfulDataAccessor(clientBuilder);
     * ElasticSearchConfig esConfig = ElasticSearchConfig.getConfig();
     * 
     * ElasticSearchAdapter esAdapter = new ElasticSearchAdapter(nonCachingRestProvider,esConfig);
     * 
     * //////
     * 
     * SyncController syncController = new SyncControllerImpl("searchtableEntityTestController");
     * 
     * ViewInspectEntitySynchronizer ses = new
     * ViewInspectEntitySynchronizer("entitysearchindex-localhost");
     * ses.setAaiDataProvider(aaiAdapter); ses.setEsDataProvider(esAdapter);
     * syncController.registerEntitySynchronizer(ses);
     * 
     * ////
     * 
     * /* IndexIntegrityValidator entitySearchIndexValidator = new IndexIntegrityValidator(new
     * RestClientBuilder());
     * 
     * entitySearchIndexValidator.setIndexName("esi-sync2-localhost");
     * entitySearchIndexValidator.setIndexType("default");
     * 
     * syncController.registerIndexValidator(entitySearchIndexValidator);
     */

  ////

  /*
   * IndexCleaner index1Cleaner = new ElasticSearchIndexCleaner(nonCachingRestProvider,
   * "entitysearchindex-localhost", "default", "127.0.0.1", "9200", 5, 5000);
   * 
   * syncController.registerIndexCleaner(index1Cleaner);
   */

  ///
  /*
   * syncController.performAction(SyncActions.SYNCHRONIZE);
   * 
   * while (syncController.getState() == SynchronizerState.PERFORMING_SYNCHRONIZATION) {
   * Thread.sleep(1000); }
   * 
   * syncController.shutdown();
   * 
   * } catch (Exception exc) { exc.printStackTrace(); System.out.println(
   * "Error:  failed to sync with message = " + exc.getMessage()); } }
   * 
   * /** Do cross entity reference sync.
   *//*
     * public void doCrossEntityReferenceSync() { try {
     * 
     * ActiveInventoryAdapter aaiAdapter = new ActiveInventoryAdapter(new OxmModelLoader(), new
     * RestClientBuilder());
     * 
     * RestClientBuilder clientBuilder = new RestClientBuilder(); clientBuilder.setUseHttps(false);
     * 
     * RestfulDataAccessor nonCachingRestProvider = new RestfulDataAccessor(clientBuilder);
     * ElasticSearchConfig esConfig = ElasticSearchConfig.getConfig();
     * 
     * ElasticSearchAdapter esAdapter = new ElasticSearchAdapter(nonCachingRestProvider,esConfig);
     * 
     * SyncController syncController = new SyncControllerImpl("crossEntityRefSyncController");
     * 
     * CrossEntityReferenceSynchronizer cers = new
     * CrossEntityReferenceSynchronizer("entitysearchindex-localhost",
     * ActiveInventoryConfig.getConfig()); cers.setAaiDataProvider(aaiAdapter);
     * cers.setEsDataProvider(esAdapter); syncController.registerEntitySynchronizer(cers);
     * 
     * ViewInspectEntitySynchronizer ses = new
     * ViewInspectEntitySynchronizer("entitysearchindex-localhost");
     * ses.setAaiDataProvider(aaiAdapter); ses.setEsDataProvider(esAdapter);
     * syncController.registerEntitySynchronizer(ses);
     * 
     * ElasticSearchConfig config = ElasticSearchConfig.getConfig();
     * 
     * IndexIntegrityValidator entitySearchIndexValidator = new IndexIntegrityValidator(
     * nonCachingRestProvider, config.getIndexName(), config.getType(), config.getIpAddress(),
     * config.getHttpPort(), config.buildElasticSearchTableConfig());
     * 
     * syncController.registerIndexValidator(entitySearchIndexValidator);
     * 
     * ////
     * 
     * IndexCleaner index1Cleaner = new ElasticSearchIndexCleaner(nonCachingRestProvider,
     * config.getIndexName(), config.getType(), config.getIpAddress(), config.getHttpPort(), 5,
     * 5000);
     * 
     * syncController.registerIndexCleaner(index1Cleaner);
     * 
     * ///
     * 
     * syncController.performAction(SyncActions.SYNCHRONIZE);
     * 
     * while (syncController.getState() == SynchronizerState.PERFORMING_SYNCHRONIZATION) {
     * Thread.sleep(1000); }
     * 
     * syncController.shutdown();
     * 
     * } catch (Exception exc) { exc.printStackTrace(); System.out.println(
     * "Error:  Failed to sync with message = " + exc.getMessage()); } }
     * 
     * /** Do suggestion entitysync.
     *//*
       * public void doSuggestionEntitySync() { try { ActiveInventoryAdapter aaiAdapter = new
       * ActiveInventoryAdapter(new OxmModelLoader(), new RestClientBuilder());
       * 
       * RestClientBuilder clientBuilder = new RestClientBuilder();
       * clientBuilder.setUseHttps(false);
       * 
       * RestfulDataAccessor nonCachingRestProvider = new RestfulDataAccessor(clientBuilder);
       * ElasticSearchConfig esConfig = ElasticSearchConfig.getConfig();
       * 
       * ElasticSearchAdapter esAdapter = new ElasticSearchAdapter(nonCachingRestProvider,
       * esConfig);
       * 
       * SyncController syncController = new SyncControllerImpl("suggestionEntityTestController");
       * 
       * AutosuggestionSynchronizer ses = new
       * AutosuggestionSynchronizer("entityautosuggestindex-localhost");
       * ses.setAaiDataProvider(aaiAdapter); ses.setEsDataProvider(esAdapter);
       * syncController.registerEntitySynchronizer(ses);
       * 
       * syncController.performAction(SyncActions.SYNCHRONIZE);
       * 
       * while (syncController.getState() == SynchronizerState.PERFORMING_SYNCHRONIZATION) {
       * Thread.sleep(1000); }
       * 
       * syncController.shutdown();
       * 
       * } catch (Exception exc) { exc.printStackTrace(); System.out.println(
       * "Error:  failed to sync with message = " + exc.getMessage()); } }
       * 
       * /* Do no op sync.
       *//*
         * public void doNoOpSync() { try { SyncController syncController = new
         * SyncControllerImpl("noopSyncTestController");
         * 
         * /* ActiveInventoryAdapter aaiAdapter = new ActiveInventoryAdapter(new
         * RestClientBuilder());
         * 
         * aaiAdapter.setCacheEnabled(true);
         * 
         * /*InMemoryEntityCache aaiInMemoryCache = new InMemoryEntityCache();
         * aaiAdapter.setEntityCache(aaiInMemoryCache);
         */

  /*
   * PersistentEntityCache aaiDiskCache = new PersistentEntityCache();
   * aaiAdapter.setEntityCache(aaiDiskCache);
   * 
   * ElasticSearchConfig config = ElasticSearchConfig.getConfig(); OXMModelLoader loader =
   * OXMModelLoader.getInstance(); SyncAdapter syncAdapter = new SyncAdapter(new
   * RestClientBuilder(), config, loader);
   * 
   * //////
   * 
   * SearchableEntitySynchronizer ses = new SearchableEntitySynchronizer();
   * ses.setAaiDataProvider(aaiAdapter); ses.setEsDataProvider(syncAdapter);
   * syncController.registerEntitySynchronizer(ses);
   * 
   * ////
   * 
   * IndexIntegrityValidator entitySearchIndexValidator = new IndexIntegrityValidator(new
   * RestClientBuilder());
   * 
   * entitySearchIndexValidator.setIndexName("esi-sync2-localhost");
   * entitySearchIndexValidator.setIndexType("default");
   * entitySearchIndexValidator.setIndexSettings("");
   * entitySearchIndexValidator.setIndexSettings("");
   * 
   * syncController.registerIndexValidator(entitySearchIndexValidator);
   * 
   * ////
   * 
   * ElasticSearchEntityPurger p1 = new ElasticSearchEntityPurger(new RestClientBuilder());
   * p1.setIndexName("esi-blal-blah");
   * 
   * ElasticSearchEntityPurger p2 = new ElasticSearchEntityPurger(new RestClientBuilder());
   * p2.setIndexName("esi-topo-blah");
   */
  ///
  /*
   * syncController.performAction(SyncActions.SYNCHRONIZE);
   * 
   * while (syncController.getState() == SynchronizerState.PERFORMING_SYNCHRONIZATION) {
   * Thread.sleep(1000); }
   * 
   * syncController.shutdown();
   * 
   * } catch (Exception exc) { System.out.println("Error:  failed to sync with message = " +
   * exc.getMessage()); } }
   * 
   * 
   * /** The main method.
   *
   * @param args the arguments
   *//*
     * public static void main(String[] args) { //boolean runSearchableEntitySync = false; //boolean
     * runGeoEntitySync = true;
     * 
     * //System.setProperty("AJSC_HOME", "e:\\dev"); //
     * System.getProperties().setProperty("AJSC_HOME", //
     * "c:\\rpo\\tier-support-ui\\target\\swm\\package\\nix\\" // +
     * "dist_files\\opt\\app\\ajsc-tier-support-ui");
     * 
     * System.setProperty("CONFIG_HOME", "appconfig-local"); System.setProperty("AJSC_HOME",
     * "x:\\1710_extensibility\\");
     * 
     * SyncControllerBuilder syncBuilder = new SyncControllerBuilder();
     * 
     * /* if (runSearchableEntitySync) syncBuilder.doSearchableEntitysync();
     */
  /*
   * syncBuilder.doSearchableEntitysync(); // syncBuilder.doCrossEntityReferenceSync(); //
   * syncBuilder.doHistoricalEntitySync(); // syncBuilder.doGeoEntitySync();
   * //syncBuilder.doSuggestionEntitySync(); //syncBuilder.doMasterEntitySync();
   * 
   * // syncBuilder.testElasticSearchUpdateAPI();
   * 
   * /* if (runGeoEntitySync) { syncBuilder.doGeoEntitySync(); }
   */



  // }
}