infrastructure

Documentation

Index

• func ClosePostgresConnection()
• func CloseRabbitMQConnection()
• func ConnectToRabbitMQ()
• func ErrorHandlerMiddleware() gin.HandlerFunc
• func GetMultipartFormBufferFromFile(file *multipart.File) (*baseMultipartFormBuffer, error)
• func GetPostgresConnection() *sql.DB
• func GetRabbitMQChannel() *amqp.Channel
• func GetRabbitMQSubmissionsQueue() *amqp.Queue
• func GetValidator() *validator.Validate
• func ParseMicroserviceError(resp *http.Response, err error) error
• func ParseRFCEDate(date string) (time.Time, error)
• func ValidateMultipartFileHeader(multipartHeader *multipart.FileHeader) error
• func WithAuthenticationMiddleware() gin.HandlerFunc
• func WithAuthorizationMiddleware(role []string) gin.HandlerFunc
• func WithServerSentEventsMiddleware() gin.HandlerFunc
• type Claims
• type EnvironmentSpec
  • func GetEnvironment() *EnvironmentSpec
• type JwtTokenHandler
  • func GetJwtTokenHandler() *JwtTokenHandler
  • func (handler JwtTokenHandler) GenerateToken(user entities.User) (string, error)
  • func (handler JwtTokenHandler) ValidateToken(token string) (dtos.CustomClaimsDTO, error)

Functions

func ClosePostgresConnection

func ClosePostgresConnection()

func CloseRabbitMQConnection

func CloseRabbitMQConnection()

func ConnectToRabbitMQ

func ConnectToRabbitMQ()

func ErrorHandlerMiddleware

func ErrorHandlerMiddleware() gin.HandlerFunc

func GetMultipartFormBufferFromFile

func GetMultipartFormBufferFromFile(file *multipart.File) (*baseMultipartFormBuffer, error)

func GetPostgresConnection

func GetPostgresConnection() *sql.DB

func GetRabbitMQChannel

func GetRabbitMQChannel() *amqp.Channel

func GetRabbitMQSubmissionsQueue

func GetRabbitMQSubmissionsQueue() *amqp.Queue

func GetValidator

func GetValidator() *validator.Validate

func ParseMicroserviceError

func ParseMicroserviceError(resp *http.Response, err error) error

ParseMicroserviceError parses the error returned by the archives microservice

func ParseRFCEDate

func ParseRFCEDate(date string) (time.Time, error)

ParseRFCEDate parses a date in RFC3339 format

func ValidateMultipartFileHeader

func ValidateMultipartFileHeader(multipartHeader *multipart.FileHeader) error

ValidateMultipartFileHeader validates the multipart archive according to the environment configuration and domain rules

func WithAuthenticationMiddleware

func WithAuthenticationMiddleware() gin.HandlerFunc

func WithAuthorizationMiddleware

func WithAuthorizationMiddleware(role []string) gin.HandlerFunc

func WithServerSentEventsMiddleware

func WithServerSentEventsMiddleware() gin.HandlerFunc

Types

type Claims

type Claims struct {
	UUID string `json:"uuid"`
	Role string `json:"role"`
	jwt.RegisteredClaims
}

type EnvironmentSpec

type EnvironmentSpec struct {
	// Execution environment
	ExecEnvironment string `split_words:"true" default:"development"`
	IsInProduction  bool   `split_words:"true" default:"false"`

	// Connection strings
	DbConnectionString             string `split_words:"true" default:"postgres://postgres:postgres@localhost:5432/codelabs?sslmode=disable"`
	RabbitMQConnectionString       string `split_words:"true" default:"amqp://rabbitmq:rabbitmq@localhost:5672/"`
	WebClientUrl                   string `split_words:"true" default:"http://localhost:5173"`
	StaticFilesMicroserviceAddress string `split_words:"true" default:"http://localhost:8081"`

	// PgSQL migration files
	DbMigrationsPath string `split_words:"true" default:"file://sql/migrations"`

	// JWT parameters
	JwtSecret          string `split_words:"true" default:"default"`
	JwtExpirationHours int    `split_words:"true" default:"6"`

	// Configuration parameters
	ArchiveMaxSizeKb int64 `split_words:"true" default:"1024"`
}

func GetEnvironment

func GetEnvironment() *EnvironmentSpec

type JwtTokenHandler

type JwtTokenHandler struct {
	Secret          string
	ExpirationHours int
}

func GetJwtTokenHandler

func GetJwtTokenHandler() *JwtTokenHandler

func (JwtTokenHandler) GenerateToken

func (handler JwtTokenHandler) GenerateToken(user entities.User) (string, error)

func (JwtTokenHandler) ValidateToken

func (handler JwtTokenHandler) ValidateToken(token string) (dtos.CustomClaimsDTO, error)