Finish DNS creation for Cloudflare

iac/src/main/infra/dns.cljs

@@ -1,22 +1,57 @@
-(ns dns
+(ns infra.dns
   (:require
+   [clojure.string :as str]
    ["@pulumi/pulumi" :as pulumi]
+   ["@pulumi/kubernetes" :as k8s]
    ["@pulumi/vault" :as vault]
-  ["@pulumi/cloudflare" :as cloudflare]))
+   ["@pulumi/cloudflare" :as cloudflare]
+   ["@pulumi/command/local" :as local]))
 
-(defn setup-dns [zone-id vault-provider]
+(defn get-record-type
-  (let [dns-secrets (.getSecret (.-generic vault)
+  "Determines the DNS record type (A or AAAA) based on IP address format."
-                                (clj->js {:path "secret/dns-entries"})
+  [ip-address]
+  (println ip-address)
+  (if (.includes ip-address ":")
+    "AAAA"
+    "A"))
+
+(defn- get-node-ips [] 
+  (str "kubectl get nodes -o jsonpath='{range .items[*]}{.status.addresses[?(@.type==\"ExternalIP\")].address}{\"\\n\"}{end}'"))
+
+(defn setup-dns [cfg vault-provider]
+  (let [get-node-ips (local/Command.
+                      "get-node-ips"
+                      (clj->js {:create (get-node-ips)
+                                :environment {:KUBECONFIG "./kubeconfig.yaml"}}))         
+        token (.requireSecret cfg "apiToken")
+        cloudflare-provider (new cloudflare/Provider "cloudflare-provider"
+                                 (clj->js {:apiToken token}))
+        dns-configs-secret (.getSecret (.-generic vault)
+                                       (clj->js {:path "secret/dns"})
                                        (clj->js {:provider  vault-provider}))
-        dns-entries-map (.-dataJson dns-secrets)
+        
-        ]
+      
-    (pulumi/all [dns-entries-map]
+         node-ips-output (.-stdout get-node-ips)]
-                (fn [[entries]]
+      
-                  (doall
+ (.apply node-ips-output
-                   (for [[name ip] entries]
+        (fn [command-output]
-                     (new cloudflare/Record (str "dns-record-" name)
+          (let [node-ips (-> command-output
+                             str/split-lines
+                             (->> (map #(first (str/split % #" ")))
+                                  (filter seq)))]
+            (.then dns-configs-secret
+                   (fn [secret-data]
+                     (let [hostname-to-zone (-> (.-data secret-data)
+                                                (js->clj :keywordize-keys true))]
+                       (vec
+                        (for [[hostname zone-id] hostname-to-zone
+                              [index ip] (map-indexed vector node-ips)
+                              :when (and hostname zone-id ip)]
+                          (new cloudflare/DnsRecord
+                               (str "dns-" (name hostname) "-node-" index)
                                (clj->js {:zoneId zone-id
-                                    :name name
+                                         :name (str hostname)
-                                    :value ip
+                                         :content ip
-                                    :type "A" ;; Need to check the IP and determine if we should use AAAA or A
+                                         :type (get-record-type ip)
-                                    :ttl 300}))))))))
+                                         :ttl 300})
+                               (clj->js {:provider cloudflare-provider}))))))))))))