Further comments for explanation

Author: mangledbottles

Client.ts

@@ -1,22 +1,19 @@
+/** Import dependecies */
 import dgram from 'dgram';
 import { Buffer } from 'buffer';
+
 const socketPort: number = 8080;
+const message = Buffer.from('UDP CONNETION DATA');
 
+/** Initialise UDP Socket */
 const client = dgram.createSocket('udp4');
-const message = Buffer.from('UDP IOT CONNETION DATA');
 
-/** Listen and handle all incoming messages */
+/** Listen and handle incoming messages from Server */
 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.on('listening', function () {
-  var address = client.address();
-  console.log('UDP Client listening on ' + address.address + ":" + address.port);
-  client.setBroadcast(true);
-});
-
 /** Send message to Server */
 client.send(message, socketPort, 'localhost', (err) => {
   if (err) {
@@ -27,16 +24,21 @@ client.send(message, socketPort, 'localhost', (err) => {
   }
 });
 
-let intervalCount: number = 0;
-function sendMessage() {
-  client.send(Buffer.from(`Connection number ${intervalCount}`), socketPort, 'localhost', (err) => {
-    if (err) {
-      console.log('Error sending data to Server')
-      client.close();
-    } else {
-      console.log('Data sent to Server')
-    }
-  });
-}
 
-// setInterval(sendMessage, 5000);
+/** 
+ * Send a message to the Server in an interval of every 5 seconds
+ * Enable this option by uncommenting
+ */
+
+// let intervalCount: number = 0;
+// function sendMessage() {
+//   client.send(Buffer.from(`Connection number ${intervalCount}`), socketPort, 'localhost', (err) => {
+//     if (err) {
+//       console.log('Error sending data to Server')
+//       client.close();
+//     } else {
+//       console.log('Data sent to Server')
+//     }
+//   });
+// }
+// setInterval(sendMessage, 5000); 

Server.ts

@@ -1,3 +1,5 @@
+
+/** Import dependecies */
 import dgram from "dgram";
 import express, { Application, Request, Response } from "express";
 import * as readline from "readline";
@@ -20,7 +22,7 @@ Server.on('error', (err) => {
   Server.close();
 });
 
-/** Setup readline */
+/** Setup readline functionalities */
 const rl = readline.createInterface({
   input: process.stdin,
   output: process.stdout
@@ -42,7 +44,7 @@ async function handleServerInput() {
 }
 
 
-/** Receive Messages */
+/** Receive Messages from Client */
 let messagesCount = 0;
 Server.on('message', (msg, rinfo) => {
   console.log(`Server got: ${msg} from ${rinfo.address}:${rinfo.port}`);
@@ -62,7 +64,7 @@ Server.on('message', (msg, rinfo) => {
 });
 
 
-/** Periodically Broadcast Information from Server to all Clients */
+/** Broadcast Information from Server to all Clients */
 interface Client {
   address: string;
   port: number;
@@ -103,7 +105,7 @@ try {
   });
 
   Server.bind(socketPort, (): void => {
-    handleServerInput(); // used for broadcasting messages to Clients
+    handleServerInput(); // used to read IO from CLI and broadcast the message to Clients
     console.log(`UDP Datagram Server is active at http://localhost:${socketPort}`);
   });