// import type { Readable, Writable } from "node:stream";
// import type { WorkerOptions } from "node:worker_threads";
declare const self: typeof globalThis;
type WebWorker = InstanceType<typeof globalThis.Worker>;

const EventEmitter = require("node:events");
const { throwNotImplemented } = require("../internal/shared");

const { MessageChannel, BroadcastChannel, Worker: WebWorker } = globalThis;
const SHARE_ENV = Symbol("nodejs.worker_threads.SHARE_ENV");

const isMainThread = Bun.isMainThread;
let [_workerData, _threadId, _receiveMessageOnPort] = $lazy("worker_threads");

type NodeWorkerOptions = import("node:worker_threads").WorkerOptions;

const emittedWarnings = new Set();
function emitWarning(type, message) {
  if (emittedWarnings.has(type)) return;
  emittedWarnings.add(type);
  // process.emitWarning(message); // our printing is bad
  console.warn("[bun] Warning:", message);
}

function injectFakeEmitter(Class) {
  function messageEventHandler(event: MessageEvent) {
    return event.data;
  }

  function errorEventHandler(event: ErrorEvent) {
    return event.error;
  }

  const wrappedListener = Symbol("wrappedListener");

  function wrapped(run, listener) {
    const callback = function (event) {
      return listener(run(event));
    };
    listener[wrappedListener] = callback;
    return callback;
  }

  function functionForEventType(event, listener) {
    switch (event) {
      case "error":
      case "messageerror": {
        return wrapped(errorEventHandler, listener);
      }

      default: {
        return wrapped(messageEventHandler, listener);
      }
    }
  }

  Class.prototype.on = function (event, listener) {
    this.addEventListener(event, functionForEventType(event, listener));

    return this;
  };

  Class.prototype.off = function (event, listener) {
    if (listener) {
      this.removeEventListener(event, listener[wrappedListener] || listener);
    } else {
      this.removeEventListener(event);
    }

    return this;
  };

  Class.prototype.once = function (event, listener) {
    this.addEventListener(event, functionForEventType(event, listener), { once: true });

    return this;
  };

  function EventClass(eventName) {
    if (eventName === "error" || eventName === "messageerror") {
      return ErrorEvent;
    }

    return MessageEvent;
  }

  Class.prototype.emit = function (event, ...args) {
    this.dispatchEvent(new (EventClass(event))(event, ...args));
    return this;
  };

  Class.prototype.prependListener = Class.prototype.on;
  Class.prototype.prependOnceListener = Class.prototype.once;
}

const _MessagePort = globalThis.MessagePort;
injectFakeEmitter(_MessagePort);

const MessagePort = _MessagePort;

let resourceLimits = {};

let workerData = _workerData;
let threadId = _threadId;
function receiveMessageOnPort(port: MessagePort) {
  let res = _receiveMessageOnPort(port);
  if (!res) return undefined;
  return {
    message: res,
  };
}

function fakeParentPort() {
  const fake = Object.create(MessagePort.prototype);
  Object.defineProperty(fake, "onmessage", {
    get() {
      return self.onmessage;
    },
    set(value) {
      self.onmessage = value;
    },
  });

  Object.defineProperty(fake, "onmessageerror", {
    get() {
      return self.onmessageerror;
    },
    set(value) {},
  });

  Object.defineProperty(fake, "postMessage", {
    value(...args: [any, any]) {
      return self.postMessage(...args);
    },
  });

  Object.defineProperty(fake, "close", {
    value() {
      return process.exit(0);
    },
  });

  Object.defineProperty(fake, "start", {
    value() {},
  });

  Object.defineProperty(fake, "unref", {
    value() {},
  });

  Object.defineProperty(fake, "ref", {
    value() {},
  });

  Object.defineProperty(fake, "hasRef", {
    value() {
      return false;
    },
  });

  Object.defineProperty(fake, "setEncoding", {
    value() {},
  });

  Object.defineProperty(fake, "addEventListener", {
    value: self.addEventListener.bind(self),
  });

  Object.defineProperty(fake, "removeEventListener", {
    value: self.removeEventListener.bind(self),
  });

  return fake;
}
let parentPort: MessagePort | null = isMainThread ? null : fakeParentPort();

function getEnvironmentData() {
  return process.env;
}

function setEnvironmentData(env: any) {
  process.env = env;
}

function markAsUntransferable() {
  throwNotImplemented("worker_threads.markAsUntransferable");
}

function moveMessagePortToContext() {
  throwNotImplemented("worker_threads.moveMessagePortToContext");
}

const unsupportedOptions = [
  "eval",
  "argv",
  "execArgv",
  "stdin",
  "stdout",
  "stderr",
  "trackedUnmanagedFds",
  "resourceLimits",
];

class Worker extends EventEmitter {
  #worker: WebWorker;
  #performance;

  // this is used by wt.Worker.terminate();
  // either is the exit code if exited, a promise resolving to the exit code, or undefined if we havent sent .terminate() yet
  #onExitPromise: Promise<number> | number | undefined = undefined;

  constructor(filename: string, options: NodeWorkerOptions = {}) {
    super();
    for (const key of unsupportedOptions) {
      if (key in options) {
        emitWarning("option." + key, `worker_threads.Worker option "${key}" is not implemented.`);
      }
    }
    this.#worker = new WebWorker(filename, options);
    this.#worker.addEventListener("close", this.#onClose.bind(this));
    this.#worker.addEventListener("error", this.#onError.bind(this));
    this.#worker.addEventListener("message", this.#onMessage.bind(this));
    this.#worker.addEventListener("messageerror", this.#onMessageError.bind(this));
    this.#worker.addEventListener("open", this.#onOpen.bind(this));
  }

