aboutsummaryrefslogtreecommitdiffstats
path: root/packages/pipeline/src/entities
diff options
context:
space:
mode:
Diffstat (limited to 'packages/pipeline/src/entities')
-rw-r--r--packages/pipeline/src/entities/block.ts13
-rw-r--r--packages/pipeline/src/entities/copper_activity.ts41
-rw-r--r--packages/pipeline/src/entities/copper_activity_type.ts17
-rw-r--r--packages/pipeline/src/entities/copper_custom_field.ts15
-rw-r--r--packages/pipeline/src/entities/copper_lead.ts38
-rw-r--r--packages/pipeline/src/entities/copper_opportunity.ts45
-rw-r--r--packages/pipeline/src/entities/dex_trade.ts56
-rw-r--r--packages/pipeline/src/entities/erc20_approval_event.ts26
-rw-r--r--packages/pipeline/src/entities/exchange_cancel_event.ts51
-rw-r--r--packages/pipeline/src/entities/exchange_cancel_up_to_event.ts26
-rw-r--r--packages/pipeline/src/entities/exchange_fill_event.ts60
-rw-r--r--packages/pipeline/src/entities/index.ts25
-rw-r--r--packages/pipeline/src/entities/ohlcv_external.ts30
-rw-r--r--packages/pipeline/src/entities/relayer.ts21
-rw-r--r--packages/pipeline/src/entities/sra_order.ts63
-rw-r--r--packages/pipeline/src/entities/sra_order_observed_timestamp.ts35
-rw-r--r--packages/pipeline/src/entities/token_metadata.ts22
-rw-r--r--packages/pipeline/src/entities/token_order.ts28
-rw-r--r--packages/pipeline/src/entities/transaction.ts19
19 files changed, 0 insertions, 631 deletions
diff --git a/packages/pipeline/src/entities/block.ts b/packages/pipeline/src/entities/block.ts
deleted file mode 100644
index 398946622..000000000
--- a/packages/pipeline/src/entities/block.ts
+++ /dev/null
@@ -1,13 +0,0 @@
-import { Column, Entity, PrimaryColumn } from 'typeorm';
-
-import { numberToBigIntTransformer } from '../utils';
-
-@Entity({ name: 'blocks', schema: 'raw' })
-export class Block {
- @PrimaryColumn() public hash!: string;
- @PrimaryColumn({ transformer: numberToBigIntTransformer })
- public number!: number;
-
- @Column({ name: 'timestamp', transformer: numberToBigIntTransformer })
- public timestamp!: number;
-}
diff --git a/packages/pipeline/src/entities/copper_activity.ts b/packages/pipeline/src/entities/copper_activity.ts
deleted file mode 100644
index cbc034285..000000000
--- a/packages/pipeline/src/entities/copper_activity.ts
+++ /dev/null
@@ -1,41 +0,0 @@
-import { Column, Entity, Index, PrimaryColumn } from 'typeorm';
-
-import { numberToBigIntTransformer } from '../utils';
-
-@Entity({ name: 'copper_activities', schema: 'raw' })
-export class CopperActivity {
- @PrimaryColumn({ type: 'bigint', transformer: numberToBigIntTransformer })
- public id!: number;
-
- @Index()
- @Column({ name: 'parent_id', type: 'bigint', transformer: numberToBigIntTransformer })
- public parentId!: number;
- @Column({ name: 'parent_type', type: 'varchar' })
- public parentType!: string;
-
- // join with CopperActivityType
- @Index()
- @Column({ name: 'type_id', type: 'bigint', transformer: numberToBigIntTransformer })
- public typeId!: number;
- @Column({ name: 'type_category', type: 'varchar' })
- public typeCategory!: string;
- @Column({ name: 'type_name', type: 'varchar', nullable: true })
- public typeName?: string;
-
- @Column({ name: 'user_id', type: 'bigint', transformer: numberToBigIntTransformer })
- public userId!: number;
- @Column({ name: 'old_value_id', type: 'bigint', nullable: true, transformer: numberToBigIntTransformer })
- public oldValueId?: number;
- @Column({ name: 'old_value_name', type: 'varchar', nullable: true })
- public oldValueName?: string;
- @Column({ name: 'new_value_id', type: 'bigint', nullable: true, transformer: numberToBigIntTransformer })
- public newValueId?: number;
- @Column({ name: 'new_value_name', type: 'varchar', nullable: true })
- public newValueName?: string;
-
- @Index()
- @Column({ name: 'date_created', type: 'bigint', transformer: numberToBigIntTransformer })
- public dateCreated!: number;
- @PrimaryColumn({ name: 'date_modified', type: 'bigint', transformer: numberToBigIntTransformer })
- public dateModified!: number;
-}
diff --git a/packages/pipeline/src/entities/copper_activity_type.ts b/packages/pipeline/src/entities/copper_activity_type.ts
deleted file mode 100644
index 8fb2dcf70..000000000
--- a/packages/pipeline/src/entities/copper_activity_type.ts
+++ /dev/null
@@ -1,17 +0,0 @@
-import { Column, Entity, PrimaryColumn } from 'typeorm';
-
-import { numberToBigIntTransformer } from '../utils';
-
-@Entity({ name: 'copper_activity_types', schema: 'raw' })
-export class CopperActivityType {
- @PrimaryColumn({ type: 'bigint', transformer: numberToBigIntTransformer })
- public id!: number;
- @Column({ name: 'category', type: 'varchar' })
- public category!: string;
- @Column({ name: 'name', type: 'varchar' })
- public name!: string;
- @Column({ name: 'is_disabled', type: 'boolean', nullable: true })
- public isDisabled?: boolean;
- @Column({ name: 'count_as_interaction', type: 'boolean', nullable: true })
- public countAsInteraction?: boolean;
-}
diff --git a/packages/pipeline/src/entities/copper_custom_field.ts b/packages/pipeline/src/entities/copper_custom_field.ts
deleted file mode 100644
index f23f6ab22..000000000
--- a/packages/pipeline/src/entities/copper_custom_field.ts
+++ /dev/null
@@ -1,15 +0,0 @@
-import { Column, Entity, PrimaryColumn } from 'typeorm';
-
-import { numberToBigIntTransformer } from '../utils';
-
-@Entity({ name: 'copper_custom_fields', schema: 'raw' })
-export class CopperCustomField {
- @PrimaryColumn({ type: 'bigint', transformer: numberToBigIntTransformer })
- public id!: number;
- @Column({ name: 'data_type', type: 'varchar' })
- public dataType!: string;
- @Column({ name: 'field_type', type: 'varchar', nullable: true })
- public fieldType?: string;
- @Column({ name: 'name', type: 'varchar' })
- public name!: string;
-}
diff --git a/packages/pipeline/src/entities/copper_lead.ts b/packages/pipeline/src/entities/copper_lead.ts
deleted file mode 100644
index c51ccd761..000000000
--- a/packages/pipeline/src/entities/copper_lead.ts
+++ /dev/null
@@ -1,38 +0,0 @@
-import { Column, Entity, Index, PrimaryColumn } from 'typeorm';
-
-import { numberToBigIntTransformer } from '../utils';
-
-@Entity({ name: 'copper_leads', schema: 'raw' })
-export class CopperLead {
- @PrimaryColumn({ type: 'bigint', transformer: numberToBigIntTransformer })
- public id!: number;
-
- @Column({ name: 'name', type: 'varchar', nullable: true })
- public name?: string;
- @Column({ name: 'first_name', type: 'varchar', nullable: true })
- public firstName?: string;
- @Column({ name: 'last_name', type: 'varchar', nullable: true })
- public lastName?: string;
- @Column({ name: 'middle_name', type: 'varchar', nullable: true })
- public middleName?: string;
- @Column({ name: 'assignee_id', type: 'bigint', transformer: numberToBigIntTransformer, nullable: true })
- public assigneeId?: number;
- @Column({ name: 'company_name', type: 'varchar', nullable: true })
- public companyName?: string;
- @Column({ name: 'customer_source_id', type: 'bigint', transformer: numberToBigIntTransformer, nullable: true })
- public customerSourceId?: number;
- @Column({ name: 'monetary_value', type: 'integer', nullable: true })
- public monetaryValue?: number;
- @Column({ name: 'status', type: 'varchar' })
- public status!: string;
- @Column({ name: 'status_id', type: 'bigint', transformer: numberToBigIntTransformer })
- public statusId!: number;
- @Column({ name: 'title', type: 'varchar', nullable: true })
- public title?: string;
-
- @Index()
- @Column({ name: 'date_created', type: 'bigint', transformer: numberToBigIntTransformer })
- public dateCreated!: number;
- @PrimaryColumn({ name: 'date_modified', type: 'bigint', transformer: numberToBigIntTransformer })
- public dateModified!: number;
-}
diff --git a/packages/pipeline/src/entities/copper_opportunity.ts b/packages/pipeline/src/entities/copper_opportunity.ts
deleted file mode 100644
index e12bd69ce..000000000
--- a/packages/pipeline/src/entities/copper_opportunity.ts
+++ /dev/null
@@ -1,45 +0,0 @@
-import { Column, Entity, PrimaryColumn } from 'typeorm';
-
-import { numberToBigIntTransformer } from '../utils';
-
-@Entity({ name: 'copper_opportunities', schema: 'raw' })
-export class CopperOpportunity {
- @PrimaryColumn({ name: 'id', type: 'bigint', transformer: numberToBigIntTransformer })
- public id!: number;
- @Column({ name: 'name', type: 'varchar' })
- public name!: string;
- @Column({ name: 'assignee_id', nullable: true, type: 'bigint', transformer: numberToBigIntTransformer })
- public assigneeId?: number;
- @Column({ name: 'close_date', nullable: true, type: 'varchar' })
- public closeDate?: string;
- @Column({ name: 'company_id', nullable: true, type: 'bigint', transformer: numberToBigIntTransformer })
- public companyId?: number;
- @Column({ name: 'company_name', nullable: true, type: 'varchar' })
- public companyName?: string;
- @Column({ name: 'customer_source_id', nullable: true, type: 'bigint', transformer: numberToBigIntTransformer })
- public customerSourceId?: number;
- @Column({ name: 'loss_reason_id', nullable: true, type: 'bigint', transformer: numberToBigIntTransformer })
- public lossReasonId?: number;
- @Column({ name: 'pipeline_id', type: 'bigint', transformer: numberToBigIntTransformer })
- public pipelineId!: number;
- @Column({ name: 'pipeline_stage_id', type: 'bigint', transformer: numberToBigIntTransformer })
- public pipelineStageId!: number;
- @Column({ name: 'primary_contact_id', nullable: true, type: 'bigint', transformer: numberToBigIntTransformer })
- public primaryContactId?: number;
- @Column({ name: 'priority', nullable: true, type: 'varchar' })
- public priority?: string;
- @Column({ name: 'status', type: 'varchar' })
- public status!: string;
- @Column({ name: 'interaction_count', type: 'bigint', transformer: numberToBigIntTransformer })
- public interactionCount!: number;
- @Column({ name: 'monetary_value', nullable: true, type: 'integer' })
- public monetaryValue?: number;
- @Column({ name: 'win_probability', nullable: true, type: 'integer' })
- public winProbability?: number;
- @Column({ name: 'date_created', type: 'bigint', transformer: numberToBigIntTransformer })
- public dateCreated!: number;
- @PrimaryColumn({ name: 'date_modified', type: 'bigint', transformer: numberToBigIntTransformer })
- public dateModified!: number;
- @Column({ name: 'custom_fields', type: 'jsonb' })
- public customFields!: { [key: number]: number };
-}
diff --git a/packages/pipeline/src/entities/dex_trade.ts b/packages/pipeline/src/entities/dex_trade.ts
deleted file mode 100644
index 93dcaf238..000000000
--- a/packages/pipeline/src/entities/dex_trade.ts
+++ /dev/null
@@ -1,56 +0,0 @@
-import { BigNumber } from '@0x/utils';
-import { Column, Entity, PrimaryColumn } from 'typeorm';
-
-import { bigNumberTransformer, numberToBigIntTransformer } from '../utils';
-
-@Entity({ name: 'dex_trades', schema: 'raw' })
-export class DexTrade {
- @PrimaryColumn({ name: 'source_url' })
- public sourceUrl!: string;
- @PrimaryColumn({ name: 'tx_hash' })
- public txHash!: string;
- @PrimaryColumn({ name: 'trade_index' })
- public tradeIndex!: string;
-
- @Column({ name: 'tx_timestamp', type: 'bigint', transformer: numberToBigIntTransformer })
- public txTimestamp!: number;
- @Column({ name: 'tx_date' })
- public txDate!: string;
- @Column({ name: 'tx_sender' })
- public txSender!: string;
- @Column({ name: 'smart_contract_id', type: 'bigint', transformer: numberToBigIntTransformer })
- public smartContractId!: number;
- @Column({ name: 'smart_contract_address' })
- public smartContractAddress!: string;
- @Column({ name: 'contract_type' })
- public contractType!: string;
- @Column({ type: 'varchar' })
- public maker!: string;
- @Column({ type: 'varchar' })
- public taker!: string;
- @Column({ name: 'amount_buy', type: 'numeric', transformer: bigNumberTransformer })
- public amountBuy!: BigNumber;
- @Column({ name: 'maker_fee_amount', type: 'numeric', transformer: bigNumberTransformer })
- public makerFeeAmount!: BigNumber;
- @Column({ name: 'buy_currency_id', type: 'bigint', transformer: numberToBigIntTransformer })
- public buyCurrencyId!: number;
- @Column({ name: 'buy_symbol' })
- public buySymbol!: string;
- @Column({ name: 'amount_sell', type: 'numeric', transformer: bigNumberTransformer })
- public amountSell!: BigNumber;
- @Column({ name: 'taker_fee_amount', type: 'numeric', transformer: bigNumberTransformer })
- public takerFeeAmount!: BigNumber;
- @Column({ name: 'sell_currency_id', type: 'bigint', transformer: numberToBigIntTransformer })
- public sellCurrencyId!: number;
- @Column({ name: 'sell_symbol' })
- public sellSymbol!: string;
- @Column({ name: 'maker_annotation' })
- public makerAnnotation!: string;
- @Column({ name: 'taker_annotation' })
- public takerAnnotation!: string;
- @Column() public protocol!: string;
- @Column({ name: 'buy_address', type: 'varchar', nullable: true })
- public buyAddress!: string | null;
- @Column({ name: 'sell_address', type: 'varchar', nullable: true })
- public sellAddress!: string | null;
-}
diff --git a/packages/pipeline/src/entities/erc20_approval_event.ts b/packages/pipeline/src/entities/erc20_approval_event.ts
deleted file mode 100644
index ee5e621d2..000000000
--- a/packages/pipeline/src/entities/erc20_approval_event.ts
+++ /dev/null
@@ -1,26 +0,0 @@
-import { BigNumber } from '@0x/utils';
-import { Column, Entity, PrimaryColumn } from 'typeorm';
-
-import { bigNumberTransformer, numberToBigIntTransformer } from '../utils';
-
-@Entity({ name: 'erc20_approval_events', schema: 'raw' })
-export class ERC20ApprovalEvent {
- @PrimaryColumn({ name: 'token_address' })
- public tokenAddress!: string;
- @PrimaryColumn({ name: 'log_index' })
- public logIndex!: number;
- @PrimaryColumn({ name: 'block_number', transformer: numberToBigIntTransformer })
- public blockNumber!: number;
-
- @Column({ name: 'raw_data' })
- public rawData!: string;
-
- @PrimaryColumn({ name: 'transaction_hash' })
- public transactionHash!: string;
- @Column({ name: 'owner_address' })
- public ownerAddress!: string;
- @Column({ name: 'spender_address' })
- public spenderAddress!: string;
- @Column({ name: 'amount', type: 'numeric', transformer: bigNumberTransformer })
- public amount!: BigNumber;
-}
diff --git a/packages/pipeline/src/entities/exchange_cancel_event.ts b/packages/pipeline/src/entities/exchange_cancel_event.ts
deleted file mode 100644
index a86194920..000000000
--- a/packages/pipeline/src/entities/exchange_cancel_event.ts
+++ /dev/null
@@ -1,51 +0,0 @@
-import { Column, Entity, PrimaryColumn } from 'typeorm';
-
-import { AssetType } from '../types';
-import { numberToBigIntTransformer } from '../utils';
-
-@Entity({ name: 'exchange_cancel_events', schema: 'raw' })
-export class ExchangeCancelEvent {
- @PrimaryColumn({ name: 'contract_address' })
- public contractAddress!: string;
- @PrimaryColumn({ name: 'log_index' })
- public logIndex!: number;
- @PrimaryColumn({ name: 'block_number', transformer: numberToBigIntTransformer })
- public blockNumber!: number;
-
- @Column({ name: 'raw_data' })
- public rawData!: string;
-
- @PrimaryColumn({ name: 'transaction_hash' })
- public transactionHash!: string;
- @Column({ name: 'maker_address' })
- public makerAddress!: string;
- @Column({ nullable: true, type: String, name: 'taker_address' })
- public takerAddress!: string;
- @Column({ name: 'fee_recipient_address' })
- public feeRecipientAddress!: string;
- @Column({ name: 'sender_address' })
- public senderAddress!: string;
- @Column({ name: 'order_hash' })
- public orderHash!: string;
-
- @Column({ name: 'raw_maker_asset_data' })
- public rawMakerAssetData!: string;
- @Column({ name: 'maker_asset_type' })
- public makerAssetType!: AssetType;
- @Column({ name: 'maker_asset_proxy_id' })
- public makerAssetProxyId!: string;
- @Column({ name: 'maker_token_address' })
- public makerTokenAddress!: string;
- @Column({ nullable: true, type: String, name: 'maker_token_id' })
- public makerTokenId!: string | null;
- @Column({ name: 'raw_taker_asset_data' })
- public rawTakerAssetData!: string;
- @Column({ name: 'taker_asset_type' })
- public takerAssetType!: AssetType;
- @Column({ name: 'taker_asset_proxy_id' })
- public takerAssetProxyId!: string;
- @Column({ name: 'taker_token_address' })
- public takerTokenAddress!: string;
- @Column({ nullable: true, type: String, name: 'taker_token_id' })
- public takerTokenId!: string | null;
-}
diff --git a/packages/pipeline/src/entities/exchange_cancel_up_to_event.ts b/packages/pipeline/src/entities/exchange_cancel_up_to_event.ts
deleted file mode 100644
index f24aea23a..000000000
--- a/packages/pipeline/src/entities/exchange_cancel_up_to_event.ts
+++ /dev/null
@@ -1,26 +0,0 @@
-import { BigNumber } from '@0x/utils';
-import { Column, Entity, PrimaryColumn } from 'typeorm';
-
-import { bigNumberTransformer, numberToBigIntTransformer } from '../utils';
-
-@Entity({ name: 'exchange_cancel_up_to_events', schema: 'raw' })
-export class ExchangeCancelUpToEvent {
- @PrimaryColumn({ name: 'contract_address' })
- public contractAddress!: string;
- @PrimaryColumn({ name: 'log_index' })
- public logIndex!: number;
- @PrimaryColumn({ name: 'block_number', transformer: numberToBigIntTransformer })
- public blockNumber!: number;
-
- @Column({ name: 'raw_data' })
- public rawData!: string;
-
- @PrimaryColumn({ name: 'transaction_hash' })
- public transactionHash!: string;
- @Column({ name: 'maker_address' })
- public makerAddress!: string;
- @Column({ name: 'sender_address' })
- public senderAddress!: string;
- @Column({ name: 'order_epoch', type: 'numeric', transformer: bigNumberTransformer })
- public orderEpoch!: BigNumber;
-}
diff --git a/packages/pipeline/src/entities/exchange_fill_event.ts b/packages/pipeline/src/entities/exchange_fill_event.ts
deleted file mode 100644
index 52111711e..000000000
--- a/packages/pipeline/src/entities/exchange_fill_event.ts
+++ /dev/null
@@ -1,60 +0,0 @@
-import { BigNumber } from '@0x/utils';
-import { Column, Entity, PrimaryColumn } from 'typeorm';
-
-import { AssetType } from '../types';
-import { bigNumberTransformer, numberToBigIntTransformer } from '../utils';
-
-@Entity({ name: 'exchange_fill_events', schema: 'raw' })
-export class ExchangeFillEvent {
- @PrimaryColumn({ name: 'contract_address' })
- public contractAddress!: string;
- @PrimaryColumn({ name: 'log_index' })
- public logIndex!: number;
- @PrimaryColumn({ name: 'block_number', transformer: numberToBigIntTransformer })
- public blockNumber!: number;
-
- @Column({ name: 'raw_data' })
- public rawData!: string;
-
- @PrimaryColumn({ name: 'transaction_hash' })
- public transactionHash!: string;
- @Column({ name: 'maker_address' })
- public makerAddress!: string;
- @Column({ name: 'taker_address' })
- public takerAddress!: string;
- @Column({ name: 'fee_recipient_address' })
- public feeRecipientAddress!: string;
- @Column({ name: 'sender_address' })
- public senderAddress!: string;
- @Column({ name: 'maker_asset_filled_amount', type: 'numeric', transformer: bigNumberTransformer })
- public makerAssetFilledAmount!: BigNumber;
- @Column({ name: 'taker_asset_filled_amount', type: 'numeric', transformer: bigNumberTransformer })
- public takerAssetFilledAmount!: BigNumber;
- @Column({ name: 'maker_fee_paid', type: 'numeric', transformer: bigNumberTransformer })
- public makerFeePaid!: BigNumber;
- @Column({ name: 'taker_fee_paid', type: 'numeric', transformer: bigNumberTransformer })
- public takerFeePaid!: BigNumber;
- @Column({ name: 'order_hash' })
- public orderHash!: string;
-
- @Column({ name: 'raw_maker_asset_data' })
- public rawMakerAssetData!: string;
- @Column({ name: 'maker_asset_type' })
- public makerAssetType!: AssetType;
- @Column({ name: 'maker_asset_proxy_id' })
- public makerAssetProxyId!: string;
- @Column({ name: 'maker_token_address' })
- public makerTokenAddress!: string;
- @Column({ nullable: true, type: String, name: 'maker_token_id' })
- public makerTokenId!: string | null;
- @Column({ name: 'raw_taker_asset_data' })
- public rawTakerAssetData!: string;
- @Column({ name: 'taker_asset_type' })
- public takerAssetType!: AssetType;
- @Column({ name: 'taker_asset_proxy_id' })
- public takerAssetProxyId!: string;
- @Column({ name: 'taker_token_address' })
- public takerTokenAddress!: string;
- @Column({ nullable: true, type: String, name: 'taker_token_id' })
- public takerTokenId!: string | null;
-}
diff --git a/packages/pipeline/src/entities/index.ts b/packages/pipeline/src/entities/index.ts
deleted file mode 100644
index 27c153c07..000000000
--- a/packages/pipeline/src/entities/index.ts
+++ /dev/null
@@ -1,25 +0,0 @@
-import { ExchangeCancelEvent } from './exchange_cancel_event';
-import { ExchangeCancelUpToEvent } from './exchange_cancel_up_to_event';
-import { ExchangeFillEvent } from './exchange_fill_event';
-
-export { Block } from './block';
-export { DexTrade } from './dex_trade';
-export { ExchangeCancelEvent } from './exchange_cancel_event';
-export { ExchangeCancelUpToEvent } from './exchange_cancel_up_to_event';
-export { ExchangeFillEvent } from './exchange_fill_event';
-export { OHLCVExternal } from './ohlcv_external';
-export { Relayer } from './relayer';
-export { SraOrder } from './sra_order';
-export { SraOrdersObservedTimeStamp, createObservedTimestampForOrder } from './sra_order_observed_timestamp';
-export { TokenMetadata } from './token_metadata';
-export { TokenOrderbookSnapshot } from './token_order';
-export { Transaction } from './transaction';
-export { ERC20ApprovalEvent } from './erc20_approval_event';
-
-export { CopperLead } from './copper_lead';
-export { CopperActivity } from './copper_activity';
-export { CopperOpportunity } from './copper_opportunity';
-export { CopperActivityType } from './copper_activity_type';
-export { CopperCustomField } from './copper_custom_field';
-
-export type ExchangeEvent = ExchangeFillEvent | ExchangeCancelEvent | ExchangeCancelUpToEvent;
diff --git a/packages/pipeline/src/entities/ohlcv_external.ts b/packages/pipeline/src/entities/ohlcv_external.ts
deleted file mode 100644
index 4f55dd930..000000000
--- a/packages/pipeline/src/entities/ohlcv_external.ts
+++ /dev/null
@@ -1,30 +0,0 @@
-import { Column, Entity, PrimaryColumn } from 'typeorm';
-
-import { numberToBigIntTransformer } from '../utils';
-
-@Entity({ name: 'ohlcv_external', schema: 'raw' })
-export class OHLCVExternal {
- @PrimaryColumn() public exchange!: string;
-
- @PrimaryColumn({ name: 'from_symbol', type: 'varchar' })
- public fromSymbol!: string;
- @PrimaryColumn({ name: 'to_symbol', type: 'varchar' })
- public toSymbol!: string;
- @PrimaryColumn({ name: 'start_time', transformer: numberToBigIntTransformer })
- public startTime!: number;
- @PrimaryColumn({ name: 'end_time', transformer: numberToBigIntTransformer })
- public endTime!: number;
-
- @Column() public open!: number;
- @Column() public close!: number;
- @Column() public low!: number;
- @Column() public high!: number;
- @Column({ name: 'volume_from' })
- public volumeFrom!: number;
- @Column({ name: 'volume_to' })
- public volumeTo!: number;
-
- @PrimaryColumn() public source!: string;
- @PrimaryColumn({ name: 'observed_timestamp', transformer: numberToBigIntTransformer })
- public observedTimestamp!: number;
-}
diff --git a/packages/pipeline/src/entities/relayer.ts b/packages/pipeline/src/entities/relayer.ts
deleted file mode 100644
index 5af8578b4..000000000
--- a/packages/pipeline/src/entities/relayer.ts
+++ /dev/null
@@ -1,21 +0,0 @@
-import { Column, Entity, PrimaryColumn } from 'typeorm';
-
-@Entity({ name: 'relayers', schema: 'raw' })
-export class Relayer {
- @PrimaryColumn() public uuid!: string;
-
- @Column() public name!: string;
- @Column({ name: 'homepage_url', type: 'varchar' })
- public homepageUrl!: string;
- @Column({ name: 'sra_http_endpoint', type: 'varchar', nullable: true })
- public sraHttpEndpoint!: string | null;
- @Column({ name: 'sra_ws_endpoint', type: 'varchar', nullable: true })
- public sraWsEndpoint!: string | null;
- @Column({ name: 'app_url', type: 'varchar', nullable: true })
- public appUrl!: string | null;
-
- @Column({ name: 'fee_recipient_addresses', type: 'varchar', array: true })
- public feeRecipientAddresses!: string[];
- @Column({ name: 'taker_addresses', type: 'varchar', array: true })
- public takerAddresses!: string[];
-}
diff --git a/packages/pipeline/src/entities/sra_order.ts b/packages/pipeline/src/entities/sra_order.ts
deleted file mode 100644
index 9c730a0bb..000000000
--- a/packages/pipeline/src/entities/sra_order.ts
+++ /dev/null
@@ -1,63 +0,0 @@
-import { BigNumber } from '@0x/utils';
-import { Column, Entity, PrimaryColumn } from 'typeorm';
-
-import { AssetType } from '../types';
-import { bigNumberTransformer } from '../utils';
-
-@Entity({ name: 'sra_orders', schema: 'raw' })
-export class SraOrder {
- @PrimaryColumn({ name: 'exchange_address' })
- public exchangeAddress!: string;
- @PrimaryColumn({ name: 'order_hash_hex' })
- public orderHashHex!: string;
- @PrimaryColumn({ name: 'source_url' })
- public sourceUrl!: string;
-
- @Column({ name: 'maker_address' })
- public makerAddress!: string;
- @Column({ name: 'taker_address' })
- public takerAddress!: string;
- @Column({ name: 'fee_recipient_address' })
- public feeRecipientAddress!: string;
- @Column({ name: 'sender_address' })
- public senderAddress!: string;
- @Column({ name: 'maker_asset_amount', type: 'numeric', transformer: bigNumberTransformer })
- public makerAssetAmount!: BigNumber;
- @Column({ name: 'taker_asset_amount', type: 'numeric', transformer: bigNumberTransformer })
- public takerAssetAmount!: BigNumber;
- @Column({ name: 'maker_fee', type: 'numeric', transformer: bigNumberTransformer })
- public makerFee!: BigNumber;
- @Column({ name: 'taker_fee', type: 'numeric', transformer: bigNumberTransformer })
- public takerFee!: BigNumber;
- @Column({ name: 'expiration_time_seconds', type: 'numeric', transformer: bigNumberTransformer })
- public expirationTimeSeconds!: BigNumber;
- @Column({ name: 'salt', type: 'numeric', transformer: bigNumberTransformer })
- public salt!: BigNumber;
- @Column({ name: 'signature' })
- public signature!: string;
-
- @Column({ name: 'raw_maker_asset_data' })
- public rawMakerAssetData!: string;
- @Column({ name: 'maker_asset_type' })
- public makerAssetType!: AssetType;
- @Column({ name: 'maker_asset_proxy_id' })
- public makerAssetProxyId!: string;
- @Column({ name: 'maker_token_address' })
- public makerTokenAddress!: string;
- @Column({ nullable: true, type: String, name: 'maker_token_id' })
- public makerTokenId!: string | null;
- @Column({ name: 'raw_taker_asset_data' })
- public rawTakerAssetData!: string;
- @Column({ name: 'taker_asset_type' })
- public takerAssetType!: AssetType;
- @Column({ name: 'taker_asset_proxy_id' })
- public takerAssetProxyId!: string;
- @Column({ name: 'taker_token_address' })
- public takerTokenAddress!: string;
- @Column({ nullable: true, type: String, name: 'taker_token_id' })
- public takerTokenId!: string | null;
-
- // TODO(albrow): Make this optional?
- @Column({ name: 'metadata_json' })
- public metadataJson!: string;
-}
diff --git a/packages/pipeline/src/entities/sra_order_observed_timestamp.ts b/packages/pipeline/src/entities/sra_order_observed_timestamp.ts
deleted file mode 100644
index cbec1c6d0..000000000
--- a/packages/pipeline/src/entities/sra_order_observed_timestamp.ts
+++ /dev/null
@@ -1,35 +0,0 @@
-import { Entity, PrimaryColumn } from 'typeorm';
-
-import { numberToBigIntTransformer } from '../utils';
-
-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', transformer: numberToBigIntTransformer })
- 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,
- observedTimestamp: number,
-): SraOrdersObservedTimeStamp {
- const observed = new SraOrdersObservedTimeStamp();
- observed.exchangeAddress = order.exchangeAddress;
- observed.orderHashHex = order.orderHashHex;
- observed.sourceUrl = order.sourceUrl;
- observed.observedTimestamp = observedTimestamp;
- return observed;
-}
diff --git a/packages/pipeline/src/entities/token_metadata.ts b/packages/pipeline/src/entities/token_metadata.ts
deleted file mode 100644
index 911b53972..000000000
--- a/packages/pipeline/src/entities/token_metadata.ts
+++ /dev/null
@@ -1,22 +0,0 @@
-import { BigNumber } from '@0x/utils';
-import { Column, Entity, PrimaryColumn } from 'typeorm';
-
-import { bigNumberTransformer } from '../utils/transformers';
-
-@Entity({ name: 'token_metadata', schema: 'raw' })
-export class TokenMetadata {
- @PrimaryColumn({ type: 'varchar', nullable: false })
- public address!: string;
-
- @PrimaryColumn({ type: 'varchar', nullable: false })
- public authority!: string;
-
- @Column({ type: 'numeric', transformer: bigNumberTransformer, nullable: true })
- public decimals!: BigNumber | null;
-
- @Column({ type: 'varchar', nullable: true })
- public symbol!: string | null;
-
- @Column({ type: 'varchar', nullable: true })
- public name!: string | null;
-}
diff --git a/packages/pipeline/src/entities/token_order.ts b/packages/pipeline/src/entities/token_order.ts
deleted file mode 100644
index 2709747cb..000000000
--- a/packages/pipeline/src/entities/token_order.ts
+++ /dev/null
@@ -1,28 +0,0 @@
-import { BigNumber } from '@0x/utils';
-import { Column, Entity, PrimaryColumn } from 'typeorm';
-
-import { bigNumberTransformer, numberToBigIntTransformer } from '../utils';
-
-@Entity({ name: 'token_orderbook_snapshots', schema: 'raw' })
-export class TokenOrderbookSnapshot {
- @PrimaryColumn({ name: 'observed_timestamp', type: 'bigint', transformer: numberToBigIntTransformer })
- public observedTimestamp!: number;
- @PrimaryColumn({ name: 'source' })
- public source!: string;
- @PrimaryColumn({ name: 'order_type' })
- public orderType!: string;
- @PrimaryColumn({ name: 'price', type: 'numeric', transformer: bigNumberTransformer })
- public price!: BigNumber;
- @PrimaryColumn({ name: 'base_asset_symbol' })
- public baseAssetSymbol!: string;
- @Column({ nullable: true, type: String, name: 'base_asset_address' })
- public baseAssetAddress!: string | null;
- @Column({ name: 'base_volume', type: 'numeric', transformer: bigNumberTransformer })
- public baseVolume!: BigNumber;
- @PrimaryColumn({ name: 'quote_asset_symbol' })
- public quoteAssetSymbol!: string;
- @Column({ nullable: true, type: String, name: 'quote_asset_address' })
- public quoteAssetAddress!: string | null;
- @Column({ name: 'quote_volume', type: 'numeric', transformer: bigNumberTransformer })
- public quoteVolume!: BigNumber;
-}
diff --git a/packages/pipeline/src/entities/transaction.ts b/packages/pipeline/src/entities/transaction.ts
deleted file mode 100644
index 742050177..000000000
--- a/packages/pipeline/src/entities/transaction.ts
+++ /dev/null
@@ -1,19 +0,0 @@
-import { BigNumber } from '@0x/utils';
-import { Column, Entity, PrimaryColumn } from 'typeorm';
-
-import { bigNumberTransformer, numberToBigIntTransformer } from '../utils';
-
-@Entity({ name: 'transactions', schema: 'raw' })
-export class Transaction {
- @PrimaryColumn({ name: 'transaction_hash' })
- public transactionHash!: string;
- @PrimaryColumn({ name: 'block_hash' })
- public blockHash!: string;
- @PrimaryColumn({ name: 'block_number', transformer: numberToBigIntTransformer })
- public blockNumber!: number;
-
- @Column({ type: 'numeric', name: 'gas_used', transformer: bigNumberTransformer })
- public gasUsed!: BigNumber;
- @Column({ type: 'numeric', name: 'gas_price', transformer: bigNumberTransformer })
- public gasPrice!: BigNumber;
-}