import WebFlow.*;
import WebFlow.event.*;
//import WebFlow.xml.*;
//import WebFlow.ATD.*;
import WebFlow.hashtable.*;
import WebFlow.submitJob2.*;
import WebFlow.RemoteFile.*;
import WebFlow.FB.*;
import org.omg.CORBA.*;
import javax.swing.*;
import java.awt.*;
import java.awt.event.*;
import java.io.*;
import java.net.*;
import java.util.*;

public class Connection extends JInternalFrame implements Runnable {

String selectedServer;
desktop d;
private JTextArea debugTA;

public static ORB orb;
String IorURL;
public static WebFlowContext master;
org.omg.CORBA.Object oxml,oatd,osj,ocd,orf,omv,ofb;
  //public static XmlServer parser;
  //public static XmlATD atdParser;
public static ContextData cd;
public static submitJob2 submit;
public static RemoteFile remote;
public static MoveFile movefile;
public static FBServer browser;

  public Connection(desktop d) {
  super("Connection", true, true, true, true);
  this.d = d;
  IorURL = d.IORfileURL;
  
  this.selectedServer = d.selectedServer;

  JPanel bck = new JPanel();
  bck.setLayout(new BorderLayout());
  getContentPane().add(bck);

  JPanel upper = new JPanel();
  JPanel center = new JPanel();
  JPanel lower = new JPanel();

  upper.setLayout(new GridLayout(3,1));
  upper.add(new JLabel(" "));    
  JLabel ttt = new JLabel("Connect to the server",JLabel.CENTER);
  ttt.setForeground(Color.blue);
  upper.add(ttt);
  upper.add(new JLabel(" "));
   
  debugTA = new JTextArea(20,50);
  JScrollPane scroller = new JScrollPane(debugTA,JScrollPane.VERTICAL_SCROLLBAR_ALWAYS,JScrollPane.HORIZONTAL_SCROLLBAR_AS_NEEDED);
  center.add(scroller);

  lower.setLayout(new GridLayout(1,2));
  ActionListener bListener = new ActionListener() {
      public void actionPerformed(ActionEvent e) {
         String what = e.getActionCommand();
         if(what.startsWith("connect")) {
            connect();
	 }
	 else {
            reset();
	 }
      }
  };
  JButton b1 = new JButton("connect to the server");
  JButton b2 = new JButton("reset display");
  b1.addActionListener(bListener);
  b2.addActionListener(bListener);
  lower.add(b1);
  lower.add(b2);

  bck.add(upper, BorderLayout.NORTH);
  bck.add(center, BorderLayout.CENTER);
  bck.add(lower, BorderLayout.SOUTH);

  Thread t = new Thread(this);
  t.start();

  }

  public void run() {
    connect();
  }

    public void reset() {
      debugTA.setText("");
    }

    public void startOver(String s) {
      debugTA.setText(s);
    }

    public void appendText(String s) {
      debugTA.append("\n"+s);
    }

    public void appendResult(String s) {
      debugTA.append(" "+s);
    }

