summaryrefslogtreecommitdiff
path: root/nodejs/lib
diff options
context:
space:
mode:
authorJulien Dessaux2024-03-17 01:26:51 +0100
committerJulien Dessaux2024-03-17 01:27:44 +0100
commit1b1df83ffd68ff1a8c62fc7d6bef1a1fde19cb6b (patch)
treec8c153795d610525c2e4eedd99502b15f54566d1 /nodejs/lib
parent[javascript] refactoring (diff)
downloadspacetraders-1b1df83ffd68ff1a8c62fc7d6bef1a1fde19cb6b.tar.gz
spacetraders-1b1df83ffd68ff1a8c62fc7d6bef1a1fde19cb6b.tar.bz2
spacetraders-1b1df83ffd68ff1a8c62fc7d6bef1a1fde19cb6b.zip
[javascript] Implementing market data gathering and caching
Diffstat (limited to '')
-rw-r--r--nodejs/lib/systems.js30
1 files changed, 23 insertions, 7 deletions
diff --git a/nodejs/lib/systems.js b/nodejs/lib/systems.js
index fefa5cd..6993431 100644
--- a/nodejs/lib/systems.js
+++ b/nodejs/lib/systems.js
@@ -1,18 +1,34 @@
import * as api from './api.js';
-import * as db from '../database/systems.js';
+import * as dbMarkets from '../database/markets.js';
+import * as dbShips from '../database/ships.js';
+import * as dbSystems from '../database/systems.js';
import * as utils from './utils.js';
+// Retrieves a marketplace's market data for waypointSymbol
+export async function market(waypointSymbol) {
+ const data = dbMarkets.getMarketAtWaypoint(waypointSymbol);
+ if (data === null) {
+ if (dbShips.getShipsAt(waypointSymbol) === null) {
+ return null;
+ }
+ const systemSymbol = utils.systemFromWaypoint(waypointSymbol);
+ let d = await api.send({endpoint: `/systems/${systemSymbol}/waypoints/${waypointSymbol}/market`});
+ delete d.data.transactions;
+ dbMarkets.setMarket(d.data);
+ return d;
+ }
+ return data;
+}
// Retrieves a shipyard's information for ctx.symbol
export async function shipyard(ctx) {
const systemSymbol = utils.systemFromWaypoint(ctx.symbol);
- console.log(systemSymbol);
return await api.send({endpoint: `/systems/${systemSymbol}/waypoints/${ctx.symbol}/shipyard`});
}
// 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);
+ let s = dbSystems.getSystem(ctx.symbol);
if (s === null) {
const response = await api.send({endpoint: `/systems/${ctx.symbol}`});
if (response.error !== undefined) {
@@ -24,7 +40,7 @@ export async function system(ctx) {
}
}
s = response.data;
- db.setSystem(s);
+ dbSystems.setSystem(s);
}
return s;
}
@@ -44,7 +60,7 @@ export async function type(ctx, response) {
// 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);
+ let updated = dbSystems.getSystemUpdated(ctx.symbol);
// TODO handle uncharted systems
if (updated === null) {
let waypoints = [];
@@ -63,8 +79,8 @@ export async function waypoints(ctx) {
break;
}
}
- db.setSystemWaypoints(ctx.symbol, waypoints);
+ dbSystems.setSystemWaypoints(ctx.symbol, waypoints);
return waypoints;
}
- return db.getSystem(ctx.symbol).waypoints;
+ return dbSystems.getSystem(ctx.symbol).waypoints;
}