Fix deploy

Author: abnegate

.github/workflows/publish.yml

@@ -19,8 +19,10 @@ jobs:
 
       - name: Set up RubyGems
         run: |
-          cat "---\n:rubygems_api_key: ${{ secrets.RUBYGEMS_TOKEN }}\n" > ~/.gem/credentials
+          echo -e "---\n:rubygems_api_key: $RUBYGEMS_TOKEN\n" > ~/.gem/credentials
           chmod 0600 ~/.gem/credentials
+        env:
+          RUBYGEMS_TOKEN: $
 
       - name: Build gem
         run: gem build appwrite.gemspec

Gemfile

@@ -1,6 +1,3 @@
 source 'https://rubygems.org'
 
-gem 'mime-types', '~> 3.4.1'
-
-gemspec
-
+gemspec

appwrite.gemspec

@@ -1,7 +1,7 @@
 Gem::Specification.new do |spec|
 
   spec.name = 'appwrite'
-  spec.version = '13.0.0'
+  spec.version = '12.1.1'
   spec.license = 'BSD-3-Clause'
   spec.summary = 'Appwrite is an open-source self-hosted backend server that abstract and simplify complex and repetitive development tasks behind a very simple REST API'
   spec.author = 'Appwrite Team'

docs/examples/functions/create-deployment.md

@@ -11,7 +11,7 @@ functions = Functions.new(client)
 
 result = functions.create_deployment(
     function_id: '<FUNCTION_ID>',
-    code: Payload.from_file('/path/to/file.png'),
+    code: InputFile.from_path('dir/file.png'),
     activate: false,
     entrypoint: '<ENTRYPOINT>', # optional
     commands: '<COMMANDS>' # optional

docs/examples/functions/create-execution.md

@@ -11,7 +11,7 @@ functions = Functions.new(client)
 
 result = functions.create_execution(
     function_id: '<FUNCTION_ID>',
-    body: Payload.from_json({ "x": "y" }), # optional
+    body: , # optional
     async: false, # optional
     path: '<PATH>', # optional
     method: ExecutionMethod::GET, # optional

docs/examples/storage/create-file.md

@@ -12,6 +12,6 @@ storage = Storage.new(client)
 result = storage.create_file(
     bucket_id: '<BUCKET_ID>',
     file_id: '<FILE_ID>',
-    file: Payload.from_file('/path/to/file.png'),
+    file: InputFile.from_path('dir/file.png'),
     permissions: ["read("any")"] # optional
 )

lib/appwrite.rb

@@ -6,8 +6,7 @@
 require_relative 'appwrite/client'
 require_relative 'appwrite/service'
 require_relative 'appwrite/exception'
-require_relative 'appwrite/payload'
-require_relative 'appwrite/multipart'
+require_relative 'appwrite/input_file'
 require_relative 'appwrite/query'
 require_relative 'appwrite/permission'
 require_relative 'appwrite/role'

lib/appwrite/client.rb

@@ -15,14 +15,17 @@ def initialize
                 'x-sdk-name'=> 'Ruby',
                 'x-sdk-platform'=> 'server',
                 'x-sdk-language'=> 'ruby',
-                'x-sdk-version'=> '13.0.0',                'X-Appwrite-Response-Format' => '1.6.0'            }
+                'x-sdk-version'=> '12.1.1',                
+                'X-Appwrite-Response-Format' => '1.6.0'
+            }
             @endpoint = 'https://cloud.appwrite.io/v1'
         end
 
         # Set Project
         #
         # Your project ID
-        #        # @param [String] value The value to set for the Project header
+        #
+        # @param [String] value The value to set for the Project header
         #
         # @return [self]
         def set_project(value)
@@ -34,7 +37,8 @@ def set_project(value)
         # Set Key
         #
         # Your secret API key
-        #        # @param [String] value The value to set for the Key header
+        #
+        # @param [String] value The value to set for the Key header
         #
         # @return [self]
         def set_key(value)
@@ -46,7 +50,8 @@ def set_key(value)
         # Set JWT
         #
         # Your secret JSON Web Token
-        #        # @param [String] value The value to set for the JWT header
+        #
+        # @param [String] value The value to set for the JWT header
         #
         # @return [self]
         def set_jwt(value)
