diff options
author | Drew DeVault <sir@cmpwn.com> | 2018-01-09 20:39:00 -0500 |
---|---|---|
committer | Drew DeVault <sir@cmpwn.com> | 2018-01-09 20:39:00 -0500 |
commit | 6394e386c2a88c3b376cd422a7b7ce5ae7534984 (patch) | |
tree | 2d78f622096e439cf5d91a090999f5c522796c42 /worker/imap | |
parent | 7d0edcc9e7ecdedb8cabafac1167581d7205596e (diff) |
Initial pass on worker/UI message passing
Diffstat (limited to 'worker/imap')
-rw-r--r-- | worker/imap/worker.go | 58 |
1 files changed, 58 insertions, 0 deletions
diff --git a/worker/imap/worker.go b/worker/imap/worker.go new file mode 100644 index 0000000..a095e60 --- /dev/null +++ b/worker/imap/worker.go @@ -0,0 +1,58 @@ +package imap + +import ( + "git.sr.ht/~sircmpwn/aerc2/worker/types" + + "fmt" +) + +type IMAPWorker struct { + messages chan types.WorkerMessage + actions chan types.WorkerMessage +} + +func NewIMAPWorker() *IMAPWorker { + return &IMAPWorker{ + messages: make(chan types.WorkerMessage, 50), + actions: make(chan types.WorkerMessage, 50), + } +} + +func (w *IMAPWorker) GetMessage() types.WorkerMessage { + select { + case msg := <-w.messages: + return msg + default: + return nil + } +} + +func (w *IMAPWorker) PostAction(msg types.WorkerMessage) { + w.actions <- msg +} + +func (w *IMAPWorker) handleMessage(_msg types.WorkerMessage) { + switch msg := _msg.(type) { + case types.Ping: + w.messages <- &types.Ack{ + Message: types.RespondTo(msg), + } + default: + w.messages <- &types.Unsupported{ + Message: types.RespondTo(_msg), + } + } +} + +func (w *IMAPWorker) Run() { + // TODO: IMAP shit + for { + select { + case msg := <-w.actions: + fmt.Printf("<= %T: %+v\n", msg, msg) + w.handleMessage(msg) + default: + // no-op + } + } +} |