Add AWS AppSyncEvent

.autover/autover.json

@@ -139,6 +139,10 @@
     {
       "Name": "Amazon.Lambda.TestTool",
       "Path": "Tools/LambdaTestTool-v2/src/Amazon.Lambda.TestTool/Amazon.Lambda.TestTool.csproj"
+    },
+	  {
+      "Name": "Amazon.Lambda.AppSyncEvents",
+      "Path": "Libraries/src/Amazon.Lambda.AppSyncEvents/Amazon.Lambda.AppSyncEvents.csproj"
     }
   ],
   "UseCommitsForChangelog": false,

.autover/changes/78ee1265-f50d-434a-b25c-fcb8e9e7a26a.json

@@ -0,0 +1,11 @@
+{
+  "Projects": [
+    {
+      "Name": "Amazon.Lambda.AppSyncEvents",
+      "Type": "Major",
+      "ChangelogMessages": [
+        "Added AppSyncResolverEvent to support direct lambda resolver"
+      ]
+    }
+  ]
+}

CONTRIBUTING.md

@@ -104,6 +104,7 @@ The available projects are:
 * Amazon.Lambda.SQSEvents
 * Amazon.Lambda.TestUtilities
 * Amazon.Lambda.TestTool.BlazorTester
+* Amazon.Lambda.AppSyncEvents
 
 The possible increment types are:
 * Patch

Libraries/Libraries.sln

@@ -123,17 +123,19 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "TestMinimalAPIApp", "test\T
 EndProject
 Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Amazon.Lambda.MQEvents", "src\Amazon.Lambda.MQEvents\Amazon.Lambda.MQEvents.csproj", "{BF85932E-2DFF-41CD-8090-A672468B8FBB}"
 EndProject
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Amazon.Lambda.LexV2Events", "src\Amazon.Lambda.LexV2Events\Amazon.Lambda.LexV2Events.csproj", "{3C6AABF5-0372-41E0-874F-DF18ECCC7FB6}"
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Amazon.Lambda.LexV2Events", "src\Amazon.Lambda.LexV2Events\Amazon.Lambda.LexV2Events.csproj", "{3C6AABF5-0372-41E0-874F-DF18ECCC7FB6}"
 EndProject
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "CustomRuntimeAspNetCoreMinimalApiCustomSerializerTest", "test\Amazon.Lambda.RuntimeSupport.Tests\CustomRuntimeAspNetCoreMinimalApiCustomSerializerTest\CustomRuntimeAspNetCoreMinimalApiCustomSerializerTest.csproj", "{0BD83939-458C-4EF5-8663-7098AD1200F2}"
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "CustomRuntimeAspNetCoreMinimalApiCustomSerializerTest", "test\Amazon.Lambda.RuntimeSupport.Tests\CustomRuntimeAspNetCoreMinimalApiCustomSerializerTest\CustomRuntimeAspNetCoreMinimalApiCustomSerializerTest.csproj", "{0BD83939-458C-4EF5-8663-7098AD1200F2}"
 EndProject
 Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "TestExecutableServerlessApp", "test\TestExecutableServerlessApp\TestExecutableServerlessApp.csproj", "{DD378063-C54A-44C7-9A6F-32A6A1AE94B3}"
 EndProject
 Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "TestServerlessApp.NET8", "test\TestServerlessApp.NET8\TestServerlessApp.NET8.csproj", "{7300983D-8FCE-42EA-9B9E-B1C5347D15D8}"
 EndProject
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "SnapshotRestore.Registry", "src\SnapshotRestore.Registry\SnapshotRestore.Registry.csproj", "{7261A438-8C1D-47AD-98B0-7678F72E4382}"
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "SnapshotRestore.Registry", "src\SnapshotRestore.Registry\SnapshotRestore.Registry.csproj", "{7261A438-8C1D-47AD-98B0-7678F72E4382}"
 EndProject
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "SnapshotRestore.Registry.Tests", "test\SnapshotRestore.Registry.Tests\SnapshotRestore.Registry.Tests.csproj", "{A699E183-D0D4-4F26-A0A7-88DA5607F455}"
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "SnapshotRestore.Registry.Tests", "test\SnapshotRestore.Registry.Tests\SnapshotRestore.Registry.Tests.csproj", "{A699E183-D0D4-4F26-A0A7-88DA5607F455}"
+EndProject
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Amazon.Lambda.AppSyncEvents", "src\Amazon.Lambda.AppSyncEvents\Amazon.Lambda.AppSyncEvents.csproj", "{99F39E49-1FD0-4EF5-BF4B-8F2473FB8198}"
 EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
