From acdaffff29a76850124b901c6093ddc07ffc06c1 Mon Sep 17 00:00:00 2001
From: oppiliappan <me@oppi.li>
Date: Thu, 18 Jun 2026 13:31:37 +0100
Subject: [PATCH] appview/db: add handlers for onboarding flow

Signed-off-by: oppiliappan <me@oppi.li>
---
 appview/db/onboarding.go | 90 ++++++++++++++++++++++++++++++++++++++++
 1 file changed, 90 insertions(+)
 create mode 100644 appview/db/onboarding.go

diff --git a/appview/db/onboarding.go b/appview/db/onboarding.go
new file mode 100644
index 00000000..3664a2e1
--- /dev/null
+++ b/appview/db/onboarding.go
@@ -0,0 +1,90 @@
+package db
+
+import (
+	"database/sql"
+	"log"
+	"time"
+
+	"tangled.org/core/appview/models"
+)
+
+// GetOnboarding returns the onboarding record for a did, or (nil, nil) if none exists.
+func GetOnboarding(e Execer, did string) (*models.Onboarding, error) {
+	query := `select did, step, status, created, updated from onboarding where did = ?`
+	row := e.QueryRow(query, did)
+
+	var o models.Onboarding
+	var status string
+	var created, updated string
+	err := row.Scan(&o.Did, &o.Step, &status, &created, &updated)
+	if err == sql.ErrNoRows {
+		return nil, nil
+	}
+	if err != nil {
+		return nil, err
+	}
+
+	o.Status = models.OnboardingStatus(status)
+	if t, err := time.Parse(time.RFC3339, created); err == nil {
+		o.Created = t
+	}
+	if t, err := time.Parse(time.RFC3339, updated); err == nil {
+		o.Updated = t
+	}
+
+	return &o, nil
+}
+
+func UpsertOnboarding(e Execer, o *models.Onboarding) error {
+	query := `
+		insert into onboarding (did, step, status, updated)
+		values (?, ?, ?, strftime('%Y-%m-%dT%H:%M:%SZ', 'now'))
+		on conflict(did) do update set
+			step = excluded.step,
+			status = excluded.status,
+			updated = excluded.updated
+	`
+	_, err := e.Exec(query, o.Did, o.Step, string(o.Status))
+	return err
+}
+
+// AdvanceOnboardingStep moves the stored step forward to the given step. It is
+// monotonic: it never decreases the step, so navigating back to an earlier page
+// and re-submitting does not regress recorded progress.
+func AdvanceOnboardingStep(e Execer, did string, step int) error {
+	_, err := e.Exec(
+		`update onboarding set step = ?, updated = strftime('%Y-%m-%dT%H:%M:%SZ', 'now') where did = ? and step < ?`,
+		step, did, step,
+	)
+	return err
+}
+
+func CompleteOnboarding(e Execer, did string) error {
+	_, err := e.Exec(
+		`update onboarding set status = ?, step = ?, updated = strftime('%Y-%m-%dT%H:%M:%SZ', 'now') where did = ?`,
+		string(models.OnboardingCompleted), models.OnboardingStepDone, did,
+	)
+	return err
+}
+
+func SkipOnboarding(e Execer, did string) error {
+	_, err := e.Exec(
+		`update onboarding set status = ?, updated = strftime('%Y-%m-%dT%H:%M:%SZ', 'now') where did = ?`,
+		string(models.OnboardingSkipped), did,
+	)
+	return err
+}
+
+// IsOnboarding reports whether a did has an in-progress onboarding record.
+func IsOnboarding(e Execer, did string) (bool, error) {
+	var exists bool
+	err := e.QueryRow(
+		`select exists(select 1 from onboarding where did = ? and status = 'in_progress')`,
+		did,
+	).Scan(&exists)
+	if err != nil {
+		log.Println("failed to check onboarding status", err)
+		return false, err
+	}
+	return exists, nil
+}
-- 
2.51.2