Added assertions to not need to use built-in Node to make it compatible with browsers

src/docs/snippets/gettingStarted/webApi/simpleApi.int.spec.ts

@@ -1,12 +1,12 @@
 import {
+  assertEqual,
   assertMatches,
+  assertOk,
   getInMemoryEventStore,
   type EventStore,
 } from '@event-driven-io/emmett';
 import { getApplication } from '@event-driven-io/emmett-expressjs';
-
 import { type Application } from 'express';
-import assert from 'node:assert/strict';
 import { randomUUID } from 'node:crypto';
 import { beforeEach, describe, it } from 'node:test';
 import request from 'supertest';
@@ -78,7 +78,7 @@ void describe('Simple Api from getting started', () => {
     await request(app)
       .delete(`/clients/${clientId}/shopping-carts/current`)
       .expect((response) => {
-        assert.equal(response.statusCode, 403);
+        assertEqual(response.statusCode, 403);
       });
 
     const shoppingCartId = getShoppingCartId(clientId);
@@ -87,8 +87,8 @@ void describe('Simple Api from getting started', () => {
       getShoppingCartId(clientId),
     );
 
-    assert.ok(result);
-    assert.equal(result.events.length, 4);
+    assertOk(result);
+    assertEqual(result.events.length, 4);
 
     assertMatches(result?.events, [
       {

src/packages/emmett-expressjs/src/e2e/decider/applicationLogicWithOC.int.spec.ts

@@ -1,10 +1,12 @@
 import {
+  assertEqual,
+  assertFails,
   assertMatches,
+  assertOk,
   getInMemoryEventStore,
   type EventStore,
 } from '@event-driven-io/emmett';
 import { type Application } from 'express';
-import assert from 'node:assert/strict';
 import { randomUUID } from 'node:crypto';
 import { beforeEach, describe, it } from 'node:test';
 import request from 'supertest';
@@ -42,9 +44,9 @@ void describe('Application logic with optimistic concurrency', () => {
     const current = createResponse.body;
 
     if (!current.id) {
-      assert.fail();
+      assertFails();
     }
-    assert.ok(current.id);
+    assertOk(current.id);
 
     const shoppingCartId = current.id;
 
@@ -122,7 +124,7 @@ void describe('Application logic with optimistic concurrency', () => {
       .delete(`/clients/${clientId}/shopping-carts/${shoppingCartId}`)
       .set(HeaderNames.IF_MATCH, toWeakETag(currentRevision))
       .expect((response) => {
-        assert.equal(response.statusCode, 403);
+        assertEqual(response.statusCode, 403);
         assertMatches(response.body, {
           detail: ShoppingCartErrors.CART_IS_ALREADY_CLOSED,
         });
@@ -131,8 +133,8 @@ void describe('Application logic with optimistic concurrency', () => {
     const result =
       await eventStore.readStream<ShoppingCartEvent>(shoppingCartId);
 
-    assert.ok(result);
-    assert.equal(result.events.length, Number(currentRevision));
+    assertOk(result);
+    assertEqual(result.events.length, Number(currentRevision));
 
     assertMatches(result?.events, [
       {

src/packages/emmett-expressjs/src/e2e/testing.ts

@@ -1,5 +1,8 @@
-import { assertUnsignedBigInt } from '@event-driven-io/emmett';
-import assert from 'node:assert/strict';
+import {
+  assertMatches,
+  assertOk,
+  assertUnsignedBigInt,
+} from '@event-driven-io/emmett';
 import { Test, type Response } from 'supertest';
 import { getWeakETagValue, type ETag } from '../etag';
 
@@ -15,8 +18,8 @@ export const expectNextRevisionInResponseEtag = <RequestBody>(
   response: TestResponse<RequestBody>,
 ) => {
   const eTagValue = response.headers['etag'];
-  assert.ok(eTagValue);
-  assert.match(eTagValue, /W\/"\d+.*"/);
+  assertOk(eTagValue);
+  assertMatches(eTagValue, /W\/"\d+.*"/);
 
   const eTag = getWeakETagValue(eTagValue as ETag);
 

src/packages/emmett-expressjs/src/testing/apiSpecification.ts

@@ -1,12 +1,13 @@
 import {
+  assertEqual,
+  assertFails,
   assertMatches,
   type DefaultStreamVersionType,
   type Event,
   type EventStore,
 } from '@event-driven-io/emmett';
 import { type Application } from 'express';
 import type { ProblemDocument } from 'http-problem-details';
-import assert from 'node:assert/strict';
 import type { Response, Test } from 'supertest';
 import supertest from 'supertest';
 import type TestAgent from 'supertest/lib/agent';
@@ -57,7 +58,7 @@ export const expectResponse =
   ) =>
   (response: Response): void => {
     const { body, headers } = options ?? {};
-    assert.equal(response.statusCode, statusCode);
+    assertEqual(response.statusCode, statusCode);
     if (body) assertMatches(response.body, body);
     if (headers) assertMatches(response.headers, headers);
   };
@@ -115,14 +116,14 @@ export const ApiSpecification = {
                 if (typeof verify === 'function') {
                   const succeeded = verify(response);
 
-                  if (succeeded === false) assert.fail();
+                  if (succeeded === false) assertFails();
                 } else if (Array.isArray(verify)) {
                   const [first, ...rest] = verify;
 
                   if (typeof first === 'function') {
                     const succeeded = first(response);
 
-                    if (succeeded === false) assert.fail();
+                    if (succeeded === false) assertFails();
                   }
 
                   const events = typeof first === 'function' ? rest : verify;

src/packages/emmett-fastify/src/e2e/decider/applicationLogicWithOC.int.spec.ts

@@ -1,10 +1,12 @@
 import {
+  assertEqual,
+  assertFails,
   assertMatches,
+  assertOk,
   getInMemoryEventStore,
   type EventStore,
 } from '@event-driven-io/emmett';
 import { type FastifyInstance } from 'fastify';
-import assert from 'node:assert/strict';
 import { randomUUID } from 'node:crypto';
 import { beforeEach, describe, it } from 'node:test';
 import { getApplication } from '../..';
@@ -34,9 +36,9 @@ void describe('Application logic with optimistic concurrency using Fastify', ()
 
     const current = createResponse.json<{ id: string }>();
     if (!current?.id) {
-      assert.fail();
+      assertFails();
     }
-    assert.ok(current.id);
+    assertOk(current.id);
 
     const shoppingCartId = current.id;
     ///////////////////////////////////////////////////
@@ -51,7 +53,7 @@ void describe('Application logic with optimistic concurrency using Fastify', ()
       url: `/clients/${clientId}/shopping-carts/${shoppingCartId}/product-items`,
       body: twoPairsOfShoes,
     });
-    assert.equal(response.statusCode, 204);
+    assertEqual(response.statusCode, 204);
 
     ///////////////////////////////////////////////////
     // 3. Add T-Shirt
@@ -67,7 +69,7 @@ void describe('Application logic with optimistic concurrency using Fastify', ()
       body: tShirt,
     });
 
-    assert.equal(response.statusCode, 204);
+    assertEqual(response.statusCode, 204);
 
     ///////////////////////////////////////////////////
     // 4. Remove pair of shoes
@@ -82,7 +84,7 @@ void describe('Application logic with optimistic concurrency using Fastify', ()
       method: 'DELETE',
       url: `/clients/${clientId}/shopping-carts/${shoppingCartId}/product-items?productId=${pairOfShoes.productId}&quantity=${pairOfShoes.quantity}&unitPrice=${pairOfShoes.unitPrice}`,
     });
-    assert.equal(response.statusCode, 204);
+    assertEqual(response.statusCode, 204);
 
     ///////////////////////////////////////////////////
     // 5. Confirm cart
@@ -93,7 +95,7 @@ void describe('Application logic with optimistic concurrency using Fastify', ()
       url: `/clients/${clientId}/shopping-carts/${shoppingCartId}/confirm`,
     });
 
-    assert.equal(response.statusCode, 204);
+    assertEqual(response.statusCode, 204);
 
     ///////////////////////////////////////////////////
     // 6. Try Cancel Cart
@@ -103,15 +105,15 @@ void describe('Application logic with optimistic concurrency using Fastify', ()
       url: `/clients/${clientId}/shopping-carts/${shoppingCartId}`,
     });
 
-    assert.equal(response.statusCode, 403);
+    assertEqual(response.statusCode, 403);
     assertMatches(response.json(), {
       detail: ShoppingCartErrors.CART_IS_ALREADY_CLOSED,
     });
     const result =
       await eventStore.readStream<ShoppingCartEvent>(shoppingCartId);
 
-    assert.ok(result);
-    assert.equal(result.events.length, Number(5));
+    assertOk(result);
+    assertEqual(result.events.length, Number(5));
 
     assertMatches(result?.events, [
       {

src/packages/emmett-fastify/src/e2e/testing.ts

@@ -1,5 +1,5 @@
+import { assertMatches, assertOk } from '@event-driven-io/emmett';
 import type { Response } from 'light-my-request';
-import assert from 'node:assert/strict';
 import type { Test } from 'supertest';
 
 export type TestResponse<RequestBody> = Omit<
@@ -14,8 +14,8 @@ export const expectNextRevisionInResponseEtag = <RequestBody>(
   response: TestResponse<RequestBody>,
 ) => {
   const eTagValue = response.headers['etag'];
-  assert.ok(eTagValue);
-  assert.match(eTagValue, /W\/"\d+.*"/);
+  assertOk(eTagValue);
+  assertMatches(eTagValue, /W\/"\d+.*"/);
 };
 
 export const runTwice = (test: () => Promise<Response>) => {

src/packages/emmett-testcontainers/src/eventStore/eventStoreDBContainer.e2e.spec.ts

@@ -1,11 +1,11 @@
 import { jsonEvent } from '@eventstore/db-client';
-import assert from 'node:assert/strict';
 import { randomUUID } from 'node:crypto';
 import { after, beforeEach, describe, it } from 'node:test';
 import {
   EventStoreDBContainer,
   StartedEventStoreDBContainer,
 } from './eventStoreDBContainer';
+import { assertOk } from '@event-driven-io/emmett';
 
 void describe('EventStoreDBContainer', () => {
   let container: StartedEventStoreDBContainer;
@@ -22,7 +22,7 @@ void describe('EventStoreDBContainer', () => {
       jsonEvent({ type: 'test-event', data: { test: 'test' } }),
     );
 
-    assert.ok(result.success);
+    assertOk(result.success);
   });
 
   after(async () => {