add diags services

services/diags.go

@@ -0,0 +1,55 @@
+package services
+
+import (
+	"context"
+	// "time"
+
+	diags "git.coopgo.io/coopgo-platform/diags/grpcapi"
+	"git.coopgo.io/coopgo-platform/diags/storage"
+	"google.golang.org/grpc"
+	// "google.golang.org/protobuf/types/known/timestamppb"
+)
+
+type DiagsService struct {
+	diags.DiagsClient
+}
+
+func NewDiagsService(dial string) (*DiagsService, error) {
+	conn, err := grpc.Dial(dial, grpc.WithInsecure())
+
+	client := diags.NewDiagsClient(conn)
+	if err != nil {
+		return nil, err
+	}
+
+	return &DiagsService{
+		DiagsClient: client,
+	}, nil
+}
+
+func (s *ServicesHandler) GetDiagsDiags() ([]DiagsDiag, error) {
+	resp, err := s.GRPC.Diags.GetDiags(context.TODO(), &diags.GetDiagsRequest{
+		Namespaces: []string{"parcoursmob_beneficiaires", "parcoursmob_diagnostiques"},
+	})
+	if err != nil {
+		return nil, err
+	}
+
+	diags := []DiagsDiag{}
+
+	for _, e := range resp.Diags {
+		newDiag := DiagsDiag{
+			Diag: e.ToStorageType(),
+		}
+		diags = append(diags, newDiag)
+	}
+
+	return diags, nil
+}
+
+// Enriched types
+
+type DiagsDiag struct {
+	OwnersGroups []GroupsManagementGroup
+	storage.Diag
+}

services/services.go

@@ -27,6 +27,7 @@ func NewServicesHandler(cfg *viper.Viper) (*ServicesHandler, error) {
 		groupsManagementDial = cfg.GetString("services.grpc.groupsmanagement.dial")
 		fleetsDial           = cfg.GetString("services.grpc.fleets.dial")
 		agendaDial           = cfg.GetString("services.grpc.agenda.dial")
+		diagsDial            = cfg.GetString("services.grpc.diags.dial")
 	)
 	mobilityAccounts, err := NewMobilityAccountService(mobilityAccountsDial)
 	if err != nil {
@@ -48,12 +49,18 @@ func NewServicesHandler(cfg *viper.Viper) (*ServicesHandler, error) {
 		return nil, err
 	}
 
+	diagsSvc, err := NewDiagsService(diagsDial)
+	if err != nil {
+		return nil, err
+	}
+
 	return &ServicesHandler{
 		GRPC: GRPCServices{
 			MobilityAccounts: mobilityAccounts,
 			GroupsManagement: groupsManagement,
 			Fleets:           fleetsSvc,
 			Agenda:           agendaSvc,
+			Diags:            diagsSvc,
 		},
 	}, nil
 }