nexus/modules/pi_control/bootstrap.php

<?php
use App\ModuleConfigException;

$moduleName = 'pi_control';
$mm = isset($modules) && $modules instanceof App\ModuleManager ? $modules : modules();

$mm->registerFunction($moduleName, 'table', function (string $name): string {
    $prefix = 'picontrol_';
    $sanitized = preg_replace('/[^a-zA-Z0-9_]/', '', $name);
    return $prefix . $sanitized;
});

$mm->registerFunction($moduleName, 'pdo', function () use ($moduleName): \PDO {
    $settings = modules()->settings($moduleName);
    $useSeparate = !empty($settings['use_separate_db']);

    if ($useSeparate) {
        // Uses module-specific DB config
        $module = modules()->get($moduleName);
        $fallback = $module['db_defaults'] ?? [];
        return modules()->modulePdo($moduleName, $fallback);
    }

    $base = app()->basePdo();
    if (!$base) {
        throw new ModuleConfigException(
            $moduleName,
            'Base-DB ist deaktiviert. Bitte Base-DB aktivieren oder eigene Modul-DB konfigurieren.'
        );
    }

    return $base;
});

$mm->registerFunction($moduleName, 'ensure_schema', function () use ($moduleName): void {
    $pdo = module_fn($moduleName, 'pdo');
    $table = fn(string $name) => module_fn($moduleName, 'table', $name);

    $driver = (string)$pdo->getAttribute(PDO::ATTR_DRIVER_NAME);

    $hostTable = $table('hosts');
    $cmdTable = $table('commands');
    $runTable = $table('runs');

    if ($driver === 'pgsql') {
        $pdo->exec("CREATE TABLE IF NOT EXISTS {$hostTable} (
            id SERIAL PRIMARY KEY,
            name VARCHAR(120) NOT NULL,
            host VARCHAR(255) NOT NULL,
            port INTEGER NOT NULL DEFAULT 22,
            username VARCHAR(120) NOT NULL,
            auth_type VARCHAR(20) NOT NULL DEFAULT 'key',
            key_path TEXT NULL,
            password TEXT NULL,
            created_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP
        )");
        $pdo->exec("CREATE TABLE IF NOT EXISTS {$cmdTable} (
            id SERIAL PRIMARY KEY,
            label VARCHAR(160) NOT NULL,
            command TEXT NOT NULL,
            admin_only BOOLEAN NOT NULL DEFAULT false,
            created_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP
        )");
        $pdo->exec("CREATE TABLE IF NOT EXISTS {$runTable} (
            id SERIAL PRIMARY KEY,
            host_id INTEGER NULL,
            command_id INTEGER NULL,
            command_text TEXT NOT NULL,
            status VARCHAR(20) NOT NULL DEFAULT 'pending',
            output TEXT NULL,
            created_by VARCHAR(120) NULL,
            created_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP
        )");
    } else {
        $pdo->exec("CREATE TABLE IF NOT EXISTS {$hostTable} (
            id INTEGER PRIMARY KEY AUTOINCREMENT,
            name VARCHAR(120) NOT NULL,
            host VARCHAR(255) NOT NULL,
            port INTEGER NOT NULL DEFAULT 22,
            username VARCHAR(120) NOT NULL,
            auth_type VARCHAR(20) NOT NULL DEFAULT 'key',
            key_path TEXT NULL,
            password TEXT NULL,
            created_at DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP
        )");
        $pdo->exec("CREATE TABLE IF NOT EXISTS {$cmdTable} (
            id INTEGER PRIMARY KEY AUTOINCREMENT,
            label VARCHAR(160) NOT NULL,
            command TEXT NOT NULL,
            admin_only INTEGER NOT NULL DEFAULT 0,
            created_at DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP
        )");
        $pdo->exec("CREATE TABLE IF NOT EXISTS {$runTable} (
            id INTEGER PRIMARY KEY AUTOINCREMENT,
            host_id INTEGER NULL,
            command_id INTEGER NULL,
            command_text TEXT NOT NULL,
            status VARCHAR(20) NOT NULL DEFAULT 'pending',
            output TEXT NULL,
            created_by VARCHAR(120) NULL,
            created_at DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP
        )");
    }

    // Seed default commands (only when empty)
    $count = (int)$pdo->query('SELECT COUNT(*) FROM ' . $cmdTable)->fetchColumn();
    if ($count === 0) {
        $defaults = [
            ['Speicherplatz auf Dateisystem', 'df -T -h', false],
            ['Netzwerkdaten', 'ip -s addr show', false],
            ['CPU-Information', 'cat /proc/cpuinfo', false],
            ['Informationen über USB-Bus', 'lsusb', false],
            ['Uptime', 'uptime -p', false],
            ['Scannen Sie einen I2C-Bus nach Geräten', '/usr/sbin/i2cdetect -y 1', true],
            ['Prozesse (Gib zum Beenden \"q\" ein)', 'top', false],
            ['SSH status', 'systemctl status ssh', false],
            ['Konfigurationsprogramm in Raspberry OS', 'sudo raspi-config', true],
            ['Pinbelegung', 'pinout', false],
            ['Exportiere GPIO (Für Nutzung vorbereiten)', 'echo 22 > /sys/class/gpio/export', true],
            ['Lese GPIO-Wert', 'echo in > /sys/class/gpio/gpio22/direction && cat /sys/class/gpio/gpio22/value', true],
            ['Schreibe \"Low\" GPIO Wert', 'echo out > /sys/class/gpio/gpio22/direction && echo 0 > /sys/class/gpio/gpio22/value', true],
            ['Schreibe \"High\" GPIO Wert', 'echo out > /sys/class/gpio/gpio22/direction && echo 1 > /sys/class/gpio/gpio22/value', true],
            ['Export entfernen (Ressource freigeben)', 'echo 22 > /sys/class/gpio/unexport', true],
            ['Alternative Funktionen von GPIO', 'raspi-gpio funcs', false],
            ['Gerät herunterfahren', 'sudo systemctl poweroff', true],
            ['Gerät neu starten', 'sudo systemctl reboot', true],
            ['Aktualisiere die Betriebssystem-Pakete', 'sudo apt update && sudo apt full-upgrade', true],
            ['Befehle, die zuvor ausgeführt wurden (Quellsprache)', 'history 30', false],
            ['Liste der zuletzt angemeldeten Nutzer', 'last -30 -F', false],
            ['Liste der aktuell angemeldeten Nutzer', 'w', false],
            ['Aktualisierung', 'sudo apt update && sudo apt upgrade -y && sudo apt-get autoremove --purge && sudo apt-get clean && sudo rm -rf /var/lib/apt/lists/* && sudo apt-get update && sudo apt-get remove texlive-*-doc', true],
            ['Update OS', 'sudo apt update && sudo apt full-upgrade -y && sudo apt-get autoremove --purge && sudo apt-get clean && sudo rm -rf /var/lib/apt/lists/* && sudo apt-get update && sudo apt-get remove texlive-*-doc', true],
            ['Paketlisten laden', 'sudo apt-get update; sudo apt-get dist-upgrade -y;exit', true],
            ['Gerät herunterfahren', 'sudo /sbin/shutdown -h now', true],
            ['Gerät neu starten', 'sudo /sbin/reboot', true],
        ];

        $stmt = $pdo->prepare(
            'INSERT INTO ' . $cmdTable . ' (label, command, admin_only) VALUES (:label, :command, :admin_only)'
        );
        foreach ($defaults as [$label, $command, $adminOnly]) {
            $stmt->bindValue(':label', $label, PDO::PARAM_STR);
            $stmt->bindValue(':command', $command, PDO::PARAM_STR);
            $stmt->bindValue(':admin_only', (bool)$adminOnly, PDO::PARAM_BOOL);
            $stmt->execute();
        }
    }
});