server.js

'use strict';

const fs = require('fs');
const process = require('process');
const express = require('express');
const app = express();
const bodyParser = require('body-parser');
const morgan = require('morgan');

// Command line opts
const argv = require('minimist')(process.argv.slice(1));
if (!argv.codepath) {
    argv.codepath = "./funktion/source.js";
    console.log("Codepath defaulting to ", argv.codepath);
}
if (!argv.port) {
    console.log("Port defaulting to 8888");
    argv.port = 8888;
}

// User function.  Starts out undefined.
let userFunction;

//
// Require the user function.
// The user function is read from argv.codepath
// it's expected to be placed there by the funktion runtime.
//
function requireUserFunction() {
    // Read and load the code. It's placed there securely by the fission runtime.
    try {
        var startTime = process.hrtime();
        userFunction = require(argv.codepath);
        var elapsed = process.hrtime(startTime);
        console.log(`user code loaded in ${elapsed[0]}sec ${elapsed[1]/1000000}ms`);
    } catch(e) {
        console.error(`user code load error: ${e}`);
    }
}

// Request logger
app.use(morgan('combined'))

app.use(bodyParser.urlencoded({ extended: false }));
app.use(bodyParser.json());
app.use(bodyParser.raw());

requireUserFunction();

// Generic route -- all http requests go to the user function.
app.all('/', function (req, res) {
    if (!userFunction) {
        res.status(500).send("Generic container: no requests supported");
        return;
    }
    const context = {
        request: req,
        response: res
        // TODO: context should also have: URL template params, query string
    };
    function callback(status, body, headers) {
        if (!status)
            return;
        if (headers) {
            for (let name of Object.keys(headers)) {
                res.set(name, headers[name]);
            }
        }
        res.status(status).send(body);
    }
    try {
        userFunction(context, callback);
    } catch(e) {
        callback(500, "Internal server error")
    }
});

app.all('/healthz', function (req, res) {
    res.status(200).send("Healthy!");
});

app.listen(argv.port);