summaryrefslogtreecommitdiff
path: root/lib
diff options
context:
space:
mode:
authorJulien Dessaux2023-05-31 01:19:31 +0200
committerJulien Dessaux2023-05-31 01:19:31 +0200
commit61b5c8493e57c73469f31a795037922bd9d34931 (patch)
tree2bfc62120d393efa0664111997dec6e23bcd6642 /lib
parentRefactoring (diff)
downloadspacetraders-61b5c8493e57c73469f31a795037922bd9d34931.tar.gz
spacetraders-61b5c8493e57c73469f31a795037922bd9d34931.tar.bz2
spacetraders-61b5c8493e57c73469f31a795037922bd9d34931.zip
Reworked the systems handling and caching with sqlite
Diffstat (limited to 'lib')
-rw-r--r--lib/systems.js85
1 files changed, 61 insertions, 24 deletions
diff --git a/lib/systems.js b/lib/systems.js
index 4b480de..3cc7c7a 100644
--- a/lib/systems.js
+++ b/lib/systems.js
@@ -1,49 +1,86 @@
import * as api from './api.js';
import * as db from '../database/systems.js';
-// Retrieves a list of waypoints that have a specific ctx.trait like a SHIPYARD or a MARKETPLACE in the system ctx.symbol
-export async function trait(ctx) {
- const s = await system(ctx);
- return s.filter(s => s.traits.some(t => t.symbol === ctx.trait));
+// Retrieves all systems information, should be called only once after registering
+export async function init(ctx) {
+ if (db.isInit()) {
+ return;
+ }
+ for (let page=1; true; ++page) {
+ const response = await api.send({endpoint: `/systems?limit=20&page=${page}`, priority:100});
+ if (response.error !== undefined) {
+ throw response;
+ }
+ response.data.forEach(system => db.setSystem(system));
+ if (response.meta.total <= response.meta.limit * page) {
+ break;
+ }
+ }
+ console.log('Finished retrieving all systems information');
+ db.init();
}
-// Retrieves a list of waypoints that have a specific ctx.type like ASTEROID_FIELD in the system ctx.symbol
-export async function type(ctx, response) {
- const s = await system(ctx);
- return s.filter(s => s.type === ctx.type);
+// Retrieves a shipyard's information for ctx.symbol
+export async function shipyard(ctx) {
+ const systemSymbol = ctx.symbol.match(/([^-]+-[^-]+)/)[1]; // TODO generalise this extraction
+ console.log(systemSymbol);
+ return await api.send({endpoint: `/systems/${systemSymbol}/waypoints/${ctx.symbol}/shipyard`});
}
-// Retrieves the system's information for ctx.symbol and cache it in the database
+// Retrieves the system's information for ctx.symbol and caches it in the database
export async function system(ctx) {
let s = db.getSystem(ctx.symbol);
if (s === null) {
- const response = await api.send({endpoint: `/systems/${ctx.symbol}/waypoints?limit=20&page=1`});
+ const response = await api.send({endpoint: `/systems/${ctx.symbol}`});
if (response.error !== undefined) {
switch(response.error.code) {
case 404:
- throw `Error retrieving waypoints for system ${ctx.symbol}: ${response.error.message}`;
+ throw `Error retrieving info for system ${ctx.symbol}: ${response.error.message}`;
default: // yet unhandled error
throw response;
}
}
- if (response.meta !== undefined && response.meta.total > response.meta.limit) {
- throw `Error retrieving waypoints for system ${ctx.symbol}: Pagination is not implemented yet!`;
- }
s = response.data;
- db.setSystem(ctx.symbol, s);
+ db.setSystem(s);
}
return s;
}
-export async function systems(ctx) {
- const response = await api.send({endpoint: `/systems?limit=20&page=1`});
- // TODO pagination
- return response;
+// Retrieves a list of waypoints that have a specific ctx.trait like a SHIPYARD or a MARKETPLACE in the system ctx.symbol
+export async function trait(ctx) {
+ const s = await system(ctx);
+ return s.waypoints.filter(s => s.traits.some(t => t.symbol === ctx.trait));
}
-// Retrieves a shipyard's information for ctx.symbol
-export async function shipyard(ctx) {
- const systemSymbol = ctx.symbol.match(/([^-]+-[^-]+)/)[1]; // TODO generalise this extraction
- console.log(systemSymbol);
- return await api.send({endpoint: `/systems/${systemSymbol}/waypoints/${ctx.symbol}/shipyard`});
+// Retrieves a list of waypoints that have a specific ctx.type like ASTEROID_FIELD in the system ctx.symbol
+export async function type(ctx, response) {
+ const s = await system(ctx);
+ return s.waypoints.filter(s => s.type === ctx.type);
+}
+
+// Retrieves the system's information for ctx.symbol and caches it in the database
+export async function waypoints(ctx) {
+ await system(ctx);
+ let updated = db.getSystemUpdated(ctx.symbol);
+ if (updated === null) {
+ let waypoints = [];
+ for (let page=1; true; ++page) {
+ const response = await api.send({endpoint: `/systems/${ctx.symbol}/waypoints?limit=20&page=${page}`, priority: 98});
+ if (response.error !== undefined) {
+ switch(response.error.code) {
+ case 404:
+ throw `Error retrieving waypoints for system ${ctx.symbol}: ${response.error.message}`;
+ default: // yet unhandled error
+ throw response;
+ }
+ }
+ waypoints = waypoints.concat(response.data);
+ if (response.meta.total <= response.meta.limit * page) {
+ break;
+ }
+ }
+ db.setSystemWaypoints(ctx.symbol, waypoints);
+ return waypoints;
+ }
+ return db.getSystem(ctx.symbol).waypoints;
}