writeWorker.ts

import { writeJson } from "https://deno.land/std@0.68.0/fs/write_json.ts";

self.onmessage = async (e) => {
  const { file, data, taskId } = e.data;
  console.debug(`[casualdb:worker:debug] write task: ${taskId}`);

  try {
    await writeJson(file, data);
    self.postMessage({ taskId, error: false });
  } catch (error) {
    self.postMessage({ taskId, error: error.valueOf() });
  } finally {
    self.close();
  }
};