1 files changed, 13 insertions, 41 deletions
diff --git a/app.js b/app.js
index 3beba3e..cfa6af0 100644
--- a/app.js
+++ b/app.js
@@ -1,3 +1,6 @@
+
+
+
 var screen = h('div', {id: 'screen'})
 document.body.appendChild(screen)
 
@@ -16,7 +19,6 @@ if (!localStorage['subscribees']) {
   localStorage['subscribees'] = JSON.stringify(subscribees)
 }
 
-
 document.body.appendChild(navbar)
 
 function compose (keys, opts) {
@@ -169,46 +171,8 @@ function route () {
       }
     }
 
-    var ws = new WebSocket('ws://bogbook.com/' + src)
-
-    var clientLog = {
-      publicKey: src
-    }
-
-    if (localStorage[src]) {
-      clientLog.log = JSON.parse(localStorage[src])
-    } else {
-      clientLog.log = []
-    }
-
-    ws.onopen = function () {
-      ws.send(JSON.stringify(clientLog))
-    }
-
-    ws.onmessage = function (ev) {
-      var serverData = JSON.parse(ev.data)
-      if (serverData.log.length > clientLog.log.length) {
-
-        // update the log of the id
-        localStorage[src] = JSON.stringify(serverData.log)
-
-        // contact new items from the log onto the client's log of everything
-        var num = serverData.log.length - clientLog.log.length
-        var diff = serverData.log.slice(0, num)
-
-        if (localStorage['log']) {
-          var oldLog = JSON.parse(localStorage['log'])
-        } else {
-          var oldLog = []
-        }
-
-        var newLog = diff.concat(oldLog)
-        localStorage['log'] = JSON.stringify(newLog)
-
-        location.reload()
-      }
-    }
-
+    requestFeed(src, 'ws://bogbook.com/')    
+    
     if (localStorage[src]) {
       var log = JSON.parse(localStorage[src])
       for (var i=0; i < log.length; i++) {
@@ -233,6 +197,14 @@ function route () {
 
   else {
     compose(keys)
+
+    var subscribees = JSON.parse(localStorage['subscribees'])
+
+    console.log(subscribees)
+    for (i = 0; i < subscribees.length; i++) {
+      requestFeed(subscribees[i], 'ws://bogbook.com/')
+    }
+
     if (localStorage['log']) {
       var log = JSON.parse(localStorage['log'])
       for (var i=0; i < log.length; i++) {