From 2c9bbbf9a54a32277b2e74123381b793f5816904 Mon Sep 17 00:00:00 2001 From: Alex Date: Sat, 26 Mar 2022 20:46:35 +0100 Subject: [PATCH] redis tests - hashes --- .../krakatoa/proxy/listener/PostLoginListener.java | 11 ++++++----- .../net/krakatoa/proxy/redis/RedisHashCommands.java | 4 ++-- 2 files changed, 8 insertions(+), 7 deletions(-) diff --git a/src/main/java/net/krakatoa/proxy/listener/PostLoginListener.java b/src/main/java/net/krakatoa/proxy/listener/PostLoginListener.java index 5032b66..ff49c2d 100644 --- a/src/main/java/net/krakatoa/proxy/listener/PostLoginListener.java +++ b/src/main/java/net/krakatoa/proxy/listener/PostLoginListener.java @@ -9,6 +9,7 @@ import earth.krakatao.protocol.KraSocketClientProtocolStatus; import java.io.IOException; import java.security.SecureRandom; import java.util.HashMap; +import java.util.Map; import java.util.concurrent.TimeUnit; import java.util.function.Consumer; import net.krakatoa.proxy.ProxySystem; @@ -120,12 +121,12 @@ public class PostLoginListener implements Listener { ProxySystem.getInstance().getRedisManager().getRedisHashCommands() .hset("player", proxiedPlayer.getUniqueId().toString(), "online"); */ - HashMap hashMap = new HashMap<>(); - hashMap.put("skin", "steve"); - hashMap.put("money", "101001"); - hashMap.put("state", "online"); + Map map = new HashMap<>(); + map.put("skin", "steve"); + map.put("money", "101001"); + map.put("state", "online"); ProxySystem.getInstance().getRedisManager().getRedisHashCommands() - .hset("player", proxiedPlayer.getUniqueId().toString(), hashMap); + .hmset("player:" + proxiedPlayer.getUniqueId().toString(), map); MessageUnpacker unpacker = MessagePack.newDefaultUnpacker(packer.toByteArray()); diff --git a/src/main/java/net/krakatoa/proxy/redis/RedisHashCommands.java b/src/main/java/net/krakatoa/proxy/redis/RedisHashCommands.java index d083827..029c4c7 100644 --- a/src/main/java/net/krakatoa/proxy/redis/RedisHashCommands.java +++ b/src/main/java/net/krakatoa/proxy/redis/RedisHashCommands.java @@ -1,7 +1,7 @@ package net.krakatoa.proxy.redis; import io.lettuce.core.dynamic.Commands; -import java.util.HashMap; +import java.util.Map; public interface RedisHashCommands extends Commands { @@ -13,7 +13,7 @@ public interface RedisHashCommands extends Commands { Long hset(String key, String field, String... value); - Long hset(String key, String field, HashMap hashMap); + String hmset(String key, Map map); //Mono hmset(Key key, Map map); }