const http = require("node:http");
const fs = require("node:fs");

// const welcomeMessage = require("./routes/default/index.js");
// const getNodeInfo = require('./routes/getNodeInfo/index.js');
// const getPeers = require('./routes/getPeers/index.js');
// const getZblock = require('./routes/getZblock/index.js');
// const getZlatest = require('./routes/getZLatest/index.js');
// const getSblock = require('./routes/getSBlock/index.js');
// const getSlatest = require('./routes/getSLatest/index.js');

// const akLogMessage = require('./lib/akLogMessage');
function akLogMessage(type, message)
{
    console.log(type+": "+message);
}

const serverOptions = { keepAliveTimeout: 60000 };

function printRequest(req)
{
    console.log(req.connection.remoteAddress);
    console.log(req.headers);
    console.log(req.method, req.url);
    console.log('HTTP/' + req.httpVersion);
}

function respondError(res, errorMessage)
{
    res.writeHead(404, { 'Content-Type': 'application/json'});
    res.end(JSON.stringify({
        error: errorMessage
    }));
}

function respondJSON(res, hash)
{
    test = /[0-9a-f]{128}/
    if (test.test(hash))
    {
        res.writeHead(200, { 'Content-Type': 'application/json'});
        res.end(JSON.stringify(JSON.parse(fs.readFileSync('../hashes/' + hash))));
    } else {
        respondError(res, 'Not hash');
    }
}

function testRootRoute(req, res)
{
    notImplemented(req, res);
}

function testRoute(req, res)
{
    respondError(res, "Mpla mpla");
}

function applicationRoutes(req, res, args)
{
    if (args[4] === 'undefined')
    {
        respondError(res, 'Bye');
        return;
    }
    switch(args[3])
    {
        case 'json': respondJSON(res, args[4]); break;
        default: notImplemented(req, res);
    }
}

// Audio returns
function respondOGG(res, hash)
{
    res.writeHead(200, { 'Content-Type': 'audio/ogg'});
    test = /[0-9a-f]{128}/
    console.log(test.test(hash))
    res.end(fs.readFileSync('../hashes/' + hash));
}

function audioRoutes(req, res, args)
{
    if (args.length < 4 || args[4] === '')
    {
        respondError(res, 'No hash');
        return;
    }
    if (args.length < 3 || args[3] === '')
    {
        respondError(res, 'No filetype/extension');
        return;
    }
    switch(args[3])
    {
        case 'ogg': respondOGG(res, args[4]); break;
        default: notImplemented(req, res);
    }
}

function getLatestList(req, res)
{
    res.writeHead(200, { 'Content-Type': 'application/json'});
    res.end(JSON.stringify(JSON.parse(fs.readFileSync('../hashes/list'))));
}

function getRoutes(req, res)
{
    var args = req.url.split('/');
    if (args[1] === 'v0' && args.length > 2 && args[2] !== ""){
        switch(args[2])
        {
            case 'test': testRoute(req, res); break;
            case 'list': getLatestList(req, res); break;
            case 'application': applicationRoutes(req, res, args); break;
            case 'audio': audioRoutes(req, res, args); break;
            default: notImplemented(req, res);
        }
    }
    else {
        notImplemented(req, res);
    }
}

function postRoutes(req, res)
{
    switch(req.url)
    {
        default: notImplemented(req, res);
    }
}

function notImplemented(req, res)
{
    res.writeHead(404, { 'Content-Type': 'application/json'});
    res.end(JSON.stringify({
        url: req.url,
        error: 'not implemented'
    }));
}

function processMethod(req, res)
{
    switch(req.method)
    {
        case 'GET': getRoutes(req, res); break;
        case 'POST': postRoutes(req, res); break;
        default: notImplemented(req, res);
    }
}

function requestParser(req, res)
{
    printRequest(req);
    akLogMessage('INFO', `Incoming from [${req.connection.remoteAddress}]:${req.socket._peername.port} @ ${req.headers.host}${req.url}`);
    res.setHeader('Access-Control-Allow-Origin', '*');
    processMethod(req, res);
}

const server = http.createServer(serverOptions, requestParser);

server.listen(8010);