Generate Exceptions (#921)

* Generate Exceptions

* Add documentation on top of class

* Leverage the new AwsErrorFactory

* Fix __constructor signature in  GeneratedException

* Fix private vs protected

* Generate all methods

* Fix things

* Add constraint in composer.Json

* Add changelog entry

Author: jderusse

CHANGELOG.md

@@ -6,6 +6,7 @@
 
 - Changed case of object's properties to camelCase.
 - Added documentation in class's headers.
+- Added Business Exceptions.
 
 ## 1.2.0
 

composer.json

@@ -13,7 +13,7 @@
     "require": {
         "php": "^7.2.5 || ^8.0",
         "ext-json": "*",
-        "async-aws/core": "^1.2"
+        "async-aws/core": "^1.9"
     },
     "extra": {
         "branch-alias": {

src/Enum/ThrottleReason.php

@@ -0,0 +1,23 @@
+<?php
+
+namespace AsyncAws\Lambda\Enum;
+
+final class ThrottleReason
+{
+    public const CALLER_RATE_LIMIT_EXCEEDED = 'CallerRateLimitExceeded';
+    public const CONCURRENT_INVOCATION_LIMIT_EXCEEDED = 'ConcurrentInvocationLimitExceeded';
+    public const FUNCTION_INVOCATION_RATE_LIMIT_EXCEEDED = 'FunctionInvocationRateLimitExceeded';
+    public const RESERVED_FUNCTION_CONCURRENT_INVOCATION_LIMIT_EXCEEDED = 'ReservedFunctionConcurrentInvocationLimitExceeded';
+    public const RESERVED_FUNCTION_INVOCATION_RATE_LIMIT_EXCEEDED = 'ReservedFunctionInvocationRateLimitExceeded';
+
+    public static function exists(string $value): bool
+    {
+        return isset([
+            self::CALLER_RATE_LIMIT_EXCEEDED => true,
+            self::CONCURRENT_INVOCATION_LIMIT_EXCEEDED => true,
+            self::FUNCTION_INVOCATION_RATE_LIMIT_EXCEEDED => true,
+            self::RESERVED_FUNCTION_CONCURRENT_INVOCATION_LIMIT_EXCEEDED => true,
+            self::RESERVED_FUNCTION_INVOCATION_RATE_LIMIT_EXCEEDED => true,
+        ][$value]);
+    }
+}

src/Exception/CodeStorageExceededException.php

@@ -0,0 +1,34 @@
+<?php
+
+namespace AsyncAws\Lambda\Exception;
+
+use AsyncAws\Core\Exception\Http\ClientException;
+use Symfony\Contracts\HttpClient\ResponseInterface;
+
+/**
+ * You have exceeded your maximum total code size per account. Learn more.
+ *
+ * @see https://docs.aws.amazon.com/lambda/latest/dg/limits.html
+ */
+final class CodeStorageExceededException extends ClientException
+{
+    /**
+     * The exception type.
+     */
+    private $type;
+
+    public function getType(): ?string
+    {
+        return $this->type;
+    }
+
+    protected function populateResult(ResponseInterface $response): void
+    {
+        $data = $response->toArray(false);
+
+        $this->type = isset($data['Type']) ? (string) $data['Type'] : null;
+        if (null !== $v = (isset($data['message']) ? (string) $data['message'] : null)) {
+            $this->message = $v;
+        }
+    }
+}

src/Exception/EC2AccessDeniedException.php

@@ -0,0 +1,29 @@
+<?php
+
+namespace AsyncAws\Lambda\Exception;
+
+use AsyncAws\Core\Exception\Http\ServerException;
+use Symfony\Contracts\HttpClient\ResponseInterface;
+
+/**
+ * Need additional permissions to configure VPC settings.
+ */
+final class EC2AccessDeniedException extends ServerException
+{
+    private $type;
+
+    public function getType(): ?string
+    {
+        return $this->type;
+    }
+
+    protected function populateResult(ResponseInterface $response): void
+    {
+        $data = $response->toArray(false);
+
+        $this->type = isset($data['Type']) ? (string) $data['Type'] : null;
+        if (null !== $v = (isset($data['message']) ? (string) $data['message'] : null)) {
+            $this->message = $v;
+        }
+    }
+}

src/Exception/EC2ThrottledException.php

@@ -0,0 +1,30 @@
+<?php
+
+namespace AsyncAws\Lambda\Exception;
+
+use AsyncAws\Core\Exception\Http\ServerException;
+use Symfony\Contracts\HttpClient\ResponseInterface;
+
+/**
+ * AWS Lambda was throttled by Amazon EC2 during Lambda function initialization using the execution role provided for
+ * the Lambda function.
+ */
+final class EC2ThrottledException extends ServerException
+{
+    private $type;
+
+    public function getType(): ?string
+    {
+        return $this->type;
+    }
+
+    protected function populateResult(ResponseInterface $response): void
+    {
+        $data = $response->toArray(false);
+
+        $this->type = isset($data['Type']) ? (string) $data['Type'] : null;
+        if (null !== $v = (isset($data['message']) ? (string) $data['message'] : null)) {
+            $this->message = $v;
+        }
+    }
+}

src/Exception/EC2UnexpectedException.php

@@ -0,0 +1,37 @@
+<?php
+
+namespace AsyncAws\Lambda\Exception;
+
+use AsyncAws\Core\Exception\Http\ServerException;
+use Symfony\Contracts\HttpClient\ResponseInterface;
+
+/**
+ * AWS Lambda received an unexpected EC2 client exception while setting up for the Lambda function.
+ */
+final class EC2UnexpectedException extends ServerException
+{
+    private $type;
+
+    private $ec2ErrorCode;
+
+    public function getEc2ErrorCode(): ?string
+    {
+        return $this->ec2ErrorCode;
+    }
+
+    public function getType(): ?string
+    {
+        return $this->type;
+    }
+
+    protected function populateResult(ResponseInterface $response): void
+    {
+        $data = $response->toArray(false);
+
+        $this->type = isset($data['Type']) ? (string) $data['Type'] : null;
+        if (null !== $v = (isset($data['message']) ? (string) $data['message'] : null)) {
+            $this->message = $v;
+        }
+        $this->ec2ErrorCode = isset($data['EC2ErrorCode']) ? (string) $data['EC2ErrorCode'] : null;
+    }
+}

src/Exception/EFSIOException.php

@@ -0,0 +1,29 @@
+<?php
+
+namespace AsyncAws\Lambda\Exception;
+
+use AsyncAws\Core\Exception\Http\ClientException;
+use Symfony\Contracts\HttpClient\ResponseInterface;
+
+/**
+ * An error occured when reading from or writing to a connected file system.
+ */
+final class EFSIOException extends ClientException
+{
+    private $type;
+
+    public function getType(): ?string
+    {
+        return $this->type;
+    }
+
+    protected function populateResult(ResponseInterface $response): void
+    {
+        $data = $response->toArray(false);
+
+        $this->type = isset($data['Type']) ? (string) $data['Type'] : null;
+        if (null !== $v = (isset($data['message']) ? (string) $data['message'] : null)) {
+            $this->message = $v;
+        }
+    }
+}

src/Exception/EFSMountConnectivityException.php

@@ -0,0 +1,29 @@
+<?php
+
+namespace AsyncAws\Lambda\Exception;
+
+use AsyncAws\Core\Exception\Http\ClientException;
+use Symfony\Contracts\HttpClient\ResponseInterface;
+
+/**
+ * The function couldn't make a network connection to the configured file system.
+ */
+final class EFSMountConnectivityException extends ClientException
+{
+    private $type;
+
+    public function getType(): ?string
+    {
+        return $this->type;
+    }
+
+    protected function populateResult(ResponseInterface $response): void
+    {
+        $data = $response->toArray(false);
+
+        $this->type = isset($data['Type']) ? (string) $data['Type'] : null;
+        if (null !== $v = (isset($data['message']) ? (string) $data['message'] : null)) {
+            $this->message = $v;
+        }
+    }
+}

src/Exception/EFSMountFailureException.php

@@ -0,0 +1,29 @@
+<?php
+
+namespace AsyncAws\Lambda\Exception;
+
+use AsyncAws\Core\Exception\Http\ClientException;
+use Symfony\Contracts\HttpClient\ResponseInterface;
+
+/**
+ * The function couldn't mount the configured file system due to a permission or configuration issue.
+ */
+final class EFSMountFailureException extends ClientException
+{
+    private $type;
+
+    public function getType(): ?string
+    {
+        return $this->type;
+    }
+
+    protected function populateResult(ResponseInterface $response): void
+    {
+        $data = $response->toArray(false);
+
+        $this->type = isset($data['Type']) ? (string) $data['Type'] : null;
+        if (null !== $v = (isset($data['message']) ? (string) $data['message'] : null)) {
+            $this->message = $v;
+        }
+    }
+}

src/Exception/EFSMountTimeoutException.php

@@ -0,0 +1,29 @@
+<?php
+
+namespace AsyncAws\Lambda\Exception;
+
+use AsyncAws\Core\Exception\Http\ClientException;
+use Symfony\Contracts\HttpClient\ResponseInterface;
+
+/**
+ * The function was able to make a network connection to the configured file system, but the mount operation timed out.
+ */
+final class EFSMountTimeoutException extends ClientException
+{
+    private $type;
+
+    public function getType(): ?string
+    {
+        return $this->type;
+    }
+
+    protected function populateResult(ResponseInterface $response): void
+    {
+        $data = $response->toArray(false);
+
+        $this->type = isset($data['Type']) ? (string) $data['Type'] : null;
+        if (null !== $v = (isset($data['message']) ? (string) $data['message'] : null)) {
+            $this->message = $v;
+        }
+    }
+}

src/Exception/ENILimitReachedException.php

@@ -0,0 +1,30 @@
+<?php
+
+namespace AsyncAws\Lambda\Exception;
+
+use AsyncAws\Core\Exception\Http\ServerException;
+use Symfony\Contracts\HttpClient\ResponseInterface;
+
+/**
+ * AWS Lambda was not able to create an elastic network interface in the VPC, specified as part of Lambda function
+ * configuration, because the limit for network interfaces has been reached.
+ */
+final class ENILimitReachedException extends ServerException
+{
+    private $type;
+
+    public function getType(): ?string
+    {
+        return $this->type;
+    }
+
+    protected function populateResult(ResponseInterface $response): void
+    {
+        $data = $response->toArray(false);
+
+        $this->type = isset($data['Type']) ? (string) $data['Type'] : null;
+        if (null !== $v = (isset($data['message']) ? (string) $data['message'] : null)) {
+            $this->message = $v;
+        }
+    }
+}

src/Exception/InvalidParameterValueException.php

@@ -0,0 +1,32 @@
+<?php
+
+namespace AsyncAws\Lambda\Exception;
+
+use AsyncAws\Core\Exception\Http\ClientException;
+use Symfony\Contracts\HttpClient\ResponseInterface;
+
+/**
+ * One of the parameters in the request is invalid.
+ */
+final class InvalidParameterValueException extends ClientException
+{
+    /**
+     * The exception type.
+     */
+    private $type;
+
+    public function getType(): ?string
+    {
+        return $this->type;
+    }
+
+    protected function populateResult(ResponseInterface $response): void
+    {
+        $data = $response->toArray(false);
+
+        $this->type = isset($data['Type']) ? (string) $data['Type'] : null;
+        if (null !== $v = (isset($data['message']) ? (string) $data['message'] : null)) {
+            $this->message = $v;
+        }
+    }
+}

src/Exception/InvalidRequestContentException.php

@@ -0,0 +1,32 @@
+<?php
+
+namespace AsyncAws\Lambda\Exception;
+
+use AsyncAws\Core\Exception\Http\ClientException;
+use Symfony\Contracts\HttpClient\ResponseInterface;
+
+/**
+ * The request body could not be parsed as JSON.
+ */
+final class InvalidRequestContentException extends ClientException
+{
+    /**
+     * The exception type.
+     */
+    private $type;
+
+    public function getType(): ?string
+    {
+        return $this->type;
+    }
+
+    protected function populateResult(ResponseInterface $response): void
+    {
+        $data = $response->toArray(false);
+
+        $this->type = isset($data['Type']) ? (string) $data['Type'] : null;
+        if (null !== $v = (isset($data['message']) ? (string) $data['message'] : null)) {
+            $this->message = $v;
+        }
+    }
+}