added ssh commands to bosminer

miners/bosminer.py

@@ -1,5 +1,6 @@
 from miners import BaseMiner
 from API.bosminer import BOSMinerAPI
+import asyncssh
 
 
 class BOSminer(BaseMiner):
@@ -9,3 +10,44 @@ class BOSminer(BaseMiner):
 
     def __repr__(self):
         return f"BOSminer: {str(self.ip)}"
+
+    async def get_ssh_connection(self, username: str, password: str) -> asyncssh.connect:
+        """Create a new asyncssh connection"""
+        conn = await asyncssh.connect(self.ip, known_hosts=None, username=username, password=password,
+                                      server_host_key_algs=['ssh-rsa'])
+        # return created connection
+        return conn
+
+    def send_ssh_command(self, cmd):
+        result = None
+        conn = await self.get_ssh_connection('root', 'admin')
+        for i in range(3):
+            try:
+                result = await conn.run(cmd)
+            except Exception as e:
+                print(f"{cmd} error: {e}")
+                if i == 3:
+                    return
+                continue
+        # let the user know the result of the command
+        if result is not None:
+            if result.stdout != "":
+                print(result.stdout)
+                if result.stderr != "":
+                    print("ERROR: " + result.stderr)
+            elif result.stderr != "":
+                print("ERROR: " + result.stderr)
+            else:
+                print(cmd)
+
+    async def fault_light_on(self):
+        await self.send_ssh_command('miner fault_light on')
+
+    async def fault_light_off(self):
+        await self.send_ssh_command('miner fault_light off')
+
+    async def bosminer_restart(self):
+        await self.send_ssh_command('/etc/init.d/bosminer restart')
+
+    async def reboot(self):
+        await self.send_ssh_command('/sbin/reboot')