CD
Cloudflare Developers•4mo ago
Defy

ok well,

ok well, i am very sorry, i am not smart enough for this. ( i barely even understand WASM, so now i am just extra confused. ) i don't really get whats going on or even where the entrypoint into the program is 😭
4 Replies
Defy
DefyOP•4mo ago
// src/lib.rs
use wasm_bindgen::prelude::*;
use web_sys::{window, Document, Element};
use worker::*;
use js_sys::JSON;
use serde_json::*;
use serde::Deserialize;


pub struct User{
    name: String,
}
pub struct Message{
    msg: String,
}

#[durable_object]
pub struct Chatroom {
    users: Vec<User>,
    messages: Vec<Message>,
    state: State,
    env: Env,
}

#[durable_object]
impl DurableObject for Chatroom {
    fn new(state: State, env: Env) -> Self {
        Self {
            users: vec![],
            messages: vec![],
            state: state,
            env,
        }
    }
     async fn fetch(&mut self, _req: Request) -> Result<Response> {
        // do some work when a worker makes a request to this DO
        Response::ok(&format!("{} active users.", self.users.len()))
    }
    
    async fn websocket_message(&mut self, ws: WebSocket, message: WebSocketIncomingMessage) -> Result<()> {
        match message {
          WebSocketIncomingMessage::Binary(_) => {
            ws.send_with_str("Durable Object received binary message")?;
          }
          WebSocketIncomingMessage::String(text) => {
            if let Ok(send_message) = serde_json::from_str::<SendMessage>(&text) {
              let result = self.handle(&send_message).await;

              let response = serde_json::to_string(&result).unwrap_or_else(|_| "{}".to_string());

              _ = ws.send_with_str(&response);
            } else {
              ws.send_with_str(&format!("Durable Object received text message: {text}"))?;
            }
          }
        }
        Ok(())
      }
      async fn websocket_close(&mut self, ws: web_sys::WebSocket, code: usize, reason: String, was_clean: bool) -> Result<()> {
        ws.close_with_code_and_reason(code as u16, &format!("Durable Object is closing WebSocket {reason:?} clean: {was_clean:?}"))?;
        Ok(())
      }
// src/lib.rs
use wasm_bindgen::prelude::*;
use web_sys::{window, Document, Element};
use worker::*;
use js_sys::JSON;
use serde_json::*;
use serde::Deserialize;


pub struct User{
    name: String,
}
pub struct Message{
    msg: String,
}

#[durable_object]
pub struct Chatroom {
    users: Vec<User>,
    messages: Vec<Message>,
    state: State,
    env: Env,
}

#[durable_object]
impl DurableObject for Chatroom {
    fn new(state: State, env: Env) -> Self {
        Self {
            users: vec![],
            messages: vec![],
            state: state,
            env,
        }
    }
     async fn fetch(&mut self, _req: Request) -> Result<Response> {
        // do some work when a worker makes a request to this DO
        Response::ok(&format!("{} active users.", self.users.len()))
    }
    
    async fn websocket_message(&mut self, ws: WebSocket, message: WebSocketIncomingMessage) -> Result<()> {
        match message {
          WebSocketIncomingMessage::Binary(_) => {
            ws.send_with_str("Durable Object received binary message")?;
          }
          WebSocketIncomingMessage::String(text) => {
            if let Ok(send_message) = serde_json::from_str::<SendMessage>(&text) {
              let result = self.handle(&send_message).await;

              let response = serde_json::to_string(&result).unwrap_or_else(|_| "{}".to_string());

              _ = ws.send_with_str(&response);
            } else {
              ws.send_with_str(&format!("Durable Object received text message: {text}"))?;
            }
          }
        }
        Ok(())
      }
      async fn websocket_close(&mut self, ws: web_sys::WebSocket, code: usize, reason: String, was_clean: bool) -> Result<()> {
        ws.close_with_code_and_reason(code as u16, &format!("Durable Object is closing WebSocket {reason:?} clean: {was_clean:?}"))?;
        Ok(())
      }
      async fn websocket_error(&mut self, ws: WebSocket, error: Error) -> Result<()> {
        ws.close_with_code_and_reason(1011, &format!("Durable Object encountered an error: {error:?}"))?;
        Ok(())
      }

}
      async fn websocket_error(&mut self, ws: WebSocket, error: Error) -> Result<()> {
        ws.close_with_code_and_reason(1011, &format!("Durable Object encountered an error: {error:?}"))?;
        Ok(())
      }

}
Unknown User
Unknown User•4mo ago
Message Not Public
Sign In & Join Server To View
Defy
DefyOP•4mo ago
i have... sucessfully been procrastinating -- btw, stuff like 
InitializeResult
ConversationActor
MemoryMessageStore
InitializeResult
ConversationActor
MemoryMessageStore
are custom structs? also, idk why but i am getting "unknown method for .server and .client did you extend WebSocketPair with those? 
    let mut ws_pair = WebSocketPair::new()?;
    let server = ws_pair.server()?;
    let client = ws_pair.client()?;
    let mut ws_pair = WebSocketPair::new()?;
    let server = ws_pair.server()?;
    let client = ws_pair.client()?;
Unknown User
Unknown User•4mo ago
Message Not Public
Sign In & Join Server To View

Did you find this page helpful?