chore: Further clean up.

Author: goloroden

.github/dependabot.yml

@@ -17,7 +17,7 @@ updates:
     prefix-development: chore
 
 - package-ecosystem: docker
-  directory: "/test/shared/docker/eventsourcingdb"
+  directory: "/test/eventsourcingdb"
   schedule:
     interval: weekly
   open-pull-requests-limit: 10

package-lock.json

@@ -15,15 +15,13 @@
 	"types": "./dist/index.d.ts",
 	"dependencies": {
 		"axios": "1.8.4",
-		"http-status-codes": "2.3.0",
 		"stream-to-async-iterator": "1.0.0"
 	},
 	"devDependencies": {
 		"@biomejs/biome": "1.9.4",
-		"@types/express": "5.0.1",
 		"@types/node": "22.14.0",
 		"@types/shelljs": "0.8.15",
-		"express": "5.1.0",
+		"get-port": "7.1.0",
 		"shelljs": "0.9.2",
 		"tsup": "8.4.0",
 		"tsx": "4.19.3",
@@ -35,8 +33,8 @@
 		"format": "npx biome format --write .",
 		"qa": "npm run analyze && npm run test",
 		"test": "npm run test:unit && npm run test:integration",
-		"test:unit": "node --test --import tsx \"./test/unit/**/*.ts\"",
-		"test:integration": "node --test --import tsx \"./test/integration/**/*.ts\""
+		"test:unit": "node --test --import tsx \"./src/**/*.test.ts\"",
+		"test:integration": "node --test --import tsx \"./test/**/*.test.ts\""
 	},
 	"repository": {
 		"type": "git",

package.json

@@ -17,19 +17,4 @@ type Precondition =
 			payload: IsSubjectOnEventIdPrecondition;
 	  };
 
-const isSubjectPristine = (subject: string): Precondition => {
-	return {
-		type: 'isSubjectPristine',
-		payload: { subject },
-	};
-};
-
-const isSubjectOnEventId = (subject: string, eventId: string): Precondition => {
-	return {
-		type: 'isSubjectOnEventId',
-		payload: { subject, eventId },
-	};
-};
-
 export type { Precondition };
-export { isSubjectPristine, isSubjectOnEventId };

src/Precondition.ts

@@ -1,7 +1,8 @@
 import { Client } from './Client.js';
 import type { ObserveEventsOptions } from './ObserveEventsOptions.js';
-import { isSubjectOnEventId, isSubjectPristine } from './Precondition.js';
 import type { ReadEventsOptions } from './ReadEventsOptions.js';
+import { isSubjectOnEventId } from './isSubjectOnEventId.js';
+import { isSubjectPristine } from './isSubjectPristine.js';
 
 export { Client, isSubjectPristine, isSubjectOnEventId };
 export type { ReadEventsOptions, ObserveEventsOptions };

src/index.ts

@@ -0,0 +1,10 @@
+import type { Precondition } from './Precondition.js';
+
+const isSubjectOnEventId = (subject: string, eventId: string): Precondition => {
+	return {
+		type: 'isSubjectOnEventId',
+		payload: { subject, eventId },
+	};
+};
+
+export { isSubjectOnEventId };

src/isSubjectOnEventId.ts

@@ -0,0 +1,10 @@
+import type { Precondition } from './Precondition.js';
+
+const isSubjectPristine = (subject: string): Precondition => {
+	return {
+		type: 'isSubjectPristine',
+		payload: { subject },
+	};
+};
+
+export { isSubjectPristine };

src/isSubjectPristine.ts

@@ -1,6 +1,6 @@
 import assert from 'node:assert/strict';
 import { suite, test } from 'node:test';
-import { LinesDecoder } from '../../../src/ndjson/LinesDecoder.js';
+import { LinesDecoder } from './LinesDecoder.js';
 
 suite('LinesDecoder', (): void => {
 	test('returns all completed lines on write().', (): void => {

test/unit/ndjson/LinesDecoderTests.ts src/ndjson/LinesDecoder.test.tstest/unit/ndjson/LinesDecoderTests.ts renamed to src/ndjson/LinesDecoder.test.ts

@@ -1,7 +1,7 @@
 import assert from 'node:assert/strict';
 import { Readable } from 'node:stream';
 import { suite, test } from 'node:test';
-import { readNdJsonStream } from '../../../src/ndjson/readNdJsonStream.js';
+import { readNdJsonStream } from './readNdJsonStream.js';
 
 suite('readNdJsonStream', (): void => {
 	test('returns an async generator that yields parsed json objects.', async (): Promise<void> => {