feat(import): add import endpoints (#102)

Co-authored-by: ferhat elmas <[email protected]>

Author: peterdeme

lib/stream-chat/client.rb

@@ -834,6 +834,26 @@ def list_push_providers
       get('push_providers')
     end
 
+    T::Sig::WithoutRuntime.sig { params(filename: String).returns(StreamChat::StreamResponse) }
+    def create_import_url(filename)
+      post('import_urls', data: { filename: filename })
+    end
+
+    T::Sig::WithoutRuntime.sig { params(path: String, mode: String).returns(StreamChat::StreamResponse) }
+    def create_import(path, mode)
+      post('imports', data: { path: path, mode: mode })
+    end
+
+    T::Sig::WithoutRuntime.sig { params(id: String).returns(StreamChat::StreamResponse) }
+    def get_import(id)
+      get("imports/#{id}")
+    end
+
+    T::Sig::WithoutRuntime.sig { params(options: T.untyped).returns(StreamChat::StreamResponse) }
+    def list_imports(options)
+      get('imports', params: options)
+    end
+
     private
 
     T::Sig::WithoutRuntime.sig { returns(T::Hash[String, String]) }

spec/client_spec.rb

@@ -3,6 +3,7 @@
 require 'jwt'
 require 'securerandom'
 require 'stream-chat'
+require 'faraday'
 
 describe StreamChat::Client do
   def loop_times(times)
@@ -709,6 +710,23 @@ def loop_times(times)
         expect(cmd['name']).not_to eq @cmd
       end
     end
+
+    it 'import end2end' do
+      url_resp = @client.create_import_url("#{SecureRandom.uuid}.json'")
+      expect(url_resp['upload_url']).not_to be_empty
+      expect(url_resp['path']).not_to be_empty
+
+      Faraday.put(url_resp['upload_url'], '{}', 'Content-Type' => 'application/json')
+
+      create_resp = @client.create_import(url_resp['path'], 'upsert')
+      expect(create_resp['import_task']['id']).not_to be_empty
+
+      get_resp = @client.get_import(create_resp['import_task']['id'])
+      expect(get_resp['import_task']['id']).to eq create_resp['import_task']['id']
+
+      list_resp = @client.list_imports({ limit: 1 })
+      expect(list_resp['import_tasks'].length).to eq 1
+    end
   end
 
   describe 'permissions' do