@@ -16,6 +16,14 @@ use system_state_controller::SystemState;
 
 use crate::system_state_controller::Destination;
 
+use std::thread::*;

@@ -19,0 +22,4 @@
+use crossbeam_channel as cbc;
+
+use driver_rust::elevio;
+use driver_rust::elevio::elev as e;

@@ -75,4 +83,76 @@ async fn main() {
     let _ = rd_handl.await;
 
     println!("Hello, world!");
+    let elev_num_floors = 4;

@@ -78,0 +119,4 @@
+        elevator.motor_direction(dirn);
+    }
+
+    loop {

@@ -121,6 +121,33 @@ impl ElevatorInfo {
         }
     }
 
+    /// Takes in a boolean for if the elevator is obstructed or not.

@@ -123,1 +123,4 @@
 
+    /// Takes in a boolean for if the elevator is obstructed or not.
+    pub fn set_obstruction(&mut self, obstruction_kind: Option<ObstructionKind>) -> () {
+        // Checks if the obstruction is true, if so it will set the obstruction kind as door

@@ -124,0 +137,4 @@
+                        }
+                    }
+                    None => {
+                        // NOTE: a contition that never should happen, therefore not doing

@@ -0,0 +1,24 @@
+use crate::SystemState;
+use crossbeam_channel::{self as cbc, Receiver};
+use driver_rust::elevio::poll::obstruction;
+use std::sync::*;

@@ -0,0 +5,4 @@
+
+use super::ObstructionKind;
+
+async fn obstruction_handler(state: Arc<RwLock<SystemState>>, obstruction_rx: Receiver<bool>) -> ! {

@@ -0,0 +7,4 @@
+
+async fn obstruction_handler(state: Arc<RwLock<SystemState>>, obstruction_rx: Receiver<bool>) -> ! {
+    loop {
+        let obstruct = obstruction_rx.recv().unwrap();

@@ -0,0 +9,4 @@
+    loop {
+        let obstruct = obstruction_rx.recv().unwrap();
+        let mut state = state.write().unwrap();
+        if obstruct {

@@ -124,0 +127,4 @@
+        // then else it will check if the current state is obstructed. if so it wil sett the
+        // elevator to idle.
+        // else it will not change the current state
+        match obstruction_kind {

@@ -18,0 +17,4 @@
+use system_state_controller::obstruction_handler;
+
+use std::thread::spawn;
+use std::time::*;