  get threadId() {
    return this.#worker.threadId;
  }

  ref() {
    this.#worker.ref();
  }

  unref() {
    this.#worker.unref();
  }

  get stdin() {
    // TODO:
    return null;
  }

  get stdout() {
    // TODO:
    return null;
  }

  get stderr() {
    // TODO:
    return null;
  }

  get performance() {
    return (this.#performance ??= {
      eventLoopUtilization() {
        emitWarning("performance", "worker_threads.Worker.performance is not implemented.");
        return {
          idle: 0,
          active: 0,
          utilization: 0,
        };
      },
    });
  }

  terminate() {
    const onExitPromise = this.#onExitPromise;
    if (onExitPromise) {
      return $isPromise(onExitPromise) ? onExitPromise : Promise.resolve(onExitPromise);
    }

    const { resolve, promise } = Promise.withResolvers();
    this.#worker.addEventListener(
      "close",
      event => {
        resolve(event.code);
      },
      { once: true },
    );
    this.#worker.terminate();

    return (this.#onExitPromise = promise);
  }

  postMessage(...args: [any, any]) {
    return this.#worker.postMessage(...args);
  }

  #onClose(e) {
    this.#onExitPromise = e.code;
    this.emit("exit", e.code);
  }

  #onError(error: ErrorEvent) {
    this.emit("error", error);
  }

  #onMessage(event: MessageEvent) {
    // TODO: is this right?
    this.emit("message", event.data);
  }

  #onMessageError(event: MessageEvent) {
    // TODO: is this right?
    this.emit("messageerror", (event as any).error ?? event.data ?? event);
  }

  #onOpen() {
    this.emit("online");
  }

  async getHeapSnapshot() {
    throwNotImplemented("worker_threads.Worker.getHeapSnapshot");
  }
}
export default {
  Worker,
  workerData,
  parentPort,
  resourceLimits,
  isMainThread,
  MessageChannel,
  BroadcastChannel,
  MessagePort,
  getEnvironmentData,
  setEnvironmentData,
  getHeapSnapshot() {
    return {};
  },
  markAsUntransferable,
  moveMessagePortToContext,
  receiveMessageOnPort,
  SHARE_ENV,
  threadId,
};
/fix-crash</option>
<option value='jarred/fix-http-compression'>jarred/fix-http-compression</option>
<option value='jarred/fix-issue-with-tsconfig-run'>jarred/fix-issue-with-tsconfig-run</option>
<option value='jarred/fix-proxy-regression'>jarred/fix-proxy-regression</option>
<option value='jarred/fixes-3129'>jarred/fixes-3129</option>
<option value='jarred/gen'>jarred/gen</option>
<option value='jarred/htmlrewriter'>jarred/htmlrewriter</option>
<option value='jarred/improve-testing'>jarred/improve-testing</option>
<option value='jarred/inquirer'>jarred/inquirer</option>
<option value='jarred/isolation'>jarred/isolation</option>
<option value='jarred/jsc'>jarred/jsc</option>
<option value='jarred/land'>jarred/land</option>
<option value='jarred/landing'>jarred/landing</option>
<option value='jarred/linux'>jarred/linux</option>
<option value='jarred/live-bindings'>jarred/live-bindings</option>
<option value='jarred/make-strings-better'>jarred/make-strings-better</option>
<option value='jarred/mdx-thrwawy'>jarred/mdx-thrwawy</option>
<option value='jarred/move'>jarred/move</option>
<option value='jarred/napi'>jarred/napi</option>
<option value='jarred/new-bund'>jarred/new-bund</option>
<option value='jarred/new-bund-ressurected-branch'>jarred/new-bund-ressurected-branch</option>
<option value='jarred/new-http'>jarred/new-http</option>
<option value='jarred/no-more-npm'>jarred/no-more-npm</option>
<option value='jarred/package-mapper'>jarred/package-mapper</option>
<option value='jarred/pg'>jarred/pg</option>
<option value='jarred/port'>jarred/port</option>
<option value='jarred/possibly-2732'>jarred/possibly-2732</option>
<option value='jarred/postgresql'>jarred/postgresql</option>
<option value='jarred/precompile-linux-dependencies'>jarred/precompile-linux-dependencies</option>
<option value='jarred/prepare-for-libuv'>jarred/prepare-for-libuv</option>
<option value='jarred/profiled-call'>jarred/profiled-call</option>
<option value='jarred/read-tsconfig-jsx'>jarred/read-tsconfig-jsx</option>
<option value='jarred/redo-evaluation-order'>jarred/redo-evaluation-order</option>
<option value='jarred/redo-zigstring-for-utf16'>jarred/redo-zigstring-for-utf16</option>
<option value='jarred/relay'>jarred/relay</option>
<option value='jarred/rename'>jarred/rename</option>
<option value='jarred/repl'>jarred/repl</option>
<option value='jarred/request-finalizer'>jarred/request-finalizer</option>
<option value='jarred/rewrite-router'>jarred/rewrite-router</option>
<option value='jarred/run'>jarred/run</option>
<option value='jarred/simdjson'>jarred/simdjson</option>
<option value='jarred/simplify'>jarred/simplify</option>
<option value='jarred/some-fixes-for-eventsource'>jarred/some-fixes-for-eventsource</option>
<option value='jarred/standalone-repro1'>jarred/standalone-repro1</option>
<option value='jarred/start'>jarred/start</option>
<option value='jarred/strong'>jarred/strong</option>
<option value='jarred/subprocess'>jarred/subprocess</option>
<option value='jarred/support-tee'>jarred/support-tee</option>
<option value='jarred/tcc'>jarred/tcc</option>
<option value='jarred/throw-if'>jarred/throw-if</option>
<option value='jarred/update-install-stuff'>jarred/update-install-stuff</option>
<option value='jarred/update-zig1'>jarred/update-zig1</option>
<option value='jarred/upgrade-zig-2'>jarred/upgrade-zig-2</option>
<option value='jarred/uws'>jarred/uws</option>
<option value='jarred/webkit-upgrade-may-17'>jarred/webkit-upgrade-may-17</option>
<option value='jarred/wip-more-reliable'>jarred/wip-more-reliable</option>
<option value='jarred/workers'>jarred/workers</option>
<option value='jarred/zlib'>jarred/zlib</option>
<option value='jarred/zls'>jarred/zls</option>
<option value='lithdew/picohttp-mimalloc'>lithdew/picohttp-mimalloc</option>
<option value='main'>main</option>
<option value='move-templates'>move-templates</option>
<option value='nestjs-guide'>nestjs-guide</option>
<option value='next-cleanup'>next-cleanup</option>
<option value='origin/main'>origin/main</option>
<option value='plugin/plugindata'>plugin/plugindata</option>
<option value='plugin/resolvedir'>plugin/resolvedir</option>
<option value='postinstall_3'>postinstall_3</option>
<option value='repl'>repl</option>
<option value='request-body-stream'>request-body-stream</option>
<option value='reserve-commands'>reserve-commands</option>
<option value='revert-5167-dylan/decode-regex-if-needed'>revert-5167-dylan/decode-regex-if-needed</option>
<option value='rfc/bun-bundler-api'>rfc/bun-bundler-api</option>
<option value='rfc/bunfig-overhaul'>rfc/bunfig-overhaul</option>
<option value='save-in-update'>save-in-update</option>
<option value='sdl'>sdl</option>
<option value='test/action'>test/action</option>
<option value='types/mock'>types/mock</option>
<option value='types/readable-stream-default'>types/readable-stream-default</option>
<option value='types/tty'>types/tty</option>
<option value='u/vjpr/zig-0.10'>u/vjpr/zig-0.10</option>
<option value='xHyroM/types/expose-Bun-Env'>xHyroM/types/expose-Bun-Env</option>
</select> <input type='submit' value='switch'/></form></td></tr>
<tr><td class='sub'>Unnamed repository; edit this file 'description' to name the repository.</td><td class='sub right'></td></tr></table>
<table class='tabs'><tr><td>
<a href='/ansg191/bun/about/?h=fix-websocket-upgrade'>about</a><a href='/ansg191/bun/?h=fix-websocket-upgrade'>summary</a><a href='/ansg191/bun/refs/?h=fix-websocket-upgrade'>refs</a><a class='active' href='/ansg191/bun/log/bench/snippets/render.js?h=fix-websocket-upgrade&amp;showmsg=1&amp;follow=1'>log</a><a href='/ansg191/bun/tree/bench/snippets/render.js?h=fix-websocket-upgrade'>tree</a><a href='/ansg191/bun/commit/bench/snippets/render.js?h=fix-websocket-upgrade&amp;follow=1'>commit</a><a href='/ansg191/bun/diff/bench/snippets/render.js?h=fix-websocket-upgrade&amp;follow=1'>diff</a></td><td class='form'><form class='right' method='get' action='/ansg191/bun/log/bench/snippets/render.js'>
<input type='hidden' name='h' value='fix-websocket-upgrade'/><input type='hidden' name='showmsg' value='1'/><select name='qt'>
<option value='grep'>log msg</option>
<option value='author'>author</option>
<option value='committer'>committer</option>
<option value='range'>range</option>
</select>
<input class='txt' type='search' size='10' name='q' value=''/>
<input type='submit' value='search'/>
</form>
</td></tr></table>
<div class='path'>path: <a href='/ansg191/bun/log/?h=fix-websocket-upgrade&amp;showmsg=1&amp;follow=1'>root</a>/<a href='/ansg191/bun/log/bench?h=fix-websocket-upgrade&amp;showmsg=1&amp;follow=1'>bench</a>/<a href='/ansg191/bun/log/bench/snippets?h=fix-websocket-upgrade&amp;showmsg=1&amp;follow=1'>snippets</a>/<a href='/ansg191/bun/log/bench/snippets/render.js?h=fix-websocket-upgrade&amp;showmsg=1&amp;follow=1'>render.js</a> (<a href='/ansg191/bun/log/bench/snippets/render.js?h=fix-websocket-upgrade&amp;showmsg=1'>unfollow</a>)</div><div class='content'><table class='list nowrap'><tr class='nohover'><th class='left'>Age</th><th class='left'>Commit message (<a href='/ansg191/bun/log/bench/snippets/render.js?h=fix-websocket-upgrade&amp;follow=1'>Collapse</a>)</th><th class='left'>Author</th><th class='left'>Files</th><th class='left'>Lines</th></tr>
<tr class='logheader'><td><span title='2023-10-17 13:22:34 -0700'>2023-10-17</span></td><td class='logsubject'><a href='/ansg191/bun/commit/src/CHANGELOG.md?h=fix-websocket-upgrade&amp;id=ac36f5c278197026b2a442d8ac0f18da6d77f9a1&amp;follow=1'>Remove ancient changelog</a></td><td><img src='//www.gravatar.com/avatar/882f2dfc408f3f96e6e745e36d5d1d80?s=13&amp;d=retro' width='13' height='13' alt='Gravatar' /> Ashcon Partovi
</td><td>1</td><td><span class='deletions'>-11</span>/<span class='insertions'>+0</span></td></tr>
<tr class='nohover-highlight'><td/><td colspan='5' class='logmsg'>
</td></tr>
<tr class='logheader'><td><span title='2023-10-17 09:23:10 -0700'>2023-10-17</span></td><td class='logsubject'><a href='/ansg191/bun/commit/docs/api/websockets.md?h=fix-websocket-upgrade&amp;id=bbc2e96090d3cdc4ccfd5e4456a8d2a236c84c44&amp;follow=1'>docs: fix ws.publish (#6558)</a></td><td><img src='//www.gravatar.com/avatar/5343880adbe698969453d9b2271e29c5?s=13&amp;d=retro' width='13' height='13' alt='Gravatar' /> Aral Roca Gomez
</td><td>1</td><td><span class='deletions'>-1</span>/<span class='insertions'>+1</span></td></tr>
<tr class='nohover-highlight'><td/><td colspan='5' class='logmsg'>
In this example there is no server variable in the context, and here it makes more sense to use ws.publish. It is explained below that once the serve is done, the server.publish can be used.

</td></tr>
<tr class='logheader'><td><span title='2023-10-17 08:59:05 -0700'>2023-10-17</span></td><td class='logsubject'><a href='/ansg191/bun/commit/packages/bun-types/scripts/bundle.ts?h=fix-websocket-upgrade&amp;id=f53eb7cd599ed242b3830c7c1dc9e78954c3b1f4&amp;follow=1'>perf(bun-types): remove needless some call (#6550)</a></td><td><img src='//www.gravatar.com/avatar/0d3ef17c9a536577f26a8b8d4094a979?s=13&amp;d=retro' width='13' height='13' alt='Gravatar' /> Mikhail
</td><td>1</td><td><span class='deletions'>-1</span>/<span class='insertions'>+1</span></td></tr>
<tr class='nohover-highlight'><td/><td colspan='5' class='logmsg'>
</td></tr>
<tr class='logheader'><td><span title='2023-10-16 21:22:43 -0700'>2023-10-16</span></td><td class='logsubject'><a href='/ansg191/bun/commit/test/transpiler/decorators.test.ts?h=fix-websocket-upgrade&amp;id=98d19fa6244384f7e17998b5420d724481ed3835&amp;follow=1'>fix(runtime): make some things more stable (partial jsc debug build) (#5881)</a></td><td><img src='//www.gravatar.com/avatar/7eeb3c9446e467f71ba578a6fcc9c614?s=13&amp;d=retro' width='13' height='13' alt='Gravatar' /> dave caruso
</td><td>116</td><td><span class='deletions'>-1446</span>/<span class='insertions'>+1830</span></td></tr>
<tr class='nohover-highlight'><td/><td colspan='5' class='logmsg'>
* make our debug assertions work

* install bun-webkit-debug

* more progress

* ok

* progress...

* more debug build stuff

* ok

* a

* asdfghjkl

* fix(runtime): fix bad assertion failure in JSBufferList

* ok

* stuff

* upgrade webkit

* Update src/bun.js/bindings/JSDOMWrapperCache.h

Co-authored-by: Jarred Sumner &lt;jarred@jarredsumner.com&gt;

* fix message for colin's changes

* okay

* fix cjs prototype

* implement mainModule

* i think this fixes it all

---------

Co-authored-by: Jarred Sumner &lt;jarred@jarredsumner.com&gt;

</td></tr>
<tr class='logheader'><td><span title='2023-10-16 20:01:24 -0700'>2023-10-16</span></td><td class='logsubject'><a href='/ansg191/bun/commit/src/report.zig?h=fix-websocket-upgrade&amp;id=a3958190e8f106adca7fbf4ba2605056cb22aced&amp;follow=1'>fix(runtime): improve IPC reliability + organization pass on that code (#6475)</a></td><td><img src='//www.gravatar.com/avatar/7eeb3c9446e467f71ba578a6fcc9c614?s=13&amp;d=retro' width='13' height='13' alt='Gravatar' /> dave caruso
</td><td>15</td><td><span class='deletions'>-98</span>/<span class='insertions'>+266</span></td></tr>
<tr class='nohover-highlight'><td/><td colspan='5' class='logmsg'>
* dfghj

* Handle messages that did not finish

* tidy

* ok

* a

* Merge remote-tracking branch 'origin/main' into dave/ipc-fixes

* test failures

---------

Co-authored-by: Jarred Sumner &lt;jarred@jarredsumner.com&gt;

</td></tr>
<tr class='logheader'><td><span title='2023-10-16 17:16:10 -0700'>2023-10-16</span></td><td class='logsubject'><a href='/ansg191/bun/commit/misctools/mime.js?h=fix-websocket-upgrade&amp;id=6504bfef74b552aa834324adfe102c9ba0193039&amp;follow=1'>Simplify getting Set of extentions (#4975)</a></td><td><img src='//www.gravatar.com/avatar/0d3ef17c9a536577f26a8b8d4094a979?s=13&amp;d=retro' width='13' height='13' alt='Gravatar' /> Mikhail
</td><td>1</td><td><span class='deletions'>-3</span>/<span class='insertions'>+3</span></td></tr>
<tr class='nohover-highlight'><td/><td colspan='5' class='logmsg'>
</td></tr>
<tr class='logheader'><td><span title='2023-10-16 17:11:04 -0700'>2023-10-16</span></td><td class='logsubject'><a href='/ansg191/bun/commit/test/js/bun/sqlite/sqlite.test.js?h=fix-websocket-upgrade&amp;id=220cb0eb941d43f7ea815e46fe50b5c621782be4&amp;follow=1'>Fix formatting</a></td><td><img src='//www.gravatar.com/avatar/882f2dfc408f3f96e6e745e36d5d1d80?s=13&amp;d=retro' width='13' height='13' alt='Gravatar' /> Ashcon Partovi
</td><td>1</td><td><span class='deletions'>-3</span>/<span class='insertions'>+1</span></td></tr>
<tr class='nohover-highlight'><td/><td colspan='5' class='logmsg'>
</td></tr>
<tr class='logheader'><td><span title='2023-10-16 16:33:02 -0700'>2023-10-16</span></td><td class='logsubject'><a href='/ansg191/bun/commit/test/cli/test/bun-test.test.ts?h=fix-websocket-upgrade&amp;id=01e04e3341e8bf19f1b08cb2238663b2fdb48c54&amp;follow=1'>fix(test): when tests run with --only the nested describe blocks `.on… (#5616)</a></td><td><img src='//www.gravatar.com/avatar/7cfb6d5e03edf1683d48935af349e12b?s=13&amp;d=retro' width='13' height='13' alt='Gravatar' /> Igor Shapiro
</td><td>2</td><td><span class='deletions'>-13</span>/<span class='insertions'>+45</span></td></tr>
<tr class='nohover-highlight'><td/><td colspan='5' class='logmsg'>
</td></tr>
<tr class='logheader'><td><span title='2023-10-16 16:18:40 -0700'>2023-10-16</span></td><td class='logsubject'><a href='/ansg191/bun/commit/test/js/node/events/event-emitter.test.ts?h=fix-websocket-upgrade&amp;id=0853e19f53bfeb636971423a62214e0519b10729&amp;follow=1'>perf(node:events): optimize `emit(...)` function (#5485)</a></td><td><img src='//www.gravatar.com/avatar/b6791c921c4df047e8a107dcf3cad7c5?s=13&amp;d=retro' width='13' height='13' alt='Gravatar' /> Yannik Schröder
</td><td>3</td><td><span class='deletions'>-11</span>/<span class='insertions'>+132</span></td></tr>
<tr class='nohover-highlight'><td/><td colspan='5' class='logmsg'>
</td></tr>
<tr class='logheader'><td><span title='2023-10-16 16:11:44 -0700'>2023-10-16</span></td><td class='logsubject'><a href='/ansg191/bun/commit/test/js/web/fetch/fetch.test.ts?h=fix-websocket-upgrade&amp;id=a9b8e3ecc82b01237721ec38afd780407c078d96&amp;follow=1'>fix: don't remove content-encoding header from header table (#5743)</a></td><td><img src='//www.gravatar.com/avatar/9aadcdb0589dd405d985b35764c8856f?s=13&amp;d=retro' width='13' height='13' alt='Gravatar' /> Liz
</td><td>2</td><td><span class='deletions'>-2</span>/<span class='insertions'>+25</span></td></tr>
<tr class='nohover-highlight'><td/><td colspan='5' class='logmsg'>
Closes #5668

</td></tr>
<tr class='logheader'><td><span title='2023-10-16 16:08:58 -0700'>2023-10-16</span></td><td class='logsubject'><a href='/ansg191/bun/commit/test/js/bun/sqlite/sqlite.test.js?h=fix-websocket-upgrade&amp;id=bec6161dce999c51dd1443c1ac7f2ce493bf800c&amp;follow=1'>fix(sqlite) Insert .all() does not return an array #5872 (#5946)</a></td><td><img src='//www.gravatar.com/avatar/532cd8767d0bbc42724e9f321ad826fc?s=13&amp;d=retro' width='13' height='13' alt='Gravatar' /> Hugo Galan
</td><td>2</td><td><span class='deletions'>-7</span>/<span class='insertions'>+11</span></td></tr>
<tr class='nohover-highlight'><td/><td colspan='5' class='logmsg'>
* fixing #5872

* removing useless comment

</td></tr>
<tr class='logheader'><td><span title='2023-10-16 16:02:11 -0700'>2023-10-16</span></td><td class='logsubject'><a href='/ansg191/bun/commit/test/js/bun/spawn/bun-ipc-child.js?h=fix-websocket-upgrade&amp;id=8c580e67645d9718960f930849cbd1841057d7c5&amp;follow=1'>Fix formatting</a></td><td><img src='//www.gravatar.com/avatar/882f2dfc408f3f96e6e745e36d5d1d80?s=13&amp;d=retro' width='13' height='13' alt='Gravatar' /> Ashcon Partovi
</td><td>2</td><td><span class='deletions'>-5</span>/<span class='insertions'>+4</span></td></tr>
<tr class='nohover-highlight'><td/><td colspan='5' class='logmsg'>
</td></tr>
<tr class='logheader'><td><span title='2023-10-16 15:57:16 -0700'>2023-10-16</span></td><td class='logsubject'><a href='/ansg191/bun/commit/test/js/web/fetch/response.test.ts?h=fix-websocket-upgrade&amp;id=c5354951bacb9efee26683d1be83177443e0d784&amp;follow=1'>Fix `Response.statusText` (#6151)</a></td><td><img src='//www.gravatar.com/avatar/c3689a501aae45682368fd8a543f0e7b?s=13&amp;d=retro' width='13' height='13' alt='Gravatar' /> Chris Toshok
</td><td>10</td><td><span class='deletions'>-238</span>/<span class='insertions'>+269</span></td></tr>
<tr class='nohover-highlight'><td/><td colspan='5' class='logmsg'>
</td></tr>
<tr class='logheader'><td><span title='2023-10-16 15:31:14 -0700'>2023-10-16</span></td><td class='logsubject'><a href='/ansg191/bun/commit/test/js/bun/spawn/spawn.test.ts?h=fix-websocket-upgrade&amp;id=f1658e2e58acb1fcdb3181e8238c50b961b822f6&amp;follow=1'>fix-subprocess-argument-missing (#6407)</a></td><td><img src='//www.gravatar.com/avatar/66e4e53a85dcd9c7e95d102111707f60?s=13&amp;d=retro' width='13' height='13' alt='Gravatar' /> Nicolae-Rares Ailincai
</td><td>4</td><td><span class='deletions'>-2</span>/<span class='insertions'>+40</span></td></tr>
<tr class='nohover-highlight'><td/><td colspan='5' class='logmsg'>
* fix-subprocess-argument-missing

* fix-tests

* nitpick, these should === not just be undefined

---------

Co-authored-by: dave caruso &lt;me@paperdave.net&gt;

</td></tr>
<tr class='logheader'><td><span title='2023-10-16 15:24:56 -0700'>2023-10-16</span></td><td class='logsubject'><a href='/ansg191/bun/commit/packages/bun-types/bun-test.d.ts?h=fix-websocket-upgrade&amp;id=90d7f335223d95cb0e603d95fd995dcfb7e6cefa&amp;follow=1'>Add type parameter to `expect` (#6128)</a></td><td><img src='//www.gravatar.com/avatar/b7b186d3fd83d73d0ae48c8bfb837c3f?s=13&amp;d=retro' width='13' height='13' alt='Gravatar' /> Voldemat
</td><td>1</td><td><span class='deletions'>-3</span>/<span class='insertions'>+3</span></td></tr>
<tr class='nohover-highlight'><td/><td colspan='5' class='logmsg'>
</td></tr>
<tr class='logheader'><td><span title='2023-10-16 15:19:38 -0700'>2023-10-16</span></td><td class='logsubject'><a href='/ansg191/bun/commit/test/js/web/worker.test.ts?h=fix-websocket-upgrade&amp;id=d9c0273421f3853f4bb0aa18c3cf2e96487886cf&amp;follow=1'>fix(node:worker_threads): ensure threadId property is exposed on ↵</a></td><td><img src='//www.gravatar.com/avatar/6a1d5a45746ce9c021e393a9bf2ccd80?s=13&amp;d=retro' width='13' height='13' alt='Gravatar' /> Jérôme Benoit
</td><td>6</td><td><span class='deletions'>-15</span>/<span class='insertions'>+75</span></td></tr>
<tr class='nohover-highlight'><td/><td colspan='5' class='logmsg'>
worker_threads instance (#6521)

* fix: ensure threadId property is exposed on worker_threads instance

Signed-off-by: Jérôme Benoit &lt;jerome.benoit@sap.com&gt;

* fix: rename lazy worker_threads module properties

Signed-off-by: Jérôme Benoit &lt;jerome.benoit@sap.com&gt;

* fix: add getter for threadId

Signed-off-by: Jérôme Benoit &lt;jerome.benoit@sap.com&gt;

* test: improve worker_threads UTs

Signed-off-by: Jérôme Benoit &lt;jerome.benoit@sap.com&gt;

* test: fix lazy loading

Signed-off-by: Jérôme Benoit &lt;jerome.benoit@sap.com&gt;

* test: fix worker_threads test

Signed-off-by: Jérôme Benoit &lt;jerome.benoit@piment-noir.org&gt;

* fix: return the worker threadId

Signed-off-by: Jérôme Benoit &lt;jerome.benoit@sap.com&gt;

* test: refine worker_threads expectation on threadId

Signed-off-by: Jérôme Benoit &lt;jerome.benoit@piment-noir.org&gt;

---------

Signed-off-by: Jérôme Benoit &lt;jerome.benoit@sap.com&gt;
Signed-off-by: Jérôme Benoit &lt;jerome.benoit@piment-noir.org&gt;

</td></tr>
<tr class='logheader'><td><span title='2023-10-16 15:14:15 -0700'>2023-10-16</span></td><td class='logsubject'><a href='/ansg191/bun/commit/src/js/out/InternalModuleRegistryConstants.h?h=fix-websocket-upgrade&amp;id=d65b1fd80b2f6d71f7df2de07143284a40baf159&amp;follow=1'>Fix use before define bug in sqlite</a></td><td><img src='//www.gravatar.com/avatar/882f2dfc408f3f96e6e745e36d5d1d80?s=13&amp;d=retro' width='13' height='13' alt='Gravatar' /> Ashcon Partovi
</td><td>2</td><td><span class='deletions'>-5</span>/<span class='insertions'>+5</span></td></tr>
<tr class='nohover-highlight'><td/><td colspan='5' class='logmsg'>
Fixes #6481


</td></tr>
<tr class='logheader'><td><span title='2023-10-16 15:14:15 -0700'>2023-10-16</span></td><td class='logsubject'><a href='/ansg191/bun/commit/test/js/bun/test/expect.test.js?h=fix-websocket-upgrade&amp;id=7becb5ec7457644e5229c03f17c3b99090e6b3c7&amp;follow=1'>fix(jest): fix toStrictEqual on same URLs (#6528)</a></td><td><img src='//www.gravatar.com/avatar/b8ea27b4f281fc528b9371cf11c06568?s=13&amp;d=retro' width='13' height='13' alt='Gravatar' /> João Alisson
</td><td>2</td><td><span class='deletions'>-13</span>/<span class='insertions'>+16</span></td></tr>
<tr class='nohover-highlight'><td/><td colspan='5' class='logmsg'>
Fixes #6492


</td></tr>
<tr class='logheader'><td><span title='2023-10-16 15:14:15 -0700'>2023-10-16</span></td><td class='logsubject'><a href='/ansg191/bun/commit/src/bun.js/test/expect.zig?h=fix-websocket-upgrade&amp;id=c3f5baa091968e0807724e6fe1d836bbd8a3f115&amp;follow=1'>Fix `toHaveBeenCalled` having wrong error signature</a></td><td><img src='//www.gravatar.com/avatar/882f2dfc408f3f96e6e745e36d5d1d80?s=13&amp;d=retro' width='13' height='13' alt='Gravatar' /> Ashcon Partovi
</td><td>1</td><td><span class='deletions'>-2</span>/<span class='insertions'>+2</span></td></tr>
<tr class='nohover-highlight'><td/><td colspan='5' class='logmsg'>
Fixes #6527


</td></tr>
<tr class='logheader'><td><span title='2023-10-16 15:14:15 -0700'>2023-10-16</span></td><td class='logsubject'><a href='/ansg191/bun/commit/test/regression/issue/06443.test.ts?h=fix-websocket-upgrade&amp;id=800ad150ff7d418eb8c60fe912a632514740e5f5&amp;follow=1'>Fix formatting</a></td><td><img src='//www.gravatar.com/avatar/882f2dfc408f3f96e6e745e36d5d1d80?s=13&amp;d=retro' width='13' height='13' alt='Gravatar' /> Ashcon Partovi
</td><td>1</td><td><span class='deletions'>-2</span>/<span class='insertions'>+1</span></td></tr>
<tr class='nohover-highlight'><td/><td colspan='5' class='logmsg'>
</td></tr>
<tr class='logheader'><td><span title='2023-10-16 15:14:15 -0700'>2023-10-16</span></td><td class='logsubject'><a href='/ansg191/bun/commit/packages/bun-types/bun.d.ts?h=fix-websocket-upgrade&amp;id=5608e59270dbb7051e74d1ba5e7f38a6a7586473&amp;follow=1'>Add `reusePort` to `Bun.serve` types</a></td><td><img src='//www.gravatar.com/avatar/882f2dfc408f3f96e6e745e36d5d1d80?s=13&amp;d=retro' width='13' height='13' alt='Gravatar' /> Ashcon Partovi
</td><td>1</td><td><span class='deletions'>-0</span>/<span class='insertions'>+9</span></td></tr>
<tr class='nohover-highlight'><td/><td colspan='5' class='logmsg'>
</td></tr>
<tr class='logheader'><td><span title='2023-10-16 15:14:15 -0700'>2023-10-16</span></td><td class='logsubject'><a href='/ansg191/bun/commit/test/regression/issue/06443.test.ts?h=fix-websocket-upgrade&amp;id=e31ed84b1bcf65cc8329f589312e3943c5794afb&amp;follow=1'>Fix `request.url` having incorrect port</a></td><td><img src='//www.gravatar.com/avatar/882f2dfc408f3f96e6e745e36d5d1d80?s=13&amp;d=retro' width='13' height='13' alt='Gravatar' /> Ashcon Partovi
</td><td>4</td><td><span class='deletions'>-1</span>/<span class='insertions'>+92</span></td></tr>
<tr class='nohover-highlight'><td/><td colspan='5' class='logmsg'>
Fixes #6443


</td></tr>
<tr class='logheader'><td><span title='2023-10-16 15:14:15 -0700'>2023-10-16</span></td><td class='logsubject'><a href='/ansg191/bun/commit/packages/bun-uws/src/HttpResponse.h?h=fix-websocket-upgrade&amp;id=548b1d02f22c565b3f2457aa96b7faad1716c1dd&amp;follow=1'>Remove uWebSockets header from Bun.serve responses</a></td><td><img src='//www.gravatar.com/avatar/882f2dfc408f3f96e6e745e36d5d1d80?s=13&amp;d=retro' width='13' height='13' alt='Gravatar' /> Ashcon Partovi
</td><td>1</td><td><span class='deletions'>-6</span>/<span class='insertions'>+6</span></td></tr>
<tr class='nohover-highlight'><td/><td colspan='5' class='logmsg'>
</td></tr>
<tr class='logheader'><td><span title='2023-10-16 15:14:15 -0700'>2023-10-16</span></td><td class='logsubject'><a href='/ansg191/bun/commit/test/regression/issue/06467.test.ts?h=fix-websocket-upgrade&amp;id=f63955a01f0b043bc0934c437a6dc1982d2c5925&amp;follow=1'>Rename some tests</a></td><td><img src='//www.gravatar.com/avatar/882f2dfc408f3f96e6e745e36d5d1d80?s=13&amp;d=retro' width='13' height='13' alt='Gravatar' /> Ashcon Partovi
</td><td>3</td><td><span class='deletions'>-0</span>/<span class='insertions'>+0</span></td></tr>
<tr class='nohover-highlight'><td/><td colspan='5' class='logmsg'>
</td></tr>
<tr class='logheader'><td><span title='2023-10-16 15:14:15 -0700'>2023-10-16</span></td><td class='logsubject'><a href='/ansg191/bun/commit/test/regression/issue/006467.test.ts?h=fix-websocket-upgrade&amp;id=2996ef71560ee4e9bd982fdadd7ff5ce32bb3e1c&amp;follow=1'>Fix #6467</a></td><td><img src='//www.gravatar.com/avatar/882f2dfc408f3f96e6e745e36d5d1d80?s=13&amp;d=retro' width='13' height='13' alt='Gravatar' /> Ashcon Partovi
</td><td>2</td><td><span class='deletions'>-3</span>/<span class='insertions'>+10</span></td></tr>
<tr class='nohover-highlight'><td/><td colspan='5' class='logmsg'>
</td></tr>
<tr class='logheader'><td><span title='2023-10-16 14:21:39 -0700'>2023-10-16</span></td><td class='logsubject'><a href='/ansg191/bun/commit/src/js/out/InternalModuleRegistryConstants.h?h=fix-websocket-upgrade&amp;id=2b1f3438e6b928f57f2fd0e74ec6043097565135&amp;follow=1'>Update InternalModuleRegistryConstants.h</a></td><td><img src='//www.gravatar.com/avatar/0f2ac0141773b63a6cd646063e7ebfca?s=13&amp;d=retro' width='13' height='13' alt='Gravatar' /> Dylan Conway
</td><td>1</td><td><span class='deletions'>-3</span>/<span class='insertions'>+3</span></td></tr>
<tr class='nohover-highlight'><td/><td colspan='5' class='logmsg'>
</td></tr>
<tr class='logheader'><td><span title='2023-10-16 16:11:03 -0400'>2023-10-16</span></td><td class='logsubject'><a href='/ansg191/bun/commit/docs/project/contributing.md?h=fix-websocket-upgrade&amp;id=2a8f3a3b4eeea1cd46ac130ec7484b8ff0187a3f&amp;follow=1'>Development -&gt; Contributing (#6538)</a></td><td><img src='//www.gravatar.com/avatar/7314f20052c467b4e5b959ac03e39ff0?s=13&amp;d=retro' width='13' height='13' alt='Gravatar' /> Colin McDonnell
</td><td>2</td><td><span class='deletions'>-1</span>/<span class='insertions'>+1</span></td></tr>
<tr class='nohover-highlight'><td/><td colspan='5' class='logmsg'>
Co-authored-by: Colin McDonnell &lt;colin@KennyM1.local&gt;

</td></tr>
<tr class='logheader'><td><span title='2023-10-14 16:16:49 -0700'>2023-10-14</span></td><td class='logsubject'><a href='/ansg191/bun/commit/test/js/third_party/postgres/postgres.test.ts?h=fix-websocket-upgrade&amp;id=a87aa2fafe05c358455173ea65877be5eefcbd63&amp;follow=1'>fix(net/tls) fix pg hang on end + hanging on query (#6487)</a></td><td><img src='//www.gravatar.com/avatar/209348ae1158d8f3be635b721db356e2?s=13&amp;d=retro' width='13' height='13' alt='Gravatar' /> Ciro Spaciari
</td><td>3</td><td><span class='deletions'>-8</span>/<span class='insertions'>+36</span></td></tr>
<tr class='nohover-highlight'><td/><td colspan='5' class='logmsg'>
* fix pg hang on end + hanging on query

* remove dummy function

* fix node-stream

* add test

* fix test

* return error in test

* fix test use once instead of on

* fix OOM

* generated

* 💅

* 💅

</td></tr>
<tr class='logheader'><td><span title='2023-10-13 20:37:48 -0700'>2023-10-13</span></td><td class='logsubject'><a href='/ansg191/bun/commit/test/cli/install/moo-0.2.0.tgz?h=fix-websocket-upgrade&amp;id=9b5e66453b0879ed77b71dcdbe50e4efa184261e&amp;follow=1'>fix installing dependencies that match workspace versions (#6494)</a></td><td><img src='//www.gravatar.com/avatar/9c0e69537b9d9493708725dd4c91e3af?s=13&amp;d=retro' width='13' height='13' alt='Gravatar' /> Dylan Conway
</td><td>4</td><td><span class='deletions'>-2</span>/<span class='insertions'>+64</span></td></tr>
<tr class='nohover-highlight'><td/><td colspan='5' class='logmsg'>
* check if dependency matches workspace version

* test

* Update lockfile.zig

* set resolution to workspace package id

</td></tr>
<tr class='logheader'><td><span title='2023-10-13 20:37:06 -0700'>2023-10-13</span></td><td class='logsubject'><a href='/ansg191/bun/commit/src/install/padding_checker.zig?h=fix-websocket-upgrade&amp;id=46f978838ddb4326d9ab089fbce50d47d829a60c&amp;follow=1'>fix lockfile struct padding (#6495)</a></td><td><img src='//www.gravatar.com/avatar/9c0e69537b9d9493708725dd4c91e3af?s=13&amp;d=retro' width='13' height='13' alt='Gravatar' /> Dylan Conway
</td><td>3</td><td><span class='deletions'>-3</span>/<span class='insertions'>+18</span></td></tr>
<tr class='nohover-highlight'><td/><td colspan='5' class='logmsg'>
* integrity padding

* error message for bytes at end of struct

</td></tr>