//ProxyImpl.java
//This file is the real implementation of the ACM Proxy

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


public class Street extends CConstrainCollectionImpl {

  private CollectionPlug2[] acmweb = new CollectionPlug2[50];
  private short acmwebpointer;
  private org.omg.CORBA.ORB orb;

  public Street () {
        super();
        Init();
  }

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

  public Street (String name,  org.omg.CORBA.ORB porb ) {
        super(name);
        Init();
        orb = porb;
  }

  public void CancelRequest(
                CosPropertyService.Any pMessageID) throws
                            IDLInterchange.InvalidMessageID {
    // In the framework of the implementation of this proxy
    // it is not possible to cancel an ongoing request, since the
    // results are sent all together.
    return;
  }

  public void RequestItemsProperties(
              CosPropertyService.Any pMessageID,
              java.lang.String[] pPropertyNames,
              CosPropertyService.Any[] pServerCookies,
              CosPropertyService.Any[] pClientCookies,
              IDLInterchange.CCollection pResultTarget) {

    System.out.println("RequestItemsProperties");

    IDLInterchange.TException pException =
                new IDLInterchange.TException();

    if ( pResultTarget == null ) {
      System.out.println("Result Target null. Can't complete request");
      pException.aRequestReason("Result Target null. Can't complete request");
      pResultTarget.RaiseException(pMessageID,pException);
      return;
    }
    if ( pPropertyNames.length == 0 ) {
      // No properties
      System.out.println("No properties in the parameters");
      pException.aRequestReason("No properties in the parameters");
      pResultTarget.RaiseException(pMessageID,pException);
      return;
    }
    if ( pServerCookies.length == 0 ) {
      // No cookies
      System.out.println("pServerCookies equals 0");
      pResultTarget.CompletedRequest(pMessageID);
      return;
    }
    if ( pServerCookies.length != pClientCookies.length ) {
      // Error.
      System.out.println("Unmatching number of Client Side Cookies");
      pException.aRequestReason("Unmatching number of Client Side Cookies");
      pResultTarget.RaiseException(pMessageID,pException);
    }

    IDLInterchange.TItemsCookieState pItems =
                new IDLInterchange.TItemsCookieState();
    try {
      pItems.aStates = pack_properties(pServerCookies, pPropertyNames);
      System.out.println("Properties packed");
      pItems.aClientCookies = pClientCookies;
      pResultTarget.SetItemsProperties(pMessageID,
                                       pItems);
      pResultTarget.CompletedRequest(pMessageID);
    }
    catch (Exception e) {
      // Something went wrong
      System.out.println(e);
      pException.aRequestReason("Error retrieving the properties");
      pResultTarget.RaiseException(pMessageID,pException);
    }
    return;
  }

  public java.lang.String 
          GetItemsPropertyNames(CosPropertyService.Any[] pCookies)[][] throws
                                        IDLInterchange.InvalidRequest,
                                        IDLInterchange.InvalidCookies,
                                        IDLInterchange.InvalidAuthenication,
                                        IDLInterchange.InvalidPayment,
                                        IDLInterchange.MultipleExceptions {
    System.out.println("GetItemsPropertyNames");

    if (pCookies.length == 0) {
        //Compatibility with AsynInterClient.py
        CollectionPlug2 aux = new CollectionPlug2();
        String[][] propos = new String[1][aux.how_many_prop];
        propos[0] = aux.GetPropertyNames();
        return (propos);
    }

    String[][] aux = new String[pCookies.length][5];
    short tablepos;
    short numberofdoc;
    for(int i=0;i<pCookies.length;i++) {
        tablepos = GetCollectionPlug(pCookies[i]);
        numberofdoc = GetDocPos(pCookies[i]);
        aux[i] = acmweb[tablepos].GetPropertyNames(numberofdoc);
    }
    return(aux);
  }
  
