Implement xp lambda run [Handler] to run lambdas locally

Author: thekid

src/main/php/xp/lambda/RunLambda.class.php

@@ -0,0 +1,61 @@
+<?php namespace xp\lambda;
+
+use com\amazon\aws\lambda\{Environment, Context};
+use lang\{XPClass, Throwable};
+use util\UUID;
+use util\cmd\Console;
+
+/**
+ * Run lambdas locally
+ *
+ * @see https://docs.aws.amazon.com/de_de/lambda/latest/dg/runtimes-api.html
+ */
+class RunLambda {
+  const TRACE_ID= 'Root=1-5bef4de7-ad49b0e87f6ef6c87fc2e700;Parent=9a9197af755a6419;Sampled=1';
+
+  private $impl, $length, $event;
+
+  /**
+   * Creates a new `run` subcommand
+   *
+   * @param  string $handler
+   * @param  ?string $event
+   * @throws lang.ClassLoadingException
+   */
+  public function __construct($handler, $event= null) {
+    $this->impl= XPClass::forName($handler);
+    if (null === $event) {
+      $this->length= 0;
+      $this->event= null;
+    } else {
+      $this->length= strlen($event);
+      $this->event= json_decode($event, true);
+    }    
+  }
+
+  /** Runs this command */
+  public function run(): int {
+    $name= $this->impl->getSimpleName();
+    $region= getenv('AWS_REGION') ?: 'test-local-1';
+    $context= new Context(
+      [
+        'Lambda-Runtime-Aws-Request-Id'       => [UUID::randomUUID()->hashCode()],
+        'Lambda-Runtime-Invoked-Function-Arn' => ["arn:aws:lambda:{$region}:123456789012:function:{$name}"],
+        'Lambda-Runtime-Trace-Id'             => [self::TRACE_ID],
+        'Lambda-Runtime-Deadline-Ms'          => [(time() + 900) * 1000],
+        'Content-Length'                      => [$this->length],
+      ],
+      $_ENV + ['AWS_LAMBDA_FUNCTION_NAME' => $name, 'AWS_REGION' => $region]
+    );
+    
+    try {
+      $lambda= $this->impl->newInstance(new Environment(getcwd(), Console::$out, []))->target();
+      $result= $lambda instanceof Lambda ? $lambda->process($this->event, $context) : $lambda($this->event, $context);
+      Console::$out->writeLine($result);
+      return 0;
+    } catch (Throwable $e) {
+      Console::$err->writeLine($e);
+      return 1;
+    }
+  }
+}

src/main/php/xp/lambda/Runner.class.php

@@ -8,35 +8,39 @@
  * XP AWS Lambda
  * =============
  *
- * - Store runtime layer as `runtime-X.X.X.zip`, building if necessary:
+ * - Run lambda locally:
  *   ```sh
- *   $ xp lambda runtime
+ *   $ xp lambda run Greet '{"name":"Test"}'
  *   ```
- * - Rebuild runtime:
+ * - Package single file in `function.zip` file for deployment:
  *   ```sh
- *   $ xp lambda runtime -b
+ *   $ xp lambda package Greet.class.php
  *   ```
- * - Speficy runtime version, selecting newest PHP 8.0 release:
+ * - Package INI file and source directory in `function.zip`:
  *   ```sh
- *   $ xp lambda runtime:8.0
+ *   $ xp lambda package task.ini src/main/php
  *   ```
- * - Test lambda:
+ * - Test lambda inside a containerized AWS environment:
  *   ```sh
  *   $ xp lambda test Greet '{"name":"Test"}'
  *   ```
  * - Test lambda, pass environment variables:
  *   ```sh
  *   $ xp lambda test -e PROFILE=prod Audit
  *   ```
- * - Package single file in `function.zip` file for deployment:
+ * - Store runtime layer as `runtime-X.X.X.zip`, building if necessary:
  *   ```sh
- *   $ xp lambda package Greet.class.php
+ *   $ xp lambda runtime
  *   ```
- * - Package INI file and source directory in `function.zip`:
+ * - Rebuild runtime:
  *   ```sh
- *   $ xp lambda package task.ini src/main/php
+ *   $ xp lambda runtime -b
+ *   ```
+ * - Speficy runtime version, selecting newest PHP 8.0 release:
+ *   ```sh
+ *   $ xp lambda runtime:8.0
  *   ```
- * The `runtime` and `test` commands require Docker or Podman to be installed!
+ * The `test` and `runtime` commands require Docker or Podman to be installed!
  * Packaging will always include the `vendor` directory automatically.
  */
 class Runner {
@@ -66,6 +70,7 @@ private static function command(string $name, array $args): object {
     sscanf($name, "%[^:]:%[^\r]", $command, $version);
     switch ($command) {
       case 'package': return new PackageLambda(new Path('function.zip'), new Sources(new Path('.'), [...$args, 'vendor']));
+      case 'run': return new RunLambda($args[0], $args[1] ?? null);
       case 'runtime': return new CreateRuntime(self::resolve($version), new Path('runtime-%s.zip'), in_array('-b', $args));
       case 'test': return new TestLambda(self::resolve($version), new Path('.'), $args);
       default: return new DisplayError('Unknown command "'.$args[0].'"');