ws

Author: MDA2AV

frameworks/actix-websocket/Cargo.toml

@@ -0,0 +1,9 @@
+[package]
+name = "actix-websocket"
+version = "0.1.0"
+edition = "2021"
+
+[dependencies]
+actix-web = "4"
+actix-ws = "0.3"
+tokio = { version = "1", features = ["macros", "rt-multi-thread"] }

frameworks/actix-websocket/Dockerfile

@@ -0,0 +1,15 @@
+FROM rust:1-bookworm AS build
+WORKDIR /app
+
+COPY Cargo.toml Cargo.lock* ./
+COPY src/ src/
+
+RUN cargo build --release
+
+FROM debian:bookworm-slim
+WORKDIR /app
+
+COPY --from=build /app/target/release/actix-websocket .
+
+EXPOSE 8080
+ENTRYPOINT ["./actix-websocket"]

frameworks/actix-websocket/meta.json

@@ -0,0 +1,10 @@
+{
+  "display_name": "actix-websocket",
+  "language": "Rust",
+  "type": "framework",
+  "engine": "Actix",
+  "description": "Actix-web WebSocket echo server",
+  "repo": "https://github.com/actix/actix-web",
+  "enabled": true,
+  "tests": ["echo-ws"]
+}

frameworks/actix-websocket/src/main.rs

@@ -0,0 +1,30 @@
+use actix_web::{web, App, HttpServer, HttpRequest, HttpResponse};
+use actix_ws;
+
+async fn ws_handler(req: HttpRequest, body: web::Payload) -> actix_web::Result<HttpResponse> {
+    let (response, mut session, mut msg_stream) = actix_ws::handle(&req, body)?;
+    actix_web::rt::spawn(async move {
+        while let Some(Ok(msg)) = msg_stream.recv().await {
+            match msg {
+                actix_ws::Message::Text(text) => { let _ = session.text(text).await; }
+                actix_ws::Message::Binary(bin) => { let _ = session.binary(bin).await; }
+                actix_ws::Message::Ping(bytes) => { let _ = session.pong(&bytes).await; }
+                actix_ws::Message::Close(_) => break,
+                _ => {}
+            }
+        }
+    });
+    Ok(response)
+}
+
+#[tokio::main]
+async fn main() -> std::io::Result<()> {
+    println!("Application started.");
+    HttpServer::new(|| {
+        App::new()
+            .route("/ws", web::get().to(ws_handler))
+    })
+    .bind("0.0.0.0:8080")?
+    .run()
+    .await
+}

frameworks/bun-websocket/Dockerfile

@@ -0,0 +1,6 @@
+FROM oven/bun:latest
+WORKDIR /app
+COPY server.ts entrypoint.sh ./
+RUN chmod +x entrypoint.sh
+EXPOSE 8080
+CMD ["./entrypoint.sh"]

frameworks/bun-websocket/entrypoint.sh

@@ -0,0 +1,6 @@
+#!/bin/sh
+CPUS=$(nproc)
+for i in $(seq 1 "$CPUS"); do
+  bun run /app/server.ts &
+done
+wait

frameworks/bun-websocket/meta.json

@@ -0,0 +1,12 @@
+{
+  "display_name": "bun-websocket",
+  "language": "TS",
+  "type": "framework",
+  "engine": "Bun",
+  "description": "Bun WebSocket echo server",
+  "repo": "https://github.com/oven-sh/bun",
+  "enabled": true,
+  "tests": [
+    "echo-ws"
+  ]
+}

frameworks/bun-websocket/server.ts

@@ -0,0 +1,18 @@
+Bun.serve({
+  port: 8080,
+  reusePort: true,
+  fetch(req, server) {
+    if (new URL(req.url).pathname === "/ws") {
+      if (server.upgrade(req)) return;
+      return new Response("Upgrade failed", { status: 400 });
+    }
+    return new Response("Not found", { status: 404 });
+  },
+  websocket: {
+    message(ws, message) {
+      ws.send(message);
+    },
+  },
+});
+
+console.log("Application started.");

frameworks/deno-websocket/Dockerfile

@@ -0,0 +1,6 @@
+FROM denoland/deno:2.2.2
+WORKDIR /app
+COPY server.ts .
+RUN deno cache server.ts
+EXPOSE 8080
+CMD ["deno", "serve", "--parallel", "--port", "8080", "--host", "0.0.0.0", "-A", "server.ts"]

frameworks/deno-websocket/meta.json

@@ -0,0 +1,12 @@
+{
+  "display_name": "deno-websocket",
+  "language": "TS",
+  "type": "framework",
+  "engine": "Deno",
+  "description": "Deno WebSocket echo server",
+  "repo": "https://github.com/denoland/deno",
+  "enabled": true,
+  "tests": [
+    "echo-ws"
+  ]
+}