westack

Documentation

Index

• Variables
• func CreateNewToken(userIdHex string, UserModel *model.Model, roles []string) (string, error)
• func GRPCCallWithBody[InputT any, ClientT interface{}, OutputT proto.Message](serviceUrl string, clientConstructor func(cc grpc.ClientConnInterface) ClientT, ...) func(ctx *fiber.Ctx) error
• func GRPCCallWithQueryParams[InputT any, ClientT interface{}, OutputT proto.Message](serviceUrl string, clientConstructor func(cc grpc.ClientConnInterface) ClientT, ...) func(ctx *fiber.Ctx) error
• func GetRoleNames(RoleMappingModel *model.Model, userIdHex string, userId primitive.ObjectID) ([]string, error)
• func InitAndServe(options Options, onBoot ...func(app *WeStack))
• func SendInternalError(ctx *fiber.Ctx, err error) error
• func UpsertUserRoles(app *WeStack, userId interface{}, roles []string, ...) error
• func UpsertUserWithRoles(app *WeStack, userToUpsert UserWithRoles, eventContext *model.EventContext) (user *model.Instance, err error)
• type LoginBody
• type Options
• type UniqueNessRestriction
• type UpserRequestBody
• type UserWithRoles
• type WeStack
  • func New(options ...Options) *WeStack
  • func (app *WeStack) Boot(customRoutesCallbacks ...func(app *WeStack))
  • func (app *WeStack) FindDatasource(dsName string) (*datasource.Datasource, error)
  • func (app *WeStack) FindModel(modelName string) (*model.Model, error)
  • func (app *WeStack) FindModelsWithClass(modelClass string) (foundModels []*model.Model)
  • func (app *WeStack) Logger() wst.ILogger
  • func (app *WeStack) Middleware(handler fiber.Handler)
  • func (app *WeStack) Start() error
  • func (app *WeStack) Stop() error

Variables

var ValidEmailRegex = regexp.MustCompile(`^[a-zA-Z0-9_.+-]+@[a-zA-Z0-9-]+\.[a-zA-Z0-9-.]+$`)

Functions

func CreateNewToken

func CreateNewToken(userIdHex string, UserModel *model.Model, roles []string) (string, error)

func GRPCCallWithBody

func GRPCCallWithBody[InputT any, ClientT interface{}, OutputT proto.Message](serviceUrl string, clientConstructor func(cc grpc.ClientConnInterface) ClientT, clientMethod func(ClientT, context.Context, *InputT, ...grpc.CallOption) (OutputT, error), timeoutSeconds ...float32) func(ctx *fiber.Ctx) error

func GRPCCallWithQueryParams

func GRPCCallWithQueryParams[InputT any, ClientT interface{}, OutputT proto.Message](serviceUrl string, clientConstructor func(cc grpc.ClientConnInterface) ClientT, clientMethod func(ClientT, context.Context, *InputT, ...grpc.CallOption) (OutputT, error), timeoutSeconds ...float32) func(ctx *fiber.Ctx) error

func GetRoleNames

func GetRoleNames(RoleMappingModel *model.Model, userIdHex string, userId primitive.ObjectID) ([]string, error)

func InitAndServe

func InitAndServe(options Options, onBoot ...func(app *WeStack))

func SendInternalError

func SendInternalError(ctx *fiber.Ctx, err error) error

func UpsertUserRoles

func UpsertUserRoles(app *WeStack, userId interface{}, roles []string, eventContext *model.EventContext) error

func UpsertUserWithRoles

func UpsertUserWithRoles(app *WeStack, userToUpsert UserWithRoles, eventContext *model.EventContext) (user *model.Instance, err error)

Types

type LoginBody

type LoginBody struct {
	Email    string `json:"email"`
	Password string `json:"password"`
}

type Options

type Options struct {
	RestApiRoot       string
	Port              int
	JwtSecretKey      string
	DatasourceOptions *map[string]*datasource.Options
	EnableCompression bool
	CompressionConfig compress.Config

	Logger            wst.ILogger
	DisablePortEnvVar bool
	// contains filtered or unexported fields
}

type UniqueNessRestriction

type UniqueNessRestriction struct {
	Code      string
	Message   string
	ErrorName string
}

type UpserRequestBody

type UpserRequestBody struct {
	Roles []string `json:"roles"`
}

type UserWithRoles

type UserWithRoles struct {
	Username string   `json:"username"`
	Password string   `json:"password"`
	Roles    []string `json:"roles"`
}

type WeStack

type WeStack struct {
	Server  *fiber.App
	Viper   *viper.Viper
	DsViper *viper.Viper
	Options Options
	Bson    wst.BsonOptions
	// contains filtered or unexported fields
}

func New

func New(options ...Options) *WeStack

func (*WeStack) Boot

func (app *WeStack) Boot(customRoutesCallbacks ...func(app *WeStack))

func (*WeStack) FindDatasource

func (app *WeStack) FindDatasource(dsName string) (*datasource.Datasource, error)

func (*WeStack) FindModel

func (app *WeStack) FindModel(modelName string) (*model.Model, error)

func (*WeStack) FindModelsWithClass

func (app *WeStack) FindModelsWithClass(modelClass string) (foundModels []*model.Model)

func (*WeStack) Logger

func (app *WeStack) Logger() wst.ILogger

func (*WeStack) Middleware

func (app *WeStack) Middleware(handler fiber.Handler)

func (*WeStack) Start

func (app *WeStack) Start() error

func (*WeStack) Stop

func (app *WeStack) Stop() error