Function processSuccessfulApiCall

packages/airnode-node/src/api/index.ts:214–295

(
  payload: ApiCallPayload,
  rawResponse: PerformApiCallSuccess
)

}

export async function processSuccessfulApiCall(
  payload: ApiCallPayload,
  rawResponse: PerformApiCallSuccess
): Promise<LogsData<ApiCallResponse>> {
  const { type, config, aggregatedApiCall } = payload;
  const { endpointName, oisTitle, parameters } = aggregatedApiCall;
  const ois = config.ois.find((o) => o.title === oisTitle)!;
  const endpoint = ois.endpoints.find((e) => e.name === endpointName)!;
  // _minConfirmations is handled prior to the API call
  const { _type, _path, _times, _gasPrice } = getReservedParameters(endpoint, parameters);

  const goPostProcessApiSpecifications = await go(() =>
    postProcessResponse(rawResponse.data, endpoint, aggregatedApiCall.parameters, {
      totalTimeoutMs: PROCESSING_TIMEOUT,
    })
  );
  if (!goPostProcessApiSpecifications.success) {
    const log = logger.pend('ERROR', goPostProcessApiSpecifications.error.message);
    return [[log], { success: false, errorMessage: goPostProcessApiSpecifications.error.message }];
  }
  const postProcessedData = goPostProcessApiSpecifications.data;

  const goExtractAndEncodeResponse = goSync(() =>
    adapter.extractAndEncodeResponse(postProcessedData.response, {
      _type,
      _path,
      _times,
    } as adapter.ResponseReservedParameters)
  );
  if (!goExtractAndEncodeResponse.success) {
    const log = logger.pend('ERROR', goExtractAndEncodeResponse.error.message);
    // The HTTP gateway is a special case for ChainAPI where we return data from a successful API call that failed processing
    if (type === 'http-gateway') {
      return [
        [log],
        { success: true, errorMessage: goExtractAndEncodeResponse.error.message, data: { rawValue: rawResponse.data } },
      ];
    }
    return [[log], { success: false, errorMessage: goExtractAndEncodeResponse.error.message }];
  }

  const response = goExtractAndEncodeResponse.data;

  switch (type) {
    case 'http-gateway':
      return [[], { success: true, data: response }];
    case 'regular': {
      const goSignWithRequestId = await go(() => signWithRequestId(aggregatedApiCall.id, response.encodedValue));
      if (!goSignWithRequestId.success) {
        const log = logger.pend('ERROR', goSignWithRequestId.error.message);
        return [[log], { success: false, errorMessage: goSignWithRequestId.error.message }];
      }

      return [
        [],
        {
          success: true,
          data: { encodedValue: response.encodedValue, signature: goSignWithRequestId.data },