apunkt/plano
1
0
Fork 0
mirror of https://github.com/katanemo/plano.git synced 2026-05-03 21:02:56 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

remove method type (#101)

Browse source
This commit is contained in:
Adil Hafeez 2024-09-30 17:59:29 -07:00 • committed by GitHub
parent f154bc3741
commit 2207021b9c
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
3 changed files with 3 additions and 61 deletions
Download patch file Download diff file Expand all files Collapse all files

21
arch/src/stream_context.rs
View file

@ -524,32 +524,17 @@ impl StreamContext {
debug!("tool_params: {}", tool_params_json_str);
let endpoint = prompt_target.endpoint.unwrap();
let mut path = endpoint.path.unwrap_or(String::from("/"));
let method = endpoint
.method
.unwrap_or(public_types::configuration::Method::Post);
let mut body = Some(tool_params_json_str.as_bytes());
if method == public_types::configuration::Method::Post {
let mut query_params = vec![];
for (key, value) in tool_params {
query_params.push(format!("{}={}", key, format!("{:?}", value)));
}
let path_args = &query_params.join("&");
path.push_str("?");
path.push_str(path_args);
} else {
body = None;
}
let path: String = endpoint.path.unwrap_or(String::from("/"));
let token_id = match self.dispatch_http_call(
&endpoint.name,
vec![
(":method", method.to_string().as_str()),
(":method", "POST"),
(":path", path.as_ref()),
(":authority", endpoint.name.as_str()),
("content-type", "application/json"),
("x-envoy-max-retries", "3"),
],
body,
Some(tool_params_json_str.as_bytes()),
vec![],
Duration::from_secs(5),
) {