service

package

v0.0.3 Latest Latest Go to latest Published: Aug 28, 2023 License: MIT Imports: 33 Imported by: 0

Documentation ¶

This section is empty.

View Source

var (
	ErrExpiredToken  = errors.New("token expired")
	JWTSigningMethod = jwt.SigningMethodES512
)

func Module() fx.Option

type Auth struct {
	fx.In

	Config      *appconfig.Config
	Ent         *ent.Client
	JWT         JWT
	Turnstile   Turnstile
	MailService Mail
}

func (s Auth) AuthByLoginInput(ctx context.Context, args model.LoginInput) (*ent.User, error)

func (s Auth) AuthByToken(ctx context.Context, token string) (*ent.User, error)

func (s Auth) CreateUser(ctx context.Context, args model.CreateUserInput) (*ent.User, error)

func (s Auth) CurrentUser(ctx context.Context) (*ent.User, error)

func (s Auth) SetUserToken(ctx context.Context, user *ent.User) error

type Directive struct {
	fx.In
}

func (s Directive) Admin(ctx context.Context, obj any, next graphql.Resolver) (res any, err error)

Admin directive is used to check if the current user is an admin. if not, return error.

func (s Directive) Private(ctx context.Context, obj any, next graphql.Resolver, userIDFieldName *string) (res any, err error)

Private directive is used to check if the current user is the owner of the object. if not, return null for the field.

type Event struct {
	fx.In

	Ent         *ent.Client
	AuthService Auth
}

func (s Event) CalculateStats(ctx context.Context, researchID string, filterInput string, resultMappingInput string) (*model.GroupCountResult, error)

*

CalculateStats filters events by filterInput and maps every event to a result using resultMappingInput, then group by result and count
@param {string} filterInput can be jsonLogic or expr expression, depends on the filter implementation
@param {string} resultMappingInput must be an expr expression

func (s Event) CreateEventFromInput(ctx context.Context, input model.CreateEventInput) (*ent.Event, error)

type JWT struct {
	Config *appconfig.Config
	// contains filtered or unexported fields
}

func NewJWT(config *appconfig.Config) (JWT, error)

func (s *JWT) Sign(userId string) (string, error)

Sign signs a JWT token with the given user ID as the `sub` claim.

func (s *JWT) Verify(token string) (sub string, t time.Time, err error)

Verify verifies the token and returns the user ID (`sub` claim) along with the expiration time if the token is valid.

type Mail struct {
	fx.In

	ResendClient *resend.Client
}

func (s Mail) Send(r *SendEmailRequest) (string, error)

type SendEmailRequest struct {
	To      []string
	Subject string
	Html    string
	Text    string
}

type Turnstile struct {
	Config *appconfig.Config
	// contains filtered or unexported fields
}

func NewTurnstile(config *appconfig.Config) Turnstile

func (s Turnstile) Verify(ctx context.Context, turnstileResponse, expectedAction string) error