File tree Expand file tree Collapse file tree 1 file changed +24
-0
lines changed Expand file tree Collapse file tree 1 file changed +24
-0
lines changed Original file line number Diff line number Diff line change
1
+ var AV = require ( 'leanengine' ) ;
2
+
3
+ var redis = require ( "redis" ) ,
4
+ redisClient = redis . createClient ( process . env [ 'REDIS_URL_rtm_onoff_status' ] ) ;
5
+
6
+ redisClient . on ( "error" , function ( err ) {
7
+ console . log ( "Redis Error: " + err ) ;
8
+ } ) ;
9
+
10
+ const { promisify} = require ( 'util' ) ;
11
+ const mgetAsync = promisify ( redisClient . mget ) . bind ( redisClient ) ;
12
+
13
+ AV . Cloud . define ( '_clientOnline' , async function ( request ) {
14
+ redisClient . set ( request . params . peerId , true ) ;
15
+ } ) ;
16
+
17
+ AV . Cloud . define ( '_clientOffline' , async function ( request ) {
18
+ redisClient . set ( request . params . peerId , false ) ;
19
+ } ) ;
20
+
21
+ AV . Cloud . define ( 'getOnOffStatus' , async function ( request ) {
22
+ const res = await mgetAsync ( request . params . peerIds ) ;
23
+ return res ;
24
+ } ) ;
You can’t perform that action at this time.
0 commit comments