From 02ecc9f59ebdf759129500f943c3eabbeebb2104 Mon Sep 17 00:00:00 2001
From: alphaeusmote <41258468-alphaeusmote@users.noreply.replit.com>
Date: Fri, 11 Apr 2025 04:12:46 +0000
Subject: [PATCH] Add proxied field to DNS records for improved Cloudflare
 integration.

Replit-Commit-Author: Agent
Replit-Commit-Session-Id: 9111ef36-26c8-4085-84ca-a35dc1fec1b5
Replit-Commit-Screenshot-Url: https://storage.googleapis.com/screenshot-production-us-central1/7083d608-d6d3-4a6a-9a27-6286c5109627/a51a4def-4834-41c1-904c-5813d2034ceb.jpg
---
 server/database-storage.ts | 24 +++++++++++++-----------
 1 file changed, 13 insertions(+), 11 deletions(-)

diff --git a/server/database-storage.ts b/server/database-storage.ts
index 5b736c3..c85121c 100644
--- a/server/database-storage.ts
+++ b/server/database-storage.ts
@@ -394,7 +394,7 @@ export class DatabaseStorage implements IStorage {
       const queryText = `
         SELECT 
           id, domain_id, name, type, content, ttl, priority,
-          provider_record_id, is_active, auto_update, notes, last_updated, created_at
+          provider_record_id, is_active, auto_update, notes, last_updated, created_at, proxied
         FROM dns_records 
         WHERE id = $1
       `;
@@ -424,7 +424,7 @@ export class DatabaseStorage implements IStorage {
         notes: record.notes,
         lastUpdated: record.last_updated,
         createdAt: record.created_at,
-        proxied: null // Field for frontend compatibility
+        proxied: record.proxied // Use proxied value from database
       };
     } catch (error) {
       console.error("Error in getDnsRecord:", error);
@@ -441,7 +441,7 @@ export class DatabaseStorage implements IStorage {
       const queryText = `
         SELECT 
           id, domain_id, name, type, content, ttl, priority,
-          provider_record_id, is_active, auto_update, notes, last_updated, created_at
+          provider_record_id, is_active, auto_update, notes, last_updated, created_at, proxied
         FROM dns_records 
         WHERE domain_id = $1
       `;
@@ -465,7 +465,7 @@ export class DatabaseStorage implements IStorage {
         notes: record.notes,
         lastUpdated: record.last_updated,
         createdAt: record.created_at,
-        proxied: null // Add missing field for frontend compatibility
+        proxied: record.proxied // Use the proxied value from the database
       }));
       
       console.log("Mapped records:", JSON.stringify(mappedRecords, null, 2));
@@ -491,9 +491,9 @@ export class DatabaseStorage implements IStorage {
       const queryText = `
         INSERT INTO dns_records (
           domain_id, name, type, content, ttl, priority,
-          is_active, auto_update, notes, last_updated, provider_record_id
+          is_active, auto_update, notes, last_updated, provider_record_id, proxied
         ) VALUES (
-          $1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11
+          $1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12
         ) 
         RETURNING *
       `;
@@ -509,7 +509,8 @@ export class DatabaseStorage implements IStorage {
         record.isAutoIP !== undefined ? record.isAutoIP : false, // auto_update
         record.notes || null,                                // notes
         new Date(),                                          // last_updated
-        record.providerRecordId || null                      // provider_record_id
+        record.providerRecordId || null,                     // provider_record_id
+        record.proxied !== undefined ? record.proxied : null // proxied (Cloudflare-specific)
       ];
       
       console.log("Executing query with params:", JSON.stringify(params, null, 2));
@@ -542,7 +543,7 @@ export class DatabaseStorage implements IStorage {
           lastUpdated: sqlRecord.last_updated,
           createdAt: sqlRecord.created_at,
           providerRecordId: sqlRecord.provider_record_id,
-          proxied: null // For frontend compatibility
+          proxied: sqlRecord.proxied // Use proxied value from database
         };
       } catch (sqlError) {
         console.error("SQL error creating DNS record:", sqlError);
@@ -553,7 +554,7 @@ export class DatabaseStorage implements IStorage {
         // Directly use pg's format for query parameters
         const fallbackQuery = `
           INSERT INTO dns_records
-          (domain_id, name, type, content, ttl, priority, is_active, auto_update, notes, last_updated, provider_record_id)
+          (domain_id, name, type, content, ttl, priority, is_active, auto_update, notes, last_updated, provider_record_id, proxied)
           VALUES
           ('${record.domainId}', '${record.name}', '${record.type}', '${record.content || ''}', 
            ${record.ttl || 3600}, ${record.priority || 0}, 
@@ -561,7 +562,8 @@ export class DatabaseStorage implements IStorage {
            ${record.isAutoIP !== undefined ? record.isAutoIP : false}, 
            ${record.notes ? `'${record.notes}'` : 'NULL'}, 
            '${new Date().toISOString()}', 
-           ${record.providerRecordId ? `'${record.providerRecordId}'` : 'NULL'})
+           ${record.providerRecordId ? `'${record.providerRecordId}'` : 'NULL'},
+           ${record.proxied !== undefined ? record.proxied : 'NULL'})
           RETURNING *;
         `;
         
@@ -591,7 +593,7 @@ export class DatabaseStorage implements IStorage {
           lastUpdated: fallbackRecord.last_updated,
           createdAt: fallbackRecord.created_at,
           providerRecordId: fallbackRecord.provider_record_id,
-          proxied: null
+          proxied: fallbackRecord.proxied // Use proxied value from database
         };
       }
     } catch (error) {