Merge pull request #20 from xp-forge/feature/endpoint

Add Environment::endpoint() to return AWS service endpoints

Author: thekid

README.md

@@ -155,7 +155,7 @@ class Streaming extends Handler {
     return function($event, $context) {
 
       // Send message to WebSocket connection
-      (new ServiceEndpoint('execute-api', $this->environment->credentials()))
+      $this->environment->endpoint('execute-api')
         ->in($context->region)
         ->using($event['requestContext']['apiId'])
         ->resource('/{stage}/@connections/{connectionId}', $event['requestContext'])

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

@@ -1,6 +1,6 @@
 <?php namespace com\amazon\aws\lambda;
 
-use com\amazon\aws\Credentials;
+use com\amazon\aws\{Credentials, ServiceEndpoint};
 use io\Path;
 use io\streams\StringWriter;
 use lang\{ElementNotFoundException, Environment as System};
@@ -61,6 +61,16 @@ public function credentials() {
     );
   }
 
+  /**
+   * Returns an endpoint for a given service
+   *
+   * @param  string $service
+   * @return com.amazon.aws.ServiceEndpoint
+   */
+  public function endpoint($service) {
+    return new ServiceEndpoint($service, $this->credentials());
+  }
+
   /**
    * Writes a trace message
    *

src/test/php/com/amazon/aws/lambda/unittest/EnvironmentTest.class.php

@@ -1,7 +1,7 @@
 <?php namespace com\amazon\aws\lambda\unittest;
 
-use com\amazon\aws\Credentials;
 use com\amazon\aws\lambda\Environment;
+use com\amazon\aws\{Credentials, ServiceEndpoint};
 use io\streams\{MemoryOutputStream, StringWriter};
 use io\{File, Files, Path};
 use lang\ElementNotFoundException;
@@ -73,6 +73,18 @@ public function credentials_with_session() {
     );
   }
 
+  #[Test]
+  public function endpoint() {
+    Assert::equals(
+      'id.execute-api.us-east-1.amazonaws.com',
+      (new Environment('.', null, ['AWS_ACCESS_KEY_ID' => '*', 'AWS_SECRET_ACCESS_KEY' => '*']))
+        ->endpoint('execute-api')
+        ->in('us-east-1')
+        ->using('id')
+        ->domain()
+    );
+  }
+
   #[Test]
   public function trace() {
     $stream= new MemoryOutputStream();