Compare commits
2 Commits
Author | SHA1 | Date | |
---|---|---|---|
19c7e22ced
|
|||
9f883b458f
|
@@ -38,6 +38,13 @@ func (ee *ExErr) Error() string {
|
|||||||
// Unwrap must be implemented so that some error.XXX methods work
|
// Unwrap must be implemented so that some error.XXX methods work
|
||||||
func (ee *ExErr) Unwrap() error {
|
func (ee *ExErr) Unwrap() error {
|
||||||
if ee.OriginalError == nil {
|
if ee.OriginalError == nil {
|
||||||
|
|
||||||
|
if ee.WrappedErr != nil {
|
||||||
|
if werr, ok := ee.WrappedErr.(error); ok {
|
||||||
|
return werr
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
return nil // this is neccessary - otherwise we return a wrapped nil and the `x == nil` comparison fails (= panic in errors.Is and other failures)
|
return nil // this is neccessary - otherwise we return a wrapped nil and the `x == nil` comparison fails (= panic in errors.Is and other failures)
|
||||||
}
|
}
|
||||||
return ee.OriginalError
|
return ee.OriginalError
|
||||||
|
@@ -1,5 +1,5 @@
|
|||||||
package goext
|
package goext
|
||||||
|
|
||||||
const GoextVersion = "0.0.512"
|
const GoextVersion = "0.0.514"
|
||||||
|
|
||||||
const GoextVersionTimestamp = "2024-09-15T21:25:21+0200"
|
const GoextVersionTimestamp = "2024-09-16T17:39:18+0200"
|
||||||
|
@@ -215,7 +215,7 @@ func createPaginationPipeline[TData any](coll *Coll[TData], token ct.CursorToken
|
|||||||
|
|
||||||
// the conflict-resolution condition, for entries with the _same_ <field> as the $primary we take the ones with a greater $secondary (= newer)
|
// the conflict-resolution condition, for entries with the _same_ <field> as the $primary we take the ones with a greater $secondary (= newer)
|
||||||
cond = append(cond, bson.M{"$and": bson.A{
|
cond = append(cond, bson.M{"$and": bson.A{
|
||||||
bson.M{fieldPrimary: valuePrimary},
|
bson.M{"$or": bson.A{bson.M{fieldPrimary: valuePrimary}, bson.M{fieldPrimary: nil}}},
|
||||||
bson.M{*fieldSecondary: bson.M{"$gt": valueSecondary}},
|
bson.M{*fieldSecondary: bson.M{"$gt": valueSecondary}},
|
||||||
}})
|
}})
|
||||||
|
|
||||||
@@ -225,7 +225,7 @@ func createPaginationPipeline[TData any](coll *Coll[TData], token ct.CursorToken
|
|||||||
|
|
||||||
// the conflict-resolution condition, for entries with the _same_ <field> as the $primary we take the ones with a smaller $secondary (= older)
|
// the conflict-resolution condition, for entries with the _same_ <field> as the $primary we take the ones with a smaller $secondary (= older)
|
||||||
cond = append(cond, bson.M{"$and": bson.A{
|
cond = append(cond, bson.M{"$and": bson.A{
|
||||||
bson.M{fieldPrimary: valuePrimary},
|
bson.M{"$or": bson.A{bson.M{fieldPrimary: valuePrimary}, bson.M{fieldPrimary: nil}}},
|
||||||
bson.M{*fieldSecondary: bson.M{"$lt": valueSecondary}},
|
bson.M{*fieldSecondary: bson.M{"$lt": valueSecondary}},
|
||||||
}})
|
}})
|
||||||
|
|
||||||
|
Reference in New Issue
Block a user