apigw-lambda-sfn-transcribe-translate-polly-sam: Update runtime to nodejs22.x

apigw-lambda-sfn-transcribe-translate-polly-sam/README.md

@@ -60,7 +60,7 @@ API Gateway handles incoming traffic and sends it to the lambda which in turn in
 
 Follow the steps to test the pattern:
 
-1. Copy the audio to the input bucket (available from the output of the cloudformation stack).
+1. Copy the audio to the input bucket (available from the output of the CloudFormation stack).
     ```bash
     aws s3 cp audio.ogg s3://{input-bucket-name}
     ```
@@ -70,7 +70,7 @@ Follow the steps to test the pattern:
     ```
 1. Run websocket client to invoke the API Gateway. Get the API ID from the output of the deployment step
     ```bash
-    wscat -c  wss://<API-ID>.execute-api.<Region>.amazonaws.com/dev?proto=https
+    wscat -c wss://<API-ID>.execute-api.<Region>.amazonaws.com/dev?proto=https
     ```
 1. On the next prompt, add the input parameters. Replace the input bucket name. It can be tested with other language codes as well.
     ```bash
@@ -90,4 +90,4 @@ Follow the steps to test the pattern:
 ----
 Copyright 2023 Amazon.com, Inc. or its affiliates. All Rights Reserved.
 
-SPDX-License-Identifier: MIT-0
+SPDX-License-Identifier: MIT-0

apigw-lambda-sfn-transcribe-translate-polly-sam/src/invokeTranslator.js

