Get rid of oplog dependency

.deploy/default/settings.json

@@ -1,5 +1,15 @@
 {
   "public": {
 
+  },
+  "packages": {
+    "mongo": {
+      "options": {
+        "minPoolSize": 100,
+        "maxPoolSize": 1000
+      },
+      "oplogUrl": "",
+      "oplogIncludeCollections": []
+    }
   }
 }

.deploy/ghcr.io/settings.json

@@ -0,0 +1,15 @@
+{
+  "public": {
+
+  },
+  "packages": {
+    "mongo": {
+      "options": {
+        "minPoolSize": 100,
+        "maxPoolSize": 1000
+      },
+      "oplogUrl": "",
+      "oplogIncludeCollections": []
+    }
+  }
+}

.env

@@ -3,5 +3,6 @@ PORT=3000
 
 MONGO_VERSION=5.0
 MONGO_URL=mongodb://patient-db:27017/meteor
+MONGO_OPLOG_URL=""
 
 HTTP_FORWARDED_COUNT=1

.github/workflows/ci:build.yml

@@ -88,6 +88,7 @@ jobs:
       - uses: actions/checkout@v4
         with:
           sparse-checkout: |
+            settings.json
             scripts/healthcheck.cjs
             scripts/assert-replica-set.js
             .github/actions/docker/container/is-healthy/action.yml
@@ -176,11 +177,18 @@ jobs:
           container: mongodb
           timeout: 60
 
+      - name: Configure server
+        id: configure-server
+        run: |
+          echo "settings=$(tr -d '\r\n' < settings.json)" >> "${GITHUB_OUTPUT}"
+
       - name: Run server
         id: server
         env:
           ROOT_URL: http://localhost
           MONGO_URL: mongodb://localhost:27017/meteor
+          MONGO_OPLOG_URL: ""
+          METEOR_SETTINGS: ${{ steps.configure-server.outputs.meteor-settings }}
           PORT: 3000
         run: |
           cd dist

.github/workflows/ci:build:image.yml

@@ -84,6 +84,7 @@ jobs:
       - uses: actions/checkout@v4
         with:
           sparse-checkout: |
+            settings.json
             scripts/assert-replica-set.js
             .github/actions/docker/container/ip-address/action.yml
             .github/actions/docker/container/is-healthy/action.yml
@@ -138,10 +139,17 @@ jobs:
           container: mongodb
           timeout: 60
 
+      - name: Configure server
+        id: configure-server
+        run: |
+          echo "settings=$(tr -d '\r\n' < settings.json)" >> "${GITHUB_OUTPUT}"
+
       - name: Run server
         env:
           ROOT_URL: http://localhost
           MONGO_URL: mongodb://mongodb:27017/meteor
+          MONGO_OPLOG_URL: ""
+          METEOR_SETTINGS: ${{ steps.configure-server.outputs.meteor-settings }}
           PORT: 3000
         run: |
           docker container run \
@@ -151,6 +159,8 @@ jobs:
             --publish "${PORT}:${PORT}" \
             --env "ROOT_URL=${ROOT_URL}" \
             --env "MONGO_URL=${MONGO_URL}" \
+            --env "MONGO_OPLOG_URL=${MONGO_OPLOG_URL}" \
+            --env "METEOR_SETTINGS=${METEOR_SETTINGS}" \
             --env "PORT=${PORT}" \
             --name server \
             ${{ steps.server-image-url.outputs.url }}

Dockerfile

@@ -104,7 +104,8 @@ EXPOSE 3000
 ENV \
   ROOT_URL="http://localhost" \
   PORT="3000" \
-  MONGO_URL="mongodb://localhost:27017/meteor"
+  MONGO_URL="mongodb://localhost:27017/meteor" \
+  MONGO_OPLOG_URL=""
 
 HEALTHCHECK \
   --interval=21s \

codecov.yml

@@ -2,7 +2,7 @@ coverage:
   status:
     project:
       default:
