Reorganize entities. Make scripts work from any directory.

packages/pipeline/src/entities/index.ts

@@ -0,0 +1,7 @@
+export { Block } from './block';
+export { ExchangeCancelEvent } from './exchange_cancel_event';
+export { ExchangeCancelUpToEvent } from './exchange_cancel_up_to_event';
+export { ExchangeFillEvent } from './exchange_fill_event';
+export { Relayer } from './relayer';
+export { SraOrder } from './sra_order';
+export { Transaction } from './transaction';

packages/pipeline/src/ormconfig.ts

@@ -1,11 +1,31 @@
 import { ConnectionOptions } from 'typeorm';
 
+import {
+    Block,
+    ExchangeCancelEvent,
+    ExchangeCancelUpToEvent,
+    ExchangeFillEvent,
+    Relayer,
+    SraOrder,
+    Transaction,
+} from './entities';
+
+const entities = [
+    Block,
+    ExchangeCancelEvent,
+    ExchangeCancelUpToEvent,
+    ExchangeFillEvent,
+    Relayer,
+    SraOrder,
+    Transaction,
+];
+
 export const testConfig: ConnectionOptions = {
     type: 'sqlite',
     database: 'database.sqlite',
     synchronize: true,
     logging: false,
-    entities: ['./lib/src/entities/**/*.js'],
+    entities,
     migrations: ['./lib/src/migrations/**/*.js'],
     cli: {
         entitiesDir: 'lib/src/entities',
@@ -18,7 +38,7 @@ export const deployConfig: ConnectionOptions = {
     url: process.env.ZEROEX_DATA_PIPELINE_DB_URL,
     synchronize: true,
     logging: false,
-    entities: ['./lib/src/entities/**/*.js'],
+    entities,
     migrations: ['./lib/src/migrations/**/*.js'],
     cli: {
         entitiesDir: 'lib/src/entities',

packages/pipeline/src/parsers/events/index.ts

@@ -9,9 +9,7 @@ import { AssetProxyId, ERC721AssetData } from '@0x/types';
 import { LogWithDecodedArgs } from 'ethereum-types';
 import * as R from 'ramda';
 
-import { ExchangeCancelEvent } from '../../entities/ExchangeCancelEvent';
-import { ExchangeCancelUpToEvent } from '../../entities/ExchangeCancelUpToEvent';
-import { ExchangeFillEvent } from '../../entities/ExchangeFillEvent';
+import { ExchangeCancelEvent, ExchangeCancelUpToEvent, ExchangeFillEvent } from '../../entities';
 import { bigNumbertoStringOrNull } from '../../utils';
 
 export type ExchangeEventEntity = ExchangeFillEvent | ExchangeCancelEvent | ExchangeCancelUpToEvent;

packages/pipeline/src/parsers/relayer_registry/index.ts

@@ -1,7 +1,7 @@
 import * as R from 'ramda';
 
 import { RelayerResponse, RelayerResponseNetwork } from '../../data_sources/relayer-registry';
-import { Relayer } from '../../entities/Relayer';
+import { Relayer } from '../../entities';
 
 export function parseRelayers(rawResp: Map<string, RelayerResponse>): Relayer[] {
     const parsedAsObject = R.mapObjIndexed(parseRelayer, rawResp);

packages/pipeline/src/parsers/sra_orders/index.ts

@@ -3,7 +3,7 @@ import { assetDataUtils, orderHashUtils } from '@0x/order-utils';
 import { AssetProxyId, ERC721AssetData } from '@0x/types';
 import * as R from 'ramda';
 
-import { SraOrder } from '../../entities/SraOrder';
+import { SraOrder } from '../../entities';
 import { bigNumbertoStringOrNull } from '../../utils';
 
 export function parseSraOrders(rawOrdersResponse: OrdersResponse): SraOrder[] {

packages/pipeline/src/parsers/web3/index.ts

@@ -1,7 +1,6 @@
 import { BlockWithoutTransactionData, Transaction as EthTransaction } from 'ethereum-types';
 
-import { Block } from '../../entities/Block';
-import { Transaction } from '../../entities/Transaction';
+import { Block, Transaction } from '../../entities';
 
 export function parseBlock(rawBlock: BlockWithoutTransactionData): Block {
     if (rawBlock.hash == null) {

packages/pipeline/src/scripts/merge_v2_events.ts

@@ -3,7 +3,7 @@ import 'reflect-metadata';
 import { Connection, createConnection } from 'typeorm';
 
 import { ExchangeEventsSource } from '../data_sources/contract-wrappers/exchange_events';
-import { ExchangeFillEvent } from '../entities/ExchangeFillEvent';
+import { ExchangeFillEvent } from '../entities';
 import { deployConfig } from '../ormconfig';
 import { parseExchangeEvents } from '../parsers/events';
 

packages/pipeline/src/scripts/pull_missing_events.ts

@@ -5,7 +5,7 @@ import 'reflect-metadata';
 import { Connection, createConnection, Repository } from 'typeorm';
 
 import { ExchangeEventsSource } from '../data_sources/contract-wrappers/exchange_events';
-import { ExchangeFillEvent } from '../entities/ExchangeFillEvent';
+import { ExchangeFillEvent } from '../entities';
 import { deployConfig } from '../ormconfig';
 import { parseExchangeEvents } from '../parsers/events';
 

packages/pipeline/src/scripts/update_relayer_info.ts

@@ -2,7 +2,7 @@ import 'reflect-metadata';
 import { Connection, createConnection } from 'typeorm';
 
 import { RelayerRegistrySource } from '../data_sources/relayer-registry';
-import { Relayer } from '../entities/Relayer';
+import { Relayer } from '../entities';
 import { deployConfig } from '../ormconfig';
 import { parseRelayers } from '../parsers/relayer_registry';
 

packages/pipeline/test/parsers/events/index_test.ts

@@ -4,7 +4,7 @@ import * as chai from 'chai';
 import { LogWithDecodedArgs } from 'ethereum-types';
 import 'mocha';
 
-import { ExchangeFillEvent } from '../../../src/entities/ExchangeFillEvent';
+import { ExchangeFillEvent } from '../../../src/entities';
 import { _convertToEntity } from '../../../src/parsers/events';
 import { chaiSetup } from '../../utils/chai_setup';
 

packages/pipeline/test/parsers/sra_orders/index_test.ts

@@ -3,7 +3,7 @@ import { BigNumber } from '@0x/utils';
 import * as chai from 'chai';
 import 'mocha';
 
-import { SraOrder } from '../../../src/entities/SraOrder';
+import { SraOrder } from '../../../src/entities';
 import { _convertToEntity } from '../../../src/parsers/sra_orders';
 import { chaiSetup } from '../../utils/chai_setup';