Add pipeline version information

Add pipeline service version information to `tkn pipeline version`. The logic
has been imported from dashboard https://git.io/JvC4h

I don't have a full test for it, since the machinery to fake a Deployment is
quite tedious to import/implement and this is not used anywhere else.

Closes #463

Signed-off-by: Chmouel Boudjnah <chmouel@redhat.com>

Author: chmouel

pkg/cmd/root.go

@@ -35,7 +35,8 @@ import (
 )
 
 const usageTemplate = `Usage:{{if .Runnable}}
-{{.UseLine}}{{end}}{{if .HasAvailableSubCommands}}
+{{.UseLine}}{{end}}{{if .Ha
+sAvailableSubCommands}}
   {{.CommandPath}} [command]{{end}}{{if gt (len .Aliases) 0}}
 
 Aliases:
@@ -89,7 +90,7 @@ func Root(p cli.Params) *cobra.Command {
 		taskrun.Command(p),
 		triggerbinding.Command(p),
 		triggertemplate.Command(p),
-		version.Command(),
+		version.Command(p),
 	)
 
 	return cmd

pkg/cmd/version/testdata/TestVersionGood.golden

@@ -0,0 +1,2 @@
+Client version: v1.2.3
+Pipeline version: unknown

pkg/cmd/version/testdata/TestVersionGood/test-available-new-version.golden

@@ -0,0 +1 @@
+A newer version (v0.0.2) of Tekton CLI is available, please check https://github.com/tektoncd/cli/releases/tag/v0.0.2

pkg/cmd/version/testdata/TestVersionGood/test-same-version.golden

@@ -0,0 +1 @@
+You are running the latest version (v0.0.10) of Tekton CLI

pkg/cmd/version/version.go

@@ -26,6 +26,8 @@ import (
 	"github.com/blang/semver"
 	"github.com/pkg/errors"
 	"github.com/spf13/cobra"
+	"github.com/tektoncd/cli/pkg/cli"
+	"github.com/tektoncd/cli/pkg/helper/version"
 )
 
 // NOTE: use go build -ldflags "-X github.com/tektoncd/cli/pkg/cmd/version.clientVersion=$(git describe)"
@@ -35,7 +37,7 @@ const devVersion = "dev"
 const latestReleaseURL = "https://api.github.com/repos/tektoncd/cli/releases/latest"
 
 // Command returns version command
-func Command() *cobra.Command {
+func Command(p cli.Params) *cobra.Command {
 	var check bool
 
 	var cmd = &cobra.Command{
@@ -47,6 +49,15 @@ func Command() *cobra.Command {
 		RunE: func(cmd *cobra.Command, args []string) error {
 			fmt.Fprintf(cmd.OutOrStdout(), "Client version: %s\n", clientVersion)
 
+			cs, err := p.Clients()
+			if err == nil {
+				version, _ := version.GetPipelineVersion(cs)
+				if version == "" {
+					version = "unknown"
+				}
+				fmt.Fprintf(cmd.OutOrStdout(), "Pipeline version: %s\n", version)
+			}
+
 			if !check || clientVersion == devVersion {
 				return nil
 			}

pkg/cmd/version/version_test.go

@@ -18,14 +18,17 @@ import (
 	"context"
 	"crypto/tls"
 	"encoding/json"
+	"fmt"
 	"net"
 	"net/http"
 	"net/http/httptest"
 	"testing"
 	"time"
 
 	"github.com/tektoncd/cli/pkg/test"
+	pipelinetest "github.com/tektoncd/pipeline/test"
 	"gotest.tools/v3/assert"
+	"gotest.tools/v3/golden"
 )
 
 func TestVersionGood(t *testing.T) {
@@ -68,16 +71,20 @@ func TestVersionGood(t *testing.T) {
 			cli.httpClient = httpClient
 			output, err := checkRelease(cli)
 			assert.NilError(t, err)
-			assert.Equal(t, s.expected, output)
+			golden.Assert(t, output, fmt.Sprintf("%s.golden", t.Name()))
 		})
 	}
 
 	clientVersion = "v1.2.3"
-	version := Command()
+
+	seedData, _ := test.SeedTestData(t, pipelinetest.Data{})
+
+	cs := pipelinetest.Clients{Kube: seedData.Kube}
+	p := &test.Params{Kube: cs.Kube}
+	version := Command(p)
 	got, err := test.ExecuteCommand(version, "version", "")
 	assert.NilError(t, err)
-	assert.Equal(t, "Client version: "+clientVersion+"\n", got)
-
+	golden.Assert(t, got, fmt.Sprintf("%s.golden", t.Name()))
 }
 
 func TestVersionBad(t *testing.T) {

pkg/helper/version/version.go

@@ -0,0 +1,55 @@
+package version
+
+import (
+	"fmt"
+	"strings"
+
+	"github.com/tektoncd/cli/pkg/cli"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+)
+
+const pipelineNamespace = "tekton-pipelines"
+
+// GetPipelineVersion Get pipeline version, functions imported from Dashboard
+func GetPipelineVersion(c *cli.Clients) (string, error) {
+	version := ""
+
+	listOptions := metav1.ListOptions{
+		LabelSelector: "app.kubernetes.io/component=controller,app.kubernetes.io/name=tekton-pipelines",
+	}
+
+	deployments, err := c.Kube.AppsV1().Deployments(pipelineNamespace).List(listOptions)
+	if err != nil {
+		return "", err
+	}
+
+	for _, deployment := range deployments.Items {
+		deploymentAnnotations := deployment.Spec.Template.GetAnnotations()
+
+		// For master of Tekton Pipelines
+		version = deploymentAnnotations["pipeline.tekton.dev/release"]
+
+		// For Tekton Pipelines 0.10.0 + 0.10.1
+		if version == "" {
+			version = deploymentAnnotations["tekton.dev/release"]
+		}
+
+		// For Tekton Pipelines 0.9.0 - 0.9.2
+		if version == "" {
+			deploymentImage := deployment.Spec.Template.Spec.Containers[0].Image
+			if strings.Contains(deploymentImage, "pipeline/cmd/controller") && strings.Contains(deploymentImage, ":") && strings.Contains(deploymentImage, "@") {
+				s := strings.SplitAfter(deploymentImage, ":")
+				if strings.Contains(s[1], "@") {
+					t := strings.Split(s[1], "@")
+					version = t[0]
+				}
+			}
+		}
+	}
+
+	if version == "" {
+		return "", fmt.Errorf("Error getting the tekton pipelines deployment version. Version is unknown")
+	}
+
+	return version, nil
+}