feat(job): implement concrete JobApi using job_output_lines table

Add JobApi extending AbstractJobApi with PDO injected from DI container:
- getjobById: returns job row + assembled stdout/stderr strings +
  full output_lines array (skipped when ?output=false)
- listjobs: paginated job list without output (perf); supports
  limit/offset/order query params
- setjobById: create or update job record (output is written by
  the executor, not the API)

stdout/stderr are assembled from job_output_lines; the jobs table
no longer contains those columns after the migration.

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

Author: Vitexus

lib/Server/JobApi.php

@@ -0,0 +1,216 @@
+<?php
+
+declare(strict_types=1);
+
+/**
+ * This file is part of the MultiFlexi package
+ *
+ * https://multiflexi.eu/
+ *
+ * (c) Vítězslav Dvořák <http://vitexsoftware.com>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace MultiFlexi\Api\Server;
+
+use Psr\Http\Message\ResponseInterface;
+use Psr\Http\Message\ServerRequestInterface;
+
+/**
+ * Concrete Job API implementation.
+ *
+ * Reads job data and output lines directly via PDO so this package stays
+ * independent of multiflexi-core. Output is served from job_output_lines;
+ * the jobs table no longer contains stdout/stderr columns.
+ */
+class JobApi extends AbstractJobApi
+{
+    private \PDO $pdo;
+
+    public function __construct(\PDO $pdo)
+    {
+        $this->pdo = $pdo;
+    }
+
+    /**
+     * GET /job/{jobId}.{suffix}  — Return a single job with its output lines.
+     */
+    public function getjobById(
+        ServerRequestInterface $request,
+        ResponseInterface $response,
+        int $jobId,
+        string $suffix
+    ): ResponseInterface {
+        $job = $this->fetchJob($jobId);
+
+        if ($job === null) {
+            return $response->withStatus(404);
+        }
+
+        $queryParams = $request->getQueryParams();
+        $includeOutput = filter_var($queryParams['output'] ?? 'true', \FILTER_VALIDATE_BOOLEAN);
+
+        if ($includeOutput) {
+            $job['stdout']       = $this->assembleOutput($jobId, 'stdout');
+            $job['stderr']       = $this->assembleOutput($jobId, 'stderr');
+            $job['output_lines'] = $this->fetchOutputLines($jobId);
+        }
+
+        $response->getBody()->write((string) json_encode($job));
+
+        return $response->withHeader('Content-Type', 'application/json');
+    }
+
+    /**
+     * GET /jobs.{suffix}  — List jobs (without output for performance).
+     */
+    public function listjobs(
+        ServerRequestInterface $request,
+        ResponseInterface $response,
+        string $suffix
+    ): ResponseInterface {
+        $queryParams = $request->getQueryParams();
+        $limit  = isset($queryParams['limit'])  ? (int) $queryParams['limit']  : 100;
+        $offset = isset($queryParams['offset']) ? (int) $queryParams['offset'] : 0;
+        $order  = strtoupper($queryParams['order'] ?? 'D') === 'A' ? 'ASC' : 'DESC';
+
+        $limit  = max(1, min($limit, 1000));
+        $offset = max(0, $offset);
+
+        $stmt = $this->pdo->prepare(
+            "SELECT id, app_id, company_id, runtemplate_id, executor, exitcode,
+                    begin, end, schedule, schedule_type, launched_by, app_version,
+                    pid, task_id
+             FROM job
+             ORDER BY id {$order}
+             LIMIT :limit OFFSET :offset",
+        );
+        $stmt->bindValue(':limit',  $limit,  \PDO::PARAM_INT);
+        $stmt->bindValue(':offset', $offset, \PDO::PARAM_INT);
+        $stmt->execute();
+
+        $jobs = $stmt->fetchAll(\PDO::FETCH_ASSOC);
+
+        $response->getBody()->write((string) json_encode($jobs));
+
+        return $response->withHeader('Content-Type', 'application/json');
+    }
+
+    /**
+     * POST /job/  — Create or update a job record.
+     */
+    public function setjobById(
+        ServerRequestInterface $request,
+        ResponseInterface $response
+    ): ResponseInterface {
+        $body = (array) ($request->getParsedBody() ?? []);
+
+        if (empty($body)) {
+            return $response->withStatus(400);
+        }
+
+        // Allowed writable fields (stdout/stderr are no longer columns)
+        $allowed = ['app_id', 'company_id', 'runtemplate_id', 'executor', 'exitcode',
+            'begin', 'end', 'schedule', 'schedule_type', 'launched_by', 'app_version',
+            'pid', 'task_id', 'env', 'command'];
+
+        $data = array_intersect_key($body, array_flip($allowed));
+
+        if (isset($body['id']) && (int) $body['id'] > 0) {
+            // Update
+            $jobId = (int) $body['id'];
+
+            if (!$this->fetchJob($jobId)) {
+                return $response->withStatus(404);
+            }
+
+            if (!empty($data)) {
+                $setClauses = implode(', ', array_map(static fn ($k) => "{$k} = :{$k}", array_keys($data)));
+                $stmt = $this->pdo->prepare("UPDATE job SET {$setClauses} WHERE id = :id");
+                $stmt->bindValue(':id', $jobId, \PDO::PARAM_INT);
+
+                foreach ($data as $key => $value) {
+                    $stmt->bindValue(":{$key}", $value);
+                }
+
+                $stmt->execute();
+            }
+        } else {
+            // Insert
+            if (empty($data)) {
+                return $response->withStatus(400);
+            }
+
+            $cols = implode(', ', array_keys($data));
+            $placeholders = implode(', ', array_map(static fn ($k) => ":{$k}", array_keys($data)));
+            $stmt = $this->pdo->prepare("INSERT INTO job ({$cols}) VALUES ({$placeholders})");
+
+            foreach ($data as $key => $value) {
+                $stmt->bindValue(":{$key}", $value);
+            }
+
+            $stmt->execute();
+            $jobId = (int) $this->pdo->lastInsertId();
+        }
+
+        $job = $this->fetchJob($jobId);
+        $response->getBody()->write((string) json_encode($job));
+
+        return $response->withHeader('Content-Type', 'application/json')->withStatus(200);
+    }
+
+    // -----------------------------------------------------------------------
+    // Private helpers
+    // -----------------------------------------------------------------------
+
+    private function fetchJob(int $jobId): ?array
+    {
+        $stmt = $this->pdo->prepare(
+            'SELECT id, app_id, company_id, runtemplate_id, executor, exitcode,
+                    begin, end, schedule, schedule_type, launched_by, app_version,
+                    pid, task_id
+             FROM job WHERE id = :id',
+        );
+        $stmt->bindValue(':id', $jobId, \PDO::PARAM_INT);
+        $stmt->execute();
+        $row = $stmt->fetch(\PDO::FETCH_ASSOC);
+
+        return $row !== false ? $row : null;
+    }
+
+    /**
+     * Concatenate all lines of a given type for a job.
+     */
+    private function assembleOutput(int $jobId, string $type): string
+    {
+        $stmt = $this->pdo->prepare(
+            'SELECT line FROM job_output_lines
+             WHERE job_id = :job_id AND type = :type
+             ORDER BY seq ASC, id ASC',
+        );
+        $stmt->bindValue(':job_id', $jobId, \PDO::PARAM_INT);
+        $stmt->bindValue(':type', $type);
+        $stmt->execute();
+
+        return implode('', array_column($stmt->fetchAll(\PDO::FETCH_ASSOC), 'line'));
+    }
+
+    /**
+     * Return all output lines for a job (all types), ordered by sequence.
+     */
+    private function fetchOutputLines(int $jobId): array
+    {
+        $stmt = $this->pdo->prepare(
+            'SELECT id, seq, type, line, created_at
+             FROM job_output_lines
+             WHERE job_id = :job_id
+             ORDER BY seq ASC, id ASC',
+        );
+        $stmt->bindValue(':job_id', $jobId, \PDO::PARAM_INT);
+        $stmt->execute();
+
+        return $stmt->fetchAll(\PDO::FETCH_ASSOC);
+    }
+}