//go:build !windows

package cmd

import (
	"io"
	"os"
	"path/filepath"
	"testing"

	"github.com/stretchr/testify/require"
)

func TestInferRegistry(t *testing.T) {
	configs := []struct {
		name               string
		config             string
		outContains        string
		wantErrContains    string
		wantErrNotContains string
	}{
		{
			name: "infer registry success",
			config: `
kind: source
spec:
  name: gcp
  path: cloudquery/gcp
  version: v10.0.0
  destinations: [dummydest]
  tables: [test]
---
kind: destination
spec:
  name: dummydest
  path: localhost:7777
  registry: grpc
`,
			outContains:        "Downloading https://assets.cloudquery.io/cq-cloud-releases/cloudquery/source/gcp/v10.0.0/",
			wantErrContains:    "",
			wantErrNotContains: "",
		},
		{
			name: "infer registry fail: recommend latest on hub",
			config: `
kind: source
spec:
  name: gcp
  path: cloudquery/gcp
  version: v99.999.0
  destinations: [dummydest]
  tables: [test]
---
kind: destination
spec:
  name: dummydest
  path: localhost:7777
  registry: grpc
`,
			wantErrContains:    "version v99.999.0 does not exist, consider using the latest version at https://www.cloudquery.io/hub/plugins/source/cloudquery/gcp/v",
			wantErrNotContains: "",
		},
		{
			name: "no infer registry fail: don't recommend github",
			config: `
kind: source
spec:
  name: gcp
  path: cloudquery/gcp
  registry: cloudquery
  version: v99.999.0
  destinations: [dummydest]
  tables: [test]
---
kind: destination
spec:
  name: dummydest
  path: localhost:7777
  registry: grpc
`,
			wantErrContains:    "",
			wantErrNotContains: "Hint",
		},
		{
			name: "no infer registry fail: don't recommend github for github",
			config: `
kind: source
spec:
  name: gcp
  path: cloudquery/gcp
  registry: github
  version: v99.999.0
  destinations: [dummydest]
  tables: [test]
---
kind: destination
spec:
  name: dummydest
  path: localhost:7777
  registry: grpc
`,
			wantErrContains:    "",
			wantErrNotContains: "Hint",
		},
	}

	for _, tc := range configs {
		tc := tc
		t.Run(tc.name, func(t *testing.T) {
			tmpDir := t.TempDir()
			testConfig := filepath.Join(tmpDir, "config.yml")

			err := os.WriteFile(testConfig, []byte(tc.config), 0644)
			require.NoError(t, err)

			oldStdout := os.Stdout
			r, w, _ := os.Pipe()
			os.Stdout = w
			defer func() {
				os.Stdout = oldStdout
			}()

			cmd := NewCmdRoot()
			basedArgs := testCommandArgs(t)
			cmd.SetArgs(append([]string{"plugin", "install", testConfig}, basedArgs...))
			err = cmd.Execute()

			_ = w.Close()
			out, _ := io.ReadAll(r)
			if tc.outContains != "" {
				require.Contains(t, string(out), tc.outContains)
			}

			if tc.wantErrContains == "" && tc.wantErrNotContains == "" {
				require.NoError(t, err)
			}
			if tc.wantErrContains != "" {
				require.ErrorContains(t, err, tc.wantErrContains)
			}
			if tc.wantErrNotContains != "" {
				require.Error(t, err)
				require.NotContains(t, err.Error(), tc.wantErrNotContains)
			}

			// check that log was written and contains some lines
			b, logFileError := os.ReadFile(basedArgs[3])
			logContent := string(b)
			require.NoError(t, logFileError, "failed to read cloudquery.log")
			require.NotEmpty(t, logContent, "cloudquery.log empty; expected some logs")
		})
	}
}
