CODEWITHSUNDEEP
amazon-web-servicesaws-lambdaaws-api-gatewayaws-sdk-nodejs
claudio marfia
claudio marfia

Reputation: 11

Problem with AWS API Gateway websocket- Lambda postToConnection

I've been trying to solve this problem all day, looking everywhere on the web, even in the official AWS documentation, why does this error keep appearing when I try to send a message to the client through this code?

PS. i use SDK v3 with node.js 18


import {
  ApiGatewayManagementApiClient,
  PostToConnectionCommand,
} from "@aws-sdk/client-apigatewaymanagementapi";

export const handler = async (event) => {
  const domain = event.requestContext.domainName;
  const stage = event.requestContext.stage;
  const connectionId = event.requestContext.connectionId;
  const callbackUrl = `https://${domain}/${stage}`;
  const client = new ApiGatewayManagementApiClient({ endpoint: callbackUrl });

  const requestParams = {
    ConnectionId: connectionId,
    Data: "Hello!",
  };

  const command = new PostToConnectionCommand(requestParams);

  try {
    await client.send(command);
  } catch (error) {
    console.log(error);
  }

  return {
    statusCode: 200,
  };
};

 fef17825-58ce-4ca7-8f38-85857f1aef0a Task timed out after 3.01 seconds

i tried any online guide or video, can anyone help me?

Upvotes: 1

Views: 1940

Answers (1)

Keck Hung
Keck Hung

Reputation: 11

I do copy and paste your code to my gateway, everything works fine.

import {
  ApiGatewayManagementApiClient,
  PostToConnectionCommand,
} from "@aws-sdk/client-apigatewaymanagementapi";

export const handler = async(event) => {
  const domain = event.requestContext.domainName;
  const stage = event.requestContext.stage;
  const connectionId = event.requestContext.connectionId;
  const callbackUrl = `https://${domain}/${stage}`;
  const client = new ApiGatewayManagementApiClient({ endpoint: callbackUrl });

  const requestParams = {
    ConnectionId: connectionId,
    Data: "Hello!",
  };

  const command = new PostToConnectionCommand(requestParams);

  try {
    await client.send(command);
  } catch (error) {
    console.log(error);
  }

  return {
    statusCode: 200,
  };
};

code result

P.S. Did you add the AmazonAPIGatewayInvokeFullAccess for your gateway function (Lambda -> Functions -> yourHandler -> Configuration -> Execution role -> Permissions -> add AmazonAPIGatewayInvokeFullAccess)?

Upvotes: 1

Related Questions