This commit is contained in:
Mike Schwörer 2023-06-10 16:28:50 +02:00
parent b613b122e3
commit a30da61419
Signed by: Mikescher
GPG Key ID: D3C7172E0A70F8CF
2 changed files with 19 additions and 2 deletions

View File

@ -1,5 +1,5 @@
package goext
const GoextVersion = "0.0.157"
const GoextVersion = "0.0.158"
const GoextVersionTimestamp = "2023-06-10T16:22:14+0200"
const GoextVersionTimestamp = "2023-06-10T16:28:50+0200"

View File

@ -19,3 +19,20 @@ func (c *Coll[TData]) Aggregate(ctx context.Context, pipeline mongo.Pipeline, op
return res, nil
}
func (c *Coll[TData]) AggregateOneOpt(ctx context.Context, pipeline mongo.Pipeline, opts ...*options.AggregateOptions) (*TData, error) {
cursor, err := c.coll.Aggregate(ctx, pipeline, opts...)
if err != nil {
return nil, err
}
if cursor.Next(ctx) {
v, err := c.decodeSingle(ctx, cursor)
if err != nil {
return nil, err
}
return &v, nil
}
return nil, nil
}