@@ -369,6 +371,10 @@ Global
 		{A699E183-D0D4-4F26-A0A7-88DA5607F455}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{A699E183-D0D4-4F26-A0A7-88DA5607F455}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{A699E183-D0D4-4F26-A0A7-88DA5607F455}.Release|Any CPU.Build.0 = Release|Any CPU
+		{99F39E49-1FD0-4EF5-BF4B-8F2473FB8198}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{99F39E49-1FD0-4EF5-BF4B-8F2473FB8198}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{99F39E49-1FD0-4EF5-BF4B-8F2473FB8198}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{99F39E49-1FD0-4EF5-BF4B-8F2473FB8198}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE
@@ -435,6 +441,7 @@ Global
 		{7300983D-8FCE-42EA-9B9E-B1C5347D15D8} = {1DE4EE60-45BA-4EF7-BE00-B9EB861E4C69}
 		{7261A438-8C1D-47AD-98B0-7678F72E4382} = {AAB54E74-20B1-42ED-BC3D-CE9F7BC7FD12}
 		{A699E183-D0D4-4F26-A0A7-88DA5607F455} = {1DE4EE60-45BA-4EF7-BE00-B9EB861E4C69}
+		{99F39E49-1FD0-4EF5-BF4B-8F2473FB8198} = {AAB54E74-20B1-42ED-BC3D-CE9F7BC7FD12}
 	EndGlobalSection
 	GlobalSection(ExtensibilityGlobals) = postSolution
 		SolutionGuid = {503678A4-B8D1-4486-8915-405A3E9CF0EB}

Libraries/src/Amazon.Lambda.AppSyncEvents/Amazon.Lambda.AppSyncEvents.csproj

@@ -0,0 +1,33 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <Import Project="..\..\..\buildtools\common.props" />
+
+  <PropertyGroup>
+    <Description>Amazon Lambda .NET Core support - AWS AppSync package.</Description>
+    <TargetFrameworks>netstandard2.0;netcoreapp3.1;net8.0</TargetFrameworks>
+    <AssemblyTitle>Amazon.Lambda.AppSyncEvents</AssemblyTitle>
+    <Version>0.0.1</Version>
+    <AssemblyName>Amazon.Lambda.AppSyncEvents</AssemblyName>
+    <PackageId>Amazon.Lambda.AppSyncEvents</PackageId>
+    <PackageTags>AWS;Amazon;Lambda</PackageTags>
+  </PropertyGroup>
+
+  <!-- .NET Standard 2.0 specific settings -->
+  <PropertyGroup Condition="'$(TargetFramework)' == 'netstandard2.0'">
+    <DefineConstants>NETSTANDARD_2_0</DefineConstants>
+    <WarningsAsErrors>IL2026,IL2067,IL2075</WarningsAsErrors>
+    <IsTrimmable>true</IsTrimmable>
+    <EnableTrimAnalyzer>true</EnableTrimAnalyzer>
+  </PropertyGroup>
+
+  <!-- Newtonsoft.Json only for .NET Standard 2.0 -->
+  <ItemGroup Condition="'$(TargetFramework)' == 'netstandard2.0'">
+    <PackageReference Include="Newtonsoft.Json" Version="13.0.1" />
+  </ItemGroup>
+
+  <!-- System.Text.Json for .NET Core 3.1 and .NET 8.0 -->
+  <ItemGroup Condition="'$(TargetFramework)' == 'netcoreapp3.1' OR '$(TargetFramework)' == 'net8.0'">
+    <PackageReference Include="System.Text.Json" Version="8.0.5" />
+  </ItemGroup>
+
+</Project>

