backend

package

Go to main page

Versions in this module

v0

v0.17.0

Jul 7, 2023

Changes in this version

type StateUserInterfaceImpl

+ func (s *StateUserInterfaceImpl) GetRecoveredMessageHashesMap() *utils.MessageHashesMap

v0.16.0

Apr 12, 2023

v0.15.0

Feb 22, 2023

Changes in this version

type StateUserInterfaceImpl

+ func (s *StateUserInterfaceImpl) GenerateUIDValidity() (imap.UID, error)

v0.14.1

Nov 25, 2022

v0.14.0

Nov 24, 2022

Changes in this version

type Backend

+ func (b *Backend) GetMailboxMessageCounts(ctx context.Context, userID string) (map[imap.MailboxID]int, error)

type StateUserInterfaceImpl

+ func (s *StateUserInterfaceImpl) GetGlobalUIDValidity() imap.UID

+ func (s *StateUserInterfaceImpl) GetRecoveryMailboxID() ids.MailboxIDPair

+ func (s *StateUserInterfaceImpl) NextRecoveryMessageID() imap.InternalMessageID

+ func (s *StateUserInterfaceImpl) SetGlobalUIDValidity(uid imap.UID)

v0.13.0

Oct 20, 2022

v0.12.0

Oct 19, 2022

Changes in this version

+ var ErrLoginBlocked = errors.New("too many login attempts")

type Backend

+ func (b *Backend) ReleaseState(ctx context.Context, st *state.State) error

+ type StateUserInterfaceImpl struct

+ func (s *StateUserInterfaceImpl) GetDB() *db.DB

+ func (s *StateUserInterfaceImpl) GetDelimiter() string

+ func (s *StateUserInterfaceImpl) GetRemote() state.Connector

+ func (s *StateUserInterfaceImpl) GetStore() store.Store

+ func (s *StateUserInterfaceImpl) GetUserID() string

+ func (s *StateUserInterfaceImpl) QueueOrApplyStateUpdate(ctx context.Context, tx *ent.Tx, update state.Update) error

+ func (s *StateUserInterfaceImpl) ReleaseState(ctx context.Context, st *state.State) error

v0.11.0

Aug 17, 2022

Changes in this version

+ func DBCreateMailboxIfNotExists(ctx context.Context, tx *ent.Tx, internalID imap.InternalMailboxID, ...) error

+ func DBDeleteMailboxWithRemoteID(ctx context.Context, tx *ent.Tx, mboxID imap.LabelID) error

+ func DBGetMailboxIDWithRemoteID(ctx context.Context, client *ent.Client, labelID imap.LabelID) (imap.InternalMailboxID, error)

+ func DBGetMailboxNameWithRemoteID(ctx context.Context, client *ent.Client, mboxID imap.LabelID) (string, error)

+ func DBGetMessageIDFromRemoteID(ctx context.Context, client *ent.Client, id imap.MessageID) (imap.InternalMessageID, error)

+ func DBGetRemoteMessageID(ctx context.Context, client *ent.Client, internalID imap.InternalMessageID) (imap.MessageID, error)

+ func DBHasMessageWithID(ctx context.Context, client *ent.Client, id imap.InternalMessageID) (bool, error)

+ func DBMailboxExistsWithRemoteID(ctx context.Context, client *ent.Client, mboxID imap.LabelID) (bool, error)

+ func DBMarkMessageAsDeletedWithRemoteID(ctx context.Context, tx *ent.Tx, messageID imap.MessageID) error

+ func DBMessageExistsWithRemoteID(ctx context.Context, client *ent.Client, messageID imap.MessageID) (bool, error)

+ func DBRenameMailboxWithRemoteID(ctx context.Context, tx *ent.Tx, mboxID imap.LabelID, name string) error

+ func DBTranslateRemoteMailboxIDs(ctx context.Context, client *ent.Client, mboxIDs []imap.LabelID) ([]imap.InternalMailboxID, error)