  public void connect() {
    startOver("initialize ORB:");
    initializeORB();
    if(orb==null) appendText("Cannot instantiate ORB");
    else appendText(" OK"); 
    appendText("connect to the master:"); 
    master = getMasterServer();
    if(master==null) appendText("Cannot connect to the master server");
    else {
        appendText("master server name is: ");
        appendResult(master.getObjectID()); 
	/*
        appendText("create a new context:");
	try {
        WebFlowContext c = WebFlowContextHelper.narrow(
                           master.addNewContext("slave"));
        if(c==null)appendResult("is null");
        else appendResult(c.getObjectID()+" OK");
	}catch(Exception ee) {
          appendResult(" exception rised!");
          appendText(ee.toString());
	}
        */
        /*
        appendText("attach XmlServer");
        oxml = master.addNewModule("XmlServer");
        parser = XmlServerHelper.narrow(oxml);
        if(parser==null) appendResult("the module is null");
        else appendResult("OK");
        parser.test();
        */

        appendText("attach ContextData");
        ocd = master.addNewModule("ContextData");
        if(ocd==null) appendText("ocd is null");
        else   appendText("OK..");   
        cd = ContextDataHelper.narrow(ocd);
        if(cd==null) appendResult("the ContextData is null");
        else appendResult("OK");
        cd.test();

	try {
        appendText("attach RemoteFile");
        orf = master.addNewModule("RemoteFile");
        remote = RemoteFileHelper.narrow(orf);
        if(remote==null) appendResult("RemoteFile is null");
        else appendResult("OK");
        remote.test();
        } catch (Exception e) {appendText(e.toString());}

        try { 
        appendText("attach MoveFile");
        orf = master.addNewModule("MoveFile");
        movefile = MoveFileHelper.narrow(orf);
        if(movefile==null) appendResult("MoveFile is null");
        else appendResult("OK");
        //movefile.test();
        } catch (Exception e) {appendText(e.toString());}

        try { 
        appendText("attach FileBrowser");
        ofb = master.addNewModule("FileBrowser");
        browser = FBServerHelper.narrow(ofb);
        if(browser==null) appendResult("FileBrowser is null");
        else appendResult("OK");
        browser.test();
        } catch (Exception e) {appendText(e.toString());}

        /*
        appendText("attach ATDServer");
        oatd = master.addNewModule("ATDServer");
        atdParser = XmlATDHelper.narrow(oatd);
        if(atdParser==null) appendResult("the module is null");
        else appendResult("OK");
        atdParser.test();
        */

        /* add submitJob module */
        try {   
        appendText("attach submitJob");
        osj = master.addNewModule("submitJob");
        submit = submitJob2Helper.narrow(osj);
        if(submit==null) appendResult("the module is null");
        else appendResult("OK");
        submit.test(); 
        } catch (Exception e) {appendText(e.toString());}
        appendText("    ");
        appendText(" SUCESSFULLY CONNECTED TO WEBFLOW SERVER");
        appendText(" ------- do not kill this window ! -----");   
    }
  }



  public void initializeORB() { 
   Properties props = System.getProperties();
   props.put("org.omg.CORBA.ORBClass", "com.ooc.CORBA.ORB");
   props.put("org.omg.CORBA.ORBSingletonClass", "com.ooc.CORBA.ORBSingleton");
   System.setProperties(props);
   String[] args = new String[1];
   args[0]=IorURL;
   orb = ORB.init(args, props);
  }  

  public WebFlowContext getMasterServer(){
    WebFlowContext ws = null;
    try {
      appendText("IorURL:");
      appendResult(IorURL);
      String masterIOR = getIORFromURL(IorURL);
      appendText("masterIOR:");
      appendResult(masterIOR);
      org.omg.CORBA.Object o = orb.string_to_object(masterIOR);
      appendText("Master object:");
      if(o==null) appendResult(" is null");
      appendResult(" is OK");
      
      ws = WebFlowContextHelper.narrow(o);
      appendText("master server:");
      if(ws==null) appendResult(" is null");
      else appendResult("is OK");

    }
    catch (Exception e) {System.out.println("getMasterServer: "+e);}
    return ws;
  }

  public String getIORFromURL(String urlString){
    String masterServerIOR="";
    String thisLine=null;
      try {
        URL u = new URL(urlString);
        try {
          DataInputStream theHTML = new DataInputStream(u.openStream());
          try {
            while ((thisLine = theHTML.readLine()) != null) {
		  masterServerIOR += thisLine;
            } 
          } 
          catch (Exception e) {
            System.out.println("getIORfromURL:"+e);
          }
        } 
        catch (Exception e) {
          System.out.println("getIORfromURL:"+e);
        }

      } 
      catch (MalformedURLException e) {
        System.out.println("getIORfromURL:"+urlString + " is not a parseable URL");
        System.out.println("getIORfromURL:"+e);
      }
    return masterServerIOR;
  }


   public synchronized void waitFor(long howLong){
     try {
        wait(howLong);
     } catch (Exception e) { System.out.println(e);}
   }


}