package org.apache.lucene.index;

/**
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You 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.
 */


import java.io.IOException;
import java.util.HashSet;
import java.util.Set;

import org.apache.lucene.analysis.MockAnalyzer;
import org.apache.lucene.document.BinaryField;
import org.apache.lucene.document.Document;
import org.apache.lucene.document.Field;
import org.apache.lucene.document.FieldSelector;
import org.apache.lucene.document.FieldSelectorVisitor;
import org.apache.lucene.document.FieldType;
import org.apache.lucene.document.SetBasedFieldSelector;
import org.apache.lucene.document.TextField;
import org.apache.lucene.index.IndexWriterConfig.OpenMode;
import org.apache.lucene.store.Directory;
import org.apache.lucene.util.BytesRef;
import org.apache.lucene.util.LuceneTestCase;

public class TestContribIndexReader extends LuceneTestCase {
  private Document getDocument(IndexReader ir, int docID, FieldSelector selector)  throws IOException {
    final FieldSelectorVisitor visitor = new FieldSelectorVisitor(selector);
    ir.document(docID, visitor);
    return visitor.getDocument();
  }

  static void addDoc(IndexWriter writer, String value) throws IOException {
    Document doc = new Document();
    doc.add(newField("content", value, TextField.TYPE_UNSTORED));
    writer.addDocument(doc);
  }

  static void addDocumentWithFields(IndexWriter writer) throws IOException {
    Document doc = new Document();
        
    FieldType customType = new FieldType(TextField.TYPE_UNSTORED);
    customType.setStored(true);
    customType.setTokenized(false);

    FieldType customType2 = new FieldType(TextField.TYPE_UNSTORED);
    customType2.setStored(true);

    FieldType customType3 = new FieldType();
    customType3.setStored(true);
    doc.add(newField("keyword", "test1", customType));
    doc.add(newField("text", "test1", customType2));
    doc.add(newField("unindexed", "test1", customType3));
    doc.add(new TextField("unstored","test1"));
    writer.addDocument(doc);
  }


  static void addDocumentWithDifferentFields(IndexWriter writer) throws IOException {
    Document doc = new Document();
      
    FieldType customType = new FieldType(TextField.TYPE_UNSTORED);
    customType.setStored(true);
    customType.setTokenized(false);

    FieldType customType2 = new FieldType(TextField.TYPE_UNSTORED);
    customType2.setStored(true);

    FieldType customType3 = new FieldType();
    customType3.setStored(true);
    doc.add(newField("keyword2", "test1", customType));
    doc.add(newField("text2", "test1", customType2));
    doc.add(newField("unindexed2", "test1", customType3));
    doc.add(new TextField("unstored2","test1"));
    writer.addDocument(doc);
  }

  static void addDocumentWithTermVectorFields(IndexWriter writer) throws IOException {
    Document doc = new Document();
    FieldType customType4 = new FieldType(TextField.TYPE_UNSTORED);
    customType4.setStored(true);
    FieldType customType5 = new FieldType(TextField.TYPE_UNSTORED);
    customType5.setStored(true);
    customType5.setStoreTermVectors(true);
    FieldType customType6 = new FieldType(TextField.TYPE_UNSTORED);
    customType6.setStored(true);
    customType6.setStoreTermVectors(true);
    customType6.setStoreTermVectorOffsets(true);
    FieldType customType7 = new FieldType(TextField.TYPE_UNSTORED);
    customType7.setStored(true);
    customType7.setStoreTermVectors(true);
    customType7.setStoreTermVectorPositions(true);
    FieldType customType8 = new FieldType(TextField.TYPE_UNSTORED);
    customType8.setStored(true);
    customType8.setStoreTermVectors(true);
    customType8.setStoreTermVectorOffsets(true);
    customType8.setStoreTermVectorPositions(true);
    doc.add(newField("tvnot","tvnot",customType4));
    doc.add(newField("termvector","termvector",customType5));
    doc.add(newField("tvoffset","tvoffset", customType6));
    doc.add(newField("tvposition","tvposition", customType7));
    doc.add(newField("tvpositionoffset","tvpositionoffset", customType8));
        
    writer.addDocument(doc);
  }

  public void testBinaryFields() throws IOException {
    Directory dir = newDirectory();
    byte[] bin = new byte[]{0, 1, 2, 3, 4, 5, 6, 7, 8, 9};
        
    IndexWriter writer = new IndexWriter(dir, newIndexWriterConfig(TEST_VERSION_CURRENT, new MockAnalyzer(random)).setMergePolicy(newLogMergePolicy()));
        
    for (int i = 0; i < 10; i++) {
      addDoc(writer, "document number " + (i + 1));
      addDocumentWithFields(writer);
      addDocumentWithDifferentFields(writer);
      addDocumentWithTermVectorFields(writer);
    }
    writer.close();
    writer = new IndexWriter(dir, newIndexWriterConfig(TEST_VERSION_CURRENT, new MockAnalyzer(random)).setOpenMode(OpenMode.APPEND).setMergePolicy(newLogMergePolicy()));
    Document doc = new Document();
    doc.add(new BinaryField("bin1", bin));
    doc.add(new TextField("junk", "junk text"));
    writer.addDocument(doc);
    writer.close();
    IndexReader reader = IndexReader.open(dir, false);
    Document doc2 = reader.document(reader.maxDoc() - 1);
    IndexableField[] fields = doc2.getFields("bin1");
    assertNotNull(fields);
    assertEquals(1, fields.length);
    Field b1 = (Field) fields[0];
    assertTrue(b1.isBinary());
    BytesRef bytesRef = b1.binaryValue(null);
    assertEquals(bin.length, bytesRef.length);
    for (int i = 0; i < bin.length; i++) {
      assertEquals(bin[i], bytesRef.bytes[i + bytesRef.offset]);
    }
    Set<String> lazyFields = new HashSet<String>();
    lazyFields.add("bin1");
    FieldSelector sel = new SetBasedFieldSelector(new HashSet<String>(), lazyFields);
    doc2 = getDocument(reader, reader.maxDoc() - 1, sel);
    IndexableField[] fieldables = doc2.getFields("bin1");
    assertNotNull(fieldables);
    assertEquals(1, fieldables.length);
    IndexableField fb1 = fieldables[0];
    assertTrue(fb1.binaryValue(null)!=null);
    bytesRef = fb1.binaryValue(null);
    assertEquals(bin.length, bytesRef.bytes.length);
    assertEquals(bin.length, bytesRef.length);
    for (int i = 0; i < bin.length; i++) {
      assertEquals(bin[i], bytesRef.bytes[i + bytesRef.offset]);
    }
    reader.close();
    // force optimize


    writer = new IndexWriter(dir, newIndexWriterConfig(TEST_VERSION_CURRENT, new MockAnalyzer(random)).setOpenMode(OpenMode.APPEND).setMergePolicy(newLogMergePolicy()));
    writer.optimize();
    writer.close();
    reader = IndexReader.open(dir, false);
    doc2 = reader.document(reader.maxDoc() - 1);
    fields = doc2.getFields("bin1");
    assertNotNull(fields);
    assertEquals(1, fields.length);
    b1 = (Field) fields[0];
    assertTrue(b1.isBinary());
    bytesRef = b1.binaryValue(null);
    assertEquals(bin.length, bytesRef.length);
    for (int i = 0; i < bin.length; i++) {
      assertEquals(bin[i], bytesRef.bytes[i + bytesRef.offset]);
    }
    reader.close();
    dir.close();
  }
}