aboutsummaryrefslogtreecommitdiffstats
path: root/ui/account.go
blob: 4b92e760f276d2d65b8c3505a481412b420488c6 (plain) (blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
package ui

import (
	"log"

	tb "github.com/nsf/termbox-go"

	"git.sr.ht/~sircmpwn/aerc2/config"
	"git.sr.ht/~sircmpwn/aerc2/worker"
	"git.sr.ht/~sircmpwn/aerc2/worker/types"
)

type AccountTab struct {
	Config    *config.AccountConfig
	Worker    worker.Worker
	Parent    *UIState
	logger    *log.Logger
	counter   int
	callbacks map[types.WorkerMessage]func(msg types.WorkerMessage)
}

func NewAccountTab(conf *config.AccountConfig,
	logger *log.Logger) (*AccountTab, error) {

	work, err := worker.NewWorker(conf.Source, logger)
	if err != nil {
		return nil, err
	}
	go work.Run()
	acc := &AccountTab{
		Config:    conf,
		Worker:    work,
		logger:    logger,
		callbacks: make(map[types.WorkerMessage]func(msg types.WorkerMessage)),
	}
	acc.postAction(types.Configure{Config: conf}, nil)
	acc.postAction(types.Connect{}, func(msg types.WorkerMessage) {
		if _, ok := msg.(types.Ack); ok {
			acc.logger.Println("Connected.")
		} else {
			acc.logger.Println("Connection failed.")
		}
	})
	return acc, nil
}

func (acc *AccountTab) Name() string {
	return acc.Config.Name
}

func (acc *AccountTab) SetParent(parent *UIState) {
	acc.Parent = parent
}

func (acc *AccountTab) Render(at Geometry) {
	cell := tb.Cell{
		Ch: ' ',
		Fg: tb.ColorDefault,
		Bg: tb.ColorDefault,
	}
	TFill(at, cell)
	TPrintf(&at, cell, "%s %d\n", acc.Name(), acc.counter)
	acc.counter++
	if acc.counter%10000 == 0 {
		acc.counter = 0
	}
	acc.Parent.InvalidateFrom(acc)
}

func (acc *AccountTab) GetChannel() chan types.WorkerMessage {
	return acc.Worker.GetMessages()
}

func (acc *AccountTab) postAction(msg types.WorkerMessage,
	cb func(msg types.WorkerMessage)) {

	acc.logger.Printf("-> %T\n", msg)
	acc.Worker.PostAction(msg)
	if cb != nil {
		acc.callbacks[msg] = cb
		delete(acc.callbacks, msg)
	}
}

func (acc *AccountTab) HandleMessage(msg types.WorkerMessage) {
	acc.logger.Printf("<- %T\n", msg)
	if cb, ok := acc.callbacks[msg.InResponseTo()]; ok {
		cb(msg)
	}
	switch msg.(type) {
	case types.Ack:
		// no-op
	case types.ApproveCertificate:
		// TODO: Ask the user
		acc.logger.Println("Approving certificate")
		acc.postAction(types.Ack{
			Message: types.RespondTo(msg),
		}, nil)
	default:
		acc.postAction(types.Unsupported{
			Message: types.RespondTo(msg),
		}, nil)
	}
}