|
1 | | -#!/usr/bin/env node |
2 | | - |
3 | 1 | var diffsync = require(`${__dirname}/diffsync.js`) |
4 | 2 | console.log('diffsync version ' + diffsync.version) |
5 | 3 |
|
6 | | -// Parse command-line arguments |
7 | | -var [port, cert_file, key_file] = process.argv.slice(2) |
8 | | -port = port ? parseInt(port) : diffsync.port |
| 4 | +var port = process.argv[2] ? parseInt(process.argv[2]) : diffsync.port |
9 | 5 |
|
10 | 6 | var bus = require('statebus')() |
11 | 7 | bus.sqlite_store({save_sync: true}) |
@@ -34,35 +30,12 @@ for (var key in bus.cache) { |
34 | 30 | } |
35 | 31 | } |
36 | 32 |
|
37 | | -var fs = require('fs') |
38 | | -var server_args = [] |
39 | | - |
40 | | -// Only use HTTPS if both cert and key files are provided and exist |
41 | | -var server_type = 'http' |
42 | | -if (cert_file && key_file && fs.existsSync(key_file) && fs.existsSync(cert_file)) { |
43 | | - server_type = 'https' |
44 | | - server_args.unshift({ |
45 | | - key : fs.readFileSync(key_file), |
46 | | - cert : fs.readFileSync(cert_file) |
47 | | - }) |
48 | | -} else if (cert_file || key_file) { |
49 | | - if (!cert_file || !key_file) { |
50 | | - console.log('Warning: Both cert_file and key_file must be provided for HTTPS') |
51 | | - process.exit(1) |
52 | | - } else { |
53 | | - console.log('Warning: SSL certificate files not found') |
54 | | - process.exit(1) |
55 | | - } |
56 | | -} |
57 | | - |
58 | | -var web_server = require(server_type).createServer(...server_args) |
59 | | - |
60 | | -web_server.listen(port) |
61 | | -console.log('openning ' + server_type + ' server on port ' + port) |
62 | | -var WebSocket = require('ws') |
63 | | -var wss = new WebSocket.Server({ server : web_server }) |
| 33 | +var server = require('http').createServer() |
| 34 | +server.listen(port) |
| 35 | +console.log('listening on port ' + port) |
| 36 | +var wss = new (require('ws').Server)({ server }) |
64 | 37 |
|
65 | | -var diff_server = diffsync.create_server({ |
| 38 | +diffsync.create_server({ |
66 | 39 | wss : wss, |
67 | 40 | initial_data : channels, |
68 | 41 | on_change : function (changes) { |
|
0 commit comments