Add debug util for gateway

Signed-off-by: Arnob kumar saha <[email protected]>

Author: ArnobKumarSaha

go.mod

@@ -0,0 +1,41 @@
+/*
+Copyright AppsCode Inc. and Contributors
+
+Licensed under the AppsCode Community License 1.0.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    https://github.com/appscode/licenses/raw/1.0.0/AppsCode-Community-1.0.0.md
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package debug
+
+import (
+	"go.bytebuilders.dev/cli/pkg/cmds/debug/gateway"
+
+	"github.com/spf13/cobra"
+	"k8s.io/cli-runtime/pkg/genericclioptions"
+	cmdutil "k8s.io/kubectl/pkg/cmd/util"
+)
+
+func NewCmdDebug() *cobra.Command {
+	cmd := &cobra.Command{
+		Use:               "debug",
+		Short:             "Debug utilities",
+		DisableAutoGenTag: true,
+	}
+
+	kubeConfigFlags := genericclioptions.NewConfigFlags(true).WithDeprecatedPasswordFlag()
+	matchVersionKubeConfigFlags := cmdutil.NewMatchVersionFlags(kubeConfigFlags)
+	f := cmdutil.NewFactory(matchVersionKubeConfigFlags)
+
+	cmd.AddCommand(gateway.NewCmdGateway(f))
+
+	return cmd
+}

go.sum

@@ -0,0 +1,78 @@
+/*
+Copyright AppsCode Inc. and Contributors
+
+Licensed under the AppsCode Community License 1.0.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    https://github.com/appscode/licenses/raw/1.0.0/AppsCode-Community-1.0.0.md
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package gateway
+
+import (
+	"context"
+	"fmt"
+	"os"
+	"path"
+
+	catalogapi "go.bytebuilders.dev/catalog/api/catalog/v1alpha1"
+
+	"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
+	"k8s.io/apimachinery/pkg/runtime"
+	"k8s.io/apimachinery/pkg/runtime/schema"
+)
+
+type BindingSpec struct {
+	SourceRef SourceRef `json:"sourceRef,omitempty" yaml:"sourceRef,omitempty"`
+}
+
+type SourceRef struct {
+	Name      string `json:"name,omitempty" yaml:"name,omitempty"`
+	Namespace string `json:"namespace,omitempty" yaml:"namespace,omitempty"`
+}
+
+type Binding struct {
+	Spec BindingSpec `json:"spec,omitempty" yaml:"spec,omitempty"`
+}
+
+func (g *gatewayOpts) collectBindings() error {
+	var uns unstructured.UnstructuredList
+	uns.SetGroupVersionKind(schema.GroupVersionKind{
+		Group:   catalogapi.GroupVersion.Group,
+		Version: catalogapi.GroupVersion.Version,
+		Kind:    g.getKindFromResource(g.db.resource) + "Binding",
+	})
+
+	if err := g.kc.List(context.Background(), &uns); err != nil {
+		return err
+	}
+
+	dirBindings := path.Join(g.dir, yamlsDir, bindingsDir)
+	if err := os.MkdirAll(dirBindings, dirPerm); err != nil {
+		return err
+	}
+
+	for _, b := range uns.Items {
+		var binding Binding
+		if err := runtime.DefaultUnstructuredConverter.FromUnstructured(b.Object, &binding); err != nil {
+			return fmt.Errorf("failed to unmarshal binding %s: %w", b.GetName(), err)
+		}
+
+		src := binding.Spec.SourceRef
+		if src.Name != g.db.name || src.Namespace != g.db.namespace {
+			continue
+		}
+		if err := writeYaml(&b, dirBindings); err != nil {
+			return err
+		}
+	}
+
+	return nil
+}

pkg/cmds/debug/debug.go

@@ -0,0 +1,93 @@
+/*
+Copyright AppsCode Inc. and Contributors
+
+Licensed under the AppsCode Community License 1.0.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    https://github.com/appscode/licenses/raw/1.0.0/AppsCode-Community-1.0.0.md
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package gateway
+
+import (
+	"context"
+	"os"
+	"path"
+
+	acmev1 "github.com/cert-manager/cert-manager/pkg/apis/acme/v1"
+	certv1 "github.com/cert-manager/cert-manager/pkg/apis/certmanager/v1"
+	"sigs.k8s.io/controller-runtime/pkg/client"
+)
+
+func (g *gatewayOpts) collectCerts() error {
+	dirCerts := path.Join(g.dir, yamlsDir, certsDir)
+	err := os.MkdirAll(dirCerts, dirPerm)
+	if err != nil {
+		return err
+	}
+
+	var list certv1.CertificateList
+	err = g.kc.List(context.TODO(), &list, client.InNamespace(g.hr.Namespace))
+	if err != nil {
+		return err
+	}
+	for _, item := range list.Items {
+		err = writeYaml(&item, dirCerts)
+		if err != nil {
+			return err
+		}
+	}
+	if err := g.collectOrders(); err != nil {
+		return err
+	}
+	return g.collectChallenges()
+}
+
+func (g *gatewayOpts) collectOrders() error {
+	dirOrders := path.Join(g.dir, yamlsDir, ordersDir)
+	err := os.MkdirAll(dirOrders, dirPerm)
+	if err != nil {
+		return err
+	}
+
+	var list acmev1.OrderList
+	err = g.kc.List(context.TODO(), &list, client.InNamespace(g.hr.Namespace))
+	if err != nil {
+		return err
+	}
+	for _, item := range list.Items {
+		err = writeYaml(&item, dirOrders)
+		if err != nil {
+			return err
+		}
+	}
+	return nil
+}
+
+func (g *gatewayOpts) collectChallenges() error {
+	dirChallenges := path.Join(g.dir, yamlsDir, challengesDir)
+	err := os.MkdirAll(dirChallenges, dirPerm)
+	if err != nil {
+		return err
+	}
+
+	var list acmev1.ChallengeList
+	err = g.kc.List(context.TODO(), &list, client.InNamespace(g.hr.Namespace))
+	if err != nil {
+		return err
+	}
+	for _, item := range list.Items {
+		err = writeYaml(&item, dirChallenges)
+		if err != nil {
+			return err
+		}
+	}
+	return nil
+}

pkg/cmds/debug/gateway/binding.go

@@ -0,0 +1,87 @@
+/*
+Copyright AppsCode Inc. and Contributors
+
+Licensed under the AppsCode Community License 1.0.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    https://github.com/appscode/licenses/raw/1.0.0/AppsCode-Community-1.0.0.md
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package gateway
+
+import (
+	"fmt"
+	"io"
+	"net/http"
+	"net/url"
+	"os"
+	"path"
+
+	"gomodules.xyz/pointer"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"kmodules.xyz/client-go/tools/portforward"
+)
+
+func (g *gatewayOpts) collectConfigDump(podMeta metav1.ObjectMeta) error {
+	tunnel, err := g.forwardToPort(podMeta, "pods", pointer.IntP(19000))
+	if err != nil {
+		return err
+	}
+	defer tunnel.Close()
+
+	// curl http://10.42.0.82:19000/config_dump?resource%3D%26mask%3D%26name_regex%3D > out.yaml
+	u := &url.URL{
+		Scheme: "http",
+		Host:   fmt.Sprintf("localhost:%d", tunnel.Local),
+		Path:   "/config_dump",
+	}
+	q := u.Query()
+	q.Set("resource", "")
+	q.Set("mask", "")
+	q.Set("name_regex", "")
+	u.RawQuery = q.Encode()
+	resp, err := http.Get(u.String())
+	if err != nil {
+		fmt.Printf("curl failed: %v\n", err)
+		return err
+	}
+	defer resp.Body.Close()
+	if resp.StatusCode != http.StatusOK {
+		return fmt.Errorf("unexpected status code %d", resp.StatusCode)
+	}
+
+	outputFile := path.Join(g.dir, logsDir, fmt.Sprintf("%s.config_dump.json", podMeta.Name))
+	f, err := os.Create(outputFile)
+	if err != nil {
+		return fmt.Errorf("cannot create %s: %v", outputFile, err)
+	}
+	defer f.Close()
+	if _, err := io.Copy(f, resp.Body); err != nil {
+		return fmt.Errorf("cannot write %s: %v", outputFile, err)
+	}
+	return nil
+}
+
+func (g *gatewayOpts) forwardToPort(podMeta metav1.ObjectMeta, resource string, port *int) (*portforward.Tunnel, error) {
+	tunnel := portforward.NewTunnel(
+		portforward.TunnelOptions{
+			Client:    g.kubeClient.CoreV1().RESTClient(),
+			Config:    g.config,
+			Resource:  resource,
+			Namespace: podMeta.Namespace,
+			Name:      podMeta.Name,
+			Remote:    *port,
+		})
+	if err := tunnel.ForwardPort(); err != nil {
+		return nil, err
+	}
+
+	return tunnel, nil
+}