+ func DBUpdateRemoteMailboxID(ctx context.Context, tx *ent.Tx, internalID imap.InternalMailboxID, ...) error

+ func DBUpdateRemoteMessageID(ctx context.Context, tx *ent.Tx, internalID imap.InternalMessageID, ...) error

+ func SplitMailboxIDPairSlice(s []MailboxIDPair) ([]imap.InternalMailboxID, []imap.LabelID)

+ func SplitMessageIDPairSlice(s []MessageIDPair) ([]imap.InternalMessageID, []imap.MessageID)

+ type MailboxIDPair struct

+ InternalID imap.InternalMailboxID

+ RemoteID imap.LabelID

+ func NewMailboxIDPair(mbox *ent.Mailbox) MailboxIDPair

+ func NewMailboxIDPairWithoutRemote(internalID imap.InternalMailboxID) MailboxIDPair

+ func (m *MailboxIDPair) String() string

+ type MessageIDPair struct

+ InternalID imap.InternalMessageID

+ RemoteID imap.MessageID

+ func DBGetMailboxMessageIDPairs(ctx context.Context, client *ent.Client, mailboxID imap.InternalMailboxID) ([]MessageIDPair, error)

+ func NewMessageIDPair(msg *ent.Message) MessageIDPair

+ func NewMessageIDPairWithoutRemote(internalID imap.InternalMessageID) MessageIDPair

+ func (m *MessageIDPair) String() string

v0.10.0

Aug 15, 2022

Changes in this version

type Backend

+ func (b *Backend) GetDelimiter() string

+ type DB struct

+ func (d *DB) Close() error

+ func (d *DB) Init(ctx context.Context) error

+ func (d *DB) Read(ctx context.Context, fn func(context.Context, *ent.Client) error) error

+ func (d *DB) Write(ctx context.Context, fn func(context.Context, *ent.Tx) error) error

v0.9.0

Aug 10, 2022

Changes in this version

+ func DBAddMessageFlag(ctx context.Context, tx *ent.Tx, messageIDs []string, addFlag string) error

+ func DBAddMessagesToMailbox(ctx context.Context, tx *ent.Tx, messageIDs []string, mboxID string) (map[string]int, error)

+ func DBBumpMailboxUIDNext(ctx context.Context, tx *ent.Tx, mbox *ent.Mailbox, withCount ...int) error

+ func DBClearRecentFlag(ctx context.Context, tx *ent.Tx, mboxID, messageID string) error

+ func DBClearRecentFlags(ctx context.Context, tx *ent.Tx, mboxID string) error

+ func DBCreateMailbox(ctx context.Context, tx *ent.Tx, mboxID, name string, ...) (*ent.Mailbox, error)

+ func DBCreateMessages(ctx context.Context, tx *ent.Tx, reqs ...*DBCreateMessageReq) ([]*ent.Message, error)

+ func DBDeleteMailbox(ctx context.Context, tx *ent.Tx, mboxID string) error

+ func DBDeleteMessages(ctx context.Context, tx *ent.Tx, messageIDs ...string) error

+ func DBGetAllMailboxes(ctx context.Context, client *ent.Client) ([]*ent.Mailbox, error)

+ func DBGetMailboxByID(ctx context.Context, client *ent.Client, id string) (*ent.Mailbox, error)

+ func DBGetMailboxByName(ctx context.Context, client *ent.Client, name string) (*ent.Mailbox, error)

+ func DBGetMailboxMessage(ctx context.Context, client *ent.Client, mailboxID, messageID string) (*ent.UID, error)

+ func DBGetMailboxMessageIDs(ctx context.Context, client *ent.Client, mailboxID string) ([]string, error)

+ func DBGetMailboxMessages(ctx context.Context, mbox *ent.Mailbox) ([]*ent.UID, error)

+ func DBGetMailboxMessagesForNewSnapshot(ctx context.Context, mbox *ent.Mailbox) ([]*ent.UID, error)

+ func DBGetMailboxName(ctx context.Context, client *ent.Client, mboxID string) (string, error)

+ func DBGetMailboxRecentCount(ctx context.Context, mbox *ent.Mailbox) (int, error)

+ func DBGetMessage(ctx context.Context, client *ent.Client, messageID string) (*ent.Message, error)

+ func DBGetMessageDeleted(ctx context.Context, client *ent.Client, mboxID string, messageIDs []string) (map[string]bool, error)

+ func DBGetMessageFlags(ctx context.Context, client *ent.Client, messageIDs []string) (map[string]imap.FlagSet, error)

+ func DBGetMessageID(ctx context.Context, client *ent.Client, internalID string) (string, error)

+ func DBGetMessageIDsMarkedDeleted(ctx context.Context, tx *ent.Tx) ([]string, error)

+ func DBGetMessageMailboxIDs(ctx context.Context, client *ent.Client, messageID string) ([]string, error)

+ func DBGetMessageUIDs(ctx context.Context, client *ent.Client, mboxID string, messageIDs []string) (map[string]int, error)

+ func DBGetMessages(ctx context.Context, client *ent.Client, messageIDs ...string) (map[string]*ent.Message, error)

+ func DBGetUIDInterval(ctx context.Context, mbox *ent.Mailbox, begin, end int) ([]*ent.UID, error)

+ func DBMailboxExistsWithID(ctx context.Context, client *ent.Client, mboxID string) (bool, error)

+ func DBMailboxExistsWithName(ctx context.Context, client *ent.Client, name string) (bool, error)

+ func DBMarkMessageAsDeleted(ctx context.Context, tx *ent.Tx, messageID string) error

+ func DBMessageExists(ctx context.Context, client *ent.Client, messageID string) (bool, error)

+ func DBRemoveMessageFlag(ctx context.Context, tx *ent.Tx, messageIDs []string, remFlag string) error

+ func DBRemoveMessagesFromMailbox(ctx context.Context, tx *ent.Tx, messageIDs []string, mboxID string) error

+ func DBRenameMailbox(ctx context.Context, tx *ent.Tx, mboxID, name string) error

+ func DBSetDeletedFlag(ctx context.Context, tx *ent.Tx, mboxID string, messageIDs []string, ...) error

+ func DBSetMessageFlags(ctx context.Context, tx *ent.Tx, messageIDs []string, setFlags imap.FlagSet) error

+ func DBUpdateMailboxID(ctx context.Context, tx *ent.Tx, oldID, newID string) error

+ func DBUpdateMessageID(ctx context.Context, tx *ent.Tx, oldID, newID string) error

type Backend

+ func (b *Backend) NewUserID() string

+ type DBCreateMessageReq struct

v0.8.1

Jun 29, 2022

Changes in this version

type State

+ func (state *State) Done() <-chan struct{}

v0.8.0

Jun 16, 2022

Changes in this version

type State

+ func (state *State) SetConnMetadataKeyValue(key string, value any) error

v0.7.2

Jun 14, 2022

v0.7.1

Jun 14, 2022

v0.7.0

Jun 14, 2022

v0.6.0

Jun 13, 2022

v0.5.0

Jun 7, 2022

Changes in this version

+ var ErrNoSuchUser = errors.New("no such user")

+ var ErrSessionNotSelected = errors.New("session is not selected")

type Backend

+ func (b *Backend) RemoveUser(ctx context.Context, userID string) error

v0.4.0

Jun 7, 2022

v0.3.0

Jun 3, 2022

v0.2.1

May 31, 2022

v0.2.0

May 31, 2022

v0.1.0

May 30, 2022

Changes in this version

+ const InternalIDHeaderLength

+ const InternalIDHeaderLengthWithNewLine

+ const InternalIDKey

+ var ErrAlreadySubscribed = errors.New("already subscribed to this mailbox")

+ var ErrAlreadyUnsubscribed = errors.New("not subscribed to this mailbox")

