Commit 6e33f07845645357ffa0cc0627d468370589424b
get most important plugins working
Dominic Tarr committed on 12/10/2016, 5:24:41 PMParent: 2f4909ea8e4b5eadece02b7fa5eefa11a02a83b1
Files changed
| plugins/friends.js | changed |
| plugins/invite.js | changed |
| plugins/replicate.js | changed |
| plugins/friends.js | ||
|---|---|---|
| @@ -33,9 +33,10 @@ | ||
| 33 | 33 … | var g = null |
| 34 | 34 … | |
| 35 | 35 … | var index = sbot._flumeUse('friends', Reduce(1, function (g, rel) { |
| 36 | 36 … | if(!g) g = {} |
| 37 | - G.addEdge(g, rel.from, rel.to, rel.value) | |
| 37 … | + | |
| 38 … | + G.addEdge(g, rel.from, rel.to, rel.value) | |
| 38 | 39 … | return g |
| 39 | 40 … | }, function (data) { |
| 40 | 41 … | if(data.value.content.type === 'contact' && ref.isFeed(data.value.content.contact)) |
| 41 | 42 … | return { |
| @@ -47,22 +48,22 @@ | ||
| 47 | 48 … | |
| 48 | 49 … | return { |
| 49 | 50 … | |
| 50 | 51 … | get: function (opts, cb) { |
| 51 | - console.log('friends.get', opts, cb) | |
| 52 | 52 … | index.get(null, cb || opts) |
| 53 | 53 … | }, |
| 54 | 54 … | |
| 55 | 55 … | createFriendStream: valid.source(function (opts) { |
| 56 | 56 … | opts = opts || {} |
| 57 | 57 … | var start = opts.start || sbot.id |
| 58 | - var reachable = {}, g = {} | |
| 58 … | + var reachable | |
| 59 | 59 … | return pull( |
| 60 | 60 … | index.stream(opts), |
| 61 | 61 … | FlatMap(function (v) { |
| 62 | 62 … | var out = [] |
| 63 | 63 … | if(!v) return [] |
| 64 | 64 … | if(v.from && v.to) { |
| 65 … | + G.addEdge(g, v.from, v.to, v.value) | |
| 65 | 66 … | var _reachable = G.hops(g, start, 0, opts.hops || 3, reachable) |
| 66 | 67 … | for(var k in _reachable) { |
| 67 | 68 … | if(reachable[k] == null) |
| 68 | 69 … | out.push({id: k, hops: reachable[k] = _reachable[k]}) |
| @@ -84,20 +85,14 @@ | ||
| 84 | 85 … | }, 'createFriendStreamOpts?'), |
| 85 | 86 … | |
| 86 | 87 … | hops: function (opts, cb) { |
| 87 | 88 … | opts = opts || {} |
| 89 … | + if(isString(opts)) | |
| 90 … | + opts = {start: opts} | |
| 88 | 91 … | index.get(null, function (err, g) { |
| 89 | 92 … | if(err) cb(err) |
| 90 | 93 … | else cb(null, G.hops(g, opts.start || sbot.id, 0, opts.hops || 3)) |
| 91 | 94 … | }) |
| 92 | 95 … | } |
| 93 | 96 … | } |
| 94 | 97 … | } |
| 95 | 98 … | |
| 96 | - | |
| 97 | - | |
| 98 | - | |
| 99 | - | |
| 100 | - | |
| 101 | - | |
| 102 | - | |
| 103 | - | |
| plugins/invite.js | ||
|---|---|---|
| @@ -108,9 +108,11 @@ | ||
| 108 | 108 … | codesDB.get(rpc.id, function(err, invite) { |
| 109 | 109 … | if(err) return cb(err) |
| 110 | 110 … | |
| 111 | 111 … | // check if we're already following them |
| 112 | - server.friends.all('follow', function(err, follows) { | |
| 112 … | + server.friends.get(function (err, follows) { | |
| 113 … | +// server.friends.all('follow', function(err, follows) { | |
| 114 … | +// if(hops[req.feed] == 1) | |
| 113 | 115 … | if (follows && follows[server.id] && follows[server.id][req.feed]) |
| 114 | 116 … | return cb(new Error('already following')) |
| 115 | 117 … | |
| 116 | 118 … | // although we already know the current feed |
| plugins/replicate.js | ||
|---|---|---|
| @@ -115,10 +115,13 @@ | ||
| 115 | 115 … | function localPeers () { |
| 116 | 116 … | if(!sbot.gossip) return |
| 117 | 117 … | sbot.gossip.peers() |
| 118 | 118 … | .forEach(function (e) { |
| 119 | - if(to_send[e.key] == null) | |
| 120 | - addPeer({id: e.key, sequence: 0}) | |
| 119 … | + if(to_send[e.key] == null) { | |
| 120 … | + sbot.latestSequence(e.key, function (err, seq) { | |
| 121 … | + addPeer({id: e.key, sequence: seq}) | |
| 122 … | + }) | |
| 123 … | + } | |
| 121 | 124 … | }) |
| 122 | 125 … | } |
| 123 | 126 … | |
| 124 | 127 … | //also request local peers. |
| @@ -154,10 +157,10 @@ | ||
| 154 | 157 … | if(data.sync) return cb(null, S = data) |
| 155 | 158 … | var id = data.id || data |
| 156 | 159 … | sbot.latestSequence(id, function (err, seq) { |
| 157 | 160 … | cb(null, { |
| 158 | - id: id, sequence: err ? 0 : toSeq(seq) | |
| 159 | - }) | |
| 161 … | + id: id, sequence: err ? 0 : toSeq(seq) | |
| 162 … | + }) | |
| 160 | 163 … | }) |
| 161 | 164 … | }, 32), |
| 162 | 165 … | pull.drain(addPeer) |
| 163 | 166 … | ) |
| @@ -192,14 +195,14 @@ | ||
| 192 | 195 … | debounce.set() |
| 193 | 196 … | pull( |
| 194 | 197 … | rpc.createHistoryStream({ |
| 195 | 198 … | id: upto.id, |
| 196 | - seq: (upto.sequence || upto.seq || 0) + 1, | |
| 199 … | + sequence: (upto.sequence || upto.seq || 0) + 1, | |
| 197 | 200 … | live: true, |
| 198 | 201 … | keys: false |
| 199 | 202 … | }), |
| 200 | 203 … | sbot.createWriteStream(function (err) { |
| 201 | - if(err) console.error(err.stack) | |
| 204 … | + if(err) console.error(err.message) | |
| 202 | 205 … | |
| 203 | 206 … | feeds-- |
| 204 | 207 … | debounce.set() |
| 205 | 208 … | }) |
| @@ -221,13 +224,4 @@ | ||
| 221 | 224 … | |
| 222 | 225 … | |
| 223 | 226 … | |
| 224 | 227 … | |
| 225 | - | |
| 226 | - | |
| 227 | - | |
| 228 | - | |
| 229 | - | |
| 230 | - | |
| 231 | - | |
| 232 | - | |
| 233 | - | |
Built with git-ssb-web