refactor(api): update GetStats to fetch status from devices collection

Author: gustavosbarreto

api/store/mongo/device.go

@@ -353,7 +353,6 @@ func (s *Store) DeviceSetOnline(ctx context.Context, uid models.UID, timestamp t
 		UID:      device.UID,
 		TenantID: device.TenantID,
 		LastSeen: device.LastSeen,
-		Status:   string(device.Status),
 	}
 
 	updated := cd.LastSeen.Before(timestamp)

api/store/mongo/stats.go

@@ -23,11 +23,26 @@ func (s *Store) GetStats(ctx context.Context) (*models.Stats, error) {
 		}}, query...)
 	}
 
-	query = append([]bson.M{{
-		"$match": bson.M{
-			"status": "accepted",
+	query = append([]bson.M{
+		{
+			"$lookup": bson.M{
+				"from":         "devices",
+				"localField":   "uid",
+				"foreignField": "uid",
+				"as":           "device",
+			},
 		},
-	}}, query...)
+		{
+			"$addFields": bson.M{
+				"status": "$device.status",
+			},
+		},
+		{
+			"$match": bson.M{
+				"status": "accepted",
+			},
+		},
+	}, query...)
 
 	onlineDevices, err := AggregateCount(ctx, s.db.Collection("connected_devices"), query)
 	if err != nil {

pkg/models/device.go

@@ -86,7 +86,7 @@ type ConnectedDevice struct {
 	UID      string    `json:"uid"`
 	TenantID string    `json:"tenant_id" bson:"tenant_id"`
 	LastSeen time.Time `json:"last_seen" bson:"last_seen"`
-	Status   string    `json:"status" bson:"status"`
+	Status   string    `json:"status" bson:",omitempty"`
 }
 
 type DevicePosition struct {