8 files changed, 329 insertions, 0 deletions
diff --git a/packages/pipeline/src/models/block.ts b/packages/pipeline/src/models/block.ts
new file mode 100644
index 000000000..a81cdb293
--- /dev/null
+++ b/packages/pipeline/src/models/block.ts
@@ -0,0 +1,22 @@
+const block = {
+    tableName: 'blocks',
+    tableProperties: {
+        id: {
+            type: 'key',
+        },
+        timestamp: {
+            type: 'timestamp',
+            required: true,
+        },
+        block_number: {
+            type: 'bigint',
+            required: true,
+        },
+    },
+};
+const logToBlockSchemaMapping: any = {
+    number: 'block_number',
+    hash: 'block_hash',
+    timestamp: 'timestamp',
+};
+export { block, logToBlockSchemaMapping };
diff --git a/packages/pipeline/src/models/event.ts b/packages/pipeline/src/models/event.ts
new file mode 100644
index 000000000..cb1c939e5
--- /dev/null
+++ b/packages/pipeline/src/models/event.ts
@@ -0,0 +1,84 @@
+const event = {
+    tableName: 'events',
+    tableProperties: {
+        id: {
+            type: 'key',
+        },
+        timestamp: {
+            type: 'timestamp',
+            required: true,
+        },
+        event_type: {
+            type: 'varchar',
+            required: true,
+        },
+        error_id: {
+            type: 'varchar',
+        },
+        order_hash: {
+            type: 'char(66)',
+        },
+        maker: {
+            type: 'char(42)',
+        },
+        maker_amount: {
+            type: 'varchar',
+        },
+        maker_fee: {
+            type: 'varchar',
+        },
+        maker_token: {
+            type: 'char(42)',
+        },
+        taker_amount: {
+            type: 'varchar',
+        },
+        taker_fee: {
+            type: 'varchar',
+        },
+        taker_token: {
+            type: 'char(42)',
+        },
+        txn_hash: {
+            type: 'char(66)',
+        },
+        gas_used: {
+            type: 'varchar',
+        },
+        gas_price: {
+            type: 'varchar',
+        },
+        fee_recipient: {
+            type: 'char(42)',
+        },
+        method_id: {
+            type: 'char(10)',
+        },
+        salt: {
+            type: 'varchar',
+        },
+        block_number: {
+            type: 'bigint',
+        },
+    },
+};
+const logToEventSchemaMapping: any = {
+    blockNumber: 'block_number',
+    transactionHash: 'txn_hash',
+    event: 'event_type',
+    logIndex: 'log_index',
+    'args.maker': 'maker',
+    'args.taker': 'taker',
+    'args.feeRecipient': 'fee_recipient',
+    'args.makerToken': 'maker_token',
+    'args.takerToken': 'taker_token',
+    'args.filledMakerTokenAmount': 'maker_amount',
+    'args.filledTakerTokenAmount': 'taker_amount',
+    'args.paidMakerFee': 'maker_fee',
+    'args.paidTakerFee': 'taker_fee',
+    'args.orderHash': 'order_hash',
+    'args.cancelledMakerTokenAmount': 'maker_amount',
+    'args.cancelledTakerTokenAmount': 'taker_amount',
+    'args.errorId': 'error_id',
+};
+export { event, logToEventSchemaMapping };
diff --git a/packages/pipeline/src/models/historical_prices.ts b/packages/pipeline/src/models/historical_prices.ts
new file mode 100644
index 000000000..cf49b579e
--- /dev/null
+++ b/packages/pipeline/src/models/historical_prices.ts
@@ -0,0 +1,43 @@
+const historicalPrices = {
+    tableName: 'historical_prices',
+    tableProperties: {
+        token: {
+            type: 'varchar',
+        },
+        base: {
+            type: 'varchar',
+        },
+        timestamp: {
+            type: 'timestamp',
+        },
+        close: {
+            type: 'numeric(50)',
+        },
+        high: {
+            type: 'numeric(50)',
+        },
+        low: {
+            type: 'numeric(50)',
+        },
+        open: {
+            type: 'numeric(50)',
+        },
+        volume_from: {
+            type: 'numeric(50)',
+        },
+        volume_to: {
+            type: 'numeric(50)',
+        },
+    },
+};
+const logToHistoricalPricesSchema: { [log: string]: string } = {
+    token: 'token',
+    time: 'timestamp',
+    close: 'close',
+    high: 'high',
+    low: 'low',
+    open: 'open',
+    volumefrom: 'volume_from',
+    volumeto: 'volume_to',
+};
+export { historicalPrices, logToHistoricalPricesSchema };
diff --git a/packages/pipeline/src/models/order.ts b/packages/pipeline/src/models/order.ts
new file mode 100644
index 000000000..dadae2883
--- /dev/null
+++ b/packages/pipeline/src/models/order.ts
@@ -0,0 +1,30 @@
+const order = {
+    tableName: 'orders',
+    tableProperties: {
+        id: {
+            type: 'key',
+        },
+        timestamp: {
+            type: 'timestamp',
+            required: true,
+        },
+        block_number: {
+            type: 'bigint',
+            required: true,
+        },
+    },
+};
+const logToOrderSchemaMapping: any = {
+    exchangeContractAddress: 'exchange_contract_address',
+    maker: 'maker',
+    makerTokenAddress: 'maker_token',
+    makerTokenAmount: 'maker_amount',
+    makerFee: 'maker_fee',
+    taker: 'taker',
+    takerTokenAddress: 'taker_token',
+    takerTokenAmount: 'taker_amount',
+    takerFee: 'taker_fee',
+    expirationUnixTimestampSec: 'expiration_unix_timestamp_sec',
+    salt: 'salt',
+};
+export { order, logToOrderSchemaMapping };
diff --git a/packages/pipeline/src/models/price.ts b/packages/pipeline/src/models/price.ts
new file mode 100644
index 000000000..9e45cc2a9
--- /dev/null
+++ b/packages/pipeline/src/models/price.ts
@@ -0,0 +1,15 @@
+const price = {
+    tableName: 'prices',
+    tableProperties: {
+        address: {
+            type: 'char(42)',
+        },
+        timestamp: {
+            type: 'timestamp',
+        },
+        price: {
+            type: 'numeric(50)',
+        },
+    },
+};
+export { price };
diff --git a/packages/pipeline/src/models/relayer.ts b/packages/pipeline/src/models/relayer.ts
new file mode 100644
index 000000000..77a123e8b
--- /dev/null
+++ b/packages/pipeline/src/models/relayer.ts
@@ -0,0 +1,75 @@
+// const relayer = {
+//     tableName: 'relayers',
+//     tableProperties: {
+//         id: {
+//             type: 'integer',
+//         },
+//         name: {
+//             type: 'varchar',
+//         },
+//         url : {
+//             type: 'varchar',
+//         },
+//         model: {
+//             type: 'varchar[]',
+//         },
+//         status: {
+//             type: 'varchar',
+//         },
+//         sra_status: {
+//             type: 'varchar',
+//         },
+//         sra_http_url: {
+//             type: 'varchar',
+//         },
+//         known_fee_addresses: {
+//             type: 'char(42)[]',
+//         },
+//         known_taker_addresses: {
+//             type: 'char(42)[]',
+//         },
+//         relayer_type: {
+//             type: 'varchar',
+//         },
+//     },
+// };
+const relayer = {
+    tableName: 'relayers',
+    tableProperties: {
+        name: {
+            type: 'varchar',
+        },
+        url: {
+            type: 'varchar',
+        },
+        sra_http_endpoint: {
+            type: 'varchar',
+        },
+        sra_ws_endpoint: {
+            type: 'varchar',
+        },
+        fee_recipient_addresses: {
+            type: 'char(42)[]',
+        },
+        taker_addresses: {
+            type: 'char(42)[]',
+        },
+    },
+};
+// const logToRelayerSchemaMapping: any = {
+//     'id' : 'id',
+//     'fields[\'Name\']': 'name',
+//     'fields[\'URL\']': 'url',
+//     'fields[\'Model\']': 'model',
+//     'fields[\'Status\']': 'status',
+//     'fields[\'SRA Status\']': 'sra_status',
+//     'fields[\'SRA HTTP URL\']': 'sra_http_url',
+//     'fields[\'Known Fee Addresses\']': 'known_fee_addresses',
+//     'fields[\'Known Taker Addresses\']': 'known_taker_addresses',
+//     'fields[\'Relayer Type\']': 'relayer_type',
+// };
+const logToRelayerSchemaMapping: any = {
+    name: 'name',
+    homepage_url: 'url',
+};
+export { relayer, logToRelayerSchemaMapping };
diff --git a/packages/pipeline/src/models/tokens.ts b/packages/pipeline/src/models/tokens.ts
new file mode 100644
index 000000000..96e8a31af
--- /dev/null
+++ b/packages/pipeline/src/models/tokens.ts
@@ -0,0 +1,24 @@
+const token = {
+    tableName: 'tokens',
+    tableProperties: {
+        address: {
+            type: 'char(66)',
+        },
+        decimals: {
+            type: 'bigint',
+        },
+        name: {
+            type: 'varchar',
+        },
+        symbol: {
+            type: 'varchar',
+        },
+    },
+};
+const logToTokenSchemaMapping: any = {
+    address: 'address',
+    decimals: 'decimals',
+    name: 'name',
+    symbol: 'symbol',
+};
+export { token, logToTokenSchemaMapping };
diff --git a/packages/pipeline/src/models/transaction.ts b/packages/pipeline/src/models/transaction.ts
new file mode 100644
index 000000000..715cc9480
--- /dev/null
+++ b/packages/pipeline/src/models/transaction.ts
@@ -0,0 +1,36 @@
+const transaction = {
+    tableName: 'transactions',
+    tableProperties: {
+        txn_hash: {
+            type: 'char(66)',
+        },
+        block_hash: {
+            type: 'char(66)',
+        },
+        block_number: {
+            type: 'bigint',
+        },
+        gas_used: {
+            type: 'varchar',
+        },
+        gas_price: {
+            type: 'varchar',
+        },
+        method_id: {
+            type: 'char(10)',
+        },
+        salt: {
+            type: 'varchar',
+        },
+    },
+};
+const logToTransactionSchemaMapping: any = {
+    hash: 'txn_hash',
+    gas: 'gas_used',
+    gasPrice: 'gas_price',
+    blockHash: 'block_hash',
+    blockNumber: 'block_number',
+    method_id: 'method_id',
+    salt: 'salt',
+};
+export { transaction, logToTransactionSchemaMapping };