Fix mobile delivery polling and human KITN rewards

Author: borisolver

platform_blueprint/deploy/prod/nginx_conf_d/apicleanapp.conf

@@ -13,6 +13,7 @@ server {
         location = /update_or_create_user { proxy_pass http://127.0.0.1:8079; proxy_set_header Host $host; proxy_read_timeout 60; proxy_redirect http:// https://; }
         location = /report { proxy_pass http://127.0.0.1:8079; proxy_set_header Host $host; proxy_read_timeout 60; proxy_redirect http:// https://; }
         location = /read_report { proxy_pass http://127.0.0.1:8079; proxy_set_header Host $host; proxy_read_timeout 60; proxy_redirect http:// https://; }
+        location = /read_report_email_status { proxy_pass http://127.0.0.1:8079; proxy_set_header Host $host; proxy_read_timeout 60; proxy_redirect http:// https://; }
         location = /get_map { proxy_pass http://127.0.0.1:8079; proxy_set_header Host $host; proxy_read_timeout 60; proxy_redirect http:// https://; }
         location = /get_stats { proxy_pass http://127.0.0.1:8079; proxy_set_header Host $host; proxy_read_timeout 60; proxy_redirect http:// https://; }
         location = /get_teams { proxy_pass http://127.0.0.1:8079; proxy_set_header Host $host; proxy_read_timeout 60; proxy_redirect http:// https://; }

report-listener/database/rewards.go

@@ -0,0 +1,43 @@
+package database
+
+import (
+	"context"
+	"fmt"
+	"strings"
+)
+
+// IncrementReporterDailyKITNs preserves the legacy mobile reward behavior for
+// wallet-backed human submissions that now enter through the canonical ingest path.
+func (d *Database) IncrementReporterDailyKITNs(ctx context.Context, reporterID string) error {
+	reporterID = strings.TrimSpace(reporterID)
+	if reporterID == "" {
+		return nil
+	}
+
+	tx, err := d.db.BeginTx(ctx, nil)
+	if err != nil {
+		return fmt.Errorf("begin reward tx: %w", err)
+	}
+	defer tx.Rollback()
+
+	if _, err := tx.ExecContext(ctx, `
+		UPDATE users
+		SET kitns_daily = kitns_daily + 1
+		WHERE id = ?
+	`, reporterID); err != nil {
+		return fmt.Errorf("increment users.kitns_daily: %w", err)
+	}
+
+	if _, err := tx.ExecContext(ctx, `
+		UPDATE users_shadow
+		SET kitns_daily = kitns_daily + 1
+		WHERE id = ?
+	`, reporterID); err != nil {
+		return fmt.Errorf("increment users_shadow.kitns_daily: %w", err)
+	}
+
+	if err := tx.Commit(); err != nil {
+		return fmt.Errorf("commit reward tx: %w", err)
+	}
+	return nil
+}

report-listener/handlers/human_ingest.go

@@ -8,6 +8,7 @@ import (
 	"encoding/hex"
 	"encoding/json"
 	"fmt"
+	"log"
 	"net/http"
 	"strings"
 	"time"
@@ -309,6 +310,11 @@ func (h *Handlers) SubmitHumanReportV1(c *gin.Context) {
 			return
 		}
 	}
+	if receipt.ReportID > 0 && !receipt.IdempotencyReplay && strings.TrimSpace(req.ReporterID) != "" {
+		if err := h.db.IncrementReporterDailyKITNs(c.Request.Context(), req.ReporterID); err != nil {
+			log.Printf("warn: failed to increment KITNs for human report %d (%s): %v", receipt.ReportID, req.ReporterID, err)
+		}
+	}
 	c.JSON(statusCode, h.humanReceiptResponseFromWire(c.Request.Context(), receipt))
 }