v0.15.4: Hub disabled notification, PushOnce, ReportingDisabled field

controller/README.md

@@ -4,7 +4,7 @@
 
 A single, lightweight Go container that replaces Portainer + scattered systemd scripts with a unified, Hungarian-language web dashboard for managing Docker Compose stacks, backups, storage, monitoring, and notifications on customer hardware.
 
-**Current version: v0.14.1**
+**Current version: v0.15.4**
 
 ---
 

controller/cmd/controller/main.go

@@ -247,17 +247,21 @@ func main() {
 
 	// --- Central hub reporting ---
 	var hubPusher *report.Pusher
-	if cfg.Hub.Enabled && cfg.Hub.URL != "" {
-		pushInterval, err := time.ParseDuration(cfg.Hub.PushInterval)
-		if err != nil {
-			pushInterval = 15 * time.Minute
-		}
+	if cfg.Hub.URL != "" && cfg.Hub.APIKey != "" {
 		hubPusher = report.NewPusher(&cfg.Hub, logger)
-		sched.Every("hub-report", pushInterval, func(ctx context.Context) error {
-			r := report.BuildReport(cfg, stackMgr, backupMgr, cpuCollector, metricsStore, Version, sett.GetStoragePaths())
-			return hubPusher.Push(r)
-		})
-		logger.Printf("[INFO] Hub reporting enabled (every %s to %s)", pushInterval, cfg.Hub.URL)
+		if cfg.Hub.Enabled {
+			pushInterval, err := time.ParseDuration(cfg.Hub.PushInterval)
+			if err != nil {
+				pushInterval = 15 * time.Minute
+			}
+			sched.Every("hub-report", pushInterval, func(ctx context.Context) error {
+				r := report.BuildReport(cfg, stackMgr, backupMgr, cpuCollector, metricsStore, Version, sett.GetStoragePaths())
+				return hubPusher.Push(r)
+			})
+			logger.Printf("[INFO] Hub reporting enabled (every %s to %s)", pushInterval, cfg.Hub.URL)
+		} else {
+			logger.Printf("[INFO] Hub reporting disabled — will send disabled notification to %s", cfg.Hub.URL)
+		}
 	}
 
 	sched.Start(ctx)
@@ -284,11 +288,27 @@ func main() {
 
 		// Hub report
 		if hubPusher != nil {
-			r := report.BuildReport(cfg, stackMgr, backupMgr, cpuCollector, metricsStore, Version, sett.GetStoragePaths())
-			if err := hubPusher.Push(r); err != nil {
-				logger.Printf("[WARN] Startup hub report failed: %v", err)
+			if cfg.Hub.Enabled {
+				r := report.BuildReport(cfg, stackMgr, backupMgr, cpuCollector, metricsStore, Version, sett.GetStoragePaths())
+				if err := hubPusher.Push(r); err != nil {
+					logger.Printf("[WARN] Startup hub report failed: %v", err)
+				} else {
+					logger.Println("[INFO] Startup hub report sent")
+				}
 			} else {
-				logger.Println("[INFO] Startup hub report sent")
+				// Send a minimal "disabled" notification so hub knows reporting is intentionally off
+				r := &report.Report{
+					Version:           1,
+					CustomerID:        cfg.Customer.ID,
+					CustomerName:      cfg.Customer.Name,
+					ControllerVersion: Version,
+					Timestamp:         time.Now().UTC(),
+					ReportingDisabled: true,
+					Health:            report.HealthReport{Status: "disabled", Issues: []string{}, Warnings: []string{}},
+					Stacks:            report.StacksReport{Deployed: []string{}, Available: []string{}},
+					Containers:        report.ContainerReport{List: []report.ContainerDetailReport{}},
+				}
+				hubPusher.PushOnce(r)
 			}
 		}
 	}()

controller/internal/report/pusher.go

@@ -84,3 +84,39 @@ func (p *Pusher) Push(report *Report) error {
 	p.logger.Printf("[WARN] Hub report push failed after 3 attempts: %v", lastErr)
 	return nil
 }
+
+// PushOnce sends a single report regardless of the enabled flag.
+// Used for one-time notifications (e.g., reporting-disabled on startup).
+func (p *Pusher) PushOnce(report *Report) error {
+	if p.hubURL == "" || p.apiKey == "" {
+		return nil
+	}
+
+	data, err := json.Marshal(report)
+	if err != nil {
+		p.logger.Printf("[WARN] Hub report marshal failed: %v", err)
+		return nil
+	}
+
+	url := p.hubURL + "/api/v1/report"
+
+	req, err := http.NewRequest(http.MethodPost, url, bytes.NewReader(data))
+	if err != nil {
+		return nil
+	}
+	req.Header.Set("Content-Type", "application/json")
+	req.Header.Set("Authorization", "Bearer "+p.apiKey)
+
+	resp, err := p.httpClient.Do(req)
+	if err != nil {
+		p.logger.Printf("[WARN] Hub disabled-notification failed: %v", err)
+		return nil
+	}
+	io.Copy(io.Discard, resp.Body)
+	resp.Body.Close()
+
+	if resp.StatusCode >= 200 && resp.StatusCode < 300 {
+		p.logger.Printf("[INFO] Hub disabled-notification sent (%d bytes)", len(data))
+	}
+	return nil
+}

controller/internal/report/types.go

@@ -9,6 +9,7 @@ type Report struct {
 	CustomerName      string           `json:"customer_name"`
 	ControllerVersion string           `json:"controller_version"`
 	Timestamp         time.Time        `json:"timestamp"`
+	ReportingDisabled bool             `json:"reporting_disabled,omitempty"`
 	System            SystemReport     `json:"system"`
 	Storage           []StorageReport  `json:"storage"`
 	Containers        ContainerReport  `json:"containers"`