fix: remove context reaper to prevent background tabs from going stale

Background windows stopped updating because the reaper suspended contexts
after ContextSuspendAfter and fully reaped them after ContextTTL. Suspended
contexts had to re-run the page init function from scratch on reconnect,
losing the live-updating experience.

Contexts now live until the browser tab closes (beforeunload beacon) or
the server shuts down. The context map grows indefinitely — no background
reaper.

Removes: startReaper, reapOrphanedContexts, suspend/resume logic,
ContextSuspendAfter/ContextTTL config fields, lastSeenAt/suspended
context fields, and all associated tests.

.claude/commands/pr.md

@@ -8,7 +8,7 @@ Create a PR on Gitea, wait for CI, and squash-merge it. Push code to both remote
 5. Create a Gitea PR: `tea pr create --head <branch> --base main`. Reference related issues with `#X`. Only use `Closes #X` if the PR fully resolves the issue.
 6. Wait for CI to pass: poll Gitea CI status. If CI fails, report the failure and stop — do not merge.
 7. Once CI passes, squash-merge on Gitea: `tea pr merge <index> --style squash` with a clean, semantic commit message including the PR number. No Claude attribution lines.
-8. Update local main and push to both remotes. If in a worktree, `main` is checked out in the primary tree, so run from there: `cd <primary-worktree> && git pull gitea main && git push origin main` (the primary worktree path is the repo root without `.claude/worktrees/…`). If not in a worktree: `git checkout main && git pull gitea main && git push origin main`.
+8. Update local main and push to both remotes: `git checkout main && git pull gitea main && git push origin main`.
 9. Clean up remote branches: `git push gitea --delete <branch> && git push origin --delete <branch>`.
 10. Prune refs: `git remote prune gitea && git remote prune origin`.
 11. Report the merged PR URL.

.gitignore

@@ -37,15 +37,21 @@ go.work.sum
 # Air artifacts
 *tmp/
 
