geoengine_api_client/apis/
ogcwms_api.rs1use reqwest;
13use serde::{Deserialize, Serialize, de::Error as _};
14use crate::{apis::ResponseContent, models};
15use super::{Error, configuration, ContentType};
16
17
18#[derive(Debug, Clone, Serialize, Deserialize)]
20#[serde(untagged)]
21pub enum WmsHandlerError {
22 UnknownValue(serde_json::Value),
23}
24
25
26pub async fn wms_handler(configuration: &configuration::Configuration, workflow: &str, request: models::WmsRequest, bbox: Option<&str>, bgcolor: Option<&str>, crs: Option<&str>, elevation: Option<&str>, exceptions: Option<&str>, format: Option<&str>, height: Option<i32>, info_format: Option<&str>, layer: Option<&str>, layers: Option<&str>, query_layers: Option<&str>, service: Option<models::WmsService>, sld: Option<&str>, sld_body: Option<&str>, styles: Option<&str>, time: Option<&str>, transparent: Option<bool>, version: Option<&str>, width: Option<i32>) -> Result<reqwest::Response, Error<WmsHandlerError>> {
27 let p_path_workflow = workflow;
29 let p_query_request = request;
30 let p_query_bbox = bbox;
31 let p_query_bgcolor = bgcolor;
32 let p_query_crs = crs;
33 let p_query_elevation = elevation;
34 let p_query_exceptions = exceptions;
35 let p_query_format = format;
36 let p_query_height = height;
37 let p_query_info_format = info_format;
38 let p_query_layer = layer;
39 let p_query_layers = layers;
40 let p_query_query_layers = query_layers;
41 let p_query_service = service;
42 let p_query_sld = sld;
43 let p_query_sld_body = sld_body;
44 let p_query_styles = styles;
45 let p_query_time = time;
46 let p_query_transparent = transparent;
47 let p_query_version = version;
48 let p_query_width = width;
49
50 let uri_str = format!("{}/wms/{workflow}", configuration.base_path, workflow=crate::apis::urlencode(p_path_workflow));
51 let mut req_builder = configuration.client.request(reqwest::Method::GET, &uri_str);
52
53 if let Some(ref param_value) = p_query_bbox {
54 req_builder = req_builder.query(&[("bbox", ¶m_value.to_string())]);
55 }
56 if let Some(ref param_value) = p_query_bgcolor {
57 req_builder = req_builder.query(&[("bgcolor", ¶m_value.to_string())]);
58 }
59 if let Some(ref param_value) = p_query_crs {
60 req_builder = req_builder.query(&[("crs", ¶m_value.to_string())]);
61 }
62 if let Some(ref param_value) = p_query_elevation {
63 req_builder = req_builder.query(&[("elevation", ¶m_value.to_string())]);
64 }
65 if let Some(ref param_value) = p_query_exceptions {
66 req_builder = req_builder.query(&[("exceptions", ¶m_value.to_string())]);
67 }
68 if let Some(ref param_value) = p_query_format {
69 req_builder = req_builder.query(&[("format", ¶m_value.to_string())]);
70 }
71 if let Some(ref param_value) = p_query_height {
72 req_builder = req_builder.query(&[("height", ¶m_value.to_string())]);
73 }
74 if let Some(ref param_value) = p_query_info_format {
75 req_builder = req_builder.query(&[("info_format", ¶m_value.to_string())]);
76 }
77 if let Some(ref param_value) = p_query_layer {
78 req_builder = req_builder.query(&[("layer", ¶m_value.to_string())]);
79 }
80 if let Some(ref param_value) = p_query_layers {
81 req_builder = req_builder.query(&[("layers", ¶m_value.to_string())]);
82 }
83 if let Some(ref param_value) = p_query_query_layers {
84 req_builder = req_builder.query(&[("query_layers", ¶m_value.to_string())]);
85 }
86 req_builder = req_builder.query(&[("request", &p_query_request.to_string())]);
87 if let Some(ref param_value) = p_query_service {
88 req_builder = req_builder.query(&[("service", ¶m_value.to_string())]);
89 }
90 if let Some(ref param_value) = p_query_sld {
91 req_builder = req_builder.query(&[("sld", ¶m_value.to_string())]);
92 }
93 if let Some(ref param_value) = p_query_sld_body {
94 req_builder = req_builder.query(&[("sld_body", ¶m_value.to_string())]);
95 }
96 if let Some(ref param_value) = p_query_styles {
97 req_builder = req_builder.query(&[("styles", ¶m_value.to_string())]);
98 }
99 if let Some(ref param_value) = p_query_time {
100 req_builder = req_builder.query(&[("time", ¶m_value.to_string())]);
101 }
102 if let Some(ref param_value) = p_query_transparent {
103 req_builder = req_builder.query(&[("transparent", ¶m_value.to_string())]);
104 }
105 if let Some(ref param_value) = p_query_version {
106 req_builder = req_builder.query(&[("version", ¶m_value.to_string())]);
107 }
108 if let Some(ref param_value) = p_query_width {
109 req_builder = req_builder.query(&[("width", ¶m_value.to_string())]);
110 }
111 if let Some(ref user_agent) = configuration.user_agent {
112 req_builder = req_builder.header(reqwest::header::USER_AGENT, user_agent.clone());
113 }
114 if let Some(ref token) = configuration.bearer_access_token {
115 req_builder = req_builder.bearer_auth(token.to_owned());
116 };
117
118 let req = req_builder.build()?;
119 let resp = configuration.client.execute(req).await?;
120
121 let status = resp.status();
122
123 if !status.is_client_error() && !status.is_server_error() {
124 Ok(resp)
125 } else {
126 let content = resp.text().await?;
127 let entity: Option<WmsHandlerError> = serde_json::from_str(&content).ok();
128 Err(Error::ResponseError(ResponseContent { status, content, entity }))
129 }
130}
131