1package tui
  2
  3import (
  4	"context"
  5	"fmt"
  6
  7	"github.com/charmbracelet/bubbles/v2/key"
  8	tea "github.com/charmbracelet/bubbletea/v2"
  9	"github.com/charmbracelet/crush/internal/app"
 10	"github.com/charmbracelet/crush/internal/config"
 11	"github.com/charmbracelet/crush/internal/llm/agent"
 12	"github.com/charmbracelet/crush/internal/permission"
 13	"github.com/charmbracelet/crush/internal/pubsub"
 14	cmpChat "github.com/charmbracelet/crush/internal/tui/components/chat"
 15	"github.com/charmbracelet/crush/internal/tui/components/completions"
 16	"github.com/charmbracelet/crush/internal/tui/components/core"
 17	"github.com/charmbracelet/crush/internal/tui/components/core/layout"
 18	"github.com/charmbracelet/crush/internal/tui/components/core/status"
 19	"github.com/charmbracelet/crush/internal/tui/components/dialogs"
 20	"github.com/charmbracelet/crush/internal/tui/components/dialogs/commands"
 21	"github.com/charmbracelet/crush/internal/tui/components/dialogs/compact"
 22	"github.com/charmbracelet/crush/internal/tui/components/dialogs/filepicker"
 23	"github.com/charmbracelet/crush/internal/tui/components/dialogs/models"
 24	"github.com/charmbracelet/crush/internal/tui/components/dialogs/permissions"
 25	"github.com/charmbracelet/crush/internal/tui/components/dialogs/quit"
 26	"github.com/charmbracelet/crush/internal/tui/components/dialogs/sessions"
 27	"github.com/charmbracelet/crush/internal/tui/page"
 28	"github.com/charmbracelet/crush/internal/tui/page/chat"
 29	"github.com/charmbracelet/crush/internal/tui/styles"
 30	"github.com/charmbracelet/crush/internal/tui/util"
 31	"github.com/charmbracelet/lipgloss/v2"
 32)
 33
 34// appModel represents the main application model that manages pages, dialogs, and UI state.
 35type appModel struct {
 36	wWidth, wHeight int // Window dimensions
 37	width, height   int
 38	keyMap          KeyMap
 39
 40	currentPage  page.PageID
 41	previousPage page.PageID
 42	pages        map[page.PageID]util.Model
 43	loadedPages  map[page.PageID]bool
 44
 45	// Status
 46	status          status.StatusCmp
 47	showingFullHelp bool
 48
 49	app *app.App
 50
 51	dialog      dialogs.DialogCmp
 52	completions completions.Completions
 53
 54	// Chat Page Specific
 55	selectedSessionID string // The ID of the currently selected session
 56}
 57
 58// Init initializes the application model and returns initial commands.
 59func (a appModel) Init() tea.Cmd {
 60	var cmds []tea.Cmd
 61	cmd := a.pages[a.currentPage].Init()
 62	cmds = append(cmds, cmd)
 63	a.loadedPages[a.currentPage] = true
 64
 65	cmd = a.status.Init()
 66	cmds = append(cmds, cmd)
 67
 68	return tea.Batch(cmds...)
 69}
 70
 71// Update handles incoming messages and updates the application state.
 72func (a *appModel) Update(msg tea.Msg) (tea.Model, tea.Cmd) {
 73	var cmds []tea.Cmd
 74	var cmd tea.Cmd
 75
 76	switch msg := msg.(type) {
 77	case tea.KeyboardEnhancementsMsg:
 78		for id, page := range a.pages {
 79			m, pageCmd := page.Update(msg)
 80			a.pages[id] = m.(util.Model)
 81			if pageCmd != nil {
 82				cmds = append(cmds, pageCmd)
 83			}
 84		}
 85		return a, tea.Batch(cmds...)
 86	case tea.WindowSizeMsg:
 87		a.completions.Update(msg)
 88		return a, a.handleWindowResize(msg.Width, msg.Height)
 89
 90	// Completions messages
 91	case completions.OpenCompletionsMsg, completions.FilterCompletionsMsg, completions.CloseCompletionsMsg:
 92		u, completionCmd := a.completions.Update(msg)
 93		a.completions = u.(completions.Completions)
 94		switch msg := msg.(type) {
 95		case completions.OpenCompletionsMsg:
 96			x, _ := a.completions.Position()
 97			if a.completions.Width()+x >= a.wWidth {
 98				// Adjust X position to fit in the window.
 99				msg.X = a.wWidth - a.completions.Width() - 1
100				u, completionCmd = a.completions.Update(msg)
101				a.completions = u.(completions.Completions)
102			}
103		}
104		return a, completionCmd
105
106	// Dialog messages
107	case dialogs.OpenDialogMsg, dialogs.CloseDialogMsg:
108		u, completionCmd := a.completions.Update(completions.CloseCompletionsMsg{})
109		a.completions = u.(completions.Completions)
110		u, dialogCmd := a.dialog.Update(msg)
111		a.dialog = u.(dialogs.DialogCmp)
112		return a, tea.Batch(completionCmd, dialogCmd)
113	case commands.ShowArgumentsDialogMsg:
114		return a, util.CmdHandler(
115			dialogs.OpenDialogMsg{
116				Model: commands.NewCommandArgumentsDialog(
117					msg.CommandID,
118					msg.Content,
119					msg.ArgNames,
120				),
121			},
122		)
123	// Page change messages
124	case page.PageChangeMsg:
125		return a, a.moveToPage(msg.ID)
126
127	// Status Messages
128	case util.InfoMsg, util.ClearStatusMsg:
129		s, statusCmd := a.status.Update(msg)
130		a.status = s.(status.StatusCmp)
131		cmds = append(cmds, statusCmd)
132		return a, tea.Batch(cmds...)
133
134	// Session
135	case cmpChat.SessionSelectedMsg:
136		a.selectedSessionID = msg.ID
137	case cmpChat.SessionDeletedMsg:
138		err := a.app.Sessions.Delete(context.Background(), msg.Session.ID)
139		if err != nil {
140			return a, util.ReportError(err)
141		}
142
143		if msg.Session.ID == a.selectedSessionID {
144			a.selectedSessionID = ""
145		}
146
147		return a, util.CmdHandler(dialogs.CloseDialogMsg{})
148	case cmpChat.SessionClearedMsg:
149		a.selectedSessionID = ""
150	// Commands
151	case commands.SwitchSessionsMsg:
152		return a, func() tea.Msg {
153			allSessions, _ := a.app.Sessions.List(context.Background())
154			return dialogs.OpenDialogMsg{
155				Model: sessions.NewSessionDialogCmp(allSessions, a.selectedSessionID),
156			}
157		}
158
159	case commands.SwitchModelMsg:
160		return a, util.CmdHandler(
161			dialogs.OpenDialogMsg{
162				Model: models.NewModelDialogCmp(),
163			},
164		)
165	// Compact
166	case commands.CompactMsg:
167		return a, util.CmdHandler(dialogs.OpenDialogMsg{
168			Model: compact.NewCompactDialogCmp(a.app.CoderAgent, msg.SessionID, true),
169		})
170
171	// Model Switch
172	case models.ModelSelectedMsg:
173		config.Get().UpdatePreferredModel(msg.ModelType, msg.Model)
174
175		// Update the agent with the new model/provider configuration
176		if err := a.app.UpdateAgentModel(); err != nil {
177			return a, util.ReportError(fmt.Errorf("model changed to %s but failed to update agent: %v", msg.Model.Model, err))
178		}
179
180		modelTypeName := "large"
181		if msg.ModelType == config.SelectedModelTypeSmall {
182			modelTypeName = "small"
183		}
184		return a, util.ReportInfo(fmt.Sprintf("%s model changed to %s", modelTypeName, msg.Model.Model))
185
186	// File Picker
187	case chat.OpenFilePickerMsg:
188		if a.dialog.ActiveDialogID() == filepicker.FilePickerID {
189			// If the commands dialog is already open, close it
190			return a, util.CmdHandler(dialogs.CloseDialogMsg{})
191		}
192		return a, util.CmdHandler(dialogs.OpenDialogMsg{
193			Model: filepicker.NewFilePickerCmp(a.app.Config().WorkingDir()),
194		})
195	// Permissions
196	case pubsub.Event[permission.PermissionRequest]:
197		return a, util.CmdHandler(dialogs.OpenDialogMsg{
198			Model: permissions.NewPermissionDialogCmp(msg.Payload),
199		})
200	case permissions.PermissionResponseMsg:
201		switch msg.Action {
202		case permissions.PermissionAllow:
203			a.app.Permissions.Grant(msg.Permission)
204		case permissions.PermissionAllowForSession:
205			a.app.Permissions.GrantPersistent(msg.Permission)
206		case permissions.PermissionDeny:
207			a.app.Permissions.Deny(msg.Permission)
208		}
209		return a, nil
210	// Agent Events
211	case pubsub.Event[agent.AgentEvent]:
212		payload := msg.Payload
213
214		// Forward agent events to dialogs
215		if a.dialog.HasDialogs() && a.dialog.ActiveDialogID() == compact.CompactDialogID {
216			u, dialogCmd := a.dialog.Update(payload)
217			a.dialog = u.(dialogs.DialogCmp)
218			cmds = append(cmds, dialogCmd)
219		}
220
221		// Handle auto-compact logic
222		if payload.Done && payload.Type == agent.AgentEventTypeResponse && a.selectedSessionID != "" {
223			// Get current session to check token usage
224			session, err := a.app.Sessions.Get(context.Background(), a.selectedSessionID)
225			if err == nil {
226				model := a.app.CoderAgent.Model()
227				contextWindow := model.ContextWindow
228				tokens := session.CompletionTokens + session.PromptTokens
229				if (tokens >= int64(float64(contextWindow)*0.95)) && !config.Get().Options.DisableAutoSummarize { // Show compact confirmation dialog
230					cmds = append(cmds, util.CmdHandler(dialogs.OpenDialogMsg{
231						Model: compact.NewCompactDialogCmp(a.app.CoderAgent, a.selectedSessionID, false),
232					}))
233				}
234			}
235		}
236
237		return a, tea.Batch(cmds...)
238	// Key Press Messages
239	case tea.KeyPressMsg:
240		return a, a.handleKeyPressMsg(msg)
241	}
242	s, _ := a.status.Update(msg)
243	a.status = s.(status.StatusCmp)
244	updated, cmd := a.pages[a.currentPage].Update(msg)
245	a.pages[a.currentPage] = updated.(util.Model)
246	if a.dialog.HasDialogs() {
247		u, dialogCmd := a.dialog.Update(msg)
248		a.dialog = u.(dialogs.DialogCmp)
249		cmds = append(cmds, dialogCmd)
250	}
251	cmds = append(cmds, cmd)
252	return a, tea.Batch(cmds...)
253}
254
255// handleWindowResize processes window resize events and updates all components.
256func (a *appModel) handleWindowResize(width, height int) tea.Cmd {
257	var cmds []tea.Cmd
258	a.wWidth, a.wHeight = width, height
259	if a.showingFullHelp {
260		height -= 5
261	} else {
262		height -= 2
263	}
264	a.width, a.height = width, height
265	// Update status bar
266	s, cmd := a.status.Update(tea.WindowSizeMsg{Width: width, Height: height})
267	a.status = s.(status.StatusCmp)
268	cmds = append(cmds, cmd)
269
270	// Update the current page
271	for p, page := range a.pages {
272		updated, pageCmd := page.Update(tea.WindowSizeMsg{Width: width, Height: height})
273		a.pages[p] = updated.(util.Model)
274		cmds = append(cmds, pageCmd)
275	}
276
277	// Update the dialogs
278	dialog, cmd := a.dialog.Update(tea.WindowSizeMsg{Width: width, Height: height})
279	a.dialog = dialog.(dialogs.DialogCmp)
280	cmds = append(cmds, cmd)
281
282	return tea.Batch(cmds...)
283}
284
285// handleKeyPressMsg processes keyboard input and routes to appropriate handlers.
286func (a *appModel) handleKeyPressMsg(msg tea.KeyPressMsg) tea.Cmd {
287	switch {
288	// completions
289	case a.completions.Open() && key.Matches(msg, a.completions.KeyMap().Up):
290		u, cmd := a.completions.Update(msg)
291		a.completions = u.(completions.Completions)
292		return cmd
293
294	case a.completions.Open() && key.Matches(msg, a.completions.KeyMap().Down):
295		u, cmd := a.completions.Update(msg)
296		a.completions = u.(completions.Completions)
297		return cmd
298	case a.completions.Open() && key.Matches(msg, a.completions.KeyMap().Select):
299		u, cmd := a.completions.Update(msg)
300		a.completions = u.(completions.Completions)
301		return cmd
302	case a.completions.Open() && key.Matches(msg, a.completions.KeyMap().Cancel):
303		u, cmd := a.completions.Update(msg)
304		a.completions = u.(completions.Completions)
305		return cmd
306		// help
307	case key.Matches(msg, a.keyMap.Help):
308		a.status.ToggleFullHelp()
309		a.showingFullHelp = !a.showingFullHelp
310		return a.handleWindowResize(a.wWidth, a.wHeight)
311	// dialogs
312	case key.Matches(msg, a.keyMap.Quit):
313		if a.dialog.ActiveDialogID() == quit.QuitDialogID {
314			return tea.Quit
315		}
316		return util.CmdHandler(dialogs.OpenDialogMsg{
317			Model: quit.NewQuitDialog(),
318		})
319
320	case key.Matches(msg, a.keyMap.Commands):
321		if a.dialog.ActiveDialogID() == commands.CommandsDialogID {
322			return util.CmdHandler(dialogs.CloseDialogMsg{})
323		}
324		if a.dialog.HasDialogs() {
325			return nil
326		}
327		return util.CmdHandler(dialogs.OpenDialogMsg{
328			Model: commands.NewCommandDialog(a.selectedSessionID),
329		})
330	case key.Matches(msg, a.keyMap.Sessions):
331		if a.dialog.ActiveDialogID() == sessions.SessionsDialogID {
332			return util.CmdHandler(dialogs.CloseDialogMsg{})
333		}
334		if a.dialog.HasDialogs() && a.dialog.ActiveDialogID() != commands.CommandsDialogID {
335			return nil
336		}
337		var cmds []tea.Cmd
338		if a.dialog.ActiveDialogID() == commands.CommandsDialogID {
339			// If the commands dialog is open, close it first
340			cmds = append(cmds, util.CmdHandler(dialogs.CloseDialogMsg{}))
341		}
342		cmds = append(cmds,
343			func() tea.Msg {
344				allSessions, _ := a.app.Sessions.List(context.Background())
345				return dialogs.OpenDialogMsg{
346					Model: sessions.NewSessionDialogCmp(allSessions, a.selectedSessionID),
347				}
348			},
349		)
350		return tea.Sequence(cmds...)
351	default:
352		if a.dialog.HasDialogs() {
353			u, dialogCmd := a.dialog.Update(msg)
354			a.dialog = u.(dialogs.DialogCmp)
355			return dialogCmd
356		} else {
357			updated, cmd := a.pages[a.currentPage].Update(msg)
358			a.pages[a.currentPage] = updated.(util.Model)
359			return cmd
360		}
361	}
362}
363
364// moveToPage handles navigation between different pages in the application.
365func (a *appModel) moveToPage(pageID page.PageID) tea.Cmd {
366	if a.app.CoderAgent.IsBusy() {
367		// TODO: maybe remove this :  For now we don't move to any page if the agent is busy
368		return util.ReportWarn("Agent is busy, please wait...")
369	}
370
371	var cmds []tea.Cmd
372	if _, ok := a.loadedPages[pageID]; !ok {
373		cmd := a.pages[pageID].Init()
374		cmds = append(cmds, cmd)
375		a.loadedPages[pageID] = true
376	}
377	a.previousPage = a.currentPage
378	a.currentPage = pageID
379	if sizable, ok := a.pages[a.currentPage].(layout.Sizeable); ok {
380		cmd := sizable.SetSize(a.width, a.height)
381		cmds = append(cmds, cmd)
382	}
383
384	return tea.Batch(cmds...)
385}
386
387// View renders the complete application interface including pages, dialogs, and overlays.
388func (a *appModel) View() tea.View {
389	page := a.pages[a.currentPage]
390	if withHelp, ok := page.(core.KeyMapHelp); ok {
391		a.status.SetKeyMap(withHelp.Help())
392	}
393	pageView := page.View()
394	components := []string{
395		pageView,
396	}
397	components = append(components, a.status.View())
398
399	appView := lipgloss.JoinVertical(lipgloss.Top, components...)
400	layers := []*lipgloss.Layer{
401		lipgloss.NewLayer(appView),
402	}
403	if a.dialog.HasDialogs() {
404		layers = append(
405			layers,
406			a.dialog.GetLayers()...,
407		)
408	}
409
410	var cursor *tea.Cursor
411	if v, ok := page.(util.Cursor); ok {
412		cursor = v.Cursor()
413	}
414	activeView := a.dialog.ActiveModel()
415	if activeView != nil {
416		cursor = nil // Reset cursor if a dialog is active unless it implements util.Cursor
417		if v, ok := activeView.(util.Cursor); ok {
418			cursor = v.Cursor()
419		}
420	}
421
422	if a.completions.Open() && cursor != nil {
423		cmp := a.completions.View()
424		x, y := a.completions.Position()
425		layers = append(
426			layers,
427			lipgloss.NewLayer(cmp).X(x).Y(y),
428		)
429	}
430
431	canvas := lipgloss.NewCanvas(
432		layers...,
433	)
434
435	var view tea.View
436	t := styles.CurrentTheme()
437	view.Layer = canvas
438	view.BackgroundColor = t.BgBase
439	view.Cursor = cursor
440	return view
441}
442
443// New creates and initializes a new TUI application model.
444func New(app *app.App) tea.Model {
445	chatPage := chat.New(app)
446	keyMap := DefaultKeyMap()
447	keyMap.pageBindings = chatPage.Bindings()
448
449	model := &appModel{
450		currentPage: chat.ChatPageID,
451		app:         app,
452		status:      status.NewStatusCmp(),
453		loadedPages: make(map[page.PageID]bool),
454		keyMap:      keyMap,
455
456		pages: map[page.PageID]util.Model{
457			chat.ChatPageID: chatPage,
458		},
459
460		dialog:      dialogs.NewDialogCmp(),
461		completions: completions.New(),
462	}
463
464	return model
465}