// cache.js
const redis = require('redis');
const config = require('config');
const logger = require('winston');

const redisObj = {
    client: null,
    connect: function () {
        this.client = redis.createClient(config.redis);
        this.client.on('error', function (err) {
            logger.error('redisCache Error ' + err);
        });
        this.client.on('ready', function () {
            logger.info('redisCache connection succeed');
        });
    },
    init: function () {
        this.connect(); // 建立連線
        const instance = this.client;

        // 主要重寫了一下三個方法。可以根據需要定義。
        const get = instance.get;
        const set = instance.set;
        const setex = instance.setex;

        instance.set = function (key, value, callback) {
            if (value ！== undefined) {
                set.call(instance, key, JSON.stringify(value), callback);
            }
        };

        instance.get = function (key, callback) {

            get.call(instance, key, (err, val) => {
                if (err) {
                    logger.warn('redis.get: ', key, err);
                }
                callback(null, JSON.parse(val));
            });

        };
        // 可以不用傳遞expires引數。在config檔案裡進行配置。
        instance.setex = function (key, value, callback) {
            if (value !== undefined) {
                setex.call(instance, key, config.cache.maxAge, JSON.stringify(value), callback);
            }
        };

        return instance;

    },
};

// 返回的是一個redis.client的例項
module.exports = redisObj.init();