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, msgID, isExtendedID, data):
+        self.msgID = msgID
+        self.isExtendedID = isExtendedID
+        self.data = data
+    def toString(self):
+        return "" + str(self.msgID) + "\n" + str(self.isExtendedID) + "\n" + str(self.data)
+
+def createMessages(raw_messages):
+    msgs = []
+    for message in raw_messages:
+        msgs.append(Message(msgID=message["msgId"],
+                            isExtendedID=message["isExtendedId"],
+                            data=message["data"]
+                            ))
+    return msgs
+
+
+def sendWithUDP(msg_config, host, port):
+    try:
+        s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
+    except socket.error:
+        print('Failed to create socket')
+        sys.exit()
+    msgs = createMessages(msg_config["config"]["messages"])
+    msg_frequency = msg_config["config"]["messageFrequency"]
+    for message in msgs:
+        time.sleep(1.0 / msg_frequency)
+        try:
+            # Set the whole string
+            s.sendto(bytes(message.toString(), 'utf-8'), (host, port))
+            print("message sent:" + message.toString())
+            # receive data from client (data, addr)
+            d = s.recvfrom(1024)
+            reply = d[0]
+            addr = d[1]
+            print('Server reply : ' + reply.decode('utf-8'))
+        except socket.error as msg:
+            print('Error Code : ' + str(msg[0]) + ' Message ' + msg[1])
+            sys.exit()
+
+def sendWithTCP(msg_config, 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 = createMessages(msg_config["config"]["messages"])
+    msg_frequency = msg_config["config"]["messageFrequency"]
+    for message in msgs:
+        time.sleep(1.0 / msg_frequency)
+        try:
+            # Set the whole string
+            s.sendall(bytes(message.toString(), 'utf-8'))
+            print("message sent:" + message.toString())
+            # receive data from client (data, addr)
+            d = s.recv(1024)
+            print('Server reply : ' + d.decode('utf-8'))
+        except socket.error as msg:
+            print('Error Code : ' + str(msg[0]) + ' Message ' + 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"]
+        print("Using TCP: " + str(useTCP))
+        if useTCP:
+            sendWithTCP(msg_config, host, port)
+        else:
+            sendWithUDP(msg_config, host, port)

Tools/boringNetworkTool/sending_config.json

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

Tools/boringNetworkTool/tcp_server.py

@@ -0,0 +1,29 @@
+import socket
+import sys
+
+HOST = ''
+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 : ' + str(msg[0]) + ' Message ' + msg[1])
+    sys.exit()
+
+try:
+    s.bind((HOST, PORT))
+except socket.error as msg:
+    print('Bind failed. Error Code : ' + str(msg[0]) + ' Message ' + msg[1])
+    sys.exit()
+
+
+s.listen(1)
+conn, addr = s.accept()
+while 1:
+    data = conn.recv(1024)
+    print("Data received: " + 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 = ''
+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 : ' + str(msg[0]) + ' Message ' + msg[1])
+    sys.exit()
+
+try:
+    s.bind((HOST, PORT))
+except socket.error as msg:
+    print('Bind failed. Error Code : ' + str(msg[0]) + ' Message ' + msg[1])
+    sys.exit()
+
+while 1:
+    d = s.recvfrom(1024)
+    data = d[0]
+    addr = d[1]
+    if not data:
+        break
+
+    print("Data received: " + data.decode('utf-8'))
+    reply = 'OK...' + data.decode('utf-8')
+    s.sendto(bytes(reply, 'utf-8'), addr)
+    print('Message[' + addr[0] + ':' + str(addr[1]) + '] - ' + data.decode('utf-8').strip())
+
+s.close()