/**
 * Copyright (c) Facebook, Inc. and its affiliates.
 *
 * This source code is licensed under the MIT license found in the
 * LICENSE file in the root directory of this source tree.
 *
 * @flow
 * @format
 */

// flowlint ambiguous-object-type:error

'use strict';

const areEqual = require('areEqual');
const invariant = require('invariant');
const warning = require('warning');

const {
  createOperationDescriptor,
  isRelayModernEnvironment,
  Network,
} = require('relay-runtime');

import type {
  CacheConfig,
  ConcreteRequest,
  GraphQLSingularResponse,
  IEnvironment,
  PayloadError,
  RequestParameters,
  Variables,
} from 'relay-runtime';

export type DataWriteConfig = {
  query: ConcreteRequest,
  variables: Variables,
  payload: GraphQLSingularResponse,
  ...
};

export type NetworkWriteConfig = {
  query: ConcreteRequest,
  variables?: Variables,
  payload: GraphQLSingularResponse | (Variables => GraphQLSingularResponse),
  ...
};

type PendingFetch = {
  request: RequestParameters,
  variables?: Variables,
  cacheConfig: ?CacheConfig,
  ident: string,
  deferred: {
    resolve: Function,
    reject: Function,
    ...
  },
  ...
};

/**
 * The next id to return from `generateId()`.
 */
let nextId = 0;

class ReactRelayTestMocker {
  _environment: IEnvironment;
  _defaults: {[string]: $PropertyType<NetworkWriteConfig, 'payload'>, ...} = {};
  _pendingFetches: Array<PendingFetch> = [];

  constructor(env: IEnvironment) {
    if (isRelayModernEnvironment(env)) {
      this._mockNetworkLayer(env);
    } else {
      warning(
        false,
        'Network mocking is currently only supported in Relay Modern. ' +
          'You will not be able to resolve requests made with Relay ' +
          'Classic environments.',
      );
    }
    this._environment = env;
  }

  static mockOutEnvironment(env: IEnvironment): ReactRelayTestMocker {
    return new ReactRelayTestMocker(env);
  }

  /**
   * Get a unique id number (as a string). Note: will wrap around after 2^32
   * calls, if your test needs that many IDs.
   *
   * @returns a unique id string
   */
  static generateId(): string {
    const toRet = nextId.toString();
    nextId++;

    return toRet;
  }

  /**
   * Create a unique identifier for a (query, variables) pair.
   * @param request: the request associated with the query
   * @param variables: the variables associated with this invocation of the
   * query
   *
   * @returns a string which can later be used to uniquely identify this query
   * in the list of pending queries
   */
  static getIdentifier(request: RequestParameters): string {
    return request.name;
  }

  /**
   * Remove variables that we don't need from the query that will make it more
   * annoying to test (e.g. client_mutation_id, actor_id)
   */
  static stripUnused(variables: Variables): Variables {
    if (variables.input) {
      const toRemove = [
        'client_mutation_id',
        'actor_id',
        'clientMutationId',
        'actorId',
      ];
      const strippedVariables = {...variables, input: {...variables.input}};
      toRemove.forEach(item => (strippedVariables.input[item] = undefined));
      return strippedVariables;
    }

    return variables;
  }

  /**
   * Replace the environment's network layer with a mocked out one to allow for
   * better testing. Mocking the network allows testing without using a mocked
   * out QueryRenderer, and will allow for easier testing of components wrapped
   * in refetch containers, for example. It also allows test writers to see how
   * their components behave under error conditions.
   */
  _mockNetworkLayer(env: IEnvironment): IEnvironment {
    const fetch = (request, variables, cacheConfig) => {
      let resolve;
      let reject;
      const promise = new Promise((res, rej) => {
        resolve = res;
        reject = rej;
      });

      const strippedVars = ReactRelayTestMocker.stripUnused(variables);
      const ident = ReactRelayTestMocker.getIdentifier(request);

      // there's a default value for this query, use it
      if (this._defaults[ident]) {
        const payload = this._defaults[ident];
        return typeof payload === 'function' ? payload(strippedVars) : payload;
      }

      this._pendingFetches.push({
        ident,
        cacheConfig,
        deferred: {resolve, reject},
        request,
        variables: strippedVars,
      });
      return promise;
    };

    const isLoading = (ident: string): boolean => {
      return this._pendingFetches.some(pending => pending.ident === ident);
    };

    const resolveRawQuery = (
      toResolve: PendingFetch,
      payload: GraphQLSingularResponse,
    ): void => {
      this._pendingFetches = this._pendingFetches.filter(
        pending => pending !== toResolve,
      );

      const {deferred} = toResolve;
      deferred.resolve(payload);
    };

    const rejectQuery = (
      toResolve: PendingFetch,
      payload: {error: PayloadError, ...},
    ): void => {
      this._pendingFetches = this._pendingFetches.filter(
        pending => pending !== toResolve,
      );

      const {deferred} = toResolve;
      deferred.reject(payload.error);
    };

    (env: any).mock = {
      isLoading,
      rejectQuery,
      resolveRawQuery,
      fetch,
    };

    (env: any).hasMockedNetwork = true;

    (env: any).__setNet(Network.create(fetch));
    return env;
  }

