//ResultImpl.java

import IDLInterchange.*;
import CosPropertyService.*;
import ACM.*;

public class ResultImpl extends CCollectionImpl implements Runnable {

  Thread result_collection;
  private USMarc lusmarc = new USMarc();
  private boolean started;
  private static boolean gatekeeper; 
  public static boolean completed;
  public static GeneralDoc[] objects = new GeneralDoc[100];
  // objects[0] contains the names of the properties, it is never used for
  // something else
  public static short pobjects;
  public static short current_MessageID;

  public static int total = -1;
  private short calls; // pointer to the next two tables

  // these tables hold the information sent by the proxy
  // we need tables just in case the proxy sends the docs in more than
  // one connection (several calls to AddItems)

  private IDLInterchange.TItemsACState[] resultdata =
                new IDLInterchange.TItemsACState[50];
  private IDLInterchange.TAccessOption[][] moredata =
                new IDLInterchange.TAccessOption[50][1];

  private static String nameRC;

  // Here the implementation of the Result Collection begins

  public ResultImpl () {
    started = false;
    nameRC = "ResultTarget";
    gatekeeper = false;
    // Creating the thread
    System.out.println("Creating the thread....");
    result_collection = new Thread(this);
    result_collection.start();
    System.out.println("Thread created");
  }

  public ResultImpl (int usegatekeeper, String pnameRC) {
    started = false;
    nameRC = pnameRC;
    if ( usegatekeeper == 1 ) {
      gatekeeper = true;
    } else {
      gatekeeper = false;
    }
    // Creating the thread
    System.out.println("Creating the thread....");
    result_collection = new Thread(this);
    result_collection.start();
    System.out.println("Thread created");
  }

  public ResultImpl (String name) {
        super(name);
        Init();
  }

  public void SetItemsProperties(
              CosPropertyService.Any pMessageID,
              IDLInterchange.TItemsCookieState pItems) {
    System.out.println("Result Target: SetItemsProperties\n");
    if ( current_MessageID != (pMessageID.a_short())) {
      System.out.println("Error: Different message IDs");
      return;
    }
    try {
    for(int i =0;i<pItems.aClientCookies.length;i++)
      objects[pItems.aClientCookies[i].a_short()].Add_propos(
                        lusmarc.USMarc2English(pItems.aStates.aNames),
                        pItems.aStates.anItemsState[i]);
    }
    catch (Exception e) {
      System.out.println(e);
    }
    return;
  }

  public void SetTotalItems(int pTotalSize) {
    total = pTotalSize;
    completed = false;
    System.out.println("I'm the ResultTarget and I got total =" + total);
    return;
  }

  public int GetTotalItems() {
    return(this.total);
  }

  public void AddItems(
              CosPropertyService.Any pMessageID,
              IDLInterchange.TItemsACState pItems,
              IDLInterchange.TAccessOption[] pNewMoreCookie) {

    System.out.println("Result Target: AddItems\n");
    if ( current_MessageID != (pMessageID.a_short())) {
      System.out.println("Error: Different message IDs");
      return;
    }
    short pointer = give_entry();  
    resultdata[pointer] = pItems;
    moredata[pointer] = pNewMoreCookie;
    group_docs(pointer);
    return;
  }

  public void CompletedRequest(CosPropertyService.Any pMessageID) {
    // The transaction is completed
    System.out.println("CompletedRequest");
    if ( current_MessageID != (pMessageID.a_short())) {
      System.out.println("Error: Different message IDs");
      return;
    }
    completed = true;
    return;
  }

  public void RaiseException(
                CosPropertyService.Any pMessageID,
                IDLInterchange.TException pException) {
    if ( current_MessageID != (pMessageID.a_short())) {
      System.out.println("Error: Different message IDs");
      return;
    }
    System.out.println("RaiseException");
    System.out.println(pException.aRequestReason());
    completed = false;
    total = 0;
    return;
  }

  // Local procedures.

  private void Init () {
    total = 0;
    calls = 0;
    pobjects = 1;
    objects[0] = new GeneralDoc(); // it will contain the names of the
                                   // propos of the documents.
    completed = false;
    current_MessageID = -1;
    if (gatekeeper) {
      //Anounce myself in the visigenic Gatekeeper
      org.omg.CORBA.ORB orb = org.omg.CORBA.ORB.init();
      naming.PublishVisi(this, "Result", orb);

      //String url = "http://Eel:15000/Result.ior";
      //try {
      //  System.out.println("Resolving the url");
      //  String[] args = new String[0];
      //  org.omg.CORBA.ORB orb = org.omg.CORBA.ORB.init(args,null);
      //  com.visigenic.vbroker.URLNaming.Resolver resolver =
      //  com.visigenic.vbroker.URLNaming.ResolverHelper.narrow(
      //      orb.resolve_initial_references("URLNamingResolver"));
      //  resolver.force_register_url(url,this);
      //}
      //catch (Exception e) {
      //    System.err.println(e);
      //}
    }
    return;
  }

  private short give_entry() {
    short aux = calls;
    if (calls == 49) {
        calls = 0;
    } else {
        calls++;
    }
    resultdata[aux] = new IDLInterchange.TItemsACState();
    moredata[aux] = new IDLInterchange.TAccessOption[1];
    return aux;
  }

  public void run() {
    if (!started) {
    // Initialize the ORB.
    String[] args = new String[0];
    org.omg.CORBA.ORB orb = org.omg.CORBA.ORB.init(args,null);
    // Initialize the BOA
    org.omg.CORBA.BOA boa = orb.BOA_init();

    //Creating a Result (CCollection)
    ResultImpl result =
                new ResultImpl(nameRC);
    boa.obj_is_ready(result);
    System.out.println("Created" + result);

    // Wait for incoming requests
    boa.impl_is_ready();
    }
  }

  public void stop () {
    result_collection.stop();
  }

  private void group_docs (short pointer) {
    System.out.println("Result Collection: Packing docs from " + calls +
                        " calls");
    String names[] = new String[resultdata[pointer].aState.aNames.length +1];
    CosPropertyService.Any values[] =
      new CosPropertyService.Any[resultdata[pointer].aState.aNames.length +1];
    try{
      for(int j=0;j<resultdata[pointer].aState.anItemsState.length;j++) {
        for(int i=0;i<resultdata[pointer].aState.aNames.length;i++) {
          names[i] = lusmarc.USMarc2English(
                        resultdata[pointer].aState.aNames[i]);
          values[i] = resultdata[pointer].aState.anItemsState[j][i];
        }
        names[resultdata[pointer].aState.aNames.length] = "Cookie";
        values[resultdata[pointer].aState.aNames.length] =
          resultdata[pointer].aACs[j][0].aCookie;
        objects[pobjects++] =
          new GeneralDoc(names,
                         values);
          //System.out.println(objects[pobjects -1].toString());
      }
    }
    catch (Exception e) {
        System.out.println(e);
    }
  }

}