/*
 * Copyright 2019, Pearson Education, Learning Technology Group
 *
 * RedisCacheServiceImpl.java
 */
package com.pearson.ltg.rbs.ltitoolgateway.redis.service;

import java.time.Duration;

import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.data.redis.connection.ReactiveRedisConnectionFactory;
import org.springframework.data.redis.core.ReactiveRedisTemplate;
import org.springframework.stereotype.Service;

import com.pearson.ltg.rbs.ltitoolgateway.model.PlatformConfiguration;

import reactor.core.publisher.Mono;

@Service
public class RedisCacheServiceImpl implements IRedisCacheService {

    @Value("${redis.expiry.time : 3600}")
    protected long expiryTime;

    @Autowired
    ReactiveRedisTemplate<String, Object> redisTemplate;

    public Mono<PlatformConfiguration> getPlatformConfigurationFromCache(String cacheKey) {
        Mono<Object> configMono = redisTemplate.opsForValue().get(cacheKey);
        return configMono.map(config -> {
            return (PlatformConfiguration)config;
        });
    }

    public void savePlatformConfigurationInCache(String cacheKey, Mono<PlatformConfiguration> platformConfiguration) {
        redisTemplate.opsForValue().set(cacheKey, platformConfiguration);
        setExpiryTime(cacheKey);
    }
    
    public Mono<String> getPlatformIdFromCache(String cacheKey) {
        return redisTemplate.opsForValue().get(cacheKey).flatMap(cache -> {
            return Mono.just((String)cache);
        });
    }

    public void savePlatformIdInCache(String cacheKey, String platformId) {
        redisTemplate.opsForValue().set(cacheKey, platformId);
        setExpiryTime(cacheKey);
    }

    @Override
    public void flushRedisCache() {
        ReactiveRedisConnectionFactory redisConnectionFactory = redisTemplate.getConnectionFactory();
        if (null != redisConnectionFactory) {
            redisConnectionFactory.getReactiveConnection().serverCommands().flushAll();
        }
    }

    @Override
    public void deleteKey(String cacheKey) {
        if (StringUtils.isNotEmpty(cacheKey)) {
            redisTemplate.delete(cacheKey);
        }
    }

    private void setExpiryTime(String cacheKey) {
        redisTemplate.expire(cacheKey, Duration.ofSeconds(expiryTime));
    }
}