crowetic/protocol
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix RadarRelay timestamps (#1391)

Browse Source 
* Fixing rr timestamps

* Apply prettier
This commit is contained in:
Alex Browne 2018-12-05 12:27:32 -08:00 committed by Jake Ellowitz
parent b2dd5495bc
commit 08eb0b91b6
2 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
packages/pipeline/src/entities/sra_order_observed_timestamp.ts
View File

@ -22,11 +22,14 @@ export class SraOrdersObservedTimeStamp {
* current time. * current time.
* @param order The order to generate a timestamp for. * @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(); const observed = new SraOrdersObservedTimeStamp();
observed.exchangeAddress = order.exchangeAddress; observed.exchangeAddress = order.exchangeAddress;
observed.orderHashHex = order.orderHashHex; observed.orderHashHex = order.orderHashHex;
observed.sourceUrl = order.sourceUrl; observed.sourceUrl = order.sourceUrl;
observed.observedTimestamp = Date.now(); observed.observedTimestamp = observedTimestamp;
return observed; return observed;
} }

5
packages/pipeline/src/scripts/pull_radar_relay_orders.ts
View File

@ -33,11 +33,12 @@ async function getOrderbookAsync(): Promise<void> {
// Save all the orders and update the observed time stamps in a single // Save all the orders and update the observed time stamps in a single
// transaction. // transaction.
console.log('Saving orders and updating timestamps...'); console.log('Saving orders and updating timestamps...');
const observedTimestamp = Date.now();
await connection.transaction(async (manager: EntityManager): Promise<void> => { await connection.transaction(async (manager: EntityManager): Promise<void> => {
for (const order of orders) { for (const order of orders) {
await manager.save(SraOrder, order); await manager.save(SraOrder, order);
const observedTimestamp = createObservedTimestampForOrder(order); const orderObservation = createObservedTimestampForOrder(order, observedTimestamp);
await manager.save(observedTimestamp); await manager.save(orderObservation);
} }
}); });
} }