From 75518c9fc45d35e8d3825b18d6d5e9e4b7c14a58 Mon Sep 17 00:00:00 2001
From: ThePerkinrex <theperkinrex@gmail.com>
Date: Wed, 11 Nov 2020 20:20:31 +0100
Subject: [PATCH] Make db connection macros not check fot the database on
 compile time

---
 server/src/db.rs     | 10 +++++-----
 server/src/main.rs   | 26 +++++++++++++-------------
 server/src/setup.sql | 14 +-------------
 3 files changed, 19 insertions(+), 31 deletions(-)

diff --git a/server/src/db.rs b/server/src/db.rs
index d0ee19a..3c073b8 100644
--- a/server/src/db.rs
+++ b/server/src/db.rs
@@ -1,4 +1,4 @@
-use sqlx::{pool::PoolConnection, prelude::*, query, query_as, query_file, SqliteConnection, SqlitePool};
+use sqlx::{pool::PoolConnection, prelude::*, query_unchecked, query_as, query_file_unchecked, SqliteConnection, SqlitePool};
 use tokio::stream::StreamExt;
 
 pub mod types;
@@ -14,7 +14,7 @@ impl DbPool {
 
         let mut conn = pool.acquire().await.unwrap();
 
-        query_file!("src/setup.sql")
+        query_file_unchecked!("src/setup.sql")
             .execute(&mut conn)
             .await
             .unwrap();
@@ -50,7 +50,7 @@ impl DbConnection {
         let uuid = Uuid::new_v4();
         // println!("{:?}", uuid.as_bytes().to_vec());
         self.conn
-            .execute(query!(
+            .execute(query_unchecked!(
                 "INSERT INTO Users(uuid, name) VALUES(?, ?)",
                 uuid.as_bytes().to_vec(),
                 name.to_string()
@@ -70,7 +70,7 @@ impl DbConnection {
     pub async fn create_lobby(&mut self) -> u32 {
         let id = rand::random();
         self.conn
-            .execute(query!(
+            .execute(query_unchecked!(
                 "INSERT INTO Lobbies(id) VALUES(?)",
                 id as i32
             ))
@@ -81,7 +81,7 @@ impl DbConnection {
 
     pub async fn join_lobby(&mut self, user: Uuid, lobby: u32) {
         self.conn
-            .execute(query!(
+            .execute(query_unchecked!(
                 "INSERT INTO UsersInLobbies(UserId, LobbyId) VALUES(?, ?)",
                 user.as_bytes().to_vec(),
                 lobby as i32
diff --git a/server/src/main.rs b/server/src/main.rs
index cbea5d1..2577844 100644
--- a/server/src/main.rs
+++ b/server/src/main.rs
@@ -7,25 +7,25 @@ mod logger;
 async fn main() {
     let (close, _stdin) = logger::setup().unwrap();
     // protobuf::route_guide_grpc::RouteGuid
-    for i in 0..100 {
-        std::thread::sleep(std::time::Duration::from_secs_f32(0.1));
+    // for i in 0..100 {
+    //     std::thread::sleep(std::time::Duration::from_secs_f32(0.1));
         
-        if i == 69 {
-            log::info!("69 Nͬ͂ͧi̽̅̽҉̫̕͢ĉ͆̚҉̢͞͏eͫ̑͑");
-            std::thread::sleep(std::time::Duration::from_secs_f32(0.2));
-        }else{
-            log::info!("{}", i);
-        }
-    }
+    //     if i == 69 {
+    //         log::info!("69 Nͬ͂ͧi̽̅̽҉̫̕͢ĉ͆̚҉̢͞͏eͫ̑͑");
+    //         std::thread::sleep(std::time::Duration::from_secs_f32(0.2));
+    //     }else{
+    //         log::info!("{}", i);
+    //     }
+    // }
     
     let games = games::load_games();
     log::info!("{:?}", games);
     games[0].run(4);
     let pool = db::DbPool::new().await;
-    let mut conn = pool.acquire().await;
-    println!("{}", conn.add_user("Hi").await);
-    println!("{:?}", conn.users().await);
-    conn.close().await;
+    // let mut conn = pool.acquire().await;
+    // println!("{}", conn.add_user("Hi").await);
+    // println!("{:?}", conn.users().await);
+    // conn.close().await;
     grpc::start(pool).await;
     
     close.close();
diff --git a/server/src/setup.sql b/server/src/setup.sql
index a486aab..8b959f7 100644
--- a/server/src/setup.sql
+++ b/server/src/setup.sql
@@ -1,5 +1,3 @@
--- Add migration script here
-
 DROP TABLE IF EXISTS `UsersInLobbies`;
 DROP TABLE IF EXISTS `Users`;
 DROP TABLE IF EXISTS `Lobbies`;
@@ -21,14 +19,4 @@ CREATE TABLE UsersInLobbies (
 	UserID CHAR(16) NOT NULL UNIQUE,
 	FOREIGN KEY (LobbyID) REFERENCES Lobbies(ID),
 	FOREIGN KEY (UserID) REFERENCES Users(UUID)
-);
-
--- INSERT INTO Users(UUID, Name) VALUES("0123456789abcdef", "Hi");
--- INSERT INTO Lobbies(ID) VALUES(0);
--- INSERT INTO Users(UUID, Name) VALUES("0123456789abcdff", "Hi2");
-
--- INSERT INTO UsersInLobbies(UserID,LobbyID) VALUES("0123456789abcdff", 0);
-
--- INSERT INTO Users(UUID, Name) VALUES("0123456789abcdfe", "Hi3");
-
--- INSERT INTO UsersInLobbies(UserID,LobbyID) VALUES("0123456789abcdfe", 1);
\ No newline at end of file
+);
\ No newline at end of file