This repository was archived by the owner on Dec 15, 2019. It is now read-only.
File tree Expand file tree Collapse file tree 3 files changed +18
-4
lines changed Expand file tree Collapse file tree 3 files changed +18
-4
lines changed Original file line number Diff line number Diff line change 2222 "port" : 8080 ,
2323 "storagePath" : " ./_storage" ,
2424 "uploadSizeLimitPerFile" : 5000000000 ,
25- "totalStorageLimitPerUser" : -1 ,
25+ "totalStorageLimitPerUser" : 10000000000 ,
2626 "mediaStreamChunckSize" : 4096000
2727 },
2828 "mongodb" : {
Original file line number Diff line number Diff line change @@ -33,7 +33,7 @@ app.use(cors());
3333app . use ( '/api' , require ( './api/api' ) ) ;
3434
3535// Spawn Websocket
36- require ( './websocket' ) ( server ) ;
36+ require ( './websocket' ) . launch ( server ) ;
3737
3838// Add express http-server
3939server . on ( 'request' , app ) ;
Original file line number Diff line number Diff line change 11const userModel = require ( './models/user' ) ;
22const WebSocket = require ( 'ws' ) ;
3+ const userMap = { } ;
34
4- module . exports = server => {
5+ /**
6+ * Launches the websocket broadcast server
7+ * @param server
8+ */
9+ module . exports . launch = server => {
510 const wss = new WebSocket . Server ( { server : server } ) ;
6- const userMap = { } ;
711
812 wss . on ( 'connection' , ws => {
913 let user ;
@@ -100,3 +104,13 @@ module.exports = server => {
100104 } ) ;
101105 } ) ;
102106} ;
107+
108+ /**
109+ * Returns the amount of currenty connected user
110+ * @param userid
111+ * @returns {number }
112+ */
113+ module . exports . getSessionsBy = userid => {
114+ const user = userMap [ userid ] ;
115+ return ( ( user && user . websockets ) || [ ] ) . length ;
116+ } ;
You can’t perform that action at this time.
0 commit comments