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;
}
}