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