41 lines
1.1 KiB
JavaScript
41 lines
1.1 KiB
JavaScript
const redis = require("redis");
|
|
const log =require("./log");
|
|
|
|
class Redis_Storage{
|
|
//create redis client in constructor
|
|
constructor(){
|
|
this.client = redis.createClient();
|
|
this.client.on("error", function (error) {
|
|
console.error(error);
|
|
});
|
|
}
|
|
//add new item to redis with key and value
|
|
async Add(key,value){
|
|
await this.client.set(key,value,(err,status)=>{
|
|
if(err!=null)return log.log(err)
|
|
log.log(status)
|
|
})
|
|
}
|
|
//get redis value with key
|
|
Get(key){
|
|
return new Promise((resolv,reject)=>{
|
|
this.client.get(key,(err,value)=>{
|
|
if(err)return reject(err)
|
|
if(value==null)return resolv(null)
|
|
resolv(value)
|
|
})
|
|
})
|
|
}
|
|
//delete redis value with key
|
|
async Delete(key){
|
|
await this.client.del(key,(err,status)=>{
|
|
if(status==1){
|
|
log.log("delete : "+key)
|
|
}else{
|
|
log.log("key delete error: " + err)
|
|
}
|
|
})
|
|
}
|
|
}
|
|
|
|
module.exports.Redis_Storage = Redis_Storage |