test: RedisCodec测试用例

spring-extension-context/src/test/java/com/livk/context/redisearch/codec/JacksonRedisCodecTest.java

@@ -0,0 +1,52 @@
+/*
+ * Copyright 2021-2024 spring-boot-extension the original author or authors.
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *       https://www.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.livk.context.redisearch.codec;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import io.lettuce.core.codec.RedisCodec;
+import org.junit.jupiter.api.Test;
+
+import java.nio.ByteBuffer;
+import java.util.Map;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+
+/**
+ * @author livk
+ */
+class JacksonRedisCodecTest {
+
+	static ObjectMapper mapper = new ObjectMapper();
+
+	static RedisCodec<String, Object> codec = new JacksonRedisCodec<>(mapper, String.class, Object.class);
+
+	@Test
+	void testKey() throws Exception {
+		String key = "redisKey";
+		byte[] bytes = mapper.writeValueAsBytes(key);
+
+		assertEquals(ByteBuffer.wrap(bytes), codec.encodeKey(key));
+		assertEquals(key, codec.decodeKey(ByteBuffer.wrap(bytes)));
+	}
+
+	@Test
+	void testValue() throws Exception {
+		Map<String, String> map = Map.of("username", "password");
+		byte[] bytes = mapper.writeValueAsBytes(map);
+
+		assertEquals(ByteBuffer.wrap(bytes), codec.encodeValue(map));
+		assertEquals(map, codec.decodeValue(ByteBuffer.wrap(bytes)));
+	}
+
+}

spring-extension-context/src/test/java/com/livk/context/redisearch/codec/JdkRedisCodecTest.java

@@ -0,0 +1,54 @@
+/*
+ * Copyright 2021-2024 spring-boot-extension the original author or authors.
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *       https://www.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.livk.context.redisearch.codec;
+
+import com.livk.commons.util.ObjectUtils;
+import io.lettuce.core.codec.RedisCodec;
+import org.junit.jupiter.api.Test;
+import org.springframework.data.redis.serializer.RedisSerializer;
+
+import java.nio.ByteBuffer;
+import java.util.Map;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertFalse;
+
+/**
+ * @author livk
+ */
+class JdkRedisCodecTest {
+
+	static RedisCodec<Object, Object> codec = new JdkRedisCodec();
+
+	@Test
+	void testKey() {
+		String key = "redisKey";
+		byte[] bytes = RedisSerializer.java().serialize(key);
+
+		assertFalse(ObjectUtils.isEmpty(bytes));
+		assertEquals(ByteBuffer.wrap(bytes), codec.encodeKey(key));
+		assertEquals(key, codec.decodeKey(ByteBuffer.wrap(bytes)));
+	}
+
+	@Test
+	void testValue() {
+		Map<String, String> map = Map.of("username", "password");
+		byte[] bytes = RedisSerializer.java().serialize(map);
+
+		assertFalse(ObjectUtils.isEmpty(bytes));
+		assertEquals(ByteBuffer.wrap(bytes), codec.encodeValue(map));
+		assertEquals(map, codec.decodeValue(ByteBuffer.wrap(bytes)));
+	}
+
+}