  public void RequestConstrain(
              CosPropertyService.Any pMessageID,
              IDLInterchange.TQuerySummary pQuerySummary,
              IDLInterchange.TServicePrefSummary pServicePrefSummary,
              IDLInterchange.CCollection pResultTarget) {
    //Testing....
    System.out.println("RequestConstrain ProxyImpl\n");

    //Getting the Result Object
    //This is used when the client is in ILU. Asynmeu.py
    //NEED WORK!!!!!!!!!!
    if (pResultTarget == null) {
      // the request comes from ILU !!!!!
      // the ior of the object is in http://amberjack:8000/Result.ior
      System.out.println("Request coming from ILU, getting the ");
      pResultTarget = IDLInterchange.CCollectionHelper.bind(orb,
                "http://amberjack.stanford.edu:8000/Result.ior");
      //pResultTarget = IDLInterchange.CCollectionHelper.bind(orb,"ResultTarget");
      System.out.println(pResultTarget);
    }

    //Extracting the query parameters.
    java.lang.String acmmax = ""; //Max docs
    acmmax = acmmax.valueOf(pServicePrefSummary.aNumberOfItems);
    System.out.println("Value of acmmax: " + acmmax);

    String acmquery =
          (pQuerySummary.aQueryDescription.QueryType0()).query.a_string();

    System.out.println(acmquery);

    try {
    short pointer = give_CollectionPlug();
    System.out.println("Filling entry " + pointer + " in acmweb table");
    short total = acmweb[pointer].connect(acmquery,acmmax);
    System.out.println("I got total = " + total);
    pResultTarget.SetTotalItems(total);

    // Before we have to set the properties we want in acmweb[pointer]
    // if there wasn't any property the how_many_prop = 0
    acmweb[pointer].SetProperties(pQuerySummary.aItemPropertyNames);

    if ((total != 0) && (acmweb[pointer].how_many_prop != 0) ) {
    // Now we pack all the documents in a TItemsACState structure to
    // send them to the ResultTarget

    IDLInterchange.TItemsACState pItems =
                new IDLInterchange.TItemsACState();
    pItems = pack_docs(acmweb[pointer],pointer);

    // Now, it's time to set pNewMoreCookie. Here we especify the contact
    // points for the objects from where we can get more docs
    IDLInterchange.TAccessOption[] pNewMoreCookie =
                new IDLInterchange.TAccessOption [1]; // Only one, the proxy
    pNewMoreCookie = pack_more_cookie(acmweb[pointer],pointer);

    // Now that we have everything, we call the resultarget method addItems
    pResultTarget.AddItems(pMessageID, pItems, pNewMoreCookie);

    // The Request has been completed. We let the result know
    pResultTarget.CompletedRequest(pMessageID);
    } else {
      pResultTarget.CompletedRequest(pMessageID);
    }
    }
    catch (Exception e) {
        System.out.println("Exception caugth" + e);
        IDLInterchange.TException pException =
                new IDLInterchange.TException();
        pException.aRequestReason(e.toString());
        pResultTarget.RaiseException(pMessageID,pException);
    }

    return;
  }

  public void RequestItems(
              CosPropertyService.Any pMessageID,
              java.lang.String[] pPropertyNames,
              CosPropertyService.Any pMoreCookie,
              int pNumberItems,
              IDLInterchange.CCollection pResultTarget) {

    System.out.println("RequestItems");
    // Requesting more items
    // pMessageID is not used by now. Should it be the form of identification?
    // By now, my form of identification is pMoreCookie
    // In pMoreCookie a have something like Ex:y
    // it means, is the entry x, and I got y elements

    // Now we need the original query, it's in acmweb[x].thefinalquery
      short tablepos = GetCollectionPlug(pMoreCookie);
      short numberofitems = GetDocPos(pMoreCookie);
      System.out.println("The cookie has: " + tablepos +
                         " " + numberofitems);
      // The acmweb is acmweb[tablepos]
      // See if we have pending docs in that connection
      if (acmweb[tablepos].flagmore) {
        // We have more docs
        // Making a new connection to the ACM web server
        short pointer = give_CollectionPlug();
        // Now we copy the last query to the new acmweb connection
        acmweb[pointer].thefinalquery =
                                acmweb[tablepos].thefinalquery;
        System.out.println("Filling entry " + pointer + " in acmweb table");
        short total = 0;
        try {
        if (pNumberItems == -1) {
          pNumberItems = 500;
        }
        total = acmweb[pointer].reconnect(numberofitems,
                                                   pNumberItems);
        }
        catch (Exception e) {
          System.out.println(e);
          IDLInterchange.TException pException =
                new IDLInterchange.TException();
          pException.aRequestReason("General Exception");
          pResultTarget.RaiseException(pMessageID,pException);
        }

        // Before we have to set the properties we want in acmweb[pointer]
        // if there wasn't any property the how_many_prop = 0
        acmweb[pointer].SetProperties(pPropertyNames);

        System.out.println("I got total = " + total);

        if ((total != 0) && (acmweb[pointer].how_many_prop != 0) ) {
        pResultTarget.SetTotalItems(total);
        // Now we pack all the documents in a TItemsACState structure to
        // send them to the ResultTarget

        IDLInterchange.TItemsACState pItems =
                new IDLInterchange.TItemsACState();
        pItems = pack_docs(acmweb[pointer],pointer);

        // Now, it's time to set pNewMoreCookie. Here we especify the contact
        // points for the objects from where we can get more docs
        IDLInterchange.TAccessOption[] pNewMoreCookie =
                new IDLInterchange.TAccessOption [1]; // Only one, the proxy
        pNewMoreCookie = pack_more_cookie(acmweb[pointer],pointer);

        // Now that we have everything, we call the resultarget method addItems
        pResultTarget.AddItems(pMessageID, pItems, pNewMoreCookie);

        // The Request has been completed. We let the result know
        pResultTarget.CompletedRequest(pMessageID);
        } else {
          pResultTarget.CompletedRequest(pMessageID);
        }
      } else {
        // We don't have more docs
        // Sending 0 docs to pResultTarget
        System.out.println("I got total = 0");
        pResultTarget.SetTotalItems(0);
        // The Request has been completed. We let the result know
        pResultTarget.CompletedRequest(pMessageID);
      }
    return;
  }

