diff options
author | Alex Browne <stephenalexbrowne@gmail.com> | 2018-11-08 08:48:25 +0800 |
---|---|---|
committer | Fred Carlsen <fred@sjelfull.no> | 2018-12-06 19:04:24 +0800 |
commit | 0f869b0545d18863414ba4d5cc0c2aeb4da700db (patch) | |
tree | 6cae33f938d797c11507534aa1ffbc12a9465319 /packages/pipeline/src/scripts/update_relayer_info.ts | |
parent | 774971c98c0881dc34ae294a0a9a7d6db55e37c4 (diff) | |
download | dexon-sol-tools-0f869b0545d18863414ba4d5cc0c2aeb4da700db.tar dexon-sol-tools-0f869b0545d18863414ba4d5cc0c2aeb4da700db.tar.gz dexon-sol-tools-0f869b0545d18863414ba4d5cc0c2aeb4da700db.tar.bz2 dexon-sol-tools-0f869b0545d18863414ba4d5cc0c2aeb4da700db.tar.lz dexon-sol-tools-0f869b0545d18863414ba4d5cc0c2aeb4da700db.tar.xz dexon-sol-tools-0f869b0545d18863414ba4d5cc0c2aeb4da700db.tar.zst dexon-sol-tools-0f869b0545d18863414ba4d5cc0c2aeb4da700db.zip |
Split index.ts into multiple scripts in scripts/ and detect last known block when pulling events
Diffstat (limited to 'packages/pipeline/src/scripts/update_relayer_info.ts')
-rw-r--r-- | packages/pipeline/src/scripts/update_relayer_info.ts | 31 |
1 files changed, 31 insertions, 0 deletions
diff --git a/packages/pipeline/src/scripts/update_relayer_info.ts b/packages/pipeline/src/scripts/update_relayer_info.ts new file mode 100644 index 000000000..05e045ff4 --- /dev/null +++ b/packages/pipeline/src/scripts/update_relayer_info.ts @@ -0,0 +1,31 @@ +import 'reflect-metadata'; +import { Connection, createConnection } from 'typeorm'; + +import { RelayerRegistrySource } from '../data_sources/relayer-registry'; +import { Relayer } from '../entities/Relayer'; +import { deployConfig } from '../ormconfig'; +import { parseRelayers } from '../parsers/relayer_registry'; + +// NOTE(albrow): We need to manually update this URL for now. Fix this when we +// have the relayer-registry behind semantic versioning. +const RELAYER_REGISTRY_URL = + 'https://raw.githubusercontent.com/0xProject/0x-relayer-registry/4701c85677d161ea729a466aebbc1826c6aa2c0b/relayers.json'; + +let connection: Connection; + +(async () => { + connection = await createConnection(deployConfig); + await getRelayers(); + process.exit(0); +})(); + +async function getRelayers(): Promise<void> { + console.log('Getting latest relayer info...'); + const relayerRepository = connection.getRepository(Relayer); + const relayerSource = new RelayerRegistrySource(RELAYER_REGISTRY_URL); + const relayersResp = await relayerSource.getRelayerInfoAsync(); + const relayers = parseRelayers(relayersResp); + console.log('Saving relayer info...'); + await relayerRepository.save(relayers); + console.log('Done saving relayer info.'); +} |