ExNodeServer/listening.js at master · exildev/ExNodeServer · GitHub

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
101
102
103
104
105
106
107
108
109
110
111
112
113
114

module.exports = {
	listenings : {},

	get_webusers: function(type){
		return this.listenings[type];
	},

	add_messages_by_type: function (type, messages, callback){
		if (this.listenings[type] == undefined){
			this.listenings[type] = {};
		}
		for (var webuser in this.listenings[type]){
			if (this.listenings[type][webuser] == undefined){
				this.listenings[type][webuser] = {'sessions': {}, 'messages': [] };
			}

			for (var i in messages) {
				var message_id = this.listenings[type][webuser]['messages'].length.toString(16);
				messages[i]['message_id'] = message_id;
				messages[i]['_visited_'] = [];
				this.listenings[type][webuser]['messages'][message_id] = messages[i];
				for (var django_id in this.listenings[type][webuser]['sessions']){
					var socket = this.listenings[type][webuser]['sessions'][django_id];
					callback(django_id, socket, messages[i]);
				}
			}
		}
	},

	add_messages: function (type, webuser, messages){
		if (this.listenings[type] == undefined){
			this.listenings[type] = {};
		}
		if (this.listenings[type][webuser] == undefined){
			this.listenings[type][webuser] = {'sessions': {}, 'messages': []};
		}

		for (var i in messages){
			var message_id = this.listenings[type][webuser]['messages'].length.toString(16);
			messages[i]['message_id'] = message_id;
			messages[i]['_visited_'] = [];
			this.listenings[type][webuser]['messages'][message_id] = messages[i];
		}
	},

	visit_message: function (type, webuser, message_id, session_id, callback){
		if (this.listenings[type][webuser]['messages'][message_id]){
			this.listenings[type][webuser]['messages'][message_id]['_visited_'].push(session_id);
			for (var session_id in this.listenings[type][webuser]['sessions']){
				callback(session_id, this.listenings[type][webuser]['sessions'][session_id], message_id);
			}
		}
	},

	add_session: function (type, webuser, session, socket){
		if (this.listenings[type] == undefined){
			this.listenings[type] = {};
		}
		if (this.listenings[type][webuser] == undefined){
			this.listenings[type][webuser] = {'sessions': {}, 'messages': []};
		}
		if (this.listenings[type][webuser]['sessions'][session] == undefined){
			this.listenings[type][webuser]['sessions'][session] = {};
		}

		this.listenings[type][webuser]['sessions'][session][socket.id] = socket;
	},

	get_messages: function (type, webuser){
		if (this.listenings[type] == undefined){
			this.listenings[type] = {};
		}
		if (this.listenings[type][webuser] == undefined){
			this.listenings[type][webuser] = {'sessions': {}, 'messages': []};
		}

		return this.listenings[type][webuser]['messages'];
	},

	get_sessions: function (type, webuser){
		if (this.listenings[type] == undefined){
			this.listenings[type] = {};
		}
		if (this.listenings[type][webuser] == undefined){
			this.listenings[type][webuser] = {'sessions': {}, 'messages': []};
		}

		return this.listenings[type][webuser]['sessions'];
	},

	delete_messages: function (type, webuser, message_id){
		if (this.listenings[type] == undefined){
			this.listenings[type] = {};
		}
		if (this.listenings[type][webuser] == undefined){
			this.listenings[type][webuser] = {'sessions': {}, 'messages': []};
		}

		delete this.listenings[type][webuser]['messages'][message_id];
	},

	delte_session: function (type, webuser, session, socket_id){
		if (this.listenings[type] == undefined){
			this.listenings[type] = {};
		}
		if (this.listenings[type][webuser] == undefined){
			this.listenings[type][webuser] = {'sessions': {}, 'messages': []};
		}

		delete this.listenings[type][webuser]['sessions'][session][socket_id];
	}

};