nodejs/database/markets.js


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34

import db from './db.js';
import * as utils from '../lib/utils.js';

const addMarketStatement = db.prepare(`INSERT INTO markets(system, data) VALUES (?, json(?));`);
const getMarketAtWaypointStatement = db.prepare(`SELECT data FROM markets WHERE data->>'symbol' = ?;`);
const getMarketsInSystemStatement = db.prepare(`SELECT data FROM markets WHERE system = ?;`);
const updateMarketStatement = db.prepare(`UPDATE markets SET data = json(:data) WHERE data->>'symbol' = :symbol;`);

export function getMarketAtWaypoint(symbol) {
    const data = getMarketAtWaypointStatement.get(symbol);
    if (data === undefined) {
	return null;
    }
    return JSON.parse(data.data);
}

export function getMarketsInSystem(symbol) {
    const data = getMarketsInSystemStatement.get(symbol);
    if (data === undefined) {
	return null;
    }
    return JSON.parse(data.data);
}

export function setMarket(data) {
    if (getMarketAtWaypoint(data.symbol) === null) {
	const system = utils.systemFromWaypoint(data.symbol);
	return addMarketStatement.run(system, JSON.stringify(data)).lastInsertRowid;
    }
    return updateMarketStatement.run({
	data: JSON.stringify(data),
	symbol: data.symbol,
    }).changes;
}