question POST endpoint init

Cargo.toml

@@ -15,3 +15,4 @@ futures = "^0.1"
 env_logger = "^0.6"
 failure = "^0.1.5"
 reqwest = "^0.9.14"
+actix = { version = "^0.7" }

src/lib.rs

@@ -104,6 +104,7 @@ extern crate reqwest;
 extern crate serde_json;
 #[macro_use]
 extern crate diesel;
+extern crate actix;
 extern crate actix_web;
 extern crate dotenv;
 extern crate failure;
@@ -133,6 +134,7 @@ pub mod helpers;
 pub mod middleware;
 pub mod models;
 pub mod presentations;
+pub mod questions;
 pub mod schema;
 pub mod session;
 

src/questions.rs

@@ -0,0 +1,25 @@
+use actix::{Handler, Message};
+use diesel::query_dsl::RunQueryDsl;
+use diesel::MysqlConnection;
+use models::NewQuestion;
+use DbExecutor;
+
+impl Message for NewQuestion {
+    type Result = Result<(), super::error::Db>;
+}
+
+impl Handler<NewQuestion> for DbExecutor {
+    type Result = Result<(), super::error::Db>;
+
+    fn handle(&mut self, msg: NewQuestion, _ctx: &mut Self::Context) -> Self::Result {
+        use schema::questions::dsl::questions;
+        let connection: &MysqlConnection = &self.0.get().unwrap();
+
+        diesel::insert_into(questions)
+            .values(&msg)
+            .execute(connection)
+            .expect("Error saving the question");
+
+        Ok(())
+    }
+}