Files: 0ddd16f4238e194a83dc7a754d0338b1fad780ba / bin.js
5182 bytesRaw
1 | |
2 | |
3 | var fs = require('fs') |
4 | var path = require('path') |
5 | var pull = require('pull-stream') |
6 | var toPull = require('stream-to-pull-stream') |
7 | var File = require('pull-file') |
8 | var explain = require('explain-error') |
9 | var ssbKeys = require('ssb-keys') |
10 | var stringify = require('pull-stringify') |
11 | var createHash = require('multiblob/util').createHash |
12 | var minimist = require('minimist') |
13 | var muxrpcli = require('muxrpcli') |
14 | var cmdAliases = require('./lib/cli-cmd-aliases') |
15 | var ProgressBar = require('./lib/progress') |
16 | var packageJson = require('./package.json') |
17 | |
18 | //get config as cli options after --, options before that are |
19 | //options to the command. |
20 | var argv = process.argv.slice(2) |
21 | var i = argv.indexOf('--') |
22 | var conf = argv.slice(i+1) |
23 | argv = ~i ? argv.slice(0, i) : argv |
24 | |
25 | var network = 'ssb' |
26 | //var network = 'decent' |
27 | //var network = 'testnet' |
28 | |
29 | var config = require('./config/inject')(network) |
30 | |
31 | var keys = ssbKeys.loadOrCreateSync(path.join(config.path, 'secret')) |
32 | if(keys.curve === 'k256') |
33 | throw new Error('k256 curves are no longer supported,'+ |
34 | 'please delete' + path.join(config.path, 'secret')) |
35 | |
36 | var manifestFile = path.join(config.path, 'manifest.json') |
37 | |
38 | if (argv[0] == 'server') { |
39 | console.log('my key ID:', keys.public) |
40 | |
41 | // special server command: |
42 | // import sbot and start the server |
43 | |
44 | var createSbot = require('./') |
45 | .use(require('./plugins/plugins')) |
46 | .use(require('./plugins/master')) |
47 | .use(require('./plugins/gossip')) |
48 | .use(require('./plugins/replicate')) |
49 | .use(require('ssb-friends')) |
50 | .use(require('ssb-blobs')) |
51 | .use(require('./plugins/invite')) |
52 | .use(require('./plugins/local')) |
53 | .use(require('./plugins/logging')) |
54 | .use(require('./query')) |
55 | .use(require('ssb-links')) |
56 | .use(require('ssb-search')) |
57 | .use(require('ssb-backlinks')) |
58 | .use(require('./decent-ws')) |
59 | .use(require('ssb-ebt')) |
60 | .use({ |
61 | name: 'serve', |
62 | version: '1.0.0', |
63 | init: function (sbot) { |
64 | sbot.ws.use(function (req, res, next) { |
65 | res.setHeader('Access-Control-Allow-Origin', '*') |
66 | var send = config |
67 | delete send.keys // very important to keep this, as it removes the server keys from the config before broadcast |
68 | send.address = sbot.ws.getAddress() |
69 | sbot.invite.create({modern: true}, function (err, cb) { |
70 | send.invite = cb |
71 | }) |
72 | //if(req.url == '/') |
73 | // res.end(mvdClient) |
74 | if(req.url == '/get-config') |
75 | res.end(JSON.stringify(send)) |
76 | else next() |
77 | }) |
78 | } |
79 | }) |
80 | |
81 | |
82 | // add third-party plugins |
83 | //require('./plugins/plugins').loadUserPlugins(createSbot, config) |
84 | |
85 | // start server |
86 | |
87 | config.keys = keys |
88 | var server = createSbot(config) |
89 | |
90 | // write RPC manifest to ~/.ssb/manifest.json |
91 | fs.writeFileSync(manifestFile, JSON.stringify(server.getManifest(), null, 2)) |
92 | |
93 | |
94 | ProgressBar(server.progress) |
95 | |
96 | } else { |
97 | |
98 | // normal command: |
99 | // create a client connection to the server |
100 | |
101 | // read manifest.json |
102 | var manifest |
103 | try { |
104 | manifest = JSON.parse(fs.readFileSync(manifestFile)) |
105 | } catch (err) { |
106 | throw explain(err, |
107 | 'no manifest file' |
108 | + '- should be generated first time server is run' |
109 | ) |
110 | } |
111 | |
112 | // connect |
113 | require('ssb-client')(keys, { |
114 | manifest: manifest, |
115 | port: config.port, |
116 | host: config.host||'localhost', |
117 | caps: config.caps, |
118 | key: config.key || keys.id |
119 | }, function (err, rpc) { |
120 | if(err) { |
121 | if (/could not connect/.test(err.message)) { |
122 | console.log('Error: Could not connect to the scuttlebot server.') |
123 | console.log('Use the "server" command to start it.') |
124 | if(config.verbose) throw err |
125 | process.exit(1) |
126 | } |
127 | throw err |
128 | } |
129 | |
130 | // add aliases |
131 | for (var k in cmdAliases) { |
132 | rpc[k] = rpc[cmdAliases[k]] |
133 | manifest[k] = manifest[cmdAliases[k]] |
134 | } |
135 | |
136 | // add some extra commands |
137 | manifest.version = 'async' |
138 | manifest.config = 'sync' |
139 | rpc.version = function (cb) { |
140 | console.log(require('./package.json').version) |
141 | cb() |
142 | } |
143 | rpc.config = function (cb) { |
144 | console.log(JSON.stringify(config, null, 2)) |
145 | cb() |
146 | } |
147 | |
148 | // HACK |
149 | // we need to output the hash of blobs that are added via blobs.add |
150 | // because muxrpc doesnt support the `sink` callback yet, we need this manual override |
151 | // -prf |
152 | if (process.argv[2] === 'blobs.add') { |
153 | var filename = process.argv[3] |
154 | var source = |
155 | filename ? File(process.argv[3]) |
156 | : !process.stdin.isTTY ? toPull.source(process.stdin) |
157 | : (function () { |
158 | console.error('USAGE:') |
159 | console.error(' blobs.add <filename> # add a file') |
160 | console.error(' source | blobs.add # read from stdin') |
161 | process.exit(1) |
162 | })() |
163 | var hasher = createHash('sha256') |
164 | pull( |
165 | source, |
166 | hasher, |
167 | rpc.blobs.add(function (err) { |
168 | if (err) |
169 | throw err |
170 | console.log('&'+hasher.digest) |
171 | process.exit() |
172 | }) |
173 | ) |
174 | return |
175 | } |
176 | |
177 | // run commandline flow |
178 | muxrpcli(argv, manifest, rpc, config.verbose) |
179 | }) |
180 | } |
181 | |
182 | |
183 | |
184 | |
185 |
Built with git-ssb-web