Kai ki
ff12b2759f
Connect the previously-skeleton cloudStore to the client with a full
bidirectional reconcile engine. Commercial build (AUTH_ENABLED) only; the
open-source build is byte-for-byte unchanged — all cloud paths short-circuit
when AUTH_ENABLED is false.
- cloudSync.ts: reconcile engine — decideAction (pure, LWW rev->updatedAt with
tombstone priority) + syncOnLogin/pushOnSave/pushDeletion (best-effort,
serialized, isAuthed-gated)
- cloudSyncClient.ts: browser fetch bridge (short-circuit + fault-tolerant)
- /api/stories/{manifest,pull,push,delete}: RLS-guarded sync endpoints
- upsert_story_if_newer RPC: optimistic concurrency (SECURITY INVOKER,
auth.uid() injection, rev->updated_at guard, revoked from public)
- cloudStore: +manifest/pullBlobs, save->RPC {stored,won}, softDelete w/ rev
- localStore: +listAllRecordsForSync/putSyncedRecord/markRecordSynced
(concurrency-guarded sync writes); types: +StorySyncMeta/StorySyncEnvelope
- facade + UserChip: inject pushOnSave/pushDeletion + login-triggered reconcile
Sync model: full reconcile on login + background push on save (no Realtime;
eventual consistency). Conflict resolution: last-write-wins.
Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>
52 lines
2.1 KiB
TypeScript
52 lines
2.1 KiB
TypeScript
// Client-side story persistence facade.
|
|
//
|
|
// Thin wrapper over the browser-local IndexedDB store (lib/persistence/localStore).
|
|
// Keeps a stable public contract for the UI (play page + "我的剧情" page) while the
|
|
// storage medium lives in lib/persistence. All D1 / server code paths were
|
|
// removed: open-source persistence is browser-local only; account-based cloud
|
|
// sync (Supabase) layers on next phase behind AUTH_ENABLED.
|
|
|
|
import type { Session } from "@infiplot/types";
|
|
import type { StoryMeta } from "@/lib/persistence/types";
|
|
import {
|
|
saveStorySession,
|
|
listStories,
|
|
loadStorySession as loadSession,
|
|
softDeleteStory,
|
|
} from "@/lib/persistence/localStore";
|
|
import { pushOnSave, pushDeletion } from "@/lib/persistence/cloudSync";
|
|
|
|
export type SaveResult =
|
|
| { ok: true; storyId: string }
|
|
| { ok: false; error: string };
|
|
|
|
/** Persist the current session locally (upsert by id). Safe to fire-and-forget:
|
|
* never throws, never blocks gameplay/navigation. */
|
|
export async function saveStory(session: Session): Promise<SaveResult> {
|
|
const rec = await saveStorySession(session);
|
|
if (!rec) return { ok: false, error: "无法保存到本地存储" };
|
|
// Fire-and-forget cloud push. pushOnSave short-circuits when auth is off /
|
|
// the user is signed out, so the open-source build sees no behavior change.
|
|
void pushOnSave(rec);
|
|
return { ok: true, storyId: rec.id };
|
|
}
|
|
|
|
/** List saved stories for the "我的剧情" page (newest first). */
|
|
export async function loadStoryList(): Promise<StoryMeta[]> {
|
|
return listStories();
|
|
}
|
|
|
|
/** Load the full (slim) Session for a saved story, or null if absent/deleted. */
|
|
export async function loadStorySession(id: string): Promise<Session | null> {
|
|
return loadSession(id);
|
|
}
|
|
|
|
/** Delete a saved story (soft-delete). Returns false if not found. */
|
|
export async function deleteStory(storyId: string): Promise<boolean> {
|
|
const ok = await softDeleteStory(storyId);
|
|
// Fire-and-forget tombstone propagation. pushDeletion short-circuits when auth
|
|
// is off / signed out, so the open-source build sees no behavior change.
|
|
if (ok) void pushDeletion(storyId);
|
|
return ok;
|
|
}
|