From 5a1f004fb100a8add5f5eff80ddf6e169ec17844 Mon Sep 17 00:00:00 2001 From: Artur Wierzbicki Date: Wed, 21 Sep 2022 13:09:16 +0200 Subject: [PATCH] Live: Fix live streaming with `live-service-web-worker` feature flag enabled (#55528) --- public/app/features/live/centrifuge/service.ts | 4 ++-- public/app/features/live/index.ts | 2 ++ 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/public/app/features/live/centrifuge/service.ts b/public/app/features/live/centrifuge/service.ts index c6414d4425da..044db5eff2d5 100644 --- a/public/app/features/live/centrifuge/service.ts +++ b/public/app/features/live/centrifuge/service.ts @@ -18,7 +18,6 @@ import { StreamingFrameOptions, } from '@grafana/runtime/src/services/live'; import { BackendDataSourceResponse } from '@grafana/runtime/src/utils/queryResponse'; -import { loadUrlToken } from 'app/core/utils/urlToken'; import { StreamingResponseData } from '../data/utils'; @@ -26,6 +25,7 @@ import { LiveDataStream } from './LiveDataStream'; import { CentrifugeLiveChannel } from './channel'; export type CentrifugeSrvDeps = { + grafanaAuthToken: string | null; appUrl: string; orgId: number; orgRole: string; @@ -70,7 +70,7 @@ export class CentrifugeService implements CentrifugeSrv { let liveUrl = `${deps.appUrl.replace(/^http/, 'ws')}/api/live/ws`; - const token = loadUrlToken(); + const token = deps.grafanaAuthToken; if (token !== null && token !== '') { liveUrl += '?auth_token=' + token; } diff --git a/public/app/features/live/index.ts b/public/app/features/live/index.ts index b1ae4baca8f9..6e6ec4977521 100644 --- a/public/app/features/live/index.ts +++ b/public/app/features/live/index.ts @@ -2,6 +2,7 @@ import { config, getBackendSrv, getGrafanaLiveSrv, setGrafanaLiveSrv } from '@gr import { liveTimer } from 'app/features/dashboard/dashgrid/liveTimer'; import { contextSrv } from '../../core/services/context_srv'; +import { loadUrlToken } from '../../core/utils/urlToken'; import { CentrifugeService } from './centrifuge/service'; import { CentrifugeServiceWorkerProxy } from './centrifuge/serviceWorkerProxy'; @@ -22,6 +23,7 @@ export function initGrafanaLive() { liveEnabled: config.liveEnabled, sessionId, dataStreamSubscriberReadiness: liveTimer.ok.asObservable(), + grafanaAuthToken: loadUrlToken(), }; const centrifugeSrv = config.featureToggles['live-service-web-worker']