Merge branch 'main' of github.com:elastic/kibana into knowledge-by-de…

…fault

.buildkite/pipelines/quality-gates/pipeline.kibana-tests.yaml

@@ -26,7 +26,7 @@ steps:
       QG_PIPELINE_LOCATION: ".buildkite/pipelines/quality-gates"
     command: "make -C /agent run-environment-tests" # will trigger https://buildkite.com/elastic/kibana-tests
     agents:
-      image: "docker.elastic.co/ci-agent-images/quality-gate-seedling:0.0.2"
+      image: "docker.elastic.co/ci-agent-images/quality-gate-seedling:0.0.4"
 
 notify:
   - slack: "${TEAM_CHANNEL?}"

x-pack/plugins/canvas/canvas_plugin_src/renderers/embeddable/embeddable.tsx

@@ -14,14 +14,11 @@ import {
   isErrorEmbeddable,
   ReactEmbeddableRenderer,
 } from '@kbn/embeddable-plugin/public';
-import { PresentationContainer } from '@kbn/presentation-containers';
-import { EmbeddableAppContext } from '@kbn/presentation-publishing';
 import { KibanaRenderContextProvider } from '@kbn/react-kibana-context-render';
-import React, { FC } from 'react';
+import React, { FC, useMemo } from 'react';
 import ReactDOM from 'react-dom';
-import useObservable from 'react-use/lib/useObservable';
 import { pluginServices } from '../../../public/services';
-import { CANVAS_APP, CANVAS_EMBEDDABLE_CLASSNAME } from '../../../common/lib';
+import { CANVAS_EMBEDDABLE_CLASSNAME } from '../../../common/lib';
 import { RendererStrings } from '../../../i18n';
 import {
   CanvasContainerApi,
@@ -32,6 +29,7 @@ import {
 import { EmbeddableExpression } from '../../expression_types/embeddable';
 import { StartDeps } from '../../plugin';
 import { embeddableInputToExpression } from './embeddable_input_to_expression';
+import { useGetAppContext } from './use_get_app_context';
 
 const { embeddable: strings } = RendererStrings;
 
@@ -55,52 +53,51 @@ const renderReactEmbeddable = ({
   handlers: RendererHandlers;
   core: CoreStart;
 }) => {
+  // wrap in functional component to allow usage of hooks
+  const RendererWrapper: FC<{ canvasApi: CanvasContainerApi }> = ({ canvasApi }) => {
+    const getAppContext = useGetAppContext(core);
+
+    useMemo(() => {
+      canvasApi.getAppContext = getAppContext;
+    }, [canvasApi, getAppContext]);
+
+    return (
+      <ReactEmbeddableRenderer
+        type={type}
+        maybeId={uuid}
+        parentApi={canvasApi}
+        key={`${type}_${uuid}`}
+        state={{ rawState: input }}
+        onAnyStateChange={(newState) => {
+          const newExpression = embeddableInputToExpression(
+            newState.rawState as unknown as EmbeddableInput,
+            type,
+            undefined,
+            true
+          );
+          if (newExpression) handlers.onEmbeddableInputChange(newExpression);
+        }}
+      />
+    );
+  };
+
   return (
     <KibanaRenderContextProvider {...core}>
       <div
         className={CANVAS_EMBEDDABLE_CLASSNAME}
         style={{ width: '100%', height: '100%', cursor: 'auto' }}
       >
-        <ReactEmbeddableRenderer
-          type={type}
-          maybeId={uuid}
-          parentApi={container as unknown as PresentationContainer}
-          key={`${type}_${uuid}`}
-          state={{ rawState: input }}
-          onAnyStateChange={(newState) => {
-            const newExpression = embeddableInputToExpression(
-              newState.rawState as unknown as EmbeddableInput,
-              type,
-              undefined,
-              true
-            );
-            if (newExpression) handlers.onEmbeddableInputChange(newExpression);
-          }}
-        />
+        <RendererWrapper canvasApi={container} />
       </div>
     </KibanaRenderContextProvider>
   );
 };
 
 const renderEmbeddableFactory = (core: CoreStart, _plugins: StartDeps) => {
   const EmbeddableRenderer: FC<{ embeddable: IEmbeddable }> = ({ embeddable }) => {
-    const currentAppId = useObservable(core.application.currentAppId$, undefined);
-
-    if (!currentAppId) {
-      return null;
-    }
-
-    const canvasAppContext: EmbeddableAppContext = {
-      getCurrentPath: () => {
-        const urlToApp = core.application.getUrlForApp(currentAppId);
-        const inAppPath = window.location.pathname.replace(urlToApp, '');
-
-        return inAppPath + window.location.search + window.location.hash;
-      },
-      currentAppId: CANVAS_APP,
-    };
+    const getAppContext = useGetAppContext(core);
 
-    embeddable.getAppContext = () => canvasAppContext;
+    embeddable.getAppContext = getAppContext;
 
     return <EmbeddablePanel embeddable={embeddable} />;
   };

x-pack/plugins/canvas/canvas_plugin_src/renderers/embeddable/use_get_app_context.tsx

@@ -0,0 +1,27 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the Elastic License
+ * 2.0; you may not use this file except in compliance with the Elastic License
+ * 2.0.
+ */
+
+import { useMemo } from 'react';
+import type { CoreStart } from '@kbn/core/public';
+import useObservable from 'react-use/lib/useObservable';
+import { CANVAS_APP } from '../../../common/lib';
+
+export function useGetAppContext(core: CoreStart) {
+  const currentAppId = useObservable(core.application.currentAppId$, undefined);
+  const getAppContext = useMemo(() => {
+    return () => ({
+      getCurrentPath: () => {
+        const urlToApp = core.application.getUrlForApp(currentAppId ?? CANVAS_APP);
+        const inAppPath = window.location.pathname.replace(urlToApp, '');
+
+        return inAppPath + window.location.search + window.location.hash;
+      },
+      currentAppId: CANVAS_APP,
+    });
+  }, [currentAppId, core.application]);
+  return getAppContext;
+}

x-pack/plugins/canvas/types/embeddables.ts

@@ -8,7 +8,7 @@
 import type { TimeRange } from '@kbn/es-query';
 import { Filter } from '@kbn/es-query';
 import { EmbeddableInput as Input } from '@kbn/embeddable-plugin/common';
-import { PublishesViewMode } from '@kbn/presentation-publishing';
+import { HasAppContext, PublishesViewMode } from '@kbn/presentation-publishing';
 import { CanAddNewPanel } from '@kbn/presentation-containers';
 
 export type EmbeddableInput = Input & {
@@ -17,4 +17,4 @@ export type EmbeddableInput = Input & {
   savedObjectId?: string;
 };
 
-export type CanvasContainerApi = PublishesViewMode & CanAddNewPanel;
+export type CanvasContainerApi = PublishesViewMode & CanAddNewPanel & Partial<HasAppContext>;

x-pack/plugins/fleet/common/settings/agent_policy_settings.tsx

@@ -36,7 +36,7 @@ export const AGENT_POLICY_ADVANCED_SETTINGS: SettingsConfig[] = [
       defaultMessage: 'Limits the maximum number of CPUs that can be executing simultaneously.',
     }),
     learnMoreLink:
-      'https://www.elastic.co/guide/en/fleet/current/enable-custom-policy-settings.html#limit-cpu-usage',
+      'https://www.elastic.co/guide/en/fleet/current/agent-policy.html#agent-policy-limit-cpu',
     api_field: {
       name: 'agent_limits_go_max_procs',
     },
@@ -121,7 +121,7 @@ export const AGENT_POLICY_ADVANCED_SETTINGS: SettingsConfig[] = [
       }
     ),
     learnMoreLink:
-      'https://www.elastic.co/guide/en/fleet/current/enable-custom-policy-settings.html#override-default-monitoring-port',
+      'https://www.elastic.co/guide/en/fleet/current/agent-policy.html#agent-policy-http-monitoring',
     schema: z
       .object({
         // enabled: z.boolean().describe('Enabled').default(false),
@@ -146,6 +146,8 @@ export const AGENT_POLICY_ADVANCED_SETTINGS: SettingsConfig[] = [
     api_field: {
       name: 'agent_logging_level',
     },
+    learnMoreLink:
+      'https://www.elastic.co/guide/en/fleet/current/agent-policy.html#agent-policy-log-level',
     schema: z.nativeEnum(AGENT_LOG_LEVELS).default(DEFAULT_LOG_LEVEL),
   },
 ];

x-pack/plugins/ml/public/application/components/rule_editor/rule_editor_flyout.js

@@ -337,12 +337,13 @@ class RuleEditorFlyoutUI extends Component {
 
   updateRuleAtIndex = (ruleIndex, editedRule) => {
     const { toasts } = this.props.kibana.services.notifications;
+    const { mlApiServices, mlJobService } = this.props.kibana.services.mlServices;
     const { job, anomaly } = this.state;
 
     const jobId = job.job_id;
     const detectorIndex = anomaly.detectorIndex;
 
-    saveJobRule(job, detectorIndex, ruleIndex, editedRule)
+    saveJobRule(job, detectorIndex, ruleIndex, editedRule, mlApiServices, mlJobService)
       .then((resp) => {
         if (resp.success) {
           toasts.add({
@@ -391,11 +392,12 @@ class RuleEditorFlyoutUI extends Component {
 
   deleteRuleAtIndex = (index) => {
     const { toasts } = this.props.kibana.services.notifications;
+    const { mlApiServices, mlJobService: jobService } = this.props.kibana.services.mlServices;
     const { job, anomaly } = this.state;
     const jobId = job.job_id;
     const detectorIndex = anomaly.detectorIndex;
 
-    deleteJobRule(job, detectorIndex, index)
+    deleteJobRule(job, detectorIndex, index, mlApiServices, jobService)
       .then((resp) => {
         if (resp.success) {
           toasts.addSuccess(
@@ -443,7 +445,8 @@ class RuleEditorFlyoutUI extends Component {
 
   addItemToFilterList = (item, filterId, closeFlyoutOnAdd) => {
     const { toasts } = this.props.kibana.services.notifications;
-    addItemToFilter(item, filterId)
+    const { mlApiServices } = this.props.kibana.services.mlServices;
+    addItemToFilter(item, filterId, mlApiServices)
       .then(() => {
         if (closeFlyoutOnAdd === true) {
           toasts.add({

x-pack/plugins/ml/public/application/components/rule_editor/utils.js

@@ -15,8 +15,7 @@ import {
   ML_DETECTOR_RULE_OPERATOR,
 } from '@kbn/ml-anomaly-utils';
 
-import { ml } from '../../services/ml_api_service';
-import { mlJobService } from '../../services/job_service';
+import { mlJobService as importedMlJobService } from '../../services/job_service';
 import { processCreatedBy } from '../../../../common/util/job_utils';
 
 export function getNewConditionDefaults() {
@@ -70,8 +69,16 @@ export function isValidRule(rule) {
   return isValid;
 }
 
-export function saveJobRule(job, detectorIndex, ruleIndex, editedRule) {
+export function saveJobRule(
+  job,
+  detectorIndex,
+  ruleIndex,
+  editedRule,
+  mlApiServices,
+  mlJobService
+) {
   const detector = job.analysis_config.detectors[detectorIndex];
+  const jobService = mlJobService || importedMlJobService;
 
   // Filter out any scope expression where the UI=specific 'enabled'
   // property is set to false.
@@ -103,16 +110,17 @@ export function saveJobRule(job, detectorIndex, ruleIndex, editedRule) {
     }
   }
 
-  return updateJobRules(job, detectorIndex, rules);
+  return updateJobRules(job, detectorIndex, rules, mlApiServices, jobService);
 }
 
-export function deleteJobRule(job, detectorIndex, ruleIndex) {
+export function deleteJobRule(job, detectorIndex, ruleIndex, mlApiServices, mlJobService) {
+  const jobService = mlJobService || importedMlJobService;
   const detector = job.analysis_config.detectors[detectorIndex];
   let customRules = [];
   if (detector.custom_rules !== undefined && ruleIndex < detector.custom_rules.length) {
     customRules = cloneDeep(detector.custom_rules);
     customRules.splice(ruleIndex, 1);
-    return updateJobRules(job, detectorIndex, customRules);
+    return updateJobRules(job, detectorIndex, customRules, mlApiServices, jobService);
   } else {
     return Promise.reject(
       new Error(
@@ -128,7 +136,7 @@ export function deleteJobRule(job, detectorIndex, ruleIndex) {
   }
 }
 
-export function updateJobRules(job, detectorIndex, rules) {
+export function updateJobRules(job, detectorIndex, rules, mlApiServices, mlJobService) {
   // Pass just the detector with the edited rule to the updateJob endpoint.
   const jobId = job.job_id;
   const jobData = {
@@ -146,9 +154,9 @@ export function updateJobRules(job, detectorIndex, rules) {
     processCreatedBy(customSettings);
     jobData.custom_settings = customSettings;
   }
-
   return new Promise((resolve, reject) => {
-    ml.updateJob({ jobId: jobId, job: jobData })
+    mlApiServices
+      .updateJob({ jobId: jobId, job: jobData })
       .then(() => {
         // Refresh the job data in the job service before resolving.
         mlJobService
@@ -168,9 +176,9 @@ export function updateJobRules(job, detectorIndex, rules) {
 
 // Updates an ML filter used in the scope part of a rule,
 // adding an item to the filter with the specified ID.
-export function addItemToFilter(item, filterId) {
+export function addItemToFilter(item, filterId, mlApiServices) {
   return new Promise((resolve, reject) => {
-    ml.filters
+    mlApiServices.filters
       .updateFilter(filterId, undefined, [item], undefined)
       .then((updatedFilter) => {
         resolve(updatedFilter);

x-pack/test/security_solution_api_integration/test_suites/detections_response/detection_engine/rule_execution_logic/trial_license_complete_tier/execution_logic/index.ts

@@ -16,11 +16,11 @@ export default ({ loadTestFile }: FtrProviderContext): void => {
     loadTestFile(require.resolve('./new_terms'));
     loadTestFile(require.resolve('./new_terms_alert_suppression'));
     loadTestFile(require.resolve('./saved_query'));
-    loadTestFile(require.resolve('./threat_match'));
-    loadTestFile(require.resolve('./threat_match_alert_suppression'));
+    loadTestFile(require.resolve('./indicator_match'));
+    loadTestFile(require.resolve('./indicator_match_alert_suppression'));
     loadTestFile(require.resolve('./threshold'));
     loadTestFile(require.resolve('./threshold_alert_suppression'));
     loadTestFile(require.resolve('./non_ecs_fields'));
-    loadTestFile(require.resolve('./query'));
+    loadTestFile(require.resolve('./custom_query'));
   });
 };