Function main

script/computerd-fuse-flush.mjs:123–206

()

}

async function main() {
  process.stderr.write("booting computerd container ...\n");
  const container = await bootContainer();
  process.stderr.write(`  ${container.url} (${container.cid.slice(0, 12)})\n`);

  let failed = false;
  try {
    // 1. Confirm FUSE actually mounted; the rest of the test is
    //    meaningless against a fallback to the container's root fs.
    const { stdout: mount } = await dockerExec(container.cid, "mount");
    if (!/fuse on \/workspace/.test(mount)) {
      throw new Error(`FUSE not mounted in container:\n${mount}`);
    }
    process.stderr.write("  FUSE mounted on /workspace\n");

    // 2. Write through FUSE. echo > triggers FUSE create, write,
    //    flush (on close), release \u2014 every spill point landed in
    //    the 68407fc fix.
    const payload = `from-fuse ${Date.now()}\n`;
    await dockerExec(container.cid, "bash", "-c", `printf '%s' '${payload}' > /workspace/x.txt`);
    process.stderr.write(`  wrote ${payload.trim()} to /workspace/x.txt via FUSE\n`);

    // 3. Pull from the container's WebSocket on the host. Mirrors
    //    what the host DO does after exec returns.
    const { createWorkspaceClient } = await import(
      `${REPO_ROOT}/node_modules/@cloudflare/computer-rpc/dist/client.js`
    );
    const { Database, SQLiteWorkspaceProvider, initializeSchema } = await import(
      `${REPO_ROOT}/node_modules/@cloudflare/dofs/dist/index.js`
    );
    const { SQLiteTestStorage } = await import(
      `${REPO_ROOT}/node_modules/@cloudflare/dofs/dist/testing.js`
    );
    const { pullOnce } = await import(
      `${REPO_ROOT}/node_modules/@cloudflare/computer-rpc/dist/sync-driver.js`
    );

    const wsUrl = `${container.url.replace("http://", "ws://")}/ws`;
    const client = createWorkspaceClient({ url: wsUrl });

    const recvStorage = new SQLiteTestStorage();
    const recvDb = new Database(recvStorage);
    initializeSchema(recvDb, () => Date.now());

    try {
      const applied = await pullOnce(recvDb, client.sync);
      process.stderr.write(`  pullOnce applied ${applied} entries\n`);
      if (applied === 0) {
        throw new Error("pullOnce applied 0 entries; expected at least 1 for /x.txt");
      }

      // 4. Read the file back through the receiver-side provider.
      //    The bytes have to match what we wrote through FUSE.
      const provider = new SQLiteWorkspaceProvider(recvDb, { now: () => Date.now() });
      const back = provider.readFileSync("/x.txt", "utf8");
      if (back !== payload) {
        throw new Error(
          `byte mismatch:\n  wrote: ${JSON.stringify(payload)}\n  read:  ${JSON.stringify(back)}`,