app

Documentation

Index

• Variables
• type App
  • func New(db database.Querier, fileStore FileStore, bus core.Bus, config *models.Config, ...) (App, func())
  • func (a App) AttachmentGet(ctx context.Context, id int64) (models.Attachment, error)
  • func (a App) AttachmentList(ctx context.Context, page pagination.Page, req models.DTOAttachmentListRequest) (models.DTOAttachmentListResult, error)
  • func (a App) AttachmentOrphanDelete(ctx context.Context, tracer trace.Tracer) error
  • func (a App) AuthHTTPAnonymous() bool
  • func (a App) AuthHTTPLogin(ctx context.Context, username, password string) (models.User, error)
  • func (a App) AuthSMTPAnonymous() bool
  • func (a App) AuthSMTPLogin(ctx context.Context, username, password string) error
  • func (a App) DatabaseVacuum(ctx context.Context) error
  • func (a App) EndpointList(ctx context.Context) ([]models.Endpoint, error)
  • func (a App) EndpointTest(ctx context.Context, id int64) error
  • func (a App) EnvelopeCount(ctx context.Context) (int, error)
  • func (a App) EnvelopeCreate(ctx context.Context, dtoMsg models.DTOMessageCreate, ...) (int64, error)
  • func (a App) EnvelopeDelete(ctx context.Context, id int64) error
  • func (a App) EnvelopeDrop(ctx context.Context) error
  • func (a App) EnvelopeGet(ctx context.Context, id int64) (models.Envelope, error)
  • func (a App) EnvelopeList(ctx context.Context, page pagination.Page, req models.DTOEnvelopeListRequest) (models.DTOEnvelopeListResult, error)
  • func (a App) EnvelopeSend(ctx context.Context, envelopeID int64, endpointID int64) error
  • func (a App) MailmanDequeue(ctx context.Context) (*models.Envelope, error)
  • func (a App) MailmanEnqueue(ctx context.Context, envelopeID int64) error
  • func (a App) MessageHTMLGet(ctx context.Context, id int64) (string, error)
  • func (a App) RetentionPolicyGet(ctx context.Context) models.ConfigRetentionPolicy
  • func (a App) RetentionPolicyRun(ctx context.Context, tracer trace.Tracer) error
  • func (a App) RuleCreate(ctx context.Context, req models.DTORuleCreate) (int64, error)
  • func (a App) RuleDelete(ctx context.Context, id int64) error
  • func (a App) RuleEndpointsGet(ctx context.Context, id int64) (models.RuleEndpoints, error)
  • func (a App) RuleEndpointsList(ctx context.Context) ([]models.RuleEndpoints, error)
  • func (App) RuleExpressionCheck(ctx context.Context, expression string) error
  • func (a App) RuleGet(ctx context.Context, id int64) (models.Rule, error)
  • func (a App) RuleList(ctx context.Context) ([]models.Rule, error)
  • func (a App) RuleUpdate(ctx context.Context, req models.DTORuleUpdate) error
  • func (a App) StorageGet(ctx context.Context) (models.Storage, error)
  • func (a App) TraceDrop(ctx context.Context) error
  • func (a App) TraceList(ctx context.Context, page pagination.Page, req models.DTOTraceListRequest) (models.DTOTraceListResult, error)
  • func (a App) Tracer(source string) trace.Tracer
• type FileStore
• type WebTestFileStore
  • func NewWebTestFileStore(name, url string) WebTestFileStore
  • func (w WebTestFileStore) File() (fs.File, error)
  • func (w WebTestFileStore) Path(ctx context.Context, att models.Attachment) (string, error)
  • func (w WebTestFileStore) Reader(ctx context.Context, att models.Attachment) (io.ReadCloser, error)

Variables

var ErrorLogin = fmt.Errorf("login invalid")

Types

type App

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

func New

func New(
	db database.Querier,
	fileStore FileStore,
	bus core.Bus,
	config *models.Config,
	endpointFactory endpoint.Factory,
	webTestFileStore WebTestFileStore,
) (App, func())

func (App) AttachmentGet

func (a App) AttachmentGet(ctx context.Context, id int64) (models.Attachment, error)

func (App) AttachmentList

func (a App) AttachmentList(ctx context.Context, page pagination.Page, req models.DTOAttachmentListRequest) (models.DTOAttachmentListResult, error)

func (App) AttachmentOrphanDelete

func (a App) AttachmentOrphanDelete(ctx context.Context, tracer trace.Tracer) error

func (App) AuthHTTPAnonymous

func (a App) AuthHTTPAnonymous() bool

AuthHTTPAnonymous checks if anonymous access is allowed.

