Skip to content

Commit

Permalink
fix(order): include orderbook in ipfs upload
Browse files Browse the repository at this point in the history
  • Loading branch information
kodemon committed Aug 2, 2023
1 parent 5dfc204 commit b028d1f
Show file tree
Hide file tree
Showing 5 changed files with 21 additions and 1 deletion.
11 changes: 11 additions & 0 deletions package-lock.json

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

1 change: 1 addition & 0 deletions package.json
Original file line number Diff line number Diff line change
Expand Up @@ -37,6 +37,7 @@
},
"devDependencies": {
"@types/debug": "^4.1.8",
"@types/form-data": "^2.5.0",
"@types/http-errors": "^2.0.1",
"@types/node": "^18.16.18",
"@types/node-fetch": "^2.6.4",
Expand Down
1 change: 1 addition & 0 deletions src/Methods/Order/CreateOrder/UploadOrder.ts
Original file line number Diff line number Diff line change
Expand Up @@ -13,6 +13,7 @@ export async function uploadOrder(params: Params): Promise<string> {
expiry: params.order.expiry,
satoshi: params.order.satoshi,
meta: params.order.meta,
orderbooks: params.order.orderbooks,
signature: params.signature.value,
signature_format: params.signature.format,
desc: params.signature.desc,
Expand Down
2 changes: 1 addition & 1 deletion src/Models/Worker.ts
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@ import { WithId } from "mongodb";
import { Network } from "../Libraries/Network";
import { mongo } from "../Services/Mongo";

export const collection = mongo.db.collection<WorkerDocument>("worker");
export const collection = mongo.db.collection<WorkerDocument>("workers");

/*
|--------------------------------------------------------------------------------
Expand Down
7 changes: 7 additions & 0 deletions src/worker.ts
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
import debug from "debug";

import { bootstrap } from "./Bootstrap";
import { getWorkers } from "./Models/Worker";
import { resolveOrderbook } from "./Orderbook/Resolver";
import { utils } from "./Utilities";
Expand All @@ -8,13 +9,19 @@ const log = debug("sado-worker");

async function start() {
log("resolving orderbooks");

await bootstrap();

const limiter = utils.promise.limiter(10);
const orderbooks = await getWorkers();
console.log(orderbooks);
for (const { address, network } of orderbooks) {
limiter.push(() => resolveOrderbook(address, network));
}
await limiter.run();

log("resolved orderbooks");

process.exit(0);
}

Expand Down

0 comments on commit b028d1f

Please sign in to comment.