Files: 52a6d8a8df089abd1131e52adf418fdf6595f98a / modules_extra / network.js
5857 bytesRaw
1 | const fs = require('fs') |
2 | // const { isVisible } = require('is-visible') |
3 | const h = require('../h') |
4 | const human = require('human-time') |
5 | |
6 | const { |
7 | Struct, Value, Dict, |
8 | dictToCollection, map: mutantMap, when, computed |
9 | } = require('@mmckegg/mutant') |
10 | |
11 | exports.needs = { |
12 | avatar_image_link: 'first', |
13 | avatar_name_link: 'first', |
14 | sbot_gossip_peers: 'first', |
15 | sbot_gossip_connect: 'first' |
16 | } |
17 | |
18 | exports.gives = { |
19 | menu_items: true, |
20 | builtin_tabs: true, |
21 | screen_view: true, |
22 | mcss: true |
23 | } |
24 | |
25 | //sbot_gossip_connect |
26 | //sbot_gossip_add |
27 | |
28 | |
29 | function legacyToMultiServer(addr) { |
30 | return 'net:'+addr.host + ':'+addr.port + '~shs:'+addr.key.substring(1).replace('.ed25519','') |
31 | } |
32 | |
33 | //on the same wifi network |
34 | function isLocal (peer) { |
35 | // don't rely on private ip address, because |
36 | // cjdns creates fake private ip addresses. |
37 | return ip.isPrivate(peer.host) && peer.type === 'local' |
38 | } |
39 | |
40 | |
41 | function getType (peer) { |
42 | return ( |
43 | isLongterm(peer) ? 'modern' |
44 | : isLegacy(peer) ? 'legacy' |
45 | : isInactive(peer) ? 'inactive' |
46 | : isUnattempted(peer) ? 'unattempted' |
47 | : 'other' //should never happen |
48 | ) |
49 | |
50 | //pub is running scuttlebot >=8 |
51 | //have connected successfully. |
52 | function isLongterm (peer) { |
53 | return peer.ping && peer.ping.rtt && peer.ping.rtt.mean > 0 |
54 | } |
55 | |
56 | //pub is running scuttlebot < 8 |
57 | //have connected sucessfully |
58 | function isLegacy (peer) { |
59 | return /connect/.test(peer.state) || (peer.duration && peer.duration.mean) > 0 && !isLongterm(peer) |
60 | } |
61 | |
62 | //tried to connect, but failed. |
63 | function isInactive (peer) { |
64 | return peer.stateChange && (peer.duration && peer.duration.mean == 0) |
65 | } |
66 | |
67 | //havn't tried to connect peer yet. |
68 | function isUnattempted (peer) { |
69 | return !peer.stateChange |
70 | } |
71 | } |
72 | |
73 | function origin (peer) { |
74 | return peer.source === 'local' ? 0 : 1 |
75 | } |
76 | |
77 | function round(n) { |
78 | return Math.round(n*100)/100 |
79 | } |
80 | |
81 | function duration (s) { |
82 | if(!s) return s |
83 | if (Math.abs(s) > 30000) |
84 | return round(s/60000)+'m' |
85 | else if (Math.abs(s) > 500) |
86 | return round(s/1000)+'s' |
87 | else |
88 | return round(s)+'ms' |
89 | } |
90 | |
91 | function peerListSort (a, b) { |
92 | var states = { |
93 | connected: 3, |
94 | connecting: 2 |
95 | } |
96 | |
97 | //types of peers |
98 | var types = { |
99 | modern: 4, |
100 | legacy: 3, |
101 | inactive: 2, |
102 | unattempted: 1, |
103 | other: 0 |
104 | } |
105 | |
106 | return ( |
107 | (states[b.state] || 0) - (states[a.state] || 0) |
108 | || origin(b) - origin(a) |
109 | || types[getType(b)] - types[getType(a)] |
110 | || b.stateChange - a.stateChange |
111 | ) |
112 | } |
113 | |
114 | function formatDate (time) { |
115 | return new Date(time).toString() |
116 | } |
117 | |
118 | function humanDate (time) { |
119 | return human(new Date(time)).replace(/minute/, 'min').replace(/second/, 'sec') |
120 | } |
121 | |
122 | exports.create = function (api) { |
123 | |
124 | return { |
125 | menu_items: () => h('a', {href: '#/network'}, '/network'), |
126 | builtin_tabs: () => ['/network'], |
127 | screen_view, |
128 | mcss: () => fs.readFileSync(__filename.replace(/js$/, 'mcss'), 'utf8') |
129 | } |
130 | |
131 | function screen_view (path) { |
132 | if (path !== '/network') return |
133 | |
134 | var peers = obs_gossip_peers(api) |
135 | |
136 | return h('div', { style: {'overflow':'auto'}, className: 'column scroller' }, [ |
137 | h('Network', [ |
138 | mutantMap(peers, peer => { |
139 | var { key, ping, source, state, stateChange } = peer |
140 | |
141 | return h('NetworkConnection', [ |
142 | h('section.avatar', [ |
143 | api.avatar_image_link(key()), |
144 | ]), |
145 | h('section.name', [ |
146 | api.avatar_name_link(key()), |
147 | ]), |
148 | h('section.type', [ |
149 | computed(peer, getType), |
150 | ]), |
151 | h('section.source', [ |
152 | h('label', 'source:'), |
153 | h('code', source) |
154 | ]), |
155 | h('section.state', [ |
156 | h('label', 'state:'), |
157 | h('i', { |
158 | className: computed(state, (state) => '-'+state) |
159 | }), |
160 | h('code', when(state, state, 'not connected')) |
161 | ]), |
162 | h('section.actions', [ |
163 | h('button', { |
164 | 'ev-click': () => { |
165 | api.sbot_gossip_connect(peer(), (err) => { |
166 | if(err) console.error(err) |
167 | else console.log('connected to', peer()) |
168 | }) |
169 | }}, |
170 | 'connect' |
171 | ) |
172 | ]), |
173 | h('section.time-ago', [ |
174 | h('div', |
175 | { title: computed(stateChange, formatDate) }, |
176 | [ computed(stateChange, humanDate) ] |
177 | ) |
178 | ]), |
179 | h('section.ping', [ |
180 | h('div.rtt', [ |
181 | h('label', 'rtt:'), |
182 | h('code', computed(ping.rtt.mean, duration)) |
183 | ]), |
184 | h('div.skew', [ |
185 | h('label', 'skew:'), |
186 | h('code', computed(ping.skew.mean, duration)) |
187 | ]), |
188 | ]), |
189 | h('section.address', [ |
190 | h('code', computed(peer, legacyToMultiServer)) |
191 | ]) |
192 | ]) |
193 | }) |
194 | ]) |
195 | ]) |
196 | } |
197 | } |
198 | |
199 | function obs_gossip_peers (api) { |
200 | var timer = null |
201 | var state = Dict({}, { |
202 | onListen: () => { |
203 | timer = setInterval(refresh, 5e3) |
204 | }, |
205 | onUnlisten: () => { |
206 | clearInterval(timer) |
207 | } |
208 | }) |
209 | |
210 | refresh() |
211 | |
212 | return dictToCollection.values(state) |
213 | |
214 | function refresh () { |
215 | api.sbot_gossip_peers((err, peers) => { |
216 | peers.forEach(data => { |
217 | var id = legacyToMultiServer(data) |
218 | var current = state.get(id) |
219 | if (!current) { |
220 | current = Peer() |
221 | current.set(data) |
222 | state.put(id, current) |
223 | } else { |
224 | current.set(data) |
225 | } |
226 | }) |
227 | }) |
228 | } |
229 | } |
230 | |
231 | function Peer () { |
232 | var peer = Struct({ |
233 | key: Value(), |
234 | ping: Struct({ |
235 | rtt: Struct({ |
236 | mean: Value() |
237 | }), |
238 | skew: Struct({ |
239 | mean: Value() |
240 | }) |
241 | }), |
242 | source: Value(), |
243 | state: Value(), |
244 | stateChange: Value() |
245 | }) |
246 | |
247 | return peer |
248 | } |
249 | |
250 |
Built with git-ssb-web