-
-
Services
-
{{.TotalServices}}
-
-
-
Healthy
-
{{.HealthyCount}}
-
-
-
Errors
-
{{.ErrorCount}}
-
+
+
+ ReleaseWave
+ Last updated: {{.UpdatedAt}}
+
+
+
+ {{/* Stats cards — polled every 30s */}}
+
+ {{template "stats" .}}
- {{if .Services}}
-
-
-
- | Status |
- Service |
- Platform |
- Latest Version |
- Released |
- Link |
-
-
-
- {{range .Services}}
-
- |
- {{if .Error}}
-
- {{else}}
-
- {{end}}
- |
- {{.Name}} |
-
- {{.Platform}}
- |
-
- {{if .Error}}
- {{.Error}}
- {{else}}
- {{.LatestTag}}
- {{end}}
- |
- {{.ReleasedAt}} |
-
- {{if .URL}}
- View
- {{end}}
- |
-
- {{end}}
-
-
- {{else}}
-
-
No services configured.
-
Add services to ~/.config/releasewave/config.yaml
+ {{/* Add service form */}}
+
- {{end}}
-
+ {{template "services" .}}
+
+
+
+
+
+{{define "stats"}}
+
+
+
Services
+
{{.TotalServices}}
+
+
+
Healthy
+
{{.HealthyCount}}
+
+
+
Errors
+
{{.ErrorCount}}
+
+
+{{end}}
+
+{{define "services"}}
+{{if .Services}}
+
+
+
+
+ | Status |
+ Service |
+ Platform |
+ Latest Version |
+ Released |
+ Actions |
+
+
+
+ {{range .Services}}
+
+ |
+ {{if .Error}}
+
+ {{else}}
+
+ {{end}}
+ |
+ {{.Name}} |
+
+ {{.Platform}}
+ |
+
+ {{if .Error}}
+ {{.Error}}
+ {{else}}
+ {{.LatestTag}}
+ {{end}}
+ |
+ {{.ReleasedAt}} |
+
+ {{if .URL}}
+ View
+ {{end}}
+
+ |
+
+ {{end}}
+
+
+
+{{else}}
+
+
No services configured.
+
Add a service above or edit ~/.config/releasewave/config.yaml
+
+{{end}}
+{{end}}
diff --git a/internal/web/web.go b/internal/web/web.go
index a397bb9..7d312fc 100644
--- a/internal/web/web.go
+++ b/internal/web/web.go
@@ -1,12 +1,14 @@
-// Package web provides a minimal web dashboard for ReleaseWave.
+// Package web provides the web dashboard for ReleaseWave.
package web
import (
"context"
+ "encoding/json"
"fmt"
"html/template"
"log/slog"
"net/http"
+ "strings"
"sync"
"time"
@@ -33,24 +35,149 @@ type dashboardData struct {
UpdatedAt string
}
-// Handler returns an http.Handler that serves the web dashboard.
+// Handler returns an http.Handler that serves the web dashboard with htmx partials.
func Handler(cfg *config.Config, providers map[string]provider.Provider) (http.Handler, error) {
tmpl, err := template.ParseFS(templateFS, "dashboard.html")
if err != nil {
return nil, fmt.Errorf("web: failed to parse embedded template: %w", err)
}
+ h := &dashboardHandler{cfg: cfg, providers: providers, tmpl: tmpl}
+
mux := http.NewServeMux()
- mux.HandleFunc("/dashboard", func(w http.ResponseWriter, r *http.Request) {
- data := fetchDashboardData(r.Context(), cfg, providers)
- w.Header().Set("Content-Type", "text/html; charset=utf-8")
- if err := tmpl.Execute(w, data); err != nil {
- slog.Error("web.render", "error", err)
- http.Error(w, "Internal Server Error", http.StatusInternalServerError)
+ mux.HandleFunc("/dashboard", h.fullPage)
+ mux.HandleFunc("/dashboard/partials/stats", h.partialStats)
+ mux.HandleFunc("/dashboard/partials/services", h.partialServices)
+ mux.HandleFunc("POST /dashboard/services", h.addService)
+ mux.HandleFunc("DELETE /dashboard/services/{name}", h.deleteService)
+
+ return mux, nil
+}
+
+type dashboardHandler struct {
+ cfg *config.Config
+ providers map[string]provider.Provider
+ tmpl *template.Template
+ mu sync.RWMutex
+}
+
+func (h *dashboardHandler) fullPage(w http.ResponseWriter, r *http.Request) {
+ data := h.getData(r.Context())
+ w.Header().Set("Content-Type", "text/html; charset=utf-8")
+ if err := h.tmpl.Execute(w, data); err != nil {
+ slog.Error("web.render", "error", err)
+ http.Error(w, "Internal Server Error", http.StatusInternalServerError)
+ }
+}
+
+func (h *dashboardHandler) partialStats(w http.ResponseWriter, r *http.Request) {
+ data := h.getData(r.Context())
+ w.Header().Set("Content-Type", "text/html; charset=utf-8")
+ if err := h.tmpl.ExecuteTemplate(w, "stats", data); err != nil {
+ slog.Error("web.render.stats", "error", err)
+ }
+}
+
+func (h *dashboardHandler) partialServices(w http.ResponseWriter, r *http.Request) {
+ data := h.getData(r.Context())
+ w.Header().Set("Content-Type", "text/html; charset=utf-8")
+ if err := h.tmpl.ExecuteTemplate(w, "services", data); err != nil {
+ slog.Error("web.render.services", "error", err)
+ }
+}
+
+func (h *dashboardHandler) addService(w http.ResponseWriter, r *http.Request) {
+ name := r.FormValue("name")
+ repo := r.FormValue("repo")
+ registry := r.FormValue("registry")
+
+ if name == "" || repo == "" {
+ w.Header().Set("Content-Type", "application/json")
+ w.WriteHeader(http.StatusBadRequest)
+ if err := json.NewEncoder(w).Encode(map[string]string{"error": "name and repo are required"}); err != nil {
+ slog.Error("web.write", "error", err)
+ }
+ return
+ }
+
+ parts := strings.Split(repo, "/")
+ if len(parts) < 3 {
+ w.Header().Set("Content-Type", "application/json")
+ w.WriteHeader(http.StatusBadRequest)
+ if err := json.NewEncoder(w).Encode(map[string]string{"error": "repo must be host/owner/repo format"}); err != nil {
+ slog.Error("web.write", "error", err)
+ }
+ return
+ }
+
+ h.mu.Lock()
+ for _, svc := range h.cfg.Services {
+ if svc.Name == name {
+ h.mu.Unlock()
+ w.Header().Set("Content-Type", "application/json")
+ w.WriteHeader(http.StatusConflict)
+ if err := json.NewEncoder(w).Encode(map[string]string{"error": "service already exists"}); err != nil {
+ slog.Error("web.write", "error", err)
+ }
+ return
}
+ }
+ h.cfg.Services = append(h.cfg.Services, config.ServiceConfig{
+ Name: name,
+ Repo: repo,
+ Registry: registry,
})
+ h.mu.Unlock()
- return mux, nil
+ slog.Info("web.add_service", "name", name, "repo", repo)
+
+ // Return updated services partial.
+ data := h.getData(r.Context())
+ w.Header().Set("Content-Type", "text/html; charset=utf-8")
+ if err := h.tmpl.ExecuteTemplate(w, "services", data); err != nil {
+ slog.Error("web.render.services", "error", err)
+ }
+}
+
+func (h *dashboardHandler) deleteService(w http.ResponseWriter, r *http.Request) {
+ name := r.PathValue("name")
+
+ h.mu.Lock()
+ found := false
+ services := make([]config.ServiceConfig, 0, len(h.cfg.Services))
+ for _, svc := range h.cfg.Services {
+ if svc.Name == name {
+ found = true
+ continue
+ }
+ services = append(services, svc)
+ }
+ if found {
+ h.cfg.Services = services
+ }
+ h.mu.Unlock()
+
+ if !found {
+ w.Header().Set("Content-Type", "application/json")
+ w.WriteHeader(http.StatusNotFound)
+ if err := json.NewEncoder(w).Encode(map[string]string{"error": "service not found"}); err != nil {
+ slog.Error("web.write", "error", err)
+ }
+ return
+ }
+
+ slog.Info("web.delete_service", "name", name)
+
+ // Return updated services partial.
+ data := h.getData(r.Context())
+ w.Header().Set("Content-Type", "text/html; charset=utf-8")
+ if err := h.tmpl.ExecuteTemplate(w, "services", data); err != nil {
+ slog.Error("web.render.services", "error", err)
+ }
+}
+
+func (h *dashboardHandler) getData(ctx context.Context) dashboardData {
+ return fetchDashboardData(ctx, h.cfg, h.providers)
}
// fetchDashboardData queries all configured services concurrently and returns dashboard data.
diff --git a/internal/web/web_test.go b/internal/web/web_test.go
index 587021b..543e540 100644
--- a/internal/web/web_test.go
+++ b/internal/web/web_test.go
@@ -5,6 +5,7 @@ import (
"errors"
"net/http"
"net/http/httptest"
+ "net/url"
"strings"
"testing"
@@ -38,6 +39,15 @@ func (m *mockProvider) GetFileContent(_ context.Context, _, _, _ string) ([]byte
var _ provider.Provider = (*mockProvider)(nil)
+func testHandler(t *testing.T, cfg *config.Config, providers map[string]provider.Provider) http.Handler {
+ t.Helper()
+ handler, err := Handler(cfg, providers)
+ if err != nil {
+ t.Fatalf("Handler() error: %v", err)
+ }
+ return handler
+}
+
func TestHandler_RendersDashboard(t *testing.T) {
cfg := &config.Config{
Services: []config.ServiceConfig{
@@ -53,11 +63,7 @@ func TestHandler_RendersDashboard(t *testing.T) {
},
}
- providers := map[string]provider.Provider{"github": mock}
- handler, err := Handler(cfg, providers)
- if err != nil {
- t.Fatalf("Handler() error: %v", err)
- }
+ handler := testHandler(t, cfg, map[string]provider.Provider{"github": mock})
req := httptest.NewRequest(http.MethodGet, "/dashboard", nil)
rec := httptest.NewRecorder()
@@ -77,6 +83,9 @@ func TestHandler_RendersDashboard(t *testing.T) {
if !strings.Contains(body, "v1.2.3") {
t.Error("expected page to contain version 'v1.2.3'")
}
+ if !strings.Contains(body, "htmx") {
+ t.Error("expected page to contain htmx reference")
+ }
}
func TestHandler_ProviderError(t *testing.T) {
@@ -86,16 +95,8 @@ func TestHandler_ProviderError(t *testing.T) {
},
}
- mock := &mockProvider{
- name: "github",
- err: errors.New("API error"),
- }
-
- providers := map[string]provider.Provider{"github": mock}
- handler, err := Handler(cfg, providers)
- if err != nil {
- t.Fatalf("Handler() error: %v", err)
- }
+ mock := &mockProvider{name: "github", err: errors.New("API error")}
+ handler := testHandler(t, cfg, map[string]provider.Provider{"github": mock})
req := httptest.NewRequest(http.MethodGet, "/dashboard", nil)
rec := httptest.NewRecorder()
@@ -112,20 +113,170 @@ func TestHandler_ProviderError(t *testing.T) {
}
func TestHandler_NoServices(t *testing.T) {
+ handler := testHandler(t, &config.Config{}, map[string]provider.Provider{})
+
+ req := httptest.NewRequest(http.MethodGet, "/dashboard", nil)
+ rec := httptest.NewRecorder()
+ handler.ServeHTTP(rec, req)
+
+ if rec.Code != http.StatusOK {
+ t.Fatalf("expected 200, got %d", rec.Code)
+ }
+ if !strings.Contains(rec.Body.String(), "No services configured") {
+ t.Error("expected empty state message")
+ }
+}
+
+func TestPartialStats(t *testing.T) {
+ cfg := &config.Config{
+ Services: []config.ServiceConfig{
+ {Name: "svc", Repo: "github.com/org/svc"},
+ },
+ }
+ mock := &mockProvider{name: "github", release: &model.Release{Tag: "v1.0.0"}}
+ handler := testHandler(t, cfg, map[string]provider.Provider{"github": mock})
+
+ req := httptest.NewRequest(http.MethodGet, "/dashboard/partials/stats", nil)
+ rec := httptest.NewRecorder()
+ handler.ServeHTTP(rec, req)
+
+ if rec.Code != http.StatusOK {
+ t.Fatalf("expected 200, got %d", rec.Code)
+ }
+ body := rec.Body.String()
+ if !strings.Contains(body, "Services") {
+ t.Error("expected stats partial to contain 'Services'")
+ }
+}
+
+func TestPartialServices(t *testing.T) {
+ cfg := &config.Config{
+ Services: []config.ServiceConfig{
+ {Name: "svc", Repo: "github.com/org/svc"},
+ },
+ }
+ mock := &mockProvider{name: "github", release: &model.Release{Tag: "v2.0.0"}}
+ handler := testHandler(t, cfg, map[string]provider.Provider{"github": mock})
+
+ req := httptest.NewRequest(http.MethodGet, "/dashboard/partials/services", nil)
+ rec := httptest.NewRecorder()
+ handler.ServeHTTP(rec, req)
+
+ if rec.Code != http.StatusOK {
+ t.Fatalf("expected 200, got %d", rec.Code)
+ }
+ body := rec.Body.String()
+ if !strings.Contains(body, "v2.0.0") {
+ t.Error("expected services partial to contain 'v2.0.0'")
+ }
+}
+
+func TestAddService(t *testing.T) {
cfg := &config.Config{}
- providers := map[string]provider.Provider{}
- handler, err := Handler(cfg, providers)
- if err != nil {
- t.Fatalf("Handler() error: %v", err)
+ mock := &mockProvider{name: "github", release: &model.Release{Tag: "v1.0.0"}}
+ handler := testHandler(t, cfg, map[string]provider.Provider{"github": mock})
+
+ form := url.Values{}
+ form.Set("name", "new-svc")
+ form.Set("repo", "github.com/org/new-svc")
+
+ req := httptest.NewRequest(http.MethodPost, "/dashboard/services", strings.NewReader(form.Encode()))
+ req.Header.Set("Content-Type", "application/x-www-form-urlencoded")
+ rec := httptest.NewRecorder()
+ handler.ServeHTTP(rec, req)
+
+ if rec.Code != http.StatusOK {
+ t.Fatalf("expected 200, got %d", rec.Code)
}
- req := httptest.NewRequest(http.MethodGet, "/dashboard", nil)
+ if len(cfg.Services) != 1 || cfg.Services[0].Name != "new-svc" {
+ t.Fatalf("expected service to be added, got %v", cfg.Services)
+ }
+}
+
+func TestAddService_Duplicate(t *testing.T) {
+ cfg := &config.Config{
+ Services: []config.ServiceConfig{{Name: "existing", Repo: "github.com/org/existing"}},
+ }
+ handler := testHandler(t, cfg, map[string]provider.Provider{})
+
+ form := url.Values{}
+ form.Set("name", "existing")
+ form.Set("repo", "github.com/org/existing")
+
+ req := httptest.NewRequest(http.MethodPost, "/dashboard/services", strings.NewReader(form.Encode()))
+ req.Header.Set("Content-Type", "application/x-www-form-urlencoded")
+ rec := httptest.NewRecorder()
+ handler.ServeHTTP(rec, req)
+
+ if rec.Code != http.StatusConflict {
+ t.Fatalf("expected 409, got %d", rec.Code)
+ }
+}
+
+func TestAddService_BadRepo(t *testing.T) {
+ handler := testHandler(t, &config.Config{}, map[string]provider.Provider{})
+
+ form := url.Values{}
+ form.Set("name", "bad")
+ form.Set("repo", "not-valid")
+
+ req := httptest.NewRequest(http.MethodPost, "/dashboard/services", strings.NewReader(form.Encode()))
+ req.Header.Set("Content-Type", "application/x-www-form-urlencoded")
+ rec := httptest.NewRecorder()
+ handler.ServeHTTP(rec, req)
+
+ if rec.Code != http.StatusBadRequest {
+ t.Fatalf("expected 400, got %d", rec.Code)
+ }
+}
+
+func TestAddService_MissingFields(t *testing.T) {
+ handler := testHandler(t, &config.Config{}, map[string]provider.Provider{})
+
+ req := httptest.NewRequest(http.MethodPost, "/dashboard/services", strings.NewReader(""))
+ req.Header.Set("Content-Type", "application/x-www-form-urlencoded")
+ rec := httptest.NewRecorder()
+ handler.ServeHTTP(rec, req)
+
+ if rec.Code != http.StatusBadRequest {
+ t.Fatalf("expected 400, got %d", rec.Code)
+ }
+}
+
+func TestDeleteService(t *testing.T) {
+ cfg := &config.Config{
+ Services: []config.ServiceConfig{
+ {Name: "svc-a", Repo: "github.com/org/a"},
+ {Name: "svc-b", Repo: "github.com/org/b"},
+ },
+ }
+ mock := &mockProvider{name: "github", release: &model.Release{Tag: "v1.0.0"}}
+ handler := testHandler(t, cfg, map[string]provider.Provider{"github": mock})
+
+ req := httptest.NewRequest(http.MethodDelete, "/dashboard/services/svc-a", nil)
rec := httptest.NewRecorder()
handler.ServeHTTP(rec, req)
if rec.Code != http.StatusOK {
t.Fatalf("expected 200, got %d", rec.Code)
}
+
+ if len(cfg.Services) != 1 || cfg.Services[0].Name != "svc-b" {
+ t.Fatalf("expected svc-a removed, got %v", cfg.Services)
+ }
+}
+
+func TestDeleteService_NotFound(t *testing.T) {
+ handler := testHandler(t, &config.Config{}, map[string]provider.Provider{})
+
+ req := httptest.NewRequest(http.MethodDelete, "/dashboard/services/ghost", nil)
+ rec := httptest.NewRecorder()
+ handler.ServeHTTP(rec, req)
+
+ if rec.Code != http.StatusNotFound {
+ t.Fatalf("expected 404, got %d", rec.Code)
+ }
}
func TestFetchDashboardData(t *testing.T) {
@@ -136,13 +287,7 @@ func TestFetchDashboardData(t *testing.T) {
},
}
- mock := &mockProvider{
- name: "github",
- release: &model.Release{
- Tag: "v3.0.0",
- },
- }
-
+ mock := &mockProvider{name: "github", release: &model.Release{Tag: "v3.0.0"}}
providers := map[string]provider.Provider{"github": mock}
data := fetchDashboardData(context.Background(), cfg, providers)