git ssb

1
#! /usr/bin/env node
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
16
//get config as cli options after --, options before that are
17
//options to the command.
18
var argv = process.argv.slice(2)
19
var i = argv.indexOf('--')
20
var conf = argv.slice(i+1)
21
argv = ~i ? argv.slice(0, i) : argv
22
23
var config = require('ssb-config/inject')(process.env.ssb_appname, minimist(conf))
24
25
var keys = ssbKeys.loadOrCreateSync(path.join(config.path, 'secret'))
26
if(keys.curve === 'k256')
27
  throw new Error('k256 curves are no longer supported,'+
28
                  'please delete' + path.join(config.path, 'secret'))
29
30
var manifestFile = path.join(config.path, 'manifest.json')
31
32
if (argv[0] == 'server') {
33
34
  // special server command:
35
  // import sbot and start the server
36
37
  var createSbot = require('./')
38
    .use(require('./plugins/plugins'))
39
    .use(require('./plugins/master'))
40
    .use(require('./plugins/gossip'))
41
    .use(require('./plugins/friends'))
42
//    .use(require('./plugins/friends2'))
43
    .use(require('./plugins/replicate'))
44
    .use(require('ssb-blobs'))
45
//    .use(require('./plugins/invite'))
46
//    .use(require('./plugins/block'))
47
    .use(require('./plugins/local'))
48
    .use(require('./plugins/logging'))
49
    .use(require('./plugins/private'))
50
    .use(require('ssb-query'))
51
    .use(require('ssb-links'))
52
    .use(require('ssb-ws'))
53
//
54
  // start server
55
56
  config.keys = keys
57
  var server = createSbot(config)
58
59
  // write RPC manifest to ~/.ssb/manifest.json
60
  fs.writeFileSync(manifestFile, JSON.stringify(server.getManifest(), null, 2))
61
} else {
62
63
  // normal command:
64
  // create a client connection to the server
65
66
  // read manifest.json
67
  var manifest
68
  try {
69
    manifest = JSON.parse(fs.readFileSync(manifestFile))
70
  } catch (err) {
71
    throw explain(err,
72
      'no manifest file'
73
      + '- should be generated first time server is run'
74
    )
75
  }
76
77
  // connect
78
  require('ssb-client')(keys, {
79
    manifest: manifest,
80
    port: config.port,
81
    host: config.host||'localhost',
82
    key: config.key || keys.id
83
  }, function (err, rpc) {
84
    if(err) {
85
      if (/could not connect/.test(err.message)) {
86
        console.log('Error: Could not connect to the scuttlebot server.')
87
        console.log('Use the "server" command to start it.')
88
        if(config.verbose) throw err
89
        process.exit(1)
90
      }
91
      throw err
92
    }
93
94
    // add aliases
95
    for (var k in cmdAliases) {
96
      rpc[k] = rpc[cmdAliases[k]]
97
      manifest[k] = manifest[cmdAliases[k]]
98
    }
99
100
    // add some extra commands
101
    manifest.version = 'async'
102
    manifest.config = 'sync'
103
    rpc.version = function (cb) {
104
      console.log(require('./package.json').version)
105
      cb()
106
    }
107
    rpc.config = function (cb) {
108
      console.log(JSON.stringify(config, null, 2))
109
      cb()
110
    }
111
112
    // HACK
113
    // we need to output the hash of blobs that are added via blobs.add
114
    // because muxrpc doesnt support the `sink` callback yet, we need this manual override
115
    // -prf
116
    if (process.argv[2] === 'blobs.add') {
117
      var filename = process.argv[3]
118
      var source =
119
        filename ? File(process.argv[3])
120
      : !process.stdin.isTTY ? toPull.source(process.stdin)
121
      : (function () {
122
        console.error('USAGE:')
123
        console.error('  blobs.add <filename> # add a file')
124
        console.error('  source | blobs.add   # read from stdin')
125
        process.exit(1)
126
      })()
127
      var hasher = createHash('sha256')
128
      pull(
129
        source,
130
        hasher,
131
        rpc.blobs.add(function (err) {
132
          if (err) 
133
            throw err
134
          console.log('&'+hasher.digest)
135
          process.exit()
136
        })
137
      )
138
      return
139
    }
140
141
    // run commandline flow
142
    muxrpcli(argv, manifest, rpc, config.verbose)
143
  })
144
}
145
146
147
148
149
150
151
152
153
154