Fix DNS record management issues by improving database interactions.

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/0c00fde5-fbe2-4141-8971-e16f704e73f1.jpg
This commit is contained in:
alphaeusmote
2025-04-10 21:42:19 +00:00
parent eed01b71ac
commit de5a9e8ef4
+68 -5
View File
@@ -386,26 +386,89 @@ export class DatabaseStorage implements IStorage {
// DNS Record management
async getDnsRecord(id: string): Promise<DnsRecord | undefined> {
const [record] = await db.select().from(dnsRecords).where(eq(dnsRecords.id, id));
const [record] = await db.select({
id: dnsRecords.id,
domainId: dnsRecords.domainId,
name: dnsRecords.name,
type: dnsRecords.type,
content: dnsRecords.content,
ttl: dnsRecords.ttl,
isActive: dnsRecords.isActive,
isAutoIP: dnsRecords.isAutoIP,
notes: dnsRecords.notes,
providerId: dnsRecords.providerId,
lastUpdated: dnsRecords.lastUpdated,
createdAt: dnsRecords.createdAt
})
.from(dnsRecords)
.where(eq(dnsRecords.id, id));
return record;
}
async getDnsRecordsByDomain(domainId: string): Promise<DnsRecord[]> {
return await db.select()
return await db.select({
id: dnsRecords.id,
domainId: dnsRecords.domainId,
name: dnsRecords.name,
type: dnsRecords.type,
content: dnsRecords.content,
ttl: dnsRecords.ttl,
isActive: dnsRecords.isActive,
isAutoIP: dnsRecords.isAutoIP,
notes: dnsRecords.notes,
providerId: dnsRecords.providerId,
lastUpdated: dnsRecords.lastUpdated,
createdAt: dnsRecords.createdAt
})
.from(dnsRecords)
.where(eq(dnsRecords.domainId, domainId));
}
async createDnsRecord(record: InsertDnsRecord): Promise<DnsRecord> {
const [newRecord] = await db.insert(dnsRecords).values(record).returning();
// Filter out the proxied field if it exists
const { proxied, ...recordData } = record as any;
// Insert the record without the proxied field
const [newRecord] = await db.insert(dnsRecords).values(recordData).returning({
id: dnsRecords.id,
domainId: dnsRecords.domainId,
name: dnsRecords.name,
type: dnsRecords.type,
content: dnsRecords.content,
ttl: dnsRecords.ttl,
isActive: dnsRecords.isActive,
isAutoIP: dnsRecords.isAutoIP,
notes: dnsRecords.notes,
providerId: dnsRecords.providerId,
lastUpdated: dnsRecords.lastUpdated,
createdAt: dnsRecords.createdAt
});
return newRecord;
}
async updateDnsRecord(id: string, recordData: Partial<InsertDnsRecord>): Promise<DnsRecord | undefined> {
// Filter out the proxied field if it exists
const { proxied, ...filteredData } = recordData as any;
const [updatedRecord] = await db.update(dnsRecords)
.set({ ...recordData, lastUpdated: new Date() })
.set({ ...filteredData, lastUpdated: new Date() })
.where(eq(dnsRecords.id, id))
.returning();
.returning({
id: dnsRecords.id,
domainId: dnsRecords.domainId,
name: dnsRecords.name,
type: dnsRecords.type,
content: dnsRecords.content,
ttl: dnsRecords.ttl,
isActive: dnsRecords.isActive,
isAutoIP: dnsRecords.isAutoIP,
notes: dnsRecords.notes,
providerId: dnsRecords.providerId,
lastUpdated: dnsRecords.lastUpdated,
createdAt: dnsRecords.createdAt
});
return updatedRecord;
}