Add support for Redis SINTERCARD command

src/main/java/org/springframework/data/redis/connection/DefaultStringRedisConnection.java

@@ -82,6 +82,7 @@
  * @author Dennis Neufeld
  * @author Shyngys Sapraliyev
  * @author Jeonggyu Choi
+ * @author Mingi Lee
  */
 @NullUnmarked
 @SuppressWarnings({ "ConstantConditions", "deprecation" })
@@ -832,6 +833,11 @@ public Long sInterStore(byte[] destKey, byte[]... keys) {
 return convertAndReturn(delegate.sInterStore(destKey, keys), Converters.identityConverter());
 }
 
+@Override
+public Long sInterCard(byte[]... keys) {
+return convertAndReturn(delegate.sInterCard(keys), Converters.identityConverter());
+}
+
 @Override
 public Boolean sIsMember(byte[] key, byte[] value) {
 return convertAndReturn(delegate.sIsMember(key, value), Converters.identityConverter());
@@ -1824,6 +1830,11 @@ public Long sInterStore(String destKey, String... keys) {
 return sInterStore(serialize(destKey), serializeMulti(keys));
 }
 
+@Override
+public Long sInterCard(String... keys) {
+return sInterCard(serializeMulti(keys));
+}
+
 @Override
 public Boolean sIsMember(String key, String value) {
 return sIsMember(serialize(key), serialize(value));

src/main/java/org/springframework/data/redis/connection/DefaultedRedisConnection.java

@@ -67,6 +67,7 @@
  * @author Dennis Neufeld
  * @author Shyngys Sapraliyev
  * @author Tihomir Mateev
+ * @author Mingi Lee
  * @since 2.0
  */
 @Deprecated
@@ -890,6 +891,13 @@ default Long sInterStore(byte[] destKey, byte[]... keys) {
 return setCommands().sInterStore(destKey, keys);
 }
 
+/** @deprecated in favor of {@link RedisConnection#setCommands()}}. */
+@Override
+@Deprecated
+default Long sInterCard(byte[]... keys) {
+return setCommands().sInterCard(keys);
+}
+
 /** @deprecated in favor of {@link RedisConnection#setCommands()}}. */
 @Override
 @Deprecated

src/main/java/org/springframework/data/redis/connection/ReactiveSetCommands.java

@@ -43,6 +43,7 @@
  *
  * @author Christoph Strobl
  * @author Mark Paluch
+ * @author Mingi Lee
  * @since 2.0
  */
 public interface ReactiveSetCommands {
@@ -775,6 +776,73 @@ default Mono<Long> sInterStore(ByteBuffer destinationKey, Collection<ByteBuffer>
  */
 Flux<NumericResponse<SInterStoreCommand, Long>> sInterStore(Publisher<SInterStoreCommand> commands);
 
+/**
+ * {@code SINTERCARD} command parameters.
+ *
+ * @author Mingi Lee
+ * @since 4.0
+ * @see <a href="https://redis.io/commands/sintercard">Redis Documentation: SINTERCARD</a>
+ */
+class SInterCardCommand implements Command {
+
+private final List<ByteBuffer> keys;
+
+private SInterCardCommand(List<ByteBuffer> keys) {
+this.keys = keys;
+}
+
+/**
+ * Creates a new {@link SInterCardCommand} given a {@link Collection} of keys.
+ *
+ * @param keys must not be {@literal null}.
+ * @return a new {@link SInterCardCommand} for a {@link Collection} of keys.
+ */
+public static SInterCardCommand keys(Collection<ByteBuffer> keys) {
+
+Assert.notNull(keys, "Keys must not be null");
+
+return new SInterCardCommand(new ArrayList<>(keys));
+}
+
+@Override
+public @Nullable ByteBuffer getKey() {
+return null;
+}
+
+/**
+ * @return never {@literal null}.
+ */
+public List<ByteBuffer> getKeys() {
+return keys;
+}
+}
+
+/**
+ * Returns the cardinality of the set which would result from the intersection of all given sets at {@literal keys}.
+ *
+ * @param keys must not be {@literal null}.
+ * @return
+ * @see <a href="https://redis.io/commands/sintercard">Redis Documentation: SINTERCARD</a>
+ * @since 4.0
+ */
+default Mono<Long> sInterCard(Collection<ByteBuffer> keys) {
+
+Assert.notNull(keys, "Keys must not be null");
+
+return sInterCard(Mono.just(SInterCardCommand.keys(keys))).next().map(NumericResponse::getOutput);
+}
+
+/**
+ * Returns the cardinality of the set which would result from the intersection of all given sets at
+ * {@link SInterCardCommand#getKeys()}.
+ *
+ * @param commands must not be {@literal null}.
+ * @return
+ * @see <a href="https://redis.io/commands/sintercard">Redis Documentation: SINTERCARD</a>
+ * @since 4.0
+ */
+Flux<NumericResponse<SInterCardCommand, Long>> sInterCard(Publisher<SInterCardCommand> commands);
+
 /**
  * {@code SUNION} command parameters.
  *

src/main/java/org/springframework/data/redis/connection/RedisSetCommands.java

@@ -29,6 +29,7 @@
  * @author Costin Leau
  * @author Christoph Strobl
  * @author Mark Paluch
+ * @author Mingi Lee
  * @see RedisCommands
  */
 @NullUnmarked
@@ -153,6 +154,16 @@ public interface RedisSetCommands {
  */
 Long sInterStore(byte @NonNull [] destKey, byte @NonNull [] @NonNull... keys);
 
+/**
+ * Returns the cardinality of the set which would result from the intersection of all the given sets.
+ *
+ * @param keys must not be {@literal null}.
+ * @return {@literal null} when used in pipeline / transaction.
+ * @see <a href="https://redis.io/commands/sintercard">Redis Documentation: SINTERCARD</a>
+ * @since 4.0
+ */
+Long sInterCard(byte @NonNull [] @NonNull... keys);
+
 /**
  * Union all sets at given {@code keys}.
  *

src/main/java/org/springframework/data/redis/connection/StringRedisConnection.java

@@ -74,6 +74,7 @@
  * @author ihaohong
  * @author Shyngys Sapraliyev
  * @author Jeonggyu Choi
+ * @author Mingi Lee
  * @see RedisCallback
  * @see RedisSerializer
  * @see StringRedisTemplate
@@ -1169,6 +1170,17 @@ String bLMove(@NonNull String sourceKey, @NonNull String destinationKey, @NonNul
  */
 Long sInterStore(@NonNull String destKey, @NonNull String @NonNull... keys);
 
+/**
+ * Returns the cardinality of the set which would result from the intersection of all the given sets.
+ *
+ * @param keys must not be {@literal null}.
+ * @return
+ * @see <a href="https://redis.io/commands/sintercard">Redis Documentation: SINTERCARD</a>
+ * @see RedisSetCommands#sInterCard(byte[]...)
+ * @since 4.0
+ */
+Long sInterCard(@NonNull String @NonNull... keys);
+
 /**
  * Union all sets at given {@code keys}.
  *

src/main/java/org/springframework/data/redis/connection/jedis/JedisClusterSetCommands.java

@@ -40,6 +40,7 @@
 /**
  * @author Christoph Strobl
  * @author Mark Paluch
+ * @author Mingi Lee
  * @since 2.0
  */
 class JedisClusterSetCommands implements RedisSetCommands {
@@ -230,6 +231,25 @@ public Long sInterStore(byte[] destKey, byte[]... keys) {
 return sAdd(destKey, result.toArray(new byte[result.size()][]));
 }
 
+@Override
+public Long sInterCard(byte[]... keys) {
+
+Assert.notNull(keys, "Keys must not be null");
+Assert.noNullElements(keys, "Keys must not contain null elements");
+
+if (ClusterSlotHashUtil.isSameSlotForAllKeys(keys)) {
+try {
+return connection.getCluster().sintercard(keys);
+} catch (Exception ex) {
+throw convertJedisAccessException(ex);
+}
+}
+
+// For multi-slot clusters, calculate intersection cardinality by performing intersection
+Set<byte[]> result = sInter(keys);
+return (long) result.size();
+}
+
 @Override
 public Set<byte[]> sUnion(byte[]... keys) {
 

src/main/java/org/springframework/data/redis/connection/jedis/JedisSetCommands.java

@@ -38,6 +38,7 @@
 /**
  * @author Christoph Strobl
  * @author Mark Paluch
+ * @author Mingi Lee
  * @since 2.0
  */
 @NullUnmarked
@@ -105,6 +106,15 @@ public Long sInterStore(byte @NonNull [] destKey, byte @NonNull [] @NonNull... k
 return connection.invoke().just(Jedis::sinterstore, PipelineBinaryCommands::sinterstore, destKey, keys);
 }
 
+@Override
+public Long sInterCard(byte @NonNull [] @NonNull... keys) {
+
+Assert.notNull(keys, "Keys must not be null");
+Assert.noNullElements(keys, "Keys must not contain null elements");
+
+return connection.invoke().just(Jedis::sintercard, PipelineBinaryCommands::sintercard, keys);
+}
+
 @Override
 public Boolean sIsMember(byte @NonNull [] key, byte @NonNull [] value) {
 

src/main/java/org/springframework/data/redis/connection/lettuce/LettuceClusterSetCommands.java

@@ -31,6 +31,7 @@
 /**
  * @author Christoph Strobl
  * @author Mark Paluch
+ * @author Mingi Lee
  * @since 2.0
  */
 class LettuceClusterSetCommands extends LettuceSetCommands {
@@ -118,6 +119,21 @@ public Long sInterStore(byte[] destKey, byte[]... keys) {
 return sAdd(destKey, result.toArray(new byte[result.size()][]));
 }
 
+@Override
+public Long sInterCard(byte[]... keys) {
+
+Assert.notNull(keys, "Keys must not be null");
+Assert.noNullElements(keys, "Keys must not contain null elements");
+
+if (ClusterSlotHashUtil.isSameSlotForAllKeys(keys)) {
+return super.sInterCard(keys);
+}
+
+// For multi-slot clusters, calculate intersection cardinality by performing intersection
+Set<byte[]> result = sInter(keys);
+return (long) result.size();
+}
+
 @Override
 public Set<byte[]> sUnion(byte[]... keys) {
 

src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveSetCommands.java

@@ -36,6 +36,7 @@
 /**
  * @author Christoph Strobl
  * @author Mark Paluch
+ * @author Mingi Lee
  * @since 2.0
  */
 class LettuceReactiveSetCommands implements ReactiveSetCommands {
@@ -175,6 +176,18 @@ public Flux<NumericResponse<SInterStoreCommand, Long>> sInterStore(Publisher<SIn
 }));
 }
 
+@Override
+public Flux<NumericResponse<SInterCardCommand, Long>> sInterCard(Publisher<SInterCardCommand> commands) {
+
+return connection.execute(cmd -> Flux.from(commands).concatMap(command -> {
+
+Assert.notNull(command.getKeys(), "Keys must not be null");
+
+return cmd.sintercard(command.getKeys().toArray(new ByteBuffer[0]))
+.map(value -> new NumericResponse<>(command, value));
+}));
+}
+
 @Override
 public Flux<CommandResponse<SUnionCommand, Flux<ByteBuffer>>> sUnion(Publisher<SUnionCommand> commands) {
 

src/main/java/org/springframework/data/redis/connection/lettuce/LettuceSetCommands.java

@@ -39,6 +39,7 @@
 /**
  * @author Christoph Strobl
  * @author Mark Paluch
+ * @author Mingi Lee
  * @since 2.0
  */
 @NullUnmarked
@@ -106,6 +107,15 @@ public Long sInterStore(byte @NonNull [] destKey, byte @NonNull [] @NonNull... k
 return connection.invoke().just(RedisSetAsyncCommands::sinterstore, destKey, keys);
 }
 
+@Override
+public Long sInterCard(byte @NonNull [] @NonNull... keys) {
+
+Assert.notNull(keys, "Keys must not be null");
+Assert.noNullElements(keys, "Keys must not contain null elements");
+
+return connection.invoke().just(RedisSetAsyncCommands::sintercard, keys);
+}
+
 @Override
 public Boolean sIsMember(byte @NonNull [] key, byte @NonNull [] value) {
 

src/main/java/org/springframework/data/redis/core/BoundSetOperations.java

@@ -28,6 +28,7 @@
  *
  * @author Costin Leau
  * @author Mark Paluch
+ * @author Mingi Lee
  */
 @NullUnmarked
 public interface BoundSetOperations<K, V> extends BoundKeyOperations<K> {
@@ -131,6 +132,26 @@ public interface BoundSetOperations<K, V> extends BoundKeyOperations<K> {
  */
 void intersectAndStore(@NonNull Collection<@NonNull K> keys, @NonNull K destKey);
 
+/**
+ * Returns the cardinality of the set which would result from the intersection of the bound key and {@code key}.
+ *
+ * @param key must not be {@literal null}.
+ * @return {@literal null} when used in pipeline / transaction.
+ * @see <a href="https://redis.io/commands/sintercard">Redis Documentation: SINTERCARD</a>
+ * @since 4.0
+ */
+Long intersectSize(@NonNull K key);
+
+/**
+ * Returns the cardinality of the set which would result from the intersection of the bound key and {@code keys}.
+ *
+ * @param keys must not be {@literal null}.
+ * @return {@literal null} when used in pipeline / transaction.
+ * @see <a href="https://redis.io/commands/sintercard">Redis Documentation: SINTERCARD</a>
+ * @since 4.0
+ */
+Long intersectSize(@NonNull Collection<@NonNull K> keys);
+
 /**
  * Union all sets at given {@code key} and {@code key}.
  *