[Ingest Manager] Agent bulk actions UI

x-pack/plugins/ingest_manager/common/constants/routes.ts

@@ -84,7 +84,9 @@ export const AGENT_API_ROUTES = {
   ACTIONS_PATTERN: `${FLEET_API_ROOT}/agents/{agentId}/actions`,
   ENROLL_PATTERN: `${FLEET_API_ROOT}/agents/enroll`,
   UNENROLL_PATTERN: `${FLEET_API_ROOT}/agents/{agentId}/unenroll`,
+  BULK_UNENROLL_PATTERN: `${FLEET_API_ROOT}/agents/bulk_unenroll`,
   REASSIGN_PATTERN: `${FLEET_API_ROOT}/agents/{agentId}/reassign`,
+  BULK_REASSIGN_PATTERN: `${FLEET_API_ROOT}/agents/bulk_reassign`,
   STATUS_PATTERN: `${FLEET_API_ROOT}/agent-status`,
 };
 

x-pack/plugins/ingest_manager/common/services/index.ts

@@ -12,3 +12,4 @@ export { isPackageLimited, doesAgentPolicyAlreadyIncludePackage } from './limite
 export { decodeCloudId } from './decode_cloud_id';
 export { isValidNamespace } from './is_valid_namespace';
 export { isDiffPathProtocol } from './is_diff_path_protocol';
+export { LicenseService } from './license';

x-pack/plugins/ingest_manager/common/services/license.ts

@@ -0,0 +1,46 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the Elastic License;
+ * you may not use this file except in compliance with the Elastic License.
+ */
+import { Observable, Subscription } from 'rxjs';
+import { ILicense } from '../../../licensing/common/types';
+
+// Generic license service class that works with the license observable
+// Both server and client plugins instancates a singleton version of this class
+export class LicenseService {
+  private observable: Observable<ILicense> | null = null;
+  private subscription: Subscription | null = null;
+  private licenseInformation: ILicense | null = null;
+
+  private updateInformation(licenseInformation: ILicense) {
+    this.licenseInformation = licenseInformation;
+  }
+
+  public start(license$: Observable<ILicense>) {
+    this.observable = license$;
+    this.subscription = this.observable.subscribe(this.updateInformation.bind(this));
+  }
+
+  public stop() {
+    if (this.subscription) {
+      this.subscription.unsubscribe();
+    }
+  }
+
+  public getLicenseInformation() {
+    return this.licenseInformation;
+  }
+
+  public getLicenseInformation$() {
+    return this.observable;
+  }
+
+  public isGoldPlus() {
+    return (
+      this.licenseInformation?.isAvailable &&
+      this.licenseInformation?.isActive &&
+      this.licenseInformation?.hasAtLeast('gold')
+    );
+  }
+}

x-pack/plugins/ingest_manager/common/services/routes.ts

@@ -127,8 +127,10 @@ export const agentRouteService = {
   getEventsPath: (agentId: string) => AGENT_API_ROUTES.EVENTS_PATTERN.replace('{agentId}', agentId),
   getUnenrollPath: (agentId: string) =>
     AGENT_API_ROUTES.UNENROLL_PATTERN.replace('{agentId}', agentId),
+  getBulkUnenrollPath: () => AGENT_API_ROUTES.BULK_UNENROLL_PATTERN,
   getReassignPath: (agentId: string) =>
     AGENT_API_ROUTES.REASSIGN_PATTERN.replace('{agentId}', agentId),
+  getBulkReassignPath: () => AGENT_API_ROUTES.BULK_REASSIGN_PATTERN,
   getListPath: () => AGENT_API_ROUTES.LIST_PATTERN,
   getStatusPath: () => AGENT_API_ROUTES.STATUS_PATTERN,
 };

x-pack/plugins/ingest_manager/common/types/rest_spec/agent.ts

