wip: fix launch

Author: Julusian

meteor/server/api/deviceTriggers/RundownContentObserver.ts

@@ -58,12 +58,12 @@ export class RundownContentObserver {
 
 		const observer = new RundownContentObserver(onChanged)
 
-		await observer.#initObservers(rundownPlaylistId, showStyleBaseId, rundownIds)
+		await observer.initObservers(rundownPlaylistId, showStyleBaseId, rundownIds)
 
 		return observer
 	}
 
-	async #initObservers(
+	private async initObservers(
 		rundownPlaylistId: RundownPlaylistId,
 		showStyleBaseId: ShowStyleBaseId,
 		rundownIds: RundownId[]

meteor/server/collections/implementations/asyncCollection.ts

@@ -53,15 +53,15 @@ export class WrappedAsyncMongoCollection<DBInterface extends { _id: ProtectedStr
 		callbacks: PromisifyCallbacks<ObserveChangesCallbacks<DBInterface>>,
 		options?: FindOptions<DBInterface>
 	): Promise<Meteor.LiveQueryHandle> {
-		return this.find(selector as any, options).observeChanges(dePromiseObjectOfFunctions(callbacks))
+		return this.find(selector as any, options).observeChangesAsync(dePromiseObjectOfFunctions(callbacks))
 	}
 
 	async observe(
 		selector: MongoQuery<DBInterface> | DBInterface['_id'],
 		callbacks: PromisifyCallbacks<ObserveCallbacks<DBInterface>>,
 		options?: FindOptions<DBInterface>
 	): Promise<Meteor.LiveQueryHandle> {
-		return this.find(selector as any, options).observe(dePromiseObjectOfFunctions(callbacks))
+		return this.find(selector as any, options).observeAsync(dePromiseObjectOfFunctions(callbacks))
 	}
 
 	async insertAsync(doc: DBInterface): Promise<DBInterface['_id']> {

meteor/server/publications/lib/debounce.ts

@@ -25,7 +25,7 @@ export class PromiseDebounce<TResult = void, TArgs extends unknown[] = []> {
 	 * Trigger an execution, and get the result.
 	 * @returns A promise that resolves with the result of the function
 	 */
-	async call(...args: TArgs): Promise<TResult> {
+	call = async (...args: TArgs): Promise<TResult> => {
 		return new Promise<TResult>((resolve, reject) => {
 			const listener: Listener<TResult> = { resolve, reject }
 			this.#waitingListeners.push(listener)
@@ -38,7 +38,7 @@ export class PromiseDebounce<TResult = void, TArgs extends unknown[] = []> {
 	/**
 	 * Trigger an execution, but don't report the result.
 	 */
-	trigger(...args: TArgs): void {
+	trigger = (...args: TArgs): void => {
 		// If an execution is 'imminent', don't do anything
 		if (this.#pendingArgs) {
 			this.#pendingArgs = args
@@ -52,11 +52,11 @@ export class PromiseDebounce<TResult = void, TArgs extends unknown[] = []> {
 		this.#timeout = Meteor.setTimeout(() => {
 			this.#timeout = undefined
 
-			this.#executeFn(args)
+			this.executeFn(args)
 		}, this.#wait)
 	}
 
-	#executeFn(args: TArgs): void {
+	private executeFn(args: TArgs): void {
 		// If an execution is still in progress, mark as pending and stop
 		if (this.#isExecuting) {
 			this.#pendingArgs = args
@@ -96,15 +96,15 @@ export class PromiseDebounce<TResult = void, TArgs extends unknown[] = []> {
 				// If there is a pending execution, run that soon
 				if (this.#pendingArgs) {
 					const args = this.#pendingArgs
-					Meteor.setTimeout(() => this.#executeFn(args), 0)
+					Meteor.setTimeout(() => this.executeFn(args), 0)
 				}
 			})
 	}
 
 	/**
 	 * Cancel any waiting execution
 	 */
-	cancelWaiting(error?: Error): void {
+	cancelWaiting = (error?: Error): void => {
 		this.#pendingArgs = null
 
 		if (this.#timeout) {

meteor/server/publications/pieceContentStatusUI/rundown/rundownContentObserver.ts

@@ -60,15 +60,15 @@ export class RundownContentObserver {
 
 		const observer = new RundownContentObserver(cache)
 
-		await observer.#initShowStyleBaseIdObserver()
+		await observer.initShowStyleBaseIdObserver()
 
 		// This takes ownership of the #showStyleBaseIdObserver, and will stop it if this throws
-		await observer.#initContentObservers(rundownIds)
+		await observer.initContentObservers(rundownIds)
 
 		return observer
 	}
 
-	async #initShowStyleBaseIdObserver() {
+	private async initShowStyleBaseIdObserver() {
 		// Run the ShowStyleBase query in a ReactiveMongoObserverGroup, so that it can be restarted whenever
 		this.#showStyleBaseIdObserver = await ReactiveMongoObserverGroup(async () => {
 			// Clear already cached data
@@ -103,7 +103,7 @@ export class RundownContentObserver {
 		})
 	}
 
-	async #initContentObservers(rundownIds: RundownId[]) {
+	private async initContentObservers(rundownIds: RundownId[]) {
 		// Subscribe to the database, and pipe any updates into the ReactiveCacheCollections
 		this.#observers = await waitForAllObserversReady([
 			Rundowns.observeChanges(