forked from ReDEnergy/SessionSync
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathglobal-events.js
More file actions
100 lines (77 loc) · 2.5 KB
/
Copy pathglobal-events.js
File metadata and controls
100 lines (77 loc) · 2.5 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
define(function(require, exports) {
'use strict';
// ------------------------------------------------------------------------
// Modules
const { PubSub } = require('../3rd/pubsub');
// ------------------------------------------------------------------------
// API
var GlobalEventSystem = (function GlobalEventSystem() {
var globalEvents = new PubSub();
return {
on : globalEvents.subscribe,
off : globalEvents.unsubscribe,
emit: globalEvents.publish,
};
})();
// Handles collection of PubSub events separated by diffrent namespaces
var NamespaceEvents = (function NamespaceEvents() {
var map = new Map();
//-------------------------------------------------------------------------
// Public API
var broadcastEvent = function broadcastEvent(topic, object) {
map.forEach(function(collection) {
collection.publish(topic, object);
});
};
var emitEvent = function emitEvent(namespace, topic, object) {
var collection = map.get(namespace);
if (collection instanceof PubSub) {
collection.publish(topic, object);
}
};
var subscribe = function subscribe(namespace, topic, callback) {
var collection = map.get(namespace);
if (collection instanceof PubSub === false) {
collection = new PubSub();
map.set(namespace, collection);
}
collection.subscribe(topic, callback);
};
var unsubscribe = function unsubscribe(namespace, topic, callback) {
var collection = map.get(namespace);
if (collection instanceof PubSub) {
collection.unsubscribe(topic, callback);
}
};
var remove = function remove(namespace) {
var collection = map.get(namespace);
if (collection instanceof PubSub) {
collection.messages = {};
map.delete(namespace);
}
};
return {
on : subscribe,
off: unsubscribe,
emit : emitEvent,
broadcast : broadcastEvent,
remove: remove
};
});
// WindowEvents based on window.document topic
var WindowEvents = new NamespaceEvents();
WindowEvents.onLocal = function onLocal(topic, callback) {
this.on(document, topic, callback);
};
WindowEvents.emitLocal = function emitLocal(topic, object) {
this.emit(document, topic, object);
};
// ------------------------------------------------------------------------
// Events
// ------------------------------------------------------------------------
// Init
// ------------------------------------------------------------------------
// Module exports
exports.GlobalEvents = GlobalEventSystem;
exports.WindowEvents = WindowEvents;
});