add unimplemented functions to handlers.rs
This commit is contained in:
parent
4fa190effa
commit
604f1dc026
|
@ -0,0 +1,29 @@
|
||||||
|
use super::request::*;
|
||||||
|
use crate::chat::types::SP;
|
||||||
|
use async_std::io::Result;
|
||||||
|
use rusqlite::Connection;
|
||||||
|
pub fn start_app(request: StartAppReq, server_sender: &SP) -> Result<()> {
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn stop_app(request: StopAppReq, conn: &Connection, server_sender: &SP) -> Result<()> {
|
||||||
|
unimplemented!()
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn load_users(request: LoadUsersReq, conn: &Connection, server_sender: &SP) -> Result<()> {
|
||||||
|
unimplemented!()
|
||||||
|
}
|
||||||
|
pub fn send_message(request: SendMessageReq, conn: &Connection, server_sender: &SP) -> Result<()> {
|
||||||
|
unimplemented!()
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn load_messages(
|
||||||
|
request: LoadMessagesReq,
|
||||||
|
conn: &Connection,
|
||||||
|
server_sender: &SP,
|
||||||
|
) -> Result<()> {
|
||||||
|
unimplemented!()
|
||||||
|
}
|
||||||
|
pub fn add_user(request: AddUserReq, conn: &Connection, server_sender: &SP) -> Result<()> {
|
||||||
|
unimplemented!()
|
||||||
|
}
|
|
@ -1,7 +1,7 @@
|
||||||
use crate::chat::types::SP;
|
use crate::chat::types::SP;
|
||||||
use rusqlite;
|
use rusqlite;
|
||||||
|
|
||||||
use super::request::*;
|
use super::{request::*, handlers};
|
||||||
use async_std::io::Result;
|
use async_std::io::Result;
|
||||||
use rusqlite::Connection;
|
use rusqlite::Connection;
|
||||||
use serde_json::from_str;
|
use serde_json::from_str;
|
||||||
|
@ -13,22 +13,22 @@ pub async fn request_selector(json: String, server_sender: &SP, conn: &Connectio
|
||||||
// }
|
// }
|
||||||
|
|
||||||
if let Ok(res) = from_str::<StartAppReq>(&json) {
|
if let Ok(res) = from_str::<StartAppReq>(&json) {
|
||||||
return Ok(());
|
handlers::start_app(res, server_sender)?
|
||||||
}
|
}
|
||||||
if let Ok(res) = from_str::<StopAppReq>(&json) {
|
if let Ok(res) = from_str::<StopAppReq>(&json) {
|
||||||
return Ok(());
|
handlers::stop_app(res, conn, server_sender)?
|
||||||
}
|
}
|
||||||
if let Ok(res) = from_str::<LoadUsersReq>(&json) {
|
if let Ok(res) = from_str::<LoadUsersReq>(&json) {
|
||||||
return Ok(());
|
handlers::load_users(res, conn, server_sender)?
|
||||||
}
|
}
|
||||||
if let Ok(res) = from_str::<SendMessageReq>(&json) {
|
if let Ok(res) = from_str::<SendMessageReq>(&json) {
|
||||||
return Ok(());
|
handlers::send_message(res, conn, server_sender)?
|
||||||
}
|
}
|
||||||
if let Ok(res) = from_str::<LoadMessagesReq>(&json) {
|
if let Ok(res) = from_str::<LoadMessagesReq>(&json) {
|
||||||
return Ok(());
|
handlers::load_messages(res, conn, server_sender)?
|
||||||
}
|
}
|
||||||
if let Ok(res) = from_str::<AddUserReq>(&json) {
|
if let Ok(res) = from_str::<AddUserReq>(&json) {
|
||||||
return Ok(());
|
handlers::add_user(res, conn, server_sender)?
|
||||||
}
|
}
|
||||||
Err(async_std::io::Error::new(
|
Err(async_std::io::Error::new(
|
||||||
async_std::io::ErrorKind::InvalidData,
|
async_std::io::ErrorKind::InvalidData,
|
||||||
|
|
Loading…
Reference in a new issue