  public IDLInterchange.TItemsState GetItemsProperties(
                        java.lang.String[] pPropertyNames,
                        CosPropertyService.Any[] pServerCookies) throws
                                IDLInterchange.InvalidRequest,
                                IDLInterchange.InvalidAuthenication,
                                IDLInterchange.InvalidPayment,
                                IDLInterchange.InvalidCookies,
                                IDLInterchange.InvalidProperties,
                                IDLInterchange.MultipleExceptions {

    System.out.println("GetItemsProperties");
    IDLInterchange.TItemsState aState =
                new IDLInterchange.TItemsState();

    // Extracting the acmweb from the cookie E0:5, means CollectionPlug
    // it means the acmweb = acmweb[0]

    String stringcookie = pServerCookies[0].a_string();
    short tablepos = GetCollectionPlug(pServerCookies[0]);

    if ( (pPropertyNames.length == 0) || ( pPropertyNames == null)  ) {
      // pPropertyNames is null, sending back all the properties I have
      // about all the objects that I have.
      // Setting aNames
      String[] aNames = new String[acmweb[tablepos].how_many_prop];
      aNames = acmweb[tablepos].GetProperties();

      //Setting anItemsState
      CosPropertyService.Any[][] anItemsState =
                new CosPropertyService.Any [acmweb[tablepos].docs_stored]
                                           [acmweb[tablepos].how_many_prop];
      short i=0;
      while ( i< acmweb[tablepos].docs_stored){
          anItemsState[i] = SetValuesProperties(i,acmweb[tablepos]);
          i++;
      }

      //Packing all the info
      aState.aNames = aNames;
      aState.anItemsState = anItemsState;
    } else {
      // Actually pPropertyNames has something, so, it comes from
      // AsynInterClient and the value is somethin like ['100'] (USMARC)
      // Needs translation

      System.out.println("Making USMarc translations..." +
                          pPropertyNames.length);

      USMarc lusmarc = new USMarc();

      String[] aNames = new String[pPropertyNames.length];
      for (int i=0;i<pPropertyNames.length;i++) {
        aNames[i] = pPropertyNames[i];
        System.out.println(aNames[i] + "*" +
                        lusmarc.USMarc2English(aNames[i]));
      }

      //Setting anItemsState
      CosPropertyService.Any[][] anItemsState =
                new CosPropertyService.Any [pServerCookies.length]
                                           [pPropertyNames.length];
      short i=0;
      while ( i< pServerCookies.length){
          anItemsState[i] = SetValuesProperties(i,acmweb[tablepos],
                            lusmarc.USMarc2English(pPropertyNames));
          i++;
      }
      //Packing all the info
      aState.aNames = aNames;
      aState.anItemsState = anItemsState;
    }
    return(aState);
  }


  // From now on...  Local procedures

