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

Add soruceUrl to SraOrder entity

Browse Source
This commit is contained in:
Alex Browne
2018-09-27 13:53:37 -07:00
parent 9ab55ccec0
commit dd093daf91
2 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
packages/pipeline/src/entities/SraOrder.ts
View File

@@ -7,6 +7,7 @@ export class SraOrder extends BaseEntity {
@PrimaryColumn() public exchangeAddress!: string; @PrimaryColumn() public exchangeAddress!: string;
@PrimaryColumn() public orderHashHex!: string; @PrimaryColumn() public orderHashHex!: string;
@Column() public sourceUrl!: string;
@Column() public lastUpdatedTimestamp!: number; @Column() public lastUpdatedTimestamp!: number;
@Column() public firstSeenTimestamp!: number; @Column() public firstSeenTimestamp!: number;

4
packages/pipeline/src/index.ts
View File

@@ -47,10 +47,12 @@ async function getSraOrdersAsync(): Promise<void> {
const orderRepository = connection.getRepository(SraOrder); const orderRepository = connection.getRepository(SraOrder);
console.log(`found ${await orderRepository.count()} existing orders`); 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 rawOrders = await connect.getOrdersAsync();
const orders = parseSraOrders(rawOrders); const orders = parseSraOrders(rawOrders);
for (const order of orders) { for (const order of orders) {
order.sourceUrl = sraUrl;
order.save(); order.save();
} }
console.log(`now there are ${await orderRepository.count()} total orders`); console.log(`now there are ${await orderRepository.count()} total orders`);