redis

السلام عليكم
احاول استخدام redis من اجل تحسين الاداء و لكن لم اعرف كبف ارجو المساعدة

const models = require('../models');
const fs = require('fs/promises');
const Redis = require('redis');

const client = Redis.createClient({
    password: 'QMzeBdscHuO1zEUGT1iaYsm747yaHJAa',
    socket: {
        host: 'redis-16975.c135.eu-central-1-1.ec2.cloud.redislabs.com',
        port: 16975
    }
});

client.on('error', err => console.log('Redis Client Error', err));


exports.newPost = async (req, res) => {
    const {title, contents, steps, country, region} = req.body;
    try {
        const post = await models.Post.create({
            title,
            contents,
            steps,
            country,
            region,
            UserId: req.currentUser.id
        });
        req.files.map(async function(file) {
            const post_img = await models.Post_Image.create({
                img_uri: '/public/images/' + file.filename,
                PostId: post.id
            })
        })
        res.status(200).json({message: "تم إضافة منشور جديد"})
    } catch(e) {
        res.status(500).json(e)
    }
}

exports.getAllPosts = async (req, res) => {
    try {

        await client.connect();

        const redisKey = 'all_posts';
        // Check if the data exists in Redis cache
        client.get(redisKey, async (err, cachedPosts) => {
            if (err) {
                console.error('Error retrieving data from Redis cache:', err);
            }
            if (cachedPosts) {
                // Data exists in cache, return it
                console.log('Data found in Redis cache');
                res.status(200).json(JSON.parse(cachedPosts));
            } else {
                // Data doesn't exist in cache, retrieve from the database
                const getPosts = await models.Post.findAll({
                    include: [
                        {
                            model: models.User,
                            attributes: { exclude: ['password', 'email'] }
                        },
                        {
                            model: models.Post_Image
                        }
                    ]
                });
                // Store the data in Redis cache
                client.set(redisKey, JSON.stringify(getPosts), (err, reply) => {
                    if (err) {
                        console.error('Error storing data in Redis cache:', err);
                    }
                    console.log('Data stored in Redis cache');
                });
                res.status(200).json(getPosts);
            }
        });
    } catch (e) {
        console.error('Error retrieving posts:', e);
        res.status(500).json(e);
    }
}


exports.getPost = async (req, res) => {
    try {
        const post = await models.Post.findOne({
            where: {id: req.params.postId},
            include: [
                {
                    model: models.User,
                    attributes: {exclude: ['password', 'email']}
                },
                {
                    model: models.Post_Image
                }
            ]
        });
        res.status(200).json(post)
    } catch(e) {
        res.status(500).json(e)
    }
}

exports.getMyAllPosts = async (req, res) => {
    try{
        const myPosts = await models.Post.findAll({
            where: {UserId: req.currentUser.id},
            include: [
                {
                    model: models.Post_Image
                }
            ]
        });
        res.status(200).json(myPosts)
    } catch(e) {
        res.status(500).json(e)
    }
}

exports.getMyPost = async (req, res) => {
    try {
        const myPost = await models.Post.findOne({
            where: {
                UserId: req.currentUser.id,
                id: req.params.postId
            }
        });
        res.status(200).json(myPost)
    } catch(e) {
        res.status(500).json(e)
    }
}

exports.updateMyPost = async (req, res) => {
    const {title, contents, steps} = req.body;
    try {
        const updatePost = await models.Post.update(
            {
                title,
                contents,
                steps
            },
            {
                where: {
                    id: req.params.postId,
                    UserId: req.currentUser.id
                }
            }
        );
        res.status(200).json({
            message: "تم التعديل على بيانات المنشور"
        })
    } catch(e) {
        res.status(500).json(e)
    }
}

exports.deleteMyPost = async (req, res) => {
    const {postId} = req.body;
    try {
        await models.Post_Image.findAll({
            where: {PostId: postId}
        }).then(res => {
            res.map((img) => {
                fs.unlink('.' + img.img_uri, function(err) {
                    if (err) throw err
                })
            })
        })
        await models.Post_Image.destroy({
            where: {PostId: postId}
        });
        await models.Comment.destroy({
            where: {PostId: postId}
        });
        await models.Like.destroy({
            where: {PostId: postId}
        });
        await models.Post.destroy({
            where: {id: postId, UserId: req.currentUser.id}
        })
        res.status(200).json({message: "تم حذف منشورك"})
    } catch(e) {
        res.status(500).json(e)
    }
}