block.go

package resolvers

// This file will be automatically regenerated based on the schema, any resolver implementations
// will be copied through when generating and any unknown code will be moved to the end.

import (
	"context"
	"fmt"

	pkgContext "github.com/oursky/likedao/pkg/context"
	servererrors "github.com/oursky/likedao/pkg/errors"
	graphql1 "github.com/oursky/likedao/pkg/generated/graphql"
	"github.com/oursky/likedao/pkg/models"
)

func (r *queryResolver) LatestBlock(ctx context.Context) (*models.Block, error) {
	res, err := pkgContext.GetQueriesFromCtx(ctx).Block.QueryLatestBlock()
	if err != nil {
		return nil, servererrors.QueryError.NewError(ctx, fmt.Sprintf("failed to query latest block: %v", err))
	}
	return res, nil
}

func (r *queryResolver) BlockByID(ctx context.Context, id models.NodeID) (*models.Block, error) {
	res, err := pkgContext.GetDataLoadersFromCtx(ctx).Block.LoadBlockByHash(id.ID)
	if err != nil {
		return nil, servererrors.QueryError.NewError(ctx, fmt.Sprintf("failed to query block: %v", err))
	}
	return res, nil
}

func (r *queryResolver) BlocksByIDs(ctx context.Context, ids []models.NodeID) ([]*models.Block, error) {
	blockHashes := models.ExtractObjectIDs(ids)
	res, errs := pkgContext.GetDataLoadersFromCtx(ctx).Block.LoadBlockByHashes(blockHashes)

	for _, err := range errs {
		if err != nil {
			return nil, servererrors.QueryError.NewError(ctx, fmt.Sprintf("failed to query blocks: %v", err))
		}
	}

	return res, nil
}

// Query returns graphql1.QueryResolver implementation.
func (r *Resolver) Query() graphql1.QueryResolver { return &queryResolver{r} }

type queryResolver struct{ *Resolver }