1 files changed, 96 insertions, 0 deletions
diff --git a/vendor/open-telemetry/sdk/Trace/SpanExporter/LoggerExporter.php b/vendor/open-telemetry/sdk/Trace/SpanExporter/LoggerExporter.php
new file mode 100644
index 000000000..1969a5426
--- /dev/null
+++ b/vendor/open-telemetry/sdk/Trace/SpanExporter/LoggerExporter.php
@@ -0,0 +1,96 @@
+<?php
+
+declare(strict_types=1);
+
+namespace OpenTelemetry\SDK\Trace\SpanExporter;
+
+use OpenTelemetry\SDK\Trace\Behavior\LoggerAwareTrait;
+use OpenTelemetry\SDK\Trace\Behavior\SpanExporterTrait;
+use OpenTelemetry\SDK\Trace\Behavior\UsesSpanConverterTrait;
+use OpenTelemetry\SDK\Trace\SpanConverterInterface;
+use OpenTelemetry\SDK\Trace\SpanExporterInterface;
+use Psr\Log\LoggerAwareInterface;
+use Psr\Log\LoggerInterface;
+use Psr\Log\LogLevel;
+use Psr\Log\NullLogger;
+use Throwable;
+
+class LoggerExporter implements SpanExporterInterface, LoggerAwareInterface
+{
+    use SpanExporterTrait;
+    use UsesSpanConverterTrait;
+    use LoggerAwareTrait;
+
+    public const GRANULARITY_AGGREGATE = 1;
+    public const GRANULARITY_SPAN = 2;
+
+    private string $serviceName;
+    private int $granularity = self::GRANULARITY_AGGREGATE;
+
+    /**
+     * @param string $serviceName
+     * @param LoggerInterface|null $logger
+     * @param string|null $defaultLogLevel
+     * @param SpanConverterInterface|null $converter
+     * @param int $granularity
+     */
+    public function __construct(
+        string $serviceName,
+        ?LoggerInterface $logger = null,
+        ?string $defaultLogLevel = LogLevel::DEBUG,
+        ?SpanConverterInterface $converter = null,
+        int $granularity = 1
+    ) {
+        $this->setServiceName($serviceName);
+        $this->setLogger($logger ?? new NullLogger());
+        $this->setDefaultLogLevel($defaultLogLevel ?? LogLevel::DEBUG);
+        $this->setSpanConverter($converter ?? new FriendlySpanConverter());
+        $this->setGranularity($granularity);
+    }
+
+    /** @inheritDoc */
+    public function doExport(iterable $spans): bool
+    {
+        try {
+            $this->doLog($spans);
+        } catch (Throwable $t) {
+            return false;
+        }
+
+        return true;
+    }
+
+    /**
+     * @param string $serviceName
+     */
+    private function setServiceName(string $serviceName): void
+    {
+        $this->serviceName = $serviceName;
+    }
+
+    /**
+     * @param int $granularity
+     */
+    public function setGranularity(int $granularity): void
+    {
+        $this->granularity = $granularity === self::GRANULARITY_SPAN
+            ? self::GRANULARITY_SPAN
+            : self::GRANULARITY_AGGREGATE;
+    }
+
+    /**
+     * @param iterable $spans
+     */
+    private function doLog(iterable $spans): void
+    {
+        if ($this->granularity === self::GRANULARITY_AGGREGATE) {
+            $this->log($this->serviceName, $this->getSpanConverter()->convert($spans));
+
+            return;
+        }
+
+        foreach ($spans as $span) {
+            $this->log($this->serviceName, $this->getSpanConverter()->convert([$span]));
+        }
+    }
+}