core
/
locationoverflow
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix the websocket worker

This commit is contained in:
core 2023-07-20 16:29:48 -04:00
parent 006b7ff92a
commit 33cdb2545f
Signed by: core
GPG Key ID: FDBF740DADDCEECF
2 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
websocket-worker/config.toml
View File

@ -1,6 +1,6 @@
websockets = [ websockets = [
"https://discord.com/api/webhooks/1130340476797583380/0RBp48jK4x3qjKYcmypjw4ydm3GoK2r_D-yzz95b5cnBHtq8lsFx66kJnmniIVAe8H4u" "https://discord.com/api/webhooks/1130340476797583380/0RBp48jK4x3qjKYcmypjw4ydm3GoK2r_D-yzz95b5cnBHtq8lsFx66kJnmniIVAe8H4u"
] ]
api_status_url = "http://localhost:8171/status" api_status_url = "https://data-api.locationoverflow.coredoes.dev/status"
workers = 8 workers = 8
token = "test-ro-token" token = "ro-discord-a68a5519-8469-4a4b-93ee-5863cd0bf2b9"

5
websocket-worker/src/main.rs
View File

@ -6,7 +6,7 @@ use serenity::http::Http;
use serenity::model::webhook::Webhook; use serenity::model::webhook::Webhook;
use tokio_threadpool::ThreadPool; use tokio_threadpool::ThreadPool;
use url::Url; use url::Url;
use websocket::{ClientBuilder, Message, OwnedMessage}; use websocket::{ClientBuilder, Message, OwnedMessage, WebSocketError};
use websocket::websocket_base::result::WebSocketResult; use websocket::websocket_base::result::WebSocketResult;
use common::message::{GatewayChatMessage, GatewayPacketC2S, GatewayPacketS2C}; use common::message::{GatewayChatMessage, GatewayPacketC2S, GatewayPacketS2C};
use common::status::{DATA_API_VERSION, Status}; use common::status::{DATA_API_VERSION, Status};
@ -99,6 +99,9 @@ async fn main() -> Result<(), Box<dyn Error>> {
} }
} }
Err(e) => { Err(e) => {
if matches!(e, WebSocketError::NoDataAvailable) {
continue;
}
error!("rx error: {}", e); error!("rx error: {}", e);
return Err(e.into()); return Err(e.into());
} }