diff options
| author | rafael <rafael> | 2024-06-24 21:16:56 +0200 |
|---|---|---|
| committer | rafael <rafael> | 2024-06-24 21:16:56 +0200 |
| commit | 67e7532b4aa61fef52762861084a1a05944db4ea (patch) | |
| tree | 6819ae479c654a3f4e84298c6555e35d8e5d3658 /examples | |
| parent | 32e9867b4e23042fcbc4ec252c60b0af55cc59d7 (diff) | |
rustfmt
Diffstat (limited to 'examples')
| -rw-r--r-- | examples/rp/src/bin/wifi_webrequest.rs | 25 |
1 files changed, 9 insertions, 16 deletions
diff --git a/examples/rp/src/bin/wifi_webrequest.rs b/examples/rp/src/bin/wifi_webrequest.rs index 350e11bf1..ae3b1e26c 100644 --- a/examples/rp/src/bin/wifi_webrequest.rs +++ b/examples/rp/src/bin/wifi_webrequest.rs | |||
| @@ -13,17 +13,17 @@ use serde_json_core; | |||
| 13 | use cyw43_pio::PioSpi; | 13 | use cyw43_pio::PioSpi; |
| 14 | use defmt::*; | 14 | use defmt::*; |
| 15 | use embassy_executor::Spawner; | 15 | use embassy_executor::Spawner; |
| 16 | use embassy_net::{Config, Stack, StackResources}; | ||
| 17 | use embassy_net::tcp::client::{TcpClientState, TcpClient}; | ||
| 18 | use embassy_net::dns::DnsSocket; | 16 | use embassy_net::dns::DnsSocket; |
| 17 | use embassy_net::tcp::client::{TcpClient, TcpClientState}; | ||
| 18 | use embassy_net::{Config, Stack, StackResources}; | ||
| 19 | use embassy_rp::bind_interrupts; | 19 | use embassy_rp::bind_interrupts; |
| 20 | use embassy_rp::gpio::{Level, Output}; | 20 | use embassy_rp::gpio::{Level, Output}; |
| 21 | use embassy_rp::peripherals::{DMA_CH0, PIO0}; | 21 | use embassy_rp::peripherals::{DMA_CH0, PIO0}; |
| 22 | use embassy_rp::pio::{InterruptHandler, Pio}; | 22 | use embassy_rp::pio::{InterruptHandler, Pio}; |
| 23 | use embassy_time::{Duration, Timer}; | 23 | use embassy_time::{Duration, Timer}; |
| 24 | use static_cell::StaticCell; | ||
| 25 | use reqwless::client::{HttpClient, TlsConfig, TlsVerify}; | 24 | use reqwless::client::{HttpClient, TlsConfig, TlsVerify}; |
| 26 | use reqwless::request::Method; | 25 | use reqwless::request::Method; |
| 26 | use static_cell::StaticCell; | ||
| 27 | use {defmt_rtt as _, panic_probe as _}; | 27 | use {defmt_rtt as _, panic_probe as _}; |
| 28 | 28 | ||
| 29 | bind_interrupts!(struct Irqs { | 29 | bind_interrupts!(struct Irqs { |
| @@ -124,9 +124,7 @@ async fn main(spawner: Spawner) { | |||
| 124 | 124 | ||
| 125 | // And now we can use it! | 125 | // And now we can use it! |
| 126 | 126 | ||
| 127 | |||
| 128 | loop { | 127 | loop { |
| 129 | |||
| 130 | let mut rx_buffer = [0; 8192]; | 128 | let mut rx_buffer = [0; 8192]; |
| 131 | let mut tls_read_buffer = [0; 16640]; | 129 | let mut tls_read_buffer = [0; 16640]; |
| 132 | let mut tls_write_buffer = [0; 16640]; | 130 | let mut tls_write_buffer = [0; 16640]; |
| @@ -134,17 +132,12 @@ async fn main(spawner: Spawner) { | |||
| 134 | let client_state = TcpClientState::<1, 1024, 1024>::new(); | 132 | let client_state = TcpClientState::<1, 1024, 1024>::new(); |
| 135 | let tcp_client = TcpClient::new(stack, &client_state); | 133 | let tcp_client = TcpClient::new(stack, &client_state); |
| 136 | let dns_client = DnsSocket::new(stack); | 134 | let dns_client = DnsSocket::new(stack); |
| 137 | let tls_config = TlsConfig::new( | 135 | let tls_config = TlsConfig::new(seed, &mut tls_read_buffer, &mut tls_write_buffer, TlsVerify::None); |
| 138 | seed, | 136 | |
| 139 | &mut tls_read_buffer, | ||
| 140 | &mut tls_write_buffer, | ||
| 141 | TlsVerify::None, | ||
| 142 | ); | ||
| 143 | |||
| 144 | let mut http_client = HttpClient::new_with_tls(&tcp_client, &dns_client, tls_config); | 137 | let mut http_client = HttpClient::new_with_tls(&tcp_client, &dns_client, tls_config); |
| 145 | let url = "https://worldtimeapi.org/api/timezone/Europe/Berlin"; | 138 | let url = "https://worldtimeapi.org/api/timezone/Europe/Berlin"; |
| 146 | // let mut http_client = HttpClient::new(&tcp_client, &dns_client); // for non-TLS requests | 139 | // let mut http_client = HttpClient::new(&tcp_client, &dns_client); // for non-TLS requests |
| 147 | // let url = "http://worldtimeapi.org/api/timezone/Europe/Berlin"; | 140 | // let url = "http://worldtimeapi.org/api/timezone/Europe/Berlin"; |
| 148 | 141 | ||
| 149 | info!("connecting to {}", &url); | 142 | info!("connecting to {}", &url); |
| 150 | 143 | ||
| @@ -160,7 +153,7 @@ async fn main(spawner: Spawner) { | |||
| 160 | Ok(resp) => resp, | 153 | Ok(resp) => resp, |
| 161 | Err(_e) => { | 154 | Err(_e) => { |
| 162 | error!("Failed to send HTTP request"); | 155 | error!("Failed to send HTTP request"); |
| 163 | return // handle the error; | 156 | return; // handle the error; |
| 164 | } | 157 | } |
| 165 | }; | 158 | }; |
| 166 | 159 | ||
| @@ -168,13 +161,13 @@ async fn main(spawner: Spawner) { | |||
| 168 | Ok(b) => b, | 161 | Ok(b) => b, |
| 169 | Err(_e) => { | 162 | Err(_e) => { |
| 170 | error!("Failed to read response body"); | 163 | error!("Failed to read response body"); |
| 171 | return // handle the error | 164 | return; // handle the error |
| 172 | } | 165 | } |
| 173 | }; | 166 | }; |
| 174 | info!("Response body: {:?}", &body); | 167 | info!("Response body: {:?}", &body); |
| 175 | 168 | ||
| 176 | // parse the response body and update the RTC | 169 | // parse the response body and update the RTC |
| 177 | 170 | ||
| 178 | #[derive(Deserialize)] | 171 | #[derive(Deserialize)] |
| 179 | struct ApiResponse<'a> { | 172 | struct ApiResponse<'a> { |
| 180 | datetime: &'a str, | 173 | datetime: &'a str, |
