From e07fbd1d17103a07e04c790291d2b419b1a708ee Mon Sep 17 00:00:00 2001
From: jprocter <jprocter@compbio.dundee.ac.uk>
Date: Fri, 13 Jan 2006 14:06:10 +0000
Subject: [PATCH] extracted serial command processing for use by other test
 classes

git-svn-id: https://svn.lifesci.dundee.ac.uk/svn/repository/trunk@107 be28352e-c001-0410-b1a7-c7978e42abec
---
 .../vamsas/test/simpleclient/ClientsFileTest.java  |  394 +++++++++++++-------
 .../vamsas/test/simpleclient/CommandProcessor.java |   65 ++++
 2 files changed, 331 insertions(+), 128 deletions(-)
 create mode 100644 src/org/vamsas/test/simpleclient/CommandProcessor.java

diff --git a/src/org/vamsas/test/simpleclient/ClientsFileTest.java b/src/org/vamsas/test/simpleclient/ClientsFileTest.java
index 6ccd736..9ab68ac 100644
--- a/src/org/vamsas/test/simpleclient/ClientsFileTest.java
+++ b/src/org/vamsas/test/simpleclient/ClientsFileTest.java
@@ -10,162 +10,300 @@ import org.vamsas.client.simpleclient.FileWatcher;
 import org.vamsas.client.simpleclient.Lock;
 
 public class ClientsFileTest {
+  private static CommandProcessor cproc;
+
   private static Vector commands;
   static {
-    ClientsFileTest.commands=new Vector();
+    cproc = new CommandProcessor();
+    ClientsFileTest.commands = new Vector();
     ClientsFileTest.commands.add(new String("add"));
+    cproc.addCommand("add", 2, "for the Client's 'Name' and 'Version'");
     ClientsFileTest.commands.add(new String("remove"));
-    ClientsFileTest.commands.add(new String("list"));    
+    cproc.addCommand("remove", 3, "for the Client's 'Name', Version and URN");
+    ClientsFileTest.commands.add(new String("list"));
+    cproc.addCommand("list", 0, "no args needed");
     ClientsFileTest.commands.add(new String("clear"));
-    ClientsFileTest.commands.add(new String("watch"));    
-    ClientsFileTest.commands.add(new String("monitor"));    
+    cproc.addCommand("clear", 0, "no args needed");
+    ClientsFileTest.commands.add(new String("watch"));
+    cproc.addCommand("watch", 0, "no args needed");
+    ClientsFileTest.commands.add(new String("monitor"));
+    cproc.addCommand("monitor", 2, "for the Client's 'Name' and 'Version'");
   }
-  private static void complainArgs(int argl, int argpos, String cmd, int argneed, String msg) {
-    if (argl-argpos<argneed)
-      throw new Error(cmd+" needs "+argneed+" arguments : "+msg);
+
+  private static void complainArgs(int argl, int argpos, String cmd,
+      int argneed, String msg) {
+    if (argl - argpos < argneed)
+      throw new Error(cmd + " needs " + argneed + " arguments : " + msg);
   }
+
   public static void main(String[] args) {
     java.io.File cf = new java.io.File(args[0]);
-    System.out.println("Connecting to clientFile "+args[0]);
+    System.out.println("Connecting to clientFile " + args[0]);
     ClientsFile cfhand;
     try {
       cfhand = new ClientsFile(cf);
-    }
-    catch (Exception e) {
+    } catch (Exception e) {
       e.printStackTrace(System.err);
       return;
     }
-    int argc=1;
-    while (argc<args.length) {
-      Iterator coms = commands.iterator();
-      int com=-1;
-      while ((coms!=null) && coms.hasNext()) {
-        com++;
-        if (args[argc].toLowerCase().equals((String) coms.next())) {
-          System.out.println("Doing "+args[argc]);
-          ClientHandle ch;
-          argc++;
-          switch (com) {
-          case 0:
-            // Add
-            ClientsFileTest.complainArgs(args.length, argc, "add", 2, "for the Client's 'Name' and 'Version'");
-            int pos = cfhand.addClient(ch=new ClientHandle(args[argc],args[argc+1]));
-            argc+=2;
-            if (pos!=0)
-              System.out.println("Client added at "+pos+" as urn:"+ch.getClientUrn());
-            else
-              System.out.println("Client was not added.");
-            break;
-          case 1:
-            // remove
-            ClientsFileTest.complainArgs(args.length, argc, "remove", 3, "for the Client's 'Name', Version and URN");
-            ch=new ClientHandle(args[argc], args[argc+1]);
-            ch.setClientUrn(args[argc+2]);
-            argc+=3;
-            cfhand.removeClient(ch, null);
-            System.out.println("Client removed (apparently)");
-            break;
-          case 2:
-            // list
-            ClientHandle[] chlist = cfhand.retrieveClientList();
-            if (chlist!=null) {
-              for (int chi=0,che=chlist.length; chi<che; chi++) {
-                System.out.println("Client "+chi+" ("+chlist[chi].getClientName()+" "+chlist[chi].getVersion()+" "+chlist[chi].getClientUrn()+")");
+    int argc = 1;
+    while (argc < args.length) {
+      // vars needed for operations
+      ClientHandle ch;
+      int com = cproc.getCommand(args, argc);
+      argc++;
+      switch (com) {
+      case 0:
+        // Add
+        int pos = cfhand.addClient(ch = new ClientHandle(args[argc],
+            args[argc + 1]));
+        argc += 2;
+        if (pos != 0)
+          System.out.println("Client added at " + pos + " as urn:"
+              + ch.getClientUrn());
+        else
+          System.out.println("Client was not added.");
+        break;
+      case 1:
+        // remove
+        ch = new ClientHandle(args[argc], args[argc + 1]);
+        ch.setClientUrn(args[argc + 2]);
+        argc += 3;
+        cfhand.removeClient(ch, null);
+        System.out.println("Client removed (apparently)");
+        break;
+      case 2:
+        // list
+        ClientHandle[] chlist = cfhand.retrieveClientList();
+        if (chlist != null) {
+          for (int chi = 0, che = chlist.length; chi < che; chi++) {
+            System.out.println("Client " + chi + " ("
+                + chlist[chi].getClientName() + " " + chlist[chi].getVersion()
+                + " " + chlist[chi].getClientUrn() + ")");
+          }
+        } else {
+          System.out.println("Client list is empty.");
+        }
+        break;
+      case 3:
+        // clear
+        cfhand = null;
+        cf.delete();
+        try {
+          cf.createNewFile();
+          cfhand = new ClientsFile(cf);
+        } catch (Exception e) {
+          System.err.println("Failed on new empty clientfile creation!");
+          e.printStackTrace(System.err);
+        }
+        break;
+      case 4:
+        // watch
+        FileWatcher w = new FileWatcher(cf);
+        while (cf.exists()) {
+          // get watcher's lock to ensure state change is fixed for retrieval
+          Lock chlock = w.getChangedState();
+          if (chlock != null) {
+            ClientHandle[] cl = cfhand.retrieveClientList(chlock);
+            System.out.println("-- Watching " + cf.getName());
+            //while (w.hasChanged())
+            //  ;
+            if (cl != null) {
+              for (int chi = 0, che = cl.length; chi < che; chi++) {
+                System.out.println("Client " + chi + " ("
+                    + cl[chi].getClientName() + " " + cl[chi].getVersion()
+                    + " " + cl[chi].getClientUrn() + ")");
               }
             } else {
               System.out.println("Client list is empty.");
             }
-            break;
-          case 3:
-            // clear
-            cfhand = null;
-            cf.delete();
-            try {
-              cf.createNewFile();
-              cfhand = new ClientsFile(cf);
-            }
-            catch (Exception e) {
-              System.err.println("Failed on new empty clientfile creation!");
-              e.printStackTrace(System.err);
-            }
-            break;
-          case 4:
-            // watch
-            FileWatcher w=new FileWatcher(cf);
-            while (cf.exists()) {
-              // get watcher's lock to ensure state change is fixed for retrieval
-              Lock chlock=w.getChangedState();
-              if (chlock!=null) {
-                ClientHandle[] cl = cfhand.retrieveClientList(chlock);
-                System.out.println("-- Watching "+cf.getName());
-                //while (w.hasChanged())
-                //  ;
-                if (cl!=null) {
-                  for (int chi=0,che=cl.length; chi<che; chi++) {
-                    System.out.println("Client "+chi+" ("+cl[chi].getClientName()+" "+cl[chi].getVersion()+" "+cl[chi].getClientUrn()+")");
-                  }
-                } else {
-                  System.out.println("Client list is empty.");
-                }
+          }
+
+        }
+        break;
+      case 5:
+        // monitor
+        int clpos = cfhand.addClient(ch = new ClientHandle(args[argc],
+            args[argc + 1]));
+        argc += 2;
+        if (clpos != 0)
+          System.out.println("Monitor Client added at " + clpos + " as urn:"
+              + ch.getClientUrn());
+        else {
+          System.err.println("Monitor Client was not added.");
+          break;
+        }
+        FileWatcher mon = new FileWatcher(cf);
+        while (cf.exists()) {
+          // get watcher's lock to ensure state change is fixed for retrieval
+          Lock chlock = mon.getChangedState();
+          if (chlock != null) {
+            ClientHandle[] cl = cfhand.retrieveClientList(chlock);
+            System.out.println("-- Monitor " + cf.getName());
+            //while (w.hasChanged())
+            //  ;
+            int newpos = -1;
+            if (cl != null) {
+              for (int chi = 0, che = cl.length; chi < che; chi++) {
+                if (ch.equals(cl[chi]))
+                  newpos = chi + 1;
               }
-              
             }
-            break;
-          case 5:
-            // monitor
-            ClientsFileTest.complainArgs(args.length, argc, "monitor", 2, "for the Client's 'Name' and 'Version'");
-            int clpos = cfhand.addClient(ch=new ClientHandle(args[argc],args[argc+1]));
-            argc+=2;
-            if (clpos!=0)
-              System.out.println("Monitor Client added at "+clpos+" as urn:"+ch.getClientUrn());
-            else {
-              System.err.println("Monitor Client was not added.");
-              break;
-            }
-            FileWatcher mon=new FileWatcher(cf);
-            while (cf.exists()) {
-              // get watcher's lock to ensure state change is fixed for retrieval
-              Lock chlock=mon.getChangedState();
-              if (chlock!=null) {
-                ClientHandle[] cl = cfhand.retrieveClientList(chlock);
-                System.out.println("-- Monitor "+cf.getName());
-                //while (w.hasChanged())
-                //  ;
-                int newpos=-1;
-                if (cl!=null) {
-                  for (int chi=0,che=cl.length; chi<che; chi++) {
-                    if (ch.equals(cl[chi]))
-                      newpos=chi+1;
-                  }
-                }
-                if (newpos==-1) {
-                  // add self again to cleared list.
-                  newpos=cfhand.addClient(ch);
-                  mon.setState();
-                  if (newpos==0) {
-                    System.err.println("Monitor client could not be re-added to list.");
-                    break;
-                  }
-                }
-                if (newpos!=clpos) {
-                  System.out.println("Monitor client moved from "+clpos+" to "+newpos);
-                  clpos=newpos;
-                }
+            if (newpos == -1) {
+              // add self again to cleared list.
+              newpos = cfhand.addClient(ch);
+              mon.setState();
+              if (newpos == 0) {
+                System.err
+                    .println("Monitor client could not be re-added to list.");
+                break;
               }
             }
-              
+            if (newpos != clpos) {
+              System.out.println("Monitor client moved from " + clpos + " to "
+                  + newpos);
+              clpos = newpos;
+            }
           }
-          coms = null;
         }
+        break;
+      default:
+        if (com == -1) {
+          System.err
+              .println("Unknown command : " + args[argc++] + "*Ignored!*");
+        } else
+          System.err.println("Command " + args[argc++]
+              + " *Ignored!* - its not implemented.");
       }
-      if (coms!=null) {
-        System.err.println("Unknown command : "+args[argc++] + "*Ignored!*");
-      };
-      for (int j=0; j<900000; j++) {
-        Integer i=Integer.getInteger("1");
-        Integer q=i;
+      
+      for (int j = 0; j < 900000; j++) {
+        Integer i = Integer.getInteger("1");
+        Integer q = i;
       }
     }
+
   }
 
+  /*      Iterator coms = commands.iterator();
+   int com=-1;
+   while ((coms!=null) && coms.hasNext()) {
+   com++;
+   if (args[argc].toLowerCase().equals((String) coms.next())) {
+   System.out.println("Doing "+args[argc]);
+   ClientHandle ch;
+   argc++;
+   switch (com) {
+   case 0:
+   // Add
+   ClientsFileTest.complainArgs(args.length, argc, "add", 2, "for the Client's 'Name' and 'Version'");
+   int pos = cfhand.addClient(ch=new ClientHandle(args[argc],args[argc+1]));
+   argc+=2;
+   if (pos!=0)
+   System.out.println("Client added at "+pos+" as urn:"+ch.getClientUrn());
+   else
+   System.out.println("Client was not added.");
+   break;
+   case 1:
+   // remove
+   ClientsFileTest.complainArgs(args.length, argc, "remove", 3, "for the Client's 'Name', Version and URN");
+   ch=new ClientHandle(args[argc], args[argc+1]);
+   ch.setClientUrn(args[argc+2]);
+   argc+=3;
+   cfhand.removeClient(ch, null);
+   System.out.println("Client removed (apparently)");
+   break;
+   case 2:
+   // list
+   ClientHandle[] chlist = cfhand.retrieveClientList();
+   if (chlist!=null) {
+   for (int chi=0,che=chlist.length; chi<che; chi++) {
+   System.out.println("Client "+chi+" ("+chlist[chi].getClientName()+" "+chlist[chi].getVersion()+" "+chlist[chi].getClientUrn()+")");
+   }
+   } else {
+   System.out.println("Client list is empty.");
+   }
+   break;
+   case 3:
+   // clear
+   cfhand = null;
+   cf.delete();
+   try {
+   cf.createNewFile();
+   cfhand = new ClientsFile(cf);
+   }
+   catch (Exception e) {
+   System.err.println("Failed on new empty clientfile creation!");
+   e.printStackTrace(System.err);
+   }
+   break;
+   case 4:
+   // watch
+   FileWatcher w=new FileWatcher(cf);
+   while (cf.exists()) {
+   // get watcher's lock to ensure state change is fixed for retrieval
+   Lock chlock=w.getChangedState();
+   if (chlock!=null) {
+   ClientHandle[] cl = cfhand.retrieveClientList(chlock);
+   System.out.println("-- Watching "+cf.getName());
+   //while (w.hasChanged())
+   //  ;
+   if (cl!=null) {
+   for (int chi=0,che=cl.length; chi<che; chi++) {
+   System.out.println("Client "+chi+" ("+cl[chi].getClientName()+" "+cl[chi].getVersion()+" "+cl[chi].getClientUrn()+")");
+   }
+   } else {
+   System.out.println("Client list is empty.");
+   }
+   }
+   
+   }
+   break;
+   case 5:
+   // monitor
+   ClientsFileTest.complainArgs(args.length, argc, "monitor", 2, "for the Client's 'Name' and 'Version'");
+   int clpos = cfhand.addClient(ch=new ClientHandle(args[argc],args[argc+1]));
+   argc+=2;
+   if (clpos!=0)
+   System.out.println("Monitor Client added at "+clpos+" as urn:"+ch.getClientUrn());
+   else {
+   System.err.println("Monitor Client was not added.");
+   break;
+   }
+   FileWatcher mon=new FileWatcher(cf);
+   while (cf.exists()) {
+   // get watcher's lock to ensure state change is fixed for retrieval
+   Lock chlock=mon.getChangedState();
+   if (chlock!=null) {
+   ClientHandle[] cl = cfhand.retrieveClientList(chlock);
+   System.out.println("-- Monitor "+cf.getName());
+   //while (w.hasChanged())
+   //  ;
+   int newpos=-1;
+   if (cl!=null) {
+   for (int chi=0,che=cl.length; chi<che; chi++) {
+   if (ch.equals(cl[chi]))
+   newpos=chi+1;
+   }
+   }
+   if (newpos==-1) {
+   // add self again to cleared list.
+   newpos=cfhand.addClient(ch);
+   mon.setState();
+   if (newpos==0) {
+   System.err.println("Monitor client could not be re-added to list.");
+   break;
+   }
+   }
+   if (newpos!=clpos) {
+   System.out.println("Monitor client moved from "+clpos+" to "+newpos);
+   clpos=newpos;
+   }
+   }
+   }
+   
+   }
+   coms = null;
+   }
+   } */
+
 }
diff --git a/src/org/vamsas/test/simpleclient/CommandProcessor.java b/src/org/vamsas/test/simpleclient/CommandProcessor.java
new file mode 100644
index 0000000..0cf0701
--- /dev/null
+++ b/src/org/vamsas/test/simpleclient/CommandProcessor.java
@@ -0,0 +1,65 @@
+package org.vamsas.test.simpleclient;
+
+import java.util.Iterator;
+import java.util.Vector;
+
+public class CommandProcessor {
+  /**
+   * this is not getOPT!!!! - processes a *series* of space separated commands - some of which take arguments.
+   */
+  private Vector commands;
+  /* static {
+    ClientsFileTest.commands=new Vector();
+    ClientsFileTest.commands.add(new String("add"));
+    ClientsFileTest.commands.add(new String("remove"));
+    ClientsFileTest.commands.add(new String("list"));    
+    ClientsFileTest.commands.add(new String("clear"));
+    ClientsFileTest.commands.add(new String("watch"));    
+    ClientsFileTest.commands.add(new String("monitor"));    
+  } */
+
+  public int addCommand(String cmd, int argneed, String complainString) {
+    int cnum=0;
+    if (commands==null)
+      commands = new Vector();
+    else 
+      cnum = commands.size();
+    Vector cv = new Vector();
+    cv.add(new String(cmd));
+    cv.add(new Integer(argneed));
+    cv.add(new String(complainString));
+    commands.add(cv);
+    return cnum;
+  }
+ 
+  /**
+   * Integer argl, Integer argpos, String cmd, Integer argneed, String msg in vector
+   */
+  public void complainArgs(int argl, int argpos, Vector ca) {
+    int argneed = ((Integer) ca.get(1)).intValue();
+    if (argl-argpos<argneed)
+      throw new Error(((String) ca.get(0))+" at position "+argpos+" needs "+argneed+" arguments : "+(String) ca.get(2));
+  }
+  /**
+   * find and verify a command
+   * @param args argstring
+   * @param argpos position to check for command
+   * @return matching command or -1
+   */
+  public int getCommand(String[]args, int argpos) {
+    Iterator coms = commands.iterator();
+    int com=-1, argc;
+    argc=argpos;
+    while ((coms!=null) && coms.hasNext()) {
+      com++;
+      Vector comnext = (Vector) coms.next();
+      if (args[argc].toLowerCase().equals((String) comnext.get(0))) {
+        if (comnext.size()>2)
+          complainArgs(args.length, argc+1, comnext);
+        return com;
+      }
+    }
+    return -1;
+        
+  }
+}
-- 
1.7.10.2