Method export

modules/siem/webhook.py:190–225

Export event via webhook. Args: event: Event to export Returns: True if successful

(self, event: SIEMEvent)

    async def export(self, event: SIEMEvent) -> bool:
        """Export event via webhook.

        Args:
            event: Event to export

        Returns:
            True if successful
        """
        if not self._should_send(event):
            self.logger.debug(f"Event below severity threshold: {event.severity}")
            return True  # Not an error, just filtered

        payload = self._format_payload(event)

        try:
            async with httpx.AsyncClient(timeout=self.timeout) as client:
                response = await client.request(
                    method=self.method,
                    url=self.url,
                    json=payload,
                    headers=self._get_headers(),
                )

                if response.status_code in [200, 201, 202, 204]:
                    self.logger.debug(f"Webhook delivered: {event.event_type}")
                    return True
                else:
                    self.logger.error(
                        f"Webhook error: {response.status_code} - {response.text}"
                    )
                    return False

        except Exception as e:
            self.logger.error(f"Webhook export failed: {e}")
            return False

    async def test_connection(self) -> bool:
        """Test webhook endpoint.

        Returns: