package org.keycloak.testframework.remote.providers.timeoffset;

import java.io.Serializable;

import org.keycloak.connections.infinispan.InfinispanConnectionProvider;
import org.keycloak.models.KeycloakSession;
import org.keycloak.testframework.remote.providers.runonserver.RunOnServer;

import org.infinispan.manager.EmbeddedCacheManager;
import org.jboss.logging.Logger;

import static org.keycloak.connections.infinispan.InfinispanUtil.setTimeServiceToKeycloakTime;

/**
 * Should be executed on the server-side with RunOnServer or @TestOnServer
 */
public class InfinispanTimeUtil implements Serializable {

    protected static final Logger logger = Logger.getLogger(InfinispanTimeUtil.class);

    private static Runnable origTimeService = null;

    public static RunOnServer enableTestingTimeService() {
        return InfinispanTimeUtil::enableTestingTimeService;
    }

    public static RunOnServer disableTestingTimeService() {
        return InfinispanTimeUtil::disableTestingTimeService;
    }

    public static void enableTestingTimeService(KeycloakSession session) {
        if (origTimeService != null) {
            return;
        }

        InfinispanConnectionProvider ispnProvider = session.getProvider(InfinispanConnectionProvider.class);

        logger.info("Will set KeycloakIspnTimeService to the infinispan cacheManager");
        EmbeddedCacheManager cacheManager = ispnProvider.getCache(InfinispanConnectionProvider.USER_CACHE_NAME).getCacheManager();
        origTimeService = setTimeServiceToKeycloakTime(cacheManager);
    }

    public static void disableTestingTimeService(KeycloakSession session) {
        if (origTimeService == null) {
            throw new IllegalStateException("Calling revertTimeService when testing TimeService was not set");
        }

        origTimeService.run();
        origTimeService = null;
    }

}
