src/utils/flush-pending-task-attachments.ts

import i18n, { OPENHANDS_I18N_NAMESPACE, waitForI18n } from "#/i18n";
import { consumePendingTaskAttachments } from "#/stores/pending-task-attachments-store";
import { displayErrorToast } from "#/utils/custom-toast-handlers";
import { sendMessageWithAttachments } from "#/utils/send-message-with-attachments";

/**
 * Sends attachments queued during cloud start-task provisioning once the
 * real conversation UUID is available.
 */
export async function flushPendingTaskAttachments(
  taskId: string,
  conversationId: string,
): Promise<void> {
  const pending = consumePendingTaskAttachments(taskId);
  if (!pending) {
    return;
  }

  try {
    await waitForI18n();
    await sendMessageWithAttachments({
      conversationId,
      content: pending.content,
      images: pending.images,
      files: pending.files,
      imagesMarkedUploadAsFile: pending.imagesMarkedUploadAsFile,
      t: i18n.getFixedT(null, OPENHANDS_I18N_NAMESPACE),
    });
  } catch (error) {
    displayErrorToast(error instanceof Error ? error.message : null);
    throw error;
  }
}