Method readFileSync

packages/dofs/src/provider.ts:354–398

(
    path: string,
    options?: BufferEncoding | { encoding?: BufferEncoding | null } | null,
  )

  }

  readFileSync(
    path: string,
    options?: BufferEncoding | { encoding?: BufferEncoding | null } | null,
  ): Buffer | string {
    const encoding = typeof options === "string" ? options : options?.encoding;
    const { path: canonical } = canonicalizePath(path);
    const pending = getPendingWriteBufferByPath(this.db, canonical);
    if (pending !== undefined) {
      const snapshot = Buffer.alloc(pending.size);
      snapshot.set(pending.buf.subarray(0, pending.size));
      return encoding ? snapshot.toString(encoding) : snapshot;
    }
    const node = resolveInode(this.db, path);
    if (node === null) {
      throw createWorkspaceError("ENOENT", `no such file: ${path}`, path);
    }
    if (node.type !== "file") {
      throw createWorkspaceError("EISDIR", `path is a directory: ${path}`, path);
    }
    // While a buffer is open for this inode it owns the latest
    // bytes; serve from it instead of the chunk store.
    const buffered = getWriteBuffer(this.db, node.inode);
    if (buffered?.dirty) {
      const snapshot = Buffer.alloc(buffered.size);
      snapshot.set(buffered.buf.subarray(0, buffered.size));
      return encoding ? snapshot.toString(encoding) : snapshot;
    }
    const chunks = this.db.all<{ hash: Uint8Array; size: number }>(
      "SELECT hash, size FROM vfs_chunks WHERE inode = ? ORDER BY idx",
      node.inode,
    );
    let total = 0;
    for (const c of chunks) total += c.size;
    const out = Buffer.alloc(total);
    let offset = 0;
    for (const chunk of chunks) {
      const bytes = getBlobBytes(this.db, chunk.hash);
      if (bytes === undefined) {
        throw createWorkspaceError("EIO", `missing blob bytes for ${path}`, path);
      }
      out.set(bytes, offset);
      offset += bytes.byteLength;
    }
    return encoding ? out.toString(encoding) : out;
  }

  writeFile(
    path: string,