[9.1] [Synthetics] Fix sync params for custom namespace !! (#232211) (#232372)

# Backport

This will backport the following commits from `main` to `9.1`:
- [[Synthetics] Fix sync params for custom namespace !!
(#232211)](#232211)

<!--- Backport version: 9.6.6 -->

### Questions ?
Please refer to the [Backport tool
documentation](https://github.com/sorenlouv/backport)

<!--BACKPORT
[{"author":{"name":"Shahzad","email":"[email protected]"},"sourceCommit":{"committedDate":"2025-08-20T11:14:53Z","message":"[Synthetics]
Fix sync params for custom namespace !! (#232211)\n\n## Summary\n\nFix
sync params for custom namespace !!\n\n\n### Testing\n\nDefine a custom
data stream namespace on monitor and make sure syncing\nof global params
works as expected.\n\n<img width=\"1439\" height=\"882\"
alt=\"image\"\nsrc=\"https://github.com/user-attachments/assets/aa14ef26-5d71-475c-b236-bf3d70c7d828\"\n/>\n\n---------\n\nCo-authored-by:
Francesco Fagnani <[email protected]>\nCo-authored-by:
kibanamachine
<[email protected]>","sha":"8ab7d90160021ce880587c1086da397b60130672","branchLabelMapping":{"^v9.2.0$":"main","^v(\\d+).(\\d+).\\d+$":"$1.$2"}},"sourcePullRequest":{"labels":["release_note:skip","Team:obs-ux-management","backport:version","author:obs-ux-management","v9.2.0","v9.1.1","v8.19.1"],"title":"[Synthetics]
Fix sync params for custom namespace
!!","number":232211,"url":"https://github.com/elastic/kibana/pull/232211","mergeCommit":{"message":"[Synthetics]
Fix sync params for custom namespace !! (#232211)\n\n## Summary\n\nFix
sync params for custom namespace !!\n\n\n### Testing\n\nDefine a custom
data stream namespace on monitor and make sure syncing\nof global params
works as expected.\n\n<img width=\"1439\" height=\"882\"
alt=\"image\"\nsrc=\"https://github.com/user-attachments/assets/aa14ef26-5d71-475c-b236-bf3d70c7d828\"\n/>\n\n---------\n\nCo-authored-by:
Francesco Fagnani <[email protected]>\nCo-authored-by:
kibanamachine
<[email protected]>","sha":"8ab7d90160021ce880587c1086da397b60130672"}},"sourceBranch":"main","suggestedTargetBranches":["9.1","8.19"],"targetPullRequestStates":[{"branch":"main","label":"v9.2.0","branchLabelMappingKey":"^v9.2.0$","isSourceBranch":true,"state":"MERGED","url":"https://github.com/elastic/kibana/pull/232211","number":232211,"mergeCommit":{"message":"[Synthetics]
Fix sync params for custom namespace !! (#232211)\n\n## Summary\n\nFix
sync params for custom namespace !!\n\n\n### Testing\n\nDefine a custom
data stream namespace on monitor and make sure syncing\nof global params
works as expected.\n\n<img width=\"1439\" height=\"882\"
alt=\"image\"\nsrc=\"https://github.com/user-attachments/assets/aa14ef26-5d71-475c-b236-bf3d70c7d828\"\n/>\n\n---------\n\nCo-authored-by:
Francesco Fagnani <[email protected]>\nCo-authored-by:
kibanamachine
<[email protected]>","sha":"8ab7d90160021ce880587c1086da397b60130672"}},{"branch":"9.1","label":"v9.1.1","branchLabelMappingKey":"^v(\\d+).(\\d+).\\d+$","isSourceBranch":false,"state":"NOT_CREATED"},{"branch":"8.19","label":"v8.19.1","branchLabelMappingKey":"^v(\\d+).(\\d+).\\d+$","isSourceBranch":false,"state":"NOT_CREATED"}]}]
BACKPORT-->

Co-authored-by: Shahzad <[email protected]>
Co-authored-by: Francesco Fagnani <[email protected]>

Author: 3 people

x-pack/solutions/observability/plugins/synthetics/server/synthetics_service/private_location/synthetics_private_location.ts

@@ -323,6 +323,10 @@ export class SyntheticsPrivateLocation {
       }
     }
 
+    this.server.logger.debug(
+      `[editingMonitors] Creating ${policiesToCreate.length} policies, updating ${policiesToUpdate.length} policies, and deleting ${policiesToDelete.length} policies`
+    );
+
     const [_createResponse, failedUpdatesRes, _deleteResponse] = await Promise.all([
       this.createPolicyBulk(policiesToCreate),
       this.updatePolicyBulk(policiesToUpdate),

x-pack/solutions/observability/plugins/synthetics/server/tasks/sync_private_locations_monitors_task.test.ts

@@ -171,11 +171,19 @@ describe('SyncPrivateLocationMonitorsTask', () => {
 
       const result = await task.runTask({ taskInstance });
 
-      expect(mockLogger.debug).toHaveBeenCalledWith(
-        'Syncing private location monitors because data has changed'
+      expect(mockLogger.debug).toHaveBeenNthCalledWith(
+        1,
+        '[syncGlobalParams] Syncing private location monitors, last total params 1 '
+      );
+      expect(mockLogger.debug).toHaveBeenNthCalledWith(
+        2,
+        '[syncGlobalParams] Syncing private location monitors because data has changed '
+      );
+      expect(mockLogger.debug).toHaveBeenNthCalledWith(
+        3,
+        '[syncGlobalParams] Sync of private location monitors succeeded '
       );
       expect(task.syncGlobalParams).toHaveBeenCalled();
-      expect(mockLogger.debug).toHaveBeenCalledWith('Sync of private location monitors succeeded');
       expect(result.error).toBeUndefined();
       expect(result.state).toEqual({
         lastStartedAt: taskInstance.startedAt?.toISOString(),
@@ -198,7 +206,9 @@ describe('SyncPrivateLocationMonitorsTask', () => {
 
       expect(getPrivateLocationsModule.getPrivateLocations).toHaveBeenCalled();
       expect(task.syncGlobalParams).not.toHaveBeenCalled();
-      expect(mockLogger.debug).toHaveBeenCalledWith('Sync of private location monitors succeeded');
+      expect(mockLogger.debug).toHaveBeenLastCalledWith(
+        '[syncGlobalParams] Sync of private location monitors succeeded '
+      );
     });
 
     it('should handle errors during the run', async () => {

x-pack/solutions/observability/plugins/synthetics/server/tasks/sync_private_locations_monitors_task.ts

@@ -87,9 +87,7 @@ export class SyncPrivateLocationMonitorsTask {
     let lastTotalParams = taskInstance.state.lastTotalParams || 0;
     let lastTotalMWs = taskInstance.state.lastTotalMWs || 0;
     try {
-      logger.debug(
-        `Syncing private location monitors, last total params ${lastTotalParams}, last run ${lastStartedAt}`
-      );
+      this.debugLog(`Syncing private location monitors, last total params ${lastTotalParams}`);
       const soClient = savedObjects.createInternalRepository([
         MAINTENANCE_WINDOW_SAVED_OBJECT_TYPE,
       ]);
@@ -101,7 +99,7 @@ export class SyncPrivateLocationMonitorsTask {
       lastTotalParams = totalParams;
       lastTotalMWs = totalMWs;
       if (hasDataChanged) {
-        logger.debug(`Syncing private location monitors because data has changed`);
+        this.debugLog(`Syncing private location monitors because data has changed`);
 
         if (allPrivateLocations.length > 0) {
           await this.syncGlobalParams({
@@ -110,9 +108,9 @@ export class SyncPrivateLocationMonitorsTask {
             encryptedSavedObjects,
           });
         }
-        logger.debug(`Sync of private location monitors succeeded`);
+        this.debugLog(`Sync of private location monitors succeeded`);
       } else {
-        logger.debug(
+        this.debugLog(
           `No data has changed since last run ${lastStartedAt}, skipping sync of private location monitors`
         );
       }
@@ -201,23 +199,30 @@ export class SyncPrivateLocationMonitorsTask {
 
     for (const spaceId of spaceIds) {
       const monitors = configsBySpaces[spaceId];
+      this.debugLog(`Processing spaceId: ${spaceId}, monitors count: ${monitors?.length ?? 0}`);
       if (!monitors) {
         continue;
       }
       for (const monitor of monitors) {
         const { privateLocations } = this.parseLocations(monitor);
 
         if (privateLocations.length > 0) {
-          privateConfigs.push({ config: monitor, globalParams: paramsBySpace[monitor.namespace] });
+          privateConfigs.push({ config: monitor, globalParams: paramsBySpace[spaceId] });
         }
       }
       if (privateConfigs.length > 0) {
+        this.debugLog(
+          `Syncing private configs for spaceId: ${spaceId}, privateConfigs count: ${privateConfigs.length}`
+        );
+
         await privateLocationAPI.editMonitors(
           privateConfigs,
           allPrivateLocations,
           spaceId,
           maintenanceWindows
         );
+      } else {
+        this.debugLog(`No privateConfigs to sync for spaceId: ${spaceId}`);
       }
     }
   }
@@ -381,6 +386,10 @@ export class SyncPrivateLocationMonitorsTask {
       totalMWs: noOfMWs,
     };
   }
+
+  debugLog = (message: string) => {
+    this.serverSetup.logger.debug(`[syncGlobalParams] ${message} `);
+  };
 }
 
 export const runSynPrivateLocationMonitorsTaskSoon = async ({