feature: Added method to event store to get events by resource id

wepala · Aug 18, 2024 · f9eeb9e · f9eeb9e
1 parent b4eead8
commit f9eeb9e
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/rest/gorm.go b/rest/gorm.go
@@ -397,6 +397,18 @@ func (e *GORMProjection) ResourceDeleteHandler(ctx context.Context, logger Log,
 	return err
 }
 
+// GetByResourceID gets events by resource id
+func (e *GORMProjection) GetByResourceID(ctxt context.Context, logger Log, resourceID string) (events []*Event, err error) {
+	result := e.gormDB.Model(&Event{}).Where("meta.resource_id = ?", resourceID).Find(events)
+	if result.Error != nil && !errors.Is(result.Error, gorm.ErrRecordNotFound) {
+		logger.Errorf("error getting events for resource %s: %v", resourceID, result.Error)
+		err = result.Error
+		return
+	}
+
+	return
+}
+
 // List Query Stuff
 
 type QueryFilterModifier func(options map[string]FilterProperty) func(db *gorm.DB) *gorm.DB