* Copyright 2010 Outerthought bvba

*

* 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.

*/

    public static final String ALTERNATE_TABLE = "alternate";

    private static LilyProxy lilyProxy;

    private static LilyIndexerConf INDEXER_CONF;

    private static RepositoryManager repositoryManager;

    private static LRepository repository;

    private static LTable defaultTable;

    private static LTable alternateTable;

    private static TypeManager typeManager;

    private static IdGenerator idGenerator;

    private static WriteableIndexerModel indexerModel;

    private static IndexesInfo indexesInfo;

    private static TrackingRepository indexUpdaterRepository;

    private static FieldType nvTag;

    private static FieldType liveTag;

    private static FieldType previewTag;

    private static FieldType latestTag;

    private static FieldType lastTag;

    private static FieldType nvfield1;

    private static FieldType nvfield2;

    private static FieldType nvLinkField1;

    private static FieldType nvLinkField2;

    private static FieldType vfield1;

    private static FieldType vfield2;

    private static FieldType vLinkField1;

    private static FieldType vLinkField2;

    private static FieldType vStringMvField;

    private static FieldType vLongField;

    private static FieldType vBlobField;

    private static FieldType vBlobMvHierField;

    private static FieldType vBlobNestedField;

    private static FieldType vDateTimeField;

    private static FieldType vDateField;

    private static FieldType vIntHierField;

    private static final String NS = "org.lilyproject.indexer.test";

    private static final String NS2 = "org.lilyproject.indexer.test.2";

    private static final String DYN_NS1 = "org.lilyproject.indexer.test.dyn1";

    private static final String DYN_NS2 = "org.lilyproject.indexer.test.dyn2";

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

    private static MessageVerifier messageVerifier;

    private static OtherListener otherListener;

    private static RecordType nvRecordType1;

    private static RecordType vRecordType1;

    private static RecordType lastRecordType;

    private static String REPO_NAME = "IndexerTestRepo";

    private static Map<String, FieldType> fields = Maps.newHashMap();

    private final Map<String, Integer> matchResultCounts = Maps.newHashMap();

    private final static TestListener listener = new TestListener();

    @BeforeClass

    public static void setUpBeforeClass() throws Exception {

        lilyProxy = new LilyProxy(null, null, null, true);

        lilyProxy.start(IOUtils.toByteArray(IndexerTest.class.getResourceAsStream("schema1.xml")));

        TestHelper.setupLogging("org.lilyproject.indexer", "org.lilyproject.indexer.engine",

                "org.lilyproject.indexer.engine.test.IndexerTest", "com.ngdata.hbaseindexer",

                "org.lilyproject.indexer.model.util");

        Configuration conf = HBaseIndexerConfiguration.create();

        indexerModel = lilyProxy.getLilyServerProxy().getIndexerModel();

        indexerModel.registerListener(listener);

        indexesInfo = (IndexesInfo) lilyProxy.getLilyServerProxy().getLilyServerTestingUtility().getRuntime()

                .getModuleById("indexer-integration").getApplicationContext().getBean("indexesInfo");

        //repoSetup.setRecordUpdateHooks(Collections.singletonList(hook));

        lilyProxy.getLilyServerProxy().createRepository(REPO_NAME);

        repositoryManager = lilyProxy.getLilyServerProxy().getClient();

        repository = repositoryManager.getRepository(REPO_NAME);

        repository.getTableManager().createTable(ALTERNATE_TABLE);

        defaultTable = (Repository) repository.getDefaultTable();

        alternateTable = (Repository) repository.getTable(ALTERNATE_TABLE);

        indexUpdaterRepository = new TrackingRepository(repositoryManager.getRepository(REPO_NAME));

        typeManager = repository.getTypeManager();

        idGenerator = repository.getIdGenerator();

        otherListener = new OtherListener(repositoryManager);

        messageVerifier = new MessageVerifier(repositoryManager);

        // Field types should exist before the indexer conf is loaded

        setupSchema();

        //solrShardManager = ClassicSolrShardManager.createForOneShard(SOLR_TEST_UTIL.getDefaultUri());

    }

    @AfterClass

    public static void tearDownAfterClass() throws Exception {

        // cleanup the last created index (especially the SEP part), this is important when running tests in connect mode

        cleanupIndex("test" + idxChangeCnt);

        lilyProxy.stop();

          /*

        if (SOLR_TEST_UTIL != null) {

            SOLR_TEST_UTIL.stop();

        }   */

    }

    // augmented each time we change the indexerconf, to give the indexes unique names

    private static int idxChangeCnt = 0;

    public static void changeIndexUpdater(String confName) throws Exception {

        changeIndexUpdater(confName, Table.RECORD.name, true);

    }

    public static void changeIndexUpdater(String confName, String indexTableName) throws Exception {

        changeIndexUpdater(confName, indexTableName, true);

    }

    public static void changeIndexUpdater(String confName, String indexTableName, boolean enableDerefMap) throws Exception {

        String indexNamePrefix = "test_";

        String prevIndexName = indexNamePrefix + idxChangeCnt;

        idxChangeCnt++;

        String indexName = indexNamePrefix + idxChangeCnt;

        System.out.println("changeIndexUpdater invocation " + idxChangeCnt + " - " + confName);

        // First clean up stuff of old index, to be sure this also gets executed in case of invalid indexerconf

        cleanupIndex(prevIndexName);

        waitForIndexesInfoUpdate(0);

        // warning: the below line will throw an exception in case of invalid conf, which is an exception

        // which some test cases expect, and hence it won't be visible but will cause the remainder of the

        // code in this method not to be executed! (so keep this in mind for anything related to resource cleanup)

        INDEXER_CONF = LilyIndexerConfBuilder.build(IndexerTest.class.getResourceAsStream(confName),

                repositoryManager.getRepository(REPO_NAME));

        Configuration hbaseConf = lilyProxy.getHBaseProxy().getConf();

        // The registration of the index into the IndexerModel is only needed for the IndexRecordFilterHook