diff options
author | Alex Browne <stephenalexbrowne@gmail.com> | 2018-11-14 07:33:43 +0800 |
---|---|---|
committer | Alex Browne <stephenalexbrowne@gmail.com> | 2018-12-05 06:24:48 +0800 |
commit | 26280e4aba147ad6000b9df309e64db84b6932fc (patch) | |
tree | 5d8c2ba185216e35dde39de56964940ba54add93 /packages/pipeline/src/entities/sra_order_observed_timestamp.ts | |
parent | 55bbe1954b35ff0a6367f1ff820d32a32b48eff3 (diff) | |
download | dexon-sol-tools-26280e4aba147ad6000b9df309e64db84b6932fc.tar dexon-sol-tools-26280e4aba147ad6000b9df309e64db84b6932fc.tar.gz dexon-sol-tools-26280e4aba147ad6000b9df309e64db84b6932fc.tar.bz2 dexon-sol-tools-26280e4aba147ad6000b9df309e64db84b6932fc.tar.lz dexon-sol-tools-26280e4aba147ad6000b9df309e64db84b6932fc.tar.xz dexon-sol-tools-26280e4aba147ad6000b9df309e64db84b6932fc.tar.zst dexon-sol-tools-26280e4aba147ad6000b9df309e64db84b6932fc.zip |
Implement scraping sra orders from radar relay
Diffstat (limited to 'packages/pipeline/src/entities/sra_order_observed_timestamp.ts')
-rw-r--r-- | packages/pipeline/src/entities/sra_order_observed_timestamp.ts | 30 |
1 files changed, 30 insertions, 0 deletions
diff --git a/packages/pipeline/src/entities/sra_order_observed_timestamp.ts b/packages/pipeline/src/entities/sra_order_observed_timestamp.ts new file mode 100644 index 000000000..bdb6cd36b --- /dev/null +++ b/packages/pipeline/src/entities/sra_order_observed_timestamp.ts @@ -0,0 +1,30 @@ +import { Entity, PrimaryColumn } from 'typeorm'; + +import { SraOrder } from './sra_order'; + +@Entity({ name: 'sra_orders_observed_timestamps', schema: 'raw' }) +export class SraOrdersObservedTimeStamp { + @PrimaryColumn({ name: 'exchange_address' }) + public exchangeAddress!: string; + @PrimaryColumn({ name: 'order_hash_hex' }) + public orderHashHex!: string; + @PrimaryColumn({ name: 'source_url' }) + public sourceUrl!: string; + + @PrimaryColumn({ name: 'observed_timestamp' }) + public observedTimestamp!: number; +} + +/** + * Returns a new SraOrdersObservedTimeStamp for the given order based on the + * current time. + * @param order The order to generate a timestamp for. + */ +export function createObservedTimestampForOrder(order: SraOrder): SraOrdersObservedTimeStamp { + const observed = new SraOrdersObservedTimeStamp(); + observed.exchangeAddress = order.exchangeAddress; + observed.orderHashHex = order.orderHashHex; + observed.sourceUrl = order.sourceUrl; + observed.observedTimestamp = Date.now(); + return observed; +} |