PHP WebShell

Текущая директория: /opt/BitGoJS/node_modules/@open-rpc/client-js/src/transports

Просмотр файла: HTTPTransport.test.ts

import { HTTPTransport, HTTPTransportOptions } from "./HTTPTransport";
import * as reqMocks from "../__mocks__/requestData";
import _fetchMock from "isomorphic-fetch";
const fetchMock = _fetchMock as jest.Mock<Promise<any>>;

describe("HTTPTransport", () => {
  it("can connect", () => {
    const httpTransport = new HTTPTransport("http://localhost:8545");
    return httpTransport.connect();
  });

  it("can close", () => {
    const httpTransport = new HTTPTransport("http://localhost:8545");
    httpTransport.close();
  });

  it("can send and retrieve request data", async () => {
    const httpTransport = new HTTPTransport(
      "http://localhost:8545/rpc-request"
    );
    const data = reqMocks.generateMockRequest(1, "foo", ["bar"]);
    const result = await httpTransport.sendData({
      request: data,
      internalID: 1,
    });
    expect(result.method).toEqual("foo");
    expect(result.params).toEqual(["bar"]);
  });

  it("can send notification data", async () => {
    const httpTransport = new HTTPTransport(
      "http://localhost:8545/rpc-notification"
    );
    const data = reqMocks.generateMockNotificationRequest("foo", ["bar"]);
    const result = await httpTransport.sendData({
      request: data,
      internalID: 1,
    });
    expect(result).toEqual(undefined);
  });

  it("should throw error on error response", async () => {
    const httpTransport = new HTTPTransport("http://localhost:8545/rpc-error");
    const data = reqMocks.generateMockRequest(9, "foo", ["bar"]);
    await expect(
      httpTransport.sendData({ request: data, internalID: 9 })
    ).rejects.toThrowError("Error message");
  });

  it("should throw error on bad data response", async () => {
    const httpTransport = new HTTPTransport(
      "http://localhost:8545/rpc-garbage"
    );
    const data = {
      request: reqMocks.generateMockRequest(9, "foo", ["bar"]),
      internalID: 9,
    };
    await expect(httpTransport.sendData(data)).rejects.toThrowError(
      "Bad response format"
    );
  });

  it("should throw error on bad data response from a batch", async (done) => {
    const httpTransport = new HTTPTransport(
      "http://localhost:8545/rpc-garbage"
    );
    const data = {
      resolve: (d: any) => ({}),
      reject: (e: Error) => {
        expect(e.message).toContain("Bad response format");
        done();
      },
      request: {
        request: reqMocks.generateMockRequest(9, "foo", ["bar"]),
        internalID: 9,
      },
    };
    await expect(httpTransport.sendData([data])).rejects.toThrow(
      "Bad response format"
    );
  });

  it("should throw error if unknown server crash", async () => {
    const httpTransport = new HTTPTransport("http://localhost:8545/crash");
    const data = {
      request: reqMocks.generateMockRequest(9, "foo", ["bar"]),
      internalID: 9,
    };
    await expect(httpTransport.sendData(data)).rejects.toThrowError(
      "Random Segfault that crashes fetch"
    );
  });

  async function callFetch(options?: HTTPTransportOptions): Promise<void> {
    const httpTransport = new HTTPTransport("http://localhost:8545", options);
    const data = reqMocks.generateMockRequest(1, "foo", ["bar"]);
    await httpTransport.sendData({ request: data, internalID: 1 });
  }

  it("sets content type to application/json", async () => {
    await callFetch({ headers: { "Content-Type": "image/png" } });
    const headers = fetchMock.mock.calls[0][1].headers;
    expect(headers.get("Content-Type")).toEqual("application/json");
  });

  it("sets header passed from options", async () => {
    const headerName = "Authorization";
    const headerValue = "Basic credentials";
    await callFetch({ headers: { [headerName]: headerValue } });
    const headers = fetchMock.mock.calls[0][1].headers;
    expect(headers.get(headerName)).toEqual(headerValue);
  });

  it("sets credentials argument passed from options", async () => {
    const credentials = "include";
    await callFetch({ credentials });
    expect(fetchMock.mock.calls[0][1].credentials).toEqual(credentials);
  });

  it("accepts an injected fetcher", async () => {
    const injectedFetchMock = _fetchMock as jest.Mock<Promise<any>>;

    const httpTransport = new HTTPTransport(
      "http://localhost:8545/rpc-notification",
      {
        fetcher: injectedFetchMock,
      }
    );
    const data = reqMocks.generateMockNotificationRequest("foo", ["bar"]);
    const result = await httpTransport.sendData({
      request: data,
      internalID: 1,
    });
    expect(injectedFetchMock.mock.calls.length).toEqual(1);
    expect(result).toEqual(undefined);
  });
});

Выполнить команду

Для локальной разработки. Не используйте в интернете!