mirror of
https://github.com/mountain-loop/yaak.git
synced 2026-03-18 23:43:55 +01:00
42 lines
1.3 KiB
Rust
42 lines
1.3 KiB
Rust
use crate::error::Result;
|
|
use std::collections::BTreeMap;
|
|
use yaak_models::models::{Environment, HttpRequestHeader, WebsocketRequest};
|
|
use yaak_models::render::make_vars_hashmap;
|
|
use yaak_templates::{parse_and_render, render_json_value_raw, RenderOptions, TemplateCallback};
|
|
|
|
pub async fn render_websocket_request<T: TemplateCallback>(
|
|
r: &WebsocketRequest,
|
|
environment_chain: Vec<Environment>,
|
|
cb: &T,
|
|
opt: &RenderOptions,
|
|
) -> Result<WebsocketRequest> {
|
|
let vars = &make_vars_hashmap(environment_chain);
|
|
|
|
let mut headers = Vec::new();
|
|
for p in r.headers.clone() {
|
|
headers.push(HttpRequestHeader {
|
|
enabled: p.enabled,
|
|
name: parse_and_render(&p.name, vars, cb, opt).await?,
|
|
value: parse_and_render(&p.value, vars, cb, opt).await?,
|
|
id: p.id,
|
|
})
|
|
}
|
|
|
|
let mut authentication = BTreeMap::new();
|
|
for (k, v) in r.authentication.clone() {
|
|
authentication.insert(k, render_json_value_raw(v, vars, cb, opt).await?);
|
|
}
|
|
|
|
let url = parse_and_render(r.url.as_str(), vars, cb, opt).await?;
|
|
|
|
let message = parse_and_render(&r.message.clone(), vars, cb, opt).await?;
|
|
|
|
Ok(WebsocketRequest {
|
|
url,
|
|
headers,
|
|
authentication,
|
|
message,
|
|
..r.to_owned()
|
|
})
|
|
}
|