server.js

var diffsync = require('./diffsync.js')
console.log('diffsync version ' + diffsync.version)

var bus = require('statebus')()
bus.sqlite_store()

var channels = {}
for (var key in bus.cache) {
    if (!bus.cache.hasOwnProperty(key)) { continue }
    var o = bus.cache[key]
    if (key.startsWith('commit/')) {
        if (!channels[o.channel])
            channels[o.channel] = { commits : {}, members : {} }

        // backwards compatability with 1022
        if (o.parents) {
            channels[o.channel].commits[o.id] = {
                to_parents : o.parents,
                from_parents : o.from_parents
            }
            if (o.text)
                channels[o.channel].commits[o.id].text = o.text

        } else {
            channels[o.channel].commits[o.id] = o.commit
        }
    }
    if (key.startsWith('member/')) {
        if (!channels[o.channel])
            channels[o.channel] = { commits : {}, members : {} }
        channels[o.channel].members[o.id] = o.member
    }
}

var fs = require('fs')
var web_server = null
var server_type = null
if (fs.existsSync('privkey.pem') && fs.existsSync('fullchain.pem')) {
    web_server = require('https').createServer({
        key : fs.readFileSync('privkey.pem'),
        cert : fs.readFileSync('fullchain.pem')
    })
    server_type = 'https'
} else {
    web_server = require('http').createServer()
    server_type = 'http'
}
var port = diffsync.port
web_server.listen(port)
console.log('openning ' + server_type + ' server on port ' + port)
var WebSocket = require('ws')
var wss = new WebSocket.Server({ server : web_server })

var diff_server = diffsync.create_server({
    wss : wss,
    initial_data : channels,
    on_change : function (changes) {
        for (var id in changes.commits) {
            if (!changes.commits.hasOwnProperty(id)) { continue }

            var c = changes.commits[id]
            var key = 'commit/' + id
            if (c) {
                bus.save({
                    key : key,
                    id : id,
                    channel : changes.channel,
                    commit : c
                })
            } else {
                bus.del(key)
            }
        }
        for (var id in changes.members) {
            if (!changes.members.hasOwnProperty(id)) { continue }

            var m = changes.members[id]
            var key = 'member/' + id + '/of/' + changes.channel
            if (m) {
                bus.save({
                    key : key,
                    id : id,
                    channel : changes.channel,
                    member : m
                })
            } else {
                bus.del(key)
            }
        }
    }
})