import Jwt from "jsonwebtoken"; import {SECRET_KEY, URL_ROOM_STARTED} from "../Enum/EnvironmentVariable"; //TODO fix import by "_Enum/..." import { uuid } from 'uuidv4'; import {HttpRequest, HttpResponse, TemplatedApp} from "uWebSockets.js"; import {BaseController} from "./BaseController"; export interface TokenInterface { name: string, userUuid: string } export class AuthenticateController extends BaseController { constructor(private App : TemplatedApp) { super(); this.login(); } onAbortedOrFinishedResponse(res: HttpResponse/*, readStream: any*/) { console.log("ERROR! onAbortedOrFinishedResponse called!"); /*if (res.id == -1) { console.log("ERROR! onAbortedOrFinishedResponse called twice for the same res!"); } else { console.log('Stream was closed, openStreams: ' + --openStreams); console.timeEnd(res.id); readStream.destroy(); }*/ /* Mark this response already accounted for */ //res.id = -1; } //permit to login on application. Return token to connect on Websocket IO. login(){ this.App.options("/login", (res: HttpResponse, req: HttpRequest) => { this.addCorsHeaders(res); res.end(); }); this.App.post("/login", (res: HttpResponse, req: HttpRequest) => { (async () => { this.addCorsHeaders(res); res.onAborted(() => { console.warn('Login request was aborted'); }) const param = await res.json(); const userUuid = uuid(); const token = Jwt.sign({name: param.name, userUuid: userUuid} as TokenInterface, SECRET_KEY, {expiresIn: '24h'}); res.writeStatus("200 OK").end(JSON.stringify({ token: token, mapUrlStart: URL_ROOM_STARTED, userId: userUuid, })); })(); }); } }