refactor: save app icon to oss

[0xff-dev]

What type of PR is this?

/kind feature

What this PR does / why we need it

refactor: save app icon to oss

Which issue(s) this PR fixes

Fix https://github.com/kubeagi/arcadia/issues/960

Special notes for your reviewer

package main

import (
    "bytes"
    "context"
    "crypto/tls"
    "encoding/base64"
    "flag"
    "fmt"
    "net/http"
    "path/filepath"
    "sync"

    v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    "k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
    "k8s.io/apimachinery/pkg/runtime/schema"
    "k8s.io/client-go/dynamic"
    "k8s.io/client-go/tools/clientcmd"
    "k8s.io/client-go/util/homedir"

    "github.com/minio/minio-go/v7"
    "github.com/minio/minio-go/v7/pkg/credentials"
)

var (
    endpoint = flag.String("api", "minio-api.172.22.96.167.nip.io", "minio api service address, such as minio-api.172.22.96.167.nip.io")
    username = flag.String("u", "admin", "username")
    password = flag.String("p", "", "password")
)

func main() {
    var kubeconfig *string
    if home := homedir.HomeDir(); home != "" {
        kubeconfig = flag.String("kubeconfig", filepath.Join(home, ".kube", "config"), "(optional) absolute path to the kubeconfig file")
    } else {
        kubeconfig = flag.String("kubeconfig", "", "absolute path to the kubeconfig file")
    }
    flag.Parse()

    tp := http.Transport{
        TLSClientConfig: &tls.Config{
            InsecureSkipVerify: true,
        },
    }
    minioClient, err := minio.New(*endpoint, &minio.Options{
        Creds:     credentials.NewStaticV4(*username, *password, ""),
        Secure:    true,
        Transport: &tp,
    })
    if err != nil {
        panic(err)
    }
    cfg, err := clientcmd.BuildConfigFromFlags("", *kubeconfig)
    if err != nil {
        panic(err)
    }

    dynamicClient := dynamic.NewForConfigOrDie(cfg)

    namespaceList, err := dynamicClient.Resource(schema.GroupVersionResource{Group: "", Version: "v1", Resource: "namespaces"}).List(context.TODO(), v1.ListOptions{})
    if err != nil {
        panic(err)
    }

    gvr := schema.GroupVersionResource{
        Group:    "arcadia.kubeagi.k8s.com.cn",
        Version:  "v1alpha1",
        Resource: "applications",
    }

    var wg sync.WaitGroup
    for _, i := range namespaceList.Items {
        wg.Add(1)
        go func(namespace string) {
            defer wg.Done()
            appList, err := dynamicClient.Resource(gvr).List(context.TODO(), v1.ListOptions{})
            if err != nil {
                fmt.Printf("[Error] in namespace %s, failed to list apps %s\n", namespace, err)
                return
            }

            for _, app := range appList.Items {
                icon, found, err := unstructured.NestedString(app.Object, "spec", "icon")
                if err != nil || !found {
                    fmt.Printf("[Error] %s/%s not found path spec.icon or error %s\n", app.GetNamespace(), app.GetName(), err)
                    continue
                }
                bs, err := ParseBase64ImageBytes(icon)
                if err != nil {
                    fmt.Printf("[Error] %s/%s failed to parse base64 image\n", app.GetNamespace(), app.GetName())
                    continue
                }
                name := fmt.Sprintf("application/%s/icon/%s", app.GetName(), app.GetName())
                _, err = minioClient.PutObject(context.TODO(), namespace, name, bytes.NewReader(bs), int64(len(bs)), minio.PutObjectOptions{})
                if err != nil {
                    fmt.Printf("[Error] %s/%s failed to upload icon to minio error %s\n", app.GetNamespace(), app.GetName(), err)
                    continue
                }
                fmt.Printf("[Success] %s/%s migration successful\n\n", app.GetNamespace(), app.GetName())
            }
        }(i.GetName())
    }
    wg.Wait()
    fmt.Println("Done")
}

func ParseBase64ImageBytes(img string) ([]byte, error) {
    i := 0
    for ; i < len(img) && img[i] != ','; i++ {
    }
    cut := img[i+1:]
    return base64.StdEncoding.DecodeString(cut)
}

[bjwswang]

@0xff-dev Please make sure the gptstore support this icon link.