Nebula/server/serverFactory.ts

import { createServer } from 'node:http';
import wisp from 'wisp-server-node';
import rammerhead from '@rubynetwork/rammerhead';
import { FastifyServerFactory, FastifyServerFactoryHandler, RawServerDefault } from 'fastify';
import { parsedDoc } from './config.js';
import { LOG_LEVEL, WispOptions } from 'wisp-server-node/dist/Types.js';

const rh = rammerhead.createRammerhead({
    logLevel: parsedDoc.server.server.logging ? 'debug' : 'disabled',
    reverseProxy: parsedDoc.server.rammerhead.reverseproxy,
    disableLocalStorageSync: parsedDoc.server.rammerhead.localstorage_sync ? false : true,
    disableHttp2: parsedDoc.server.rammerhead.http2 ? false : true 
});

const wispOptions: WispOptions = {
    logLevel: parsedDoc.server.server.logging ? LOG_LEVEL.DEBUG : LOG_LEVEL.NONE,
    pingInterval: 30
}

const serverFactory: FastifyServerFactory = (handler: FastifyServerFactoryHandler): RawServerDefault => {
    const httpServer = createServer();
    httpServer.on('request', (req, res) => {
        if (rammerhead.shouldRouteRh(req)) {
            rammerhead.routeRhRequest(rh, req, res);
        }
        else {
            handler(req, res);
        }
    });
    httpServer.on('upgrade', (req, socket, head) => {
        if (rammerhead.shouldRouteRh(req)) {
            rammerhead.routeRhUpgrade(rh, req, socket, head);
        }
        else if (parsedDoc.server.server.wisp) {
            if (req.url?.endsWith('/wisp/')) {
                wisp.routeRequest(req, socket as any, head, wispOptions);
            }
        }
    });
    return httpServer;
}

export { serverFactory };