HumixAPI/index.js at master · normankung/HumixAPI · 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
var redis = require('redis');
var config = ("./config.js");
var redisPort = config.redisPort || "6379";
var redisIP = config.redisIP || "127.0.0.1";
var dbSelect=config.dbSelect||"0";

function getUserContext(userName){

    return new Promise(function(resolve , reject){
    var client = redis.createClient(redisPort,redisIP);
    client.select(dbSelect,function(err){
    var userPrefix="user."+userName;
    if(err)
    {
        client.end(true);
        console.log(err);
        reject(err);
    }else{

          client.hgetall(userPrefix,function(err,res){

                    if(err)
                    {

                       client.end(true);
                         reject(err);
                    }
                    else {

                        if(res){
                            client.end(true);
                            resolve(res);
                        }
                            reject('can not query this user');

                    }

                });


    }


});
    });
}


var setUserContext= function (userName,context){

return new Promise(function(resolve,reject){
var client = redis.createClient(redisPort,redisIP);
 var userPrefix='user.'+userName;
 client.select(dbSelect,function(err){
     if(err){
         client.end(true);
         reject (err);
     }else{


         for(var i in context) {
             if(typeof(context[i])!='string'){

             context[i]  = JSON.stringify(context[i]);
             }
         }

        client.hmset( userPrefix,context,function(err,res){
            if(err) {
                client.end(true);
                reject(err);
            }
            else {
                client.end(true);
               resolve(res);


            }
        });
     }
 }

);


});
}


module.exports={

    setUserContext: setUserContext,
    getUserContext: getUserContext


}