finish

e2e/reporters/recorder.ts → e2e/reporters/recorder.js

@@ -89,11 +89,6 @@ class E2eRecorderReporter extends JestMetadataReporter {
       await debugUtils.aggregateLogs();
     }
   }
-
-  static onTestEnvironmentCreate(env) {
-    console.log('I AM ALIVE');
-    console.log('  ..--..');
-  }
 }
 
 function sleep(ms) {

environment-decorator.js

@@ -1,2 +1,2 @@
 /* Jest 27 fallback */
-module.exports = require('./dist/environment-listener');
+module.exports = require('./dist/environment-decorator');

environment-listener.js

@@ -0,0 +1,2 @@
+/* Jest 27 fallback */
+module.exports = require('./dist/environment-listener');

src/environment-listener.ts

@@ -4,9 +4,8 @@ import { JestMetadataError } from './errors';
 import { detectDuplicateRealms, injectRealmIntoSandbox, realm } from './realms';
 import { jestUtils, logger } from './utils';
 
-const log = logger.child({ cat: 'environment', tid: 'environment' });
-
 const listener: EnvironmentListenerFn = (context) => {
+  const log = logger.child({ cat: 'environment', tid: 'environment' });
   const jestEnvironment = context.env;
   const jestEnvironmentConfig = context.config;
   const environmentContext = context.context;

src/jest-reporter/__tests__/fallback-api.test.ts

@@ -8,7 +8,7 @@ import {
   MetadataFactoryImpl,
   WriteMetadataEventEmitter,
 } from '../../metadata';
-import { SerialSyncEmitter } from '../../utils';
+import { SerialEmitter } from '../../utils';
 import { AssociateMetadata } from '../AssociateMetadata';
 import { FallbackAPI } from '../FallbackAPI';
 import { QueryMetadata } from '../QueryMetadata';
@@ -23,10 +23,10 @@ describe('Fallback API', () => {
     const IPCServer = jest.requireMock('../../ipc').IPCServer;
     const ipc: jest.Mocked<IPCServer> = new IPCServer();
 
-    const emitter = new SerialSyncEmitter<MetadataEvent>('core').on('*', (event: MetadataEvent) => {
+    const emitter = new SerialEmitter<MetadataEvent>('core').on('*', (event: MetadataEvent) => {
       metadataHandler.handle(event);
     }) as MetadataEventEmitter;
-    const setEmitter = new SerialSyncEmitter('set') as WriteMetadataEventEmitter;
+    const setEmitter = new SerialEmitter('set') as WriteMetadataEventEmitter;
     const metadataRegistry = new GlobalMetadataRegistry();
     const metadataFactory = new MetadataFactoryImpl(metadataRegistry, setEmitter);
     const globalMetadata = metadataFactory.createGlobalMetadata();

src/metadata/__tests__/integration.test.ts

@@ -1,6 +1,6 @@
 import fixtures from '../../../e2e';
 
-import { SerialSyncEmitter } from '../../utils';
+import { SerialEmitter } from '../../utils';
 import { PlantSerializer } from '../__utils__';
 import {
   GlobalMetadataRegistry,
@@ -13,7 +13,7 @@ describe('metadata - integration test:', () => {
   test.each(Object.values(fixtures.metadata))(
     `e2e/__fixtures__/%s`,
     (_name: string, fixture: any[]) => {
-      const emitter: WriteMetadataEventEmitter = new SerialSyncEmitter('set');
+      const emitter: WriteMetadataEventEmitter = new SerialEmitter('set');
       const metadataRegistry = new GlobalMetadataRegistry();
       const metadataFactory = new MetadataFactoryImpl(metadataRegistry, emitter);
       const globalMetadata = metadataFactory.createGlobalMetadata();

src/metadata/__tests__/run-traversal.test.ts

@@ -1,6 +1,6 @@
 import fixtures from '../../../e2e';
 
-import { SerialSyncEmitter } from '../../utils';
+import { SerialEmitter } from '../../utils';
 import {
   GlobalMetadataRegistry,
   Metadata,
@@ -15,7 +15,7 @@ describe('file metadata traversal:', () => {
   });
 
   test.each(lastFixtures)(`fixtures/%s`, (_name: string, fixture: any[]) => {
-    const emitter: WriteMetadataEventEmitter = new SerialSyncEmitter('set');
+    const emitter: WriteMetadataEventEmitter = new SerialEmitter('set');
     const metadataRegistry = new GlobalMetadataRegistry();
     const metadataFactory = new MetadataFactoryImpl(metadataRegistry, emitter);
     const globalMetadata = metadataFactory.createGlobalMetadata();

src/realms/BaseRealm.ts

@@ -12,18 +12,16 @@ import {
   WriteMetadataEventEmitter,
 } from '../metadata';
 
-import { AggregatedEmitter, SerialSyncEmitter } from '../utils';
+import { AggregatedEmitter, SerialEmitter } from '../utils';
 
 export abstract class BaseRealm {
-  readonly coreEmitter = new SerialSyncEmitter<MetadataEvent>('core').on(
+  readonly coreEmitter = new SerialEmitter<MetadataEvent>('core').on(
     '*',
     (event: MetadataEvent) => {
       this.metadataHandler.handle(event);
     },
   ) as MetadataEventEmitter;
-  readonly setEmitter = new SerialSyncEmitter<WriteMetadataEvent>(
-    'set',
-  ) as WriteMetadataEventEmitter;
+  readonly setEmitter = new SerialEmitter<WriteMetadataEvent>('set') as WriteMetadataEventEmitter;
   readonly events = new AggregatedEmitter<MetadataEvent>('events').add(this.coreEmitter);
 
   readonly metadataRegistry = new GlobalMetadataRegistry();

src/utils/emitters/AggregatedEmitter.test.ts

@@ -1,5 +1,5 @@
 import { AggregatedEmitter } from './AggregatedEmitter';
-import { SerialSyncEmitter } from './SerialSyncEmitter';
+import { SerialEmitter } from './SerialEmitter';
 
 describe('AggregatedEmitter', () => {
   let emitter: AggregatedEmitter<{ type: string }>;
@@ -9,8 +9,8 @@ describe('AggregatedEmitter', () => {
   });
 
   test('should re-emit events of added #emitters', () => {
-    const dummy1 = new SerialSyncEmitter('dummy1');
-    const dummy2 = new SerialSyncEmitter('dummy2');
+    const dummy1 = new SerialEmitter('dummy1');
+    const dummy2 = new SerialEmitter('dummy2');
     const listener = jest.fn();
     const event1 = { type: 'test', id: 1 };
     const event2 = { type: 'test', id: 2 };
@@ -26,8 +26,8 @@ describe('AggregatedEmitter', () => {
   });
 
   test('should allow subscribing to events only once', () => {
-    const dummy1 = new SerialSyncEmitter('dummy1');
-    const dummy2 = new SerialSyncEmitter('dummy2');
+    const dummy1 = new SerialEmitter('dummy1');
+    const dummy2 = new SerialEmitter('dummy2');
     const listener = jest.fn();
     const event1 = { type: 'test', id: 1 };
     const event2 = { type: 'test', id: 2 };
@@ -42,7 +42,7 @@ describe('AggregatedEmitter', () => {
   });
 
   test('should allow unsubscribing from events', () => {
-    const dummy = new SerialSyncEmitter('dummy1');
+    const dummy = new SerialEmitter('dummy1');
     const listener = jest.fn();
     const event = { type: 'test', id: 1 };
 

src/utils/emitters/AggregatedEmitter.ts

@@ -1,12 +1,12 @@
 import type { Emitter, ReadonlyEmitter } from '../../types';
-import { SerialSyncEmitter } from './SerialSyncEmitter';
+import { SerialEmitter } from './SerialEmitter';
 
 export class AggregatedEmitter<Event extends { type: string }> implements ReadonlyEmitter<Event> {
   readonly #emitters = new WeakSet<Emitter<Event>>();
-  readonly #rootEmitter: SerialSyncEmitter<Event>;
+  readonly #rootEmitter: SerialEmitter<Event>;
 
   constructor(name: string) {
-    this.#rootEmitter = new SerialSyncEmitter<Event>(name);
+    this.#rootEmitter = new SerialEmitter<Event>(name);
   }
 
   add(emitter: Emitter<Event>): this {