async function sendMessageToQueue()

in integrations/amplitude-sam/src/handlers/s3-trigger-processor/index.js [114:137]

• 15 lines of code
• 2 McCabe index (conditional complexity)

async function sendMessageToQueue(applicationId, endpoint, cohort, action){

    endpoint.action = action;
    endpoint.applicationId = applicationId;
    endpoint.cohort = cohort;
    var msgBody = JSON.stringify(endpoint);

    var params = {
       MessageBody: msgBody,
       //MessageDeduplicationId: `${applicationId}_${cohort}_${endpoint.amplitude_id}`,  // Required for FIFO queues
       MessageDeduplicationId: uuidv4(), //TODO: making this unique for now, but may want to make this smarter above in the future?
       MessageGroupId: "Amplitude",  // Required for FIFO queues
       QueueUrl: queueURL
     };
     
     try {
        var data = await sqs.sendMessage(params).promise();
        log.trace(data.MessageId)
        return data.MessageId
    }
    catch (err){
        log.error(err, err.stack);
    }
}