cache.js

let redis = require("redis");
const redis_client = redis.createClient({host:'127.0.0.1',port:'6379',ttl:5*60*1000});

// redis_client.auth('6478**12',function(){
//     console.log('auth succress');
// });
redis_client.on("error",function(err){
    console.log(err);

});
redis = {};
redis.set = function(key,value){
  value = JSON.stringify(value);
  return redis_client.set(key,value,function(err){
        console.log(err);
    });
};
text = async(key)=>{
     doc = await new Promise((resolve)=>{
        redis_client.get(key,function(err,res){
            return resolve(res);
        });
    });
    // doc = JSON.parse(doc);
    return doc;
}

redis.get = async(key)=>{
    const ret  = await text(key);
    return ret;
}

redis.hget = async(key, field)=>{
    doc = await new Promise((resolve)=>{
        redis_client.hget(key, field, function(err,res){
            return resolve(res);
        });
    });
    return doc;
}

redis.hgetall = async(key)=>{
    doc = await new Promise((resolve)=>{
        redis_client.hgetall(key, function(err,res){
            return resolve(res);
        });
    });
    return doc;
}

redis.hset = async(key, field, value)=>{
    doc = await new Promise((resolve)=>{
        redis_client.hset(key, field, value, function(err,res){
            return resolve(res);
        });
    });
    return doc;
}

redis.expire = async(key, seconds)=>{
    doc = await new Promise((resolve)=>{
        redis_client.expire(key, seconds, function(err,res){
            return resolve(res);
        });
    });
    return doc;
}

module.exports = redis;