feat: Add mark unread and update mark read params (#305)

Author: vagruchi

channel.go

@@ -609,10 +609,10 @@ func (ch *Channel) demoteModerators(ctx context.Context, userIDs []string, msg *
 
 type markReadOption struct {
 	MessageID string `json:"message_id"`
+	ThreadID  string `json:"thread_id"`
 
 	UserID string `json:"user_id"`
 }
-
 type MarkReadOption func(*markReadOption)
 
 func MarkReadUntilMessage(id string) func(*markReadOption) {
@@ -621,6 +621,12 @@ func MarkReadUntilMessage(id string) func(*markReadOption) {
 	}
 }
 
+func MarkReadThread(id string) func(*markReadOption) {
+	return func(opt *markReadOption) {
+		opt.ThreadID = id
+	}
+}
+
 // MarkRead sends the mark read event for user with given ID,
 // only works if the `read_events` setting is enabled.
 func (ch *Channel) MarkRead(ctx context.Context, userID string, options ...MarkReadOption) (*Response, error) {
@@ -643,6 +649,49 @@ func (ch *Channel) MarkRead(ctx context.Context, userID string, options ...MarkR
 	return &resp, err
 }
 
+type markUnreadOption struct {
+	MessageID string `json:"message_id"`
+	ThreadID  string `json:"thread_id"`
+
+	UserID string `json:"user_id"`
+}
+
+type MarkUnreadOption func(option *markUnreadOption)
+
+// Specify ID of the message from where the channel is marked unread
+func MarkUnreadFromMessage(id string) func(*markUnreadOption) {
+	return func(opt *markUnreadOption) {
+		opt.MessageID = id
+	}
+}
+
+func MarkUnreadThread(id string) func(*markUnreadOption) {
+	return func(opt *markUnreadOption) {
+		opt.ThreadID = id
+	}
+}
+
+// MarkUnread message or thread (not both) for specified user.
+func (ch *Channel) MarkUnread(ctx context.Context, userID string, options ...MarkUnreadOption) (*Response, error) {
+	if userID == "" {
+		return nil, errors.New("user ID must be not empty")
+	}
+
+	p := path.Join("channels", url.PathEscape(ch.Type), url.PathEscape(ch.ID), "unread")
+
+	opts := &markUnreadOption{
+		UserID: userID,
+	}
+
+	for _, fn := range options {
+		fn(opts)
+	}
+
+	var resp Response
+	err := ch.client.makeRequest(ctx, http.MethodPost, p, nil, opts, &resp)
+	return &resp, err
+}
+
 // RefreshState makes request to channel api and updates channel internal state.
 func (ch *Channel) RefreshState(ctx context.Context) (*QueryResponse, error) {
 	q := &QueryRequest{State: true}