  private IDLInterchange.TAccessOption[] pack_more_cookie (
                        CollectionPlug2 acmweb,
                        short pointer ) {
    //Pointer is used for the Cookie: E'pointer':'number of doc'

    IDLInterchange.TAccessOption[] pNewMoreCookie =
                new IDLInterchange.TAccessOption [1]; // Only one, the proxy

    // The aTarget is myself so, aTarget = this. I'm the only one
    // able to respond to queries, I'm the proxy!!!!
    IDLInterchange.CItem aTarget = this;

    // anItemClass, by now is not used
    String anItemClass = "";

    // aHints, by now is not used. Filled with garbage ;-)
    CosPropertyService.Property[] aHints =
                new CosPropertyService.Property[1];
    short garbage = 0;
    CosPropertyService.Any Garbage =
                new CosPropertyService.Any();
    Garbage.a_short(garbage);
    CosPropertyService.Property property =
                new CosPropertyService.Property("",Garbage);
    aHints[0] = property;

    // The aCookie tells me what was the last object
    CosPropertyService.Any aCookie = new CosPropertyService.Any();
    // Setting the cookie -> E'pointer':'number of doc'
    String forcookies = "E";
    forcookies = forcookies.concat(String.valueOf(pointer));
    forcookies = forcookies.concat(":");
    forcookies = forcookies.concat(String.valueOf(acmweb.docs_stored));
    aCookie.a_string(forcookies);

    pNewMoreCookie[0] = new IDLInterchange.TAccessOption(
                        aTarget, aCookie, anItemClass, aHints);

    return pNewMoreCookie; 
  }

  private IDLInterchange.TItemsState pack_properties(
                CosPropertyService.Any[] pServerCookies,
                String[] pPropertyNames) throws Exception {
    IDLInterchange.TItemsState result =
                new IDLInterchange.TItemsState();
    short tablepos;
    short indexdoc;
    // Do I have these properties?
    System.out.println("Packing properties");
    if (!CollectionPlug2.my_props(pPropertyNames)) {
      System.out.println("I don't have this set of properties");
      throw new Exception();
    } else {
      System.out.println("Right set of properties");
    }

    result.aNames = pPropertyNames;
    CosPropertyService.Any[][] anItemsState =
                new CosPropertyService.Any [pServerCookies.length]
                                           [pPropertyNames.length];

    for(int i =0;i<pServerCookies.length;i++) {
      tablepos = GetCollectionPlug(pServerCookies[i]);
      indexdoc = GetDocPos(pServerCookies[i]);
      if ( acmweb[tablepos].docs_stored < (indexdoc + 1) ) {
        System.out.println("Cookie points to a free entry");
        throw new Exception();
      }
      acmweb[tablepos].SetProperties(pPropertyNames);
      anItemsState[i] = SetValuesProperties(indexdoc,
                                         acmweb[tablepos]);
    }
    result.anItemsState = anItemsState;
    
    return result;
  }

