Commit 5bc8ae7eb4551759e46280b098e8e739c7c6b977
tidy, and fix things
Dominic Tarr committed on 7/20/2017, 11:13:17 AMParent: bd5e4e2882df1a2c3e0823ff27646e6c18fc90d3
Files changed
index.js | changed |
irc.js | changed |
index.js | |||
---|---|---|---|
@@ -1,4 +1,5 @@ | |||
1 … | +'use strict' | ||
1 | 2 … | var ssb = require('./ssb') | |
2 | 3 … | var IRC = require('./irc') | |
3 | 4 … | var pull = require('pull-stream') | |
4 | 5 … | //this should just wrap the stuff in util.js | |
@@ -23,26 +24,24 @@ | |||
23 | 24 … | ssb.render(note, ssb.link(note.id, config)) | |
24 | 25 … | ) | |
25 | 26 … | } | |
26 | 27 … | ||
27 | - function next () { | ||
28 … | + function next (err, arg) { | ||
28 | 29 … | if(--n) return | |
29 | 30 … | //XXX: properly persist state with a flumeview? | |
30 | - console.log("STATE", state) | ||
31 | 31 … | ||
32 | 32 … | //make sure we have joined every channel | |
33 | 33 … | for(var k in state.channels) { | |
34 | 34 … | var channel = state.channels[k] === true ? k : state.channels[k] | |
35 | - console.log("JOIN", channel) | ||
36 | 35 … | IRC.join(irc, channel) | |
37 | 36 … | } | |
38 | 37 … | ||
39 | 38 … | //only notify about live posts. | |
40 | 39 … | //this may cut out if the connection to IRC drops | |
41 | - //though, since | ||
40 … | + //it should reconnect, but messages while disconnecting will be dropped. | ||
42 | 41 … | ||
43 | 42 … | pull( | |
44 | - sbot.createLogStream({live: true}), | ||
43 … | + sbot.createLogStream({live: true, old: false}), | ||
45 | 44 … | pull.drain(function (msg) { | |
46 | 45 … | if(msg.sync) return | |
47 | 46 … | var a = ssb.match(state, msg) | |
48 | 47 … | if(a.length) | |
@@ -53,5 +52,16 @@ | |||
53 | 52 … | } | |
54 | 53 … | ||
55 | 54 … | ||
56 | 55 … | ||
56 … | +if(!module.parent) { | ||
57 … | + require('ssb-client')(function (err, sbot) { | ||
58 … | + exports.init(sbot, require('ssb-config')) | ||
59 … | + }) | ||
57 | 60 … | ||
61 … | +} | ||
62 … | + | ||
63 … | + | ||
64 … | + | ||
65 … | + | ||
66 … | + | ||
67 … | + |
irc.js | ||
---|---|---|
@@ -1,7 +1,14 @@ | ||
1 | 1 … | var IRC = module.exports = function (config, cb) { |
2 … | + | |
2 | 3 … | var IRC = require('node-irc') |
3 | 4 … | var conf = config.irc || {} |
5 … | + console.log( | |
6 … | + "CONNECT", | |
7 … | + conf.host || 'irc.freenode.net', | |
8 … | + conf.port || 6667, | |
9 … | + conf.name || 'ssbbot_' | |
10 … | + ) | |
4 | 11 … | var irc = new IRC( |
5 | 12 … | conf.host || 'irc.freenode.net', |
6 | 13 … | conf.port || 6667, |
7 | 14 … | conf.name || 'ssbbot' |
@@ -10,14 +17,15 @@ | ||
10 | 17 … | irc.connect() |
11 | 18 … | irc.client.on('error', reconnect) |
12 | 19 … | irc.client.on('close', reconnect) |
13 | 20 … | var retry = false |
14 | - function reconnect () { | |
21 … | + function reconnect (err) { | |
22 … | + console.log('reconnect...', err) | |
15 | 23 … | if(retry) return |
16 | 24 … | retry = true |
17 | 25 … | setTimeout(connect, 10e3) |
18 | 26 … | } |
19 | - }) | |
27 … | + })() | |
20 | 28 … | irc.on('ready', cb) |
21 | 29 … | irc.on('error', function () { |
22 | 30 … | |
23 | 31 … | }) |
Built with git-ssb-web