summaryrefslogtreecommitdiff
path: root/game_server/src/backend_connection.rs
diff options
context:
space:
mode:
Diffstat (limited to 'game_server/src/backend_connection.rs')
-rw-r--r--game_server/src/backend_connection.rs90
1 files changed, 0 insertions, 90 deletions
diff --git a/game_server/src/backend_connection.rs b/game_server/src/backend_connection.rs
deleted file mode 100644
index a751b30..0000000
--- a/game_server/src/backend_connection.rs
+++ /dev/null
@@ -1,90 +0,0 @@
-use reqwest::{Response, Client, Url, UrlError, Error as ReqError};
-use std::sync::mpsc::{Sender, Receiver};
-use std::sync::mpsc;
-use crate::server::{UserId, Token};
-use crate::group::GroupId;
-
-pub struct BackendConnection {
- host: String,
- req_sender: Sender<RequestData>,
- res_rec: Receiver<ResponseResult>,
- max_uid: u32,
-}
-
-#[derive(Debug)]
-pub enum BackendError {
- UrlError(UrlError),
- RequestError(ReqError),
- InvalidTokenFormat,
- InvalidToken,
- BadResponse(Response),
-}
-
-pub type TokenValidity = Result<TokenResponse, BackendError>;
-pub type RequestData = Url;
-pub type ResponseResult = Result<Response, ReqError>;
-
-pub struct TokenResponse {
- pub group_id: GroupId,
- pub group_type: String,
- pub group_name: String,
- pub user_id: UserId,
-}
-
-impl BackendConnection {
- fn run_background(req_rec: Receiver<RequestData>, res_sender: Sender<ResponseResult>) {
- let client = Client::new();
- loop {
- let request_data = req_rec.recv().unwrap();
- let location = request_data;
- let request = client.get(location);
- let response = request.send();
- res_sender.send(response).unwrap();
- }
- }
-
- pub fn new(host: &str) -> Self {
- let (req_sender, req_rec): (Sender<RequestData>, Receiver<RequestData>)
- = mpsc::channel();
- let (res_sender, res_rec): (Sender<ResponseResult>, Receiver<ResponseResult>)
- = mpsc::channel();
- std::thread::spawn(move || Self::run_background(req_rec, res_sender));
- BackendConnection {
- host: host.to_string(),
- req_sender,
- res_rec,
- max_uid: 420,
- }
- }
-
- pub fn request(&self, location: &str) -> Result<(), UrlError> {
- Ok(self.req_sender.send(Url::parse(&format!("{}{}", self.host, location))?).unwrap())
- }
-
- pub fn get_response(&self) -> ResponseResult {
- self.res_rec.recv().unwrap()
- }
-
- pub fn validate_token(&mut self, token: &Token) -> TokenValidity {
- let location = format!("/api/lobby/tokens/{}", token);
- self.request(&location).map_err(|err| BackendError::UrlError(err))?;
- let response = self.get_response().map_err(|err| BackendError::RequestError(err))?;
- if response.status().is_success() {
- // zu Testzwecken werden noch keine JSON-Daten deserialisiert
- // Dennis Server gibt ja noch nix zurück
- self.max_uid += 1;
- Ok(TokenResponse {
- group_id: 12,
- group_type: "scribble".to_string(),
- group_name: "Scribble".to_string(),
- user_id: self.max_uid - 1,
- })
- } else if response.status() == reqwest::StatusCode::NOT_FOUND {
- Err(BackendError::InvalidToken)
- } else if response.status().is_client_error() {
- Err(BackendError::InvalidTokenFormat)
- } else {
- Err(BackendError::BadResponse(response))
- }
- }
-}