summaryrefslogtreecommitdiff
path: root/includes/external/matrix/node_modules/matrix-js-sdk/lib/ReEmitter.js
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/lib/ReEmitter.js
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/lib/ReEmitter.js')
-rw-r--r--includes/external/matrix/node_modules/matrix-js-sdk/lib/ReEmitter.js89
1 files changed, 89 insertions, 0 deletions
diff --git a/includes/external/matrix/node_modules/matrix-js-sdk/lib/ReEmitter.js b/includes/external/matrix/node_modules/matrix-js-sdk/lib/ReEmitter.js
new file mode 100644
index 0000000..8122797
--- /dev/null
+++ b/includes/external/matrix/node_modules/matrix-js-sdk/lib/ReEmitter.js
@@ -0,0 +1,89 @@
+"use strict";
+
+var _interopRequireDefault = require("@babel/runtime/helpers/interopRequireDefault");
+Object.defineProperty(exports, "__esModule", {
+ value: true
+});
+exports.TypedReEmitter = exports.ReEmitter = void 0;
+var _defineProperty2 = _interopRequireDefault(require("@babel/runtime/helpers/defineProperty"));
+/*
+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
+
+class ReEmitter {
+ constructor(target) {
+ this.target = target;
+ (0, _defineProperty2.default)(this, "reEmitters", new Map());
+ }
+
+ // Map from emitter to event name to re-emitter
+
+ reEmit(source, eventNames) {
+ 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) => {
+ // 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);
+ }
+ }
+ stopReEmitting(source, eventNames) {
+ 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);
+ }
+}
+exports.ReEmitter = ReEmitter;
+class TypedReEmitter extends ReEmitter {
+ constructor(target) {
+ super(target);
+ }
+ reEmit(source, eventNames) {
+ super.reEmit(source, eventNames);
+ }
+ stopReEmitting(source, eventNames) {
+ super.stopReEmitting(source, eventNames);
+ }
+}
+exports.TypedReEmitter = TypedReEmitter;
+//# sourceMappingURL=ReEmitter.js.map \ No newline at end of file