Function releaseWriteBufferSync

packages/dofs/src/fs/writeFile.ts:590–639

(db: Database, path: string, now: () => number)

// time so an intermediate chmod survives. Pending-create entries
// emit their INSERT + dirent + chunks in the same transaction.
export function releaseWriteBufferSync(db: Database, path: string, now: () => number): void {
  const { path: canonical } = canonicalizePath(path);
  const pending = getPendingWriteBufferByPath(db, canonical);
  if (pending !== undefined) {
    releasePendingBuffer(db, pending, now);
    return;
  }
  const node = resolveFileInode(db, path);
  const entry = getWriteBuffer(db, node.inode);
  if (entry === undefined) return;
  entry.openCount -= 1;
  if (entry.openCount > 0) return;

  if (!entry.dirty) {
    deleteWriteBuffer(db, node.inode);
    return;
  }

  const mtime = now();
  const mode = entry.mode & 0o7777;
  const buffered = entry.buf.subarray(0, entry.size);

  db.transactionSync(() => {
    if (entry.size === 0) {
      // An empty file owns no chunk rows; clear any old ones the
      // buffer would otherwise have replaced and bump metadata.
      db.run("DELETE FROM vfs_chunks WHERE inode = ?", node.inode);
      const rev = incrementRev(db);
      db.run(
        "UPDATE vfs_nodes SET mode = ?, mtime = ?, rev = ?, size = 0, manifest_hash = NULL WHERE inode = ?",
        mode,
        mtime,
        rev,
        node.inode,
      );
      return;
    }
    applyChunkedInodeUpdate(
      db,
      node.inode,
      entry.size,
      mode,
      mtime,
      (_idx, start, end) => start < entry.size && end > 0,
      (_idx, start, end) => buffered.subarray(start, Math.min(end, entry.size)),
    );
  });

  deleteWriteBuffer(db, node.inode);
}

// Commit a pending-create buffer to SQLite. Returns the real inode
// allocated by the INSERT, or throws. Promotes the cache entry's key