Skip to content

Commit ce5a13c

Browse files
authored
[Ingest Manager] Do not bumb config revision during config creation (#72270) (#72428)
1 parent 68c844e commit ce5a13c

File tree

4 files changed

+14
-7
lines changed

4 files changed

+14
-7
lines changed

x-pack/plugins/ingest_manager/server/routes/agent_config/handlers.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -135,6 +135,7 @@ export const createAgentConfigHandler: RequestHandler<
135135
newSysPackageConfig.namespace = agentConfig.namespace;
136136
await packageConfigService.create(soClient, callCluster, newSysPackageConfig, {
137137
user,
138+
bumpConfigRevision: false,
138139
});
139140
}
140141

x-pack/plugins/ingest_manager/server/services/agent_config.ts

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,8 @@ class AgentConfigService {
4141
soClient: SavedObjectsClientContract,
4242
id: string,
4343
agentConfig: Partial<AgentConfigSOAttributes>,
44-
user?: AuthenticatedUser
44+
user?: AuthenticatedUser,
45+
options: { bumpRevision: boolean } = { bumpRevision: true }
4546
): Promise<AgentConfig> {
4647
const oldAgentConfig = await this.get(soClient, id, false);
4748

@@ -60,7 +61,7 @@ class AgentConfigService {
6061

6162
await soClient.update<AgentConfigSOAttributes>(SAVED_OBJECT_TYPE, id, {
6263
...agentConfig,
63-
revision: oldAgentConfig.revision + 1,
64+
...(options.bumpRevision ? { revision: oldAgentConfig.revision + 1 } : {}),
6465
updated_at: new Date().toISOString(),
6566
updated_by: user ? user.username : 'system',
6667
});
@@ -265,7 +266,7 @@ class AgentConfigService {
265266
soClient: SavedObjectsClientContract,
266267
id: string,
267268
packageConfigIds: string[],
268-
options?: { user?: AuthenticatedUser }
269+
options: { user?: AuthenticatedUser; bumpRevision: boolean } = { bumpRevision: true }
269270
): Promise<AgentConfig> {
270271
const oldAgentConfig = await this.get(soClient, id, false);
271272

@@ -281,7 +282,8 @@ class AgentConfigService {
281282
[...((oldAgentConfig.package_configs || []) as string[])].concat(packageConfigIds)
282283
),
283284
},
284-
options?.user
285+
options?.user,
286+
{ bumpRevision: options.bumpRevision }
285287
);
286288
}
287289

x-pack/plugins/ingest_manager/server/services/package_config.ts

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@ class PackageConfigService {
4242
soClient: SavedObjectsClientContract,
4343
callCluster: CallESAsCurrentUser,
4444
packageConfig: NewPackageConfig,
45-
options?: { id?: string; user?: AuthenticatedUser }
45+
options?: { id?: string; user?: AuthenticatedUser; bumpConfigRevision?: boolean }
4646
): Promise<PackageConfig> {
4747
// Check that its agent config does not have a package config with the same name
4848
const parentAgentConfig = await agentConfigService.get(soClient, packageConfig.config_id);
@@ -104,6 +104,7 @@ class PackageConfigService {
104104
// Assign it to the given agent config
105105
await agentConfigService.assignPackageConfigs(soClient, packageConfig.config_id, [newSo.id], {
106106
user: options?.user,
107+
bumpRevision: options?.bumpConfigRevision ?? true,
107108
});
108109

109110
return {
@@ -117,7 +118,7 @@ class PackageConfigService {
117118
soClient: SavedObjectsClientContract,
118119
packageConfigs: NewPackageConfig[],
119120
configId: string,
120-
options?: { user?: AuthenticatedUser }
121+
options?: { user?: AuthenticatedUser; bumpConfigRevision?: boolean }
121122
): Promise<PackageConfig[]> {
122123
const isoDate = new Date().toISOString();
123124
const { saved_objects: newSos } = await soClient.bulkCreate<PackageConfigSOAttributes>(
@@ -142,6 +143,7 @@ class PackageConfigService {
142143
newSos.map((newSo) => newSo.id),
143144
{
144145
user: options?.user,
146+
bumpRevision: options?.bumpConfigRevision ?? true,
145147
}
146148
);
147149

x-pack/plugins/ingest_manager/server/services/setup.ts

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -218,5 +218,7 @@ async function addPackageToConfig(
218218
config.namespace
219219
);
220220

221-
await packageConfigService.create(soClient, callCluster, newPackageConfig);
221+
await packageConfigService.create(soClient, callCluster, newPackageConfig, {
222+
bumpConfigRevision: false,
223+
});
222224
}

0 commit comments

Comments
 (0)