diff options
Diffstat (limited to 'packages/pipeline/test/entities')
14 files changed, 0 insertions, 609 deletions
diff --git a/packages/pipeline/test/entities/block_test.ts b/packages/pipeline/test/entities/block_test.ts deleted file mode 100644 index 503f284f0..000000000 --- a/packages/pipeline/test/entities/block_test.ts +++ /dev/null @@ -1,23 +0,0 @@ -import 'mocha'; -import 'reflect-metadata'; - -import { Block } from '../../src/entities'; -import { createDbConnectionOnceAsync } from '../db_setup'; -import { chaiSetup } from '../utils/chai_setup'; - -import { testSaveAndFindEntityAsync } from './util'; - -chaiSetup.configure(); - -// tslint:disable:custom-no-magic-numbers -describe('Block entity', () => { - it('save/find', async () => { - const connection = await createDbConnectionOnceAsync(); - const block = new Block(); - block.hash = '0x12345'; - block.number = 1234567; - block.timestamp = 5432154321; - const blocksRepository = connection.getRepository(Block); - await testSaveAndFindEntityAsync(blocksRepository, block); - }); -}); diff --git a/packages/pipeline/test/entities/copper_test.ts b/packages/pipeline/test/entities/copper_test.ts deleted file mode 100644 index 2543364e6..000000000 --- a/packages/pipeline/test/entities/copper_test.ts +++ /dev/null @@ -1,54 +0,0 @@ -import 'mocha'; -import 'reflect-metadata'; - -import { - CopperActivity, - CopperActivityType, - CopperCustomField, - CopperLead, - CopperOpportunity, -} from '../../src/entities'; -import { createDbConnectionOnceAsync } from '../db_setup'; -import { - ParsedActivities, - ParsedActivityTypes, - ParsedCustomFields, - ParsedLeads, - ParsedOpportunities, -} from '../fixtures/copper/parsed_entities'; -import { chaiSetup } from '../utils/chai_setup'; - -import { testSaveAndFindEntityAsync } from './util'; - -chaiSetup.configure(); - -describe('Copper entities', () => { - describe('save and find', async () => { - it('Copper lead', async () => { - const connection = await createDbConnectionOnceAsync(); - const repository = connection.getRepository(CopperLead); - ParsedLeads.forEach(async entity => testSaveAndFindEntityAsync(repository, entity)); - }); - it('Copper activity', async () => { - const connection = await createDbConnectionOnceAsync(); - const repository = connection.getRepository(CopperActivity); - ParsedActivities.forEach(async entity => testSaveAndFindEntityAsync(repository, entity)); - }); - // searching on jsonb fields is broken in typeorm - it.skip('Copper opportunity', async () => { - const connection = await createDbConnectionOnceAsync(); - const repository = connection.getRepository(CopperOpportunity); - ParsedOpportunities.forEach(async entity => testSaveAndFindEntityAsync(repository, entity)); - }); - it('Copper activity type', async () => { - const connection = await createDbConnectionOnceAsync(); - const repository = connection.getRepository(CopperActivityType); - ParsedActivityTypes.forEach(async entity => testSaveAndFindEntityAsync(repository, entity)); - }); - it('Copper custom field', async () => { - const connection = await createDbConnectionOnceAsync(); - const repository = connection.getRepository(CopperCustomField); - ParsedCustomFields.forEach(async entity => testSaveAndFindEntityAsync(repository, entity)); - }); - }); -}); diff --git a/packages/pipeline/test/entities/dex_trades_test.ts b/packages/pipeline/test/entities/dex_trades_test.ts deleted file mode 100644 index 83aaeec8f..000000000 --- a/packages/pipeline/test/entities/dex_trades_test.ts +++ /dev/null @@ -1,60 +0,0 @@ -import { BigNumber } from '@0x/utils'; -import 'mocha'; -import * as R from 'ramda'; -import 'reflect-metadata'; - -import { DexTrade } from '../../src/entities'; -import { createDbConnectionOnceAsync } from '../db_setup'; -import { chaiSetup } from '../utils/chai_setup'; - -import { testSaveAndFindEntityAsync } from './util'; - -chaiSetup.configure(); - -const baseTrade = { - sourceUrl: 'https://bloxy.info/api/dex/trades', - txTimestamp: 1543447585938, - txDate: '2018-11-21', - txSender: '0x00923b9a074762b93650716333b3e1473a15048e', - smartContractId: 7091917, - smartContractAddress: '0x818e6fecd516ecc3849daf6845e3ec868087b755', - contractType: 'DEX/Kyber Network Proxy', - maker: '0xbf2179859fc6d5bee9bf9158632dc51678a4100c', - taker: '0xbf2179859fc6d5bee9bf9158632dc51678a4100d', - amountBuy: new BigNumber('1.011943163078103'), - makerFeeAmount: new BigNumber(0), - buyCurrencyId: 1, - buySymbol: 'ETH', - amountSell: new BigNumber('941.4997928436911'), - takerFeeAmount: new BigNumber(0), - sellCurrencyId: 16610, - sellSymbol: 'ELF', - makerAnnotation: '', - takerAnnotation: '', - protocol: 'Kyber Network Proxy', - sellAddress: '0xbf2179859fc6d5bee9bf9158632dc51678a4100e', -}; - -const tradeWithNullAddresses: DexTrade = R.merge(baseTrade, { - txHash: '0xb93a7faf92efbbb5405c9a73cd4efd99702fe27c03ff22baee1f1b1e37b3a0bf', - buyAddress: '0xbf2179859fc6d5bee9bf9158632dc51678a4100e', - sellAddress: '0xbf2179859fc6d5bee9bf9158632dc51678a4100f', -}); - -const tradeWithNonNullAddresses: DexTrade = R.merge(baseTrade, { - txHash: '0xb93a7faf92efbbb5405c9a73cd4efd99702fe27c03ff22baee1f1b1e37b3a0be', - buyAddress: null, - sellAddress: null, -}); - -// tslint:disable:custom-no-magic-numbers -describe('DexTrade entity', () => { - it('save/find', async () => { - const connection = await createDbConnectionOnceAsync(); - const trades = [tradeWithNullAddresses, tradeWithNonNullAddresses]; - const tradesRepository = connection.getRepository(DexTrade); - for (const trade of trades) { - await testSaveAndFindEntityAsync(tradesRepository, trade); - } - }); -}); diff --git a/packages/pipeline/test/entities/erc20_approval_events_test.ts b/packages/pipeline/test/entities/erc20_approval_events_test.ts deleted file mode 100644 index 1ecf41ee5..000000000 --- a/packages/pipeline/test/entities/erc20_approval_events_test.ts +++ /dev/null @@ -1,29 +0,0 @@ -import { BigNumber } from '@0x/utils'; -import 'mocha'; -import 'reflect-metadata'; - -import { ERC20ApprovalEvent } from '../../src/entities'; -import { createDbConnectionOnceAsync } from '../db_setup'; -import { chaiSetup } from '../utils/chai_setup'; - -import { testSaveAndFindEntityAsync } from './util'; - -chaiSetup.configure(); - -// tslint:disable:custom-no-magic-numbers -describe('ERC20ApprovalEvent entity', () => { - it('save/find', async () => { - const connection = await createDbConnectionOnceAsync(); - const event = new ERC20ApprovalEvent(); - event.tokenAddress = '0xc02aaa39b223fe8d0a0e5c4f27ead9083c756cc2'; - event.blockNumber = 6281577; - event.rawData = '0x000000000000000000000000000000000000000000000002b9cba5ee21ad3df9'; - event.logIndex = 43; - event.transactionHash = '0xcb46b19c786376a0a0140d51e3e606a4c4f926d8ca5434e96d2f69d04d8d9c7f'; - event.ownerAddress = '0x0b65c5f6f3a05d6be5588a72b603360773b3fe04'; - event.spenderAddress = '0x448a5065aebb8e423f0896e6c5d525c040f59af3'; - event.amount = new BigNumber('50281464906893835769'); - const blocksRepository = connection.getRepository(ERC20ApprovalEvent); - await testSaveAndFindEntityAsync(blocksRepository, event); - }); -}); diff --git a/packages/pipeline/test/entities/exchange_cancel_event_test.ts b/packages/pipeline/test/entities/exchange_cancel_event_test.ts deleted file mode 100644 index f3b306d69..000000000 --- a/packages/pipeline/test/entities/exchange_cancel_event_test.ts +++ /dev/null @@ -1,57 +0,0 @@ -import 'mocha'; -import * as R from 'ramda'; -import 'reflect-metadata'; - -import { ExchangeCancelEvent } from '../../src/entities'; -import { AssetType } from '../../src/types'; -import { createDbConnectionOnceAsync } from '../db_setup'; -import { chaiSetup } from '../utils/chai_setup'; - -import { testSaveAndFindEntityAsync } from './util'; - -chaiSetup.configure(); - -const baseCancelEvent = { - contractAddress: '0x4f833a24e1f95d70f028921e27040ca56e09ab0b', - logIndex: 1234, - blockNumber: 6276262, - rawData: '0x000000000000000000000000f6da68519f78b0d0bc93c701e86affcb75c92428', - transactionHash: '0x6dd106d002873746072fc5e496dd0fb2541b68c77bcf9184ae19a42fd33657fe', - makerAddress: '0xf6da68519f78b0d0bc93c701e86affcb75c92428', - takerAddress: '0xf6da68519f78b0d0bc93c701e86affcb75c92428', - feeRecipientAddress: '0xc370d2a5920344aa6b7d8d11250e3e861434cbdd', - senderAddress: '0xf6da68519f78b0d0bc93c701e86affcb75c92428', - orderHash: '0xab12ed2cbaa5615ab690b9da75a46e53ddfcf3f1a68655b5fe0d94c75a1aac4a', - rawMakerAssetData: '0xf47261b0000000000000000000000000c02aaa39b223fe8d0a0e5c4f27ead9083c756cc2', - makerAssetProxyId: '0xf47261b0', - makerTokenAddress: '0xc02aaa39b223fe8d0a0e5c4f27ead9083c756cc2', - rawTakerAssetData: '0xf47261b0000000000000000000000000e41d2489571d322189246dafa5ebde1f4699f498', - takerAssetProxyId: '0xf47261b0', - takerTokenAddress: '0xe41d2489571d322189246dafa5ebde1f4699f498', -}; - -const erc20CancelEvent = R.merge(baseCancelEvent, { - makerAssetType: 'erc20' as AssetType, - makerTokenId: null, - takerAssetType: 'erc20' as AssetType, - takerTokenId: null, -}); - -const erc721CancelEvent = R.merge(baseCancelEvent, { - makerAssetType: 'erc721' as AssetType, - makerTokenId: '19378573', - takerAssetType: 'erc721' as AssetType, - takerTokenId: '63885673888', -}); - -// tslint:disable:custom-no-magic-numbers -describe('ExchangeCancelEvent entity', () => { - it('save/find', async () => { - const connection = await createDbConnectionOnceAsync(); - const events = [erc20CancelEvent, erc721CancelEvent]; - const cancelEventRepository = connection.getRepository(ExchangeCancelEvent); - for (const event of events) { - await testSaveAndFindEntityAsync(cancelEventRepository, event); - } - }); -}); diff --git a/packages/pipeline/test/entities/exchange_cancel_up_to_event_test.ts b/packages/pipeline/test/entities/exchange_cancel_up_to_event_test.ts deleted file mode 100644 index aa34f8c1c..000000000 --- a/packages/pipeline/test/entities/exchange_cancel_up_to_event_test.ts +++ /dev/null @@ -1,29 +0,0 @@ -import { BigNumber } from '@0x/utils'; -import 'mocha'; -import 'reflect-metadata'; - -import { ExchangeCancelUpToEvent } from '../../src/entities'; -import { createDbConnectionOnceAsync } from '../db_setup'; -import { chaiSetup } from '../utils/chai_setup'; - -import { testSaveAndFindEntityAsync } from './util'; - -chaiSetup.configure(); - -// tslint:disable:custom-no-magic-numbers -describe('ExchangeCancelUpToEvent entity', () => { - it('save/find', async () => { - const connection = await createDbConnectionOnceAsync(); - const cancelUpToEventRepository = connection.getRepository(ExchangeCancelUpToEvent); - const cancelUpToEvent = new ExchangeCancelUpToEvent(); - cancelUpToEvent.blockNumber = 6276262; - cancelUpToEvent.contractAddress = '0x4f833a24e1f95d70f028921e27040ca56e09ab0b'; - cancelUpToEvent.logIndex = 42; - cancelUpToEvent.makerAddress = '0xf6da68519f78b0d0bc93c701e86affcb75c92428'; - cancelUpToEvent.orderEpoch = new BigNumber('123456789123456789'); - cancelUpToEvent.rawData = '0x000000000000000000000000f6da68519f78b0d0bc93c701e86affcb75c92428'; - cancelUpToEvent.senderAddress = '0xf6da68519f78b0d0bc93c701e86affcb75c92428'; - cancelUpToEvent.transactionHash = '0x6dd106d002873746072fc5e496dd0fb2541b68c77bcf9184ae19a42fd33657fe'; - await testSaveAndFindEntityAsync(cancelUpToEventRepository, cancelUpToEvent); - }); -}); diff --git a/packages/pipeline/test/entities/exchange_fill_event_test.ts b/packages/pipeline/test/entities/exchange_fill_event_test.ts deleted file mode 100644 index b2cb8c5e0..000000000 --- a/packages/pipeline/test/entities/exchange_fill_event_test.ts +++ /dev/null @@ -1,62 +0,0 @@ -import { BigNumber } from '@0x/utils'; -import 'mocha'; -import * as R from 'ramda'; -import 'reflect-metadata'; - -import { ExchangeFillEvent } from '../../src/entities'; -import { AssetType } from '../../src/types'; -import { createDbConnectionOnceAsync } from '../db_setup'; -import { chaiSetup } from '../utils/chai_setup'; - -import { testSaveAndFindEntityAsync } from './util'; - -chaiSetup.configure(); - -const baseFillEvent = { - contractAddress: '0x4f833a24e1f95d70f028921e27040ca56e09ab0b', - blockNumber: 6276262, - logIndex: 102, - rawData: '0x000000000000000000000000f6da68519f78b0d0bc93c701e86affcb75c92428', - transactionHash: '0x6dd106d002873746072fc5e496dd0fb2541b68c77bcf9184ae19a42fd33657fe', - makerAddress: '0xf6da68519f78b0d0bc93c701e86affcb75c92428', - takerAddress: '0xf6da68519f78b0d0bc93c701e86affcb75c92428', - feeRecipientAddress: '0xc370d2a5920344aa6b7d8d11250e3e861434cbdd', - senderAddress: '0xf6da68519f78b0d0bc93c701e86affcb75c92428', - makerAssetFilledAmount: new BigNumber('10000000000000000'), - takerAssetFilledAmount: new BigNumber('100000000000000000'), - makerFeePaid: new BigNumber('0'), - takerFeePaid: new BigNumber('12345'), - orderHash: '0xab12ed2cbaa5615ab690b9da75a46e53ddfcf3f1a68655b5fe0d94c75a1aac4a', - rawMakerAssetData: '0xf47261b0000000000000000000000000c02aaa39b223fe8d0a0e5c4f27ead9083c756cc2', - makerAssetProxyId: '0xf47261b0', - makerTokenAddress: '0xc02aaa39b223fe8d0a0e5c4f27ead9083c756cc2', - rawTakerAssetData: '0xf47261b0000000000000000000000000e41d2489571d322189246dafa5ebde1f4699f498', - takerAssetProxyId: '0xf47261b0', - takerTokenAddress: '0xe41d2489571d322189246dafa5ebde1f4699f498', -}; - -const erc20FillEvent = R.merge(baseFillEvent, { - makerAssetType: 'erc20' as AssetType, - makerTokenId: null, - takerAssetType: 'erc20' as AssetType, - takerTokenId: null, -}); - -const erc721FillEvent = R.merge(baseFillEvent, { - makerAssetType: 'erc721' as AssetType, - makerTokenId: '19378573', - takerAssetType: 'erc721' as AssetType, - takerTokenId: '63885673888', -}); - -// tslint:disable:custom-no-magic-numbers -describe('ExchangeFillEvent entity', () => { - it('save/find', async () => { - const connection = await createDbConnectionOnceAsync(); - const events = [erc20FillEvent, erc721FillEvent]; - const fillEventsRepository = connection.getRepository(ExchangeFillEvent); - for (const event of events) { - await testSaveAndFindEntityAsync(fillEventsRepository, event); - } - }); -}); diff --git a/packages/pipeline/test/entities/ohlcv_external_test.ts b/packages/pipeline/test/entities/ohlcv_external_test.ts deleted file mode 100644 index 8b995db50..000000000 --- a/packages/pipeline/test/entities/ohlcv_external_test.ts +++ /dev/null @@ -1,35 +0,0 @@ -import 'mocha'; -import 'reflect-metadata'; - -import { OHLCVExternal } from '../../src/entities'; -import { createDbConnectionOnceAsync } from '../db_setup'; -import { chaiSetup } from '../utils/chai_setup'; - -import { testSaveAndFindEntityAsync } from './util'; - -chaiSetup.configure(); - -const ohlcvExternal: OHLCVExternal = { - exchange: 'CCCAGG', - fromSymbol: 'ETH', - toSymbol: 'ZRX', - startTime: 1543352400000, - endTime: 1543356000000, - open: 307.41, - close: 310.08, - low: 304.6, - high: 310.27, - volumeFrom: 904.6, - volumeTo: 278238.5, - source: 'Crypto Compare', - observedTimestamp: 1543442338074, -}; - -// tslint:disable:custom-no-magic-numbers -describe('OHLCVExternal entity', () => { - it('save/find', async () => { - const connection = await createDbConnectionOnceAsync(); - const repository = connection.getRepository(OHLCVExternal); - await testSaveAndFindEntityAsync(repository, ohlcvExternal); - }); -}); diff --git a/packages/pipeline/test/entities/relayer_test.ts b/packages/pipeline/test/entities/relayer_test.ts deleted file mode 100644 index 760ffb6f9..000000000 --- a/packages/pipeline/test/entities/relayer_test.ts +++ /dev/null @@ -1,55 +0,0 @@ -import 'mocha'; -import * as R from 'ramda'; -import 'reflect-metadata'; - -import { Relayer } from '../../src/entities'; -import { createDbConnectionOnceAsync } from '../db_setup'; -import { chaiSetup } from '../utils/chai_setup'; - -import { testSaveAndFindEntityAsync } from './util'; - -chaiSetup.configure(); - -const baseRelayer = { - uuid: 'e8d27d8d-ddf6-48b1-9663-60b0a3ddc716', - name: 'Radar Relay', - homepageUrl: 'https://radarrelay.com', - appUrl: null, - sraHttpEndpoint: null, - sraWsEndpoint: null, - feeRecipientAddresses: [], - takerAddresses: [], -}; - -const relayerWithUrls = R.merge(baseRelayer, { - uuid: 'e8d27d8d-ddf6-48b1-9663-60b0a3ddc717', - appUrl: 'https://app.radarrelay.com', - sraHttpEndpoint: 'https://api.radarrelay.com/0x/v2/', - sraWsEndpoint: 'wss://ws.radarrelay.com/0x/v2', -}); - -const relayerWithAddresses = R.merge(baseRelayer, { - uuid: 'e8d27d8d-ddf6-48b1-9663-60b0a3ddc718', - feeRecipientAddresses: [ - '0xa258b39954cef5cb142fd567a46cddb31a670124', - '0xa258b39954cef5cb142fd567a46cddb31a670125', - '0xa258b39954cef5cb142fd567a46cddb31a670126', - ], - takerAddresses: [ - '0xa258b39954cef5cb142fd567a46cddb31a670127', - '0xa258b39954cef5cb142fd567a46cddb31a670128', - '0xa258b39954cef5cb142fd567a46cddb31a670129', - ], -}); - -// tslint:disable:custom-no-magic-numbers -describe('Relayer entity', () => { - it('save/find', async () => { - const connection = await createDbConnectionOnceAsync(); - const relayers = [baseRelayer, relayerWithUrls, relayerWithAddresses]; - const relayerRepository = connection.getRepository(Relayer); - for (const relayer of relayers) { - await testSaveAndFindEntityAsync(relayerRepository, relayer); - } - }); -}); diff --git a/packages/pipeline/test/entities/sra_order_test.ts b/packages/pipeline/test/entities/sra_order_test.ts deleted file mode 100644 index c43de8ce8..000000000 --- a/packages/pipeline/test/entities/sra_order_test.ts +++ /dev/null @@ -1,84 +0,0 @@ -import { BigNumber } from '@0x/utils'; -import 'mocha'; -import * as R from 'ramda'; -import 'reflect-metadata'; -import { Repository } from 'typeorm'; - -import { SraOrder, SraOrdersObservedTimeStamp } from '../../src/entities'; -import { AssetType } from '../../src/types'; -import { createDbConnectionOnceAsync } from '../db_setup'; -import { chaiSetup } from '../utils/chai_setup'; - -import { testSaveAndFindEntityAsync } from './util'; - -chaiSetup.configure(); - -const baseOrder = { - sourceUrl: 'https://api.radarrelay.com/0x/v2', - exchangeAddress: '0x4f833a24e1f95d70f028921e27040ca56e09ab0b', - makerAddress: '0xb45df06e38540a675fdb5b598abf2c0dbe9d6b81', - takerAddress: '0x0000000000000000000000000000000000000000', - feeRecipientAddress: '0xa258b39954cef5cb142fd567a46cddb31a670124', - senderAddress: '0x0000000000000000000000000000000000000000', - makerAssetAmount: new BigNumber('1619310371000000000'), - takerAssetAmount: new BigNumber('8178335207070707070707'), - makerFee: new BigNumber('100'), - takerFee: new BigNumber('200'), - expirationTimeSeconds: new BigNumber('1538529488'), - salt: new BigNumber('1537924688891'), - signature: '0x1b5a5d672b0d647b5797387ccbb89d8', - rawMakerAssetData: '0xf47261b0000000000000000000000000c02aaa39b223fe8d0a0e5c4f27ead9083c756cc2', - makerAssetProxyId: '0xf47261b0', - makerTokenAddress: '0xc02aaa39b223fe8d0a0e5c4f27ead9083c756cc2', - rawTakerAssetData: '0xf47261b000000000000000000000000042d6622dece394b54999fbd73d108123806f6a18', - takerAssetProxyId: '0xf47261b0', - takerTokenAddress: '0x42d6622dece394b54999fbd73d108123806f6a18', - metadataJson: '{"isThisArbitraryData":true,"powerLevel":9001}', -}; - -const erc20Order = R.merge(baseOrder, { - orderHashHex: '0x1bdbeb0d088a33da28b9ee6d94e8771452f90f4a69107da2fa75195d61b9a1c9', - makerAssetType: 'erc20' as AssetType, - makerTokenId: null, - takerAssetType: 'erc20' as AssetType, - takerTokenId: null, -}); - -const erc721Order = R.merge(baseOrder, { - orderHashHex: '0x1bdbeb0d088a33da28b9ee6d94e8771452f90f4a69107da2fa75195d61b9a1d0', - makerAssetType: 'erc721' as AssetType, - makerTokenId: '19378573', - takerAssetType: 'erc721' as AssetType, - takerTokenId: '63885673888', -}); - -// tslint:disable:custom-no-magic-numbers -describe('SraOrder and SraOrdersObservedTimeStamp entities', () => { - // Note(albrow): SraOrder and SraOrdersObservedTimeStamp are tightly coupled - // and timestamps have a foreign key constraint such that they have to point - // to an existing SraOrder. For these reasons, we are testing them together - // in the same test. - it('save/find', async () => { - const connection = await createDbConnectionOnceAsync(); - const orderRepository = connection.getRepository(SraOrder); - const timestampRepository = connection.getRepository(SraOrdersObservedTimeStamp); - const orders = [erc20Order, erc721Order]; - for (const order of orders) { - await testOrderWithTimestampAsync(orderRepository, timestampRepository, order); - } - }); -}); - -async function testOrderWithTimestampAsync( - orderRepository: Repository<SraOrder>, - timestampRepository: Repository<SraOrdersObservedTimeStamp>, - order: SraOrder, -): Promise<void> { - await testSaveAndFindEntityAsync(orderRepository, order); - const timestamp = new SraOrdersObservedTimeStamp(); - timestamp.exchangeAddress = order.exchangeAddress; - timestamp.orderHashHex = order.orderHashHex; - timestamp.sourceUrl = order.sourceUrl; - timestamp.observedTimestamp = 1543377376153; - await testSaveAndFindEntityAsync(timestampRepository, timestamp); -} diff --git a/packages/pipeline/test/entities/token_metadata_test.ts b/packages/pipeline/test/entities/token_metadata_test.ts deleted file mode 100644 index 48e656644..000000000 --- a/packages/pipeline/test/entities/token_metadata_test.ts +++ /dev/null @@ -1,39 +0,0 @@ -import { BigNumber } from '@0x/utils'; -import 'mocha'; -import 'reflect-metadata'; - -import { TokenMetadata } from '../../src/entities'; -import { createDbConnectionOnceAsync } from '../db_setup'; -import { chaiSetup } from '../utils/chai_setup'; - -import { testSaveAndFindEntityAsync } from './util'; - -chaiSetup.configure(); - -const metadataWithoutNullFields: TokenMetadata = { - address: '0xe41d2489571d322189246dafa5ebde1f4699f498', - authority: 'https://website-api.0xproject.com/tokens', - decimals: new BigNumber(18), - symbol: 'ZRX', - name: '0x', -}; - -const metadataWithNullFields: TokenMetadata = { - address: '0xe41d2489571d322189246dafa5ebde1f4699f499', - authority: 'https://website-api.0xproject.com/tokens', - decimals: null, - symbol: null, - name: null, -}; - -// tslint:disable:custom-no-magic-numbers -describe('TokenMetadata entity', () => { - it('save/find', async () => { - const connection = await createDbConnectionOnceAsync(); - const tokenMetadata = [metadataWithoutNullFields, metadataWithNullFields]; - const tokenMetadataRepository = connection.getRepository(TokenMetadata); - for (const tokenMetadatum of tokenMetadata) { - await testSaveAndFindEntityAsync(tokenMetadataRepository, tokenMetadatum); - } - }); -}); diff --git a/packages/pipeline/test/entities/token_order_test.ts b/packages/pipeline/test/entities/token_order_test.ts deleted file mode 100644 index c6057f5aa..000000000 --- a/packages/pipeline/test/entities/token_order_test.ts +++ /dev/null @@ -1,31 +0,0 @@ -import { BigNumber } from '@0x/utils'; -import 'mocha'; - -import { TokenOrderbookSnapshot } from '../../src/entities'; -import { createDbConnectionOnceAsync } from '../db_setup'; -import { chaiSetup } from '../utils/chai_setup'; - -import { testSaveAndFindEntityAsync } from './util'; - -chaiSetup.configure(); - -const tokenOrderbookSnapshot: TokenOrderbookSnapshot = { - source: 'ddextest', - observedTimestamp: Date.now(), - orderType: 'bid', - price: new BigNumber(10.1), - baseAssetSymbol: 'ETH', - baseAssetAddress: '0x818e6fecd516ecc3849daf6845e3ec868087b755', - baseVolume: new BigNumber(143), - quoteAssetSymbol: 'ABC', - quoteAssetAddress: '0x00923b9a074762b93650716333b3e1473a15048e', - quoteVolume: new BigNumber(12.3234234), -}; - -describe('TokenOrderbookSnapshot entity', () => { - it('save/find', async () => { - const connection = await createDbConnectionOnceAsync(); - const tokenOrderbookSnapshotRepository = connection.getRepository(TokenOrderbookSnapshot); - await testSaveAndFindEntityAsync(tokenOrderbookSnapshotRepository, tokenOrderbookSnapshot); - }); -}); diff --git a/packages/pipeline/test/entities/transaction_test.ts b/packages/pipeline/test/entities/transaction_test.ts deleted file mode 100644 index 634844544..000000000 --- a/packages/pipeline/test/entities/transaction_test.ts +++ /dev/null @@ -1,26 +0,0 @@ -import { BigNumber } from '@0x/utils'; -import 'mocha'; -import 'reflect-metadata'; - -import { Transaction } from '../../src/entities'; -import { createDbConnectionOnceAsync } from '../db_setup'; -import { chaiSetup } from '../utils/chai_setup'; - -import { testSaveAndFindEntityAsync } from './util'; - -chaiSetup.configure(); - -// tslint:disable:custom-no-magic-numbers -describe('Transaction entity', () => { - it('save/find', async () => { - const connection = await createDbConnectionOnceAsync(); - const transactionRepository = connection.getRepository(Transaction); - const transaction = new Transaction(); - transaction.blockHash = '0x6ff106d00b6c3746072fc06bae140fb2549036ba7bcf9184ae19a42fd33657fd'; - transaction.blockNumber = 6276262; - transaction.gasPrice = new BigNumber(3000000); - transaction.gasUsed = new BigNumber(125000); - transaction.transactionHash = '0x6dd106d002873746072fc5e496dd0fb2541b68c77bcf9184ae19a42fd33657fe'; - await testSaveAndFindEntityAsync(transactionRepository, transaction); - }); -}); diff --git a/packages/pipeline/test/entities/util.ts b/packages/pipeline/test/entities/util.ts deleted file mode 100644 index 42df23a4a..000000000 --- a/packages/pipeline/test/entities/util.ts +++ /dev/null @@ -1,25 +0,0 @@ -import * as chai from 'chai'; -import 'mocha'; - -import { Repository } from 'typeorm'; - -const expect = chai.expect; - -/** - * First saves the given entity to the database, then finds it and makes sure - * that the found entity is exactly equal to the original one. This is a bare - * minimum basic test to make sure that the entity type definition and our - * database schema are aligned and that it is possible to save and find the - * entity. - * @param repository A TypeORM repository corresponding with the type of the entity. - * @param entity An instance of a TypeORM entity which will be saved/retrieved from the database. - */ -export async function testSaveAndFindEntityAsync<T>(repository: Repository<T>, entity: T): Promise<void> { - // Note(albrow): We are forced to use an 'any' hack here because - // TypeScript complains about stack depth when checking the types. - await repository.save<any>(entity); - const gotEntity = await repository.findOneOrFail({ - where: entity, - }); - expect(gotEntity).deep.equal(entity); -} |