Compare commits
5
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
39ea1ae5aa | ||
|
|
86444bc850 | ||
|
|
7704924d88 | ||
|
|
7ffc2f9522 | ||
|
|
f3c6137fed |
@@ -76,6 +76,8 @@ src/
|
||||
|
||||
**Rule for contributors (including future Codex and Claude Code sessions):** if a feature requires a change to `_core` to support a new entity type, that's a smell — extend the registry instead.
|
||||
|
||||
**Completion rule for module additions and behavior changes:** include the authenticated v1 API and OpenAPI documentation, assistant tools backed by that API, and a complete reminder lifecycle for every user-visible due date. API, agent, and UI must call the same scoped server services; create/update must synchronize unfired reminders and delete must cancel them.
|
||||
|
||||
---
|
||||
|
||||
## Data model (v1)
|
||||
|
||||
@@ -77,6 +77,8 @@ src/
|
||||
|
||||
**Rule for contributors (including future Codex and Claude Code sessions):** if a feature requires a change to `_core` to support a new entity type, that's a smell — extend the registry instead.
|
||||
|
||||
**Completion rule for module additions and behavior changes:** include the authenticated v1 API and OpenAPI documentation, assistant tools backed by that API, and a complete reminder lifecycle for every user-visible due date. API, agent, and UI must call the same scoped server services; create/update must synchronize unfired reminders and delete must cancel them.
|
||||
|
||||
---
|
||||
|
||||
## Data model (v1)
|
||||
|
||||
File diff suppressed because it is too large
Load Diff
@@ -0,0 +1,70 @@
|
||||
-- Custom SQL migration file, put your code below! --
|
||||
CREATE TABLE "pets" (
|
||||
"id" uuid PRIMARY KEY DEFAULT gen_random_uuid() NOT NULL,
|
||||
"household_id" uuid NOT NULL,
|
||||
"name" text NOT NULL,
|
||||
"species" text NOT NULL,
|
||||
"breed" text,
|
||||
"birth_date" date,
|
||||
"notes" text,
|
||||
"primary_image_url" text,
|
||||
"images" jsonb DEFAULT '[]'::jsonb NOT NULL,
|
||||
"created_at" timestamp with time zone DEFAULT now() NOT NULL,
|
||||
"updated_at" timestamp with time zone DEFAULT now() NOT NULL,
|
||||
CONSTRAINT "pets_household_id_households_id_fk" FOREIGN KEY ("household_id") REFERENCES "public"."households"("id") ON DELETE cascade ON UPDATE no action
|
||||
);
|
||||
--> statement-breakpoint
|
||||
CREATE TABLE "pet_appointments" (
|
||||
"id" uuid PRIMARY KEY DEFAULT gen_random_uuid() NOT NULL,
|
||||
"pet_id" uuid NOT NULL,
|
||||
"household_id" uuid NOT NULL,
|
||||
"title" text NOT NULL,
|
||||
"appointment_at" timestamp with time zone NOT NULL,
|
||||
"clinic" text,
|
||||
"notes" text,
|
||||
"calendar_event_id" uuid,
|
||||
"created_at" timestamp with time zone DEFAULT now() NOT NULL,
|
||||
"updated_at" timestamp with time zone DEFAULT now() NOT NULL,
|
||||
CONSTRAINT "pet_appointments_pet_id_pets_id_fk" FOREIGN KEY ("pet_id") REFERENCES "public"."pets"("id") ON DELETE cascade ON UPDATE no action,
|
||||
CONSTRAINT "pet_appointments_household_id_households_id_fk" FOREIGN KEY ("household_id") REFERENCES "public"."households"("id") ON DELETE cascade ON UPDATE no action
|
||||
);
|
||||
--> statement-breakpoint
|
||||
CREATE TABLE "pet_vaccinations" (
|
||||
"id" uuid PRIMARY KEY DEFAULT gen_random_uuid() NOT NULL,
|
||||
"pet_id" uuid NOT NULL,
|
||||
"household_id" uuid NOT NULL,
|
||||
"name" text NOT NULL,
|
||||
"administered_on" date NOT NULL,
|
||||
"due_on" date,
|
||||
"provider" text,
|
||||
"notes" text,
|
||||
"created_at" timestamp with time zone DEFAULT now() NOT NULL,
|
||||
"updated_at" timestamp with time zone DEFAULT now() NOT NULL,
|
||||
CONSTRAINT "pet_vaccinations_pet_id_pets_id_fk" FOREIGN KEY ("pet_id") REFERENCES "public"."pets"("id") ON DELETE cascade ON UPDATE no action,
|
||||
CONSTRAINT "pet_vaccinations_household_id_households_id_fk" FOREIGN KEY ("household_id") REFERENCES "public"."households"("id") ON DELETE cascade ON UPDATE no action
|
||||
);
|
||||
--> statement-breakpoint
|
||||
CREATE TABLE "pet_prescriptions" (
|
||||
"id" uuid PRIMARY KEY DEFAULT gen_random_uuid() NOT NULL,
|
||||
"pet_id" uuid NOT NULL,
|
||||
"household_id" uuid NOT NULL,
|
||||
"medication" text NOT NULL,
|
||||
"dosage" text NOT NULL,
|
||||
"instructions" text,
|
||||
"prescribed_on" date,
|
||||
"expires_on" date,
|
||||
"refills_remaining" integer,
|
||||
"active" boolean DEFAULT true NOT NULL,
|
||||
"created_at" timestamp with time zone DEFAULT now() NOT NULL,
|
||||
"updated_at" timestamp with time zone DEFAULT now() NOT NULL,
|
||||
CONSTRAINT "pet_prescriptions_pet_id_pets_id_fk" FOREIGN KEY ("pet_id") REFERENCES "public"."pets"("id") ON DELETE cascade ON UPDATE no action,
|
||||
CONSTRAINT "pet_prescriptions_household_id_households_id_fk" FOREIGN KEY ("household_id") REFERENCES "public"."households"("id") ON DELETE cascade ON UPDATE no action
|
||||
);
|
||||
--> statement-breakpoint
|
||||
CREATE INDEX "pets_household_idx" ON "pets" USING btree ("household_id");
|
||||
--> statement-breakpoint
|
||||
CREATE INDEX "pet_appointments_pet_at_idx" ON "pet_appointments" USING btree ("pet_id", "appointment_at");
|
||||
--> statement-breakpoint
|
||||
CREATE INDEX "pet_vaccinations_pet_due_idx" ON "pet_vaccinations" USING btree ("pet_id", "due_on");
|
||||
--> statement-breakpoint
|
||||
CREATE INDEX "pet_prescriptions_pet_active_idx" ON "pet_prescriptions" USING btree ("pet_id", "active");
|
||||
File diff suppressed because it is too large
Load Diff
@@ -190,6 +190,13 @@
|
||||
"when": 1783561000000,
|
||||
"tag": "0026_assistant_model_route",
|
||||
"breakpoints": true
|
||||
},
|
||||
{
|
||||
"idx": 27,
|
||||
"version": "7",
|
||||
"when": 1783648174004,
|
||||
"tag": "0027_pets_module",
|
||||
"breakpoints": true
|
||||
}
|
||||
]
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,17 @@
|
||||
import { notFound } from "next/navigation";
|
||||
import { DetailBackLink } from "@/components/detail-back-link";
|
||||
import { PetForm } from "@/modules/pets/components/pet-form";
|
||||
import { getPet } from "@/modules/pets/server/queries";
|
||||
|
||||
export default async function EditPetPage({ params }: { params: Promise<{ id: string }> }) {
|
||||
const { id } = await params;
|
||||
const pet = await getPet(id);
|
||||
if (!pet) notFound();
|
||||
return (
|
||||
<div className="page-content max-w-xl">
|
||||
<DetailBackLink href={`/pets/${pet.id}`} label={pet.name} className="mb-3" />
|
||||
<h1 className="page-title">Edit pet</h1>
|
||||
<PetForm pet={pet} />
|
||||
</div>
|
||||
);
|
||||
}
|
||||
@@ -0,0 +1,33 @@
|
||||
import Link from "next/link";
|
||||
import { notFound } from "next/navigation";
|
||||
import { DetailBackLink } from "@/components/detail-back-link";
|
||||
import { getPet } from "@/modules/pets/server/queries";
|
||||
import { MedicalRecords } from "@/modules/pets/components/medical-records";
|
||||
|
||||
export default async function PetPage({ params }: { params: Promise<{ id: string }> }) {
|
||||
const { id } = await params;
|
||||
const pet = await getPet(id);
|
||||
if (!pet) notFound();
|
||||
return (
|
||||
<div className="page-content max-w-xl">
|
||||
<DetailBackLink href="/pets" label="Pets" className="mb-3" />
|
||||
<div className="mb-6 flex items-center justify-between">
|
||||
<div>
|
||||
<h1 className="page-title mb-1">{pet.name}</h1>
|
||||
<p className="capitalize text-[var(--ink-mute)]">
|
||||
{[pet.species, pet.breed].filter(Boolean).join(" · ")}
|
||||
</p>
|
||||
</div>
|
||||
<Link href={`/pets/${pet.id}/edit`} className="btn btn-ghost">
|
||||
Edit
|
||||
</Link>
|
||||
</div>
|
||||
<section className="card p-4">
|
||||
<h2 className="mb-2 font-semibold">Profile</h2>
|
||||
{pet.birthDate && <p>Born {pet.birthDate}</p>}
|
||||
{pet.notes && <p className="whitespace-pre-wrap">{pet.notes}</p>}
|
||||
<MedicalRecords pet={pet} />
|
||||
</section>
|
||||
</div>
|
||||
);
|
||||
}
|
||||
@@ -0,0 +1,12 @@
|
||||
import { DetailBackLink } from "@/components/detail-back-link";
|
||||
import { PetForm } from "@/modules/pets/components/pet-form";
|
||||
|
||||
export default function NewPetPage() {
|
||||
return (
|
||||
<div className="page-content max-w-xl">
|
||||
<DetailBackLink href="/pets" label="Pets" className="mb-3" />
|
||||
<h1 className="page-title">Add pet</h1>
|
||||
<PetForm />
|
||||
</div>
|
||||
);
|
||||
}
|
||||
@@ -0,0 +1,34 @@
|
||||
import Link from "next/link";
|
||||
import { listPets } from "@/modules/pets/server/queries";
|
||||
|
||||
export default async function PetsPage() {
|
||||
const pets = await listPets();
|
||||
return (
|
||||
<div className="page-content">
|
||||
<div className="mb-6 flex items-center justify-between gap-4">
|
||||
<h1 className="page-title mb-0">Pets</h1>
|
||||
<Link href="/pets/new" className="btn btn-primary">
|
||||
Add pet
|
||||
</Link>
|
||||
</div>
|
||||
{pets.length === 0 ? (
|
||||
<p className="text-sm text-[var(--ink-mute)]">No pets yet.</p>
|
||||
) : (
|
||||
<div className="grid gap-3 sm:grid-cols-2 lg:grid-cols-3">
|
||||
{pets.map((pet) => (
|
||||
<Link
|
||||
key={pet.id}
|
||||
href={`/pets/${pet.id}`}
|
||||
className="card p-4 hover:bg-[var(--surface-2)]"
|
||||
>
|
||||
<h2 className="font-semibold">{pet.name}</h2>
|
||||
<p className="text-sm capitalize text-[var(--ink-mute)]">
|
||||
{[pet.species, pet.breed].filter(Boolean).join(" · ")}
|
||||
</p>
|
||||
</Link>
|
||||
))}
|
||||
</div>
|
||||
)}
|
||||
</div>
|
||||
);
|
||||
}
|
||||
@@ -3,6 +3,7 @@ import {
|
||||
BookHeart,
|
||||
Calendar,
|
||||
Sprout,
|
||||
PawPrint,
|
||||
CalendarDays,
|
||||
CheckSquare,
|
||||
ChevronDown,
|
||||
@@ -73,6 +74,7 @@ const ICONS: Record<string, React.ComponentType<LucideProps>> = {
|
||||
filter: Filter,
|
||||
sun: Sun,
|
||||
sprout: Sprout,
|
||||
"paw-print": PawPrint,
|
||||
mail: Mail,
|
||||
menu: Menu,
|
||||
"message-circle": MessageCircle,
|
||||
|
||||
@@ -0,0 +1,39 @@
|
||||
export function resolveHouseholdTimezone(): string {
|
||||
return process.env.HOUSEHOLD_TIMEZONE?.trim() || process.env.TZ?.trim() || "America/Chicago";
|
||||
}
|
||||
|
||||
function part(parts: Intl.DateTimeFormatPart[], type: Intl.DateTimeFormatPartTypes): number {
|
||||
const value = parts.find((item) => item.type === type)?.value;
|
||||
if (!value) throw new Error(`Missing ${type} timezone part`);
|
||||
return Number(value);
|
||||
}
|
||||
|
||||
export function householdDateAt(
|
||||
isoDate: string,
|
||||
hour: number,
|
||||
timeZone = resolveHouseholdTimezone(),
|
||||
): Date {
|
||||
const [year, month, day] = isoDate.split("-").map(Number);
|
||||
if (!year || !month || !day || hour < 0 || hour > 23) throw new Error("Invalid household date");
|
||||
|
||||
const candidate = Date.UTC(year, month - 1, day, hour);
|
||||
const parts = new Intl.DateTimeFormat("en-US", {
|
||||
timeZone,
|
||||
year: "numeric",
|
||||
month: "2-digit",
|
||||
day: "2-digit",
|
||||
hour: "2-digit",
|
||||
minute: "2-digit",
|
||||
second: "2-digit",
|
||||
hourCycle: "h23",
|
||||
}).formatToParts(new Date(candidate));
|
||||
const formattedAsUtc = Date.UTC(
|
||||
part(parts, "year"),
|
||||
part(parts, "month") - 1,
|
||||
part(parts, "day"),
|
||||
part(parts, "hour"),
|
||||
part(parts, "minute"),
|
||||
part(parts, "second"),
|
||||
);
|
||||
return new Date(candidate - (formattedAsUtc - candidate));
|
||||
}
|
||||
@@ -4,6 +4,7 @@ import calendarManifest from "./calendar/manifest";
|
||||
import listsManifest from "./lists/manifest";
|
||||
import notesManifest from "./notes/manifest";
|
||||
import gardenManifest from "./garden/manifest";
|
||||
import petsManifest from "./pets/manifest";
|
||||
import bangsManifest from "./bangs/manifest";
|
||||
import journalManifest from "./journal/manifest";
|
||||
import agentManifest from "./agent/manifest";
|
||||
@@ -13,6 +14,7 @@ registerModule(calendarManifest);
|
||||
registerModule(listsManifest);
|
||||
registerModule(notesManifest);
|
||||
registerModule(gardenManifest);
|
||||
registerModule(petsManifest);
|
||||
registerModule(bangsManifest);
|
||||
registerModule(journalManifest);
|
||||
registerModule(agentManifest);
|
||||
|
||||
@@ -0,0 +1,121 @@
|
||||
"use client";
|
||||
|
||||
import { useTransition } from "react";
|
||||
import type { PetDetailDto } from "../server/queries";
|
||||
import { createAppointment, createPrescription, createVaccination } from "../server/actions";
|
||||
|
||||
export function MedicalRecords({ pet }: { pet: PetDetailDto }) {
|
||||
const [pending, startTransition] = useTransition();
|
||||
function add(form: HTMLFormElement, action: () => Promise<unknown>) {
|
||||
startTransition(async () => {
|
||||
await action();
|
||||
form.reset();
|
||||
location.reload();
|
||||
});
|
||||
}
|
||||
return (
|
||||
<div className="mt-6 grid gap-4">
|
||||
<section className="card p-4">
|
||||
<h2 className="mb-3 font-semibold">Appointments</h2>
|
||||
<form
|
||||
onSubmit={(event) => {
|
||||
event.preventDefault();
|
||||
const form = event.currentTarget;
|
||||
const data = new FormData(form);
|
||||
add(form, () =>
|
||||
createAppointment({
|
||||
petId: pet.id,
|
||||
title: String(data.get("title")),
|
||||
appointmentAt: String(data.get("appointmentAt")),
|
||||
clinic: String(data.get("clinic")) || null,
|
||||
reminderOffsets: [30],
|
||||
}),
|
||||
);
|
||||
}}
|
||||
className="flex flex-wrap gap-2"
|
||||
>
|
||||
<input name="title" className="input" placeholder="Appointment" required />
|
||||
<input name="appointmentAt" className="input" type="datetime-local" required />
|
||||
<input name="clinic" className="input" placeholder="Clinic" />
|
||||
<button className="btn btn-primary" disabled={pending}>
|
||||
Add appointment
|
||||
</button>
|
||||
</form>
|
||||
<ul className="mt-3 space-y-1">
|
||||
{pet.appointments.map((item) => (
|
||||
<li key={item.id}>
|
||||
{item.title} — {new Date(item.appointmentAt).toLocaleString()}
|
||||
</li>
|
||||
))}
|
||||
</ul>
|
||||
</section>
|
||||
<section className="card p-4">
|
||||
<h2 className="mb-3 font-semibold">Vaccinations</h2>
|
||||
<form
|
||||
onSubmit={(event) => {
|
||||
event.preventDefault();
|
||||
const form = event.currentTarget;
|
||||
const data = new FormData(form);
|
||||
add(form, () =>
|
||||
createVaccination({
|
||||
petId: pet.id,
|
||||
name: String(data.get("name")),
|
||||
administeredOn: String(data.get("administeredOn")),
|
||||
dueOn: String(data.get("dueOn")) || null,
|
||||
}),
|
||||
);
|
||||
}}
|
||||
className="flex flex-wrap gap-2"
|
||||
>
|
||||
<input name="name" className="input" placeholder="Vaccination" required />
|
||||
<input name="administeredOn" className="input" type="date" required />
|
||||
<input name="dueOn" className="input" type="date" />
|
||||
<button className="btn btn-primary" disabled={pending}>
|
||||
Add vaccination
|
||||
</button>
|
||||
</form>
|
||||
<ul className="mt-3 space-y-1">
|
||||
{pet.vaccinations.map((item) => (
|
||||
<li key={item.id}>
|
||||
{item.name} — {item.administeredOn}
|
||||
</li>
|
||||
))}
|
||||
</ul>
|
||||
</section>
|
||||
<section className="card p-4">
|
||||
<h2 className="mb-3 font-semibold">Prescriptions</h2>
|
||||
<form
|
||||
onSubmit={(event) => {
|
||||
event.preventDefault();
|
||||
const form = event.currentTarget;
|
||||
const data = new FormData(form);
|
||||
add(form, () =>
|
||||
createPrescription({
|
||||
petId: pet.id,
|
||||
medication: String(data.get("medication")),
|
||||
dosage: String(data.get("dosage")),
|
||||
expiresOn: String(data.get("expiresOn")) || null,
|
||||
active: true,
|
||||
}),
|
||||
);
|
||||
}}
|
||||
className="flex flex-wrap gap-2"
|
||||
>
|
||||
<input name="medication" className="input" placeholder="Medication" required />
|
||||
<input name="dosage" className="input" placeholder="Dosage" required />
|
||||
<input name="expiresOn" className="input" type="date" />
|
||||
<button className="btn btn-primary" disabled={pending}>
|
||||
Add prescription
|
||||
</button>
|
||||
</form>
|
||||
<ul className="mt-3 space-y-1">
|
||||
{pet.prescriptions.map((item) => (
|
||||
<li key={item.id}>
|
||||
{item.medication} — {item.dosage}
|
||||
</li>
|
||||
))}
|
||||
</ul>
|
||||
</section>
|
||||
</div>
|
||||
);
|
||||
}
|
||||
@@ -0,0 +1,81 @@
|
||||
"use client";
|
||||
|
||||
import { useState, useTransition } from "react";
|
||||
import { useRouter } from "next/navigation";
|
||||
import type { PetDetailDto } from "../server/queries";
|
||||
import { createPet, updatePet } from "../server/actions";
|
||||
import { Input } from "@/components/ui/input";
|
||||
|
||||
export function PetForm({ pet }: { pet?: PetDetailDto }) {
|
||||
const router = useRouter();
|
||||
const [isPending, startTransition] = useTransition();
|
||||
const [error, setError] = useState<string | null>(null);
|
||||
|
||||
function submit(event: React.FormEvent<HTMLFormElement>) {
|
||||
event.preventDefault();
|
||||
const data = new FormData(event.currentTarget);
|
||||
const input = {
|
||||
name: String(data.get("name") ?? ""),
|
||||
species: String(data.get("species") ?? ""),
|
||||
breed: String(data.get("breed") ?? "") || null,
|
||||
birthDate: String(data.get("birthDate") ?? "") || null,
|
||||
notes: String(data.get("notes") ?? "") || null,
|
||||
images: pet?.images ?? [],
|
||||
primaryImageUrl: pet?.primaryImageUrl ?? null,
|
||||
};
|
||||
setError(null);
|
||||
startTransition(async () => {
|
||||
try {
|
||||
if (pet) {
|
||||
await updatePet({ id: pet.id, ...input });
|
||||
router.push(`/pets/${pet.id}`);
|
||||
} else {
|
||||
const created = await createPet(input);
|
||||
router.push(`/pets/${created.id}`);
|
||||
}
|
||||
router.refresh();
|
||||
} catch {
|
||||
setError("Could not save pet.");
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
return (
|
||||
<form onSubmit={submit} className="flex max-w-xl flex-col gap-4">
|
||||
<label className="flex flex-col gap-1 text-sm font-medium">
|
||||
Name
|
||||
<Input name="name" required maxLength={120} defaultValue={pet?.name} />
|
||||
</label>
|
||||
<label className="flex flex-col gap-1 text-sm font-medium">
|
||||
Species
|
||||
<Input name="species" required maxLength={80} defaultValue={pet?.species} />
|
||||
</label>
|
||||
<label className="flex flex-col gap-1 text-sm font-medium">
|
||||
Breed
|
||||
<Input name="breed" maxLength={120} defaultValue={pet?.breed ?? ""} />
|
||||
</label>
|
||||
<label className="flex flex-col gap-1 text-sm font-medium">
|
||||
Birth date
|
||||
<Input name="birthDate" type="date" defaultValue={pet?.birthDate ?? ""} />
|
||||
</label>
|
||||
<label className="flex flex-col gap-1 text-sm font-medium">
|
||||
Notes
|
||||
<textarea
|
||||
name="notes"
|
||||
defaultValue={pet?.notes ?? ""}
|
||||
className="input min-h-24"
|
||||
maxLength={4000}
|
||||
/>
|
||||
</label>
|
||||
{error && <p className="text-sm text-destructive">{error}</p>}
|
||||
<div className="flex justify-end gap-2">
|
||||
<button type="button" className="btn btn-ghost" onClick={() => router.back()}>
|
||||
Cancel
|
||||
</button>
|
||||
<button type="submit" className="btn btn-primary" disabled={isPending}>
|
||||
{isPending ? "Saving…" : pet ? "Save" : "Create"}
|
||||
</button>
|
||||
</div>
|
||||
</form>
|
||||
);
|
||||
}
|
||||
@@ -0,0 +1,49 @@
|
||||
import { z } from "zod";
|
||||
import type { ModuleManifest } from "../_core/module";
|
||||
import { searchPets } from "./server/queries";
|
||||
|
||||
const petsManifest: ModuleManifest = {
|
||||
id: "pets",
|
||||
name: "Pets",
|
||||
nav: { href: "/pets", label: "Pets", icon: "paw-print" },
|
||||
entities: [
|
||||
{
|
||||
type: "pets.pet",
|
||||
label: { singular: "Pet", plural: "Pets" },
|
||||
search: { search: searchPets },
|
||||
reminder: { canRemind: true },
|
||||
resolveUrl: (id) => `/pets/${id}`,
|
||||
renderActivity: (entry) => {
|
||||
const name = entry.payload?.name as string | undefined;
|
||||
if (entry.action === "create") return `Added pet${name ? ` "${name}"` : ""}`;
|
||||
if (entry.action === "delete") return `Removed pet${name ? ` "${name}"` : ""}`;
|
||||
return `Updated pet${name ? ` "${name}"` : ""}`;
|
||||
},
|
||||
},
|
||||
],
|
||||
dashboardWidgets: [
|
||||
{
|
||||
id: "pets.overview",
|
||||
title: "Pets overview",
|
||||
description: "Pet count and medical items due within 30 days.",
|
||||
category: "Pets",
|
||||
defaultSize: { w: 3, h: 2 },
|
||||
minSize: { w: 2, h: 2 },
|
||||
defaultPriority: 60,
|
||||
configSchema: z.object({}),
|
||||
defaultConfig: {},
|
||||
render: () => null,
|
||||
},
|
||||
],
|
||||
quickAdds: [
|
||||
{
|
||||
id: "pets.add",
|
||||
label: "Add pet",
|
||||
icon: "paw-print",
|
||||
url: "/pets/new",
|
||||
createKey: "pets.pet",
|
||||
},
|
||||
],
|
||||
};
|
||||
|
||||
export default petsManifest;
|
||||
@@ -0,0 +1,102 @@
|
||||
import {
|
||||
boolean,
|
||||
date,
|
||||
index,
|
||||
integer,
|
||||
jsonb,
|
||||
pgTable,
|
||||
text,
|
||||
timestamp,
|
||||
uuid,
|
||||
} from "drizzle-orm/pg-core";
|
||||
import { households } from "../_core/schema";
|
||||
|
||||
export const pets = pgTable(
|
||||
"pets",
|
||||
{
|
||||
id: uuid("id").primaryKey().defaultRandom(),
|
||||
householdId: uuid("household_id")
|
||||
.notNull()
|
||||
.references(() => households.id, { onDelete: "cascade" }),
|
||||
name: text("name").notNull(),
|
||||
species: text("species").notNull(),
|
||||
breed: text("breed"),
|
||||
birthDate: date("birth_date"),
|
||||
notes: text("notes"),
|
||||
primaryImageUrl: text("primary_image_url"),
|
||||
images: jsonb("images").notNull().default([]).$type<string[]>(),
|
||||
createdAt: timestamp("created_at", { withTimezone: true }).notNull().defaultNow(),
|
||||
updatedAt: timestamp("updated_at", { withTimezone: true }).notNull().defaultNow(),
|
||||
},
|
||||
(table) => [index("pets_household_idx").on(table.householdId)],
|
||||
);
|
||||
|
||||
export const petAppointments = pgTable(
|
||||
"pet_appointments",
|
||||
{
|
||||
id: uuid("id").primaryKey().defaultRandom(),
|
||||
petId: uuid("pet_id")
|
||||
.notNull()
|
||||
.references(() => pets.id, { onDelete: "cascade" }),
|
||||
householdId: uuid("household_id")
|
||||
.notNull()
|
||||
.references(() => households.id, { onDelete: "cascade" }),
|
||||
title: text("title").notNull(),
|
||||
appointmentAt: timestamp("appointment_at", { withTimezone: true }).notNull(),
|
||||
clinic: text("clinic"),
|
||||
notes: text("notes"),
|
||||
calendarEventId: uuid("calendar_event_id"),
|
||||
createdAt: timestamp("created_at", { withTimezone: true }).notNull().defaultNow(),
|
||||
updatedAt: timestamp("updated_at", { withTimezone: true }).notNull().defaultNow(),
|
||||
},
|
||||
(table) => [index("pet_appointments_pet_at_idx").on(table.petId, table.appointmentAt)],
|
||||
);
|
||||
|
||||
export const petVaccinations = pgTable(
|
||||
"pet_vaccinations",
|
||||
{
|
||||
id: uuid("id").primaryKey().defaultRandom(),
|
||||
petId: uuid("pet_id")
|
||||
.notNull()
|
||||
.references(() => pets.id, { onDelete: "cascade" }),
|
||||
householdId: uuid("household_id")
|
||||
.notNull()
|
||||
.references(() => households.id, { onDelete: "cascade" }),
|
||||
name: text("name").notNull(),
|
||||
administeredOn: date("administered_on").notNull(),
|
||||
dueOn: date("due_on"),
|
||||
provider: text("provider"),
|
||||
notes: text("notes"),
|
||||
createdAt: timestamp("created_at", { withTimezone: true }).notNull().defaultNow(),
|
||||
updatedAt: timestamp("updated_at", { withTimezone: true }).notNull().defaultNow(),
|
||||
},
|
||||
(table) => [index("pet_vaccinations_pet_due_idx").on(table.petId, table.dueOn)],
|
||||
);
|
||||
|
||||
export const petPrescriptions = pgTable(
|
||||
"pet_prescriptions",
|
||||
{
|
||||
id: uuid("id").primaryKey().defaultRandom(),
|
||||
petId: uuid("pet_id")
|
||||
.notNull()
|
||||
.references(() => pets.id, { onDelete: "cascade" }),
|
||||
householdId: uuid("household_id")
|
||||
.notNull()
|
||||
.references(() => households.id, { onDelete: "cascade" }),
|
||||
medication: text("medication").notNull(),
|
||||
dosage: text("dosage").notNull(),
|
||||
instructions: text("instructions"),
|
||||
prescribedOn: date("prescribed_on"),
|
||||
expiresOn: date("expires_on"),
|
||||
refillsRemaining: integer("refills_remaining"),
|
||||
active: boolean("active").notNull().default(true),
|
||||
createdAt: timestamp("created_at", { withTimezone: true }).notNull().defaultNow(),
|
||||
updatedAt: timestamp("updated_at", { withTimezone: true }).notNull().defaultNow(),
|
||||
},
|
||||
(table) => [index("pet_prescriptions_pet_active_idx").on(table.petId, table.active)],
|
||||
);
|
||||
|
||||
export type Pet = typeof pets.$inferSelect;
|
||||
export type PetAppointment = typeof petAppointments.$inferSelect;
|
||||
export type PetVaccination = typeof petVaccinations.$inferSelect;
|
||||
export type PetPrescription = typeof petPrescriptions.$inferSelect;
|
||||
@@ -0,0 +1,381 @@
|
||||
"use server";
|
||||
|
||||
import { and, eq } from "drizzle-orm";
|
||||
import { revalidatePath } from "next/cache";
|
||||
import { z } from "zod";
|
||||
import type { ApiAuthContext } from "@/lib/api-auth";
|
||||
import { db } from "@/lib/db";
|
||||
import { getCurrentSession } from "@/lib/session";
|
||||
import { logActivityForScope } from "@/modules/_core/activity";
|
||||
import { cancelReminder, listReminderOffsets } from "@/modules/_core/reminders";
|
||||
import { petAppointments, petPrescriptions, pets, petVaccinations } from "../schema";
|
||||
import { syncPetAppointmentReminders, syncPetDueDateReminder } from "./reminders";
|
||||
import {
|
||||
appointmentInput,
|
||||
appointmentUpdateInput,
|
||||
petInput,
|
||||
petUpdateInput,
|
||||
prescriptionInput,
|
||||
prescriptionUpdateInput,
|
||||
vaccinationInput,
|
||||
vaccinationUpdateInput,
|
||||
} from "./schemas";
|
||||
|
||||
type Scope = Pick<ApiAuthContext, "householdId" | "userId">;
|
||||
const idInput = z.object({ id: z.string().uuid() });
|
||||
|
||||
async function requirePet(scope: Scope, id: string) {
|
||||
const [pet] = await db
|
||||
.select()
|
||||
.from(pets)
|
||||
.where(and(eq(pets.id, id), eq(pets.householdId, scope.householdId)))
|
||||
.limit(1);
|
||||
if (!pet) throw new Error("Pet not found");
|
||||
return pet;
|
||||
}
|
||||
|
||||
async function requireAppointment(scope: Scope, id: string) {
|
||||
const [row] = await db
|
||||
.select()
|
||||
.from(petAppointments)
|
||||
.where(and(eq(petAppointments.id, id), eq(petAppointments.householdId, scope.householdId)))
|
||||
.limit(1);
|
||||
if (!row) throw new Error("Record not found");
|
||||
return row;
|
||||
}
|
||||
async function requireVaccination(scope: Scope, id: string) {
|
||||
const [row] = await db
|
||||
.select()
|
||||
.from(petVaccinations)
|
||||
.where(and(eq(petVaccinations.id, id), eq(petVaccinations.householdId, scope.householdId)))
|
||||
.limit(1);
|
||||
if (!row) throw new Error("Record not found");
|
||||
return row;
|
||||
}
|
||||
async function requirePrescription(scope: Scope, id: string) {
|
||||
const [row] = await db
|
||||
.select()
|
||||
.from(petPrescriptions)
|
||||
.where(and(eq(petPrescriptions.id, id), eq(petPrescriptions.householdId, scope.householdId)))
|
||||
.limit(1);
|
||||
if (!row) throw new Error("Record not found");
|
||||
return row;
|
||||
}
|
||||
|
||||
function revalidatePet(id: string) {
|
||||
revalidatePath("/pets");
|
||||
revalidatePath(`/pets/${id}`);
|
||||
}
|
||||
|
||||
export async function createPetForScope(scope: Scope, input: z.input<typeof petInput>) {
|
||||
const parsed = petInput.parse(input);
|
||||
const [pet] = await db
|
||||
.insert(pets)
|
||||
.values({
|
||||
householdId: scope.householdId,
|
||||
...parsed,
|
||||
breed: parsed.breed ?? null,
|
||||
birthDate: parsed.birthDate ?? null,
|
||||
notes: parsed.notes ?? null,
|
||||
primaryImageUrl: parsed.primaryImageUrl ?? parsed.images[0] ?? null,
|
||||
})
|
||||
.returning();
|
||||
if (!pet) throw new Error("Pet was not created");
|
||||
await logActivityForScope(scope, {
|
||||
entityType: "pets.pet",
|
||||
entityId: pet.id,
|
||||
action: "create",
|
||||
payload: { name: pet.name },
|
||||
});
|
||||
return pet;
|
||||
}
|
||||
export async function createPet(input: z.input<typeof petInput>) {
|
||||
const { household, user } = await getCurrentSession();
|
||||
const pet = await createPetForScope({ householdId: household.id, userId: user.id }, input);
|
||||
revalidatePet(pet.id);
|
||||
return pet;
|
||||
}
|
||||
|
||||
export async function updatePetForScope(
|
||||
scope: Scope,
|
||||
input: { id: string } & z.input<typeof petUpdateInput>,
|
||||
) {
|
||||
const parsed = idInput.and(petUpdateInput).parse(input);
|
||||
await requirePet(scope, parsed.id);
|
||||
const { id, ...changes } = parsed;
|
||||
await db
|
||||
.update(pets)
|
||||
.set({ ...changes, updatedAt: new Date() })
|
||||
.where(eq(pets.id, id));
|
||||
await logActivityForScope(scope, { entityType: "pets.pet", entityId: id, action: "update" });
|
||||
}
|
||||
export async function updatePet(input: { id: string } & z.input<typeof petUpdateInput>) {
|
||||
const { household, user } = await getCurrentSession();
|
||||
await updatePetForScope({ householdId: household.id, userId: user.id }, input);
|
||||
revalidatePet(input.id);
|
||||
}
|
||||
|
||||
export async function deletePetForScope(scope: Scope, input: { id: string }) {
|
||||
const { id } = idInput.parse(input);
|
||||
const pet = await requirePet(scope, id);
|
||||
await logActivityForScope(scope, {
|
||||
entityType: "pets.pet",
|
||||
entityId: id,
|
||||
action: "delete",
|
||||
payload: { name: pet.name },
|
||||
});
|
||||
await db.delete(pets).where(eq(pets.id, id));
|
||||
}
|
||||
export async function deletePet(input: { id: string }) {
|
||||
const { household, user } = await getCurrentSession();
|
||||
await deletePetForScope({ householdId: household.id, userId: user.id }, input);
|
||||
revalidatePath("/pets");
|
||||
}
|
||||
|
||||
export async function createAppointmentForScope(
|
||||
scope: Scope,
|
||||
input: z.input<typeof appointmentInput>,
|
||||
) {
|
||||
const parsed = appointmentInput.parse(input);
|
||||
const pet = await requirePet(scope, parsed.petId);
|
||||
const [row] = await db
|
||||
.insert(petAppointments)
|
||||
.values({
|
||||
householdId: scope.householdId,
|
||||
petId: parsed.petId,
|
||||
title: parsed.title,
|
||||
appointmentAt: parsed.appointmentAt,
|
||||
clinic: parsed.clinic ?? null,
|
||||
notes: parsed.notes ?? null,
|
||||
})
|
||||
.returning();
|
||||
if (!row) throw new Error("Appointment was not created");
|
||||
if (scope.userId)
|
||||
await syncPetAppointmentReminders({
|
||||
householdId: scope.householdId,
|
||||
appointmentId: row.id,
|
||||
appointmentAt: row.appointmentAt,
|
||||
createdBy: scope.userId,
|
||||
petName: pet.name,
|
||||
title: row.title,
|
||||
offsets: parsed.reminderOffsets,
|
||||
});
|
||||
return row;
|
||||
}
|
||||
export async function updateAppointmentForScope(
|
||||
scope: Scope,
|
||||
input: { id: string } & z.input<typeof appointmentUpdateInput>,
|
||||
) {
|
||||
const parsed = idInput.and(appointmentUpdateInput).parse(input);
|
||||
const row = await requireAppointment(scope, parsed.id);
|
||||
const pet = await requirePet(scope, row.petId);
|
||||
const offsets = parsed.reminderOffsets ?? (await listReminderOffsets("pets.appointment", row.id));
|
||||
const { id, reminderOffsets: _, ...changes } = parsed;
|
||||
const [updated] = await db
|
||||
.update(petAppointments)
|
||||
.set({ ...changes, updatedAt: new Date() })
|
||||
.where(eq(petAppointments.id, id))
|
||||
.returning();
|
||||
if (!updated) throw new Error("Appointment not found");
|
||||
if (scope.userId)
|
||||
await syncPetAppointmentReminders({
|
||||
householdId: scope.householdId,
|
||||
appointmentId: id,
|
||||
appointmentAt: updated.appointmentAt,
|
||||
createdBy: scope.userId,
|
||||
petName: pet.name,
|
||||
title: updated.title,
|
||||
offsets,
|
||||
});
|
||||
return updated;
|
||||
}
|
||||
export async function deleteAppointmentForScope(scope: Scope, input: { id: string }) {
|
||||
const { id } = idInput.parse(input);
|
||||
await requireAppointment(scope, id);
|
||||
await cancelReminder("pets.appointment", id);
|
||||
await db.delete(petAppointments).where(eq(petAppointments.id, id));
|
||||
}
|
||||
|
||||
export async function createAppointment(input: z.input<typeof appointmentInput>) {
|
||||
const { household, user } = await getCurrentSession();
|
||||
const row = await createAppointmentForScope(
|
||||
{ householdId: household.id, userId: user.id },
|
||||
input,
|
||||
);
|
||||
revalidatePet(row.petId);
|
||||
return row;
|
||||
}
|
||||
export async function updateAppointment(
|
||||
input: { id: string } & z.input<typeof appointmentUpdateInput>,
|
||||
) {
|
||||
const { household, user } = await getCurrentSession();
|
||||
const row = await updateAppointmentForScope(
|
||||
{ householdId: household.id, userId: user.id },
|
||||
input,
|
||||
);
|
||||
revalidatePet(row.petId);
|
||||
return row;
|
||||
}
|
||||
export async function deleteAppointment(input: { id: string }) {
|
||||
const { household, user } = await getCurrentSession();
|
||||
const row = await requireAppointment({ householdId: household.id, userId: user.id }, input.id);
|
||||
await deleteAppointmentForScope({ householdId: household.id, userId: user.id }, input);
|
||||
revalidatePet(row.petId);
|
||||
}
|
||||
|
||||
export async function createVaccinationForScope(
|
||||
scope: Scope,
|
||||
input: z.input<typeof vaccinationInput>,
|
||||
) {
|
||||
const parsed = vaccinationInput.parse(input);
|
||||
const pet = await requirePet(scope, parsed.petId);
|
||||
const [row] = await db
|
||||
.insert(petVaccinations)
|
||||
.values({
|
||||
householdId: scope.householdId,
|
||||
...parsed,
|
||||
dueOn: parsed.dueOn ?? null,
|
||||
provider: parsed.provider ?? null,
|
||||
notes: parsed.notes ?? null,
|
||||
})
|
||||
.returning();
|
||||
if (!row) throw new Error("Vaccination was not created");
|
||||
if (scope.userId)
|
||||
await syncPetDueDateReminder({
|
||||
householdId: scope.householdId,
|
||||
entityType: "pets.vaccination",
|
||||
entityId: row.id,
|
||||
dueOn: row.dueOn,
|
||||
createdBy: scope.userId,
|
||||
title: `Vaccination due: ${pet.name}`,
|
||||
body: row.name,
|
||||
});
|
||||
return row;
|
||||
}
|
||||
export async function updateVaccinationForScope(
|
||||
scope: Scope,
|
||||
input: { id: string } & z.input<typeof vaccinationUpdateInput>,
|
||||
) {
|
||||
const parsed = idInput.and(vaccinationUpdateInput).parse(input);
|
||||
const row = await requireVaccination(scope, parsed.id);
|
||||
const pet = await requirePet(scope, row.petId);
|
||||
const { id, ...changes } = parsed;
|
||||
const [updated] = await db
|
||||
.update(petVaccinations)
|
||||
.set({ ...changes, updatedAt: new Date() })
|
||||
.where(eq(petVaccinations.id, id))
|
||||
.returning();
|
||||
if (!updated) throw new Error("Vaccination not found");
|
||||
if (scope.userId)
|
||||
await syncPetDueDateReminder({
|
||||
householdId: scope.householdId,
|
||||
entityType: "pets.vaccination",
|
||||
entityId: id,
|
||||
dueOn: updated.dueOn,
|
||||
createdBy: scope.userId,
|
||||
title: `Vaccination due: ${pet.name}`,
|
||||
body: updated.name,
|
||||
});
|
||||
return updated;
|
||||
}
|
||||
export async function deleteVaccinationForScope(scope: Scope, input: { id: string }) {
|
||||
const { id } = idInput.parse(input);
|
||||
await requireVaccination(scope, id);
|
||||
await cancelReminder("pets.vaccination", id);
|
||||
await db.delete(petVaccinations).where(eq(petVaccinations.id, id));
|
||||
}
|
||||
|
||||
export async function createVaccination(input: z.input<typeof vaccinationInput>) {
|
||||
const { household, user } = await getCurrentSession();
|
||||
const row = await createVaccinationForScope(
|
||||
{ householdId: household.id, userId: user.id },
|
||||
input,
|
||||
);
|
||||
revalidatePet(row.petId);
|
||||
return row;
|
||||
}
|
||||
export async function deleteVaccination(input: { id: string }) {
|
||||
const { household, user } = await getCurrentSession();
|
||||
const row = await requireVaccination({ householdId: household.id, userId: user.id }, input.id);
|
||||
await deleteVaccinationForScope({ householdId: household.id, userId: user.id }, input);
|
||||
revalidatePet(row.petId);
|
||||
}
|
||||
|
||||
export async function createPrescriptionForScope(
|
||||
scope: Scope,
|
||||
input: z.input<typeof prescriptionInput>,
|
||||
) {
|
||||
const parsed = prescriptionInput.parse(input);
|
||||
const pet = await requirePet(scope, parsed.petId);
|
||||
const [row] = await db
|
||||
.insert(petPrescriptions)
|
||||
.values({
|
||||
householdId: scope.householdId,
|
||||
...parsed,
|
||||
instructions: parsed.instructions ?? null,
|
||||
prescribedOn: parsed.prescribedOn ?? null,
|
||||
expiresOn: parsed.expiresOn ?? null,
|
||||
refillsRemaining: parsed.refillsRemaining ?? null,
|
||||
})
|
||||
.returning();
|
||||
if (!row) throw new Error("Prescription was not created");
|
||||
if (scope.userId)
|
||||
await syncPetDueDateReminder({
|
||||
householdId: scope.householdId,
|
||||
entityType: "pets.prescription",
|
||||
entityId: row.id,
|
||||
dueOn: row.active ? row.expiresOn : null,
|
||||
createdBy: scope.userId,
|
||||
title: `Prescription due: ${pet.name}`,
|
||||
body: row.medication,
|
||||
});
|
||||
return row;
|
||||
}
|
||||
export async function updatePrescriptionForScope(
|
||||
scope: Scope,
|
||||
input: { id: string } & z.input<typeof prescriptionUpdateInput>,
|
||||
) {
|
||||
const parsed = idInput.and(prescriptionUpdateInput).parse(input);
|
||||
const row = await requirePrescription(scope, parsed.id);
|
||||
const pet = await requirePet(scope, row.petId);
|
||||
const { id, ...changes } = parsed;
|
||||
const [updated] = await db
|
||||
.update(petPrescriptions)
|
||||
.set({ ...changes, updatedAt: new Date() })
|
||||
.where(eq(petPrescriptions.id, id))
|
||||
.returning();
|
||||
if (!updated) throw new Error("Prescription not found");
|
||||
if (scope.userId)
|
||||
await syncPetDueDateReminder({
|
||||
householdId: scope.householdId,
|
||||
entityType: "pets.prescription",
|
||||
entityId: id,
|
||||
dueOn: updated.active ? updated.expiresOn : null,
|
||||
createdBy: scope.userId,
|
||||
title: `Prescription due: ${pet.name}`,
|
||||
body: updated.medication,
|
||||
});
|
||||
return updated;
|
||||
}
|
||||
export async function deletePrescriptionForScope(scope: Scope, input: { id: string }) {
|
||||
const { id } = idInput.parse(input);
|
||||
await requirePrescription(scope, id);
|
||||
await cancelReminder("pets.prescription", id);
|
||||
await db.delete(petPrescriptions).where(eq(petPrescriptions.id, id));
|
||||
}
|
||||
|
||||
export async function createPrescription(input: z.input<typeof prescriptionInput>) {
|
||||
const { household, user } = await getCurrentSession();
|
||||
const row = await createPrescriptionForScope(
|
||||
{ householdId: household.id, userId: user.id },
|
||||
input,
|
||||
);
|
||||
revalidatePet(row.petId);
|
||||
return row;
|
||||
}
|
||||
export async function deletePrescription(input: { id: string }) {
|
||||
const { household, user } = await getCurrentSession();
|
||||
const row = await requirePrescription({ householdId: household.id, userId: user.id }, input.id);
|
||||
await deletePrescriptionForScope({ householdId: household.id, userId: user.id }, input);
|
||||
revalidatePet(row.petId);
|
||||
}
|
||||
@@ -0,0 +1,210 @@
|
||||
import { and, asc, desc, eq, or, sql } from "drizzle-orm";
|
||||
import { db } from "@/lib/db";
|
||||
import { getCurrentSession } from "@/lib/session";
|
||||
import { petAppointments, petPrescriptions, pets, petVaccinations } from "../schema";
|
||||
|
||||
export type PetListItemDto = {
|
||||
id: string;
|
||||
name: string;
|
||||
species: string;
|
||||
breed: string | null;
|
||||
primaryImageUrl: string | null;
|
||||
};
|
||||
|
||||
export type PetAppointmentDto = {
|
||||
id: string;
|
||||
petId: string;
|
||||
title: string;
|
||||
appointmentAt: string;
|
||||
clinic: string | null;
|
||||
notes: string | null;
|
||||
calendarEventId: string | null;
|
||||
};
|
||||
|
||||
export type PetVaccinationDto = {
|
||||
id: string;
|
||||
petId: string;
|
||||
name: string;
|
||||
administeredOn: string;
|
||||
dueOn: string | null;
|
||||
provider: string | null;
|
||||
notes: string | null;
|
||||
};
|
||||
|
||||
export type PetPrescriptionDto = {
|
||||
id: string;
|
||||
petId: string;
|
||||
medication: string;
|
||||
dosage: string;
|
||||
instructions: string | null;
|
||||
prescribedOn: string | null;
|
||||
expiresOn: string | null;
|
||||
refillsRemaining: number | null;
|
||||
active: boolean;
|
||||
};
|
||||
|
||||
export type PetDetailDto = PetListItemDto & {
|
||||
householdId: string;
|
||||
birthDate: string | null;
|
||||
notes: string | null;
|
||||
images: string[];
|
||||
appointments: PetAppointmentDto[];
|
||||
vaccinations: PetVaccinationDto[];
|
||||
prescriptions: PetPrescriptionDto[];
|
||||
};
|
||||
|
||||
const toAppointment = (row: typeof petAppointments.$inferSelect): PetAppointmentDto => ({
|
||||
id: row.id,
|
||||
petId: row.petId,
|
||||
title: row.title,
|
||||
appointmentAt: row.appointmentAt.toISOString(),
|
||||
clinic: row.clinic,
|
||||
notes: row.notes,
|
||||
calendarEventId: row.calendarEventId,
|
||||
});
|
||||
const toVaccination = (row: typeof petVaccinations.$inferSelect): PetVaccinationDto => ({
|
||||
id: row.id,
|
||||
petId: row.petId,
|
||||
name: row.name,
|
||||
administeredOn: row.administeredOn,
|
||||
dueOn: row.dueOn,
|
||||
provider: row.provider,
|
||||
notes: row.notes,
|
||||
});
|
||||
const toPrescription = (row: typeof petPrescriptions.$inferSelect): PetPrescriptionDto => ({
|
||||
id: row.id,
|
||||
petId: row.petId,
|
||||
medication: row.medication,
|
||||
dosage: row.dosage,
|
||||
instructions: row.instructions,
|
||||
prescribedOn: row.prescribedOn,
|
||||
expiresOn: row.expiresOn,
|
||||
refillsRemaining: row.refillsRemaining,
|
||||
active: row.active,
|
||||
});
|
||||
|
||||
export async function listPetsForScope(householdId: string): Promise<PetListItemDto[]> {
|
||||
const rows = await db
|
||||
.select()
|
||||
.from(pets)
|
||||
.where(eq(pets.householdId, householdId))
|
||||
.orderBy(asc(pets.name));
|
||||
return rows.map((row) => ({
|
||||
id: row.id,
|
||||
name: row.name,
|
||||
species: row.species,
|
||||
breed: row.breed,
|
||||
primaryImageUrl: row.primaryImageUrl,
|
||||
}));
|
||||
}
|
||||
|
||||
export async function listPets() {
|
||||
const { household } = await getCurrentSession();
|
||||
return listPetsForScope(household.id);
|
||||
}
|
||||
|
||||
export async function getPetForScope(
|
||||
householdId: string,
|
||||
id: string,
|
||||
): Promise<PetDetailDto | null> {
|
||||
const [pet] = await db
|
||||
.select()
|
||||
.from(pets)
|
||||
.where(and(eq(pets.id, id), eq(pets.householdId, householdId)))
|
||||
.limit(1);
|
||||
if (!pet) return null;
|
||||
const [appointments, vaccinations, prescriptions] = await Promise.all([
|
||||
db
|
||||
.select()
|
||||
.from(petAppointments)
|
||||
.where(and(eq(petAppointments.petId, id), eq(petAppointments.householdId, householdId)))
|
||||
.orderBy(desc(petAppointments.appointmentAt)),
|
||||
db
|
||||
.select()
|
||||
.from(petVaccinations)
|
||||
.where(and(eq(petVaccinations.petId, id), eq(petVaccinations.householdId, householdId)))
|
||||
.orderBy(desc(petVaccinations.administeredOn)),
|
||||
db
|
||||
.select()
|
||||
.from(petPrescriptions)
|
||||
.where(and(eq(petPrescriptions.petId, id), eq(petPrescriptions.householdId, householdId)))
|
||||
.orderBy(desc(petPrescriptions.createdAt)),
|
||||
]);
|
||||
return {
|
||||
id: pet.id,
|
||||
householdId: pet.householdId,
|
||||
name: pet.name,
|
||||
species: pet.species,
|
||||
breed: pet.breed,
|
||||
birthDate: pet.birthDate,
|
||||
notes: pet.notes,
|
||||
primaryImageUrl: pet.primaryImageUrl,
|
||||
images: pet.images,
|
||||
appointments: appointments.map(toAppointment),
|
||||
vaccinations: vaccinations.map(toVaccination),
|
||||
prescriptions: prescriptions.map(toPrescription),
|
||||
};
|
||||
}
|
||||
|
||||
export async function getPet(id: string) {
|
||||
const { household } = await getCurrentSession();
|
||||
return getPetForScope(household.id, id);
|
||||
}
|
||||
|
||||
export async function searchPets(query: string, householdId: string) {
|
||||
const term = `%${query}%`;
|
||||
const rows = await db
|
||||
.select({ id: pets.id, name: pets.name, species: pets.species, breed: pets.breed })
|
||||
.from(pets)
|
||||
.where(
|
||||
and(
|
||||
eq(pets.householdId, householdId),
|
||||
or(
|
||||
sql`${pets.name} ilike ${term}`,
|
||||
sql`${pets.species} ilike ${term}`,
|
||||
sql`coalesce(${pets.breed}, '') ilike ${term}`,
|
||||
),
|
||||
),
|
||||
)
|
||||
.limit(10);
|
||||
return rows.map((row) => ({
|
||||
id: row.id,
|
||||
title: row.name,
|
||||
excerpt: [row.species, row.breed].filter(Boolean).join(" · "),
|
||||
url: `/pets/${row.id}`,
|
||||
}));
|
||||
}
|
||||
|
||||
export async function getPetsOverviewStats(householdId: string) {
|
||||
const [petCount] = await db
|
||||
.select({ count: sql<number>`count(*)::int` })
|
||||
.from(pets)
|
||||
.where(eq(pets.householdId, householdId));
|
||||
const [vaccinations, prescriptions] = await Promise.all([
|
||||
db
|
||||
.select({ count: sql<number>`count(*)::int` })
|
||||
.from(petVaccinations)
|
||||
.where(
|
||||
and(
|
||||
eq(petVaccinations.householdId, householdId),
|
||||
sql`${petVaccinations.dueOn} <= current_date + interval '30 days'`,
|
||||
),
|
||||
),
|
||||
db
|
||||
.select({ count: sql<number>`count(*)::int` })
|
||||
.from(petPrescriptions)
|
||||
.where(
|
||||
and(
|
||||
eq(petPrescriptions.householdId, householdId),
|
||||
eq(petPrescriptions.active, true),
|
||||
sql`${petPrescriptions.expiresOn} <= current_date + interval '30 days'`,
|
||||
),
|
||||
),
|
||||
]);
|
||||
return {
|
||||
petCount: Number(petCount?.count ?? 0),
|
||||
dueSoonCount: Number(vaccinations[0]?.count ?? 0) + Number(prescriptions[0]?.count ?? 0),
|
||||
};
|
||||
}
|
||||
|
||||
export { toAppointment, toPrescription, toVaccination };
|
||||
@@ -0,0 +1,54 @@
|
||||
import { fireAtForEventStart, normalizeReminderOffsets } from "@/lib/reminder-offsets";
|
||||
import { householdDateAt } from "@/lib/household-timezone";
|
||||
import {
|
||||
cancelReminder,
|
||||
scheduleReminder,
|
||||
syncRemindersForEntity,
|
||||
} from "@/modules/_core/reminders";
|
||||
|
||||
export async function syncPetAppointmentReminders(input: {
|
||||
householdId: string;
|
||||
appointmentId: string;
|
||||
appointmentAt: Date;
|
||||
createdBy: string;
|
||||
petName: string;
|
||||
title: string;
|
||||
offsets: number[];
|
||||
}) {
|
||||
await syncRemindersForEntity({
|
||||
householdId: input.householdId,
|
||||
entityType: "pets.appointment",
|
||||
entityId: input.appointmentId,
|
||||
createdBy: input.createdBy,
|
||||
reminders: normalizeReminderOffsets(input.offsets).map((offsetMinutes) => ({
|
||||
fireAt: fireAtForEventStart(input.appointmentAt, offsetMinutes),
|
||||
offsetMinutes,
|
||||
title: `Vet visit: ${input.petName}`,
|
||||
body: input.title,
|
||||
})),
|
||||
});
|
||||
}
|
||||
|
||||
export async function syncPetDueDateReminder(input: {
|
||||
householdId: string;
|
||||
entityType: "pets.vaccination" | "pets.prescription";
|
||||
entityId: string;
|
||||
dueOn: string | null;
|
||||
createdBy: string;
|
||||
title: string;
|
||||
body: string;
|
||||
}) {
|
||||
if (!input.dueOn) {
|
||||
await cancelReminder(input.entityType, input.entityId);
|
||||
return;
|
||||
}
|
||||
await scheduleReminder({
|
||||
householdId: input.householdId,
|
||||
entityType: input.entityType,
|
||||
entityId: input.entityId,
|
||||
fireAt: householdDateAt(input.dueOn, 9),
|
||||
createdBy: input.createdBy,
|
||||
title: input.title,
|
||||
body: input.body,
|
||||
});
|
||||
}
|
||||
@@ -0,0 +1,56 @@
|
||||
import { z } from "zod";
|
||||
|
||||
const isoDate = z.string().regex(/^\d{4}-\d{2}-\d{2}$/);
|
||||
const optionalText = (max: number) => z.string().trim().max(max).nullable().optional();
|
||||
|
||||
export const petInput = z.object({
|
||||
name: z.string().trim().min(1).max(120),
|
||||
species: z.string().trim().min(1).max(80),
|
||||
breed: optionalText(120),
|
||||
birthDate: isoDate.nullable().optional(),
|
||||
notes: optionalText(4000),
|
||||
images: z.array(z.string().min(1)).max(10).default([]),
|
||||
primaryImageUrl: z.string().min(1).nullable().optional(),
|
||||
});
|
||||
|
||||
export const petUpdateInput = petInput.partial();
|
||||
|
||||
export const appointmentInput = z.object({
|
||||
petId: z.string().uuid(),
|
||||
title: z.string().trim().min(1).max(160),
|
||||
appointmentAt: z.coerce.date(),
|
||||
clinic: optionalText(160),
|
||||
notes: optionalText(4000),
|
||||
reminderOffsets: z.array(z.number().int().min(0).max(43_200)).default([30]),
|
||||
});
|
||||
|
||||
export const appointmentUpdateInput = appointmentInput.omit({ petId: true }).partial();
|
||||
|
||||
export const vaccinationInput = z.object({
|
||||
petId: z.string().uuid(),
|
||||
name: z.string().trim().min(1).max(160),
|
||||
administeredOn: isoDate,
|
||||
dueOn: isoDate.nullable().optional(),
|
||||
provider: optionalText(160),
|
||||
notes: optionalText(4000),
|
||||
});
|
||||
|
||||
export const vaccinationUpdateInput = vaccinationInput.omit({ petId: true }).partial();
|
||||
|
||||
export const prescriptionInput = z.object({
|
||||
petId: z.string().uuid(),
|
||||
medication: z.string().trim().min(1).max(160),
|
||||
dosage: z.string().trim().min(1).max(160),
|
||||
instructions: optionalText(2000),
|
||||
prescribedOn: isoDate.nullable().optional(),
|
||||
expiresOn: isoDate.nullable().optional(),
|
||||
refillsRemaining: z.number().int().min(0).max(99).nullable().optional(),
|
||||
active: z.boolean().default(true),
|
||||
});
|
||||
|
||||
export const prescriptionUpdateInput = prescriptionInput.omit({ petId: true }).partial();
|
||||
|
||||
export const scheduleAppointmentInput = z.object({
|
||||
appointmentId: z.string().uuid(),
|
||||
calendarId: z.string().uuid(),
|
||||
});
|
||||
@@ -0,0 +1,16 @@
|
||||
import assert from "node:assert/strict";
|
||||
import test from "node:test";
|
||||
import { householdDateAt } from "../../src/lib/household-timezone";
|
||||
|
||||
test("householdDateAt preserves 9 AM across Chicago daylight saving time", () => {
|
||||
const formatter = new Intl.DateTimeFormat("en-CA", {
|
||||
timeZone: "America/Chicago",
|
||||
hour: "2-digit",
|
||||
minute: "2-digit",
|
||||
hourCycle: "h23",
|
||||
});
|
||||
|
||||
for (const date of ["2026-01-15", "2026-07-15"]) {
|
||||
assert.equal(formatter.format(householdDateAt(date, 9, "America/Chicago")), "09:00");
|
||||
}
|
||||
});
|
||||
@@ -0,0 +1,8 @@
|
||||
import assert from "node:assert/strict";
|
||||
import test from "node:test";
|
||||
import petsManifest from "../../src/modules/pets/manifest";
|
||||
|
||||
test("pets manifest contributes visible navigation and a quick add action", () => {
|
||||
assert.deepEqual(petsManifest.nav, { href: "/pets", label: "Pets", icon: "paw-print" });
|
||||
assert.equal(petsManifest.quickAdds?.[0]?.createKey, "pets.pet");
|
||||
});
|
||||
@@ -0,0 +1,59 @@
|
||||
import assert from "node:assert/strict";
|
||||
import test from "node:test";
|
||||
import {
|
||||
appointmentInput,
|
||||
petInput,
|
||||
prescriptionInput,
|
||||
scheduleAppointmentInput,
|
||||
vaccinationInput,
|
||||
} from "../../src/modules/pets/server/schemas";
|
||||
|
||||
const PET_ID = "f5a50e32-a217-4d65-ae10-98a1f441d171";
|
||||
const CALENDAR_ID = "bd8e10c2-58f4-4db8-9326-0b50fdda47bb";
|
||||
|
||||
test("pet and medical record schemas accept bounded valid input", () => {
|
||||
assert.equal(petInput.parse({ name: "Mochi", species: "cat", images: [] }).name, "Mochi");
|
||||
assert.equal(
|
||||
appointmentInput.parse({
|
||||
petId: PET_ID,
|
||||
title: "Annual exam",
|
||||
appointmentAt: "2026-08-01T15:00:00.000Z",
|
||||
}).title,
|
||||
"Annual exam",
|
||||
);
|
||||
assert.equal(
|
||||
vaccinationInput.parse({ petId: PET_ID, name: "Rabies", administeredOn: "2026-07-01" }).name,
|
||||
"Rabies",
|
||||
);
|
||||
assert.equal(
|
||||
prescriptionInput.parse({ petId: PET_ID, medication: "Apoquel", dosage: "5 mg daily" }).active,
|
||||
true,
|
||||
);
|
||||
assert.deepEqual(
|
||||
scheduleAppointmentInput.parse({ appointmentId: PET_ID, calendarId: CALENDAR_ID }),
|
||||
{
|
||||
appointmentId: PET_ID,
|
||||
calendarId: CALENDAR_ID,
|
||||
},
|
||||
);
|
||||
});
|
||||
|
||||
test("pet and medical record schemas reject invalid identifiers, dates, and galleries", () => {
|
||||
assert.throws(() => petInput.parse({ name: "", species: "cat" }));
|
||||
assert.throws(() =>
|
||||
petInput.parse({
|
||||
name: "Mochi",
|
||||
species: "cat",
|
||||
images: Array(11).fill("/api/uploads/pets/a.jpg"),
|
||||
}),
|
||||
);
|
||||
assert.throws(() =>
|
||||
appointmentInput.parse({ petId: "not-a-uuid", title: "Exam", appointmentAt: "not-a-date" }),
|
||||
);
|
||||
assert.throws(() =>
|
||||
vaccinationInput.parse({ petId: PET_ID, name: "Rabies", administeredOn: "07/01/2026" }),
|
||||
);
|
||||
assert.throws(() =>
|
||||
scheduleAppointmentInput.parse({ appointmentId: "bad", calendarId: "also-bad" }),
|
||||
);
|
||||
});
|
||||
Reference in New Issue
Block a user