types

filter.go

@@ -162,7 +162,7 @@ func _validateFilter(structT reflect.Type, f bson.M, checkValues bool) (bson.M,
 			valT := reflect.TypeOf(val)
 			if valT.Kind() == reflect.Slice {
 				l := len(val.([]interface{}))
-				newVal = make([]interface{}, l, l)
+				newVal = make([]interface{}, l)
 				for i := 0; i < l; i++ {
 					var err error
 					switch valF := val.([]interface{})[i].(type) {

go.mod

@@ -1,9 +1,9 @@
-module gitbase.de/gopackage/mgoapi
+module gitbase.de/gopackage/mgoapi/v2
 
 go 1.16
 
 require (
-	gitbase.de/gopackage/mgocrud v0.0.0-20210301125326-161e3b46fb99
+	gitbase.de/gopackage/mgocrud/v2 v2.0.9
 	github.com/dgrijalva/jwt-go v3.2.0+incompatible
 	github.com/gin-gonic/gin v1.6.3
 	gopkg.in/mgo.v2 v2.0.0-20190816093944-a6b53ec6cb22

go.sum

@@ -1,5 +1,5 @@
-gitbase.de/gopackage/mgocrud v0.0.0-20210301125326-161e3b46fb99 h1:2PovCTzQpTTmgxKdO915G+JmQPFYY6NKRZMKxw9jSYE=
-gitbase.de/gopackage/mgocrud v0.0.0-20210301125326-161e3b46fb99/go.mod h1:obb5Piqrb7N1VnmPp8HHJsAcOqIn9l04ibvH6I2qkhg=
+gitbase.de/gopackage/mgocrud/v2 v2.0.9 h1:tIg5XKJiEd/QEjY9zW5/OK0kl6+auhlEO0wmd0vR4Mk=
+gitbase.de/gopackage/mgocrud/v2 v2.0.9/go.mod h1:eAIqxjo60/nP/S+YA25SBLQZ98WUrHwpvjE7Zl+ewTM=
 github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
 github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=

handler.go

@@ -7,16 +7,15 @@ import (
 
 	"runtime/debug"
 
-	"gitbase.de/gopackage/mgocrud"
+	"gitbase.de/gopackage/mgocrud/v2"
 	"github.com/gin-gonic/gin"
-	mgo "gopkg.in/mgo.v2"
 	"gopkg.in/mgo.v2/bson"
 )
 
 func (api *API) collectionGetOneHandler(m mgocrud.ModelInterface) gin.HandlerFunc {
 	return func(c *gin.Context) {
 
-		session := api.DBSession.Copy()
+		session := api.DBConnection.NewSession()
 		defer session.Close()
 		db := session.DB(api.DBName)
 
@@ -42,7 +41,7 @@ func (api *API) collectionGetOneHandler(m mgocrud.ModelInterface) gin.HandlerFun
 		newM, err := getDocument(c, db, m, validSelect)
 		if err != nil {
 			status := 500
-			if err == mgo.ErrNotFound {
+			if err == mgocrud.ErrNotFound {
 				status = 404
 			}
 			c.JSON(status, errorObject(err))
@@ -80,7 +79,7 @@ func (api *API) collectionGetHandler(m mgocrud.ModelInterface) gin.HandlerFunc {
 
 		results := x.Interface()
 
-		session := api.DBSession.Copy()
+		session := api.DBConnection.NewSession()
 		defer session.Close()
 		db := session.DB(api.DBName)
 
@@ -144,7 +143,7 @@ func (api *API) collectionGetHandler(m mgocrud.ModelInterface) gin.HandlerFunc {
 
 		queryCount := c.Query("count")
 		if queryCount == "1" || strings.ToLower(queryCount) == "true" {
-			count, err := mgocrud.ReadCollectionCount(db, m, validFilter)
+			count, err := db.ReadCollectionCount(m, validFilter)
 			if err != nil {
 				c.JSON(500, errorObject(err))
 				return
@@ -170,7 +169,7 @@ func (api *API) collectionGetHandler(m mgocrud.ModelInterface) gin.HandlerFunc {
 			}
 		}
 
-		err = mgocrud.ReadCollection(db, results, validFilter, validSelect, offset, limit, clearedSort, pipelineModFunc)
+		err = db.ReadCollection(results, validFilter, validSelect, offset, limit, clearedSort, pipelineModFunc)
 		if err != nil {
 			c.JSON(500, errorObject(err))
 			return
@@ -206,7 +205,7 @@ func (api *API) collectionPostHandler(m mgocrud.ModelInterface) gin.HandlerFunc
 			return
 		}
 
-		session := api.DBSession.Copy()
+		session := api.DBConnection.NewSession()
 		defer session.Close()
 		db := session.DB(api.DBName)
 
@@ -219,7 +218,7 @@ func (api *API) collectionPostHandler(m mgocrud.ModelInterface) gin.HandlerFunc
 			return
 		}
 
-		err := mgocrud.CreateDocument(db, newM)
+		err := db.CreateDocument(newM)
 		if err != nil {
 			c.JSON(500, errorObject(err))
 			return
@@ -227,7 +226,7 @@ func (api *API) collectionPostHandler(m mgocrud.ModelInterface) gin.HandlerFunc
 
 		readM := newModelOf(newM).(mgocrud.ModelInterface)
 		readM.SetID(newM.GetID())
-		err = mgocrud.ReadDocument(db, readM, nil)
+		err = db.ReadDocument(readM, nil)
 		if err != nil {
 			c.JSON(500, errorObject(err))
 			return
@@ -258,14 +257,14 @@ func (api *API) collectionPostHandler(m mgocrud.ModelInterface) gin.HandlerFunc
 
 func (api *API) collectionPutHandler(m mgocrud.ModelInterface) gin.HandlerFunc {
 	return func(c *gin.Context) {
-		session := api.DBSession.Copy()
+		session := api.DBConnection.NewSession()
 		defer session.Close()
 		db := session.DB(api.DBName)
 
 		orgM, err := getDocument(c, db, m, nil)
 		if err != nil {
 			status := 500
-			if err == mgo.ErrNotFound {
+			if err == mgocrud.ErrNotFound {
 				status = 404
 			}
 			c.JSON(status, errorObject(err))
@@ -359,7 +358,7 @@ func (api *API) collectionPutHandler(m mgocrud.ModelInterface) gin.HandlerFunc {
 			return
 		}
 
-		err = mgocrud.UpdateDocument(db, orgM, changes)
+		err = db.UpdateDocument(orgM, changes)
 		if err != nil {
 			c.JSON(500, errorObject(err))
 			return
@@ -400,21 +399,21 @@ func (api *API) collectionPutHandler(m mgocrud.ModelInterface) gin.HandlerFunc {
 func (api *API) collectionDeleteHandler(m mgocrud.ModelInterface) gin.HandlerFunc {
 	return func(c *gin.Context) {
 
-		session := api.DBSession.Copy()
+		session := api.DBConnection.NewSession()
 		defer session.Close()
 		db := session.DB(api.DBName)
 
 		orgM, err := getDocument(c, db, m, bson.M{"_id": 1})
 		if err != nil {
 			status := 500
-			if err == mgo.ErrNotFound {
+			if err == mgocrud.ErrNotFound {
 				status = 404
 			}
 			c.JSON(status, errorObject(err))
 			return
 		}
 
-		err = mgocrud.DeleteDocument(db, orgM)
+		err = db.DeleteDocument(orgM)
 		if err != nil {
 			c.JSON(500, errorObject(err))
 		}

helper.go

@@ -6,9 +6,8 @@ import (
 	"regexp"
 	"strings"
 
-	"gitbase.de/gopackage/mgocrud"
+	"gitbase.de/gopackage/mgocrud/v2"
 	"github.com/gin-gonic/gin"
-	mgo "gopkg.in/mgo.v2"
 	"gopkg.in/mgo.v2/bson"
 )
 
@@ -41,7 +40,7 @@ func string2ObjectID(id string) (objectID *bson.ObjectId, err error) {
 			case error:
 				err = x
 			default:
-				err = errors.New("Unknown panic in: string2ObjectID")
+				err = errors.New("unknown panic in: string2ObjectID")
 			}
 		}
 	}()
@@ -72,9 +71,7 @@ func getStructMeta(s reflect.Type, dontRecurse map[string]bool) []map[string]int
 			if f.Anonymous {
 				// embed directly
 				embed := getStructMeta(_type, dontRecurse)
-				for _, e := range embed {
-					meta = append(meta, e)
-				}
+				meta = append(meta, embed...)
 			} else {
 				fMeta := make(map[string]interface{})
 
@@ -89,7 +86,7 @@ func getStructMeta(s reflect.Type, dontRecurse map[string]bool) []map[string]int
 					fType = _type.String()
 				}
 				//fType = strings.Replace(fType, "*", "", -1)
-				fType = regexp.MustCompile("\\*[a-zA-Z0-9]*\\.?").ReplaceAllString(fType, "")
+				fType = regexp.MustCompile(`\*[a-zA-Z0-9]*\.?`).ReplaceAllString(fType, "")
 				fMeta["type"] = fType
 				kind = _type.Kind()
 				fMeta["kind"] = kind.String()
@@ -157,14 +154,14 @@ func getModelMeta(m mgocrud.ModelInterface) []map[string]interface{} {
 	return getStructMeta(modelType, dontRecurse)
 }
 
-func getDocument(c *gin.Context, db *mgo.Database, m mgocrud.ModelInterface, selector bson.M) (mgocrud.ModelInterface, error) {
+func getDocument(c *gin.Context, db mgocrud.Database, m mgocrud.ModelInterface, selector bson.M) (mgocrud.ModelInterface, error) {
 	objectID, err := string2ObjectID(c.Param("id"))
 	if err != nil {
 		return nil, err
 	}
 	newM := newModelOf(m).(mgocrud.ModelInterface)
 	newM.SetID(objectID)
-	err = mgocrud.ReadDocument(db, newM, selector)
+	err = db.ReadDocument(newM, selector)
 	if err != nil {
 		return nil, err
 	}

hooks.go

@@ -4,7 +4,7 @@ import (
 	"fmt"
 	"reflect"
 
-	"gitbase.de/gopackage/mgocrud"
+	"gitbase.de/gopackage/mgocrud/v2"
 	"gopkg.in/mgo.v2/bson"
 )
 
@@ -71,7 +71,7 @@ func validateObject(c *Context, m mgocrud.ModelInterface, changes bson.M) error
 		}
 	}
 
-	return mgocrud.ValidateObject(c.DB, m, changes)
+	return c.DB.ValidateObject(m, changes)
 }
 
 func savedObject(c *Context, m mgocrud.ModelInterface, changes bson.M) error {

login.go

@@ -5,15 +5,15 @@ import (
 	"reflect"
 	"time"
 
+	"gitbase.de/gopackage/mgocrud/v2"
 	jwt "github.com/dgrijalva/jwt-go"
 
 	"github.com/gin-gonic/gin"
-	mgo "gopkg.in/mgo.v2"
 )
 
 // LoginModel is interface for modules which can be used for the login route
 type LoginModel interface {
-	LoginCheck(db *mgo.Database) (tokenData interface{}, err error)
+	LoginCheck(db mgocrud.Database) (tokenData interface{}, err error)
 	LoginResponse(token string) (interface{}, error)
 }
 
@@ -27,7 +27,7 @@ func (api *API) loginPostHandler(m LoginModel) func(c *gin.Context) {
 			return
 		}
 
-		session := api.DBSession.Copy()
+		session := api.DBConnection.NewSession()
 		defer session.Close()
 		db := session.DB(api.DBName)
 

register.go

@@ -1,14 +1,13 @@
 package mgoapi
 
 import (
-	"gitbase.de/gopackage/mgocrud"
+	"gitbase.de/gopackage/mgocrud/v2"
 	"github.com/gin-gonic/gin"
-	mgo "gopkg.in/mgo.v2"
 )
 
 // API is wrapper for one RouterGroup and mgo DB
 type API struct {
-	DBSession            *mgo.Session
+	DBConnection         mgocrud.Connection
 	DBName               string
 	routerGroup          *gin.RouterGroup
 	jwtSecret            []byte
@@ -19,30 +18,30 @@ type API struct {
 type Context struct {
 	*gin.Context
 	API *API
-	DB  *mgo.Database
+	DB  mgocrud.Database
 }
 
 // New returns new instance of the API
-func New(session *mgo.Session, dbname string, routerGroup *gin.RouterGroup) *API {
+func New(connection mgocrud.Connection, dbname string, routerGroup *gin.RouterGroup) *API {
 	return &API{
-		DBSession:   session,
-		DBName:      dbname,
-		routerGroup: routerGroup,
+		DBConnection: connection,
+		DBName:       dbname,
+		routerGroup:  routerGroup,
 	}
 }
 
-var modelRegistry = make([]mgocrud.ModelInterface, 0, 0)
+var modelRegistry = make([]mgocrud.ModelInterface, 0)
 
 // RegisterModel setups gin routes for model GET, POST, PUT and DELETE
 func (api *API) RegisterModel(m mgocrud.ModelInterface) {
 
 	modelRegistry = append(modelRegistry, m)
 
-	session := api.DBSession.Copy()
+	session := api.DBConnection.NewSession()
 	defer session.Close()
 	db := session.DB(api.DBName)
 
-	err := mgocrud.EnsureIndex(db, m)
+	err := db.EnsureIndex(m)
 	if err != nil {
 		panic(err)
 	}