working endpoint

api/api.go

@@ -142,6 +142,9 @@ func (a *API) initRouter() http.Handler {
 		// get organization information
 		log.Infow("new route", "method", "GET", "path", organizationEndpoint)
 		r.Get(organizationEndpoint, a.organizationInfoHandler)
+		// get organization members
+		log.Infow("new route", "method", "GET", "path", organizationMembersEndpoint)
+		r.Get(organizationMembersEndpoint, a.organizationMembersHandler)
 	})
 	a.router = r
 	return r

api/organizations.go

@@ -102,6 +102,46 @@ func (a *API) organizationInfoHandler(w http.ResponseWriter, r *http.Request) {
 	httpWriteJSON(w, organizationFromDB(org, parent))
 }
 
+// organizationMembersHandler handles the request to get the members of an
+// organization. It returns the list of members with their role in the
+// organization with the address provided in the request.
+func (a *API) organizationMembersHandler(w http.ResponseWriter, r *http.Request) {
+	// get the organization info from the request context
+	org, _, ok := a.organizationFromRequest(r)
+	if !ok {
+		ErrUnauthorized.Write(w)
+		return
+	}
+	// send the organization back to the user
+	members, err := a.db.OrganizationsMembers(org.Address)
+	if err != nil {
+		ErrGenericInternalServerError.Withf("could not get organization members: %v", err).Write(w)
+		return
+	}
+	orgMembers := []OrganizationMember{}
+	for _, member := range members {
+		var role string
+		for _, userOrg := range member.Organizations {
+			if userOrg.Address == org.Address {
+				role = string(userOrg.Role)
+				break
+			}
+		}
+		if role == "" {
+			continue
+		}
+		orgMembers = append(orgMembers, OrganizationMember{
+			Info: &UserInfo{
+				Email:     member.Email,
+				FirstName: member.FirstName,
+				LastName:  member.LastName,
+			},
+			Role: role,
+		})
+	}
+	httpWriteJSON(w, orgMembers)
+}
+
 // updateOrganizationHandler handles the request to update the information of an
 // organization. Only the admin of the organization can update the information.
 // Only certain fields can be updated, and they will be updated only if they are

api/routes.go

@@ -31,4 +31,6 @@ const (
 	organizationsEndpoint = "/organizations"
 	// GET /organizations/{address} to get the organization information
 	organizationEndpoint = "/organizations/{address}"
+	// GET /organizations/{address}/members to get the organization members
+	organizationMembersEndpoint = "/organizations/{address}/members"
 )

api/types.go

@@ -23,6 +23,13 @@ type OrganizationInfo struct {
 	Parent      *OrganizationInfo `json:"parent"`
 }
 
+// OrganizationMember is the struct that represents a members of organizations
+// with his role in the API.
+type OrganizationMember struct {
+	Info *UserInfo `json:"info"`
+	Role string    `json:"role"`
+}
+
 // OrganizationAddresses is the struct that represents a list of addresses of
 // organizations in the API.
 type OrganizationAddresses struct {

db/organizations.go

@@ -112,3 +112,31 @@ func (ms *MongoStorage) ReplaceCreatorEmail(oldEmail, newEmail string) error {
 	}
 	return nil
 }
+
+// OrganizationsMembers method returns the users that are members of the
+// organization with the given address. If an error occurs, it returns the
+// error.
+func (ms *MongoStorage) OrganizationsMembers(address string) ([]User, error) {
+	ms.keysLock.RLock()
+	defer ms.keysLock.RUnlock()
+	// create a context with a timeout
+	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
+	defer cancel()
+	// find the organization in the database
+	filter := bson.M{
+		"organizations": bson.M{
+			"$elemMatch": bson.M{
+				"_id": address,
+			},
+		},
+	}
+	users := []User{}
+	cursor, err := ms.users.Find(ctx, filter)
+	if err != nil {
+		return nil, err
+	}
+	if err := cursor.All(ctx, &users); err != nil {
+		return nil, err
+	}
+	return users, nil
+}

db/organizations_test.go

@@ -160,3 +160,32 @@ func TestReplaceCreatorEmail(t *testing.T) {
 	c.Assert(org.Name, qt.Equals, name)
 	c.Assert(org.Creator, qt.Equals, newCreator)
 }
+
+func TestOrganizationsMembers(t *testing.T) {
+	defer func() {
+		if err := db.Reset(); err != nil {
+			t.Error(err)
+		}
+	}()
+	c := qt.New(t)
+	// create a new organization with a creator
+	address := "orgToReplaceCreator"
+	name := "Organization to replace creator"
+	c.Assert(db.SetUser(&User{
+		Email:    testUserEmail,
+		Password: testUserPass,
+	}), qt.IsNil)
+	c.Assert(db.SetOrganization(&Organization{
+		Address: address,
+		Name:    name,
+		Creator: testUserEmail,
+	}), qt.IsNil)
+	_, _, err := db.Organization(address, false)
+	c.Assert(err, qt.IsNil)
+	// get the organization members
+	members, err := db.OrganizationsMembers(address)
+	c.Assert(err, qt.IsNil)
+	c.Assert(members, qt.HasLen, 1)
+	singleMember := members[0]
+	c.Assert(singleMember.Email, qt.Equals, testUserEmail)
+}