-# Example binaries and data files
-internal/examples/*/[a-z]*[!.go]
-internal/examples/shakespeare/shake.db
+# binaries
+internal/examples/chatroom/chatroom
+internal/examples/counter/counter
+internal/examples/countercomp/countercomp
+internal/examples/greeter/greeter
+internal/examples/livereload/livereload
+internal/examples/picocss/picocss
+internal/examples/plugins/plugins
+internal/examples/realtimechart/realtimechart
+internal/examples/shakespeare/shakespeare
+internal/examples/nats-chatroom/nats-chatroom
+/nats-chatroom
 
 # NATS data directory
 data/
 
-# Standalone experiments
-nats-chatroom
-
 # Claude Code worktrees
 .claude/worktrees/

README.md

@@ -74,13 +74,14 @@ func main() {
 - **Plugin system** — `func(v *V)` hooks for integrating CSS/JS libraries
 - **Structured logging** — zerolog with configurable levels; console output in dev, JSON in production
 - **Graceful shutdown** — listens for SIGINT/SIGTERM, drains contexts, closes pub/sub
+- **Context lifecycle** — background reaper cleans up disconnected contexts; configurable TTL
 - **HTML DSL** — the `h` package provides type-safe Go-native HTML composition
 
 ## Examples
 
-The `internal/examples/` directory contains 19 runnable examples:
+The `internal/examples/` directory contains 14 runnable examples:
 
-`chatroom` · `counter` · `countercomp` · `effectspike` · `greeter` · `keyboard` · `livereload` · `maplibre` · `middleware` · `nats-chatroom` · `pathparams` · `picocss` · `plugins` · `pubsub-crud` · `realtimechart` · `session` · `shakespeare` · `signup` · `spa`
+`chatroom` · `counter` · `countercomp` · `greeter` · `keyboard` · `livereload` · `nats-chatroom` · `pathparams` · `picocss` · `plugins` · `pubsub-crud` · `realtimechart` · `session` · `shakespeare`
 
 ## Experimental
 

ci-check.sh

@@ -6,13 +6,9 @@ set -o pipefail
 ROOT="$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)"
 cd "$ROOT"
 
-echo "== CI: Check formatting =="
-if [ -n "$(gofmt -l .)" ]; then
-  echo "ERROR: files not formatted:"
-  gofmt -l .
-  exit 1
-fi
-echo "OK: all files formatted"
+echo "== CI: Format code =="
+go fmt ./...
+echo "OK: formatting complete"
 
 echo "== CI: Run go vet =="
 if ! go vet ./...; then

computed.go

@@ -1,6 +1,7 @@
 package via
 
 import (
+	"fmt"
 	"strconv"
 	"strings"
 
@@ -50,5 +51,5 @@ func (s *computedSignal) recompute() {
 }
 
 func (s *computedSignal) patchValue() string {
-	return s.lastVal
+	return fmt.Sprintf("%v", s.lastVal)
 }

context.go

@@ -25,7 +25,7 @@ type Context struct {
 	app               *V
 	view              func() h.H
 	routeParams       map[string]string
-	parentPageCtx     *Context
+	parentPageCtx *Context
 	patchChan         chan patch
 	actionLimiter     *rate.Limiter
 	actionRegistry    map[string]actionEntry
@@ -39,9 +39,9 @@ type Context struct {
 	subscriptions     []Subscription
 	subsMu            sync.Mutex
 	disposeOnce       sync.Once
-	createdAt         time.Time
-	sseConnected      atomic.Bool
-	sseDisconnectedAt atomic.Pointer[time.Time]
+	createdAt           time.Time
+	sseConnected        atomic.Bool
+	sseDisconnectedAt   atomic.Pointer[time.Time]
 }
 
 // View defines the UI rendered by this context.
@@ -630,17 +630,17 @@ func newContext(id string, route string, v *V) *Context {
 	}
 
 	return &Context{
-		id:              id,
-		route:           route,
-		csrfToken:       genCSRFToken(),
-		routeParams:     make(map[string]string),
-		app:             v,
-		actionLimiter:   newLimiter(v.actionRateLimit, defaultActionRate, defaultActionBurst),
-		actionRegistry:  make(map[string]actionEntry),
-		signals:         new(sync.Map),
-		patchChan:       make(chan patch, 8),
-		ctxDisposedChan: make(chan struct{}, 1),
-		pageStopChan:    make(chan struct{}),
-		createdAt:       time.Now(),
+		id:                id,
+		route:             route,
+		csrfToken:         genCSRFToken(),
+		routeParams:       make(map[string]string),
+		app:               v,
+		actionLimiter: newLimiter(v.actionRateLimit, defaultActionRate, defaultActionBurst),
+		actionRegistry:    make(map[string]actionEntry),
+		signals:           new(sync.Map),
+		patchChan:         make(chan patch, 8),
+		ctxDisposedChan:   make(chan struct{}, 1),
+		pageStopChan:      make(chan struct{}),
+		createdAt:         time.Now(),
 	}
 }

docs/state-and-interactivity.md

@@ -94,7 +94,7 @@ Available triggers:
 |--------|-------|-------|
 | `OnClick()` | `click` | |
 | `OnDblClick()` | `dblclick` | |
-| `OnChange()` | `change` | |
+| `OnChange()` | `change` | 200ms debounce |
 | `OnInput()` | `input` | No debounce |
 | `OnSubmit()` | `submit` | |
 | `OnKeyDown(key)` | `keydown` | Filtered by key name (e.g. `"Enter"`, `"Escape"`) |

h/h.go

@@ -5,7 +5,7 @@
 //
 //	h.Div(
 //		h.H1(h.Text("Hello, Via")),
-//		h.P(h.Text("Pure Go. No templates.")),
+//		h.P(h.Text("Pure Go. No tmplates.")),
 //	)
 package h
 

internal/examples/livereload/main.go

@@ -2,6 +2,7 @@ package main
 
 import (
 	"github.com/ryanhamamura/via"
+	// "github.com/go-via/via-plugin-picocss/picocss"
 	"github.com/ryanhamamura/via/h"
 )
 
@@ -14,6 +15,9 @@ func main() {
 		DocumentTitle: "Live Reload Demo",
 		DevMode:       true,
 		LogLevel:      via.LogLevelDebug,
+		Plugins:       []via.Plugin{
+			// picocss.Default
+		},
 	})
 
 	v.Page("/", func(c *via.Context) {

internal/examples/maplibre/main.go

@@ -2,8 +2,6 @@ package main
 
 import (
 	"math/rand"
-	"strconv"
-	"sync"
 	"time"
 
 	"github.com/ryanhamamura/via"
@@ -11,19 +9,6 @@ import (
 	"github.com/ryanhamamura/via/maplibre"
 )
 
-type posMsg struct {
-	Lng float64 `json:"lng"`
-	Lat float64 `json:"lat"`
-}
-
-var (
-	vehicleOnce sync.Once
-	vehicle     struct {
-		mu       sync.RWMutex
-		lng, lat float64
-	}
-)
-
 func main() {
 	v := via.New()
 	v.Config(via.Options{
@@ -33,21 +18,6 @@ func main() {
 		Plugins:       []via.Plugin{maplibre.Plugin},
 	})
 
-	// Single goroutine moves the vehicle — all clients read the same position.
-	vehicle.lng = -122.43
-	vehicle.lat = 37.77
-	vehicleOnce.Do(func() {
-		go func() {
-			for {
-				time.Sleep(time.Second)
-				vehicle.mu.Lock()
-				vehicle.lng = -122.43 + (rand.Float64()-0.5)*0.02
-				vehicle.lat = 37.77 + (rand.Float64()-0.5)*0.02
-				vehicle.mu.Unlock()
-			}
-		}()
-	})
-
 	v.Page("/", func(c *via.Context) {
 		m := maplibre.New(c, maplibre.Options{
 			Style:  "https://demotiles.maplibre.org/style.json",
@@ -75,7 +45,7 @@ func main() {
 			},
 		})
 
-		// Purple vehicle marker — reads shared Go state
+		// Signal-backed marker — server pushes position updates
 		vehicleLng := c.Signal(-122.43)
 		vehicleLat := c.Signal(37.77)
 
@@ -86,37 +56,12 @@ func main() {
 		})
 
 		c.OnInterval(time.Second, func() {
-			vehicle.mu.RLock()
-			lng, lat := vehicle.lng, vehicle.lat
-			vehicle.mu.RUnlock()
-			vehicleLng.SetValue(lng)
-			vehicleLat.SetValue(lat)
+			vehicleLng.SetValue(-122.43 + (rand.Float64()-0.5)*0.02)
+			vehicleLat.SetValue(37.77 + (rand.Float64()-0.5)*0.02)
 			c.SyncSignals()
 		})
 
-		// Yellow click marker — synced across clients via PubSub
-		clickLng := c.Signal(-122.4194)
-		clickLat := c.Signal(37.7749)
-
-		m.AddMarker("clicked", maplibre.Marker{
-			LngSignal: clickLng,
-			LatSignal: clickLat,
-			Color:     "#f39c12",
-		})
-
-		via.Subscribe(c, "map.click", func(msg posMsg) {
-			clickLng.SetValue(msg.Lng)
-			clickLat.SetValue(msg.Lat)
-			c.SyncSignals()
-		})
-
-		click := m.OnClick()
-		handleClick := c.Action(func() {
-			e := click.Data()
-			via.Publish(c, "map.click", posMsg{Lng: e.LngLat.Lng, Lat: e.LngLat.Lat})
-		})
-
-		// Blue draggable pin — synced across clients via PubSub
+		// Draggable marker — user drags, signals update
 		pinLng := c.Signal(-122.41)
 		pinLat := c.Signal(37.78)
 
@@ -127,16 +72,14 @@ func main() {
 			Draggable: true,
 		})
 
-		via.Subscribe(c, "map.pin", func(msg posMsg) {
-			pinLng.SetValue(msg.Lng)
-			pinLat.SetValue(msg.Lat)
-			c.SyncSignals()
-		})
-
-		handlePinDrag := c.Action(func() {
-			lng, _ := strconv.ParseFloat(pinLng.String(), 64)
-			lat, _ := strconv.ParseFloat(pinLat.String(), 64)
-			via.Publish(c, "map.pin", posMsg{Lng: lng, Lat: lat})
+		// Click event — click to place a marker
+		click := m.OnClick()
+		handleClick := c.Action(func() {
+			e := click.Data()
+			m.AddMarker("clicked", maplibre.Marker{
+				LngLat: e.LngLat,
+				Color:  "#f39c12",
+			})
 		})
 
 		// GeoJSON polygon source + fill layer
@@ -168,7 +111,7 @@ func main() {
 			},
 		})
 
-		// FlyTo actions
+		// FlyTo actions using CameraOptions
 		zoom14 := 14.0
 		flyToSF := c.Action(func() {
 			m.FlyTo(maplibre.CameraOptions{
@@ -191,7 +134,6 @@ func main() {
 					h.H1(h.Text("MapLibre GL Example")),
 					m.Element(
 						click.Input(handleClick.OnInput()),
-						h.Input(h.Type("hidden"), pinLng.Bind(), handlePinDrag.OnInput()),
 					),
 					h.Div(h.Attr("style", "margin-top:1rem;display:flex;gap:0.5rem;flex-wrap:wrap"),
 						h.Button(h.Text("Fly to San Francisco"), flyToSF.OnClick()),
@@ -200,7 +142,6 @@ func main() {
 					h.Div(h.Attr("style", "margin-top:0.5rem;font-size:0.9rem"),
 						h.P(h.Text("Zoom: "), m.Zoom.Text()),
 						h.P(h.Text("Center: "), m.CenterLng.Text(), h.Text(", "), m.CenterLat.Text()),
-						h.P(h.Text("Click: "), clickLng.Text(), h.Text(", "), clickLat.Text()),
 						h.P(h.Text("Vehicle: "), vehicleLng.Text(), h.Text(", "), vehicleLat.Text()),
 						h.P(h.Text("Draggable Pin: "), pinLng.Text(), h.Text(", "), pinLat.Text()),
 					),

internal/examples/pathparams/main.go

@@ -4,12 +4,17 @@ import (
 	"strconv"
 
 	"github.com/ryanhamamura/via"
+	// "github.com/go-via/via-plugin-picocss/picocss"
 	. "github.com/ryanhamamura/via/h"
 )
 
 func main() {
 	v := via.New()
 
+	v.Config(via.Options{
+		// Plugins: []via.Plugin{picocss.Default},
+	})
+
 	v.Page("/counters/{counter_id}/{start_at_step}", func(c *via.Context) {
 
 		counterID := c.GetPathParam("counter_id")

internal/examples/picocss/main.go

@@ -2,6 +2,7 @@ package main
 
 import (
 	"github.com/ryanhamamura/via"
+	// "github.com/go-via/via-plugin-picocss/picocss"
 	"github.com/ryanhamamura/via/h"
 )
 
@@ -12,6 +13,11 @@ func main() {
 
 	v.Config(via.Options{
 		DocumentTitle: "Via Counter",
+		// Plugin is placed here. Use picocss.WithOptions(pococss.Options) to add the plugin
+		// with a different color theme or to enable a classes for a wide range of colors.
+		// Plugins: []via.Plugin{
+		// 	picocss.Default,
+		// },
 	})
 
 	v.Page("/", func(c *via.Context) {

internal/examples/realtimechart/main.go

@@ -6,6 +6,7 @@ import (
 	"time"
 
 	"github.com/ryanhamamura/via"
+	// "github.com/go-via/via-plugin-picocss/picocss"
 	"github.com/ryanhamamura/via/h"
 )
 
@@ -14,7 +15,10 @@ func main() {
 
 	v.Config(via.Options{
 		LogLevel: via.LogLevelDebug,
-		DevMode:  true,
+		DevMode: true,
+		Plugins: []via.Plugin{
+			// picocss.Default,
+		},
 	})
 
 	v.AppendToHead(

internal/examples/shakespeare/main.go

@@ -6,9 +6,9 @@ import (
 	"log"
 	"time"
 
-	_ "github.com/mattn/go-sqlite3"
 	"github.com/ryanhamamura/via"
 	"github.com/ryanhamamura/via/h"
+	_ "github.com/mattn/go-sqlite3"
 )
 
 type DataSource interface {
@@ -22,9 +22,6 @@ type ShakeDB struct {
 	findByTextStmt *sql.Stmt
 }
 
-// Prepare opens shake.db, a ~22 MB SQLite database of Shakespeare's works.
-// Download from https://github.com/nicholasgasior/gopher-fizzbuzz/raw/master/shake.db
-// and place it in this directory before running.
 func (shakeDB *ShakeDB) Prepare() {
 	db, err := sql.Open("sqlite3", "shake.db")
 	if err != nil {

maplibre/types.go

@@ -316,7 +316,7 @@ type Marker struct {
 type Popup struct {
 	Content         string // HTML content
 	LngLat          LngLat
-	HideCloseButton bool // true removes the close button (MapLibre shows it by default)
+	HideCloseButton bool   // true removes the close button (MapLibre shows it by default)
 	MaxWidth        string
 }
 

signal.go

@@ -80,3 +80,4 @@ func (s *Signal) Int() int {
 	}
 	return 0
 }
+

signal_test.go

@@ -1,6 +1,7 @@
 package via
 
 import (
+	//	"net/http/httptest"
 	"testing"
 
 	"github.com/ryanhamamura/via/h"

static_test.go

@@ -81,8 +81,8 @@ func TestStaticAutoSlash(t *testing.T) {
 
 func TestStaticFS(t *testing.T) {
 	fsys := fstest.MapFS{
-		"style.css": {Data: []byte("body{}")},
-		"js/app.js": {Data: []byte("console.log('hi')")},
+		"style.css":        {Data: []byte("body{}")},
+		"js/app.js":        {Data: []byte("console.log('hi')")},
 	}
 
 	v := New()

via.go

@@ -240,10 +240,10 @@ func (v *V) page(route string, raw, wrapped func(*Context)) {
 			bodyElements = append(bodyElements, h.Raw("<dataspa-inspector/>"))
 		}
 		view := h.HTML5(h.HTML5Props{
-			Title: v.cfg.DocumentTitle,
-			Head:  headElements,
-			Body:  bodyElements,
-		})
+			Title:     v.cfg.DocumentTitle,
+			Head:      headElements,
+			Body:      bodyElements,
+			})
 		_ = view.Render(w)
 	}))
 }
@@ -439,39 +439,36 @@ func (v *V) ensureDatastarHandler() {
 	})
 }
 
-func loadDevModeMap(path string) map[string]string {
-	m := make(map[string]string)
-	file, err := os.Open(path)
-	if err != nil {
-		return m
-	}
-	defer file.Close()
-	json.NewDecoder(file).Decode(&m)
-	return m
-}
-
-func saveDevModeMap(path string, m map[string]string) error {
-	file, err := os.Create(path)
-	if err != nil {
-		return err
-	}
-	defer file.Close()
-	return json.NewEncoder(file).Encode(m)
-}
-
 func (v *V) devModePersist(c *Context) {
 	p := filepath.Join(".via", "devmode", "ctx.json")
 	if err := os.MkdirAll(filepath.Dir(p), 0755); err != nil {
 		v.logFatal("failed to create directory for devmode files: %v", err)
 	}
 
-	ctxRegMap := loadDevModeMap(p)
+	// load persisted list from file, or empty list if file not found
+	file, err := os.Open(p)
+	ctxRegMap := make(map[string]string)
+	if err == nil {
+		json.NewDecoder(file).Decode(&ctxRegMap)
+	}
+	file.Close()
+
+	// add ctx to persisted list
 	if _, ok := ctxRegMap[c.id]; !ok {
 		ctxRegMap[c.id] = c.route
 	}
 
-	if err := saveDevModeMap(p, ctxRegMap); err != nil {
-		v.logErr(c, "devmode failed to persist ctx: %v", err)
+	// write persisted list to file
+	file, err = os.Create(p)
+	if err != nil {
+		v.logErr(c, "devmode failed to percist ctx: %v", err)
+
+	}
+	defer file.Close()
+
+	encoder := json.NewEncoder(file)
+	if err := encoder.Encode(ctxRegMap); err != nil {
+		v.logErr(c, "devmode failed to persist ctx")
 	}
 	v.logDebug(c, "devmode persisted ctx to file")
 }
@@ -479,11 +476,27 @@ func (v *V) devModePersist(c *Context) {
 func (v *V) devModeRemovePersisted(c *Context) {
 	p := filepath.Join(".via", "devmode", "ctx.json")
 
-	ctxRegMap := loadDevModeMap(p)
+	// load persisted list from file, or empty list if file not found
+	file, err := os.Open(p)
+	ctxRegMap := make(map[string]string)
+	if err == nil {
+		json.NewDecoder(file).Decode(&ctxRegMap)
+	}
+	file.Close()
+
 	delete(ctxRegMap, c.id)
 
-	if err := saveDevModeMap(p, ctxRegMap); err != nil {
-		v.logErr(c, "devmode failed to remove persisted ctx: %v", err)
+	// write persisted list to file
+	file, err = os.Create(p)
+	if err != nil {
+		v.logErr(c, "devmode failed to remove percisted ctx: %v", err)
+
+	}
+	defer file.Close()
+
+	encoder := json.NewEncoder(file)
+	if err := encoder.Encode(ctxRegMap); err != nil {
+		v.logErr(c, "devmode failed to remove persisted ctx")
 	}
 	v.logDebug(c, "devmode removed persisted ctx from file")
 }

via_test.go

@@ -134,9 +134,9 @@ func TestAction(t *testing.T) {
 
 func TestEventTypes(t *testing.T) {
 	tests := []struct {
-		name    string
-		attr    string
-		buildEl func(trigger *actionTrigger) h.H
+		name     string
+		attr     string
+		buildEl  func(trigger *actionTrigger) h.H
 	}{
 		{"OnSubmit", "data-on:submit", func(tr *actionTrigger) h.H { return h.Form(tr.OnSubmit()) }},
 		{"OnInput", "data-on:input", func(tr *actionTrigger) h.H { return h.Input(tr.OnInput()) }},