Add bref-local-handler.php to invoke bref handlers locally (#71)

* Add bref-local-handler.php to invoke bref handlers locally

* Dont use Invoker

Author: Nyholm

src/bref/bin/bref-local-handler.php

@@ -0,0 +1,58 @@
+#!/usr/bin/env php
+<?php
+
+if ($argc < 2) {
+    error_log("bref-local-handler.php must be invoked with at least one argument: \n./vendor/bin/bref-local-handler.php ./bin/container.php:App\\Service\\MyService [data or file path]");
+    exit(1);
+}
+
+/*
+ * Set the correct runtime
+ */
+if (!isset($_SERVER['APP_RUNTIME'])) {
+    $_SERVER['APP_RUNTIME'] = \Runtime\Bref\Runtime::class;
+}
+
+$config = [
+    'bref_runner_type' => 'local',
+];
+
+/*
+ * Handle first argument and prepare "handler"
+ */
+$handler = $argv[1];
+if (!isset($_SERVER['_HANDLER'])) {
+    $_SERVER['_HANDLER'] = $handler;
+}
+
+if (false === $pos = strpos($handler, ':')) {
+    $file = $handler;
+} else {
+    $file = substr($handler, 0, $pos);
+}
+$_SERVER['SCRIPT_FILENAME'] = $file;
+
+/*
+ * Handle second argument which is that data or a file with the data
+ */
+if (isset($argv[2])) {
+    $json = $argv[2];
+    if (is_file($json)) {
+        $json = file_get_contents($json);
+    }
+
+    try {
+        $data = json_decode($json, true, 512, JSON_THROW_ON_ERROR);
+    } catch (JsonException $e) {
+        throw new Exception('The JSON provided for the event data is invalid JSON.');
+    }
+
+    $config['bref_local_runner_data'] = $data;
+}
+
+/*
+ * Dump all options to APP_RUNTIME_OPTIONS
+ */
+$_SERVER['APP_RUNTIME_OPTIONS'] = array_merge($config, $_SERVER['APP_RUNTIME_OPTIONS'] ?? []);
+
+include $file;

src/bref/composer.json

@@ -32,5 +32,8 @@
         }
     },
     "minimum-stability": "dev",
-    "prefer-stable": true
+    "prefer-stable": true,
+    "bin": [
+        "bin/bref-local-handler.php"
+    ]
 }

src/bref/src/LocalRunner.php

@@ -0,0 +1,31 @@
+<?php
+
+namespace Runtime\Bref;
+
+use Bref\Context\Context;
+use Bref\Event\Handler;
+use Symfony\Component\Runtime\RunnerInterface;
+
+/**
+ * This will run BrefHandlers for local development.
+ *
+ * @author Tobias Nyholm <[email protected]>
+ */
+class LocalRunner implements RunnerInterface
+{
+    private $handler;
+    private $data;
+
+    public function __construct(Handler $handler, $data)
+    {
+        $this->handler = $handler;
+        $this->data = $data;
+    }
+
+    public function run(): int
+    {
+        $this->handler->handle($this->data, new Context('', 0, '', ''));
+
+        return 0;
+    }
+}

src/bref/src/Runtime.php

@@ -14,14 +14,20 @@
 
 class Runtime extends SymfonyRuntime
 {
+    private $handlerRunnerClass;
+
     /**
      * @param array{
      *   bref_loop_max?: int,
+     *   bref_runner_type?: string,
+     *   bref_local_runner_data?: mixed,
      * } $options
      */
     public function __construct(array $options = [])
     {
         $options['bref_loop_max'] = $options['bref_loop_max'] ?? $_SERVER['BREF_LOOP_MAX'] ?? $_ENV['BREF_LOOP_MAX'] ?? 1;
+        $options['bref_runner_type'] = $options['bref_runner_type'] ?? $_SERVER['BREF_RUNNER_TYPE'] ?? $_ENV['BREF_RUNNER_TYPE'] ?? 'aws';
+        $options['bref_local_runner_data'] = $options['bref_local_runner_data'] ?? $_SERVER['BREF_LOCAL_RUNNER_DATA'] ?? $_ENV['BREF_LOCAL_RUNNER_DATA'] ?? [];
         parent::__construct($options);
     }
 
@@ -48,7 +54,13 @@ public function getRunner(?object $application): RunnerInterface
         }
 
         if ($application instanceof Handler) {
-            return new BrefRunner($application, $this->options['bref_loop_max']);
+            if ('aws' === $this->options['bref_runner_type']) {
+                return new BrefRunner($application, $this->options['bref_loop_max']);
+            } elseif ('local' === $this->options['bref_runner_type']) {
+                return new LocalRunner($application, $this->options['bref_local_runner_data']);
+            } else {
+                throw new \InvalidArgumentException(sprintf('Value "%s" of "bref_runner_type" is not supported.', $this->options['bref_runner_type']));
+            }
         }
 
         if ($application instanceof Application) {