Added a user import from csv.

Doesn't check for redundancy. Only meant for an initial startup

Author: kluzynick

backend/Cargo.lock

@@ -12,3 +12,8 @@ serde = { version = "1.0", features = ["derive"]}
 serde_json = "1.0"
 log = "0.4"
 simplelog = "0.5"
+csv = "1.0.5"
+
+[[bin]]
+name = "csv_user_import"
+path = "src/bin/csv_user_import.rs"

backend/Cargo.toml

@@ -0,0 +1,96 @@
+use log::debug;
+use log::error;
+use log::info;
+use log::trace;
+use log::warn;
+use diesel::prelude::*;
+use diesel::MysqlConnection;
+use dotenv::dotenv;
+use csv;
+use web_dev::users::models::{NewUser,UserRequest};
+use web_dev::users::requests;
+use serde::Deserialize;
+use serde::Serialize;
+
+#[derive(Serialize, Deserialize, Debug)]
+struct Csv_User {
+	#[serde(rename = "Banner ID")]
+	banner_id: i32,
+	#[serde(rename = "Last Name")]
+	last_name: String,
+	#[serde(rename = "First Name")]
+	first_name: String,
+	#[serde(rename = "Email")]
+	email: String,
+	#[serde(rename = "Year")]
+	year: String,
+	#[serde(rename = "Department")]
+	department: String,
+}
+
+fn main(){
+	dotenv().ok();
+
+    simplelog::TermLogger::init(simplelog::LevelFilter::Trace, simplelog::Config::default())
+        .unwrap();
+
+    info!("Connecting to database");
+
+    let database_url = match env::var("DATABASE_URL") {
+        Ok(url) => url,
+        Err(e) => {
+            error!("Could not read DATABASE_URL environment variable");
+            return;
+        }
+    };
+
+    debug!("Connecting to {}", database_url);
+
+    let connection = match MysqlConnection::establish(&database_url) {
+        Ok(c) => c,
+        Err(e) => {
+            error!("Could not connect to database: {}", e);
+            return;
+        }
+    };
+
+    debug!("Connected to database");
+
+	use std::env;
+	let arg = env::args().nth(1);
+	let filename = 	match arg {
+		Some(name) => name,
+		None => {
+			println!("Needs a filename");
+			return;
+		}
+	};
+	println!("{}", filename);
+	
+	let all_users_result = csv::Reader::from_path(filename);
+	let mut all_users = match all_users_result{
+		Ok(data) => data,
+		Err(e) => {
+				println!("Bad file. Error {}",e);
+				return;
+			}
+	};		
+	for result in all_users.deserialize(){
+		let csv_user: Csv_User = match result{
+			Ok(data) => data,
+			Err(e) => {
+				println!("Bad data, {:?}", e);
+				return;
+			}
+		};
+		let new_user:NewUser = NewUser{
+			first_name: csv_user.first_name,
+			last_name: csv_user.last_name,
+			email:  Some(csv_user.email),
+			banner_id: csv_user.banner_id as u32,
+		};
+		
+		requests::create_user(new_user, &connection);
+	}
+}
+

backend/src/bin/csv_user_import.rs

@@ -0,0 +1,6 @@
+#[macro_use]
+extern crate diesel;
+
+
+pub mod errors;
+pub mod users;

backend/src/lib.rs

@@ -1,6 +1,3 @@
-#[macro_use]
-extern crate diesel;
-
 use std::env;
 use std::sync::Mutex;
 
@@ -18,8 +15,6 @@ use dotenv::dotenv;
 use self::errors::WebdevError;
 use self::errors::WebdevErrorKind;
 
-mod errors;
-mod users;
 
 use self::users::models::UserRequest;
 use self::users::requests::handle_user;

backend/src/main.rs

@@ -23,7 +23,7 @@ pub struct User {
     pub email: Option<String>,
 }
 
-#[derive(Insertable, Serialize, Deserialize)]
+#[derive(Insertable, Serialize, Deserialize, Debug)]
 #[table_name = "users"]
 pub struct NewUser {
     pub first_name: String,

backend/src/users/models.rs

@@ -81,7 +81,7 @@ fn get_user(id: u64, database_connection: &MysqlConnection) -> Result<User, Webd
     }
 }
 
-fn create_user(user: NewUser, database_connection: &MysqlConnection) -> Result<User, WebdevError> {
+pub fn create_user(user: NewUser, database_connection: &MysqlConnection) -> Result<User, WebdevError> {
     diesel::insert_into(users_schema::table)
         .values(user)
         .execute(database_connection)?;