{"version":3,"file":"publicDashboardQueryHandler.cjs","sources":["../../../src/utils/publicDashboardQueryHandler.ts"],"sourcesContent":["import { catchError, type Observable, of, switchMap } from 'rxjs';\n\nimport { type DataQuery, type DataQueryRequest, type DataQueryResponse } from '@grafana/data';\n\nimport { config } from '../config';\nimport { getBackendSrv } from '../services/backendSrv';\n\nimport { type BackendDataSourceResponse, toDataQueryResponse } from './queryResponse';\n\nexport function publicDashboardQueryHandler(request: DataQueryRequest<DataQuery>): Observable<DataQueryResponse> {\n  const {\n    intervalMs,\n    maxDataPoints,\n    requestId,\n    panelId,\n    queryCachingTTL,\n    range: { from: fromRange, to: toRange },\n  } = request;\n  // Return early if no queries exist\n  if (!request.targets.length) {\n    return of({ data: [] });\n  }\n\n  if (panelId == null || Number.isNaN(panelId)) {\n    return of({ data: [] });\n  }\n\n  const body = {\n    intervalMs,\n    maxDataPoints,\n    queryCachingTTL,\n    timeRange: {\n      from: fromRange.valueOf().toString(),\n      to: toRange.valueOf().toString(),\n      timezone: request.timezone,\n    },\n  };\n\n  return getBackendSrv()\n    .fetch<BackendDataSourceResponse>({\n      url: `/api/public/dashboards/${config.publicDashboardAccessToken!}/panels/${panelId}/query`,\n      method: 'POST',\n      data: body,\n      requestId,\n    })\n    .pipe(\n      switchMap((raw) => {\n        return of(toDataQueryResponse(raw, request.targets));\n      }),\n      catchError((err) => {\n        return of(toDataQueryResponse(err));\n      })\n    );\n}\n"],"names":["of","getBackendSrv","config","switchMap","toDataQueryResponse","catchError"],"mappings":";;;;;;;;;;AASO,SAAS,4BAA4B,OAAA,EAAqE;AAC/G,EAAA,MAAM;AAAA,IACJ,UAAA;AAAA,IACA,aAAA;AAAA,IACA,SAAA;AAAA,IACA,OAAA;AAAA,IACA,eAAA;AAAA,IACA,KAAA,EAAO,EAAE,IAAA,EAAM,SAAA,EAAW,IAAI,OAAA;AAAQ,GACxC,GAAI,OAAA;AAEJ,EAAA,IAAI,CAAC,OAAA,CAAQ,OAAA,CAAQ,MAAA,EAAQ;AAC3B,IAAA,OAAOA,OAAA,CAAG,EAAE,IAAA,EAAM,IAAI,CAAA;AAAA,EACxB;AAEA,EAAA,IAAI,OAAA,IAAW,IAAA,IAAQ,MAAA,CAAO,KAAA,CAAM,OAAO,CAAA,EAAG;AAC5C,IAAA,OAAOA,OAAA,CAAG,EAAE,IAAA,EAAM,IAAI,CAAA;AAAA,EACxB;AAEA,EAAA,MAAM,IAAA,GAAO;AAAA,IACX,UAAA;AAAA,IACA,aAAA;AAAA,IACA,eAAA;AAAA,IACA,SAAA,EAAW;AAAA,MACT,IAAA,EAAM,SAAA,CAAU,OAAA,EAAQ,CAAE,QAAA,EAAS;AAAA,MACnC,EAAA,EAAI,OAAA,CAAQ,OAAA,EAAQ,CAAE,QAAA,EAAS;AAAA,MAC/B,UAAU,OAAA,CAAQ;AAAA;AACpB,GACF;AAEA,EAAA,OAAOC,wBAAA,GACJ,KAAA,CAAiC;AAAA,IAChC,GAAA,EAAK,CAAA,uBAAA,EAA0BC,aAAA,CAAO,0BAA2B,WAAW,OAAO,CAAA,MAAA,CAAA;AAAA,IACnF,MAAA,EAAQ,MAAA;AAAA,IACR,IAAA,EAAM,IAAA;AAAA,IACN;AAAA,GACD,CAAA,CACA,IAAA;AAAA,IACCC,cAAA,CAAU,CAAC,GAAA,KAAQ;AACjB,MAAA,OAAOH,OAAA,CAAGI,iCAAA,CAAoB,GAAA,EAAK,OAAA,CAAQ,OAAO,CAAC,CAAA;AAAA,IACrD,CAAC,CAAA;AAAA,IACDC,eAAA,CAAW,CAAC,GAAA,KAAQ;AAClB,MAAA,OAAOL,OAAA,CAAGI,iCAAA,CAAoB,GAAG,CAAC,CAAA;AAAA,IACpC,CAAC;AAAA,GACH;AACJ;;;;"}