import { SendMessageRequest } from 'aws-sdk/clients/sqs' ; import crypto from 'crypto' ; function sha256 ( message ) { return crypto . createHash ( 'sha256' ) . update ( message ) . digest ( 'hex' ) ; } interface UnnormalizedMessage { userId : string ; } export function buildSendMessageRequestForQueue ( message , queueUrl ) { const { userId , ... body } = message ; const messageBody = JSON . stringify ( message ) ; return { MessageGroupId : userId , MessageBody : messageBody , MessageDeduplicationId : sha256 ( messageBody ) , QueueUrl : queueUrl , } ; }