package com.atlassian.vcache.internal.test;
   
   import com.atlassian.vcache.RequestCache;
   import com.atlassian.vcache.VCache;
   import org.hamcrest.Matchers;
   import org.junit.Test;
   
   import java.util.stream.Collectors;
   
  import static org.junit.Assert.assertThat;
  
  /**
   * Base test class for the {@link RequestCache}.
   */
  public abstract class AbstractRequestCacheTest extends AbstractLocalCacheOperationsTest {
      @Override
      protected abstract <K, V> RequestCache<K, V> createCache(String name);
  
      @Test
      public void testGetName() throws Exception {
          final VCache namedCache = createCache("netflix");
          assertThat(namedCache.getName(), Matchers.is("netflix"));
      }
  
      @Test
      public void detect_illegal_recursion_supplier() {
          thrown.expect(IllegalStateException.class);
          thrown.expectMessage("Recursive call with key: first");
  
          final RequestCache<String, String> cache = createCache("abc");
  
          cache.get("first", () ->
                  cache.get("first", () -> "fail"));
      }
  
      @Test
      public void detect_illegal_recursion_factory() {
          final RequestCache<String, String> cache = createCache("abc");
  
          thrown.expect(IllegalStateException.class);
          thrown.expectMessage("Recursive call with key: first");
  
          cache.getBulk(
                  strings1 -> {
                      return cache.getBulk(strings2 -> {
                          return strings2.stream().collect(Collectors.toMap(k -> k, k -> k + "-2"));
                      }, strings1);
                  },
                  "first");
      }
  }