summaryrefslogtreecommitdiff
path: root/nodejs/lib
diff options
context:
space:
mode:
Diffstat (limited to 'nodejs/lib')
-rw-r--r--nodejs/lib/contracts.js35
1 files changed, 31 insertions, 4 deletions
diff --git a/nodejs/lib/contracts.js b/nodejs/lib/contracts.js
index 5c2e970..a009889 100644
--- a/nodejs/lib/contracts.js
+++ b/nodejs/lib/contracts.js
@@ -19,21 +19,48 @@ export async function contracts() {
return contracts;
}
+// returns true if the contract has been fulfilled
export async function deliver(ctx) {
+ const contract = dbContracts.getContract(ctx.id);
+ if (contract.terms.deliver[0].unitsRequired === contract.terms.deliver[0].unitsFulfilled) {
+ await fulfill(ctx);
+ return true;
+ }
await libShips.dock(ctx);
- const response = await api.send({ endpoint: `/my/contracts/${ctx.contract}/deliver`, method: 'POST', payload: {
+ const response = await api.send({ endpoint: `/my/contracts/${ctx.id}/deliver`, method: 'POST', payload: {
shipSymbol: ctx.symbol,
tradeSymbol: ctx.good,
units: ctx.units,
}});
if (response.error !== undefined) {
- throw response;
+ switch(response.error.code) {
+ case 4509: // contract delivery terms have been met
+ await fulfill(ctx);
+ return true;
+ default: // yet unhandled error
+ api.debugLog(response);
+ throw response;
+ }
}
+ dbContracts.setContract(response.data.contract);
dbShips.setShipCargo(ctx.symbol, response.data.cargo);
- // TODO update contract delivered units
// TODO track credits
+ if(response.data.contract.terms.deliver[0].unitsRequired === response.data.contract.terms.deliver[0].unitsFulfilled) {
+ await fulfill(ctx);
+ return true;
+ }
+ return false;
}
export async function fulfill(ctx) {
- return await api.send({ endpoint: `/my/contracts/${ctx.contract}/fulfill`, method: 'POST'});
+ const contract = dbContracts.getContract(ctx.id);
+ if (contract.fulfilled) {
+ return;
+ }
+ const response = await api.send({ endpoint: `/my/contracts/${ctx.id}/fulfill`, method: 'POST'});
+ if (response.error !== undefined) {
+ api.debugLog(response);
+ throw response;
+ }
+ dbContracts.setContract(response.data.contract);
}