v2

type Dispatcher ¶

type Dispatcher interface {
	Dispatch(context.Context, pluginhost.DispatchInput) (pluginhost.DispatchOutput, error)
}

type Envelope ¶

type Envelope string

const (
	EnvelopeData      Envelope = "data"
	EnvelopePanel     Envelope = "panel"
	EnvelopeRaw       Envelope = "raw"
	EnvelopeWebSocket Envelope = "websocket"
)

type Gateway ¶

type Gateway struct {
	Registry         *Registry
	Dispatcher       Dispatcher
	Timeout          time.Duration
	RequestBodyLimit int64
}

Gateway is the unary v2 compatibility boundary. It has no legacy handler fallback: a route must resolve from an active, verified package artifact.

func (g Gateway) Serve(c *gin.Context)

type Registry ¶

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

func NewRegistry(source RouteSource) *Registry

func (r *Registry) Resolve(method, normalizedPath string) (Route, bool)

func (r *Registry) ResolveContext(ctx context.Context, method, requestPath string) (Route, error)

type Route ¶

type Route struct {
	Method       string
	LegacyPath   string
	PackageID    string
	Version      string
	PackageRoute string
	Envelope     Envelope
	Generation   uint64
	Transport    Transport
}

Route is a request-time route authorization bound to one verified package release and one running installation generation.

func (r Route) Validate() error

type RouteSource ¶

type RouteSource interface {
	ResolveV2Route(context.Context, string, string) (Route, error)
}

RouteSource performs the trusted, request-time route lookup.

func NewVerifiedRouteSource(db *gorm.DB, encodedPublicKey string) RouteSource

type Transport ¶

type Transport string

const (
	TransportHTTP      Transport = "http"
	TransportWebSocket Transport = "websocket"
)

type WebSocketGateway ¶

type WebSocketGateway struct {
	Registry       *Registry
	Dispatcher     pluginhost.WebSocketManager
	Timeout        time.Duration
	SessionTimeout time.Duration
	Upgrade        WebSocketUpgrade
}

WebSocketGateway resolves and opens a package relay before accepting the browser upgrade. Legacy socket handlers are intentionally not reachable.

func (g WebSocketGateway) Serve(c *gin.Context)

func (g WebSocketGateway) ServeHTTP(writer http.ResponseWriter, request *http.Request)

type WebSocketUpgrade ¶

type WebSocketUpgrade func(http.ResponseWriter, *http.Request, http.Header) (*websocket.Conn, error)