fix(ssh): reconnect on failed transport writes

Author: stakach

shard.yml

@@ -1,5 +1,5 @@
 name: placeos-driver
-version: 7.17.3
+version: 7.17.4
 
 dependencies:
   action-controller:

src/placeos-driver/transport/ssh.cr

@@ -304,6 +304,10 @@ class PlaceOS::Driver
         socket << message
       end
       self
+    rescue error
+      # disconnect on failed sends - we need to reset state
+      spawn(same_thread: true) { disconnect }
+      raise error
     end
 
     def send(message, task : PlaceOS::Driver::Task, &block : (Bytes, PlaceOS::Driver::Task) -> Nil) : TransportSSH