1. #[embassy_executor::task(pool_size = 3)]
2. pub async fn task(stack: &'static Stack<WifiDevice<'static, WifiStaDevice>>) {
3. let mut rx_buffer = [0; RX_BUFFER_SIZE];
4. let mut tx_buffer = [0; TX_BUFFER_SIZE];
6. let router = Router::new()
7. .post(("valve", u8::segment()), control_valve)
8. .get("/panic", || async { panic!("oops") })
9. .get("/sleep", || async { Timer::after_secs(3).await })
10. .get("/ping", || async { "pong" })
11. .with_state(AppState);
13. loop {
14. let mut socket = TcpSocket::new(stack, &mut rx_buffer, &mut tx_buffer);
16. if let Err(e) = socket.accept(80).await {
17. log::warn!("accept error: {:?}", e);
18. continue;
19. }
21. if let Some(IpEndpoint { addr, port }) = socket.remote_endpoint() {
22. log::info!("connection from: {addr}:{port}");
23. }
25. let (read, write) = socket.split();
26. if let Err(err) = router.serve(read, write).await {
27. log::warn!("failed to serve request: {err:?}");
28. };
30. socket.flush().await.log_ignore();
31. socket.close();
32. Timer::after(Duration::from_millis(100)).await;
33. socket.abort();
34. }
35. }