bus

type Bus struct {
	// contains filtered or unexported fields
}

type Config struct {
	Mode        string // "embedded" or "external"
	URL         string // NATS URL, used when Mode == "external"
	DataDir     string // JetStream storage directory (empty = auto)
	SessionName string // used to isolate data dirs per session
	// Port is the TCP port for the embedded NATS server. 0 means
	// kernel-assigned: a private server on a free port, never a probe of an
	// existing one. The 24242 default belongs to config, not to this package —
	// defaulting here is what once sent `port: 0` test daemons into the
	// developer's live NATS.
	Port int
	// Attach marks a client of a session some other process owns — the TUI of
	// `rysh attach`. The owning daemon has already declared every bucket, so an
	// attaching Bus looks them up instead: one StreamInfo per bucket rather than
	// an AccountInfo plus a stream create. A slow shared server used to fail
	// attach outright at "create rysh-workspace-<session> KV: context deadline
	// exceeded" while the daemon itself was fine.
	Attach bool
	// Workspace is this daemon's project root (the session record's Path). A
	// guest compares it with the host's; an owner answers it on
	// HostIdentitySubject. Design 028 §9 limit 7.
	Workspace string
	// HostQueryTimeout bounds a guest's question to the host daemon (0 = 300ms).
	HostQueryTimeout time.Duration
	// Logger receives the guest/host identity lines (nil = slog.Default()).
	Logger *slog.Logger
}

type GuestOf struct {
	ServerID      string `json:"server_id"`
	ServerName    string `json:"server_name,omitempty"`
	Port          int    `json:"port"`
	HostSession   string `json:"host_session"`             // "unknown" when the host did not answer
	HostWorkspace string `json:"host_workspace,omitempty"` // likewise; omitted from the public view
	HostPID       int    `json:"host_pid,omitempty"`
	UnknownReason string `json:"unknown_reason,omitempty"`
	Pending       bool   `json:"pending,omitempty"` // the host query is still in flight
	// Mismatch is the WARN-worthy case: the host belongs to another WORKSPACE
	// (ORDER-13, root-0273). Warning is set with it, and only with it.
	Mismatch bool `json:"mismatch"`
	// SessionMismatch / WorkspaceMismatch say exactly what differs. A host that
	// is another session of the SAME workspace (the desktop sidecar's daemon
	// under its own session name) is recorded in Note, at INFO, not warned.
	SessionMismatch   bool   `json:"session_mismatch"`
	WorkspaceMismatch bool   `json:"workspace_mismatch"`
	Note              string `json:"note,omitempty"`
	Warning           string `json:"warning,omitempty"`
}

type HostIdentity struct {
	Session   string `json:"session"`
	Workspace string `json:"workspace"`
	PID       int    `json:"pid"`
}