ext/node/polyfills/internal/cluster/worker.ts - main - githubmirror/deno

ext/node/polyfills/internal/cluster/worker.ts

69 строк2 KB

Kenta Moriuchi

chore: make prefer-primordials lint an internal plugin (#35978)

23 июл 2026, 11:53

23 июл 2026, 11:535b55d08

// Copyright 2018-2026 the Deno authors. MIT license.
// Copyright Joyent and Node contributors. All rights reserved. MIT license.

// Ports lib/internal/cluster/worker.js.

// TODO(petamoriken): enable prefer-primordials for node polyfills
// deno-lint-ignore-file no-explicit-any deno-internal/prefer-primordials

(function () {
const { core, primordials } = __bootstrap;
const { EventEmitter } = core.loadExtScript("ext:deno_node/_events.mjs");
const { kEmptyObject } = core.loadExtScript(
  "ext:deno_node/internal/util.mjs",
);

const { FunctionPrototypeCall, ObjectSetPrototypeOf, ReflectApply } =
  primordials;

// Common Worker implementation shared between cluster primary and worker.
function Worker(this: any, options?: any) {
  if (!(this instanceof Worker)) {
    return new (Worker as any)(options);
  }

  FunctionPrototypeCall(EventEmitter, this);

  if (options === null || typeof options !== "object") {
    options = kEmptyObject;
  }

  this.exitedAfterDisconnect = undefined;

  this.state = options.state || "none";
  this.id = options.id | 0;

  if (options.process) {
    this.process = options.process;
    this.process.on(
      "error",
      (code: any, signal: any) => this.emit("error", code, signal),
    );
    this.process.on(
      "message",
      (message: any, handle: any) => this.emit("message", message, handle),
    );
  }
}

ObjectSetPrototypeOf(Worker.prototype, EventEmitter.prototype);
ObjectSetPrototypeOf(Worker, EventEmitter);

(Worker as any).prototype.kill = function (this: any) {
  ReflectApply(this.destroy, this, arguments);
};

(Worker as any).prototype.send = function (this: any) {
  return ReflectApply(this.process.send, this.process, arguments);
};

(Worker as any).prototype.isDead = function (this: any) {
  return this.process.exitCode != null || this.process.signalCode != null;
};

(Worker as any).prototype.isConnected = function (this: any) {
  return this.process.connected;
};

return { Worker, default: Worker };
})();