Implement single document loaders through find cursor

mongox/common/loadbinary.go

@@ -6,30 +6,30 @@ import (
 	"github.com/mainnika/mongox-go-driver/mongox/query"
 	"go.mongodb.org/mongo-driver/bson"
 	"go.mongodb.org/mongo-driver/mongo"
-	"go.mongodb.org/mongo-driver/mongo/options"
 )
 
 // LoadBinary function loads a first single target document by a query
 func LoadBinary(db *mongox.Database, target interface{}, filters ...interface{}) (bson.Raw, error) {
 
-	collection := db.GetCollectionOf(target)
+	composed := query.Compose(append(filters, query.Limit(1))...)
-	opts := options.FindOne()
+	hasPreloader, _ := composed.Preloader()
-	composed := query.Compose(filters...)
 
-	opts.Sort = composed.Sorter()
+	var result *mongo.Cursor
+	var err error
 
-	result := collection.FindOne(db.Context(), composed.M(), opts)
+	if hasPreloader {
-	if result.Err() != nil {
+		result, err = createAggregateLoad(db, target, composed)
-		return nil, errors.InternalErrorf("can't create find one result: %s", result.Err())
+	} else {
-	}
+		result, err = createSimpleLoad(db, target, composed)
-
-	bytes, err := result.DecodeBytes()
-	if err == mongo.ErrNoDocuments {
-		return nil, errors.NotFoundErrorf("%s", err)
 	}
 	if err != nil {
-		return nil, errors.InternalErrorf("can't decode desult: %s", err)
+		return nil, errors.InternalErrorf("can't create find result: %s", err)
+	}
+
+	hasNext := result.Next(db.Context())
+	if !hasNext {
+		return nil, errors.NotFoundErrorf("can't find result: %s", result.Err())
 	}
 
-	return bytes, nil
+	return result.Current, nil
 }

mongox/common/loadone.go

@@ -5,30 +5,30 @@ import (
 	"github.com/mainnika/mongox-go-driver/mongox/errors"
 	"github.com/mainnika/mongox-go-driver/mongox/query"
 	"go.mongodb.org/mongo-driver/mongo"
-	"go.mongodb.org/mongo-driver/mongo/options"
 )
 
 // LoadOne function loads a first single target document by a query
 func LoadOne(db *mongox.Database, target interface{}, filters ...interface{}) error {
 
-	collection := db.GetCollectionOf(target)
+	composed := query.Compose(append(filters, query.Limit(1))...)
-	opts := options.FindOne()
+	hasPreloader, _ := composed.Preloader()
-	composed := query.Compose(filters...)
 
-	opts.Sort = composed.Sorter()
+	var result *mongo.Cursor
+	var err error
 
-	result := collection.FindOne(db.Context(), composed.M(), opts)
+	if hasPreloader {
-	if result.Err() != nil {
+		result, err = createAggregateLoad(db, target, composed)
-		return errors.InternalErrorf("can't create find one result: %s", result.Err())
+	} else {
-	}
+		result, err = createSimpleLoad(db, target, composed)
-
-	err := result.Decode(target)
-	if err == mongo.ErrNoDocuments {
-		return errors.NotFoundErrorf("%s", err)
 	}
 	if err != nil {
-		return errors.InternalErrorf("can't decode desult: %s", err)
+		return errors.InternalErrorf("can't create find result: %s", err)
+	}
+
+	hasNext := result.Next(db.Context())
+	if !hasNext {
+		return errors.NotFoundErrorf("can't find result: %s", result.Err())
 	}
 
-	return nil
+	return result.Decode(target)
 }