From bb56191a99ab1d7bd170058e7f4735a4a79cf55d Mon Sep 17 00:00:00 2001 From: 0xkenj1 Date: Fri, 17 May 2024 16:42:48 -0300 Subject: [PATCH] fix: unit tests --- packages/adapters/txservice/src/aggregator.ts | 2 -- .../txservice/test/aggregator.spec.ts | 23 +++++++++++++++++-- 2 files changed, 21 insertions(+), 4 deletions(-) diff --git a/packages/adapters/txservice/src/aggregator.ts b/packages/adapters/txservice/src/aggregator.ts index 29d5027fac..fbaca6cde6 100644 --- a/packages/adapters/txservice/src/aggregator.ts +++ b/packages/adapters/txservice/src/aggregator.ts @@ -304,8 +304,6 @@ export class RpcProviderAggregator { synced: provider.synced, metrics: { reliability: provider.reliability, - latency: provider.latency, - cps: provider.cps, priority: provider.priority, }, }, diff --git a/packages/adapters/txservice/test/aggregator.spec.ts b/packages/adapters/txservice/test/aggregator.spec.ts index d70cf3cfd6..33e1adc0f3 100644 --- a/packages/adapters/txservice/test/aggregator.spec.ts +++ b/packages/adapters/txservice/test/aggregator.spec.ts @@ -82,6 +82,10 @@ describe("RpcProviderAggregator", () => { coreSyncProvider = Sinon.createStubInstance(SyncProvider); (coreSyncProvider as any)._syncedBlockNumber = 123; (coreSyncProvider as any).synced = true; + (coreSyncProvider as any).name = "-------fakeProvider------"; + (coreSyncProvider as any).lag = 1; + (coreSyncProvider as any).reliability = 1.0; + (coreSyncProvider as any).priority = 0; (coreSyncProvider as any).url = "https://-------fakeProvider------"; Sinon.stub(coreSyncProvider, "syncedBlockNumber").get(() => (coreSyncProvider as any)._syncedBlockNumber); (chainProvider as any).providers = [coreSyncProvider]; @@ -290,9 +294,24 @@ describe("RpcProviderAggregator", () => { it("should return error result if the signer readContract call throws", async () => { const testError = new Error("test error"); signer.call.rejects(testError); - // The error.context.error is the "test error" thrown by the signer.call. - await expect(chainProvider.readContract(TEST_READ_TX)).to.be.rejectedWith(TransactionReadError); + await expect(chainProvider.readContract(TEST_READ_TX)).to.rejected.then((error) => { + if (error instanceof TransactionReadError) { + expect(error.context.error).to.eq(testError); + expect(error.context.provider).to.deep.eq({ + url: coreSyncProvider.name, + blockNumber: coreSyncProvider.syncedBlockNumber, + lag: coreSyncProvider.lag, + synced: coreSyncProvider.synced, + metrics: { + reliability: coreSyncProvider.reliability, + priority: coreSyncProvider.priority, + }, + }); + } else { + expect.fail("Error should be a TransactionReadError"); + } + }); }); it("should execute with provider if no signer available", async () => {