polkadot-js/api

// Copyright 2017-2024 @polkadot/rpc-core authors & contributors
// SPDX-License-Identifier: Apache-2.0

/// <reference types="@polkadot/dev-test/globals.d.ts" />

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: { blah: DefinitionRpc; bleh: 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);
      });
    });
  });
});