SSH Runner: Fix several issues and refactor code

.github/workflows/linux-tests.yml

@@ -90,13 +90,13 @@ jobs:
           tests: test/${{ matrix.test-type }}
           duration: 20
 
-  linux_docker_tests:
+  linux_runner_tests:
     needs: build_container
     runs-on: ubuntu-latest
     strategy:
       matrix:
         python-version: [3.12, 3.9]
-    name: Docker Runner Tests (${{ matrix.python-version }})
+    name: Runner Tests (${{ matrix.python-version }})
     steps:
       - name: Set up Python ${{ matrix.python-version }}
         uses: actions/setup-python@v5
@@ -113,12 +113,26 @@ jobs:
           pip install -r conans/requirements_dev.txt
           pip install -r conans/requirements_server.txt
           pip install -r conans/requirements_runner.txt
+          sudo apt-get update && sudo apt-get install -y openssh-server
 
-      - name: Run tests
+      - name: Install OpenSSH Server
+        run: sudo apt-get update && sudo apt-get install -y openssh-server
+
+      - name: Configure SSH Daemon, Generate SSH Keys & Configure Access
+        run: |
+          sudo sed -i 's/#PermitRootLogin prohibit-password/PermitRootLogin yes/' /etc/ssh/sshd_config
+          sudo sed -i 's/#PasswordAuthentication yes/PasswordAuthentication no/' /etc/ssh/sshd_config
+          sudo systemctl restart ssh
+          mkdir -p ~/.ssh
+          ssh-keygen -t rsa -b 4096 -N "" -f ~/.ssh/id_rsa
+          cat ~/.ssh/id_rsa.pub >> ~/.ssh/authorized_keys
+          chmod 600 ~/.ssh/authorized_keys
+
+      - name: Run runner tests
         uses: ./.github/actions/test-coverage
         with:
           python-version: ${{ matrix.python-version }}
-          test-type: docker
-          tests: '-m docker_runner -rs'
+          test-type: runners
+          tests: '-m docker_runner -m ssh_runner -rs'
           duration: 20
           workers: 1

conan/api/output.py

@@ -186,7 +186,7 @@ def rewrite_line(self, line):
         self.stream.flush()
         self._color = tmp_color
 
-    def _write_message(self, msg, fg=None, bg=None):
+    def _write_message(self, msg, fg=None, bg=None, newline=True):
         if isinstance(msg, dict):
             # For traces we can receive a dict already, we try to transform then into more natural
             # text
@@ -206,8 +206,11 @@ def _write_message(self, msg, fg=None, bg=None):
         else:
             ret += "{}".format(msg)
 
+        if newline:
+            ret = "%s\n" % ret
+
         with self.lock:
-            self.stream.write("{}\n".format(ret))
+            self.stream.write(ret)
             self.stream.flush()
 
     def trace(self, msg):

conan/cli/commands/create.py

@@ -73,7 +73,7 @@ def create(conan_api, parser, *args):
             raise ConanException(f"Invalid runner configuration. 'type' must be defined")
         runner_instances_map = {
             'docker': DockerRunner,
-            # 'ssh': SSHRunner,
+            'ssh': SSHRunner,
             # 'wsl': WSLRunner,
         }
         try:

conan/internal/model/conf.py

@@ -133,6 +133,10 @@
     "tools.build:linker_scripts": "List of linker script files to pass to the linker used by different toolchains like CMakeToolchain, AutotoolsToolchain, and MesonToolchain",
     # Package ID composition
     "tools.info.package_id:confs": "List of existing configuration to be part of the package ID",
+    # Runners
+    "runner.type": "Type of runner to use. Possible values: docker, ssh",
+    "runner.host": "Hostname of the remote machine to connect to",
+    "runner.configfile": "(boolean/str) Enable the use of the SSH configuration file (False by default). If a string is provided, it will be used as the path to the SSH configuration file.",
 }
 
 BUILT_IN_CONFS = {key: value for key, value in sorted(BUILT_IN_CONFS.items())}

conan/internal/runner/output.py

@@ -0,0 +1,18 @@
+from conan.api.output import Color, ConanOutput
+
+class RunnerOutput(ConanOutput):
+    def __init__(self, runner_info: str):
+        super().__init__()
+        self.set_warnings_as_errors(True) # Make log errors blocker
+        self._prefix = f"{runner_info} | "
+
+    def _write_message(self, msg, fg=None, bg=None, newline=True):
+        for line in msg.splitlines():
+            super()._write_message(self._prefix, Color.BLACK, Color.BRIGHT_YELLOW, newline=False)
+            super()._write_message(line, fg, bg, newline)
+
+    @property
+    def padding(self):
+        return len(self._prefix) + 1
+
+