Sprint A-2: Chronicle Sync Dashboard — Owner + Admin expansion

Owner API Keys page:
- HTMX lazy-loaded sync overview card showing total mappings, per-type
  breakdown (entities, maps, events, etc.), and last sync activity
- Searchable, filterable, paginated sync mappings table with name joins
  (LEFT JOIN entities/maps for display names), type filter, sort options
- Direction badges (both/push/pull) and version tracking per mapping

Admin API Monitor:
- Campaign Sync Overview table showing per-campaign sync health: active
  keys, total mappings, last activity, and 24h error counts
- Aggregated from sync_mappings, sync_api_keys, and api_request_logs

Backend:
- Extended SyncMappingRepository interface with CountByType,
  LastSyncActivity, ListMappingsWithNames, ListCampaignSyncStats
- Added GetSyncSummary and ListMappingsWithNames service methods
- New handler endpoints for HTMX sync fragments
- Injected SyncMappingService into management Handler via setter
- Consolidated sync mapping repo creation in routes.go wiring

https://claude.ai/code/session_01WJEjfBqjZaGatHiXXXDupo

Author: claude

internal/app/routes.go

@@ -926,6 +926,10 @@ func (a *App) RegisterRoutes() {
 	syncRepo := syncapi.NewSyncAPIRepository(a.DB)
 	syncService := syncapi.NewSyncAPIService(syncRepo)
 	syncHandler := syncapi.NewHandler(syncService)
+	// Inject sync mapping service early so the owner dashboard can show sync status.
+	syncMappingRepoEarly := syncapi.NewSyncMappingRepository(a.DB)
+	syncMappingSvcEarly := syncapi.NewSyncMappingService(syncMappingRepoEarly)
+	syncHandler.SetSyncMappingService(syncMappingSvcEarly)
 	if a.PluginHealth.IsHealthy("syncapi") {
 		syncapi.RegisterAdminRoutes(adminGroup, syncHandler)
 		syncapi.RegisterCampaignRoutes(e, syncHandler, campaignService, authService)
@@ -1012,11 +1016,9 @@ func (a *App) RegisterRoutes() {
 		mediaAPIHandler.SetURLSigner(urlSigner)
 	}
 
-	// Sync mapping service and handler for Foundry VTT bidirectional sync.
-	syncMappingRepo := syncapi.NewSyncMappingRepository(a.DB)
-	syncMappingSvc := syncapi.NewSyncMappingService(syncMappingRepo)
-	syncMappingHandler := syncapi.NewSyncHandler(syncMappingSvc)
-	_ = syncMappingSvc // Service will also be used by map/entity handlers.
+	// Sync mapping handler for Foundry VTT bidirectional sync.
+	// Reuses the sync mapping service created earlier for the owner dashboard.
+	syncMappingHandler := syncapi.NewSyncHandler(syncMappingSvcEarly)
 	mapAPIHandler := syncapi.NewMapAPIHandler(syncService, mapsService, drawingService, campaignService)
 
 	if a.PluginHealth.IsHealthy("syncapi") {

internal/plugins/syncapi/admin_dashboard.templ

@@ -94,6 +94,11 @@ templ AdminAPIDashboardTempl(data AdminDashboardData) {
 				@topTable("Top Keys", "fa-key", data.TopKeys)
 			</div>
 
+			// Campaign Sync Overview.
+			if len(data.CampaignSyncStats) > 0 {
+				@AdminCampaignSyncTableTempl(data.CampaignSyncStats)
+			}
+
 			// Security events.
 			<div class="card p-6">
 				<div class="flex items-center justify-between mb-4">

internal/plugins/syncapi/handler.go

@@ -17,14 +17,20 @@ import (
 // Handler handles sync API HTTP requests for both the management UI
 // (key management, dashboards) and the actual sync API endpoints.
 type Handler struct {
-	service SyncAPIService
+	service    SyncAPIService
+	syncMapSvc SyncMappingService
 }
 
 // NewHandler creates a new sync API handler.
 func NewHandler(service SyncAPIService) *Handler {
 	return &Handler{service: service}
 }
 
+// SetSyncMappingService injects the sync mapping service for owner dashboard sync status.
+func (h *Handler) SetSyncMappingService(svc SyncMappingService) {
+	h.syncMapSvc = svc
+}
+
 // --- Campaign Owner: API Key Management ---
 
 // KeysPage renders the API keys management page for a campaign (GET /campaigns/:id/api-keys).
@@ -209,6 +215,59 @@ func (h *Handler) SyncStatusEmbed(c echo.Context) error {
 	return middleware.Render(c, http.StatusOK, SyncStatusFragment(cc.Campaign.ID, keys, stats))
 }
 
+// SyncOverviewFragment returns an HTMX fragment showing the sync summary card.
+// GET /campaigns/:id/api-keys/sync-overview
+func (h *Handler) SyncOverviewFragment(c echo.Context) error {
+	cc := campaigns.GetCampaignContext(c)
+	if cc == nil {
+		return apperror.NewForbidden("campaign context required")
+	}
+
+	if h.syncMapSvc == nil {
+		return middleware.Render(c, http.StatusOK, SyncOverviewEmptyTempl())
+	}
+
+	summary, err := h.syncMapSvc.GetSyncSummary(c.Request().Context(), cc.Campaign.ID)
+	if err != nil {
+		summary = &SyncSummary{}
+	}
+
+	return middleware.Render(c, http.StatusOK, SyncOverviewCardTempl(summary))
+}
+
+// SyncMappingsFragment returns an HTMX fragment with the paginated sync mappings table.
+// GET /campaigns/:id/api-keys/sync-mappings?search=&type=&sort=&offset=0
+func (h *Handler) SyncMappingsFragment(c echo.Context) error {
+	cc := campaigns.GetCampaignContext(c)
+	if cc == nil {
+		return apperror.NewForbidden("campaign context required")
+	}
+
+	if h.syncMapSvc == nil {
+		return middleware.Render(c, http.StatusOK, SyncMappingsEmptyTempl())
+	}
+
+	offset, _ := strconv.Atoi(c.QueryParam("offset"))
+	if offset < 0 {
+		offset = 0
+	}
+
+	opts := SyncMappingListOptions{
+		Search: strings.TrimSpace(c.QueryParam("search")),
+		Type:   strings.TrimSpace(c.QueryParam("type")),
+		Sort:   strings.TrimSpace(c.QueryParam("sort")),
+		Limit:  25,
+		Offset: offset,
+	}
+
+	rows, total, err := h.syncMapSvc.ListMappingsWithNames(c.Request().Context(), cc.Campaign.ID, opts)
+	if err != nil {
+		rows = []SyncMappingRow{}
+	}
+
+	return middleware.Render(c, http.StatusOK, SyncMappingsTableTempl(cc.Campaign.ID, rows, total, opts))
+}
+
 // --- Admin: API Monitoring Dashboard ---
 
 // AdminDashboard renders the admin API monitoring page (GET /admin/api).
@@ -230,20 +289,27 @@ func (h *Handler) AdminDashboard(c echo.Context) error {
 
 	keys, totalKeys, _ := h.service.ListAllKeys(ctx, 20, 0)
 
+	// Fetch per-campaign sync stats if sync mapping service is available.
+	var campaignSyncStats []CampaignSyncStats
+	if h.syncMapSvc != nil {
+		campaignSyncStats, _ = h.syncMapSvc.ListCampaignSyncStats(ctx)
+	}
+
 	csrfToken := middleware.GetCSRFToken(c)
 
 	data := AdminDashboardData{
-		Stats:           stats,
-		RequestSeries:   requestSeries,
-		SecuritySeries:  securitySeries,
-		TopIPs:          topIPs,
-		TopPaths:        topPaths,
-		TopKeys:         topKeys,
-		SecurityEvents:  secEvents,
-		IPBlocks:        ipBlocks,
-		APIKeys:         keys,
-		TotalKeys:       totalKeys,
-		CSRFToken:       csrfToken,
+		Stats:             stats,
+		RequestSeries:     requestSeries,
+		SecuritySeries:    securitySeries,
+		TopIPs:            topIPs,
+		TopPaths:          topPaths,
+		TopKeys:           topKeys,
+		SecurityEvents:    secEvents,
+		IPBlocks:          ipBlocks,
+		APIKeys:           keys,
+		TotalKeys:         totalKeys,
+		CampaignSyncStats: campaignSyncStats,
+		CSRFToken:         csrfToken,
 	}
 
 	return middleware.Render(c, http.StatusOK, AdminAPIDashboardTempl(data))
@@ -423,15 +489,16 @@ func (h *Handler) AdminRevokeKey(c echo.Context) error {
 
 // AdminDashboardData holds all data for the admin API monitoring dashboard.
 type AdminDashboardData struct {
-	Stats          *APIStats
-	RequestSeries  []TimeSeriesPoint
-	SecuritySeries []TimeSeriesPoint
-	TopIPs         []TopEntry
-	TopPaths       []TopEntry
-	TopKeys        []TopEntry
-	SecurityEvents []SecurityEvent
-	IPBlocks       []IPBlock
-	APIKeys        []APIKey
-	TotalKeys      int
-	CSRFToken      string
+	Stats              *APIStats
+	RequestSeries      []TimeSeriesPoint
+	SecuritySeries     []TimeSeriesPoint
+	TopIPs             []TopEntry
+	TopPaths           []TopEntry
+	TopKeys            []TopEntry
+	SecurityEvents     []SecurityEvent
+	IPBlocks           []IPBlock
+	APIKeys            []APIKey
+	TotalKeys          int
+	CampaignSyncStats  []CampaignSyncStats
+	CSRFToken          string
 }

internal/plugins/syncapi/model.go

@@ -229,3 +229,44 @@ type SyncPullResponse struct {
 	Mappings   []SyncMapping `json:"mappings"`
 	HasMore    bool          `json:"has_more"`
 }
+
+// SyncSummary provides an overview of sync state for a campaign.
+// Used by the owner's API Keys page to show what's syncing.
+type SyncSummary struct {
+	TotalMappings    int            `json:"total_mappings"`
+	ByType           map[string]int `json:"by_type"`
+	LastSyncActivity *time.Time     `json:"last_sync_activity,omitempty"`
+	RecentErrors     int            `json:"recent_errors"`
+}
+
+// SyncMappingRow is a display-friendly sync mapping with the linked
+// Chronicle entity name for the owner's mappings table.
+type SyncMappingRow struct {
+	ID            string    `json:"id"`
+	ChronicleType string   `json:"chronicle_type"`
+	ChronicleID   string   `json:"chronicle_id"`
+	ChronicleName string   `json:"chronicle_name"`
+	ExternalID    string   `json:"external_id"`
+	SyncDirection string   `json:"sync_direction"`
+	SyncVersion   int      `json:"sync_version"`
+	LastSyncedAt  time.Time `json:"last_synced_at"`
+}
+
+// SyncMappingListOptions configures the sync mappings list query.
+type SyncMappingListOptions struct {
+	Search string
+	Type   string
+	Sort   string
+	Limit  int
+	Offset int
+}
+
+// CampaignSyncStats provides per-campaign sync statistics for the admin dashboard.
+type CampaignSyncStats struct {
+	CampaignID    string     `json:"campaign_id"`
+	CampaignName  string     `json:"campaign_name"`
+	ActiveKeys    int        `json:"active_keys"`
+	TotalMappings int        `json:"total_mappings"`
+	LastActivity  *time.Time `json:"last_activity,omitempty"`
+	RecentErrors  int        `json:"recent_errors"`
+}

internal/plugins/syncapi/owner_keys.templ

@@ -141,6 +141,30 @@ templ OwnerKeysPageTempl(campaignID string, keys []APIKey, stats *APIStats, csrf
 				</form>
 			</div>
 
+			// Sync Status Overview (HTMX lazy-loaded).
+			<div
+				hx-get={ fmt.Sprintf("/campaigns/%s/api-keys/sync-overview", campaignID) }
+				hx-trigger="load"
+				hx-swap="innerHTML"
+			>
+				<div class="card p-6 text-center">
+					<i class="fa-solid fa-spinner fa-spin text-fg-muted"></i>
+					<p class="text-sm text-fg-muted mt-2">Loading sync status...</p>
+				</div>
+			</div>
+
+			// Sync Mappings Table (HTMX lazy-loaded).
+			<div id="sync-mappings-container"
+				hx-get={ fmt.Sprintf("/campaigns/%s/api-keys/sync-mappings", campaignID) }
+				hx-trigger="load"
+				hx-swap="innerHTML"
+			>
+				<div class="card p-6 text-center">
+					<i class="fa-solid fa-spinner fa-spin text-fg-muted"></i>
+					<p class="text-sm text-fg-muted mt-2">Loading sync mappings...</p>
+				</div>
+			</div>
+
 			// Security info.
 			<div class="card p-6">
 				<div class="flex items-start gap-4">

internal/plugins/syncapi/routes.go

@@ -44,6 +44,10 @@ func RegisterCampaignRoutes(e *echo.Echo, h *Handler, campaignSvc campaigns.Camp
 
 	// Sync status embed (owner only — used by dashboard sync status block).
 	cg.GET("/sync-status", h.SyncStatusEmbed, campaigns.RequireRole(campaigns.RoleOwner))
+
+	// Sync dashboard fragments (owner only — HTMX-loaded on API keys page).
+	cg.GET("/api-keys/sync-overview", h.SyncOverviewFragment, campaigns.RequireRole(campaigns.RoleOwner))
+	cg.GET("/api-keys/sync-mappings", h.SyncMappingsFragment, campaigns.RequireRole(campaigns.RoleOwner))
 }
 
 // RegisterAPIRoutes adds the public REST API endpoints under /api/v1/.