Jaco
9fe2798b70
* Use .js imports in src * Adjust * Fix imports * Bump dev * Adjust with .js imports for typegen * Adjust * Adjust * Remove target override
76 lines
2.6 KiB
TypeScript
76 lines
2.6 KiB
TypeScript
// Copyright 2017-2023 @polkadot/rpc-core authors & contributors
|
|
// SPDX-License-Identifier: Apache-2.0
|
|
|
|
/// <reference types="@polkadot/dev/node/test/node" />
|
|
|
|
import type { ProviderInterface } from '@polkadot/rpc-provider/types';
|
|
import type { DefinitionRpc } from '@polkadot/types/types';
|
|
|
|
import { TypeRegistry } from '@polkadot/types/create';
|
|
|
|
import { RpcCore } from './index.js';
|
|
|
|
describe('methodSend', (): void => {
|
|
const registry = new TypeRegistry();
|
|
let rpc: RpcCore;
|
|
let methods: Record<string, DefinitionRpc>;
|
|
let provider: ProviderInterface;
|
|
|
|
beforeEach((): void => {
|
|
methods = {
|
|
blah: {
|
|
description: 'test',
|
|
params: [
|
|
{ name: 'foo', type: 'Bytes' }
|
|
],
|
|
type: 'Bytes'
|
|
},
|
|
bleh: {
|
|
description: 'test',
|
|
params: [],
|
|
type: 'Bytes'
|
|
}
|
|
};
|
|
|
|
provider = {
|
|
send: jest.fn((method: string, params: unknown[]): Promise<unknown> =>
|
|
Promise.resolve(params[0])
|
|
)
|
|
} as unknown as ProviderInterface;
|
|
|
|
rpc = new RpcCore('987', registry, provider);
|
|
});
|
|
|
|
it('checks for mismatched parameters', async (): Promise<void> => {
|
|
// private method
|
|
// eslint-disable-next-line @typescript-eslint/no-unsafe-assignment,@typescript-eslint/no-unsafe-call,@typescript-eslint/no-unsafe-member-access
|
|
const method = (rpc as any)._createMethodSend('test', 'bleh', methods.bleh);
|
|
|
|
await new Promise<boolean>((resolve) => {
|
|
// eslint-disable-next-line @typescript-eslint/no-unsafe-call,@typescript-eslint/no-unsafe-member-access
|
|
method(1).subscribe(
|
|
(): void => undefined,
|
|
(error: Error): void => {
|
|
expect(error.message).toMatch(/parameters, 1 found instead/);
|
|
resolve(true);
|
|
});
|
|
});
|
|
});
|
|
|
|
it('calls the provider with the correct parameters', async (): Promise<void> => {
|
|
// private method
|
|
// eslint-disable-next-line @typescript-eslint/no-unsafe-assignment,@typescript-eslint/no-unsafe-call,@typescript-eslint/no-unsafe-member-access
|
|
const method = (rpc as any)._createMethodSend('test', 'blah', methods.blah);
|
|
|
|
await new Promise<boolean>((resolve) => {
|
|
// Args are length-prefixed, because it's a Bytes
|
|
// eslint-disable-next-line @typescript-eslint/no-unsafe-call,@typescript-eslint/no-unsafe-member-access
|
|
method(new Uint8Array([2 << 2, 0x12, 0x34])).subscribe((): void => {
|
|
// eslint-disable-next-line @typescript-eslint/no-unsafe-member-access
|
|
expect(provider.send).toHaveBeenCalledWith('test_blah', ['0x1234'], false);
|
|
resolve(true);
|
|
});
|
|
});
|
|
});
|
|
});
|