support log level for docker container

Author: PNixx

README.md

@@ -41,11 +41,19 @@ php examples/run.php start
 
 ## Docker
 
+Build and run from source:
+
 ```bash
 docker build --rm -t clickhouse-queue .
 docker run --name clickhouse-queue clickhouse-queue
 ```
 
+Run container with shared tmp directory:
+
+```bash
+docker run -it -v /path/to/tmp:/var/www/clickhouse-queue/tmp --name clickhouse-queue pnixx/clickhouse-queue
+```
+
 Environment variables:
 * `CLICKHOUSE_HOST` - ClickHouse host for inserts, default `localhost`
 * `CLICKHOUSE_PORT` - ClickHouse port for inserts, default `8123`
@@ -61,6 +69,7 @@ Environment variables:
 * `RABBIT_VHOST` - RabbitMQ vhost, default `/`
 * `MAX_DELAY` - time flush data to ClickHouse, default `5`
 * `MAX_FILE_SIZE` - max buffer size before flush to ClickHouse, default `5242880`
+* `LOG_LEVEL` - output log level, default `warning`
 
 ## Message structure
 
@@ -87,7 +96,7 @@ Donations to this project are going directly to [PNixx](https://github.com/PNixx
 * BTC address: `1H3rhpf7WEF5JmMZ3PVFMQc7Hm29THgUfN`
 * ETH address: `0x6F094365A70fe7836A633d2eE80A1FA9758234d5`
 * XMR address: `42gP71qLB5M43RuDnrQ3vSJFFxis9Kw9VMURhpx9NLQRRwNvaZRjm2TFojAMC8Fk1BQhZNKyWhoyJSn5Ak9kppgZPjE17Zh`
-* TON address: `UQBt0-s1igIpJoEup0B1yAUkZ56rzbpruuAjNhQ26MVCaNlC`
+* TON address: `UQB5RntjBNMA6qXjuqTrl2TcqceNu3vMOj1AyyW3eeGGI-Qd`
 
 ## Contributing
 

examples/run.php

@@ -11,8 +11,12 @@
 require __DIR__ . '/../vendor/autoload.php';
 
 // Create the logger
+$log_level = Level::Warning;
+if( getenv('LOG_LEVEL') ) {
+	$log_level = Level::fromName(getenv('LOG_LEVEL'));
+}
 $logger = new Logger('Worker');
-$handler = new StreamHandler('php://output', Level::Warning);
+$handler = new StreamHandler('php://output', $log_level);
 $handler->setFormatter(new LineFormatter(null, null, true));
 $logger->pushHandler($handler);
 

src/ClickhouseWorker.php

@@ -1,6 +1,7 @@
 <?php
 namespace PNixx\Clickhouse;
 
+use Monolog\Level;
 use Psr\Log\LoggerInterface;
 use Revolt\EventLoop;
 use Workerman\Stomp\Client;
@@ -259,6 +260,7 @@ private function stompConnect(): void {
 			'passcode'         => $this->config['stomp']['password'] ?? null ?: 'guest',
 			'reconnect_period' => 1,
 			'vhost'            => $this->config['stomp']['vhost'] ?? null ?: '/',
+			'debug'            => $this->logger && method_exists($this->logger, 'isHandling') && $this->logger->isHandling(Level::Debug),
 		]));
 
 		//Wait connection success