make major bonus updates

2026-07-31 16:13:05 +01:00
parent 8834281b4d
commit d720f4e863
12 changed files with 4174 additions and 2598 deletions
@@ -19,7 +19,7 @@
 ## Auth

 | Role           | Auth                       | Session                    | Record in    |
-| ---------------- | -------------------------- | --------------------------- | -------------------- |
+| -------------- | -------------------------- | -------------------------- | ------------ |
 | Admin (parent) | PB email+pass              | 24hr JWT                   | `fam_admins` |
 | Member (child) | Invite code + device token | `device_token` cookie only | `members`    |

@@ -61,11 +61,13 @@
 ## Data Flow

 ### Reads (both roles)
+
 - **Parent (admin):** `famStore.init()` fetches all collections via PB SDK (authenticated via `pb_token` cookie).
 - **Child (member):** `famStore.init()` fetches all collections via PB SDK — **unauthenticated/anonymous**. All family-scoped collections have public `listRule` / `viewRule` (empty string = allow all), so reads work without any auth. PB SDK `.subscribe()` also works anonymously for public collections.
 - **TopNav season pills:** Read from `famStore.seasons` — reactive, no extra fetches needed.

 ### Writes (both roles go through Hono proxy)
+
 - **Chore toggle:** Browser → Hono proxy → PB (auth via device token or admin JWT)
 - **Admin CRUD:** Form actions → Hono proxy → PB (admin JWT via `sessionHeaders`)
 - **Member updates:** Browser → Hono proxy → PB (auth via `x-device-token` + `x-device-famid`)
@@ -75,6 +77,7 @@
 - **WhatsApp:** Deferred — Hono CRON handler has pluggable notification interface

 ### UI reactivity
+
 - Svelte `$state` / `$derived` / `$effect`
 - PB SDK `.subscribe()` for realtime multi-user sync (public reads → works for both roles)
 - `famStore.applyRecord()` for instant optimistic UI feedback from form actions
@@ -84,15 +87,16 @@
 Env vars must be declared in `frontend/src/env.ts` using `defineEnvVars` from `@sveltejs/kit/hooks`:

 ```ts
-import { defineEnvVars } from '@sveltejs/kit/hooks';
+import { defineEnvVars } from "@sveltejs/kit/hooks";
 export const variables = defineEnvVars({
  DEBUG_RECORD_ID: {},
  SERVER_IP: { public: true },
-  PB_PORT: {public: true}
+  PB_PORT: { public: true },
 });
 ```

 Only vars with `{public: true}` are exposed to client-side code via `$app/env/public`. If you need a new client-side env var (e.g., `PUBLIC_PB_URL`), you must:
+
 1. Add it to `.env` with `PUBLIC_` prefix
 2. Add it to `frontend/src/env.ts` with `{public: true}`

