Merge branch 'main' into e2e/vigy/clear-env-issue

Author: vigy02

.changeset/early-starfishes-impress.md

@@ -0,0 +1,5 @@
+---
+'@aws-amplify/ai-constructs': patch
+---
+
+Fix case where bedrock content blocks would be populated with 'null' instead of 'undefined.

.changeset/modern-toys-jump.md

@@ -0,0 +1,5 @@
+---
+'@aws-amplify/backend-deployer': patch
+---
+
+detect more generic CFN deployment failure errors

.changeset/seven-rabbits-poke.md

@@ -103,6 +103,7 @@
   "mysql",
   "namespace",
   "namespaces",
+  "netstat",
   "nodejs",
   "nodenext",
   "nodir",

.eslint_dictionary.json

@@ -1,4 +1,5 @@
 # Ignore artifacts:
+.amplify
 build
 coverage
 bin
@@ -10,6 +11,7 @@ verdaccio-cache
 expected-cdk-out
 .changeset/pre.json
 concurrent_workspace_script_cache.json
+packages/integration-tests/src/e2e-tests
 scripts/components/api-changes-validator/test-resources/working-directory
 /test-projects
-testDir
+testDir

.prettierignore

@@ -6,16 +6,19 @@
 
 /// <reference types="node" />
 
+import { AIConversationOutput } from '@aws-amplify/backend-output-schemas';
+import { BackendOutputStorageStrategy } from '@aws-amplify/plugin-types';
 import * as bedrock from '@aws-sdk/client-bedrock-runtime';
 import { Construct } from 'constructs';
 import { FunctionResources } from '@aws-amplify/plugin-types';
+import * as jsonSchemaToTypeScript from 'json-schema-to-ts';
 import { ResourceProvider } from '@aws-amplify/plugin-types';
-import * as smithy from '@smithy/types';
 
 declare namespace __export__conversation {
     export {
         ConversationHandlerFunction,
-        ConversationHandlerFunctionProps
+        ConversationHandlerFunctionProps,
+        ConversationTurnEventVersion
     }
 }
 export { __export__conversation }
@@ -25,10 +28,12 @@ declare namespace __export__conversation__runtime {
         ConversationMessage,
         ConversationMessageContentBlock,
         ConversationTurnEvent,
+        createExecutableTool,
         ExecutableTool,
+        FromJSONSchema,
+        JSONSchema,
         handleConversationTurnEvent,
         ToolDefinition,
-        ToolExecutionInput,
         ToolInputSchema,
         ToolResultContentBlock
     }
@@ -39,6 +44,8 @@ export { __export__conversation__runtime }
 class ConversationHandlerFunction extends Construct implements ResourceProvider<FunctionResources> {
     constructor(scope: Construct, id: string, props: ConversationHandlerFunctionProps);
     // (undocumented)
+    static readonly eventVersion: ConversationTurnEventVersion;
+    // (undocumented)
     resources: FunctionResources;
 }
 
@@ -49,6 +56,7 @@ type ConversationHandlerFunctionProps = {
         modelId: string;
         region?: string;
     }>;
+    outputStorageStrategy?: BackendOutputStorageStrategy<AIConversationOutput>;
 };
 
 // @public (undocumented)
@@ -64,6 +72,12 @@ type ConversationMessageContentBlock = bedrock.ContentBlock | {
             bytes: string;
         };
     };
+    text?: never;
+    document?: never;
+    toolUse?: never;
+    toolResult?: never;
+    guardContent?: never;
+    $unknown?: never;
 };
 
 // @public (undocumented)
@@ -87,11 +101,16 @@ type ConversationTurnEvent = {
         };
     };
     request: {
-        headers: {
-            authorization: string;
-        };
+        headers: Record<string, string>;
+    };
+    messages?: Array<ConversationMessage>;
+    messageHistoryQuery: {
+        getQueryName: string;
+        getQueryInputTypeName: string;
+        listQueryName: string;
+        listQueryInputTypeName: string;
+        listQueryLimit?: number;
     };
