import { describe, expect, it, vi } from 'vitest';

import { createUploadEditCoordinator } from './uploadEditCoordinator';

const context = (field: string, recordId = 'record') => ({ modelId: 'model', recordId, field, taskId: 'task' });
const value = (field: string) => ({ draftId: field, revision: 1, files: [] });

describe('dMS form attachment coordinator', () => {
  it('batches positions while preserving each result and makes a fresh request for submission', async () => {
    const load = vi.fn(async (contexts) => ({ data: contexts.map((item: any) => value(item.field)) }));
    const coordinator = createUploadEditCoordinator(load);
    const result = await Promise.all([coordinator.loadShared(context('main')), coordinator.loadShared(context('child'))]);
    expect(load).toHaveBeenCalledTimes(1);
    expect(result.map((item) => item.data.draftId)).toEqual(['main', 'child']);
    await coordinator.loadShared(context('main'));
    expect(load).toHaveBeenCalledTimes(2);
  });
  it('does not combine different records, swallow denial, or return partial batch results', async () => {
    const load = vi.fn(async () => ({ data: [value('file')] }));
    const coordinator = createUploadEditCoordinator(load);
    await Promise.all([coordinator.loadShared(context('main')), coordinator.loadShared(context('main', 'other'))]);
    expect(load).toHaveBeenCalledTimes(2);
    const partial = await Promise.allSettled([coordinator.loadShared(context('main')), coordinator.loadShared(context('child'))]);
    expect(partial.every((item) => item.status === 'rejected')).toBe(true);
    load.mockRejectedValueOnce(new Error('denied'));
    await expect(coordinator.loadShared(context('main'))).rejects.toThrow('denied');
  });
  it('waits for editor finalization before preparing the confirmed manifest', async () => {
    const coordinator = createUploadEditCoordinator(vi.fn());
    let finish!: () => void;
    const closing = new Promise<void>((resolve) => {
      finish = resolve;
    });
    const prepare = vi.fn(async () => undefined);
    const work = coordinator.prepare([{ settle: () => closing, prepare }]);
    await Promise.resolve();
    expect(prepare).not.toHaveBeenCalled();
    finish();
    await work;
    expect(prepare).toHaveBeenCalledOnce();
  });
  it('rejects pending and new reads after disposal', async () => {
    const coordinator = createUploadEditCoordinator(vi.fn());
    const pending = coordinator.loadShared(context('main'));
    coordinator.dispose();
    await expect(pending).rejects.toThrow('表单已关闭');
    await expect(coordinator.loadShared(context('main'))).rejects.toThrow('表单已关闭');
  });
});