Merge pull request #19 from xp-forge/refactor/extract-to-aws-core

Extract AWS core library

Author: thekid

README.md

@@ -142,32 +142,35 @@ $ aws lambda update-function-configuration \
 
 Using other AWS services
 ------------------------
-In order to programmatically use other AWS services such as SQS with the [AWS SDK for PHP](https://docs.aws.amazon.com/sdk-for-php/index.html), pass the credentials via environment:
+In order to programmatically use other AWS services use the *ServiceEndpoint* class:
 
 ```php
-use Aws\Sqs\SqsClient;
-use Aws\Credentials\CredentialProvider;
+use com\amazon\aws\{Credentials, ServiceEndpoint};
 use com\amazon\aws\lambda\Handler;
 
-class Trigger extends Handler {
+class Streaming extends Handler {
 
   /** @return com.amazon.aws.lambda.Lambda|callable */
   public function target() {
-    $queue= new SqsClient([
-      'version'     => '2012-11-05',
-      'region'      => $this->environment->variable('AWS_REGION'),
-      'credentials' => CredentialProvider::env(),
-    ]);
-
-    // ...omitted for brevity...
+    return function($event, $context) {
+
+      // Send message to WebSocket connection
+      (new ServiceEndpoint('execute-api', $this->environment->credentials()))
+        ->in($context->region)
+        ->using($event['requestContext']['apiId'])
+        ->resource('/{stage}/@connections/{connectionId}', $event['requestContext'])
+        ->transmit(['message' => 'Reply'])
+      ;
+      return ['statusCode' => 200];
+    };
   }
 }
 ```
 
 To test this locally, pass the necessary environment variables via *-e* on the command line:
 
 ```bash
-$ xp lambda test -e AWS_ACCESS_KEY_ID=... -e AWS_SECRET_ACCESS_KEY=... Trigger
+$ xp lambda test -e AWS_ACCESS_KEY_ID=... -e AWS_SECRET_ACCESS_KEY=... Streaming '{"requestContext":...}'
 # ...
 ```
 
@@ -216,7 +219,7 @@ public class com.amazon.aws.lambda.Environment {
   public function path(string $path): io.Path
   public function tempDir(): io.Path
   public function variable(string $name): ?string
-  public function credentials(): com.amazon.aws.lambda.Credentials
+  public function credentials(): com.amazon.aws.Credentials
   public function trace(var... $args): void
   public function properties(string $name): util.PropertyAccess
 }

composer.json

@@ -9,6 +9,7 @@
     "xp-framework/core": "^11.0 | ^10.14",
     "xp-framework/http": "^10.0 | ^9.0",
     "xp-framework/zip": "^10.0 | ^9.0",
+    "xp-forge/aws": "^1.0",
     "xp-forge/json": "^5.0 | ^4.0",
     "php": ">=7.0.0"
   },

src/main/php/com/amazon/aws/lambda/Credentials.class.php

@@ -1,5 +1,6 @@
 <?php namespace com\amazon\aws\lambda;
 
+use com\amazon\aws\Credentials;
 use io\Path;
 use io\streams\StringWriter;
 use lang\{ElementNotFoundException, Environment as System};
@@ -50,7 +51,7 @@ public function variable($name) {
   /**
    * Returns credentials from this environment
    *
-   * @return com.amazon.aws.lambda.Credentials
+   * @return com.amazon.aws.Credentials
    */
   public function credentials() {
     return new Credentials(

src/main/php/com/amazon/aws/lambda/Environment.class.php

@@ -1,6 +1,7 @@
 <?php namespace com\amazon\aws\lambda\unittest;
 
-use com\amazon\aws\lambda\{Environment, Credentials};
+use com\amazon\aws\Credentials;
+use com\amazon\aws\lambda\Environment;
 use io\streams\{MemoryOutputStream, StringWriter};
 use io\{File, Files, Path};
 use lang\ElementNotFoundException;