@@ -1,7 +1,8 @@
-const AWS = require('aws-sdk');
-const stepfunctions = new AWS.StepFunctions();
-const apig = new AWS.ApiGatewayManagementApi({
-    endpoint: process.env.APIG_ENDPOINT,
+const { SFNClient, StartSyncExecutionCommand } = require('@aws-sdk/client-sfn');
+const { ApiGatewayManagementApiClient, PostToConnectionCommand } = require('@aws-sdk/client-apigatewaymanagementapi');
+const stepfunctions = new SFNClient({});
+const apig = new ApiGatewayManagementApiClient({
+    endpoint: `https://${process.env.APIG_ENDPOINT}`,
   });
 
 module.exports.handler = async (event, context) => {
@@ -25,12 +26,11 @@ module.exports.handler = async (event, context) => {
       stateMachineArn: process.env.statemachine_arn,
       input: body
   }
-  let response = await stepfunctions.startSyncExecution(params).promise();
-  await apig
-    .postToConnection({
+  let response = await stepfunctions.send(new StartSyncExecutionCommand(params));
+  await apig.send(new PostToConnectionCommand({
         ConnectionId: connectionId,
         Data: response?JSON.stringify( {"url" : JSON.parse(response.output).url} ):"No data"
-    }).promise();
+    }));
   if ( response && response.output)
     response = {"url" : JSON.parse(response.output).url}
   return {

apigw-lambda-sfn-transcribe-translate-polly-sam/src/speech.js

@@ -1,7 +1,10 @@
-const AWS = require('aws-sdk');
-const s3 = new AWS.S3();
-const polly = new AWS.Polly();
-const uuidv1 = require('uuidv1');
+const { S3Client, PutObjectCommand } = require('@aws-sdk/client-s3');
+const { PollyClient, SynthesizeSpeechCommand } = require('@aws-sdk/client-polly');
+const { getSignedUrl } = require('@aws-sdk/s3-request-presigner');
+const { GetObjectCommand } = require('@aws-sdk/client-s3');
+const { randomUUID } = require('crypto');
+const s3 = new S3Client({});
+const polly = new PollyClient({});
 
 
 module.exports.handler = async (event, context) => {
@@ -62,21 +65,28 @@ module.exports.handler = async (event, context) => {
 
     console.log(speechParams)
 
-    const response = await polly.synthesizeSpeech(speechParams).promise();
+    const response = await polly.send(new SynthesizeSpeechCommand(speechParams));
     let audioStream = response.AudioStream;
-    let key = uuidv1();
+
+    const chunks = [];
+    for await (const chunk of audioStream) {
+        chunks.push(chunk);
+    }
+    const audioBuffer = Buffer.concat(chunks);
+
+    let key = randomUUID();
     let params = {
       Bucket: outputBucket,
       Key: key + '.mp3',
-      Body: audioStream
+      Body: audioBuffer
     };
 
-    const s3Response = await s3.putObject(params).promise();
+    const s3Response = await s3.send(new PutObjectCommand(params));
     let s3params = {
         Bucket: outputBucket,
         Key: key + '.mp3',
       };
-    let url = s3.getSignedUrl("getObject", s3params);
+    let url = await getSignedUrl(s3, new GetObjectCommand(s3params));
     console.log(url);
     return { url, outputBucket, key: key + '.mp3' };
-}
+}

apigw-lambda-sfn-transcribe-translate-polly-sam/src/transcribeCheck.js

@@ -1,5 +1,5 @@
-const AWS = require('aws-sdk');
-const transcribe = new AWS.TranscribeService();
+const { TranscribeClient, GetTranscriptionJobCommand } = require('@aws-sdk/client-transcribe');
+const transcribe = new TranscribeClient({});
 
 module.exports.handler = async (event, context) => {
     console.log(event)
@@ -12,7 +12,7 @@ module.exports.handler = async (event, context) => {
         TranscriptionJobName: jobName
     };
 
-    let jobData = await transcribe.getTranscriptionJob(params).promise();
+    let jobData = await transcribe.send(new GetTranscriptionJobCommand(params));
     let jobStatus = jobData.TranscriptionJob.TranscriptionJobStatus;
     if ( jobStatus == 'COMPLETED' || jobStatus == 'FAILED') {
         let s3Loc = jobData.TranscriptionJob.Transcript.TranscriptFileUri;
@@ -25,4 +25,4 @@ module.exports.handler = async (event, context) => {
     else {
         return { continue: true, jobName, outputBucket, inputLanguageCode, outputLanguageCode }
     }
-}
+}

apigw-lambda-sfn-transcribe-translate-polly-sam/src/transcribeLaunch.js

@@ -1,6 +1,6 @@
 const path = require('path');
-const AWS = require('aws-sdk');
-const transcribe = new AWS.TranscribeService();
+const { TranscribeClient, StartTranscriptionJobCommand } = require('@aws-sdk/client-transcribe');
+const transcribe = new TranscribeClient({});
 
 module.exports.handler = async (event, context) => {
   console.log(event)
@@ -25,6 +25,6 @@ module.exports.handler = async (event, context) => {
     OutputBucketName: OUTPUT_BUCKET
   };
   console.log(params);
-  await transcribe.startTranscriptionJob(params).promise();
+  await transcribe.send(new StartTranscriptionJobCommand(params));
   return { jobName, outputBucket:OUTPUT_BUCKET, inputLanguageCode, outputLanguageCode };
 };

apigw-lambda-sfn-transcribe-translate-polly-sam/src/translate.js

@@ -1,6 +1,7 @@
-const AWS = require('aws-sdk');
-const s3 = new AWS.S3();
-const translate = new AWS.Translate();
+const { S3Client, GetObjectCommand } = require('@aws-sdk/client-s3');
+const { TranslateClient, TranslateTextCommand } = require('@aws-sdk/client-translate');
+const s3 = new S3Client({});
+const translate = new TranslateClient({});
 
 
 module.exports.handler = async (event, context) => {
@@ -102,18 +103,18 @@ module.exports.handler = async (event, context) => {
         }
     }
 
-    const s3Body = await s3.getObject(params).promise()
-    const transcribedOutput = s3Body.Body.toString('utf-8');
+    const s3Body = await s3.send(new GetObjectCommand(params))
+    const transcribedOutput = await s3Body.Body.transformToString();
     console.log(transcribedOutput)
     const originalText = JSON.parse(transcribedOutput).results.transcripts[0].transcript;
     let translateParams = {
         Text: originalText,
         SourceLanguageCode: sourceLanguageCode,
         TargetLanguageCode: targetLanguageCode
       }
-    const translatedResponse = await translate.translateText(translateParams).promise();
+    const translatedResponse = await translate.send(new TranslateTextCommand(translateParams));
     const translatedText = translatedResponse.TranslatedText
     console.log(translatedText)
     return { translatedText, outputBucket, outputLanguageCode }
 
-}
+}

apigw-lambda-sfn-transcribe-translate-polly-sam/template.yaml

@@ -54,7 +54,7 @@ Resources:
     Properties:
       Handler: src/transcribeLaunch.handler
       FunctionName: "translator-dev-transcribeLaunch"
-      Runtime: nodejs20.x
+      Runtime: nodejs22.x
       Architectures:
         - x86_64
       MemorySize: 128
@@ -65,7 +65,7 @@ Resources:
     Properties:
       Handler: src/transcribeCheck.handler
       FunctionName: "translator-dev-transcribeCheck"
-      Runtime: nodejs20.x
+      Runtime: nodejs22.x
       Architectures:
         - x86_64
       MemorySize: 128
@@ -76,7 +76,7 @@ Resources:
     Properties:
       Handler: src/translate.handler
       FunctionName: "translator-dev-translate"
-      Runtime: nodejs20.x
+      Runtime: nodejs22.x
       Architectures:
         - x86_64
       MemorySize: 128
@@ -87,7 +87,7 @@ Resources:
     Properties:
       Handler: src/speech.handler
       FunctionName: "translator-dev-speech"
-      Runtime: nodejs20.x
+      Runtime: nodejs22.x
       Architectures:
         - x86_64
       MemorySize: 128
@@ -111,7 +111,7 @@ Resources:
   InvokerLambda:
     Type: AWS::Serverless::Function
     Properties:
-      Runtime: "nodejs16.x"
+      Runtime: "nodejs22.x"
       FunctionName: "translator-dev-invokeTranslator"
       Timeout: 300
       MemorySize: 1024
@@ -134,7 +134,7 @@ Resources:
     Type: AWS::Lambda::Function
     Properties:
       FunctionName: "translator-dev-authorizer"
-      Runtime: "nodejs18.x"
+      Runtime: "nodejs22.x"
       Timeout: 300
       MemorySize: 1024
       Handler: index.handler