partey_workadventure/pusher/src/Controller/MapController.ts

112 lines
4.4 KiB
TypeScript
Raw Normal View History

2021-06-24 10:09:10 +02:00
import { HttpRequest, HttpResponse, TemplatedApp } from "uWebSockets.js";
import { BaseController } from "./BaseController";
import { parse } from "query-string";
import { adminApi } from "../Services/AdminApi";
import { ADMIN_API_URL, DISABLE_ANONYMOUS } from "../Enum/EnvironmentVariable";
import { GameRoomPolicyTypes } from "../Model/PusherRoom";
import { isMapDetailsData, MapDetailsData } from "../Services/AdminApi/MapDetailsData";
import { socketManager } from "../Services/SocketManager";
import { AuthTokenData, jwtTokenManager } from "../Services/JWTTokenManager";
import { v4 } from "uuid";
2021-06-24 10:09:10 +02:00
export class MapController extends BaseController {
constructor(private App: TemplatedApp) {
2020-09-28 18:52:54 +02:00
super();
this.App = App;
2020-10-13 15:12:24 +02:00
this.getMapUrl();
}
// Returns a map mapping map name to file name of the map
2020-10-13 15:12:24 +02:00
getMapUrl() {
this.App.options("/map", (res: HttpResponse, req: HttpRequest) => {
2020-09-28 18:52:54 +02:00
this.addCorsHeaders(res);
res.end();
});
2020-10-13 15:12:24 +02:00
this.App.get("/map", (res: HttpResponse, req: HttpRequest) => {
res.onAborted(() => {
2021-06-24 10:09:10 +02:00
console.warn("/map request was aborted");
});
2020-10-13 15:12:24 +02:00
const query = parse(req.getQuery());
if (typeof query.playUri !== "string") {
console.error("Expected playUri parameter in /map endpoint");
res.writeStatus("400 Bad request");
this.addCorsHeaders(res);
res.end("Expected playUri parameter");
2020-11-13 12:11:59 +01:00
return;
2020-10-13 15:12:24 +02:00
}
// If no admin URL is set, let's react on '/_/[instance]/[map url]' URLs
if (!ADMIN_API_URL) {
const roomUrl = new URL(query.playUri);
const match = /\/_\/[^/]+\/(.+)/.exec(roomUrl.pathname);
if (!match) {
res.writeStatus("404 Not Found");
this.addCorsHeaders(res);
res.end(JSON.stringify({}));
return;
}
const mapUrl = roomUrl.protocol + "//" + match[1];
res.writeStatus("200 OK");
this.addCorsHeaders(res);
res.end(
JSON.stringify({
mapUrl,
policy_type: GameRoomPolicyTypes.ANONYMOUS_POLICY,
roomSlug: "", // Deprecated
group: null,
tags: [],
textures: [],
contactPage: undefined,
authenticationMandatory: DISABLE_ANONYMOUS,
} as MapDetailsData)
);
2020-11-13 12:11:59 +01:00
return;
2020-10-13 15:12:24 +02:00
}
(async () => {
try {
let userId: string | undefined = undefined;
if (query.authToken != undefined) {
let authTokenData: AuthTokenData;
try {
authTokenData = jwtTokenManager.verifyJWTToken(query.authToken as string);
userId = authTokenData.identifier;
} catch (e) {
try {
// Decode token, in this case we don't need to create new token.
authTokenData = jwtTokenManager.verifyJWTToken(query.authToken as string, true);
userId = authTokenData.identifier;
console.info("JWT expire, but decoded", userId);
} catch (e) {
// The token was not good, redirect user on login page
res.writeStatus("500");
res.end("Token decrypted error");
return;
}
}
}
const mapDetails = await adminApi.fetchMapDetails(query.playUri as string, userId);
if (isMapDetailsData(mapDetails) && DISABLE_ANONYMOUS) {
mapDetails.authenticationMandatory = true;
}
res.writeStatus("200 OK");
this.addCorsHeaders(res);
res.end(JSON.stringify(mapDetails));
} catch (e) {
this.errorToResponse(e, res);
}
2020-10-13 15:12:24 +02:00
})();
});
}
}