session_tab_memory.go RawHistoryFolder

1package client
2
3import (
4	"sync"
5
6	"github.com/bnema/vev/internal/domain"
7	"github.com/bnema/vev/internal/protocol"
8)
9
10// sessionTabMemory belongs to one client process and survives attachment swaps.
11// Authority and lifecycle identity prevent unrelated hosts or recreated sessions
12// from inheriting a selection. Only committed views update the memory.
13type sessionTabMemory struct {
14	mu   sync.Mutex
15	tabs map[sessionTabKey]domain.TabStableID
16}
17
18type sessionTabKey struct {
19	authority routeAuthority
20	target    protocol.ExactSessionTarget
21}
22
23func (m *sessionTabMemory) remember(authority routeAuthority, target protocol.ExactSessionTarget, tab domain.TabStableID) {
24	if m == nil || target.Validate() != nil || domain.ValidateTabStableID(tab) != nil {
25		return
26	}
27	m.mu.Lock()
28	defer m.mu.Unlock()
29	if m.tabs == nil {
30		m.tabs = make(map[sessionTabKey]domain.TabStableID)
31	}
32	key := sessionTabKey{authority: authority, target: target}
33	if previous, known := m.tabs[key]; known {
34		if previous != tab {
35			m.tabs[key] = tab
36		}
37		return
38	}
39	// Reclaim obsolete lifecycles only on the first view of a session.
40	// The exact key, not this cleanup, isolates recreated sessions.
41	for old := range m.tabs {
42		if old.authority == authority && old.target.SessionName == target.SessionName {
43			delete(m.tabs, old)
44		}
45	}
46	m.tabs[key] = tab
47}
48
49func (m *sessionTabMemory) preferred(authority routeAuthority, target protocol.ExactSessionTarget, explicit domain.TabStableID) domain.TabStableID {
50	if explicit != "" || m == nil {
51		return explicit
52	}
53	m.mu.Lock()
54	defer m.mu.Unlock()
55	return m.tabs[sessionTabKey{authority: authority, target: target}]
56}