types
This commit is contained in:
@@ -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
2
go.mod
@@ -3,7 +3,7 @@ module gitbase.de/gopackage/mgoapi/v2
|
|||||||
go 1.16
|
go 1.16
|
||||||
|
|
||||||
require (
|
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/dgrijalva/jwt-go v3.2.0+incompatible
|
||||||
github.com/gin-gonic/gin v1.6.3
|
github.com/gin-gonic/gin v1.6.3
|
||||||
gopkg.in/mgo.v2 v2.0.0-20190816093944-a6b53ec6cb22
|
gopkg.in/mgo.v2 v2.0.0-20190816093944-a6b53ec6cb22
|
||||||
|
|||||||
4
go.sum
4
go.sum
@@ -1,5 +1,5 @@
|
|||||||
gitbase.de/gopackage/mgocrud/v2 v2.0.8 h1:129q3/5c4kFB0WnVZZXd+jhpR5FYjYjzmcoZxLPPjiY=
|
gitbase.de/gopackage/mgocrud/v2 v2.0.9 h1:tIg5XKJiEd/QEjY9zW5/OK0kl6+auhlEO0wmd0vR4Mk=
|
||||||
gitbase.de/gopackage/mgocrud/v2 v2.0.8/go.mod h1:eAIqxjo60/nP/S+YA25SBLQZ98WUrHwpvjE7Zl+ewTM=
|
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.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 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
|
||||||
github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
|
github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
|
||||||
|
|||||||
@@ -154,7 +154,7 @@ func getModelMeta(m mgocrud.ModelInterface) []map[string]interface{} {
|
|||||||
return getStructMeta(modelType, dontRecurse)
|
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"))
|
objectID, err := string2ObjectID(c.Param("id"))
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
|
|||||||
3
login.go
3
login.go
@@ -5,6 +5,7 @@ import (
|
|||||||
"reflect"
|
"reflect"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
|
"gitbase.de/gopackage/mgocrud/v2"
|
||||||
jwt "github.com/dgrijalva/jwt-go"
|
jwt "github.com/dgrijalva/jwt-go"
|
||||||
|
|
||||||
"github.com/gin-gonic/gin"
|
"github.com/gin-gonic/gin"
|
||||||
@@ -12,7 +13,7 @@ import (
|
|||||||
|
|
||||||
// LoginModel is interface for modules which can be used for the login route
|
// LoginModel is interface for modules which can be used for the login route
|
||||||
type LoginModel interface {
|
type LoginModel interface {
|
||||||
LoginCheck(db Database) (tokenData interface{}, err error)
|
LoginCheck(db mgocrud.Database) (tokenData interface{}, err error)
|
||||||
LoginResponse(token string) (interface{}, error)
|
LoginResponse(token string) (interface{}, error)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -7,7 +7,7 @@ import (
|
|||||||
|
|
||||||
// API is wrapper for one RouterGroup and mgo DB
|
// API is wrapper for one RouterGroup and mgo DB
|
||||||
type API struct {
|
type API struct {
|
||||||
DBConnection Connection
|
DBConnection mgocrud.Connection
|
||||||
DBName string
|
DBName string
|
||||||
routerGroup *gin.RouterGroup
|
routerGroup *gin.RouterGroup
|
||||||
jwtSecret []byte
|
jwtSecret []byte
|
||||||
@@ -18,11 +18,11 @@ type API struct {
|
|||||||
type Context struct {
|
type Context struct {
|
||||||
*gin.Context
|
*gin.Context
|
||||||
API *API
|
API *API
|
||||||
DB Database
|
DB mgocrud.Database
|
||||||
}
|
}
|
||||||
|
|
||||||
// New returns new instance of the API
|
// 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{
|
return &API{
|
||||||
DBConnection: connection,
|
DBConnection: connection,
|
||||||
DBName: dbname,
|
DBName: dbname,
|
||||||
|
|||||||
Reference in New Issue
Block a user