123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273
// deno-fmt-ignore-file// deno-lint-ignore-file
// Copyright Joyent and Node contributors. All rights reserved. MIT license.// Taken from Node 18.8.0// This file is automatically generated by "node/_tools/setup.ts". Do not modify this file manually
// TODO(cjihrig): kEvents is an internally used symbol in Node.js. It is not// implemented in Deno, so parts of this test must be removed in order to pass.
'use strict';// Flags: --no-warnings
const common = require('../common');const { once, EventEmitter } = require('events');const {  strictEqual,  deepStrictEqual,  fail,  rejects,} = require('assert');
async function onceAnEvent() {  const ee = new EventEmitter();
  process.nextTick(() => {    ee.emit('myevent', 42);  });
  const [value] = await once(ee, 'myevent');  strictEqual(value, 42);  strictEqual(ee.listenerCount('error'), 0);  strictEqual(ee.listenerCount('myevent'), 0);}
async function onceAnEventWithNullOptions() {  const ee = new EventEmitter();
  process.nextTick(() => {    ee.emit('myevent', 42);  });
  const [value] = await once(ee, 'myevent', null);  strictEqual(value, 42);}

async function onceAnEventWithTwoArgs() {  const ee = new EventEmitter();
  process.nextTick(() => {    ee.emit('myevent', 42, 24);  });
  const value = await once(ee, 'myevent');  deepStrictEqual(value, [42, 24]);}
async function catchesErrors() {  const ee = new EventEmitter();
  const expected = new Error('kaboom');  let err;  process.nextTick(() => {    ee.emit('error', expected);  });
  try {    await once(ee, 'myevent');  } catch (_e) {    err = _e;  }  strictEqual(err, expected);  strictEqual(ee.listenerCount('error'), 0);  strictEqual(ee.listenerCount('myevent'), 0);}
async function catchesErrorsWithAbortSignal() {  const ee = new EventEmitter();  const ac = new AbortController();  const signal = ac.signal;
  const expected = new Error('boom');  let err;  process.nextTick(() => {    ee.emit('error', expected);  });
  try {    const promise = once(ee, 'myevent', { signal });    strictEqual(ee.listenerCount('error'), 1);
    await promise;  } catch (e) {    err = e;  }  strictEqual(err, expected);  strictEqual(ee.listenerCount('error'), 0);  strictEqual(ee.listenerCount('myevent'), 0);}
async function stopListeningAfterCatchingError() {  const ee = new EventEmitter();
  const expected = new Error('kaboom');  let err;  process.nextTick(() => {    ee.emit('error', expected);    ee.emit('myevent', 42, 24);  });
  try {    await once(ee, 'myevent');  } catch (_e) {    err = _e;  }  process.removeAllListeners('multipleResolves');  strictEqual(err, expected);  strictEqual(ee.listenerCount('error'), 0);  strictEqual(ee.listenerCount('myevent'), 0);}
async function onceError() {  const ee = new EventEmitter();
  const expected = new Error('kaboom');  process.nextTick(() => {    ee.emit('error', expected);  });
  const promise = once(ee, 'error');  strictEqual(ee.listenerCount('error'), 1);  const [ err ] = await promise;  strictEqual(err, expected);  strictEqual(ee.listenerCount('error'), 0);  strictEqual(ee.listenerCount('myevent'), 0);}
async function onceWithEventTarget() {  const et = new EventTarget();  const event = new Event('myevent');  process.nextTick(() => {    et.dispatchEvent(event);  });  const [ value ] = await once(et, 'myevent');  strictEqual(value, event);}
async function onceWithEventTargetError() {  const et = new EventTarget();  const error = new Event('error');  process.nextTick(() => {    et.dispatchEvent(error);  });
  const [ err ] = await once(et, 'error');  strictEqual(err, error);}
async function prioritizesEventEmitter() {  const ee = new EventEmitter();  ee.addEventListener = fail;  ee.removeAllListeners = fail;  process.nextTick(() => ee.emit('foo'));  await once(ee, 'foo');}
async function abortSignalBefore() {  const ee = new EventEmitter();  ee.on('error', common.mustNotCall());  const abortedSignal = AbortSignal.abort();
  await Promise.all([1, {}, 'hi', null, false].map((signal) => {    return rejects(once(ee, 'foo', { signal }), {      code: 'ERR_INVALID_ARG_TYPE'    });  }));
  return rejects(once(ee, 'foo', { signal: abortedSignal }), {    name: 'AbortError'  });}
async function abortSignalAfter() {  const ee = new EventEmitter();  const ac = new AbortController();  ee.on('error', common.mustNotCall());  const r = rejects(once(ee, 'foo', { signal: ac.signal }), {    name: 'AbortError'  });  process.nextTick(() => ac.abort());  return r;}
async function abortSignalAfterEvent() {  const ee = new EventEmitter();  const ac = new AbortController();  process.nextTick(() => {    ee.emit('foo');    ac.abort();  });  const promise = once(ee, 'foo', { signal: ac.signal });  await promise;}
async function abortSignalRemoveListener() {  const ee = new EventEmitter();  const ac = new AbortController();
  try {    process.nextTick(() => ac.abort());    await once(ee, 'test', { signal: ac.signal });  } catch {    strictEqual(ee.listeners('test').length, 0);    strictEqual(ee.listeners('error').length, 0);  }}
async function eventTargetAbortSignalBefore() {  const et = new EventTarget();  const abortedSignal = AbortSignal.abort();
  await Promise.all([1, {}, 'hi', null, false].map((signal) => {    return rejects(once(et, 'foo', { signal }), {      code: 'ERR_INVALID_ARG_TYPE'    });  }));
  return rejects(once(et, 'foo', { signal: abortedSignal }), {    name: 'AbortError'  });}
async function eventTargetAbortSignalAfter() {  const et = new EventTarget();  const ac = new AbortController();  const r = rejects(once(et, 'foo', { signal: ac.signal }), {    name: 'AbortError'  });  process.nextTick(() => ac.abort());  return r;}
async function eventTargetAbortSignalAfterEvent() {  const et = new EventTarget();  const ac = new AbortController();  process.nextTick(() => {    et.dispatchEvent(new Event('foo'));    ac.abort();  });  await once(et, 'foo', { signal: ac.signal });}
Promise.all([  onceAnEvent(),  onceAnEventWithNullOptions(),  onceAnEventWithTwoArgs(),  catchesErrors(),  catchesErrorsWithAbortSignal(),  stopListeningAfterCatchingError(),  onceError(),  onceWithEventTarget(),  onceWithEventTargetError(),  prioritizesEventEmitter(),  abortSignalBefore(),  abortSignalAfter(),  abortSignalAfterEvent(),  abortSignalRemoveListener(),  eventTargetAbortSignalBefore(),  eventTargetAbortSignalAfter(),  eventTargetAbortSignalAfterEvent(),]).then(common.mustCall());