zdam-egzamin-zawodowy
/
backend
Archived
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

add user resolvers implementation

This commit is contained in:
Dawid Wysokiński 2021-03-06 12:29:33 +01:00
parent 7da98d0f97
commit 31f632e653
7 changed files with 260 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

150
internal/graphql/generated/generated.go
View File

@ -143,6 +143,11 @@ type ComplexityRoot struct {
Items func(childComplexity int) int
Total func(childComplexity int) int
}
UserWithToken struct {
Token func(childComplexity int) int
User func(childComplexity int) int
}
}
type MutationResolver interface {
@ -160,7 +165,7 @@ type MutationResolver interface {
UpdateUser(ctx context.Context, id int, input models.UserInput) (*models.User, error)
UpdateManyUsers(ctx context.Context, ids []int, input models.UserInput) ([]*models.User, error)
DeleteUsers(ctx context.Context, ids []int) ([]*models.User, error)
SignIn(ctx context.Context, email string, password string, staySignedIn *bool) (*models.User, error)
SignIn(ctx context.Context, email string, password string, staySignedIn *bool) (*UserWithToken, error)
}
type QueryResolver interface {
Professions(ctx context.Context, filter *models.ProfessionFilter, limit *int, offset *int, sort []string) (*ProfessionList, error)
@ -763,6 +768,20 @@ func (e *executableSchema) Complexity(typeName, field string, childComplexity in
return e.complexity.UserList.Total(childComplexity), true
case "UserWithToken.token":
if e.complexity.UserWithToken.Token == nil {
break
}
return e.complexity.UserWithToken.Token(childComplexity), true
case "UserWithToken.user":
if e.complexity.UserWithToken.User == nil {
break
}
return e.complexity.UserWithToken.User(childComplexity), true
}
return 0, false
}
@ -1142,6 +1161,11 @@ input UserFilter {
createdAtLTE: Time
}
type UserWithToken {
token: String!
user: User!
}
extend type Query {
users(
filter: UserFilter
@ -1166,8 +1190,11 @@ extend type Mutation {
deleteUsers(ids: [ID!]!): [User!]
@authenticated(yes: true)
@hasRole(role: ADMIN)
signIn(email: String!, password: String!, staySignedIn: Boolean): User
@authenticated(yes: false)
signIn(
email: String!
password: String!
staySignedIn: Boolean
): UserWithToken @authenticated(yes: false)
}
`, BuiltIn: false},
}
@ -2822,10 +2849,10 @@ func (ec *executionContext) _Mutation_signIn(ctx context.Context, field graphql.
if tmp == nil {
return nil, nil
}
if data, ok := tmp.(*models.User); ok {
if data, ok := tmp.(*UserWithToken); ok {
return data, nil
}
return nil, fmt.Errorf(`unexpected type %T from directive, should be *github.com/zdam-egzamin-zawodowy/backend/internal/models.User`, tmp)
return nil, fmt.Errorf(`unexpected type %T from directive, should be *github.com/zdam-egzamin-zawodowy/backend/internal/graphql/generated.UserWithToken`, tmp)
})
if err != nil {
ec.Error(ctx, err)
@ -2834,9 +2861,9 @@ func (ec *executionContext) _Mutation_signIn(ctx context.Context, field graphql.
if resTmp == nil {
return graphql.Null
}
res := resTmp.(*models.User)
res := resTmp.(*UserWithToken)
fc.Result = res
return ec.marshalOUser2ᚖgithubᚗcomᚋzdamᚑegzaminᚑzawodowyᚋbackendᚋinternalᚋmodelsᚐUser(ctx, field.Selections, res)
return ec.marshalOUserWithToken2ᚖgithubᚗcomᚋzdamᚑegzaminᚑzawodowyᚋbackendᚋinternalᚋgraphqlᚋgeneratedᚐUserWithToken(ctx, field.Selections, res)
}
func (ec *executionContext) _Profession_id(ctx context.Context, field graphql.CollectedField, obj *models.Profession) (ret graphql.Marshaler) {
@ -4777,6 +4804,76 @@ func (ec *executionContext) _UserList_items(ctx context.Context, field graphql.C
return ec.marshalOUser2ᚕᚖgithubᚗcomᚋzdamᚑegzaminᚑzawodowyᚋbackendᚋinternalᚋmodelsᚐUserᚄ(ctx, field.Selections, res)
}
func (ec *executionContext) _UserWithToken_token(ctx context.Context, field graphql.CollectedField, obj *UserWithToken) (ret graphql.Marshaler) {
defer func() {
if r := recover(); r != nil {
ec.Error(ctx, ec.Recover(ctx, r))
ret = graphql.Null
}
}()
fc := &graphql.FieldContext{
Object: "UserWithToken",
Field: field,
Args: nil,
IsMethod: false,
IsResolver: false,
}
ctx = graphql.WithFieldContext(ctx, fc)
resTmp, err := ec.ResolverMiddleware(ctx, func(rctx context.Context) (interface{}, error) {
ctx = rctx // use context from middleware stack in children
return obj.Token, nil
})
if err != nil {
ec.Error(ctx, err)
return graphql.Null
}
if resTmp == nil {
if !graphql.HasFieldError(ctx, fc) {
ec.Errorf(ctx, "must not be null")
}
return graphql.Null
}
res := resTmp.(string)
fc.Result = res
return ec.marshalNString2string(ctx, field.Selections, res)
}
func (ec *executionContext) _UserWithToken_user(ctx context.Context, field graphql.CollectedField, obj *UserWithToken) (ret graphql.Marshaler) {
defer func() {
if r := recover(); r != nil {
ec.Error(ctx, ec.Recover(ctx, r))
ret = graphql.Null
}
}()
fc := &graphql.FieldContext{
Object: "UserWithToken",
Field: field,
Args: nil,
IsMethod: false,
IsResolver: false,
}
ctx = graphql.WithFieldContext(ctx, fc)
resTmp, err := ec.ResolverMiddleware(ctx, func(rctx context.Context) (interface{}, error) {
ctx = rctx // use context from middleware stack in children
return obj.User, nil
})
if err != nil {
ec.Error(ctx, err)
return graphql.Null
}
if resTmp == nil {
if !graphql.HasFieldError(ctx, fc) {
ec.Errorf(ctx, "must not be null")
}
return graphql.Null
}
res := resTmp.(*models.User)
fc.Result = res
return ec.marshalNUser2ᚖgithubᚗcomᚋzdamᚑegzaminᚑzawodowyᚋbackendᚋinternalᚋmodelsᚐUser(ctx, field.Selections, res)
}
func (ec *executionContext) ___Directive_name(ctx context.Context, field graphql.CollectedField, obj *introspection.Directive) (ret graphql.Marshaler) {
defer func() {
if r := recover(); r != nil {
@ -7377,6 +7474,38 @@ func (ec *executionContext) _UserList(ctx context.Context, sel ast.SelectionSet,
return out
}
var userWithTokenImplementors = []string{"UserWithToken"}
func (ec *executionContext) _UserWithToken(ctx context.Context, sel ast.SelectionSet, obj *UserWithToken) graphql.Marshaler {
fields := graphql.CollectFields(ec.OperationContext, sel, userWithTokenImplementors)
out := graphql.NewFieldSet(fields)
var invalids uint32
for i, field := range fields {
switch field.Name {
case "__typename":
out.Values[i] = graphql.MarshalString("UserWithToken")
case "token":
out.Values[i] = ec._UserWithToken_token(ctx, field, obj)
if out.Values[i] == graphql.Null {
invalids++
}
case "user":
out.Values[i] = ec._UserWithToken_user(ctx, field, obj)
if out.Values[i] == graphql.Null {
invalids++
}
default:
panic("unknown field " + strconv.Quote(field.Name))
}
}
out.Dispatch()
if invalids > 0 {
return graphql.Null
}
return out
}
var __DirectiveImplementors = []string{"__Directive"}
func (ec *executionContext) ___Directive(ctx context.Context, sel ast.SelectionSet, obj *introspection.Directive) graphql.Marshaler {
@ -8647,6 +8776,13 @@ func (ec *executionContext) unmarshalOUserFilter2ᚖgithubᚗcomᚋzdamᚑegzami
return &res, graphql.ErrorOnPath(ctx, err)
}
func (ec *executionContext) marshalOUserWithToken2ᚖgithubᚗcomᚋzdamᚑegzaminᚑzawodowyᚋbackendᚋinternalᚋgraphqlᚋgeneratedᚐUserWithToken(ctx context.Context, sel ast.SelectionSet, v *UserWithToken) graphql.Marshaler {
if v == nil {
return graphql.Null
}
return ec._UserWithToken(ctx, sel, v)
}
func (ec *executionContext) marshalO__EnumValue2ᚕgithubᚗcomᚋ99designsᚋgqlgenᚋgraphqlᚋintrospectionᚐEnumValueᚄ(ctx context.Context, sel ast.SelectionSet, v []introspection.EnumValue) graphql.Marshaler {
if v == nil {
return graphql.Null

5
internal/graphql/generated/models.go
View File

@ -25,3 +25,8 @@ type UserList struct {
Total int `json:"total"`
Items []*models.User `json:"items"`
}
type UserWithToken struct {
Token string `json:"token"`
User *models.User `json:"user"`
}

16
internal/graphql/resolvers/helpers.go Normal file
View File

@ -0,0 +1,16 @@
package resolvers
import (
"context"
"github.com/99designs/gqlgen/graphql"
)
func shouldCount(ctx context.Context) bool {
for _, field := range graphql.CollectFieldsCtx(ctx, nil) {
if field.Name == "total" {
return true
}
}
return false
}

17
internal/graphql/resolvers/resolver.go
View File

@ -1,12 +1,25 @@
package resolvers
import "github.com/zdam-egzamin-zawodowy/backend/internal/graphql/generated"
import (
"github.com/zdam-egzamin-zawodowy/backend/internal/auth"
"github.com/zdam-egzamin-zawodowy/backend/internal/graphql/generated"
"github.com/zdam-egzamin-zawodowy/backend/internal/profession"
"github.com/zdam-egzamin-zawodowy/backend/internal/qualification"
"github.com/zdam-egzamin-zawodowy/backend/internal/question"
"github.com/zdam-egzamin-zawodowy/backend/internal/user"
)
// This file will not be regenerated automatically.
//
// It serves as dependency injection for your app, add any dependencies you require here.
type Resolver struct{}
type Resolver struct {
AuthUsecase auth.Usecase
UserUsecase user.Usecase
ProfessionUsecase profession.Usecase
QualificationUsecase qualification.Usecase
QuestionUsecase question.Usecase
}
type mutationResolver struct{ *Resolver }
type queryResolver struct{ *Resolver }

67
internal/graphql/resolvers/user.resolvers.go
View File

@ -5,40 +5,85 @@ package resolvers
import (
"context"
"fmt"
"github.com/zdam-egzamin-zawodowy/backend/internal/gin/middleware"
"github.com/zdam-egzamin-zawodowy/backend/internal/graphql/generated"
"github.com/zdam-egzamin-zawodowy/backend/internal/models"
"github.com/zdam-egzamin-zawodowy/backend/internal/user"
"github.com/zdam-egzamin-zawodowy/backend/pkg/utils"
)
func (r *mutationResolver) CreateUser(ctx context.Context, input models.UserInput) (*models.User, error) {
panic(fmt.Errorf("not implemented"))
return r.UserUsecase.Store(ctx, &input)
}
func (r *mutationResolver) UpdateUser(ctx context.Context, id int, input models.UserInput) (*models.User, error) {
panic(fmt.Errorf("not implemented"))
return r.UserUsecase.UpdateOneByID(ctx, id, &input)
}
func (r *mutationResolver) UpdateManyUsers(ctx context.Context, ids []int, input models.UserInput) ([]*models.User, error) {
panic(fmt.Errorf("not implemented"))
return r.UserUsecase.UpdateMany(
ctx,
&models.UserFilter{
ID: ids,
},
&input,
)
}
func (r *mutationResolver) DeleteUsers(ctx context.Context, ids []int) ([]*models.User, error) {
panic(fmt.Errorf("not implemented"))
return r.UserUsecase.Delete(ctx, &models.UserFilter{
ID: ids,
})
}
func (r *mutationResolver) SignIn(ctx context.Context, email string, password string, staySignedIn *bool) (*models.User, error) {
panic(fmt.Errorf("not implemented"))
func (r *mutationResolver) SignIn(
ctx context.Context,
email string,
password string,
staySignedIn *bool,
) (*generated.UserWithToken, error) {
var err error
userWithToken := &generated.UserWithToken{}
userWithToken.User, userWithToken.Token, err = r.AuthUsecase.SignIn(
ctx,
email,
password,
utils.SafeBoolPointer(staySignedIn, false),
)
if err != nil {
return nil, err
}
return userWithToken, nil
}
func (r *queryResolver) Users(ctx context.Context, filter *models.UserFilter, limit *int, offset *int, sort []string) (*generated.UserList, error) {
panic(fmt.Errorf("not implemented"))
func (r *queryResolver) Users(
ctx context.Context,
filter *models.UserFilter,
limit *int,
offset *int,
sort []string,
) (*generated.UserList, error) {
var err error
userList := &generated.UserList{}
userList.Items, userList.Total, err = r.UserUsecase.Fetch(
ctx,
&user.FetchConfig{
Count: shouldCount(ctx),
Filter: filter,
Limit: utils.SafeIntPointer(limit, 100),
Offset: utils.SafeIntPointer(offset, 0),
Sort: sort,
},
)
return userList, err
}
func (r *queryResolver) User(ctx context.Context, id int) (*models.User, error) {
panic(fmt.Errorf("not implemented"))
return r.UserUsecase.GetByID(ctx, id)
}
func (r *queryResolver) Me(ctx context.Context) (*models.User, error) {
panic(fmt.Errorf("not implemented"))
user, _ := middleware.UserFromContext(ctx)
return user, nil
}

12
internal/graphql/schema/user.graphql
View File

@ -56,6 +56,11 @@ input UserFilter {
createdAtLTE: Time
}
type UserWithToken {
token: String!
user: User!
}
extend type Query {
users(
filter: UserFilter
@ -80,6 +85,9 @@ extend type Mutation {
deleteUsers(ids: [ID!]!): [User!]
@authenticated(yes: true)
@hasRole(role: ADMIN)
signIn(email: String!, password: String!, staySignedIn: Boolean): User
@authenticated(yes: false)
signIn(
email: String!
password: String!
staySignedIn: Boolean
): UserWithToken @authenticated(yes: false)
}

15
pkg/utils/safe_pointer.go Normal file
View File

@ -0,0 +1,15 @@
package utils
func SafeBoolPointer(v *bool, def bool) bool {
if v == nil {
return def
}
return *v
}
func SafeIntPointer(s *int, def int) int {
if s == nil {
return def
}
return *s
}