  private IDLInterchange.TItemsACState pack_docs (
                        CollectionPlug2 acmweb,
                        short pointer ) {
    //Pointer is used for the Cookie: E'pointer':'number of doc'

    // This function gets the object containing the connection to the
    // the acm web and the query, plus documents found
    // and translate that information into a IDLInterchange.TItemsACState
    // to pass the results to the ResultTarget

    // Setting common staff
    // The aTarget is myself so, aTarget = this. I'm the only one
    // able to respond to queries, I'm the proxy!!!!
    IDLInterchange.CItem aTarget = this;

    // anItemClass, by now is not used
    String anItemClass = "";

    // aHints, by now is not used. Filled with garbage ;-)
    CosPropertyService.Property[] aHints =
                new CosPropertyService.Property[1];
    short garbage = 0;
    CosPropertyService.Any Garbage =
                new CosPropertyService.Any();
    Garbage.a_short(garbage);
    CosPropertyService.Property property =
                new CosPropertyService.Property("",Garbage);
    aHints[0] = property;

    // More common staff, aState (TItemsState), but the common staff
    // is in aNames which is a String[]
    // Here we put the names of the records that were requested
    String[] aNames = new String[acmweb.how_many_prop];
    aNames = acmweb.GetProperties();

    // Setting aState. Only aNames, the rest (anItemsState) after the loop.
    IDLInterchange.TItemsState aState =
                new IDLInterchange.TItemsState();
    aState.aNames = aNames;

    // Now we have set up all the common fields. aCookie, anITemsState
    // are the only left.
    // aCookie is used to identify the document, so it could something
    // like the number (order) in the acmweb.tdocs table, that's all
    // It's something that only the proxy understands, so with that
    // I guess is enough by now.
    // And anItemsState is the value of the requested fields for that doc.

    // So, as each document has a different cookie, we need to loop
    // all of them and set the values
    CosPropertyService.Any[][] anItemsState =
                new CosPropertyService.Any [acmweb.docs_stored]
                                           [acmweb.how_many_prop];
                // or acmweb.total instead ?????
    IDLInterchange.TAccessOption[][] aACs =
                new IDLInterchange.TAccessOption [acmweb.docs_stored][1];
                // or acmweb.total instead ??????
    short i = 0;
    String forcookies = "";
    CosPropertyService.Any aCookie =
                      new CosPropertyService.Any();
    while ( i< acmweb.docs_stored){
    //Here the wonder if we should put total instead
      // Setting aState.anItemsState
      anItemsState[i] = SetValuesProperties(i,acmweb);

      // Setting the cookie -> E'pointer':'number of doc'
      forcookies = "E";
      forcookies = forcookies.concat(String.valueOf(pointer));
      forcookies = forcookies.concat(":");
      forcookies = forcookies.concat(String.valueOf(i));

      // Putting the cookie and the rest in the right place
      aACs[i][0] = new IDLInterchange.TAccessOption();
      aACs[i][0].aTarget = this; // the proxy itself is the only able to
                               // respond to more the request_more_properties
      aACs[i][0].aCookie = new CosPropertyService.Any();
      aACs[i][0].aCookie.a_string(forcookies);
      System.out.println(aACs[i][0].aCookie.a_string());
      aACs[i][0].anItemClass = anItemClass; // garbage, not used
      aACs[i][0].aHints = aHints; // garbage, not used

      i++;
    }

    // Putting the values set in the loop in the right variable
    aState.anItemsState = anItemsState;
    IDLInterchange.TItemsACState pItems =
                new IDLInterchange.TItemsACState(aACs,aState);

    return pItems;
  }

  private CosPropertyService.Any[] SetValuesProperties (short p,
                                                      CollectionPlug2 acmweb) {
    CosPropertyService.Any[] aux =
                new CosPropertyService.Any [acmweb.how_many_prop];
    String[] values = new String[acmweb.how_many_prop];

    values = acmweb.SetValuesProperties(p);

    for(int j=0;j<values.length;j++) {
        aux[j] = new CosPropertyService.Any();
        aux[j].a_string(values[j]);
    }

    return aux;
  }

  private CosPropertyService.Any[] SetValuesProperties (short p,
                      CollectionPlug2 acmweb, String[] propnames) {
    CosPropertyService.Any[] aux =
                new CosPropertyService.Any [propnames.length];
    String[] values = new String[propnames.length];

    values = acmweb.SetValuesProperties(p,propnames);

    for(int j=0;j<values.length;j++) {
        aux[j] = new CosPropertyService.Any();
        aux[j].a_string(values[j]);
    }

    return aux;
  }

  private short GetCollectionPlug (CosPropertyService.Any Cookie) {
    short tablepos = 0;

    String stringcookie = Cookie.a_string();
    stringcookie = stringcookie.substring(1);
    int pos = stringcookie.indexOf(":");
    try {
      String aux = stringcookie.substring(0,pos);
      tablepos = Integer.valueOf(aux).shortValue();
    }
    catch (Exception e) {
        System.out.println(e);
    } 
    finally {
      return (tablepos);
    }
  }

  private short GetDocPos (CosPropertyService.Any Cookie) {
    short numberofdoc = 0;

    String stringcookie = Cookie.a_string();
    stringcookie = stringcookie.substring(1);
    int pos = stringcookie.indexOf(":");
    try {
      String aux = stringcookie.substring(0,pos);
      short tablepos = Integer.valueOf(aux).shortValue();
      numberofdoc = Integer.valueOf(
            stringcookie.substring((pos +1),
            stringcookie.length())).shortValue();
    }
    catch (Exception e) {
        System.out.println(e);
    }
    finally {
        return (numberofdoc);
    }
  }

  private void Init() {
        acmwebpointer = 0;
        for(int i=0;i<acmweb.length;i++)
                acmweb[i] = new CollectionPlug2();
  }

  private short give_CollectionPlug () {
        short aux = acmwebpointer;
        if (acmwebpointer == 49) {
                acmwebpointer = 0;
        } else {
                acmwebpointer++;
        }
        acmweb[aux] = new CollectionPlug2();
        return aux;
  }

}