cmd: add --all flag to kibana resync command (#124)

Implements a new  `--all` flag for kibana resync

Author: karencfv

cmd/deployment/kibana/resync.go

@@ -28,14 +28,32 @@ import (
 )
 
 var resyncKibanaCmd = &cobra.Command{
-	Use:     "resync <cluster id>",
-	Short:   "Resynchronizes the search index and cache for the selected Kibana instance",
-	PreRunE: cmdutil.MinimumNArgsAndUUID(1),
+	Use:     "resync {<deployment id> | --all}",
+	Short:   "Resynchronizes the search index and cache for the selected Kibana instance or all instances",
+	PreRunE: cmdutil.CheckInputHas1ArgsOr0ArgAndAll,
 	RunE: func(cmd *cobra.Command, args []string) error {
+		all, _ := cmd.Flags().GetBool("all")
+
+		if all {
+			fmt.Println("Resynchronizing all Kibana instances")
+			res, err := kibana.ResyncAll(kibana.ResyncAllParams{
+				API: ecctl.Get().API,
+			})
+			if err != nil {
+				return err
+			}
+
+			return ecctl.Get().Formatter.Format("", res)
+		}
+
 		fmt.Printf("Resynchronizing Kibana instance: %s\n", args[0])
 		return kibana.Resync(kibana.DeploymentParams{
 			API: ecctl.Get().API,
 			ID:  args[0],
 		})
 	},
 }
+
+func init() {
+	resyncKibanaCmd.Flags().Bool("all", false, "Resynchronizes the search index for all Kibana instances")
+}

docs/ecctl_deployment_kibana.md

@@ -45,7 +45,7 @@ ecctl deployment kibana [flags]
 * [ecctl deployment kibana plan](ecctl_deployment_kibana_plan.md)	 - Manages Kibana plans
 * [ecctl deployment kibana reallocate](ecctl_deployment_kibana_reallocate.md)	 - Reallocates Kibana instances
 * [ecctl deployment kibana restart](ecctl_deployment_kibana_restart.md)	 - Restarts a Kibana instance
-* [ecctl deployment kibana resync](ecctl_deployment_kibana_resync.md)	 - Resynchronizes the search index and cache for the selected Kibana instance
+* [ecctl deployment kibana resync](ecctl_deployment_kibana_resync.md)	 - Resynchronizes the search index and cache for the selected Kibana instance or all instances
 * [ecctl deployment kibana show](ecctl_deployment_kibana_show.md)	 - Returns the cluster information
 * [ecctl deployment kibana start](ecctl_deployment_kibana_start.md)	 - Starts a Kibana instance
 * [ecctl deployment kibana stop](ecctl_deployment_kibana_stop.md)	 - Downscales a Kibana instance

docs/ecctl_deployment_kibana_resync.md

@@ -1,18 +1,19 @@
 ## ecctl deployment kibana resync
 
-Resynchronizes the search index and cache for the selected Kibana instance
+Resynchronizes the search index and cache for the selected Kibana instance or all instances
 
 ### Synopsis
 
-Resynchronizes the search index and cache for the selected Kibana instance
+Resynchronizes the search index and cache for the selected Kibana instance or all instances
 
 ```
-ecctl deployment kibana resync <cluster id> [flags]
+ecctl deployment kibana resync {<deployment id> | --all} [flags]
 ```
 
 ### Options
 
 ```
+      --all    Resynchronizes the search index for all Kibana instances
   -h, --help   help for resync
 ```
 

pkg/deployment/kibana/resync.go

@@ -18,11 +18,26 @@
 package kibana
 
 import (
+	"github.com/elastic/cloud-sdk-go/pkg/api"
 	"github.com/elastic/cloud-sdk-go/pkg/client/clusters_kibana"
+	"github.com/elastic/cloud-sdk-go/pkg/models"
 
 	"github.com/elastic/ecctl/pkg/util"
 )
 
+// ResyncAllParams is consumed by ResyncAll
+type ResyncAllParams struct {
+	*api.API
+}
+
+// Validate ensures the parameters are usable by the consuming function.
+func (params ResyncAllParams) Validate() error {
+	if params.API == nil {
+		return util.ErrAPIReq
+	}
+	return nil
+}
+
 // Resync forces indexer to immediately resynchronize the search index
 // and cache for a given Kibana instance.
 func Resync(params DeploymentParams) error {
@@ -38,3 +53,20 @@ func Resync(params DeploymentParams) error {
 		),
 	)
 }
