Initial commit
This commit is contained in:
commit
c08f0874bd
|
@ -0,0 +1,3 @@
|
|||
/target
|
||||
Cargo.lock
|
||||
.env
|
|
@ -0,0 +1,14 @@
|
|||
[package]
|
||||
name = "corpos-backend"
|
||||
version = "0.1.0"
|
||||
edition = "2021"
|
||||
|
||||
# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
|
||||
|
||||
[dependencies]
|
||||
dotenv = "0.15.0"
|
||||
serde = { version = "1.0", features = ["derive"] }
|
||||
tokio = { version = "1", features = ["full"] }
|
||||
sqlx = { version = "0.5", features = [ "runtime-tokio-rustls", "mysql" ] }
|
||||
actix-web = "4"
|
||||
chrono = "0.4"
|
|
@ -0,0 +1,2 @@
|
|||
pub mod main_dao;
|
||||
pub mod user_dao;
|
|
@ -0,0 +1,6 @@
|
|||
use crate::r#do::user::User;
|
||||
|
||||
|
||||
pub async fn insert_user(user: User) -> Result<(), sqlx::Error>{
|
||||
Ok(())
|
||||
}
|
|
@ -0,0 +1 @@
|
|||
pub mod user;
|
|
@ -0,0 +1,7 @@
|
|||
use serde::Serialize;
|
||||
|
||||
#[derive(Serialize)]
|
||||
pub struct User{
|
||||
pub id: u16,
|
||||
pub name: String
|
||||
}
|
|
@ -0,0 +1,17 @@
|
|||
mod r#do; mod dao;
|
||||
mod routes; mod service;
|
||||
mod util;
|
||||
use util::env_util;
|
||||
use routes::main_router::{start_all_routes, after_startup_fn};
|
||||
|
||||
#[tokio::main]
|
||||
async fn main() -> Result<(), std::io::Error> {
|
||||
// Retrieve env variables and send to services that need them.
|
||||
let env_vars = env_util::get_dot_env_map();
|
||||
|
||||
// Start database
|
||||
|
||||
|
||||
// Start server
|
||||
start_all_routes(&after_startup_fn, env_vars).await
|
||||
}
|
|
@ -0,0 +1,41 @@
|
|||
use std::collections::HashMap;
|
||||
use actix_web::{HttpServer, App};
|
||||
use super::user_routes;
|
||||
|
||||
// This function is to be used in case code is meant to be run after server startup
|
||||
pub fn after_startup_fn(){
|
||||
println!("{}", "Started server.");
|
||||
}
|
||||
|
||||
pub async fn start_all_routes(after_startup_fn_call: &dyn Fn(), env_vars: HashMap<String, String>)
|
||||
-> Result<(), std::io::Error>
|
||||
{
|
||||
// Get env variables to build server address
|
||||
let host_addr: &str = match env_vars.get("HOST_ADDRESS") {
|
||||
Some(str) => {str},
|
||||
None => {panic!("HOST_ADDRESS env variable not found.");},
|
||||
};
|
||||
let host_port: u16 = match env_vars.get("HOST_PORT") {
|
||||
Some(str) => {
|
||||
match str.parse::<u16>() {
|
||||
Ok(resolved_port) => {resolved_port},
|
||||
Err(e) => {panic!("{:?}", e);}
|
||||
}
|
||||
},
|
||||
None => {panic!("HOST_PORT env variable not found.");},
|
||||
};
|
||||
|
||||
// Start server
|
||||
let server_future = HttpServer::new( || {
|
||||
App::new()
|
||||
// Define routes
|
||||
.service(user_routes::get_user_from_db)
|
||||
})
|
||||
.bind((host_addr, host_port))?
|
||||
.run();
|
||||
|
||||
let (server_start_result, _after_startup_value) =
|
||||
tokio::join!(server_future, async {after_startup_fn_call();});
|
||||
|
||||
return server_start_result; // Return server
|
||||
}
|
|
@ -0,0 +1,3 @@
|
|||
|
||||
pub mod main_router;
|
||||
pub mod user_routes;
|
|
@ -0,0 +1,8 @@
|
|||
use actix_web::{get, web, Responder, HttpResponse, body::MessageBody};
|
||||
|
||||
use crate::r#do::user::User;
|
||||
|
||||
#[get("/user/{id}")]
|
||||
pub async fn get_user_from_db(id: web::Path<u16>) -> HttpResponse {
|
||||
HttpResponse::Ok().json(web::Json(User {id: *id, name: "nigga".to_string()}))
|
||||
}
|
|
@ -0,0 +1,14 @@
|
|||
extern crate dotenv;
|
||||
|
||||
use dotenv::dotenv;
|
||||
use std::{env, collections::HashMap};
|
||||
|
||||
pub fn get_dot_env_map() -> HashMap<String, String>{
|
||||
dotenv().ok();
|
||||
let mut dotenv_vars: HashMap<String, String> = HashMap::new();
|
||||
for (key, val) in env::vars() {
|
||||
// Use pattern bindings instead of testing .is_some() followed by .unwrap()
|
||||
dotenv_vars.insert(key, val);
|
||||
}
|
||||
dotenv_vars
|
||||
}
|
|
@ -0,0 +1 @@
|
|||
pub mod env_util;
|
Loading…
Reference in New Issue