From 08eb0b91b6d0f0dc90ae920a18ca5dd080bf235c Mon Sep 17 00:00:00 2001 From: Alex Browne Date: Wed, 5 Dec 2018 12:27:32 -0800 Subject: [PATCH] Fix RadarRelay timestamps (#1391) * Fixing rr timestamps * Apply prettier --- .../pipeline/src/entities/sra_order_observed_timestamp.ts | 7 +++++-- packages/pipeline/src/scripts/pull_radar_relay_orders.ts | 5 +++-- 2 files changed, 8 insertions(+), 4 deletions(-) diff --git a/packages/pipeline/src/entities/sra_order_observed_timestamp.ts b/packages/pipeline/src/entities/sra_order_observed_timestamp.ts index cd2d413973..cbec1c6d0e 100644 --- a/packages/pipeline/src/entities/sra_order_observed_timestamp.ts +++ b/packages/pipeline/src/entities/sra_order_observed_timestamp.ts @@ -22,11 +22,14 @@ export class SraOrdersObservedTimeStamp { * current time. * @param order The order to generate a timestamp for. */ -export function createObservedTimestampForOrder(order: SraOrder): SraOrdersObservedTimeStamp { +export function createObservedTimestampForOrder( + order: SraOrder, + observedTimestamp: number, +): SraOrdersObservedTimeStamp { const observed = new SraOrdersObservedTimeStamp(); observed.exchangeAddress = order.exchangeAddress; observed.orderHashHex = order.orderHashHex; observed.sourceUrl = order.sourceUrl; - observed.observedTimestamp = Date.now(); + observed.observedTimestamp = observedTimestamp; return observed; } diff --git a/packages/pipeline/src/scripts/pull_radar_relay_orders.ts b/packages/pipeline/src/scripts/pull_radar_relay_orders.ts index 6c18bcaef8..40bb6fc97f 100644 --- a/packages/pipeline/src/scripts/pull_radar_relay_orders.ts +++ b/packages/pipeline/src/scripts/pull_radar_relay_orders.ts @@ -33,11 +33,12 @@ async function getOrderbookAsync(): Promise { // Save all the orders and update the observed time stamps in a single // transaction. console.log('Saving orders and updating timestamps...'); + const observedTimestamp = Date.now(); await connection.transaction(async (manager: EntityManager): Promise => { for (const order of orders) { await manager.save(SraOrder, order); - const observedTimestamp = createObservedTimestampForOrder(order); - await manager.save(observedTimestamp); + const orderObservation = createObservedTimestampForOrder(order, observedTimestamp); + await manager.save(orderObservation); } }); }