Subversion Repository Public Repository

Nextrek

@ 1126
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
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
const CHAT = Symbol.for("My.App.Namespace.chat");

var globalSymbols = Object.getOwnPropertySymbols(global);
var hasChat = (globalSymbols.indexOf(CHAT) > -1);

if (!hasChat) {
    global[CHAT] = {
        ROLES: {
            OPERATOR: 'OPERATOR',
            CUSTOMER: 'CUSTOMER'
        },

        DEFAULT_ROOMS: {
            OPERATORS: 'OPERATORS'
        },

        EVENTS: {
            CONNECTION: {
                OPEN: 'CONNECTION:OPEN',
                CLOSE: 'CONNECTION:CLOSE'
            },
            ROOM: {
                CREATED: 'ROOM:CREATED',
                JOIN: 'ROOM:JOIN',
                LEAVE: 'ROOM:LEAVE'
            },
            SEND: {
                MESSAGE: 'SEND:MESSAGE',
                IMAGE: 'SEND:IMAGE',
                ATTACHMENT: 'SEND:FILE',
                LINK: 'SEND:LINK'
            },
            OPERATORS: {
                LIST: {
                    UPDATE: 'OPERATORS:LIST:UPDATE'
                }
            },
            CUSTOMERS: {
                LIST: {
                    UPDATE: 'CUSTOMERS:LIST:UPDATE'
                }
            },
            ROOMS: {
                LIST: {
                    UPDATE: 'ROOMS:LIST:UPDATE'
                }
            }
        },

        ERRORS: {
            USER:
                {
                    NOT_FOUND: 'ERROR:USER:NOTFOUND'
                }
        },

        users: [],

        rooms: {
            CUSTOMER: {},
            OPERATOR: {}
        },

        isRoomAllowed(from, to) {
            if (from.role === _this.ROLES.OPERATOR) {

            }
        },

        usersMap: {},

        getUser(id) {
            const user = this.usersMap[id];
            return {
                id: user.id,
                name: user.name
            }
        },

        createUser(name, role, id) {
            const _this = this;
            const user = {
                name: name,
                role: role,
                room: id,
            }

            this.addUser(user);

            return user;
        },

        addUser(user) {
            this.usersMap[user.room] = user;
            this.users.push(user);
            this.rooms[user.role][user.room] = [];
        },

        deleteUser(user) {
            this.users.splice(this.users.indexOf(user), 1);
            delete this.usersMap[user.room];
        },
        
        getUsersByRole(role) {
            return this.users.filter((user) => {
                return user.role === role
            });
        },
        
        countUsersByRole(role) {
            this.getUsersByRole(role).length
        },
        
        isUserInRoom(owner, guest) {
            return this.rooms[owner.role][owner.room].indexOf(guest) > - 1;
        },

        joinOwnerRoom(owner, user) {
            if (user && user.role === this.ROLES.OPERATOR) {
                if (!this.isUserInRoom(owner, user) && !this.isUserInRoom(user, owner)) {
                    this.rooms[owner.role][owner.room].push(user);
                    return owner.room;
                } else {
                    return this.rooms[owner.role][owner.room] ? owner.room : user.room;
                }
            }
        },

        event(type, data) {
            return {
                type,
                data,
                ts: Date.now()
            }
        },

        message(data, room, from) {
            return {
                from,
                room: room,
                content: data.content,
                contentType: data.contentType
            }
        }
    };
}

var singleton = {};

Object.defineProperty(singleton, "instance", {
    get: function () {
        return global[CHAT];
    }
});

Object.freeze(singleton);


module.exports = singleton;

Commits for Nextrek/socketIO/chat.js

Diff revisions: vs.
Revision Author Commited Message
1126 Diff Diff GGentile picture GGentile Fri 04 Jan, 2019 14:09:04 +0000
1125 Diff Diff GGentile picture GGentile Fri 04 Jan, 2019 11:31:52 +0000

event ROOM:CREATED

1124 Diff Diff GGentile picture GGentile Fri 04 Jan, 2019 11:20:58 +0000
1123 Diff Diff GGentile picture GGentile Fri 04 Jan, 2019 00:19:22 +0000
1121 Diff Diff GGentile picture GGentile Wed 02 Jan, 2019 13:10:03 +0000

chat singleton

1120 Diff Diff GGentile picture GGentile Tue 04 Dec, 2018 10:31:37 +0000
1119 GGentile picture GGentile Mon 03 Dec, 2018 23:13:28 +0000