  /**
   * set a default payload for a given query
   */
  setDefault(toSet: NetworkWriteConfig): void {
    const {query, payload} = toSet;
    const ident = ReactRelayTestMocker.getIdentifier(query.params);

    this._defaults[ident] = payload;
  }

  /**
   * remove a default payload for a given query
   */
  unsetDefault(toUnset: NetworkWriteConfig): void {
    const {query} = toUnset;
    const ident = ReactRelayTestMocker.getIdentifier(query.params);

    delete this._defaults[ident];
  }

  /**
   * Write directly to the Relay store instead of trying to resolve a query that
   * was sent via the network.
   *
   * Use this method when testing a component wrapped in a fragment container
   * (via `createFragmentContainer`). The component under test should also be
   * wrapped in a `RelayTestRenderer`.
   */
  dataWrite(config: DataWriteConfig): void {
    const {query, variables, payload} = config;

    const operationDescriptor = createOperationDescriptor(query, variables);

    invariant(
      payload.data != null && payload.errors === undefined,
      'Only `data` can be written when using `writeDirect`. You may need to ' +
        'wrap your payload in an object like `{data: payload}`.',
    );

    this._environment.commitPayload(operationDescriptor, payload.data);
  }

  /**
   * Write the data specified in config's payload to the instance's environment.
   * NOTE: callers may need to invoke `jest.runOnlyPendingTimers()` after
   * calling this function.
   *
   * @param config: an object containing the data to write and the query and
   * variables that the payload is simulating a response to
   */
  networkWrite(config: NetworkWriteConfig): void {
    invariant(
      (this._environment: any).hasMockedNetwork,
      'You cannot resolve queries without a mocked environment. Did you mean ' +
        'to use `writeDirect` instead?',
    );
    const {query, variables, payload} = config;

    const ident = ReactRelayTestMocker.getIdentifier(query.params);

    let usedVars;

    if (variables) {
      const operationDescriptor = createOperationDescriptor(query, variables);
      usedVars = ReactRelayTestMocker.stripUnused(
        operationDescriptor.request.variables,
      );
    }

    let toResolve;
    this._pendingFetches.forEach(pending => {
      const pendingVars = pending.variables;
      if (pending.ident === ident) {
        invariant(
          !toResolve || variables,
          'Multiple queries with the same name are currently pending. You ' +
            'should pass variables to `write` so that it can determine which ' +
            'to resolve',
        );
        if (variables) {
          if (areEqual(pendingVars, usedVars)) {
            toResolve = pending;
          }
        } else {
          toResolve = pending;
        }
      }
    });

    const varMessage = usedVars
      ? ' - variables: ' + JSON.stringify(usedVars)
      : '';

    invariant(
      toResolve,
      'You are attempting to resolve a query that has not been fetched ' +
        '(%s%s).\n\tPlease ensure you passed the correct variables, or use ' +
        '`writeDirect` instead.',
      ident,
      varMessage,
    );

    const realPayload =
      typeof payload === 'function' ? payload(toResolve.variables) : payload;

    // if there are errors, reject the query
    if (realPayload.errors != null && realPayload.errors.length > 0) {
      (this._environment: any).mock.rejectQuery(toResolve, {
        error: realPayload.errors[0],
      });
    } else {
      (this._environment: any).mock.resolveRawQuery(toResolve, realPayload);
    }
  }
}

module.exports = ReactRelayTestMocker;