diff options
Diffstat (limited to 'gossip.js')
-rw-r--r-- | gossip.js | 23 |
1 files changed, 5 insertions, 18 deletions
@@ -1,10 +1,10 @@ -function sync (src, server, keys) { +function sync (src, keys) { + var server = 'ws://localhost:8080/' + var ws = new WebSocket(server + src) - console.log(server) - console.log(src) - console.log(keys.publicKey) - + console.log('SYNCING') + bog(src).then(srclog => { if (srclog) { open(srclog[0]).then(msg => { @@ -13,43 +13,30 @@ function sync (src, server, keys) { seq: msg.seq, requester: keys.publicKey } - console.log(req) ws.onopen = function () { ws.send(JSON.stringify(req)) } ws.onmessage = function (message) { var serverMsg = JSON.parse(message.data) - console.log(serverMsg) if (msg.seq === serverMsg.seq) { - console.log('DO NOTHING') } else if (msg.seq > serverMsg.seq) { - console.log('SENDING') var diff = msg.seq - serverMsg.seq - console.log(diff) var sendlog = srclog.slice(0, diff) - console.log(sendlog) var send = { src, log: sendlog, requester: keys.publicKey } - console.log(send) ws.send(JSON.stringify(send)) } else { if (serverMsg.log) { - console.log('RECEIVING') var newlog = serverMsg.log.concat(srclog) - console.log('NEWLOG') - localforage.setItem(src, newlog).then(function () {regenerate()}) - - console.log(newlog) } } } }) } else { - console.log('NO LOG!') var req = { src, seq: null, |