Leader

.github/workflows/lint.yml

@@ -26,8 +26,6 @@ jobs:
         env:
           CI: false
         run: |
-          go mod tidy
-          cd hack/migrate
-          go mod tidy
+          make -B tidy hack/migrate/go.mod
           changed_files=$(git status -s)
           [[ -z "$changed_files" ]] ||  ( git diff && printf "Change is detected in: \n$changed_files\n Did you run 'go mod tidy' before sending the PR?" && exit 1)

.github/workflows/test.yaml

@@ -29,7 +29,7 @@ jobs:
   migrate:
     runs-on: ubuntu-latest
     env:
-      migrate_command: cd hack/migrate && go mod tidy && go run main.go --db-url 'postgres://postgres:postgres@localhost:5432/mission-control?sslmode=disable'
+      migrate_command: make -B tidy hack/migrate/go.mod && cd hack/migrate && go run main.go --db-url 'postgres://postgres:postgres@localhost:5432/mission-control?sslmode=disable'
     steps:
       - name: Install Go
         uses: buildjet/setup-go@v5

.gitignore

@@ -2,3 +2,6 @@
 *.out.json
 ginkgo.report
 .vscode
+nohup.out
+*.test
+.aider*

Makefile

@@ -60,6 +60,18 @@ download-openapi-schemas:
 	rm -rf tmp
 
 
+hack/migrate/go.mod: tidy
+	cp go.mod hack/migrate && \
+	cd hack/migrate && \
+	go mod edit -module=github.com/flanksource/duty/hack/generate-schemas && \
+	go mod edit -require=github.com/flanksource/[email protected] && \
+ 	go mod edit -replace=github.com/flanksource/duty=../../ && \
+	go mod tidy
+
+.PHONY: migrate-test
+migrate-test: hack/migrate/go.mod
+	cd hack/migrate && go run ./main.go
+
 cp-playbook-schema:
 	cp ../incident-commander/config/schemas/playbook-spec.schema.json schema/
 
@@ -75,4 +87,3 @@ fmt_sql:
 
 tidy:
 	go mod tidy
-	cd hack/migrate && go mod tidy

cache/cache.go

@@ -0,0 +1,13 @@
+package cache
+
+import (
+	"time"
+
+	"github.com/eko/gocache/lib/v4/cache"
+	gocache_store "github.com/eko/gocache/store/go_cache/v4"
+	gocache "github.com/patrickmn/go-cache"
+)
+
+func NewCache[T any](name string, expiration time.Duration) cache.CacheInterface[T] {
+	return cache.New[T](gocache_store.NewGoCache(gocache.New(expiration, expiration)))
+}

context/context.go

@@ -335,7 +335,7 @@ func (k *Context) KubernetesRestConfig() *rest.Config {
 }
 
 func (k *Context) KubernetesDynamicClient() *dutyKubernetes.DynamicClient {
-	return dutyKubernetes.NewKubeClient(k.KubernetesRestConfig())
+	return dutyKubernetes.NewKubeClient(k.Kubernetes(), k.KubernetesRestConfig())
 }
 
 func (k *Context) WithKubeconfig(input types.EnvVar) (*Context, error) {

context/envvar.go

@@ -54,7 +54,7 @@ func GetEnvValueFromCache(ctx Context, input types.EnvVar, namespace string) (va
 	if err != nil {
 		ctx.Logger.V(3).Infof("lookup failed %s => %s", source, err.Error())
 	} else if ctx.Logger.IsLevelEnabled(5) {
-		ctx.Logger.V(5).Infof("lookup %s => %s %s", source, logger.PrintableSecret(value))
+		ctx.Logger.V(5).Infof("lookup %s => %s", source, logger.PrintableSecret(value))
 	}
 
 	return value, err

hack/migrate/.gitignore

@@ -0,0 +1,2 @@
+go.mod
+go.sum