From 6a99129fe770dd271e3e353f2ff2bdbe4c82d903 Mon Sep 17 00:00:00 2001 From: kozabrada123 <“kozabrada123@users.noreply.github.com”> Date: Fri, 5 May 2023 19:42:31 +0200 Subject: [PATCH] Add temp debug, remove unused token --- src/gateway.rs | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/gateway.rs b/src/gateway.rs index 6241e2a..df9f230 100644 --- a/src/gateway.rs +++ b/src/gateway.rs @@ -35,7 +35,6 @@ implemented [Types] with the trait [`WebSocketEvent`] */ pub struct Gateway<'a> { pub url: String, - pub token: String, pub events: Events<'a>, websocket: WebSocketConnection, heartbeat_handler: Option @@ -44,11 +43,9 @@ pub struct Gateway<'a> { impl<'a> Gateway<'a> { pub async fn new( websocket_url: String, - token: String, ) -> Result, tokio_tungstenite::tungstenite::Error> { return Ok(Gateway { url: websocket_url.clone(), - token, events: Events::default(), websocket: WebSocketConnection::new(websocket_url).await, heartbeat_handler: None, @@ -58,6 +55,7 @@ impl<'a> Gateway<'a> { /// This function reads all messages from the gateway's websocket and updates its events along with the events' observers pub async fn update_events(&mut self) { while let Some(msg) = self.websocket.rx.lock().await.recv().await { + println!("Debug GW: Received WSE: {}", msg.to_string()); let gateway_payload: GatewayPayload = serde_json::from_str(msg.to_text().unwrap()).unwrap(); // See https://discord.com/developers/docs/topics/opcodes-and-status-codes#gateway-gateway-opcodes @@ -202,6 +200,8 @@ impl<'a> Gateway<'a> { let payload_json = serde_json::to_string(&gateway_payload).unwrap(); + println!("Debug GW: Sending WSE: {}", payload_json.clone()); + let message = tokio_tungstenite::tungstenite::Message::text(payload_json); self.websocket.tx.lock().await.send(message).await.unwrap(); @@ -513,7 +513,7 @@ mod example { #[tokio::test] async fn test_gateway() { - let gateway = Gateway::new("ws://localhost:3001/".to_string(), "none".to_string()) + let gateway = Gateway::new("ws://localhost:3001/".to_string()) .await .unwrap(); }