1 Commits

Author SHA1 Message Date
e574667a8c types 2022-02-09 22:00:02 +01:00
6 changed files with 9 additions and 74 deletions

View File

@@ -1,66 +0,0 @@
package mgoapi
import (
"gitbase.de/gopackage/mgocrud/v2"
"gopkg.in/mgo.v2/bson"
)
type Connection interface {
Close()
NewSession() Session
}
type Session interface {
Close()
DB(name string) Database
}
type Database interface {
Session() Session
C(name string) Collection
Name() string
EnsureIndex(m mgocrud.ModelInterface) error
ValidateObject(m mgocrud.ModelInterface, changes bson.M) error
ReadDocument(m mgocrud.ModelInterface, selector bson.M) error
CreateDocument(m mgocrud.ModelInterface) error
ReadCollection(results interface{}, filter bson.M, selector bson.M, offset int, limit int, sort []string, pipelineModifier mgocrud.PipelineModifierFunction) error
ReadCollectionCount(m mgocrud.ModelInterface, filter bson.M) (count int, err error)
UpdateDocument(m mgocrud.ModelInterface, changes bson.M) error
UpsertDocument(m mgocrud.ModelInterface, changes bson.M) error
DeleteDocument(m mgocrud.ModelInterface) error
DeleteDocuments(m mgocrud.ModelInterface, filter bson.M) (removed int, err error)
}
type Collection interface {
Insert(docs ...interface{}) error
UpdateId(id interface{}, update interface{}) error
RemoveId(id interface{}) error
Upsert(selector interface{}, update interface{}) (ChangeInfo, error)
RemoveAll(filter interface{}) (ChangeInfo, error)
FindId(id interface{}) Query
Find(query interface{}) Query
EnsureIndex(index Index) error
Pipe(pipeline interface{}) Pipe
}
type ChangeInfo interface {
Matched() int
Removed() int
Updated() int
}
type Query interface {
Select(selector interface{}) Query
One(result interface{}) error
Sort(fields ...string) Query
Skip(n int) Query
Limit(n int) Query
All(result interface{}) error
Count() (int, error)
}
type Index interface{}
type Pipe interface {
All(result interface{}) error
}

2
go.mod
View File

@@ -3,7 +3,7 @@ module gitbase.de/gopackage/mgoapi/v2
go 1.16
require (
gitbase.de/gopackage/mgocrud/v2 v2.0.8
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

4
go.sum
View File

@@ -1,5 +1,5 @@
gitbase.de/gopackage/mgocrud/v2 v2.0.8 h1:129q3/5c4kFB0WnVZZXd+jhpR5FYjYjzmcoZxLPPjiY=
gitbase.de/gopackage/mgocrud/v2 v2.0.8/go.mod h1:eAIqxjo60/nP/S+YA25SBLQZ98WUrHwpvjE7Zl+ewTM=
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=

View File

@@ -154,7 +154,7 @@ func getModelMeta(m mgocrud.ModelInterface) []map[string]interface{} {
return getStructMeta(modelType, dontRecurse)
}
func getDocument(c *gin.Context, db 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

View File

@@ -5,6 +5,7 @@ import (
"reflect"
"time"
"gitbase.de/gopackage/mgocrud/v2"
jwt "github.com/dgrijalva/jwt-go"
"github.com/gin-gonic/gin"
@@ -12,7 +13,7 @@ import (
// LoginModel is interface for modules which can be used for the login route
type LoginModel interface {
LoginCheck(db Database) (tokenData interface{}, err error)
LoginCheck(db mgocrud.Database) (tokenData interface{}, err error)
LoginResponse(token string) (interface{}, error)
}

View File

@@ -7,7 +7,7 @@ import (
// API is wrapper for one RouterGroup and mgo DB
type API struct {
DBConnection Connection
DBConnection mgocrud.Connection
DBName string
routerGroup *gin.RouterGroup
jwtSecret []byte
@@ -18,11 +18,11 @@ type API struct {
type Context struct {
*gin.Context
API *API
DB Database
DB mgocrud.Database
}
// New returns new instance of the API
func New(connection Connection, dbname string, routerGroup *gin.RouterGroup) *API {
func New(connection mgocrud.Connection, dbname string, routerGroup *gin.RouterGroup) *API {
return &API{
DBConnection: connection,
DBName: dbname,