We detect game entry. Proxy pops up / restores prompt.

config_dev.py

@@ -0,0 +1,8 @@
+
+# Connect to:
+HOST = "127.0.0.1"
+PORT = 2002
+# Listen on:
+LISTEN_PORT = 9999
+LISTEN_ON = "127.0.0.1"
+

tcp-proxy.py

@@ -11,7 +11,9 @@ from twisted.enterprise import adbapi
 import pendulum
 from subprocess import check_output
 
-from config_dev import *
+RAW = True
+
+from config import *
 
 # Connect to:
 # HOST = "twgs"
@@ -146,24 +148,74 @@ class GlueFactory(protocol.ClientFactory):
 # ProxyServer is created for each connection
 
 
+class ProxyAction:
+    def __init__(self, queue_client, queue_twgs):
+        self.active = False
+        self.queue_client = queue_client
+        self.queue_twgs = queue_twgs
+        self.buffer = ""
+        self.prompt = ""
+
+    def isActive(self):
+        return self.active
+
+    def keepAlive(self):
+        if self.active:
+            self.queue_twgs.put(b" ")
+            reactor.callLater(30, self.keepAlive)
+
+    def activate(self, prompt):
+        self.active = True
+        self.prompt = prompt
+        self.send("\r\n**********\r\nTWGS Proxy ready...\r\n")
+        self.send("Prompt seen: [{0}] ...\r\n".format(self.prompt))
+        self.send("(T) Display Time\r\n")
+        self.send("(Q) Quit\r\n")
+        self.send("  --==> ")
+        reactor.callLater(30, self.keepAlive)
+
+    def server(self, line):
+        pass
+
+    def send(self, text):
+        self.queue_client.put((text.encode(),))
+
+    def received(self, chunk):
+        # self.buffer += chunk.encode('UTF-8', 'ignore')
+        text = chunk.decode("utf-8", "ignore").upper()
+
+        if text == "T":
+            now = pendulum.now()
+            self.send("\r\nThe time is: {0}.\r\n".format(now.to_rss_string()))
+        if text == "Q":
+            self.send("\r\nReturning to TWGS.\r\n{0}".format(self.prompt))
+            self.active = False
+
+
 class TWGSServer(protocol.Protocol):
     def __init__(self):
         self.buffer = ""
         self.fpRaw = None
         self.fpLines = None
+        self.action = None
+        self.user = ""
+        self.game = ""
 
     def connectionMade(self):
         self.queue_twgs = defer.DeferredQueue()
         self.queue_client = defer.DeferredQueue()
         self.queue_client.get().addCallback(self.clientDataReceived)
+        self.action = ProxyAction(self.queue_client, self.queue_twgs)
 
         factory = GlueFactory(self.queue_client, self.queue_twgs, self)
         reactor.connectTCP(HOST, PORT, factory, 5)
 
     def logUser(self, user):
         now = pendulum.now()
+        self.user = user
         filename = now.format("YYYY-MM-DD_HHmm") + "-" + user.lower()
-        # self.fpRaw = open(filename + ".raw", "ab")
+        if RAW:
+            self.fpRaw = open(filename + ".raw", "ab")
         self.fpLines = open(filename + ".lines", "a")
         # print("Log created:", now.to_rss_string(), "\n", file=self.fpRaw)
         print("Log created:", now.to_rss_string(), "\n", file=self.fpLines)
@@ -185,6 +237,15 @@ class TWGSServer(protocol.Protocol):
                         + b" is active. \x1b[1;34m~\x1b[0m to activate.\n\r\n\r",
                     )
                 )
+        if "TradeWars Game Server" in line:
+            if "Copyright (C) EIS" in line:
+                # We are not in a game
+                self.game = ""
+        if "Selection (? for menu): " in line:
+            game = line[-1]
+            if game >= "A" and game < "Q":
+                self.game = game
+                log.msg("USER {0} ENTERED {1}".format(self.user, self.game))
 
     def clientDataReceived(self, chunk):
         if chunk is False:
@@ -206,6 +267,9 @@ class TWGSServer(protocol.Protocol):
 
                 # Treat some ANSI codes as a newline (for purposes of Lines)
                 self.buffer = treatAsNL(self.buffer)
+                # I think I need something else in here.  When something enters or leaves the sector
+                # The message isn't shown on it's own line.  I think they are using ANSI codes to
+                # clear the line.  (Which certainly would be faster!)
 
                 # Break the buffer into lines
 
@@ -223,12 +287,14 @@ class TWGSServer(protocol.Protocol):
 
     def dataReceived(self, chunk):
         # log.msg("Server: %d bytes received" % len(chunk))
-        if chunk == b"~":
-            self.queue_client.put(
-                (b"\r\n**********\r\nTWGS Proxy is almost awake...\r\n",)
-            )
+        if self.action and self.action.isActive():
+            # Do something completely different here
+            self.action.received(chunk)
         else:
-            self.queue_twgs.put(chunk)
+            if chunk == b"~":
+                self.action.activate(self.buffer)
+            else:
+                self.queue_twgs.put(chunk)
 
     def connectionLost(self, why):
         log.msg("lost connection %s" % why)