v1.2.39 - Fix IP Bans page: convert rows+columns SQL response format to objects for display

api/index.js

@@ -6205,27 +6205,13 @@ async function loadIpBans() {
 
 // Execute SQL query and handle IP bans response
 async function executeSqlQueryRaw(query, queryId) {
-    if (!pool || pool.length === 0) {
+    if (!relayPool) {
         log('Not connected to relay', 'ERROR');
         return;
     }
 
-    const relay = pool[0];
-    if (!relay) {
-        log('No relay connection available', 'ERROR');
-        return;
-    }
-
-    // Create a kind 23456 event with SQL query
-    const event = {
-        kind: 23456,
-        content: query,
-        tags: [['t', 'sql_query'], ['id', queryId]],
-        created_at: Math.floor(Date.now() / 1000)
-    };
-
     try {
-        await relay.publish(event);
+        await sendAdminCommand(['sql_query', query, queryId]);
         log('Loading IP bans...', 'INFO');
     } catch (error) {
         log('Failed to load IP bans: ' + error.message, 'ERROR');
@@ -6234,7 +6220,20 @@ async function executeSqlQueryRaw(query, queryId) {
 
 // Handle IP bans SQL response
 function handleIpBansResponse(responseData) {
-    if (!responseData.results || responseData.results.length === 0) {
+    // Convert rows+columns format to array of objects
+    let results = [];
+    if (responseData.rows && responseData.columns) {
+        const cols = responseData.columns;
+        results = responseData.rows.map(row => {
+            const obj = {};
+            cols.forEach((col, i) => { obj[col] = row[i]; });
+            return obj;
+        });
+    } else if (responseData.results) {
+        results = responseData.results;
+    }
+
+    if (results.length === 0) {
         document.getElementById('ip-bans-tbody').innerHTML = '<tr><td colspan="7" style="text-align: center;">No IP bans found</td></tr>';
         document.getElementById('ip-bans-total').textContent = '0';
         document.getElementById('ip-bans-active').textContent = '0';
@@ -6243,20 +6242,20 @@ function handleIpBansResponse(responseData) {
     }
 
     const now = Math.floor(Date.now() / 1000);
-    let totalIPs = responseData.results.length;
+    let totalIPs = results.length;
     let currentlyBanned = 0;
     let totalBans = 0;
 
     // Filter results based on current filter
-    let filteredResults = responseData.results;
+    let filteredResults = results;
     if (ipBansFilter === 'banned') {
-        filteredResults = responseData.results.filter(row => row.banned_until > now);
+        filteredResults = results.filter(row => row.banned_until > now);
     } else if (ipBansFilter === 'expired') {
-        filteredResults = responseData.results.filter(row => row.banned_until <= now && row.banned_until > 0);
+        filteredResults = results.filter(row => row.banned_until <= now && row.banned_until > 0);
     }
 
     // Calculate stats
-    responseData.results.forEach(row => {
+    results.forEach(row => {
         totalBans += parseInt(row.ban_count || 0);
         if (row.banned_until > now) {
             currentlyBanned++;

relay.pid

@@ -1 +1 @@
-2303481
+2375515

src/ip_ban.c

@@ -250,9 +250,34 @@ void ip_ban_save_to_db(sqlite3* db) {
     DEBUG_TRACE("IP ban table saved: %d entries written to DB", saved);
 }
 
+// Check if an IP is in the idle_ban_whitelist config (comma-separated list)
+static int ip_is_whitelisted(const char* ip) {
+    const char* whitelist = get_config_value("idle_ban_whitelist");
+    if (!whitelist || whitelist[0] == '\0') return 0;
+
+    // Make a mutable copy to tokenize
+    char buf[1024];
+    strncpy(buf, whitelist, sizeof(buf) - 1);
+    buf[sizeof(buf) - 1] = '\0';
+
+    char* token = strtok(buf, ",");
+    while (token) {
+        // Trim leading/trailing spaces
+        while (*token == ' ') token++;
+        char* end = token + strlen(token) - 1;
+        while (end > token && *end == ' ') { *end = '\0'; end--; }
+        if (strcmp(token, ip) == 0) return 1;
+        token = strtok(NULL, ",");
+    }
+    return 0;
+}
+
 int ip_ban_is_banned(const char* ip) {
     if (!ip || !g_initialized) return 0;
 
+    // Whitelisted IPs are never banned
+    if (ip_is_whitelisted(ip)) return 0;
+
     pthread_mutex_lock(&g_ban_mutex);
     int idx = find_slot(ip);
     if (idx < 0 || g_ban_table[idx].state == IP_BAN_EMPTY) {
@@ -359,6 +384,7 @@ void ip_ban_record_failure(const char* ip) {
 void ip_ban_record_idle_failure(const char* ip) {
     if (!ip || !g_initialized) return;
     if (!get_config_bool("idle_ban_enabled", 1)) return;
+    if (ip_is_whitelisted(ip)) return;  // Never record idle failures for whitelisted IPs
 
     int threshold = get_config_int("idle_ban_threshold", 1);
     int window_sec = get_config_int("idle_ban_window_sec", 30);

src/main.h

@@ -13,8 +13,8 @@
 // Using CRELAY_ prefix to avoid conflicts with nostr_core_lib VERSION macros
 #define CRELAY_VERSION_MAJOR 1
 #define CRELAY_VERSION_MINOR 2
-#define CRELAY_VERSION_PATCH 36
-#define CRELAY_VERSION "v1.2.36"
+#define CRELAY_VERSION_PATCH 39
+#define CRELAY_VERSION "v1.2.39"
 
 // Relay metadata (authoritative source for NIP-11 information)
 #define RELAY_NAME "C-Relay"