Remove m2m connections

Author: AnthonyRonning

src/cloudflare.rs

@@ -107,41 +107,6 @@ async fn handle_server_stream(
     empty_response()
 }
 
-// TODO
-pub(crate) fn handle_mutiny_to_mutiny(
-    _req: Request,
-    _ctx: RouteContext<()>,
-) -> worker::Result<Response> {
-    // For websocket compatibility
-    let pair = WebSocketPair::new()?;
-    let server = pair.server;
-    server.accept()?;
-    logger::debug("accepted websocket, about to spawn event stream");
-    wasm_bindgen_futures::spawn_local(async move {
-        let mut event_stream = server.events().expect("stream error");
-        logger::debug("spawned event stream, waiting for first message..");
-        while let Some(event) = event_stream.next().await {
-            if let Err(e) = event {
-                logger::error(&format!("error parsing some event: {e}"));
-                continue;
-            }
-            match event.expect("received error in websocket") {
-                WebsocketEvent::Message(msg) => {
-                    if msg.text().is_none() {
-                        continue;
-                    };
-                    // TODO parse msg when we support m2m here
-                }
-                WebsocketEvent::Close(_) => {
-                    logger::debug("closing");
-                    break;
-                }
-            }
-        }
-    });
-    Response::from_websocket(pair.client)
-}
-
 pub(crate) fn empty_response() -> worker::Result<Response> {
     Response::empty()?.with_cors(&cors())
 }

src/lib.rs

@@ -30,8 +30,6 @@ async fn main() {
 
     let app = Router::new()
         .route("/v1/:ip/:port", get(crate::server::ws_handler))
-        // TODO m2m
-        //.route("/v1/mutiny/:identifier", get(mutiny_ws_handler))
         .layer(
             TraceLayer::new_for_http()
                 .make_span_with(DefaultMakeSpan::default().include_headers(true)),
@@ -69,7 +67,6 @@ pub async fn main(req: Request, env: Env, _ctx: Context) -> worker::Result<worke
     // Environment bindings like KV Stores, Durable Objects, Secrets, and Variables.
     router
         // TODO this is for mutiny to mutiny, which is being ignored for now
-        .get("/v1/mutiny/:id", crate::cloudflare::handle_mutiny_to_mutiny)
         .get("/v1/:ip/:port", crate::cloudflare::handle_ws_to_tcp)
         .options("/*catchall", |_, _| crate::cloudflare::empty_response())
         .run(req, env)