attachment-archive rebuild-queue.ts

25% Statements 2/8

50% Branches 2/4

25% Functions 1/4

25% Lines 2/8

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
32
33
34
35
36  
 
 
 
 
1x
 
 
4x
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
  import { SendMessageCommand, SQSClient } from "@aws-sdk/client-sqs";
import { createHash } from "crypto";
 
import { AttachmentArchiveRebuildMessage } from "./types";
 
const sqsClient = new SQSClient({ region: process.env.region || process.env.AWS_REGION });
 
export function buildAttachmentArchiveMessageGroupId(packageId: string): string {
  return `package-${createHash("sha256").update(packageId).digest("hex")}`;
}
 
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: buildAttachmentArchiveMessageGroupId(message.packageId),
    }),
  );
}