@@ -101,6 +105,7 @@ The actual values come from `.env` (symlinked from project root at `frontend/.en
 ## ⚠️ CRITICAL: Reactivity Pattern (NEVER use `$effect` to sync from famStore)

 **Do NOT do this:**
+
 ```svelte
 <!-- ❌ WRONG: $effect syncing local state from famStore fights Svelte reactivity -->
 let items = $state(data.items);
@@ -111,21 +116,45 @@ $effect(() => {
 ```

 **Do this instead:**
+
 ```svelte
 <!-- ✅ RIGHT: Initialize from famStore, mutate via applyRecord in callbacks -->
 let items = $state(famStore.initialized ? famStore.items : (data.items || []));
 ```

+### ⚠️ CRITICAL: `$state` vs `$derived` for famStore collections
+
+**When a page reads data that should update via SSE (realtime from other users/actions), you MUST use `$derived` — NOT `$state`.**
+
+This is the most commonly missed rule. Agents repeatedly initialize collections from `famStore` with `$state`, which captures a **frozen snapshot** at init time. When PocketBase pushes a record via SSE → `famStore.applyRecord()`, the `$state` variable never reacts — the UI stays stale until a page refresh.
+
+**Rule: if the data should update without a refresh, use `$derived`.**
+
+```svelte
+// ❌ WRONG — frozen snapshot, won't react to SSE updates
+let configs = $state(famStore.initialized ? famStore.bonusConfigs : data.configs);
+
+// ✅ RIGHT — reactive, updates when famStore changes via SSE
+let configs = $derived(
+  famStore.initialized ? famStore.bonusConfigs : (data.configs || [])
+);
+```
+
+**The only exception:** high-frequency member actions (like chore toggles) that need **optimistic UI** before the server responds. Those use `$state` + `famStore.applyRecord()` for instant feedback, then reconcile on the server response. See `applyRecord` pattern below.
+
+**All other pages (admin CRUD, bonuses, rewards, settings, etc.) must use `$derived`** so that SSE updates flow through `famStore` → `$derived` → UI automatically.
+
 ## Update Patterns

 Two patterns based on who's acting:

 | Pattern                      | Who    | Frequency            | Sensitivity              | Optimistic?                                   | Auth                      |
-|---------|-----|-----------|-------------|-------------|------|
+| ---------------------------- | ------ | -------------------- | ------------------------ | --------------------------------------------- | ------------------------- |
 | Direct `fetch` + `memberApi` | Member | High (chore toggles) | None                     | Yes (instant UI, reconcile on response)       | `x-device-token` header   |
 | Form action                  | Admin  | Low (CRUD)           | High (settings, members) | No — form is server-side, wait for round trip | httpOnly `session` cookie |

 **Member direct fetch** — optimistic UI via local state mutation, reconciled on response:
+
 ```svelte
 let completions = $state(data.completions)
 async function toggle(chore) {
@@ -1,4 +1,5 @@
 import { PocketBase } from 'pocketbase';
+import type { Session } from './lib/types';

 // See https://svelte.dev/docs/kit/types#app.d.ts
 // for information about these interfaces
@@ -8,6 +9,7 @@ declare global {
 		// interface Error {}
 		interface Locals {
 			pb: PocketBase;
+			session?: Session | null;
 		}
 		// interface PageData {}
 		// interface PageState {}
@@ -9,15 +9,20 @@ function sessionHeaders(event: RequestEvent): Record<string, string> {
 	return {
 		'x-session-famid': s.famId,
 		'x-session-userid': s.userId,
-		'Content-Type': 'application/json',
+		'Content-Type': 'application/json'
 	};
 }

-async function request(method: string, path: string, body?: unknown, headers?: Record<string, string>) {
+async function request(
+	method: string,
+	path: string,
+	body?: unknown,
+	headers?: Record<string, string>
+) {
 	const res = await fetch(`${HONO_URL}${path}`, {
 		method,
 		headers: headers || { 'Content-Type': 'application/json' },
-		body: body ? JSON.stringify(body) : undefined,
+		body: body ? JSON.stringify(body) : undefined
 	});
 	const data = await res.json();
 	if (!res.ok) throw new Error(data.error || `${method} ${path} failed`);
@@ -29,14 +34,30 @@ export const hono = {
 		async list(event: RequestEvent, resource: string, famId: string) {
 			return request('GET', `/api/admin/${famId}/${resource}`, undefined, sessionHeaders(event));
 		},
-		async create(event: RequestEvent, resource: string, famId: string, data: Record<string, unknown>) {
+		async create(
+			event: RequestEvent,
+			resource: string,
+			famId: string,
+			data: Record<string, unknown>
+		) {
 			return request('POST', `/api/admin/${famId}/${resource}`, data, sessionHeaders(event));
 		},
-		async update(event: RequestEvent, resource: string, famId: string, id: string, data: Record<string, unknown>) {
+		async update(
+			event: RequestEvent,
+			resource: string,
+			famId: string,
+			id: string,
+			data: Record<string, unknown>
+		) {
 			return request('PATCH', `/api/admin/${famId}/${resource}/${id}`, data, sessionHeaders(event));
 		},
 		async remove(event: RequestEvent, resource: string, famId: string, id: string) {
-			return request('DELETE', `/api/admin/${famId}/${resource}/${id}`, undefined, sessionHeaders(event));
+			return request(
+				'DELETE',
+				`/api/admin/${famId}/${resource}/${id}`,
+				undefined,
+				sessionHeaders(event)
+			);
 		},
 		async renameFam(event: RequestEvent, famId: string, name: string) {
 			return request('PATCH', `/api/admin/${famId}/fam`, { name }, sessionHeaders(event));
@@ -63,46 +84,126 @@ export const hono = {
 			return request('GET', `/api/admin/${famId}/rewards`, undefined, sessionHeaders(event));
 		},
 		async claimReward(event: RequestEvent, famId: string, rewardId: string) {
-			return request('POST', `/api/admin/${famId}/rewards/${rewardId}/claim`, undefined, sessionHeaders(event));
+			return request(
+				'POST',
+				`/api/admin/${famId}/rewards/${rewardId}/claim`,
+				undefined,
+				sessionHeaders(event)
+			);
 		},
 		async issueAllRewards(event: RequestEvent, famId: string, memberId: string, message?: string) {
-			return request('POST', `/api/admin/${famId}/rewards/issue-all`, { memberId, message }, sessionHeaders(event));
+			return request(
+				'POST',
+				`/api/admin/${famId}/rewards/issue-all`,
+				{ memberId, message },
+				sessionHeaders(event)
+			);
 		},
 		async bonusConfigs(event: RequestEvent, famId: string) {
 			return request('GET', `/api/admin/${famId}/bonus-configs`, undefined, sessionHeaders(event));
 		},
 		async bonusConfigProgress(event: RequestEvent, famId: string) {
-			return request('GET', `/api/admin/${famId}/bonus-configs/progress`, undefined, sessionHeaders(event));
+			return request(
+				'GET',
+				`/api/admin/${famId}/bonus-configs/progress`,
+				undefined,
+				sessionHeaders(event)
+			);
 		},
 		async evaluateBonusConfig(event: RequestEvent, famId: string, configId?: string) {
-			return request('POST', `/api/admin/${famId}/bonus-configs/evaluate`, { configId }, sessionHeaders(event));
+			return request(
+				'POST',
+				`/api/admin/${famId}/bonus-configs/evaluate`,
+				{ configId },
+				sessionHeaders(event)
+			);
 		},
-		async triggerBonusConfig(event: RequestEvent, famId: string, configId: string, memberId?: string) {
-			return request('POST', `/api/admin/${famId}/bonus-configs/${configId}/trigger`, { memberId }, sessionHeaders(event));
+		async triggerBonusConfig(
+			event: RequestEvent,
+			famId: string,
+			configId: string,
+			memberId?: string
+		) {
+			return request(
+				'POST',
+				`/api/admin/${famId}/bonus-configs/${configId}/trigger`,
+				{ memberId },
+				sessionHeaders(event)
+			);
 		},
-		async assignBonusConfig(event: RequestEvent, famId: string, configId: string, data: Record<string, unknown>) {
-			return request('POST', `/api/admin/${famId}/bonus-configs/${configId}/assign`, data, sessionHeaders(event));
+		async assignBonusConfig(
+			event: RequestEvent,
+			famId: string,
+			configId: string,
+			data: Record<string, unknown>
+		) {
+			return request(
+				'POST',
+				`/api/admin/${famId}/bonus-configs/${configId}/assign`,
+				data,
+				sessionHeaders(event)
+			);
 		},
-		async completeBonusConfig(event: RequestEvent, famId: string, configId: string, phase?: string) {
-			return request('POST', `/api/admin/${famId}/bonus-configs/${configId}/complete`, { phase }, sessionHeaders(event));
+		async completeBonusConfig(event: RequestEvent, famId: string, configId: string) {
+			return request(
+				'POST',
+				`/api/admin/${famId}/bonus-configs/${configId}/complete`,
+				undefined,
+				sessionHeaders(event)
+			);
 		},
 		async destroyBonusConfig(event: RequestEvent, famId: string, configId: string) {
-			return request('POST', `/api/admin/${famId}/bonus-configs/${configId}/destroy`, undefined, sessionHeaders(event));
+			return request(
+				'POST',
+				`/api/admin/${famId}/bonus-configs/${configId}/destroy`,
+				undefined,
+				sessionHeaders(event)
+			);
 		},
 		async bonusConfigTallies(event: RequestEvent, famId: string) {
-			return request('GET', `/api/admin/${famId}/bonus-configs/tallies`, undefined, sessionHeaders(event));
+			return request(
+				'GET',
+				`/api/admin/${famId}/bonus-configs/tallies`,
+				undefined,
+				sessionHeaders(event)
+			);
 		},
 		async revokeCompletion(event: RequestEvent, famId: string, completionId: string) {
-			return request('POST', `/api/admin/${famId}/completions/${completionId}/revoke`, undefined, sessionHeaders(event));
+			return request(
+				'POST',
+				`/api/admin/${famId}/completions/${completionId}/revoke`,
+				undefined,
+				sessionHeaders(event)
+			);
 		},
 		async sendMessage(event: RequestEvent, famId: string, memberId: string, message: string) {
-			return request('POST', `/api/admin/${famId}/send-message`, { memberId, message }, sessionHeaders(event));
+			return request(
+				'POST',
+				`/api/admin/${famId}/send-message`,
+				{ memberId, message },
+				sessionHeaders(event)
+			);
 		},
 		async memberChores(event: RequestEvent, famId: string, memberId: string) {
-			return request('GET', `/api/admin/${famId}/members/${memberId}/chores`, undefined, sessionHeaders(event));
+			return request(
+				'GET',
+				`/api/admin/${famId}/members/${memberId}/chores`,
+				undefined,
+				sessionHeaders(event)
+			);
 		},
-		async updateMember(event: RequestEvent, famId: string, memberId: string, data: Record<string, unknown>) {
-			return request('PATCH', `/api/admin/${famId}/members/${memberId}`, data, sessionHeaders(event));
+		async updateMember(
+			event: RequestEvent,
+			famId: string,
+			memberId: string,
+			data: Record<string, unknown>
+		) {
+			return request(
+				'PATCH',
+				`/api/admin/${famId}/members/${memberId}`,
+				data,
+				sessionHeaders(event)
+			);
 		},
 		async getProfile(event: RequestEvent, famId: string) {
 			return request('GET', `/api/admin/${famId}/profile`, undefined, sessionHeaders(event));
@@ -115,6 +216,6 @@ export const hono = {
 		},
 		async request(event: RequestEvent, method: string, path: string, body?: unknown) {
 			return request(method, path, body, sessionHeaders(event));
-		},
-	},
+		}
+	}
 };
@@ -1,99 +1,145 @@
 import { pb } from '$lib/pocketbase';
 import type {
-	Member, ChoreTemplate, AssignedChore, Completion,
-	WeeklyHistory, Reward, BonusConfig, Fam, Season,
+	Member,
+	ChoreTemplate,
+	AssignedChore,
+	Completion,
+	WeeklyHistory,
+	Reward,
+	BonusConfig,
+	BonusTemplate,
+	Fam,
+	Season
 } from '$lib/types';

-type CollectionName = 'members' | 'chore_templates' | 'assigned_chores' | 'completions' | 'bonus_configs' | 'rewards' | 'seasons';
+type CollectionName =
+	| 'members'
+	| 'chore_templates'
+	| 'assigned_chores'
+	| 'completions'
+	| 'bonus_configs'
+	| 'bonus_templates'
+	| 'rewards'
+	| 'seasons';

 class FamStore {
-	fam = $state<Fam | null>(null)
-	members = $state<Member[]>([])
-	templates = $state<ChoreTemplate[]>([])
-	assigned = $state<AssignedChore[]>([])
-	completions = $state<Completion[]>([])
-	history = $state<WeeklyHistory[]>([])
-	rewards = $state<Reward[]>([])
-	bonusConfigs = $state<BonusConfig[]>([])
-	seasons = $state<Season[]>([])
-	initialized = $state(false)
-	famId = $state('')
+	fam = $state<Fam | null>(null);
+	members = $state<Member[]>([]);
+	templates = $state<ChoreTemplate[]>([]);
+	assigned = $state<AssignedChore[]>([]);
+	completions = $state<Completion[]>([]);
+	history = $state<WeeklyHistory[]>([]);
+	rewards = $state<Reward[]>([]);
+	bonusConfigs = $state<BonusConfig[]>([]);
+	bonusTemplates = $state<BonusTemplate[]>([]);
+	seasons = $state<Season[]>([]);
+	initialized = $state(false);
+	famId = $state('');

-	private unsubs: (() => void)[] = []
-	private destroyed = false
+	private unsubs: (() => void)[] = [];
+	private destroyed = false;

 	memberMap(): Map<string, Member> {
-		return new Map(this.members.map((m) => [m.id, m]))
+		return new Map(this.members.map((m) => [m.id, m]));
 	}

 	templateMap(): Map<string, ChoreTemplate> {
-		return new Map(this.templates.map((t) => [t.id, t]))
+		return new Map(this.templates.map((t) => [t.id, t]));
 	}

 	bonusConfigMap(): Map<string, BonusConfig> {
-		return new Map(this.bonusConfigs.map((b) => [b.id, b]))
+		return new Map(this.bonusConfigs.map((b) => [b.id, b]));
 	}

 	assignedForMember(memberId: string): AssignedChore[] {
-		return this.assigned.filter((a) => a.memberId === memberId)
+		return this.assigned.filter((a) => a.memberId === memberId);
 	}

 	completionsForDate(date: string): Completion[] {
-		return this.completions.filter((c) => (c.date?.slice(0, 10) || c.date) === date)
+		return this.completions.filter((c) => (c.date?.slice(0, 10) || c.date) === date);
 	}

 	isCompleted(assignedChoreId: string, date: string): boolean {
-		return this.completions.some((c) => c.assignedChoreId === assignedChoreId && (c.date?.slice(0, 10) || c.date) === date)
+		return this.completions.some(
+			(c) => c.assignedChoreId === assignedChoreId && (c.date?.slice(0, 10) || c.date) === date
+		);
 	}

-	private initPromise: Promise<void> | null = null
+	private initPromise: Promise<void> | null = null;

 	async init(famId: string) {
-		if (this.initialized && this.famId === famId) return
+		if (this.initialized && this.famId === famId) return;

 		// Wait for any in-flight init to finish first
 		if (this.initPromise) {
-			await this.initPromise
-			if (this.initialized && this.famId === famId) return
+			await this.initPromise;
+			if (this.initialized && this.famId === famId) return;
 		}

-		this.cleanup()
-		this.destroyed = false
-		this.famId = famId
+		this.cleanup();
+		this.destroyed = false;
+		this.famId = famId;

 		this.initPromise = (async () => {
 			try {
-				const [famRes, membersRes, templatesRes, assignedRes, completionsRes, bonusConfigsRes, rewardsRes, seasonsRes] =
-					await Promise.all([
+				const [
+					famRes,
+					membersRes,
+					templatesRes,
+					assignedRes,
+					completionsRes,
+					bonusConfigsRes,
+					bonusTemplatesRes,
+					rewardsRes,
+					seasonsRes
+				] = await Promise.all([
 					pb.collection('fams').getOne(famId) as Promise<Fam>,
-						pb.collection('members').getFullList({ filter: `famId = '${famId}'` }) as Promise<Member[]>,
-						pb.collection('chore_templates').getFullList({ filter: `famId = '${famId}'` }) as Promise<ChoreTemplate[]>,
-						pb.collection('assigned_chores').getFullList({ filter: `famId = '${famId}'` }) as Promise<AssignedChore[]>,
-						pb.collection('completions').getFullList({ filter: `famId = '${famId}'` }) as Promise<Completion[]>,
-						pb.collection('bonus_configs').getFullList({ filter: `famId = '${famId}'` }) as Promise<BonusConfig[]>,
-						pb.collection('rewards').getFullList({ filter: `famId = '${famId}'` }) as Promise<Reward[]>,
-						pb.collection('seasons').getFullList({ filter: `famId = '${famId}'` }) as Promise<Season[]>,
-					])
-				this.fam = famRes
-				this.members = membersRes
-				this.templates = templatesRes
-				this.assigned = assignedRes
-				this.completions = completionsRes
-				this.bonusConfigs = bonusConfigsRes
-				this.rewards = rewardsRes
-				this.seasons = seasonsRes
-				this.initialized = true
+					pb.collection('members').getFullList({ filter: `famId = '${famId}'` }) as Promise<
+						Member[]
+					>,
+					pb.collection('chore_templates').getFullList({ filter: `famId = '${famId}'` }) as Promise<
+						ChoreTemplate[]
+					>,
+					pb.collection('assigned_chores').getFullList({ filter: `famId = '${famId}'` }) as Promise<
+						AssignedChore[]
+					>,
+					pb.collection('completions').getFullList({ filter: `famId = '${famId}'` }) as Promise<
+						Completion[]
+					>,
+					pb.collection('bonus_configs').getFullList({ filter: `famId = '${famId}'` }) as Promise<
+						BonusConfig[]
+					>,
+					pb.collection('bonus_templates').getFullList({ filter: `famId = '${famId}'` }) as Promise<
+						BonusTemplate[]
+					>,
+					pb.collection('rewards').getFullList({ filter: `famId = '${famId}'` }) as Promise<
+						Reward[]
+					>,
+					pb.collection('seasons').getFullList({ filter: `famId = '${famId}'` }) as Promise<
+						Season[]
+					>
+				]);
+				this.fam = famRes;
+				this.members = membersRes;
+				this.templates = templatesRes;
+				this.assigned = assignedRes;
+				this.completions = completionsRes;
+				this.bonusConfigs = bonusConfigsRes;
+				this.bonusTemplates = bonusTemplatesRes;
+				this.rewards = rewardsRes;
+				this.seasons = seasonsRes;
+				this.initialized = true;
 			} catch (e) {
-				console.error('FamStore.init failed:', e)
-				this.initPromise = null
-				throw e
+				console.error('FamStore.init failed:', e);
+				this.initPromise = null;
+				throw e;
 			}

-			await this.subscribe()
-			this.initPromise = null
-		})()
+			await this.subscribe();
+			this.initPromise = null;
+		})();

-		return this.initPromise!
+		return this.initPromise!;
 	}

 	private async subscribe() {
@@ -103,58 +149,92 @@ class FamStore {
 			{ collection: 'assigned_chores', filter: this.famId },
 			{ collection: 'completions', filter: this.famId },
 			{ collection: 'bonus_configs', filter: this.famId },
+			{ collection: 'bonus_templates', filter: this.famId },
 			{ collection: 'rewards', filter: this.famId },
-			{ collection: 'seasons', filter: this.famId },
-		]
+			{ collection: 'seasons', filter: this.famId }
+		];

 		const promises = subs.map(({ collection, filter }) => {
-			const filterStr = filter ? `famId = '${filter}'` : ''
-			return pb.collection(collection).subscribe('*', (data: any) => {
-				if (this.destroyed) return
-				this.handleRealtime(collection, data.action, data.record)
-			}, { filter: filterStr || undefined }).then((unsub) => {
-				if (this.destroyed) { unsub(); return }
-				this.unsubs.push(unsub)
-			}).catch((err: Error) => {
-				console.error(`[famStore] subscribe failed for ${collection}:`, err)
-			})
+			const filterStr = filter ? `famId = '${filter}'` : '';
+			return pb
+				.collection(collection)
+				.subscribe(
+					'*',
+					(data: any) => {
+						if (this.destroyed) return;
+						this.handleRealtime(collection, data.action, data.record);
+					},
+					{ filter: filterStr || undefined }
+				)
+				.then((unsub) => {
+					if (this.destroyed) {
+						unsub();
+						return;
+					}
+					this.unsubs.push(unsub);
 				})
+				.catch((err: Error) => {
+					console.error(`[famStore] subscribe failed for ${collection}:`, err);
+				});
+		});

-		await Promise.allSettled(promises)
+		await Promise.allSettled(promises);
 	}

 	// Called from form action callbacks for instant UI feedback,
 	// and from PB subscribe SSE for multi-user realtime.
 	applyRecord(collection: CollectionName, record: any, action: 'create' | 'update' | 'delete') {
 		const apply = <T extends { id: string }>(list: T[]): T[] => {
-			if (action === 'create') return [record, ...list]
-			if (action === 'update') return list.map((x) => (x.id === record.id ? { ...x, ...record } : x))
-			if (action === 'delete') return list.filter((x) => x.id !== record.id)
-			return list
-    }
+			if (action === 'create') return [record, ...list];
+			if (action === 'update')
+				return list.map((x) => (x.id === record.id ? { ...x, ...record } : x));
+			if (action === 'delete') return list.filter((x) => x.id !== record.id);
+			return list;
+		};

 		switch (collection) {
-			case 'members': this.members = apply(this.members); break
-			case 'chore_templates': this.templates = apply(this.templates); break
-			case 'assigned_chores': this.assigned = apply(this.assigned); break
-			case 'completions': this.completions = apply(this.completions); break
-			case 'bonus_configs': this.bonusConfigs = apply(this.bonusConfigs); break
-			case 'rewards': this.rewards = apply(this.rewards); break
-			case 'seasons': this.seasons = apply(this.seasons); break
+			case 'members':
+				this.members = apply(this.members);
+				break;
+			case 'chore_templates':
+				this.templates = apply(this.templates);
+				break;
+			case 'assigned_chores':
+				this.assigned = apply(this.assigned);
+				break;
+			case 'completions':
+				this.completions = apply(this.completions);
+				break;
+			case 'bonus_configs':
+				this.bonusConfigs = apply(this.bonusConfigs);
+				break;
+			case 'bonus_templates':
+				this.bonusTemplates = apply(this.bonusTemplates);
+				break;
+			case 'rewards':
+				this.rewards = apply(this.rewards);
+				break;
+			case 'seasons':
+				this.seasons = apply(this.seasons);
+				break;
 		}
 	}

 	private handleRealtime(collection: string, action: string, record: any) {
-		this.applyRecord(collection as CollectionName, record, action as 'create' | 'update' | 'delete')
+		this.applyRecord(
+			collection as CollectionName,
+			record,
+			action as 'create' | 'update' | 'delete'
+		);
 	}

 	cleanup() {
 		// TODO - we need to properly unsubscribe from pocketbase
-		this.destroyed = true
-		for (const unsub of this.unsubs) unsub()
-		this.unsubs = []
-		this.initialized = false
+		this.destroyed = true;
+		for (const unsub of this.unsubs) unsub();
+		this.unsubs = [];
+		this.initialized = false;
 	}
 }

-export const famStore = new FamStore()
+export const famStore = new FamStore();
@@ -1,156 +1,171 @@
-export type Frequency = 'daily' | 'weekly'
-export type RewardType = 'points' | 'money'
-export type BonusTarget = 'individual' | 'competitive' | 'collaborative'
-export type BonusType = 'threshold' | 'count' | 'manual'
-export type BonusOccurrence = 'recurring' | 'once'
-export type BonusRewardType = 'points' | 'cash' | 'prize'
-export type BonusPeriod = 'weekly' | 'monthly'
-export type BonusStatus = 'active' | 'archived'
-export type BonusState = 'pending' | 'unclaimed' | 'claimed'
+export type Frequency = 'daily' | 'weekly';
+export type RewardType = 'points' | 'money';
+export type BonusTarget = 'individual' | 'competitive' | 'collaborative';
+export type BonusType = 'threshold' | 'count' | 'manual';
+export type BonusOccurrence = 'recurring' | 'once';
+export type BonusRewardType = 'points' | 'cash' | 'prize';
+export type BonusPeriod = 'weekly' | 'monthly' | 'daily';
+export type BonusStatus = 'active' | 'completed' | 'disabled';
+export type BonusState = 'pending' | 'unclaimed' | 'claimed';
+
+export interface BonusTemplate {
+	id: string;
+	famId: string;
+	name: string;
+	description?: string;
+	target: BonusTarget;
+	type: BonusType;
+	occurrence: BonusOccurrence;
+	rewardType: BonusRewardType;
+	rewardValue: string;
+	criteriaValue?: number;
+	period?: BonusPeriod;
+	created: string;
+	updated: string;
+}

 export interface Season {
-	id: string
-	famId: string
-	name: string
-	color: string
-	active: boolean
-	autoDisable?: string
-	autoStart?: string
-	created: string
-	updated: string
+	id: string;
+	famId: string;
+	name: string;
+	color: string;
+	active: boolean;
+	autoDisable?: string;
+	autoStart?: string;
+	created: string;
+	updated: string;
 }

 export interface Fam {
-	id: string
-	name: string
-	slug: string
-	inviteCode: string
-	stripeCustomerId?: string
-	featureFlags: Record<string, boolean>
-	created: string
-	updated: string
+	id: string;
+	name: string;
+	slug: string;
+	inviteCode: string;
+	stripeCustomerId?: string;
+	featureFlags: Record<string, boolean>;
+	created: string;
+	updated: string;
 }

 export interface Member {
-	id: string
-	famId: string
-	name: string
-	color: string
-	deviceToken: string
-	deviceTokenHint: string
-	created: string
-	updated: string
+	id: string;
+	famId: string;
+	name: string;
+	color: string;
+	deviceToken: string;
+	deviceTokenHint: string;
+	created: string;
+	updated: string;
 }

 export interface ChoreTemplate {
-	id: string
-	famId: string
-	name: string
-	description?: string
-	defaultFrequency: Frequency
-	defaultType: RewardType
-	defaultValue: number
-	created: string
-	updated: string
+	id: string;
+	famId: string;
+	name: string;
+	description?: string;
+	defaultFrequency: Frequency;
+	defaultType: RewardType;
+	defaultValue: number;
+	created: string;
+	updated: string;
 }

 export interface AssignedChore {
-	id: string
-	famId: string
-	memberId: string
-	templateId: string
-	frequency: Frequency
-	type: RewardType
-	value: number
-	customName?: string
-	seasonIds?: string[]
-	created: string
-	updated: string
+	id: string;
+	famId: string;
+	memberId: string;
+	templateId: string;
+	frequency: Frequency;
+	type: RewardType;
+	value: number;
+	customName?: string;
+	seasonIds?: string[];
+	created: string;
+	updated: string;
 }

 export interface Completion {
-	id: string
-	famId: string
-	memberId: string
-	assignedChoreId: string
-	date: string
-	completedAt: string
+	id: string;
+	famId: string;
+	memberId: string;
+	assignedChoreId: string;
+	date: string;
+	completedAt: string;
 }

 export interface WeeklyHistory {
-	id: string
-	famId: string
-	memberId: string
-	weekStart: string
-	pointsEarned: number
-	moneyEarned: number
-	choresCompleted: number
-	bonusEarned: number
+	id: string;
+	famId: string;
+	memberId: string;
+	weekStart: string;
+	pointsEarned: number;
+	moneyEarned: number;
+	choresCompleted: number;
+	bonusEarned: number;
 }

 export interface BonusConfig {
-	id: string
-	famId: string
-	name: string
-	description?: string
-	target: BonusTarget
-	memberId?: string
-	type: BonusType
-	occurrence: BonusOccurrence
-	rewardType: BonusRewardType
-	rewardValue: string
-	criteriaValue?: number
-	period?: BonusPeriod
-	status: BonusStatus
-	phase?: 'template' | 'ready' | 'active' | 'completed'
-	created: string
-	updated: string
+	id: string;
+	famId: string;
+	name: string;
+	description?: string;
+	target: BonusTarget;
+	memberId?: string;
+	type: BonusType;
+	occurrence: BonusOccurrence;
+	rewardType: BonusRewardType;
+	rewardValue: string;
+	criteriaValue?: number;
+	period?: BonusPeriod;
+	status: BonusStatus;
+	created: string;
+	updated: string;
 }

 export interface Reward {
-	id: string
-	famId: string
-	memberId: string
-	bonusConfigId?: string
-	label: string
-	value: number
-	rewardType: BonusRewardType
-	status: 'unclaimed' | 'requested' | 'claimed'
-	claimedAt?: string
-	requestedAt?: string
-	date: string
-	created: string
-	updated: string
+	id: string;
+	famId: string;
+	memberId: string;
+	bonusConfigId?: string;
+	label: string;
+	value: number;
+	rewardType: BonusRewardType;
+	status: 'unclaimed' | 'requested' | 'claimed';
+	claimedAt?: string;
+	requestedAt?: string;
+	date: string;
+	created: string;
+	updated: string;
 }

 export interface BonusProgress {
-	memberId: string
-	memberName: string
-	memberColor: string
-	current: number
-	criteriaValue: number
-	reward: { id: string; status: string } | null
-	state: BonusState
-	achieved: boolean
+	memberId: string;
+	memberName: string;
+	memberColor: string;
+	current: number;
+	criteriaValue: number;
+	reward: { id: string; status: string } | null;
+	state: BonusState;
+	achieved: boolean;
 }

 export interface BonusConfigWithProgress {
-	config: BonusConfig
-	progress: BonusProgress[]
-	periodStart: string
-	periodEnd: string
+	config: BonusConfig;
+	progress: BonusProgress[];
+	periodStart: string;
+	periodEnd: string;
 }

 export interface Settings {
-	id: string
-	famId: string
-	webhookUrl?: string
+	id: string;
+	famId: string;
+	webhookUrl?: string;
 }

 export interface Session {
-	famId: string
-	userId: string
-	famSlug: string
-	memberName?: string
-	role?: string
+	famId: string;
+	userId: string;
+	famSlug: string;
+	memberName?: string;
+	role?: string;
 }
@@ -118,16 +118,22 @@
 	}

 	function rewardLabel(r: any): string {
-		if (r.rewardType === 'cash') return `£${(Number(r.value) / 100).toFixed(2)}`;
+		if (r.rewardType === 'cash') return `£${Number(r.value).toFixed(2)}`;
 		if (r.rewardType === 'points') return `${r.value} pts`;
 		return r.label;
 	}

 	function manualConfigs() {
-		return parentBonusConfigs.filter(
-			(b: any) =>
-				(b.phase === 'active' || (!b.phase && b.status === 'active')) && b.type === 'manual'
+		return parentBonusConfigs.filter((b: any) => {
+			if (!(b.status === 'active' && b.type === 'manual')) return false;
+			if (b.occurrence === 'once') {
+				const hasReward = parentRewards.some(
+					(r: any) => r.bonusConfigId === b.id && (!b.memberId || r.memberId === b.memberId)
 				);
+				if (hasReward) return false;
+			}
+			return true;
+		});
 	}

 	// ─── Child View (kanban) ───
@@ -140,11 +146,29 @@
 	let nameInput = $state('');
 	let showColorPicker = $state(false);

-	let templates = $derived(famStore.initialized ? (famStore.templates as ChoreTemplate[]) : (data.templates as ChoreTemplate[]));
-	let assigned = $derived(famStore.initialized ? (famStore.assigned as AssignedChore[]) : (data.assigned as AssignedChore[]));
-	let completions = $derived(famStore.initialized ? (famStore.completions as Completion[]) : (data.completions as Completion[]));
-	let rewards = $derived(famStore.initialized ? (famStore.rewards as Reward[]) : (data.rewards as Reward[]));
-	let bonusConfigs = $derived(famStore.initialized ? (famStore.bonusConfigs as BonusConfig[]) : (data.bonusConfigs as BonusConfig[]));
+	let templates = $derived(
+		famStore.initialized
+			? (famStore.templates as ChoreTemplate[])
+			: (data.templates as ChoreTemplate[])
+	);
+	let assigned = $derived(
+		famStore.initialized
+			? (famStore.assigned as AssignedChore[])
+			: (data.assigned as AssignedChore[])
+	);
+	let completions = $derived(
+		famStore.initialized
+			? (famStore.completions as Completion[])
+			: (data.completions as Completion[])
+	);
+	let rewards = $derived(
+		famStore.initialized ? (famStore.rewards as Reward[]) : (data.rewards as Reward[])
+	);
+	let bonusConfigs = $derived(
+		famStore.initialized
+			? (famStore.bonusConfigs as BonusConfig[])
+			: (data.bonusConfigs as BonusConfig[])
+	);

 	let loading = $state(true);
 	let error = $state('');
@@ -187,8 +211,12 @@
 	let completedToday = $derived(
 		completions.filter((c) => c.memberId === memberId && c.date?.slice(0, 10) === todayChild)
 	);
-	let claimableRewardsChild = $derived(rewards.filter((r) => r.memberId === memberId && r.status === 'unclaimed'));
-	let requestedRewardsChild = $derived(rewards.filter((r) => r.memberId === memberId && r.status === 'requested'));
+	let claimableRewardsChild = $derived(
+		rewards.filter((r) => r.memberId === memberId && r.status === 'unclaimed')
+	);
+	let requestedRewardsChild = $derived(
+		rewards.filter((r) => r.memberId === memberId && r.status === 'requested')
+	);

 	let weeklyTotal = $derived.by(() => {
 		const dailyChores = memberChores.filter((a) => a.frequency === 'daily');
@@ -211,9 +239,7 @@
 				const chore = assigned.find((a) => a.id === c.assignedChoreId);
 				return sum + (chore?.type === 'money' ? Number(chore.value) : 0);
 			}, 0) +
-			myRewards
-				.filter((r) => r.rewardType === 'cash')
-				.reduce((sum, r) => sum + Number(r.value), 0)
+			myRewards.filter((r) => r.rewardType === 'cash').reduce((sum, r) => sum + Number(r.value), 0)
 		);
 	});

@@ -248,13 +274,12 @@
 		const myCompletions = completions.filter((c) => c.memberId === memberId);
 		const activeConfigs = bonusConfigs.filter(
 			(b: BonusConfig) =>
-				(b.phase === 'active' || (!b.phase && b.status === 'active')) &&
+				b.status === 'active' &&
 				b.target === 'individual' &&
 				(!b.memberId || b.memberId === memberId)
 		);
 		return activeConfigs.map((cfg) => {
-			const pStart =
-				cfg.period === 'weekly' ? ws : cfg.period === 'monthly' ? monthStartStr() : '';
+			const pStart = cfg.period === 'weekly' ? ws : cfg.period === 'monthly' ? monthStartStr() : '';
 			const pEnd = pStart
 				? (() => {
 						if (cfg.period === 'weekly') {
@@ -274,8 +299,7 @@
 			const periodCompletions = pStart
 				? myCompletions.filter(
 						(c) =>
-							(c.date?.slice(0, 10) || c.date) >= pStart &&
-							(c.date?.slice(0, 10) || c.date) <= pEnd
+							(c.date?.slice(0, 10) || c.date) >= pStart && (c.date?.slice(0, 10) || c.date) <= pEnd
 					)
 				: myCompletions;

@@ -374,14 +398,18 @@
 				famStore.applyRecord('completions', existing, 'delete');
 			}
 		} else {
-			famStore.applyRecord('completions', {
+			famStore.applyRecord(
+				'completions',
+				{
 					id: 'optimistic-' + chore.id,
 					famId,
 					memberId,
 					assignedChoreId: chore.id,
 					date: todayChild,
 					completedAt: new Date().toISOString()
-			} as Completion, 'create');
+				} as Completion,
+				'create'
+			);
 		}

 		try {
@@ -392,14 +420,18 @@
 			}
 		} catch (e) {
 			if (wasCompleted) {
-				famStore.applyRecord('completions', {
+				famStore.applyRecord(
+					'completions',
+					{
 						id: 'revert-' + chore.id + '-' + Date.now(),
 						famId,
 						memberId,
 						assignedChoreId: chore.id,
 						date: todayChild,
 						completedAt: new Date().toISOString()
-				} as Completion, 'create');
+					} as Completion,
+					'create'
+				);
 			} else {
 				const optimistic = completions.find((c) => c.id === 'optimistic-' + chore.id);
 				if (optimistic) {
@@ -421,7 +453,7 @@
 	}

 	function rewardLabelChild(r: Reward): string {
-		if (r.rewardType === 'cash') return `£${(Number(r.value) / 100).toFixed(2)}`;
+		if (r.rewardType === 'cash') return `£${Number(r.value).toFixed(2)}`;
 		if (r.rewardType === 'points') return `${r.value} pts`;
 		return r.label;
 	}
@@ -468,7 +500,14 @@
 							{#each todays as c}
 								<li>
 									✅ {choreNameFor(c.assignedChoreId)}
-									<form method="POST" action="?/revoke" use:enhance={() => { return async (args) => handleResult(args); }} class="revoke-form">
+									<form
+										method="POST"
+										action="?/revoke"
+										use:enhance={() => {
+											return async (args) => handleResult(args);
+										}}
+										class="revoke-form"
+									>
 										<input type="hidden" name="id" value={c.id} />
 										<button type="submit" class="revoke-btn" title="Revoke">↩</button>
 									</form>
@@ -487,7 +526,7 @@
 				{#each manualConfigs() as bc}
 					{@const val =
 						bc.rewardType === 'cash'
-							? `£${(Number(bc.rewardValue) / 100).toFixed(2)}`
+							? `£${Number(bc.rewardValue).toFixed(2)}`
 							: bc.rewardType === 'points'
 								? `${bc.rewardValue} pts`
 								: bc.rewardValue}
@@ -500,7 +539,13 @@
 							<span class="trigger-value">{val}</span>
 						</div>
 						{#if targeted}
-							<form method="POST" action="?/trigger" use:enhance={() => { return async (args: any) => handleResult(args); }}>
+							<form
+								method="POST"
+								action="?/trigger"
+								use:enhance={() => {
+									return async (args: any) => handleResult(args);
+								}}
+							>
 								<input type="hidden" name="configId" value={bc.id} />
 								<input type="hidden" name="memberId" value={targeted.id} />
 								<div class="trigger-row">
@@ -511,7 +556,13 @@
 								</div>
 							</form>
 						{:else}
-							<form method="POST" action="?/trigger" use:enhance={() => { return async (args: any) => handleResult(args); }}>
+							<form
+								method="POST"
+								action="?/trigger"
+								use:enhance={() => {
+									return async (args: any) => handleResult(args);
+								}}
+							>
 								<input type="hidden" name="configId" value={bc.id} />
 								<div class="trigger-row">
 									<select name="memberId" class="trigger-select">
@@ -562,6 +613,7 @@
 												<span class="value">{rewardLabel(r)}</span>
 												<Button type="submit" size="sm" variant="primary">Issue</Button>
 											</div>
+										</div>
 									</form>
 								{/each}
 								{#if requested.length > 1}
@@ -569,13 +621,14 @@
 										method="POST"
 										action="?/issueAll"
 										use:enhance={() => {
-											return async (args: any) =>
-												handleResult(args);
+											return async (args: any) => handleResult(args);
 										}}
 									>
 										<input type="hidden" name="memberId" value={m.id} />
 										<input type="hidden" name="message" value={selectedMessage[m.id] || ''} />
-										<Button type="submit" size="sm" variant="secondary">Issue All ({requested.length})</Button>
+										<Button type="submit" size="sm" variant="secondary"
+											>Issue All ({requested.length})</Button
+										>
 									</form>
 								{/if}
 							{/if}
@@ -746,11 +799,11 @@
 					</div>
 					<div class="badge-card cash">
 						<span class="badge-label">Total Cash</span>
-						<span class="badge-value">£{(totalCash / 100).toFixed(2)}</span>
+						<span class="badge-value">£{totalCash.toFixed(2)}</span>
 					</div>
 					<div class="badge-card pending">
 						<span class="badge-label">Pending Cash</span>
-						<span class="badge-value">£{(pendingCash / 100).toFixed(2)}</span>
+						<span class="badge-value">£{pendingCash.toFixed(2)}</span>
 					</div>
 					<div class="badge-card points">
 						<span class="badge-label">Total Points</span>
@@ -1440,9 +1493,16 @@
 		font-weight: 600;
 		cursor: pointer;
 	}
-	.request-all-btn:hover { background: #1d4ed8; }
-	.request-col { border-color: #93c5fd; background: #eff6ff; }
-	.claim-card.requested { opacity: 0.7; }
+	.request-all-btn:hover {
+		background: #1d4ed8;
+	}
+	.request-col {
+		border-color: #93c5fd;
+		background: #eff6ff;
+	}
+	.claim-card.requested {
+		opacity: 0.7;
+	}
 	.requested-badge {
 		font-size: 0.7rem;
 		padding: 2px 8px;
@@ -1465,7 +1525,9 @@
 		color: #2563eb;
 		margin: 0 0 0.25rem;
 	}
-	.payment-row.outstanding { opacity: 0.6; }
+	.payment-row.outstanding {
+		opacity: 0.6;
+	}

 	h1 {
 		display: flex;
@@ -4,21 +4,95 @@ import { hono } from '$lib/server/hono';
 export async function load(event) {
 	if (!event.locals.session) throw redirect(303, '/login');
 	const famId = event.locals.session.famId;
-	const [configs, members, progress, rewards] = await Promise.all([
+	const [configs, templates, members, progress, rewards] = await Promise.all([
 		hono.admin.bonusConfigs(event, famId),
+		hono.admin.list(event, 'bonus-templates', famId),
 		hono.admin.list(event, 'members', famId),
 		hono.admin.bonusConfigProgress(event, famId),
-		hono.admin.rewards(event, famId),
+		hono.admin.rewards(event, famId)
 	]);
-	return { configs, members, progress, rewards };
+	return { configs, templates, members, progress, rewards };
 }

 export const actions = {
+	createTemplate: async (event) => {
+		if (!event.locals.session) throw redirect(303, '/login');
+		const famId = event.locals.session.famId;
+		const fd = await event.request.formData();
+		const data: Record<string, unknown> = {
+			name: fd.get('name'),
+			description: fd.get('description') || '',
+			target: fd.get('target'),
+			type: fd.get('type'),
+			occurrence: fd.get('occurrence'),
+			rewardType: fd.get('rewardType'),
+			rewardValue: fd.get('rewardValue')
+		};
+		const criteriaValue = fd.get('criteriaValue');
+		if (criteriaValue) data.criteriaValue = parseInt(criteriaValue as string, 10) || 0;
+		const period = fd.get('period');
+		if (period !== null) data.period = period;
+		if (data.occurrence === 'once') data.period = '';
+		try {
+			const record = await hono.admin.create(event, 'bonus-templates', famId, data);
+			return { record };
+		} catch (e) {
+			return fail(400, { error: e instanceof Error ? e.message : 'Failed to create template' });
+		}
+	},
+
+	updateTemplate: async (event) => {
+		if (!event.locals.session) throw redirect(303, '/login');
+		const famId = event.locals.session.famId;
+		const fd = await event.request.formData();
+		const id = fd.get('id') as string;
+		const data: Record<string, unknown> = {};
+		const name = fd.get('name');
+		if (name) data.name = name;
+		const target = fd.get('target');
+		if (target) data.target = target;
+		const type = fd.get('type');
+		if (type) data.type = type;
+		const occurrence = fd.get('occurrence');
+		if (occurrence) data.occurrence = occurrence;
+		const rewardType = fd.get('rewardType');
+		if (rewardType) data.rewardType = rewardType;
+		const rewardValue = fd.get('rewardValue');
+		if (rewardValue) data.rewardValue = rewardValue;
+		const criteriaValue = fd.get('criteriaValue');
+		if (criteriaValue) data.criteriaValue = parseInt(criteriaValue as string, 10) || 0;
+		const period = fd.get('period');
+		if (period !== null) data.period = period;
+		if (occurrence === 'once') data.period = '';
+		const description = fd.get('description');
+		if (description) data.description = description;
+		try {
+			const record = await hono.admin.update(event, 'bonus-templates', famId, id, data);
+			return { record };
+		} catch (e) {
+			return fail(400, { error: e instanceof Error ? e.message : 'Failed to update template' });
+		}
+	},
+
+	deleteTemplate: async (event) => {
+		if (!event.locals.session) throw redirect(303, '/login');
+		const famId = event.locals.session.famId;
+		const fd = await event.request.formData();
+		const id = fd.get('id') as string;
+		try {
+			await hono.admin.remove(event, 'bonus-templates', famId, id);
+			return { deleted: true };
+		} catch (e) {
+			return fail(400, { error: e instanceof Error ? e.message : 'Failed to delete template' });
+		}
+	},
+
 	createConfig: async (event) => {
 		if (!event.locals.session) throw redirect(303, '/login');
 		const famId = event.locals.session.famId;
 		const fd = await event.request.formData();
-		const phase = fd.get('phase') as string;
+		const startMode = fd.get('startMode') as string;
+		const status = startMode === 'disabled' ? 'disabled' : 'active';
 		const data: Record<string, unknown> = {
 			name: fd.get('name'),
 			target: fd.get('target'),
@@ -26,12 +100,13 @@ export const actions = {
 			occurrence: fd.get('occurrence'),
 			rewardType: fd.get('rewardType'),
 			rewardValue: fd.get('rewardValue'),
-			phase: phase || 'ready',
+			status
 		};
 		const criteriaValue = fd.get('criteriaValue');
 		if (criteriaValue) data.criteriaValue = parseInt(criteriaValue as string, 10) || 0;
 		const period = fd.get('period');
 		if (period !== null) data.period = period;
+		if (data.occurrence === 'once') data.period = '';
 		const description = fd.get('description');
 		if (description) data.description = description;
 		const memberId = fd.get('memberId');
@@ -66,6 +141,7 @@ export const actions = {
 		if (criteriaValue) data.criteriaValue = parseInt(criteriaValue as string, 10) || 0;
 		const period = fd.get('period');
 		if (period !== null) data.period = period;
+		if (occurrence === 'once') data.period = '';
 		const description = fd.get('description');
 		if (description) data.description = description;
 		const memberId = fd.get('memberId');
@@ -87,7 +163,7 @@ export const actions = {
 			await hono.admin.remove(event, 'bonus-configs', famId, id);
 			return { deleted: true };
 		} catch (e) {
-			return fail(400, { error: e instanceof Error ? e.message : 'Failed to archive config' });
+			return fail(400, { error: e instanceof Error ? e.message : 'Failed to delete config' });
 		}
 	},

@@ -95,6 +171,8 @@ export const actions = {
 		if (!event.locals.session) throw redirect(303, '/login');
 		const famId = event.locals.session.famId;
 		const fd = await event.request.formData();
+		const startMode = fd.get('startMode') as string;
+		const status = startMode === 'disabled' ? 'disabled' : 'active';
 		const data: Record<string, unknown> = {
 			name: fd.get('name'),
 			description: fd.get('description') || '',
@@ -106,13 +184,16 @@ export const actions = {
 			criteriaValue: parseInt(fd.get('criteriaValue') as string, 10) || 0,
 			period: fd.get('period') || '',
 			memberId: fd.get('memberId') || '',
-			phase: 'active',
+			status
 		};
+		if (data.occurrence === 'once') data.period = '';
 		try {
 			const record = await hono.admin.create(event, 'bonus-configs', famId, data);
 			return { record };
 		} catch (e) {
-			return fail(400, { error: e instanceof Error ? e.message : 'Failed to create bonus from template' });
+			return fail(400, {
+				error: e instanceof Error ? e.message : 'Failed to create bonus from template'
+			});
 		}
 	},

@@ -124,7 +205,10 @@ export const actions = {
 		const target = fd.get('target') as string;
 		const memberId = fd.get('memberId') as string;
 		try {
-			const record = await hono.admin.assignBonusConfig(event, famId, id, { target, memberId: memberId || null });
+			const record = await hono.admin.assignBonusConfig(event, famId, id, {
+				target,
+				memberId: memberId || null
+			});
 			return { record };
 		} catch (e) {
 			return fail(400, { error: e instanceof Error ? e.message : 'Failed to assign bonus' });
@@ -136,12 +220,11 @@ export const actions = {
 		const famId = event.locals.session.famId;
 		const fd = await event.request.formData();
 		const id = fd.get('id') as string;
-		const phase = fd.get('phase') as string;
 		try {
-			const record = await hono.admin.completeBonusConfig(event, famId, id, phase || 'completed');
+			const record = await hono.admin.completeBonusConfig(event, famId, id);
 			return { record };
 		} catch (e) {
-			return fail(400, { error: e instanceof Error ? e.message : 'Failed to update bonus phase' });
+			return fail(400, { error: e instanceof Error ? e.message : 'Failed to complete bonus' });
 		}
 	},

@@ -158,6 +241,23 @@ export const actions = {
 		}
 	},

+	toggleConfig: async (event) => {
+		if (!event.locals.session) throw redirect(303, '/login');
+		const famId = event.locals.session.famId;
+		const fd = await event.request.formData();
+		const id = fd.get('id') as string;
+		const currentStatus = fd.get('currentStatus') as string;
+		const newStatus = currentStatus === 'disabled' ? 'active' : 'disabled';
+		try {
+			const record = await hono.admin.update(event, 'bonus-configs', famId, id, {
+				status: newStatus
+			});
+			return { record };
+		} catch (e) {
+			return fail(400, { error: e instanceof Error ? e.message : 'Failed to toggle bonus' });
+		}
+	},
+
 	claimReward: async (event) => {
 		if (!event.locals.session) throw redirect(303, '/login');
 		const famId = event.locals.session.famId;
@@ -178,5 +278,5 @@ export const actions = {
 		} catch (e) {
 			return { error: e instanceof Error ? e.message : 'Failed to evaluate' };
 		}
-	},
+	}
 };
@@ -17,7 +17,7 @@
 	}

 	function rewardAmount(r: any): string {
-		if (r.rewardType === 'cash') return `£${(Number(r.value) / 100).toFixed(2)}`;
+		if (r.rewardType === 'cash') return `£${Number(r.value).toFixed(2)}`;
 		if (r.rewardType === 'points') return `${r.value} pts`;
 		return r.label;
 	}
@@ -112,7 +112,7 @@
 						<td></td>
 						<td></td>
 						<td class="num"><strong>Outstanding cash</strong></td>
-						<td class="num"><strong>£{(totalOutstanding / 100).toFixed(2)}</strong></td>
+						<td class="num"><strong>£{totalOutstanding.toFixed(2)}</strong></td>
 						<td></td>
 						<td></td>
 					</tr>
@@ -3,27 +3,27 @@ import { SERVER_IP, PB_PORT, PB_EMAIL, PB_PASSWORD } from "../../config.ts";
 const PB_ENDPOINT = `http://${SERVER_IP}:${PB_PORT}`;

 interface FieldDef {
-	name: string
-	type: string
-	required?: boolean
-	unique?: boolean
-	max?: number
-	min?: number
-	values?: string[]
-	maxSelect?: number
-	collectionId?: string
-	cascadeDelete?: boolean
+  name: string;
+  type: string;
+  required?: boolean;
+  unique?: boolean;
+  max?: number;
+  min?: number;
+  values?: string[];
+  maxSelect?: number;
+  collectionId?: string;
+  cascadeDelete?: boolean;
 }

 interface CollectionDef {
-	name: string
-	type: string
-	fields: FieldDef[]
-	listRule?: string | null
-	viewRule?: string | null
-	createRule?: string | null
-	updateRule?: string | null
-	deleteRule?: string | null
+  name: string;
+  type: string;
+  fields: FieldDef[];
+  listRule?: string | null;
+  viewRule?: string | null;
+  createRule?: string | null;
+  updateRule?: string | null;
+  deleteRule?: string | null;
 }

 async function getSuperadminToken(): Promise<string> {
@@ -63,7 +63,8 @@ async function createCollection(
    body: JSON.stringify(col),
  });
  const data = await res.json();
-	if (!res.ok) throw new Error(`Create ${col.name} failed: ${JSON.stringify(data)}`);
+  if (!res.ok)
+    throw new Error(`Create ${col.name} failed: ${JSON.stringify(data)}`);
  console.log(`  ✓ Created: ${col.name}`);
  return data.id;
 }
@@ -146,10 +147,7 @@ async function main() {
    createRule: null,
    updateRule: null,
    deleteRule: null,
-		fields: [
-			rel("famId", ids.fams!, true),
-			text("webhookUrl"),
-		],
+    fields: [rel("famId", ids.fams!, true), text("webhookUrl")],
  });

  ids.members = await createCollection(token, {
@@ -216,14 +214,37 @@ async function main() {
      rel("famId", ids.fams!, true),
      text("name", true),
      text("description"),
-			select("target", ["individual", "competitive"], true),
+      select("target", ["individual", "competitive", "collaborative"], true),
      select("type", ["threshold", "count", "manual"], true),
      select("occurrence", ["recurring", "once"], true),
      select("rewardType", ["points", "cash", "prize"], true),
      text("rewardValue", true),
      number("criteriaValue"),
-			select("period", ["weekly", "monthly"]),
-			select("status", ["active", "archived"], true),
+      rel("memberId", ids.members!),
+      select("period", ["schedule", "daily", "weekly", "monthly"]),
+      select("status", ["active", "completed"], true),
+    ],
+  });
+
+  ids.bonus_templates = await createCollection(token, {
+    name: "bonus_templates",
+    type: "base",
+    listRule: "",
+    viewRule: "",
+    createRule: null,
+    updateRule: null,
+    deleteRule: null,
+    fields: [
+      rel("famId", ids.fams!, true),
+      text("name", true),
+      text("description"),
+      select("target", ["individual", "competitive", "collaborative"], true),
+      select("type", ["threshold", "count", "manual"], true),
+      select("occurrence", ["recurring", "once"], true),
+      select("rewardType", ["points", "cash", "prize"], true),
+      text("rewardValue", true),
+      number("criteriaValue"),
+      select("period", ["schedule", "daily", "weekly", "monthly"]),
    ],
  });

@@ -6,11 +6,14 @@ let token: string | null = null;

 async function auth(): Promise<string> {
  if (token) return token;
-	const res = await fetch(`${PB_ENDPOINT}/api/collections/_superusers/auth-with-password`, {
+  const res = await fetch(
+    `${PB_ENDPOINT}/api/collections/_superusers/auth-with-password`,
+    {
      method: "POST",
      headers: { "Content-Type": "application/json" },
      body: JSON.stringify({ identity: PB_EMAIL, password: PB_PASSWORD }),
-	});
+    },
+  );
  const data = await res.json();
  if (!res.ok) throw new Error(`PB auth failed: ${JSON.stringify(data)}`);
  token = data.token;
@@ -19,9 +22,12 @@ async function auth(): Promise<string> {

 async function getCollection(name: string): Promise<any | null> {
  const t = await auth();
-	const res = await fetch(`${PB_ENDPOINT}/api/collections?filter=name='${name}'`, {
+  const res = await fetch(
+    `${PB_ENDPOINT}/api/collections?filter=name='${name}'`,
+    {
      headers: { Authorization: `Bearer ${t}` },
-	});
+    },
+  );
  const data = await res.json();
  return data?.items?.[0] || null;
 }
@@ -30,11 +36,15 @@ async function createCollection(col: any): Promise<void> {
  const t = await auth();
  const res = await fetch(`${PB_ENDPOINT}/api/collections`, {
    method: "POST",
-		headers: { "Content-Type": "application/json", Authorization: `Bearer ${t}` },
+    headers: {
+      "Content-Type": "application/json",
+      Authorization: `Bearer ${t}`,
+    },
    body: JSON.stringify(col),
  });
  const data = await res.json();
-	if (!res.ok) throw new Error(`Create ${col.name} failed: ${JSON.stringify(data)}`);
+  if (!res.ok)
+    throw new Error(`Create ${col.name} failed: ${JSON.stringify(data)}`);
  console.log(`  ✓ Created collection: ${col.name}`);
 }

@@ -42,11 +52,15 @@ async function updateCollection(id: string, col: any): Promise<void> {
  const t = await auth();
  const res = await fetch(`${PB_ENDPOINT}/api/collections/${id}`, {
    method: "PATCH",
-		headers: { "Content-Type": "application/json", Authorization: `Bearer ${t}` },
+    headers: {
+      "Content-Type": "application/json",
+      Authorization: `Bearer ${t}`,
+    },
    body: JSON.stringify(col),
  });
  const data = await res.json();
-	if (!res.ok) throw new Error(`Update collection ${id} failed: ${JSON.stringify(data)}`);
+  if (!res.ok)
+    throw new Error(`Update collection ${id} failed: ${JSON.stringify(data)}`);
  console.log(`  ✓ Updated collection: ${col.name || id}`);
 }

@@ -71,17 +85,60 @@ export async function migrate(): Promise<void> {
      updateRule: null,
      deleteRule: null,
      fields: [
-				{ name: "famId", type: "relation", required: true, collectionId: famsId, maxSelect: 1, cascadeDelete: false },
+        {
+          name: "famId",
+          type: "relation",
+          required: true,
+          collectionId: famsId,
+          maxSelect: 1,
+          cascadeDelete: false,
+        },
        { name: "name", type: "text", required: true },
        { name: "description", type: "text", required: false },
-				{ name: "target", type: "select", required: true, values: ["individual", "competitive", "collaborative"], maxSelect: 1 },
-				{ name: "type", type: "select", required: true, values: ["threshold", "count", "manual"], maxSelect: 1 },
-				{ name: "occurrence", type: "select", required: true, values: ["recurring", "once"], maxSelect: 1 },
-				{ name: "rewardType", type: "select", required: true, values: ["points", "cash", "prize"], maxSelect: 1 },
+        {
+          name: "target",
+          type: "select",
+          required: true,
+          values: ["individual", "competitive", "collaborative"],
+          maxSelect: 1,
+        },
+        {
+          name: "type",
+          type: "select",
+          required: true,
+          values: ["threshold", "count", "manual"],
+          maxSelect: 1,
+        },
+        {
+          name: "occurrence",
+          type: "select",
+          required: true,
+          values: ["recurring", "once"],
+          maxSelect: 1,
+        },
+        {
+          name: "rewardType",
+          type: "select",
+          required: true,
+          values: ["points", "cash", "prize"],
+          maxSelect: 1,
+        },
        { name: "rewardValue", type: "text", required: true },
        { name: "criteriaValue", type: "number", required: false },
-				{ name: "period", type: "select", required: false, values: ["schedule", "weekly", "monthly"], maxSelect: 1 },
-				{ name: "status", type: "select", required: true, values: ["active", "archived"], maxSelect: 1 },
+        {
+          name: "period",
+          type: "select",
+          required: false,
+          values: ["schedule", "daily", "weekly", "monthly"],
+          maxSelect: 1,
+        },
+        {
+          name: "status",
+          type: "select",
+          required: true,
+          values: ["active", "archived"],
+          maxSelect: 1,
+        },
      ],
    });
  } else {
@@ -89,13 +146,17 @@ export async function migrate(): Promise<void> {

    const targetField = existing.fields.find((f: any) => f.name === "target");
    const periodField = existing.fields.find((f: any) => f.name === "period");
-		const needTargetUpdate = targetField && !targetField.values.includes("collaborative");
-		const needPeriodUpdate = periodField && !periodField.values.includes("schedule");
+    const needTargetUpdate =
+      targetField && !targetField.values.includes("collaborative");
+    const needPeriodUpdate =
+      periodField && !periodField.values.includes("daily");

    if (needTargetUpdate || needPeriodUpdate) {
      console.log("[migrate] Updating bonus_configs fields...");
-			if (needTargetUpdate) targetField.values = ["individual", "competitive", "collaborative"];
-			if (needPeriodUpdate) periodField.values = ["schedule", "weekly", "monthly"];
+      if (needTargetUpdate)
+        targetField.values = ["individual", "competitive", "collaborative"];
+      if (needPeriodUpdate)
+        periodField.values = ["schedule", "daily", "weekly", "monthly"];
      await updateCollection(existing.id, {
        name: "bonus_configs",
        type: "base",
@@ -125,16 +186,49 @@ export async function migrate(): Promise<void> {
      const bonusConfigsCol = await getCollection("bonus_configs");

      const keepFields = rewardsCol.fields.filter((f: any) =>
-				["famId", "memberId", "label", "value", "claimed", "claimedAt", "rewardType", "bonusConfigId", "created", "updated", "id"].includes(f.name)
+        [
+          "famId",
+          "memberId",
+          "label",
+          "value",
+          "claimed",
+          "claimedAt",
+          "rewardType",
+          "bonusConfigId",
+          "created",
+          "updated",
+          "id",
+        ].includes(f.name),
      );

      const newFields = [
        ...keepFields,
        ...(bonusConfigsCol && !fieldNames.includes("bonusConfigId")
-					? [{ name: "bonusConfigId", type: "relation", required: false, collectionId: bonusConfigsCol.id, maxSelect: 1, cascadeDelete: false }]
+          ? [
+              {
+                name: "bonusConfigId",
+                type: "relation",
+                required: false,
+                collectionId: bonusConfigsCol.id,
+                maxSelect: 1,
+                cascadeDelete: false,
+              },
+            ]
          : []),
-				...(fieldNames.includes("rewardType") ? [] : [{ name: "rewardType", type: "select", required: true, values: ["cash", "prize", "points"], maxSelect: 1 }]),
-				...(fieldNames.includes("claimedAt") ? [] : [{ name: "claimedAt", type: "date", required: false }]),
+        ...(fieldNames.includes("rewardType")
+          ? []
+          : [
+              {
+                name: "rewardType",
+                type: "select",
+                required: true,
+                values: ["cash", "prize", "points"],
+                maxSelect: 1,
+              },
+            ]),
+        ...(fieldNames.includes("claimedAt")
+          ? []
+          : [{ name: "claimedAt", type: "date", required: false }]),
        { name: "date", type: "text", required: false },
      ];

@@ -168,11 +262,17 @@ export async function migrate(): Promise<void> {
            patches.claimedAt = new Date().toISOString();
          }
          if (Object.keys(patches).length > 0) {
-						await fetch(`${PB_ENDPOINT}/api/collections/rewards/records/${r.id}`, {
+            await fetch(
+              `${PB_ENDPOINT}/api/collections/rewards/records/${r.id}`,
+              {
                method: "PATCH",
-							headers: { "Content-Type": "application/json", Authorization: `Bearer ${t2}` },
+                headers: {
+                  "Content-Type": "application/json",
+                  Authorization: `Bearer ${t2}`,
+                },
                body: JSON.stringify(patches),
-						});
+              },
+            );
          }
        }
        console.log(`  ✓ Backfilled ${backfillData.items.length} rewards`);
@@ -188,10 +288,15 @@ export async function migrate(): Promise<void> {
  const settingsCol = await getCollection("settings");
  if (settingsCol) {
    const fieldNames = settingsCol.fields.map((f: any) => f.name);
-		if (fieldNames.includes("pointsThreshold") || fieldNames.includes("weeklyBonus")) {
-			console.log("[migrate] Updating settings collection (dropping old fields)...");
+    if (
+      fieldNames.includes("pointsThreshold") ||
+      fieldNames.includes("weeklyBonus")
+    ) {
+      console.log(
+        "[migrate] Updating settings collection (dropping old fields)...",
+      );
      const keepFields = settingsCol.fields.filter((f: any) =>
-				["famId", "webhookUrl", "created", "updated", "id"].includes(f.name)
+        ["famId", "webhookUrl", "created", "updated", "id"].includes(f.name),
      );
      await updateCollection(settingsCol.id, {
        name: "settings",
@@ -225,8 +330,22 @@ export async function migrate(): Promise<void> {
      updateRule: null,
      deleteRule: null,
      fields: [
-				{ name: "famId", type: "relation", required: true, collectionId: famsCol.id, maxSelect: 1, cascadeDelete: false },
-				{ name: "memberId", type: "relation", required: true, collectionId: membersCol.id, maxSelect: 1, cascadeDelete: false },
+        {
+          name: "famId",
+          type: "relation",
+          required: true,
+          collectionId: famsCol.id,
+          maxSelect: 1,
+          cascadeDelete: false,
+        },
+        {
+          name: "memberId",
+          type: "relation",
+          required: true,
+          collectionId: membersCol.id,
+          maxSelect: 1,
+          cascadeDelete: false,
+        },
        { name: "message", type: "text", required: true },
        { name: "read", type: "bool", required: false },
      ],
@@ -241,7 +360,13 @@ export async function migrate(): Promise<void> {
    const hasPayday = famsCol.fields.some((f: any) => f.name === "payday");
    if (!hasPayday) {
      console.log("[migrate] Adding payday field to fams...");
-			const paydayField = { name: "payday", type: "number", required: false, min: 0, max: 6 };
+      const paydayField = {
+        name: "payday",
+        type: "number",
+        required: false,
+        min: 0,
+        max: 6,
+      };
      famsCol.fields.push(paydayField);
      await updateCollection(famsCol.id, {
        name: "fams",
@@ -265,42 +390,60 @@ export async function migrate(): Promise<void> {
    const completionsCol = await getCollection("completions");
    if (completionsCol) {
      const t = await auth();
-			const all = await fetch(`${PB_ENDPOINT}/api/collections/completions/records?perPage=1000`, {
+      const all = await fetch(
+        `${PB_ENDPOINT}/api/collections/completions/records?perPage=1000`,
+        {
          headers: { Authorization: `Bearer ${t}` },
-			});
+        },
+      );
      const data = await all.json();
      if (data?.items?.length) {
        let backfilled = 0;
        for (const rec of data.items) {
          const plain = rec.date?.slice(0, 10);
          if (plain && plain !== rec.date) {
-						await fetch(`${PB_ENDPOINT}/api/collections/completions/records/${rec.id}`, {
+            await fetch(
+              `${PB_ENDPOINT}/api/collections/completions/records/${rec.id}`,
+              {
                method: "PATCH",
-							headers: { "Content-Type": "application/json", Authorization: `Bearer ${t}` },
+                headers: {
+                  "Content-Type": "application/json",
+                  Authorization: `Bearer ${t}`,
+                },
                body: JSON.stringify({ date: plain }),
-						});
+              },
+            );
            backfilled++;
          }
        }
-				if (backfilled > 0) console.log(`  ✓ Backfilled ${backfilled} completion dates`);
+        if (backfilled > 0)
+          console.log(`  ✓ Backfilled ${backfilled} completion dates`);
        else console.log(`  ↳ completions.date already normalised`);
      }
    }
  } catch (e) {
-		console.log(`  ↳ Step 6 backfill skipped: ${e instanceof Error ? e.message : e}`);
+    console.log(
+      `  ↳ Step 6 backfill skipped: ${e instanceof Error ? e.message : e}`,
+    );
  }

  // ── 7. Add memberId field to bonus_configs ──
  const bonusConfigsCol = await getCollection("bonus_configs");
  if (bonusConfigsCol) {
-		const hasMemberId = bonusConfigsCol.fields.some((f: any) => f.name === "memberId");
+    const hasMemberId = bonusConfigsCol.fields.some(
+      (f: any) => f.name === "memberId",
+    );
    if (!hasMemberId) {
      const membersCol = await getCollection("members");
      if (membersCol) {
        console.log("[migrate] Adding memberId field to bonus_configs...");
        bonusConfigsCol.fields.push({
-					name: "memberId", type: "relation", required: false,
-					collectionId: membersCol.id, maxSelect: 1, cascadeDelete: false,
+          name: "memberId",
+          type: "relation",
+          required: false,
+          collectionId: membersCol.id,
+          maxSelect: 1,
+          cascadeDelete: false,
        });
        await updateCollection(bonusConfigsCol.id, {
          name: "bonus_configs",
@@ -318,46 +461,8 @@ export async function migrate(): Promise<void> {
    }
  }

-	// ── 8. Add phase field to bonus_configs ──
-	if (bonusConfigsCol) {
-		const hasPhase = bonusConfigsCol.fields.some((f: any) => f.name === "phase");
-		if (!hasPhase) {
-			console.log("[migrate] Adding phase field to bonus_configs...");
-			bonusConfigsCol.fields.push({
-				name: "phase", type: "select", required: true,
-				values: ["template", "ready", "active", "completed"], maxSelect: 1,
-			});
-			await updateCollection(bonusConfigsCol.id, {
-				name: "bonus_configs",
-				type: "base",
-				listRule: bonusConfigsCol.listRule,
-				viewRule: bonusConfigsCol.viewRule,
-				createRule: bonusConfigsCol.createRule,
-				updateRule: bonusConfigsCol.updateRule,
-				deleteRule: bonusConfigsCol.deleteRule,
-				fields: bonusConfigsCol.fields,
-			});
-
-			// Backfill existing records → phase = "active"
-			const t = await auth();
-			const all = await fetch(`${PB_ENDPOINT}/api/collections/bonus_configs/records?perPage=1000`, {
-				headers: { Authorization: `Bearer ${t}` },
-			});
-			const data = await all.json();
-			if (data?.items?.length) {
-				for (const rec of data.items) {
-					await fetch(`${PB_ENDPOINT}/api/collections/bonus_configs/records/${rec.id}`, {
-						method: "PATCH",
-						headers: { "Content-Type": "application/json", Authorization: `Bearer ${t}` },
-						body: JSON.stringify({ phase: "active" }),
-					});
-				}
-				console.log(`  ✓ Backfilled ${data.items.length} bonus_configs → phase=active`);
-			}
-		} else {
-			console.log(`  ↳ bonus_configs.phase already exists`);
-		}
-	}
+  // ── 8. (Removed) bonus_configs.phase field was dropped — replaced by status: active|completed.
+  // Templates now live in a dedicated `bonus_templates` collection (see step 23+).

  // ── 9. Add role + userId fields to members ──
  const membersCol = await getCollection("members");
@@ -366,8 +471,20 @@ export async function migrate(): Promise<void> {
    const hasUserId = membersCol.fields.some((f: any) => f.name === "userId");
    if (!hasRole || !hasUserId) {
      console.log("[migrate] Adding role/userId fields to members...");
-			if (!hasRole) membersCol.fields.push({ name: "role", type: "select", required: false, values: ["parent", "child"], maxSelect: 1 });
-			if (!hasUserId) membersCol.fields.push({ name: "userId", type: "text", required: false });
+      if (!hasRole)
+        membersCol.fields.push({
+          name: "role",
+          type: "select",
+          required: false,
+          values: ["parent", "child"],
+          maxSelect: 1,
+        });
+      if (!hasUserId)
+        membersCol.fields.push({
+          name: "userId",
+          type: "text",
+          required: false,
+        });
      await updateCollection(membersCol.id, {
        name: "members",
        type: "base",
@@ -408,19 +525,29 @@ export async function migrate(): Promise<void> {
  if (membersCol) {
    try {
      const t = await auth();
-			const allMembers = await fetch(`${PB_ENDPOINT}/api/collections/members/records?perPage=1000`, {
+      const allMembers = await fetch(
+        `${PB_ENDPOINT}/api/collections/members/records?perPage=1000`,
+        {
          headers: { Authorization: `Bearer ${t}` },
-			});
+        },
+      );
      const membersData = await allMembers.json();
-			const needBackfill = (membersData?.items || []).filter((m: any) => !m.userId);
+      const needBackfill = (membersData?.items || []).filter(
+        (m: any) => !m.userId,
+      );
      if (needBackfill.length > 0) {
-				console.log(`[migrate] Backfilling userId for ${needBackfill.length} members...`);
-				const adminsRes = await fetch(`${PB_ENDPOINT}/api/collections/fam_admins/records?perPage=1000`, {
+        console.log(
+          `[migrate] Backfilling userId for ${needBackfill.length} members...`,
+        );
+        const adminsRes = await fetch(
+          `${PB_ENDPOINT}/api/collections/fam_admins/records?perPage=1000`,
+          {
            headers: { Authorization: `Bearer ${t}` },
-				});
+          },
+        );
        const adminsData = await adminsRes.json();
        const adminsByFam = new Map<string, any[]>();
-				for (const a of (adminsData?.items || [])) {
+        for (const a of adminsData?.items || []) {
          const list = adminsByFam.get(a.famId) || [];
          list.push(a);
          adminsByFam.set(a.famId, list);
@@ -429,21 +556,32 @@ export async function migrate(): Promise<void> {
        for (const m of needBackfill) {
          const admins = adminsByFam.get(m.famId) || [];
          if (admins.length === 1) {
-						await fetch(`${PB_ENDPOINT}/api/collections/members/records/${m.id}`, {
+            await fetch(
+              `${PB_ENDPOINT}/api/collections/members/records/${m.id}`,
+              {
                method: "PATCH",
-							headers: { "Content-Type": "application/json", Authorization: `Bearer ${t}` },
+                headers: {
+                  "Content-Type": "application/json",
+                  Authorization: `Bearer ${t}`,
+                },
                body: JSON.stringify({ userId: admins[0].userId }),
-						});
+              },
+            );
            count++;
          }
        }
        if (count > 0) console.log(`  ✓ Backfilled ${count} member userIds`);
-				if (count < needBackfill.length) console.log(`  ↳ Skipped ${needBackfill.length - count} members (no unique fam_admin match)`);
+        if (count < needBackfill.length)
+          console.log(
+            `  ↳ Skipped ${needBackfill.length - count} members (no unique fam_admin match)`,
+          );
      } else {
        console.log(`  ↳ members.userId already backfilled`);
      }
    } catch (e) {
-			console.log(`  ↳ Backfill step skipped: ${e instanceof Error ? e.message : e}`);
+      console.log(
+        `  ↳ Backfill step skipped: ${e instanceof Error ? e.message : e}`,
+      );
    }
  }

@@ -452,7 +590,9 @@ export async function migrate(): Promise<void> {
    const hasUserId = membersCol.fields.some((f: any) => f.name === "userId");
    if (hasUserId) {
      console.log("[migrate] Dropping userId field from members...");
-			membersCol.fields = membersCol.fields.filter((f: any) => f.name !== "userId");
+      membersCol.fields = membersCol.fields.filter(
+        (f: any) => f.name !== "userId",
+      );
      await updateCollection(membersCol.id, {
        name: "members",
        type: "base",
@@ -475,8 +615,10 @@ export async function migrate(): Promise<void> {
    const hasColor = adminsCol.fields.some((f: any) => f.name === "color");
    if (!hasName || !hasColor) {
      console.log("[migrate] Adding name/color to fam_admins...");
-			if (!hasName) adminsCol.fields.push({ name: "name", type: "text", required: false });
-			if (!hasColor) adminsCol.fields.push({ name: "color", type: "text", required: false });
+      if (!hasName)
+        adminsCol.fields.push({ name: "name", type: "text", required: false });
+      if (!hasColor)
+        adminsCol.fields.push({ name: "color", type: "text", required: false });
      await updateCollection(adminsCol.id, {
        name: "fam_admins",
        type: "base",
@@ -489,23 +631,34 @@ export async function migrate(): Promise<void> {
      });
      // Backfill name from email prefix
      const t = await auth();
-			const all = await fetch(`${PB_ENDPOINT}/api/collections/fam_admins/records?perPage=1000`, {
+      const all = await fetch(
+        `${PB_ENDPOINT}/api/collections/fam_admins/records?perPage=1000`,
+        {
          headers: { Authorization: `Bearer ${t}` },
-			});
+        },
+      );
      const data = await all.json();
-			for (const a of (data?.items || [])) {
+      for (const a of data?.items || []) {
        const patch: Record<string, string> = {};
        if (!a.name) patch.name = (a.email || "admin").split("@")[0];
        if (!a.color) patch.color = "#6366f1";
        if (Object.keys(patch).length) {
-					await fetch(`${PB_ENDPOINT}/api/collections/fam_admins/records/${a.id}`, {
+          await fetch(
+            `${PB_ENDPOINT}/api/collections/fam_admins/records/${a.id}`,
+            {
              method: "PATCH",
-						headers: { "Content-Type": "application/json", Authorization: `Bearer ${t}` },
+              headers: {
+                "Content-Type": "application/json",
+                Authorization: `Bearer ${t}`,
+              },
              body: JSON.stringify(patch),
-					});
+            },
+          );
        }
      }
-			console.log(`  ✓ Backfilled name/color for ${(data?.items || []).length} admins`);
+      console.log(
+        `  ✓ Backfilled name/color for ${(data?.items || []).length} admins`,
+      );
    } else {
      console.log(`  ↳ fam_admins.name/color already exists`);
    }
@@ -516,7 +669,9 @@ export async function migrate(): Promise<void> {
    const hasRole = membersCol.fields.some((f: any) => f.name === "role");
    if (hasRole) {
      console.log("[migrate] Dropping role field from members...");
-			membersCol.fields = membersCol.fields.filter((f: any) => f.name !== "role");
+      membersCol.fields = membersCol.fields.filter(
+        (f: any) => f.name !== "role",
+      );
      await updateCollection(membersCol.id, {
        name: "members",
        type: "base",
@@ -537,7 +692,9 @@ export async function migrate(): Promise<void> {
    const hasEmail = membersCol.fields.some((f: any) => f.name === "email");
    if (hasEmail) {
      console.log("[migrate] Dropping email field from members...");
-			membersCol.fields = membersCol.fields.filter((f: any) => f.name !== "email");
+      membersCol.fields = membersCol.fields.filter(
+        (f: any) => f.name !== "email",
+      );
      await updateCollection(membersCol.id, {
        name: "members",
        type: "base",
@@ -562,10 +719,14 @@ export async function migrate(): Promise<void> {
        console.log("[migrate] Adding seasons to fams...");
        c.fields.push({ name: "seasons", type: "json" });
        await updateCollection(c.id, {
-					name: "fams", type: "base",
-					listRule: c.listRule, viewRule: c.viewRule,
-					createRule: c.createRule, updateRule: c.updateRule,
-					deleteRule: c.deleteRule, fields: c.fields,
+          name: "fams",
+          type: "base",
+          listRule: c.listRule,
+          viewRule: c.viewRule,
+          createRule: c.createRule,
+          updateRule: c.updateRule,
+          deleteRule: c.deleteRule,
+          fields: c.fields,
        });
      } else {
        console.log(`  ↳ fams.seasons already exists`);
@@ -582,10 +743,14 @@ export async function migrate(): Promise<void> {
        console.log("[migrate] Adding seasonIds to assigned_chores...");
        c.fields.push({ name: "seasonIds", type: "json" });
        await updateCollection(c.id, {
-					name: "assigned_chores", type: "base",
-					listRule: c.listRule, viewRule: c.viewRule,
-					createRule: c.createRule, updateRule: c.updateRule,
-					deleteRule: c.deleteRule, fields: c.fields,
+          name: "assigned_chores",
+          type: "base",
+          listRule: c.listRule,
+          viewRule: c.viewRule,
+          createRule: c.createRule,
+          updateRule: c.updateRule,
+          deleteRule: c.deleteRule,
+          fields: c.fields,
        });
      } else {
        console.log(`  ↳ assigned_chores.seasonIds already exists`);
@@ -602,13 +767,26 @@ export async function migrate(): Promise<void> {
      const famsCol = await getCollection("fams");
      const res = await fetch(`${PB_ENDPOINT}/api/collections`, {
        method: "POST",
-				headers: { "Content-Type": "application/json", Authorization: `Bearer ${t}` },
+        headers: {
+          "Content-Type": "application/json",
+          Authorization: `Bearer ${t}`,
+        },
        body: JSON.stringify({
-					name: "seasons", type: "base",
-					listRule: "", viewRule: "",
-					createRule: null, updateRule: null, deleteRule: null,
+          name: "seasons",
+          type: "base",
+          listRule: "",
+          viewRule: "",
+          createRule: null,
+          updateRule: null,
+          deleteRule: null,
          fields: [
-						{ name: "famId", type: "relation", required: true, maxSelect: 1, collectionId: famsCol?.id || "" },
+            {
+              name: "famId",
+              type: "relation",
+              required: true,
+              maxSelect: 1,
+              collectionId: famsCol?.id || "",
+            },
            { name: "name", type: "text", required: true },
            { name: "color", type: "text" },
            { name: "active", type: "bool" },
@@ -618,7 +796,10 @@ export async function migrate(): Promise<void> {
        }),
      });
      if (res.ok) console.log("  ✓ Created seasons collection");
-			else console.log(`  ↳ seasons collection creation skipped or already exists`);
+      else
+        console.log(
+          `  ↳ seasons collection creation skipped or already exists`,
+        );
    } else {
      console.log(`  ↳ seasons collection already exists`);
    }
@@ -633,10 +814,14 @@ export async function migrate(): Promise<void> {
        console.log("[migrate] Adding active bool to seasons...");
        c.fields.push({ name: "active", type: "bool" });
        await updateCollection(c.id, {
-					name: "seasons", type: "base",
-					listRule: c.listRule, viewRule: c.viewRule,
-					createRule: c.createRule, updateRule: c.updateRule,
-					deleteRule: c.deleteRule, fields: c.fields,
+          name: "seasons",
+          type: "base",
+          listRule: c.listRule,
+          viewRule: c.viewRule,
+          createRule: c.createRule,
+          updateRule: c.updateRule,
+          deleteRule: c.deleteRule,
+          fields: c.fields,
        });
      } else {
        console.log(`  ↳ seasons.active already exists`);
@@ -649,22 +834,35 @@ export async function migrate(): Promise<void> {
    const t = await auth();
    const fams = await getCollection("fams");
    if (fams) {
-			const hasSeasonsField = fams.fields.some((f: any) => f.name === "seasons");
+      const hasSeasonsField = fams.fields.some(
+        (f: any) => f.name === "seasons",
+      );
      if (hasSeasonsField) {
-				console.log("[migrate] Backfilling season active flags from fams.seasons...");
-				const allFams = await fetch(`${PB_ENDPOINT}/api/collections/fams/records?perPage=1000`, {
+        console.log(
+          "[migrate] Backfilling season active flags from fams.seasons...",
+        );
+        const allFams = await fetch(
+          `${PB_ENDPOINT}/api/collections/fams/records?perPage=1000`,
+          {
            headers: { Authorization: `Bearer ${t}` },
-				});
+          },
+        );
        const famData = await allFams.json();
        for (const fam of famData.items || []) {
          const activeIds = fam.seasons || [];
          if (activeIds.length > 0) {
            for (const sid of activeIds) {
-							await fetch(`${PB_ENDPOINT}/api/collections/seasons/records/${sid}`, {
+              await fetch(
+                `${PB_ENDPOINT}/api/collections/seasons/records/${sid}`,
+                {
                  method: "PATCH",
-								headers: { "Content-Type": "application/json", Authorization: `Bearer ${t}` },
+                  headers: {
+                    "Content-Type": "application/json",
+                    Authorization: `Bearer ${t}`,
+                  },
                  body: JSON.stringify({ active: true }),
-							});
+                },
+              );
            }
          }
        }
@@ -684,10 +882,14 @@ export async function migrate(): Promise<void> {
        console.log("[migrate] Removing seasons field from fams...");
        c.fields = c.fields.filter((f: any) => f.name !== "seasons");
        await updateCollection(c.id, {
-					name: "fams", type: "base",
-					listRule: c.listRule, viewRule: c.viewRule,
-					createRule: c.createRule, updateRule: c.updateRule,
-					deleteRule: c.deleteRule, fields: c.fields,
+          name: "fams",
+          type: "base",
+          listRule: c.listRule,
+          viewRule: c.viewRule,
+          createRule: c.createRule,
+          updateRule: c.updateRule,
+          deleteRule: c.deleteRule,
+          fields: c.fields,
        });
      } else {
        console.log(`  ↳ fams.seasons already removed`);
@@ -709,17 +911,26 @@ export async function migrate(): Promise<void> {
        let page = 1;
        let total = 0;
        while (true) {
-					const res = await fetch(`${PB_ENDPOINT}/api/collections/rewards/records?page=${page}&perPage=100`, {
+          const res = await fetch(
+            `${PB_ENDPOINT}/api/collections/rewards/records?page=${page}&perPage=100`,
+            {
              headers: { Authorization: `Bearer ${t}` },
-					});
+            },
+          );
          const data = await res.json();
          for (const r of data.items || []) {
            const status = r.claimed ? "claimed" : "unclaimed";
-						await fetch(`${PB_ENDPOINT}/api/collections/rewards/records/${r.id}`, {
+            await fetch(
+              `${PB_ENDPOINT}/api/collections/rewards/records/${r.id}`,
+              {
                method: "PATCH",
-							headers: { "Content-Type": "application/json", Authorization: `Bearer ${t}` },
+                headers: {
+                  "Content-Type": "application/json",
+                  Authorization: `Bearer ${t}`,
+                },
                body: JSON.stringify({ status }),
-						});
+              },
+            );
            total++;
          }
          if (!data.items || data.items.length < 100) break;
@@ -730,16 +941,26 @@ export async function migrate(): Promise<void> {
        // Remove claimed field and add status + requestedAt fields
        c.fields = c.fields.filter((f: any) => f.name !== "claimed");
        if (!c.fields.some((f: any) => f.name === "status")) {
-					c.fields.push({ name: "status", type: "select", required: true, values: ["unclaimed", "requested", "claimed"], maxSelect: 1 });
+          c.fields.push({
+            name: "status",
+            type: "select",
+            required: true,
+            values: ["unclaimed", "requested", "claimed"],
+            maxSelect: 1,
+          });
        }
        if (!c.fields.some((f: any) => f.name === "requestedAt")) {
          c.fields.push({ name: "requestedAt", type: "date", required: false });
        }
        await updateCollection(c.id, {
-					name: "rewards", type: "base",
-					listRule: c.listRule, viewRule: c.viewRule,
-					createRule: c.createRule, updateRule: c.updateRule,
-					deleteRule: c.deleteRule, fields: c.fields,
+          name: "rewards",
+          type: "base",
+          listRule: c.listRule,
+          viewRule: c.viewRule,
+          createRule: c.createRule,
+          updateRule: c.updateRule,
+          deleteRule: c.deleteRule,
+          fields: c.fields,
        });
      } else if (!hasClaimedField) {
        console.log(`  ↳ rewards.claimed already converted to status`);
@@ -747,5 +968,201 @@ export async function migrate(): Promise<void> {
    }
  }

+  // ── 23. Create bonus_templates collection if missing ──
+  {
+    const existing = await getCollection("bonus_templates");
+    if (!existing) {
+      const famsCol = await getCollection("fams");
+      if (!famsCol) throw new Error("fams collection not found");
+      console.log("[migrate] Creating bonus_templates collection...");
+      await createCollection({
+        name: "bonus_templates",
+        type: "base",
+        listRule: "",
+        viewRule: "",
+        createRule: null,
+        updateRule: null,
+        deleteRule: null,
+        fields: [
+          {
+            name: "famId",
+            type: "relation",
+            required: true,
+            collectionId: famsCol.id,
+            maxSelect: 1,
+            cascadeDelete: false,
+          },
+          { name: "name", type: "text", required: true },
+          { name: "description", type: "text", required: false },
+          {
+            name: "target",
+            type: "select",
+            required: true,
+            values: ["individual", "competitive", "collaborative"],
+            maxSelect: 1,
+          },
+          {
+            name: "type",
+            type: "select",
+            required: true,
+            values: ["threshold", "count", "manual"],
+            maxSelect: 1,
+          },
+          {
+            name: "occurrence",
+            type: "select",
+            required: true,
+            values: ["recurring", "once"],
+            maxSelect: 1,
+          },
+          {
+            name: "rewardType",
+            type: "select",
+            required: true,
+            values: ["points", "cash", "prize"],
+            maxSelect: 1,
+          },
+          { name: "rewardValue", type: "text", required: true },
+          { name: "criteriaValue", type: "number", required: false },
+          {
+            name: "period",
+            type: "select",
+            required: false,
+            values: ["schedule", "daily", "weekly", "monthly"],
+            maxSelect: 1,
+          },
+        ],
+      });
+    } else {
+      console.log(`  ↳ bonus_templates already exists`);
+    }
+  }
+
+  // ── 24. Migrate phase='template' bonus_configs → bonus_templates, then delete originals ──
+  {
+    const configsCol = await getCollection("bonus_configs");
+    const templatesCol = await getCollection("bonus_templates");
+    if (configsCol && templatesCol) {
+      const t = await auth();
+      const all = await fetch(
+        `${PB_ENDPOINT}/api/collections/bonus_configs/records?perPage=1000`,
+        {
+          headers: { Authorization: `Bearer ${t}` },
+        },
+      );
+      const data = await all.json();
+      const templateRecords = (data?.items || []).filter(
+        (r: any) => r.phase === "template",
+      );
+      if (templateRecords.length > 0) {
+        console.log(
+          `[migrate] Moving ${templateRecords.length} templates from bonus_configs → bonus_templates...`,
+        );
+        for (const rec of templateRecords) {
+          const {
+            id,
+            phase,
+            status,
+            completedAt,
+            memberId,
+            created,
+            updated,
+            collectionId,
+            expand,
+            ...fields
+          } = rec;
+          await fetch(
+            `${PB_ENDPOINT}/api/collections/bonus_templates/records`,
+            {
+              method: "POST",
+              headers: {
+                "Content-Type": "application/json",
+                Authorization: `Bearer ${t}`,
+              },
+              body: JSON.stringify(fields),
+            },
+          );
+          await fetch(
+            `${PB_ENDPOINT}/api/collections/bonus_configs/records/${id}`,
+            {
+              method: "DELETE",
+              headers: { Authorization: `Bearer ${t}` },
+            },
+          );
+        }
+        console.log(`  ✓ Moved ${templateRecords.length} bonus templates`);
+      } else {
+        console.log(`  ↳ no phase=template bonus_configs to migrate`);
+      }
+    }
+  }
+
+  // ── 25. Drop phase/completedAt from bonus_configs; status → active|completed ──
+  {
+    const c = await getCollection("bonus_configs");
+    if (c) {
+      const hasPhase = c.fields.some((f: any) => f.name === "phase");
+      const hasCompletedAt = c.fields.some(
+        (f: any) => f.name === "completedAt",
+      );
+      const statusField = c.fields.find((f: any) => f.name === "status");
+      const needsStatusUpdate =
+        statusField && !statusField.values.includes("completed");
+      if (hasPhase || hasCompletedAt || needsStatusUpdate) {
+        console.log(
+          "[migrate] Restructuring bonus_configs (drop phase/completedAt, status → active|completed)...",
+        );
+        if (statusField && needsStatusUpdate)
+          statusField.values = ["active", "completed"];
+        c.fields = c.fields.filter(
+          (f: any) => f.name !== "phase" && f.name !== "completedAt",
+        );
+        await updateCollection(c.id, {
+          name: "bonus_configs",
+          type: "base",
+          listRule: c.listRule,
+          viewRule: c.viewRule,
+          createRule: c.createRule,
+          updateRule: c.updateRule,
+          deleteRule: c.deleteRule,
+          fields: c.fields,
+        });
+        const t = await auth();
+        const all = await fetch(
+          `${PB_ENDPOINT}/api/collections/bonus_configs/records?perPage=1000`,
+          {
+            headers: { Authorization: `Bearer ${t}` },
+          },
+        );
+        const data = await all.json();
+        let updated = 0;
+        for (const rec of data?.items || []) {
+          const completed =
+            rec.phase === "completed" || rec.status === "archived";
+          const newStatus = completed ? "completed" : "active";
+          if (rec.status !== newStatus) {
+            await fetch(
+              `${PB_ENDPOINT}/api/collections/bonus_configs/records/${rec.id}`,
+              {
+                method: "PATCH",
+                headers: {
+                  "Content-Type": "application/json",
+                  Authorization: `Bearer ${t}`,
+                },
+                body: JSON.stringify({ status: newStatus }),
+              },
+            );
+            updated++;
+          }
+        }
+        console.log(
+          `  ✓ Updated ${updated} bonus_configs to status=active|completed`,
+        );
+      } else {
+        console.log(`  ↳ bonus_configs already restructured`);
+      }
+    }
+  }
+
  console.log("[migrate] Done");
 }