Create edit ILM flow

x-pack/platform/packages/shared/kbn-streams-schema/src/helpers/converters.test.ts

@@ -103,6 +103,7 @@ describe('Converter Helpers', () => {
           read_failure_store: true,
           manage_failure_store: true,
           view_index_metadata: true,
+          create_snapshot_repository: true,
         },
         effective_failure_store: {
           disabled: {},
@@ -142,6 +143,7 @@ describe('Converter Helpers', () => {
           read_failure_store: true,
           manage_failure_store: true,
           view_index_metadata: true,
+          create_snapshot_repository: true,
         },
         effective_lifecycle: {
           dsl: {},

x-pack/platform/packages/shared/kbn-streams-schema/src/models/ingest/base.ts

@@ -37,6 +37,8 @@ interface IngestStreamPrivileges {
   read_failure_store: boolean;
   // User can manage failure store information
   manage_failure_store: boolean;
+  // User can create snapshot repositories (needed for frozen phase searchable snapshots)
+  create_snapshot_repository: boolean;
 }
 
 const ingestStreamPrivilegesSchema: z.Schema<IngestStreamPrivileges> = z.object({
@@ -48,6 +50,7 @@ const ingestStreamPrivilegesSchema: z.Schema<IngestStreamPrivileges> = z.object(
   text_structure: z.boolean(),
   read_failure_store: z.boolean(),
   manage_failure_store: z.boolean(),
+  create_snapshot_repository: z.boolean(),
 });
 
 export interface IngestBase {

x-pack/platform/packages/shared/kbn-streams-schema/src/models/ingest/classic.test.ts

@@ -120,6 +120,7 @@ describe('ClassicStream', () => {
           text_structure: true,
           read_failure_store: true,
           manage_failure_store: true,
+          create_snapshot_repository: true,
           view_index_metadata: true,
         },
         data_stream_exists: true,
@@ -157,6 +158,7 @@ describe('ClassicStream', () => {
           text_structure: true,
           failure_store: true,
           view_index_metadata: true,
+          create_snapshot_repository: true,
         },
         data_stream_exists: true,
         dashboards: [],

x-pack/platform/packages/shared/kbn-streams-schema/src/models/ingest/wired.test.ts

@@ -119,6 +119,7 @@ describe('WiredStream', () => {
           read_failure_store: true,
           manage_failure_store: true,
           view_index_metadata: true,
+          create_snapshot_repository: true,
         },
         effective_lifecycle: {
           dsl: {},
@@ -165,6 +166,7 @@ describe('WiredStream', () => {
           text_structure: true,
           failure_store: true,
           view_index_metadata: true,
+          create_snapshot_repository: true,
         },
         dashboards: [],
         queries: [],

x-pack/platform/plugins/shared/streams/server/lib/streams/client.ts

@@ -540,6 +540,8 @@ export class StreamsClient {
       REQUIRED_MANAGE_PRIVILEGES.push('monitor_text_structure');
     }
 
+    const CREATE_SNAPSHOT_REPOSITORY_CLUSTER_PRIVILEGE = 'cluster:admin/repository/put';
+
     const REQUIRED_INDEX_PRIVILEGES = [
       'read',
       'write',
@@ -557,7 +559,7 @@ export class StreamsClient {
 
     const privileges =
       await this.dependencies.scopedClusterClient.asCurrentUser.security.hasPrivileges({
-        cluster: REQUIRED_MANAGE_PRIVILEGES,
+        cluster: [...REQUIRED_MANAGE_PRIVILEGES, CREATE_SNAPSHOT_REPOSITORY_CLUSTER_PRIVILEGE],
         index: [
           {
             names,
@@ -588,6 +590,8 @@ export class StreamsClient {
       text_structure: isServerless ? true : privileges.cluster.monitor_text_structure,
       read_failure_store: names.every((name) => privileges.index[name].read_failure_store),
       manage_failure_store: names.every((name) => privileges.index[name].manage_failure_store),
+      create_snapshot_repository:
+        privileges.cluster[CREATE_SNAPSHOT_REPOSITORY_CLUSTER_PRIVILEGE] === true,
     };
   }
 

x-pack/platform/plugins/shared/streams/server/routes/internal/streams/lifecycle/route.ts

@@ -223,9 +223,39 @@ const lifecycleIlmPoliciesUpdateRoute = createServerRoute({
   },
 });
 
+const lifecycleSnapshotRepositoriesRoute = createServerRoute({
+  endpoint: 'GET /internal/streams/lifecycle/_snapshot_repositories',
+  options: {
+    access: 'internal',
+  },
+  security: {
+    authz: {
+      requiredPrivileges: [STREAMS_API_PRIVILEGES.read],
+    },
+  },
+  params: z.object({}),
+  handler: async ({
+    request,
+    getScopedClients,
+  }): Promise<{ repositories: Array<{ name: string; type: string }> }> => {
+    const { scopedClusterClient } = await getScopedClients({ request });
+    const repositoriesByName = await scopedClusterClient.asCurrentUser.snapshot.getRepository({
+      name: '*',
+    });
+
+    const repositories = Object.entries(repositoriesByName).map(([name, { type }]) => ({
+      name,
+      type: type ?? '',
+    }));
+
+    return { repositories };
+  },
+});
+
 export const internalLifecycleRoutes = {
   ...lifecycleStatsRoute,
   ...lifecycleIlmExplainRoute,
   ...lifecycleIlmPoliciesRoute,
   ...lifecycleIlmPoliciesUpdateRoute,
+  ...lifecycleSnapshotRepositoriesRoute,
 };

x-pack/platform/plugins/shared/streams_app/public/components/data_management/schema_editor/utils.test.ts

@@ -99,6 +99,7 @@ const privileges = {
   text_structure: true,
   read_failure_store: true,
   manage_failure_store: true,
+  create_snapshot_repository: true,
 };
 
 const buildWiredDefinition = (): Streams.WiredStream.GetResponse => ({

x-pack/platform/plugins/shared/streams_app/public/components/data_management/shared/mocks/stream_definitions.ts

@@ -39,6 +39,7 @@ export const createMockClassicStreamDefinition = (
     read_failure_store: true,
     manage_failure_store: true,
     view_index_metadata: true,
+    create_snapshot_repository: true,
   },
   data_stream_exists: true,
   effective_lifecycle: { dsl: {} },
@@ -81,6 +82,7 @@ export const createMockWiredStreamDefinition = (
     read_failure_store: true,
     manage_failure_store: true,
     view_index_metadata: true,
+    create_snapshot_repository: true,
   },
   inherited_fields: {
     'attributes.inherited_field': {

x-pack/platform/plugins/shared/streams_app/public/components/data_management/stream_detail_enrichment/utils.test.ts

@@ -218,6 +218,7 @@ describe('utils', () => {
       text_structure: true,
       read_failure_store: true,
       manage_failure_store: true,
+      create_snapshot_repository: true,
     });
 
     const createWiredDefinition = (): Streams.WiredStream.GetResponse => ({

x-pack/platform/plugins/shared/streams_app/public/components/data_management/stream_detail_lifecycle/common/data_lifecycle/data_lifecycle_summary.test.tsx

@@ -11,10 +11,16 @@ import { DataLifecycleSummary } from './data_lifecycle_summary';
 import { type LifecyclePhase } from './lifecycle_types';
 
 describe('DataLifecycleSummary', () => {
+  const defaultProps = {
+    model: {
+      phases: [],
+    },
+    capabilities: { canManageLifecycle: true },
+    showDownsampling: true,
+  };
   describe('Loading State', () => {
     it('should show skeleton when data is being fetched', () => {
-      const phases: LifecyclePhase[] = [];
-      render(<DataLifecycleSummary phases={phases} loading={true} canManageLifecycle />);
+      render(<DataLifecycleSummary {...defaultProps} model={{ loading: true, phases: [] }} />);
 
       expect(screen.getByTestId('dataLifecycleSummary-title')).toBeInTheDocument();
       expect(screen.getByTestId('dataLifecycleSummary-skeleton')).toBeInTheDocument();
@@ -23,8 +29,7 @@ describe('DataLifecycleSummary', () => {
 
   describe('Empty State', () => {
     it('should render title with no phases when phases array is empty', () => {
-      const phases: LifecyclePhase[] = [];
-      render(<DataLifecycleSummary phases={phases} canManageLifecycle />);
+      render(<DataLifecycleSummary {...defaultProps} />);
 
       expect(screen.getByTestId('dataLifecycleSummary-title')).toBeInTheDocument();
       expect(screen.queryByTestId('dataLifecycleSummary-skeleton')).not.toBeInTheDocument();
@@ -62,7 +67,7 @@ describe('DataLifecycleSummary', () => {
         },
       ];
 
-      render(<DataLifecycleSummary phases={phases} canManageLifecycle />);
+      render(<DataLifecycleSummary {...defaultProps} model={{ phases }} />);
 
       expect(screen.getByText('0d')).toBeInTheDocument();
       expect(screen.getByTestId('lifecyclePhase-hot-name')).toBeInTheDocument();
@@ -93,7 +98,7 @@ describe('DataLifecycleSummary', () => {
         },
       ];
 
-      render(<DataLifecycleSummary phases={phases} canManageLifecycle />);
+      render(<DataLifecycleSummary {...defaultProps} model={{ phases }} />);
 
       expect(screen.getByText('0s')).toBeInTheDocument();
     });
@@ -119,7 +124,7 @@ describe('DataLifecycleSummary', () => {
         },
       ];
 
-      render(<DataLifecycleSummary phases={phases} canManageLifecycle />);
+      render(<DataLifecycleSummary {...defaultProps} model={{ phases }} />);
 
       expect(screen.getByTestId('lifecyclePhase-Main phase-name')).toBeInTheDocument();
       expect(screen.getByTestId('lifecyclePhase-Main phase-size')).toHaveTextContent('2.0 GB');
@@ -139,7 +144,7 @@ describe('DataLifecycleSummary', () => {
         },
       ];
 
-      render(<DataLifecycleSummary phases={phases} canManageLifecycle />);
+      render(<DataLifecycleSummary {...defaultProps} model={{ phases }} />);
 
       expect(screen.getByTestId('lifecyclePhase-Main phase-name')).toBeInTheDocument();
       expect(screen.queryByTestId('dataLifecycle-delete-icon')).not.toBeInTheDocument();
@@ -156,7 +161,7 @@ describe('DataLifecycleSummary', () => {
         },
       ];
 
-      render(<DataLifecycleSummary phases={phases} canManageLifecycle />);
+      render(<DataLifecycleSummary {...defaultProps} model={{ phases }} />);
 
       expect(screen.getByText('∞')).toBeInTheDocument();
     });
@@ -179,7 +184,7 @@ describe('DataLifecycleSummary', () => {
         },
       ];
 
-      render(<DataLifecycleSummary phases={phases} canManageLifecycle />);
+      render(<DataLifecycleSummary {...defaultProps} model={{ phases }} />);
 
       expect(screen.getByTestId('downsamplingPhase-1h-label')).toBeInTheDocument();
       expect(screen.getByTestId('downsamplingPhase-1h-interval')).toHaveTextContent('1h');
@@ -208,16 +213,14 @@ describe('DataLifecycleSummary', () => {
         },
       ];
 
-      render(<DataLifecycleSummary phases={phases} canManageLifecycle />);
+      render(<DataLifecycleSummary {...defaultProps} model={{ phases }} />);
 
       expect(screen.getByTestId('downsamplingPhase-1h-label')).toBeInTheDocument();
       expect(screen.getByTestId('downsamplingPhase-1h-interval')).toHaveTextContent('1h');
       expect(screen.queryByTestId('downsamplingPhase-delete-label')).not.toBeInTheDocument();
     });
-  });
 
-  describe('DSL Downsampling', () => {
-    it('should render multiple downsampling steps in a single bar for DSL', () => {
+    it('should not render downsampling bar when show downsampling is false', () => {
       const phases: LifecyclePhase[] = [
         {
           color: '#FF0000',
@@ -235,12 +238,38 @@ describe('DataLifecycleSummary', () => {
 
       render(
         <DataLifecycleSummary
-          phases={phases}
-          downsampleSteps={downsampleSteps}
-          canManageLifecycle
+          {...defaultProps}
+          model={{ phases, downsampleSteps }}
+          showDownsampling={false}
         />
       );
 
+      expect(screen.queryByTestId('downsamplingBar-label')).not.toBeInTheDocument();
+      expect(screen.queryByTestId('downsamplingPhase-1d-label')).not.toBeInTheDocument();
+      expect(screen.queryByText('20d')).not.toBeInTheDocument();
+      expect(screen.queryByText('40d')).not.toBeInTheDocument();
+    });
+  });
+
+  describe('DSL Downsampling', () => {
+    it('should render multiple downsampling steps in a single bar for DSL', () => {
+      const phases: LifecyclePhase[] = [
+        {
+          color: '#FF0000',
+          name: 'hot',
+          label: 'hot',
+          size: '1.0 MB',
+          grow: true,
+        },
+      ];
+
+      const downsampleSteps = [
+        { fixed_interval: '1d', after: '20d' },
+        { fixed_interval: '5d', after: '40d' },
+      ];
+
+      render(<DataLifecycleSummary {...defaultProps} model={{ phases, downsampleSteps }} />);
+
       expect(screen.getByTestId('downsamplingPhase-1d-label')).toBeInTheDocument();
       expect(screen.getByTestId('downsamplingPhase-1d-interval')).toHaveTextContent('1d');
       expect(screen.getByTestId('downsamplingPhase-5d-label')).toBeInTheDocument();
@@ -261,7 +290,7 @@ describe('DataLifecycleSummary', () => {
         },
       ];
 
-      render(<DataLifecycleSummary phases={phases} canManageLifecycle />);
+      render(<DataLifecycleSummary {...defaultProps} model={{ phases }} />);
 
       expect(screen.queryByTestId('downsamplingPhase-1d-label')).not.toBeInTheDocument();
     });
@@ -290,11 +319,10 @@ describe('DataLifecycleSummary', () => {
 
       render(
         <DataLifecycleSummary
-          phases={phases}
-          isIlm
-          onRemovePhase={jest.fn()}
-          onRemoveDownsampleStep={jest.fn()}
-          canManageLifecycle
+          {...defaultProps}
+          model={{ phases }}
+          phaseActions={{ onRemovePhase: jest.fn() }}
+          downsamplingActions={{ onRemoveDownsampleStep: jest.fn() }}
         />
       );
 
@@ -308,4 +336,55 @@ describe('DataLifecycleSummary', () => {
       expect(screen.getByTestId('lifecyclePhase-warm-removeButton')).toBeInTheDocument();
     });
   });
+
+  describe('Edit flyout open behavior', () => {
+    it('should navigate to phase when edit flyout is open (no popover)', () => {
+      const onEditPhase = jest.fn();
+      const phases: LifecyclePhase[] = [
+        { grow: 5, name: 'hot', label: 'hot', color: '#FF0000', min_age: '0d' },
+        { grow: 3, name: 'warm', label: 'warm', color: '#FFA500', min_age: '30d' },
+      ];
+
+      render(
+        <DataLifecycleSummary
+          {...defaultProps}
+          model={{ phases }}
+          phaseActions={{ onEditPhase }}
+          uiState={{ isEditLifecycleFlyoutOpen: true }}
+        />
+      );
+
+      fireEvent.click(screen.getByTestId('lifecyclePhase-warm-button'));
+
+      expect(onEditPhase).toHaveBeenCalledWith(phases[1].label);
+      expect(screen.queryByTestId('lifecyclePhase-warm-popoverTitle')).not.toBeInTheDocument();
+    });
+
+    it('should navigate to downsampling step when edit flyout is open (no popover)', () => {
+      const onEditDownsampleStep = jest.fn();
+      const phases: LifecyclePhase[] = [
+        {
+          color: '#FF0000',
+          name: 'hot',
+          label: 'hot',
+          grow: 5,
+          downsample: { after: '0d', fixed_interval: '1h' },
+        },
+      ];
+
+      render(
+        <DataLifecycleSummary
+          {...defaultProps}
+          model={{ phases }}
+          downsamplingActions={{ onEditDownsampleStep }}
+          uiState={{ isEditLifecycleFlyoutOpen: true }}
+        />
+      );
+
+      fireEvent.click(screen.getByTestId('downsamplingPhase-1h-label'));
+
+      expect(onEditDownsampleStep).toHaveBeenCalledWith(1, 'hot');
+      expect(screen.queryByTestId('downsamplingPopover-step1-title')).not.toBeInTheDocument();
+    });
+  });
 });