fix(#5686): fix pbh_origin_icon for pbh without tstop + fix delete /e…

…ntity-pbehaviors endpoint for pbh without tstop
capensis · Nov 11, 2024 · ebbdc74 · ebbdc74
1 parent fc670fb
commit ebbdc74
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 2 deletions.
diff --git a/community/go-engines-community/lib/api/pbehavior/store.go b/community/go-engines-community/lib/api/pbehavior/store.go
@@ -667,7 +667,10 @@ func (s *store) EntityDelete(ctx context.Context, r BulkEntityDeleteRequestItem)
 				"entity": r.Entity,
 				"origin": r.Origin,
 				"tstart": bson.M{"$lte": now},
-				"tstop":  bson.M{"$gte": now},
+				"$or": bson.A{
+					bson.M{"tstop": nil},
+					bson.M{"tstop": bson.M{"$gte": now}},
+				},
 			}, options.FindOneAndDelete().SetProjection(bson.M{"_id": 1})).
 			Decode(&pbh)
 		if err != nil {

diff --git a/community/go-engines-community/lib/api/serviceweather/mongo_query.go b/community/go-engines-community/lib/api/serviceweather/mongo_query.go
@@ -616,7 +616,10 @@ func getPbhOriginLookup(origin string, now datetime.CpsTime) []bson.M {
 				{"$match": bson.M{
 					"origin": origin,
 					"tstart": bson.M{"$lte": now},
-					"tstop":  bson.M{"$gte": now},
+					"$or": bson.A{
+						bson.M{"tstop": nil},
+						bson.M{"tstop": bson.M{"$gte": now}},
+					},
 				}},
 				{"$limit": 1},
 			},