+ var ErrExistingMailbox = errors.New("a mailbox with that name already exists")

+ var ErrNoSuchMailbox = errors.New("no such mailbox")

+ var ErrNoSuchMessage = errors.New("no such message")

+ var ErrNoSuchSnapshot = errors.New("no such snapshot")

+ var ErrNotImplemented = errors.New("not implemented")

+ var ErrSessionIsNotSelected = errors.New("session is not selected")

+ func AsClose(parent context.Context) context.Context

+ func AsSilent(parent context.Context) context.Context

+ func AsUID(parent context.Context) context.Context

+ type Backend struct

+ func New(dir string) *Backend

+ func (b *Backend) AddUser(userID, username, password string, conn connector.Connector, store store.Store, ...) error

+ func (b *Backend) Close(ctx context.Context) error

+ func (b *Backend) GetState(username, password string) (*State, error)

+ func (b *Backend) SetDelimiter(delim string)

+ type Mailbox struct

+ func (m *Mailbox) Append(ctx context.Context, literal []byte, flags imap.FlagSet, date time.Time) (int, error)

+ func (m *Mailbox) Attributes(ctx context.Context) (imap.FlagSet, error)

+ func (m *Mailbox) Close(ctx context.Context) error

+ func (m *Mailbox) Copy(ctx context.Context, seq *proto.SequenceSet, name string) (response.Item, error)

+ func (m *Mailbox) Count() int

+ func (m *Mailbox) Expunge(ctx context.Context, seq *proto.SequenceSet) error

+ func (m *Mailbox) ExpungeIssued() bool

+ func (m *Mailbox) Fetch(ctx context.Context, seq *proto.SequenceSet, ...) error

+ func (m *Mailbox) Flags(ctx context.Context) (imap.FlagSet, error)

+ func (m *Mailbox) Flush(ctx context.Context, permitExpunge bool) ([]response.Response, error)

+ func (m *Mailbox) GetMessagesWithFlag(flag string) []int

+ func (m *Mailbox) GetMessagesWithoutFlag(flag string) []int

+ func (m *Mailbox) Move(ctx context.Context, seq *proto.SequenceSet, name string) (response.Item, error)

+ func (m *Mailbox) Name() string

+ func (m *Mailbox) PermanentFlags(ctx context.Context) (imap.FlagSet, error)

+ func (m *Mailbox) ReadOnly() bool

+ func (m *Mailbox) Search(ctx context.Context, keys []*proto.SearchKey) ([]int, error)

+ func (m *Mailbox) Selected() bool

+ func (m *Mailbox) Store(ctx context.Context, seq *proto.SequenceSet, operation proto.Operation, ...) error

+ func (m *Mailbox) Subscribed() bool

+ func (m *Mailbox) UIDNext() int

+ func (m *Mailbox) UIDValidity() int

+ type Match struct

+ Atts imap.FlagSet

+ Delimiter string

+ Name string

+ type State struct

+ func (state *State) Close(ctx context.Context) error

+ func (state *State) Create(ctx context.Context, name string) error

+ func (state *State) Delete(ctx context.Context, name string) error

+ func (state *State) Examine(ctx context.Context, name string, fn func(*Mailbox) error) error

+ func (state *State) Idle(ctx context.Context, ...) error

+ func (state *State) IsSelected() bool

+ func (state *State) List(ctx context.Context, ref, pattern string, subscribed bool, ...) error

+ func (state *State) Mailbox(ctx context.Context, name string, fn func(*Mailbox) error) error

+ func (state *State) Rename(ctx context.Context, oldName, newName string) error

+ func (state *State) Select(ctx context.Context, name string, fn func(*Mailbox) error) error

+ func (state *State) Selected(ctx context.Context, fn func(*Mailbox) error) error

+ func (state *State) Subscribe(ctx context.Context, name string) error

+ func (state *State) Unsubscribe(ctx context.Context, name string) error

+ func (state *State) UserID() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL