caisin/sea-orm
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Just clone the state for each thread

Browse Source
This commit is contained in:
Sam Samai 2021-09-21 18:21:55 +10:00
parent 8a618f88c7
commit ac8d84ea44
1 changed files with 9 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
examples/actix_example/src/main.rs
View File

@ -1,6 +1,3 @@
// use actix_web::{get, post, web, App, HttpResponse, HttpServer, Responder};
use std::sync::Arc;
use actix_files as fs; use actix_files as fs;
use actix_web::{ use actix_web::{
error, get, middleware, post, web, App, Error, HttpRequest, HttpResponse, error, get, middleware, post, web, App, Error, HttpRequest, HttpResponse,
@ -22,10 +19,8 @@ const DEFAULT_POSTS_PER_PAGE: usize = 25;
#[derive(Debug, Clone)] #[derive(Debug, Clone)]
struct AppState { struct AppState {
templates: tera::Tera, templates: tera::Tera,
conn: Arc<DatabaseConnection>, conn: DatabaseConnection,
} }
type SharedState = Arc<AppState>;
#[derive(Debug, Deserialize)] #[derive(Debug, Deserialize)]
pub struct Params { pub struct Params {
page: Option<usize>, page: Option<usize>,
@ -41,7 +36,7 @@ struct FlashData {
#[get("/")] #[get("/")]
async fn list( async fn list(
req: HttpRequest, req: HttpRequest,
data: web::Data<SharedState>, data: web::Data<AppState>,
opt_flash: Option<actix_flash::Message<FlashData>>, opt_flash: Option<actix_flash::Message<FlashData>>,
) -> Result<HttpResponse, Error> { ) -> Result<HttpResponse, Error> {
let template = &data.templates; let template = &data.templates;
@ -77,7 +72,7 @@ async fn list(
} }
#[get("/new")] #[get("/new")]
async fn new(data: web::Data<SharedState>) -> Result<HttpResponse, Error> { async fn new(data: web::Data<AppState>) -> Result<HttpResponse, Error> {
let template = &data.templates; let template = &data.templates;
let ctx = tera::Context::new(); let ctx = tera::Context::new();
let body = template let body = template
@ -88,7 +83,7 @@ async fn new(data: web::Data<SharedState>) -> Result<HttpResponse, Error> {
#[post("/")] #[post("/")]
async fn create( async fn create(
data: web::Data<SharedState>, data: web::Data<AppState>,
post_form: web::Form<post::Model>, post_form: web::Form<post::Model>,
) -> actix_flash::Response<HttpResponse, FlashData> { ) -> actix_flash::Response<HttpResponse, FlashData> {
let conn = &data.conn; let conn = &data.conn;
@ -113,7 +108,7 @@ async fn create(
} }
#[get("/{id}")] #[get("/{id}")]
async fn edit(data: web::Data<SharedState>, id: web::Path<i32>) -> Result<HttpResponse, Error> { async fn edit(data: web::Data<AppState>, id: web::Path<i32>) -> Result<HttpResponse, Error> {
let conn = &data.conn; let conn = &data.conn;
let template = &data.templates; let template = &data.templates;
@ -134,7 +129,7 @@ async fn edit(data: web::Data<SharedState>, id: web::Path<i32>) -> Result<HttpRe
#[post("/{id}")] #[post("/{id}")]
async fn update( async fn update(
data: web::Data<SharedState>, data: web::Data<AppState>,
id: web::Path<i32>, id: web::Path<i32>,
post_form: web::Form<post::Model>, post_form: web::Form<post::Model>,
) -> actix_flash::Response<HttpResponse, FlashData> { ) -> actix_flash::Response<HttpResponse, FlashData> {
@ -160,7 +155,7 @@ async fn update(
#[post("/delete/{id}")] #[post("/delete/{id}")]
async fn delete( async fn delete(
data: web::Data<SharedState>, data: web::Data<AppState>,
id: web::Path<i32>, id: web::Path<i32>,
) -> actix_flash::Response<HttpResponse, FlashData> { ) -> actix_flash::Response<HttpResponse, FlashData> {
let conn = &data.conn; let conn = &data.conn;
@ -200,13 +195,13 @@ async fn main() -> std::io::Result<()> {
let templates = Tera::new(concat!(env!("CARGO_MANIFEST_DIR"), "/templates/**/*")).unwrap(); let templates = Tera::new(concat!(env!("CARGO_MANIFEST_DIR"), "/templates/**/*")).unwrap();
let state = AppState { let state = AppState {
templates: templates, templates: templates,
conn: Arc::new(conn), conn: conn,
}; };
let mut listenfd = ListenFd::from_env(); let mut listenfd = ListenFd::from_env();
let mut server = HttpServer::new(move || { let mut server = HttpServer::new(move || {
App::new() App::new()
.data(Arc::new(state.clone())) .data(state.clone())
.wrap(middleware::Logger::default()) // enable logger .wrap(middleware::Logger::default()) // enable logger
.wrap(actix_flash::Flash::default()) .wrap(actix_flash::Flash::default())
.configure(init) .configure(init)