handle 404 error to avoid handling a not found resource continuously (#277)

Signed-off-by: Wei Liu <liuweixa@redhat.com>

Author: skeeey

cmd/maestro/server/event_server.go

@@ -269,6 +269,10 @@ func broadcastStatusEvent(ctx context.Context,
 	} else {
 		resource, sErr = resourceService.Get(ctx, resourceID)
 		if sErr != nil {
+			if sErr.Is404() {
+				log.Infof("skipping resource %s as it is not found", resource.ID)
+				return nil
+			}
 			return fmt.Errorf("failed to get resource %s: %s", resourceID, sErr.Error())
 		}
 	}

pkg/client/cloudevents/source_client.go

@@ -59,9 +59,19 @@ func NewSourceClient(sourceOptions *ceoptions.CloudEventsSourceOptions, resource
 func (s *SourceClientImpl) OnCreate(ctx context.Context, id string) error {
 	resource, err := s.ResourceService.Get(ctx, id)
 	if err != nil {
+		if err.Is404() {
+			log.Infof("skipping to publish create request for resource %s as it is not found", resource.ID)
+			return nil
+		}
+
 		return err
 	}
 
+	if !resource.Meta.DeletedAt.Time.IsZero() {
+		log.Infof("delete resource %s as it is not created on the agent yet", resource.ID)
+		return s.ResourceService.Delete(ctx, id)
+	}
+
 	log.Infof("Publishing resource %s for db row insert", resource.ID)
 	eventType := cetypes.CloudEventsType{
 		CloudEventsDataType: s.Codec.EventDataType(),
@@ -79,6 +89,10 @@ func (s *SourceClientImpl) OnCreate(ctx context.Context, id string) error {
 func (s *SourceClientImpl) OnUpdate(ctx context.Context, id string) error {
 	resource, err := s.ResourceService.Get(ctx, id)
 	if err != nil {
+		if err.Is404() {
+			log.Infof("skipping to publish update request for resource %s as it is not found", resource.ID)
+			return nil
+		}
 		return err
 	}
 
@@ -99,6 +113,10 @@ func (s *SourceClientImpl) OnUpdate(ctx context.Context, id string) error {
 func (s *SourceClientImpl) OnDelete(ctx context.Context, id string) error {
 	resource, err := s.ResourceService.Get(ctx, id)
 	if err != nil {
+		if err.Is404() {
+			log.Infof("skipping to publish delete request for resource %s as it is not found", resource.ID)
+			return nil
+		}
 		return err
 	}