All files / lib/attachment-archive package-activity.ts

100% Statements 20/20
88.88% Branches 8/9
100% Functions 15/15
100% Lines 19/19

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 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101                            6x 16x 16x 16x       14x           14x                               6x 14x           14x   9x         5x     4x     12x 12x 12x   12x                                                 1x 2x         2x    
import { opensearch } from "shared-types";
import { getPackageActivityLabelSlug } from "shared-utils";
 
import { buildSectionArchiveFolderName, getSectionArchiveRootFolderName } from "./archive-manifest";
import { AttachmentArchiveSectionInfo, AttachmentArchiveSourceAttachment } from "./types";
 
export interface AttachmentArchiveSectionDescriptor extends AttachmentArchiveSectionInfo {
  packageId: string;
  attachments: AttachmentArchiveSourceAttachment[];
}
 
export function getArchiveEligibleChangelogEntries(
  changelog: opensearch.changelog.ItemResult[],
): opensearch.changelog.Document[] {
  return changelog
    .map((item) => item._source)
    .filter((document): document is opensearch.changelog.Document => Boolean(document))
    .filter((document) => !document.isAdminChange);
}
 
function getArchiveEntryTimestamp(entry: opensearch.changelog.Document) {
  return typeof entry.timestamp === "number" ? entry.timestamp : undefined;
}
 
function getSectionAttachments(
  entry: opensearch.changelog.Document,
): AttachmentArchiveSourceAttachment[] {
  return (entry.attachments || []).map((attachment) => ({
    bucket: attachment.bucket,
    filename: attachment.filename,
    key: attachment.key,
    title: attachment.title,
    uploadDate: attachment.uploadDate,
  }));
}
 
export function buildAttachmentArchiveSections({
  packageId,
  changelog,
}: {
  packageId: string;
  changelog: opensearch.changelog.ItemResult[];
}): AttachmentArchiveSectionDescriptor[] {
  return getArchiveEligibleChangelogEntries(changelog)
    .map((entry, originalIndex) => ({
      attachments: getSectionAttachments(entry),
      entry,
      originalIndex,
      timestamp: getArchiveEntryTimestamp(entry),
    }))
    .filter(({ attachments }) => attachments.length > 0)
    .sort((left, right) => {
      if (
        left.timestamp !== undefined &&
        right.timestamp !== undefined &&
        left.timestamp !== right.timestamp
      ) {
        return left.timestamp - right.timestamp;
      }
 
      return left.originalIndex - right.originalIndex;
    })
    .map(({ attachments, entry }, index) => {
      const sectionNumber = index + 1;
      const sectionLabel = getPackageActivityLabelSlug(entry.event);
      const sectionFolderName = buildSectionArchiveFolderName({ sectionNumber, sectionLabel });
 
      return {
        packageId,
        attachments,
        sectionId: entry.id,
        sectionNumber,
        sectionLabel,
        sectionFolderName,
        rootFolderName: getSectionArchiveRootFolderName({
          packageId,
          sectionNumber,
          sectionLabel,
        }),
      };
    });
}
 
export function getAttachmentArchiveSectionById({
  packageId,
  changelog,
  sectionId,
}: {
  packageId: string;
  changelog: opensearch.changelog.ItemResult[];
  sectionId: string;
}): AttachmentArchiveSectionDescriptor | undefined {
  return buildAttachmentArchiveSections({ packageId, changelog }).find(
    (section) => section.sectionId === sectionId,
  );
}
 
export function hasArchiveableAttachments(changelog: opensearch.changelog.ItemResult[]): boolean {
  return buildAttachmentArchiveSections({ packageId: "_", changelog }).length > 0;
}