From 6a5123a1b2d2b40089c94109619c471b3c33acf2 Mon Sep 17 00:00:00 2001 From: Rudolf Meijering Date: Tue, 28 Sep 2021 15:24:43 +0200 Subject: [PATCH] Refactor state types --- .../server/saved_objects/migrationsv2/actions/transform_docs.ts | 2 +- src/core/server/saved_objects/migrationsv2/index.ts | 2 +- src/core/server/saved_objects/migrationsv2/initial_state.ts | 2 +- .../migrationsv2/migrations_state_action_machine.test.ts | 2 +- .../migrationsv2/migrations_state_action_machine.ts | 2 +- .../migrationsv2/migrations_state_machine_cleanup.ts | 2 +- src/core/server/saved_objects/migrationsv2/model/helpers.ts | 2 +- src/core/server/saved_objects/migrationsv2/model/model.test.ts | 2 +- src/core/server/saved_objects/migrationsv2/model/model.ts | 2 +- .../server/saved_objects/migrationsv2/model/progress.test.ts | 2 +- src/core/server/saved_objects/migrationsv2/model/progress.ts | 2 +- .../server/saved_objects/migrationsv2/model/retry_state.test.ts | 2 +- src/core/server/saved_objects/migrationsv2/model/retry_state.ts | 2 +- src/core/server/saved_objects/migrationsv2/next.test.ts | 2 +- src/core/server/saved_objects/migrationsv2/next.ts | 2 +- .../server/saved_objects/migrationsv2/{types.ts => state.ts} | 0 16 files changed, 15 insertions(+), 15 deletions(-) rename src/core/server/saved_objects/migrationsv2/{types.ts => state.ts} (100%) diff --git a/src/core/server/saved_objects/migrationsv2/actions/transform_docs.ts b/src/core/server/saved_objects/migrationsv2/actions/transform_docs.ts index 4c712afcff3a4..41fa3b74dbc56 100644 --- a/src/core/server/saved_objects/migrationsv2/actions/transform_docs.ts +++ b/src/core/server/saved_objects/migrationsv2/actions/transform_docs.ts @@ -6,7 +6,7 @@ * Side Public License, v 1. */ import * as TaskEither from 'fp-ts/lib/TaskEither'; -import type { TransformRawDocs } from '../types'; +import type { TransformRawDocs } from '../state'; import type { SavedObjectsRawDoc } from '../../serialization'; import { DocumentsTransformFailed, diff --git a/src/core/server/saved_objects/migrationsv2/index.ts b/src/core/server/saved_objects/migrationsv2/index.ts index 33f73395bcc6c..6f3878a8477f7 100644 --- a/src/core/server/saved_objects/migrationsv2/index.ts +++ b/src/core/server/saved_objects/migrationsv2/index.ts @@ -10,7 +10,7 @@ import { ElasticsearchClient } from '../../elasticsearch'; import { IndexMapping } from '../mappings'; import { Logger } from '../../logging'; import type { SavedObjectsMigrationVersion } from '../types'; -import type { TransformRawDocs } from './types'; +import type { TransformRawDocs } from './state'; import { MigrationResult } from '../migrations/core'; import { next } from './next'; import { model } from './model'; diff --git a/src/core/server/saved_objects/migrationsv2/initial_state.ts b/src/core/server/saved_objects/migrationsv2/initial_state.ts index a61967be9242c..f074f123c8930 100644 --- a/src/core/server/saved_objects/migrationsv2/initial_state.ts +++ b/src/core/server/saved_objects/migrationsv2/initial_state.ts @@ -11,7 +11,7 @@ import { IndexMapping } from '../mappings'; import { SavedObjectsMigrationVersion } from '../../../types'; import { SavedObjectsMigrationConfigType } from '../saved_objects_config'; import type { ISavedObjectTypeRegistry } from '../saved_objects_type_registry'; -import { InitState } from './types'; +import { InitState } from './state'; import { excludeUnusedTypesQuery } from '../migrations/core'; /** diff --git a/src/core/server/saved_objects/migrationsv2/migrations_state_action_machine.test.ts b/src/core/server/saved_objects/migrationsv2/migrations_state_action_machine.test.ts index 21468d7552320..cde851b692347 100644 --- a/src/core/server/saved_objects/migrationsv2/migrations_state_action_machine.test.ts +++ b/src/core/server/saved_objects/migrationsv2/migrations_state_action_machine.test.ts @@ -15,7 +15,7 @@ import * as Option from 'fp-ts/lib/Option'; import { ResponseError } from '@elastic/elasticsearch/lib/errors'; import { elasticsearchClientMock } from '../../elasticsearch/client/mocks'; import { LoggerAdapter } from '../../logging/logger_adapter'; -import { AllControlStates, State } from './types'; +import { AllControlStates, State } from './state'; import { createInitialState } from './initial_state'; import { ByteSizeValue } from '@kbn/config-schema'; diff --git a/src/core/server/saved_objects/migrationsv2/migrations_state_action_machine.ts b/src/core/server/saved_objects/migrationsv2/migrations_state_action_machine.ts index 3a5e592a8b9bf..87b78102371d3 100644 --- a/src/core/server/saved_objects/migrationsv2/migrations_state_action_machine.ts +++ b/src/core/server/saved_objects/migrationsv2/migrations_state_action_machine.ts @@ -13,7 +13,7 @@ import type { ElasticsearchClient } from '../../elasticsearch'; import { getErrorMessage, getRequestDebugMeta } from '../../elasticsearch'; import { Model, Next, stateActionMachine } from './state_action_machine'; import { cleanup } from './migrations_state_machine_cleanup'; -import { ReindexSourceToTempTransform, ReindexSourceToTempIndexBulk, State } from './types'; +import { ReindexSourceToTempTransform, ReindexSourceToTempIndexBulk, State } from './state'; import { SavedObjectsRawDoc } from '../serialization'; interface StateTransitionLogMeta extends LogMeta { diff --git a/src/core/server/saved_objects/migrationsv2/migrations_state_machine_cleanup.ts b/src/core/server/saved_objects/migrationsv2/migrations_state_machine_cleanup.ts index 9c0ef0d1a2cb6..ff8ff57d41ce4 100644 --- a/src/core/server/saved_objects/migrationsv2/migrations_state_machine_cleanup.ts +++ b/src/core/server/saved_objects/migrationsv2/migrations_state_machine_cleanup.ts @@ -8,7 +8,7 @@ import type { ElasticsearchClient } from '../../elasticsearch'; import * as Actions from './actions'; -import type { State } from './types'; +import type { State } from './state'; export async function cleanup(client: ElasticsearchClient, state?: State) { if (!state) return; diff --git a/src/core/server/saved_objects/migrationsv2/model/helpers.ts b/src/core/server/saved_objects/migrationsv2/model/helpers.ts index 4e920608594b1..c3a4c85679680 100644 --- a/src/core/server/saved_objects/migrationsv2/model/helpers.ts +++ b/src/core/server/saved_objects/migrationsv2/model/helpers.ts @@ -7,7 +7,7 @@ */ import { gt, valid } from 'semver'; -import { State } from '../types'; +import { State } from '../state'; import { IndexMapping } from '../../mappings'; import { FetchIndexResponse } from '../actions'; diff --git a/src/core/server/saved_objects/migrationsv2/model/model.test.ts b/src/core/server/saved_objects/migrationsv2/model/model.test.ts index 3e48a7147bffd..8ab306e09a960 100644 --- a/src/core/server/saved_objects/migrationsv2/model/model.test.ts +++ b/src/core/server/saved_objects/migrationsv2/model/model.test.ts @@ -40,7 +40,7 @@ import type { ReindexSourceToTempIndexBulk, CheckUnknownDocumentsState, CalculateExcludeFiltersState, -} from '../types'; +} from '../state'; import { SavedObjectsRawDoc } from '../../serialization'; import { TransformErrorObjects, TransformSavedObjectDocumentError } from '../../migrations/core'; import { AliasAction, RetryableEsClientError } from '../actions'; diff --git a/src/core/server/saved_objects/migrationsv2/model/model.ts b/src/core/server/saved_objects/migrationsv2/model/model.ts index 5d8862e48df1a..0b15e2ce411f2 100644 --- a/src/core/server/saved_objects/migrationsv2/model/model.ts +++ b/src/core/server/saved_objects/migrationsv2/model/model.ts @@ -11,7 +11,7 @@ import * as Option from 'fp-ts/lib/Option'; import { estypes } from '@elastic/elasticsearch'; import { AliasAction, isLeftTypeof } from '../actions'; -import { AllActionStates, MigrationLog, State } from '../types'; +import { AllActionStates, MigrationLog, State } from '../state'; import type { ResponseType } from '../next'; import { disableUnknownTypeMappingFields } from '../../migrations/core/migration_context'; import { diff --git a/src/core/server/saved_objects/migrationsv2/model/progress.test.ts b/src/core/server/saved_objects/migrationsv2/model/progress.test.ts index 2086774dd2fb4..c21d3ae015ee9 100644 --- a/src/core/server/saved_objects/migrationsv2/model/progress.test.ts +++ b/src/core/server/saved_objects/migrationsv2/model/progress.test.ts @@ -6,7 +6,7 @@ * Side Public License, v 1. */ -import type { MigrationLog } from '../types'; +import type { MigrationLog } from '../state'; import { createInitialProgress, incrementProcessedProgress, diff --git a/src/core/server/saved_objects/migrationsv2/model/progress.ts b/src/core/server/saved_objects/migrationsv2/model/progress.ts index ef66283fcf682..c164cc3ef343d 100644 --- a/src/core/server/saved_objects/migrationsv2/model/progress.ts +++ b/src/core/server/saved_objects/migrationsv2/model/progress.ts @@ -6,7 +6,7 @@ * Side Public License, v 1. */ -import type { MigrationLog, Progress } from '../types'; +import type { MigrationLog, Progress } from '../state'; /** * Returns an initial state of the progress object (everything undefined) diff --git a/src/core/server/saved_objects/migrationsv2/model/retry_state.test.ts b/src/core/server/saved_objects/migrationsv2/model/retry_state.test.ts index d49e570e0cdef..5a195f8597182 100644 --- a/src/core/server/saved_objects/migrationsv2/model/retry_state.test.ts +++ b/src/core/server/saved_objects/migrationsv2/model/retry_state.test.ts @@ -7,7 +7,7 @@ */ import { resetRetryState, delayRetryState } from './retry_state'; -import { State } from '../types'; +import { State } from '../state'; const createState = (parts: Record) => { return parts as State; diff --git a/src/core/server/saved_objects/migrationsv2/model/retry_state.ts b/src/core/server/saved_objects/migrationsv2/model/retry_state.ts index 5d69d32a7160c..02057a6af2061 100644 --- a/src/core/server/saved_objects/migrationsv2/model/retry_state.ts +++ b/src/core/server/saved_objects/migrationsv2/model/retry_state.ts @@ -6,7 +6,7 @@ * Side Public License, v 1. */ -import { State } from '../types'; +import { State } from '../state'; export const delayRetryState = ( state: S, diff --git a/src/core/server/saved_objects/migrationsv2/next.test.ts b/src/core/server/saved_objects/migrationsv2/next.test.ts index a34480fc311cd..98a8690844872 100644 --- a/src/core/server/saved_objects/migrationsv2/next.test.ts +++ b/src/core/server/saved_objects/migrationsv2/next.test.ts @@ -8,7 +8,7 @@ import { ElasticsearchClient } from '../../elasticsearch'; import { next } from './next'; -import { State } from './types'; +import { State } from './state'; describe('migrations v2 next', () => { it.todo('when state.retryDelay > 0 delays execution of the next action'); diff --git a/src/core/server/saved_objects/migrationsv2/next.ts b/src/core/server/saved_objects/migrationsv2/next.ts index 433c0998f7567..97bc54d367436 100644 --- a/src/core/server/saved_objects/migrationsv2/next.ts +++ b/src/core/server/saved_objects/migrationsv2/next.ts @@ -41,7 +41,7 @@ import type { OutdatedDocumentsRefresh, CheckUnknownDocumentsState, CalculateExcludeFiltersState, -} from './types'; +} from './state'; import * as Actions from './actions'; import { ElasticsearchClient } from '../../elasticsearch'; diff --git a/src/core/server/saved_objects/migrationsv2/types.ts b/src/core/server/saved_objects/migrationsv2/state.ts similarity index 100% rename from src/core/server/saved_objects/migrationsv2/types.ts rename to src/core/server/saved_objects/migrationsv2/state.ts