-        target: 67%
+        target: 71%
         threshold: 1%
     patch:
       default:

compose.yaml

@@ -8,6 +8,8 @@ services:
       - ROOT_URL=${ROOT_URL}
       - PORT=${PORT}
       - MONGO_URL=${MONGO_URL}
+      - MONGO_OPLOG_URL=${MONGO_OPLOG_URL}
+      - METEOR_SETTINGS=${METEOR_SETTINGS}
       - HTTP_FORWARDED_COUNT=${HTTP_FORWARDED_COUNT}
     depends_on:
       patient-db:

imports/_test/fixtures.ts

@@ -3,11 +3,18 @@
 
 import {assert, expect} from 'chai';
 
-import {cleanup as unmount} from '@testing-library/react';
+import {Meteor} from 'meteor/meteor';
+
 import totalOrder from 'total-order';
 import {sorted} from '@iterable-iterator/sorted';
 
+import sleep from '../lib/async/sleep';
+
+// eslint-disable-next-line import/no-unassigned-import
+import '../api/endpoint/_dev/_disableRateLimiting';
 import logout from '../api/user/logout';
+import define from '../api/collection/define';
+import {removeCollection} from '../api/collection/registry';
 import invoke from '../api/endpoint/invoke';
 import call from '../api/endpoint/call';
 import reset from '../api/endpoint/_dev/reset';
@@ -16,6 +23,10 @@
 import type Selector from '../api/query/Selector';
 import appIsReady from '../app/isReady';
 import isAppTest from '../app/isAppTest';
