5411 - mu - Soul of a tiny new machine. More thorough tests → More comprehensible and rewrite-friendly software → More resilient society.

about summary refs log tree commit diff stats

diff options

author	Kartik Agaram <vc@akkartik.com>	2019-07-17 07:31:47 -0700
committer	Kartik Agaram <vc@akkartik.com>	2019-07-17 07:31:47 -0700
commit	2bceaa4a26bcd38dd9014f6b656620773db79811 (patch)
tree	ad34b0c09333773d94fd8ecb767fecf164693c19 /build_and_test_until
parent	294a15206329d2992df073622fb5ce2c1e96001b (diff)
download	mu-2bceaa4a26bcd38dd9014f6b656620773db79811.tar.gz

5411

Fix CI.

Diffstat (limited to 'build_and_test_until')

0 files changed, 0 insertions, 0 deletions

h=0.1.1&id=ef6178a12ae5ef7070711f5cc2f2114dfd015dcd'>ef6178a ^

648ca98 ^

0911cd5 ^

648ca98 ^

24dfc47 ^

2349b7d ^

648ca98 ^

589db74 ^

0911cd5 ^

648ca98 ^

0f8b7a1 ^

ef6178a ^

0911cd5 ^

648ca98 ^

24dfc47 ^

589db74 ^

648ca98 ^

648ca98 ^

a729179 ^

648ca98 ^

b76deea ^

24dfc47 ^

b76deea ^

589db74 ^

c286d3d ^

589db74 ^

c286d3d ^

b76deea ^

0911cd5 ^

24dfc47 ^

589db74 ^

2349b7d ^

11f0a72 ^

0f8b7a1 ^

24dfc47 ^

589db74 ^

0911cd5 ^

24dfc47 ^

0911cd5 ^

24dfc47 ^

589db74 ^

0911cd5 ^

24dfc47 ^

0911cd5 ^

62946ff ^

24dfc47 ^

62946ff ^

607ece8 ^

1228448 ^

648ca98 ^

b76deea ^

648ca98 ^

c286d3d ^

589db74 ^

c286d3d ^

2349b7d ^

589db74 ^

cf66462 ^

77c76ba ^

cf66462 ^

589db74 ^

cf66462 ^

2349b7d ^

2349b7d ^

2349b7d ^

b60999c ^

24daef8 ^

b60999c ^

b389647 ^

4ec7f5d ^

b389647 ^

0f8b7a1 ^

b389647 ^

ef6178a ^

b389647 ^

0abafa6 ^

77ede6e ^

b389647 ^

312a53e ^

b389647 ^

589db74 ^

2958579 ^

b389647 ^

b60999c ^

1
2
3

6
7

12
13

14
15
16

17
18

27
28

31
32
33

36
37

54
55

74
75
76

77
78

82
83

86
87

89
90
91

93
94
95

106
107

130
131

136
137

161
162

163
164

177
178

179
180
181

182
183
184

185
186

package widgets

