Working message when unable to connect to TWGS server.

Examples of chaining .addCallback in defer.py
Updated req.txt.

defer.py

@@ -0,0 +1,38 @@
+#!/usr/bin/env python
+
+from twisted.internet import reactor, defer
+from pprint import pprint
+
+def getData(inputData):
+    print('getData({0})'.format(inputData))
+    deferred = defer.Deferred()
+    # simulate a delayed result by asking reactor
+    # to fire in 2 seconds with inputData * 3 as result
+    reactor.callLater(2, deferred.callback, inputData * 3)
+    return deferred
+
+def cbPrint(result):
+    print("result: {0}".format(result))
+    # doing eferred, or the return result + 1 works
+    deferred = defer.Deferred()
+    reactor.callLater(1, deferred.callback, result + 1)
+    return deferred
+    # return result + 1
+
+def cbPrint2(result):
+    print("result:")
+    pprint(result)
+    return result + 2
+
+d = getData(3)
+# Ok, chaining callbacks is ... different.
+
+d.addCallback(cbPrint)
+# Before return result, this was printing None.  
+d.addCallback(cbPrint2)
+d.addCallback(cbPrint)
+
+reactor.callLater(5, reactor.stop)
+print("starting the reactor")
+reactor.run()
+

req.txt

@@ -1,11 +1,18 @@
+appdirs==1.4.3
 attrs==19.3.0
 Automat==0.8.0
+black==19.10b0
+Click==7.0
 constantly==15.1.0
 hyperlink==19.0.0
 idna==2.8
 incremental==17.5.0
+pathspec==0.6.0
 pkg-resources==0.0.0
 PyHamcrest==1.9.0
+regex==2019.11.1
 six==1.12.0
+toml==0.10.0
 Twisted==19.7.0
+typed-ast==1.4.0
 zope.interface==4.6.0

tcp-proxy.py

@@ -17,7 +17,7 @@ LISTEN_PORT = 9999
 LISTEN_ON = "127.0.0.1"
 
 
-class ProxyClientProtocol(protocol.Protocol):
+class PlayerProtocol(protocol.Protocol):
     def __init__(self):
         self.user = None
         self.dbinit = False
@@ -111,26 +111,37 @@ class ProxyClientProtocol(protocol.Protocol):
         self.transport.loseConnection()
 
 
-class ProxyClientFactory(protocol.ClientFactory):
+class GlueFactory(protocol.ClientFactory):
     maxDelay = 10
-    protocol = ProxyClientProtocol
+    protocol = PlayerProtocol
 
     def __init__(self, svr_queue, cli_queue):
         self.svr_queue = svr_queue
         self.cli_queue = cli_queue
 
+    def closeIt(self):
+        log.msg("closeIt")
+        self.svr_queue.put(False)
+
+    def clientConnectionFailed(self, connector, why):
+        log.msg("connectionFailed: %s" % why)
+        self.svr_queue.put(b"Unable to connect to the game server.\r\n")
+        # syncterm gets cranky/locks up if we close this here.
+        # (Because it is still sending rlogin information?)
+        reactor.callLater(2, self.closeIt)
+
 
 # ProxyServer is created for each connection
 
 
-class ProxyServer(protocol.Protocol):
+class TWGSServer(protocol.Protocol):
     def connectionMade(self):
         self.svr_queue = defer.DeferredQueue()
         self.cli_queue = defer.DeferredQueue()
         self.svr_queue.get().addCallback(self.clientDataReceived)
 
-        factory = ProxyClientFactory(self.svr_queue, self.cli_queue)
-        reactor.connectTCP(HOST, PORT, factory)
+        factory = GlueFactory(self.svr_queue, self.cli_queue)
+        reactor.connectTCP(HOST, PORT, factory, 5)
 
     def clientDataReceived(self, chunk):
         if chunk is False:
@@ -148,10 +159,13 @@ class ProxyServer(protocol.Protocol):
         log.msg("lost connection %s" % why)
         self.cli_queue.put(False)
 
+    def connectionFailed(self, why):
+        log.msg("connectionFailed: %s" % why)
+
 
 if __name__ == "__main__":
     log.startLogging(sys.stdout)
     factory = protocol.Factory()
-    factory.protocol = ProxyServer
+    factory.protocol = TWGSServer
     reactor.listenTCP(LISTEN_PORT, factory, interface=LISTEN_ON)
     reactor.run()