Merge pull request #86 from ydb-platform/add-sample-logger

Add simple logger

Author: ilyakharev

CHANGELOG.md

@@ -1,4 +1,7 @@
+* added simple std looger
+
 ## 1.7.0
+
 * added environment credentials
 
 ## 1.6.0

src/Logger/SimpleStdLogger.php

@@ -0,0 +1,80 @@
+<?php
+
+namespace YdbPlatform\Ydb\Logger;
+
+class SimpleStdLogger implements \Psr\Log\LoggerInterface
+{
+    const DEBUG = 7;
+    const INFO = 6;
+    const NOTICE = 5;
+    const WARNING = 4;
+    const ERROR = 3;
+    const CRITICAL = 2;
+    const ALERT = 1;
+    const EMERGENCY = 0;
+
+    protected static $levels = [
+        self::DEBUG     => 'DEBUG',
+        self::INFO      => 'INFO',
+        self::NOTICE    => 'NOTICE',
+        self::WARNING   => 'WARNING',
+        self::ERROR     => 'ERROR',
+        self::CRITICAL  => 'CRITICAL',
+        self::ALERT     => 'ALERT',
+        self::EMERGENCY => 'EMERGENCY',
+    ];
+
+    protected $level;
+    public function __construct(int $level)
+    {
+        $this->level = $level;
+    }
+
+    public function emergency($message, array $context = []): void
+    {
+        $this->log(self::EMERGENCY, $message, $context);
+    }
+
+    public function alert($message, array $context = []): void
+    {
+        $this->log(self::EMERGENCY, $message, $context);
+    }
+
+    public function critical($message, array $context = []): void
+    {
+        $this->log(self::EMERGENCY, $message, $context);
+    }
+
+    public function error($message, array $context = []): void
+    {
+        $this->log(self::EMERGENCY, $message, $context);
+    }
+
+    public function warning($message, array $context = []): void
+    {
+        $this->log(self::EMERGENCY, $message, $context);
+    }
+
+    public function notice($message, array $context = []): void
+    {
+        $this->log(self::EMERGENCY, $message, $context);
+    }
+
+    public function info($message, array $context = []): void
+    {
+        $this->log(self::EMERGENCY, $message, $context);
+    }
+
+    public function debug($message, array $context = []): void
+    {
+        $this->log(self::EMERGENCY, $message, $context);
+    }
+
+    public function log($level, $message, array $context = []): void
+    {
+        if ($level>$this->level) return;
+        fwrite(STDERR,
+            date("d/m/y H:i")." ".$level. " ".$message." ".json_encode($context)
+        );
+    }
+}

src/Ydb.php

@@ -11,6 +11,7 @@
 use YdbPlatform\Ydb\Exceptions\Ydb\SessionExpiredException;
 use YdbPlatform\Ydb\Retry\Retry;
 use YdbPlatform\Ydb\Retry\RetryParams;
+use YdbPlatform\Ydb\Logger\NullLogger;
 
 require "Version.php";
 
@@ -91,7 +92,11 @@ public function __construct($config = [], LoggerInterface $logger = null)
         $this->database = $config['database'] ?? null;
         $this->iam_config = $config['iam_config'] ?? [];
 
-        $this->logger = $logger;
+        if ($logger){
+            $this->logger = $logger;
+        } else {
+            $this->logger = new NullLogger();
+        }
 
         if(isset($config['credentials'])){
             $this->iam_config['credentials'] = $config['credentials'];