@@ -26,6 +26,7 @@ export interface GetAgentsRequest {
 export interface GetAgentsResponse {
   list: Agent[];
   total: number;
+  totalInactive: number;
   page: number;
   perPage: number;
 }
@@ -104,11 +105,24 @@ export interface PostAgentUnenrollRequest {
   params: {
     agentId: string;
   };
+  body: {
+    force?: boolean;
+  };
 }
 
 // eslint-disable-next-line @typescript-eslint/no-empty-interface
 export interface PostAgentUnenrollResponse {}
 
+export interface PostBulkAgentUnenrollRequest {
+  body: {
+    agents: string[] | string;
+    force?: boolean;
+  };
+}
+
+// eslint-disable-next-line @typescript-eslint/no-empty-interface
+export interface PostBulkAgentUnenrollResponse {}
+
 export interface PutAgentReassignRequest {
   params: {
     agentId: string;
@@ -119,6 +133,20 @@ export interface PutAgentReassignRequest {
 // eslint-disable-next-line @typescript-eslint/no-empty-interface
 export interface PutAgentReassignResponse {}
 
+export interface PostBulkAgentReassignRequest {
+  body: {
+    policy_id: string;
+    agents: string[] | string;
+  };
+}
+
+export interface PostBulkAgentReassignResponse {
+  [key: string]: {
+    success: boolean;
+    error?: Error;
+  };
+}
+
 export interface GetOneAgentEventsRequest {
   params: {
     agentId: string;

x-pack/plugins/ingest_manager/public/applications/ingest_manager/hooks/index.ts

@@ -8,6 +8,7 @@ export { useCapabilities } from './use_capabilities';
 export { useCore } from './use_core';
 export { useConfig, ConfigContext } from './use_config';
 export { useSetupDeps, useStartDeps, DepsContext } from './use_deps';
+export { licenseService, useLicense } from './use_license';
 export { useBreadcrumbs } from './use_breadcrumbs';
 export { useLink } from './use_link';
 export { useKibanaLink } from './use_kibana_link';

x-pack/plugins/ingest_manager/public/applications/ingest_manager/hooks/use_license.ts

@@ -0,0 +1,12 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the Elastic License;
+ * you may not use this file except in compliance with the Elastic License.
+ */
+import { LicenseService } from '../services';
+
+export const licenseService = new LicenseService();
+
+export function useLicense() {
+  return licenseService;
+}

x-pack/plugins/ingest_manager/public/applications/ingest_manager/hooks/use_request/agents.ts

@@ -10,8 +10,14 @@ import {
   GetOneAgentResponse,
   GetOneAgentEventsResponse,
   GetOneAgentEventsRequest,
+  PostAgentUnenrollRequest,
+  PostBulkAgentUnenrollRequest,
+  PostBulkAgentUnenrollResponse,
+  PostAgentUnenrollResponse,
   PutAgentReassignRequest,
   PutAgentReassignResponse,
+  PostBulkAgentReassignRequest,
+  PostBulkAgentReassignResponse,
   GetAgentsRequest,
   GetAgentsResponse,
   GetAgentStatusRequest,
@@ -83,3 +89,40 @@ export function sendPutAgentReassign(
     ...options,
   });
 }
+
+export function sendPostBulkAgentReassign(
+  body: PostBulkAgentReassignRequest['body'],
+  options?: RequestOptions
+) {
+  return sendRequest<PostBulkAgentReassignResponse>({
+    method: 'post',
+    path: agentRouteService.getBulkReassignPath(),
+    body,
+    ...options,
+  });
+}
+
+export function sendPostAgentUnenroll(
+  agentId: string,
+  body: PostAgentUnenrollRequest['body'],
+  options?: RequestOptions
+) {
+  return sendRequest<PostAgentUnenrollResponse>({
+    path: agentRouteService.getUnenrollPath(agentId),
+    method: 'post',
+    body,
+    ...options,
+  });
+}
+
+export function sendPostBulkAgentUnenroll(
+  body: PostBulkAgentUnenrollRequest['body'],
+  options?: RequestOptions
+) {
+  return sendRequest<PostBulkAgentUnenrollResponse>({
+    path: agentRouteService.getBulkUnenrollPath(),
+    method: 'post',
+    body,
+    ...options,
+  });
+}

x-pack/plugins/ingest_manager/public/applications/ingest_manager/index.tsx

@@ -22,9 +22,16 @@ import { PAGE_ROUTING_PATHS } from './constants';
 import { DefaultLayout, WithoutHeaderLayout } from './layouts';
 import { Loading, Error } from './components';
 import { IngestManagerOverview, EPMApp, AgentPolicyApp, FleetApp, DataStreamApp } from './sections';
-import { DepsContext, ConfigContext, useConfig } from './hooks';
+import {
+  DepsContext,
+  ConfigContext,
+  useConfig,
+  useCore,
+  sendSetup,
+  sendGetPermissionsCheck,
+  licenseService,
+} from './hooks';
 import { PackageInstallProvider } from './sections/epm/hooks';
-import { useCore, sendSetup, sendGetPermissionsCheck } from './hooks';
 import { FleetStatusProvider } from './hooks/use_fleet_status';
 import './index.scss';
 import { KibanaContextProvider } from '../../../../../../src/plugins/kibana_react/public';
@@ -279,4 +286,5 @@ export function renderApp(
 export const teardownIngestManager = (coreStart: CoreStart) => {
   coreStart.chrome.docTitle.reset();
   coreStart.chrome.setBreadcrumbs([]);
+  licenseService.stop();
 };

x-pack/plugins/ingest_manager/public/applications/ingest_manager/sections/fleet/agent_details_page/components/actions_menu.tsx

@@ -9,7 +9,7 @@ import { FormattedMessage } from '@kbn/i18n/react';
 import { Agent } from '../../../../types';
 import { useCapabilities } from '../../../../hooks';
 import { ContextMenuActions } from '../../../../components';
-import { AgentUnenrollProvider, AgentReassignAgentPolicyFlyout } from '../../components';
+import { AgentUnenrollAgentModal, AgentReassignAgentPolicyFlyout } from '../../components';
 import { useAgentRefresh } from '../hooks';
 
 export const AgentDetailsActionMenu: React.FunctionComponent<{
@@ -20,6 +20,7 @@ export const AgentDetailsActionMenu: React.FunctionComponent<{
   const hasWriteCapabilites = useCapabilities().write;
   const refreshAgent = useAgentRefresh();
   const [isReassignFlyoutOpen, setIsReassignFlyoutOpen] = useState(assignFlyoutOpenByDefault);
+  const [isUnenrollModalOpen, setIsUnenrollModalOpen] = useState(false);
   const isUnenrolling = agent.status === 'unenrolling';
 
   const onClose = useMemo(() => {
@@ -34,7 +35,20 @@ export const AgentDetailsActionMenu: React.FunctionComponent<{
     <>
       {isReassignFlyoutOpen && (
         <EuiPortal>
-          <AgentReassignAgentPolicyFlyout agent={agent} onClose={onClose} />
+          <AgentReassignAgentPolicyFlyout agents={[agent]} onClose={onClose} />
+        </EuiPortal>
+      )}
+      {isUnenrollModalOpen && (
+        <EuiPortal>
+          <AgentUnenrollAgentModal
+            agents={[agent]}
+            agentCount={1}
+            onClose={() => {
+              setIsUnenrollModalOpen(false);
+              refreshAgent();
+            }}
+            useForceUnenroll={isUnenrolling}
+          />
         </EuiPortal>
       )}
       <ContextMenuActions
@@ -58,32 +72,28 @@ export const AgentDetailsActionMenu: React.FunctionComponent<{
           >
             <FormattedMessage
               id="xpack.ingestManager.agentList.reassignActionText"
-              defaultMessage="Assign new agent policy"
+              defaultMessage="Assign to new policy"
             />
           </EuiContextMenuItem>,
-          <AgentUnenrollProvider key="unenrollAgent" forceUnenroll={isUnenrolling}>
-            {(unenrollAgentsPrompt) => (
-              <EuiContextMenuItem
-                icon="cross"
-                disabled={!hasWriteCapabilites || !agent.active}
-                onClick={() => {
-                  unenrollAgentsPrompt([agent.id], 1, refreshAgent);
-                }}
-              >
-                {isUnenrolling ? (
-                  <FormattedMessage
-                    id="xpack.ingestManager.agentList.forceUnenrollOneButton"
-                    defaultMessage="Force unenroll"
-                  />
-                ) : (
-                  <FormattedMessage
-                    id="xpack.ingestManager.agentList.unenrollOneButton"
-                    defaultMessage="Unenroll"
-                  />
-                )}
-              </EuiContextMenuItem>
+          <EuiContextMenuItem
+            icon="cross"
+            disabled={!hasWriteCapabilites || !agent.active}
+            onClick={() => {
+              setIsUnenrollModalOpen(true);
+            }}
+          >
+            {isUnenrolling ? (
+              <FormattedMessage
+                id="xpack.ingestManager.agentList.forceUnenrollOneButton"
+                defaultMessage="Force unenroll"
+              />
+            ) : (
+              <FormattedMessage
+                id="xpack.ingestManager.agentList.unenrollOneButton"
+                defaultMessage="Unenroll agent"
+              />
             )}
-          </AgentUnenrollProvider>,
+          </EuiContextMenuItem>,
         ]}
       />
     </>