Method downloadMedia

packages/core/src/collections/content.ts:265–301

(
    groupId: string,
    contentItem: { type: ContentType; data: string },
    notify = true
  )

  // }

  async downloadMedia(
    groupId: string,
    contentItem: { type: ContentType; data: string },
    notify = true
  ) {
    const content = await getContentFromData(
      contentItem.type,
      contentItem.data
    );
    if (!content) return contentItem;
    contentItem.data = await content.insertMedia(async (hashes) => {
      const attachments = await this.db.attachments.all
        .where((eb) => eb("attachments.hash", "in", hashes))
        .items();

      await this.db.fs().queueDownloads(
        attachments.map((a) => ({
          filename: a.hash,
          chunkSize: a.chunkSize
        })),
        groupId,
        notify ? { readOnDownload: false } : undefined
      );

      const sources: Record<string, string> = {};
      for (const attachment of attachments) {
        const src = await this.db.attachments.read(
          attachment.hash,
          getOutputType(attachment)
        );
        if (!src || typeof src !== "string") continue;
        sources[attachment.hash] = src;
      }
      return sources;
    });
    return contentItem;
  }

  async removeAttachments(id: string, hashes: string[]) {
    const contentItem = await this.get(id);