[8.x] 🌊 Enable streams in the UI for serverless observability (#215533) (#218009)

# Backport This will backport the following commits from `main` to `8.x`: - [🌊 Enable streams in the UI for serverless observability (#215533)](https://github.com/elastic/kibana/pull/215533)  ### Questions ? Please refer to the [Backport tool documentation](https://github.com/sorenlouv/backport)  Co-authored-by: Joe Reuter <johannes.reuter@elastic.co>
2025-04-24 01:38:56 -04:00 · 2025-04-11 20:44:21 +02:00 · 2025-04-11 20:44:21 +02:00 · c6e3428a6d
commit c6e3428a6d
parent df83efc556
3 changed files with 68 additions and 27 deletions
--- a/x-pack/platform/plugins/shared/streams/public/plugin.ts
+++ b/x-pack/platform/plugins/shared/streams/public/plugin.ts
@ -9,10 +9,17 @@ import { CoreSetup, CoreStart, PluginInitializerContext } from '@kbn/core/public
 import { Logger } from '@kbn/logging';

 import { createRepositoryClient } from '@kbn/server-route-repository-client';
-import { from, shareReplay, startWith } from 'rxjs';
+import { Observable, from, shareReplay, startWith } from 'rxjs';
 import { once } from 'lodash';
 import type { StreamsPublicConfig } from '../common/config';
-import { StreamsPluginClass, StreamsPluginSetup, StreamsPluginStart } from './types';
+import {
+  StreamsPluginClass,
+  StreamsPluginSetup,
+  StreamsPluginSetupDependencies,
+  StreamsPluginStart,
+  StreamsPluginStartDependencies,
+  StreamsStatus,
+} from './types';
 import { StreamsRepositoryClient } from './api';

 export class Plugin implements StreamsPluginClass {
@ -26,37 +33,52 @@ export class Plugin implements StreamsPluginClass {
    this.logger = context.logger.get();
  }

-  setup(core: CoreSetup<{}>, pluginSetup: {}): StreamsPluginSetup {
+  setup(core: CoreSetup, pluginSetup: StreamsPluginSetupDependencies): StreamsPluginSetup {
    this.repositoryClient = createRepositoryClient(core);
    return {
-      status$: createStatusObservable(this.logger, this.repositoryClient),
+      status$: createStreamsStatusObservable(pluginSetup, this.repositoryClient, this.logger),
    };
  }

-  start(core: CoreStart, pluginsStart: {}): StreamsPluginStart {
+  start(core: CoreStart, pluginsStart: StreamsPluginStartDependencies): StreamsPluginStart {
    return {
      streamsRepositoryClient: this.repositoryClient,
-      status$: createStatusObservable(this.logger, this.repositoryClient),
+      status$: createStreamsStatusObservable(pluginsStart, this.repositoryClient, this.logger),
    };
  }

  stop() {}
 }

-const createStatusObservable = once((logger: Logger, repositoryClient: StreamsRepositoryClient) => {
-  return from(
-    repositoryClient
-      .fetch('GET /api/streams/_status', {
-        signal: new AbortController().signal,
-      })
-      .then(
-        (response) => ({
-          status: response.enabled ? ('enabled' as const) : ('disabled' as const),
-        }),
-        (error) => {
-          logger.error(error);
-          return { status: 'unknown' as const };
-        }
-      )
-  ).pipe(startWith({ status: 'unknown' as const }), shareReplay(1));
-});
+const ENABLED_STATUS: StreamsStatus = { status: 'enabled' };
+const DISABLED_STATUS: StreamsStatus = { status: 'disabled' };
+const UNKNOWN_STATUS: StreamsStatus = { status: 'unknown' };
+
+const createStreamsStatusObservable = once(
+  (
+    deps: StreamsPluginSetupDependencies | StreamsPluginStartDependencies,
+    repositoryClient: StreamsRepositoryClient,
+    logger: Logger
+  ): Observable<StreamsStatus> => {
+    const isObservabilityServerless =
+      deps.cloud?.isServerlessEnabled && deps.cloud?.serverless.projectType === 'observability';
+
+    if (isObservabilityServerless) {
+      return from([ENABLED_STATUS]);
+    }
+
+    return from(
+      repositoryClient
+        .fetch('GET /api/streams/_status', {
+          signal: new AbortController().signal,
+        })
+        .then(
+          (response) => (response.enabled ? ENABLED_STATUS : DISABLED_STATUS),
+          (error) => {
+            logger.error(error);
+            return UNKNOWN_STATUS;
+          }
+        )
+    ).pipe(startWith(UNKNOWN_STATUS), shareReplay(1));
+  }
+);
--- a/x-pack/platform/plugins/shared/streams/public/types.ts
+++ b/x-pack/platform/plugins/shared/streams/public/types.ts
@ -7,15 +7,33 @@

 import type { Plugin as PluginClass } from '@kbn/core/public';
 import { Observable } from 'rxjs';
+import { CloudSetup, CloudStart } from '@kbn/cloud-plugin/public';
 import type { StreamsRepositoryClient } from './api';

+export interface StreamsStatus {
+  status: 'unknown' | 'enabled' | 'disabled';
+}
+
 export interface StreamsPluginSetup {
-  status$: Observable<{ status: 'unknown' | 'enabled' | 'disabled' }>;
+  status$: Observable<StreamsStatus>;
 }

 export interface StreamsPluginStart {
  streamsRepositoryClient: StreamsRepositoryClient;
-  status$: Observable<{ status: 'unknown' | 'enabled' | 'disabled' }>;
+  status$: Observable<StreamsStatus>;
 }

-export type StreamsPluginClass = PluginClass<StreamsPluginSetup, StreamsPluginStart, {}, {}>;
+export interface StreamsPluginSetupDependencies {
+  cloud?: CloudSetup;
+}
+
+export interface StreamsPluginStartDependencies {
+  cloud?: CloudStart;
+}
+
+export type StreamsPluginClass = PluginClass<
+  StreamsPluginSetup,
+  StreamsPluginStart,
+  StreamsPluginSetupDependencies,
+  StreamsPluginStartDependencies
+>;
--- a/x-pack/platform/plugins/shared/streams/tsconfig.json
+++ b/x-pack/platform/plugins/shared/streams/tsconfig.json
@ -43,6 +43,7 @@
    "@kbn/utils",
    "@kbn/core-saved-objects-server-internal",
    "@kbn/core-analytics-server",
-    "@kbn/es-types",
+    "@kbn/cloud-plugin",
+    "@kbn/es-types"
  ]
 }