func (App) AuthHTTPLogin

func (a App) AuthHTTPLogin(ctx context.Context, username, password string) (models.User, error)

func (App) AuthSMTPAnonymous

func (a App) AuthSMTPAnonymous() bool

func (App) AuthSMTPLogin

func (a App) AuthSMTPLogin(ctx context.Context, username, password string) error

func (App) DatabaseVacuum

func (a App) DatabaseVacuum(ctx context.Context) error

DatabaseVacuum implements core.App.

func (App) EndpointList

func (a App) EndpointList(ctx context.Context) ([]models.Endpoint, error)

func (App) EndpointTest

func (a App) EndpointTest(ctx context.Context, id int64) error

func (App) EnvelopeCount

func (a App) EnvelopeCount(ctx context.Context) (int, error)

func (App) EnvelopeCreate

func (a App) EnvelopeCreate(ctx context.Context, dtoMsg models.DTOMessageCreate, dtoDatts []models.DTOAttachmentCreate) (int64, error)

func (App) EnvelopeDelete

func (a App) EnvelopeDelete(ctx context.Context, id int64) error

func (App) EnvelopeDrop

func (a App) EnvelopeDrop(ctx context.Context) error

func (App) EnvelopeGet

func (a App) EnvelopeGet(ctx context.Context, id int64) (models.Envelope, error)

func (App) EnvelopeList

func (a App) EnvelopeList(ctx context.Context, page pagination.Page, req models.DTOEnvelopeListRequest) (models.DTOEnvelopeListResult, error)

func (App) EnvelopeSend

func (a App) EnvelopeSend(ctx context.Context, envelopeID int64, endpointID int64) error

func (App) MailmanDequeue

func (a App) MailmanDequeue(ctx context.Context) (*models.Envelope, error)

func (App) MailmanEnqueue

func (a App) MailmanEnqueue(ctx context.Context, envelopeID int64) error

func (App) MessageHTMLGet

func (a App) MessageHTMLGet(ctx context.Context, id int64) (string, error)

func (App) RetentionPolicyGet

func (a App) RetentionPolicyGet(ctx context.Context) models.ConfigRetentionPolicy

func (App) RetentionPolicyRun

func (a App) RetentionPolicyRun(ctx context.Context, tracer trace.Tracer) error

func (App) RuleCreate

func (a App) RuleCreate(ctx context.Context, req models.DTORuleCreate) (int64, error)

func (App) RuleDelete

func (a App) RuleDelete(ctx context.Context, id int64) error

func (App) RuleEndpointsGet

func (a App) RuleEndpointsGet(ctx context.Context, id int64) (models.RuleEndpoints, error)

func (App) RuleEndpointsList

func (a App) RuleEndpointsList(ctx context.Context) ([]models.RuleEndpoints, error)

func (App) RuleExpressionCheck

func (App) RuleExpressionCheck(ctx context.Context, expression string) error

func (App) RuleGet

func (a App) RuleGet(ctx context.Context, id int64) (models.Rule, error)

func (App) RuleList

func (a App) RuleList(ctx context.Context) ([]models.Rule, error)

func (App) RuleUpdate

func (a App) RuleUpdate(ctx context.Context, req models.DTORuleUpdate) error

func (App) StorageGet

func (a App) StorageGet(ctx context.Context) (models.Storage, error)

func (App) TraceDrop

func (a App) TraceDrop(ctx context.Context) error

func (App) TraceList

func (a App) TraceList(ctx context.Context, page pagination.Page, req models.DTOTraceListRequest) (models.DTOTraceListResult, error)

func (App) Tracer

func (a App) Tracer(source string) trace.Tracer

type FileStore

type FileStore interface {
	Create(ctx context.Context, att models.Attachment, data io.Reader) error
	Remove(ctx context.Context, att models.Attachment) error
	Size(ctx context.Context) (int64, error)
	Trim(ctx context.Context, size int64, minAge time.Time) (int, error)
	Reader(ctx context.Context, att models.Attachment) (io.ReadCloser, error)
	Path(ctx context.Context, att models.Attachment) (string, error)
}

type WebTestFileStore

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

WebTestFileStore is used for testing endpoints.

func NewWebTestFileStore

func NewWebTestFileStore(name, url string) WebTestFileStore

func (WebTestFileStore) File

func (w WebTestFileStore) File() (fs.File, error)

func (WebTestFileStore) Path

func (w WebTestFileStore) Path(ctx context.Context, att models.Attachment) (string, error)

func (WebTestFileStore) Reader

func (w WebTestFileStore) Reader(ctx context.Context, att models.Attachment) (io.ReadCloser, error)