Commit 1b9093405deadf26da6cab9aefb5cdf7ec500421
Fix indention
Anders Rune Jensen committed on 9/19/2017, 12:37:43 PMParent: a1a4821bd547e1257c2506c9f0e0e5d0f93deb65
Files changed
index.js | changed |
index.js | ||
---|---|---|
@@ -9,40 +9,40 @@ | ||
9 | 9 … | .option('-f, --folder [value]', 'Folder for sharing') |
10 | 10 … | .parse(process.argv); |
11 | 11 … | |
12 | 12 … | require('ssb-client')((err, sbot) => { |
13 | - if (err) throw err; | |
13 … | + if (err) throw err; | |
14 | 14 … | |
15 | - console.log("Looking for dat links") | |
16 | - | |
17 | - pull( | |
18 | - sbot.createLogStream({ reverse: true, limit: 10000 }), | |
19 | - pull.filter((msg) => { | |
20 | - return !msg.value || | |
21 | - msg.value.content.type == 'post' && | |
22 | - typeof msg.value.content.text == "string" && | |
23 | - msg.value.content.text.indexOf("dat://") != -1 | |
24 | - }), | |
25 | - pull.collect((err, log) => { | |
26 | - if (err) throw err; | |
15 … | + console.log("Looking for dat links") | |
27 | 16 … | |
28 | - console.log("Found " + log.length) | |
17 … | + pull( | |
18 … | + sbot.createLogStream({ reverse: true, limit: 10000 }), | |
19 … | + pull.filter((msg) => { | |
20 … | + return !msg.value || | |
21 … | + msg.value.content.type == 'post' && | |
22 … | + typeof msg.value.content.text == "string" && | |
23 … | + msg.value.content.text.indexOf("dat://") != -1 | |
24 … | + }), | |
25 … | + pull.collect((err, log) => { | |
26 … | + if (err) throw err; | |
27 … | + | |
28 … | + console.log("Found " + log.length) | |
29 … | + | |
30 … | + log.forEach(msg => { | |
31 … | + uri.withinString(msg.value.content.text, (datLink) => { | |
32 … | + if (!datLink.startsWith("dat://")) return | |
33 … | + | |
34 … | + console.log("Saving to:", program.folder + "/" + datLink.substring(6)) | |
35 … | + | |
36 … | + Dat(program.folder + "/" + datLink.substring(6), { | |
37 … | + key: datLink | |
38 … | + }, function (err, dat) { | |
39 … | + if (err) throw err | |
29 | 40 … | |
30 | - log.forEach(msg => { | |
31 | - uri.withinString(msg.value.content.text, (datLink) => { | |
32 | - if (!datLink.startsWith("dat://")) return | |
33 | - | |
34 | - console.log("Saving to:", program.folder + "/" + datLink.substring(6)) | |
35 | - | |
36 | - Dat(program.folder + "/" + datLink.substring(6), { | |
37 | - key: datLink | |
38 | - }, function (err, dat) { | |
39 | - if (err) throw err | |
40 | - | |
41 | - console.log("sharing:", datLink) | |
42 | - dat.joinNetwork() | |
43 | - }) | |
44 | - }) | |
45 | - }) | |
41 … | + console.log("sharing:", datLink) | |
42 … | + dat.joinNetwork() | |
43 … | + }) | |
46 | 44 … | }) |
47 | - ) | |
45 … | + }) | |
46 … | + }) | |
47 … | + ) | |
48 | 48 … | }) |
Built with git-ssb-web