fix: SFTP auto-refresh after file transfer
- Added program *tea.Program to SFTPBrowserTab and Model
- SetProgram() allows goroutines to send messages to Bubble Tea
- After transfer: program.Send(sftpRefreshMsg{}) triggers re-render
- Model stores program reference, passes to SFTP tab on creation
This commit is contained in:
@@ -69,6 +69,8 @@ type SFTPBrowserTab struct {
|
||||
transferring bool
|
||||
transferMsg string
|
||||
|
||||
program *tea.Program
|
||||
|
||||
mu sync.Mutex
|
||||
closeOnce sync.Once
|
||||
}
|
||||
@@ -98,6 +100,10 @@ func NewSFTPBrowserTab(host *models.Host, dataDir string) *SFTPBrowserTab {
|
||||
|
||||
func (t *SFTPBrowserTab) Name() string { return "SFTP: " + t.host.Name }
|
||||
|
||||
func (t *SFTPBrowserTab) SetProgram(p *tea.Program) {
|
||||
t.program = p
|
||||
}
|
||||
|
||||
func (t *SFTPBrowserTab) Init() tea.Cmd {
|
||||
go t.connect()
|
||||
go t.refreshLocal()
|
||||
@@ -497,11 +503,21 @@ func (t *SFTPBrowserTab) copyFile(srcType, dstType paneType, srcPath, dstPath, n
|
||||
t.refreshLocal()
|
||||
}
|
||||
|
||||
// Trigger re-render in Bubble Tea
|
||||
if t.program != nil {
|
||||
t.program.Send(sftpRefreshMsg{})
|
||||
}
|
||||
|
||||
// Clear success message after brief delay
|
||||
time.Sleep(1 * time.Second)
|
||||
t.mu.Lock()
|
||||
t.transferMsg = ""
|
||||
t.mu.Unlock()
|
||||
|
||||
// Trigger re-render again after clearing message
|
||||
if t.program != nil {
|
||||
t.program.Send(sftpRefreshMsg{})
|
||||
}
|
||||
}
|
||||
|
||||
func downloadFile(client *sftp.Client, remotePath, localPath string, progressFn func(int64)) error {
|
||||
|
||||
@@ -27,6 +27,7 @@ type Model struct {
|
||||
Error error
|
||||
Quit bool
|
||||
dataDir string
|
||||
program *tea.Program
|
||||
}
|
||||
|
||||
// New creates a new TUI model
|
||||
@@ -47,6 +48,11 @@ func (m *Model) Init() tea.Cmd {
|
||||
return m.tabs.Init()
|
||||
}
|
||||
|
||||
// SetProgram stores a reference to the tea.Program for sending messages from goroutines
|
||||
func (m *Model) SetProgram(p *tea.Program) {
|
||||
m.program = p
|
||||
}
|
||||
|
||||
// Update handles messages and updates the model
|
||||
func (m *Model) Update(msg tea.Msg) (tea.Model, tea.Cmd) {
|
||||
switch msg := msg.(type) {
|
||||
@@ -82,6 +88,9 @@ func (m *Model) Update(msg tea.Msg) (tea.Model, tea.Cmd) {
|
||||
|
||||
case openSFTPMsg:
|
||||
tab := NewSFTPBrowserTab(msg.host, m.dataDir)
|
||||
if m.program != nil {
|
||||
tab.SetProgram(m.program)
|
||||
}
|
||||
cmd := m.tabs.Add(tab)
|
||||
return m, cmd
|
||||
|
||||
|
||||
Reference in New Issue
Block a user