Mongodb code

.env.defaults

@@ -2,6 +2,16 @@ STT_BOT_USERNAME=
 STT_BOT_PASSWORD=
 JWT_SECRET=
 DB_CONNECTION_STRING=postgres://...
+MONGO_CONN_STRING=mongodb://admin:secret@localhost
+MONGO_DB_NAME=datacore
+MONGO_PROFILE_COLLECTION=playerProfiles
+MONGO_TRACKED_VOYAGES_COLLECTION=trackedVoyages
+MONGO_TRACKED_ASSIGNMENTS_COLLECTION=trackedAssignments
+MONGO_TELEMETRY_VOYAGE_COLLECTION=telemetry
+MONGO_FBB_SOLVES_COLLECTION=solves
+MONGO_FBB_TRIALS_COLLECTION=trials
+MONGO_FBB_COLLECTION=bossBattles
+MONGO_DISCORD_USERS_COLLECTION=discordUsers
 CORS_ORIGIN=https://datacore.app/
 PROFILE_DATA_PATH=static
 LOG_PATH=

app/controllers/api.controller.ts

@@ -1,5 +1,9 @@
 import { Router, Request, Response } from 'express';
-import { DataCoreAPI, LogData } from '../logic';
+import { ApiResult, DataCoreAPI, LogData } from '../logic';
+import { PlayerData } from '../datacore/player';
+import { ITrackedAssignment, ITrackedVoyage } from '../datacore/voyage';
+import { IFBB_BossBattle_Document } from '../mongoModels/playerCollab';
+import { CrewTrial, Solve } from '../datacore/boss';
 
 // Assign router to the express.Router() instance
 const router: Router = Router();
@@ -174,6 +178,294 @@ router.post('/telemetry', async (req: Request, res: Response, next) => {
 });
 
 
