Feat/faisal/addspi

pyproject.toml

@@ -11,6 +11,7 @@ pyzmq = "^22.0.3"
 attrs = "^21.2.0"
 loguru = "^0.5.3"
 pydoc-markdown = {version = "^3.10.3", optional = true}
+spidev = {version = "^3.5", markers = "sys_platform == 'linux'"}
 
 [tool.poetry.dev-dependencies]
 pytest = "^6.2.4"

requirements.txt

@@ -1,8 +1,9 @@
-attrs==20.3.0; (python_version >= "2.7" and python_full_version < "3.0.0") or (python_full_version >= "3.4.0")
+attrs==21.2.0; (python_version >= "2.7" and python_full_version < "3.0.0") or (python_full_version >= "3.5.0")
 cffi==1.14.5; implementation_name == "pypy" and python_version >= "3.6"
 colorama==0.4.4; python_version >= "3.5" and python_full_version < "3.0.0" and sys_platform == "win32" or sys_platform == "win32" and python_version >= "3.5" and python_full_version >= "3.5.0"
 loguru==0.5.3; python_version >= "3.5"
 py==1.10.0; python_version >= "3.6" and python_full_version < "3.0.0" and implementation_name == "pypy" or implementation_name == "pypy" and python_version >= "3.6" and python_full_version >= "3.4.0"
 pycparser==2.20; python_version >= "3.6" and python_full_version < "3.0.0" and implementation_name == "pypy" or implementation_name == "pypy" and python_version >= "3.6" and python_full_version >= "3.4.0"
 pyzmq==22.0.3; python_version >= "3.6"
+spidev==3.5; sys_platform == "linux"
 win32-setctime==1.0.3; sys_platform == "win32" and python_version >= "3.5"

systems/clients.py

@@ -1,4 +1,5 @@
 from abc import ABC, abstractmethod
+from platform import machine
 from random import randint
 from time import sleep
 
@@ -7,6 +8,9 @@
 
 from systems.controllers import Message
 
+if ("armv" in machine()):    # if machine is rpi, import spidev
+    import spidev
+
 
 class Client(ABC):
     core_frontend_address: str
@@ -76,19 +80,39 @@ def run(self):
             return
 
         while True:
-            dummy_message = Message(controller="MotorController",
-                                    data={
-                                        "speed": randint(50, 100),
-                                        "voltage": randint(20, 40),
-                                        "temperature": randint(50, 100)
-                                    },
-                                    destinations=[['browser', 'ui'],
-                                                  ['canbus']])
-            self.socket.send_json(dummy_message)
+            if ("armv" in machine()):    # checks if python is running in a rpi
+                speed = self.get_spi("s")
+                if (speed == -1):
+                    speed = randint(50, 100)
+                voltage = self.get_spi("v")
+                if (voltage == -1):
+                    voltage = randint(50, 100)
+            else:
+                speed = randint(50, 100)
+                voltage = randint(50, 100)
+            message = Message(controller="MotorController",
+                              data={
+                                  "speed": speed,
+                                  "voltage": voltage
+                              },
+                              destinations=[['browser', 'ui'], ['canbus']])
+            self.socket.send_json(message)
             incoming_message: Message = self.socket.recv_json()
             logger.debug(f"Can Bus received: {incoming_message}")
             sleep(1)
 
+    def get_spi(self, mode) -> int:
+        spi = spidev.SpiDev()
+        spi.open(0, 0)
+        spi.max_speed_hz = 1000000
+        recieved_byte = spi.xfer2([ord('s')])
+        sleep(0.5)
+        if ((recieved_byte[0] == 0) or (recieved_byte[0] == 255)):
+            spi.close()
+            return -1
+        spi.close()
+        return recieved_byte[0]
+
     def connect_to_server(self) -> bool:
         self.socket.connect(self.core_frontend_address)
         logger.info(f"{self.identity} started, "