Boring Network Tool

Tools/boringNetworkTool/README.MD

@@ -0,0 +1,20 @@
+##Boring Network Tool
+
+The file main.py can be used to send either 
+TCP or UDP messages to a given hostname and port, specified via the config json.
+
+This script does not require any external packages, aside from standard python 3.7 or higher.
+
+###Usage
+
+sending_config.json 
+has a similar configuration to the json in Pidaq/Examples/CanSender, and can be used to specify the
+messages to send, and whether to send them via TCP or UDP.  The frequency with which to send the
+messages can also be specified.  Finally, the port and hostname are specified in the json as well.
+
+tcp_server.py implements a simple TCP server to verify the functionality of the script.
+
+udp_server.py implements a simple UDP server to verify the functionality of the script.
+
+For both server scripts, to receive any messages and print them out, simply use localhost 
+and port 8888 to connect to the server after running it

Tools/boringNetworkTool/main.py

@@ -0,0 +1,83 @@
+import socket
+import sys
+import time
+import json
+
+
+class Message:
+    def __init__(self, data):
+        self.data = data
+
+    def to_string(self) -> str:
+        return "%s \n" % str(self.data)
+
+
+def create_messages(raw_messages):
+    msgs = []
+    for message in raw_messages:
+        msgs.append(Message(data=message["data"]))
+    return msgs
+
+
+def send_with_udp(msgconfig, host, port):
+    try:
+        s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
+    except socket.error:
+        print('Failed to create socket')
+        sys.exit()
+    msgs = create_messages(msgconfig["config"]["messages"])
+    msg_frequency = msgconfig["config"]["messageFrequency"]
+    for message in msgs:
+        time.sleep(1.0 / msg_frequency)
+        try:
+            # Set the whole string
+            s.sendto(bytes(message.to_string(), 'utf-8'), (host, port))
+            print("message sent: %s" % message.to_string())
+            # receive data from client (data, addr)
+            if msgconfig["config"]["sendContinuous"] is False:
+                d = s.recvfrom(1024)
+                reply = d[0]
+                print('Server reply : %s' % reply.decode('utf-8'))
+        except socket.error as msg:
+            print('Error Code : %s Message : %s ' % (str(msg[0]), msg[1]))
+            sys.exit()
+
+
+def send_with_tcp(msgconfig, host, port):
+    try:
+        s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+        s.connect((host, port))
+    except socket.error:
+        print('Failed to create socket')
+        sys.exit()
+    msgs = create_messages(msgconfig["config"]["messages"])
+    msg_frequency = msgconfig["config"]["messageFrequency"]
+    for message in msgs:
+        time.sleep(1.0 / msg_frequency)
+        try:
+            # Set the whole string
+            s.sendall(bytes(message.to_string(), 'utf-8'))
+            print("message sent: %s" % message.to_string())
+            # receive data from client (data, addr)
+            d = s.recv(1024)
+            print('Server reply : %s' % d.decode('utf-8'))
+        except socket.error as msg:
+            print('Error Code : %s Message : %s ' % (str(msg[0]), msg[1]))
+            s.close()
+            sys.exit()
+    s.close()
+
+
+if __name__ == "__main__":
+    with open('sending_config.json', mode='r') as json_config:
+        msg_config = json.load(json_config)
+        host = msg_config["config"]["ip"]
+        port = msg_config["config"]["port"]
+        useTCP = msg_config["config"]["useTCP"]
+        sendContinuous = msg_config["config"]["sendContinuous"]
+        print("Using TCP: %s" % str(useTCP))
+        print("Waiting for response: %s" % str(sendContinuous))
+        if useTCP:
+            send_with_tcp(msg_config, host, port)
+        else:
+            send_with_udp(msg_config, host, port)

Tools/boringNetworkTool/sending_config.json

@@ -0,0 +1,54 @@
+{
+  "config": {
+    "ip": "localhost",
+    "port": 8888,
+    "useTCP": false,
+    "sendContinuous": true,
+    "messageFrequency": 5,
+    "messages": [
+      {
+        "data": [
+          5,
+          6,
+          7,
+          8,
+          9,
+          10
+        ]
+      },
+      {
+        "data": [
+          72,
+          54,
+          32,
+          87
+        ]
+      },
+      {
+        "data": [
+          100,
+          253,
+          0,
+          87
+        ]
+      },
+      {
+        "data": [
+          87
+        ]
+      },
+      {
+        "data": [
+          98,
+          56,
+          182,
+          78,
+          28,
+          37,
+          16,
+          82
+        ]
+      }
+    ]
+  }
+}

Tools/boringNetworkTool/tcp_server.py

@@ -0,0 +1,29 @@
+import socket
+import sys
+
+HOST = 'localhost'
+PORT = 8888
+
+try:
+    s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+    print('Socket created')
+except socket.error as msg:
+    print('Failed to create socket. Error Code : %s Message : %s' % (str(msg[0]), msg[1]))
+    sys.exit()
+
+try:
+    s.bind((HOST, PORT))
+except socket.error as msg:
+    print('Bind failed. Error Code : %s Message : %s' % (str(msg[0]), msg[1]))
+    sys.exit()
+
+
+s.listen(1)
+conn, addr = s.accept()
+while 1:
+    data = conn.recv(1024)
+    print("Data received: %s" % data.decode('utf-8'))
+    if not data:
+        break
+    conn.sendall(data)
+conn.close()

Tools/boringNetworkTool/udp_server.py

@@ -0,0 +1,32 @@
+import socket
+import sys
+
+HOST = 'localhost'
+PORT = 8888
+
+try:
+    s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
+    print('Socket created')
+except socket.error as msg:
+    print('Failed to create socket. Error Code : %s Message : %s' % (str(msg[0]), msg[1]))
+    sys.exit()
+
+try:
+    s.bind((HOST, PORT))
+except socket.error as msg:
+    print('Bind failed. Error Code : %s Message : %s' % (str(msg[0]), msg[1]))
+    sys.exit()
+
+while 1:
+    d = s.recvfrom(1024)
+    data = d[0]
+    addr = d[1]
+    if not data:
+        break
+
+    print("Data received: %s" % data.decode('utf-8'))
+    reply = 'OK... %s' % data.decode('utf-8')
+    s.sendto(bytes(reply, 'utf-8'), addr)
+    print('Message[%s:%s] - %s' % (addr[0], str(addr[1]), data.decode('utf-8').strip()))
+
+s.close()