//ResultImpl.java



// Gerard Rodriguez, January 1998, Stanford University

//

// ResultImpl.java is a very simple example of a Collection acting

// as a Result Target, which purpose was just to test the Street Proxy, it

// is not intended to be a fully implementation of a Result Collection



// For an example of a fully operational Client in Infobus, look for DLITE.

// http://dlite.stanford.edu





import IDLInterchange.*;

import CosPropertyService.*;



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;



  // The objects array stores all the documents send my the proxy.

  // it contains the names of the properties supported by the proxy

  // and the values of these properties.

  static final short MAX_OBJECTS = 100;

  public static GeneralDoc[] objects = new GeneralDoc[MAX_OBJECTS];

  public static short pobjects;

  // objects[0] contains the names of the properties, it is never used for

  // something else.



  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)



  static final short MAX_CALLS = 50;

  private IDLInterchange.TItemsACState[] resultdata =

                new IDLInterchange.TItemsACState[MAX_CALLS];

  private IDLInterchange.TAccessOption[][] moredata =

                new IDLInterchange.TAccessOption[MAX_CALLS][1];



  private static String nameRC;



  // Here the implementation of the Result Collection begins



  // Constructor for the Class

  public ResultImpl () {

    started = false;

    nameRC = "ResultTarget";

    gatekeeper = false;

    // Creating the thread for the Result Collection

    System.out.println("Creating the thread....");

    result_collection = new Thread(this);

    result_collection.start();

    System.out.println("Thread created");

  }



  // Class Constructor if we use the Visigenic Gatekeeper

  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");

  }



  // Constructor for the class once the thread has started

  public ResultImpl (String name) {

        super(name);

        Init();

  }



  //SetItemsProperties()

  //

  // Set properties of existing Items in this collection.  If a item does not

  // exist in this collection, raise an exception.

  //     o pMessageID is the client-side data that matches the

  //       pMessageID of the initial request (a RequestItemsProperties call)

  //     o pItems contains the state information requested.



  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;

  }



  //SetTotalItems()

  //

  //   Sets the total expected size of this collection.

  //     o pTotalSize is the expected total size of the collection.

  //       If -1, then the expected size is unknown.



  public void SetTotalItems(int pTotalSize) {

    total = pTotalSize;

    completed = false;

    System.out.println("I'm the ResultTarget and I got total =" + total);

    return;

  }



  //GetTotalItems()

  //

  //   Returns the total expected size of this collection.  If -1,

  //   then the expected size is unknown.



  public int GetTotalItems() {

    return(this.total);

  }



  //AddItems()

  //

  //   Add additional Items to this collection.

  //     o pMessageID is the client-side data that matches the

  //       pMessageID of the initial request (a RequestConstrain or

  //       RequestItems call.)

  //     o pItems contains the state information requested.

  //     o pNewMoreCookie should be passed to collection to request

  //       more Items.  A NIL value means there are no more Items.



  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;

  }



  //CompletedRequest()

  //

  //   Signals to the client that the request with pMessageID

  //   has completed successfully.  No other messages with pMessageID

  //   shall be sent.



  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;

  }



  //RaiseException()

  //

  //   Signals to the client that the request with pMessageID

  //   has encountered an exception.  No other messages with pMessageID

  //   shall be sent.



  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 = -1;

    return;

  }



  // Local procedures.



  private void Init () {

    total = -1;

    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 == (MAX_CALLS -1)) {

        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);

    }

  }



}