Function receive

backend/src/bin/nodejs-worker.ts:36–51

(delayed?: boolean)

})

const receive = async (delayed?: boolean): Promise<SqsMessage | undefined> => {
  const params: SqsReceiveMessageRequest = {
    QueueUrl: delayed ? SQS_CONFIG.nodejsWorkerDelayableQueue : SQS_CONFIG.nodejsWorkerQueue,
    MessageAttributeNames: !delayed
      ? undefined
      : ['remainingDelaySeconds', 'tenantId', 'targetQueueUrl'],
  }

  const messages = await receiveMessage(SQS_CLIENT(), params)

  if (messages && messages.length === 1) {
    return messages[0]
  }

  return undefined
}

const removeFromQueue = (receiptHandle: string, delayed?: boolean): Promise<void> => {
  const params: SqsDeleteMessageRequest = {