import (
	"fmt"
	"log"

	"github.com/gdamore/tcell"

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

type AccountView struct {
	acct         *config.AccountConfig
	conf         *config.AercConfig
	dirlist      *DirectoryList
	grid         *ui.Grid
	host         TabHost
	logger       *log.Logger
	onInvalidate func(d ui.Drawable)
	msglist      *MessageList
	msgStores    map[string]*lib.MessageStore
	worker       *types.Worker
}

func NewAccountView(conf *config.AercConfig, acct *config.AccountConfig,
	logger *log.Logger, host TabHost) *AccountView {

	grid := ui.NewGrid().Rows([]ui.GridSpec{
		{ui.SIZE_WEIGHT, 1},
	}).Columns([]ui.GridSpec{
		{ui.SIZE_EXACT, conf.Ui.SidebarWidth},
		{ui.SIZE_WEIGHT, 1},
	})

	worker, err := worker.NewWorker(acct.Source, logger)
	if err != nil {
		host.SetStatus(fmt.Sprintf("%s: %s", acct.Name, err))
		return &AccountView{
			acct:   acct,
			grid:   grid,
			host:   host,
			logger: logger,
		}
	}

	dirlist := NewDirectoryList(acct, logger, worker)
	grid.AddChild(ui.NewBordered(dirlist, ui.BORDER_RIGHT))

	msglist := NewMessageList(logger)
	grid.AddChild(msglist).At(0, 1)

	view := &AccountView{
		acct:      acct,
		conf:      conf,
		dirlist:   dirlist,
		grid:      grid,
		host:      host,
		logger:    logger,
		msglist:   msglist,
		msgStores: make(map[string]*lib.MessageStore),
		worker:    worker,
	}

	go worker.Backend.Run()
	go func() {
		for {
			msg := <-worker.Messages
			msg = worker.ProcessMessage(msg)
			view.onMessage(msg)
		}
	}()

	worker.PostAction(&types.Configure{Config: acct}, nil)
	worker.PostAction(&types.Connect{}, view.connected)
	host.SetStatus("Connecting...")

	return view
}

func (acct *AccountView) Name() string {
	return acct.acct.Name
}

func (acct *AccountView) Children() []ui.Drawable {
	return acct.grid.Children()
}

func (acct *AccountView) OnInvalidate(onInvalidate func(d ui.Drawable)) {
	acct.grid.OnInvalidate(func(_ ui.Drawable) {
		onInvalidate(acct)
	})
}

func (acct *AccountView) Invalidate() {
	acct.grid.Invalidate()
}

func (acct *AccountView) Draw(ctx *ui.Context) {
	acct.grid.Draw(ctx)
}

func (acct *AccountView) Focus(focus bool) {
	// TODO: Unfocus children I guess
}

func (acct *AccountView) connected(msg types.WorkerMessage) {
	switch msg := msg.(type) {
	case *types.Done:
		acct.host.SetStatus("Listing mailboxes...")
		acct.logger.Println("Listing mailboxes...")
		acct.dirlist.UpdateList(func(dirs []string) {
			var dir string
			for _, _dir := range dirs {
				if _dir == acct.acct.Default {
					dir = _dir
					break
				}
			}
			if dir == "" {
				dir = dirs[0]
			}
			acct.dirlist.Select(dir)
			acct.logger.Println("Connected.")
			acct.host.SetStatus("Connected.")
		})
	case *types.CertificateApprovalRequest:
		// TODO: Ask the user
		acct.worker.PostAction(&types.ApproveCertificate{
			Message:  types.RespondTo(msg),
			Approved: true,
		}, acct.connected)
	}
}

func (acct *AccountView) Directories() *DirectoryList {
	return acct.dirlist
}

func (acct *AccountView) Messages() *MessageList {
	return acct.msglist
}

func (acct *AccountView) onMessage(msg types.WorkerMessage) {
	switch msg := msg.(type) {
	case *types.Done:
		switch msg.InResponseTo().(type) {
		case *types.OpenDirectory:
			if store, ok := acct.msgStores[acct.dirlist.selected]; ok {
				// If we've opened this dir before, we can re-render it from
				// memory while we wait for the update and the UI feels
				// snappier. If not, we'll unset the store and show the spinner
				// while we download the UID list.
				acct.msglist.SetStore(store)
			} else {
				acct.msglist.SetStore(nil)
			}
			acct.worker.PostAction(&types.FetchDirectoryContents{},
				func(msg types.WorkerMessage) {
					store := acct.msgStores[acct.dirlist.selected]
					acct.msglist.SetStore(store)
				})
		}
	case *types.DirectoryInfo:
		if store, ok := acct.msgStores[msg.Name]; ok {
			store.Update(msg)
		} else {
			acct.msgStores[msg.Name] = lib.NewMessageStore(acct.worker, msg)
		}
	case *types.DirectoryContents:
		store := acct.msgStores[acct.dirlist.selected]
		store.Update(msg)
	case *types.FullMessage:
		store := acct.msgStores[acct.dirlist.selected]
		store.Update(msg)
	case *types.MessageInfo:
		store := acct.msgStores[acct.dirlist.selected]
		store.Update(msg)
	case *types.MessagesDeleted:
		store := acct.msgStores[acct.dirlist.selected]
		store.Update(msg)
	case *types.Error:
		acct.logger.Printf("%v", msg.Error)
		acct.host.SetStatus(fmt.Sprintf("%v", msg.Error)).
			Color(tcell.ColorDefault, tcell.ColorRed)
	}
}


context:
space:
mode: