@@ -88,20 +88,17 @@ defmodule ReqTrino do
88
88
end
89
89
90
90
def build_req_params ( request , opts ) do
91
- request
92
- |> Request . put_header ( @ header_user , opts [ :user ] )
91
+ Request . put_header ( request , @ header_user , opts [ :user ] )
93
92
end
94
93
95
- defp run ( % Request { options: options } = request ) do
96
- if _query = request . options [ :trino ] do
97
- % { request | url: URI . parse ( "#{ options [ :host ] } /v1/statement" ) , body: options [ :trino ] }
98
- |> build_req_params ( options )
99
- |> Request . append_response_steps ( trino_result: & handle_trino_result / 1 )
100
- else
101
- request
102
- end
94
+ defp run ( % Request { options: % { trino: query , host: host } } = request ) do
95
+ % { request | url: URI . parse ( "#{ host } /v1/statement" ) , body: query }
96
+ |> build_req_params ( request . options )
97
+ |> Request . append_response_steps ( trino_result: & handle_trino_result / 1 )
103
98
end
104
99
100
+ defp run ( request ) , do: request
101
+
105
102
defp stream_results ( initial_body , request_options ) do
106
103
Stream . unfold ( { :initial , initial_body } , fn
107
104
{ :initial , body } ->
@@ -143,9 +140,7 @@ defmodule ReqTrino do
143
140
end
144
141
end
145
142
146
- defp handle_trino_result ( response ) do
147
- response
148
- end
143
+ defp handle_trino_result ( response ) , do: response
149
144
150
145
def decode_body ( body , request_options ) do
151
146
% Result {
0 commit comments