@Test
public void testDynoClient_authSuccess() throws Exception {
    redisServer = new RedisServerBuilder()
            .port(REDIS_PORT)
            .setting("requirepass password")
            .build();
    redisServer.start();

    Host authHost = new HostBuilder().setHostname("localhost").setPort(REDIS_PORT).setRack(REDIS_RACK).setStatus(Status.Up).setHashtag(null).setPassword("password").createHost();

    TokenMapSupplierImpl tokenMapSupplier = new TokenMapSupplierImpl(authHost);
    DynoJedisClient dynoClient = constructJedisClient(tokenMapSupplier,
            () -> Collections.singletonList(authHost));

    String statusCodeReply = dynoClient.set("some-key", "some-value");
    Assert.assertEquals("OK", statusCodeReply);

    String value = dynoClient.get("some-key");
    Assert.assertEquals("some-value", value);
}
 

@Test
public void testJedisConnFactory_authSuccess() throws Exception {
    redisServer = new RedisServerBuilder()
            .port(REDIS_PORT)
            .setting("requirepass password")
            .build();
    redisServer.start();

    Host authHost = new HostBuilder().setHostname("localhost").setPort(REDIS_PORT).setRack(REDIS_RACK).setStatus(Status.Up).setHashtag(null).setPassword("password").createHost();

    JedisConnectionFactory conFactory =
            new JedisConnectionFactory(new DynoOPMonitor("some-application-name"), null);
    ConnectionPoolConfiguration cpConfig = new ConnectionPoolConfigurationImpl("some-name");
    CountingConnectionPoolMonitor poolMonitor = new CountingConnectionPoolMonitor();
    HostConnectionPool<Jedis> hostConnectionPool =
            new HostConnectionPoolImpl<>(authHost, conFactory, cpConfig, poolMonitor);
    Connection<Jedis> connection = conFactory
            .createConnection(hostConnectionPool);

    connection.execPing();
}
 

@Test
public void testJedisConnFactory_authenticationRequired() throws Exception {
    redisServer = new RedisServerBuilder()
            .port(REDIS_PORT)
            .setting("requirepass password")
            .build();
    redisServer.start();

    Host noAuthHost = new HostBuilder().setHostname("localhost").setPort(REDIS_PORT).setRack(REDIS_RACK).setStatus(Status.Up).createHost();

    JedisConnectionFactory conFactory =
            new JedisConnectionFactory(new DynoOPMonitor("some-application-name"), null);
    ConnectionPoolConfiguration cpConfig = new ConnectionPoolConfigurationImpl("some-name");
    CountingConnectionPoolMonitor poolMonitor = new CountingConnectionPoolMonitor();
    HostConnectionPool<Jedis> hostConnectionPool =
            new HostConnectionPoolImpl<>(noAuthHost, conFactory, cpConfig, poolMonitor);
    Connection<Jedis> connection = conFactory
            .createConnection(hostConnectionPool);

    try {
        connection.execPing();
        Assert.fail("expected to throw");
    } catch (JedisDataException e) {
        Assert.assertEquals("NOAUTH Authentication required.", e.getMessage());
    }
}
 

@Before
public void init() throws Exception {
    final int port = getRandomPort();
    redisServer = new RedisServerBuilder()
            .port(port)
            .build();
    redisServer.start();
    redisSender = new JedisPool("localhost", port).getResource();
    redisSubscriber = new JedisPool("localhost", port).getResource();
}
 

@Before
public void init() throws Exception {
    redisServer = new RedisServerBuilder()
            .port(LOCAL_REDIS_PORT)
            .setting("timeout " + REDIS_IDLE_TIMEOUT_IN_SECONDS)
            .build();
    redisServer.start(); // this waits until server write start notification to stdout (!)
    log().info("started redis server");

    TimeUnit.SECONDS.sleep(RETRY_INITIALIZE_INTERVAL_IN_SECONDS); // makes sure jedis client is initialized

    redisClient = new JedisPool("localhost", LOCAL_REDIS_PORT).getResource(); // uses localhost / local port
    log().info("initialized redis client");
    logStatus();
}
 

private RedisServer createRedisServer() {
    final RedisServerBuilder redisServerBuilder = RedisServer.builder()
            .port(redisPort)
            .setting("appendonly yes")
            .setting("appendfsync everysec");
    settings.stream().forEach(s -> redisServerBuilder.setting(s));

    final RedisServer redisServer = redisServerBuilder.build();
    return redisServer;
}
 

@Override
protected void before() throws Throwable {
    if (System.getProperty(builder.skipProperty) != null) {
        log.info("Skip RedisRule because of existing property '" + builder.skipProperty + "'");
        return;
    }
    log.info("start Redis-Instance ...");
    redisServer = new RedisServerBuilder().port(builder.port).build();
    redisServer.start();
    log.info("Redis-Instance started.");
}
 

@Test
public void testJedisConnFactory_invalidPassword() throws Exception {
    redisServer = new RedisServerBuilder()
            .port(REDIS_PORT)
            .setting("requirepass password")
            .build();
    redisServer.start();

    Host authHost = new HostBuilder().setHostname("localhost").setPort(REDIS_PORT).setRack(REDIS_RACK).setStatus(Status.Up).setHashtag(null).setPassword("invalid-password").createHost();

    JedisConnectionFactory jedisConnectionFactory =
            new JedisConnectionFactory(new DynoOPMonitor("some-application-name"), null);

    ConnectionPoolConfiguration connectionPoolConfiguration = new ConnectionPoolConfigurationImpl(
            "some-name");
    HostConnectionPool<Jedis> hostConnectionPool = new HostConnectionPoolImpl<>(authHost,
            jedisConnectionFactory, connectionPoolConfiguration, new CountingConnectionPoolMonitor());
    Connection<Jedis> connection = jedisConnectionFactory
            .createConnection(hostConnectionPool);

    try {
        connection.execPing();
        Assert.fail("expected to throw");
    } catch (JedisDataException e) {
        Assert.assertEquals("ERR invalid password", e.getMessage());
    }
}
 

@BeforeClass
public static void startRedisServer() throws IOException {
    redisServer = new RedisServerBuilder().port(6379).setting("maxmemory 256M").build();
    redisServer.start();
}
 

@BeforeClass
public static void startRedisServer() throws IOException {
    redisServer = new RedisServerBuilder().port(6379).setting("maxmemory 128M").build();
    redisServer.start();
}
 

@BeforeClass
public static void startRedisServer() throws IOException {
    redisServer = new RedisServerBuilder().port(6379).setting("maxmemory 256M").build();
    redisServer.start();
}
 

@BeforeClass
public static void startRedisServer() throws IOException {
    redisServer = new RedisServerBuilder().port(6379).setting("maxmemory 256M").build();
    redisServer.start();
}
 

@BeforeClass
public static void startRedisServer() throws IOException {
    redisServer = new RedisServerBuilder().port(6379).setting("maxmemory 128M").build();
    redisServer.start();
}