(
State(state): State<AppState>,
ConnectInfo(address): ConnectInfo<SocketAddr>,
Path(udid): Path<String>,
Json(payload): Json<crate::transport::webrtc::WebRtcOfferPayload>,
)
| 2822 | } |
| 2823 | |
| 2824 | async fn webrtc_offer( |
| 2825 | State(state): State<AppState>, |
| 2826 | ConnectInfo(address): ConnectInfo<SocketAddr>, |
| 2827 | Path(udid): Path<String>, |
| 2828 | Json(payload): Json<crate::transport::webrtc::WebRtcOfferPayload>, |
| 2829 | ) -> Result<Json<crate::transport::webrtc::WebRtcAnswerPayload>, AppError> { |
| 2830 | crate::transport::webrtc::create_answer(state, udid, payload, address.ip().is_loopback()) |
| 2831 | .await |
| 2832 | .map(Json) |
| 2833 | } |
| 2834 | |
| 2835 | async fn handle_control_socket(state: AppState, udid: String, socket: WebSocket) { |
| 2836 | let session = match state.registry.get_or_create_async(&udid).await { |
nothing calls this directly
no test coverage detected