diff --git a/packages/data-transport-layer/package.json b/packages/data-transport-layer/package.json index da0ca5267abf..ac98ed5bdad3 100644 --- a/packages/data-transport-layer/package.json +++ b/packages/data-transport-layer/package.json @@ -29,6 +29,7 @@ "@sentry/node": "^6.3.1", "@sentry/tracing": "^6.3.1", "@types/express": "^4.17.11", + "axios": "^0.21.1", "bcfg": "^0.1.6", "bfj": "^7.0.2", "browser-or-node": "^1.3.0", diff --git a/packages/data-transport-layer/src/services/l2-ingestion/service.ts b/packages/data-transport-layer/src/services/l2-ingestion/service.ts index 6a32bc301a58..fb6434f433c3 100644 --- a/packages/data-transport-layer/src/services/l2-ingestion/service.ts +++ b/packages/data-transport-layer/src/services/l2-ingestion/service.ts @@ -3,8 +3,8 @@ import { BaseService } from '@eth-optimism/common-ts' import { JsonRpcProvider } from '@ethersproject/providers' import { BigNumber } from 'ethers' import { LevelUp } from 'levelup' -import axios from 'axios'; -import bfj from 'bfj'; +import axios from 'axios' +import bfj from 'bfj' /* Imports: Internal */ import { TransportDB } from '../../db/transport-db' @@ -184,13 +184,17 @@ export class L2IngestionService extends BaseService { true, ], id: '1', - }; + } - const resp = await axios.post(this.state.l2RpcProvider.connection.url, req, {responseType: 'stream'}); - const respJson = await bfj.parse(resp.data, { - yieldRate: 4096 // this yields abit more often than the default of 16384 - }); - const blocks = respJson.data; + const resp = await axios.post( + this.state.l2RpcProvider.connection.url, + req, + { responseType: 'stream' } + ) + const respJson = await bfj.parse(resp.data, { + yieldRate: 4096, // this yields abit more often than the default of 16384 + }) + blocks = respJson.data } for (const block of blocks) {