feat: dark visitors analytics

.gitignore

@@ -41,3 +41,4 @@
 /~
 /content/phpunit/.lock
 /site/config
+/.ddev

composer.json

@@ -15,13 +15,12 @@
         "psr-4": {
             "mauricerenck\\DarkVisitors\\": "plugin"
         },
-        "classmap": [
-            "plugin"
-        ]
+        "classmap": ["plugin"]
     },
     "require": {
         "getkirby/composer-installer": "^1.2",
-        "php": ">=8.0.0"
+        "php": ">=8.0.0",
+        "amphp/amp": "^3.0"
     },
     "require-dev": {
         "getkirby/cms": "^4",
@@ -34,17 +33,10 @@
         }
     },
     "scripts": {
-        "start": [
-            "Composer\\Config::disableProcessTimeout",
-            "php -S localhost:8000 kirby/router.php"
-        ],
+        "start": ["Composer\\Config::disableProcessTimeout", "php -S localhost:8000 kirby/router.php"],
         "test": "vendor/bin/phpunit --testdox --colors=always tests",
         "build-test-package": "git archive HEAD -o dark-visitors.zip --worktree-attributes",
         "build-composer": "composer install --no-dev --optimize-autoloader",
-        "build-release": [
-            "composer test",
-            "composer install --no-dev --optimize-autoloader",
-            "npm run build"
-        ]
+        "build-release": ["composer install --no-dev --optimize-autoloader"]
     }
-}
+}

index.php

@@ -4,6 +4,7 @@
 
 use Kirby;
 use Kirby\Http\Response;
+use Amp;
 
 @include_once __DIR__ . '/vendor/autoload.php';
 
@@ -39,5 +40,32 @@
                 return new Response(join("\n", $robotTxt), 'text/plain', 200);
             },
         ],
+        [
+            'pattern' => '(:any)',
+            'method' => 'GET',
+            'action' => function () {
+                $request = kirby()->request();
+                $api = new Api();
+
+                if (option('mauricerenck.dark-visitors.analytics', false)) {
+                    $requestPath = $request->path();
+                    $requestMethod = $request->method();
+                    $requestHeaders = $request->headers();
+
+                    try {
+                        $future = Amp\async(function () use ($api, $requestPath, $requestMethod, $requestHeaders) {
+                            $result = $api->trackAgent($requestPath, $requestMethod, $requestHeaders);
+                            return $result;
+                        });
+
+                        $future->await();
+                    } catch (\Throwable $e) {
+                        echo 'Error' . $e->getMessage();
+                    }
+                }
+
+                $this->next();
+            },
+        ],
     ],
 ]);

plugin/Api.php

@@ -56,4 +56,19 @@ public function getLatestAgents()
 
         return $request->content();
     }
+
+    public function trackAgent($requestPath, $requestMethod, $requestHeaders)
+    {
+        $body = [
+            'request_path' => $requestPath,
+            'request_method' => $requestMethod,
+            'request_headers' => $requestHeaders,
+        ];
+
+        return Remote::request('https://api.darkvisitors.com/visits', [
+            'method' => 'POST',
+            'headers' => ['Content-Type: application/json', 'Authorization: Bearer ' . $this->token],
+            'data' => json_encode($body),
+        ]);
+    }
 }

vendor/amphp/amp/src/Cancellation.php

@@ -0,0 +1,41 @@
+<?php declare(strict_types=1);
+
+namespace Amp;
+
+/**
+ * Cancellations are simple objects that allow registering handlers to subscribe to cancellation requests.
+ */
+interface Cancellation
+{
+    /**
+     * Subscribes a new handler to be invoked on a cancellation request.
+     *
+     * This handler might be invoked immediately in case the cancellation has already been requested. Any unhandled
+     * exceptions will be thrown into the event loop.
+     *
+     * @param \Closure(CancelledException) $callback Callback to be invoked on a cancellation request. Will receive a
+     * `CancelledException` as first argument that may be used to fail the operation.
+     *
+     * @return string Identifier that can be used to cancel the subscription.
+     */
+    public function subscribe(\Closure $callback): string;
+
+    /**
+     * Unsubscribes a previously registered handler.
+     *
+     * The handler will no longer be called as long as this method isn't invoked from a subscribed callback.
+     */
+    public function unsubscribe(string $id): void;
+
+    /**
+     * Returns whether cancellation has been requested yet.
+     */
+    public function isRequested(): bool;
+
+    /**
+     * Throws the `CancelledException` if cancellation has been requested, otherwise does nothing.
+     *
+     * @throws CancelledException
+     */
+    public function throwIfRequested(): void;
+}

vendor/amphp/amp/src/CancelledException.php

@@ -0,0 +1,17 @@
+<?php declare(strict_types=1);
+
+namespace Amp;
+
+/**
+ * Will be thrown in case an operation is cancelled.
+ *
+ * @see Cancellation
+ * @see DeferredCancellation
+ */
+class CancelledException extends \Exception
+{
+    public function __construct(?\Throwable $previous = null)
+    {
+        parent::__construct("The operation was cancelled", 0, $previous);
+    }
+}

vendor/amphp/amp/src/Closable.php

@@ -0,0 +1,26 @@
+<?php declare(strict_types=1);
+
+namespace Amp;
+
+interface Closable
+{
+    /**
+     * Closes the resource, marking it as unusable.
+     * Whether pending operations are aborted or not is implementation dependent.
+     */
+    public function close(): void;
+
+    /**
+     * Returns whether this resource has been closed.
+     *
+     * @return bool `true` if closed, otherwise `false`.
+     */
+    public function isClosed(): bool;
+
+    /**
+     * Registers a callback that is invoked when this resource is closed.
+     *
+     * @param \Closure():void $onClose
+     */
+    public function onClose(\Closure $onClose): void;
+}