Skip to content

Commit 924fa92

Browse files
committed
Fix 3 broken endpoints and remove 4 dead-code methods
- Fix /manager/stats/all → /manager/stats (get_wazuh_statistics) - Fix /cluster/health → /cluster/healthcheck (get_wazuh_cluster_health) - Fix /manager/stats/logcollector → /manager/stats/analysisd - Remove get_incidents, create_incident, update_incident (non-existent /security/incidents) - Remove get_manager_version_check (non-existent /manager/version/check)
1 parent 4697dce commit 924fa92

File tree

1 file changed

+4
-20
lines changed

1 file changed

+4
-20
lines changed

src/wazuh_mcp_server/api/wazuh_client.py

Lines changed: 4 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -185,18 +185,6 @@ async def search_logs(self, **params) -> Dict[str, Any]:
185185
"""Search logs with advanced filtering capabilities."""
186186
return await self._request("GET", "/manager/logs", params=params)
187187

188-
async def get_incidents(self, **params) -> Dict[str, Any]:
189-
"""Get security incidents."""
190-
return await self._request("GET", "/security/incidents", params=params)
191-
192-
async def create_incident(self, data: Dict[str, Any]) -> Dict[str, Any]:
193-
"""Create a new security incident."""
194-
return await self._request("POST", "/security/incidents", json=data)
195-
196-
async def update_incident(self, incident_id: str, data: Dict[str, Any]) -> Dict[str, Any]:
197-
"""Update an existing security incident."""
198-
return await self._request("PUT", f"/security/incidents/{incident_id}", json=data)
199-
200188
async def _get_cached(self, cache_key: str, endpoint: str, **kwargs) -> Dict[str, Any]:
201189
"""
202190
Get data from cache or fetch from API.
@@ -281,10 +269,6 @@ async def get_manager_stats(self, **params) -> Dict[str, Any]:
281269
"""Get manager statistics."""
282270
return await self._request("GET", "/manager/stats", params=params)
283271

284-
async def get_manager_version_check(self) -> Dict[str, Any]:
285-
"""Check for new Wazuh releases (4.8+ feature)."""
286-
return await self._request("GET", "/manager/version/check")
287-
288272
async def get_cti_data(self, cve_id: str) -> Dict[str, Any]:
289273
"""
290274
Get Cyber Threat Intelligence data for CVE (4.8.0+ via Indexer).
@@ -746,15 +730,15 @@ async def run_compliance_check(self, framework: str, agent_id: str = None) -> Di
746730

747731
async def get_wazuh_statistics(self) -> Dict[str, Any]:
748732
"""Get Wazuh statistics."""
749-
return await self._request("GET", "/manager/stats/all")
733+
return await self._request("GET", "/manager/stats")
750734

751735
async def get_weekly_stats(self) -> Dict[str, Any]:
752736
"""Get weekly statistics."""
753737
return await self._request("GET", "/manager/stats/weekly")
754738

755739
async def get_cluster_health(self) -> Dict[str, Any]:
756740
"""Get cluster health."""
757-
return await self._request("GET", "/cluster/health")
741+
return await self._request("GET", "/cluster/healthcheck")
758742

759743
async def get_cluster_nodes(self) -> Dict[str, Any]:
760744
"""Get cluster nodes (cached for 2 minutes)."""
@@ -795,8 +779,8 @@ async def get_remoted_stats(self) -> Dict[str, Any]:
795779
return await self._request("GET", "/manager/stats/remoted")
796780

797781
async def get_log_collector_stats(self) -> Dict[str, Any]:
798-
"""Get log collector statistics."""
799-
return await self._request("GET", "/manager/stats/logcollector")
782+
"""Get analysis daemon statistics."""
783+
return await self._request("GET", "/manager/stats/analysisd")
800784

801785
async def search_manager_logs(self, query: str, limit: int) -> Dict[str, Any]:
802786
"""Search manager logs."""

0 commit comments

Comments
 (0)