diff --git a/src/services/bridge-api.ts b/src/services/bridge-api.ts index 9596f4c..4bd6138 100644 --- a/src/services/bridge-api.ts +++ b/src/services/bridge-api.ts @@ -7,35 +7,28 @@ export default class BridgeApi { async getAvailLatestHeadOnEthereum(): Promise> { return await axios({ method: "get", - url: `${this.url}/avl/head`, + url: `${this.url}/v1/avl/head`, }); } async getEthLatestHeadOnAvail(): Promise> { return await axios({ method: "get", - url: `${this.url}/eth/head`, - }); - } - - async getBlockNumberBySlot(slot: number): Promise> { - return await axios({ - method: "get", - url: `${this.url}/beacon/slot/${slot}`, + url: `${this.url}/v1/eth/head`, }); } async getProofToSubmitOnEthereum(blockHash: string, transactionIndex: string): Promise> { return await axios({ method: "get", - url: `${this.url}/eth/proof/${blockHash}?index=${transactionIndex}`, + url: `${this.url}/v1/eth/proof/${blockHash}?index=${transactionIndex}`, }); } async getProofToSubmitOnAvail(blockHash: string, messageId: string): Promise> { return await axios({ method: "get", - url: `${this.url}/avl/proof/${blockHash}/${messageId}`, + url: `${this.url}/v1/avl/proof/${blockHash}/${messageId}`, }); } diff --git a/src/services/transaction-cron.ts b/src/services/transaction-cron.ts index c1a52f7..8a45612 100644 --- a/src/services/transaction-cron.ts +++ b/src/services/transaction-cron.ts @@ -266,21 +266,17 @@ export default class TransactionCron { try { let response = await this.bridgeApi.getEthLatestHeadOnAvail(); - if (response && response.data && response.data.slot) { - let block = await this.bridgeApi.getBlockNumberBySlot( - response.data.slot - ); - if (block && block.data && block.data.blockNumber) { + if (response && response.data && response.data.blockNumber) { + let blockNumber = response.data.blockNumber await prisma.ethereumsends.updateMany({ where: { status: "BRIDGED", - sourceBlockNumber: { lte: block.data.blockNumber }, + sourceBlockNumber: { lte: blockNumber }, }, data: { status: "READY_TO_CLAIM", }, }); - } } } catch (error) { logger.error(