better recovery of the SSH example (#704)

* better recovery of the SSH example
* move stuff to `start` altogether

examples/ssh/ssh.py

@@ -1,5 +1,6 @@
 #!/usr/bin/env python3
 import asyncio
+from datetime import timedelta
 import pathlib
 import random
 import sys
@@ -43,19 +44,24 @@ async def get_payload():
             capabilities=[vm.VM_CAPS_VPN],
         )
 
-    async def run(self):
-        connection_uri = self.network_node.get_websocket_uri(22)
-        app_key = self.cluster._engine._api_config.app_key
+    async def start(self):
+        # perform the initialization of the Service
+        # (which includes sending the network details within the `deploy` command)
+        async for script in super().start():
+            yield script
 
         password = "".join(random.choice(string.ascii_letters + string.digits) for _ in range(8))
 
-        script = self._ctx.new_script()
+        script = self._ctx.new_script(timeout=timedelta(seconds=10))
         script.run("/bin/bash", "-c", "syslogd")
         script.run("/bin/bash", "-c", "ssh-keygen -A")
         script.run("/bin/bash", "-c", f'echo -e "{password}\n{password}" | passwd')
         script.run("/bin/bash", "-c", "/usr/sbin/sshd")
         yield script
 
+        connection_uri = self.network_node.get_websocket_uri(22)
+        app_key = self.cluster._engine._api_config.app_key
+
         print(
             "Connect with:\n"
             f"{TEXT_COLOR_CYAN}"
@@ -65,9 +71,6 @@ async def run(self):
 
         print(f"{TEXT_COLOR_RED}password: {password}{TEXT_COLOR_DEFAULT}")
 
-        # await indefinitely...
-        await asyncio.Future()
-
 
 async def main(subnet_tag, payment_driver=None, payment_network=None):
     # By passing `event_consumer=log_summary()` we enable summary logging.