diff options
| -rw-r--r-- | packages/pipeline/src/entities/SraOrder.ts | 1 | ||||
| -rw-r--r-- | packages/pipeline/src/index.ts | 4 |
2 files changed, 4 insertions, 1 deletions
diff --git a/packages/pipeline/src/entities/SraOrder.ts b/packages/pipeline/src/entities/SraOrder.ts index c9a1f926d..e4987df57 100644 --- a/packages/pipeline/src/entities/SraOrder.ts +++ b/packages/pipeline/src/entities/SraOrder.ts @@ -7,6 +7,7 @@ export class SraOrder extends BaseEntity { @PrimaryColumn() public exchangeAddress!: string; @PrimaryColumn() public orderHashHex!: string; + @Column() public sourceUrl!: string; @Column() public lastUpdatedTimestamp!: number; @Column() public firstSeenTimestamp!: number; diff --git a/packages/pipeline/src/index.ts b/packages/pipeline/src/index.ts index 3e8434e3d..c442c7970 100644 --- a/packages/pipeline/src/index.ts +++ b/packages/pipeline/src/index.ts @@ -47,10 +47,12 @@ async function getSraOrdersAsync(): Promise<void> { const orderRepository = connection.getRepository(SraOrder); console.log(`found ${await orderRepository.count()} existing orders`); - const connect = new HttpClient('https://api.radarrelay.com/0x/v2'); + const sraUrl = 'https://api.radarrelay.com/0x/v2'; + const connect = new HttpClient(sraUrl); const rawOrders = await connect.getOrdersAsync(); const orders = parseSraOrders(rawOrders); for (const order of orders) { + order.sourceUrl = sraUrl; order.save(); } console.log(`now there are ${await orderRepository.count()} total orders`); |