summaryrefslogtreecommitdiff
path: root/includes/external/matrix/node_modules/matrix-js-sdk/src/ReEmitter.ts
diff options
context:
space:
mode:
authorRaindropsSys <contact@minteck.org>2023-04-24 14:03:36 +0200
committerRaindropsSys <contact@minteck.org>2023-04-24 14:03:36 +0200
commit633c92eae865e957121e08de634aeee11a8b3992 (patch)
tree09d881bee1dae0b6eee49db1dfaf0f500240606c /includes/external/matrix/node_modules/matrix-js-sdk/src/ReEmitter.ts
parentc4657e4509733699c0f26a3c900bab47e915d5a0 (diff)
downloadpluralconnect-633c92eae865e957121e08de634aeee11a8b3992.tar.gz
pluralconnect-633c92eae865e957121e08de634aeee11a8b3992.tar.bz2
pluralconnect-633c92eae865e957121e08de634aeee11a8b3992.zip
Updated 18 files, added 1692 files and deleted includes/system/compare.inc (automated)
Diffstat (limited to 'includes/external/matrix/node_modules/matrix-js-sdk/src/ReEmitter.ts')
-rw-r--r--includes/external/matrix/node_modules/matrix-js-sdk/src/ReEmitter.ts91
1 files changed, 91 insertions, 0 deletions
diff --git a/includes/external/matrix/node_modules/matrix-js-sdk/src/ReEmitter.ts b/includes/external/matrix/node_modules/matrix-js-sdk/src/ReEmitter.ts
new file mode 100644
index 0000000..565e8ea
--- /dev/null
+++ b/includes/external/matrix/node_modules/matrix-js-sdk/src/ReEmitter.ts
@@ -0,0 +1,91 @@
+/*
+Copyright 2015, 2016 OpenMarket Ltd
+Copyright 2017 Vector Creations Ltd
+Copyright 2017 New Vector Ltd
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+// eslint-disable-next-line no-restricted-imports
+import { EventEmitter } from "events";
+
+import { ListenerMap, TypedEventEmitter } from "./models/typed-event-emitter";
+
+export class ReEmitter {
+ public constructor(private readonly target: EventEmitter) {}
+
+ // Map from emitter to event name to re-emitter
+ private reEmitters = new Map<EventEmitter, Map<string, (...args: any[]) => void>>();
+
+ public reEmit(source: EventEmitter, eventNames: string[]): void {
+ let reEmittersByEvent = this.reEmitters.get(source);
+ if (!reEmittersByEvent) {
+ reEmittersByEvent = new Map();
+ this.reEmitters.set(source, reEmittersByEvent);
+ }
+
+ for (const eventName of eventNames) {
+ // We include the source as the last argument for event handlers which may need it,
+ // such as read receipt listeners on the client class which won't have the context
+ // of the room.
+ const forSource = (...args: any[]): void => {
+ // EventEmitter special cases 'error' to make the emit function throw if no
+ // handler is attached, which sort of makes sense for making sure that something
+ // handles an error, but for re-emitting, there could be a listener on the original
+ // source object so the test doesn't really work. We *could* try to replicate the
+ // same logic and throw if there is no listener on either the source or the target,
+ // but this behaviour is fairly undesireable for us anyway: the main place we throw
+ // 'error' events is for calls, where error events are usually emitted some time
+ // later by a different part of the code where 'emit' throwing because the app hasn't
+ // added an error handler isn't terribly helpful. (A better fix in retrospect may
+ // have been to just avoid using the event name 'error', but backwards compat...)
+ if (eventName === "error" && this.target.listenerCount("error") === 0) return;
+ this.target.emit(eventName, ...args, source);
+ };
+ source.on(eventName, forSource);
+ reEmittersByEvent.set(eventName, forSource);
+ }
+ }
+
+ public stopReEmitting(source: EventEmitter, eventNames: string[]): void {
+ const reEmittersByEvent = this.reEmitters.get(source);
+ if (!reEmittersByEvent) return; // We were never re-emitting these events in the first place
+
+ for (const eventName of eventNames) {
+ source.off(eventName, reEmittersByEvent.get(eventName)!);
+ reEmittersByEvent.delete(eventName);
+ }
+
+ if (reEmittersByEvent.size === 0) this.reEmitters.delete(source);
+ }
+}
+
+export class TypedReEmitter<Events extends string, Arguments extends ListenerMap<Events>> extends ReEmitter {
+ public constructor(target: TypedEventEmitter<Events, Arguments>) {
+ super(target);
+ }
+
+ public reEmit<ReEmittedEvents extends string, T extends Events & ReEmittedEvents>(
+ source: TypedEventEmitter<ReEmittedEvents, any>,
+ eventNames: T[],
+ ): void {
+ super.reEmit(source, eventNames);
+ }
+
+ public stopReEmitting<ReEmittedEvents extends string, T extends Events & ReEmittedEvents>(
+ source: TypedEventEmitter<ReEmittedEvents, any>,
+ eventNames: T[],
+ ): void {
+ super.stopReEmitting(source, eventNames);
+ }
+}