Function onMessage

packages/node/src/worker/engineWorker.ts:563–617

(msg: MainToWorkerMessage)

};

function onMessage(msg: MainToWorkerMessage): void {
  switch (msg.type) {
    case "init":
      handleInitMessage(msg, messageContext);
      return;
    case "frame":
      handleFrameMessage(msg, messageContext);
      return;
    case "frameKick":
      handleFrameKickMessage(msg, messageContext);
      return;
    case "setConfig":
      handleSetConfigMessage(msg, messageContext);
      return;
    case "postUserEvent":
      handlePostUserEventMessage(msg, messageContext);
      return;
    case "eventsAck":
      handleEventsAckMessage(msg, messageContext);
      return;
    case "getCaps":
      handleGetCapsMessage(msg, messageContext);
      return;
    case "commitScrollback":
      handleCommitScrollbackMessage(msg, messageContext);
      return;
    case "shutdown":
      handleShutdownMessage(msg, messageContext);
      return;
    case "debug:enable":
      handleDebugEnableMessage(msg, messageContext);
      return;
    case "debug:disable":
      handleDebugDisableMessage(msg, messageContext);
      return;
    case "debug:query":
      handleDebugQueryMessage(msg, messageContext);
      return;
    case "debug:getPayload":
      handleDebugGetPayloadMessage(msg, messageContext);
      return;
    case "debug:getStats":
      handleDebugGetStatsMessage(msg, messageContext);
      return;
    case "debug:export":
      handleDebugExportMessage(msg, messageContext);
      return;
    case "debug:reset":
      handleDebugResetMessage(msg, messageContext);
      return;
    case "perf:snapshot":
      handlePerfSnapshotMessage(msg, messageContext);
      return;
  }
}

if (parentPort === null) {
  throw new Error("engineWorker: parentPort is null (not running in worker_threads)");