support sudo for mkdir plugin

Author: marcofortina

docs/plugins/generated.md

@@ -3823,6 +3823,11 @@ Create a directory with owner/group/mode parameters.
 | Parameter | Required | Type | Default | Description |
 |---|---:|---|---|---|
 | `path` | yes | `path` |  | Remote or local path, depending on the plugin. |
+| `mode` | no | `string` |  | POSIX file mode, for example 0644 or 0755. |
+| `owner` | no | `string` |  | Remote file owner. |
+| `group` | no | `string` |  | Primary group, file group owner or remote group name. |
+| `cwd` | no | `path` |  | Remote or local working directory for this operation. |
+| `sudo` | no | `boolean` | `False` | Run the remote operation through sudo -n when supported. |
 
 Result fields:
 

src/automax/plugins/fs_mkdir.py

@@ -20,6 +20,7 @@ class FsMkdirPlugin(BasePlugin):
     name = "fs.mkdir"
     description = "Create a directory with owner/group/mode parameters."
     required_params = ("path",)
+    optional_params = ("mode", "owner", "group", "cwd", "sudo")
     opens_remote_session = True
 
     def _command(self, params: Dict[str, Any], context: ExecutionContext) -> str:
@@ -36,12 +37,13 @@ def _command(self, params: Dict[str, Any], context: ExecutionContext) -> str:
         if group:
             checks.append(f'test "$(stat -c %G {path})" = {quote(group)}')
 
-        commands = [f"mkdir -p {path}"]
+        sudo = "sudo -n " if bool(params.get("sudo", False)) else ""
+        commands = [f"{sudo}mkdir -p {path}"]
         if mode:
-            commands.append(f"chmod {quote(mode)} {path}")
+            commands.append(f"{sudo}chmod {quote(mode)} {path}")
         if owner or group:
             owner_group = f"{owner or ''}:{group or ''}"
-            commands.append(f"chown {quote(owner_group)} {path}")
+            commands.append(f"{sudo}chown {quote(owner_group)} {path}")
 
         command = (
             " && ".join(checks)

tests/test_next_engine.py

@@ -322,6 +322,47 @@ def test_builtin_filesystem_plugins_are_registered():
         assert alias not in output_names
 
 
+
+
+def test_fs_mkdir_manual_commands_render_sudo_owner_group_and_mode():
+    from automax.plugins.fs_mkdir import FsMkdirPlugin
+
+    context = ExecutionContext(
+        run_id="test",
+        dry_run=True,
+        job={},
+        task={},
+        step={},
+        substep={},
+        target=Target(name="node", host="host"),
+        vars={},
+        outputs={},
+        secrets={},
+    )
+
+    commands = FsMkdirPlugin().manual_commands(
+        {
+            "path": "/u01/app/grid",
+            "owner": "grid",
+            "group": "oinstall",
+            "mode": "0775",
+            "sudo": True,
+        },
+        context,
+    )
+
+    assert commands == [
+        'test -d /u01/app/grid && '
+        'test "$(stat -c %a /u01/app/grid)" = 0775 && '
+        'test "$(stat -c %U /u01/app/grid)" = grid && '
+        'test "$(stat -c %G /u01/app/grid)" = oinstall || '
+        '{ sudo -n mkdir -p /u01/app/grid && '
+        'sudo -n chmod 0775 /u01/app/grid && '
+        'sudo -n chown grid:oinstall /u01/app/grid; '
+        'echo __AUTOMAX_CHANGED__; }'
+    ]
+
+
 def test_ssh_smoke_script_is_syntax_valid():
     script = Path("scripts/ssh-smoke.sh")
     assert script.exists()