1import { getKlusterCtx } from '../k8sF/ctxF/klusterCtxF.mts'
2import { cfFetch, getCfHeaders } from './cfFetchAI.mts'
3import { betLog } from '../../sharedF/betterConsLogF.mts'
4
5export const cleanupExplicitWcDns = async (hostname: string) => {
6  const {cfApiKeySecretName} = getKlusterCtx()
7
8  const headers = getCfHeaders({cfApiKeySecretName, required: false})
9  if (!headers) return
10
11  const zoneName = hostname.split('.').slice(-2).join('.')
12  const zones = await cfFetch('/zones', headers)
13  const zone = zones.find((z: any) => z.name === zoneName)
14  if (!zone) return
15
16  const allRecords = await cfFetch(`/zones/${zone.id}/dns_records?per_page=1000`, headers)
17  const matchNames = [hostname, `a-${hostname}`, `cname-${hostname}`]
18  const txtOwnerRecords = allRecords.filter((r: any) =>
19    r.type === 'TXT' && r.content?.includes('heritage=external-dns') && matchNames.includes(r.name)
20  )
21  const aRecords = allRecords.filter((r: any) =>
22    (r.type === 'A' || r.type === 'CNAME') && r.name === hostname
23  )
24  const toDelete = [...txtOwnerRecords, ...aRecords]
25
26  if (!toDelete.length) return
27
28  for (const record of toDelete) {
29    await cfFetch(`/zones/${zone.id}/dns_records/${record.id}`, headers, {method: 'DELETE'})
30  }
31  betLog({cleanupExplicitWcDns: hostname, deletedRecords: toDelete.length})
32}
33