Add helper for normalizing timestamps

Author: Acconut

lib/stream-chat/channel.rb

@@ -235,17 +235,7 @@ def update_member_partial(user_id, set: nil, unset: nil)
     sig { params(user_ids: T::Array[String], options: T.untyped).returns(StreamChat::StreamResponse) }
     def add_members(user_ids, **options)
       payload = options.dup
-
-      # Convert hide_history_before timestamp to RFC 3339 format if it's a DateTime or Time object
-      if payload.key?(:hide_history_before)
-        hide_history_before = payload[:hide_history_before]
-        if hide_history_before.is_a?(DateTime)
-          payload[:hide_history_before] = hide_history_before.rfc3339
-        elsif hide_history_before.is_a?(Time)
-          payload[:hide_history_before] = hide_history_before.iso8601
-        end
-      end
-
+      payload[:hide_history_before] = StreamChat.normalize_timestamp(payload[:hide_history_before]) if payload[:hide_history_before]
       payload = payload.merge({ add_members: user_ids })
       update(nil, nil, **payload)
     end

lib/stream-chat/client.rb

@@ -738,7 +738,7 @@ def delete_channels(cids, hard_delete: false)
     # Revoke tokens for an application issued since the given date.
     sig { params(before: T.any(DateTime, String)).returns(StreamChat::StreamResponse) }
     def revoke_tokens(before)
-      before = before.rfc3339 if before.instance_of?(DateTime)
+      before = StreamChat.normalize_timestamp(before)
       update_app_settings({ 'revoke_tokens_issued_before' => before })
     end
 
@@ -751,7 +751,7 @@ def revoke_user_token(user_id, before)
     # Revoke tokens for users issued since.
     sig { params(user_ids: T::Array[String], before: T.any(DateTime, String)).returns(StreamChat::StreamResponse) }
     def revoke_users_token(user_ids, before)
-      before = before.rfc3339 if before.instance_of?(DateTime)
+      before = StreamChat.normalize_timestamp(before)
 
       updates = []
       user_ids.map do |user_id|
@@ -1024,7 +1024,7 @@ def query_threads(filter, sort: nil, **options)
     sig { params(message_id: String, user_id: String, remind_at: T.nilable(DateTime)).returns(StreamChat::StreamResponse) }
     def create_reminder(message_id, user_id, remind_at = nil)
       data = { user_id: user_id }
-      data[:remind_at] = remind_at.rfc3339 if remind_at.instance_of?(DateTime)
+      data[:remind_at] = StreamChat.normalize_timestamp(remind_at) if remind_at
       post("messages/#{message_id}/reminders", data: data)
     end
 
@@ -1036,7 +1036,7 @@ def create_reminder(message_id, user_id, remind_at = nil)
     sig { params(message_id: String, user_id: String, remind_at: T.nilable(DateTime)).returns(StreamChat::StreamResponse) }
     def update_reminder(message_id, user_id, remind_at = nil)
       data = { user_id: user_id }
-      data[:remind_at] = remind_at.rfc3339 if remind_at
+      data[:remind_at] = StreamChat.normalize_timestamp(remind_at) if remind_at
       patch("messages/#{message_id}/reminders", data: data)
     end
 

lib/stream-chat/util.rb

@@ -14,4 +14,13 @@ def self.get_sort_fields(sort)
     end
     sort_fields
   end
+
+  # Normalizes a timestamp to RFC 3339 / ISO 8601 string format.
+  def self.normalize_timestamp(t)
+    case t
+    when DateTime then t.rfc3339
+    when Time then t.iso8601
+    else t
+    end
+  end
 end