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.ts5
-rw-r--r--packages/pipeline/src/entities/Relayer.ts12
-rw-r--r--packages/pipeline/src/entities/Transaction.ts15
-rw-r--r--packages/pipeline/src/entities/exchange_cancel_event.ts56
-rw-r--r--packages/pipeline/src/entities/exchange_cancel_up_to_event.ts23
-rw-r--r--packages/pipeline/src/entities/exchange_fill_event.ts72
-rw-r--r--packages/pipeline/src/entities/sra_order.ts81
7 files changed, 169 insertions, 95 deletions
diff --git a/packages/pipeline/src/entities/Block.ts b/packages/pipeline/src/entities/Block.ts
index 49e0ef840..5bd51f3d2 100644
--- a/packages/pipeline/src/entities/Block.ts
+++ b/packages/pipeline/src/entities/Block.ts
@@ -1,9 +1,10 @@
import { Column, Entity, PrimaryColumn } from 'typeorm';
-@Entity()
+@Entity({ name: 'blocks' })
export class Block {
@PrimaryColumn() public hash!: string;
@PrimaryColumn() public number!: number;
- @Column() public unixTimestampSeconds!: number;
+ @Column({ name: 'unix_timestamp_seconds' })
+ public unixTimestampSeconds!: number;
}
diff --git a/packages/pipeline/src/entities/Relayer.ts b/packages/pipeline/src/entities/Relayer.ts
index 605355fa8..94b5232a8 100644
--- a/packages/pipeline/src/entities/Relayer.ts
+++ b/packages/pipeline/src/entities/Relayer.ts
@@ -1,23 +1,23 @@
import { Column, Entity, PrimaryColumn } from 'typeorm';
-@Entity()
+@Entity({ name: 'relayers' })
export class Relayer {
@PrimaryColumn() public uuid!: string;
@Column() public name!: string;
@Column() public url!: string;
- @Column({ nullable: true, type: String })
+ @Column({ nullable: true, type: String, name: 'sra_http_endpoint' })
public sraHttpEndpoint!: string | null;
- @Column({ nullable: true, type: String })
+ @Column({ nullable: true, type: String, name: 'sra_ws_endpoint' })
public sraWsEndpoint!: string | null;
- @Column({ nullable: true, type: String })
+ @Column({ nullable: true, type: String, name: 'app_url' })
public appUrl!: string | null;
// TODO(albrow): Add exchange contract or protocol version?
// TODO(albrow): Add network ids for addresses?
- @Column({ type: 'varchar', array: true })
+ @Column({ type: 'varchar', array: true, name: 'fee_recipient_addresses' })
public feeRecipientAddresses!: string[];
- @Column({ type: 'varchar', array: true })
+ @Column({ type: 'varchar', array: true, name: 'taker_addresses' })
public takerAddresses!: string[];
}
diff --git a/packages/pipeline/src/entities/Transaction.ts b/packages/pipeline/src/entities/Transaction.ts
index 8a68da813..eb2883fda 100644
--- a/packages/pipeline/src/entities/Transaction.ts
+++ b/packages/pipeline/src/entities/Transaction.ts
@@ -1,13 +1,16 @@
import { Column, Entity, PrimaryColumn } from 'typeorm';
-@Entity()
+@Entity({ name: 'transactions' })
export class Transaction {
- @PrimaryColumn() public transactionHash!: string;
- @PrimaryColumn() public blockHash!: string;
- @PrimaryColumn() public blockNumber!: number;
+ @PrimaryColumn({ name: 'transaction_hash' })
+ public transactionHash!: string;
+ @PrimaryColumn({ name: 'block_hash' })
+ public blockHash!: string;
+ @PrimaryColumn({ name: 'block_number' })
+ public blockNumber!: number;
- @Column({ type: 'bigint' })
+ @Column({ type: 'bigint', name: 'gas_used' })
public gasUsed!: number;
- @Column({ type: 'bigint' })
+ @Column({ type: 'bigint', name: 'gas_price' })
public gasPrice!: number;
}
diff --git a/packages/pipeline/src/entities/exchange_cancel_event.ts b/packages/pipeline/src/entities/exchange_cancel_event.ts
index 698b9e2ec..6d0c3bc32 100644
--- a/packages/pipeline/src/entities/exchange_cancel_event.ts
+++ b/packages/pipeline/src/entities/exchange_cancel_event.ts
@@ -2,33 +2,49 @@ import { Column, Entity, PrimaryColumn } from 'typeorm';
import { AssetType } from '../types';
-@Entity()
+@Entity({ name: 'exchange_cancel_events' })
export class ExchangeCancelEvent {
- @PrimaryColumn() public contractAddress!: string;
- @PrimaryColumn() public logIndex!: number;
- @PrimaryColumn() public blockNumber!: number;
+ @PrimaryColumn({ name: 'contract_address' })
+ public contractAddress!: string;
+ @PrimaryColumn({ name: 'log_index' })
+ public logIndex!: number;
+ @PrimaryColumn({ name: 'block_number' })
+ public blockNumber!: number;
- @Column() public rawData!: string;
+ @Column({ name: 'raw_data' })
+ public rawData!: string;
// TODO(albrow): Include transaction hash
- @Column() public makerAddress!: string;
- @Column({ nullable: true, type: String })
+ @Column({ name: 'maker_address' })
+ public makerAddress!: string;
+ @Column({ nullable: true, type: String, name: 'taker_address' })
public takerAddress!: string;
- @Column() public feeRecepientAddress!: string;
- @Column() public senderAddress!: string;
- @Column() public orderHash!: string;
+ @Column({ name: 'fee_recipient_address' })
+ public feeRecipientAddress!: string;
+ @Column({ name: 'sender_address' })
+ public senderAddress!: string;
+ @Column({ name: 'order_hash' })
+ public orderHash!: string;
- @Column() public rawMakerAssetData!: string;
- @Column() public makerAssetType!: AssetType;
- @Column() public makerAssetProxyId!: string;
- @Column() public makerTokenAddress!: string;
- @Column({ nullable: true, type: 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() public rawTakerAssetData!: string;
- @Column() public takerAssetType!: AssetType;
- @Column() public takerAssetProxyId!: string;
- @Column() public takerTokenAddress!: string;
- @Column({ nullable: true, type: String })
+ @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): Include topics?
diff --git a/packages/pipeline/src/entities/exchange_cancel_up_to_event.ts b/packages/pipeline/src/entities/exchange_cancel_up_to_event.ts
index 3ca75ccf7..891550050 100644
--- a/packages/pipeline/src/entities/exchange_cancel_up_to_event.ts
+++ b/packages/pipeline/src/entities/exchange_cancel_up_to_event.ts
@@ -1,16 +1,23 @@
import { Column, Entity, PrimaryColumn } from 'typeorm';
-@Entity()
+@Entity({ name: 'exchange_cancel_up_to_event' })
export class ExchangeCancelUpToEvent {
- @PrimaryColumn() public contractAddress!: string;
- @PrimaryColumn() public logIndex!: number;
- @PrimaryColumn() public blockNumber!: number;
+ @PrimaryColumn({ name: 'contract_address' })
+ public contractAddress!: string;
+ @PrimaryColumn({ name: 'log_index' })
+ public logIndex!: number;
+ @PrimaryColumn({ name: 'block_number' })
+ public blockNumber!: number;
// TODO(albrow): Include transaction hash
- @Column() public rawData!: string;
+ @Column({ name: 'raw_data' })
+ public rawData!: string;
- @Column() public makerAddress!: string;
- @Column() public senderAddress!: string;
- @Column() public orderEpoch!: string;
+ @Column({ name: 'maker_address' })
+ public makerAddress!: string;
+ @Column({ name: 'sender_address' })
+ public senderAddress!: string;
+ @Column({ name: 'order_epoch' })
+ public orderEpoch!: string;
// TODO(albrow): Include topics?
}
diff --git a/packages/pipeline/src/entities/exchange_fill_event.ts b/packages/pipeline/src/entities/exchange_fill_event.ts
index 6e549af93..0c5546d7e 100644
--- a/packages/pipeline/src/entities/exchange_fill_event.ts
+++ b/packages/pipeline/src/entities/exchange_fill_event.ts
@@ -2,36 +2,58 @@ import { Column, Entity, PrimaryColumn } from 'typeorm';
import { AssetType } from '../types';
-@Entity()
+@Entity({ name: 'exchange_fill_events' })
export class ExchangeFillEvent {
- @PrimaryColumn() public contractAddress!: string;
- @PrimaryColumn() public logIndex!: number;
- @PrimaryColumn() public blockNumber!: number;
+ @PrimaryColumn({ name: 'contract_address' })
+ public contractAddress!: string;
+ @PrimaryColumn({ name: 'log_index' })
+ public logIndex!: number;
+ @PrimaryColumn({ name: 'block_number' })
+ public blockNumber!: number;
- @Column() public rawData!: string;
+ @Column({ name: 'raw_data' })
+ public rawData!: string;
- @Column() public transactionHash!: string;
- @Column() public makerAddress!: string;
- @Column() public takerAddress!: string;
- @Column() public feeRecipientAddress!: string;
- @Column() public senderAddress!: string;
- @Column() public makerAssetFilledAmount!: string;
- @Column() public takerAssetFilledAmount!: string;
- @Column() public makerFeePaid!: string;
- @Column() public takerFeePaid!: string;
- @Column() public orderHash!: string;
+ @Column({ 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' })
+ public makerAssetFilledAmount!: string;
+ @Column({ name: 'taker_asset_filled_amount' })
+ public takerAssetFilledAmount!: string;
+ @Column({ name: 'maker_fee_paid' })
+ public makerFeePaid!: string;
+ @Column({ name: 'taker_fee_paid' })
+ public takerFeePaid!: string;
+ @Column({ name: 'order_hash' })
+ public orderHash!: string;
- @Column() public rawMakerAssetData!: string;
- @Column() public makerAssetType!: AssetType;
- @Column() public makerAssetProxyId!: string;
- @Column() public makerTokenAddress!: string;
- @Column({ nullable: true, type: 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() public rawTakerAssetData!: string;
- @Column() public takerAssetType!: AssetType;
- @Column() public takerAssetProxyId!: string;
- @Column() public takerTokenAddress!: string;
- @Column({ nullable: true, type: String })
+ @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): Include topics?
diff --git a/packages/pipeline/src/entities/sra_order.ts b/packages/pipeline/src/entities/sra_order.ts
index a22f7c4e5..f3f79852f 100644
--- a/packages/pipeline/src/entities/sra_order.ts
+++ b/packages/pipeline/src/entities/sra_order.ts
@@ -2,40 +2,65 @@ import { Column, Entity, PrimaryColumn } from 'typeorm';
import { AssetType } from '../types';
-@Entity()
+@Entity({ name: 'sra_orders' })
export class SraOrder {
- @PrimaryColumn() public exchangeAddress!: string;
- @PrimaryColumn() public orderHashHex!: string;
+ @PrimaryColumn({ name: 'exchange_address' })
+ public exchangeAddress!: string;
+ @PrimaryColumn({ name: 'order_hash_hex' })
+ public orderHashHex!: string;
- @Column() public sourceUrl!: string;
- @Column() public lastUpdatedTimestamp!: number;
- @Column() public firstSeenTimestamp!: number;
+ @Column({ name: 'source_url' })
+ public sourceUrl!: string;
+ @Column({ name: 'last_updated_timestamp' })
+ public lastUpdatedTimestamp!: number;
+ @Column({ name: 'first_seen_timestamp' })
+ public firstSeenTimestamp!: number;
- @Column() public makerAddress!: string;
- @Column() public takerAddress!: string;
- @Column() public feeRecipientAddress!: string;
- @Column() public senderAddress!: string;
- @Column() public makerAssetAmount!: string;
- @Column() public takerAssetAmount!: string;
- @Column() public makerFee!: string;
- @Column() public takerFee!: string;
- @Column() public expirationTimeSeconds!: string;
- @Column() public salt!: string;
- @Column() public signature!: 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' })
+ public makerAssetAmount!: string;
+ @Column({ name: 'taker_asset_amount' })
+ public takerAssetAmount!: string;
+ @Column({ name: 'maker_fee' })
+ public makerFee!: string;
+ @Column({ name: 'taker_fee' })
+ public takerFee!: string;
+ @Column({ name: 'expiration_time_seconds' })
+ public expirationTimeSeconds!: string;
+ @Column({ name: 'salt' })
+ public salt!: string;
+ @Column({ name: 'signature' })
+ public signature!: string;
- @Column() public rawMakerAssetData!: string;
- @Column() public makerAssetType!: AssetType;
- @Column() public makerAssetProxyId!: string;
- @Column() public makerTokenAddress!: string;
- @Column({ nullable: true, type: 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() public rawTakerAssetData!: string;
- @Column() public takerAssetType!: AssetType;
- @Column() public takerAssetProxyId!: string;
- @Column() public takerTokenAddress!: string;
- @Column({ nullable: true, type: String })
+ @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() public metaDataJson!: string;
+ @Column({ name: 'metadata_json' })
+ public metadataJson!: string;
}
generated by cgit v1.2.3 (git 2.25.1) at 2024-11-05 19:46:55 +0800