Allow broadcasting to a specific log channel (#40)

* Allow broadcasting to a specific log channel

* Fix  check condition

* Update src/ConnectionManager.php

* Update config/mqtt-client.php

---------

Co-authored-by: Namoshek <Namoshek@users.noreply.github.com>

.github/workflows/tests.yml

@@ -15,9 +15,9 @@ jobs:
 
     strategy:
       matrix:
-        php-version: ['7.4', '8.0', '8.1']
+        php-version: ['7.4', '8.0', '8.1', '8.2']
         include:
-          - php-version: '8.1'
+          - php-version: '8.2'
             run-sonarqube-analysis: true
 
     steps:

composer.json

@@ -20,9 +20,9 @@
     ],
     "require": {
         "php": "^7.4|^8.0",
-    "illuminate/config": "~7.0|~8.0|~9.0",
+        "illuminate/config": "^7.0|^8.0|^9.0|^10.0",
-    "illuminate/support": "~7.0|~8.0|~9.0",
+        "illuminate/support": "^7.0|^8.0|^9.0|^10.0",
-    "php-mqtt/client": "^1.0"
+        "php-mqtt/client": "^1.3.0"
     },
     "require-dev": {
         "squizlabs/php_codesniffer": "^3.5"

config/mqtt-client.php

@@ -55,6 +55,10 @@ return [
             // with the log level as configured.
             'enable_logging' => env('MQTT_ENABLE_LOGGING', true),
 
+            // Which logging channel to use for logs produced by the MQTT client.
+            // If left empty, the default log channel or stack is being used.
+            'log_channel' => env('MQTT_LOG_CHANNEL', null),
+
             // Defines which repository implementation shall be used. Currently,
             // only a MemoryRepository is supported.
             'repository' => MemoryRepository::class,

src/ConnectionManager.php

@@ -139,11 +139,16 @@ class ConnectionManager
         $cleanSession   = (bool) Arr::get($config, 'use_clean_session', true);
         $repository     = Arr::get($config, 'repository', Repository::class);
         $loggingEnabled = (bool) Arr::get($config, 'enable_logging', true);
+        $logChannel     = Arr::get($config, 'log_channel', null);
 
         $settings   = $this->buildConnectionSettings(Arr::get($config, 'connection_settings', []));
         $repository = $this->application->make($repository);
         $logger     = $loggingEnabled ? $this->application->make('log') : null;
 			
+        if($logger && $logChannel) {
+            $logger = $logger->channel($logChannel);
+        }
+
         $client = new MqttClient($host, $port, $clientId, $protocol, $repository, $logger);
         $client->connect($settings, $cleanSession);