Source code: FTreeP/FTPBase.java

   package FTreeP;
   
   import java.io.*;
   import java.net.*;
   import java.util.*;
   
   import java.awt.*;
   import java.awt.event.*;
   
  import javax.swing.*;
  import javax.swing.tree.*;
  import javax.swing.event.*;
  
  import ExitThread.*;
  import DirectoryIndexer.*;
  
  public class FTPBase
  {
    public static String CRLF = "" + (char) 13 + (char) 10;
    public static final boolean DEBUG = true;
  
    private static boolean master = false;
    public static boolean gui = false;
  
    public static DirectoryIndexer directory_index = null;
  
    public static JTabbedPane tabbed_pane = null;
  
    private static FTPConsole gui_console = null;
    private static JFrame frame = null;
  
    public static void main(String[] args)
    {
      try {
  
      if(args.length != 0) throw new Exception("Usage: java FTreeP");
  
      File f = new File("FTreeP/ftreep.cfg");
  
      BufferedReader fin = new BufferedReader(new FileReader(f));
  
      String master_server = "";
      int master_port = 0;
      int listen_port = 0;
      String dir_cfg_file = "";
  
      while(fin.ready())
      {
        String line = fin.readLine();
        StringTokenizer st = new StringTokenizer(line);
        st.nextToken();
        String value = st.nextToken();
  
        try {
  
          if(line.startsWith("#") | line.equals("")) continue;
          else if(line.startsWith("master "))
          {
            if(value.equalsIgnoreCase("yes")) master = true;
            else if(value.equalsIgnoreCase("no")) master = false;
            else { throw new Exception(); }
          }
          else if(line.startsWith("master_server"))
          {
            master_server = value;
          }
          else if(line.startsWith("master_port"))
          {
            master_port = Integer.parseInt(value);
          }
          else if(line.startsWith("listen_port"))
          {
            listen_port = Integer.parseInt(value);
          }
          else if(line.startsWith("gui yes"))
          {
            gui = true;
          }
          else if(line.startsWith("directory_cfg_file"))
          {
            dir_cfg_file = value;
          }
  
        } catch(Exception e)
        {
          e.printStackTrace();
          throw new Exception("Error: Badly formed configuration file: '" + line + "'.");
        }
      }
  
      if(dir_cfg_file.equals("")) throw new Exception("Error: directory_cfg_file must be present in configuration file.");
      else directory_index = new DirectoryIndexer(dir_cfg_file);
  
      if(gui) initGUI();
  
      new ExitThread().start();
  
      if(master == true)
      {
       system_println("Waiting for incoming FTP connections...\n");
 
       new FTPDirectoryIndexListener(master_port).start();
 
       ServerSocket ss = new ServerSocket(listen_port);
 
       while(true)
       {
         Socket command = ss.accept();
         new FTPCommandRelay(command).start();
       }
     }
     else
     {
       system_println("Waiting for incoming FTPCommandRelay connections...\n");
 
       {
         system_print("Sending current Directory Index... ");
         Socket dir_socket = new Socket(master_server, master_port);
         BufferedWriter dir_out = new BufferedWriter(new OutputStreamWriter(dir_socket.getOutputStream()));
         f = new File(dir_cfg_file);
         fin = new BufferedReader(new FileReader(f));
 
         while(fin.ready())
         {
           String line = fin.readLine();
           dir_out.write(line + "\n");
           dir_out.flush();
         }
 
         fin.close();
         dir_out.close();
         dir_socket.close();
 
         system_println("Done!");
       }
 
       ServerSocket ss = new ServerSocket(listen_port);
       system_println("Listening on port " + listen_port + "... ");
 
       while(true)
       {
         Socket command = ss.accept();
         new FTPDataHost(command).start();
       }
     }
 
     } catch(Exception e) { e.printStackTrace(); }
   }
 
   public static void initGUI()
   {
     gui_console = new FTPConsole();
 
     tabbed_pane = new JTabbedPane();
 
     tabbed_pane.addTab("FTreeP Console", gui_console);
     tabbed_pane.setSelectedIndex(0);
 
     frame = new JFrame();
 
     frame.addWindowListener(
       new WindowAdapter()
       {
         public void windowClosing(WindowEvent e)
         {
           try{
 
           System.exit(0);
 
           } catch(Exception ex) {}
         }
       }
     );
 
     frame.getContentPane().setLayout(new BorderLayout());
     frame.getContentPane().add(tabbed_pane);
 
     if(master) frame.setTitle("FTreeP - Command Relay");
     else frame.setTitle("FTreeP - Data Host");
 
     frame.setSize(640, 480);
     frame.setVisible(true);
   }
 
   public static void system_print(String s) throws Exception
   {
     if(!gui) System.out.print(s);
     else gui_console.print(s);
   }
 
   public static void system_println(String s) throws Exception
   {
     if(!gui) System.out.println(s);
     else gui_console.println(s);
   }
 }
 
 class FTPDirectoryIndexListener
 extends Thread
 {
   private ServerSocket ss = null;
 
   public FTPDirectoryIndexListener(int master_port) throws Exception
   {
     ss = new ServerSocket(master_port);
   }
 
   public void run()
   {
     try {
 
     while(true)
     {
       Socket s = ss.accept();
       new FTPDirectoryIndexReceive(s).start();
     }
 
     } catch(Exception e) { e.printStackTrace(); }
   }
 }
 
 class FTPDirectoryIndexReceive
 extends Thread
 {
   private Socket dir_socket = null;
   private BufferedReader dir_in = null;
 
   public FTPDirectoryIndexReceive(Socket dir_socket) throws Exception
   {
     this.dir_socket = dir_socket;
     dir_in = new BufferedReader(new InputStreamReader(dir_socket.getInputStream()));
   }
 
   public void run()
   {
     /* FIX THIS HACK!!! */
     try {
 
       FTPBase.system_print("Receiving new Directory Index... ");
 
       try {
 
         boolean t = true;
         while(t)
         {
           String line = dir_in.readLine();
 
           if(line.startsWith("#") | line.equals("")) continue;
 
           StringTokenizer st = new StringTokenizer(line, "\t");
 
           Resource r = new Resource(st.nextToken(), st.nextToken(), st.nextToken(), Integer.parseInt(st.nextToken()));
 
           if(FTPBase.directory_index.contains(r) == false) FTPBase.directory_index.add(r);
         }
 
         dir_in.close();
         dir_socket.close();
 
       } catch(Exception e) {}
 
       FTPBase.system_println("Done!");
 
     } catch(Exception e) {}
   }
 }
 
 class FTPConsole
 extends JScrollPane
 {
   private JTextArea console = null;
 
   public FTPConsole()
   {
     if(FTPBase.gui)
     {
       console = new JTextArea();
       console.setEditable(false);
 
       this.setViewportView(console);
     }
   }
 
   public void print(String s)
   {
     if(FTPBase.gui) console.append(s);
     else System.out.print(s);
   }
 
   public void println(String s)
   {
     if(FTPBase.gui) console.append(s + "\n");
     else System.out.println(s);
   }
 }