2018-07-29 19:11:33 +03:00
|
|
|
package resolvers
|
|
|
|
|
|
|
|
import (
|
|
|
|
"context"
|
|
|
|
"github.com/MichaelMure/git-bug/bug"
|
2018-07-29 21:58:22 +03:00
|
|
|
"github.com/MichaelMure/git-bug/graphql/connections"
|
2018-07-29 20:37:06 +03:00
|
|
|
"github.com/MichaelMure/git-bug/graphql/models"
|
2018-07-29 19:11:33 +03:00
|
|
|
)
|
|
|
|
|
2018-07-30 00:48:52 +03:00
|
|
|
type repoResolver struct{}
|
2018-07-29 19:11:33 +03:00
|
|
|
|
2018-07-30 00:48:52 +03:00
|
|
|
func (repoResolver) AllBugs(ctx context.Context, obj *models.Repository, input models.ConnectionInput) (models.BugConnection, error) {
|
2018-07-29 21:58:22 +03:00
|
|
|
|
|
|
|
// Simply pass a []string with the ids to the pagination algorithm
|
2018-07-30 00:48:52 +03:00
|
|
|
source, err := obj.Repo.AllBugIds()
|
2018-07-29 21:58:22 +03:00
|
|
|
|
|
|
|
if err != nil {
|
|
|
|
return models.BugConnection{}, err
|
|
|
|
}
|
|
|
|
|
|
|
|
// The edger create a custom edge holding just the id
|
|
|
|
edger := func(id string, offset int) connections.Edge {
|
|
|
|
return connections.LazyBugEdge{
|
|
|
|
Id: id,
|
|
|
|
Cursor: connections.OffsetToCursor(offset),
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
// The conMaker will finally load and compile bugs from git to replace the selected edges
|
|
|
|
conMaker := func(lazyBugEdges []connections.LazyBugEdge, info models.PageInfo, totalCount int) (models.BugConnection, error) {
|
|
|
|
edges := make([]models.BugEdge, len(lazyBugEdges))
|
|
|
|
|
|
|
|
for i, lazyBugEdge := range lazyBugEdges {
|
2018-07-30 00:48:52 +03:00
|
|
|
b, err := obj.Repo.ResolveBug(lazyBugEdge.Id)
|
2018-07-29 21:58:22 +03:00
|
|
|
|
|
|
|
if err != nil {
|
|
|
|
return models.BugConnection{}, err
|
|
|
|
}
|
|
|
|
|
|
|
|
snap := b.Snapshot()
|
|
|
|
|
|
|
|
edges[i] = models.BugEdge{
|
|
|
|
Cursor: lazyBugEdge.Cursor,
|
|
|
|
Node: *snap,
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
return models.BugConnection{
|
|
|
|
Edges: edges,
|
|
|
|
PageInfo: info,
|
|
|
|
TotalCount: totalCount,
|
|
|
|
}, nil
|
|
|
|
}
|
|
|
|
|
|
|
|
return connections.StringCon(source, edger, conMaker, input)
|
2018-07-29 19:11:33 +03:00
|
|
|
}
|
|
|
|
|
2018-07-30 00:48:52 +03:00
|
|
|
func (repoResolver) Bug(ctx context.Context, obj *models.Repository, prefix string) (*bug.Snapshot, error) {
|
|
|
|
b, err := obj.Repo.ResolveBugPrefix(prefix)
|
2018-07-29 19:11:33 +03:00
|
|
|
|
|
|
|
if err != nil {
|
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
|
|
|
|
return b.Snapshot(), nil
|
|
|
|
}
|
2018-07-30 02:08:45 +03:00
|
|
|
|
|
|
|
func (repoResolver) Mutation(ctx context.Context, obj *models.Repository) (models.RepositoryMutation, error) {
|
|
|
|
return models.RepositoryMutation{
|
|
|
|
Repo: obj.Repo,
|
|
|
|
Cache: obj.Cache,
|
|
|
|
}, nil
|
|
|
|
}
|