Skip to content

Commit

Permalink
Merge branch 'main' into cspm/graph-label-popover
Browse files Browse the repository at this point in the history
  • Loading branch information
kfirpeled authored Dec 19, 2024
2 parents 31b29f4 + 5df5e4f commit d555510
Show file tree
Hide file tree
Showing 12 changed files with 1,046 additions and 565 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@ import { encode, decode } from '@kbn/cbor';
import { elasticsearchServiceMock, loggingSystemMock } from '@kbn/core/server/mocks';
import { ContentStream, ContentStreamEncoding, ContentStreamParameters } from './content_stream';
import type { GetResponse } from '@elastic/elasticsearch/lib/api/types';
import * as estypes from '@elastic/elasticsearch/lib/api/typesWithBodyKey';
import * as estypes from '@elastic/elasticsearch/lib/api/types';
import { FileDocument } from '../../../../file_client/file_metadata_client/adapters/es_index';
import { IndexRequest } from '@elastic/elasticsearch/lib/api/types';

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@ import { ByteSizeValue } from '@kbn/config-schema';
import { defaults } from 'lodash';
import { Duplex, Writable, Readable } from 'stream';

import { GetResponse } from '@elastic/elasticsearch/lib/api/typesWithBodyKey';
import { GetResponse } from '@elastic/elasticsearch/lib/api/types';
import { inspect } from 'util';
import { wrapErrorAndReThrow } from '../../../../file_client/utils';
import type { FileChunkDocument } from '../mappings';
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7,10 +7,7 @@
* License v3.0 only", or the "Server Side Public License, v 1".
*/

import type {
MappingTypeMapping,
MappingProperty,
} from '@elastic/elasticsearch/lib/api/typesWithBodyKey';
import type { MappingTypeMapping, MappingProperty } from '@elastic/elasticsearch/lib/api/types';