Libraries/src/Amazon.Lambda.AppSyncEvents/AppSyncAuthorizerEvent.cs

@@ -0,0 +1,40 @@
+using System.Collections.Generic;
+
+namespace Amazon.Lambda.AppSyncEvents
+{
+    // Represents an AppSync authorization event
+    public class AppSyncAuthorizerEvent
+    {
+        // The authorization token from the request
+        public string AuthorizationToken { get; set; }
+
+        // Headers from the request
+        public Dictionary<string, string> RequestHeaders { get; set; }
+
+        // Context information about the request
+        public RequestContext RequestContext { get; set; }
+    }
+
+    // Request context for AppSync authorization
+
+    public class RequestContext
+    {
+        // The ID of the AppSync API
+        public string ApiId { get; set; }
+
+        // The AWS account ID
+        public string AccountId { get; set; }
+
+        // Unique identifier for the request
+        public string RequestId { get; set; }
+
+        // The GraphQL query string
+        public string QueryString { get; set; }
+
+        // Name of the GraphQL operation
+        public string OperationName { get; set; }
+
+        /// Variables passed to the GraphQL operation.
+        public Dictionary<string, object> Variables { get; set; }
+    }
+}

Libraries/src/Amazon.Lambda.AppSyncEvents/AppSyncAuthorizerResult.cs

@@ -0,0 +1,44 @@
+using System.Collections.Generic;
+#if NETSTANDARD_2_0
+using Newtonsoft.Json;
+#else
+using System.Text.Json.Serialization;
+#endif
+
+namespace Amazon.Lambda.AppSyncEvents
+{
+    public class AppSyncAuthorizerResult
+    {
+        // Indicates if the request is authorized
+#if NETSTANDARD_2_0
+        [JsonProperty("isAuthorized")]
+#else
+        [JsonPropertyName("isAuthorized")]
+#endif
+        public bool IsAuthorized { get; set; }
+
+        // Custom context to pass to resolvers, only supports key-value pairs.
+#if NETSTANDARD_2_0
+        [JsonProperty("resolverContext")]
+#else
+        [JsonPropertyName("resolverContext")]
+#endif
+        public Dictionary<string, string> ResolverContext { get; set; }
+
+        // List of fields that are denied access
+#if NETSTANDARD_2_0
+        [JsonProperty("deniedFields")]
+#else
+        [JsonPropertyName("deniedFields")]
+#endif
+        public IEnumerable<string> DeniedFields { get; set; }
+
+        // The number of seconds that the response should be cached for
+#if NETSTANDARD_2_0
+        [JsonProperty("ttlOverride")]
+#else
+        [JsonPropertyName("ttlOverride")]
+#endif
+        public int? TtlOverride { get; set; }
+    }
+}

Libraries/src/Amazon.Lambda.AppSyncEvents/AppSyncCognitoIdentity.cs

