webhooks

Documentation

Index

• Variables
• func IsValidationError(err error) bool
• func Migrate(db *gorm.DB) error
• type Repository
  • func NewRepository(db *gorm.DB) *Repository
  • func (r *Repository) Delete(filters ...SelectFilter) error
  • func (r *Repository) Replace(webhook *Webhook) error
  • func (r *Repository) Select(filters ...SelectFilter) ([]*Webhook, error)
• type SelectFilter
  • func WithExtID(extID string) SelectFilter
  • func WithUserID(userID string) SelectFilter
• type Service
  • func NewService(params ServiceParams) *Service
  • func (s *Service) Delete(userID string, filters ...SelectFilter) error
  • func (s *Service) Replace(userID string, webhook *webhooks.Webhook) error
  • func (s *Service) Select(userID string, filters ...SelectFilter) ([]webhooks.Webhook, error)
• type ServiceParams
• type ValidationError
  • func (e ValidationError) Error() string
  • func (e ValidationError) Unwrap() error
• type Webhook

Variables

var Module = fx.Module(
	"webhooks",
	fx.Decorate(func(log *zap.Logger) *zap.Logger {
		return log.Named("webhooks")
	}),
	fx.Provide(NewRepository, fx.Private),
	fx.Provide(
		NewService,
	),
)

Functions

func IsValidationError

func IsValidationError(err error) bool

func Migrate

func Migrate(db *gorm.DB) error

Types

type Repository

type Repository struct {
	// contains filtered or unexported fields
}

func NewRepository

func NewRepository(db *gorm.DB) *Repository

func (*Repository) Delete

func (r *Repository) Delete(filters ...SelectFilter) error

func (*Repository) Replace

func (r *Repository) Replace(webhook *Webhook) error

func (*Repository) Select

func (r *Repository) Select(filters ...SelectFilter) ([]*Webhook, error)

type SelectFilter

type SelectFilter func(*selectFilter)

func WithExtID

func WithExtID(extID string) SelectFilter

func WithUserID

func WithUserID(userID string) SelectFilter

type Service

type Service struct {
	// contains filtered or unexported fields
}

func NewService

func NewService(params ServiceParams) *Service

func (*Service) Delete

func (s *Service) Delete(userID string, filters ...SelectFilter) error

func (*Service) Replace

func (s *Service) Replace(userID string, webhook *webhooks.Webhook) error

func (*Service) Select

func (s *Service) Select(userID string, filters ...SelectFilter) ([]webhooks.Webhook, error)

type ServiceParams

type ServiceParams struct {
	fx.In

	IDGen db.IDGen

	Webhooks *Repository

	DevicesSvc *devices.Service
	PushSvc    *push.Service

	Logger *zap.Logger
}

type ValidationError

type ValidationError struct {
	Field string
	Value string
	Err   error
}

func (ValidationError) Error

func (e ValidationError) Error() string

func (ValidationError) Unwrap

func (e ValidationError) Unwrap() error

type Webhook

type Webhook struct {
	ID     uint64 `json:"-"    gorm:"->;primaryKey;type:BIGINT UNSIGNED;autoIncrement"`
	ExtID  string `json:"id"   gorm:"not null;type:varchar(36);uniqueIndex:unq_webhooks_user_extid,priority:2"`
	UserID string `json:"-"    gorm:"<-:create;not null;type:varchar(32);uniqueIndex:unq_webhooks_user_extid,priority:1"`

	URL   string             `json:"url"   validate:"required,http_url"   gorm:"not null;type:varchar(256)"`
	Event webhooks.EventType `json:"event" gorm:"not null;type:varchar(32)"`

	User models.User `gorm:"foreignKey:UserID;constraint:OnDelete:CASCADE"`

	models.TimedModel
}