91 lines
2.6 KiB
TypeScript
91 lines
2.6 KiB
TypeScript
// Copyright 2021 Signal Messenger, LLC
|
|
// SPDX-License-Identifier: AGPL-3.0-only
|
|
|
|
import {
|
|
getPendingAttachment,
|
|
preProcessAttachment,
|
|
processAttachment,
|
|
} from './processAttachment';
|
|
import type {
|
|
AttachmentDraftType,
|
|
InMemoryAttachmentDraftType,
|
|
} from '../types/Attachment';
|
|
import { AttachmentToastType } from '../types/AttachmentToastType';
|
|
import * as log from '../logging/log';
|
|
|
|
export type AddAttachmentActionType = (
|
|
conversationId: string,
|
|
attachment: InMemoryAttachmentDraftType
|
|
) => unknown;
|
|
export type AddPendingAttachmentActionType = (
|
|
conversationId: string,
|
|
pendingAttachment: AttachmentDraftType
|
|
) => unknown;
|
|
export type RemoveAttachmentActionType = (
|
|
conversationId: string,
|
|
filePath: string
|
|
) => unknown;
|
|
|
|
export type HandleAttachmentsProcessingArgsType = {
|
|
addAttachment: AddAttachmentActionType;
|
|
addPendingAttachment: AddPendingAttachmentActionType;
|
|
conversationId: string;
|
|
draftAttachments: ReadonlyArray<AttachmentDraftType>;
|
|
files: ReadonlyArray<File>;
|
|
onShowToast: (toastType: AttachmentToastType) => unknown;
|
|
removeAttachment: RemoveAttachmentActionType;
|
|
};
|
|
|
|
export async function handleAttachmentsProcessing({
|
|
addAttachment,
|
|
addPendingAttachment,
|
|
conversationId,
|
|
draftAttachments,
|
|
files,
|
|
onShowToast,
|
|
removeAttachment,
|
|
}: HandleAttachmentsProcessingArgsType): Promise<void> {
|
|
if (!files.length) {
|
|
return;
|
|
}
|
|
|
|
const nextDraftAttachments = [...draftAttachments];
|
|
const filesToProcess: Array<File> = [];
|
|
for (let i = 0; i < files.length; i += 1) {
|
|
const file = files[i];
|
|
const processingResult = preProcessAttachment(file, nextDraftAttachments);
|
|
if (processingResult != null) {
|
|
onShowToast(processingResult);
|
|
} else {
|
|
const pendingAttachment = getPendingAttachment(file);
|
|
if (pendingAttachment) {
|
|
addPendingAttachment(conversationId, pendingAttachment);
|
|
filesToProcess.push(file);
|
|
// we keep a running count of the draft attachments so we can show a
|
|
// toast in case we add too many attachments at once
|
|
nextDraftAttachments.push(pendingAttachment);
|
|
}
|
|
}
|
|
}
|
|
|
|
await Promise.all(
|
|
filesToProcess.map(async file => {
|
|
try {
|
|
const attachment = await processAttachment(file);
|
|
if (!attachment) {
|
|
removeAttachment(conversationId, file.path);
|
|
return;
|
|
}
|
|
addAttachment(conversationId, attachment);
|
|
} catch (err) {
|
|
log.error(
|
|
'handleAttachmentsProcessing: failed to process attachment:',
|
|
err.stack
|
|
);
|
|
removeAttachment(conversationId, file.path);
|
|
onShowToast(AttachmentToastType.ToastUnableToLoadAttachment);
|
|
}
|
|
})
|
|
);
|
|
}
|