+
+// ResyncAll asynchronously resynchronizes the search index for all Kibana instances.
+func ResyncAll(params ResyncAllParams) (*models.ModelVersionIndexSynchronizationResults, error) {
+	if err := params.Validate(); err != nil {
+		return nil, err
+	}
+
+	res, err := params.API.V1API.ClustersKibana.ResyncKibanaClusters(
+		clusters_kibana.NewResyncKibanaClustersParams(),
+		params.API.AuthWriter,
+	)
+	if err != nil {
+		return nil, api.UnwrapError(err)
+	}
+
+	return res.Payload, nil
+}

pkg/deployment/kibana/resync_test.go

@@ -26,6 +26,7 @@ import (
 
 	"github.com/elastic/cloud-sdk-go/pkg/api"
 	"github.com/elastic/cloud-sdk-go/pkg/api/mock"
+	"github.com/elastic/cloud-sdk-go/pkg/models"
 	multierror "github.com/hashicorp/go-multierror"
 
 	"github.com/elastic/ecctl/pkg/util"
@@ -102,3 +103,67 @@ func TestResync(t *testing.T) {
 		})
 	}
 }
+
+func TestResyncAll(t *testing.T) {
+	type args struct {
+		params ResyncAllParams
+	}
+	tests := []struct {
+		name    string
+		args    args
+		wantErr error
+		want    *models.ModelVersionIndexSynchronizationResults
+	}{
+		{
+			name:    "Fails due to parameter validation (API)",
+			args:    args{params: ResyncAllParams{}},
+			wantErr: errors.New("api reference is required for command"),
+		},
+		{
+			name: "Fails due to unknown API response",
+			args: args{params: ResyncAllParams{
+				API: api.NewMock(mock.Response{Response: http.Response{
+					StatusCode: http.StatusForbidden,
+					Body:       mock.NewStringBody(`{"error": "some forbidden error"}`),
+				}}),
+			}},
+			wantErr: errors.New(`{"error": "some forbidden error"}`),
+		},
+		{
+			name: "Fails due to API error",
+			args: args{params: ResyncAllParams{
+				API: api.NewMock(mock.Response{
+					Error: errors.New("error with API"),
+				}),
+			}},
+			wantErr: &url.Error{
+				Op:  "Post",
+				URL: "https://mock-host/mock-path/clusters/kibana/_resync?skip_matching_version=true",
+				Err: errors.New("error with API"),
+			},
+		},
+		{
+			name: "Succeeds to re-synchronize all Kibana instances without errors",
+			args: args{params: ResyncAllParams{
+				API: api.NewMock(mock.Response{Response: http.Response{
+					StatusCode: http.StatusAccepted,
+					Body:       mock.NewStringBody(`{}`),
+				}}),
+			}},
+			want: &models.ModelVersionIndexSynchronizationResults{},
+		},
+	}
+
+	for _, tt := range tests {
+		t.Run(tt.name, func(t *testing.T) {
+			got, err := ResyncAll(tt.args.params)
+			if !reflect.DeepEqual(tt.wantErr, err) {
+				t.Errorf("ResyncAll() error = %v, wantErr %v", err, tt.wantErr)
+				return
+			}
+			if !reflect.DeepEqual(got, tt.want) {
+				t.Errorf("ResyncAll() = %v, want %v", got, tt.want)
+			}
+		})
+	}
+}