mirror of
https://github.com/scm-manager/scm-manager.git
synced 2025-11-12 16:35:45 +01:00
merge cache configuration from default location, config directory and plugins
This commit is contained in:
Sebastian Sdorra
434
scm-webapp/src/test/java/sonia/scm/cache/EhConfigurationReaderTest.java
vendored
Normal file
434
scm-webapp/src/test/java/sonia/scm/cache/EhConfigurationReaderTest.java
vendored
Normal file
@@ -0,0 +1,434 @@
|
||||
/**
|
||||
* Copyright (c) 2010, Sebastian Sdorra All rights reserved.
|
||||
*
|
||||
* Redistribution and use in source and binary forms, with or without
|
||||
* modification, are permitted provided that the following conditions are met:
|
||||
*
|
||||
* 1. Redistributions of source code must retain the above copyright notice,
|
||||
* this list of conditions and the following disclaimer. 2. Redistributions in
|
||||
* binary form must reproduce the above copyright notice, this list of
|
||||
* conditions and the following disclaimer in the documentation and/or other
|
||||
* materials provided with the distribution. 3. Neither the name of SCM-Manager;
|
||||
* nor the names of its contributors may be used to endorse or promote products
|
||||
* derived from this software without specific prior written permission.
|
||||
*
|
||||
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
|
||||
* AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
|
||||
* IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
|
||||
* ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE FOR
|
||||
* ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
|
||||
* DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
|
||||
* SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
|
||||
* CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
|
||||
* OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
|
||||
* OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
||||
*
|
||||
* http://bitbucket.org/sdorra/scm-manager
|
||||
*
|
||||
*/
|
||||
|
||||
|
||||
|
||||
package sonia.scm.cache;
|
||||
|
||||
//~--- non-JDK imports --------------------------------------------------------
|
||||
|
||||
import com.google.common.base.Function;
|
||||
import com.google.common.collect.Iterators;
|
||||
import com.google.common.io.Closeables;
|
||||
import com.google.common.io.Files;
|
||||
import com.google.common.io.Resources;
|
||||
|
||||
import net.sf.ehcache.config.CacheConfiguration;
|
||||
import net.sf.ehcache.config.Configuration;
|
||||
import net.sf.ehcache.config.ConfigurationFactory;
|
||||
|
||||
import org.junit.Rule;
|
||||
import org.junit.Test;
|
||||
import org.junit.rules.TemporaryFolder;
|
||||
|
||||
import static org.junit.Assert.*;
|
||||
|
||||
import static org.mockito.Mockito.*;
|
||||
|
||||
//~--- JDK imports ------------------------------------------------------------
|
||||
|
||||
import java.io.File;
|
||||
import java.io.IOException;
|
||||
import java.io.InputStream;
|
||||
|
||||
import java.net.URL;
|
||||
|
||||
import java.util.Iterator;
|
||||
|
||||
/**
|
||||
*
|
||||
* @author Sebastian Sdorra
|
||||
*/
|
||||
public class EhConfigurationReaderTest
|
||||
{
|
||||
|
||||
/**
|
||||
* Method description
|
||||
*
|
||||
*/
|
||||
@Test
|
||||
public void testDefaultConfiguration()
|
||||
{
|
||||
EhConfigurationTestReader reader =
|
||||
new EhConfigurationTestReader("cache.001.xml");
|
||||
Configuration c = createConfiguration(reader);
|
||||
|
||||
checkDefaultConfiguration(c);
|
||||
checkCacheConfiguration(c, "sonia.test.cache.001", 1000l, 30l, 60l);
|
||||
|
||||
}
|
||||
|
||||
/**
|
||||
* Method description
|
||||
*
|
||||
*/
|
||||
@Test
|
||||
public void testMergeAndOverride()
|
||||
{
|
||||
//J-
|
||||
EhConfigurationTestReader reader = new EhConfigurationTestReader(
|
||||
"cache.001.xml",
|
||||
Iterators.forArray("cache.002.xml", "cache.003.xml"),
|
||||
"cache.004.xml"
|
||||
);
|
||||
//J+
|
||||
|
||||
Configuration c = createConfiguration(reader);
|
||||
|
||||
// cache sonia.test.cache.001 override by cache.004.xml
|
||||
checkCacheConfiguration(c, "sonia.test.cache.001", 6l, 2l, 8l);
|
||||
checkCacheConfiguration(c, "sonia.test.cache.002", 2000l, 60l, 120l);
|
||||
checkCacheConfiguration(c, "sonia.test.cache.003", 3000l, 120l, 2400l);
|
||||
}
|
||||
|
||||
/**
|
||||
* Method description
|
||||
*
|
||||
*/
|
||||
@Test
|
||||
public void testMergeWithManualConfiguration()
|
||||
{
|
||||
EhConfigurationTestReader reader =
|
||||
new EhConfigurationTestReader("cache.001.xml", null, "cache.002.xml");
|
||||
|
||||
Configuration c = createConfiguration(reader);
|
||||
|
||||
checkDefaultConfiguration(c);
|
||||
|
||||
checkCacheConfiguration(c, "sonia.test.cache.001", 1000l, 30l, 60l);
|
||||
checkCacheConfiguration(c, "sonia.test.cache.002", 2000l, 60l, 120l);
|
||||
}
|
||||
|
||||
/**
|
||||
* Method description
|
||||
*
|
||||
*/
|
||||
@Test
|
||||
public void testMergeWithModuleConfigurations()
|
||||
{
|
||||
EhConfigurationTestReader reader =
|
||||
new EhConfigurationTestReader("cache.001.xml",
|
||||
Iterators.forArray("cache.002.xml", "cache.003.xml"));
|
||||
|
||||
Configuration c = createConfiguration(reader);
|
||||
|
||||
checkDefaultConfiguration(c);
|
||||
|
||||
checkCacheConfiguration(c, "sonia.test.cache.001", 1000l, 30l, 60l);
|
||||
checkCacheConfiguration(c, "sonia.test.cache.002", 2000l, 60l, 120l);
|
||||
checkCacheConfiguration(c, "sonia.test.cache.003", 3000l, 120l, 2400l);
|
||||
}
|
||||
|
||||
/**
|
||||
* Method description
|
||||
*
|
||||
*/
|
||||
@Test(expected = IllegalStateException.class)
|
||||
public void testMissingDefaultConfiguration()
|
||||
{
|
||||
EhConfigurationTestReader reader = new EhConfigurationTestReader();
|
||||
|
||||
reader.read();
|
||||
}
|
||||
|
||||
/**
|
||||
* Method description
|
||||
*
|
||||
*/
|
||||
@Test
|
||||
public void testOverrideDefaultConfiguration()
|
||||
{
|
||||
//J-
|
||||
EhConfigurationTestReader reader = new EhConfigurationTestReader(
|
||||
"cache.001.xml",
|
||||
Iterators.forArray("cache.005.xml")
|
||||
);
|
||||
//J+
|
||||
Configuration c = createConfiguration(reader);
|
||||
|
||||
checkDefaultConfiguration(c, 170l, 18900l);
|
||||
}
|
||||
|
||||
/**
|
||||
* Method description
|
||||
*
|
||||
*
|
||||
* @param c
|
||||
* @param name
|
||||
* @param maxEntriesLocalHeap
|
||||
* @param timeToIdleSeconds
|
||||
* @param timeToLiveSeconds
|
||||
*/
|
||||
private void checkCacheConfiguration(Configuration c, String name,
|
||||
long maxEntriesLocalHeap, long timeToIdleSeconds, long timeToLiveSeconds)
|
||||
{
|
||||
CacheConfiguration cc = c.getCacheConfigurations().get(name);
|
||||
|
||||
assertNotNull(cc);
|
||||
assertEquals(maxEntriesLocalHeap, cc.getMaxEntriesLocalHeap());
|
||||
assertEquals(timeToIdleSeconds, cc.getTimeToIdleSeconds());
|
||||
assertEquals(timeToLiveSeconds, cc.getTimeToLiveSeconds());
|
||||
}
|
||||
|
||||
/**
|
||||
* Method description
|
||||
*
|
||||
*
|
||||
* @param c
|
||||
*/
|
||||
private void checkDefaultConfiguration(Configuration c)
|
||||
{
|
||||
checkDefaultConfiguration(c, 100l, 10000l);
|
||||
}
|
||||
|
||||
/**
|
||||
* Method description
|
||||
*
|
||||
*
|
||||
* @param c
|
||||
* @param maxEntriesLocalHeap
|
||||
* @param maxEntriesLocalDisk
|
||||
*/
|
||||
private void checkDefaultConfiguration(Configuration c,
|
||||
long maxEntriesLocalHeap, long maxEntriesLocalDisk)
|
||||
{
|
||||
CacheConfiguration dcc = c.getDefaultCacheConfiguration();
|
||||
|
||||
assertNotNull(dcc);
|
||||
assertEquals(maxEntriesLocalHeap, dcc.getMaxEntriesLocalHeap());
|
||||
assertEquals(maxEntriesLocalDisk, dcc.getMaxEntriesLocalDisk());
|
||||
}
|
||||
|
||||
/**
|
||||
* Method description
|
||||
*
|
||||
*
|
||||
* @param reader
|
||||
*
|
||||
* @return
|
||||
*/
|
||||
private Configuration createConfiguration(EhCacheConfigurationReader reader)
|
||||
{
|
||||
Configuration config = null;
|
||||
InputStream content = null;
|
||||
|
||||
try
|
||||
{
|
||||
content = reader.read();
|
||||
config = ConfigurationFactory.parseConfiguration(content);
|
||||
}
|
||||
finally
|
||||
{
|
||||
Closeables.closeQuietly(content);
|
||||
}
|
||||
|
||||
assertNotNull(config);
|
||||
|
||||
return config;
|
||||
}
|
||||
|
||||
//~--- inner classes --------------------------------------------------------
|
||||
|
||||
/**
|
||||
* Class description
|
||||
*
|
||||
*
|
||||
* @version Enter version here..., 13/03/19
|
||||
* @author Enter your name here...
|
||||
*/
|
||||
private class EhConfigurationTestReader extends EhCacheConfigurationReader
|
||||
{
|
||||
|
||||
/**
|
||||
* Constructs ...
|
||||
*
|
||||
*/
|
||||
public EhConfigurationTestReader() {}
|
||||
|
||||
/**
|
||||
* Constructs ...
|
||||
*
|
||||
*
|
||||
* @param defaultConfiguration
|
||||
*/
|
||||
public EhConfigurationTestReader(String defaultConfiguration)
|
||||
{
|
||||
this.defaultConfiguration = defaultConfiguration;
|
||||
}
|
||||
|
||||
/**
|
||||
* Constructs ...
|
||||
*
|
||||
*
|
||||
* @param defaultConfiguration
|
||||
* @param moduleConfigurations
|
||||
*/
|
||||
public EhConfigurationTestReader(String defaultConfiguration,
|
||||
Iterator<String> moduleConfigurations)
|
||||
{
|
||||
this.defaultConfiguration = defaultConfiguration;
|
||||
this.moduleConfigurations = moduleConfigurations;
|
||||
}
|
||||
|
||||
/**
|
||||
* Constructs ...
|
||||
*
|
||||
*
|
||||
* @param defaultConfiguration
|
||||
* @param moduleConfigurations
|
||||
* @param manualConfiguration
|
||||
*/
|
||||
public EhConfigurationTestReader(String defaultConfiguration,
|
||||
Iterator<String> moduleConfigurations, String manualConfiguration)
|
||||
{
|
||||
this.defaultConfiguration = defaultConfiguration;
|
||||
this.moduleConfigurations = moduleConfigurations;
|
||||
this.manualConfiguration = manualConfiguration;
|
||||
}
|
||||
|
||||
//~--- get methods --------------------------------------------------------
|
||||
|
||||
/**
|
||||
* Method description
|
||||
*
|
||||
*
|
||||
* @return
|
||||
*/
|
||||
@Override
|
||||
public URL getDefaultResource()
|
||||
{
|
||||
URL url = null;
|
||||
|
||||
if (defaultConfiguration != null)
|
||||
{
|
||||
url = getResource(defaultConfiguration);
|
||||
}
|
||||
|
||||
return url;
|
||||
}
|
||||
|
||||
/**
|
||||
* Method description
|
||||
*
|
||||
*
|
||||
* @return
|
||||
*/
|
||||
@Override
|
||||
public Iterator<URL> getModuleResources()
|
||||
{
|
||||
Iterator<URL> urlIterator;
|
||||
|
||||
if (moduleConfigurations == null)
|
||||
{
|
||||
urlIterator = Iterators.emptyIterator();
|
||||
}
|
||||
else
|
||||
{
|
||||
urlIterator = Iterators.transform(moduleConfigurations,
|
||||
new Function<String, URL>()
|
||||
{
|
||||
|
||||
@Override
|
||||
public URL apply(String resource)
|
||||
{
|
||||
return getResource(resource);
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
return urlIterator;
|
||||
}
|
||||
|
||||
/**
|
||||
* Method description
|
||||
*
|
||||
*
|
||||
* @return
|
||||
*/
|
||||
@Override
|
||||
protected File getManualFileResource()
|
||||
{
|
||||
File file;
|
||||
|
||||
if (manualConfiguration == null)
|
||||
{
|
||||
file = mock(File.class);
|
||||
when(file.exists()).thenReturn(Boolean.FALSE);
|
||||
}
|
||||
else
|
||||
{
|
||||
try
|
||||
{
|
||||
file = tempFolder.newFile();
|
||||
|
||||
URL manual = getResource(manualConfiguration);
|
||||
|
||||
Files.copy(Resources.newInputStreamSupplier(manual), file);
|
||||
}
|
||||
catch (IOException ex)
|
||||
{
|
||||
throw new RuntimeException("could not create manual config file", ex);
|
||||
}
|
||||
}
|
||||
|
||||
return file;
|
||||
}
|
||||
|
||||
/**
|
||||
* Method description
|
||||
*
|
||||
*
|
||||
* @param name
|
||||
*
|
||||
* @return
|
||||
*/
|
||||
private URL getResource(String name)
|
||||
{
|
||||
return Resources.getResource("sonia/scm/cache/".concat(name));
|
||||
}
|
||||
|
||||
//~--- fields -------------------------------------------------------------
|
||||
|
||||
/** Field description */
|
||||
private String defaultConfiguration;
|
||||
|
||||
/** Field description */
|
||||
private String manualConfiguration;
|
||||
|
||||
/** Field description */
|
||||
private Iterator<String> moduleConfigurations;
|
||||
}
|
||||
|
||||
|
||||
//~--- fields ---------------------------------------------------------------
|
||||
|
||||
/** Field description */
|
||||
@Rule
|
||||
public TemporaryFolder tempFolder = new TemporaryFolder();
|
||||
}
|
||||
Reference in New Issue
Block a user