Merge pull request #88 from k8sgpt-ai/release-please--branches--main

chore(main): release 0.0.8

.goreleaser.yaml

@@ -13,6 +13,8 @@ builds:
       - linux
       - windows
       - darwin
+    ldflags:
+          - -s -w -X main.version={{.Version}}
 
 archives:
   - format: tar.gz

.release-please-manifest.json

@@ -1 +1 @@
-{".":"0.0.6"}
+{".":"0.0.8"}

CHANGELOG.md

@@ -1,5 +1,30 @@
 # Changelog
 
+## [0.0.8](https://github.com/k8sgpt-ai/k8sgpt/compare/v0.0.7...v0.0.8) (2023-03-27)
+
+
+### Features
+
+* add generation of api-keys to cli ([#87](https://github.com/k8sgpt-ai/k8sgpt/issues/87)) ([1c653ec](https://github.com/k8sgpt-ai/k8sgpt/commit/1c653ecc51b74a2f51ce7240ffaee0fe75f2e8dd))
+* add generation of api-keys to cli ([#87](https://github.com/k8sgpt-ai/k8sgpt/issues/87)) ([bb2db5c](https://github.com/k8sgpt-ai/k8sgpt/commit/bb2db5ca7923e2049308d1674bb59ae8154e415c))
+* addition of simple language support ([c3008c5](https://github.com/k8sgpt-ai/k8sgpt/commit/c3008c5e75acbb35d864135199ca9c034f59e35f))
+* version ([0c231d6](https://github.com/k8sgpt-ai/k8sgpt/commit/0c231d635e7ad71609bb80abac5e0ade15ffb860))
+* version ([931f072](https://github.com/k8sgpt-ai/k8sgpt/commit/931f072e0ab0cfd77f261b0b719cf0819f85b951))
+
+## [0.0.7](https://github.com/k8sgpt-ai/k8sgpt/compare/v0.0.6...v0.0.7) (2023-03-27)
+
+
+### Features
+
+* wip fixing missing details ([0852c65](https://github.com/k8sgpt-ai/k8sgpt/commit/0852c658ded33b91e1d323bd8cba6ac6935cb525))
+
+
+### Other
+
+* moved code ([a194d4a](https://github.com/k8sgpt-ai/k8sgpt/commit/a194d4a509329cbc5a00724b0a19c75726c2a0d3))
+* return success on no issues ([009f47c](https://github.com/k8sgpt-ai/k8sgpt/commit/009f47c8e8ee6d3ce9b36110c36edae97690c949))
+* updated readme ([06fb807](https://github.com/k8sgpt-ai/k8sgpt/commit/06fb8073dc5b0b5bd9f8d115d9ec206ab238d68f))
+
 ## [0.0.6](https://github.com/k8sgpt-ai/k8sgpt/compare/v0.0.6...v0.0.6) (2023-03-26)
 
 

README.md

@@ -3,18 +3,24 @@
   <img alt="Text changing depending on mode. Light: 'So light!' Dark: 'So dark!'" src="./images/banner-black.png" width="600px;">
 </picture>
 
-_Install it now_
+`k8sgpt` is a tool for scanning your kubernetes clusters, diagnosing and triaging issues in simple english.
+
+It has SRE experience codified into it's analyzers and helps to pull out the most relevent information to enrich it with AI.
+
+## Quick Start
 
 ```
 brew tap k8sgpt-ai/k8sgpt
 brew install k8sgpt
 ```
 
-`k8sgpt` is a tool for scanning your kubernetes clusters, diagnosing and triaging issues in simple english.
+* Currently the default AI provider is OpenAI, you will need to generate an API key from [OpenAI](https://openai.com)
+  * You can do this by running `k8sgpt generate` to open a browser link to generate it 
+* Run `k8sgpt auth` to set it in k8sgpt.
+* Run `k8sgpt analyze` to run a scan.
+* And use `k8sgpt analyze --explain` to get a more detailed explanation of the issues.
 
-It has SRE experience codified into it's analyzers and helps to pull out the most relevent information to enrich it with AI.
-
-<img src="images/image.png" width=650px; />
+<img src="images/demo4.gif" width=650px; />
 
 ## Analyzers
 
@@ -31,11 +37,45 @@ K8sGPT uses analyzers to triage and diagnose issues in your cluster. It has a se
 ## Usage
 
 ```
-# Ensure KUBECONFIG env is set to an active Kubernetes cluster
+Usage:
+  k8sgpt [command]
+
+Available Commands:
+  analyze     This command will find problems within your Kubernetes cluster
+  auth        Authenticate with your chosen backend
+  completion  Generate the autocompletion script for the specified shell
+  generate    Generate Key for your chosen backend (opens browser)
+  help        Help about any command
+  version     Print the version number of k8sgpt
+
+Flags:
+      --config string       config file (default is $HOME/.k8sgpt.git.yaml)
+  -h, --help                help for k8sgpt
+      --kubeconfig string   Path to a kubeconfig. Only required if out-of-cluster.
+      --master string       The address of the Kubernetes API server. Overrides any value in kubeconfig. Only required if out-of-cluster.
+  -t, --toggle              Help message for toggle
+
+Use "k8sgpt [command] --help" for more information about a command.
+```
+
+_Run a scan with the default analyzers_
+
+```
+k8sgpt generate
 k8sgpt auth
-k8sgpt find problems 
-# for more detail
-k8s find problems --explain
+k8sgpt analyze --explain
+```
+
+_Filter on resource_
+
+```
+k8sgpt analyze --explain --resource=Service
+```
+
+_Output to JSON_
+
+```
+k8sgpt analyze --explain --resource=Service --output=json
 ```
 
 ## Upcoming major milestones

cmd/analyze/analyze.go

@@ -5,19 +5,23 @@ import (
 	"encoding/json"
 	"fmt"
 	"os"
+	"strings"
 
 	"github.com/fatih/color"
 	"github.com/k8sgpt-ai/k8sgpt/pkg/ai"
 	"github.com/k8sgpt-ai/k8sgpt/pkg/analyzer"
 	"github.com/k8sgpt-ai/k8sgpt/pkg/kubernetes"
+	"github.com/schollz/progressbar/v3"
 	"github.com/spf13/cobra"
 	"github.com/spf13/viper"
 )
 
 var (
-	explain bool
-	backend string
-	output  string
+	explain  bool
+	backend  string
+	output   string
+	filters  []string
+	language string
 )
 
 // AnalyzeCmd represents the problems command
@@ -50,7 +54,7 @@ var AnalyzeCmd = &cobra.Command{
 		switch backendType {
 		case "openai":
 			aiClient = &ai.OpenAIClient{}
-			if err := aiClient.Configure(token); err != nil {
+			if err := aiClient.Configure(token, language); err != nil {
 				color.Red("Error: %v", err)
 				os.Exit(1)
 			}
@@ -68,10 +72,51 @@ var AnalyzeCmd = &cobra.Command{
 			color.Red("Error: %v", err)
 			os.Exit(1)
 		}
-		for n, analysis := range *analysisResults {
+		// Removed filtered results from slice
+		if len(filters) > 0 {
+			var filteredResults []analyzer.Analysis
+			for _, analysis := range *analysisResults {
+				for _, filter := range filters {
+					if strings.Contains(analysis.Kind, filter) {
+						filteredResults = append(filteredResults, analysis)
+					}
+				}
+			}
+			analysisResults = &filteredResults
+		}
+
+		var bar *progressbar.ProgressBar
+		if len(*analysisResults) > 0 {
+			bar = progressbar.Default(int64(len(*analysisResults)))
+		} else {
+			color.Green("{ \"status\": \"OK\" }")
+			os.Exit(0)
+		}
+
+		// This variable is used to store the results that will be printed
+		// It's necessary because the heap memory is lost when the function returns
+		var printOutput []analyzer.Analysis
+
+		for _, analysis := range *analysisResults {
+
+			if explain {
+				parsedText, err := analyzer.ParseViaAI(ctx, aiClient, analysis.Error)
+				if err != nil {
+					color.Red("Error: %v", err)
+					continue
+				}
+				analysis.Details = parsedText
+				bar.Add(1)
+			}
+			printOutput = append(printOutput, analysis)
+		}
+
+		// print results
+		for n, analysis := range printOutput {
 
 			switch output {
 			case "json":
+				analysis.Error = analysis.Error[0:]
 				j, err := json.Marshal(analysis)
 				if err != nil {
 					color.Red("Error: %v", err)
@@ -79,19 +124,24 @@ var AnalyzeCmd = &cobra.Command{
 				}
 				fmt.Println(string(j))
 			default:
-				fmt.Printf("%s %s(%s): %s \n%s\n", color.CyanString("%d", n), color.YellowString(analysis.Name), color.CyanString(analysis.ParentObject), color.RedString(analysis.Error), color.GreenString(analysis.Details))
+				fmt.Printf("%s %s(%s): %s \n%s\n", color.CyanString("%d", n),
+					color.YellowString(analysis.Name), color.CyanString(analysis.ParentObject),
+					color.RedString(analysis.Error[0]), color.GreenString(analysis.Details))
 			}
 		}
-
 	},
 }
 
 func init() {
 
+	// array of strings flag
+	AnalyzeCmd.Flags().StringSliceVarP(&filters, "filter", "f", []string{}, "Filter for these analzyers (e.g. Pod,PersistentVolumeClaim,Service,ReplicaSet)")
+
 	AnalyzeCmd.Flags().BoolVarP(&explain, "explain", "e", false, "Explain the problem to me")
 	// add flag for backend
 	AnalyzeCmd.Flags().StringVarP(&backend, "backend", "b", "openai", "Backend AI provider")
 	// output as json
 	AnalyzeCmd.Flags().StringVarP(&output, "output", "o", "text", "Output format (text, json)")
-
+	// add language options for output
+	AnalyzeCmd.Flags().StringVarP(&language, "language", "l", "english", "Languages to use for AI (e.g. 'English', 'Spanish', 'French', 'German', 'Italian', 'Portuguese', 'Dutch', 'Russian', 'Chinese', 'Japanese', 'Korean')")
 }

cmd/generate/generate.go

@@ -0,0 +1,62 @@
+package generate
+
+import (
+	"fmt"
+	"github.com/fatih/color"
+	"github.com/spf13/cobra"
+	"github.com/spf13/viper"
+	"os/exec"
+	"runtime"
+	"time"
+)
+
+var (
+	backend string
+)
+
+// generateCmd represents the auth command
+var GenerateCmd = &cobra.Command{
+	Use:   "generate",
+	Short: "Generate Key for your chosen backend (opens browser)",
+	Long:  `Opens your browser to generate a key for your chosen backend.`,
+	Run: func(cmd *cobra.Command, args []string) {
+
+		backendType := viper.GetString("backend_type")
+		if backendType == "" {
+			// Set the default backend
+			backend = "openai"
+		}
+		// override the default backend if a flag is provided
+		if backend != "" {
+			backendType = backend
+		}
+		fmt.Println("")
+		color.Green("Opening: https://beta.openai.com/account/api-keys to generate a key for %s", backendType)
+		color.Green("Please copy the generated key and run `k8sgpt auth` to add it to your config file")
+		fmt.Println("")
+		time.Sleep(5 * time.Second)
+		openbrowser("https://beta.openai.com/account/api-keys")
+	},
+}
+
+func init() {
+	// add flag for backend
+	GenerateCmd.Flags().StringVarP(&backend, "backend", "b", "openai", "Backend AI provider")
+}
+
+func openbrowser(url string) {
+	var err error
+	switch runtime.GOOS {
+	case "linux":
+		err = exec.Command("xdg-open", url).Start()
+	case "windows":
+		err = exec.Command("rundll32", "url.dll,FileProtocolHandler", url).Start()
+	case "darwin":
+		err = exec.Command("open", url).Start()
+	default:
+		err = fmt.Errorf("unsupported platform")
+	}
+	if err != nil {
+		fmt.Println(err)
+	}
+}

cmd/root.go

@@ -1,6 +1,7 @@
 package cmd
 
 import (
+	"github.com/k8sgpt-ai/k8sgpt/cmd/generate"
 	"os"
 
 	"github.com/fatih/color"
@@ -15,6 +16,7 @@ var (
 	cfgFile    string
 	masterURL  string
 	kubeconfig string
+	version    string
 )
 
 // rootCmd represents the base command when called without any subcommands
@@ -29,7 +31,8 @@ var rootCmd = &cobra.Command{
 
 // Execute adds all child commands to the root command and sets flags appropriately.
 // This is called by main.main(). It only needs to happen once to the rootCmd.
-func Execute() {
+func Execute(v string) {
+	version = v
 	err := rootCmd.Execute()
 	if err != nil {
 		os.Exit(1)
@@ -44,6 +47,7 @@ func init() {
 	// will be global for your application.
 	rootCmd.AddCommand(auth.AuthCmd)
 	rootCmd.AddCommand(analyze.AnalyzeCmd)
+	rootCmd.AddCommand(generate.GenerateCmd)
 	rootCmd.PersistentFlags().StringVar(&cfgFile, "config", "", "config file (default is $HOME/.k8sgpt.git.yaml)")
 	rootCmd.PersistentFlags().StringVar(&masterURL, "master", "", "The address of the Kubernetes API server. Overrides any value in kubeconfig. Only required if out-of-cluster.")
 	rootCmd.PersistentFlags().StringVar(&kubeconfig, "kubeconfig", "", "Path to a kubeconfig. Only required if out-of-cluster.")

cmd/version.go

@@ -0,0 +1,19 @@
+package cmd
+
+import (
+	"github.com/spf13/cobra"
+)
+
+// versionCmd represents the version command
+var versionCmd = &cobra.Command{
+	Use:   "version",
+	Short: "Print the version number of k8sgpt",
+	Long:  `All software has versions. This is k8sgpt's`,
+	Run: func(cmd *cobra.Command, args []string) {
+		cmd.Printf("k8sgpt version %s", version)
+	},
+}
+
+func init() {
+	rootCmd.AddCommand(versionCmd)
+}

go.mod

@@ -3,9 +3,9 @@ module github.com/k8sgpt-ai/k8sgpt
 go 1.20
 
 require (
-	github.com/briandowns/spinner v1.23.0
 	github.com/fatih/color v1.15.0
 	github.com/sashabaranov/go-openai v1.5.7
+	github.com/schollz/progressbar/v3 v3.13.1
 	github.com/spf13/cobra v1.6.1
 	github.com/spf13/viper v1.15.0
 	golang.org/x/term v0.6.0
@@ -36,20 +36,23 @@ require (
 	github.com/mailru/easyjson v0.7.6 // indirect
 	github.com/mattn/go-colorable v0.1.13 // indirect
 	github.com/mattn/go-isatty v0.0.17 // indirect
+	github.com/mattn/go-runewidth v0.0.14 // indirect
+	github.com/mitchellh/colorstring v0.0.0-20190213212951-d06e56a500db // indirect
 	github.com/mitchellh/mapstructure v1.5.0 // indirect
 	github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd // indirect
 	github.com/modern-go/reflect2 v1.0.2 // indirect
 	github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822 // indirect
 	github.com/pelletier/go-toml/v2 v2.0.6 // indirect
+	github.com/rivo/uniseg v0.4.4 // indirect
 	github.com/spf13/afero v1.9.3 // indirect
 	github.com/spf13/cast v1.5.0 // indirect
 	github.com/spf13/jwalterweatherman v1.1.0 // indirect
 	github.com/spf13/pflag v1.0.5 // indirect
 	github.com/subosito/gotenv v1.4.2 // indirect
-	golang.org/x/net v0.7.0 // indirect
+	golang.org/x/net v0.8.0 // indirect
 	golang.org/x/oauth2 v0.0.0-20221014153046-6fdb5e3db783 // indirect
 	golang.org/x/sys v0.6.0 // indirect
-	golang.org/x/text v0.7.0 // indirect
+	golang.org/x/text v0.8.0 // indirect
 	golang.org/x/time v0.1.0 // indirect
 	google.golang.org/appengine v1.6.7 // indirect
 	google.golang.org/protobuf v1.28.1 // indirect

go.sum

@@ -38,8 +38,6 @@ cloud.google.com/go/storage v1.14.0/go.mod h1:GrKmX003DSIwi9o29oFT7YDnHYwZoctc3f
 dmitri.shuralyov.com/gpu/mtl v0.0.0-20190408044501-666a987793e9/go.mod h1:H6x//7gZCb22OMCxBHrMx7a5I7Hp++hsVxbQ4BYO7hU=
 github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU=
 github.com/BurntSushi/xgb v0.0.0-20160522181843-27f122750802/go.mod h1:IVnqGOEym/WlBOVXweHU+Q+/VP0lqqI8lqeDx9IjBqo=
-github.com/briandowns/spinner v1.23.0 h1:alDF2guRWqa/FOZZYWjlMIx2L6H0wyewPxo/CH4Pt2A=
-github.com/briandowns/spinner v1.23.0/go.mod h1:rPG4gmXeN3wQV/TsAY4w8lPdIM6RX3yqeBQJSrbXjuE=
 github.com/census-instrumentation/opencensus-proto v0.2.1/go.mod h1:f6KPmirojxKA12rnyqOA5BBL4O983OfeGPqjHWSTneU=
 github.com/chzyer/logex v1.1.10/go.mod h1:+Ywpsq7O8HXn0nuIou7OrIPyXbp3wmkHB+jjWRnGsAI=
 github.com/chzyer/readline v0.0.0-20180603132655-2972be24d48e/go.mod h1:nSuG5e5PlCu98SY8svDHJxuZscDgtXS6KTTbou5AhLI=
@@ -164,6 +162,7 @@ github.com/json-iterator/go v1.1.12 h1:PV8peI4a0ysnczrg+LtxykD8LfKY9ML6u2jnxaEnr
 github.com/json-iterator/go v1.1.12/go.mod h1:e30LSqwooZae/UwlEbR2852Gd8hjQvJoHmT4TnhNGBo=
 github.com/jstemmer/go-junit-report v0.0.0-20190106144839-af01ea7f8024/go.mod h1:6v2b51hI/fHJwM22ozAgKL4VKDeJcHhJFhtBdhmNjmU=
 github.com/jstemmer/go-junit-report v0.9.1/go.mod h1:Brl9GWCQeLvo8nXZwPNNblvFj/XSXhF0NWZEnDohbsk=
+github.com/k0kubun/go-ansi v0.0.0-20180517002512-3bf9e2903213/go.mod h1:vNUNkEQ1e29fT/6vq2aBdFsgNPmy8qMdSay1npru+Sw=
 github.com/kisielk/errcheck v1.5.0/go.mod h1:pFxgyoBC7bSaBwPgfKdkLd5X25qrDl4LWUI2bnpBCr8=
 github.com/kisielk/gotool v1.0.0/go.mod h1:XhKaO+MFFWcvkIS/tQcRk01m1F5IRFswLeQ+oQHNcck=
 github.com/kr/fs v0.1.0/go.mod h1:FFnZGqtBN9Gxj7eW1uZ42v5BccTP0vu6NEaFoC2HwRg=
@@ -185,6 +184,10 @@ github.com/mattn/go-colorable v0.1.13/go.mod h1:7S9/ev0klgBDR4GtXTXX8a3vIGJpMovk
 github.com/mattn/go-isatty v0.0.16/go.mod h1:kYGgaQfpe5nmfYZH+SKPsOc2e4SrIfOl2e/yFXSvRLM=
 github.com/mattn/go-isatty v0.0.17 h1:BTarxUcIeDqL27Mc+vyvdWYSL28zpIhv3RoTdsLMPng=
 github.com/mattn/go-isatty v0.0.17/go.mod h1:kYGgaQfpe5nmfYZH+SKPsOc2e4SrIfOl2e/yFXSvRLM=
+github.com/mattn/go-runewidth v0.0.14 h1:+xnbZSEeDbOIg5/mE6JF0w6n9duR1l3/WmbinWVwUuU=
+github.com/mattn/go-runewidth v0.0.14/go.mod h1:Jdepj2loyihRzMpdS35Xk/zdY8IAYHsh153qUoGf23w=
+github.com/mitchellh/colorstring v0.0.0-20190213212951-d06e56a500db h1:62I3jR2EmQ4l5rM/4FEfDWcRD+abF5XlKShorW5LRoQ=
+github.com/mitchellh/colorstring v0.0.0-20190213212951-d06e56a500db/go.mod h1:l0dey0ia/Uv7NcFFVbCLtqEBQbrT4OCwCSKTEv6enCw=
 github.com/mitchellh/mapstructure v1.5.0 h1:jeMsZIYE/09sWLaz43PL7Gy6RuMjD2eJVyuac5Z2hdY=
 github.com/mitchellh/mapstructure v1.5.0/go.mod h1:bFUtVrKA4DC2yAKiSyO/QUcy7e+RRV2QTWOzhPopBRo=
 github.com/modern-go/concurrent v0.0.0-20180228061459-e0a39a4cb421/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q=
@@ -205,17 +208,16 @@ github.com/pkg/sftp v1.13.1/go.mod h1:3HaPG6Dq1ILlpPZRO0HVMrsydcdLt6HRDccSgb87qR
 github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
 github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
 github.com/prometheus/client_model v0.0.0-20190812154241-14fe0d1b01d4/go.mod h1:xMI15A0UPsDsEKsMN9yxemIoYk6Tm2C1GtYGdfGttqA=
+github.com/rivo/uniseg v0.2.0/go.mod h1:J6wj4VEh+S6ZtnVlnTBMWIodfgj8LQOQFoIToxlJtxc=
+github.com/rivo/uniseg v0.4.4 h1:8TfxU8dW6PdqD27gjM8MVNuicgxIjxpm4K7x4jp8sis=
+github.com/rivo/uniseg v0.4.4/go.mod h1:FN3SvrM+Zdj16jyLfmOkMNblXMcoc8DfTHruCPUcx88=
 github.com/rogpeppe/go-internal v1.3.0/go.mod h1:M8bDsm7K2OlrFYOpmOWEs/qY81heoFRclV5y23lUDJ4=
 github.com/rogpeppe/go-internal v1.6.1 h1:/FiVV8dS/e+YqF2JvO3yXRFbBLTIuSDkuC7aBOAvL+k=
 github.com/russross/blackfriday/v2 v2.1.0/go.mod h1:+Rmxgy9KzJVeS9/2gXHxylqXiyQDYRxCVz55jmeOWTM=
-github.com/sashabaranov/go-openai v1.5.4 h1:I2K7JMIx/EC/mwT2fbypBzJ3OtwKNxaFg4jf3KOvXuc=
-github.com/sashabaranov/go-openai v1.5.4/go.mod h1:lj5b/K+zjTSFxVLijLSTDZuP7adOgerWeFyZLUhAKRg=
-github.com/sashabaranov/go-openai v1.5.5 h1:VYdzEGVk4zV04ZNqNb1DT8w7JCzWM77h3h6pBH27B1k=
-github.com/sashabaranov/go-openai v1.5.5/go.mod h1:lj5b/K+zjTSFxVLijLSTDZuP7adOgerWeFyZLUhAKRg=
-github.com/sashabaranov/go-openai v1.5.6 h1:i/DI9y1kzlPqKA0KeTYezJJSy01sqpOdUIm2BV7vgtA=
-github.com/sashabaranov/go-openai v1.5.6/go.mod h1:lj5b/K+zjTSFxVLijLSTDZuP7adOgerWeFyZLUhAKRg=
 github.com/sashabaranov/go-openai v1.5.7 h1:8DGgRG+P7yWixte5j720y6yiXgY3Hlgcd0gcpHdltfo=
 github.com/sashabaranov/go-openai v1.5.7/go.mod h1:lj5b/K+zjTSFxVLijLSTDZuP7adOgerWeFyZLUhAKRg=
+github.com/schollz/progressbar/v3 v3.13.1 h1:o8rySDYiQ59Mwzy2FELeHY5ZARXZTVJC7iHD6PEFUiE=
+github.com/schollz/progressbar/v3 v3.13.1/go.mod h1:xvrbki8kfT1fzWzBT/UZd9L6GA+jdL7HAgq2RFnO6fQ=
 github.com/spf13/afero v1.9.3 h1:41FoI0fD7OR7mGcKE/aOiLkGreyf8ifIOQmJANWogMk=
 github.com/spf13/afero v1.9.3/go.mod h1:iUV7ddyEEZPO5gA3zD4fJt6iStLlL+Lg4m2cihcDf8Y=
 github.com/spf13/cast v1.5.0 h1:rj3WzYc11XZaIZMPKmwP96zkFEnnAmV8s6XbB2aY32w=
@@ -325,8 +327,8 @@ golang.org/x/net v0.0.0-20201031054903-ff519b6c9102/go.mod h1:sp8m0HH+o8qH0wwXwY
 golang.org/x/net v0.0.0-20201209123823-ac852fbbde11/go.mod h1:m0MpNAwzfU5UDzcl9v0D8zg8gWTRqZa9RBIspLL5mdg=
 golang.org/x/net v0.0.0-20201224014010-6772e930b67b/go.mod h1:m0MpNAwzfU5UDzcl9v0D8zg8gWTRqZa9RBIspLL5mdg=
 golang.org/x/net v0.0.0-20210226172049-e18ecbb05110/go.mod h1:m0MpNAwzfU5UDzcl9v0D8zg8gWTRqZa9RBIspLL5mdg=
-golang.org/x/net v0.7.0 h1:rJrUqqhjsgNp7KqAIc25s9pZnjU7TUcSY7HcVZjdn1g=
-golang.org/x/net v0.7.0/go.mod h1:2Tu9+aMcznHK/AK1HMvgo6xiTLG5rD5rZLDS+rp2Bjs=
+golang.org/x/net v0.8.0 h1:Zrh2ngAOFYneWTAIAPethzeaQLuHwhuBkuV6ZiRnUaQ=
+golang.org/x/net v0.8.0/go.mod h1:QVkue5JL9kW//ek3r6jTKnTFis1tRmNAW2P1shuFdJc=
 golang.org/x/oauth2 v0.0.0-20180821212333-d2e6202438be/go.mod h1:N/0e6XlmueqKjAGxoOufVs8QHGRruUQn6yWY3a++T0U=
 golang.org/x/oauth2 v0.0.0-20190226205417-e64efc72b421/go.mod h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw=
 golang.org/x/oauth2 v0.0.0-20190604053449-0f29369cfe45/go.mod h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw=
@@ -395,8 +397,8 @@ golang.org/x/text v0.3.1-0.20180807135948-17ff2d5776d2/go.mod h1:NqM8EUOU14njkJ3
 golang.org/x/text v0.3.2/go.mod h1:bEr9sfX3Q8Zfm5fL9x+3itogRgK3+ptLWKqgva+5dAk=
 golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
 golang.org/x/text v0.3.4/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
-golang.org/x/text v0.7.0 h1:4BRB4x83lYWy72KwLD/qYDuTu7q9PjSagHvijDw7cLo=
-golang.org/x/text v0.7.0/go.mod h1:mrYo+phRRbMaCq/xk9113O4dZlRixOauAjOtrjsXDZ8=
+golang.org/x/text v0.8.0 h1:57P1ETyNKtuIjB4SRd15iJxuhj8Gc416Y78H3qgMh68=
+golang.org/x/text v0.8.0/go.mod h1:e1OnstbJyHTd6l/uOt8jFFHp6TRDWZR/bV3emEE/zU8=
 golang.org/x/time v0.0.0-20181108054448-85acf8d2951c/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ=
 golang.org/x/time v0.0.0-20190308202827-9d24e82272b4/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ=
 golang.org/x/time v0.0.0-20191024005414-555d28b269f0/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ=

main.go

@@ -5,6 +5,8 @@ package main
 
 import "github.com/k8sgpt-ai/k8sgpt/cmd"
 
+var version = "dev"
+
 func main() {
-	cmd.Execute()
+	cmd.Execute(version)
 }

pkg/ai/ai.go

@@ -3,19 +3,29 @@ package ai
 import (
 	"context"
 	"errors"
+	"fmt"
 
 	"github.com/sashabaranov/go-openai"
 )
 
+const (
+	default_prompt = "Simplify the following Kubernetes error message and provide a solution in %s: %s"
+	prompt_a       = "Read the following input %s and provide possible scenarios for remediation in %s"
+	prompt_b       = "Considering the following input from the Kubernetes resource %s and the error message %s, provide possible scenarios for remediation in %s"
+	prompt_c       = "Reading the following %s error message and it's accompanying log message %s, how would you simplify this message?"
+)
+
 type OpenAIClient struct {
-	client *openai.Client
+	client   *openai.Client
+	language string
 }
 
-func (c *OpenAIClient) Configure(token string) error {
+func (c *OpenAIClient) Configure(token string, language string) error {
 	client := openai.NewClient(token)
 	if client == nil {
 		return errors.New("error creating OpenAI client")
 	}
+	c.language = language
 	c.client = client
 	return nil
 }
@@ -27,7 +37,7 @@ func (c *OpenAIClient) GetCompletion(ctx context.Context, prompt string) (string
 		Messages: []openai.ChatCompletionMessage{
 			{
 				Role:    "user",
-				Content: "Simplify the following Kubernetes error message and provide a solution: " + prompt,
+				Content: fmt.Sprintf(default_prompt, c.language, prompt),
 			},
 		},
 	})

pkg/ai/iai.go

@@ -3,6 +3,6 @@ package ai
 import "context"
 
 type IAI interface {
-	Configure(token string) error
+	Configure(token string, language string) error
 	GetCompletion(ctx context.Context, prompt string) (string, error)
 }

pkg/analyzer/analysis.go

@@ -10,13 +10,13 @@ type PreAnalysis struct {
 	FailureDetails        []string
 	ReplicaSet            appsv1.ReplicaSet
 	PersistentVolumeClaim v1.PersistentVolumeClaim
-	Endpoint       v1.Endpoints
+	Endpoint              v1.Endpoints
 }
 
 type Analysis struct {
-	Kind         string `json:"kind"`
-	Name         string `json:"name"`
-	Error        string `json:"error"`
-	Details      string `json:"details"`
-	ParentObject string `json:"parentObject"`
+	Kind         string   `json:"kind"`
+	Name         string   `json:"name"`
+	Error        []string `json:"error"`
+	Details      string   `json:"details"`
+	ParentObject string   `json:"parentObject"`
 }

pkg/analyzer/analyzer.go

@@ -2,9 +2,13 @@ package analyzer
 
 import (
 	"context"
+	"encoding/base64"
+	"strings"
 
+	"github.com/fatih/color"
 	"github.com/k8sgpt-ai/k8sgpt/pkg/ai"
 	"github.com/k8sgpt-ai/k8sgpt/pkg/kubernetes"
+	"github.com/spf13/viper"
 )
 
 func RunAnalysis(ctx context.Context, client *kubernetes.Client, aiClient ai.IAI, explain bool, analysisResults *[]Analysis) error {
@@ -20,13 +24,50 @@ func RunAnalysis(ctx context.Context, client *kubernetes.Client, aiClient ai.IAI
 	}
 
 	err = AnalyzePersistentVolumeClaim(ctx, client, aiClient, explain, analysisResults)
-  if err != nil {
+	if err != nil {
 		return err
 	}
-  
+
 	err = AnalyzeEndpoints(ctx, client, aiClient, explain, analysisResults)
 	if err != nil {
 		return err
 	}
 	return nil
 }
+
+func ParseViaAI(ctx context.Context, aiClient ai.IAI, prompt []string) (string, error) {
+	// parse the text with the AI backend
+	inputKey := strings.Join(prompt, " ")
+	// Check for cached data
+	sEnc := base64.StdEncoding.EncodeToString([]byte(inputKey))
+	// find in viper cache
+	if viper.IsSet(sEnc) {
+		// retrieve data from cache
+		response := viper.GetString(sEnc)
+		if response == "" {
+			color.Red("error retrieving cached data")
+			return "", nil
+		}
+		output, err := base64.StdEncoding.DecodeString(response)
+		if err != nil {
+			color.Red("error decoding cached data: %v", err)
+			return "", nil
+		}
+		return string(output), nil
+	}
+
+	response, err := aiClient.GetCompletion(ctx, inputKey)
+	if err != nil {
+		color.Red("error getting completion: %v", err)
+		return "", nil
+	}
+
+	if !viper.IsSet(sEnc) {
+		viper.Set(sEnc, base64.StdEncoding.EncodeToString([]byte(response)))
+		if err := viper.WriteConfig(); err != nil {
+			color.Red("error writing config: %v", err)
+			return "", nil
+		}
+	}
+	return response, nil
+}

pkg/analyzer/podAnalyzer.go

@@ -2,16 +2,11 @@ package analyzer
 
 import (
 	"context"
-	"encoding/base64"
 	"fmt"
-	"strings"
-	"time"
 
-	"github.com/briandowns/spinner"
-	"github.com/fatih/color"
 	"github.com/k8sgpt-ai/k8sgpt/pkg/ai"
 	"github.com/k8sgpt-ai/k8sgpt/pkg/kubernetes"
-	"github.com/spf13/viper"
+	"github.com/k8sgpt-ai/k8sgpt/pkg/util"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 )
 
@@ -70,108 +65,16 @@ func AnalyzePod(ctx context.Context, client *kubernetes.Client, aiClient ai.IAI,
 	}
 
 	for key, value := range preAnalysis {
-		inputValue := strings.Join(value.FailureDetails, " ")
 		var currentAnalysis = Analysis{
 			Kind:  "Pod",
 			Name:  key,
-			Error: value.FailureDetails[0],
+			Error: value.FailureDetails,
 		}
 
-		parent, _ := getParent(client, value.Pod.ObjectMeta)
-
-		if explain {
-			s := spinner.New(spinner.CharSets[35], 100*time.Millisecond) // Build our new spinner
-			s.Start()
-
-			// Check for cached data
-			sEnc := base64.StdEncoding.EncodeToString([]byte(inputValue))
-			// find in viper cache
-			if viper.IsSet(sEnc) {
-				s.Stop()
-				// retrieve data from cache
-				response := viper.GetString(sEnc)
-				if response == "" {
-					color.Red("error retrieving cached data")
-					continue
-				}
-				output, err := base64.StdEncoding.DecodeString(response)
-				if err != nil {
-					color.Red("error decoding cached data: %v", err)
-					continue
-				}
-				currentAnalysis.Details = string(output)
-				currentAnalysis.ParentObject = parent
-				*analysisResults = append(*analysisResults, currentAnalysis)
-				continue
-			}
-
-			response, err := aiClient.GetCompletion(ctx, inputValue)
-			s.Stop()
-			if err != nil {
-				color.Red("error getting completion: %v", err)
-				continue
-			}
-
-			if !viper.IsSet(sEnc) {
-				viper.Set(sEnc, base64.StdEncoding.EncodeToString([]byte(response)))
-				if err := viper.WriteConfig(); err != nil {
-					return err
-				}
-			}
-			currentAnalysis.Details = response
-		}
+		parent, _ := util.GetParent(client, value.Pod.ObjectMeta)
 		currentAnalysis.ParentObject = parent
 		*analysisResults = append(*analysisResults, currentAnalysis)
 	}
 
 	return nil
 }
-
-func getParent(client *kubernetes.Client, meta metav1.ObjectMeta) (string, bool) {
-	if meta.OwnerReferences != nil {
-		for _, owner := range meta.OwnerReferences {
-			switch owner.Kind {
-			case "ReplicaSet":
-				rs, err := client.GetClient().AppsV1().ReplicaSets(meta.Namespace).Get(context.Background(), owner.Name, metav1.GetOptions{})
-				if err != nil {
-					return "", false
-				}
-				if rs.OwnerReferences != nil {
-					return getParent(client, rs.ObjectMeta)
-				}
-				return "ReplicaSet/" + rs.Name, false
-
-			case "Deployment":
-				dep, err := client.GetClient().AppsV1().Deployments(meta.Namespace).Get(context.Background(), owner.Name, metav1.GetOptions{})
-				if err != nil {
-					return "", false
-				}
-				if dep.OwnerReferences != nil {
-					return getParent(client, dep.ObjectMeta)
-				}
-				return "Deployment/" + dep.Name, false
-
-			case "StatefulSet":
-				sts, err := client.GetClient().AppsV1().StatefulSets(meta.Namespace).Get(context.Background(), owner.Name, metav1.GetOptions{})
-				if err != nil {
-					return "", false
-				}
-				if sts.OwnerReferences != nil {
-					return getParent(client, sts.ObjectMeta)
-				}
-				return "StatefulSet/" + sts.Name, false
-
-			case "DaemonSet":
-				ds, err := client.GetClient().AppsV1().DaemonSets(meta.Namespace).Get(context.Background(), owner.Name, metav1.GetOptions{})
-				if err != nil {
-					return "", false
-				}
-				if ds.OwnerReferences != nil {
-					return getParent(client, ds.ObjectMeta)
-				}
-				return "DaemonSet/" + ds.Name, false
-			}
-		}
-	}
-	return meta.Name, false
-}

pkg/analyzer/pvcAnalyzer.go

@@ -2,16 +2,11 @@ package analyzer
 
 import (
 	"context"
-	"encoding/base64"
 	"fmt"
-	"strings"
-	"time"
 
-	"github.com/briandowns/spinner"
-	"github.com/fatih/color"
 	"github.com/k8sgpt-ai/k8sgpt/pkg/ai"
 	"github.com/k8sgpt-ai/k8sgpt/pkg/kubernetes"
-	"github.com/spf13/viper"
+	"github.com/k8sgpt-ai/k8sgpt/pkg/util"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 )
 
@@ -52,54 +47,10 @@ func AnalyzePersistentVolumeClaim(ctx context.Context, client *kubernetes.Client
 		var currentAnalysis = Analysis{
 			Kind:  "PersistentVolumeClaim",
 			Name:  key,
-			Error: value.FailureDetails[0],
+			Error: value.FailureDetails,
 		}
 
-		parent, _ := getParent(client, value.PersistentVolumeClaim.ObjectMeta)
-
-		if explain {
-			s := spinner.New(spinner.CharSets[35], 100*time.Millisecond) // Build our new spinner
-			s.Start()
-
-			inputValue := strings.Join(value.FailureDetails, " ")
-
-			// Check for cached data
-			sEnc := base64.StdEncoding.EncodeToString([]byte(inputValue))
-			// find in viper cache
-			if viper.IsSet(sEnc) {
-				s.Stop()
-				// retrieve data from cache
-				response := viper.GetString(sEnc)
-				if response == "" {
-					color.Red("error retrieving cached data")
-					continue
-				}
-				output, err := base64.StdEncoding.DecodeString(response)
-				if err != nil {
-					color.Red("error decoding cached data: %v", err)
-					continue
-				}
-				currentAnalysis.Details = string(output)
-				currentAnalysis.ParentObject = parent
-				*analysisResults = append(*analysisResults, currentAnalysis)
-				continue
-			}
-
-			response, err := aiClient.GetCompletion(ctx, inputValue)
-			s.Stop()
-			if err != nil {
-				color.Red("error getting completion: %v", err)
-				continue
-			}
-
-			if !viper.IsSet(sEnc) {
-				viper.Set(sEnc, base64.StdEncoding.EncodeToString([]byte(response)))
-				if err := viper.WriteConfig(); err != nil {
-					return err
-				}
-			}
-			currentAnalysis.Details = response
-		}
+		parent, _ := util.GetParent(client, value.PersistentVolumeClaim.ObjectMeta)
 		currentAnalysis.ParentObject = parent
 		*analysisResults = append(*analysisResults, currentAnalysis)
 	}

pkg/analyzer/rsAnalyzer.go

@@ -2,16 +2,11 @@ package analyzer
 
 import (
 	"context"
-	"encoding/base64"
 	"fmt"
-	"strings"
-	"time"
 
-	"github.com/briandowns/spinner"
-	"github.com/fatih/color"
 	"github.com/k8sgpt-ai/k8sgpt/pkg/ai"
 	"github.com/k8sgpt-ai/k8sgpt/pkg/kubernetes"
-	"github.com/spf13/viper"
+	"github.com/k8sgpt-ai/k8sgpt/pkg/util"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 )
 
@@ -50,54 +45,10 @@ func AnalyzeReplicaSet(ctx context.Context, client *kubernetes.Client, aiClient
 		var currentAnalysis = Analysis{
 			Kind:  "ReplicaSet",
 			Name:  key,
-			Error: value.FailureDetails[0],
+			Error: value.FailureDetails,
 		}
 
-		parent, _ := getParent(client, value.ReplicaSet.ObjectMeta)
-
-		if explain {
-			s := spinner.New(spinner.CharSets[35], 100*time.Millisecond) // Build our new spinner
-			s.Start()
-
-			inputValue := strings.Join(value.FailureDetails, " ")
-
-			// Check for cached data
-			sEnc := base64.StdEncoding.EncodeToString([]byte(inputValue))
-			// find in viper cache
-			if viper.IsSet(sEnc) {
-				s.Stop()
-				// retrieve data from cache
-				response := viper.GetString(sEnc)
-				if response == "" {
-					color.Red("error retrieving cached data")
-					continue
-				}
-				output, err := base64.StdEncoding.DecodeString(response)
-				if err != nil {
-					color.Red("error decoding cached data: %v", err)
-					continue
-				}
-				currentAnalysis.Details = string(output)
-				currentAnalysis.ParentObject = parent
-				*analysisResults = append(*analysisResults, currentAnalysis)
-				continue
-			}
-
-			response, err := aiClient.GetCompletion(ctx, inputValue)
-			s.Stop()
-			if err != nil {
-				color.Red("error getting completion: %v", err)
-				continue
-			}
-
-			if !viper.IsSet(sEnc) {
-				viper.Set(sEnc, base64.StdEncoding.EncodeToString([]byte(response)))
-				if err := viper.WriteConfig(); err != nil {
-					return err
-				}
-			}
-			currentAnalysis.Details = response
-		}
+		parent, _ := util.GetParent(client, value.ReplicaSet.ObjectMeta)
 		currentAnalysis.ParentObject = parent
 		*analysisResults = append(*analysisResults, currentAnalysis)
 	}

pkg/analyzer/serviceAnalyzer.go

@@ -2,16 +2,11 @@ package analyzer
 
 import (
 	"context"
-	"encoding/base64"
 	"fmt"
-	"strings"
-	"time"
 
-	"github.com/briandowns/spinner"
-	"github.com/fatih/color"
 	"github.com/k8sgpt-ai/k8sgpt/pkg/ai"
 	"github.com/k8sgpt-ai/k8sgpt/pkg/kubernetes"
-	"github.com/spf13/viper"
+	"github.com/k8sgpt-ai/k8sgpt/pkg/util"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 )
 
@@ -66,54 +61,10 @@ func AnalyzeEndpoints(ctx context.Context, client *kubernetes.Client, aiClient a
 		var currentAnalysis = Analysis{
 			Kind:  "Service",
 			Name:  key,
-			Error: value.FailureDetails[0],
+			Error: value.FailureDetails,
 		}
 
-		parent, _ := getParent(client, value.Endpoint.ObjectMeta)
-
-		if explain {
-			s := spinner.New(spinner.CharSets[35], 100*time.Millisecond) // Build our new spinner
-			s.Start()
-
-			inputValue := strings.Join(value.FailureDetails, " ")
-
-			// Check for cached data
-			sEnc := base64.StdEncoding.EncodeToString([]byte(inputValue))
-			// find in viper cache
-			if viper.IsSet(sEnc) {
-				s.Stop()
-				// retrieve data from cache
-				response := viper.GetString(sEnc)
-				if response == "" {
-					color.Red("error retrieving cached data")
-					continue
-				}
-				output, err := base64.StdEncoding.DecodeString(response)
-				if err != nil {
-					color.Red("error decoding cached data: %v", err)
-					continue
-				}
-				currentAnalysis.Details = string(output)
-				currentAnalysis.ParentObject = parent
-				*analysisResults = append(*analysisResults, currentAnalysis)
-				continue
-			}
-
-			response, err := aiClient.GetCompletion(ctx, inputValue)
-			s.Stop()
-			if err != nil {
-				color.Red("error getting completion: %v", err)
-				continue
-			}
-
-			if !viper.IsSet(sEnc) {
-				viper.Set(sEnc, base64.StdEncoding.EncodeToString([]byte(response)))
-				if err := viper.WriteConfig(); err != nil {
-					return err
-				}
-			}
-			currentAnalysis.Details = response
-		}
+		parent, _ := util.GetParent(client, value.Endpoint.ObjectMeta)
 		currentAnalysis.ParentObject = parent
 		*analysisResults = append(*analysisResults, currentAnalysis)
 	}

pkg/util/util.go

@@ -0,0 +1,57 @@
+package util
+
+import (
+	"context"
+
+	"github.com/k8sgpt-ai/k8sgpt/pkg/kubernetes"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+)
+
+func GetParent(client *kubernetes.Client, meta metav1.ObjectMeta) (string, bool) {
+	if meta.OwnerReferences != nil {
+		for _, owner := range meta.OwnerReferences {
+			switch owner.Kind {
+			case "ReplicaSet":
+				rs, err := client.GetClient().AppsV1().ReplicaSets(meta.Namespace).Get(context.Background(), owner.Name, metav1.GetOptions{})
+				if err != nil {
+					return "", false
+				}
+				if rs.OwnerReferences != nil {
+					return GetParent(client, rs.ObjectMeta)
+				}
+				return "ReplicaSet/" + rs.Name, false
+
+			case "Deployment":
+				dep, err := client.GetClient().AppsV1().Deployments(meta.Namespace).Get(context.Background(), owner.Name, metav1.GetOptions{})
+				if err != nil {
+					return "", false
+				}
+				if dep.OwnerReferences != nil {
+					return GetParent(client, dep.ObjectMeta)
+				}
+				return "Deployment/" + dep.Name, false
+
+			case "StatefulSet":
+				sts, err := client.GetClient().AppsV1().StatefulSets(meta.Namespace).Get(context.Background(), owner.Name, metav1.GetOptions{})
+				if err != nil {
+					return "", false
+				}
+				if sts.OwnerReferences != nil {
+					return GetParent(client, sts.ObjectMeta)
+				}
+				return "StatefulSet/" + sts.Name, false
+
+			case "DaemonSet":
+				ds, err := client.GetClient().AppsV1().DaemonSets(meta.Namespace).Get(context.Background(), owner.Name, metav1.GetOptions{})
+				if err != nil {
+					return "", false
+				}
+				if ds.OwnerReferences != nil {
+					return GetParent(client, ds.ObjectMeta)
+				}
+				return "DaemonSet/" + ds.Name, false
+			}
+		}
+	}
+	return meta.Name, false
+}