chore(main): release 0.0.6 (#79)

Co-authored-by: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com>

.github/workflows/semantic_pr.yaml

@@ -0,0 +1,56 @@
+name: Semantic PR Validation
+on:
+  pull_request_target:
+    types:
+      - opened
+      - edited
+      - synchronize
+defaults:
+  run:
+    shell: bash
+jobs:
+  validate:
+    runs-on: ubuntu-22.04
+    permissions:
+      contents: read # Needed for checking out the repository
+      pull-requests: read # Needed for reading prs
+    steps:
+      - name: Validate Pull Request
+        uses: amannn/action-semantic-pull-request@c3cd5d1ea3580753008872425915e343e351ab54 # v5.2.0
+        env:
+          GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
+        with:
+          # Configure which types are allowed.
+          # Default: https://github.com/commitizen/conventional-commit-types
+          types: |
+            feat
+            fix
+            build
+            chore
+            ci
+            docs
+            perf
+            refactor
+            revert
+            style
+            test
+            deps
+          scopes: |
+            deps
+          # Configure that a scope must always be provided.
+          requireScope: false
+          # When using "Squash and merge" on a PR with only one commit, GitHub
+          # will suggest using that commit message instead of the PR title for the
+          # merge commit, and it's easy to commit this by mistake. Enable this option
+          # to also validate the commit message for one commit PRs.
+          validateSingleCommit: true
+          # Configure additional validation for the subject based on a regex.
+          # This ensures the subject doesn't start with an uppercase character.
+          subjectPattern: ^(?![A-Z]).+$
+          # If `subjectPattern` is configured, you can use this property to override
+          # the default error message that is shown when the pattern doesn't match.
+          # The variables `subject` and `title` can be used within the message.
+          subjectPatternError: |
+            The subject "{subject}" found in the pull request title "{title}"
+            didn't match the configured pattern. Please ensure that the subject
+            doesn't start with an uppercase character.

.release-please-manifest.json

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

CHANGELOG.md

@@ -1,5 +1,107 @@
 # Changelog
 
+## [0.0.6](https://github.com/k8sgpt-ai/k8sgpt/compare/v0.0.6...v0.0.6) (2023-03-26)
+
+
+### Features
+
+* add service analysis ([961fb6c](https://github.com/k8sgpt-ai/k8sgpt/commit/961fb6c555f59f1276531f462739b76b1508830e))
+* added analysis for pvcs ([88d49ae](https://github.com/k8sgpt-ai/k8sgpt/commit/88d49ae21c7d889d59361de157360f80503683be))
+* also fixes bug if the events feed is empty ([#73](https://github.com/k8sgpt-ai/k8sgpt/issues/73)) ([a1093dc](https://github.com/k8sgpt-ai/k8sgpt/commit/a1093dcfe468a7671c9e543372f73780fb38418e))
+* build container ([260640f](https://github.com/k8sgpt-ai/k8sgpt/commit/260640f865baefba8ac256f800d4992f25ca15fd))
+* find parent objects ([b29c6e4](https://github.com/k8sgpt-ai/k8sgpt/commit/b29c6e45825807d07dd6fdb954457772f40b1b0e))
+* find parent objects and add information about them ([#72](https://github.com/k8sgpt-ai/k8sgpt/issues/72)) ([14e85b0](https://github.com/k8sgpt-ai/k8sgpt/commit/14e85b08ff7d9a571796905260db7f1056b6e838))
+* find replicaset errors ([8ac56e0](https://github.com/k8sgpt-ai/k8sgpt/commit/8ac56e062baef2a0cf7c7ce2b4c97753f079f157))
+* initial json implementation ([#68](https://github.com/k8sgpt-ai/k8sgpt/issues/68)) ([979f13f](https://github.com/k8sgpt-ai/k8sgpt/commit/979f13f043f54a5bc74d0a49fee0db2faaf0a4f8))
+* interfaced out ai clients ([90b3c08](https://github.com/k8sgpt-ai/k8sgpt/commit/90b3c0898c8ab1299ce8b60effe981f5fc9ed63b))
+* support for multi-auth ([51aa59a](https://github.com/k8sgpt-ai/k8sgpt/commit/51aa59aea8c0fd5533d2300c7a79c0b9008ef887))
+* updated readme ([7336924](https://github.com/k8sgpt-ai/k8sgpt/commit/73369240b4fc8c91dae0ae272e671f7b413e3bdc))
+
+
+### Bug Fixes
+
+* add permissions to read repository ([d6cc4cf](https://github.com/k8sgpt-ai/k8sgpt/commit/d6cc4cfcbffbf84f27c7e4e4159da1e42dd5d689))
+* build ([1fbed3e](https://github.com/k8sgpt-ai/k8sgpt/commit/1fbed3e44ff790fccfef502ddafae92e34629c21))
+* container naming ([115276e](https://github.com/k8sgpt-ai/k8sgpt/commit/115276e01a38fc1692d6b66ab56a33f1e1793974))
+* **deps:** update module github.com/sashabaranov/go-openai to v1.5.5 ([105fe44](https://github.com/k8sgpt-ai/k8sgpt/commit/105fe44680e5a987d4a65ff9c58b5b2211808c5e))
+* **deps:** update module github.com/sashabaranov/go-openai to v1.5.6 ([37a1d3f](https://github.com/k8sgpt-ai/k8sgpt/commit/37a1d3f47e07caddb168f228627973870a9d867e))
+* **deps:** update module github.com/sashabaranov/go-openai to v1.5.7 ([7f7726d](https://github.com/k8sgpt-ai/k8sgpt/commit/7f7726d59a63baeaf8ff110e00b30a20ec7f1df5))
+* minor adaptions ([ef17b84](https://github.com/k8sgpt-ai/k8sgpt/commit/ef17b845ba3c65c16ed5dcc417e3e3d3d40dd04e))
+* missing parent when explain is used ([9c7d559](https://github.com/k8sgpt-ai/k8sgpt/commit/9c7d55955b777ad201307cb946e0fc81cf9c4b99))
+* release please config ([c402c7b](https://github.com/k8sgpt-ai/k8sgpt/commit/c402c7bab7baababbbc7c82965d8337de7d50d35))
+* remove sboms from goreleaser ([addc01f](https://github.com/k8sgpt-ai/k8sgpt/commit/addc01f700dd2ea31ec24dcf4995bb7ed4a4785e))
+* semantic commit token permission ([#69](https://github.com/k8sgpt-ai/k8sgpt/issues/69)) ([0181c0a](https://github.com/k8sgpt-ai/k8sgpt/commit/0181c0aeb56ad82fd232ce1c7788c43b7bd03bf2))
+
+
+### Docs
+
+* add some important information to contributing ([9ab7f58](https://github.com/k8sgpt-ai/k8sgpt/commit/9ab7f587620d69e4e8fc98faabce6417c35f7497))
+* update CONTRIBUTING ([05a787d](https://github.com/k8sgpt-ai/k8sgpt/commit/05a787d53dfe5e625c6449ac1e21ec36e66ddd28))
+* update CONTRIBUTING ([26449e1](https://github.com/k8sgpt-ai/k8sgpt/commit/26449e10efd8926cccd4a2eaa4e9dc3afa8bd01a))
+
+
+### Other
+
+* add bot secret to goreleaser ([171e58b](https://github.com/k8sgpt-ai/k8sgpt/commit/171e58b51107f75717694e35c4e249ee41f0409a))
+* add brew tap generation on release ([2992c4e](https://github.com/k8sgpt-ai/k8sgpt/commit/2992c4e5c8abad50c90ed85523c732f19ab1f31c))
+* add initial renovate config ([e37dbc7](https://github.com/k8sgpt-ai/k8sgpt/commit/e37dbc7909f1c520c4c6660c25b45de5847ea581))
+* add pull request template ([a6d5132](https://github.com/k8sgpt-ai/k8sgpt/commit/a6d5132b8c2ff077680e2edfd8361a93008197fd))
+* add release-please ([da7b409](https://github.com/k8sgpt-ai/k8sgpt/commit/da7b40978d55a6afed4c3a1ca83a756238feaca8))
+* add semantic pr validation ([#66](https://github.com/k8sgpt-ai/k8sgpt/issues/66)) ([ad594c7](https://github.com/k8sgpt-ai/k8sgpt/commit/ad594c7cb2105e0eff72d1767b2ddcc4dc0e3d38))
+* change module repo ([a307c13](https://github.com/k8sgpt-ai/k8sgpt/commit/a307c132b3464ff2e949c8a5588e01d344de91a0))
+* **deps:** pin amannn/action-semantic-pull-request action to c3cd5d1 ([3621766](https://github.com/k8sgpt-ai/k8sgpt/commit/36217667ceb87d9b97b44dc91e0ff6e7a1b86e14))
+* **deps:** pin dependencies ([f6072f5](https://github.com/k8sgpt-ai/k8sgpt/commit/f6072f56cbe2c073b7b7ebef6c12fa98120e54e2))
+* **deps:** pin dependencies ([5b360de](https://github.com/k8sgpt-ai/k8sgpt/commit/5b360de2ae6094cf850a4ae973a22855c21a9040))
+* **deps:** pin dependencies ([7fea7d1](https://github.com/k8sgpt-ai/k8sgpt/commit/7fea7d14a572fe0fd05f5f241b98e93655fb1965))
+* **deps:** update actions/checkout digest to 8f4b7f8 ([9955d75](https://github.com/k8sgpt-ai/k8sgpt/commit/9955d754505b60f28d17397132a1d02e95ffe303))
+* **main:** release 0.0.3 ([53c9947](https://github.com/k8sgpt-ai/k8sgpt/commit/53c994725ea2c2c54898ffe5307d9df40e9c1fe5))
+* **main:** release 0.0.3 ([f5d8609](https://github.com/k8sgpt-ai/k8sgpt/commit/f5d86092f49faef8d71cb950986d76c3f92daf46))
+* **main:** release 0.0.3 ([22873a6](https://github.com/k8sgpt-ai/k8sgpt/commit/22873a67163e58484d2a0ad343b4ba3c83e51d8f))
+* **main:** release 0.0.4 ([13b7d58](https://github.com/k8sgpt-ai/k8sgpt/commit/13b7d58e590078f086a0af2f9d1800e0e65a28bb))
+* **main:** release 0.0.4 ([aef7256](https://github.com/k8sgpt-ai/k8sgpt/commit/aef7256dc3a85817573744f8b4a54f834368bac7))
+* **main:** release 0.0.4 ([6dbcde9](https://github.com/k8sgpt-ai/k8sgpt/commit/6dbcde94e961a6e5a1fc0559d2a1da5567a659de))
+* **main:** release 0.0.5 ([9fecc1e](https://github.com/k8sgpt-ai/k8sgpt/commit/9fecc1ea6df4104412fc1230372de6f26aa1ade2))
+* **main:** release 0.0.6 ([d554bba](https://github.com/k8sgpt-ai/k8sgpt/commit/d554bba38494745f83b5a8931f665429af35a31a))
+* release 0.0.3 ([4840aa0](https://github.com/k8sgpt-ai/k8sgpt/commit/4840aa081e3aa4a7a01fd3fd5f837fa6f0c3c02c))
+* release 0.0.3 ([de02795](https://github.com/k8sgpt-ai/k8sgpt/commit/de027955ea18a751c5f991e7ff0f60b90ae704b0))
+* release 0.0.3 ([a927c32](https://github.com/k8sgpt-ai/k8sgpt/commit/a927c32def806bb8b99e1cfcd4ee3dcdeca6ae5d))
+* release 0.0.4 ([08f2c31](https://github.com/k8sgpt-ai/k8sgpt/commit/08f2c3112e2cc16b49b9cf8fdbd97368acecc754))
+* release 0.0.5 ([8da8945](https://github.com/k8sgpt-ai/k8sgpt/commit/8da8945d1b8d898440be235f88bdb2c08b0f9f84))
+* release 0.0.6 ([dc2bfa9](https://github.com/k8sgpt-ai/k8sgpt/commit/dc2bfa918c080a6c1b2e5ef66d699d9e08e28e10))
+
+## [0.0.6](https://github.com/k8sgpt-ai/k8sgpt/compare/v0.0.5...v0.0.6) (2023-03-26)
+
+
+### Features
+
+* add service analysis ([961fb6c](https://github.com/k8sgpt-ai/k8sgpt/commit/961fb6c555f59f1276531f462739b76b1508830e))
+* added analysis for pvcs ([88d49ae](https://github.com/k8sgpt-ai/k8sgpt/commit/88d49ae21c7d889d59361de157360f80503683be))
+* also fixes bug if the events feed is empty ([#73](https://github.com/k8sgpt-ai/k8sgpt/issues/73)) ([a1093dc](https://github.com/k8sgpt-ai/k8sgpt/commit/a1093dcfe468a7671c9e543372f73780fb38418e))
+* find parent objects ([b29c6e4](https://github.com/k8sgpt-ai/k8sgpt/commit/b29c6e45825807d07dd6fdb954457772f40b1b0e))
+* find parent objects and add information about them ([#72](https://github.com/k8sgpt-ai/k8sgpt/issues/72)) ([14e85b0](https://github.com/k8sgpt-ai/k8sgpt/commit/14e85b08ff7d9a571796905260db7f1056b6e838))
+* initial json implementation ([#68](https://github.com/k8sgpt-ai/k8sgpt/issues/68)) ([979f13f](https://github.com/k8sgpt-ai/k8sgpt/commit/979f13f043f54a5bc74d0a49fee0db2faaf0a4f8))
+* interfaced out ai clients ([90b3c08](https://github.com/k8sgpt-ai/k8sgpt/commit/90b3c0898c8ab1299ce8b60effe981f5fc9ed63b))
+* support for multi-auth ([51aa59a](https://github.com/k8sgpt-ai/k8sgpt/commit/51aa59aea8c0fd5533d2300c7a79c0b9008ef887))
+
+
+### Bug Fixes
+
+* missing parent when explain is used ([9c7d559](https://github.com/k8sgpt-ai/k8sgpt/commit/9c7d55955b777ad201307cb946e0fc81cf9c4b99))
+* semantic commit token permission ([#69](https://github.com/k8sgpt-ai/k8sgpt/issues/69)) ([0181c0a](https://github.com/k8sgpt-ai/k8sgpt/commit/0181c0aeb56ad82fd232ce1c7788c43b7bd03bf2))
+
+
+### Other
+
+* add semantic pr validation ([#66](https://github.com/k8sgpt-ai/k8sgpt/issues/66)) ([ad594c7](https://github.com/k8sgpt-ai/k8sgpt/commit/ad594c7cb2105e0eff72d1767b2ddcc4dc0e3d38))
+* **deps:** pin amannn/action-semantic-pull-request action to c3cd5d1 ([3621766](https://github.com/k8sgpt-ai/k8sgpt/commit/36217667ceb87d9b97b44dc91e0ff6e7a1b86e14))
+
+## [0.0.5](https://github.com/k8sgpt-ai/k8sgpt/compare/v0.0.4...v0.0.5) (2023-03-24)
+
+
+### Other
+
+* release 0.0.5 ([8da8945](https://github.com/k8sgpt-ai/k8sgpt/commit/8da8945d1b8d898440be235f88bdb2c08b0f9f84))
+
 ## [0.0.4](https://github.com/k8sgpt-ai/k8sgpt/compare/v0.0.4...v0.0.4) (2023-03-24)
 
 

README.md

@@ -1,9 +1,9 @@
 <picture>
-  <source media="(prefers-color-scheme: dark)" srcset="./images/logo-white.png" width="100px;">
-  <img alt="Text changing depending on mode. Light: 'So light!' Dark: 'So dark!'" src="./images/logo-black.png" width="100px;">
+  <source media="(prefers-color-scheme: dark)" srcset="./images/banner-white.png" width="600px;">
+  <img alt="Text changing depending on mode. Light: 'So light!' Dark: 'So dark!'" src="./images/banner-black.png" width="600px;">
 </picture>
 
-_Try it out now_
+_Install it now_
 
 ```
 brew tap k8sgpt-ai/k8sgpt
@@ -16,18 +16,34 @@ It has SRE experience codified into it's analyzers and helps to pull out the mos
 
 <img src="images/image.png" width=650px; />
 
+## Analyzers
+
+K8sGPT uses analyzers to triage and diagnose issues in your cluster. It has a set of analyzers that are built in, but you will be able to write your own analyzers.
+
+### Built in analyzers
+
+- [x] podAnalyzer
+- [x] pvcAnalyzer
+- [x] rsAnalyzer
+- [x] serviceAnalyzer
+- [x] eventAnalyzer
+
 ## Usage
 
 ```
 # Ensure KUBECONFIG env is set to an active Kubernetes cluster
-k8sgpt auth key <Your OpenAI key>
-
+k8sgpt auth
 k8sgpt find problems 
 # for more detail
 k8s find problems --explain
-
 ```
 
+## Upcoming major milestones
+
+- [ ] Multiple AI backend support
+- [ ] Custom AI/ML model backend support
+- [ ] Custom analyzers
+
 ### What about kubectl-ai?
 
 The the kubectl-ai [project](https://github.com/sozercan/kubectl-ai) uses AI to create manifests and apply them to the cluster. It is not what we are trying to do here, it is focusing on writing YAML manifests.

cmd/analyze/analyze.go

@@ -0,0 +1,97 @@
+package analyze
+
+import (
+	"context"
+	"encoding/json"
+	"fmt"
+	"os"
+
+	"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/spf13/cobra"
+	"github.com/spf13/viper"
+)
+
+var (
+	explain bool
+	backend string
+	output  string
+)
+
+// AnalyzeCmd represents the problems command
+var AnalyzeCmd = &cobra.Command{
+	Use:   "analyze",
+	Short: "This command will find problems within your Kubernetes cluster",
+	Long: `This command will find problems within your Kubernetes cluster and
+	 provide you with a list of issues that need to be resolved`,
+	Run: func(cmd *cobra.Command, args []string) {
+
+		// get backend from file
+		backendType := viper.GetString("backend_type")
+		if backendType == "" {
+			color.Red("No backend set. Please run k8sgpt auth")
+			os.Exit(1)
+		}
+		// override the default backend if a flag is provided
+		if backend != "" {
+			backendType = backend
+		}
+		// get the token with viper
+		token := viper.GetString(fmt.Sprintf("%s_key", backendType))
+		// check if nil
+		if token == "" {
+			color.Red("No %s key set. Please run k8sgpt auth", backendType)
+			os.Exit(1)
+		}
+
+		var aiClient ai.IAI
+		switch backendType {
+		case "openai":
+			aiClient = &ai.OpenAIClient{}
+			if err := aiClient.Configure(token); err != nil {
+				color.Red("Error: %v", err)
+				os.Exit(1)
+			}
+		default:
+			color.Red("Backend not supported")
+			os.Exit(1)
+		}
+
+		ctx := context.Background()
+		// Get kubernetes client from viper
+		client := viper.Get("kubernetesClient").(*kubernetes.Client)
+
+		var analysisResults *[]analyzer.Analysis = &[]analyzer.Analysis{}
+		if err := analyzer.RunAnalysis(ctx, client, aiClient, explain, analysisResults); err != nil {
+			color.Red("Error: %v", err)
+			os.Exit(1)
+		}
+		for n, analysis := range *analysisResults {
+
+			switch output {
+			case "json":
+				j, err := json.Marshal(analysis)
+				if err != nil {
+					color.Red("Error: %v", err)
+					os.Exit(1)
+				}
+				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))
+			}
+		}
+
+	},
+}
+
+func init() {
+
+	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)")
+
+}

cmd/auth/auth.go

@@ -1,24 +1,61 @@
 package auth
 
 import (
+	"fmt"
+	"os"
+	"strings"
+	"syscall"
+
+	"github.com/fatih/color"
 	"github.com/spf13/cobra"
+	"github.com/spf13/viper"
+	"golang.org/x/term"
+)
+
+var (
+	backend string
 )
 
 // authCmd represents the auth command
 var AuthCmd = &cobra.Command{
 	Use:   "auth",
-	Short: "A brief description of your command",
-	Long: `A longer description that spans multiple lines and likely contains examples
-and usage of using your command. For example:
-
-Cobra is a CLI library for Go that empowers applications.
-This application is a tool to generate the needed files
-to quickly create a Cobra application.`,
+	Short: "Authenticate with your chosen backend",
+	Long:  `Provide the necessary credentials to authenticate with your chosen backend.`,
 	Run: func(cmd *cobra.Command, args []string) {
-		cmd.Help()
+
+		backendType := viper.GetString("backend_type")
+		if backendType == "" {
+			// Set the default backend
+			viper.Set("backend_type", "openai")
+			if err := viper.WriteConfig(); err != nil {
+				color.Red("Error writing config file: %s", err.Error())
+				os.Exit(1)
+			}
+		}
+		// override the default backend if a flag is provided
+		if backend != "" {
+			backendType = backend
+		}
+
+		fmt.Printf("Enter %s Key: ", backendType)
+		bytePassword, err := term.ReadPassword(int(syscall.Stdin))
+		if err != nil {
+			color.Red("Error reading %s Key from stdin: %s", backendType,
+				err.Error())
+			os.Exit(1)
+		}
+		password := strings.TrimSpace(string(bytePassword))
+
+		viper.Set(fmt.Sprintf("%s_key", backendType), password)
+		if err := viper.WriteConfig(); err != nil {
+			color.Red("Error writing config file: %s", err.Error())
+			os.Exit(1)
+		}
+		color.Green("key added")
 	},
 }
 
 func init() {
-
+	// add flag for backend
+	AuthCmd.Flags().StringVarP(&backend, "backend", "b", "openai", "Backend AI provider")
 }

cmd/auth/key.go

@@ -1,42 +0,0 @@
-package auth
-
-import (
-	"fmt"
-	"os"
-	"strings"
-	"syscall"
-
-	"github.com/fatih/color"
-	"github.com/spf13/cobra"
-	"github.com/spf13/viper"
-	"golang.org/x/term"
-)
-
-// keyCmd represents the key command
-var keyCmd = &cobra.Command{
-	Use:   "key",
-	Short: "Add a key to OpenAI",
-	Long:  `This command will add a key from OpenAI to enable you to interact with the API`,
-	Run: func(cmd *cobra.Command, args []string) {
-
-		fmt.Print("Enter OpenAI API Key: ")
-		bytePassword, err := term.ReadPassword(int(syscall.Stdin))
-		if err != nil {
-			color.Red("Error reading OpenAI API Key from stdin: %s", err.Error())
-			os.Exit(1)
-		}
-		password := strings.TrimSpace(string(bytePassword))
-
-		viper.Set("openai_api_key", password)
-		if err := viper.WriteConfig(); err != nil {
-			color.Red("Error writing config file: %s", err.Error())
-			os.Exit(1)
-		}
-		color.Green("key added")
-	},
-}
-
-func init() {
-	AuthCmd.AddCommand(keyCmd)
-
-}

cmd/find/find.go

@@ -1,19 +0,0 @@
-package find
-
-import (
-	"github.com/spf13/cobra"
-)
-
-// findCmd represents the find command
-var FindCmd = &cobra.Command{
-	Use:   "find",
-	Short: "Find issues within your Kubernetes cluster",
-	Long:  ``,
-	Run: func(cmd *cobra.Command, args []string) {
-		cmd.Help()
-	},
-}
-
-func init() {
-
-}

cmd/find/problems.go

@@ -1,49 +0,0 @@
-package find
-
-import (
-	"context"
-	"os"
-
-	"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/spf13/cobra"
-	"github.com/spf13/viper"
-)
-
-var explain bool
-
-// problemsCmd represents the problems command
-var problemsCmd = &cobra.Command{
-	Use:   "problems",
-	Short: "This command will find problems within your Kubernetes cluster",
-	Long: `This command will find problems within your Kubernetes cluster and
-	 provide you with a list of issues that need to be resolved`,
-	Run: func(cmd *cobra.Command, args []string) {
-
-		// Initialise the openAI client
-		openAIClient, err := ai.NewClient()
-		if err != nil {
-			color.Red("Error: %v", err)
-			os.Exit(1)
-		}
-
-		ctx := context.Background()
-		// Get kubernetes client from viper
-		client := viper.Get("kubernetesClient").(*kubernetes.Client)
-
-		if err := analyzer.RunAnalysis(ctx, client, openAIClient, explain); err != nil {
-			color.Red("Error: %v", err)
-			os.Exit(1)
-		}
-	},
-}
-
-func init() {
-
-	problemsCmd.Flags().BoolVarP(&explain, "explain", "e", false, "Explain the problem to me")
-
-	FindCmd.AddCommand(problemsCmd)
-
-}

cmd/root.go

@@ -4,8 +4,8 @@ import (
 	"os"
 
 	"github.com/fatih/color"
+	"github.com/k8sgpt-ai/k8sgpt/cmd/analyze"
 	"github.com/k8sgpt-ai/k8sgpt/cmd/auth"
-	"github.com/k8sgpt-ai/k8sgpt/cmd/find"
 	"github.com/k8sgpt-ai/k8sgpt/pkg/kubernetes"
 	"github.com/spf13/cobra"
 	"github.com/spf13/viper"
@@ -43,8 +43,7 @@ func init() {
 	// Cobra supports persistent flags, which, if defined here,
 	// will be global for your application.
 	rootCmd.AddCommand(auth.AuthCmd)
-	rootCmd.AddCommand(find.FindCmd)
-
+	rootCmd.AddCommand(analyze.AnalyzeCmd)
 	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.")
@@ -59,6 +58,7 @@ func init() {
 	}
 
 	viper.Set("kubernetesClient", kubernetesClient)
+
 }
 
 // initConfig reads in config file and ENV variables if set.

main.go

@@ -1,3 +1,6 @@
+/*
+Copyright © 2023 NAME HERE <EMAIL ADDRESS>
+*/
 package main
 
 import "github.com/k8sgpt-ai/k8sgpt/cmd"

pkg/ai/ai.go

@@ -2,36 +2,25 @@ package ai
 
 import (
 	"context"
-	"fmt"
+	"errors"
 
 	"github.com/sashabaranov/go-openai"
-	"github.com/spf13/viper"
 )
 
-type Client struct {
+type OpenAIClient struct {
 	client *openai.Client
 }
 
-func (c *Client) GetClient() *openai.Client {
-	return c.client
-}
-
-func NewClient() (*Client, error) {
-
-	// get the token with viper
-	token := viper.GetString("openai_api_key")
-	// check if nil
-	if token == "" {
-		return nil, fmt.Errorf("no OpenAI API Key found")
-	}
-
+func (c *OpenAIClient) Configure(token string) error {
 	client := openai.NewClient(token)
-	return &Client{
-		client: client,
-	}, nil
+	if client == nil {
+		return errors.New("error creating OpenAI client")
+	}
+	c.client = client
+	return nil
 }
 
-func (c *Client) GetCompletion(ctx context.Context, prompt string) (string, error) {
+func (c *OpenAIClient) GetCompletion(ctx context.Context, prompt string) (string, error) {
 	// Create a completion request
 	resp, err := c.client.CreateChatCompletion(ctx, openai.ChatCompletionRequest{
 		Model: openai.GPT3Dot5Turbo,

pkg/ai/iai.go

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

pkg/analyzer/analysis.go

@@ -0,0 +1,22 @@
+package analyzer
+
+import (
+	appsv1 "k8s.io/api/apps/v1"
+	v1 "k8s.io/api/core/v1"
+)
+
+type PreAnalysis struct {
+	Pod                   v1.Pod
+	FailureDetails        []string
+	ReplicaSet            appsv1.ReplicaSet
+	PersistentVolumeClaim v1.PersistentVolumeClaim
+	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"`
+}

pkg/analyzer/analyzer.go

@@ -2,17 +2,29 @@ package analyzer
 
 import (
 	"context"
+
 	"github.com/k8sgpt-ai/k8sgpt/pkg/ai"
 	"github.com/k8sgpt-ai/k8sgpt/pkg/kubernetes"
 )
 
-func RunAnalysis(ctx context.Context, client *kubernetes.Client, aiClient *ai.Client, explain bool) error {
-	err := AnalyzePod(ctx, client, aiClient, explain)
+func RunAnalysis(ctx context.Context, client *kubernetes.Client, aiClient ai.IAI, explain bool, analysisResults *[]Analysis) error {
+
+	err := AnalyzePod(ctx, client, aiClient, explain, analysisResults)
 	if err != nil {
 		return err
 	}
 
-	err = AnalyzeReplicaSet(ctx, client, aiClient, explain)
+	err = AnalyzeReplicaSet(ctx, client, aiClient, explain, analysisResults)
+	if err != nil {
+		return err
+	}
+
+	err = AnalyzePersistentVolumeClaim(ctx, client, aiClient, explain, analysisResults)
+  if err != nil {
+		return err
+	}
+  
+	err = AnalyzeEndpoints(ctx, client, aiClient, explain, analysisResults)
 	if err != nil {
 		return err
 	}

pkg/analyzer/events.go

@@ -31,3 +31,27 @@ func FetchLatestPodEvent(ctx context.Context, kubernetesClient *kubernetes.Clien
 	}
 	return latestEvent, nil
 }
+
+func FetchLatestPvcEvent(ctx context.Context, kubernetesClient *kubernetes.Client, pvc *v1.PersistentVolumeClaim) (*v1.Event, error) {
+
+	// get the list of events
+	events, err := kubernetesClient.GetClient().CoreV1().Events(pvc.Namespace).List(ctx,
+		metav1.ListOptions{
+			FieldSelector: "involvedObject.name=" + pvc.Name,
+		})
+
+	if err != nil {
+		return nil, err
+	}
+	// find most recent event
+	var latestEvent *v1.Event
+	for _, event := range events.Items {
+		if latestEvent == nil {
+			latestEvent = &event
+		}
+		if event.LastTimestamp.After(latestEvent.LastTimestamp.Time) {
+			latestEvent = &event
+		}
+	}
+	return latestEvent, nil
+}

pkg/analyzer/podAnalyzer.go

@@ -4,77 +4,85 @@ 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"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
-	"strings"
-	"time"
 )
 
-func AnalyzePod(ctx context.Context, client *kubernetes.Client, aiClient *ai.Client, explain bool) error {
+func AnalyzePod(ctx context.Context, client *kubernetes.Client, aiClient ai.IAI, explain bool, analysisResults *[]Analysis) error {
 
 	// search all namespaces for pods that are not running
 	list, err := client.GetClient().CoreV1().Pods("").List(ctx, metav1.ListOptions{})
 	if err != nil {
 		return err
 	}
-
-	var brokenPods = map[string][]string{}
+	var preAnalysis = map[string]PreAnalysis{}
 
 	for _, pod := range list.Items {
-
+		var failures []string
 		// Check for pending pods
 		if pod.Status.Phase == "Pending" {
 
 			// Check through container status to check for crashes
 			for _, containerStatus := range pod.Status.Conditions {
 				if containerStatus.Type == "PodScheduled" && containerStatus.Reason == "Unschedulable" {
-					brokenPods[fmt.Sprintf("%s/%s", pod.Namespace, pod.Name)] = []string{containerStatus.Message}
+					if containerStatus.Message != "" {
+						failures = []string{containerStatus.Message}
+					}
 				}
 			}
 		}
 
 		// Check through container status to check for crashes
-		var failureDetails = []string{}
 		for _, containerStatus := range pod.Status.ContainerStatuses {
 			if containerStatus.State.Waiting != nil {
 				if containerStatus.State.Waiting.Reason == "CrashLoopBackOff" || containerStatus.State.Waiting.Reason == "ImagePullBackOff" {
-
-					failureDetails = append(failureDetails, containerStatus.State.Waiting.Message)
-					brokenPods[fmt.Sprintf("%s/%s", pod.Namespace, pod.Name)] = failureDetails
+					if containerStatus.State.Waiting.Message != "" {
+						failures = append(failures, containerStatus.State.Waiting.Message)
+					}
 				}
 				// This represents a container that is still being created or blocked due to conditions such as OOMKilled
 				if containerStatus.State.Waiting.Reason == "ContainerCreating" && pod.Status.Phase == "Pending" {
 
 					// parse the event log and append details
 					evt, err := FetchLatestPodEvent(ctx, client, &pod)
-					if err != nil {
+					if err != nil || evt == nil {
 						continue
 					}
-					if evt.Reason == "FailedCreatePodSandBox" {
-						failureDetails = append(failureDetails, evt.Message)
-						brokenPods[fmt.Sprintf("%s/%s", pod.Namespace, pod.Name)] = failureDetails
+					if evt.Reason == "FailedCreatePodSandBox" && evt.Message != "" {
+						failures = append(failures, evt.Message)
 					}
 				}
-
 			}
 		}
-
+		if len(failures) > 0 {
+			preAnalysis[fmt.Sprintf("%s/%s", pod.Namespace, pod.Name)] = PreAnalysis{
+				Pod:            pod,
+				FailureDetails: failures,
+			}
+		}
 	}
 
-	count := 0
-	for key, value := range brokenPods {
-		fmt.Printf("%s: %s: %s\n", color.CyanString("%d", count), color.YellowString(key), color.RedString(value[0]))
-		count++
+	for key, value := range preAnalysis {
+		inputValue := strings.Join(value.FailureDetails, " ")
+		var currentAnalysis = Analysis{
+			Kind:  "Pod",
+			Name:  key,
+			Error: value.FailureDetails[0],
+		}
+
+		parent, _ := getParent(client, value.Pod.ObjectMeta)
+
 		if explain {
 			s := spinner.New(spinner.CharSets[35], 100*time.Millisecond) // Build our new spinner
 			s.Start()
 
-			inputValue := strings.Join(value, " ")
-
 			// Check for cached data
 			sEnc := base64.StdEncoding.EncodeToString([]byte(inputValue))
 			// find in viper cache
@@ -91,8 +99,9 @@ func AnalyzePod(ctx context.Context, client *kubernetes.Client, aiClient *ai.Cli
 					color.Red("error decoding cached data: %v", err)
 					continue
 				}
-
-				color.Green(string(output))
+				currentAnalysis.Details = string(output)
+				currentAnalysis.ParentObject = parent
+				*analysisResults = append(*analysisResults, currentAnalysis)
 				continue
 			}
 
@@ -109,10 +118,60 @@ func AnalyzePod(ctx context.Context, client *kubernetes.Client, aiClient *ai.Cli
 					return err
 				}
 			}
-
-			color.Green(response)
+			currentAnalysis.Details = response
 		}
+		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

@@ -0,0 +1,108 @@
+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"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+)
+
+func AnalyzePersistentVolumeClaim(ctx context.Context, client *kubernetes.Client, aiClient ai.IAI, explain bool, analysisResults *[]Analysis) error {
+
+	// search all namespaces for pods that are not running
+	list, err := client.GetClient().CoreV1().PersistentVolumeClaims("").List(ctx, metav1.ListOptions{})
+	if err != nil {
+		return err
+	}
+
+	var preAnalysis = map[string]PreAnalysis{}
+
+	for _, pvc := range list.Items {
+		var failures []string
+
+		// Check for empty rs
+		if pvc.Status.Phase == "Pending" {
+
+			// parse the event log and append details
+			evt, err := FetchLatestPvcEvent(ctx, client, &pvc)
+			if err != nil || evt == nil {
+				continue
+			}
+			if evt.Reason == "ProvisioningFailed" && evt.Message != "" {
+				failures = append(failures, evt.Message)
+			}
+		}
+		if len(failures) > 0 {
+			preAnalysis[fmt.Sprintf("%s/%s", pvc.Namespace, pvc.Name)] = PreAnalysis{
+				PersistentVolumeClaim: pvc,
+				FailureDetails:        failures,
+			}
+		}
+	}
+
+	for key, value := range preAnalysis {
+		var currentAnalysis = Analysis{
+			Kind:  "PersistentVolumeClaim",
+			Name:  key,
+			Error: value.FailureDetails[0],
+		}
+
+		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
+		}
+		currentAnalysis.ParentObject = parent
+		*analysisResults = append(*analysisResults, currentAnalysis)
+	}
+
+	return nil
+}

pkg/analyzer/rsAnalyzer.go

@@ -4,17 +4,18 @@ 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"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
-	"strings"
-	"time"
 )
 
-func AnalyzeReplicaSet(ctx context.Context, client *kubernetes.Client, aiClient *ai.Client, explain bool) error {
+func AnalyzeReplicaSet(ctx context.Context, client *kubernetes.Client, aiClient ai.IAI, explain bool, analysisResults *[]Analysis) error {
 
 	// search all namespaces for pods that are not running
 	list, err := client.GetClient().AppsV1().ReplicaSets("").List(ctx, metav1.ListOptions{})
@@ -22,9 +23,10 @@ func AnalyzeReplicaSet(ctx context.Context, client *kubernetes.Client, aiClient
 		return err
 	}
 
-	var brokenRS = map[string][]string{}
+	var preAnalysis = map[string]PreAnalysis{}
 
 	for _, rs := range list.Items {
+		var failures []string
 
 		// Check for empty rs
 		if rs.Status.Replicas == 0 {
@@ -32,21 +34,32 @@ func AnalyzeReplicaSet(ctx context.Context, client *kubernetes.Client, aiClient
 			// Check through container status to check for crashes
 			for _, rsStatus := range rs.Status.Conditions {
 				if rsStatus.Type == "ReplicaFailure" && rsStatus.Reason == "FailedCreate" {
-					brokenRS[fmt.Sprintf("%s/%s", rs.Namespace, rs.Name)] = []string{rsStatus.Message}
+					failures = []string{rsStatus.Message}
 				}
 			}
 		}
+		if len(failures) > 0 {
+			preAnalysis[fmt.Sprintf("%s/%s", rs.Namespace, rs.Name)] = PreAnalysis{
+				ReplicaSet:     rs,
+				FailureDetails: failures,
+			}
+		}
 	}
 
-	count := 0
-	for key, value := range brokenRS {
-		fmt.Printf("%s: %s: %s\n", color.CyanString("%d", count), color.YellowString(key), color.RedString(value[0]))
-		count++
+	for key, value := range preAnalysis {
+		var currentAnalysis = Analysis{
+			Kind:  "ReplicaSet",
+			Name:  key,
+			Error: value.FailureDetails[0],
+		}
+
+		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, " ")
+			inputValue := strings.Join(value.FailureDetails, " ")
 
 			// Check for cached data
 			sEnc := base64.StdEncoding.EncodeToString([]byte(inputValue))
@@ -64,8 +77,9 @@ func AnalyzeReplicaSet(ctx context.Context, client *kubernetes.Client, aiClient
 					color.Red("error decoding cached data: %v", err)
 					continue
 				}
-
-				color.Green(string(output))
+				currentAnalysis.Details = string(output)
+				currentAnalysis.ParentObject = parent
+				*analysisResults = append(*analysisResults, currentAnalysis)
 				continue
 			}
 
@@ -82,7 +96,10 @@ func AnalyzeReplicaSet(ctx context.Context, client *kubernetes.Client, aiClient
 					return err
 				}
 			}
+			currentAnalysis.Details = response
 		}
+		currentAnalysis.ParentObject = parent
+		*analysisResults = append(*analysisResults, currentAnalysis)
 	}
 
 	return nil

pkg/analyzer/serviceAnalyzer.go

@@ -0,0 +1,121 @@
+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"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+)
+
+func AnalyzeEndpoints(ctx context.Context, client *kubernetes.Client, aiClient ai.IAI, explain bool, analysisResults *[]Analysis) error {
+
+	// search all namespaces for pods that are not running
+	list, err := client.GetClient().CoreV1().Endpoints("").List(ctx, metav1.ListOptions{})
+	if err != nil {
+		return err
+	}
+
+	var preAnalysis = map[string]PreAnalysis{}
+
+	for _, ep := range list.Items {
+		var failures []string
+
+		// Check for empty service
+		if len(ep.Subsets) == 0 {
+			svc, err := client.GetClient().CoreV1().Services(ep.Namespace).Get(ctx, ep.Name, metav1.GetOptions{})
+			if err != nil {
+				return err
+			}
+
+			for k, v := range svc.Spec.Selector {
+				failures = append(failures, fmt.Sprintf("Service has no endpoints, expected label %s=%s", k, v))
+			}
+		} else {
+			count := 0
+			pods := []string{}
+
+			// Check through container status to check for crashes
+			for _, epSubset := range ep.Subsets {
+				if len(epSubset.NotReadyAddresses) > 0 {
+					for _, addresses := range epSubset.NotReadyAddresses {
+						count++
+						pods = append(pods, addresses.TargetRef.Kind+"/"+addresses.TargetRef.Name)
+					}
+					failures = append(failures, fmt.Sprintf("Service has not ready endpoints, pods: %s, expected %d", pods, count))
+				}
+			}
+		}
+
+		if len(failures) > 0 {
+			preAnalysis[fmt.Sprintf("%s/%s", ep.Namespace, ep.Name)] = PreAnalysis{
+				Endpoint:       ep,
+				FailureDetails: failures,
+			}
+		}
+	}
+
+	for key, value := range preAnalysis {
+		var currentAnalysis = Analysis{
+			Kind:  "Service",
+			Name:  key,
+			Error: value.FailureDetails[0],
+		}
+
+		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
+		}
+		currentAnalysis.ParentObject = parent
+		*analysisResults = append(*analysisResults, currentAnalysis)
+	}
+	return nil
+}