SIMON Master Console Rebuild

File viewer

guarded to /htdocs

/connlink/test1/ui/old/simon_safe_lib.php

<?php
declare(strict_types=1);

/**
 * SIMON Emergency Safe Library
 * Standalone no-fatal helper for recovery dashboards.
 */

ini_set('display_errors', '1');
ini_set('display_startup_errors', '1');
error_reporting(E_ALL);

if (!function_exists('mb_substr')) {
    function mb_substr($string, $start, $length = null, $encoding = null) {
        return $length === null ? substr((string)$string, (int)$start) : substr((string)$string, (int)$start, (int)$length);
    }
}

function sr_dirs(): void {
    foreach (['cache/jobs','cache/feeds','data/events','logs/jobs','logs/compat'] as $d) {
        $p = sr_path($d);
        if (!is_dir($p)) @mkdir($p, 0775, true);
    }
}

function sr_default_feeds(): array {
    return [
        ['id'=>'newsapi','name'=>'NewsAPI','group'=>'News','category'=>'news','endpoint'=>'/connlink/test1/ui/newsapi_proxy.php','enabled'=>true,'refresh'=>300,'priority'=>100,'icon'=>'NEWS'],
        ['id'=>'webhook','name'=>'Webhook Inbox','group'=>'SIMON Internal','category'=>'internal','endpoint'=>'/connlink/test1/ui/webhook_inbox.php?stream=default','enabled'=>true,'refresh'=>30,'priority'=>100,'icon'=>'HOOK'],
        ['id'=>'google_search','name'=>'Google Search Proxy','group'=>'Search','category'=>'search','endpoint'=>'/connlink/test1/ui/gsearch_proxy.php?q=simon','enabled'=>true,'refresh'=>0,'priority'=>70,'icon'=>'SEARCH'],
    ];
}

function sr_load_registry(): array {
    $file = sr_path('carrier_registry.json');
    if (!is_file($file)) return ['version'=>'fallback','feeds'=>sr_default_feeds()];
    $raw = @file_get_contents($file);
    $json = json_decode((string)$raw, true);
    if (!is_array($json) || !isset($json['feeds']) || !is_array($json['feeds'])) {
        return ['version'=>'fallback_bad_json','feeds'=>sr_default_feeds()];
    }
    return $json;
}

function sr_save_registry(array $registry): bool {
    $registry['updated'] = gmdate('c');
    return @file_put_contents(sr_path('carrier_registry.json'), json_encode($registry, JSON_PRETTY_PRINT | JSON_UNESCAPED_SLASHES), LOCK_EX) !== false;
}

function sr_feeds(bool $enabledOnly=false): array {
    $reg = sr_load_registry();
    $feeds = [];
    foreach (($reg['feeds'] ?? []) as $f) {
        if (!is_array($f) || empty($f['id'])) continue;
        $f['name'] = (string)($f['name'] ?? ucfirst(str_replace('_',' ', $f['id'])));
        $f['group'] = (string)($f['group'] ?? ($f['category'] ?? 'General'));
        $f['category'] = (string)($f['category'] ?? 'general');
        $f['endpoint'] = (string)($f['endpoint'] ?? ($f['url'] ?? ''));
        $f['enabled'] = (bool)($f['enabled'] ?? true);
        $f['refresh'] = (int)($f['refresh'] ?? 300);
        $f['priority'] = (int)($f['priority'] ?? 50);
        $f['icon'] = (string)($f['icon'] ?? 'FEED');
        if ($enabledOnly && !$f['enabled']) continue;
        $feeds[] = $f;
    }
    usort($feeds, fn($a,$b) => ($b['priority'] <=> $a['priority']) ?: strcmp($a['name'], $b['name']));
    return $feeds;
}

function sr_feed(string $id): ?array {
    foreach (sr_feeds(false) as $f) if ($f['id'] === $id) return $f;
    return null;
}

function sr_cache_file(string $id): string {
    $safe = preg_replace('/[^a-zA-Z0-9_\-]/', '_', $id) ?: 'unknown';
    return sr_path('cache/jobs/' . $safe . '.json');
}

function sr_cache_read(string $id): ?array {
    $file = sr_cache_file($id);
    if (!is_file($file)) return null;
    $json = json_decode((string)@file_get_contents($file), true);
    return is_array($json) ? $json : null;
}

function sr_cache_write(string $id, array $payload): bool {
    sr_dirs();
    $payload['cached_at'] = $payload['cached_at'] ?? gmdate('c');
    return @file_put_contents(sr_cache_file($id), json_encode($payload, JSON_PRETTY_PRINT | JSON_UNESCAPED_SLASHES), LOCK_EX) !== false;
}

function sr_abs_url(string $url): string {
    if ($url === '') return '';
    if (preg_match('~^https?://~i', $url)) return $url;
    if (str_starts_with($url, '/')) {
        $scheme = (!empty($_SERVER['HTTPS']) && $_SERVER['HTTPS'] !== 'off') ? 'https' : 'http';
        $host = $_SERVER['HTTP_HOST'] ?? 'localhost';
        return $scheme . '://' . $host . $url;
    }
    return $url;
}

