-
Notifications
You must be signed in to change notification settings - Fork 19
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
feat: update bulk insert with test codes
- Loading branch information
1 parent
20a52c8
commit d7e1416
Showing
7 changed files
with
338 additions
and
137 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,156 @@ | ||
| import { describe } from '@jest/globals' | ||
| import { | ||
| listHandler as adapterListHandler, | ||
| removeHandler as adapterRemoveHandler | ||
| } from '../src/adapter' | ||
| import { | ||
| listHandler as aggregatorListHandler, | ||
| removeHandler as aggregatorRemoveHandler | ||
| } from '../src/aggregator' | ||
| import { | ||
| insertHandler as chainInsertHandler, | ||
| listHandler as chainListHandler, | ||
| removeHandler as chainRemoveHandler | ||
| } from '../src/chain' | ||
| import { bulkInsertHandler } from '../src/datafeed' | ||
| import { | ||
| contractListHandler, | ||
| contractRemoveHandler, | ||
| functionListHandler, | ||
| functionRemoveHandler, | ||
| organizationInsertHandler, | ||
| organizationListHandler, | ||
| organizationRemoveHandler, | ||
| reporterListHandler as delegatorReporterListHandler, | ||
| reporterRemoveHandler as delegatorReporterRemoveHandler | ||
| } from '../src/delegator' | ||
| import { | ||
| listHandler as listenerListHandler, | ||
| removeHandler as listenerRemoveHandler | ||
| } from '../src/listener' | ||
| import { | ||
| listHandler as reporterListHandler, | ||
| removeHandler as reporterRemoveHandler | ||
| } from '../src/reporter' | ||
| import { | ||
| insertHandler as serviceInsertHandler, | ||
| listHandler as serviceListHandler, | ||
| removeHandler as serviceRemoveHandler | ||
| } from '../src/service' | ||
| import { DATAFEED_BULK_0, DATAFEED_BULK_1 } from './mockData' | ||
|
|
||
| describe('CLI datafeed', function () { | ||
| beforeAll(async () => { | ||
| await chainInsertHandler()({ name: 'localhost' }) | ||
| await chainInsertHandler()({ name: 'baobab' }) | ||
| await serviceInsertHandler()({ name: 'DATA_FEED' }) | ||
| await serviceInsertHandler()({ name: 'DATA_FEED_V2' }) | ||
| await organizationInsertHandler()({ name: 'bisonai' }) | ||
| await organizationInsertHandler()({ name: 'kf' }) | ||
| }) | ||
|
|
||
| afterAll(async () => { | ||
| const chains = await chainListHandler()() | ||
| for (const chain of chains) { | ||
| await chainRemoveHandler()({ id: chain.id }) | ||
| } | ||
| const services = await serviceListHandler()() | ||
| for (const service of services) { | ||
| await serviceRemoveHandler()({ id: service.id }) | ||
| } | ||
| const organizations = await organizationListHandler()() | ||
| for (const organization of organizations) { | ||
| await organizationRemoveHandler()({ id: organization.id }) | ||
| } | ||
| }) | ||
|
|
||
| afterEach(async () => { | ||
| const afterAdapterList = await adapterListHandler()() | ||
| const afterAggregatorList = await aggregatorListHandler()({}) | ||
| const afterDelegatorReporterList = await delegatorReporterListHandler()() | ||
| const afterContractList = await contractListHandler()() | ||
| const afterListenerList = await listenerListHandler()({}) | ||
| const afterReporterList = await reporterListHandler()({}) | ||
| const afterFunctionList = await functionListHandler()() | ||
|
|
||
| for (const _function of afterFunctionList) { | ||
| await functionRemoveHandler()({ id: Number(_function.id) }) | ||
| } | ||
| for (const aggregator of afterAggregatorList) { | ||
| await aggregatorRemoveHandler()({ id: aggregator.id }) | ||
| } | ||
|
|
||
| for (const adapter of afterAdapterList) { | ||
| await adapterRemoveHandler()({ id: adapter.id }) | ||
| } | ||
|
|
||
| for (const delegatorReporter of afterDelegatorReporterList) { | ||
| await delegatorReporterRemoveHandler()({ id: delegatorReporter.id }) | ||
| } | ||
| for (const contract of afterContractList) { | ||
| await contractRemoveHandler()({ id: contract.id }) | ||
| } | ||
| for (const listener of afterListenerList) { | ||
| await listenerRemoveHandler()({ id: listener.id }) | ||
| } | ||
| for (const reporter of afterReporterList) { | ||
| await reporterRemoveHandler()({ id: reporter.id }) | ||
| } | ||
| }) | ||
|
|
||
| test('datafeed bulk insert with default values', async function () { | ||
| const beforeAdapterList = await adapterListHandler()() | ||
| const beforeAggregatorList = await aggregatorListHandler()({}) | ||
| const beforeDelegatorReporterList = await delegatorReporterListHandler()() | ||
| const beforeContractList = await contractListHandler()() | ||
| const beforeListenerList = await listenerListHandler()({}) | ||
| const beforeReporterList = await reporterListHandler()({}) | ||
| const beforeFunctionList = await functionListHandler()() | ||
|
|
||
| await bulkInsertHandler()({ data: DATAFEED_BULK_0 }) | ||
|
|
||
| const afterAdapterList = await adapterListHandler()() | ||
| const afterAggregatorList = await aggregatorListHandler()({}) | ||
| const afterDelegatorReporterList = await delegatorReporterListHandler()() | ||
| const afterContractList = await contractListHandler()() | ||
| const afterListenerList = await listenerListHandler()({}) | ||
| const afterReporterList = await reporterListHandler()({}) | ||
| const afterFunctionList = await functionListHandler()() | ||
|
|
||
| expect(afterAdapterList.length).toEqual(beforeAdapterList.length + 3) | ||
| expect(afterAggregatorList.length).toEqual(beforeAggregatorList.length + 3) | ||
| expect(afterDelegatorReporterList.length).toEqual(beforeDelegatorReporterList.length + 3) | ||
| expect(afterContractList.length).toEqual(beforeContractList.length + 3) | ||
| expect(afterListenerList.length).toEqual(beforeListenerList.length + 3) | ||
| expect(afterReporterList.length).toEqual(beforeReporterList.length + 3) | ||
| expect(afterFunctionList.length).toEqual(beforeFunctionList.length + 3) | ||
| }) | ||
|
|
||
| test('datafeed bulk insert', async function () { | ||
| const beforeAdapterList = await adapterListHandler()() | ||
| const beforeAggregatorList = await aggregatorListHandler()({}) | ||
| const beforeDelegatorReporterList = await delegatorReporterListHandler()() | ||
| const beforeContractList = await contractListHandler()() | ||
| const beforeListenerList = await listenerListHandler()({}) | ||
| const beforeReporterList = await reporterListHandler()({}) | ||
| const beforeFunctionList = await functionListHandler()() | ||
|
|
||
| await bulkInsertHandler()({ data: DATAFEED_BULK_1 }) | ||
|
|
||
| const afterAdapterList = await adapterListHandler()() | ||
| const afterAggregatorList = await aggregatorListHandler()({}) | ||
| const afterDelegatorReporterList = await delegatorReporterListHandler()() | ||
| const afterContractList = await contractListHandler()() | ||
| const afterListenerList = await listenerListHandler()({}) | ||
| const afterReporterList = await reporterListHandler()({}) | ||
| const afterFunctionList = await functionListHandler()() | ||
|
|
||
| expect(afterAdapterList.length).toEqual(beforeAdapterList.length + 3) | ||
| expect(afterAggregatorList.length).toEqual(beforeAggregatorList.length + 3) | ||
| expect(afterDelegatorReporterList.length).toEqual(beforeDelegatorReporterList.length + 3) | ||
| expect(afterContractList.length).toEqual(beforeContractList.length + 3) | ||
| expect(afterListenerList.length).toEqual(beforeListenerList.length + 3) | ||
| expect(afterReporterList.length).toEqual(beforeReporterList.length + 3) | ||
| expect(afterFunctionList.length).toEqual(beforeFunctionList.length + 3) | ||
| }) | ||
| }) |
Oops, something went wrong.