diff --git a/lib/dify/client.rb b/lib/dify/client.rb index 76626d8..2e71783 100644 --- a/lib/dify/client.rb +++ b/lib/dify/client.rb @@ -56,7 +56,7 @@ def upload_file(file_path, user, filename = "localfile", mine_type = "text/plain private - def _send_request(method, endpoint, data = nil, params = nil, _stream = false) + def _send_request(method, endpoint, data = nil, params = nil, _stream: false) uri = URI.parse("#{@base_url}#{endpoint}") http = Net::HTTP.new(uri.host, uri.port) @@ -87,7 +87,7 @@ def create_completion_message(inputs, query, response_mode, user) response_mode: response_mode, user: user } - _send_request("POST", "/completion-messages", data, nil, response_mode == "streaming") + _send_request("POST", "/completion-messages", data, nil, _stream: response_mode == "streaming") end end @@ -101,7 +101,7 @@ def run_workflow(inputs, user, response_mode = "blocking", trace_id = nil) data[:trace_id] = trace_id if trace_id - _send_request("POST", "/workflows/run", data, nil, response_mode == "streaming") + _send_request("POST", "/workflows/run", data, nil, _stream: response_mode == "streaming") end def get_workflow(workflow_id) @@ -119,7 +119,7 @@ def create_chat_message(inputs, query, user, response_mode = "blocking", convers } data[:conversation_id] = conversation_id if conversation_id - _send_request("POST", "/chat-messages", data, nil, response_mode == "streaming") + _send_request("POST", "/chat-messages", data, nil, _stream: response_mode == "streaming") end def get_conversation_messages(user, conversation_id = nil, first_id = nil, limit = nil)