chore/ingress-additions

ftplugin/k8s_ingresses.lua

@@ -1,4 +1,5 @@
 local api = vim.api
+local ResourceBuilder = require("kubectl.resourcebuilder")
 local ingresses_view = require("kubectl.views.ingresses")
 local loop = require("kubectl.utils.loop")
 local overview_view = require("kubectl.views.overview")
@@ -13,6 +14,58 @@ local function set_keymap(bufnr)
       overview_view.View()
     end,
   })
+  api.nvim_buf_set_keymap(bufnr, "n", "gx", "", {
+    noremap = true,
+    silent = true,
+    desc = "Open host in browser",
+    callback = function()
+      local name, ns = ingresses_view.getCurrentSelection()
+      ResourceBuilder:new("ingress_host")
+        :setCmd({ "get", "ingress", name, "-n", ns, "-o", "json" }, "kubectl")
+        :fetchAsync(function(self)
+          self:decodeJson()
+          local data = self.data
+
+          -- determine port
+          local port = ""
+          if
+            data.spec.rules
+            and data.spec.rules[1]
+            and data.spec.rules[1].http
+            and data.spec.rules[1].http.paths
+            and data.spec.rules[1].http.paths[1]
+            and data.spec.rules[1].http.paths[1].backend
+          then
+            local backend = data.spec.rules[1].http.paths[1].backend
+            port = backend.service.port.number or backend.servicePort or "80"
+          end
+
+          -- determine host
+          local host = ""
+          if data.spec.rules and data.spec.rules[1] and data.spec.rules[1].host then
+            host = data.spec.rules[1].host
+          else
+            if data.status and data.status.loadBalancer and data.status.loadBalancer.ingress then
+              local ingress = data.status.loadBalancer.ingress[1]
+              if ingress.hostname then
+                host = ingress.hostname
+              elseif ingress.ip then
+                host = ingress.ip
+              end
+            else
+              return
+            end
+          end
+          local proto = port == "443" and "https" or "http"
+          if port ~= "443" and port ~= "80" then
+            port = ":" .. port
+          end
+          local final_url = string.format("%s://%s%s", proto, host, port)
+          vim.notify("Opening " .. final_url)
+          vim.ui.open(final_url)
+        end)
+    end,
+  })
 end
 
 --- Initialize the module

lua/kubectl/views/ingresses/definition.lua

@@ -5,6 +5,9 @@ local M = {
   display_name = "Ingresses",
   ft = "k8s_ingresses",
   url = { "{{BASE}}/apis/networking.k8s.io/v1/{{NAMESPACE}}ingresses?pretty=false" },
+  hints = {
+    { key = "<Plug>(kubectl.browse)", desc = "browse", long_desc = "Open host in browser" },
+  },
 }
 
 local function get_ports(row)
@@ -27,6 +30,9 @@ local function get_ports(row)
 end
 
 local function get_hosts(row)
+  if not row.spec or not row.spec.rules then
+    return ""
+  end
   local hosts = {}
 
   for _, rule in ipairs(row.spec.rules) do
@@ -55,6 +61,12 @@ local function get_address(row)
   return table.concat(addresses, ", ")
 end
 
+local function get_class(row)
+  return row.spec.ingressClassName
+    or row.metadata.annotations and row.metadata.annotations["kubernetes.io/ingress.class"]
+    or ""
+end
+
 function M.processRow(rows)
   local data = {}
 
@@ -69,7 +81,7 @@ function M.processRow(rows)
       data[i] = {
         namespace = row.metadata.namespace,
         name = row.metadata.name,
-        class = row.spec.ingressClassName,
+        class = get_class(row),
         hosts = get_hosts(row),
         address = get_address(row),
         ports = get_ports(row),