From 8cb4a9d751d1497e1059fedb03964bc9e56e5c06 Mon Sep 17 00:00:00 2001 From: Kevin Kuehler Date: Thu, 10 Oct 2019 15:27:07 -0700 Subject: Start adding thread support * Add threading-enabled config option * Add DirectoryThreaded and FetchDirectoryThreaded types to control path * Add generic thread type for all backends to use Signed-off-by: Kevin Kuehler --- lib/msgstore.go | 18 +++++++++++++++--- 1 file changed, 15 insertions(+), 3 deletions(-) (limited to 'lib') diff --git a/lib/msgstore.go b/lib/msgstore.go index 071a504..064ad36 100644 --- a/lib/msgstore.go +++ b/lib/msgstore.go @@ -21,6 +21,9 @@ type MessageStore struct { bodyCallbacks map[uint32][]func(io.Reader) headerCallbacks map[uint32][]func(*types.MessageInfo) + // If set, messages in the mailbox will be threaded + thread bool + // Search/filter results results []uint32 resultIndex int @@ -42,6 +45,7 @@ type MessageStore struct { func NewMessageStore(worker *types.Worker, dirInfo *models.DirectoryInfo, defaultSortCriteria []*types.SortCriterion, + thread bool, triggerNewEmail func(*models.MessageInfo), triggerDirectoryChange func()) *MessageStore { @@ -53,6 +57,8 @@ func NewMessageStore(worker *types.Worker, bodyCallbacks: make(map[uint32][]func(io.Reader)), headerCallbacks: make(map[uint32][]func(*types.MessageInfo)), + thread: thread, + defaultSortCriteria: defaultSortCriteria, pendingBodies: make(map[uint32]interface{}), @@ -157,9 +163,15 @@ func (store *MessageStore) Update(msg types.WorkerMessage) { switch msg := msg.(type) { case *types.DirectoryInfo: store.DirInfo = *msg.Info - store.worker.PostAction(&types.FetchDirectoryContents{ - SortCriteria: store.defaultSortCriteria, - }, nil) + if store.thread { + store.worker.PostAction(&types.FetchDirectoryThreaded{ + SortCriteria: store.defaultSortCriteria, + }, nil) + } else { + store.worker.PostAction(&types.FetchDirectoryContents{ + SortCriteria: store.defaultSortCriteria, + }, nil) + } update = true case *types.DirectoryContents: newMap := make(map[uint32]*models.MessageInfo) -- cgit v1.2.3