Updated Span Converter

Author: riticksingh

composer.json

@@ -36,6 +36,8 @@
             "OpenTelemetry\\Contrib\\": "contrib",
             "Opentelemetry\\Proto\\Collector\\Trace\\V1\\": "proto/Opentelemetry/Proto/Collector/Trace/V1",
             "Opentelemetry\\Proto\\Trace\\V1\\":"proto/Opentelemetry/Proto/Trace/V1",
+            "Opentelemetry\\Proto\\Common\\V1\\":"proto/Opentelemetry/Proto/Common/V1",
+            "Opentelemetry\\Proto\\Resource\\V1\\":"proto/Opentelemetry/Proto/Resource/V1",
             "GPBMetadata\\Opentelemetry\\Proto\\Collector\\Trace\\V1\\": "proto/GPBMetadata/Opentelemetry/Proto/Collector/Trace/V1",
             "GPBMetadata\\Opentelemetry\\Proto\\Trace\\V1\\":"proto/GPBMetadata/Opentelemetry/Proto/Trace/V1",
             "GPBMetadata\\Opentelemetry\\Proto\\Common\\V1\\":"proto/GPBMetadata/Opentelemetry/Proto/Common/V1",

contrib/OtlpGrpc/Exporter.php

@@ -2,7 +2,7 @@
 
 declare(strict_types=1);
 namespace OpenTelemetry\Contrib\OtlpGrpc;
-//require __DIR__ . '/../../vendor/autoload.php';
+require __DIR__ . '/../../vendor/autoload.php';
 
 
 use grpc;
@@ -106,6 +106,7 @@ public function export(iterable $spans): int
         foreach ($spans as $span) {
             array_push($convertedSpans, $this->spanConverter->convert($span));
         }
+        echo "$convertedSpans";
 
         $request= new V1\ExportTraceServiceRequest();
         $request->setResourceSpans($convertedSpans);

contrib/OtlpGrpc/SpanConverter.php

@@ -4,8 +4,10 @@
 
 namespace OpenTelemetry\Contrib\OtlpGrpc;
 
-//use OpenTelemetry\Trace\Span;
-use Opentelemetry\Proto\Trace\V1\InstrumentationLibrarySpans as Span;
+use OpenTelemetry\Trace\Span;
+use Opentelemetry\Proto\Trace\V1\Span as CollectorSpan;
+use Opentelemetry\Proto\Trace\V1\Status\StatusCode;
+use Opentelemetry\Proto\Trace\V1\Status;
 
 class SpanConverter
 {
@@ -54,6 +56,7 @@ public function convert(Span $span)
             'name' => $span->getSpanName(),
             'timestamp' => (int) ($span->getStartEpochTimestamp() / 1e3), // RealtimeClock in microseconds
             'duration' => (int) (($span->getEnd() - $span->getStart()) / 1e3), // Diff in microseconds
+
         ];
 
         foreach ($span->getAttributes() as $k => $v) {
@@ -73,6 +76,33 @@ public function convert(Span $span)
             ];
         }
 
+        foreach ($span->getLinks() as $link) {
+            if (!array_key_exists('link', $row)) {
+                $row['link'] = [];
+            }
+            $row['link'][] = [
+                'trace_id' => $span->getContext()->getTraceId(),
+                'span_id' => $span->getContext()->getSpanId(),
+            ];
+        }
+        if (!array_key_exists('status', $row)) {
+                $proto_status = StatusCode::STATUS_CODE_OK;
+                //////
+                /////HIGHLIGHTED
+                ////
+                ///
+                if ($span->getStatus()->getCanonicalStatusCode() === "ERROR") {
+                    $proto_status = StatusCode::STATUS_CODE_ERROR;
+                }
+                $status=new Status();
+                $row['status']=$status->setCode('$proto_status')->setMessage("Description");
+            }
+
         return $row;
     }
 }
+            // $key=new keyValue();
+            // $key->setKey("id")
+            // $value=new AnyValue();
+            // $value->setStringValue($span->getContext()->getSpanId());
+            // $key->setValue($value);