Adding a notification method in case of configuration change (#8623)

centreon · Apr 17, 2020 · c33595b · c33595b
1 parent 626325b
commit c33595b
Show file tree

Hide file tree

Showing 4 changed files with 55 additions and 0 deletions.
diff --git a/src/Centreon/Domain/MonitoringServer/Interfaces/MonitoringServerRepositoryInterface.php b/src/Centreon/Domain/MonitoringServer/Interfaces/MonitoringServerRepositoryInterface.php
@@ -52,4 +52,12 @@ public function findResource(int $monitoringServerId, string $resourceName): ?Mo
      * @throws \Exception
      */
     public function findLocalServer(): ?MonitoringServer;
+
+    /**
+     * We notify that the configuration has changed.
+     *
+     * @param MonitoringServer $monitoringServer Monitoring server to notify
+     * @throws \Exception
+     */
+    public function notifyConfigurationChanged(MonitoringServer $monitoringServer): void;
 }
diff --git a/src/Centreon/Domain/MonitoringServer/Interfaces/MonitoringServerServiceInterface.php b/src/Centreon/Domain/MonitoringServer/Interfaces/MonitoringServerServiceInterface.php
@@ -55,4 +55,12 @@ public function findResource(int $monitoringServerId, string $resourceName): ?Mo
      * @throws MonitoringServerException
      */
     public function findLocalServer(): ?MonitoringServer;
+
+    /**
+     * We notify that the configuration has changed.
+     *
+     * @param MonitoringServer $monitoringServer Monitoring server to notify
+     * @throws MonitoringServerException
+     */
+    public function notifyConfigurationChanged(MonitoringServer $monitoringServer): void;
 }
diff --git a/src/Centreon/Domain/MonitoringServer/MonitoringServerService.php b/src/Centreon/Domain/MonitoringServer/MonitoringServerService.php
@@ -81,4 +81,21 @@ public function findLocalServer(): ?MonitoringServer
             throw new MonitoringServerException('Error when searching for the local monitoring servers', 0, $ex);
         }
     }
+
+    /**
+     * @inheritDoc
+     */
+    public function notifyConfigurationChanged(MonitoringServer $monitoringServer): void
+    {
+        if ($monitoringServer->getId() === null && $monitoringServer->getName() === null) {
+            throw new MonitoringServerException(
+                'The id or name of the monitoring server must be defined and not null'
+            );
+        }
+        try {
+            $this->monitoringServerRepository->notifyConfigurationChanged($monitoringServer);
+        } catch (\Exception $ex) {
+            throw new MonitoringServerException('Error when notifying a configuration change', 0, $ex);
+        }
+    }
 }
diff --git a/src/Centreon/Infrastructure/MonitoringServer/MonitoringServerRepositoryRDB.php b/src/Centreon/Infrastructure/MonitoringServer/MonitoringServerRepositoryRDB.php
@@ -173,4 +173,26 @@ public function findResource(int $monitoringServerId, string $resourceName): ?Mo
         }
         return null;
     }
+
+    /**
+     * @inheritDoc
+     */
+    public function notifyConfigurationChanged(MonitoringServer $monitoringServer): void
+    {
+        if ($monitoringServer->getId() !== null) {
+            $request = $this->translateDbName(
+                'UPDATE `:db`.nagios_server SET updated = "1" WHERE id = :server_id'
+            );
+            $statement = $this->db->prepare($request);
+            $statement->bindValue(':server_id', $monitoringServer->getId(), \PDO::PARAM_INT);
+            $statement->execute();
+        } elseif ($monitoringServer->getName() !== null) {
+            $request = $this->translateDbName(
+                'UPDATE `:db`.nagios_server SET updated = "1" WHERE name = :server_name'
+            );
+            $statement = $this->db->prepare($request);
+            $statement->bindValue(':server_name', $monitoringServer->getName(), \PDO::PARAM_STR);
+            $statement->execute();
+        }
+    }
 }