Merge pull request #1 from mangledbottles/datagram

Datagram Socket API

Initial solution utilized Socket.io which works on the TCP protocol and this assignment requires use of the UDP protocol.
This merge is an implementation of this assignment using the UDP protocol.

Author: mangledbottles

.dockerignore

@@ -0,0 +1 @@
+node_modules

App/index.html

@@ -0,0 +1,20 @@
+import dgram from 'dgram';
+import { Buffer } from 'buffer';
+const port: number = 8080;
+
+const message = Buffer.from('UDP IOT CONNETION DATA');
+const client = dgram.createSocket('udp4');
+
+client.on('message', (msg, info) => {
+  console.log(`Data received from server: ${msg.toString()}`);
+  console.log(`Received ${msg.length} bytes from ${info.address}:${info.port}\n`);
+});
+
+client.send(message, port, 'localhost', (err) => {
+  if (err) {
+    console.log('Error sending data to Server')
+    client.close();
+  } else {
+    console.log('Data sent to Server')
+  }
+});

Client.ts

@@ -0,0 +1,23 @@
+FROM node:16.10.0
+
+WORKDIR /
+
+COPY package*.json ./
+
+RUN npm install
+
+# Install Typescript dependecies
+RUN npm install -g ts-node typescript
+
+COPY . .
+
+ENV PORT=8081
+
+# HTTP Server Port
+EXPOSE 8081
+
+# UDP Datagram Server Port
+EXPOSE 8080/udp
+
+# Start Broker Server
+CMD [ "npm", "run", "server" ]

Dockerfile

@@ -0,0 +1,48 @@
+import dgram from "dgram";
+import express, { Application, Request, Response } from "express";
+
+const app: Application = express();
+const port: number = 8080;
+
+/** HTTP Server for checking status */
+app.get('/', (req: Request, res: Response) => {``
+    res.send({ message: 'Server is active', timestamp: new Date() }); 
+});
+
+const Server = dgram.createSocket('udp4');
+
+Server.on('error', (err) => {
+  console.log(`Server error:\n${err.stack}`);
+  Server.close();
+});
+
+/** Receive Messages */
+Server.on('message', (msg, rinfo) => {
+  console.log(`Server got: ${msg} from ${rinfo.address}:${rinfo.port}`);
+
+  Server.send(msg, rinfo.port, 'localhost', function (error) {
+    if (error) {
+      console.log(`Error sending data to Client #${rinfo.port}`)
+    } else {
+      console.log(`Data sent to Client #${rinfo.port}`);
+    }
+  });
+});
+
+/** Launch server and listen on given port */
+try {
+  Server.on('listening', () => {
+    const address = Server.address();
+    console.log(`Server listening ${address.address}:${address.port}`);
+  });
+
+  Server.bind(port, (): void => {
+    console.log(`UDP Datagram Server is active at http://localhost:${port}`);
+  });
+
+  app.listen(8081, (): void => {
+    console.log(`HTTP Server is active at http://localhost:8081`);
+  });
+} catch (error: any) {
+  console.error(`An error occurred with message ${error.toString()}`);
+}

Server.ts

@@ -0,0 +1 @@
+ docker run -p 8080:8080/udp 433be8938248

Server/Index.ts

@@ -6,7 +6,8 @@
   "scripts": {
     "start": "npm run dev",
     "build": "npm run clean && tsc",
-    "dev": "nodemon Index.ts",
+    "server": "nodemon Server.ts",
+    "client": "nodemon Client.ts",
     "dev-js": "nodemon Index.js",
     "clean": "rimraf ./dist",
     "reset": "git pull && git checkout . && npm i && npm run build"
@@ -20,12 +21,10 @@
   "devDependencies": {
     "@types/express": "^4.17.13",
     "@types/node": "^16.10.1",
-    "@types/socket.io": "^3.0.2",
     "nodemon": "^2.0.13",
     "typescript": "^4.4.3"
   },
   "dependencies": {
-    "express": "^4.17.1",
-    "socket.io": "^4.2.0"
+    "express": "^4.17.1"
   }
 }