[common] Add channels list queryv0.6.0

1 files changed, 22 insertions, 0 deletions

diff --git a/server/user.go b/server/user.go
index 69b7ced..5e29c8d 100644
--- a/server/user.go
+++ b/server/user.go
@@ -126,6 +126,8 @@ func (s *Server) handleUserPayload(user *User, sender net.Conn, payload any) err
 		return s.handleUsermode(user, sender, v)
 	case core.History:
 		return s.handleHistory(user, sender, v)
+	case core.List:
+		return s.handleList(user, sender, v)
 	default:
 		return core.ErrUnexpectedPayloadType
 	}
@@ -206,3 +208,23 @@ func (s *Server) handleHistory(user *User, conn net.Conn, hist core.History) err
 
 	return nil
 }
+
+func (s *Server) handleList(user *User, conn net.Conn, list core.List) error {
+	channels, err := s.Storage.GetUserChannels(user.Addr, int(list.Count), int(list.Offset))
+	if err != nil {
+		return fmt.Errorf("cannot get user channels list: %v", err)
+	}
+
+	for _, c := range channels {
+		li := core.ListItem{c}
+		data, err := core.Encode(li)
+		if err != nil {
+			return err
+		}
+		if _, err := conn.Write(data); err != nil {
+			return err
+		}
+	}
+
+	return nil
+}