feat(graphql): implements scalars

gqlgen.yml

@@ -67,3 +67,21 @@ models:
  - github.com/99designs/gqlgen/graphql.Int
  - github.com/99designs/gqlgen/graphql.Int64
  - github.com/99designs/gqlgen/graphql.Int32
+ Time:
+ model:
+ - github.com/99designs/gqlgen/graphql.Time
+ Address:
+ model:
+ - okp4/nemeton-leaderboard/graphql/scalar.Address
+ ValoperAddress:
+ model:
+ - okp4/nemeton-leaderboard/graphql/scalar.ValoperAddress
+ PGPKeyID:
+ model:
+ - github.com/99designs/gqlgen/graphql.Uint64
+ URI:
+ model:
+ - okp4/nemeton-leaderboard/graphql/scalar.URI
+ Cursor:
+ model:
+ - okp4/nemeton-leaderboard/graphql/scalar.Cursor

graphql/scalar/address.go

@@ -0,0 +1,39 @@
+package scalar
+
+import (
+ "fmt"
+ "io"
+
+ "github.com/99designs/gqlgen/graphql"
+ "github.com/cosmos/cosmos-sdk/types"
+)
+
+func UnmarshalAccAddress(v interface{}) (types.AccAddress, error) {
+ strAddress, ok := v.(string)
+ if !ok {
+ return nil, fmt.Errorf("expect type 'string' and got type '%T'", v)
+ }
+
+ return types.AccAddressFromBech32(strAddress)
+}
+
+func MarshalAccAddress(addr types.AccAddress) graphql.Marshaler {
+ return graphql.WriterFunc(func(w io.Writer) {
+ _, _ = w.Write(addr)
+ })
+}
+
+func UnmarshalValoperAddress(v interface{}) (types.ValAddress, error) {
+ strAddress, ok := v.(string)
+ if !ok {
+ return nil, fmt.Errorf("expect type 'string' and got type '%T'", v)
+ }
+
+ return types.ValAddressFromBech32(strAddress)
+}
+
+func MarshalValoperAddress(addr types.ValAddress) graphql.Marshaler {
+ return graphql.WriterFunc(func(w io.Writer) {
+ _, _ = w.Write(addr)
+ })
+}

graphql/scalar/cursor.go

@@ -0,0 +1,24 @@
+package scalar
+
+import (
+ "fmt"
+ "io"
+
+ "github.com/99designs/gqlgen/graphql"
+ "go.mongodb.org/mongo-driver/bson/primitive"
+)
+
+func UnmarshalCursor(v interface{}) (primitive.ObjectID, error) {
+ strCursor, ok := v.(string)
+ if !ok {
+ return primitive.ObjectID{}, fmt.Errorf("expect type 'string' and got type '%T'", v)
+ }
+
+ return primitive.ObjectIDFromHex(strCursor)
+}
+
+func MarshalCursor(c primitive.ObjectID) graphql.Marshaler {
+ return graphql.WriterFunc(func(w io.Writer) {
+ _, _ = w.Write([]byte(c.Hex()))
+ })
+}

graphql/scalar/pgp.go

@@ -0,0 +1 @@
+package scalar

graphql/scalar/uri.go

@@ -0,0 +1,31 @@
+package scalar
+
+import (
+ "bytes"
+ "fmt"
+ "io"
+ "net/url"
+
+ "github.com/99designs/gqlgen/graphql"
+)
+
+func UnmarshalURI(v interface{}) (*url.URL, error) {
+ strURL, ok := v.(string)
+ if !ok {
+ return nil, fmt.Errorf("expect type 'string' and got type '%T'", v)
+ }
+
+ return url.Parse(strURL)
+}
+
+func MarshalURI(uri *url.URL) graphql.Marshaler {
+ return graphql.WriterFunc(func(w io.Writer) {
+ var buffer bytes.Buffer
+
+ buffer.WriteRune('"')
+ buffer.WriteString(uri.String())
+ buffer.WriteRune('"')
+
+ _, _ = buffer.WriteTo(w)
+ })
+}

graphql/schema.graphqls

@@ -14,7 +14,7 @@ scalar Time
 Represents an okp4 address as [Bech32](https://en.bitcoin.it/wiki/Bech32) format prefixed by the blockchain prefix.
 e.g. `okp41jse8senm9hcvydhl8v9x47kfe5z82zmwtw8jvj`
 """
-scalar Address
+scalar AccAddress
 
 """
 Represents an okp4 validator address as [Bech32](https://en.bitcoin.it/wiki/Bech32) format prefixed by the blockchain valoper prefix.
@@ -30,7 +30,7 @@ scalar PGPKeyID
 
 """
 Represents an [Uniform Resource Identifier](https://fr.wikipedia.org/wiki/Uniform_Resource_Identifier) to permanently identify a resource.
-e.g. ``
+e.g. `https://okp4.network/`
 """
 scalar URI
 
@@ -87,7 +87,7 @@ type Query {
  cursor: Cursor
  rank: Int
  valoper: ValoperAddress
- delegator: Address
+ delegator: AccAddress
  discord: String
  twitter: String
  ): Validator
@@ -320,7 +320,7 @@ type Validator {
  """
  The address of the validator node delegator.
  """
- delegator: Address!
+ delegator: AccAddress!
 
  """
  The validator twitter account.

graphql/schema.resolvers.go

@@ -6,10 +6,12 @@ package graphql
 import (
  "context"
  "fmt"
-
  "okp4/nemeton-leaderboard/app/nemeton"
  "okp4/nemeton-leaderboard/graphql/generated"
  "okp4/nemeton-leaderboard/graphql/model"
+
+ "github.com/cosmos/cosmos-sdk/types"
+ "go.mongodb.org/mongo-driver/bson/primitive"
 )
 
 // Blocks is the resolver for the blocks field.
@@ -48,7 +50,7 @@ func (r *queryResolver) Phases(ctx context.Context) (*model.Phases, error) {
 }
 
 // Board is the resolver for the board field.
-func (r *queryResolver) Board(ctx context.Context, search *string, first *int, after *string) (*model.BoardConnection, error) {
+func (r *queryResolver) Board(ctx context.Context, search *string, first *int, after *primitive.ObjectID) (*model.BoardConnection, error) {
  panic(fmt.Errorf("not implemented: Board - board"))
 }
 
@@ -58,7 +60,7 @@ func (r *queryResolver) ValidatorCount(ctx context.Context) (int, error) {
 }
 
 // Validator is the resolver for the validator field.
-func (r *queryResolver) Validator(ctx context.Context, cursor *string, rank *int, valoper *string, delegator *string, discord *string, twitter *string) (*model.Validator, error) {
+func (r *queryResolver) Validator(ctx context.Context, cursor *primitive.ObjectID, rank *int, valoper types.ValAddress, delegator *string, discord *string, twitter *string) (*model.Validator, error) {
  panic(fmt.Errorf("not implemented: Validator - validator"))
 }
 
@@ -71,8 +73,6 @@ func (r *Resolver) Phases() generated.PhasesResolver { return &phasesResolver{r}
 // Query returns generated.QueryResolver implementation.
 func (r *Resolver) Query() generated.QueryResolver { return &queryResolver{r} }
 
-type (
- phaseResolver struct{ *Resolver }
- phasesResolver struct{ *Resolver }
- queryResolver struct{ *Resolver }
-)
+type phaseResolver struct{ *Resolver }
+type phasesResolver struct{ *Resolver }
+type queryResolver struct{ *Resolver }