+/** MongoDB-connected routes */
+
+router.get('/queryAlive', async (req: Request, res: Response, next) => {
+	if (!req.query || !req.query.what) {
+		res.status(400).send('Whaat?');
+		return;
+	}
+
+	try {
+		let apiResult = {
+			Status: 200,
+			Body: { 
+				service: req.query.what,
+				result: "UP"
+			}
+		}
+
+		if (req.query.what === 'mongodb') {
+			if (!DataCoreAPI.mongoAvailable) {				
+				apiResult.Status = 503;
+				apiResult.Body.result = "DOWN";	
+			}
+		}
+
+		res.status(apiResult.Status).send(apiResult.Body);
+	} catch (e) {
+		next(e);
+	}
+});
+
+
+router.post('/postProfile', async (req: Request, res: Response, next) => {
+	if (!req.body) {
+		res.status(400).send('Whaat?');
+		return;
+	}	
+	try {
+		let playerData = req.body as PlayerData;
+		let apiResult = await DataCoreAPI.mongoPostPlayerData(playerData.player.dbid, playerData, getLogDataFromReq(req));
+		res.status(apiResult.Status).send(apiResult.Body);
+	} catch (e) {		
+		next(e);
+	}
+});
+
+router.get('/getProfile', async (req: Request, res: Response, next) => {
+	if (!req.query || (!req.query.dbid && !req.query.dbidhash)) {
+		res.status(400).send('Whaat?');
+		return;
+	}
+
+	try {
+		let apiResult: ApiResult | undefined = undefined;
+
+		if (req.query.dbid) {
+			apiResult = await DataCoreAPI.mongoGetPlayerData(Number.parseInt(req.query.dbid.toString()));
+		}
+		else if (req.query.dbidhash) {
+			apiResult = await DataCoreAPI.mongoGetPlayerData(undefined, req.query.dbidhash.toString());
+		}
+		if (apiResult) {
+			res.status(apiResult.Status).send(apiResult.Body);
+		}
+		else {
+			res.status(500).send();
+		}
+	} catch (e) {
+		next(e);
+	}
+});
+
+router.get('/getProfiles', async (req: Request, res: Response, next) => {
+	if (!req.query || (!req.query.fleet && !req.query.squadron )) {
+		res.status(400).send('Whaat?');
+		return;
+	}
+
+	try {		
+		let fleet = req.query?.fleet ? Number.parseInt(req.query.fleet.toString()) : undefined;
+		let squadron = req.query?.squadron ? Number.parseInt(req.query.squadron.toString()) : undefined;
+		let apiResult = await DataCoreAPI.mongoGetManyPlayers(fleet, squadron);
+		res.status(apiResult.Status).send(apiResult.Body);
+	} catch (e) {
+		next(e);
+	}
+});
+
+router.post('/postVoyage', async (req: Request, res: Response, next) => {
+	if (!req.body) {
+		res.status(400).send('Whaat?');
+		return;
+	}	
+	try {
+		let dbid = req.body.dbid;
+		let voyage = req.body.voyage as ITrackedVoyage;		
+		let apiResult = await DataCoreAPI.mongoPostTrackedVoyage(dbid, voyage, getLogDataFromReq(req));
+		res.status(apiResult.Status).send(apiResult.Body);
+	} catch (e) {		
+		next(e);
+	}
+});
+
+router.get('/getVoyages', async (req: Request, res: Response, next) => {
+	if (!req.query || (!req.query.dbid && !req.query.trackerId )) {
+		res.status(400).send('Whaat?');
+		return;
+	}
+
+	try {		
+		let dbid = req.query?.dbid ? Number.parseInt(req.query.dbid.toString()) : undefined;
+		let trackerId = req.query?.trackerId ? Number.parseInt(req.query.trackerId.toString()) : undefined;
+		let apiResult = await DataCoreAPI.mongoGetTrackedVoyages(dbid, trackerId);
+		res.status(apiResult.Status).send(apiResult.Body);
+	} catch (e) {
+		next(e);
+	}
+});
+
+router.post('/postAssignment', async (req: Request, res: Response, next) => {
+	if (!req.body) {
+		res.status(400).send('Whaat?');
+		return;
+	}	
+
+	try {
+		let dbid = req.body.dbid;
+		let crew = req.body.crew;		
+		let assignment = req.body.assignment as ITrackedAssignment;
+		let apiResult = await DataCoreAPI.mongoPostTrackedAssignment(dbid, crew, assignment, getLogDataFromReq(req));
+		res.status(apiResult.Status).send(apiResult.Body);
+	} catch (e) {		
+		next(e);
+	}
+});
+
+router.post('/postAssignments', async (req: Request, res: Response, next) => {
+	if (!req.body) {
+		res.status(400).send('Whaat?');
+		return;
+	}	
+
+	try {
+		let dbid = req.body.dbid;
+		let assign = req.body.assignments as { [key: string]: ITrackedAssignment[] };
+		let crew = Object.keys(assign);
+		let assignmap = Object.values(assign);
+		let assignments = [] as ITrackedAssignment[];
+		let finalcrew = [] as string[];
+		let x = 0;
+
+		for (let a1 of assignmap) {
+			let symbol = crew[x];
+			for (let a2 of a1) {
+				assignments.push(a2);
+				finalcrew.push(symbol);
+			}	
+			x++;
+		}
+
+		let apiResult = await DataCoreAPI.mongoPostTrackedAssignmentsMany(dbid, finalcrew, assignments, getLogDataFromReq(req));
+		res.status(apiResult.Status).send(apiResult.Body);
+	} catch (e) {		
+		next(e);
+	}
+});
+
+router.get('/getAssignments', async (req: Request, res: Response, next) => {
+	if (!req.query || (!req.query.dbid && !req.query.trackerId )) {
+		res.status(400).send('Whaat?');
+		return;
+	}
+
+	try {
+		let dbid = req.query?.dbid ? Number.parseInt(req.query.dbid.toString()) : undefined;
+		let trackerId = req.query?.trackerId ? Number.parseInt(req.query.trackerId.toString()) : undefined;
+		let apiResult = await DataCoreAPI.mongoGetTrackedVoyages(dbid, trackerId);
+		res.status(apiResult.Status).send(apiResult.Body);
+	} catch (e) {
+		next(e);
+	}
+});
+
+router.get('/getTrackedData', async (req: Request, res: Response, next) => {
+	if (!req.query || (!req.query.dbid && !req.query.trackerId )) {
+		res.status(400).send('Whaat?');
+		return;
+	}
+
+	try {
+		let dbid = req.query?.dbid ? Number.parseInt(req.query.dbid.toString()) : undefined;
+		let trackerId = req.query?.trackerId ? Number.parseInt(req.query.trackerId.toString()) : undefined;
+		let apiResult = await DataCoreAPI.mongoGetTrackedData(dbid, trackerId);
+		res.status(apiResult.Status).send(apiResult.Body);
+	} catch (e) {
+		next(e);
+	}
+});
+
+router.post('/postBossBattle', async (req: Request, res: Response, next) => {
+	if (!req.body) {
+		res.status(400).send('Whaat?');
+		return;
+	}	
+
+	try {		
+		if ("id" in req.body) {
+			req.body.bossBattleId = req.body.id;
+			delete req.body.id;
+		}
+		let battle = req.body as IFBB_BossBattle_Document;
+		let apiResult = await DataCoreAPI.mongoPostBossBattle(battle);
+		res.status(apiResult.Status).send(apiResult.Body);
+	} catch (e) {		
+		next(e);
+	}
+});
+
+
+router.post('/postBossBattleSolves', async (req: Request, res: Response, next) => {
+	if (!req.body) {
+		res.status(400).send('Whaat?');
+		return;
+	}	
+
+	try {		
+		let bossBattleId = req.body.bossBattleId as number;
+		let chainIndex = req.body.chainIndex as number;
+		let solves = req.body.solves as Solve[];
+
+		if (!bossBattleId || !chainIndex || !solves) {
+			res.status(400).send("Bad data");
+		}
+
+		let apiResult = await DataCoreAPI.mongoPostSolves(bossBattleId, chainIndex, solves);
+
+		res.status(apiResult.Status).send(apiResult.Body);
+	} catch (e) {		
+		next(e);
+	}
+});
+
+router.post('/postBossBattleTrials', async (req: Request, res: Response, next) => {
+	if (!req.body) {
+		res.status(400).send('Whaat?');
+		return;
+	}	
+
+	try {		
+		let bossBattleId = req.body.bossBattleId as number;
+		let chainIndex = req.body.chainIndex as number;
+		let trials = req.body.trials as CrewTrial[];
+
+		if (!bossBattleId || !chainIndex || !trials) {
+			res.status(400).send("Bad data");
+		}
+
+		let apiResult = await DataCoreAPI.mongoPostTrials(bossBattleId, chainIndex, trials);
+
+		res.status(apiResult.Status).send(apiResult.Body);
+	} catch (e) {		
+		next(e);
+	}
+});
+
+
+router.get('/getBossBattle', async (req: Request, res: Response, next) => {
+	if (!req.query || (!req.query.room && !req.query.id )) {
+		res.status(400).send('Whaat?');
+		return;
+	}
+
+	try {		
+		let room = undefined as string | undefined;		
+		let id = undefined as number | undefined;
+
+		if (req.query.room) {
+			room = req.query.room as string;
+		}
+		if (req.query.id) {
+			id = Number.parseInt(req.query.id as string);
+		}
+
+		let apiResult = await DataCoreAPI.mongoGetCollaboration(id, room);
+		res.status(apiResult.Status).send(apiResult.Body);
+	} catch (e) {
+		next(e);
+	}
+});
 
 // Export the express.Router() instance to be used by server.ts
 export const ApiController: Router = router;

