diff options
author | Alex Browne <stephenalexbrowne@gmail.com> | 2018-11-14 07:33:43 +0800 |
---|---|---|
committer | Fred Carlsen <fred@sjelfull.no> | 2018-12-06 19:04:25 +0800 |
commit | e394c4fe1dd3bcceb382bb56e9c63e0b320e193f (patch) | |
tree | 1af4fe8639441006826ab8132155f28251fb0119 /packages/pipeline/src/entities/sra_order_observed_timestamp.ts | |
parent | 5c655eeda75f8a859378a0511d9e19438c149a60 (diff) | |
download | dexon-sol-tools-e394c4fe1dd3bcceb382bb56e9c63e0b320e193f.tar dexon-sol-tools-e394c4fe1dd3bcceb382bb56e9c63e0b320e193f.tar.gz dexon-sol-tools-e394c4fe1dd3bcceb382bb56e9c63e0b320e193f.tar.bz2 dexon-sol-tools-e394c4fe1dd3bcceb382bb56e9c63e0b320e193f.tar.lz dexon-sol-tools-e394c4fe1dd3bcceb382bb56e9c63e0b320e193f.tar.xz dexon-sol-tools-e394c4fe1dd3bcceb382bb56e9c63e0b320e193f.tar.zst dexon-sol-tools-e394c4fe1dd3bcceb382bb56e9c63e0b320e193f.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; +} |