Add token revocation methods (#46)

Author: Siddhant Agarwal

lib/stream-chat/client.rb

@@ -4,6 +4,7 @@
 require 'open-uri'
 require 'faraday'
 require 'jwt'
+require 'time'
 require 'stream-chat/channel'
 require 'stream-chat/errors'
 require 'stream-chat/version'
@@ -45,9 +46,10 @@ def initialize(api_key = '', api_secret = '', timeout = 6.0, **options)
       end
     end
 
-    def create_token(user_id, exp = nil)
+    def create_token(user_id, exp = nil, iat = nil)
       payload = { user_id: user_id }
       payload['exp'] = exp unless exp.nil?
+      payload['iat'] = iat unless iat.nil?
       JWT.encode(payload, @api_secret, 'HS256')
     end
 
@@ -283,6 +285,30 @@ def get_export_channel_status(task_id)
       get("export_channels/#{task_id}")
     end
 
+    def revoke_tokens(before)
+      before = before.rfc3339 if before.instance_of?(DateTime)
+      update_app_settings({ 'revoke_tokens_issued_before' => before })
+    end
+
+    def revoke_user_token(user_id, before)
+      revoke_users_token([user_id], before)
+    end
+
+    def revoke_users_token(user_ids, before)
+      before = before.rfc3339 if before.instance_of?(DateTime)
+
+      updates = []
+      user_ids.each do |user_id|
+        updates.push({
+                       'id' => user_id,
+                       'set' => {
+                         'revoke_tokens_issued_before' => before
+                       }
+                     })
+      end
+      update_users_partial(updates)
+    end
+
     def put(relative_url, params: nil, data: nil)
       make_http_request(:put, relative_url, params: params, data: data)
     end