package com.atlassian.vcache.internal.redis;
   
   import com.atlassian.marshalling.jdk.JavaSerializationMarshalling;
   import com.atlassian.vcache.DirectExternalCache;
   import com.atlassian.vcache.ExternalCacheSettings;
   import com.atlassian.vcache.internal.RequestContext;
   import com.atlassian.vcache.internal.RequestMetrics;
   import com.atlassian.vcache.internal.core.DefaultRequestContext;
   import com.atlassian.vcache.internal.core.Sha1ExternalCacheKeyGenerator;
  import com.atlassian.vcache.internal.core.metrics.DefaultMetricsCollector;
  import com.atlassian.vcache.internal.core.metrics.MetricsCollector;
  import com.atlassian.vcache.internal.test.AbstractUnreliableDirectExternalCacheIT;
  import org.junit.Rule;
  
  import java.time.Duration;
  import java.util.concurrent.ExecutionException;
  
  public class RedisDirectExternalCacheIT extends AbstractUnreliableDirectExternalCacheIT {
      @Rule
      public JedisTester jedisTester = new JedisTester();
  
      @Rule
      public JedisTester offlineJedisTester = new JedisTester(false);
  
      private final RequestContext requestContext = new DefaultRequestContext(() -> "tenant-id");
      private final MetricsCollector metricsCollector = new DefaultMetricsCollector(() -> requestContext);
  
      @Override
      protected DirectExternalCache<String> createCache(String name, ExternalCacheSettings settings) {
          return metricsCollector.wrap(
                  new RedisDirectExternalCache<>(
                          jedisTester.jedisSupplier(),
                          () -> requestContext,
                          new Sha1ExternalCacheKeyGenerator("it-test-42"),
                          name,
                          JavaSerializationMarshalling.pair(String.class),
                          settings,
                          Duration.ofSeconds(1)));
      }
  
      @Override
      protected DirectExternalCache<String> createOfflineCache(String name, ExternalCacheSettings settings) {
          return new RedisDirectExternalCache<>(
                  offlineJedisTester.jedisSupplier(),
                  () -> requestContext,
                  new Sha1ExternalCacheKeyGenerator("it-test-43"),
                  name,
                  JavaSerializationMarshalling.pair(String.class),
                  settings,
                  Duration.ofSeconds(1));
      }
  
      @Override
      protected RequestMetrics requestMetrics() {
          return metricsCollector.obtainRequestMetrics(requestContext);
      }
  
      @Override
      public void exact_getIdentified_removeIf() throws ExecutionException, InterruptedException {
          // not supported
      }
  
      @Override
      public void exact_getIdentified_replaceIf() throws ExecutionException, InterruptedException {
          // not supported
      }
  }