ACL patterns for Pub/Sub channels

src/main/java/redis/clients/jedis/BuilderFactory.java

@@ -689,6 +689,7 @@ public String toString() {
    * Create a AccessControlUser object from the ACL GETUSER < > result
    */
   public static final Builder<AccessControlUser> ACCESS_CONTROL_USER = new Builder<AccessControlUser>() {
+    @SuppressWarnings("unchecked")
     @Override
     public AccessControlUser build(Object data) {
       if (data == null) {
@@ -723,6 +724,15 @@ public AccessControlUser build(Object data) {
         accessControlUser.addKey(SafeEncoder.encode((byte[]) k));
       }
 
+      if (objectList.size() <= 9) {
+        // before redis 6.2, no channels info
+        return accessControlUser;
+      }
+      List<Object> channels = objectList.get(9);
+      for (Object channel : channels) {
+        accessControlUser.addChannel(SafeEncoder.encode((byte[]) channel));
+      }
+
       return accessControlUser;
     }
 

src/main/java/redis/clients/jedis/commands/AccessControlLogBinaryCommands.java

@@ -53,6 +53,12 @@ public interface AccessControlLogBinaryCommands {
    */
   List<byte[]> aclUsersBinary();
 
+  /**
+   * The command returns all the rules defined for an existing ACL user.
+   * @see <a href="https://redis.io/commands/acl-getuser">ACL GETUSER username</a>
+   * @param name username
+   * @return a list of ACL rule definitions for the user.
+   */
   AccessControlUser aclGetUser(byte[] name);
 
   /**

src/main/java/redis/clients/jedis/commands/AccessControlLogCommands.java

@@ -55,6 +55,12 @@ public interface AccessControlLogCommands {
    */
   List<String> aclUsers();
 
+  /**
+   * The command returns all the rules defined for an existing ACL user.
+   * @see <a href="https://redis.io/commands/acl-getuser">ACL GETUSER username</a>
+   * @param name username
+   * @return a list of ACL rule definitions for the user.
+   */
   AccessControlUser aclGetUser(String name);
 
   /**

src/main/java/redis/clients/jedis/resps/AccessControlUser.java

@@ -8,6 +8,7 @@ public class AccessControlUser {
   private final List<String> flags = new ArrayList<>();
   private final List<String> keys = new ArrayList<>();
   private final List<String> passwords = new ArrayList<>();
+  private final List<String> channels = new ArrayList<>();
   private String commands;
 
   public AccessControlUser() {
@@ -37,6 +38,14 @@ public List<String> getPassword() {
     return passwords;
   }
 
+  public void addChannel(String channel){
+     channels.add(channel);
+  }
+
+  public List<String> getChannels() {
+    return channels;
+  }
+
   public String getCommands() {
     return commands;
   }
@@ -48,6 +57,6 @@ public void setCommands(String commands) {
   @Override
   public String toString() {
     return "AccessControlUser{" + "flags=" + flags + ", keys=" + keys + ", passwords=" + passwords
-        + ", commands='" + commands + '\'' + '}';
+        + ", commands='" + commands + ", channels='" + channels + '\'' + '}';
   }
 }

src/test/java/redis/clients/jedis/commands/jedis/AccessControlListCommandsTest.java

@@ -454,13 +454,15 @@ public void aclBinaryCommandsTest() {
     assertEquals(1L, jedis.aclDelUser(USER_ZZZ.getBytes()));
 
     jedis.aclSetUser(USER_ZZZ.getBytes(), "reset".getBytes(), "+@all".getBytes(), "~*".getBytes(),
-      "-@string".getBytes(), "+incr".getBytes(), "-debug".getBytes(), "+debug|digest".getBytes());
+      "-@string".getBytes(), "+incr".getBytes(), "-debug".getBytes(), "+debug|digest".getBytes(),
+            "resetchannels".getBytes(), "&testchannel:*".getBytes());
 
     AccessControlUser userInfo = jedis.aclGetUser(USER_ZZZ.getBytes());
 
     assertThat(userInfo.getCommands(), containsString("+@all"));
     assertThat(userInfo.getCommands(), containsString("-@string"));
     assertThat(userInfo.getCommands(), containsString("+debug|digest"));
+    assertEquals("testchannel:*", userInfo.getChannels().get(0));
 
     jedis.aclDelUser(USER_ZZZ.getBytes());