qbit-scripting/worker/test/transport-fixture.mjs

/* Copyright (C) 2026 Kingsrook, LLC.
 * SPDX-License-Identifier: Apache-2.0
 */
import process from "node:process";
import { setTimeout } from "node:timers";

// Synthetic protocol peer only. No user source is loaded by this fixture.
process.stdin.once("data", () =>
{
   if(process.argv[2] === "output")
   {
      process.stdout.write("x".repeat(2048));
   }
   else if(process.argv[2] === "broker")
   {
      process.stdout.write(JSON.stringify({ protocol: "qbit-scripting-worker/1", type: "broker", requestId: "fixture-1", token: "wrong", operation: "query" }) + "\n");
   }
   else if(process.argv[2] === "duplicate")
   {
      const frame = JSON.stringify({ protocol: "qbit-scripting-worker/1", type: "executeResult", requestId: "fixture-1", outcome: "OK", result: { action: "ALLOW" } }) + "\n";
      process.stdout.write(frame + frame);
   }
});
setTimeout(() => process.exit(0), 10000);