server.js

const path = require('path')
const fs = require('fs')

const express = require('express');
const compression = require('compression')
const cors = require('cors');
const { cruise } = require("dependency-cruiser");

const { SETTINGS, REQUESTS, VERSION } = require('./globals')

const { handleSSERequests } = require('./sse');
const serialize = require('./public/serialize');
const { getRootDirectory } = require('./helpers');

let cruiseModules;

const server = express();

server.use(cors());

server.get('/events', handleSSERequests)

server.use(compression())
server.use(express.static(path.join(__dirname, 'public')));

server.get('/', function renderHomepage(request, response) {
	response.redirect(request.originalUrl + 'graph');
});
server.get('/graph', function renderGraphPage(_, response){
	response.sendFile(path.join(__dirname, 'public/graph/graph.html'))
});
server.get('/info', function sendDependencyInfo(_, response){
	const root = getRootDirectory();
	const viewsRelativeDirectory = path.relative(root, SETTINGS.views.directory)

	if (!cruiseModules) {
		const fullExt = SETTINGS.views.extension.startsWith('.') ? SETTINGS.views.extension : '.' + SETTINGS.views.extension;
		const addExtIfMissing = name => name + (name.endsWith(fullExt) ? '' : fullExt)
		const { output: { modules } } = cruise([SETTINGS.entryPoint], { exclude: ['node_modules', 'express-handler-tracker'] });
		cruiseModules = modules.filter(module => !module.coreModule).map(({ source, dependencies }) => ({ source, dependencies: dependencies.filter(dep => !dep.coreModule).map(({ resolved }) => resolved) }))
		for (const module of [...cruiseModules]){
			const viewNames = [...(fs.readFileSync(path.join(root, module.source)).toString().matchAll(/.*?\.render\(('|")(?<name>.*?)('|")(,|\))/gi) || [])]
				.map(match => path.join(
					viewsRelativeDirectory,
					addExtIfMissing(match.groups.name)
				));
			module.dependencies.push(...viewNames);
			cruiseModules.push(...viewNames.map(name => ({ source: name, dependencies: []})));
		}
	}

	response.send({
		modules: cruiseModules,
		root,
		views: {
			directory: viewsRelativeDirectory,
			extension: SETTINGS.views.extension
		},
		VERSION: VERSION,
		external: {}
	});
});


server.get('/reset', (request, response) => {
	REQUESTS.clear();
	response.redirect(request.originalUrl);
});

server.get('/requests', function sendRequests(_, response){
	response.set('Content-Type', 'application/json');
	response.send(JSON.stringify(serialize(Object.fromEntries([...REQUESTS.entries()].filter(([key]) => key !== 'latest')), { json: true })));
});
server.get('/delete-request/:id', function deleteRequest(request, response){
	const id = +request.params.id;
	if (!id) return response.status(404).end();

	if (!REQUESTS.has(id)) return response.status(404).end();

	REQUESTS.delete(id);

	return response.status(200).end();
})
server.patch('/update-request/:id', express.json(), function updateRequest(request, response){
	const id = +request.params.id;
	if (!id) return response.status(404).end();

	const foundRequest = REQUESTS.get(id)
	if (!foundRequest) return response.status(404).end();

	for (const key of ['label']){
		if (key in request.body) {
			const value = request.body[key]
			if (value === undefined) delete foundRequest[key]
			else foundRequest[key] = value
		}
	}
	return response.status(200).end();
})

server.patch('/update-event/:requestId/:eventStart', express.json(), function updateRequest(request, response){
	const requestId = +request.params.requestId;
	if (!requestId) return response.status(404).end();

	const foundRequest = REQUESTS.get(requestId)
	if (!foundRequest) return response.status(404).end();

	const eventStart = +request.params.eventStart;
	const event = foundRequest.events.find(e => e.start === eventStart);
	if (!event) return response.status(404).end();

	for (const key of ['annotation', 'diffs', 'locals', 'body', 'json', 'args', 'reason', 'value']){
		if (key in request.body) {
			const value = request.body[key];
			if (value === undefined) delete event[key];
			else event[key] = value;
		}
	}

	return response.status(200).end();
})

server.delete('/delete-event/:requestId/:eventStart', express.json(), function updateRequest(request, response){
	const requestId = +request.params.requestId;
	if (!requestId) return response.status(404).end();

	const foundRequest = REQUESTS.get(requestId)
	if (!foundRequest) return response.status(404).end();

	const eventStart = +request.params.eventStart;
	const eventIndex = foundRequest.events.findIndex(e => e.start === eventStart);
	if (eventIndex === -1) return response.status(404).end();

	foundRequest.events.splice(eventIndex, 1)
	return response.status(200).end();
})

module.exports = server