db

func EndpointGet(cc core.Context, id int64) (endpoints.Endpoint, error)

func EndpointList(cc core.Context) ([]endpoints.Endpoint, error)

func EndpointListByRule(cc core.Context, id int64) ([]endpoints.Endpoint, error)

func EnvelopeAttachmentCount(cc core.Context) (int, error)

func EnvelopeAttachmentDelete(cc core.Context, att *envelope.Attachment) error

func EnvelopeAttachmentList(cc core.Context, page pagination.Page, filter envelope.AttachmentFilter) (envelope.AttachmentListResult, error)

func EnvelopeAttachmentListOrphan(cc core.Context, limit int) ([]*envelope.Attachment, error)

func EnvelopeCount(cc core.Context) (int, error)

func EnvelopeCreate(cc core.Context, msg *envelope.Message, atts []*envelope.Attachment) (int64, []int64, error)

func EnvelopeDelete(cc core.Context, id int64) error

func EnvelopeDeleteAll(cc core.Context) error

func EnvelopeDeleteOlderThan(cc core.Context, olderThan time.Time) (int64, error)

func EnvelopeDeleteUntilCount(cc core.Context, keep int, olderThan time.Time) (int64, error)

func EnvelopeGet(cc core.Context, id int64) (envelope.Envelope, error)

func EnvelopeMessageHTMLGet(cc core.Context, id int64) (string, error)

func EnvelopeMessageList(cc core.Context, page pagination.Page, filter envelope.MessageFilter) (envelope.MessageListResult, error)

func InternalDeleteOlderThan(cc core.Context, date time.Time) error

func InternalEndpointUpsert(cc core.Context, end endpoints.Endpoint, updatedAt time.Time) error

func InternalRuleEndpointsUpsert(cc core.Context, ruleInternalID string, endpointInternalIDs []string, updatedAt time.Time) error

func InternalRuleUpsert(cc core.Context, r rules.Rule, updatedAt time.Time) error

func Migrate(cc context.Context, bunDB *bun.DB) error

func New(dbPath string) (*bun.DB, error)

func RuleEndpointList(cc core.Context, ruleID int64) ([]rules.Endpoint, error)

func RuleIsInternal(cc core.Context, ruleID int64) (bool, error)

func RuleList(cc core.Context) ([]rules.Rule, error)

func RuleListEnable(cc core.Context) ([]rules.Rule, error)

func RuleUpdate(cc core.Context, ruleID int64, enable bool) (rules.Rule, error)

func Size(cc core.Context) (int64, error)

func Vacuum(cc core.Context) error