inbox

type Closer ¶

type Closer interface {
	Close() error
}

Closer provides a function for closing an inbox.

type Identifier ¶

type Identifier interface {
	Identifier() int
}

Identifier provides a method for obtaining a unique identifier for the inbox.

type Inbox ¶

type Inbox interface {
	Closer
	Identifier
	MessageHandler
	FromAddress() string
	Channel() string
}

Inbox combines the operations of an inbox including its lifecycle, identification, and message handling.

type Manager ¶

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

func New(lo *logf.Logger, db *sqlx.DB, i18n *i18n.I18n) (*Manager, error)

func (m *Manager) Close()

func (m *Manager) Create(inbox imodels.Inbox) (imodels.Inbox, error)

func (m *Manager) Get(id int) (Inbox, error)

func (m *Manager) GetAll() ([]imodels.Inbox, error)

func (m *Manager) GetDBRecord(id int) (imodels.Inbox, error)

func (m *Manager) InitInboxes(initFn initFn) error

func (m *Manager) Register(i Inbox)

func (m *Manager) Reload(ctx context.Context, initFn initFn) error

func (m *Manager) SetMessageStore(store MessageStore)

func (m *Manager) SetUserStore(store UserStore)

func (m *Manager) SoftDelete(id int) error

func (m *Manager) Start(ctx context.Context) error

func (m *Manager) Toggle(id int) (imodels.Inbox, error)

func (m *Manager) Update(id int, inbox imodels.Inbox) (imodels.Inbox, error)

type MessageHandler ¶

type MessageHandler interface {
	Receive(context.Context) error
	Send(models.Message) error
}

MessageHandler defines methods for handling message operations.

type MessageStore ¶

type MessageStore interface {
	MessageExists(string) (bool, error)
	EnqueueIncoming(models.IncomingMessage) error
}

MessageStore defines methods for storing and processing messages.

type Opts ¶

type Opts struct {
	QueueSize   int
	Concurrency int
}

Opts contains the options for initializing the inbox manager.

type UserStore ¶

type UserStore interface {
	GetContact(id int, email string) (umodels.User, error)
}

UserStore defines methods for fetching user information.