aboutsummaryrefslogtreecommitdiff
path: root/worker
diff options
context:
space:
mode:
Diffstat (limited to 'worker')
-rw-r--r--worker/imap/worker.go58
-rw-r--r--worker/types/messages.go55
-rw-r--r--worker/worker.go18
3 files changed, 131 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
+ }
+ }
+}
diff --git a/worker/types/messages.go b/worker/types/messages.go
new file mode 100644
index 0000000..845bb86
--- /dev/null
+++ b/worker/types/messages.go
@@ -0,0 +1,55 @@
+package types
+
+import (
+ "git.sr.ht/~sircmpwn/aerc2/config"
+)
+
+type WorkerMessage interface {
+ InResponseTo() WorkerMessage
+}
+
+type Message struct {
+ inResponseTo WorkerMessage
+}
+
+// Meta-messages
+type Ack struct {
+ Message
+}
+
+type Error struct {
+ Message
+ Error error
+}
+
+type Unsupported struct {
+ Message
+}
+
+// Commands
+type Ping struct {
+ Message
+}
+
+type Configure struct {
+ Message
+ Config config.AccountConfig
+}
+
+type Connect struct {
+ Message
+}
+
+type Disconnect struct {
+ Message
+}
+
+func RespondTo(msg WorkerMessage) Message {
+ return Message{
+ inResponseTo: msg,
+ }
+}
+
+func (m Message) InResponseTo() WorkerMessage {
+ return m.inResponseTo
+}
diff --git a/worker/worker.go b/worker/worker.go
new file mode 100644
index 0000000..1f9f04c
--- /dev/null
+++ b/worker/worker.go
@@ -0,0 +1,18 @@
+package worker
+
+import (
+ "git.sr.ht/~sircmpwn/aerc2/worker/imap"
+ "git.sr.ht/~sircmpwn/aerc2/worker/types"
+)
+
+type Worker interface {
+ GetMessage() types.WorkerMessage
+ PostAction(types.WorkerMessage)
+ Run()
+}
+
+// Guesses the appropriate worker type based on the given source string
+func NewWorker(source string) Worker {
+ // TODO: Do this properly
+ return imap.NewIMAPWorker()
+}