From 8819cf9c67e33c76cbac65a9ca2b6ff86786d251 Mon Sep 17 00:00:00 2001 From: Julien Dessaux Date: Sat, 30 Mar 2024 14:22:59 +0100 Subject: [node] fixed contracting and implemented renegotiation --- nodejs/automation/contracting.ts | 54 ++++++++++++++++++++-------------------- nodejs/automation/init.ts | 9 ++++--- nodejs/automation/mining.ts | 17 ++++++++----- nodejs/database/contracts.ts | 13 ++++------ nodejs/database/markets.ts | 2 +- nodejs/database/ships.ts | 13 ++++------ nodejs/lib/contracts.ts | 19 +++++++++++--- nodejs/lib/ships.ts | 47 +++++++++++++++++++++++----------- 8 files changed, 103 insertions(+), 71 deletions(-) (limited to 'nodejs') diff --git a/nodejs/automation/contracting.ts b/nodejs/automation/contracting.ts index ab3c606..7fc8877 100644 --- a/nodejs/automation/contracting.ts +++ b/nodejs/automation/contracting.ts @@ -11,7 +11,7 @@ import * as systems from '../lib/systems.ts'; import * as utils from '../lib/utils.ts'; export async function init() { - const cs = dbContracts.getContracts(); + const cs = dbContracts.getContracts().filter(c => !c.fulfilled); cs.forEach(contract => run(contract)); } @@ -37,34 +37,34 @@ async function runProcurement(contract: Contract, ships: Array) { const asteroids = await systems.type(ships[0].nav.systemSymbol, 'ENGINEERED_ASTEROID'); const asteroidSymbol = asteroids[0].symbol; ships.forEach(async function(ship) { - while (!contract.fulfilled) { - ship = dbShips.getShip(ship.symbol) as Ship; - let goodCargo = ship.cargo.inventory.filter(i => i.symbol === wantedCargo)[0] - // If we are in transit, we wait until we arrive - const delay = new Date(ship.nav.route.arrival).getTime() - new Date().getTime(); - if (delay > 0) await api.sleep(delay); - // Then it depends on where we are - switch (ship.nav.waypointSymbol) { - case asteroidSymbol: - await mining.mineUntilFullOf(wantedCargo, ship, asteroidSymbol); - await libShips.navigate(ship, deliveryPoint); - break; - case deliveryPoint: - if (goodCargo !== undefined) { // we could be here if a client restart happens right after selling before we navigate away - console.log(`delivering ${goodCargo.units} of ${wantedCargo}`); - contract = await contracts.deliver(contract, ship); - if (contract.fulfilled) break; - } - await libShips.navigate(ship, asteroidSymbol); - break; - default: - if (libShips.isFull(ship)) { - await selling.sell(ship, wantedCargo); - } else { + while (true) { + while (!contract.fulfilled) { + ship = dbShips.getShip(ship.symbol); + let goodCargo = ship.cargo.inventory.filter(i => i.symbol === wantedCargo)[0] + // If we are in transit, we wait until we arrive + const delay = new Date(ship.nav.route.arrival).getTime() - new Date().getTime(); + if (delay > 0) await api.sleep(delay); + // Then it depends on where we are + switch (ship.nav.waypointSymbol) { + case asteroidSymbol: + await mining.mineUntilFullFor(contract, ship, asteroidSymbol); + await libShips.navigate(ship, deliveryPoint); + break; + case deliveryPoint: + 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); + if (contract.fulfilled) break; + } await libShips.navigate(ship, asteroidSymbol); - } + break; + default: + if (await libShips.isFull(ship)) { + await selling.sell(ship, wantedCargo); + } + await libShips.navigate(ship, asteroidSymbol); + } } + contract = await libShips.negotiate(ship); // TODO that's not correct, the procurement type can change } - // TODO repurpose the ship }); } diff --git a/nodejs/automation/init.ts b/nodejs/automation/init.ts index 2850fac..74f42fb 100644 --- a/nodejs/automation/init.ts +++ b/nodejs/automation/init.ts @@ -29,8 +29,11 @@ export async function init(): Promise { if (json.error !== undefined) { switch(json.error?.code) { case 4111: // 4111 means the agent symbol has already been claimed so no server reset happened - await libContracts.contracts(); - await libShips.ships(); + // TODO await agents.agents(); + const contracts = await libContracts.getContracts(); + const ongoing = contracts.filter(c => !c.fulfilled); + const ships = await libShips.getShips(); + if (ongoing.length === 0) libShips.negotiate(ships[0]); return; default: throw json; @@ -42,5 +45,5 @@ export async function init(): Promise { dbContracts.setContract(json.data.contract); dbShips.setShip(json.data.ship); // Temporary fix to fetch the data on the startup probe - await libShips.ships(); + await libShips.getShips(); } diff --git a/nodejs/automation/mining.ts b/nodejs/automation/mining.ts index b9db7d4..272c39a 100644 --- a/nodejs/automation/mining.ts +++ b/nodejs/automation/mining.ts @@ -1,21 +1,26 @@ import * as selling from './selling.js'; +import * as dbContracts from '../database/contracts.js'; import * as dbShips from '../database/ships.js'; import * as api from '../lib/api.js'; import * as libShips from '../lib/ships.js'; import * as utils from '../lib/utils.js'; +import { Contract } from '../model/contract.ts'; import { Ship } from '../model/ship.ts'; -export async function mineUntilFullOf(good: string, ship: Ship, asteroidSymbol: string): Promise { +export async function mineUntilFullFor(contract: Contract, ship: Ship, asteroidSymbol: string): Promise { // TODO find a good asteroid while(true) { await mineUntilFull(ship); - ship = dbShips.getShip(ship.symbol) as Ship; - const cargo = utils.categorizeCargo(ship.cargo, good); + contract = dbContracts.getContract(contract.id); + const deliver = contract.terms.deliver[0]; + ship = dbShips.getShip(ship.symbol); + const cargo = utils.categorizeCargo(ship.cargo, deliver.tradeSymbol); const wantedUnits = Object.values(cargo.wanted).reduce((acc, e) => acc += e, 0); - // > 90% full of the valuable goods ? - if (wantedUnits >= ship.cargo.capacity * 0.9) return ship; + // > 90% full of the valuable goods ? Or just have enough for the contract? + if (wantedUnits >= ship.cargo.capacity * 0.9 + || cargo.wanted[deliver.tradeSymbol] >= deliver.unitsRequired - deliver.unitsFulfilled) return; // we are full but need to sell junk - await selling.sell(ship, good); + await selling.sell(ship, deliver.tradeSymbol); await libShips.navigate(ship, asteroidSymbol); } } diff --git a/nodejs/database/contracts.ts b/nodejs/database/contracts.ts index 8442622..64d6c65 100644 --- a/nodejs/database/contracts.ts +++ b/nodejs/database/contracts.ts @@ -18,12 +18,9 @@ export function getContracts(): Array { } export function setContract(data: Contract): void { - if (getContract(data.id) === null) { - addContractStatement.run(JSON.stringify(data)); - } else { - updateContractStatement.run({ - data: JSON.stringify(data), - id: data.id, - }); - } + const changes = updateContractStatement.run({ + data: JSON.stringify(data), + id: data.id, + }).changes; + if (changes === 0) addContractStatement.run(JSON.stringify(data)); } diff --git a/nodejs/database/markets.ts b/nodejs/database/markets.ts index 7ae5ca2..558d181 100644 --- a/nodejs/database/markets.ts +++ b/nodejs/database/markets.ts @@ -8,7 +8,7 @@ const getMarketAtWaypointStatement = db.prepare(`SELECT data FROM markets WHERE const updateMarketStatement = db.prepare(`UPDATE markets SET data = json(:data) WHERE data->>'symbol' = :symbol;`); export function getMarketAtWaypoint(symbol: string): Market|null { - const data = getMarketAtWaypointStatement.get(symbol) as DbData; + const data = getMarketAtWaypointStatement.get(symbol) as DbData|undefined; if (!data) return null; return JSON.parse(data.data); } diff --git a/nodejs/database/ships.ts b/nodejs/database/ships.ts index f918099..5ea2ffa 100644 --- a/nodejs/database/ships.ts +++ b/nodejs/database/ships.ts @@ -23,14 +23,11 @@ export function getShipsAt(symbol: string): Array { export function setShip(data: Ship): void { - if (getShip(data.symbol) === null) { - addShipStatement.run(JSON.stringify(data)); - } else { - updateShipStatement.run({ - data: JSON.stringify(data), - symbol: data.symbol, - }); - } + const changes = updateShipStatement.run({ + data: JSON.stringify(data), + symbol: data.symbol, + }).changes; + if (changes === 0) addShipStatement.run(JSON.stringify(data)); } export function setShipCargo(symbol: string, cargo: Cargo): void { diff --git a/nodejs/lib/contracts.ts b/nodejs/lib/contracts.ts index 54347cb..2b6f877 100644 --- a/nodejs/lib/contracts.ts +++ b/nodejs/lib/contracts.ts @@ -22,16 +22,29 @@ export async function accept(contract: Contract): Promise { return response.data.contract; } -export async function contracts(): Promise> { +export async function getContracts(): Promise> { const response = await api.sendPaginated({endpoint: '/my/contracts'}); response.forEach(contract => dbContracts.setContract(contract)); return response; } +export async function getContract(contract: Contract): Promise { + try { + return dbContracts.getContract(contract.id); + } catch {} + const response = await api.send({endpoint: `/my/contracts/${contract.id}`}); + if (response.error) { + api.debugLog(response); + throw response; + } + dbContracts.setContract(response.data); + return response.data; +} + export async function deliver(contract: Contract, ship: Ship): Promise { contract = dbContracts.getContract(contract.id); ship = dbShips.getShip(ship.symbol); - if (contract.terms.deliver[0].unitsRequired >= contract.terms.deliver[0].unitsFulfilled) { + if (contract.terms.deliver[0].unitsRequired <= contract.terms.deliver[0].unitsFulfilled) { return await fulfill(contract); } const tradeSymbol = contract.terms.deliver[0].tradeSymbol; @@ -54,7 +67,7 @@ export async function deliver(contract: Contract, ship: Ship): Promise } dbContracts.setContract(response.data.contract); dbShips.setShipCargo(ship.symbol, response.data.cargo); - if(response.data.contract.terms.deliver[0].unitsRequired >= response.data.contract.terms.deliver[0].unitsFulfilled) { + if(response.data.contract.terms.deliver[0].unitsRequired <= response.data.contract.terms.deliver[0].unitsFulfilled) { return await fulfill(response.data.contract); } return response.data.contract; diff --git a/nodejs/lib/ships.ts b/nodejs/lib/ships.ts index c673698..8fd3a6f 100644 --- a/nodejs/lib/ships.ts +++ b/nodejs/lib/ships.ts @@ -1,6 +1,7 @@ import { Response } from '../model/api.ts'; import { Agent } from '../model/agent.ts'; import { Cargo } from '../model/cargo.ts'; +import { Contract } from '../model/contract.ts'; import { Cooldown, Fuel, Nav, Ship } from '../model/ship.ts'; import * as api from './api.ts'; import * as dbAgents from '../database/agents.ts'; @@ -9,7 +10,7 @@ import * as dbShips from '../database/ships.ts'; import * as systems from '../lib/systems.ts'; export async function dock(ship: Ship): Promise { - ship = dbShips.getShip(ship.symbol); + ship = await getShip(ship); if (ship.nav.status === 'DOCKED') return; const response = await api.send<{nav: Nav}>({endpoint: `/my/ships/${ship.symbol}/dock`, method: 'POST'}); if (response.error) { @@ -27,8 +28,8 @@ export async function dock(ship: Ship): Promise { } export async function extract(ship: Ship): Promise { - ship = dbShips.getShip(ship.symbol); - if (isFull(ship)) return ship.cargo; + ship = await getShip(ship); + if (await isFull(ship)) return ship.cargo; // TODO move to a suitable asteroid? // const asteroidFields = await systems.type({symbol: ship.nav.systemSymbol, type: 'ENGINEERED_ASTEROID'}); // TODO if there are multiple fields, find the closest one? @@ -55,8 +56,8 @@ export async function extract(ship: Ship): Promise { return response.data.cargo } -export function isFull(ship: Ship): boolean { - ship = dbShips.getShip(ship.symbol); +export async function isFull(ship: Ship): Promise { + ship = await getShip(ship); return ship.cargo.units >= ship.cargo.capacity * 0.9; } @@ -73,7 +74,7 @@ export function isFull(ship: Ship): boolean { //} export async function navigate(ship: Ship, waypoint: string): Promise { - ship = dbShips.getShip(ship.symbol); + ship = await getShip(ship); if (ship.nav.waypointSymbol === waypoint) return; await orbit(ship); // TODO if we do not have enough fuel, make a stop to refuel along the way or drift to the destination @@ -99,13 +100,25 @@ export async function navigate(ship: Ship, waypoint: string): Promise { await refuel(ship); } -//export async function negotiate(ctx) { -// // TODO -// return await api.send({endpoint: `/my/ships/${ctx.ship}/negotiate/contract`, method: 'POST'}); -//} +export async function negotiate(ship: Ship): Promise { + ship = await getShip(ship); + const response = await api.send<{contract: Contract}>({endpoint: `/my/ships/${ship.symbol}/negotiate/contract`, method: 'POST'}); + if (response.error) { + switch(response.error.code) { + case 4214: // ship is in transit + const errorData = response.error.data as { secondsToArrival: number}; + await api.sleep(errorData.secondsToArrival * 1000); + return await negotiate(ship); + default: // yet unhandled error + api.debugLog(response); + throw response; + } + } + return response.data.contract; +} export async function orbit(ship: Ship): Promise { - ship = dbShips.getShip(ship.symbol); + ship = await getShip(ship); if (ship.nav.status === 'IN_ORBIT') return; const response = await api.send<{nav: Nav}>({endpoint: `/my/ships/${ship.symbol}/orbit`, method: 'POST'}); if (response.error) { @@ -115,6 +128,7 @@ export async function orbit(ship: Ship): Promise { await api.sleep(errorData.secondsToArrival * 1000); return await orbit(ship); default: // yet unhandled error + api.debugLog(response); throw response; } } @@ -134,7 +148,7 @@ export async function orbit(ship: Ship): Promise { //} export async function refuel(ship: Ship): Promise { - ship = dbShips.getShip(ship.symbol); + ship = await getShip(ship); if (ship.fuel.current >= ship.fuel.capacity * 0.9) return; // TODO check if our current waypoint has a marketplace (and sells fuel)? await dock(ship); @@ -148,7 +162,7 @@ export async function refuel(ship: Ship): Promise { } export async function sell(ship: Ship, tradeSymbol: string): Promise { - ship = dbShips.getShip(ship.symbol); + ship = await getShip(ship); // TODO check if our current waypoint has a marketplace and buys tradeSymbol? await dock(ship); let units = 0; @@ -163,7 +177,7 @@ export async function sell(ship: Ship, tradeSymbol: string): Promise { return response.data.cargo; } -export async function ships(): Promise> { +export async function getShips(): Promise> { const response = await api.send>({endpoint: `/my/ships`, page: 1}); if (response.error) { api.debugLog(response); @@ -173,7 +187,10 @@ export async function ships(): Promise> { return response.data; } -export async function ship(ship: Ship): Promise { +export async function getShip(ship: Ship): Promise { + try { + return dbShips.getShip(ship.symbol); + } catch {} const response = await api.send({endpoint: `/my/ships/${ship.symbol}`}); if (response.error) { api.debugLog(response); -- cgit v1.2.3