update updateMany func

internal/mopertest/aggregation_test.go

@@ -37,6 +37,7 @@ func TestAggregation(t *testing.T) {
 
 	if int(result[0]["total"].(int32)) != expect {
 		t.Error("wrong result", result[0]["total"], expect)
+		return
 	}
 }
 

mocom/index.go

@@ -0,0 +1,20 @@
+package mocom
+
+import (
+	"context"
+
+	"go.mongodb.org/mongo-driver/mongo"
+	"go.mongodb.org/mongo-driver/mongo/options"
+)
+
+func AddIndex[T Model](ctx context.Context, index mongo.IndexModel, opts ...*options.CreateIndexesOptions) (string, error) {
+	var t T
+	col := collWrite(t.CollName())
+	return col.Indexes().CreateOne(ctx, index, opts...)
+}
+
+func AddIndexes[T Model](ctx context.Context, indexes []mongo.IndexModel, opts ...*options.CreateIndexesOptions) ([]string, error) {
+	var t T
+	col := collWrite(t.CollName())
+	return col.Indexes().CreateMany(ctx, indexes, opts...)
+}

mocom/update.go

@@ -24,7 +24,7 @@ func UpdateAndReturn[T Model](ctx context.Context, filter interface{}, update in
 	return
 }
 
-func UpdateMany[T Model](ctx context.Context, filter interface{}, update interface{}) (*mongo.UpdateResult, error) {
+func UpdateMany[T Model](ctx context.Context, filter interface{}, update interface{}, opts ...*options.UpdateOptions) (*mongo.UpdateResult, error) {
 	var t T
-	return collWrite(t.CollName()).UpdateMany(ctx, filter, update)
+	return collWrite(t.CollName()).UpdateMany(ctx, filter, update, opts...)
 }