utils

May 18, 2025

Changes in this version

type Accesser

+ func (a *Accesser) SuperUserAuthMiddleware(next echo.HandlerFunc) echo.HandlerFunc

type Repo

+ SuperUserAuthMiddleware func(next echo.HandlerFunc) echo.HandlerFunc

May 6, 2025

Changes in this version

type Accesser

+ func (a *Accesser) GroupAuthMiddleware(next echo.HandlerFunc) echo.HandlerFunc

+ func (a *Accesser) OfficershipAuthMiddleware(next echo.HandlerFunc) echo.HandlerFunc

+ func (a *Accesser) PermissionsAuthMiddleware(next echo.HandlerFunc) echo.HandlerFunc

+ type HTTPError struct

+ Message string

+ Status int

+ type NotInExpr inExpr

+ func NotIn(column string, e any) NotInExpr

+ func (e NotInExpr) ToSql() (sql string, args []interface{}, err error)

+ type Repo interface

+ AddUserAuthMiddleware func(next echo.HandlerFunc) echo.HandlerFunc

+ AuthMiddleware func(next echo.HandlerFunc) echo.HandlerFunc

+ GetToken func(r *http.Request) (*AccessClaims, int, error)

+ GroupAuthMiddleware func(next echo.HandlerFunc) echo.HandlerFunc

+ ListUserAuthMiddleware func(next echo.HandlerFunc) echo.HandlerFunc

+ ManageStreamAuthMiddleware func(next echo.HandlerFunc) echo.HandlerFunc

+ ModifyUserAuthMiddleware func(next echo.HandlerFunc) echo.HandlerFunc

+ OfficershipAuthMiddleware func(next echo.HandlerFunc) echo.HandlerFunc

+ PermissionsAuthMiddleware func(next echo.HandlerFunc) echo.HandlerFunc

+ type StringSQL string

+ func (s StringSQL) ToSql() (sql string, args []interface{}, err error)

Feb 21, 2025

Changes in this version

+ func NonNil[T any](k T) T

+ func PSQL() sq.StatementBuilderType

type Accesser

+ func (a *Accesser) AddUserAuthMiddleware(next echo.HandlerFunc) echo.HandlerFunc

+ func (a *Accesser) ListUserAuthMiddleware(next echo.HandlerFunc) echo.HandlerFunc

+ func (a *Accesser) ManageStreamAuthMiddleware(next echo.HandlerFunc) echo.HandlerFunc

+ func (a *Accesser) ModifyUserAuthMiddleware(next echo.HandlerFunc) echo.HandlerFunc

type Config

+ SecurityBaseURL string

+ type CustomTime struct

+ func (t *CustomTime) MarshalJSON() ([]byte, error)

Aug 8, 2022

Changes in this version

+ var ErrInvalidToken = errors.New("invalid token")

+ var ErrNoToken = errors.New("token not found")

+ type AccessClaims struct

+ Permissions []string

+ UserID int

+ type Accesser struct

+ func NewAccesser(conf Config) *Accesser

+ func (a *Accesser) AuthMiddleware(next echo.HandlerFunc) echo.HandlerFunc

+ func (a *Accesser) GetToken(r *http.Request) (*AccessClaims, error)

+ type Config struct

+ AccessCookieName string

+ SigningKey []byte

Aug 9, 2021

Changes in this version

+ var ErrInvalidCookie = errors.New("invalid cookie")

+ var ErrNoCookie = errors.New("failed to find token cookie")

+ func NewCDN(config CDNConfig) *s3.S3

+ func NewDB(config DatabaseConfig) (*sqlx.DB, error)

+ func NewMQ(conf MQConfig) (*amqp.Connection, error)

+ type CDNConfig struct

+ AccessKeyID string

+ Endpoint string

+ Region string

+ SecretAccessKey string

+ type DatabaseConfig struct

+ Host string

+ Name string

+ Password string

+ Port string

+ SSLMode string

+ Username string

type JWTClaims

+ Permissions []Permission

+ func GetToken(cookie *http.Cookie) (*JWTClaims, error)

+ func GetTokenEcho(c echo.Context) (*JWTClaims, error)

+ func GetTokenHTTP(r *http.Request) (*JWTClaims, error)

+ type MQConfig struct

+ Host string

+ Password string

+ Port string

+ Username string

+ type Mail struct

+ Bcc []string

+ Cc []string

+ From string

+ Subject string

+ To string

+ type MailConfig struct

+ Host string

+ Password string

+ Port int

+ Username string

+ type Mailer struct

+ Enabled bool

+ func NewMailer(config MailConfig) (*Mailer, error)

+ func (m *Mailer) SendMail(item Mail) error

+ type Permission struct

+ Name string

+ PermissionID int

Nov 20, 2020

Changes in this version

+ func InitCDN() *s3.S3

+ func InitDB() *sqlx.DB

+ func InitMessaging()

+ func Transact(db *sqlx.DB, txFunc func(*sqlx.Tx) error) (err error)

+ func ValidateToken()

+ type IMessagingClient interface

+ Close func()

+ ConnectToBroker func(connectionString string)

+ Info func() string

+ Publish func(msg []byte, exchangeName string, exchangeType string) error

+ PublishOnQueue func(msg []byte, queueName string) error

+ PublishOnQueueWithContext func(ctx context.Context, msg []byte, queueName string) error

+ Subscribe func(exchangeName string, exchangeType string, consumerName string, ...) error

+ SubscribeToQueue func(queueName string, consumerName string, handlerFunc func(amqp.Delivery)) error

+ var MQ IMessagingClient

+ type JWTClaims struct

+ UserID int

+ type MessagingClient struct

+ func (m *MessagingClient) Close()

+ func (m *MessagingClient) ConnectToBroker(connectionString string)

+ func (m *MessagingClient) Info() string

+ func (m *MessagingClient) Publish(body []byte, exchangeName string, exchangeType string) error

+ func (m *MessagingClient) PublishOnQueue(body []byte, queueName string) error

+ func (m *MessagingClient) PublishOnQueueWithContext(ctx context.Context, body []byte, queueName string) error

+ func (m *MessagingClient) Subscribe(exchangeName string, exchangeType string, consumerName string, ...) error

+ func (m *MessagingClient) SubscribeToQueue(queueName string, consumerName string, handlerFunc func(amqp.Delivery)) error