From 90e1028d2fd154b8c637139145a2dc1c6999d585 Mon Sep 17 00:00:00 2001
From: Alex Browne <stephenalexbrowne@gmail.com>
Date: Wed, 19 Sep 2018 17:30:34 -0700
Subject: Add typeorm and begin inserting database records

---
 packages/pipeline/src/index.ts | 38 +++++++++++++++++++++++++++++++++++---
 1 file changed, 35 insertions(+), 3 deletions(-)

(limited to 'packages/pipeline/src/index.ts')

diff --git a/packages/pipeline/src/index.ts b/packages/pipeline/src/index.ts
index eccb24d18..d70ec3e3e 100644
--- a/packages/pipeline/src/index.ts
+++ b/packages/pipeline/src/index.ts
@@ -1,13 +1,45 @@
-import { Etherscan } from './data-sources/etherscan';
+import { ExchangeFillEventArgs } from '@0xproject/contract-wrappers';
+import { LogWithDecodedArgs } from 'ethereum-types';
+import 'reflect-metadata';
+import { createConnection } from 'typeorm';
 
 import { artifacts } from './artifacts';
+import { Etherscan } from './data-sources/etherscan';
+import { ExchangeFillEvent } from './entities/ExchangeFillEvent';
+import { config } from './ormconfig';
 
 const etherscan = new Etherscan(process.env.ETHERSCAN_API_KEY as string);
 
 (async () => {
-    const events = await etherscan.getContractEventsAsync(
+    const connection = await createConnection(config);
+    const repository = connection.getRepository(ExchangeFillEvent);
+    console.log(`found ${await repository.count()} existing fill events`);
+    const eventLogs = await etherscan.getContractEventsAsync(
         '0x4f833a24e1f95d70f028921e27040ca56e09ab0b',
         artifacts.Exchange.compilerOutput.abi,
     );
-    console.log(events);
+    for (const eventLog of eventLogs) {
+        if (eventLog.event !== 'Fill') {
+            continue;
+        }
+        const fillEventLog = eventLog as LogWithDecodedArgs<ExchangeFillEventArgs>;
+        const exchangeFillEvent = new ExchangeFillEvent();
+        exchangeFillEvent.logIndex = fillEventLog.logIndex as number;
+        exchangeFillEvent.address = fillEventLog.address as string;
+        exchangeFillEvent.rawData = fillEventLog.data as string;
+        exchangeFillEvent.blockNumber = fillEventLog.blockNumber as number;
+        exchangeFillEvent.makerAddress = fillEventLog.args.makerAddress.toString();
+        exchangeFillEvent.takerAddress = fillEventLog.args.takerAddress.toString();
+        exchangeFillEvent.feeRecepientAddress = fillEventLog.args.feeRecipientAddress;
+        exchangeFillEvent.senderAddress = fillEventLog.args.senderAddress;
+        exchangeFillEvent.makerAssetFilledAmount = fillEventLog.args.makerAssetFilledAmount.toString();
+        exchangeFillEvent.takerAssetFilledAmount = fillEventLog.args.takerAssetFilledAmount.toString();
+        exchangeFillEvent.makerFeePaid = fillEventLog.args.makerFeePaid.toString();
+        exchangeFillEvent.takerFeePaid = fillEventLog.args.takerFeePaid.toString();
+        exchangeFillEvent.orderHash = fillEventLog.args.orderHash;
+        exchangeFillEvent.makerAssetData = fillEventLog.args.makerAssetData;
+        exchangeFillEvent.takerAssetData = fillEventLog.args.takerAssetData;
+        await repository.save(exchangeFillEvent);
+    }
+    console.log(`now ${await repository.count()} total fill events`);
 })();
-- 
cgit