ferron_common/util/
header_placeholders.rs

1use crate::modules::SocketData;
2
3pub fn replace_header_placeholders(
4  input: &str,
5  request_parts: &hyper::http::request::Parts,
6  socket_data: Option<&SocketData>,
7) -> String {
8  let mut output = String::new();
9  let mut index_rb_saved = 0;
10  loop {
11    let index_lb = input[index_rb_saved..].find("{");
12    if let Some(index_lb) = index_lb {
13      let index_rb_afterlb = input[index_rb_saved + index_lb + 1..].find("}");
14      if let Some(index_rb_afterlb) = index_rb_afterlb {
15        let index_rb = index_rb_afterlb + index_lb + 1;
16        let placeholder_value = &input[index_rb_saved + index_lb + 1..index_rb_saved + index_rb];
17        output.push_str(&input[index_rb_saved..index_rb_saved + index_lb]);
18        match placeholder_value {
19          "path" => output.push_str(request_parts.uri.path()),
20          "path_and_query" => output.push_str(
21            request_parts
22              .uri
23              .path_and_query()
24              .map_or(request_parts.uri.path(), |p| p.as_str()),
25          ),
26          "method" => output.push_str(request_parts.method.as_str()),
27          "version" => output.push_str(match request_parts.version {
28            hyper::Version::HTTP_09 => "HTTP/0.9",
29            hyper::Version::HTTP_10 => "HTTP/1.0",
30            hyper::Version::HTTP_11 => "HTTP/1.1",
31            hyper::Version::HTTP_2 => "HTTP/2.0",
32            hyper::Version::HTTP_3 => "HTTP/3.0",
33            _ => "HTTP/Unknown",
34          }),
35          "scheme" => {
36            if let Some(socket_data) = socket_data {
37              output.push_str(if socket_data.encrypted { "https" } else { "http" });
38            } else {
39              // No socket data, leave it as is
40              output.push_str("{scheme}");
41            }
42          }
43          "client_ip" => {
44            if let Some(socket_data) = socket_data {
45              output.push_str(&socket_data.remote_addr.ip().to_string());
46            } else {
47              // No socket data, leave it as is
48              output.push_str("{client_ip}");
49            }
50          }
51          "client_port" => {
52            if let Some(socket_data) = socket_data {
53              output.push_str(&socket_data.remote_addr.port().to_string());
54            } else {
55              // No socket data, leave it as is
56              output.push_str("{client_port}");
57            }
58          }
59          "server_ip" => {
60            if let Some(socket_data) = socket_data {
61              output.push_str(&socket_data.local_addr.ip().to_string());
62            } else {
63              // No socket data, leave it as is
64              output.push_str("{server_ip}");
65            }
66          }
67          "server_port" => {
68            if let Some(socket_data) = socket_data {
69              output.push_str(&socket_data.local_addr.port().to_string());
70            } else {
71              // No socket data, leave it as is
72              output.push_str("{server_port}");
73            }
74          }
75          _ => {
76            if let Some(header_name) = placeholder_value.strip_prefix("header:") {
77              if let Some(header_value) = request_parts.headers.get(header_name) {
78                output.push_str(header_value.to_str().unwrap_or(""));
79              }
80            } else {
81              // Unknown placeholder, leave it as is
82              output.push('{');
83              output.push_str(placeholder_value);
84              output.push('}');
85            }
86          }
87        }
88        if index_rb < input.len() - 1 {
89          index_rb_saved += index_rb + 1;
90        } else {
91          break;
92        }
93      } else {
94        output.push_str(&input[index_rb_saved..]);
95      }
96    } else {
97      output.push_str(&input[index_rb_saved..]);
98      break;
99    }
100  }
101  output
102}
103
104#[cfg(test)]
105mod tests {
106  use super::*;
107  use hyper::header::HeaderName;
108  use hyper::http::{request::Parts, Method, Version};
109  use hyper::Request;
110
111  fn make_parts(uri_str: &str, method: Method, version: Version, headers: Option<Vec<(&str, &str)>>) -> Parts {
112    let mut parts = Request::builder()
113      .uri(uri_str)
114      .method(method)
115      .version(version)
116      .body(())
117      .unwrap()
118      .into_parts()
119      .0;
120
121    if let Some(hdrs) = headers {
122      for (k, v) in hdrs {
123        parts
124          .headers
125          .insert(k.parse::<HeaderName>().unwrap(), v.parse().unwrap());
126      }
127    }
128    parts
129  }
130
131  #[test]
132  fn test_basic_placeholders() {
133    let parts = make_parts("/some/path", Method::GET, Version::HTTP_11, None);
134    let input = "Path: {path}, Method: {method}, Version: {version}";
135    let expected = "Path: /some/path, Method: GET, Version: HTTP/1.1";
136    let output = replace_header_placeholders(input, &parts, None);
137    assert_eq!(output, expected);
138  }
139
140  #[test]
141  fn test_header_placeholder() {
142    let parts = make_parts(
143      "/test",
144      Method::POST,
145      Version::HTTP_2,
146      Some(vec![("User-Agent", "MyApp/1.0")]),
147    );
148    let input = "Header: {header:User-Agent}";
149    let expected = "Header: MyApp/1.0";
150    let output = replace_header_placeholders(input, &parts, None);
151    assert_eq!(output, expected);
152  }
153
154  #[test]
155  fn test_missing_header() {
156    let parts = make_parts("/", Method::GET, Version::HTTP_11, None);
157    let input = "Header: {header:Missing}";
158    let expected = "Header: ";
159    let output = replace_header_placeholders(input, &parts, None);
160    assert_eq!(output, expected);
161  }
162
163  #[test]
164  fn test_unknown_placeholder() {
165    let parts = make_parts("/", Method::GET, Version::HTTP_11, None);
166    let input = "Unknown: {foo}";
167    let expected = "Unknown: {foo}";
168    let output = replace_header_placeholders(input, &parts, None);
169    assert_eq!(output, expected);
170  }
171
172  #[test]
173  fn test_no_placeholders() {
174    let parts = make_parts("/", Method::GET, Version::HTTP_11, None);
175    let input = "Static string with no placeholders.";
176    let output = replace_header_placeholders(input, &parts, None);
177    assert_eq!(output, input);
178  }
179
180  #[test]
181  fn test_multiple_placeholders() {
182    let parts = make_parts(
183      "/data",
184      Method::PUT,
185      Version::HTTP_2,
186      Some(vec![("Content-Type", "application/json"), ("Host", "api.example.com")]),
187    );
188    let input = "{method} {path} {version} Host: {header:Host} Content-Type: {header:Content-Type}";
189    let expected = "PUT /data HTTP/2.0 Host: api.example.com Content-Type: application/json";
190    let output = replace_header_placeholders(input, &parts, None);
191    assert_eq!(output, expected);
192  }
193}
ferron_common/util/header_placeholders.rs

ferron_common/util/
header_placeholders.rs
