attachment-archive rebuild-queue.ts

0% Statements 0/7

0% Branches 0/4

0% Functions 0/3

0% Lines 0/7

Press n or j to go to the next uncovered block, b, p or k for the previous block.


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31  
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
  import { SendMessageCommand, SQSClient } from "@aws-sdk/client-sqs";
 
import { AttachmentArchiveRebuildMessage } from "./types";
 
const sqsClient = new SQSClient({ region: process.env.region || process.env.AWS_REGION });
 
export function hasAttachmentArchiveRebuildQueueConfigured(): boolean {
  return Boolean(process.env.ATTACHMENT_ARCHIVE_REBUILD_QUEUE_URL);
}
 
export function getAttachmentArchiveRebuildQueueUrl(): string {
  const queueUrl = process.env.ATTACHMENT_ARCHIVE_REBUILD_QUEUE_URL;
  if (!queueUrl) {
    throw new Error("ATTACHMENT_ARCHIVE_REBUILD_QUEUE_URL must be defined");
  }
 
  return queueUrl;
}
 
export async function sendAttachmentArchiveRebuildRequest(
  message: AttachmentArchiveRebuildMessage,
) {
  await sqsClient.send(
    new SendMessageCommand({
      QueueUrl: getAttachmentArchiveRebuildQueueUrl(),
      MessageBody: JSON.stringify(message),
      MessageGroupId: message.packageId,
    }),
  );
}