Client and Server working

Author: chrisMYchen

Client.js

@@ -0,0 +1,89 @@
+'use strict';
+const WebSocket = require('ws');
+
+
+class Client {
+  constructor(serverUrl, key) {
+    //TODO: URL validation
+      this.serverUrl = serverUrl;
+      this.ws = undefined;
+      this.key = key;
+      this.opened = false;
+  }
+
+  connect() {
+    if (this.ws === undefined) {
+        this.ws = new WebSocket(this.serverUrl, {key: this.key});
+        console.log("new connection!");
+        return this.ws;
+    }
+    else {
+      console.log("else statement");
+      return this.ws;
+    }
+  }
+
+  sendMessageToServer(data){
+    if (this.opened) {
+      console.log("already opened");
+      this.ws.send(JSON.stringify(data));
+    }
+    else {
+      console.log("ahhhh");
+      this.ws.on('open', function open() {
+        this.send(JSON.stringify(data));
+      });
+    }
+  }
+
+
+  open() {
+    let myWS = this;
+    this.ws.on('open', function open(openevent) {
+        myWS.opened = true;
+        console.log('opened');
+        console.log(openevent);
+    });
+  }
+
+  logResponseEvents(){
+    this.ws.on('message', function incoming(data, flags) {
+      console.log(data);
+    });
+  }
+
+  close() {
+    if (this.ws !== undefined) {
+        this.ws.close();
+        this.ws = undefined;
+    }
+  }
+
+}
+
+module.exports = Client;
+// var myRippledClient = new Client('wss://s1.ripple.com:443');
+// myRippledClient.connect();
+// const closedLedgerData = {
+//   "id": "Example watch for new validated ledgers",
+//   "command": "subscribe",
+//   "streams": ["ledger"]
+// };
+// myRippledClient.subscribeToEvents(closedLedgerData);
+// myRippledClient.listenEvents();
+//
+function sleep (time) {
+  return new Promise((resolve) => setTimeout(resolve, time));
+}
+
+
+
+let myClient = new Client('ws://localhost:8080', 'Christopher');
+myClient.connect();
+myClient.open();
+myClient.logResponseEvents();
+myClient.sendMessageToServer("test data");
+sleep(500).then(() => {
+  console.log("sleeped");
+  myClient.sendMessageToServer("second slow message wow");
+});

RippleNode.js

@@ -0,0 +1,34 @@
+'use strict';
+const WebSocket = require('ws');
+const express = require('express');
+const http = require('http');
+const Server = require('./Server');
+const Client = require('./Client');
+class RippleNode {
+  constructor(myPort, id){
+    this.port = myPort;
+    this.id = id;
+    this.server = new Server(this.port);
+    this.connections = [];
+  }
+  //list of urls
+  connect(urls) {
+    urls.forEach(function createClientConnection(url) {
+      let myClient = new Client(url, id);
+      connections.push(myClient);
+    });
+  }
+
+  //when node acts as client
+  logAllResponses() {
+    this.connections.forEach(function listen(client) {
+      client.logResponseEvents();
+    })
+  }
+
+
+}
+
+
+var argv = require('minimist')(process.argv.slice(2));
+console.dir(argv);

Server.js

@@ -0,0 +1,45 @@
+'use strict';
+const WebSocket = require('ws');
+const express = require('express');
+const http = require('http');
+
+class Server {
+    constructor(myPort) {
+      this.port = myPort;
+      this.server = new WebSocket.Server({port: this.port});
+    }
+
+    listen() {
+      let my_obj = this;
+      this.server.on('connection', function connection(ws) {
+        ws.on('message', function incoming(message) {
+          my_obj.processMessage(message);
+          // console.log(ws);
+          my_obj.broadcast("new client connected!");
+        });
+        my_obj.sendMessage('hello!', ws);
+      });
+    }
+
+    processMessage(message) {
+      //based on message type, we do something different
+      console.log('received: %s', message);
+    }
+
+    sendMessage(message, ws) {
+      ws.send(message);
+    }
+
+    broadcast(message) {
+      this.server.clients.forEach(function each(client) {
+        if (client.readyState === WebSocket.OPEN) {
+          client.send(message);
+        }
+      });
+    }
+};
+
+module.exports = Server;
+//
+let myServer = new Server(8080);
+myServer.listen();