460 lines
12 KiB
Go
460 lines
12 KiB
Go
// gomuks - A terminal Matrix client written in Go.
|
|
// Copyright (C) 2019 Tulir Asokan
|
|
//
|
|
// This program is free software: you can redistribute it and/or modify
|
|
// it under the terms of the GNU Affero General Public License as published by
|
|
// the Free Software Foundation, either version 3 of the License, or
|
|
// (at your option) any later version.
|
|
//
|
|
// This program is distributed in the hope that it will be useful,
|
|
// but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
// GNU Affero General Public License for more details.
|
|
//
|
|
// You should have received a copy of the GNU Affero General Public License
|
|
// along with this program. If not, see <https://www.gnu.org/licenses/>.
|
|
|
|
package ui
|
|
|
|
import (
|
|
"bufio"
|
|
"fmt"
|
|
"os"
|
|
"sync/atomic"
|
|
"time"
|
|
"unicode"
|
|
|
|
sync "github.com/sasha-s/go-deadlock"
|
|
|
|
"maunium.net/go/gomuks/ui/messages"
|
|
"maunium.net/go/mauview"
|
|
"maunium.net/go/tcell"
|
|
|
|
"maunium.net/go/gomuks/config"
|
|
"maunium.net/go/gomuks/debug"
|
|
"maunium.net/go/gomuks/interface"
|
|
"maunium.net/go/gomuks/lib/notification"
|
|
"maunium.net/go/gomuks/matrix/pushrules"
|
|
"maunium.net/go/gomuks/matrix/rooms"
|
|
"maunium.net/go/gomuks/ui/widget"
|
|
)
|
|
|
|
type MainView struct {
|
|
flex *mauview.Flex
|
|
|
|
roomList *RoomList
|
|
roomView *mauview.Box
|
|
currentRoom *RoomView
|
|
rooms map[string]*RoomView
|
|
roomsLock sync.RWMutex
|
|
cmdProcessor *CommandProcessor
|
|
focused mauview.Focusable
|
|
|
|
modal mauview.Component
|
|
|
|
lastFocusTime time.Time
|
|
|
|
matrix ifc.MatrixContainer
|
|
gmx ifc.Gomuks
|
|
config *config.Config
|
|
parent *GomuksUI
|
|
}
|
|
|
|
func (ui *GomuksUI) NewMainView() mauview.Component {
|
|
mainView := &MainView{
|
|
flex: mauview.NewFlex().SetDirection(mauview.FlexColumn),
|
|
roomView: mauview.NewBox(nil).SetBorder(false),
|
|
rooms: make(map[string]*RoomView),
|
|
|
|
matrix: ui.gmx.Matrix(),
|
|
gmx: ui.gmx,
|
|
config: ui.gmx.Config(),
|
|
parent: ui,
|
|
}
|
|
mainView.roomList = NewRoomList(mainView)
|
|
mainView.cmdProcessor = NewCommandProcessor(mainView)
|
|
|
|
mainView.flex.
|
|
AddFixedComponent(mainView.roomList, 25).
|
|
AddFixedComponent(widget.NewBorder(), 1).
|
|
AddProportionalComponent(mainView.roomView, 1)
|
|
mainView.BumpFocus(nil)
|
|
|
|
ui.mainView = mainView
|
|
|
|
return mainView
|
|
}
|
|
|
|
func (view *MainView) ShowModal(modal mauview.Component) {
|
|
view.modal = modal
|
|
var ok bool
|
|
view.focused, ok = modal.(mauview.Focusable)
|
|
if !ok {
|
|
view.focused = nil
|
|
} else {
|
|
view.focused.Focus()
|
|
}
|
|
}
|
|
|
|
func (view *MainView) HideModal() {
|
|
view.modal = nil
|
|
view.focused = view.roomView
|
|
}
|
|
|
|
func (view *MainView) Draw(screen mauview.Screen) {
|
|
if view.config.Preferences.HideRoomList {
|
|
view.roomView.Draw(screen)
|
|
} else {
|
|
view.flex.Draw(screen)
|
|
}
|
|
|
|
if view.modal != nil {
|
|
view.modal.Draw(screen)
|
|
}
|
|
}
|
|
|
|
func (view *MainView) BumpFocus(roomView *RoomView) {
|
|
if roomView != nil {
|
|
view.lastFocusTime = time.Now()
|
|
view.MarkRead(roomView)
|
|
}
|
|
}
|
|
|
|
func (view *MainView) MarkRead(roomView *RoomView) {
|
|
if roomView != nil && roomView.Room.HasNewMessages() && roomView.MessageView().ScrollOffset == 0 {
|
|
msgList := roomView.MessageView().messages
|
|
if len(msgList) > 0 {
|
|
msg := msgList[len(msgList)-1]
|
|
if roomView.Room.MarkRead(msg.ID()) {
|
|
view.matrix.MarkRead(roomView.Room.ID, msg.ID())
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
func (view *MainView) InputChanged(roomView *RoomView, text string) {
|
|
if !roomView.config.Preferences.DisableTypingNotifs {
|
|
if len(text) == 0 {
|
|
go view.matrix.SendTyping(roomView.Room.ID, false)
|
|
} else if text[0] != '/' {
|
|
go view.matrix.SendTyping(roomView.Room.ID, true)
|
|
}
|
|
}
|
|
}
|
|
|
|
func findWordToTabComplete(text string) string {
|
|
output := ""
|
|
runes := []rune(text)
|
|
for i := len(runes) - 1; i >= 0; i-- {
|
|
if unicode.IsSpace(runes[i]) {
|
|
break
|
|
}
|
|
output = string(runes[i]) + output
|
|
}
|
|
return output
|
|
}
|
|
|
|
func (view *MainView) ShowBare(roomView *RoomView) {
|
|
if roomView == nil {
|
|
return
|
|
}
|
|
_, height := view.parent.app.Screen().Size()
|
|
view.parent.app.Suspend(func() {
|
|
print("\033[2J\033[0;0H")
|
|
// We don't know how much space there exactly is. Too few messages looks weird,
|
|
// and too many messages shouldn't cause any problems, so we just show too many.
|
|
height *= 2
|
|
fmt.Println(roomView.MessageView().CapturePlaintext(height))
|
|
fmt.Println("Press enter to return to normal mode.")
|
|
reader := bufio.NewReader(os.Stdin)
|
|
_, _, _ = reader.ReadRune()
|
|
print("\033[2J\033[0;0H")
|
|
})
|
|
}
|
|
|
|
func (view *MainView) OnKeyEvent(event mauview.KeyEvent) bool {
|
|
view.BumpFocus(view.currentRoom)
|
|
|
|
if view.modal != nil {
|
|
return view.modal.OnKeyEvent(event)
|
|
}
|
|
|
|
k := event.Key()
|
|
c := event.Rune()
|
|
if event.Modifiers() == tcell.ModCtrl || event.Modifiers() == tcell.ModAlt {
|
|
switch {
|
|
case k == tcell.KeyDown:
|
|
view.SwitchRoom(view.roomList.Next())
|
|
case k == tcell.KeyUp:
|
|
view.SwitchRoom(view.roomList.Previous())
|
|
case k == tcell.KeyEnter:
|
|
view.ShowModal(NewFuzzySearchModal(view, 42, 12))
|
|
case k == tcell.KeyHome:
|
|
msgView := view.currentRoom.MessageView()
|
|
msgView.AddScrollOffset(msgView.TotalHeight())
|
|
case k == tcell.KeyEnd:
|
|
msgView := view.currentRoom.MessageView()
|
|
msgView.AddScrollOffset(-msgView.TotalHeight())
|
|
case c == 'n' || k == tcell.KeyCtrlN:
|
|
return view.flex.OnKeyEvent(tcell.NewEventKey(tcell.KeyEnter, '\n', event.Modifiers()|tcell.ModShift, ""))
|
|
case c == 'a':
|
|
view.SwitchRoom(view.roomList.NextWithActivity())
|
|
case c == 'l' || k == tcell.KeyCtrlL:
|
|
view.ShowBare(view.currentRoom)
|
|
default:
|
|
goto defaultHandler
|
|
}
|
|
return true
|
|
}
|
|
defaultHandler:
|
|
if view.config.Preferences.HideRoomList {
|
|
return view.roomView.OnKeyEvent(event)
|
|
}
|
|
return view.flex.OnKeyEvent(event)
|
|
}
|
|
|
|
const WheelScrollOffsetDiff = 3
|
|
|
|
func (view *MainView) OnMouseEvent(event mauview.MouseEvent) bool {
|
|
if view.modal != nil {
|
|
return view.modal.OnMouseEvent(event)
|
|
}
|
|
if view.config.Preferences.HideRoomList {
|
|
return view.roomView.OnMouseEvent(event)
|
|
}
|
|
return view.flex.OnMouseEvent(event)
|
|
}
|
|
|
|
func (view *MainView) OnPasteEvent(event mauview.PasteEvent) bool {
|
|
if view.modal != nil {
|
|
return view.modal.OnPasteEvent(event)
|
|
} else if view.config.Preferences.HideRoomList {
|
|
return view.roomView.OnPasteEvent(event)
|
|
}
|
|
return view.flex.OnPasteEvent(event)
|
|
}
|
|
|
|
func (view *MainView) Focus() {
|
|
if view.focused != nil {
|
|
view.focused.Focus()
|
|
}
|
|
}
|
|
|
|
func (view *MainView) Blur() {
|
|
if view.focused != nil {
|
|
view.focused.Blur()
|
|
}
|
|
}
|
|
|
|
func (view *MainView) SwitchRoom(tag string, room *rooms.Room) {
|
|
view.switchRoom(tag, room, true)
|
|
}
|
|
|
|
func (view *MainView) switchRoom(tag string, room *rooms.Room, lock bool) {
|
|
if room == nil {
|
|
return
|
|
}
|
|
room.Load()
|
|
|
|
roomView, ok := view.getRoomView(room.ID, lock)
|
|
if !ok {
|
|
debug.Print("Tried to switch to room with nonexistent roomView!")
|
|
debug.Print(tag, room)
|
|
return
|
|
}
|
|
roomView.Update()
|
|
view.roomView.SetInnerComponent(roomView)
|
|
view.currentRoom = roomView
|
|
view.MarkRead(roomView)
|
|
view.roomList.SetSelected(tag, room)
|
|
view.flex.SetFocused(view.roomView)
|
|
view.focused = view.roomView
|
|
view.roomView.Focus()
|
|
view.parent.Render()
|
|
|
|
if msgView := roomView.MessageView(); len(msgView.messages) < 20 && !msgView.initialHistoryLoaded {
|
|
msgView.initialHistoryLoaded = true
|
|
go view.LoadHistory(room.ID)
|
|
}
|
|
}
|
|
|
|
func (view *MainView) addRoomPage(room *rooms.Room) *RoomView {
|
|
if _, ok := view.rooms[room.ID]; !ok {
|
|
roomView := NewRoomView(view, room).
|
|
SetInputChangedFunc(view.InputChanged)
|
|
view.rooms[room.ID] = roomView
|
|
return roomView
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (view *MainView) GetRoom(roomID string) ifc.RoomView {
|
|
room, ok := view.getRoomView(roomID, true)
|
|
if !ok {
|
|
return view.addRoom(view.matrix.GetOrCreateRoom(roomID))
|
|
}
|
|
return room
|
|
}
|
|
|
|
func (view *MainView) getRoomView(roomID string, lock bool) (room *RoomView, ok bool) {
|
|
if lock {
|
|
view.roomsLock.RLock()
|
|
room, ok = view.rooms[roomID]
|
|
view.roomsLock.RUnlock()
|
|
} else {
|
|
room, ok = view.rooms[roomID]
|
|
}
|
|
return room, ok
|
|
}
|
|
|
|
func (view *MainView) AddRoom(room *rooms.Room) {
|
|
view.addRoom(room)
|
|
}
|
|
|
|
func (view *MainView) RemoveRoom(room *rooms.Room) {
|
|
view.roomsLock.Lock()
|
|
_, ok := view.getRoomView(room.ID, false)
|
|
if !ok {
|
|
view.roomsLock.Unlock()
|
|
debug.Print("Remove aborted (not found)", room.ID, room.GetTitle())
|
|
return
|
|
}
|
|
debug.Print("Removing", room.ID, room.GetTitle())
|
|
|
|
view.roomList.Remove(room)
|
|
t, r := view.roomList.Selected()
|
|
view.switchRoom(t, r, false)
|
|
delete(view.rooms, room.ID)
|
|
view.roomsLock.Unlock()
|
|
|
|
view.parent.Render()
|
|
}
|
|
|
|
func (view *MainView) addRoom(room *rooms.Room) *RoomView {
|
|
if view.roomList.Contains(room.ID) {
|
|
debug.Print("Add aborted (room exists)", room.ID, room.GetTitle())
|
|
return nil
|
|
}
|
|
debug.Print("Adding", room.ID, room.GetTitle())
|
|
view.roomList.Add(room)
|
|
view.roomsLock.Lock()
|
|
roomView := view.addRoomPage(room)
|
|
if !view.roomList.HasSelected() {
|
|
t, r := view.roomList.First()
|
|
view.switchRoom(t, r, false)
|
|
}
|
|
view.roomsLock.Unlock()
|
|
return roomView
|
|
}
|
|
|
|
func (view *MainView) SetRooms(rooms *rooms.RoomCache) {
|
|
view.roomList.Clear()
|
|
view.roomsLock.Lock()
|
|
view.rooms = make(map[string]*RoomView)
|
|
for _, room := range rooms.Map {
|
|
if room.HasLeft {
|
|
continue
|
|
}
|
|
view.roomList.Add(room)
|
|
view.addRoomPage(room)
|
|
}
|
|
t, r := view.roomList.First()
|
|
view.switchRoom(t, r, false)
|
|
view.roomsLock.Unlock()
|
|
}
|
|
|
|
func (view *MainView) UpdateTags(room *rooms.Room) {
|
|
if !view.roomList.Contains(room.ID) {
|
|
return
|
|
}
|
|
reselect := view.roomList.selected == room
|
|
view.roomList.Remove(room)
|
|
view.roomList.Add(room)
|
|
if reselect {
|
|
view.roomList.SetSelected(room.Tags()[0].Tag, room)
|
|
}
|
|
view.parent.Render()
|
|
}
|
|
|
|
func (view *MainView) SetTyping(roomID string, users []string) {
|
|
roomView, ok := view.getRoomView(roomID, true)
|
|
if ok {
|
|
roomView.SetTyping(users)
|
|
view.parent.Render()
|
|
}
|
|
}
|
|
|
|
func sendNotification(room *rooms.Room, sender, text string, critical, sound bool) {
|
|
if room.GetTitle() != sender {
|
|
sender = fmt.Sprintf("%s (%s)", sender, room.GetTitle())
|
|
}
|
|
debug.Printf("Sending notification with body \"%s\" from %s in room ID %s (critical=%v, sound=%v)", text, sender, room.ID, critical, sound)
|
|
notification.Send(sender, text, critical, sound)
|
|
}
|
|
|
|
func (view *MainView) Bump(room *rooms.Room) {
|
|
view.roomList.Bump(room)
|
|
}
|
|
|
|
func (view *MainView) NotifyMessage(room *rooms.Room, message ifc.Message, should pushrules.PushActionArrayShould) {
|
|
view.Bump(room)
|
|
uiMsg, ok := message.(*messages.UIMessage)
|
|
if ok && uiMsg.SenderID == view.config.UserID {
|
|
return
|
|
}
|
|
// Whether or not the room where the message came is the currently shown room.
|
|
isCurrent := room == view.roomList.SelectedRoom()
|
|
// Whether or not the terminal window is focused.
|
|
recentlyFocused := time.Now().Add(-30 * time.Second).Before(view.lastFocusTime)
|
|
isFocused := time.Now().Add(-5 * time.Second).Before(view.lastFocusTime)
|
|
|
|
// Whether or not the push rules say this message should be notified about.
|
|
shouldNotify := should.Notify || !should.NotifySpecified
|
|
|
|
if !isCurrent || !isFocused {
|
|
// The message is not in the current room, show new message status in room list.
|
|
room.AddUnread(message.ID(), shouldNotify, should.Highlight)
|
|
} else {
|
|
view.matrix.MarkRead(room.ID, message.ID())
|
|
}
|
|
|
|
if shouldNotify && !recentlyFocused {
|
|
// Push rules say notify and the terminal is not focused, send desktop notification.
|
|
shouldPlaySound := should.PlaySound && should.SoundName == "default"
|
|
sendNotification(room, message.NotificationSenderName(), message.NotificationContent(), should.Highlight, shouldPlaySound)
|
|
}
|
|
|
|
// TODO this should probably happen somewhere else
|
|
// (actually it's probably completely broken now)
|
|
message.SetIsHighlight(should.Highlight)
|
|
}
|
|
|
|
func (view *MainView) LoadHistory(roomID string) {
|
|
defer debug.Recover()
|
|
roomView, ok := view.getRoomView(roomID, true)
|
|
if !ok {
|
|
return
|
|
}
|
|
msgView := roomView.MessageView()
|
|
|
|
if !atomic.CompareAndSwapInt32(&msgView.loadingMessages, 0, 1) {
|
|
// Locked
|
|
return
|
|
}
|
|
defer atomic.StoreInt32(&msgView.loadingMessages, 0)
|
|
// Update the "Loading more messages..." text
|
|
view.parent.Render()
|
|
|
|
history, err := view.matrix.GetHistory(roomView.Room, 50)
|
|
if err != nil {
|
|
roomView.AddServiceMessage("Failed to fetch history")
|
|
debug.Print("Failed to fetch history for", roomView.Room.ID, err)
|
|
view.parent.Render()
|
|
return
|
|
}
|
|
for _, evt := range history {
|
|
roomView.AddHistoryEvent(evt)
|
|
}
|
|
view.parent.Render()
|
|
}
|