Add old logic back in

src/main.rs

···
+use std::process::Command;
+
 mod args;
 mod did;
 mod knot;
···
 
     match ws::connect(format!("ws://{}/events", knot_server), |_out| {
         println!("    Connection successful");
-        |msg| {
+        |msg: ws::Message| {
             println!("Got message: {}", msg);
+
+            // parse json
+            let body = match json::parse(match msg.as_text() {
+                Ok(val) => val,
+                Err(_) => return Ok(()),
+            }) {
+                Ok(val) => val,
+                Err(_) => {
+                    println!("    Invalid body. Skipping message");
+                    return Ok(());
+                }
+            };
+
+            // filter by did and reponame
+            if let Some(repo_did) = body["event"]["repoDid"].as_str()
+                && let Some(repo) = body["event"]["repoName"].as_str()
+                && repo_did != &did_doc.did
+                && repo != &config.repo_name
+            {
+                // repo doesnt match so skip
+                return Ok(());
+            }
+
+            println!("        Executing `/bin/sh -c {}`", &config.shell);
+
+            // exec shell command in /bin/sh
+            match Command::new("/bin/sh")
+                .arg("-c")
+                .arg(&config.shell)
+                .output()
+            {
+                Ok(val) => val,
+                Err(_) => return Ok(()),
+            };
+
             Ok(())
         }
     }) {
-        Ok(_) => {},
-        Err(err) => println!("    Connection failed: {}", err)
+        Ok(_) => {}
+        Err(err) => println!("    Connection failed: {}", err),
     };
 
     return Ok(());