@@ -0,0 +1,46 @@
+using System.Collections.Generic;
+
+namespace Amazon.Lambda.AppSyncEvents
+{
+    /// <summary>
+    /// Represents Amazon Cognito User Pools authorization identity for AppSync
+    /// </summary>
+    public class AppSyncCognitoIdentity
+    {
+        /// <summary>
+        /// The source IP address of the caller received by AWS AppSync
+        /// </summary>
+        public List<string> SourceIp { get; set; }
+
+        /// <summary>
+        /// The username of the authenticated user
+        /// </summary>
+        public string Username { get; set; }
+
+        /// <summary>
+        /// The UUID of the authenticated user
+        /// </summary>
+        public string Sub { get; set; }
+
+        /// <summary>
+        /// The claims that the user has
+        /// </summary>
+        public Dictionary<string, object> Claims { get; set; }
+
+        /// <summary>
+        /// The default authorization strategy for this caller (ALLOW or DENY)
+        /// </summary>
+        public string DefaultAuthStrategy { get; set; }
+
+        /// <summary>
+        /// List of OIDC groups
+        /// </summary>
+        public List<string> Groups { get; set; }
+
+        /// <summary>
+        /// The token issuer
+        /// </summary>
+        public string Issuer { get; set; }
+    }
+
+}

Libraries/src/Amazon.Lambda.AppSyncEvents/AppSyncIamIdentity.cs

@@ -0,0 +1,50 @@
+using System.Collections.Generic;
+
+namespace Amazon.Lambda.AppSyncEvents
+{
+    /// <summary>
+    /// Represents AWS IAM authorization identity for AppSync
+    /// </summary>
+    public class AppSyncIamIdentity
+    {
+        /// <summary>
+        /// The source IP address of the caller received by AWS AppSync
+        /// </summary>
+        public List<string> SourceIp { get; set; }
+
+        /// <summary>
+        /// The username of the authenticated user (IAM user principal)
+        /// </summary>
+        public string Username { get; set; }
+
+        /// <summary>
+        /// The AWS account ID of the caller
+        /// </summary>
+        public string AccountId { get; set; }
+
+        /// <summary>
+        /// The Amazon Cognito identity pool ID associated with the caller
+        /// </summary>
+        public string CognitoIdentityPoolId { get; set; }
+
+        /// <summary>
+        /// The Amazon Cognito identity ID of the caller
+        /// </summary>
+        public string CognitoIdentityId { get; set; }
+
+        /// <summary>
+        /// The ARN of the IAM user
+        /// </summary>
+        public string UserArn { get; set; }
+
+        /// <summary>
+        /// Either authenticated or unauthenticated based on the identity type
+        /// </summary>
+        public string CognitoIdentityAuthType { get; set; }
+
+        /// <summary>
+        /// A comma separated list of external identity provider information used in obtaining the credentials used to sign the request
+        /// </summary>
+        public string CognitoIdentityAuthProvider { get; set; }
+    }
+}

Libraries/src/Amazon.Lambda.AppSyncEvents/AppSyncLambdaIdentity.cs

@@ -0,0 +1,16 @@
+using System.Collections.Generic;
+
+namespace Amazon.Lambda.AppSyncEvents
+{
+    /// <summary>
+    /// Represents AWS LAMBDA authorization identity for AppSync
+    /// </summary>
+    public class AppSyncLambdaIdentity
+    {
+        /// <summary>
+        /// Optional context information that will be passed to subsequent resolvers
+        /// Can contain user information, claims, or any other contextual data
+        /// </summary>
+        public Dictionary<string, string> ResolverContext { get; set; }
+    }
+}

Libraries/src/Amazon.Lambda.AppSyncEvents/AppSyncOidcIdentity.cs

@@ -0,0 +1,25 @@
+using System.Collections.Generic;
+
+namespace Amazon.Lambda.AppSyncEvents
+{
+    /// <summary>
+    /// Represents OPENID CONNECT authorization identity for AppSync
+    /// </summary>
+    public class AppSyncOidcIdentity
+    {
+        /// <summary>
+        /// Claims from the OIDC token as key-value pairs
+        /// </summary>
+        public Dictionary<string, object> Claims { get; set; }
+
+        /// <summary>
+        /// The issuer of the OIDC token
+        /// </summary>
+        public string Issuer { get; set; }
+
+        /// <summary>
+        /// The UUID of the authenticated user
+        /// </summary>
+        public string Sub { get; set; }
+    }
+}