alexei.dolgolyov
410a131cec
This session (frontend focus):
- Rebuild /apps/new as a 4-step wizard (Basics → Configure → Trigger → Review):
WizardRail, SourceKindPicker card grid, AppManifest review, per-step validation,
ConfirmDialog-based unsaved-changes guard.
- Extract lib/workload/sourceForms.ts (single source of truth for source_config)
+ {Image,Compose,Static,Dockerfile}SourceForm + StaticDiscoveryWizard; fold the
/apps/[id] edit form onto the same components (removes the duplication). Add
vitest + sourceForms unit tests.
- Branch preview environments UI: /chain is_preview/preview_branch + a Preview
environments panel on /apps/[id] (per-branch URLs, ConfirmDialog teardown, armed
state); RegistryImagePicker on the registry trigger and the image source.
- Fixes: image-inspect 404 -> admin-gated POST /api/discovery/image/inspect;
conflict-panel blur flicker; friendly localized discovery errors; CPU/Memory
label hints; dashboard + /apps "Total workloads" count only source_kind workloads
(drop stale trigger_kind gate); NPM cert/access-list name cache; EntityPicker
empty-list guard.
- Update CLAUDE.md frontend conventions + add a Build & Test section.
Also captures pre-existing in-progress platform work (not from this session):
workload notifications, Prometheus metrics export, store lockfile, health probes,
backup hardening, and related store/webhook/scheduler changes.
90 lines
2.4 KiB
Go
90 lines
2.4 KiB
Go
package api
|
|
|
|
import (
|
|
"encoding/json"
|
|
"fmt"
|
|
"log/slog"
|
|
"net/http"
|
|
"time"
|
|
|
|
"github.com/alexei/tinyforge/internal/events"
|
|
)
|
|
|
|
// streamEvents handles GET /api/events.
|
|
// It streams instance status changes and deploy status changes via SSE.
|
|
func (s *Server) streamEvents(w http.ResponseWriter, r *http.Request) {
|
|
release, ok := acquireSSESlot(w, s.sseGate)
|
|
if !ok {
|
|
return
|
|
}
|
|
defer release()
|
|
|
|
flusher, ok := w.(http.Flusher)
|
|
if !ok {
|
|
respondError(w, http.StatusInternalServerError, "streaming not supported")
|
|
return
|
|
}
|
|
|
|
w.Header().Set("Content-Type", "text/event-stream")
|
|
w.Header().Set("Cache-Control", "no-cache")
|
|
w.Header().Set("Connection", "keep-alive")
|
|
w.Header().Set("X-Accel-Buffering", "no")
|
|
w.WriteHeader(http.StatusOK)
|
|
flusher.Flush()
|
|
|
|
// Build logs are high-volume: a single verbose `docker build` can emit
|
|
// thousands of lines. Streaming them to EVERY connection would flood each
|
|
// subscriber's bounded bus buffer and evict status/log events for ALL
|
|
// clients. So build logs are delivered ONLY to connections that opt in
|
|
// with ?workload_id=<id>, and only for that workload. Connections without
|
|
// the param (e.g. the global dashboard) never receive build-log frames.
|
|
buildLogWorkloadID := r.URL.Query().Get("workload_id")
|
|
sub := s.eventBus.Subscribe(func(evt events.Event) bool {
|
|
switch evt.Type {
|
|
case events.EventInstanceStatus, events.EventDeployStatus, events.EventLog:
|
|
return true
|
|
case events.EventBuildLog:
|
|
if buildLogWorkloadID == "" {
|
|
return false
|
|
}
|
|
p, ok := evt.Payload.(events.BuildLogPayload)
|
|
return ok && p.WorkloadID == buildLogWorkloadID
|
|
default:
|
|
return false
|
|
}
|
|
})
|
|
defer s.eventBus.Unsubscribe(sub)
|
|
|
|
// Periodic heartbeat so the browser detects dead connections.
|
|
heartbeat := time.NewTicker(30 * time.Second)
|
|
defer heartbeat.Stop()
|
|
|
|
ctx := r.Context()
|
|
for {
|
|
select {
|
|
case <-ctx.Done():
|
|
return
|
|
case evt, ok := <-sub:
|
|
if !ok {
|
|
return
|
|
}
|
|
writeSSE(w, flusher, evt)
|
|
case <-heartbeat.C:
|
|
// SSE comment line — keeps the connection alive without triggering onmessage.
|
|
fmt.Fprintf(w, ": heartbeat\n\n")
|
|
flusher.Flush()
|
|
}
|
|
}
|
|
}
|
|
|
|
// writeSSE writes a single SSE event to the response writer and flushes.
|
|
func writeSSE(w http.ResponseWriter, flusher http.Flusher, evt events.Event) {
|
|
data, err := json.Marshal(evt)
|
|
if err != nil {
|
|
slog.Error("marshal SSE event", "error", err)
|
|
return
|
|
}
|
|
fmt.Fprintf(w, "data: %s\n\n", data)
|
|
flusher.Flush()
|
|
}
|