Initial push

2026-06-13 08:09:39 -04:00
parent d2d2a4d596
commit b8750e50c5
5 changed files with 587 additions and 21 deletions
--- a/hubzilla/addon/dsc01/dsc01_spool.php
+++ b/hubzilla/addon/dsc01/dsc01_spool.php
@@ -0,0 +1,153 @@
+<?php
+
+/**
+ * DSC-01 Spool Handler
+ * Validates POST submissions, builds the spool envelope,
+ * and POSTs to the orchestrator receiver.
+ * See DSC-RENDERER-SPEC.md — Record shape / Spool sections.
+ */
+
+// ---------------------------------------------------------------------------
+// POST HANDLER
+// ---------------------------------------------------------------------------
+
+function dsc01_handle_post($association_slug, $access) {
+    $categories = dsc01_load_categories();
+    $valid_codes = array_keys($categories);
+
+    $raw_codes = $_POST['dsc_codes'] ?? [];
+    $codes = [];
+    if (is_array($raw_codes)) {
+        foreach ($raw_codes as $code) {
+            $code = strtoupper(trim((string) $code));
+            if (in_array($code, $valid_codes, true)) {
+                $codes[] = $code;
+            }
+        }
+    }
+    $codes = array_values(array_unique($codes));
+
+    $narrative = isset($_POST['narrative'])
+        ? substr(strip_tags((string) $_POST['narrative']), 0, 8192)
+        : '';
+
+    // Validation — at least one category required
+    if (empty($codes)) {
+        $out  = '<div class="alert alert-danger"><strong>Please select at least one category.</strong></div>';
+        $out .= dsc01_render_landing($association_slug, $access, $codes, $narrative);
+        return $out;
+    }
+
+    // Build spool envelope
+    $cfg_raw = @file_get_contents('addon/vs01/config.json');
+    $cfg     = $cfg_raw ? json_decode($cfg_raw, true) : [];
+    $assoc   = $cfg['associations'][$association_slug] ?? [];
+
+    $envelope = dsc01_build_spool_envelope(
+        $codes,
+        $narrative,
+        $association_slug,
+        $assoc['channel_id'] ?? '',
+        $access
+    );
+
+    $result = dsc01_post_to_orchestrator($envelope);
+
+    if ($result === true) {
+        $assoc_name = dsc01_h($assoc['name'] ?? $association_slug);
+        return '<div class="dsc01-content">
+                    <div class="alert alert-success">
+                        Your checklist for ' . $assoc_name . ' has been submitted.
+                        <a href="' . z_root() . '/vs01/' . dsc01_h($association_slug) . '">
+                            Return to ' . $assoc_name . '
+                        </a>
+                    </div>
+                </div>';
+    }
+
+    $out  = '<div class="alert alert-danger">
+                Submission failed. Please try again or contact the operator.
+                <br><small>' . dsc01_h($result) . '</small>
+            </div>';
+    $out .= dsc01_render_landing($association_slug, $access, $codes, $narrative);
+    return $out;
+}
+
+// ---------------------------------------------------------------------------
+// SPOOL ENVELOPE
+// ---------------------------------------------------------------------------
+
+function dsc01_build_spool_envelope($dsc_codes, $narrative, $association_slug, $channel_id, $standing) {
+    return [
+        'addon'                   => 'dsc01',
+        'contract_version'        => '1.0',
+        'association_slug'        => $association_slug,
+        'association_channel_id'  => (string) $channel_id,
+        'submitted_at'             => date('c'),
+        'standing'                 => $standing,
+        'dsc_codes'                => $dsc_codes,
+        'narrative'                => $narrative,
+    ];
+}
+
+// ---------------------------------------------------------------------------
+// ORCHESTRATOR POST
+// ---------------------------------------------------------------------------
+
+function dsc01_post_to_orchestrator($envelope) {
+    $config       = dsc01_load_config();
+    $receiver_url = $config['receiver_url'] ?? '';
+    $node_token   = $config['node_token'] ?? '';
+
+    if (!$receiver_url) {
+        logger('dsc01_spool: receiver_url not configured');
+        return 'Orchestrator receiver URL not configured.';
+    }
+
+    $payload = json_encode($envelope);
+    if ($payload === false) {
+        logger('dsc01_spool: failed to encode envelope');
+        return 'Failed to encode submission.';
+    }
+
+    $ch = curl_init($receiver_url);
+    curl_setopt_array($ch, [
+        CURLOPT_POST           => true,
+        CURLOPT_POSTFIELDS     => $payload,
+        CURLOPT_RETURNTRANSFER => true,
+        CURLOPT_TIMEOUT        => 10,
+        CURLOPT_HTTPHEADER     => [
+            'Content-Type: application/json',
+            'X-Node-Token: ' . $node_token,
+        ],
+    ]);
+
+    $response   = curl_exec($ch);
+    $http_code  = curl_getinfo($ch, CURLINFO_HTTP_CODE);
+    $curl_error = curl_error($ch);
+    curl_close($ch);
+
+    if ($curl_error) {
+        logger('dsc01_spool: curl error: ' . $curl_error);
+        return 'Network error: ' . $curl_error;
+    }
+
+    if ($http_code === 200 || $http_code === 201) {
+        return true;
+    }
+
+    logger('dsc01_spool: orchestrator returned HTTP ' . $http_code . ': ' . $response);
+    return 'Orchestrator error (HTTP ' . $http_code . ').';
+}
+
+// ---------------------------------------------------------------------------
+// CONFIG
+// ---------------------------------------------------------------------------
+
+function dsc01_load_config() {
+    $path = 'addon/dsc01/config.json';
+    $raw  = @file_get_contents($path);
+    if ($raw === false) return [];
+    $data = json_decode($raw, true);
+    return (json_last_error() === JSON_ERROR_NONE) ? $data : [];
+}