package com.jboss.datagrid.test.backwardcompatibility;


@RunWith(Arquillian.class)
public class SingleFileStoreBackwardCompatibilityIT {

    private DefaultCacheManager dfc;
    private String cacheName = "testCache";

    private static final String OLD_ISPN = "dep1_with_old_ispn";
    private static final String NEW_ISPN = "dep2_with_new_ispn";

    private static Map<String, String> storedMap;

    @ArquillianResource
    Deployer deployer;

    @Deployment(name = OLD_ISPN, testable = true, managed = true, order=1)
    @TargetsContainer("container1")
    public static WebArchive createDeploymentOld() {
        WebArchive jar = DeploymentBuilder.createTestArchiveWithPreviousJDG("test1.war", "previous");
        System.out.println("ClassLoader: " + SingleFileStoreBackwardCompatibilityIT.class.getClassLoader());
        return jar;
    }

    @Deployment(name = NEW_ISPN, testable = true, managed = true, order=2)
    @TargetsContainer("container2")
    public static WebArchive createDeploymentNew() {
        WebArchive jar = DeploymentBuilder.createTestArchive("test2.war", "current");
        return jar;
    }

    private DefaultCacheManager configureCacheManager(boolean clearCacheStore) throws Exception {
        GlobalConfiguration glob = new GlobalConfigurationBuilder().nonClusteredDefault()
                .globalJmxStatistics().allowDuplicateDomains(true).
                        build();
        ConfigurationBuilder c = new ConfigurationBuilder();
        c.clustering().cacheMode(CacheMode.LOCAL);

        File tmpStore = new File("/tmp/cache/" + cacheName + ".dat");
        if (clearCacheStore && tmpStore.exists()) {
            tmpStore.delete();
        }
        c.persistence().passivation(false).addSingleFileStore().purgeOnStartup(false).location("/tmp/cache/");
        Configuration cnf = c.build();
        DefaultCacheManager manager = new DefaultCacheManager(glob);

        manager.defineConfiguration(cacheName, cnf);
        return manager;
    }

    @Test
    @OperateOnDeployment(OLD_ISPN)
    @InSequence(1)
    public void testStoreWithOldJDG() throws Exception {
        deployer.deploy(OLD_ISPN);
        dfc = configureCacheManager(true);
        dfc.start();
        Cache<Object, Object> cache = dfc.getCache(cacheName);
        System.out.println("Version: " + cache.getVersion());
        System.out.println("ClassLoader: " + cache.getClass().getClassLoader());
        storedMap = new HashMap<String, String>();
        storedMap.put("k", "v");
        cache.put("mapKey", storedMap);
        dfc.stop();
        deployer.undeploy(OLD_ISPN);
    }

    @Test
    @OperateOnDeployment(NEW_ISPN)
    @InSequence(2)
    public void testReadWithNewJDG() throws Exception {
        deployer.deploy(NEW_ISPN);
        dfc = configureCacheManager(false);
        dfc.start();
        Cache<Object, Object> cache = dfc.getCache(cacheName);
        System.out.println("ClassLoader: " + cache.getClass().getClassLoader());
        System.out.println("Version: " + cache.getVersion());
        assertEquals(storedMap, cache.get("mapKey"));
        dfc.stop();
        deployer.undeploy(NEW_ISPN);
    }

}