{
  "Version": "2019-10-30",
  "StartAction": "start",
  "Actions": [
    {
      "Identifier": "start",
      "Type": "StartMediaStreaming",
      "Parameters": {"Audio": true},
      "Transitions": {"NextAction": "pollVoxEQ", "Errors": [{"NextAction": "fallback"}]}
    },
    {
      "Identifier": "pollVoxEQ",
      "Type": "InvokeLambdaFunction",
      "Parameters": {"FunctionArn": "arn:aws:lambda:REGION:ACCT:function:VoxEQVerdictPoller"},
      "Transitions": {"NextAction": "setAttributes", "Errors": [{"NextAction": "fallback"}], "TimeLimit": {"NextAction": "fallback"}}
    },
    {
      "Identifier": "setAttributes",
      "Type": "UpdateContactAttributes",
      "Parameters": {
        "Attributes": {
          "voxeqRisk": "$.Lambda. Result.riskScore",
          "voxeqSynthetic": "$.Lambda. Result.isSynthetic",
          "voxeqAgeGroup": "$.Lambda. Result.labels.ageGroup",
          "voxeqBirthSex": "$.Lambda. Result.labels.birthSex",
          "voxeqHeightBand": "$.Lambda. Result.labels.heightBand",
          "voxeqTone": "$.Lambda. Result.render.tone",
          "voxeqPace": "$.Lambda. Result.render.pace"
        }
      },
      "Transitions": {"NextAction": "routeRisk"}
    },
    {
      "Identifier": "routeRisk",
      "Type": "CheckAttributes",
      "Parameters": {"Conditions": [{"Attribute": "voxeqRisk", "Operator": ">=", "Value": "80"}]},
      "Transitions": {"Conditions": [{"NextAction": "queueFraud"}], "Default": "lexEntry"}
    },
    { "Identifier": "queueFraud", "Type": "TransferToQueue", "Parameters": {"Queue": "Fraud_Analyst"} },
    {
      "Identifier": "lexEntry",
      "Type": "GetCustomerInput",
      "Parameters": {
        "BotName": "YourLexV2Bot",
        "BotAlias": "prod",
        "SessionAttributes": {
          "voxeqAgeGroup": "$.Attributes.voxeqAgeGroup",
          "voxeqBirthSex": "$.Attributes.voxeqBirthSex",
          "voxeqTone": "$.Attributes.voxeqTone",
          "voxeqPace": "$.Attributes.voxeqPace"
        }
      },
      "Transitions": {"NextAction": "end", "Errors": [{"NextAction": "fallback"}], "TimeLimit": {"NextAction": "fallback"}}
    },
    { "Identifier": "fallback", "Type": "PlayPrompt", "Parameters": {"Text": "Sorry, we\nre having trouble. Please hold while we connect you."}, "Transitions": {"NextAction": "end"} },
    { "Identifier": "end", "Type": "Disconnect" }
  ]
}

// Runtime: Node.js 18
import { DynamoDBClient, PutItemCommand } from "@aws-sdk/client-dynamodb";
const ddb = new DynamoDBClient({});

export const handler = async (event) => {
  // event contains audio chunks from media streaming (decode per your stream format)
  const contactId = event.contactId;
  const audioPcm16k = extractPcmFromEvent(event); // implement decoder for your stream

  // Call your backend to invoke VoxEQ Verify + Prompt
  // Backend should POST audio bytes to VoxEQ APIs and return { riskScore, isSynthetic, labels }
  const verdict = await fetch(process.env. BACKEND_URL + "/voxeq/analyze", {
    method: "POST",
    headers: { "content-type": "application/octet-stream", "x-contact-id": contactId },
    body: audioPcm16k
  }).then(r => r.json());

  // Optional: derive rendering hints for bots/agents
  const render = deriveRender(verdict.labels); // e.g., tone = “neutral|empathetic”, pace = “slow|normal|fast”

  await ddb.send(new PutItemCommand({
    TableName: process.env. VERDICT_TABLE,
    Item: {
      ContactId: { S: contactId },
      ExpiresAt: { N: String(Math.floor(Date.now()/1000) + 120) }, // 2-minute TTL
      RiskScore: { N: String(verdict.riskScore || 0) },
      IsSynthetic: { BOOL: !!verdict.isSynthetic },
      Labels: { S: JSON.stringify(verdict.labels || {}) },
      Render: { S: JSON.stringify(render) }
    }
  }));

  return { statusCode: 200 };
};

function deriveRender(labels) {
  // Minimal example: map Prompt labels to tone/pace defaults
  const age = (labels?.ageGroup || "adult").toLowerCase();
  const tone = age === "senior" ? "respectful" : "neutral";
  const pace = age === "senior" ? "slow" : age === "youth" ? "fast" : "normal";
  return { tone, pace };
}

import { DynamoDBClient, GetItemCommand } from "@aws-sdk/client-dynamodb";
const ddb = new DynamoDBClient({});

export const handler = async (event) => {
  const contactId = event. Details?.ContactData?.ContactId;
  const out = { riskScore: 0, isSynthetic: false, labels: {}, render: { tone: "neutral", pace: "normal" } };

  if (contactId) {
    const res = await ddb.send(new GetItemCommand({
      TableName: process.env. VERDICT_TABLE,
      Key: { ContactId: { S: contactId } }
    }));
    if (res. Item) {
      out.riskScore = Number(res. Item. RiskScore. N);
      out.isSynthetic = !!res. Item. IsSynthetic. BOOL;
      out.labels = JSON.parse(res. Item. Labels. S || "{}");
      out.render = JSON.parse(res. Item. Render. S || "{}");
    }
  }

  return { // shape expected by Connect Invoke Lambda block
    riskScore: out.riskScore,
    isSynthetic: out.isSynthetic,
    labels: out.labels,
    render: out.render
  };
};

// Lex v2 Lambda code hook (simplified)
export const handler = async (event) => {
  const sa = event.sessionState?.sessionAttributes || {};
  const tone = sa.voxeqTone || "neutral";
  const pace = sa.voxeqPace || "normal";

  const msg = renderWithTonePace("How can I help you today?", { tone, pace });

  return {
    sessionState: {
      dialogAction: { type: "ElicitIntent" },
      sessionAttributes: sa
    },
    messages: [{ contentType: "PlainText", content: msg }]
  };
};

function renderWithTonePace(text, { tone, pace }) {
  // Example only: choose synonyms and insert brief pauses based on tone/pace
  const prefix = tone === "respectful" ? "Certainly. " : tone === "empathetic" ? "I understand. " : "";
  const spacer = pace === "slow" ? " … " : pace === "fast" ? " " : " ";
  return prefix + text.split(" ").join(spacer);
}