-    messages: Array<ConversationMessage>;
     toolsConfiguration?: {
         dataTools?: Array<ToolDefinition & {
             graphqlRequestInputDescriptor: {
@@ -105,27 +124,38 @@ type ConversationTurnEvent = {
 };
 
 // @public (undocumented)
-type ExecutableTool = ToolDefinition & {
-    execute: (input: ToolExecutionInput | undefined) => Promise<ToolResultContentBlock>;
+type ConversationTurnEventVersion = `1.${number}`;
+
+// @public
+const createExecutableTool: <TJSONSchema extends JSONSchema = JSONSchema, TToolInput = FromJSONSchema<TJSONSchema>>(name: string, description: string, inputSchema: ToolInputSchema<TJSONSchema>, handler: (input: TToolInput) => Promise<bedrock.ToolResultContentBlock>) => ExecutableTool<TJSONSchema, TToolInput>;
+
+// @public (undocumented)
+type ExecutableTool<TJSONSchema extends JSONSchema = JSONSchema, TToolInput = FromJSONSchema<TJSONSchema>> = ToolDefinition<TJSONSchema> & {
+    execute: (input: TToolInput) => Promise<ToolResultContentBlock>;
 };
 
+// @public (undocumented)
+type FromJSONSchema<TJSONSchema extends JSONSchema> = jsonSchemaToTypeScript.FromSchema<TJSONSchema>;
+
 // @public
 const handleConversationTurnEvent: (event: ConversationTurnEvent, props?: {
-    tools?: Array<ExecutableTool>;
+    tools?: Array<ExecutableTool<JSONSchema, any>>;
 }) => Promise<void>;
 
 // @public (undocumented)
-type ToolDefinition = {
+type JSONSchema = jsonSchemaToTypeScript.JSONSchema;
+
+// @public (undocumented)
+type ToolDefinition<TJSONSchema extends JSONSchema = JSONSchema> = {
     name: string;
     description: string;
-    inputSchema: ToolInputSchema;
+    inputSchema: ToolInputSchema<TJSONSchema>;
 };
 
 // @public (undocumented)
-type ToolExecutionInput = smithy.DocumentType;
-
-// @public (undocumented)
-type ToolInputSchema = bedrock.ToolInputSchema;
+type ToolInputSchema<TJSONSchema extends JSONSchema> = {
+    json: TJSONSchema;
+};
 
 // @public (undocumented)
 type ToolResultContentBlock = bedrock.ToolResultContentBlock;

package-lock.json

@@ -1,5 +1,34 @@
 # @aws-amplify/ai-constructs
 
+## 0.4.0
+
+### Minor Changes
+
+- 4781704: Add information about event version to conversation components
+- 3a29d43: Pass user agent in conversation handler lambda
+
+### Patch Changes
+
+- 6e4a62f: Fix multi tool usage in single turn.
+
+## 0.3.0
+
+### Minor Changes
+
+- 300a72d: Infer executable tool input type from input schema
+- 0a5e51c: Stream conversation logs in sandbox
+
+### Patch Changes
+
+- Updated dependencies [0a5e51c]
+  - @aws-amplify/backend-output-schemas@1.3.0
+
+## 0.2.0
+
+### Minor Changes
+
+- d0a90b1: Use message history instead of event payload for conversational route
+
 ## 0.1.4
 
 ### Patch Changes

packages/ai-constructs/API.md

@@ -1,6 +1,6 @@
 {
   "name": "@aws-amplify/ai-constructs",
-  "version": "0.1.4",
+  "version": "0.4.0",
   "type": "commonjs",
   "publishConfig": {
     "access": "public"
@@ -26,9 +26,16 @@
   },
   "license": "Apache-2.0",
   "dependencies": {
+    "@aws-amplify/backend-output-schemas": "^1.3.0",
+    "@aws-amplify/platform-core": "^1.1.0",
     "@aws-amplify/plugin-types": "^1.0.1",
     "@aws-sdk/client-bedrock-runtime": "^3.622.0",
-    "@smithy/types": "^3.3.0"
+    "@smithy/types": "^3.3.0",
+    "json-schema-to-ts": "^3.1.1"
+  },
+  "devDependencies": {
+    "@aws-amplify/backend-output-storage": "^1.1.2",
+    "typescript": "^5.0.0"
   },
   "peerDependencies": {
     "aws-cdk-lib": "^2.152.0",

packages/ai-constructs/CHANGELOG.md

@@ -4,6 +4,7 @@ import { App, Stack } from 'aws-cdk-lib';
 import { ConversationHandlerFunction } from './conversation_handler_construct';
 import { Template } from 'aws-cdk-lib/assertions';
 import path from 'path';
+import { StackMetadataBackendOutputStorageStrategy } from '@aws-amplify/backend-output-storage';
 
 void describe('Conversation Handler Function construct', () => {
   void it('creates handler with log group with JWT token redacting policy', () => {
@@ -140,6 +141,56 @@ void describe('Conversation Handler Function construct', () => {
     });
   });
 
+  void it('does not store output if output strategy is absent', () => {
+    const app = new App();
+    const stack = new Stack(app);
+    new ConversationHandlerFunction(stack, 'conversationHandler', {
+      models: [
+        {
+          modelId: 'testModelId',
+        },
+      ],
+      outputStorageStrategy: undefined,
+    });
+    const template = Template.fromStack(stack);
+    const output = template.findOutputs(
+      'definedConversationHandlers'
+    ).definedConversationHandlers;
+    assert.ok(!output);
+  });
+
+  void it('stores output if output strategy is present', () => {
+    const app = new App();
+    const stack = new Stack(app);
+    new ConversationHandlerFunction(stack, 'conversationHandler', {
+      models: [
+        {
+          modelId: 'testModelId',
+        },
+      ],
+      outputStorageStrategy: new StackMetadataBackendOutputStorageStrategy(
+        stack
+      ),
+    });
+    const template = Template.fromStack(stack);
+    const outputValue = template.findOutputs('definedConversationHandlers')
+      .definedConversationHandlers.Value;
+    assert.deepStrictEqual(outputValue, {
+      'Fn::Join': [
+        '',
+        [
+          '["',
+          {
+            /* eslint-disable spellcheck/spell-checker */
+            Ref: 'conversationHandlerconversationHandlerFunction45BC2E1F',
+            /* eslint-enable spellcheck/spell-checker */
+          },
+          '"]',
+        ],
+      ],
+    });
+  });
+
   void it('throws if entry is not absolute', () => {
     const app = new App();
     const stack = new Stack(app);