feat: add GET process (#311)

Author: gssbzn

mongodbatlas/processes.go

@@ -26,6 +26,7 @@ const processesPath = "api/atlas/v1.0/groups/%s/processes"
 //
 // See more: https://docs.atlas.mongodb.com/reference/api/monitoring-and-logs/
 type ProcessesService interface {
+	Get(context.Context, string, string, int) (*Process, *Response, error)
 	List(context.Context, string, *ProcessesListOptions) ([]*Process, *Response, error)
 }
 
@@ -64,6 +65,36 @@ type ProcessesListOptions struct {
 	ClusterID string `url:"clusterId,omitempty"` // ClusterID is only available for Ops Manager and CLoud Manager.
 }
 
+// Get information for the specified Atlas MongoDB process in the specified project.
+// An Atlas MongoDB process can be either a mongod or a mongos.
+//
+// See more: https://www.mongodb.com/docs/atlas/reference/api/processes-get-one/
+func (s *ProcessesServiceOp) Get(ctx context.Context, groupID, hostname string, port int) (*Process, *Response, error) {
+	if groupID == "" {
+		return nil, nil, NewArgError("groupID", "must be set")
+	}
+	if hostname == "" {
+		return nil, nil, NewArgError("hostname", "must be set")
+	}
+	if port == 0 {
+		return nil, nil, NewArgError("port", "must be set")
+	}
+	path := fmt.Sprintf(processesPath, groupID)
+	path = fmt.Sprintf("%s/%s:%d", path, hostname, port)
+	req, err := s.Client.NewRequest(ctx, http.MethodGet, path, nil)
+	if err != nil {
+		return nil, nil, err
+	}
+
+	root := new(Process)
+	resp, err := s.Client.Do(ctx, req, root)
+	if err != nil {
+		return nil, resp, err
+	}
+
+	return root, resp, nil
+}
+
 // List lists all processes in the project associated to {GROUP-ID}.
 //
 // See more: https://docs.atlas.mongodb.com/reference/api/processes-get-all/

mongodbatlas/processes_test.go

@@ -221,7 +221,7 @@ func TestProcesses_RetrievePageByNumber(t *testing.T) {
 		}
 	`
 
-	mux.HandleFunc("/api/atlas/v1.0/groups/1/processes", func(w http.ResponseWriter, r *http.Request) {
+	mux.HandleFunc(fmt.Sprintf("/api/atlas/v1.0/groups/%s/processes", groupID), func(w http.ResponseWriter, r *http.Request) {
 		testMethod(t, r, http.MethodGet)
 		expectedQuery := "pageNum=2"
 		if r.URL.RawQuery != expectedQuery {
@@ -240,3 +240,48 @@ func TestProcesses_RetrievePageByNumber(t *testing.T) {
 
 	checkCurrentPage(t, resp, 2)
 }
+
+func TestProcessesServiceOp_Get(t *testing.T) {
+	client, mux, teardown := setup()
+	defer teardown()
+	const hostname = "atlas-abcdef-shard-00-00.nta8e.mongodb.net"
+	const port = 27017
+	path := fmt.Sprintf("/api/atlas/v1.0/groups/%s/processes/%s:%d", groupID, hostname, port)
+	mux.HandleFunc(path, func(w http.ResponseWriter, r *http.Request) {
+		testMethod(t, r, http.MethodGet)
+		_, _ = fmt.Fprint(w, `{
+		  "created" : "2020-08-25T18:44:13Z",
+		  "groupId" : "1",
+		  "hostname" : "atlas-abcdef-shard-00-00.nta8e.mongodb.net",
+		  "id" : "atlas-abcdef-shard-00-00.nta8e.mongodb.net:27017",
+		  "lastPing" : "2020-09-01T18:40:06Z",
+		  "port" : 27017,
+		  "replicaSetName" : "atlas-abcdef-shard-0",
+		  "typeName" : "REPLICA_PRIMARY",
+		  "userAlias" : "testcluster-shard-00-00.nta8e.mongodb.net",
+		  "version" : "4.4.0"
+		}`)
+	})
+
+	cluster, _, err := client.Processes.Get(ctx, groupID, hostname, port)
+	if err != nil {
+		t.Fatalf("Processes.Get returned error: %v", err)
+	}
+
+	expected := &Process{
+		ID:             "atlas-abcdef-shard-00-00.nta8e.mongodb.net:27017",
+		GroupID:        groupID,
+		Hostname:       hostname,
+		TypeName:       "REPLICA_PRIMARY",
+		Created:        "2020-08-25T18:44:13Z",
+		LastPing:       "2020-09-01T18:40:06Z",
+		Port:           port,
+		ReplicaSetName: "atlas-abcdef-shard-0",
+		UserAlias:      "testcluster-shard-00-00.nta8e.mongodb.net",
+		Version:        "4.4.0",
+	}
+
+	if diff := deep.Equal(cluster, expected); diff != nil {
+		t.Error(diff)
+	}
+}