feature(api,ssh,pkg): add events to sessions

api/routes/routes.go

@@ -67,6 +67,7 @@ func NewRouter(service services.Service, opts ...Option) *echo.Echo {
 	internalAPI.GET(GetPublicKeyURL, gateway.Handler(handler.GetPublicKey))
 	internalAPI.POST(CreatePrivateKeyURL, gateway.Handler(handler.CreatePrivateKey))
 	internalAPI.POST(EvaluateKeyURL, gateway.Handler(handler.EvaluateKey))
+	internalAPI.POST(EventsSessionsURL, gateway.Handler(handler.EventSession))
 
 	// Public routes for external access through API gateway
 	publicAPI := e.Group("/api")

api/routes/session.go

@@ -19,6 +19,7 @@ const (
 	KeepAliveSessionURL = "/sessions/:uid/keepalive"
 	RecordSessionURL    = "/sessions/:uid/record"
 	PlaySessionURL      = "/sessions/:uid/play"
+	EventsSessionsURL   = "/sessions/:uid/events"
 )
 
 const (
@@ -133,3 +134,20 @@ func (h *Handler) PlaySession(c gateway.Context) error {
 func (h *Handler) DeleteRecordedSession(c gateway.Context) error {
 	return c.NoContent(http.StatusOK)
 }
+
+func (h *Handler) EventSession(c gateway.Context) error {
+	var req requests.SessionEvent
+	if err := c.Bind(&req); err != nil {
+		return err
+	}
+
+	if err := c.Validate(&req); err != nil {
+		return err
+	}
+
+	return h.service.EventSession(c.Ctx(), models.UID(req.UID), &models.SessionEvent{
+		Type:      req.Type,
+		Timestamp: req.Timestamp,
+		Data:      req.Data,
+	})
+}