Function callApi

packages/airnode-node/src/api/index.ts:297–326

(payload: ApiCallPayload)

}

export async function callApi(payload: ApiCallPayload): Promise<LogsData<ApiCallResponse>> {
  const verificationResult = verifyCallApi(payload);
  if (verificationResult) return verificationResult;

  const {
    aggregatedApiCall: { parameters },
  } = payload;
  const ois = payload.config.ois.find((o) => o.title === payload.aggregatedApiCall.oisTitle)!;
  const endpoint = ois.endpoints.find((e) => e.name === payload.aggregatedApiCall.endpointName)!;
  const { endpointParameters: processedEndpointParameters } = await preProcessEndpointParameters(endpoint, parameters, {
    totalTimeoutMs: PROCESSING_TIMEOUT,
  });

  // Skip API call if operation is undefined and fixedOperationParameters is empty array. We can be sure that there is
  // at least one processing specification defined (either v1 or v2) because it is verified by the OIS schema.
  if (!endpoint.operation && isEmpty(endpoint.fixedOperationParameters)) {
    // The pre-processing output can be used as output directly or it can be used to manipulate parameters to use in
    // post-processing.
    return processSuccessfulApiCall(payload, { data: processedEndpointParameters });
  }

  const [logs, response] = await performApiCall({
    ...payload,
    aggregatedApiCall: { ...payload.aggregatedApiCall, parameters: processedEndpointParameters },
  } as ApiCallPayload);
  if (isPerformApiCallFailure(response)) {
    return [logs, response];
  }
  return processSuccessfulApiCall(payload, response);
}