import java.util.ArrayList;

import java.util.Date;

import java.util.List;

import java.io.*;

 

import adventure.messagerouting.AdventureMessage;

import adventure.messagerouting.C;

import adventure.messagerouting.MessageClient;

import adventure.messagerouting.exceptions.MessageRoutingException;

import adventure.messagerouting.interfaces.OnAuthErrorListener;

import adventure.messagerouting.interfaces.OnErrorListener;

import adventure.messagerouting.interfaces.OnHttpMessageListener;

import adventure.messagerouting.interfaces.OnMessageListener;

import adventure.messagerouting.XmppExtensions.HeaderExtension;

import adventure.messagerouting.XmppExtensions.OkExtension;

import adventure.messagerouting.XmppExtensions.OperationExtension;

import adventure.messagerouting.XmppExtensions.PartExtension;

import org.jivesoftware.smack.packet.Message;

import org.jivesoftware.smack.packet.Packet;

import org.jivesoftware.smack.packet.PacketExtension;

 

public class testclient {// {{{

  public static void main(String [] args) {

    try {

      Runtime.getRuntime().addShutdownHook(new clientShutdownThread(new client()));

    } catch (Throwable t) {

      System.out.println("Could not add Shutdown hook. "+t);

    }

 

    try {

      while (true) { Thread.currentThread().sleep(10000); }

    } catch (InterruptedException ie) { }

    System.exit(0);

  }

}// }}}

 

class clientShutdownThread extends Thread {// {{{

  private client mt = null;

 

  public clientShutdownThread(client mt) {

    super();

    this.mt = mt;

    mt.start();

  }

  

  public void run() {

    mt.interrupt();

    System.out.println("Shutting down ...");

  }

}// }}}

 

class client extends Thread {

  private static MessageClient mc1;

  private static MessageClient mc2;

  

  public static AdventureMessage mc1latestMessage;

  public static AdventureMessage mc2latestMessage;

 

  AdventureMessage sentMessage;

 

  public void run() {

    System.out.println("starting testclient");

    System.out.println("logging in to send test message...");

     mc1 = new MessageClient("adventure_processexecution","adventure_processexecution");

     

     System.out.println("logged in");

      System.out.println("sending test message");

      String processReference="51cc50f7e4b0f6769ce8bd5a";

      mc1.login();

     

      

      //test 1, normal messages

      

      /*

      //sending process id, receiving model

      mc1.sendMessage(processReference,"[email protected]", true);

      //wrong id

      mc1.sendMessage("abcdwrongprocessid","[email protected]", true);

      //empty id

      mc1.sendMessage("","[email protected]", true);

 

      mc1.AddOnMessageEventListener(new OnMessageListener(){

        @Override

        public void OnMessage(AdventureMessage message) {

          System.out.println("recevingin response");

          System.out.println("[mc1] Http From:  " + message.getXmppMessage().getFrom() + " To: " + message.getXmppMessage().getTo());      

          if (message.getMessageBody() != null){

            System.out.println("message body: "+message.getMessageBody());

          }

          

        }

      });*/

      

      //test 2, sending http message with correct id

      

         List<PacketExtension> list = new ArrayList<PacketExtension>();

        

        OperationExtension o = new OperationExtension();

        o.setAck(false);

        o.setContent("GET");

        list.add(o);

        

        HeaderExtension h = new HeaderExtension();

        h.setName("myHeaderKey");

        h.setContent("myHeaderValue");

        list.add(h);

        

        HeaderExtension h2 = new HeaderExtension();

        h2.setName("anotherHeaderKey");

        h2.setContent("anotherHeaderValue");

        list.add(h2);

        

        PartExtension p = new PartExtension();

    //    p3.setContentDisposition("riddl-data; name="excellent"; filename="result.txt"");

        p.setContentTransferEncoding("binary");

        p.setContentType("text/plain");

        p.setContent(processReference);

        list.add(p);

        System.out.println("list: "+list);

        mc1.sendHttpMessage("[email protected]", list);

        /*

        //sending wrong process id

      

        list = new ArrayList<PacketExtension>();

        

        o = new OperationExtension();

        o.setAck(false);

        o.setContent("GET");

        list.add(o);

        PartExtension p2 = new PartExtension();

        //    p3.setContentDisposition("riddl-data; name="excellent"; filename="result.txt"");

        p2.setContentTransferEncoding("binary");

        p2.setContentType("text/plain");

        p2.setContent("abcd");

        list.add(p2);

        System.out.println("list: "+list);

        mc1.sendHttpMessage("[email protected]", list);

        

        

        //sendin no/blank process id, wrong structure

        

      list = new ArrayList<PacketExtension>();

       o = new OperationExtension();

      o.setAck(false);

      o.setContent("GET");

      list.add(o);

      p2 = new PartExtension();

       p2.setContentTransferEncoding("binary");

      p2.setContentType("text/plain");

     list.add(p2);

      System.out.println("list: "+list);

      mc1.sendHttpMessage("[email protected]", list);

        */

        

        //receiving response to id: processmodel

         mc1.AddOnHttpMessageEventListener(new OnHttpMessageListener(){

            @Override

            public void OnHttpMessage(AdventureMessage message) {

              System.out.println("http response incoming");

              System.out.println("[mc1] Http From:  " + message.getXmppMessage().getFrom() + " To: " + message.getXmppMessage().getTo());

              if (message.getHeaders() != null)

                for (HeaderExtension header : message.getHeaders())

                System.out.println("[mc1] Header: " + header.toXML());

                //TODO: parse list and parameters to receive http message

              if (message.getParts() != null)

                System.out.println("got some parts");

                for (PartExtension part : message.getParts())

                {

                  System.out.println("part: "+part);  

                  System.out.println("[mc1] Part: " + part.toXML());

                  if(part.getContent()!=null){

                    String processModel=part.getContent();

                    System.out.println("processModel: "+processModel);          

                  }

                  else{

                    System.out.println("no process id received");

                  }

                  

                }

              

            }

          });

      

  }

 

}