server.js

const config = require( './src/config' )
const handleIncomingMessage = require( './src/handleIncomingMessage' )
const { handleGetIq, handleSetIq } = require( './src/handleIncomingIq' )
const redisLib = require('redis');
const startApiServer = require( './src/startApiServer' )
const { component } = require("@xmpp/component");
const debug = require('@xmpp/debug')
const { newMessage } = require( './src/helper' )
const { promisifyAll } = require('bluebird');
promisifyAll( redisLib );

// init Redis connection
console.log( "Connecting to Redis" )
const redis = redisLib.createClient(config.REDIS_URL);

// init XMPP connection
const startSgx = () => {
    const xmpp = component({
        service: config.COMPONENT_HOST,
        domain: config.COMPONENT_DOMAIN,
        password: config.COMPONENT_SECRET,
    });

    debug(xmpp, true) // always enabled
    
    xmpp.on( "error", console.error )

    xmpp.on( "offline", () => {
        console.log( "offline" );
        
    });

    xmpp.on( "disconnect", ( err ) => {
        console.log( err )
    })

    xmpp.on( "stanza", async ( stanza ) => {
        if ( stanza.is( "message" ) ) {
            handleIncomingMessage( xmpp, redis, stanza );
        }
    });
   
    xmpp.iqCallee.get( "jabber:iq:register", "query", (ctx) => {
        return handleGetIq() 
    });
    
    xmpp.iqCallee.set( "jabber:iq:register", "query", (ctx) => {
        return handleSetIq( xmpp, redis, ctx.stanza )
    });

    xmpp.on( "online", async (address) => {
        console.log( "online as", address.toString() );
        if ( config.XMPP_ADMIN ) {
            const message = newMessage( "Now Online Again", config.XMPP_ADMIN )
            await xmpp.send( message );
        }
        startApiServer( xmpp, redis )
    })
    
    console.log( "Connecting to XMPP" )
    xmpp.start().catch( err => console.error( err ) )
}

startSgx()