Merge pull request #122 from mateusfreira/fix-parsing-db-cration

Minor fix db creation

Author: mateusfreira

src/lib/bo.rs

@@ -245,7 +245,7 @@ impl From<i32> for ConsensuStrategy {
 
 impl From<String> for ConsensuStrategy {
     fn from(val: String) -> Self {
-        log::debug!("Val in ConsensuStrategy {}", val);
+        log::debug!("Val in ConsensuStrategy {}.", val);
         use self::ConsensuStrategy::*;
         match val.as_str() {
             "arbiter" => Arbiter,

src/lib/db_ops.rs

@@ -17,6 +17,11 @@ pub fn create_db(
     strategy: ConsensuStrategy,
 ) -> Response {
     if dbs.is_primary() || client.is_primary() {
+        log::debug!(
+            "Request::CreateDb - Creating database {} with strategy {:?}",
+            name,
+            strategy
+        );
         // If this node is the primary or the primary is asking to create it
         let empty_db_box = create_temp_db(name.clone(), strategy, dbs);
         let empty_db = Arc::try_unwrap(empty_db_box);

src/lib/parse_request.rs

@@ -58,7 +58,7 @@ impl Request {
         PARSER_HASH_TABLE.keys().map(|x| x.to_string()).collect()
     }
     pub fn parse(input: &str) -> Result<Request, String> {
-        let mut command = input.splitn(3, " ");
+        let mut command = input.trim_end_matches(';').splitn(3, " ");
         match command.next() {
             Some("") | None => {
                 log::debug!("empty command");
@@ -661,7 +661,10 @@ fn parse_create_db_command(command: &mut std::str::SplitN<&str>) -> Result<Reque
         }
     };
     let mut rest = match command.next() {
-        Some(rest) => rest.splitn(2, " "),
+        Some(rest) => {
+            log::debug!("CreateDb rest command {}", rest);
+            rest.splitn(2, " ")
+        },
         None => {
             log::debug!("create-db needs token and strategy");
             return Err(String::from("create-db must be followed by a token"));

src/lib/replication_ops.rs

@@ -285,7 +285,7 @@ pub fn replicate_request(
                 token,
                 strategy,
             } => {
-                log::debug!("Will replicate command a created database name {}", name);
+                log::debug!("Will replicate command a created database name {}, {}", name, strategy.to_string());
                 replicate_web(
                     replication_sender,
                     format!("create-db {} {} {}", name, token, strategy.to_string()),