Merge pull request #10 from cgauge/console-logger

Provide Console Socket

src/Providers/ApmServiceProvider.php

@@ -3,6 +3,7 @@
 namespace CustomerGauge\Logstash\Providers;
 
 use CustomerGauge\Logstash\Sockets\ApmSocket;
+use CustomerGauge\Logstash\Sockets\ConsoleApmSocket;
 use CustomerGauge\Logstash\Sockets\HttpApmSocket;
 use CustomerGauge\Logstash\Sockets\QueueApmSocket;
 use Illuminate\Config\Repository;
@@ -44,6 +45,16 @@ public function register()
 
             return new QueueApmSocket($socket);
         });
+
+        $this->app->bind(ConsoleApmSocket::class, function () {
+            $config = $this->app->make(Repository::class);
+
+            $processor = $config->get('logging.processor.console');
+
+            $socket = $this->prepareSocketWithProcessors($processor);
+
+            return new ConsoleApmSocket($socket);
+        });
     }
 
     private function prepareSocketWithProcessors(?string $processor): ApmSocket

src/Sockets/ConsoleApmSocket.php

@@ -0,0 +1,18 @@
+<?php declare(strict_types=1);
+
+namespace CustomerGauge\Logstash\Sockets;
+
+final class ConsoleApmSocket
+{
+    public ApmSocket $socket;
+
+    public function __construct(ApmSocket $socket)
+    {
+        $this->socket = $socket;
+    }
+
+    public function handle(array $record): bool
+    {
+        return $this->socket->handle($record);
+    }
+}