Initial upload

Author: getpinga

README.md

@@ -1,2 +1,68 @@
-# registry-ntfy
-ntfy.sh Error Notifier for Namingo Registry
+# ntfy.sh Error Notifier for Namingo Registry
+
+This script checks for new high-severity errors from Namingo Registry and sends real-time push notifications via [ntfy.sh](https://ntfy.sh).
+
+## ⚙️ Setup Steps
+
+### 1. 📥 Download
+
+Clone or copy the files to your server:
+
+```bash
+sudo mkdir -p /opt/registry/ntfy
+cd /opt/registry/ntfy
+# Add ntfy_error_notifier.php and ntfy_config.php here
+```
+
+### 2. 🛠 Configure
+
+Edit `ntfy_config.php` with your database credentials and ntfy topic name:
+
+```php
+return [
+    'db' => [
+        'host' => 'localhost',
+        'name' => 'registry',
+        'user' => 'youruser',
+        'pass' => 'yourpass',
+        'charset' => 'utf8mb4'
+    ],
+    'ntfy_topic' => 'https://ntfy.sh/my-channel', // Replace with your topic
+    'min_level' => 400,
+    'last_id_file' => __DIR__ . '/.last_id'
+];
+```
+
+### 3. 🔔 Create an ntfy.sh Topic
+
+- Visit [https://ntfy.sh](https://ntfy.sh)
+- Choose a topic name (e.g., `my-channel`)
+- Subscribe to it using the ntfy app (Android/iOS) or web
+
+No registration required, but for private topics, consider [authentication options](https://docs.ntfy.sh/publish/#authentication).
+
+### 4. 🧪 Test Run
+
+Run manually to ensure everything works:
+
+```bash
+php /opt/registry/ntfy/ntfy_error_notifier.php
+```
+
+### 5. 🕒 Add to Cron
+
+Open your crontab:
+
+```bash
+crontab -e
+```
+
+Add the following line to check for errors every minute:
+
+```bash
+* * * * * /usr/bin/php /opt/registry/ntfy/ntfy_error_notifier.php > /dev/null 2>&1
+```
+
+## 📄 License
+
+MIT License

ntfy_config.php

@@ -0,0 +1,13 @@
+<?php
+return [
+    'db' => [
+        'host' => 'localhost',
+        'name' => 'registry',
+        'user' => 'youruser',
+        'pass' => 'yourpass',
+        'charset' => 'utf8mb4'
+    ],
+    'ntfy_topic' => 'https://ntfy.sh/my-channel', // Your ntfy.sh topic URL
+    'min_level' => 400, // Minimum level to report (400=ERROR, 500=CRITICAL)
+    'last_id_file' => __DIR__ . '/.last_id'
+];

ntfy_error_notifier.php

@@ -0,0 +1,65 @@
+<?php
+
+$config = require __DIR__ . '/ntfy_config.php';
+
+try {
+    // Setup DB
+    $dsn = "mysql:host={$config['db']['host']};dbname={$config['db']['name']};charset={$config['db']['charset']}";
+    $pdo = new PDO($dsn, $config['db']['user'], $config['db']['pass'], [
+        PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION
+    ]);
+
+    // Track last ID
+    $lastIdFile = $config['last_id_file'];
+    $lastId = file_exists($lastIdFile) ? (int)file_get_contents($lastIdFile) : 0;
+
+    // Fetch new severe logs
+    $stmt = $pdo->prepare("
+        SELECT id, level, level_name, message, created_at 
+        FROM error_log 
+        WHERE id > :last_id AND level >= :min_level 
+        ORDER BY id ASC
+    ");
+    $stmt->execute([
+        ':last_id' => $lastId,
+        ':min_level' => $config['min_level']
+    ]);
+
+    $logs = $stmt->fetchAll(PDO::FETCH_ASSOC);
+    if (!$logs) {
+        exit(0); // Nothing new
+    }
+
+    foreach ($logs as $log) {
+        $text = "[{$log['created_at']}] [{$log['level_name']}] {$log['message']}";
+        sendNtfy($config['ntfy_topic'], $text, $log['level']);
+        $lastId = $log['id'];
+    }
+
+    // Update last ID
+    file_put_contents($lastIdFile, $lastId);
+} catch (Throwable $e) {
+    // Log to system log or email in real production use
+    error_log("ntfy_error_notifier failed: " . $e->getMessage());
+    exit(1);
+}
+
+// ntfy.sh notifier
+function sendNtfy(string $topic, string $message, int $level): void {
+    $priority = $level >= 500 ? 'urgent' : ($level >= 400 ? 'high' : 'default');
+    $title = $level >= 500 ? '🚨 Critical Error' : '⚠️ Error';
+
+    $ch = curl_init($topic);
+    curl_setopt_array($ch, [
+        CURLOPT_POST => true,
+        CURLOPT_POSTFIELDS => $message,
+        CURLOPT_HTTPHEADER => [
+            "Title: $title",
+            "Priority: $priority"
+        ],
+        CURLOPT_RETURNTRANSFER => true,
+        CURLOPT_TIMEOUT => 5
+    ]);
+    curl_exec($ch);
+    curl_close($ch);
+}