app/datacore/archetype.ts

@@ -0,0 +1,62 @@
+import { Icon } from "./game-elements"
+
+export interface ArchetypeRoot20 {
+    archetypes: Archetype20[]
+}
+
+export interface ArchetypeRoot17 {
+    archetypes: Archetype17[]
+}
+
+export interface ArchetypeBase {
+  id: number;
+  type: string | number;
+  symbol: string;
+  name: string;
+  icon: Icon;
+  flavor: string;
+  rarity: number;
+  recipe?: ArchetypeRecipe;
+  item_sources: ItemSource[];
+  bonuses?: ArchetypeBonus;
+  short_name?: string;
+}
+
+export interface Archetype20 extends ArchetypeBase {
+    type: string;
+    item_type: number;
+  }
+
+  export interface Archetype17 extends ArchetypeBase {
+    type: number;
+  }
+
+  export interface ArchetypeRecipe {
+    demands: ArchetypeDemand[]
+    validity_hash: string
+  }
+
+  export interface ArchetypeDemand {
+    archetype_id: number
+    count: number
+  }
+
+  export interface ItemSource {
+    challenge_id?: number
+    challenge_skill?: string
+    challenge_difficulty?: number
+    type: number
+    id: number
+    name: string
+    energy_quotient: number
+    chance_grade: number
+    place?: string
+    mission?: number
+    dispute?: number
+    mastery?: number
+  }
+
+  export interface ArchetypeBonus {
+    [key: string]: number | undefined;
+  }
+