From 3e80bc8a4d3127d17dbc3f52301d33a79e53a980 Mon Sep 17 00:00:00 2001 From: Julien Dessaux Date: Sat, 6 Apr 2024 21:36:42 +0200 Subject: [node] multiple contracting fixes and some more refactoring --- nodejs/automation/contracting.ts | 53 +++++++++++++++++----------------------- nodejs/automation/selling.ts | 21 ++++------------ 2 files changed, 28 insertions(+), 46 deletions(-) (limited to 'nodejs/automation') diff --git a/nodejs/automation/contracting.ts b/nodejs/automation/contracting.ts index 93a9a0e..93c2f8e 100644 --- a/nodejs/automation/contracting.ts +++ b/nodejs/automation/contracting.ts @@ -1,29 +1,35 @@ -import { Contract } from '../lib/types.ts'; +import { debugLog } from '../lib/api.ts'; import { Ship } from '../lib/ships.ts'; +import { Contract } from '../lib/types.ts'; import * as mining from './mining.js'; import * as selling from './selling.js'; import * as dbContracts from '../database/contracts.ts'; -import * as contracts from '../lib/contracts.ts'; +import * as libContracts from '../lib/contracts.ts'; import * as libSystems from '../lib/systems.ts'; import * as systems from '../lib/systems.ts'; -import * as utils from '../lib/utils.ts'; +import { + sortByDistanceFrom, +} from '../lib/utils.ts'; export async function run(ship: Ship): Promise { - while(true) { // we use the fact that there can only be at most one active contract at a time - const contracts = dbContracts.getContracts().filter(c => !c.fulfilled); - let contract: Contract; - if (contracts.length === 0) { - contract = await ship.negotiate(); - } else { - contract = contracts[0]; - } + const contracts = await libContracts.getContracts(); + const active = contracts.filter(function(c) { + if (c.fulfilled) return false; + const deadline = new Date(c.terms.deadline).getTime(); + const now = new Date().getTime(); + return deadline > now; + }); + for (const contract of active) { await runOne(contract, ship); - await ship.negotiate(); + } + while(true) { + await runOne(await ship.negotiate(), ship); } } async function runOne(contract: Contract, ship: Ship): Promise { - await contracts.accept(contract); + debugLog(contract); + await libContracts.accept(contract); switch(contract.type) { case 'PROCUREMENT': if (contract.terms.deliver[0].tradeSymbol.match(/_ORE$/)) { @@ -52,7 +58,7 @@ async function runOreProcurement(contract: Contract, ship: Ship): Promise break; case deliveryPoint.symbol: if (goodCargo !== undefined) { // we could be here if a client restart happens right after selling before we navigate away - contract = await contracts.deliver(contract, ship); + contract = await libContracts.deliver(contract, ship); if (contract.fulfilled) return; } await ship.navigate(asteroid); @@ -73,20 +79,7 @@ async function runTradeProcurement(contract: Contract, ship: Ship): Promise b.distance) { - return 1; - } - return 0; - }); + const markets = sortByDistanceFrom(ship.nav.route.destination, await libSystems.trait(ship.nav.systemSymbol, 'MARKETPLACE')); // check from the closest one that exports what we need let buyingPoint: string = ""; outer: for (let i = 0; i < markets.length; i++) { @@ -105,7 +98,7 @@ async function runTradeProcurement(contract: Contract, ship: Ship): Promise { return ship; } // we need to move somewhere else to sell our remaining goods - // first we look into markets in our system - const rawMarkets = await libSystems.trait(ship.nav.systemSymbol, 'MARKETPLACE'); - // sorted by distance from where we are - const markets = rawMarkets.map(function (m) { return { - data: m, - distance: (m.x - ship.nav.route.destination.x) ** 2 + (m.y - ship.nav.route.destination.y) ** 2, - }}); - markets.sort(function(a, b) { - if (a.distance < b.distance) { - return -1; - } else if (a.distance > b.distance) { - return 1; - } - return 0; - }); + const markets = sortByDistanceFrom(ship.nav.route.destination, await libSystems.trait(ship.nav.systemSymbol, 'MARKETPLACE')); // check from the closest one if they import what we need to sell for (let i = 0; i < markets.length; i++) { const waypoint = await libSystems.waypoint(markets[i].data.symbol); -- cgit v1.2.3