Api handler implementation for osupdaterun resource in apiv2 (#253)

Co-authored-by: Daniele Moro <9449199+daniele-moro@users.noreply.github.com>

Author: SushilLakra

apiv2/internal/server/os_update_run.go

@@ -5,31 +5,164 @@ package server
 
 import (
 	"context"
+	"time"
 
 	"google.golang.org/grpc/codes"
+	"google.golang.org/protobuf/types/known/timestamppb"
 
 	computev1 "github.com/open-edge-platform/infra-core/apiv2/v2/internal/pbapi/resources/compute/v1"
+	statusv1 "github.com/open-edge-platform/infra-core/apiv2/v2/internal/pbapi/resources/status/v1"
 	restv1 "github.com/open-edge-platform/infra-core/apiv2/v2/internal/pbapi/services/v1"
+	inv_computev1 "github.com/open-edge-platform/infra-core/inventory/v2/pkg/api/compute/v1"
+	inventory "github.com/open-edge-platform/infra-core/inventory/v2/pkg/api/inventory/v1"
 	"github.com/open-edge-platform/infra-core/inventory/v2/pkg/errors"
+	"github.com/open-edge-platform/infra-core/inventory/v2/pkg/validator"
 )
 
-func (is *InventorygRPCServer) ListOSUpdateRun(_ context.Context, _ *restv1.ListOSUpdateRunRequest) (
+func parseTimestamp(ts string) (*timestamppb.Timestamp, error) {
+	if ts == "" {
+		zlog.Warn().Msgf("timestamp is empty")
+		return nil, errors.Errorfc(
+			codes.InvalidArgument, "timestamp is empty",
+		)
+	}
+	parsedTime, err := time.Parse(ISO8601TimeFormat, ts)
+	if err != nil {
+		zlog.Warn().Err(err).Msgf("Failed to parse timestamp: %s", ts)
+		return nil, err
+	}
+	return timestamppb.New(parsedTime), nil
+}
+
+func fromInvOSUpdateRunResource(invOSUpdateRunResource *inv_computev1.OSUpdateRunResource) (*computev1.OSUpdateRun, error) {
+	if invOSUpdateRunResource == nil {
+		return &computev1.OSUpdateRun{}, nil
+	}
+	instance, err := fromInvInstance(invOSUpdateRunResource.GetInstance())
+	if err != nil {
+		zlog.Warn().Err(err).Msgf("Failed to get the inventory instance edge from OS Update Run resource")
+		return nil, err
+	}
+	invStatusTimestamp, err := parseTimestamp(invOSUpdateRunResource.GetStatusTimestamp())
+	if err != nil && err.Error() != errors.Errorfc(codes.InvalidArgument, "timestamp is empty").Error() {
+		zlog.Warn().Msgf("Status timestamp parsing failed for OS Update Run resource: %s", invOSUpdateRunResource.GetResourceId())
+		return nil, errors.Errorfc(
+			codes.InvalidArgument, "status timestamp parsing failed for OS Update Run resource: %s",
+			invOSUpdateRunResource.GetResourceId(),
+		)
+	}
+	invStartTime, err := parseTimestamp(invOSUpdateRunResource.GetStartTime())
+	if err != nil && err.Error() != errors.Errorfc(codes.InvalidArgument, "timestamp is empty").Error() {
+		zlog.Warn().Msgf("Start time parsing failed for OS Update Run resource: %s", invOSUpdateRunResource.GetResourceId())
+		return nil, errors.Errorfc(
+			codes.InvalidArgument, "start time parsing failed for OS Update Run resource: %s",
+			invOSUpdateRunResource.GetResourceId(),
+		)
+	}
+	invEndTime, err := parseTimestamp(invOSUpdateRunResource.GetEndTime())
+	if err != nil && err.Error() != errors.Errorfc(codes.InvalidArgument, "timestamp is empty").Error() {
+		zlog.Warn().Msgf("End time parsing failed for OS Update Run resource: %s", invOSUpdateRunResource.GetResourceId())
+		return nil, errors.Errorfc(
+			codes.InvalidArgument, "end time parsing failed for OS Update Run resource: %s",
+			invOSUpdateRunResource.GetResourceId(),
+		)
+	}
+
+	osUpdateRunResource := &computev1.OSUpdateRun{
+		ResourceId:      invOSUpdateRunResource.GetResourceId(),
+		Name:            invOSUpdateRunResource.GetName(),
+		Description:     invOSUpdateRunResource.GetDescription(),
+		AppliedPolicy:   fromInvOSUpdatePolicy(invOSUpdateRunResource.GetAppliedPolicy()),
+		Instance:        instance,
+		StatusIndicator: statusv1.StatusIndication(invOSUpdateRunResource.GetStatusIndicator()),
+		Status:          invOSUpdateRunResource.GetStatus(),
+		StatusDetails:   invOSUpdateRunResource.GetStatusDetails(),
+		StatusTimestamp: invStatusTimestamp,
+		StartTime:       invStartTime,
+		EndTime:         invEndTime,
+		Timestamps:      GrpcToOpenAPITimestamps(invOSUpdateRunResource),
+	}
+	return osUpdateRunResource, nil
+}
+
+func (is *InventorygRPCServer) ListOSUpdateRun(ctx context.Context, req *restv1.ListOSUpdateRunRequest) (
 	*restv1.ListOSUpdateRunResponse, error,
 ) {
-	// TODO implement me
-	return nil, errors.Errorfc(codes.Unimplemented, "ListOSUpdateRun not implemented")
+	zlog.Debug().Msg("ListOSUpdateRunResources")
+
+	filter := &inventory.ResourceFilter{
+		Resource: &inventory.Resource{
+			Resource: &inventory.Resource_OsUpdateRun{
+				OsUpdateRun: &inv_computev1.OSUpdateRunResource{},
+			},
+		},
+		Offset:  req.GetOffset(),
+		Limit:   req.GetPageSize(),
+		OrderBy: req.GetOrderBy(),
+		Filter:  req.GetFilter(),
+	}
+	if err := validator.ValidateMessage(filter); err != nil {
+		zlog.InfraSec().InfraErr(err).Msg("failed to validate query params")
+		return nil, errors.Wrap(err)
+	}
+	invResp, err := is.InvClient.List(ctx, filter)
+	if err != nil {
+		zlog.InfraErr(err).Msg("Failed to list OS resources from inventory")
+		return nil, errors.Wrap(err)
+	}
+
+	osUpdateRunResources := []*computev1.OSUpdateRun{}
+	for _, invRes := range invResp.GetResources() {
+		osUpdateRunResource, err := fromInvOSUpdateRunResource(invRes.GetResource().GetOsUpdateRun())
+		if err != nil {
+			zlog.InfraErr(err).Msgf("Failed to convert inventory OS Update Run resource %s",
+				invRes.GetResource().GetOsUpdateRun().GetResourceId())
+			return nil, errors.Wrap(err)
+		}
+		osUpdateRunResources = append(osUpdateRunResources, osUpdateRunResource)
+	}
+
+	resp := &restv1.ListOSUpdateRunResponse{
+		OsUpdateRuns:  osUpdateRunResources,
+		TotalElements: invResp.GetTotalElements(),
+		HasNext:       invResp.GetHasNext(),
+	}
+	zlog.Debug().Msgf("Listed %s", resp)
+	return resp, nil
 }
 
-func (is *InventorygRPCServer) GetOSUpdateRun(_ context.Context, _ *restv1.GetOSUpdateRunRequest) (
+func (is *InventorygRPCServer) GetOSUpdateRun(ctx context.Context, req *restv1.GetOSUpdateRunRequest) (
 	*computev1.OSUpdateRun, error,
 ) {
-	// TODO implement me
-	return nil, errors.Errorfc(codes.Unimplemented, "GetOSUpdateRun not implemented")
+	zlog.Debug().Msg("GetOSUpdateRunResource")
+
+	invResp, err := is.InvClient.Get(ctx, req.GetResourceId())
+	if err != nil {
+		zlog.InfraErr(err).Msg("Failed to get OS Update Run resource from inventory")
+		return nil, errors.Wrap(err)
+	}
+
+	invOSUpdateRunResource := invResp.GetResource().GetOsUpdateRun()
+	osUpdateRunResource, err := fromInvOSUpdateRunResource(invOSUpdateRunResource)
+	if err != nil {
+		zlog.InfraErr(err).Msgf("Failed to convert inventory OS Update Run resource %s", invOSUpdateRunResource.GetResourceId())
+		return nil, errors.Wrap(err)
+	}
+
+	zlog.Debug().Msgf("Got %s", osUpdateRunResource)
+	return osUpdateRunResource, nil
 }
 
-func (is *InventorygRPCServer) DeleteOSUpdateRun(_ context.Context, _ *restv1.DeleteOSUpdateRunRequest) (
+func (is *InventorygRPCServer) DeleteOSUpdateRun(ctx context.Context, req *restv1.DeleteOSUpdateRunRequest) (
 	*restv1.DeleteOSUpdateRunResponse, error,
 ) {
-	// TODO implement me
-	return nil, errors.Errorfc(codes.Unimplemented, "DeleteOSUpdateRun not implemented")
+	zlog.Debug().Msg("DeleteOSUpdateRunResource")
+
+	_, err := is.InvClient.Delete(ctx, req.GetResourceId())
+	if err != nil {
+		zlog.InfraErr(err).Msg("Failed to delete OS Update Run resource from inventory")
+		return nil, errors.Wrap(err)
+	}
+	zlog.Debug().Msgf("Deleted %s", req.GetResourceId())
+	return &restv1.DeleteOSUpdateRunResponse{}, nil
 }