Merge pull request #408 from sparkfun/TCP_Updates

TCP updates

Author: nseidle

Firmware/RTK_Everywhere/TcpServer.ino

@@ -359,7 +359,7 @@ void tcpServerUpdate()
     // Wait until the TCP server is enabled
     case TCP_SERVER_STATE_OFF:
         // Determine if the TCP server should be running
-        if (EQ_RTK_MODE(tcpServerMode) && settings.enableTcpServer && (!wifiIsConnected()))
+        if (EQ_RTK_MODE(tcpServerMode) && settings.enableTcpServer) // Was && (!wifiIsConnected())) - TODO check this
         {
             if (networkUserOpen(NETWORK_USER_TCP_SERVER, NETWORK_TYPE_ACTIVE))
             {

Firmware/Tools/TCP_Client.py

@@ -0,0 +1,34 @@
+import socket
+import argparse
+import multiprocessing
+
+def client(server, port):
+    sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+    sock.connect((server, port))
+    while True:
+        payload = sock.recv(1024)
+        print(payload.decode('latin1'), end='')
+        
+if __name__ == "__main__":
+
+    parser = argparse.ArgumentParser(
+        description='TCP Client')
+
+    parser.add_argument('-server', type=str, default="",
+                        help='Host Name or IP Address of the TCP Server')
+
+    parser.add_argument('-port', type=int, default=2948,
+                        help='TCP Port Number')
+
+    args = parser.parse_args()
+
+    print("Connecting to " + args.server + " on port " + str(args.port))
+
+    proc = multiprocessing.Process(target = client, args = (args.server, args.port))
+    proc.start()
+
+    try:
+        while True:
+            pass
+    except KeyboardInterrupt:
+        proc.terminate()

Firmware/Tools/TCP_Server.py

@@ -0,0 +1,51 @@
+import socket
+import argparse
+import multiprocessing
+
+
+def client(server, port):
+    sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+    sock.bind((server, port))
+    sock.listen()
+    while True:
+        print("Waiting for new connection")
+        conn, addr = sock.accept()
+        print("Connection from " + str(addr))
+        conn.settimeout(5.0)
+        keepGoing = True
+        while keepGoing:
+            try:
+                payload = conn.recv(1024)
+            except TimeoutError:
+                keepGoing = False
+            if len(payload) > 0:
+                print(payload.decode('latin1'), end='')
+        conn.close()
+        print()
+        
+if __name__ == "__main__":
+
+    parser = argparse.ArgumentParser(
+        description='TCP Server')
+
+    parser.add_argument('-server', type=str, default="",
+                        help='Host Name or IP Address (e.g. 127.0.0.1 localhost)')
+
+    parser.add_argument('-port', type=int, default=2948,
+                        help='TCP Port Number')
+
+    args = parser.parse_args()
+
+    if (args.server != ""):
+        print("Listening on " + args.server + ":" + str(args.port))
+    else:
+        print("Listening on port " + str(args.port))
+
+    proc = multiprocessing.Process(target = client, args = (args.server, args.port))
+    proc.start()
+
+    try:
+        while True:
+            pass
+    except KeyboardInterrupt:
+        proc.terminate()