90 lines
3 KiB
TypeScript
90 lines
3 KiB
TypeScript
import {
|
|
Agent,
|
|
Cargo,
|
|
Contract,
|
|
} from './types.ts';
|
|
import {
|
|
APIError,
|
|
debugLog,
|
|
send,
|
|
sendPaginated,
|
|
} from './api.ts';
|
|
import { Ship } from './ships.ts';
|
|
import * as dbAgents from '../database/agents.ts';
|
|
import * as dbContracts from '../database/contracts.ts';
|
|
|
|
export async function accept(contract: Contract): Promise<Contract> {
|
|
contract = dbContracts.getContract(contract.id);
|
|
if (contract.accepted) return contract;
|
|
const response = await send<{agent: Agent, contract: Contract, type: ''}>({endpoint: `/my/contracts/${contract.id}/accept`, method: 'POST'});
|
|
if (response.error) {
|
|
debugLog(response);
|
|
throw response;
|
|
}
|
|
dbAgents.setAgent(response.data.agent);
|
|
dbContracts.setContract(response.data.contract);
|
|
return response.data.contract;
|
|
}
|
|
|
|
export async function getContracts(): Promise<Array<Contract>> {
|
|
const response = await sendPaginated<Contract>({endpoint: '/my/contracts'});
|
|
response.forEach(contract => dbContracts.setContract(contract));
|
|
return response;
|
|
}
|
|
|
|
export async function getContract(contract: Contract): Promise<Contract> {
|
|
try {
|
|
return dbContracts.getContract(contract.id);
|
|
} catch {}
|
|
const response = await send<Contract>({endpoint: `/my/contracts/${contract.id}`});
|
|
if (response.error) {
|
|
debugLog(response);
|
|
throw response;
|
|
}
|
|
dbContracts.setContract(response.data);
|
|
return response.data;
|
|
}
|
|
|
|
export async function deliver(contract: Contract, ship: Ship): Promise<Contract> {
|
|
contract = dbContracts.getContract(contract.id);
|
|
if (contract.terms.deliver[0].unitsRequired <= contract.terms.deliver[0].unitsFulfilled) {
|
|
return await fulfill(contract);
|
|
}
|
|
const tradeSymbol = contract.terms.deliver[0].tradeSymbol;
|
|
let units = 0;
|
|
ship.cargo.inventory.forEach(i => {if (i.symbol === tradeSymbol) units = i.units; });
|
|
await ship.dock(); // we need to be docked to deliver
|
|
const response = await send<{contract: Contract, cargo: Cargo}>({ endpoint: `/my/contracts/${contract.id}/deliver`, method: 'POST', payload: {
|
|
shipSymbol: ship.symbol,
|
|
tradeSymbol: tradeSymbol,
|
|
units: units,
|
|
}});
|
|
if (response.error) {
|
|
switch(response.error.code) {
|
|
case 4509: // contract delivery terms have been met
|
|
return await fulfill(contract);
|
|
default: // yet unhandled error
|
|
debugLog(response);
|
|
throw response;
|
|
}
|
|
}
|
|
dbContracts.setContract(response.data.contract);
|
|
ship.cargo = response.data.cargo;
|
|
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;
|
|
}
|
|
|
|
export async function fulfill(contract: Contract): Promise<Contract> {
|
|
contract = dbContracts.getContract(contract.id);
|
|
if (contract.fulfilled) return contract;
|
|
const response = await send<{agent: Agent, contract: Contract}>({ endpoint: `/my/contracts/${contract.id}/fulfill`, method: 'POST'});
|
|
if (response.error) {
|
|
debugLog(response);
|
|
throw response;
|
|
}
|
|
dbAgents.setAgent(response.data.agent);
|
|
dbContracts.setContract(response.data.contract);
|
|
return response.data.contract;
|
|
}
|