add open stats for bucket info and fixed the aggregate per api key

api/open_status_check.go

@@ -30,6 +30,23 @@ func ConfigureOpenStatusCheckRouter(e *echo.Group, node *core.LightNode) {
 			"content": content,
 		})
 	})
+
+	e.GET("/status/bucket/:uuid", func(c echo.Context) error {
+		var bucket core.Bucket
+		node.DB.Model(&core.Bucket{}).Where("uuid = ?", c.Param("uuid")).Scan(&bucket)
+		if bucket.ID == 0 {
+			return c.JSON(404, map[string]interface{}{
+				"message": "Bucket not found. Please check if you have the proper API key or if the bucket uuid is valid",
+			})
+		}
+
+		bucket.RequestingApiKey = ""
+		return c.JSON(200, map[string]interface{}{
+			"bucket": bucket,
+		})
+		return nil
+	})
+
 	e.GET("/status/bucket/contents/:uuid", func(c echo.Context) error {
 		var bucket core.Bucket
 		node.DB.Model(&core.Bucket{}).Where("uuid = ?", c.Param("uuid")).Scan(&bucket)

jobs/aggregate.go

@@ -49,7 +49,7 @@ func (r *AggregateProcessor) Run() error {
 
 	for _, bucket := range buckets {
 		var content []core.Content
-		r.LightNode.DB.Model(&core.Content{}).Where(query, bucket.Uuid, bucket.RequestingApiKey).Find(&content)
+		r.LightNode.DB.Model(&core.Content{}).Where(query, bucket.Uuid, r.Content.RequestingApiKey).Find(&content)
 		var totalSize int64
 		var aggContent []core.Content
 		for _, c := range content {