making some progress...

1 files changed, 37 insertions, 1 deletions

diff --git a/server.js b/server.js
index 377aea3..a6583b7 100644
--- a/server.js
+++ b/server.js
@@ -21,7 +21,43 @@ var wserver = new WebSocket.Server({ port: 8080 })
 
 wserver.on('connection', function (ws) {
   ws.on('message', function (message) {
-    console.log(message)
+    var data = JSON.parse(message)
+    console.log(data)
+
+    // initial req/res contains a sequence number
+    if (data.seq) {
+      if (fs.existsSync(__dirname + '/bogs/' + data.feed)) {
+        fs.readFile(__dirname + '/bogs/' + data.feed, 'UTF-8', function (err, data) {
+          if (data) {
+            var log = JSON.parse(data)
+            console.log(log)
+          }
+        })
+      } else {
+        var res = {
+          feed: data.feed,
+          seq: null
+        }
+        console.log(res)
+        ws.send(JSON.stringify(res))
+      }
+
+    }
+
+    // if the client has a longer log, it'll send one for the server to save
+    if (data.log) {
+      console.log(data)
+      if (fs.existsSync(__dirname + '/bogs/' + data.feed)) {
+        var log = JSON.parse(fs.readFileSync(__dirname + '/bogs/' + data.feed))
+        console.log(log)
+
+      } else {
+        fs.writeFile(__dirname + '/bogs/' + data.feed, JSON.stringify(data.log), function (err, success) {
+          console.log('saved ' + data.feed + ' sent by ' + data.requester)
+        })
+      }
+    }
+
   })
 })