+import {_router} from '../ui/App';
+import {getWatchStreamCount} from '../api/query/watch';
+
+import {unmount as _unmount} from './react';
 
 export {
 	default as randomId,
@@ -25,6 +36,28 @@
 
 let resolving = 0;
 
+export const waitFor = async (condition: () => boolean) => {
+	while (!condition()) {
+		// eslint-disable-next-line no-await-in-loop
+		await sleep(50);
+	}
+};
+
+export const withMockCollection =
+	<T extends Document, U = T>(
+		callback: (collection: Collection<T, U>) => Promise<void> | void,
+	) =>
+	async () => {
+		const collectionName = '__mocks__';
+		const collection = define<T, U>(collectionName);
+		try {
+			await callback(collection);
+		} finally {
+			await collection.dropCollectionAsync();
+			removeCollection(collectionName);
+		}
+	};
+
 const resolveOnPopstate = async () =>
 	new Promise<void>((resolve) => {
 		let pos = ++resolving;
@@ -77,17 +110,43 @@
 	return history.length - 1;
 };
 
+const mount = isAppTest()
+	? () => {
+			_router.navigate('/');
+	  }
+	: // eslint-disable-next-line @typescript-eslint/no-empty-function
+	  () => {};
+
+const unmount = isAppTest()
+	? () => {
+			_router.navigate('/_test/unmount');
+	  }
+	: () => {
+			_unmount();
+	  };
+
+const assertChangeStreamWatchersAreOff = () => {
+	const n = getWatchStreamCount();
+	if (n !== 0) {
+		console.warn(`ChangeStream watch count is different from 0 (got ${n})!`);
+	}
+};
+
 export const client = (title, fn) => {
 	if (Meteor.isClient) {
 		const cleanup = async () => {
 			await logout();
 			unmount();
+			assertChangeStreamWatchersAreOff();
+			mount();
 			await call(reset);
 		};
 
 		let original;
 
 		const prepare = async () => {
+			// @ts-expect-error TODO
+			await import('./mocha.css');
 			await import('../../client/polyfill');
 
 			original = await forgetHistory();
@@ -174,23 +233,71 @@
 
 export const dropIds = (x) => x.map(dropId);
 
-export const create = (template, extra) => {
-	if (typeof template === 'function') return extra ?? template();
+export const dropOwner = ({owner, ...rest}) => {
+	assert(typeof owner === 'string');
+	return rest;
+};
+
+export const dropOwners = (x) => x.map(dropOwner);
+
+type Created<T> = T extends {[K in keyof T]: T[K]}
+	? {[K in keyof T]: Created<T[K]>}
+	: T extends () => any
+	? ReturnType<T>
+	: never;
+
+type Extra<T> = T extends any[]
+	? Created<T>
+	: T extends {[K in keyof T]: T[K]}
+	? Partial<Created<T>>
+	: T extends () => any
+	? ReturnType<T>
+	: never;
+
+export function create<T extends () => any>(
+	template: T,
+	extra?: Extra<T>,
+	hasExtra?: boolean,
+): Created<T>;
+export function create<T extends {[K in keyof T]: T[K]}>(
+	template: T,
+	extra?: Extra<T>,
+	hasExtra?: boolean,
+): Created<T>;
+
+export function create<T>(
+	template: T,
+	extra?: Extra<T>,
+	hasExtra?: boolean,
+): Created<T> {
+	if (typeof template === 'function') return hasExtra ? extra : template();
 	if (Array.isArray(template)) {
-		return template
-			.map((x, i) => create(x, extra?.[i]))
-			.concat(extra?.slice(template.length) ?? []);
+		return (template as Array<T[keyof T]>)
+			.map((x, i) =>
+				create(
+					x,
+					extra?.[i],
+					Object.prototype.hasOwnProperty.call(extra ?? [], i),
+				),
+			)
+			.concat(extra?.slice(template.length) ?? []) as Created<T>;
 	}
 
 	return Object.fromEntries(
 		(extra === undefined ? [] : Object.entries(extra)).concat(
-			Object.entries(template).map(([key, value]) => [
-				key,
-				create(value, extra?.[key]),
-			]),
+			Object.entries(template as {[K in keyof T]: T[K]}).map(
+				<V>([key, value]: [string, V]) => [
+					key,
+					create(
+						value,
+						extra?.[key],
+						Object.prototype.hasOwnProperty.call(extra ?? {}, key),
+					),
+				],
+			),
 		),
-	);
-};
+	) as Created<T>;
+}
 
 export const findOneOrThrow = async <T extends Document, U = T>(
 	collection: Collection<T, U>,
@@ -204,4 +311,7 @@
 	return result!;
 };
 
-export const makeTemplate = (template) => (extra?) => create(template, extra);
+export const makeTemplate = (template) => (extra?) =>
+	create(template, extra, extra !== undefined);
+
+export const isNode = () => Meteor.isServer;

imports/_test/mocha.css

@@ -0,0 +1,38 @@
+div#mocha {
+	z-index: 99999999;
+	opacity: 0;
+	position: fixed;
+	top: 64px;
+	left: 73px;
+	right: 0;
+	background: white;
+	margin: 0;
+	padding: 1em;
+	overflow: auto;
+	height: calc(100% - 64px);
+}
+
+div#mocha:hover {
+	opacity: 0.9;
+}
+
+div#mocha > ul#mocha-report > li.suite > ul > li.test::before {
+	font-size: 18px;
+	line-height: 1em;
+}
+
+div#mocha > ul#mocha-report > li.suite > ul > li.test.pass::before {
+	color: #0b9;
+}
+
+div#mocha > ul#mocha-report > li.suite > ul > li.test.fail::before {
+	color: #b00;
+}
+
+div#mocha > ul#mocha-stats {
+	position: initial;
+}
+
+div#mocha > ul#mocha-report > li.suite > h1 {
+	font-size: 0.8em;
+}

imports/_test/react.ts

@@ -0,0 +1,13 @@
+import {configure as configureReact} from '@testing-library/react';
+
+configureReact({
+	reactStrictMode: true,
+});
+
+export {
+	render,
+	renderHook,
+	waitFor,
+	waitForElementToBeRemoved,
+	cleanup as unmount,
+} from '@testing-library/react';