main.js

'use strict'
const debug = require('debug')('traffic:main')
const xmpp = require('node-xmpp-server')
const bunyan = require('bunyan')

const pjson = require('./package.json')
const log = bunyan.createLogger({
  name: pjson.name,
  serializers: { err: bunyan.stdSerializers.err }
})

if (process.env.NODE_ENV === 'development') {
  var dynalite = require('dynalite')({ path: './serverdb', createTableMs: 50 })
  dynalite.listen(4567, err => {
    if (err) log.error(err)
  })
}

const s2s = new xmpp.Router()
s2s._server.on('listening', () => {
  const address = s2s._server.address()
  log.info(
    {
      module: 'router',
      address: address.address,
      port: address.port,
      server: s2s.constructor.name
    },
    'LISTENING'
  )
})
const Router = require('./router')
const router = new Router({ log, router: s2s })
// FIXME: https://github.com/node-xmpp/node-xmpp/issues/366
const DomainContext = require('node-xmpp-server/lib/S2S/domaincontext')
DomainContext.prototype.receive = function (stanza) {
  debug('router receive %s', stanza)
  // https://xmpp.org/rfcs/rfc6120.html#stanzas-attributes
  if (stanza.attrs.to && stanza.attrs.from) {
    if (stanza.attrs.xmlns === 'jabber:server') {
      stanza.attrs.xmlns = 'jabber:client'
    }
    router.process(stanza, true)
  }
}

const C2S = require('./c2s')
const tcp = new C2S({ server: new xmpp.C2S.TCPServer(), log, router })
const ws = new C2S({ server: new xmpp.C2S.WebSocketServer(), log, router })

tcp.server.on('online', () => {
  debug('ONLINE', tcp.server.constructor.name)
})

ws.server.on('online', () => {
  debug('ONLINE', ws.server.constructor.name)
})