Function writeFileSync

packages/dofs/src/fs/writeFile.ts:923–994

(
  db: Database,
  path: string,
  bytes: Uint8Array,
  options: WriteFileOptions,
  now: () => number,
)

// to the async path; differs only in that the bytes have already been
// materialized.
export function writeFileSync(
  db: Database,
  path: string,
  bytes: Uint8Array,
  options: WriteFileOptions,
  now: () => number,
): void {
  const { parts, path: canonical } = canonicalizePath(path);
  if (parts.length === 0) {
    throw createWorkspaceError("EISDIR", "cannot write to the root directory", canonical);
  }
  assertNotReadOnly(db, canonical);
  const mode = (options.mode ?? 0o644) & 0o7777;
  const mtime = now();

  db.transactionSync(() => {
    const parentInode = resolveParent(db, parts, canonical);
    const leafName = parts[parts.length - 1];
    const existing = db.one<{ child_inode: number }>(
      "SELECT child_inode FROM vfs_dirents WHERE parent_inode = ? AND name = ?",
      parentInode,
      leafName,
    );

    let inode: number;
    if (existing !== undefined) {
      if (options.exclusive) {
        throw createWorkspaceError("EEXIST", `path exists: ${canonical}`, canonical);
      }
      const node = db.one<{ type: "file" | "dir" }>(
        "SELECT type FROM vfs_nodes WHERE inode = ?",
        existing.child_inode,
      );
      if (node?.type === "dir") {
        throw createWorkspaceError("EISDIR", `path is a directory: ${canonical}`, canonical);
      }
      inode = existing.child_inode;
      // Replace the existing representation. Orphaned blobs (if any)
      // are cleaned up by a later gc() pass.
      db.run("DELETE FROM vfs_chunks WHERE inode = ?", inode);
    } else {
      inode = insertFileNode(db, mode, mtime);
      insertFileDirent(db, parentInode, leafName, inode, canonical);
    }

    const rev = incrementRev(db);
    const chunks = chunksOf(bytes);
    // Upsert blobs and write the new chunk list.
    for (let idx = 0; idx < chunks.length; idx++) {
      const chunk = chunks[idx];
      upsertChunkBlob(db, chunk, mtime);
      db.run(
        "INSERT INTO vfs_chunks (inode, idx, hash, size) VALUES (?, ?, ?, ?)",
        inode,
        idx,
        chunk.hash,
        chunk.size,
      );