요청 하나에 사진 한 장, 그리고 실시간 진행 줄

        let detail: EncounterDetail
        do {
            let ids = try await run.run(stored: already, send: { batch, key in
                try await Self.classified { try await self.stage(batch, key: key) }
            }, landed: { ids in try await outbox.setStaged(entry.id, ids) })
            await run.finishing()
            do {
                detail = try await Self.classified { try await capture(entry.payload, requestId: entry.id, staged: ids) }
            } catch OutboxFailure.permanent(let reason) where reason.contains("is not here") {
                // Staged a week ago and swept: stage them again on the next pass.
                try await outbox.setStaged(entry.id, nil)
                throw OutboxFailure.transient("The engine no longer had this plate's photos; they go up again.")
            }
        } catch let failure as OutboxFailure {
            await run.fail(failure)
            throw failure
        }

  // A photo per request with the line live (cwkSiblingKit todo #545), then the
  // plate naming them. Everything is keyed by the plate's request id, so a
  // retry resends only what did not land and never makes a second plate.
  const save = async () => {
    if (!files.length || saving) return;
    setSaving(true);
    try {
      const ids = await kitUploadFiles(files, {
        stored: staged.current,
        send: (file, index, onProgress) => api.stage(file, `${requestId.current}:files-${index}-${index + 1}`, onProgress),
        onStatus: setUpload,
        landed: (stored) => {
          staged.current = stored;
        },
      });
      setUpload((s) => s && kitUploadPhase(s, "finishing"));
      const form = new FormData();
      form.append("request_id", requestId.current);
      form.append("kind", kind);
      form.append("note", note);
      form.append("captured_at", new Date().toISOString());
      form.append("timezone", Intl.DateTimeFormat().resolvedOptions().timeZone);
      ids.forEach((id) => form.append("staged", id));
      await api.capture(form);
      reset();
      setError(null);
      onSaved();
    } catch (exc) {
      // The request id and the staged photos stay: Retry resends only what was lost.
      setUpload((s) => s && kitUploadPhase(s, "failed", (exc as Error).message));
    } finally {
      setSaving(false);
    }
  };

def test_photos_staged_one_per_request_become_the_plate(make_client, fake_pippa, tmp_path):
    """The phone since cwkSiblingKit #545: each photo to /api/staged-uploads under
    its own key, then the plate names them. A replay of either step is free."""
    client = make_client()
    ids = []
    for index in range(3):
        key = f"plate-req-staged-01:files-{index}-{index + 1}"
        files = {"file": (f"plate-{index + 1}.jpg", jpeg_bytes(), "image/jpeg")}
        first = client.post("/api/staged-uploads", data={"client_key": key}, files=files)
        assert first.status_code == 200, first.text
        again = client.post("/api/staged-uploads", data={"client_key": key}, files=files)
        assert again.json() == first.json()
        ids.append(first.json()["id"])
    body = client.post("/api/encounters", data={"request_id": "req-staged-01", "kind": "out", "staged": ids})
    assert body.status_code == 200, body.text
    plate = body.json()
    assert len(plate["photos"]) == 3
    # Released once the plate committed; a lost reply's retry still answers the plate.
    assert not list((tmp_path / "sizzle-db" / "staged").glob("*.bin"))
    replay = client.post("/api/encounters", data={"request_id": "req-staged-01", "kind": "out", "staged": ids})
    assert replay.status_code == 200
    assert replay.json()["encounter"]["id"] == plate["encounter"]["id"]