From 73dc4974a23b580de47bcfd0e1871832a28fa9b5 Mon Sep 17 00:00:00 2001 From: Nikita Tokarchuk Date: Wed, 22 Jul 2020 04:45:32 +0200 Subject: [PATCH] Add query context support for an array deleting --- mongox/database/deletearray.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/mongox/database/deletearray.go b/mongox/database/deletearray.go index 4fe5988..fe35d65 100644 --- a/mongox/database/deletearray.go +++ b/mongox/database/deletearray.go @@ -39,6 +39,7 @@ func (d *Database) DeleteArray(target interface{}, filters ...interface{}) (err opts := options.Delete() ids := primitive.A{} composed := query.Compose(filters...) + ctx := query.WithContext(d.Context(), composed) for i := 0; i < targetLen; i++ { elem := targetSliceV.Index(i) @@ -51,7 +52,7 @@ func (d *Database) DeleteArray(target interface{}, filters ...interface{}) (err composed.And(primitive.M{"_id": primitive.M{"$in": ids}}) - result, err := collection.DeleteMany(d.Context(), composed.M(), opts) + result, err := collection.DeleteMany(ctx, composed.M(), opts) if err != nil { return }