@@ -69,7 +74,8 @@ def set_locale(value)
         # Set Session
         #
         # The user session to authenticate with
-        #        # @param [String] value The value to set for the Session header
+        #
+        # @param [String] value The value to set for the Session header
         #
         # @return [self]
         def set_session(value)
@@ -81,7 +87,8 @@ def set_session(value)
         # Set ForwardedUserAgent
         #
         # The user agent string of the client that made the request
-        #        # @param [String] value The value to set for the ForwardedUserAgent header
+        #
+        # @param [String] value The value to set for the ForwardedUserAgent header
         #
         # @return [self]
         def set_forwarded_user_agent(value)
@@ -112,6 +119,7 @@ def set_self_signed(self_signed = true)
             self
         end
 
+
         # Add Header
         #
         # @param [String] key The key for the header to add
@@ -154,9 +162,20 @@ def chunked_upload(
             on_progress: nil,
             response_type: nil
         )
-            payload = params[param_name.to_sym]
+            input_file = params[param_name.to_sym]
+
+            case input_file.source_type
+            when 'path'
+                size = ::File.size(input_file.path)
+            when 'string'
+                size = input_file.data.bytesize
+            end
 
-            if payload.size < @chunk_size
+            if size < @chunk_size
+                if input_file.source_type == 'path'
+                    input_file.data = IO.read(input_file.path)
+                end
+                params[param_name.to_sym] = input_file
                 return call(
                     method: 'POST',
                     path: path,
@@ -180,13 +199,21 @@ def chunked_upload(
                 offset = chunks_uploaded * @chunk_size
             end
 
-            while offset < payload.size
-                params[param_name.to_sym] = Payload.from_binary(
-                    payload.to_binary(offset, [@chunk_size, payload.size - offset].min),
-                    filename: payload.filename
+            while offset < size
+                case input_file.source_type
+                when 'path'
+                    string = IO.read(input_file.path, @chunk_size, offset)
+                when 'string'
+                    string = input_file.data.byteslice(offset, [@chunk_size, size - offset].min)
+                end
+
+                params[param_name.to_sym] = InputFile::from_string(
+                    string,
+                    filename: input_file.filename,
+                    mime_type: input_file.mime_type
                 )
 
-                headers['content-range'] = "bytes #{offset}-#{[offset + @chunk_size - 1, payload.size - 1].min}/#{payload.size}"
+                headers['content-range'] = "bytes #{offset}-#{[offset + @chunk_size - 1, size - 1].min}/#{size}"
 
                 result = call(
                     method: 'POST',
@@ -203,8 +230,8 @@ def chunked_upload(
 
                 on_progress.call({
                     id: result['$id'],
-                    progress: ([offset, payload.size].min).to_f/payload.size.to_f * 100.0,
-                    size_uploaded: [offset, payload.size].min,
+                    progress: ([offset, size].min).to_f/size.to_f * 100.0,
+                    size_uploaded: [offset, size].min,
                     chunks_total: result['chunksTotal'],
                     chunks_uploaded: result['chunksUploaded']
                 }) unless on_progress.nil?
@@ -231,27 +258,18 @@ def fetch(
             @http.use_ssl = !@self_signed
             payload = ''
 
-            headers = @headers.merge(headers.transform_keys(&:to_s))
+            headers = @headers.merge(headers)
 
             params.compact!
 
+            @boundary = "----A30#3ad1"
             if method != "GET"
-                case headers['content-type']
+                case headers[:'content-type']
                     when 'application/json'
                         payload = params.to_json
                     when 'multipart/form-data'
-                        multipart = MultipartBuilder.new()
-                        
-                        params.each do |name, value|
-                            if value.is_a?(Payload)
-                                multipart.add(name, value.to_s, filename: value.filename)
-                            else
-                                multipart.add(name, value)
-                            end
-                        end
-
-                        headers['content-type'] = multipart.content_type
-                        payload = multipart.body
+                        payload = encode_form_data(params) + "--#{@boundary}--\r\n"
+                        headers[:'content-type'] = "multipart/form-data; boundary=#{@boundary}"
                     else
                         payload = encode(params)
                 end
@@ -281,7 +299,7 @@ def fetch(
                 return fetch(method, uri, headers, {}, response_type, limit - 1)
             end
 
-            if response.content_type.start_with?('application/json')
+            if response.content_type == 'application/json'
                 begin
                     result = JSON.parse(response.body)
                 rescue JSON::ParserError => e
@@ -292,34 +310,49 @@ def fetch(
                     raise Appwrite::Exception.new(result['message'], result['status'], result['type'], result)
                 end
 
-                if response_type.respond_to?("from")
-                    return response_type.from(map: result)
+                unless response_type.respond_to?("from")
+                    return result
                 end
 
-                return result
+                return response_type.from(map: result)
             end
 
             if response.code.to_i >= 400
                 raise Appwrite::Exception.new(response.body, response.code, response)
             end
 
-            if response.content_type.start_with?('multipart/form-data')
-                multipart = MultipartParser.new(response.body, response['content-type'])
-                result = multipart.to_hash
-
-                if response_type.respond_to?("from")
-                    return response_type.from(map: result)
-                end
-                
-                return result
-            end
-
-            if response.class.body_permitted?
-                return response.body
+            if response.respond_to?("body_permitted?")
+                return response.body if response.body_permitted?
             end
 
             return response
         end
+        
+        def encode_form_data(value, key=nil)
+            case value
+            when Hash
+                value.map { |k,v| encode_form_data(v,k) }.join
+            when Array
+                value.map { |v| encode_form_data(v, "#{key}[]") }.join
+            when nil
+                ''
+            else
+                post_body = []
+                if value.instance_of? InputFile
+                    post_body << "--#{@boundary}"
+                    post_body << "Content-Disposition: form-data; name=\"#{key}\"; filename=\"#{value.filename}\""
+                    post_body << "Content-Type: #{value.mime_type}"
+                    post_body << ""
+                    post_body << value.data
+                else
+                    post_body << "--#{@boundary}"
+                    post_body << "Content-Disposition: form-data; name=\"#{key}\""
+                    post_body << ""
+                    post_body << value.to_s
+                end
+                post_body.join("\r\n") + "\r\n"
+            end
+        end
 
         def encode(value, key = nil)
             case value

lib/appwrite/input_file.rb

@@ -0,0 +1,33 @@
+require 'mime/types'
+
+module Appwrite
+    class InputFile
+        attr_accessor :path
+        attr_accessor :filename
+        attr_accessor :mime_type
+        attr_accessor :source_type
+        attr_accessor :data
+
+        def self.from_path(path)
+            instance = InputFile.new
+            instance.path = path
+            instance.filename = ::File.basename(path)
+            instance.mime_type = MIME::Types.type_for(path).first.content_type
+            instance.source_type = 'path'
+            instance
+        end
+
+        def self.from_string(string, filename: nil, mime_type: nil)
+            instance = InputFile.new
+            instance.data = string
+            instance.filename = filename
+            instance.mime_type = mime_type
+            instance.source_type = 'string'
+            instance
+        end
+
+        def self.from_bytes(bytes, filename: nil, mime_type: nil)
+            self.from_string(bytes.pack('C*'), filename: filename, mime_type: mime_type)
+        end
+    end
+end

lib/appwrite/models/document.rb

@@ -10,21 +10,24 @@ class Document
             attr_reader :updated_at
             attr_reader :permissions
             attr_reader :data
+
             def initialize(
                 id:,
                 collection_id:,
                 database_id:,
                 created_at:,
                 updated_at:,
                 permissions:,
-                data:            )
+                data:
+            )
                 @id = id
                 @collection_id = collection_id
                 @database_id = database_id
                 @created_at = created_at
                 @updated_at = updated_at
                 @permissions = permissions
-                @data = data            end
+                @data = data
+            end
 
             def self.from(map:)
                 Document.new(
@@ -34,7 +37,8 @@ def self.from(map:)
                     created_at: map["$createdAt"],
                     updated_at: map["$updatedAt"],
                     permissions: map["$permissions"],
-                    data: map                )
+                    data: map
+                )
             end
 
             def to_map
@@ -45,7 +49,8 @@ def to_map
                     "$createdAt": @created_at,
                     "$updatedAt": @updated_at,
                     "$permissions": @permissions,
-                    "data": @data                }
+                    "data": @data
+                }
             end
 
             def convert_to(from_json)