1 files changed, 57 insertions, 0 deletions
diff --git a/vendor/open-telemetry/sdk/Trace/SpanExporter/ConsoleSpanExporter.php b/vendor/open-telemetry/sdk/Trace/SpanExporter/ConsoleSpanExporter.php
new file mode 100644
index 000000000..482d122cc
--- /dev/null
+++ b/vendor/open-telemetry/sdk/Trace/SpanExporter/ConsoleSpanExporter.php
@@ -0,0 +1,57 @@
+<?php
+
+declare(strict_types=1);
+
+namespace OpenTelemetry\SDK\Trace\SpanExporter;
+
+use JsonException;
+use OpenTelemetry\API\Behavior\LogsMessagesTrait;
+use OpenTelemetry\SDK\Common\Export\TransportInterface;
+use OpenTelemetry\SDK\Common\Future\CancellationInterface;
+use OpenTelemetry\SDK\Common\Future\FutureInterface;
+use OpenTelemetry\SDK\Trace\Behavior\UsesSpanConverterTrait;
+use OpenTelemetry\SDK\Trace\SpanConverterInterface;
+use OpenTelemetry\SDK\Trace\SpanExporterInterface;
+
+class ConsoleSpanExporter implements SpanExporterInterface
+{
+    use UsesSpanConverterTrait;
+    use LogsMessagesTrait;
+
+    private TransportInterface $transport;
+
+    public function __construct(TransportInterface $transport, ?SpanConverterInterface $converter = null)
+    {
+        $this->transport = $transport;
+        $this->setSpanConverter($converter ?? new FriendlySpanConverter());
+    }
+
+    public function export(iterable $batch, ?CancellationInterface $cancellation = null): FutureInterface
+    {
+        $payload = '';
+        foreach ($batch as $span) {
+            try {
+                $payload .= json_encode(
+                    $this->getSpanConverter()->convert([$span]),
+                    JSON_THROW_ON_ERROR | JSON_PRETTY_PRINT
+                ) . PHP_EOL;
+            } catch (JsonException $e) {
+                self::logWarning('Error converting span: ' . $e->getMessage());
+            }
+        }
+
+        return $this->transport->send($payload)
+            ->map(fn () => true)
+            ->catch(fn () => false);
+    }
+
+    public function shutdown(?CancellationInterface $cancellation = null): bool
+    {
+        return $this->transport->shutdown();
+    }
+
+    public function forceFlush(?CancellationInterface $cancellation = null): bool
+    {
+        return $this->transport->forceFlush();
+    }
+}