Class HttpStore

packages/metro-cache/src/stores/HttpStore.js:78–410

const NULL_BYTE_BUFFER = Buffer.from([NULL_BYTE]);

export default class HttpStore<T> {
  static HttpError: typeof HttpError = HttpError;
  static NetworkError: typeof NetworkError = NetworkError;

  #getEndpoint: Endpoint;
  #setEndpoint: Endpoint;

  constructor(options: Options) {
    this.#getEndpoint = this.#createEndpointConfig(
      options.getOptions != null ? options.getOptions : options,
    );
    this.#setEndpoint = this.#createEndpointConfig(
      options.setOptions != null ? options.setOptions : options,
    );
  }

  #createEndpointConfig(options: EndpointOptions): Endpoint {
    const agentConfig: http$agentOptions & HttpsProxyAgentOptions = {
      family: options.family,
      keepAlive: true,
      keepAliveMsecs: options.timeout || 5000,
      maxFreeSockets: 64,
      maxSockets: 64,
    };

    if (options.key != null) {
      // $FlowFixMe[incompatible-use] `key` is missing in the Flow definition
      agentConfig.key = options.key;
    }

    if (options.cert != null) {
      // $FlowFixMe[incompatible-use] `cert` is missing in the Flow definition
      agentConfig.cert = options.cert;
    }

    if (options.ca != null) {
      // $FlowFixMe[incompatible-use] `ca` is missing in the Flow definition
      agentConfig.ca = options.ca;
    }

    if (options.socketPath != null) {
      // $FlowFixMe[incompatible-use] `socketPath` is missing in the Flow definition
      agentConfig.socketPath = options.socketPath;
    }

    const uri = new URL(options.endpoint);
    const module = uri.protocol === 'http:' ? http : https;

    const agent =
      options.proxy != null
        ? new HttpsProxyAgent(options.proxy, agentConfig)
        : new module.Agent(agentConfig);

    if (!uri.hostname || !uri.pathname) {
      throw new TypeError('Invalid endpoint: ' + options.endpoint);
    }

    return {