Fix #339: Add endpoint to list IDPs

Signed-off-by: George J Padayatti <[email protected]>

src/v2/handler/idp/config_list_idps.go

@@ -0,0 +1,74 @@
+package idp
+
+import (
+	"context"
+	"encoding/json"
+	"errors"
+	"net/http"
+
+	"github.com/bb-consent/api/src/common"
+	"github.com/bb-consent/api/src/config"
+	"github.com/bb-consent/api/src/v2/idp"
+	"github.com/bb-consent/api/src/v2/paginate"
+)
+
+func returnHTTPResponse(resp interface{}, w http.ResponseWriter) {
+	response, _ := json.Marshal(resp)
+	w.Header().Set(config.ContentTypeHeader, config.ContentTypeJSON)
+	w.WriteHeader(http.StatusOK)
+	w.Write(response)
+}
+
+type listIdpsResp struct {
+	Idps       interface{}         `json:"idps"`
+	Pagination paginate.Pagination `json:"pagination"`
+}
+
+// ConfigListIdps
+func ConfigListIdps(w http.ResponseWriter, r *http.Request) {
+
+	// Headers
+	organisationId := r.Header.Get(config.OrganizationId)
+	organisationId = common.Sanitize(organisationId)
+
+	var resp listIdpsResp
+
+	// Query params
+	offset, limit := paginate.ParsePaginationQueryParams(r)
+
+	// Repository
+	idpRepo := idp.IdentityProviderRepository{}
+	idpRepo.Init(organisationId)
+
+	// Paginate idps
+	var idps []idp.IdentityProvider
+	query := paginate.PaginateDBObjectsQuery{
+		Filter:     idpRepo.DefaultFilter,
+		Collection: idp.Collection(),
+		Context:    context.Background(),
+		Limit:      limit,
+		Offset:     offset,
+	}
+	result, err := paginate.PaginateDBObjects(query, &idps)
+	if err != nil {
+		if errors.Is(err, paginate.EmptyDBError) {
+			emptyIdps := make([]interface{}, 0)
+			resp = listIdpsResp{
+				Idps:       emptyIdps,
+				Pagination: result.Pagination,
+			}
+			returnHTTPResponse(resp, w)
+			return
+		}
+		m := "Failed to paginate idps"
+		common.HandleErrorV2(w, http.StatusInternalServerError, m, err)
+		return
+
+	}
+	resp = listIdpsResp{
+		Idps:       result.Items,
+		Pagination: result.Pagination,
+	}
+
+	returnHTTPResponse(resp, w)
+}

src/v2/http_path/config_paths.go

@@ -45,6 +45,7 @@ const AddIdentityProvider = "/v2/config/idp/open-id"
 const UpdateIdentityProvider = "/v2/config/idp/open-id/{idpId}"
 const DeleteIdentityProvider = "/v2/config/idp/open-id/{idpId}"
 const GetIdentityProvider = "/v2/config/idp/open-id/{idpId}"
+const ConfigListIdentityProviders = "/v2/config/idps"
 
 // Individuals
 const ConfigCreateIndividual = "/v2/config/individual"

src/v2/http_path/routes.go

@@ -61,6 +61,7 @@ func SetRoutes(r *mux.Router, e *casbin.Enforcer) {
 	r.Handle(UpdateIdentityProvider, m.Chain(idpHandler.UpdateIdentityProvider, m.Logger(), m.Authorize(e), m.Authenticate(), m.AddContentType())).Methods("PUT")
 	r.Handle(DeleteIdentityProvider, m.Chain(idpHandler.DeleteIdentityProvider, m.Logger(), m.Authorize(e), m.Authenticate(), m.AddContentType())).Methods("DELETE")
 	r.Handle(GetIdentityProvider, m.Chain(idpHandler.GetIdentityProvider, m.Logger(), m.Authorize(e), m.Authenticate(), m.AddContentType())).Methods("GET")
+	r.Handle(ConfigListIdentityProviders, m.Chain(idpHandler.ConfigListIdps, m.Logger(), m.Authorize(e), m.Authenticate(), m.AddContentType())).Methods("GET")
 
 	// Individual related api(s)
 	r.Handle(ConfigReadIndividual, m.Chain(individualHandler.ConfigReadIndividual, m.Logger(), m.Authorize(e), m.SetApplicationMode(), m.Authenticate(), m.AddContentType())).Methods("GET")

src/v2/idp/idp.go

@@ -17,7 +17,7 @@ func Collection() *mongo.Collection {
 type IdentityProvider struct {
 	Id               primitive.ObjectID `json:"id" bson:"_id,omitempty"`
 	IssuerUrl        string             `json:"issuerUrl"`
-	AuthorizationURL string             `json:"authorizationUrl" valid:"required"`
+	AuthorizationURL string             `json:"authorisationUrl" valid:"required"`
 	TokenURL         string             `json:"tokenUrl" valid:"required"`
 	LogoutURL        string             `json:"logoutUrl" valid:"required"`
 	ClientID         string             `json:"clientId" valid:"required"`