function sr_fetch(string $url): array {
    $started = microtime(true);
    $abs = sr_abs_url($url);
    if ($abs === '') return ['ok'=>false,'json'=>null,'latency_ms'=>0,'error'=>'missing_endpoint','url'=>''];
    $ctx = stream_context_create(['http'=>[
        'method'=>'GET',
        'timeout'=>18,
        'header'=>"Accept: application/json, text/plain, */*\r\nUser-Agent: SIMON-Recovery/2.1\r\n"
    ]]);
    $raw = @file_get_contents($abs, false, $ctx);
    $latency = (int)round((microtime(true)-$started)*1000);
    if ($raw === false) return ['ok'=>false,'json'=>null,'latency_ms'=>$latency,'error'=>'request_failed','url'=>$abs];
    $json = json_decode($raw, true);
    return ['ok'=>true,'json'=>is_array($json)?$json:null,'latency_ms'=>$latency,'error'=>is_array($json)?null:'non_json_response','url'=>$abs];
}

function sr_extract_items(array $json): array {
    foreach (['items','articles','events','results','features','data'] as $k) {
        if (isset($json[$k]) && is_array($json[$k])) return $json[$k];
    }
    return array_is_list($json) ? $json : [];
}

function sr_run_feed(string $id): array {
    $feed = sr_feed($id);
    if (!$feed) return ['ok'=>false,'id'=>$id,'name'=>$id,'status'=>'missing_feed','message'=>'Feed not in registry','items'=>[],'item_count'=>0,'latency_ms'=>0,'updated'=>gmdate('c')];
    if (!$feed['enabled']) {
        $r = ['ok'=>false,'id'=>$id,'name'=>$feed['name'],'group'=>$feed['group'],'category'=>$feed['category'],'endpoint'=>$feed['endpoint'],'status'=>'disabled','message'=>'Feed disabled','items'=>[],'item_count'=>0,'latency_ms'=>0,'updated'=>gmdate('c')];
        sr_cache_write($id, $r);
        return $r;
    }
    $fetch = sr_fetch($feed['endpoint']);
    $items = $fetch['json'] ? sr_extract_items($fetch['json']) : [];
    $r = [
        'ok'=>$fetch['ok'] && $fetch['json'] !== null,
        'id'=>$id,
        'name'=>$feed['name'],
        'group'=>$feed['group'],
        'category'=>$feed['category'],
        'endpoint'=>$feed['endpoint'],
        'request_url'=>$fetch['url'],
        'status'=>($fetch['ok'] && $fetch['json'] !== null) ? 'online' : 'failed',
        'message'=>$fetch['error'] ?: 'Endpoint called successfully.',
        'items'=>$items,
        'item_count'=>count($items),
        'latency_ms'=>$fetch['latency_ms'],
        'updated'=>gmdate('c')
    ];
    sr_cache_write($id, $r);
    return $r;
}

function sr_run_all(int $limit=60): array {
    $out = [];
    foreach (array_slice(sr_feeds(true), 0, $limit) as $feed) $out[] = sr_run_feed($feed['id']);
    return $out;
}

function sr_rows(): array {
    $rows = [];
    foreach (sr_feeds(false) as $feed) {
        $cache = sr_cache_read($feed['id']);
        $items = isset($cache['items']) && is_array($cache['items']) ? $cache['items'] : [];
        $rows[] = [
            'id'=>$feed['id'],
            'name'=>$feed['name'],
            'group'=>$feed['group'],
            'category'=>$feed['category'],
            'endpoint'=>$feed['endpoint'],
            'enabled'=>$feed['enabled'],
            'priority'=>$feed['priority'],
            'refresh'=>$feed['refresh'],
            'icon'=>$feed['icon'],
            'status'=>$cache['status'] ?? ($feed['enabled'] ? 'not_tested' : 'disabled'),
            'ok'=>(bool)($cache['ok'] ?? false),
            'items'=>$items,
            'item_count'=>count($items),
            'latency_ms'=>(int)($cache['latency_ms'] ?? 0),
            'cached_at'=>$cache['cached_at'] ?? null,
            'message'=>$cache['message'] ?? '',
        ];
    }
    return $rows;
}

function sr_top(string $title, string $sub=''): void {
    echo '<!doctype html><html><head><meta charset="utf-8"><meta name="viewport" content="width=device-width,initial-scale=1"><title>'.sr_h($title).'</title><style>'.sr_css().'</style></head><body><div class="wrap"><div class="top"><div class="brand"><div class="logo"></div><div><div class="kicker">SIMON Emergency Recovery</div><h1>'.sr_h($title).'</h1><div class="sub">'.sr_h($sub).'</div></div></div><div class="actions"><a class="btn" href="compat/compat.php">Compat</a><a class="btn" href="jobs_dashboard.php">Jobs</a><a class="btn" href="feed_manager.php">Feed Manager</a><a class="btn" href="ai_dashboard.php">AI</a><a class="btn" href="graph_dashboard.php">Graph</a></div></div>';
}
function sr_bottom(): void { echo '</div></body></html>'; }
?>

Quick jump

open a path

True command center for SIMON + WEB360

File viewer

Quick jump