wire.go RawHistoryFolder

1// Package daemon holds vev's server-side session multiplexer use case.
2package daemon
3
4import (
5	"github.com/bnema/vev/internal/domain"
6	"github.com/bnema/vev/internal/protocol"
7)
8
9func serverWelcome(s *session, resumeToken uint64) (protocol.Welcome, error) {
10	s.mu.Lock()
11	var identity *protocol.CommittedRouteIdentity
12	if s.incarnation != (domain.SessionLifecycleID{}) {
13		identity = &protocol.CommittedRouteIdentity{
14			Target:    protocol.ExactSessionTarget{LifecycleID: s.incarnation, SessionName: s.name},
15			Ephemeral: s.ephemeral,
16		}
17	}
18	message := protocol.Welcome{
19		SessionID:         string(s.id),
20		SessionName:       s.name,
21		Ephemeral:         s.ephemeral,
22		Capabilities:      protocol.CapabilityResume,
23		CommittedIdentity: identity,
24	}
25	s.mu.Unlock()
26	message.ResumeToken = resumeToken
27	if identity != nil {
28		if err := identity.Validate(); err != nil {
29			return protocol.Welcome{}, err
30		}
31	}
32	return message, nil
33}
34
35func serverError(code uint16, text string) protocol.ErrorMsg {
36	return protocol.ErrorMsg{Code: code, Text: text}
37}
38
39func serverDetached(reason uint8) protocol.Detached { return protocol.Detached{Reason: reason} }
40func serverPong() protocol.Pong                     { return protocol.Pong{} }
41func serverSessions(infos []protocol.SessionInfo) protocol.Sessions {
42	return protocol.Sessions{Sessions: infos}
43}