Adds laravel instrumentation

composer.json

@@ -34,7 +34,9 @@
         "psr/http-server-middleware": "^1.0",
         "middlewares/fast-route": "^1.2.1",
         "middlewares/request-handler": "^1.4.0",
-        "squizlabs/php_codesniffer": "3.*"
+        "squizlabs/php_codesniffer": "3.*",
+        "illuminate/http": "^7.20",
+        "illuminate/routing": "^7.20"
     },
     "config": {
         "sort-packages": true

src/Zipkin/Instrumentation/Laravel/Middleware.php

@@ -0,0 +1,107 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Zipkin\Instrumentation\Laravel;
+
+use Zipkin\Tracing;
+use Zipkin\Tracer;
+use Zipkin\SpanCustomizerShield;
+use Zipkin\Span;
+use Zipkin\Propagation\TraceContext;
+use Zipkin\Propagation\SamplingFlags;
+use Zipkin\Propagation\DefaultSamplingFlags;
+use Zipkin\Kind;
+use Zipkin\Instrumentation\Laravel\Propagation\RequestHeaders;
+use Zipkin\Instrumentation\Http\Server\HttpServerTracing;
+use Throwable;
+use Illuminate\Http\Request;
+use Closure;
+
+class Middleware
+{
+    /**
+     * @var Tracer
+     */
+    private $tracer;
+
+    /**
+     * @var callable(array):?bool
+     */
+    private $extractor;
+
+    /**
+     * @var Parser
+     */
+    private $parser;
+
+    /**
+     * @var (callable(Request):?bool)|null
+     */
+    private $requestSampler;
+
+    public function __construct(HttpServerTracing $tracing)
+    {
+        $this->tracer = $tracing->getTracing()->getTracer();
+        $this->extractor = $tracing->getTracing()->getPropagation()->getExtractor(new RequestHeaders());
+        $this->parser = $tracing->getParser();
+        $this->requestSampler = $tracing->getRequestSampler();
+    }
+
+    public static function createFromTracing(Tracing $tracing): self
+    {
+        return new self(new HttpServerTracing($tracing, new DefaultParser));
+    }
+
+    public function handle(Request $request, Closure $next)
+    {
+        $extractedContext = ($this->extractor)($request);
+
+        $span = $this->nextSpan($extractedContext, $request);
+        $scopeCloser = $this->tracer->openScope($span);
+
+        if ($span->isNoop()) {
+            try {
+                return $next($request);
+            } finally {
+                $span->finish();
+                $scopeCloser();
+            }
+        }
+
+        $span->setKind(Kind\SERVER);
+        $spanCustomizer = new SpanCustomizerShield($span);
+        $span->setName($this->parser->spanName($request));
+        $this->parser->request($request, $span->getContext(), $spanCustomizer);
+
+        try {
+            $response = $next($request);
+            $this->parser->response($response, $span->getContext(), $spanCustomizer);
+            return $response;
+        } catch (Throwable $e) {
+            $span->setError($e);
+            throw $e;
+        } finally {
+            $span->finish();
+            $scopeCloser();
+        }
+    }
+
+    private function nextSpan(?SamplingFlags $extractedContext, Request $request): Span
+    {
+        if ($extractedContext instanceof TraceContext) {
+            return $this->tracer->joinSpan($extractedContext);
+        }
+
+        $extractedContext = $extractedContext ?? DefaultSamplingFlags::createAsEmpty();
+        if ($this->requestSampler === null) {
+            return $this->tracer->nextSpan($extractedContext);
+        }
+
+        return $this->tracer->nextSpanWithSampler(
+            $this->requestSampler,
+            [$request],
+            $extractedContext
+        );
+    }
+}

src/Zipkin/Instrumentation/Laravel/Propagation/RequestHeaders.php

@@ -0,0 +1,21 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Zipkin\Instrumentation\Laravel\Propagation;
+
+use Zipkin\Propagation\Getter;
+use Illuminate\Http\Request;
+
+final class RequestHeaders implements Getter
+{
+    /**
+     * {@inheritdoc}
+     *
+     * @param Request $carrier
+     */
+    public function get($carrier, string $key): ?string
+    {
+        return $carrier->hasHeader($key) ? $carrier->header($key)[0] : null;
+    }
+}

src/Zipkin/Instrumentation/Laravel/Request.php

@@ -0,0 +1,55 @@
+<?php
+
+namespace ZipkinBundle;
+
+use Zipkin\Instrumentation\Http\Server\Request as ServerRequest;
+use Illuminate\Http\Request as IlluminateHttpRequest;
+
+class Request extends ServerRequest
+{
+    /**
+     * @var IlluminateHttpRequest
+     */
+    private $delegate;
+
+    private $route;
+
+    public function __construct(IlluminateHttpRequest $delegate)
+    {
+        $this->delegate = $delegate;
+    }
+
+    public function getMethod(): string
+    {
+        return $this->delegate->getMethod();
+    }
+
+    public function getPath(): ?string
+    {
+        return $this->delegate->getPathInfo() ?: '/';
+    }
+
+    public function getUrl(): string
+    {
+        return $this->delegate->getUri();
+    }
+
+    public function getHeader(string $name): string
+    {
+        return $this->delegate->headers->get($name);
+    }
+
+    /**
+     * @return IlluminateHttpRequest
+     */
+    public function unwrap()
+    {
+        return $this->delegate;
+    }
+
+    public function getRoute(): ?string
+    {
+
+        return $this->delegate->route()->uri;
+    }
+}

src/Zipkin/Instrumentation/Laravel/Response.php

@@ -0,0 +1,33 @@
+<?php
+
+namespace ZipkinBundle;
+
+use Zipkin\Instrumentation\Http\Server\Response as ServerResponse;
+use Symfony\Component\HttpFoundation\Response as HttpFoundationResponse;
+use Symfony\Component\HttpFoundation\Request as HttpFoundationRequest;
+
+class Response extends ServerResponse
+{
+    /**
+     * @var HttpFoundationResponse
+     */
+    private $delegate;
+
+    public function __construct(HttpFoundationResponse $delegate)
+    {
+        $this->delegate = $delegate;
+    }
+
+    public function getStatusCode(): int
+    {
+        return $this->delegate->getStatusCode();
+    }
+
+    /**
+     * @return HttpFoundationRequest
+     */
+    public function unwrap()
+    {
+        return $this->delegate;
+    }
+}