System Touch

Author: mearvk

source/bitcoin/module/TraderModule.java

@@ -5,7 +5,6 @@
 import bitcoin.time.BitcoinAmericaAndNewYorkDate;
 import commons.CommonRails;
 import server.nitro.NitroWebExpress;
-import server.nitro.WebExpress;
 
 import exceptions.ExceptionHandler;
 import java.io.BufferedReader;
@@ -142,6 +141,7 @@ public String get_wallet_name(final String URL)
         catch (Exception e)
         {
             ExceptionHandler.dispatch(e);
+
             CommonRails.printSystemComponent(this, this.hashCode(), "0x8A66Ea");
         }
 
@@ -177,6 +177,7 @@ public void delete_wallet(final String URL) throws IOException
         catch (Exception e)
         {
             ExceptionHandler.dispatch(e);
+
             CommonRails.printSystemComponent(this, this.hashCode(), "0x8A66Ea");
         }
     }
@@ -192,6 +193,7 @@ public void unload_wallet(final String URL) throws IOException
         catch (Exception e)
         {
             ExceptionHandler.dispatch(e);
+
             CommonRails.printSystemComponent(this, this.hashCode(), "0x8A66Ea");
         }
     }
@@ -207,6 +209,7 @@ public void rename_wallet(final String URL)
         catch (Exception e)
         {
             ExceptionHandler.dispatch(e);
+
             CommonRails.printSystemComponent(this, this.hashCode(), "0x8A66Ea");
         }
     }
@@ -222,6 +225,7 @@ public void add_new_wallet(final String URL)
         catch (Exception e)
         {
             ExceptionHandler.dispatch(e);
+
             CommonRails.printSystemComponent(this, this.hashCode(), "0x8A66Ea");
         }
     }
@@ -237,6 +241,7 @@ public void send_local_wallet_to_remote_wallet(final String URL)
         catch (Exception e)
         {
             ExceptionHandler.dispatch(e);
+
             CommonRails.printSystemComponent(this, this.hashCode(), "0x8A66Ea");
         }
     }

source/connections/ConnectionPoller.java

@@ -6,7 +6,7 @@
 import exceptions.ExceptionHandler;
 import messaging.MessageQueue;
 import server.base.BaseServer;
-import server.nitro.WebExpress;
+import server.webexpress.WebExpress;
 import telnet.TelnetMessageQueue;
 
 import java.io.BufferedReader;

source/messaging/MessageQueueSorter.java

@@ -3,7 +3,7 @@
 import commons.CommonRails;
 import commons.socket.SocketUtils;
 import exceptions.ExceptionHandler;
-import server.nitro.WebExpress;
+import server.webexpress.WebExpress;
 
 import java.io.BufferedWriter;
 import java.io.IOException;

source/server/nitro/NitroWebExpress.java

@@ -13,6 +13,7 @@
 import messaging.MessageQueue;
 import messaging.MessageQueueSorter;
 import national.NationalID;
+import server.webexpress.WebExpress;
 
 import java.io.BufferedReader;
 import java.io.BufferedWriter;

source/server/nitro/WebExpress.java source/server/webexpress/WebExpress.javasource/server/nitro/WebExpress.java renamed to source/server/webexpress/WebExpress.java

@@ -1,4 +1,4 @@
-package server.nitro;
+package server.webexpress;
 
 import commons.CommonRails;
 import messaging.MessageQueue;
@@ -74,7 +74,7 @@ public WebExpress(final String HOST, final Integer PORT, final String THREAD_NAM
 
             this.TELNET_COMMUNICATION_PROXY.OUTPUT_BUILDER.setName("TelnetCommunicationProxy.Builder.Output");
 
-            this.TELNET_COMMUNICATION_PROXY.input_builder.setName("TelnetCommunicationProxy.Builder.Input");
+            this.TELNET_COMMUNICATION_PROXY.INPUT_BUILDER.setName("TelnetCommunicationProxy.Builder.Input");
         }
         else
         {

source/telnet/TelnetCommunicationProxy.java

@@ -2,13 +2,12 @@
 
 import commons.CommonRails;
 import exceptions.ExceptionHandler;
-import server.nitro.WebExpress;
+import server.webexpress.WebExpress;
 
 import java.io.BufferedReader;
 import java.io.BufferedWriter;
 import java.net.InetAddress;
 import java.net.Socket;
-import java.util.Date;
 
 public class TelnetCommunicationProxy
 {
@@ -28,7 +27,7 @@ public class TelnetCommunicationProxy
 
     public TelnetOutputBuilder OUTPUT_BUILDER;
 
-    public TelnetInputBuilder input_builder;
+    public TelnetInputBuilder INPUT_BUILDER;
 
     public TelnetProxyLivenessMonitor liveness_monitor;
 
@@ -50,11 +49,11 @@ public TelnetCommunicationProxy(final WebExpress WEB_EXPRESS)
 
         this.OUTPUT_BUILDER = new TelnetOutputBuilder(this);
 
-        this.input_builder = new TelnetInputBuilder(this);
+        this.INPUT_BUILDER = new TelnetInputBuilder(this);
 
         this.OUTPUT_BUILDER.start();
 
-        this.input_builder.start();
+        this.INPUT_BUILDER.start();
 
         this.liveness_monitor = new TelnetProxyLivenessMonitor(this);
 
@@ -121,7 +120,7 @@ public void run()
                         proxy.reader.mark(1);
                     }
 
-                    proxy.input_builder.telnet_message_queue.add(inbound);
+                    proxy.INPUT_BUILDER.telnet_message_queue.add(inbound);
 
                     // ── Outbound: re-enqueue a status ping so OUTPUT_BUILDER stays active ──
                     TelnetMessageQueue.Message outbound = new TelnetMessageQueue.Message();

source/telnet/TelnetInstaller.java

@@ -2,7 +2,7 @@
 
 import commons.CommonRails;
 import exceptions.ExceptionHandler;
-import server.nitro.WebExpress;
+import server.webexpress.WebExpress;
 
 import java.io.BufferedReader;
 import java.io.BufferedWriter;
@@ -36,11 +36,13 @@ public TelnetInstaller(final WebExpress WEB_EXPRESS)
 
             this.process = process_builder.start();
 
-            // register process with CommonRails so it can monitor exit/finish events
-            try {
+            try
+            {
                 CommonRails.registerProcess(this.process_builder, this.process, this);
-            } catch (Exception ignore) {
-                // best-effort: don't let registration prevent initialization
+            }
+            catch (Exception ignore)
+            {
+                ignore.printStackTrace(System.err);
             }
 
             this.reader = new BufferedReader(new InputStreamReader(process.getInputStream()));