refactor: Migrate Slack logger implementation to use chat.postMessage

- Update SlackHandler configuration to use bot token
- Modify SlackClient to utilize Slack's chat.postMessage API
- Update SlackHandler to work with the new SlackClient implementation
- Adjust CurlClient to support authorization headers
- Add environment variables for SLACK_BOT_TOKEN and SLACK_CHANNEL
- Improve error handling and Slack API response processing

Author: walmir-silva

.env.example

@@ -9,8 +9,9 @@ LOG_CHANNEL=file
 LOG_LEVEL=debug
 LOG_ENCRYPTION_KEY=83302e6472acda6a8aeadf78409ceda3959994991393cdafbe23d2a46a148ba4
 
-# URL do Webhook do Slack para logs
-LOG_SLACK_WEBHOOK_URL=https://hooks.slack.com/services/T00000000/B00000000/XXXXXXXXXXXXXXXXXXXXXXXX
+# Slack para logs
+SLACK_BOT_TOKEN=xoxb-your-bot-token-here
+SLACK_CHANNEL=#your-channel-name
 
 # URL e Porta do Papertrail
 PAPERTRAIL_URL=logs.papertrailapp.com

config/logging.php

@@ -140,7 +140,8 @@
             'class' => \KaririCode\Logging\Handler\SlackHandler::class,
             'with' => [
                 'slackClient' => \KaririCode\Logging\Util\SlackClient::create(
-                    Config::env('LOG_SLACK_WEBHOOK_URL'),
+                    Config::env('SLACK_BOT_TOKEN'),
+                    Config::env('SLACK_CHANNEL', '#logs'),
                     new \KaririCode\Logging\Resilience\CircuitBreaker(
                         Config::env('CIRCUIT_BREAKER_FAILURE_THRESHOLD', 3),
                         Config::env('CIRCUIT_BREAKER_RESET_TIMEOUT', 60)

src/Handler/SlackHandler.php

@@ -13,15 +13,12 @@
 
 class SlackHandler extends AbstractHandler
 {
-    private SlackClient $slackClient;
-
     public function __construct(
-        SlackClient $slackClient,
-        LoggingLogLevel $minLevel = LogLevel::CRITICAL,
-        protected LogFormatter $formatter = new LineFormatter()
+        private SlackClient $slackClient,
+        protected LoggingLogLevel $minLevel = LogLevel::CRITICAL,
+        protected LogFormatter $formatter = new LineFormatter(),
     ) {
         parent::__construct($minLevel, $formatter);
-        $this->slackClient = $slackClient;
     }
 
     public function handle(ImmutableValue $record): void

src/Util/CurlClient.php

@@ -25,25 +25,6 @@ public function post(string $url, array $data, array $headers = []): array
         ];
     }
 
-    /**
-     * Initialize a new cURL session.
-     *
-     * @param string $url the URL to initialize the cURL session with
-     *
-     * @throws \RuntimeException if cURL initialization fails
-     *
-     * @return \CurlHandle the cURL handle
-     */
-    private function initializeCurl(string $url): \CurlHandle
-    {
-        $ch = curl_init($url);
-        if (false === $ch) {
-            throw new \RuntimeException('Failed to initialize cURL');
-        }
-
-        return $ch;
-    }
-
     /**
      * Set POST options for the cURL session.
      *
@@ -64,12 +45,31 @@ private function setPostOptions(\CurlHandle $ch, array $data, array $headers): v
         curl_setopt_array($ch, [
             CURLOPT_POST => true,
             CURLOPT_POSTFIELDS => $payload,
-            CURLOPT_HTTPHEADER => array_merge(self::DEFAULT_HEADERS, $headers),
+            CURLOPT_HTTPHEADER => $headers,
             CURLOPT_RETURNTRANSFER => true,
             CURLOPT_TIMEOUT => self::TIMEOUT,
         ]);
     }
 
+    /**
+     * Initialize a new cURL session.
+     *
+     * @param string $url the URL to initialize the cURL session with
+     *
+     * @throws \RuntimeException if cURL initialization fails
+     *
+     * @return \CurlHandle the cURL handle
+     */
+    private function initializeCurl(string $url): \CurlHandle
+    {
+        $ch = curl_init($url);
+        if (false === $ch) {
+            throw new \RuntimeException('Failed to initialize cURL');
+        }
+
+        return $ch;
+    }
+
     /**
      * Execute the cURL request.
      *

src/Util/SlackClient.php

@@ -11,35 +11,29 @@
 
 class SlackClient
 {
-    private readonly string $webhookUrl;
-    private readonly CircuitBreaker $circuitBreaker;
-    private readonly Retry $retry;
-    private readonly Fallback $fallback;
-    private readonly CurlClient $curlClient;
+    private const SLACK_API_URL = 'https://slack.com/api/chat.postMessage';
 
     public function __construct(
-        string $webhookUrl,
-        CircuitBreaker $circuitBreaker,
-        Retry $retry,
-        Fallback $fallback,
-        CurlClient $curlClient
+        private string $botToken,
+        private string $channel,
+        private CircuitBreaker $circuitBreaker,
+        private Retry $retry,
+        private Fallback $fallback,
+        private CurlClient $curlClient
     ) {
-        $this->setWebhookUrl($webhookUrl);
-        $this->circuitBreaker = $circuitBreaker;
-        $this->retry = $retry;
-        $this->fallback = $fallback;
-        $this->curlClient = $curlClient;
     }
 
     public static function create(
-        string $webhookUrl,
+        string $botToken,
+        string $channel,
         ?CircuitBreaker $circuitBreaker = null,
         ?Retry $retry = null,
         ?Fallback $fallback = null,
         ?CurlClient $curlClient = null
     ): self {
         return new self(
-            $webhookUrl,
+            $botToken,
+            $channel,
             $circuitBreaker ?? new CircuitBreaker(3, 60),
             $retry ?? new Retry(3, 1000, 2, 100),
             $fallback ?? new Fallback(),
@@ -75,13 +69,21 @@ private function doSendMessage(string $message): void
 
     private function createPayload(string $message): array
     {
-        return ['text' => $message];
+        return [
+            'channel' => $this->channel,
+            'text' => $message,
+        ];
     }
 
     private function sendRequest(array $payload): array
     {
+        $headers = [
+            'Content-Type: application/json; charset=utf-8',
+            'Authorization: Bearer ' . $this->botToken,
+        ];
+
         try {
-            return $this->curlClient->post($this->webhookUrl, $payload);
+            return $this->curlClient->post(self::SLACK_API_URL, $payload, $headers);
         } catch (\JsonException $e) {
             $this->circuitBreaker->recordFailure();
             throw new LoggingException('Failed to encode message for Slack: ' . $e->getMessage(), 0, $e);
@@ -94,26 +96,14 @@ private function sendRequest(array $payload): array
     private function handleResponse(array $response): void
     {
         $httpCode = $response['status'];
-        $responseBody = $response['body'];
+        $responseBody = json_decode($response['body'], true);
 
-        if ($httpCode < 200 || $httpCode >= 300) {
+        if ($httpCode < 200 || $httpCode >= 300 || !$responseBody['ok']) {
             $this->circuitBreaker->recordFailure();
-            throw new LoggingException('Slack API responded with HTTP code ' . $httpCode . ': ' . $responseBody);
+            $errorMessage = $responseBody['error'] ?? 'Unknown error';
+            throw new LoggingException('Slack API responded with error: ' . $errorMessage);
         }
 
         $this->circuitBreaker->recordSuccess();
     }
-
-    private function setWebhookUrl(string $webhookUrl): void
-    {
-        if (false === filter_var($webhookUrl, FILTER_VALIDATE_URL)) {
-            throw new \InvalidArgumentException('Invalid webhook URL');
-        }
-        $this->webhookUrl = $webhookUrl;
-    }
-
-    public function getWebhookUrl(): string
-    {
-        return $this->webhookUrl;
-    }
 }

tests/Logger/test_config.php

@@ -1 +1 @@
-<?php return ['key' => 'value'];
+<?php return ['key' => 'value'];

tests/application.php

@@ -1,5 +1,6 @@
 <?php
 
+// application.php
 require_once __DIR__ . '/../vendor/autoload.php';
 
 use KaririCode\Logging\LoggerConfiguration;
@@ -26,16 +27,16 @@
 
 $serviceProvider->register();
 
-$defaultLogger = $loggerRegistry->getLogger('console');
+// $defaultLogger = $loggerRegistry->getLogger('console');
 
-$defaultLogger->debug('User email is john.doe@example.com');
-$defaultLogger->info('User IP is 192.168.1.1');
-$defaultLogger->notice('User credit card number is 1234-5678-1234-5678', ['context' => 'credit card']);
-$defaultLogger->warning('User phone number is (11) 91234-7890', ['context' => 'phone']);
-$defaultLogger->error('This is an error message with email john.doe@example.com', ['context' => 'error']);
-$defaultLogger->critical('This is a critical message with IP 192.168.1.1', ['context' => 'critical']);
-$defaultLogger->alert('This is an alert message with credit card 1234-5678-1234-5678', ['context' => 'alert']);
-$defaultLogger->emergency('This is an emergency message with phone number 123-456-7890', ['context' => 'emergency']);
+// $defaultLogger->debug('User email is john.doe@example.com');
+// $defaultLogger->info('User IP is 192.168.1.1');
+// $defaultLogger->notice('User credit card number is 1234-5678-1234-5678', ['context' => 'credit card']);
+// $defaultLogger->warning('User phone number is (11) 91234-7890', ['context' => 'phone']);
+// $defaultLogger->error('This is an error message with email john.doe@example.com', ['context' => 'error']);
+// $defaultLogger->critical('This is a critical message with IP 192.168.1.1', ['context' => 'critical']);
+// $defaultLogger->alert('This is an alert message with credit card 1234-5678-1234-5678', ['context' => 'alert']);
+// $defaultLogger->emergency('This is an emergency message with phone number 123-456-7890', ['context' => 'emergency']);
 
 // $asyncLogger = $loggerRegistry->getLogger('async');
 // if ($asyncLogger) {
@@ -58,3 +59,6 @@
 
 // $errorLogger = $loggerRegistry->getLogger('error');
 // $errorLogger->error('This is a critical error.', ['context' => 'Testing error logger']);
+
+$slackLogger = $loggerRegistry->getLogger('slack');
+$slackLogger->critical('Este é um teste de mensagem crítica enviada para o Slack');