[node] implemented basic procurement trading loop

2 files changed, 111 insertions, 44 deletions

diff --git a/nodejs/automation/contracting.ts b/nodejs/automation/contracting.ts
index 7fc8877..02715c8 100644
--- a/nodejs/automation/contracting.ts
+++ b/nodejs/automation/contracting.ts
@@ -7,64 +7,132 @@ import * as dbShips from '../database/ships.ts';
 import * as api from '../lib/api.ts';
 import * as contracts from '../lib/contracts.ts';
 import * as libShips from '../lib/ships.ts';
+import * as libSystems from '../lib/systems.ts';
 import * as systems from '../lib/systems.ts';
 import * as utils from '../lib/utils.ts';
 
-export async function init() {
-	const cs = dbContracts.getContracts().filter(c => !c.fulfilled);
-	cs.forEach(contract => run(contract));
+export async function init(): Promise<void> {
+	const ship = dbShips.getShips()[0]; // This should always be the command ship
+	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 libShips.negotiate(ship);
+		} else {
+			contract = contracts[0];
+		}
+		await run(contract, ship);
+		await libShips.negotiate(ship);
+	}
 }
 
-async function run(contract: Contract) {
+async function run(contract: Contract, ship: Ship): Promise<void> {
 	await contracts.accept(contract);
-	const contractSystem = utils.systemFromWaypoint(contract.terms.deliver[0].destinationSymbol);
-	let ships = dbShips.getShipsAt(contractSystem);
-	ships = ships.filter(ship => ship.registration.role !== 'SATELLITE'); // filter out probes
-
 	switch(contract.type) {
 		case 'PROCUREMENT':
-			await runProcurement(contract, ships);
+			if (contract.terms.deliver[0].tradeSymbol.match(/_ORE$/)) {
+				await runOreProcurement(contract, ship);
+			} else {
+				await runTradeProcurement(contract, ship);
+			}
 			break;
 		default:
 			throw `Handling of contract type ${contract.type} is not implemented yet`;
 	}
 }
 
-async function runProcurement(contract: Contract, ships: Array<Ship>) {
-	// TODO check if contract is fulfilled!
+async function runOreProcurement(contract: Contract, ship: Ship): Promise<void> {
 	const wantedCargo = contract.terms.deliver[0].tradeSymbol;
 	const deliveryPoint = contract.terms.deliver[0].destinationSymbol;
-	const asteroids = await systems.type(ships[0].nav.systemSymbol, 'ENGINEERED_ASTEROID');
+	const asteroids = await systems.type(ship.nav.systemSymbol, 'ENGINEERED_ASTEROID');
 	const asteroidSymbol = asteroids[0].symbol;
-	ships.forEach(async function(ship) {
-		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);
+	while (!contract.fulfilled) {
+		ship = dbShips.getShip(ship.symbol);
+		const goodCargo = ship.cargo.inventory.filter(i => i.symbol === wantedCargo)[0]
+		// what we do 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) return;
+				}
+				await libShips.navigate(ship, asteroidSymbol);
+				break;
+			default:
+				await selling.sell(ship, wantedCargo);
+				await libShips.navigate(ship, asteroidSymbol);
+		}
+	}
+}
+
+async function runTradeProcurement(contract: Contract, ship: Ship): Promise<void> {
+	const deliver = contract.terms.deliver[0];
+	const deliveryPoint = deliver.destinationSymbol;
+	const wantedCargo = deliver.tradeSymbol;
+	while (!contract.fulfilled) {
+		ship = dbShips.getShip(ship.symbol);
+		const goodCargo = ship.cargo.inventory.filter(i => i.symbol === wantedCargo)[0]
+		// make sure we are not carrying useless stuff
+		await selling.sell(ship, wantedCargo);
+		// go buy what we need
+		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;
+		});
+		// check from the closest one that exports what we need
+		let buyingPoint: string = null;
+		outer: for (let i = 0; i < markets.length; i++) {
+			const waypointSymbol = markets[i].data.symbol;
+			const market = await libSystems.market(waypointSymbol);
+			for (let j = 0; j < market.exports; j++) {
+				if (market.exports[j].symbol === wantedCargo) {
+					buyingPoint = market.symbol;
+					break outer;
 				}
 			}
-			contract = await libShips.negotiate(ship); 	// TODO that's not correct, the procurement type can change
 		}
-	});
+		// if we did not find an exporting market we look for an exchange
+		if (buyingPoint === null) {
+			outer: for (let i = 0; i < markets.length; i++) {
+				const waypointSymbol = markets[i].data.symbol;
+				const market = await libSystems.market(waypointSymbol);
+				for (let j = 0; j < market.exchanges; j++) {
+					if (market.exports[j].symbol === wantedCargo) {
+						buyingPoint = market.symbol;
+						break outer;
+					}
+				}
+			}
+		}
+		if (buyingPoint === null) {
+			throw `runTradeProcurement failed, no market exports or exchanges ${wantedCargo}`;
+		}
+		// go buy what we need
+		await libShips.navigate(ship, buyingPoint);
+		const units = Math.min(
+			deliver.unitsRequired - deliver.unitsFulfilled,
+			ship.cargo.capacity - ship.cargo.units,
+		);
+		await libShips.buy(ship, wantedCargo, units);
+		// then make a delivery
+		await libShips.navigate(ship, deliveryPoint);
+		contract = await contracts.deliver(contract, ship);
+		if (contract.fulfilled) return;
+	}
+	console.log("runTradeProcurement not implemented");
+	throw "not implemented";
 }
diff --git a/nodejs/automation/init.ts b/nodejs/automation/init.ts
index 74f42fb..79c5e39 100644
--- a/nodejs/automation/init.ts
+++ b/nodejs/automation/init.ts
@@ -8,6 +8,7 @@ import { Response } from '../model/api.ts';
 import { Contract } from '../model/contract.ts';
 import { Ship } from '../model/ship.ts';
 import * as api from '../lib/api.ts';
+//import * as agents from '../lib/angent.ts';
 import * as libContracts from '../lib/contracts.ts';
 import * as libShips from '../lib/ships.ts';
 
@@ -30,10 +31,8 @@ export async function init(): Promise<void> {
 		switch(json.error?.code) {
 			case 4111:  // 4111 means the agent symbol has already been claimed so no server reset happened
 				// 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]);
+				await libContracts.getContracts();
+				await libShips.getShips();
 				return;
 			default:
 				throw json;