MCPcopy Create free account
hub / github.com/cloudflare/computer / writeFetchCursor

Function writeFetchCursor

packages/dofs/src/sync/watermarks.ts:105–114  ·  view source on GitHub ↗
(
  db: Database,
  cursor: ChangeCursor,
  backend: string = DEFAULT_BACKEND_ID,
)

Source from the content-addressed store, hash-verified

103}
104
105export function writeFetchCursor(
106 db: Database,
107 cursor: ChangeCursor,
108 backend: string = DEFAULT_BACKEND_ID,
109): void {
110 db.transactionSync(() => {
111 writeWatermarkValue(db, "fetchRev", cursor.rev, backend);
112 writeFetchCursorPath(db, cursor.path, backend);
113 });
114}
115
116export function compareChangeCursors(a: ChangeCursor, b: ChangeCursor): number {
117 if (a.rev !== b.rev) return a.rev - b.rev;

Callers 8

pullOnceImplFunction · 0.90
writeFetchCursorIfAheadFunction · 0.90
reconcileWatermarksFunction · 0.90
pushMethod · 0.90
wire.test.tsFile · 0.90
watermarks.test.tsFile · 0.85
workspace.test.tsFile · 0.85

Calls 3

writeWatermarkValueFunction · 0.85
writeFetchCursorPathFunction · 0.85
transactionSyncMethod · 0.65

Tested by

no test coverage detected