CLOUDP-57859: Describe the given process, OM (#108)

Author: gssbzn

internal/cli/ops_manager_processes.go

@@ -25,8 +25,8 @@ func OpsManagerProcessesBuilder() *cobra.Command {
 		Aliases: []string{"process"},
 		Short:   description.Processes,
 	}
-
 	cmd.AddCommand(OpsManagerProcessListBuilder())
+	cmd.AddCommand(OpsManagerProcessDescribeBuilder())
 
 	return cmd
 }

internal/cli/ops_manager_processes_describe.go

@@ -0,0 +1,73 @@
+// Copyright 2020 MongoDB Inc
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//      http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package cli
+
+import (
+	"github.com/mongodb/mongocli/internal/description"
+	"github.com/mongodb/mongocli/internal/flags"
+	"github.com/mongodb/mongocli/internal/json"
+	"github.com/mongodb/mongocli/internal/store"
+	"github.com/mongodb/mongocli/internal/usage"
+	"github.com/spf13/cobra"
+)
+
+type opsManagerProcessesDescribeOpts struct {
+	globalOpts
+	hostID string
+	store  store.HostDescriber
+}
+
+func (opts *opsManagerProcessesDescribeOpts) init() error {
+	if opts.ProjectID() == "" {
+		return errMissingProjectID
+	}
+
+	var err error
+	opts.store, err = store.New()
+	return err
+}
+
+func (opts *opsManagerProcessesDescribeOpts) Run() error {
+	result, err := opts.store.Host(opts.ProjectID(), opts.hostID)
+
+	if err != nil {
+		return err
+	}
+
+	return json.PrettyPrint(result)
+}
+
+// mongocli om process(es) describe [processID] [--projectId projectId]
+func OpsManagerProcessDescribeBuilder() *cobra.Command {
+	opts := &opsManagerProcessesDescribeOpts{}
+	cmd := &cobra.Command{
+		Use:     "describe [processID]",
+		Short:   description.ListProcesses,
+		Aliases: []string{"d"},
+		Hidden:  true,
+		Args:    cobra.ExactArgs(1),
+		PreRunE: func(cmd *cobra.Command, args []string) error {
+			return opts.init()
+		},
+		RunE: func(cmd *cobra.Command, args []string) error {
+			opts.hostID = args[0]
+			return opts.Run()
+		},
+	}
+
+	cmd.Flags().StringVar(&opts.projectID, flags.ProjectID, "", usage.ProjectID)
+
+	return cmd
+}

internal/fixtures/hosts.go renamed to internal/cli/ops_manager_processes_describe_test.go

@@ -12,12 +12,36 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-package fixtures
+package cli
 
 import (
-	om "github.com/mongodb/go-client-mongodb-ops-manager/opsmngr"
+	"testing"
+
+	"github.com/golang/mock/gomock"
+	"github.com/mongodb/go-client-mongodb-ops-manager/opsmngr"
+	"github.com/mongodb/mongocli/internal/mocks"
 )
 
-func Hosts() *om.Hosts {
-	return &om.Hosts{}
+func TestOpsManagerProcessesDescribe_Run(t *testing.T) {
+	ctrl := gomock.NewController(t)
+	mockStore := mocks.NewMockHostDescriber(ctrl)
+
+	defer ctrl.Finish()
+
+	expected := &opsmngr.Host{}
+
+	opts := &opsManagerProcessesDescribeOpts{
+		store: mockStore,
+	}
+
+	mockStore.
+		EXPECT().
+		Host(opts.projectID, opts.hostID).
+		Return(expected, nil).
+		Times(1)
+
+	err := opts.Run()
+	if err != nil {
+		t.Fatalf("Run() unexpected error: %v", err)
+	}
 }

internal/cli/ops_manager_processes_list.go

@@ -76,7 +76,7 @@ func OpsManagerProcessListBuilder() *cobra.Command {
 		},
 	}
 
-	cmd.Flags().StringVar(&opts.clusterID, flags.ClusterID, "", usage.Page)
+	cmd.Flags().StringVar(&opts.clusterID, flags.ClusterID, "", usage.ClusterID)
 	cmd.Flags().IntVar(&opts.pageNum, flags.Page, 0, usage.Page)
 	cmd.Flags().IntVar(&opts.itemsPerPage, flags.Limit, 0, usage.Limit)
 

internal/cli/ops_manager_processes_list_test.go

@@ -18,7 +18,7 @@ import (
 	"testing"
 
 	"github.com/golang/mock/gomock"
-	"github.com/mongodb/mongocli/internal/fixtures"
+	"github.com/mongodb/go-client-mongodb-ops-manager/opsmngr"
 	"github.com/mongodb/mongocli/internal/mocks"
 )
 
@@ -28,7 +28,7 @@ func TestOpsManagerProcessesList_Run(t *testing.T) {
 
 	defer ctrl.Finish()
 
-	expected := fixtures.Hosts()
+	expected := &opsmngr.Hosts{}
 
 	listOpts := &opsManagerProcessesListOpts{
 		store: mockStore,

internal/mocks/mock_hosts.go

@@ -26,7 +26,11 @@ type HostLister interface {
 	Hosts(string, *om.HostListOptions) (*om.Hosts, error)
 }
 
-// HostMeasurements encapsulate the logic to manage different cloud providers
+type HostDescriber interface {
+	Host(string, string) (*om.Host, error)
+}
+
+// Hosts encapsulate the logic to manage different cloud providers
 func (s *Store) Hosts(groupID string, opts *om.HostListOptions) (*om.Hosts, error) {
 	switch s.service {
 	case config.OpsManagerService, config.CloudManagerService:
@@ -36,3 +40,14 @@ func (s *Store) Hosts(groupID string, opts *om.HostListOptions) (*om.Hosts, erro
 		return nil, fmt.Errorf("unsupported service: %s", s.service)
 	}
 }
+
+// Host encapsulate the logic to manage different cloud providers
+func (s *Store) Host(groupID, hostID string) (*om.Host, error) {
+	switch s.service {
+	case config.OpsManagerService, config.CloudManagerService:
+		result, _, err := s.client.(*om.Client).Hosts.Get(context.Background(), groupID, hostID)
+		return result, err
+	default:
+		return nil, fmt.Errorf("unsupported service: %s", s.service)
+	}
+}