diff options
| -rwxr-xr-x | api/index.js | 246 |
1 files changed, 89 insertions, 157 deletions
diff --git a/api/index.js b/api/index.js index 9bd064b..b39ee07 100755 --- a/api/index.js +++ b/api/index.js @@ -1,177 +1,109 @@ -#!/usr/bin/env node -/* - * Quick API - * Author: Kaotisk Hund <kaotisk@arching-kaos.com> - * Description: Provides a quick API implementation. - * License: MIT - */ +const http = require("node:http"); -const config = require('./config'); -const akLogMessage = require('./lib/akLogMessage'); - -const DEFAULT_PORT = 8610; -const PORT = config.port || DEFAULT_PORT; - -akLogMessage("INFO", "Daemon started") -/* - * Split the prefix of each API call in segments for better management - * - * To add a new route, use URL_PREFIX and start your route with '/' - * - * LOCAL_IP and DEF_PROTO as well as PORT and URL_PREFIX are used to generate - * visitable links. - * - */ -const API_VERSION = "v0"; -const URL_PREFIX = "/"+API_VERSION; -const DEF_PROTO="http://"; -const LOCAL_IP="127.0.0.1"; - -/* Requiring packages */ -const { spawn } = require('child_process'); -const logger = require('morgan'); -const express = require('express'); -const cors = require('cors'); -const fs = require('fs'); -const path = require('path'); -const bodyParser = require('body-parser'); -const multer = require('multer'); -const upload = multer(); -const session = require('express-session'); -// Delete this (maybe) -const cookieParser = require('cookie-parser'); - -// We start our server ... -const app = express(); -app.disable('x-powered-by'); - -// Set logger format output -app.use(logger('combined')); - -// Port number to listen to -const server = app.listen(PORT); - -// Use CORS -app.use(cors()); - -// Whitelist of IPs -// var iplist = fs.readFileSync(config.ipList) +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'); -// Parsers -app.use(bodyParser.json()); -app.use(bodyParser.urlencoded({extended:true})); - -// for parsing multipart/form-data -app.use(upload.array()); - -// Cookie! -app.use(cookieParser()); +const akLogMessage = require('./lib/akLogMessage'); -app.use(session({ - secret: config.session.secret, - resave: false, - saveUninitialized: true -})); +const serverOptions = { keepAliveTimeout: 60000 }; -// Function for adding stuff... -function genericaddtest(req,res){ - console.table(req.body) - var myobj = req.body; - res.set('Content-Type', 'application/json'); - res.send(myobj); +function printRequest(req) +{ + console.log(req.connection.remoteAddress); + console.log(req.headers); + console.log(req.method, req.url); + console.log('HTTP/' + req.httpVersion); } -// POST data -app.post('/test', cors(corsOptions), genericaddtest); - -const routes = require('./routes'); - -//Routes.provideTheAppHere(app); -app.use('/', routes); - +function respondError(res, errorMessage) +{ + res.writeHead(404, { 'Content-Type': 'application/json'}); + res.end(JSON.stringify({ + error: errorMessage + })); +} -/* - * Adds a latest resolved IPFS path for a given IPNS link - * to a file. - * - * Returns: - * - error if error - * - success: - * - adds the entry to the file - * - returns the whole file to the client - * - */ -function addNSEntriesToFile(entry,res){ - var data = JSON.parse(fs.readFileSync(config.pairsFile)); - var duplicate_entry = 0; - data.forEach(a=>{ - if ( a.zchain === entry.zchain && a.latest=== entry.latest ){ - duplicate_entry = 1; - res.send({error:"already there"}); - } - }); +function testRootRoute(req, res) +{ + notImplemented(req, res); +} - if ( duplicate_entry === 0 ) { - // Store it as the first array element of our new list - var all = [entry]; +function testRoute(req, res) +{ + respondError(res, "Mpla mpla"); +} - // Append the previous entries - for (var i = 0; i < data.length; i++){ - all[i+1] = data[i]; +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 'root': testRootRoute(req, res); break; + case 'peers': getPeers(req, res); break; + case 'node_info': getNodeInfo(req, res); break; + case 'zblock': getZblock(req, res); break; + case 'zlatest': getZlatest(req, res); break; + case 'sblock': getSblock(req, res); break; + case 'slatest': getSlatest(req, res); break; + default: notImplemented(req, res); } + } + else { + welcomeMessage(req, res); + } +} - // Turn additional back into text - var json = JSON.stringify(all); +function postRoutes(req, res) +{ + switch(req.url) + { + default: notImplemented(req, res); + } +} - // Write out the file - fs.writeFile(config.pairsFile, json, 'utf8', finished); +function notImplemented(req, res) +{ + res.writeHead(404, { 'Content-Type': 'application/json'}); + res.end(JSON.stringify({ + url: req.url, + error: 'not implemented' + })); +} - // Callback for when file is finished - function finished(err) { - console.log('finished writing file'); - } - res.send(json); +function processMethod(req, res) +{ + switch(req.method) + { + case 'GET': getRoutes(req, res); break; + case 'POST': postRoutes(req, res); break; + default: notImplemented(req, res); } } -/* - * Adds a latest given zblock to a file. - * - * Returns: - * - error if error - * - success: - * - adds the entry to the file - * - returns the whole file to the client - * - */ -function addEntriesToFile(entry,res){ - var data = JSON.parse(fs.readFileSync(config.blocksFile)); - - var duplicate_entry = 0; - data.forEach(a=>{ - if ( a.zblock === entry.zblock ){ - duplicate_entry = 1; - res.send({error:"already there"}); - } - }); +function checkIfAllowedIP(address) +{ + return address.startsWith('fc') ? true : false; +} - if ( duplicate_entry === 0 ) { - var all = [entry]; - for (var i = 0; i < data.length; i++){ - all[i+1] = data[i]; - } - var json = JSON.stringify(all); - fs.writeFile(config.blocksFile, json, 'utf8', finished); - // wtf is dis? - function finished(err) { - console.log('finished writing file'); - } - res.send(json); +function requestParser(req, res) +{ + printRequest(req); + akLogMessage('INFO', `Incoming from [${req.connection.remoteAddress}]:${req.socket._peername.port} @ ${req.headers.host}${req.url}`); + if (checkIfAllowedIP(req.connection.remoteAddress)){ + processMethod(req, res); + } + else { + res.end(); } } -app.use(cors); -var corsOptions = { - origin: '*', - optionsSuccessStatus: 200 // some legacy browsers (IE11, various SmartTVs) choke on 204 -} +const server = http.createServer(serverOptions, requestParser); + +server.listen(8610); |