Upd: Service verification list all data agreements

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

internal/handler/v2/service/service_verification_list_all_data_agreements.go

@@ -0,0 +1,146 @@
+package service
+
+import (
+	"errors"
+	"fmt"
+	"log"
+	"net/http"
+
+	"github.com/bb-consent/api/internal/common"
+	"github.com/bb-consent/api/internal/config"
+	"github.com/bb-consent/api/internal/dataagreement"
+	"github.com/bb-consent/api/internal/paginate"
+	"github.com/bb-consent/api/internal/revision"
+)
+
+// listDataAgreementsError is an error enumeration for list data agreement API.
+type listDataAgreementsError int
+
+const (
+	// ErrRevisionIDIsMissing indicates that the revisionId query param is missing.
+	revisionIDIsMissingError listDataAgreementsError = iota
+	lifecycleIsMissingError
+)
+
+// Error returns the string representation of the error.
+func (e listDataAgreementsError) Error() string {
+	switch e {
+	case revisionIDIsMissingError:
+		return "Query param revisionId is missing!"
+	default:
+		return "Unknown error!"
+	}
+}
+
+// parseListDataAgreementsQueryParams parses query params for listing data agreements.
+func parseListDataAgreementsQueryParams(r *http.Request) (revisionId string, err error) {
+	query := r.URL.Query()
+
+	// Check if revisionId query param is provided.
+	if r, ok := query["revisionId"]; ok && len(r) > 0 {
+		return r[0], nil
+	}
+
+	return "", revisionIDIsMissingError
+}
+
+func verificationActiveDataAgreementsFromObjectData(organisationId string) ([]interface{}, error) {
+	var activeDataAgreements []interface{}
+	dataAgreements, err := dataagreement.GetAllDataAgreementsWithLatestRevisionsObjectData(organisationId)
+	if err != nil {
+		return activeDataAgreements, err
+	}
+
+	for _, dataAgreement := range dataAgreements {
+		if len(dataAgreement.ObjectData) >= 1 {
+			// Recreate data agreement from revision
+			activeDataAgreement, err := revision.RecreateDataAgreementFromObjectData(dataAgreement.ObjectData)
+			if err != nil {
+				return activeDataAgreements, err
+			}
+			activeDataAgreements = append(activeDataAgreements, activeDataAgreement)
+		}
+	}
+
+	return activeDataAgreements, nil
+}
+
+type verificationListDataAgreementsResp struct {
+	DataAgreements interface{}         `json:"dataAgreements"`
+	Pagination     paginate.Pagination `json:"pagination"`
+}
+
+// ServiceVerificationListDataAgreements
+func ServiceVerificationListDataAgreements(w http.ResponseWriter, r *http.Request) {
+	// Headers
+	organisationId := r.Header.Get(config.OrganizationId)
+	organisationId = common.Sanitize(organisationId)
+
+	var resp verificationListDataAgreementsResp
+
+	// Query params
+	offset, limit := paginate.ParsePaginationQueryParams(r)
+	log.Printf("Offset: %v and limit: %v\n", offset, limit)
+	revisionId, err := parseListDataAgreementsQueryParams(r)
+	revisionId = common.Sanitize(revisionId)
+	if err != nil && errors.Is(err, revisionIDIsMissingError) {
+
+		darepo := dataagreement.DataAgreementRepository{}
+		darepo.Init(organisationId)
+
+		activeDataAgreements, err := verificationActiveDataAgreementsFromObjectData(organisationId)
+		if err != nil {
+			common.HandleErrorV2(w, http.StatusInternalServerError, "Failed to fetch active data agreements", err)
+			return
+		}
+
+		query := paginate.PaginateObjectsQuery{
+			Limit:  limit,
+			Offset: offset,
+		}
+		result := paginate.PaginateObjects(query, activeDataAgreements)
+
+		resp = verificationListDataAgreementsResp{
+			DataAgreements: result.Items,
+			Pagination:     result.Pagination,
+		}
+		common.ReturnHTTPResponse(resp, w)
+		return
+
+	} else {
+		// Fetch revision by id
+		revisionResp, err := revision.GetByRevisionId(revisionId)
+		if err != nil {
+			m := fmt.Sprintf("Failed to fetch revision by id: %v", revisionId)
+			common.HandleErrorV2(w, http.StatusInternalServerError, m, err)
+			return
+		}
+
+		// Recreate data agreement from revision
+		da, err := revision.RecreateDataAgreementFromRevision(revisionResp)
+		if err != nil {
+			m := fmt.Sprintf("Failed to fetch data agreement by revision: %v", revisionId)
+			common.HandleErrorV2(w, http.StatusInternalServerError, m, err)
+			return
+		}
+
+		interfaceSlice := make([]interface{}, 0)
+		interfaceSlice = append(interfaceSlice, da)
+
+		// Constructing the response
+		resp = verificationListDataAgreementsResp{
+			DataAgreements: interfaceSlice,
+			Pagination: paginate.Pagination{
+				CurrentPage: 1,
+				TotalItems:  1,
+				TotalPages:  1,
+				Limit:       1,
+				HasPrevious: false,
+				HasNext:     false,
+			},
+		}
+
+	}
+
+	common.ReturnHTTPResponse(resp, w)
+}

internal/http_path/v2/routes.go

@@ -99,7 +99,7 @@ func SetRoutes(r *mux.Router, e *casbin.Enforcer) {
 
 	// Verification mechanisms
 
-	r.Handle(ServiceVerificationFetchAllDataAgreementRecords, m.Chain(serviceHandler.ServiceFetchDataAgreementRecords, m.Logger(), m.Authorize(e), m.SetApplicationMode(), m.ValidateAPIKey(), m.Authenticate(), m.AddContentType())).Methods("GET")
+	r.Handle(ServiceVerificationListDataAgreements, m.Chain(serviceHandler.ServiceVerificationListDataAgreements, m.Logger(), m.Authorize(e), m.SetApplicationMode(), m.ValidateAPIKey(), m.Authenticate(), m.AddContentType())).Methods("GET")
 	r.Handle(ServiceVerificationFetchDataAgreementRecord, m.Chain(serviceHandler.ServiceVerificationFetchDataAgreementRecord, m.Logger(), m.Authorize(e), m.SetApplicationMode(), m.ValidateAPIKey(), m.Authenticate(), m.AddContentType())).Methods("GET")
 	r.Handle(ServiceVerificationFetchDataAgreementRecords, m.Chain(serviceHandler.ServiceVerificationFetchDataAgreementRecords, m.Logger(), m.Authorize(e), m.SetApplicationMode(), m.ValidateAPIKey(), m.Authenticate(), m.AddContentType())).Methods("GET")
 

internal/http_path/v2/service_paths.go

@@ -11,7 +11,7 @@ const ServiceReadPolicy = "/v2/service/policy/{policyId}"
 const ServiceListDataAttributesForDataAgreement = "/v2/service/data-agreement/{dataAgreementId}/data-attributes"
 
 // Verification mechanisms
-const ServiceVerificationFetchAllDataAgreementRecords = "/v2/service/verification/data-agreements"
+const ServiceVerificationListDataAgreements = "/v2/service/verification/data-agreements"
 const ServiceVerificationFetchDataAgreementRecord = "/v2/service/verification/consent-record/{consentRecordId}"
 const ServiceVerificationFetchDataAgreementRecords = "/v2/service/verification/consent-records"