package org.paneris.bibliomania.fti;
   
   class GroupTextSearchResults extends TextSearchResultsBase {
     private TextSearchResults[] streams;
     private int[] positions;
     private TextSearchResults leadStream;
     private int currentWordIndex;
   
     public GroupTextSearchResults(TextSearchResults[] streams) {
      this.streams = streams;
      positions = new int[streams.length];
      for (int i = 0; i < positions.length; ++i)
        positions[i] = i;
  
      // FIXME sort them, actually
  
      if (streams.length > 0)
        leadStream = streams[0];
    }
  
    /**
     * FIXME won't work if doing goups of not just single words, but then
     * positions can't be static either
     */
  
    public int hitWordsCount() {
      return streams.length;
    }
  
    private void findHit() {
      for (int w = 0; w < streams.length;) {
        TextSearchResults stream = streams[w];
        int wantedIndex = currentWordIndex + positions[w];
        stream.skipToWordIndex(wantedIndex);
        int streamIndex = stream.currentWordIndex();
        if (streamIndex == -1) {
          currentWordIndex = -1;
          return;
        }
  
        if (streamIndex == wantedIndex)
          ++w;
        else {
          currentWordIndex = streamIndex - positions[w];
          w = 0;
        }
      }
    }
  
    public void init() {
      for (int w = 0; w < streams.length; ++w)
        streams[w].init();
      currentWordIndex = 0;
      findHit();
    }
  
    public void skipToNextHit() {
      if (currentWordIndex != -1) {
        ++currentWordIndex;
        findHit();
      }
    }
  
    public int currentOffset() {
      return currentWordIndex == -1 ? -1 : leadStream.currentOffset();
    }
  
    public int currentWordIndex() {
      return currentWordIndex;
    }
  
    public void close() {
      for (int i = 0; i < streams.length; ++i)
        streams[i].close();
    }
  }