sphinx-relay/api/utils/tribes.ts

import * as moment from 'moment'
import * as zbase32 from './zbase32'
import {signBuffer, getInfo} from './lightning'
import * as path from 'path'
import * as mqtt from 'mqtt'

const env = process.env.NODE_ENV || 'development'
const config = require(path.join(__dirname,'../../config/app.json'))[env]

export async function connect() {
    const pwd = await genSignedTimestamp()
    const info = await getInfo()

    const client = mqtt.connect(`tcp://${config.tribes_host}`,{
        username:info.identity_pubkey,
        password:pwd,
    })

    client.on('connect', function () {
        console.log("MQTT CLIENT CONNECTED!")
        // subscribe to all public groups here
        // that you are NOT admin of (dont sub to your own!)
    })
    client.on('close', function () {
        console.log("MQTT CLOSED")
    })
}

export async function genSignedTimestamp(){
    const now = moment().unix()
    const tsBytes = Buffer.from(now.toString(16), 'hex')
    const sig = await signBuffer(tsBytes)
    const sigBytes = zbase32.decode(sig)
    const totalLength = tsBytes.length + sigBytes.length
    const buf = Buffer.concat([tsBytes, sigBytes], totalLength)
    return urlBase64(buf)
}

export function getHost() {
    return config.tribes_host || ''
}

function urlBase64(buf){
    return buf.toString('base64').replace(/\//g, '_').replace(/\+/g, '-')
}