async function findAllConnections()

in lambda/streamConsumer/streamConsumer.js [59:75]


async function findAllConnections() {
  try {
    var params = {
      TableName: tableName,
      IndexName: "GSI-2",
      ProjectionExpression: "#PK, CLIENT, ENDPOINT",
      ExpressionAttributeNames: {
        "#PK": "CONNECTION",
      },
    }

    const connections = await docClient.scan(params).promise()
    return connections
  } catch (err) {
    return err;
  }
}