Merge pull request Napp#4 from trybeapp/daemon-pr

Add daemon submitter

Author: Mads Møller

README.md

@@ -123,6 +123,24 @@ The above results in:
 
 ![XML-example](https://raw.githubusercontent.com/Napp/xray-laravel/master/docs/xray-xml-example.png)
 
+## Daemon support
+
+The X-Ray daemon is automatically run in a Lambda environment. Use this over the default `Napp\Xray\Submission\APISegmentSubmitter` to relay requests to Amazon X-Ray.
+
+Firstly, publish the X-Ray config and then update the submitter in `config/xray.php` to `\Napp\Xray\Submission\DaemonSegmentSubmitter::class`
+
+```console
+php artisan vendor:publish --tag=xray-config
+```
+
+```php
+# config/xray.php
+...
+ 'submitter' => \Napp\Xray\Submission\DaemonSegmentSubmitter::class,
+...
+```
+
+The daemon submitter will pick up the `_AWS_XRAY_DAEMON_ADDRESS` `_AWS_XRAY_DAEMON_PORT`. These environment variables are injected for you if using a service like [Laravel Vapor](https://vapor.laravel.com/)
 
 ## Disable Tracer
 

src/Submission/DaemonSegmentSubmitter.php

@@ -0,0 +1,59 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Napp\Xray\Submission;
+
+use Pkerrigan\Xray\Segment;
+use Pkerrigan\Xray\Submission\DaemonSegmentSubmitter as SubmissionDaemonSegmentSubmitter;
+use Pkerrigan\Xray\Submission\SegmentSubmitter;
+
+class DaemonSegmentSubmitter implements SegmentSubmitter
+{
+    /**
+     * @var SubmissionDaemonSegmentSubmitter
+     */
+    private $submitter;
+
+    /**
+     * @var string
+     */
+    private $host;
+
+    /**
+     * @var int
+     */
+    private $port;
+
+    public function __construct()
+    {
+        $this->host = env('_AWS_XRAY_DAEMON_ADDRESS');
+        $this->port = (int) env('_AWS_XRAY_DAEMON_PORT');
+    }
+
+    /**
+     * Get or create the Daemon submitter.
+     *
+     * @return SubmissionDaemonSegmentSubmitter
+     */
+    protected function submitter(): SubmissionDaemonSegmentSubmitter
+    {
+        if (is_null($this->submitter)) {
+            $this->submitter = new SubmissionDaemonSegmentSubmitter(
+                $this->host,
+                $this->port
+            );
+        }
+
+        return $this->submitter;
+    }
+
+    /**
+     * @param Segment $segment
+     * @return void
+     */
+    public function submitSegment(Segment $segment)
+    {
+        $this->submitter()->submitSegment($segment);
+    }
+}