Function runDataRequest

server/sources/shared/protocols/api.protocol.js:235–558

({
  connection,
  dataRequest,
  chartId,
  getCache,
  filters = [],
  timezone = "",
  variables = {},
  auditContext = null,
})

}

async function runDataRequest({
  connection,
  dataRequest,
  chartId,
  getCache,
  filters = [],
  timezone = "",
  variables = {},
  auditContext = null,
}) {
  if (getCache) {
    const drCache = await checkAndGetCache(connection.id, dataRequest);
    if (drCache) {
      await completeConnectorAudit(auditContext, {
        cacheHit: true,
        connectionType: "api",
        ...serializeResponsePreview(drCache.responseData),
      });
      return drCache;
    }
  }

  const limit = dataRequest.itemsLimit
    ? parseInt(dataRequest.itemsLimit, 10) : 0;
  const { variables: requestVariables } = dataRequest;
  const savedConnection = await getSavedConnection(connection);
  const policyContext = buildApiPolicyContext("api_request_run", savedConnection);

  try {
    let processedRoute = dataRequest.route || "";
    let processedHeaders = dataRequest.headers || {};
    let processedBody = dataRequest.body || "";

    const result = applyApiVariables(dataRequest, variables);
    processedRoute = result.processedRoute || processedRoute;
    processedHeaders = result.processedHeaders || processedHeaders;
    processedBody = result.processedBody || processedBody;

    let tempUrl = savedConnection.getApiUrl(savedConnection);
    let route = processedRoute;
    if (route && (route[0] !== "/" && route[0] !== "?")) {
      route = `/${route}`;
    }

    tempUrl += route;

    const queryParams = querystring.parse(tempUrl.split("?")[1]);

    if (queryParams && Object.keys(queryParams).length > 0) {
      if (dataRequest.VariableBindings && dataRequest.VariableBindings.length > 0) {
        for (const q of Object.keys(queryParams)) {
          const paramValue = queryParams[q];
          if (typeof paramValue === "string") {
            let processedValue = paramValue;
            const variableMatches = [...paramValue.matchAll(/\{\{([^}]+)\}\}/g)];

            for (const match of variableMatches) {
              const variableName = match[1].trim();