Compare commits
9 Commits
437997872a
...
58e1b84fea
Author | SHA1 | Date | |
---|---|---|---|
58e1b84fea | |||
a6522dbcd0 | |||
97cd047861 | |||
ed784bb1cf | |||
c1792f27ff | |||
0ad698a942 | |||
0d66a49997 | |||
008fdc0d37 | |||
eec9eb41e9 |
@ -2,6 +2,7 @@ package util
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
|
"encoding/json"
|
||||||
"fmt"
|
"fmt"
|
||||||
"os"
|
"os"
|
||||||
"strings"
|
"strings"
|
||||||
@ -149,32 +150,40 @@ func FormatForExternalPrompt(messages []model.Message, system bool) string {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func GenerateTitle(ctx *lmcli.Context, messages []model.Message) (string, error) {
|
func GenerateTitle(ctx *lmcli.Context, messages []model.Message) (string, error) {
|
||||||
const prompt = `Above is an excerpt from a conversation between a user and AI assistant. Please reply with a short title (no more than 8 words) that reflects the topic of the conversation, read from the user's perspective.
|
const systemPrompt = `You will be shown a conversation between a user and an AI assistant. Your task is to generate a short title (8 words or less) for the provided conversation that reflects the conversation's topic. Your response is expected to be in JSON in the format shown below.
|
||||||
|
|
||||||
Example conversation:
|
Example conversation:
|
||||||
|
|
||||||
"""
|
[{"role": "user", "content": "Can you help me with my math homework?"},{"role": "assistant", "content": "Sure, what topic are you struggling with?"}]
|
||||||
User:
|
|
||||||
|
|
||||||
Hello!
|
|
||||||
|
|
||||||
Assistant:
|
|
||||||
|
|
||||||
Hello! How may I assist you?
|
|
||||||
"""
|
|
||||||
|
|
||||||
Example response:
|
Example response:
|
||||||
|
|
||||||
"""
|
{"title": "Help with math homework"}
|
||||||
Title: A brief introduction
|
|
||||||
"""
|
|
||||||
`
|
`
|
||||||
conversation := FormatForExternalPrompt(messages, false)
|
type msg struct {
|
||||||
|
Role string
|
||||||
|
Content string
|
||||||
|
}
|
||||||
|
|
||||||
|
var msgs []msg
|
||||||
|
for _, m := range messages {
|
||||||
|
msgs = append(msgs, msg{string(m.Role), m.Content})
|
||||||
|
}
|
||||||
|
|
||||||
|
// Serialize the conversation to JSON
|
||||||
|
conversation, err := json.Marshal(msgs)
|
||||||
|
if err != nil {
|
||||||
|
return "", err
|
||||||
|
}
|
||||||
|
|
||||||
generateRequest := []model.Message{
|
generateRequest := []model.Message{
|
||||||
|
{
|
||||||
|
Role: model.MessageRoleSystem,
|
||||||
|
Content: systemPrompt,
|
||||||
|
},
|
||||||
{
|
{
|
||||||
Role: model.MessageRoleUser,
|
Role: model.MessageRoleUser,
|
||||||
Content: fmt.Sprintf("\"\"\"\n%s\n\"\"\"\n\n%s", conversation, prompt),
|
Content: string(conversation),
|
||||||
},
|
},
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -193,11 +202,16 @@ Title: A brief introduction
|
|||||||
return "", err
|
return "", err
|
||||||
}
|
}
|
||||||
|
|
||||||
response = strings.TrimPrefix(response, "Title: ")
|
// Parse the JSON response
|
||||||
response = strings.Trim(response, "\"")
|
var jsonResponse struct {
|
||||||
response = strings.TrimSpace(response)
|
Title string `json:"title"`
|
||||||
|
}
|
||||||
|
err = json.Unmarshal([]byte(response), &jsonResponse)
|
||||||
|
if err != nil {
|
||||||
|
return "", err
|
||||||
|
}
|
||||||
|
|
||||||
return response, nil
|
return jsonResponse.Title, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// ShowWaitAnimation prints an animated ellipses to stdout until something is
|
// ShowWaitAnimation prints an animated ellipses to stdout until something is
|
||||||
|
@ -33,7 +33,7 @@ func convertTools(tools []model.Tool) []Tool {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
geminiTools[i] = Tool{
|
geminiTools[i] = Tool{
|
||||||
FunctionDeclarations: []FunctionDeclaration{
|
FunctionDeclarations: []FunctionDeclaration{
|
||||||
{
|
{
|
||||||
Name: tool.Name,
|
Name: tool.Name,
|
||||||
|
52
pkg/tui/shared/shared.go
Normal file
52
pkg/tui/shared/shared.go
Normal file
@ -0,0 +1,52 @@
|
|||||||
|
package shared
|
||||||
|
|
||||||
|
import (
|
||||||
|
"git.mlow.ca/mlow/lmcli/pkg/lmcli"
|
||||||
|
tea "github.com/charmbracelet/bubbletea"
|
||||||
|
)
|
||||||
|
|
||||||
|
type Values struct {
|
||||||
|
ConvShortname string
|
||||||
|
}
|
||||||
|
|
||||||
|
type State struct {
|
||||||
|
Ctx *lmcli.Context
|
||||||
|
Values *Values
|
||||||
|
Width int
|
||||||
|
Height int
|
||||||
|
Err error
|
||||||
|
}
|
||||||
|
|
||||||
|
// a convenience struct for holding rendered content for indiviudal UI
|
||||||
|
// elements
|
||||||
|
type Sections struct {
|
||||||
|
Header string
|
||||||
|
Content string
|
||||||
|
Error string
|
||||||
|
Input string
|
||||||
|
Footer string
|
||||||
|
}
|
||||||
|
|
||||||
|
type (
|
||||||
|
// send to change the current state
|
||||||
|
MsgViewChange View
|
||||||
|
// sent to a state when it is entered
|
||||||
|
MsgViewEnter struct{}
|
||||||
|
// sent when an error occurs
|
||||||
|
MsgError error
|
||||||
|
)
|
||||||
|
|
||||||
|
func WrapError(err error) tea.Cmd {
|
||||||
|
return func() tea.Msg {
|
||||||
|
return MsgError(err)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
type View int
|
||||||
|
|
||||||
|
const (
|
||||||
|
StateChat View = iota
|
||||||
|
StateConversations
|
||||||
|
//StateSettings
|
||||||
|
//StateHelp
|
||||||
|
)
|
8
pkg/tui/styles/styles.go
Normal file
8
pkg/tui/styles/styles.go
Normal file
@ -0,0 +1,8 @@
|
|||||||
|
package styles
|
||||||
|
|
||||||
|
import "github.com/charmbracelet/lipgloss"
|
||||||
|
|
||||||
|
var Header = lipgloss.NewStyle().
|
||||||
|
PaddingLeft(1).
|
||||||
|
PaddingRight(1).
|
||||||
|
Background(lipgloss.Color("0"))
|
175
pkg/tui/tui.go
175
pkg/tui/tui.go
@ -10,99 +10,60 @@ import (
|
|||||||
"fmt"
|
"fmt"
|
||||||
|
|
||||||
"git.mlow.ca/mlow/lmcli/pkg/lmcli"
|
"git.mlow.ca/mlow/lmcli/pkg/lmcli"
|
||||||
|
"git.mlow.ca/mlow/lmcli/pkg/tui/shared"
|
||||||
|
"git.mlow.ca/mlow/lmcli/pkg/tui/views/chat"
|
||||||
|
"git.mlow.ca/mlow/lmcli/pkg/tui/views/conversations"
|
||||||
tea "github.com/charmbracelet/bubbletea"
|
tea "github.com/charmbracelet/bubbletea"
|
||||||
"github.com/charmbracelet/lipgloss"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
type state int
|
// Application model
|
||||||
|
type Model struct {
|
||||||
|
shared.State
|
||||||
|
|
||||||
const (
|
state shared.View
|
||||||
stateChat = iota
|
chat chat.Model
|
||||||
stateConversations
|
conversations conversations.Model
|
||||||
//stateModelSelect // stateOptions?
|
|
||||||
//stateHelp
|
|
||||||
)
|
|
||||||
|
|
||||||
// this struct holds the final rendered content of various UI components, and
|
|
||||||
// gets populated in the application's Update() method. View() simply composes
|
|
||||||
// these elements into the final output
|
|
||||||
type views struct {
|
|
||||||
header string
|
|
||||||
content string
|
|
||||||
error string
|
|
||||||
input string
|
|
||||||
footer string
|
|
||||||
}
|
}
|
||||||
|
|
||||||
type (
|
func initialModel(ctx *lmcli.Context, values shared.Values) Model {
|
||||||
// send to change the current state
|
m := Model{
|
||||||
msgStateChange state
|
State: shared.State{
|
||||||
// sent to a state when it is entered
|
Ctx: ctx,
|
||||||
msgStateEnter struct{}
|
Values: &values,
|
||||||
// sent when an error occurs
|
|
||||||
msgError error
|
|
||||||
)
|
|
||||||
|
|
||||||
type Options struct {
|
|
||||||
convShortname string
|
|
||||||
}
|
|
||||||
|
|
||||||
type basemodel struct {
|
|
||||||
opts *Options
|
|
||||||
ctx *lmcli.Context
|
|
||||||
views *views
|
|
||||||
err error
|
|
||||||
width int
|
|
||||||
height int
|
|
||||||
}
|
|
||||||
|
|
||||||
type model struct {
|
|
||||||
basemodel
|
|
||||||
|
|
||||||
state state
|
|
||||||
chat chatModel
|
|
||||||
conversations conversationsModel
|
|
||||||
}
|
|
||||||
|
|
||||||
func initialModel(ctx *lmcli.Context, opts Options) model {
|
|
||||||
m := model{
|
|
||||||
basemodel: basemodel{
|
|
||||||
opts: &opts,
|
|
||||||
ctx: ctx,
|
|
||||||
views: &views{},
|
|
||||||
},
|
},
|
||||||
}
|
}
|
||||||
m.state = stateChat
|
|
||||||
m.chat = newChatModel(&m)
|
m.state = shared.StateChat
|
||||||
m.conversations = newConversationsModel(&m)
|
m.chat = chat.Chat(m.State)
|
||||||
|
m.conversations = conversations.Conversations(m.State)
|
||||||
return m
|
return m
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m model) Init() tea.Cmd {
|
func (m Model) Init() tea.Cmd {
|
||||||
return tea.Batch(
|
return tea.Batch(
|
||||||
m.conversations.Init(),
|
m.conversations.Init(),
|
||||||
m.chat.Init(),
|
m.chat.Init(),
|
||||||
func() tea.Msg {
|
func() tea.Msg {
|
||||||
return msgStateChange(m.state)
|
return shared.MsgViewChange(m.state)
|
||||||
},
|
},
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m *model) handleGlobalInput(msg tea.KeyMsg) (bool, tea.Cmd) {
|
func (m *Model) handleGlobalInput(msg tea.KeyMsg) (bool, tea.Cmd) {
|
||||||
// delegate input to the active child state first, only handling it at the
|
// delegate input to the active child state first, only handling it at the
|
||||||
// global level if the child state does not
|
// global level if the child state does not
|
||||||
var cmds []tea.Cmd
|
var cmds []tea.Cmd
|
||||||
switch m.state {
|
switch m.state {
|
||||||
case stateChat:
|
case shared.StateChat:
|
||||||
handled, cmd := m.chat.handleInput(msg)
|
handled, cmd := m.chat.HandleInput(msg)
|
||||||
cmds = append(cmds, cmd)
|
cmds = append(cmds, cmd)
|
||||||
if handled {
|
if handled {
|
||||||
m.chat, cmd = m.chat.Update(nil)
|
m.chat, cmd = m.chat.Update(nil)
|
||||||
cmds = append(cmds, cmd)
|
cmds = append(cmds, cmd)
|
||||||
return true, tea.Batch(cmds...)
|
return true, tea.Batch(cmds...)
|
||||||
}
|
}
|
||||||
case stateConversations:
|
case shared.StateConversations:
|
||||||
handled, cmd := m.conversations.handleInput(msg)
|
handled, cmd := m.conversations.HandleInput(msg)
|
||||||
cmds = append(cmds, cmd)
|
cmds = append(cmds, cmd)
|
||||||
if handled {
|
if handled {
|
||||||
m.conversations, cmd = m.conversations.Update(nil)
|
m.conversations, cmd = m.conversations.Update(nil)
|
||||||
@ -117,7 +78,7 @@ func (m *model) handleGlobalInput(msg tea.KeyMsg) (bool, tea.Cmd) {
|
|||||||
return false, nil
|
return false, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m model) Update(msg tea.Msg) (tea.Model, tea.Cmd) {
|
func (m Model) Update(msg tea.Msg) (tea.Model, tea.Cmd) {
|
||||||
var cmds []tea.Cmd
|
var cmds []tea.Cmd
|
||||||
|
|
||||||
switch msg := msg.(type) {
|
switch msg := msg.(type) {
|
||||||
@ -126,32 +87,24 @@ func (m model) Update(msg tea.Msg) (tea.Model, tea.Cmd) {
|
|||||||
if handled {
|
if handled {
|
||||||
return m, cmd
|
return m, cmd
|
||||||
}
|
}
|
||||||
case msgStateChange:
|
case shared.MsgViewChange:
|
||||||
m.state = state(msg)
|
m.state = shared.View(msg)
|
||||||
switch m.state {
|
switch m.state {
|
||||||
case stateChat:
|
case shared.StateChat:
|
||||||
m.chat.handleResize(m.width, m.height)
|
m.chat.HandleResize(m.Width, m.Height)
|
||||||
case stateConversations:
|
case shared.StateConversations:
|
||||||
m.conversations.handleResize(m.width, m.height)
|
m.conversations.HandleResize(m.Width, m.Height)
|
||||||
}
|
}
|
||||||
return m, func() tea.Msg { return msgStateEnter(struct{}{}) }
|
return m, func() tea.Msg { return shared.MsgViewEnter(struct{}{}) }
|
||||||
case msgConversationSelected:
|
|
||||||
// passed up through conversation list model
|
|
||||||
m.opts.convShortname = msg.ShortName.String
|
|
||||||
cmds = append(cmds, func() tea.Msg {
|
|
||||||
return msgStateChange(stateChat)
|
|
||||||
})
|
|
||||||
case tea.WindowSizeMsg:
|
case tea.WindowSizeMsg:
|
||||||
m.width, m.height = msg.Width, msg.Height
|
m.Width, m.Height = msg.Width, msg.Height
|
||||||
case msgError:
|
|
||||||
m.err = msg
|
|
||||||
}
|
}
|
||||||
|
|
||||||
var cmd tea.Cmd
|
var cmd tea.Cmd
|
||||||
switch m.state {
|
switch m.state {
|
||||||
case stateConversations:
|
case shared.StateConversations:
|
||||||
m.conversations, cmd = m.conversations.Update(msg)
|
m.conversations, cmd = m.conversations.Update(msg)
|
||||||
case stateChat:
|
case shared.StateChat:
|
||||||
m.chat, cmd = m.chat.Update(msg)
|
m.chat, cmd = m.chat.Update(msg)
|
||||||
}
|
}
|
||||||
if cmd != nil {
|
if cmd != nil {
|
||||||
@ -161,60 +114,18 @@ func (m model) Update(msg tea.Msg) (tea.Model, tea.Cmd) {
|
|||||||
return m, tea.Batch(cmds...)
|
return m, tea.Batch(cmds...)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m model) View() string {
|
func (m Model) View() string {
|
||||||
if m.width == 0 {
|
|
||||||
// this is the case upon initial startup, but it's also a safe bet that
|
|
||||||
// we can just skip rendering if the terminal is really 0 width...
|
|
||||||
// without this, the m.*View() functions may crash
|
|
||||||
return ""
|
|
||||||
}
|
|
||||||
sections := make([]string, 0, 6)
|
|
||||||
|
|
||||||
if m.views.header != "" {
|
|
||||||
sections = append(sections, m.views.header)
|
|
||||||
}
|
|
||||||
|
|
||||||
switch m.state {
|
switch m.state {
|
||||||
case stateConversations:
|
case shared.StateConversations:
|
||||||
sections = append(sections, m.views.content)
|
return m.conversations.View()
|
||||||
if m.views.error != "" {
|
case shared.StateChat:
|
||||||
sections = append(sections, m.views.error)
|
return m.chat.View()
|
||||||
}
|
|
||||||
case stateChat:
|
|
||||||
sections = append(sections, m.views.content)
|
|
||||||
if m.views.error != "" {
|
|
||||||
sections = append(sections, m.views.error)
|
|
||||||
}
|
|
||||||
sections = append(sections, m.views.input)
|
|
||||||
}
|
|
||||||
|
|
||||||
if m.views.footer != "" {
|
|
||||||
sections = append(sections, m.views.footer)
|
|
||||||
}
|
|
||||||
|
|
||||||
return lipgloss.JoinVertical(lipgloss.Left, sections...)
|
|
||||||
}
|
|
||||||
|
|
||||||
func errorBanner(err error, width int) string {
|
|
||||||
if err == nil {
|
|
||||||
return ""
|
|
||||||
}
|
|
||||||
return lipgloss.NewStyle().
|
|
||||||
Width(width).
|
|
||||||
AlignHorizontal(lipgloss.Center).
|
|
||||||
Bold(true).
|
|
||||||
Foreground(lipgloss.Color("1")).
|
|
||||||
Render(fmt.Sprintf("%s", err))
|
|
||||||
}
|
|
||||||
|
|
||||||
func wrapError(err error) tea.Cmd {
|
|
||||||
return func() tea.Msg {
|
|
||||||
return msgError(err)
|
|
||||||
}
|
}
|
||||||
|
return ""
|
||||||
}
|
}
|
||||||
|
|
||||||
func Launch(ctx *lmcli.Context, convShortname string) error {
|
func Launch(ctx *lmcli.Context, convShortname string) error {
|
||||||
p := tea.NewProgram(initialModel(ctx, Options{convShortname}), tea.WithAltScreen())
|
p := tea.NewProgram(initialModel(ctx, shared.Values{ConvShortname: convShortname}), tea.WithAltScreen())
|
||||||
if _, err := p.Run(); err != nil {
|
if _, err := p.Run(); err != nil {
|
||||||
return fmt.Errorf("Error running program: %v", err)
|
return fmt.Errorf("Error running program: %v", err)
|
||||||
}
|
}
|
||||||
|
@ -1,26 +1,28 @@
|
|||||||
package tui
|
package util
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"fmt"
|
||||||
"os"
|
"os"
|
||||||
"os/exec"
|
"os/exec"
|
||||||
"strings"
|
"strings"
|
||||||
|
|
||||||
"github.com/charmbracelet/bubbles/viewport"
|
"github.com/charmbracelet/bubbles/viewport"
|
||||||
tea "github.com/charmbracelet/bubbletea"
|
tea "github.com/charmbracelet/bubbletea"
|
||||||
|
"github.com/charmbracelet/lipgloss"
|
||||||
"github.com/muesli/reflow/ansi"
|
"github.com/muesli/reflow/ansi"
|
||||||
)
|
)
|
||||||
|
|
||||||
type msgTempfileEditorClosed string
|
type MsgTempfileEditorClosed string
|
||||||
|
|
||||||
// openTempfileEditor opens an $EDITOR on a new temporary file with the given
|
// OpenTempfileEditor opens $EDITOR on a temporary file with the given content.
|
||||||
// content. Upon closing, the contents of the file are read back returned
|
// Upon closing, the contents of the file are read and returned wrapped in a
|
||||||
// wrapped in a msgTempfileEditorClosed returned by the tea.Cmd
|
// MsgTempfileEditorClosed
|
||||||
func openTempfileEditor(pattern string, content string, placeholder string) tea.Cmd {
|
func OpenTempfileEditor(pattern string, content string, placeholder string) tea.Cmd {
|
||||||
msgFile, _ := os.CreateTemp("/tmp", pattern)
|
msgFile, _ := os.CreateTemp("/tmp", pattern)
|
||||||
|
|
||||||
err := os.WriteFile(msgFile.Name(), []byte(placeholder+content), os.ModeAppend)
|
err := os.WriteFile(msgFile.Name(), []byte(placeholder+content), os.ModeAppend)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return wrapError(err)
|
return func() tea.Msg { return err }
|
||||||
}
|
}
|
||||||
|
|
||||||
editor := os.Getenv("EDITOR")
|
editor := os.Getenv("EDITOR")
|
||||||
@ -32,7 +34,7 @@ func openTempfileEditor(pattern string, content string, placeholder string) tea.
|
|||||||
return tea.ExecProcess(c, func(err error) tea.Msg {
|
return tea.ExecProcess(c, func(err error) tea.Msg {
|
||||||
bytes, err := os.ReadFile(msgFile.Name())
|
bytes, err := os.ReadFile(msgFile.Name())
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return msgError(err)
|
return err
|
||||||
}
|
}
|
||||||
os.Remove(msgFile.Name())
|
os.Remove(msgFile.Name())
|
||||||
fileContents := string(bytes)
|
fileContents := string(bytes)
|
||||||
@ -40,12 +42,12 @@ func openTempfileEditor(pattern string, content string, placeholder string) tea.
|
|||||||
fileContents = fileContents[len(placeholder):]
|
fileContents = fileContents[len(placeholder):]
|
||||||
}
|
}
|
||||||
stripped := strings.Trim(fileContents, "\n \t")
|
stripped := strings.Trim(fileContents, "\n \t")
|
||||||
return msgTempfileEditorClosed(stripped)
|
return MsgTempfileEditorClosed(stripped)
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
// similar to lipgloss.Height, except returns 0 on empty strings
|
// similar to lipgloss.Height, except returns 0 instead of 1 on empty strings
|
||||||
func height(str string) int {
|
func Height(str string) int {
|
||||||
if str == "" {
|
if str == "" {
|
||||||
return 0
|
return 0
|
||||||
}
|
}
|
||||||
@ -54,7 +56,7 @@ func height(str string) int {
|
|||||||
|
|
||||||
// truncate a string until its rendered cell width + the provided tail fits
|
// truncate a string until its rendered cell width + the provided tail fits
|
||||||
// within the given width
|
// within the given width
|
||||||
func truncateToCellWidth(str string, width int, tail string) string {
|
func TruncateToCellWidth(str string, width int, tail string) string {
|
||||||
cellWidth := ansi.PrintableRuneWidth(str)
|
cellWidth := ansi.PrintableRuneWidth(str)
|
||||||
if cellWidth <= width {
|
if cellWidth <= width {
|
||||||
return str
|
return str
|
||||||
@ -70,10 +72,7 @@ func truncateToCellWidth(str string, width int, tail string) string {
|
|||||||
return str + tail
|
return str + tail
|
||||||
}
|
}
|
||||||
|
|
||||||
// fraction is the fraction of the total screen height into view the offset
|
func ScrollIntoView(vp *viewport.Model, offset int, edge int) {
|
||||||
// should be scrolled into view. 0.5 = items will be snapped to middle of
|
|
||||||
// view
|
|
||||||
func scrollIntoView(vp *viewport.Model, offset int, edge int) {
|
|
||||||
currentOffset := vp.YOffset
|
currentOffset := vp.YOffset
|
||||||
if offset >= currentOffset && offset < currentOffset+vp.Height {
|
if offset >= currentOffset && offset < currentOffset+vp.Height {
|
||||||
return
|
return
|
||||||
@ -87,3 +86,16 @@ func scrollIntoView(vp *viewport.Model, offset int, edge int) {
|
|||||||
vp.SetYOffset(currentOffset - distance - edge)
|
vp.SetYOffset(currentOffset - distance - edge)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func ErrorBanner(err error, width int) string {
|
||||||
|
if err == nil {
|
||||||
|
return ""
|
||||||
|
}
|
||||||
|
return lipgloss.NewStyle().
|
||||||
|
Width(width).
|
||||||
|
AlignHorizontal(lipgloss.Center).
|
||||||
|
Bold(true).
|
||||||
|
Foreground(lipgloss.Color("1")).
|
||||||
|
Render(fmt.Sprintf("%s", err))
|
||||||
|
}
|
||||||
|
|
@ -1,4 +1,4 @@
|
|||||||
package tui
|
package chat
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
@ -9,6 +9,9 @@ import (
|
|||||||
|
|
||||||
cmdutil "git.mlow.ca/mlow/lmcli/pkg/cmd/util"
|
cmdutil "git.mlow.ca/mlow/lmcli/pkg/cmd/util"
|
||||||
models "git.mlow.ca/mlow/lmcli/pkg/lmcli/model"
|
models "git.mlow.ca/mlow/lmcli/pkg/lmcli/model"
|
||||||
|
"git.mlow.ca/mlow/lmcli/pkg/tui/shared"
|
||||||
|
"git.mlow.ca/mlow/lmcli/pkg/tui/styles"
|
||||||
|
tuiutil "git.mlow.ca/mlow/lmcli/pkg/tui/util"
|
||||||
"github.com/charmbracelet/bubbles/cursor"
|
"github.com/charmbracelet/bubbles/cursor"
|
||||||
"github.com/charmbracelet/bubbles/spinner"
|
"github.com/charmbracelet/bubbles/spinner"
|
||||||
"github.com/charmbracelet/bubbles/textarea"
|
"github.com/charmbracelet/bubbles/textarea"
|
||||||
@ -40,7 +43,7 @@ type (
|
|||||||
msgResponseChunk string
|
msgResponseChunk string
|
||||||
// sent when response is finished being received
|
// sent when response is finished being received
|
||||||
msgResponseEnd string
|
msgResponseEnd string
|
||||||
// a special case of msgError that stops the response waiting animation
|
// a special case of common.MsgError that stops the response waiting animation
|
||||||
msgResponseError error
|
msgResponseError error
|
||||||
// sent on each completed reply
|
// sent on each completed reply
|
||||||
msgAssistantReply models.Message
|
msgAssistantReply models.Message
|
||||||
@ -52,13 +55,13 @@ type (
|
|||||||
msgMessagesLoaded []models.Message
|
msgMessagesLoaded []models.Message
|
||||||
)
|
)
|
||||||
|
|
||||||
type chatModel struct {
|
type Model struct {
|
||||||
basemodel
|
shared.State
|
||||||
width int
|
shared.Sections
|
||||||
height int
|
|
||||||
|
|
||||||
// app state
|
// app state
|
||||||
conversation *models.Conversation
|
conversation *models.Conversation
|
||||||
|
rootMessages []models.Message
|
||||||
messages []models.Message
|
messages []models.Message
|
||||||
selectedMessage int
|
selectedMessage int
|
||||||
waitingForReply bool
|
waitingForReply bool
|
||||||
@ -68,10 +71,6 @@ type chatModel struct {
|
|||||||
replyChunkChan chan string
|
replyChunkChan chan string
|
||||||
persistence bool // whether we will save new messages in the conversation
|
persistence bool // whether we will save new messages in the conversation
|
||||||
|
|
||||||
tokenCount uint
|
|
||||||
startTime time.Time
|
|
||||||
elapsed time.Duration
|
|
||||||
|
|
||||||
// ui state
|
// ui state
|
||||||
focus focusState
|
focus focusState
|
||||||
wrap bool // whether message content is wrapped to viewport width
|
wrap bool // whether message content is wrapped to viewport width
|
||||||
@ -80,6 +79,10 @@ type chatModel struct {
|
|||||||
messageCache []string // cache of syntax highlighted and wrapped message content
|
messageCache []string // cache of syntax highlighted and wrapped message content
|
||||||
messageOffsets []int
|
messageOffsets []int
|
||||||
|
|
||||||
|
tokenCount uint
|
||||||
|
startTime time.Time
|
||||||
|
elapsed time.Duration
|
||||||
|
|
||||||
// ui elements
|
// ui elements
|
||||||
content viewport.Model
|
content viewport.Model
|
||||||
input textarea.Model
|
input textarea.Model
|
||||||
@ -87,13 +90,9 @@ type chatModel struct {
|
|||||||
replyCursor cursor.Model // cursor to indicate incoming response
|
replyCursor cursor.Model // cursor to indicate incoming response
|
||||||
}
|
}
|
||||||
|
|
||||||
func newChatModel(tui *model) chatModel {
|
func Chat(state shared.State) Model {
|
||||||
m := chatModel{
|
m := Model{
|
||||||
basemodel: basemodel{
|
State: state,
|
||||||
opts: tui.opts,
|
|
||||||
ctx: tui.ctx,
|
|
||||||
views: tui.views,
|
|
||||||
},
|
|
||||||
|
|
||||||
conversation: &models.Conversation{},
|
conversation: &models.Conversation{},
|
||||||
persistence: true,
|
persistence: true,
|
||||||
@ -126,7 +125,7 @@ func newChatModel(tui *model) chatModel {
|
|||||||
m.replyCursor.SetChar(" ")
|
m.replyCursor.SetChar(" ")
|
||||||
m.replyCursor.Focus()
|
m.replyCursor.Focus()
|
||||||
|
|
||||||
system := tui.ctx.GetSystemPrompt()
|
system := state.Ctx.GetSystemPrompt()
|
||||||
if system != "" {
|
if system != "" {
|
||||||
m.messages = []models.Message{{
|
m.messages = []models.Message{{
|
||||||
Role: models.MessageRoleSystem,
|
Role: models.MessageRoleSystem,
|
||||||
@ -151,11 +150,6 @@ func newChatModel(tui *model) chatModel {
|
|||||||
|
|
||||||
// styles
|
// styles
|
||||||
var (
|
var (
|
||||||
headerStyle = lipgloss.NewStyle().
|
|
||||||
PaddingLeft(1).
|
|
||||||
PaddingRight(1).
|
|
||||||
Background(lipgloss.Color("0"))
|
|
||||||
|
|
||||||
messageHeadingStyle = lipgloss.NewStyle().
|
messageHeadingStyle = lipgloss.NewStyle().
|
||||||
MarginTop(1).
|
MarginTop(1).
|
||||||
MarginBottom(1).
|
MarginBottom(1).
|
||||||
@ -180,10 +174,10 @@ var (
|
|||||||
footerStyle = lipgloss.NewStyle()
|
footerStyle = lipgloss.NewStyle()
|
||||||
)
|
)
|
||||||
|
|
||||||
func (m *chatModel) handleInput(msg tea.KeyMsg) (bool, tea.Cmd) {
|
func (m *Model) HandleInput(msg tea.KeyMsg) (bool, tea.Cmd) {
|
||||||
switch m.focus {
|
switch m.focus {
|
||||||
case focusInput:
|
case focusInput:
|
||||||
consumed, cmd := m.handleInputKey(msg)
|
consumed, cmd := m.HandleInputKey(msg)
|
||||||
if consumed {
|
if consumed {
|
||||||
return true, cmd
|
return true, cmd
|
||||||
}
|
}
|
||||||
@ -201,7 +195,7 @@ func (m *chatModel) handleInput(msg tea.KeyMsg) (bool, tea.Cmd) {
|
|||||||
return true, nil
|
return true, nil
|
||||||
}
|
}
|
||||||
return true, func() tea.Msg {
|
return true, func() tea.Msg {
|
||||||
return msgStateChange(stateConversations)
|
return shared.MsgViewChange(shared.StateConversations)
|
||||||
}
|
}
|
||||||
case "ctrl+c":
|
case "ctrl+c":
|
||||||
if m.waitingForReply {
|
if m.waitingForReply {
|
||||||
@ -225,15 +219,15 @@ func (m *chatModel) handleInput(msg tea.KeyMsg) (bool, tea.Cmd) {
|
|||||||
return false, nil
|
return false, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m chatModel) Init() tea.Cmd {
|
func (m Model) Init() tea.Cmd {
|
||||||
return tea.Batch(
|
return tea.Batch(
|
||||||
m.waitForChunk(),
|
m.waitForChunk(),
|
||||||
m.waitForReply(),
|
m.waitForReply(),
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m *chatModel) handleResize(width, height int) {
|
func (m *Model) HandleResize(width, height int) {
|
||||||
m.width, m.height = width, height
|
m.Width, m.Height = width, height
|
||||||
m.content.Width = width
|
m.content.Width = width
|
||||||
m.input.SetWidth(width - m.input.FocusedStyle.Base.GetHorizontalFrameSize())
|
m.input.SetWidth(width - m.input.FocusedStyle.Base.GetHorizontalFrameSize())
|
||||||
if len(m.messages) > 0 {
|
if len(m.messages) > 0 {
|
||||||
@ -242,22 +236,22 @@ func (m *chatModel) handleResize(width, height int) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m chatModel) Update(msg tea.Msg) (chatModel, tea.Cmd) {
|
func (m Model) Update(msg tea.Msg) (Model, tea.Cmd) {
|
||||||
var cmds []tea.Cmd
|
var cmds []tea.Cmd
|
||||||
switch msg := msg.(type) {
|
switch msg := msg.(type) {
|
||||||
case msgStateEnter:
|
case shared.MsgViewEnter:
|
||||||
// wake up spinners and cursors
|
// wake up spinners and cursors
|
||||||
cmds = append(cmds, cursor.Blink, m.spinner.Tick)
|
cmds = append(cmds, cursor.Blink, m.spinner.Tick)
|
||||||
|
|
||||||
if m.opts.convShortname != "" && m.conversation.ShortName.String != m.opts.convShortname {
|
if m.State.Values.ConvShortname != "" && m.conversation.ShortName.String != m.State.Values.ConvShortname {
|
||||||
cmds = append(cmds, m.loadConversation(m.opts.convShortname))
|
cmds = append(cmds, m.loadConversation(m.State.Values.ConvShortname))
|
||||||
}
|
}
|
||||||
|
|
||||||
m.rebuildMessageCache()
|
m.rebuildMessageCache()
|
||||||
m.updateContent()
|
m.updateContent()
|
||||||
case tea.WindowSizeMsg:
|
case tea.WindowSizeMsg:
|
||||||
m.handleResize(msg.Width, msg.Height)
|
m.HandleResize(msg.Width, msg.Height)
|
||||||
case msgTempfileEditorClosed:
|
case tuiutil.MsgTempfileEditorClosed:
|
||||||
contents := string(msg)
|
contents := string(msg)
|
||||||
switch m.editorTarget {
|
switch m.editorTarget {
|
||||||
case input:
|
case input:
|
||||||
@ -266,15 +260,16 @@ func (m chatModel) Update(msg tea.Msg) (chatModel, tea.Cmd) {
|
|||||||
m.setMessageContents(m.selectedMessage, contents)
|
m.setMessageContents(m.selectedMessage, contents)
|
||||||
if m.persistence && m.messages[m.selectedMessage].ID > 0 {
|
if m.persistence && m.messages[m.selectedMessage].ID > 0 {
|
||||||
// update persisted message
|
// update persisted message
|
||||||
err := m.ctx.Store.UpdateMessage(&m.messages[m.selectedMessage])
|
err := m.State.Ctx.Store.UpdateMessage(&m.messages[m.selectedMessage])
|
||||||
if err != nil {
|
if err != nil {
|
||||||
cmds = append(cmds, wrapError(fmt.Errorf("Could not save edited message: %v", err)))
|
cmds = append(cmds, shared.WrapError(fmt.Errorf("Could not save edited message: %v", err)))
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
m.updateContent()
|
m.updateContent()
|
||||||
}
|
}
|
||||||
case msgConversationLoaded:
|
case msgConversationLoaded:
|
||||||
m.conversation = (*models.Conversation)(msg)
|
m.conversation = (*models.Conversation)(msg)
|
||||||
|
m.rootMessages, _ = m.State.Ctx.Store.RootMessages(m.conversation.ID)
|
||||||
cmds = append(cmds, m.loadMessages(m.conversation))
|
cmds = append(cmds, m.loadMessages(m.conversation))
|
||||||
case msgMessagesLoaded:
|
case msgMessagesLoaded:
|
||||||
m.selectedMessage = len(msg) - 1
|
m.selectedMessage = len(msg) - 1
|
||||||
@ -328,7 +323,7 @@ func (m chatModel) Update(msg tea.Msg) (chatModel, tea.Cmd) {
|
|||||||
if m.persistence {
|
if m.persistence {
|
||||||
err := m.persistConversation()
|
err := m.persistConversation()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
cmds = append(cmds, wrapError(err))
|
cmds = append(cmds, shared.WrapError(err))
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -350,15 +345,15 @@ func (m chatModel) Update(msg tea.Msg) (chatModel, tea.Cmd) {
|
|||||||
case msgResponseError:
|
case msgResponseError:
|
||||||
m.waitingForReply = false
|
m.waitingForReply = false
|
||||||
m.status = "Press ctrl+s to send"
|
m.status = "Press ctrl+s to send"
|
||||||
m.err = error(msg)
|
m.State.Err = error(msg)
|
||||||
m.updateContent()
|
m.updateContent()
|
||||||
case msgConversationTitleChanged:
|
case msgConversationTitleChanged:
|
||||||
title := string(msg)
|
title := string(msg)
|
||||||
m.conversation.Title = title
|
m.conversation.Title = title
|
||||||
if m.persistence {
|
if m.persistence {
|
||||||
err := m.ctx.Store.UpdateConversation(m.conversation)
|
err := m.State.Ctx.Store.UpdateConversation(m.conversation)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
cmds = append(cmds, wrapError(err))
|
cmds = append(cmds, shared.WrapError(err))
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
case cursor.BlinkMsg:
|
case cursor.BlinkMsg:
|
||||||
@ -394,21 +389,21 @@ func (m chatModel) Update(msg tea.Msg) (chatModel, tea.Cmd) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// update views once window dimensions are known
|
// update views once window dimensions are known
|
||||||
if m.width > 0 {
|
if m.Width > 0 {
|
||||||
m.views.header = m.headerView()
|
m.Header = m.headerView()
|
||||||
m.views.footer = m.footerView()
|
m.Footer = m.footerView()
|
||||||
m.views.error = errorBanner(m.err, m.width)
|
m.Error = tuiutil.ErrorBanner(m.Err, m.Width)
|
||||||
fixedHeight := height(m.views.header) + height(m.views.error) + height(m.views.footer)
|
fixedHeight := tuiutil.Height(m.Header) + tuiutil.Height(m.Error) + tuiutil.Height(m.Footer)
|
||||||
|
|
||||||
// calculate clamped input height to accomodate input text
|
// calculate clamped input height to accomodate input text
|
||||||
// minimum 4 lines, maximum half of content area
|
// minimum 4 lines, maximum half of content area
|
||||||
newHeight := max(4, min((m.height-fixedHeight-1)/2, m.input.LineCount()))
|
newHeight := max(4, min((m.Height-fixedHeight-1)/2, m.input.LineCount()))
|
||||||
m.input.SetHeight(newHeight)
|
m.input.SetHeight(newHeight)
|
||||||
m.views.input = m.input.View()
|
m.Input = m.input.View()
|
||||||
|
|
||||||
// remaining height towards content
|
// remaining height towards content
|
||||||
m.content.Height = m.height - fixedHeight - height(m.views.input)
|
m.content.Height = m.Height - fixedHeight - tuiutil.Height(m.Input)
|
||||||
m.views.content = m.content.View()
|
m.Content = m.content.View()
|
||||||
}
|
}
|
||||||
|
|
||||||
// this is a pretty nasty hack to ensure the input area viewport doesn't
|
// this is a pretty nasty hack to ensure the input area viewport doesn't
|
||||||
@ -436,7 +431,7 @@ func (m chatModel) Update(msg tea.Msg) (chatModel, tea.Cmd) {
|
|||||||
return m, tea.Batch(cmds...)
|
return m, tea.Batch(cmds...)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m *chatModel) handleMessagesKey(msg tea.KeyMsg) (bool, tea.Cmd) {
|
func (m *Model) handleMessagesKey(msg tea.KeyMsg) (bool, tea.Cmd) {
|
||||||
switch msg.String() {
|
switch msg.String() {
|
||||||
case "tab", "enter":
|
case "tab", "enter":
|
||||||
m.focus = focusInput
|
m.focus = focusInput
|
||||||
@ -445,7 +440,7 @@ func (m *chatModel) handleMessagesKey(msg tea.KeyMsg) (bool, tea.Cmd) {
|
|||||||
return true, nil
|
return true, nil
|
||||||
case "e":
|
case "e":
|
||||||
message := m.messages[m.selectedMessage]
|
message := m.messages[m.selectedMessage]
|
||||||
cmd := openTempfileEditor("message.*.md", message.Content, "# Edit the message below\n")
|
cmd := tuiutil.OpenTempfileEditor("message.*.md", message.Content, "# Edit the message below\n")
|
||||||
m.editorTarget = selectedMessage
|
m.editorTarget = selectedMessage
|
||||||
return true, cmd
|
return true, cmd
|
||||||
case "ctrl+k":
|
case "ctrl+k":
|
||||||
@ -453,7 +448,7 @@ func (m *chatModel) handleMessagesKey(msg tea.KeyMsg) (bool, tea.Cmd) {
|
|||||||
m.selectedMessage--
|
m.selectedMessage--
|
||||||
m.updateContent()
|
m.updateContent()
|
||||||
offset := m.messageOffsets[m.selectedMessage]
|
offset := m.messageOffsets[m.selectedMessage]
|
||||||
scrollIntoView(&m.content, offset, m.content.Height/2)
|
tuiutil.ScrollIntoView(&m.content, offset, m.content.Height/2)
|
||||||
}
|
}
|
||||||
return true, nil
|
return true, nil
|
||||||
case "ctrl+j":
|
case "ctrl+j":
|
||||||
@ -461,9 +456,43 @@ func (m *chatModel) handleMessagesKey(msg tea.KeyMsg) (bool, tea.Cmd) {
|
|||||||
m.selectedMessage++
|
m.selectedMessage++
|
||||||
m.updateContent()
|
m.updateContent()
|
||||||
offset := m.messageOffsets[m.selectedMessage]
|
offset := m.messageOffsets[m.selectedMessage]
|
||||||
scrollIntoView(&m.content, offset, m.content.Height/2)
|
tuiutil.ScrollIntoView(&m.content, offset, m.content.Height/2)
|
||||||
}
|
}
|
||||||
return true, nil
|
return true, nil
|
||||||
|
case "ctrl+h", "ctrl+l":
|
||||||
|
dir := CyclePrev
|
||||||
|
if msg.String() == "ctrl+l" {
|
||||||
|
dir = CycleNext
|
||||||
|
}
|
||||||
|
|
||||||
|
var err error
|
||||||
|
var selected *models.Message
|
||||||
|
if m.selectedMessage == 0 {
|
||||||
|
selected, err = m.cycleSelectedRoot(m.conversation, dir)
|
||||||
|
if err != nil {
|
||||||
|
return true, shared.WrapError(fmt.Errorf("Could not cycle conversation root: %v", err))
|
||||||
|
}
|
||||||
|
} else if m.selectedMessage > 0 {
|
||||||
|
selected, err = m.cycleSelectedReply(&m.messages[m.selectedMessage-1], dir)
|
||||||
|
if err != nil {
|
||||||
|
return true, shared.WrapError(fmt.Errorf("Could not cycle reply: %v", err))
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if selected == nil {
|
||||||
|
return false, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
// Retrieve updated view at this point
|
||||||
|
newPath, err := m.State.Ctx.Store.PathToLeaf(selected)
|
||||||
|
if err != nil {
|
||||||
|
m.State.Err = fmt.Errorf("Could not fetch messages: %v", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
m.messages = append(m.messages[:m.selectedMessage], newPath...)
|
||||||
|
m.rebuildMessageCache()
|
||||||
|
m.updateContent()
|
||||||
|
return true, nil
|
||||||
case "ctrl+r":
|
case "ctrl+r":
|
||||||
// resubmit the conversation with all messages up until and including the selected message
|
// resubmit the conversation with all messages up until and including the selected message
|
||||||
if m.waitingForReply || len(m.messages) == 0 {
|
if m.waitingForReply || len(m.messages) == 0 {
|
||||||
@ -479,7 +508,74 @@ func (m *chatModel) handleMessagesKey(msg tea.KeyMsg) (bool, tea.Cmd) {
|
|||||||
return false, nil
|
return false, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m *chatModel) handleInputKey(msg tea.KeyMsg) (bool, tea.Cmd) {
|
type CycleDirection int
|
||||||
|
|
||||||
|
const (
|
||||||
|
CycleNext CycleDirection = 1
|
||||||
|
CyclePrev CycleDirection = -1
|
||||||
|
)
|
||||||
|
|
||||||
|
func cycleMessages(m *models.Message, msgs []models.Message, dir CycleDirection) (*models.Message, error) {
|
||||||
|
currentIndex := -1
|
||||||
|
for i, reply := range msgs {
|
||||||
|
if reply.ID == m.ID {
|
||||||
|
currentIndex = i
|
||||||
|
break
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if currentIndex < 0 {
|
||||||
|
return nil, fmt.Errorf("message not found")
|
||||||
|
}
|
||||||
|
|
||||||
|
var next int
|
||||||
|
if dir == CyclePrev {
|
||||||
|
// Wrap around to the last reply if at the beginning
|
||||||
|
next = (currentIndex - 1 + len(msgs)) % len(msgs)
|
||||||
|
} else {
|
||||||
|
// Wrap around to the first reply if at the end
|
||||||
|
next = (currentIndex + 1) % len(msgs)
|
||||||
|
}
|
||||||
|
return &msgs[next], nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (m *Model) cycleSelectedRoot(conv *models.Conversation, dir CycleDirection) (*models.Message, error) {
|
||||||
|
if len(m.rootMessages) < 2 {
|
||||||
|
return nil, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
nextRoot, err := cycleMessages(conv.SelectedRoot, m.rootMessages, dir)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
|
||||||
|
conv.SelectedRoot = nextRoot
|
||||||
|
err = m.State.Ctx.Store.UpdateConversation(conv)
|
||||||
|
if err != nil {
|
||||||
|
return nil, fmt.Errorf("Could not update conversation: %v", err)
|
||||||
|
}
|
||||||
|
return nextRoot, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (m *Model) cycleSelectedReply(message *models.Message, dir CycleDirection) (*models.Message, error) {
|
||||||
|
if len(message.Replies) < 2 {
|
||||||
|
return nil, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
nextReply, err := cycleMessages(message.SelectedReply, message.Replies, dir)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
|
||||||
|
message.SelectedReply = nextReply
|
||||||
|
err = m.State.Ctx.Store.UpdateMessage(message)
|
||||||
|
if err != nil {
|
||||||
|
return nil, fmt.Errorf("Could not update message: %v", err)
|
||||||
|
}
|
||||||
|
return nextReply, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (m *Model) HandleInputKey(msg tea.KeyMsg) (bool, tea.Cmd) {
|
||||||
switch msg.String() {
|
switch msg.String() {
|
||||||
case "esc":
|
case "esc":
|
||||||
m.focus = focusMessages
|
m.focus = focusMessages
|
||||||
@ -488,7 +584,7 @@ func (m *chatModel) handleInputKey(msg tea.KeyMsg) (bool, tea.Cmd) {
|
|||||||
m.selectedMessage = len(m.messages) - 1
|
m.selectedMessage = len(m.messages) - 1
|
||||||
}
|
}
|
||||||
offset := m.messageOffsets[m.selectedMessage]
|
offset := m.messageOffsets[m.selectedMessage]
|
||||||
scrollIntoView(&m.content, offset, m.content.Height/2)
|
tuiutil.ScrollIntoView(&m.content, offset, m.content.Height/2)
|
||||||
}
|
}
|
||||||
m.updateContent()
|
m.updateContent()
|
||||||
m.input.Blur()
|
m.input.Blur()
|
||||||
@ -504,7 +600,7 @@ func (m *chatModel) handleInputKey(msg tea.KeyMsg) (bool, tea.Cmd) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
if len(m.messages) > 0 && m.messages[len(m.messages)-1].Role == models.MessageRoleUser {
|
if len(m.messages) > 0 && m.messages[len(m.messages)-1].Role == models.MessageRoleUser {
|
||||||
return true, wrapError(fmt.Errorf("Can't reply to a user message"))
|
return true, shared.WrapError(fmt.Errorf("Can't reply to a user message"))
|
||||||
}
|
}
|
||||||
|
|
||||||
m.addMessage(models.Message{
|
m.addMessage(models.Message{
|
||||||
@ -517,7 +613,7 @@ func (m *chatModel) handleInputKey(msg tea.KeyMsg) (bool, tea.Cmd) {
|
|||||||
if m.persistence {
|
if m.persistence {
|
||||||
err := m.persistConversation()
|
err := m.persistConversation()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return true, wrapError(err)
|
return true, shared.WrapError(err)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -526,14 +622,37 @@ func (m *chatModel) handleInputKey(msg tea.KeyMsg) (bool, tea.Cmd) {
|
|||||||
m.content.GotoBottom()
|
m.content.GotoBottom()
|
||||||
return true, cmd
|
return true, cmd
|
||||||
case "ctrl+e":
|
case "ctrl+e":
|
||||||
cmd := openTempfileEditor("message.*.md", m.input.Value(), "# Edit your input below\n")
|
cmd := tuiutil.OpenTempfileEditor("message.*.md", m.input.Value(), "# Edit your input below\n")
|
||||||
m.editorTarget = input
|
m.editorTarget = input
|
||||||
return true, cmd
|
return true, cmd
|
||||||
}
|
}
|
||||||
return false, nil
|
return false, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m *chatModel) renderMessageHeading(i int, message *models.Message) string {
|
func (m Model) View() string {
|
||||||
|
if m.Width == 0 {
|
||||||
|
return ""
|
||||||
|
}
|
||||||
|
sections := make([]string, 0, 6)
|
||||||
|
|
||||||
|
if m.Header != "" {
|
||||||
|
sections = append(sections, m.Header)
|
||||||
|
}
|
||||||
|
|
||||||
|
sections = append(sections, m.Content)
|
||||||
|
if m.Error != "" {
|
||||||
|
sections = append(sections, m.Error)
|
||||||
|
}
|
||||||
|
sections = append(sections, m.Input)
|
||||||
|
|
||||||
|
if m.Footer != "" {
|
||||||
|
sections = append(sections, m.Footer)
|
||||||
|
}
|
||||||
|
|
||||||
|
return lipgloss.JoinVertical(lipgloss.Left, sections...)
|
||||||
|
}
|
||||||
|
|
||||||
|
func (m *Model) renderMessageHeading(i int, message *models.Message) string {
|
||||||
icon := ""
|
icon := ""
|
||||||
friendly := message.Role.FriendlyRole()
|
friendly := message.Role.FriendlyRole()
|
||||||
style := lipgloss.NewStyle().Faint(true).Bold(true)
|
style := lipgloss.NewStyle().Faint(true).Bold(true)
|
||||||
@ -558,6 +677,29 @@ func (m *chatModel) renderMessageHeading(i int, message *models.Message) string
|
|||||||
var suffix string
|
var suffix string
|
||||||
|
|
||||||
faint := lipgloss.NewStyle().Faint(true)
|
faint := lipgloss.NewStyle().Faint(true)
|
||||||
|
|
||||||
|
if i == 0 && len(m.rootMessages) > 0 {
|
||||||
|
selectedRootIndex := 0
|
||||||
|
for j, reply := range m.rootMessages {
|
||||||
|
if reply.ID == *m.conversation.SelectedRootID {
|
||||||
|
selectedRootIndex = j
|
||||||
|
break
|
||||||
|
}
|
||||||
|
}
|
||||||
|
suffix += faint.Render(fmt.Sprintf(" <%d/%d>", selectedRootIndex+1, len(m.rootMessages)))
|
||||||
|
}
|
||||||
|
if i > 0 && len(m.messages[i-1].Replies) > 1 {
|
||||||
|
// Find the selected reply index
|
||||||
|
selectedReplyIndex := 0
|
||||||
|
for j, reply := range m.messages[i-1].Replies {
|
||||||
|
if reply.ID == *m.messages[i-1].SelectedReplyID {
|
||||||
|
selectedReplyIndex = j
|
||||||
|
break
|
||||||
|
}
|
||||||
|
}
|
||||||
|
suffix += faint.Render(fmt.Sprintf(" <%d/%d>", selectedReplyIndex+1, len(m.messages[i-1].Replies)))
|
||||||
|
}
|
||||||
|
|
||||||
if m.focus == focusMessages {
|
if m.focus == focusMessages {
|
||||||
if i == m.selectedMessage {
|
if i == m.selectedMessage {
|
||||||
prefix = "> "
|
prefix = "> "
|
||||||
@ -571,14 +713,14 @@ func (m *chatModel) renderMessageHeading(i int, message *models.Message) string
|
|||||||
return messageHeadingStyle.Render(prefix + user + suffix)
|
return messageHeadingStyle.Render(prefix + user + suffix)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m *chatModel) renderMessage(i int) string {
|
func (m *Model) renderMessage(i int) string {
|
||||||
msg := &m.messages[i]
|
msg := &m.messages[i]
|
||||||
|
|
||||||
// Write message contents
|
// Write message contents
|
||||||
sb := &strings.Builder{}
|
sb := &strings.Builder{}
|
||||||
sb.Grow(len(msg.Content) * 2)
|
sb.Grow(len(msg.Content) * 2)
|
||||||
if msg.Content != "" {
|
if msg.Content != "" {
|
||||||
err := m.ctx.Chroma.Highlight(sb, msg.Content)
|
err := m.State.Ctx.Chroma.Highlight(sb, msg.Content)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
sb.Reset()
|
sb.Reset()
|
||||||
sb.WriteString(msg.Content)
|
sb.WriteString(msg.Content)
|
||||||
@ -642,7 +784,7 @@ func (m *chatModel) renderMessage(i int) string {
|
|||||||
if msg.Content != "" {
|
if msg.Content != "" {
|
||||||
sb.WriteString("\n\n")
|
sb.WriteString("\n\n")
|
||||||
}
|
}
|
||||||
_ = m.ctx.Chroma.HighlightLang(sb, toolString, "yaml")
|
_ = m.State.Ctx.Chroma.HighlightLang(sb, toolString, "yaml")
|
||||||
}
|
}
|
||||||
|
|
||||||
content := strings.TrimRight(sb.String(), "\n")
|
content := strings.TrimRight(sb.String(), "\n")
|
||||||
@ -659,7 +801,7 @@ func (m *chatModel) renderMessage(i int) string {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// render the conversation into a string
|
// render the conversation into a string
|
||||||
func (m *chatModel) conversationMessagesView() string {
|
func (m *Model) conversationMessagesView() string {
|
||||||
sb := strings.Builder{}
|
sb := strings.Builder{}
|
||||||
|
|
||||||
m.messageOffsets = make([]int, len(m.messages))
|
m.messageOffsets = make([]int, len(m.messages))
|
||||||
@ -700,7 +842,7 @@ func (m *chatModel) conversationMessagesView() string {
|
|||||||
return sb.String()
|
return sb.String()
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m *chatModel) headerView() string {
|
func (m *Model) headerView() string {
|
||||||
titleStyle := lipgloss.NewStyle().Bold(true)
|
titleStyle := lipgloss.NewStyle().Bold(true)
|
||||||
var title string
|
var title string
|
||||||
if m.conversation != nil && m.conversation.Title != "" {
|
if m.conversation != nil && m.conversation.Title != "" {
|
||||||
@ -708,12 +850,12 @@ func (m *chatModel) headerView() string {
|
|||||||
} else {
|
} else {
|
||||||
title = "Untitled"
|
title = "Untitled"
|
||||||
}
|
}
|
||||||
title = truncateToCellWidth(title, m.width-headerStyle.GetHorizontalPadding(), "...")
|
title = tuiutil.TruncateToCellWidth(title, m.Width-styles.Header.GetHorizontalPadding(), "...")
|
||||||
header := titleStyle.Render(title)
|
header := titleStyle.Render(title)
|
||||||
return headerStyle.Width(m.width).Render(header)
|
return styles.Header.Width(m.Width).Render(header)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m *chatModel) footerView() string {
|
func (m *Model) footerView() string {
|
||||||
segmentStyle := lipgloss.NewStyle().PaddingLeft(1).PaddingRight(1).Faint(true)
|
segmentStyle := lipgloss.NewStyle().PaddingLeft(1).PaddingRight(1).Faint(true)
|
||||||
segmentSeparator := "|"
|
segmentSeparator := "|"
|
||||||
|
|
||||||
@ -741,14 +883,14 @@ func (m *chatModel) footerView() string {
|
|||||||
rightSegments = append(rightSegments, segmentStyle.Render(throughput))
|
rightSegments = append(rightSegments, segmentStyle.Render(throughput))
|
||||||
}
|
}
|
||||||
|
|
||||||
model := fmt.Sprintf("Model: %s", *m.ctx.Config.Defaults.Model)
|
model := fmt.Sprintf("Model: %s", *m.State.Ctx.Config.Defaults.Model)
|
||||||
rightSegments = append(rightSegments, segmentStyle.Render(model))
|
rightSegments = append(rightSegments, segmentStyle.Render(model))
|
||||||
|
|
||||||
left := strings.Join(leftSegments, segmentSeparator)
|
left := strings.Join(leftSegments, segmentSeparator)
|
||||||
right := strings.Join(rightSegments, segmentSeparator)
|
right := strings.Join(rightSegments, segmentSeparator)
|
||||||
|
|
||||||
totalWidth := lipgloss.Width(left) + lipgloss.Width(right)
|
totalWidth := lipgloss.Width(left) + lipgloss.Width(right)
|
||||||
remaining := m.width - totalWidth
|
remaining := m.Width - totalWidth
|
||||||
|
|
||||||
var padding string
|
var padding string
|
||||||
if remaining > 0 {
|
if remaining > 0 {
|
||||||
@ -757,12 +899,12 @@ func (m *chatModel) footerView() string {
|
|||||||
|
|
||||||
footer := left + padding + right
|
footer := left + padding + right
|
||||||
if remaining < 0 {
|
if remaining < 0 {
|
||||||
footer = truncateToCellWidth(footer, m.width, "...")
|
footer = tuiutil.TruncateToCellWidth(footer, m.Width, "...")
|
||||||
}
|
}
|
||||||
return footerStyle.Width(m.width).Render(footer)
|
return footerStyle.Width(m.Width).Render(footer)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m *chatModel) setMessage(i int, msg models.Message) {
|
func (m *Model) setMessage(i int, msg models.Message) {
|
||||||
if i >= len(m.messages) {
|
if i >= len(m.messages) {
|
||||||
panic("i out of range")
|
panic("i out of range")
|
||||||
}
|
}
|
||||||
@ -770,12 +912,12 @@ func (m *chatModel) setMessage(i int, msg models.Message) {
|
|||||||
m.messageCache[i] = m.renderMessage(i)
|
m.messageCache[i] = m.renderMessage(i)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m *chatModel) addMessage(msg models.Message) {
|
func (m *Model) addMessage(msg models.Message) {
|
||||||
m.messages = append(m.messages, msg)
|
m.messages = append(m.messages, msg)
|
||||||
m.messageCache = append(m.messageCache, m.renderMessage(len(m.messages)-1))
|
m.messageCache = append(m.messageCache, m.renderMessage(len(m.messages)-1))
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m *chatModel) setMessageContents(i int, content string) {
|
func (m *Model) setMessageContents(i int, content string) {
|
||||||
if i >= len(m.messages) {
|
if i >= len(m.messages) {
|
||||||
panic("i out of range")
|
panic("i out of range")
|
||||||
}
|
}
|
||||||
@ -783,14 +925,14 @@ func (m *chatModel) setMessageContents(i int, content string) {
|
|||||||
m.messageCache[i] = m.renderMessage(i)
|
m.messageCache[i] = m.renderMessage(i)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m *chatModel) rebuildMessageCache() {
|
func (m *Model) rebuildMessageCache() {
|
||||||
m.messageCache = make([]string, len(m.messages))
|
m.messageCache = make([]string, len(m.messages))
|
||||||
for i := range m.messages {
|
for i := range m.messages {
|
||||||
m.messageCache[i] = m.renderMessage(i)
|
m.messageCache[i] = m.renderMessage(i)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m *chatModel) updateContent() {
|
func (m *Model) updateContent() {
|
||||||
atBottom := m.content.AtBottom()
|
atBottom := m.content.AtBottom()
|
||||||
m.content.SetContent(m.conversationMessagesView())
|
m.content.SetContent(m.conversationMessagesView())
|
||||||
if atBottom {
|
if atBottom {
|
||||||
@ -799,36 +941,36 @@ func (m *chatModel) updateContent() {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m *chatModel) loadConversation(shortname string) tea.Cmd {
|
func (m *Model) loadConversation(shortname string) tea.Cmd {
|
||||||
return func() tea.Msg {
|
return func() tea.Msg {
|
||||||
if shortname == "" {
|
if shortname == "" {
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
c, err := m.ctx.Store.ConversationByShortName(shortname)
|
c, err := m.State.Ctx.Store.ConversationByShortName(shortname)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return msgError(fmt.Errorf("Could not lookup conversation: %v", err))
|
return shared.MsgError(fmt.Errorf("Could not lookup conversation: %v", err))
|
||||||
}
|
}
|
||||||
if c.ID == 0 {
|
if c.ID == 0 {
|
||||||
return msgError(fmt.Errorf("Conversation not found: %s", shortname))
|
return shared.MsgError(fmt.Errorf("Conversation not found: %s", shortname))
|
||||||
}
|
}
|
||||||
return msgConversationLoaded(c)
|
return msgConversationLoaded(c)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m *chatModel) loadMessages(c *models.Conversation) tea.Cmd {
|
func (m *Model) loadMessages(c *models.Conversation) tea.Cmd {
|
||||||
return func() tea.Msg {
|
return func() tea.Msg {
|
||||||
messages, err := m.ctx.Store.PathToLeaf(c.SelectedRoot)
|
messages, err := m.State.Ctx.Store.PathToLeaf(c.SelectedRoot)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return msgError(fmt.Errorf("Could not load conversation messages: %v\n", err))
|
return shared.MsgError(fmt.Errorf("Could not load conversation messages: %v\n", err))
|
||||||
}
|
}
|
||||||
return msgMessagesLoaded(messages)
|
return msgMessagesLoaded(messages)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m *chatModel) persistConversation() error {
|
func (m *Model) persistConversation() error {
|
||||||
if m.conversation.ID == 0 {
|
if m.conversation.ID == 0 {
|
||||||
// Start a new conversation with all messages so far
|
// Start a new conversation with all messages so far
|
||||||
c, messages, err := m.ctx.Store.StartConversation(m.messages...)
|
c, messages, err := m.State.Ctx.Store.StartConversation(m.messages...)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
@ -843,16 +985,18 @@ func (m *chatModel) persistConversation() error {
|
|||||||
if m.messages[i].ID > 0 {
|
if m.messages[i].ID > 0 {
|
||||||
// message has an ID, update its contents
|
// message has an ID, update its contents
|
||||||
// TODO: check for content/tool equality before updating?
|
// TODO: check for content/tool equality before updating?
|
||||||
err := m.ctx.Store.UpdateMessage(&m.messages[i])
|
err := m.State.Ctx.Store.UpdateMessage(&m.messages[i])
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
} else if i > 0 {
|
} else if i > 0 {
|
||||||
// messages is new, so add it as a reply to previous message
|
// messages is new, so add it as a reply to previous message
|
||||||
saved, err := m.ctx.Store.Reply(&m.messages[i-1], m.messages[i])
|
saved, err := m.State.Ctx.Store.Reply(&m.messages[i-1], m.messages[i])
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
// add this message as a reply to the previous
|
||||||
|
m.messages[i-1].Replies = append(m.messages[i-1].Replies, saved[0])
|
||||||
m.messages[i] = saved[0]
|
m.messages[i] = saved[0]
|
||||||
} else {
|
} else {
|
||||||
// message has no id and no previous messages to add it to
|
// message has no id and no previous messages to add it to
|
||||||
@ -864,29 +1008,29 @@ func (m *chatModel) persistConversation() error {
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m *chatModel) generateConversationTitle() tea.Cmd {
|
func (m *Model) generateConversationTitle() tea.Cmd {
|
||||||
return func() tea.Msg {
|
return func() tea.Msg {
|
||||||
title, err := cmdutil.GenerateTitle(m.ctx, m.messages)
|
title, err := cmdutil.GenerateTitle(m.State.Ctx, m.messages)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return msgError(err)
|
return shared.MsgError(err)
|
||||||
}
|
}
|
||||||
return msgConversationTitleChanged(title)
|
return msgConversationTitleChanged(title)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m *chatModel) waitForReply() tea.Cmd {
|
func (m *Model) waitForReply() tea.Cmd {
|
||||||
return func() tea.Msg {
|
return func() tea.Msg {
|
||||||
return msgAssistantReply(<-m.replyChan)
|
return msgAssistantReply(<-m.replyChan)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m *chatModel) waitForChunk() tea.Cmd {
|
func (m *Model) waitForChunk() tea.Cmd {
|
||||||
return func() tea.Msg {
|
return func() tea.Msg {
|
||||||
return msgResponseChunk(<-m.replyChunkChan)
|
return msgResponseChunk(<-m.replyChunkChan)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m *chatModel) promptLLM() tea.Cmd {
|
func (m *Model) promptLLM() tea.Cmd {
|
||||||
m.waitingForReply = true
|
m.waitingForReply = true
|
||||||
m.replyCursor.Blink = false
|
m.replyCursor.Blink = false
|
||||||
m.status = "Press ctrl+c to cancel"
|
m.status = "Press ctrl+c to cancel"
|
||||||
@ -906,16 +1050,16 @@ func (m *chatModel) promptLLM() tea.Cmd {
|
|||||||
m.elapsed = 0
|
m.elapsed = 0
|
||||||
|
|
||||||
return func() tea.Msg {
|
return func() tea.Msg {
|
||||||
completionProvider, err := m.ctx.GetCompletionProvider(*m.ctx.Config.Defaults.Model)
|
completionProvider, err := m.State.Ctx.GetCompletionProvider(*m.State.Ctx.Config.Defaults.Model)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return msgError(err)
|
return shared.MsgError(err)
|
||||||
}
|
}
|
||||||
|
|
||||||
requestParams := models.RequestParameters{
|
requestParams := models.RequestParameters{
|
||||||
Model: *m.ctx.Config.Defaults.Model,
|
Model: *m.State.Ctx.Config.Defaults.Model,
|
||||||
MaxTokens: *m.ctx.Config.Defaults.MaxTokens,
|
MaxTokens: *m.State.Ctx.Config.Defaults.MaxTokens,
|
||||||
Temperature: *m.ctx.Config.Defaults.Temperature,
|
Temperature: *m.State.Ctx.Config.Defaults.Temperature,
|
||||||
ToolBag: m.ctx.EnabledTools,
|
ToolBag: m.State.Ctx.EnabledTools,
|
||||||
}
|
}
|
||||||
|
|
||||||
replyHandler := func(msg models.Message) {
|
replyHandler := func(msg models.Message) {
|
@ -1,4 +1,4 @@
|
|||||||
package tui
|
package conversations
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"fmt"
|
"fmt"
|
||||||
@ -6,6 +6,9 @@ import (
|
|||||||
"time"
|
"time"
|
||||||
|
|
||||||
models "git.mlow.ca/mlow/lmcli/pkg/lmcli/model"
|
models "git.mlow.ca/mlow/lmcli/pkg/lmcli/model"
|
||||||
|
"git.mlow.ca/mlow/lmcli/pkg/tui/shared"
|
||||||
|
"git.mlow.ca/mlow/lmcli/pkg/tui/styles"
|
||||||
|
tuiutil "git.mlow.ca/mlow/lmcli/pkg/tui/util"
|
||||||
"git.mlow.ca/mlow/lmcli/pkg/util"
|
"git.mlow.ca/mlow/lmcli/pkg/util"
|
||||||
"github.com/charmbracelet/bubbles/viewport"
|
"github.com/charmbracelet/bubbles/viewport"
|
||||||
tea "github.com/charmbracelet/bubbletea"
|
tea "github.com/charmbracelet/bubbletea"
|
||||||
@ -24,8 +27,9 @@ type (
|
|||||||
msgConversationSelected models.Conversation
|
msgConversationSelected models.Conversation
|
||||||
)
|
)
|
||||||
|
|
||||||
type conversationsModel struct {
|
type Model struct {
|
||||||
basemodel
|
shared.State
|
||||||
|
shared.Sections
|
||||||
|
|
||||||
conversations []loadedConversation
|
conversations []loadedConversation
|
||||||
cursor int // index of the currently selected conversation
|
cursor int // index of the currently selected conversation
|
||||||
@ -34,21 +38,15 @@ type conversationsModel struct {
|
|||||||
content viewport.Model
|
content viewport.Model
|
||||||
}
|
}
|
||||||
|
|
||||||
func newConversationsModel(tui *model) conversationsModel {
|
func Conversations(state shared.State) Model {
|
||||||
m := conversationsModel{
|
m := Model{
|
||||||
basemodel: basemodel{
|
State: state,
|
||||||
opts: tui.opts,
|
|
||||||
ctx: tui.ctx,
|
|
||||||
views: tui.views,
|
|
||||||
width: tui.width,
|
|
||||||
height: tui.height,
|
|
||||||
},
|
|
||||||
content: viewport.New(0, 0),
|
content: viewport.New(0, 0),
|
||||||
}
|
}
|
||||||
return m
|
return m
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m *conversationsModel) handleInput(msg tea.KeyMsg) (bool, tea.Cmd) {
|
func (m *Model) HandleInput(msg tea.KeyMsg) (bool, tea.Cmd) {
|
||||||
switch msg.String() {
|
switch msg.String() {
|
||||||
case "enter":
|
case "enter":
|
||||||
if len(m.conversations) > 0 && m.cursor < len(m.conversations) {
|
if len(m.conversations) > 0 && m.cursor < len(m.conversations) {
|
||||||
@ -66,7 +64,7 @@ func (m *conversationsModel) handleInput(msg tea.KeyMsg) (bool, tea.Cmd) {
|
|||||||
// this hack positions the *next* conversatoin slightly
|
// this hack positions the *next* conversatoin slightly
|
||||||
// *off* the screen, ensuring the entire m.cursor is shown,
|
// *off* the screen, ensuring the entire m.cursor is shown,
|
||||||
// even if its height may not be constant due to wrapping.
|
// even if its height may not be constant due to wrapping.
|
||||||
scrollIntoView(&m.content, m.itemOffsets[m.cursor+1], -1)
|
tuiutil.ScrollIntoView(&m.content, m.itemOffsets[m.cursor+1], -1)
|
||||||
}
|
}
|
||||||
m.content.SetContent(m.renderConversationList())
|
m.content.SetContent(m.renderConversationList())
|
||||||
} else {
|
} else {
|
||||||
@ -80,7 +78,7 @@ func (m *conversationsModel) handleInput(msg tea.KeyMsg) (bool, tea.Cmd) {
|
|||||||
if m.cursor == 0 {
|
if m.cursor == 0 {
|
||||||
m.content.GotoTop()
|
m.content.GotoTop()
|
||||||
} else {
|
} else {
|
||||||
scrollIntoView(&m.content, m.itemOffsets[m.cursor], 1)
|
tuiutil.ScrollIntoView(&m.content, m.itemOffsets[m.cursor], 1)
|
||||||
}
|
}
|
||||||
m.content.SetContent(m.renderConversationList())
|
m.content.SetContent(m.renderConversationList())
|
||||||
} else {
|
} else {
|
||||||
@ -102,27 +100,32 @@ func (m *conversationsModel) handleInput(msg tea.KeyMsg) (bool, tea.Cmd) {
|
|||||||
return false, nil
|
return false, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m conversationsModel) Init() tea.Cmd {
|
func (m Model) Init() tea.Cmd {
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m *conversationsModel) handleResize(width, height int) {
|
func (m *Model) HandleResize(width, height int) {
|
||||||
m.width, m.height = width, height
|
m.Width, m.Height = width, height
|
||||||
m.content.Width = width
|
m.content.Width = width
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m conversationsModel) Update(msg tea.Msg) (conversationsModel, tea.Cmd) {
|
func (m Model) Update(msg tea.Msg) (Model, tea.Cmd) {
|
||||||
var cmds []tea.Cmd
|
var cmds []tea.Cmd
|
||||||
switch msg := msg.(type) {
|
switch msg := msg.(type) {
|
||||||
case msgStateEnter:
|
case shared.MsgViewEnter:
|
||||||
cmds = append(cmds, m.loadConversations())
|
cmds = append(cmds, m.loadConversations())
|
||||||
m.content.SetContent(m.renderConversationList())
|
m.content.SetContent(m.renderConversationList())
|
||||||
case tea.WindowSizeMsg:
|
case tea.WindowSizeMsg:
|
||||||
m.handleResize(msg.Width, msg.Height)
|
m.HandleResize(msg.Width, msg.Height)
|
||||||
m.content.SetContent(m.renderConversationList())
|
m.content.SetContent(m.renderConversationList())
|
||||||
case msgConversationsLoaded:
|
case msgConversationsLoaded:
|
||||||
m.conversations = msg
|
m.conversations = msg
|
||||||
m.content.SetContent(m.renderConversationList())
|
m.content.SetContent(m.renderConversationList())
|
||||||
|
case msgConversationSelected:
|
||||||
|
m.Values.ConvShortname = msg.ShortName.String
|
||||||
|
cmds = append(cmds, func() tea.Msg {
|
||||||
|
return shared.MsgViewChange(shared.StateChat)
|
||||||
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
var cmd tea.Cmd
|
var cmd tea.Cmd
|
||||||
@ -131,22 +134,22 @@ func (m conversationsModel) Update(msg tea.Msg) (conversationsModel, tea.Cmd) {
|
|||||||
cmds = append(cmds, cmd)
|
cmds = append(cmds, cmd)
|
||||||
}
|
}
|
||||||
|
|
||||||
if m.width > 0 {
|
if m.Width > 0 {
|
||||||
m.views.header = m.headerView()
|
m.Header = m.headerView()
|
||||||
m.views.footer = "" // TODO: show /something/
|
m.Footer = "" // TODO: show /something/
|
||||||
m.views.error = errorBanner(m.err, m.width)
|
m.Error = tuiutil.ErrorBanner(m.Err, m.Width)
|
||||||
fixedHeight := height(m.views.header) + height(m.views.error) + height(m.views.footer)
|
fixedHeight := tuiutil.Height(m.Header) + tuiutil.Height(m.Error) + tuiutil.Height(m.Footer)
|
||||||
m.content.Height = m.height - fixedHeight
|
m.content.Height = m.Height - fixedHeight
|
||||||
m.views.content = m.content.View()
|
m.Content = m.content.View()
|
||||||
}
|
}
|
||||||
return m, tea.Batch(cmds...)
|
return m, tea.Batch(cmds...)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m *conversationsModel) loadConversations() tea.Cmd {
|
func (m *Model) loadConversations() tea.Cmd {
|
||||||
return func() tea.Msg {
|
return func() tea.Msg {
|
||||||
messages, err := m.ctx.Store.LatestConversationMessages()
|
messages, err := m.Ctx.Store.LatestConversationMessages()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return msgError(fmt.Errorf("Could not load conversations: %v", err))
|
return shared.MsgError(fmt.Errorf("Could not load conversations: %v", err))
|
||||||
}
|
}
|
||||||
|
|
||||||
loaded := make([]loadedConversation, len(messages))
|
loaded := make([]loadedConversation, len(messages))
|
||||||
@ -159,13 +162,35 @@ func (m *conversationsModel) loadConversations() tea.Cmd {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m *conversationsModel) headerView() string {
|
func (m Model) View() string {
|
||||||
titleStyle := lipgloss.NewStyle().Bold(true)
|
if m.Width == 0 {
|
||||||
header := titleStyle.Render("Conversations")
|
return ""
|
||||||
return headerStyle.Width(m.width).Render(header)
|
}
|
||||||
|
sections := make([]string, 0, 6)
|
||||||
|
|
||||||
|
if m.Header != "" {
|
||||||
|
sections = append(sections, m.Header)
|
||||||
|
}
|
||||||
|
|
||||||
|
sections = append(sections, m.Content)
|
||||||
|
if m.Error != "" {
|
||||||
|
sections = append(sections, m.Error)
|
||||||
|
}
|
||||||
|
|
||||||
|
if m.Footer != "" {
|
||||||
|
sections = append(sections, m.Footer)
|
||||||
|
}
|
||||||
|
|
||||||
|
return lipgloss.JoinVertical(lipgloss.Left, sections...)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m *conversationsModel) renderConversationList() string {
|
func (m *Model) headerView() string {
|
||||||
|
titleStyle := lipgloss.NewStyle().Bold(true)
|
||||||
|
header := titleStyle.Render("Conversations")
|
||||||
|
return styles.Header.Width(m.Width).Render(header)
|
||||||
|
}
|
||||||
|
|
||||||
|
func (m *Model) renderConversationList() string {
|
||||||
now := time.Now()
|
now := time.Now()
|
||||||
midnight := time.Date(now.Year(), now.Month(), now.Day(), 0, 0, 0, 0, now.Location())
|
midnight := time.Date(now.Year(), now.Month(), now.Day(), 0, 0, 0, 0, now.Location())
|
||||||
monthStart := time.Date(now.Year(), now.Month(), 1, 0, 0, 0, 0, now.Location())
|
monthStart := time.Date(now.Year(), now.Month(), 1, 0, 0, 0, 0, now.Location())
|
||||||
@ -228,7 +253,7 @@ func (m *conversationsModel) renderConversationList() string {
|
|||||||
currentCategory = category
|
currentCategory = category
|
||||||
heading := categoryStyle.Render(currentCategory)
|
heading := categoryStyle.Render(currentCategory)
|
||||||
sb.WriteString(heading)
|
sb.WriteString(heading)
|
||||||
currentOffset += height(heading)
|
currentOffset += tuiutil.Height(heading)
|
||||||
sb.WriteRune('\n')
|
sb.WriteRune('\n')
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -240,7 +265,7 @@ func (m *conversationsModel) renderConversationList() string {
|
|||||||
tStyle = tStyle.Inherit(selectedStyle)
|
tStyle = tStyle.Inherit(selectedStyle)
|
||||||
}
|
}
|
||||||
|
|
||||||
title := tStyle.Width(m.width - 3).PaddingLeft(2).Render(c.conv.Title)
|
title := tStyle.Width(m.Width - 3).PaddingLeft(2).Render(c.conv.Title)
|
||||||
if i == m.cursor {
|
if i == m.cursor {
|
||||||
title = ">" + title[1:]
|
title = ">" + title[1:]
|
||||||
}
|
}
|
||||||
@ -252,7 +277,7 @@ func (m *conversationsModel) renderConversationList() string {
|
|||||||
ageStyle.Render(util.HumanTimeElapsedSince(lastReplyAge)),
|
ageStyle.Render(util.HumanTimeElapsedSince(lastReplyAge)),
|
||||||
))
|
))
|
||||||
sb.WriteString(item)
|
sb.WriteString(item)
|
||||||
currentOffset += height(item)
|
currentOffset += tuiutil.Height(item)
|
||||||
if i < len(m.conversations)-1 {
|
if i < len(m.conversations)-1 {
|
||||||
sb.WriteRune('\n')
|
sb.WriteRune('\n')
|
||||||
}
|
}
|
Loading…
Reference in New Issue
Block a user