/**
* These are the fields we expect to find a given document acting as a file chunk.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@ import { MockedLogger } from '@kbn/logging-mocks';
import { createEsFileClient } from './create_es_file_client';
import { FileClient } from './types';
import { ElasticsearchBlobStorageClient } from '../blob_storage_service';
import * as estypes from '@elastic/elasticsearch/lib/api/typesWithBodyKey';
import * as estypes from '@elastic/elasticsearch/lib/api/types';
import { FileDocument } from './file_metadata_client/adapters/es_index';

describe('When initializing file client via createESFileClient()', () => {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -14,6 +14,7 @@ import {
EuiFlexGroup,
EuiFlexItem,
EUI_MODAL_CONFIRM_BUTTON,
EuiSpacer,
} from '@elastic/eui';

import type { DeleteAction } from './use_delete_action';
Expand Down Expand Up @@ -79,16 +80,22 @@ export const DeleteActionModal: FC<DeleteAction> = ({
</EuiFlexItem>
<EuiFlexItem>
{userCanDeleteIndex && dataViewExists && (
<EuiSwitch
data-test-subj="mlAnalyticsJobDeleteDataViewSwitch"
label={i18n.translate('xpack.ml.dataframe.analyticsList.deleteTargetDataViewTitle', {
defaultMessage: 'Delete data view {dataView}',
values: { dataView: indexName },
})}
checked={deleteDataView}
onChange={toggleDeleteDataView}
disabled={userCanDeleteDataView === false}
/>
<>
<EuiSpacer size="s" />
<EuiSwitch
data-test-subj="mlAnalyticsJobDeleteDataViewSwitch"
label={i18n.translate(
'xpack.ml.dataframe.analyticsList.deleteTargetDataViewTitle',
{
defaultMessage: 'Delete data view {dataView}',
values: { dataView: indexName },
}
)}
checked={deleteDataView}
onChange={toggleDeleteDataView}
disabled={userCanDeleteDataView === false}
/>
</>
)}
</EuiFlexItem>
</EuiFlexGroup>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -281,7 +281,18 @@ export function AnalyticsIdSelector({
</EuiFlyoutHeader>
<EuiFlyoutBody data-test-subj={'mlJobSelectorFlyoutBody'}>{renderTabs()}</EuiFlyoutBody>
<EuiFlyoutFooter>
<EuiFlexGroup>
<EuiFlexGroup justifyContent="spaceBetween">
<EuiFlexItem grow={false}>
<EuiButtonEmpty
iconType="cross"
onClick={closeFlyout}
data-test-subj="mlFlyoutAnalyticsSelectorButtonClose"
>
{i18n.translate('xpack.ml.analyticsSelector.closeFlyoutButton', {
defaultMessage: 'Close',
})}
</EuiButtonEmpty>
</EuiFlexItem>
<EuiFlexItem grow={false}>
<EuiButton
onClick={applySelection}
Expand All @@ -295,17 +306,6 @@ export function AnalyticsIdSelector({
/>
</EuiButton>
</EuiFlexItem>
<EuiFlexItem grow={false}>
<EuiButtonEmpty
iconType="cross"
onClick={closeFlyout}
data-test-subj="mlFlyoutAnalyticsSelectorButtonClose"
>
{i18n.translate('xpack.ml.analyticsSelector.closeFlyoutButton', {
defaultMessage: 'Close',
})}
</EuiButtonEmpty>
</EuiFlexItem>
</EuiFlexGroup>
</EuiFlyoutFooter>
</EuiFlyout>
Expand Down
12 changes: 6 additions & 6 deletions x-pack/plugins/reporting/server/lib/store/store.test.ts
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
* 2.0; you may not use this file except in compliance with the Elastic License
* 2.0.
*/
import * as estypes from '@elastic/elasticsearch/lib/api/typesWithBodyKey';
import * as estypes from '@elastic/elasticsearch/lib/api/types';
import { elasticsearchServiceMock, loggingSystemMock } from '@kbn/core/server/mocks';
import { JOB_STATUS } from '@kbn/reporting-common';
import { ReportDocument } from '@kbn/reporting-common/types';
Expand Down Expand Up @@ -212,7 +212,7 @@ describe('ReportingStore', () => {

const [[updateCall]] = mockEsClient.update.mock.calls;

const response = (updateCall as estypes.UpdateRequest).body?.doc as Report;
const response = (updateCall as estypes.UpdateRequest)?.doc as Report;
expect(response.migration_version).toBe(`7.14.0`);
expect(response.status).toBe(`processing`);
expect(updateCall.if_seq_no).toBe(42);
Expand Down Expand Up @@ -242,7 +242,7 @@ describe('ReportingStore', () => {
await store.setReportFailed(report, { errors: 'yes' } as any);

const [[updateCall]] = mockEsClient.update.mock.calls;
const response = (updateCall as estypes.UpdateRequest).body?.doc as Report;
const response = (updateCall as estypes.UpdateRequest)?.doc as Report;
expect(response.migration_version).toBe(`7.14.0`);
expect(response.status).toBe(`failed`);
expect(updateCall.if_seq_no).toBe(43);
Expand Down Expand Up @@ -272,7 +272,7 @@ describe('ReportingStore', () => {
await store.setReportError(report, { errors: 'yes' } as any);

const [[updateCall]] = mockEsClient.update.mock.calls;
const response = (updateCall as estypes.UpdateRequest).body?.doc as Report;
const response = (updateCall as estypes.UpdateRequest)?.doc as Report;
expect(response.migration_version).toBe(`7.14.0`);
expect(updateCall.if_seq_no).toBe(43);
expect(updateCall.if_primary_term).toBe(10002);
Expand Down Expand Up @@ -301,7 +301,7 @@ describe('ReportingStore', () => {
await store.setReportCompleted(report, { certainly_completed: 'yes' } as any);

const [[updateCall]] = mockEsClient.update.mock.calls;
const response = (updateCall as estypes.UpdateRequest).body?.doc as Report;
const response = (updateCall as estypes.UpdateRequest)?.doc as Report;
expect(response.migration_version).toBe(`7.14.0`);
expect(response.status).toBe(`completed`);
expect(updateCall.if_seq_no).toBe(44);
Expand Down Expand Up @@ -336,7 +336,7 @@ describe('ReportingStore', () => {
} as any);

const [[updateCall]] = mockEsClient.update.mock.calls;
const response = (updateCall as estypes.UpdateRequest).body?.doc as Report;
const response = (updateCall as estypes.UpdateRequest)?.doc as Report;

expect(response.migration_version).toBe(`7.14.0`);
expect(response.status).toBe(`completed_with_warnings`);
Expand Down
2 changes: 1 addition & 1 deletion x-pack/plugins/reporting/server/lib/store/store.ts
Original file line number Diff line number Diff line change
Expand Up @@ -86,7 +86,7 @@ const esDocForUpdate = (
if_seq_no: report._seq_no,
if_primary_term: report._primary_term,
refresh: 'wait_for' as estypes.Refresh,
body: { doc },
doc,
};
};

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@ import { Writable } from 'stream';
import { finished } from 'stream/promises';
import { setTimeout } from 'timers/promises';

import { UpdateResponse } from '@elastic/elasticsearch/lib/api/typesWithBodyKey';
import { UpdateResponse } from '@elastic/elasticsearch/lib/api/types';
import type { Logger } from '@kbn/core/server';
import {
CancellationToken,
Expand Down
Loading

0 comments on commit d555510

Please sign in to comment.