Compare commits

...
Author SHA1 Message Date
ginnoir 39ea1ae5aa feat(pets): add profile and medical records 2026-07-10 03:05:55 -05:00
ginnoir 86444bc850 feat(pets): register module navigation 2026-07-10 02:57:45 -05:00
ginnoir 7704924d88 feat(pets): add scoped records and reminders 2026-07-09 20:55:10 -05:00
ginnoir 7ffc2f9522 feat(pets): add pet record schema 2026-07-09 20:50:11 -05:00
ginnoir f3c6137fed docs: add pets module plan 2026-07-09 20:46:34 -05:00
ginnoir 7bf4a801b3 chore: release v0.6.5
CI / checks (push) Has been skipped
Release Image / build-and-push (push) Successful in 7m19s
2026-07-09 00:38:50 -05:00
ginnoir 3e8fe2d06d fix(agent): call api v1 via loopback instead of public url
CI / checks (push) Has been cancelled
Tool self-fetches were hairpinning to fam.ginnoir.com and failing,
so list_calendars/create_event returned 500 and the model gave up.
2026-07-09 00:38:33 -05:00
ginnoir 60eb101015 chore: release v0.6.4
CI / checks (push) Has been skipped
Release Image / build-and-push (push) Successful in 7m30s
2026-07-08 22:51:47 -05:00
ginnoir 72d123b9a0 fix(agent): stop tool thrash after writes and log rounds
CI / checks (push) Has been cancelled
Cap get_api_docs, break duplicate tool rounds, force a reply after
successful writes, and log each tool call so limit hits are diagnosable.
2026-07-08 22:51:31 -05:00
35 changed files with 4431 additions and 31 deletions
+2
View File
@@ -57,3 +57,5 @@ LLM_API_KEY=
LLM_MODEL=llama3.2
# IANA timezone for assistant relative dates ("Thursday at 2"). Falls back to TZ, then America/Chicago.
HOUSEHOLD_TIMEZONE=America/Chicago
# Optional override for agent tool → /api/v1 self-calls (defaults to http://127.0.0.1:$PORT).
# INTERNAL_API_BASE_URL=http://127.0.0.1:3000
+2
View File
@@ -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)
+12
View File
@@ -1,5 +1,17 @@
# Changelog
## [0.6.5](https://github.com/ginnoir/famapp/compare/v0.6.4...v0.6.5) (2026-07-09)
### Bug Fixes
- **agent:** call api v1 via loopback instead of public url ([3e8fe2d](https://github.com/ginnoir/famapp/commit/3e8fe2d06dc31d3a1058b4b8942c46b1220a6b4c))
## [0.6.4](https://github.com/ginnoir/famapp/compare/v0.6.3...v0.6.4) (2026-07-09)
### Bug Fixes
- **agent:** stop tool thrash after writes and log rounds ([72d123b](https://github.com/ginnoir/famapp/commit/72d123b9a0f67589d92614a8d2138912585b0d79))
## [0.6.3](https://github.com/ginnoir/famapp/compare/v0.6.2...v0.6.3) (2026-07-09)
### Bug Fixes
+2
View File
@@ -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
+70
View File
@@ -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
+7
View File
@@ -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
}
]
}
+1 -1
View File
@@ -1,6 +1,6 @@
{
"name": "famapp",
"version": "0.6.3",
"version": "0.6.5",
"private": true,
"type": "module",
"packageManager": "pnpm@10.33.3",
+17
View File
@@ -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>
);
}
+33
View File
@@ -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>
);
}
+12
View File
@@ -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>
);
}
+34
View File
@@ -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>
);
}
+2
View File
@@ -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,
+39
View File
@@ -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 @@ export type AssistantChatMessage = {
role: "user" | "assistant";
content: string;
imageUrl?: string;
toolCalls?: Array<{ name: string; status: number }>;
};
const STORAGE_VERSION = "v2";
@@ -19,6 +20,14 @@ function isValidMessage(value: unknown): value is AssistantChatMessage {
if (row.role !== "user" && row.role !== "assistant") return false;
if (typeof row.content !== "string" || row.content.trim().length === 0) return false;
if (row.imageUrl !== undefined && typeof row.imageUrl !== "string") return false;
if (row.toolCalls !== undefined) {
if (!Array.isArray(row.toolCalls)) return false;
for (const call of row.toolCalls) {
if (!call || typeof call !== "object") return false;
const entry = call as Record<string, unknown>;
if (typeof entry.name !== "string" || typeof entry.status !== "number") return false;
}
}
return true;
}
@@ -229,7 +229,11 @@ export function AssistantPanel({ configured, userId, assistantName, assistantMod
setMessages((current) => [
...current,
{ role: "assistant", content: result.message.content },
{
role: "assistant",
content: result.message.content,
...(result.toolCalls.length > 0 ? { toolCalls: result.toolCalls } : {}),
},
]);
scrollToBottom();
} catch (err) {
@@ -347,6 +351,13 @@ export function AssistantPanel({ configured, userId, assistantName, assistantMod
/>
) : null}
{message.content}
{message.role === "assistant" &&
message.toolCalls &&
message.toolCalls.length > 0 ? (
<p className="mt-1 text-[10px] text-muted-foreground">
{message.toolCalls.map((call) => `${call.name}${call.status}`).join(" · ")}
</p>
) : null}
</div>
))}
+85
View File
@@ -0,0 +1,85 @@
const MUTATION_TOOLS = new Set([
"add_list_item",
"update_list_item",
"delete_list_item",
"create_list",
"update_list",
"delete_list",
"create_event",
"update_event",
"delete_event",
"create_calendar",
"create_note",
"update_note",
"delete_note",
"create_journal_entry",
"update_journal_entry",
"delete_journal_entry",
"create_garden_plant",
"update_garden_plant",
"delete_garden_plant",
"create_garden_container",
"update_garden_container",
"delete_garden_container",
"log_garden_care",
"create_garden_care_schedule",
"update_garden_care_schedule",
"delete_garden_care_schedule",
"schedule_garden_care_on_calendar",
"create_bang",
"update_bang",
"delete_bang",
"create_share_link",
"revoke_share_link",
]);
export function isMutationTool(name: string): boolean {
return MUTATION_TOOLS.has(name);
}
export function isSuccessfulWrite(name: string, status: number, argsJson = ""): boolean {
if (!isSuccessfulStatus(status)) return false;
if (isMutationTool(name)) return true;
if (name !== "call_api") return false;
try {
const args = JSON.parse(argsJson || "{}") as { method?: string };
const method = typeof args.method === "string" ? args.method.toUpperCase() : "";
return method === "POST" || method === "PATCH" || method === "DELETE";
} catch {
return false;
}
}
export function isSuccessfulStatus(status: number): boolean {
return status >= 200 && status < 300;
}
export function fingerprintToolCalls(calls: Array<{ name: string; arguments: string }>): string {
return calls.map((call) => `${call.name}:${normalizeArgs(call.arguments)}`).join("|");
}
export function truncateToolResult(result: string, maxChars = 6000): string {
if (result.length <= maxChars) return result;
return `${result.slice(0, maxChars)}\n…[truncated ${result.length - maxChars} chars]`;
}
export function summarizeToolTrace(toolCalls: Array<{ name: string; status: number }>): string {
if (toolCalls.length === 0) return "No tools were called.";
return toolCalls.map((call) => `${call.name}${call.status}`).join(", ");
}
function normalizeArgs(argsJson: string): string {
try {
const parsed: unknown = JSON.parse(argsJson || "{}");
if (!parsed || typeof parsed !== "object" || Array.isArray(parsed)) {
return JSON.stringify(parsed);
}
const sorted: Record<string, unknown> = {};
for (const key of Object.keys(parsed as Record<string, unknown>).sort()) {
sorted[key] = (parsed as Record<string, unknown>)[key];
}
return JSON.stringify(sorted);
} catch {
return argsJson.trim();
}
}
+128 -4
View File
@@ -1,9 +1,16 @@
import logger from "@/lib/logger";
import { createLlmClient, type ChatMessage, type LlmClient } from "@/lib/llm";
import { buildVisionContentParts, textFromMessageContent } from "@/lib/llm/content";
import { AGENT_SYSTEM_PROMPT, AGENT_TOOLS, appendAgentRuntimeContext } from "../tools";
import type { ClientChatMessage } from "../messages";
import { describeToolActivity } from "../tool-labels";
import { createApiToolExecutor, type ToolExecutor } from "../tool-executor";
import {
fingerprintToolCalls,
isSuccessfulWrite,
summarizeToolTrace,
truncateToolResult,
} from "./loop-guards";
import { resolveAssistantImageDataUrls } from "./resolve-images";
import { thinkingLabel, type AgentProgressEvent } from "./progress";
@@ -41,6 +48,21 @@ async function toLlmUserMessage(message: ClientChatMessage): Promise<ChatMessage
};
}
function forceReplyAfterWrite(writeNames: string[]): ChatMessage {
return {
role: "user",
content: `The write already succeeded (${writeNames.join(", ")}). Stop calling tools and reply to the user in one short sentence confirming what you did.`,
};
}
function forceReplyAfterRepeat(): ChatMessage {
return {
role: "user",
content:
"You repeated the same tool call. Stop calling tools and reply with what you already know, or ask one clarifying question.",
};
}
export async function runAgentChat(options: {
messages: ClientChatMessage[];
request: Request;
@@ -62,13 +84,16 @@ export async function runAgentChat(options: {
const transcript: ChatMessage[] = [{ role: "system", content: systemPrompt }, ...userMessages];
const toolCalls: AgentToolCallSummary[] = [];
const seenFingerprints = new Set<string>();
const successfulWriteNames: string[] = [];
let forceReply = false;
for (let round = 0; round < MAX_TOOL_ROUNDS; round += 1) {
onProgress?.({ type: "thinking", label: thinkingLabel(round), round });
const completion = await llm.chatCompletion({
messages: transcript,
tools: AGENT_TOOLS,
tools: forceReply ? undefined : AGENT_TOOLS,
});
const assistantMessage = completion.message;
@@ -76,6 +101,15 @@ export async function runAgentChat(options: {
if (!assistantMessage.tool_calls?.length) {
onProgress?.({ type: "responding", label: "Writing a reply…" });
logger.info(
{
msg: "agent.chat.done",
rounds: round + 1,
toolCalls: toolCalls.map((call) => `${call.name}:${call.status}`),
forcedReply: forceReply,
},
"agent chat completed",
);
return {
message: {
role: "assistant",
@@ -87,6 +121,36 @@ export async function runAgentChat(options: {
};
}
if (forceReply) {
logger.warn(
{
msg: "agent.chat.forced_tools_ignored",
round,
names: assistantMessage.tool_calls.map((c) => c.function.name),
},
"model kept calling tools after force-reply",
);
break;
}
const fingerprint = fingerprintToolCalls(
assistantMessage.tool_calls.map((call) => ({
name: call.function.name,
arguments: call.function.arguments,
})),
);
if (seenFingerprints.has(fingerprint)) {
logger.warn(
{ msg: "agent.chat.duplicate_tools", round, fingerprint, toolCalls: fingerprint },
"duplicate tool round detected",
);
transcript.push(forceReplyAfterRepeat());
forceReply = true;
continue;
}
seenFingerprints.add(fingerprint);
for (const toolCall of assistantMessage.tool_calls) {
const label = describeToolActivity(toolCall.function.name, toolCall.function.arguments);
onProgress?.({ type: "tool", name: toolCall.function.name, label });
@@ -96,8 +160,20 @@ export async function runAgentChat(options: {
try {
result = await executeTool(toolCall.function.name, toolCall.function.arguments);
const parsed = JSON.parse(result) as { status?: number };
const parsed = JSON.parse(result) as { status?: number; body?: unknown };
status = typeof parsed.status === "number" ? parsed.status : 200;
if (status >= 400) {
logger.warn(
{
msg: "agent.chat.tool_error",
round,
name: toolCall.function.name,
status,
body: parsed.body,
},
"agent tool returned error",
);
}
} catch (err) {
status = 500;
result = JSON.stringify({
@@ -107,21 +183,69 @@ export async function runAgentChat(options: {
}
toolCalls.push({ name: toolCall.function.name, status });
logger.info(
{
msg: "agent.chat.tool",
round,
name: toolCall.function.name,
status,
args: toolCall.function.arguments.slice(0, 300),
},
"agent tool call",
);
if (isSuccessfulWrite(toolCall.function.name, status, toolCall.function.arguments)) {
successfulWriteNames.push(toolCall.function.name);
}
transcript.push({
role: "tool",
tool_call_id: toolCall.id,
name: toolCall.function.name,
content: result,
content: truncateToolResult(result),
});
}
if (successfulWriteNames.length > 0) {
transcript.push(forceReplyAfterWrite(successfulWriteNames));
forceReply = true;
}
}
onProgress?.({ type: "responding", label: "Wrapping up…" });
const trace = summarizeToolTrace(toolCalls);
if (successfulWriteNames.length > 0) {
logger.warn(
{
msg: "agent.chat.forced_summary",
rounds: MAX_TOOL_ROUNDS,
toolCalls: toolCalls.map((call) => `${call.name}:${call.status}`),
},
"agent summarizing after write without clean stop",
);
return {
message: {
role: "assistant",
content: "I hit the tool-call limit for this request. Please try a simpler question.",
content: `Done. Completed: ${[...new Set(successfulWriteNames)].join(", ")}.`,
},
toolCalls,
};
}
logger.warn(
{
msg: "agent.chat.tool_limit",
rounds: MAX_TOOL_ROUNDS,
toolCalls: toolCalls.map((call) => `${call.name}:${call.status}`),
forcedReply: forceReply,
},
"agent hit tool-call limit",
);
return {
message: {
role: "assistant",
content: `I hit the tool-call limit for this request. Tools used: ${trace}.`,
},
toolCalls,
};
+54 -10
View File
@@ -1,3 +1,5 @@
import logger from "@/lib/logger";
type ApiCallResult = {
status: number;
body: unknown;
@@ -5,8 +7,22 @@ type ApiCallResult = {
export type ToolExecutor = (name: string, argsJson: string) => Promise<string>;
/** Loopback base for in-process tool → /api/v1 calls. Avoids hairpinning to the public URL. */
export function resolveInternalApiBase(request: Request): string {
const configured = process.env.INTERNAL_API_BASE_URL?.trim();
if (configured) return configured.replace(/\/$/, "");
const port = process.env.PORT?.trim() || "3000";
const requestUrl = new URL(request.url);
if (requestUrl.hostname === "localhost" || requestUrl.hostname === "127.0.0.1") {
return requestUrl.origin;
}
return `http://127.0.0.1:${port}`;
}
export function createApiToolExecutor(request: Request): ToolExecutor {
const origin = new URL(request.url).origin;
const origin = resolveInternalApiBase(request);
return async (name: string, argsJson: string) => {
const args = parseArgs(argsJson);
@@ -451,13 +467,18 @@ async function getApiDocs(args: Record<string, unknown>): Promise<ApiCallResult>
const specPath = path.join(process.cwd(), "docs", "api", "openapi.yaml");
const spec = await readFile(specPath, "utf8");
const search = typeof args.search === "string" ? args.search.trim().toLowerCase() : "";
const pathLines = spec
.split("\n")
.map((line) => line.trim())
.filter((line) => line.startsWith("/api/v1/"));
if (!search) {
return {
status: 200,
body: {
spec,
hint: "Pass search to filter paths, or use call_api with a /api/v1/* path.",
paths: pathLines.slice(0, 80),
pathCount: pathLines.length,
hint: "Pass search (e.g. calendar, events, lists) to get matching lines. Do not request the full OpenAPI dump.",
},
};
}
@@ -469,8 +490,8 @@ async function getApiDocs(args: Record<string, unknown>): Promise<ApiCallResult>
body: {
search,
matchCount: matches.length,
matches: matches.slice(0, 100),
hint: "Use call_api with method and path from the matches above.",
matches: matches.slice(0, 40),
hint: "Use a dedicated tool when one exists; otherwise call_api with method and path from the matches above.",
},
};
}
@@ -517,14 +538,30 @@ async function callApi(
path: string,
body?: Record<string, unknown>,
): Promise<ApiCallResult> {
const response = await fetch(`${origin}${path}`, {
method,
headers: {
const url = `${origin}${path}`;
const headers: Record<string, string> = {
"Content-Type": "application/json",
cookie: request.headers.get("cookie") ?? "",
},
};
const cookie = request.headers.get("cookie");
if (cookie) headers.cookie = cookie;
const authorization = request.headers.get("authorization");
if (authorization) headers.authorization = authorization;
let response: Response;
try {
response = await fetch(url, {
method,
headers,
body: body !== undefined ? JSON.stringify(body) : undefined,
});
} catch (err) {
const message = err instanceof Error ? err.message : "fetch failed";
logger.error(
{ msg: "agent.tool.fetch_failed", method, url, error: message },
"agent tool internal fetch failed",
);
return { status: 502, body: { error: `Internal API unreachable: ${message}`, url } };
}
const text = await response.text();
let parsed: unknown = null;
@@ -536,5 +573,12 @@ async function callApi(
}
}
if (response.status >= 400) {
logger.warn(
{ msg: "agent.tool.api_error", method, url, status: response.status, body: parsed },
"agent tool API error",
);
}
return { status: response.status, body: parsed };
}
+7 -5
View File
@@ -718,15 +718,16 @@ export const AGENT_TOOLS: AgentToolDefinition[] = [
function: {
name: "get_api_docs",
description:
"Read famapp REST API documentation (OpenAPI). Use when unsure which endpoint to call or no dedicated tool exists. Pass search to filter relevant paths.",
"Search famapp REST API docs for /api/v1 paths. Always pass search. Returns matching lines only — not the full OpenAPI file.",
parameters: {
type: "object",
properties: {
search: {
type: "string",
description: "Optional keyword to filter paths (e.g. garden, share, journal)",
description: "Keyword to filter paths (e.g. garden, share, journal, events)",
},
},
required: ["search"],
},
},
},
@@ -767,10 +768,11 @@ export const AGENT_SYSTEM_PROMPT = `You are the famapp household assistant. Help
Use the provided tools to read and update data. Prefer calling tools instead of guessing. Be concise and friendly.
Prefer a dedicated tool when one exists (create_event, add_list_item, create_note, etc.). When no dedicated tool fits, or you need an endpoint that is not wrapped yet:
1. Call get_api_docs with a relevant search term to find the right /api/v1/* endpoint.
Prefer a dedicated tool when one exists (create_event, add_list_item, create_note, etc.). After a successful write (2xx), stop calling tools and confirm in one short sentence do not re-list or re-create.
When no dedicated tool fits, or you need an endpoint that is not wrapped yet:
1. Call get_api_docs with a relevant search term (always pass search; never request the full spec).
2. Call call_api with the documented method, path, query, and body.
If a tool call fails, read the error body and fix the arguments before trying a different approach.
If a tool call fails, read the error body and fix the arguments before trying a different approach. Do not repeat the exact same tool call.
When the user sends a photo, read dates, times, locations, and action items from it, then use tools to act.
+2
View File
@@ -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>
);
}
+81
View File
@@ -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>
);
}
+49
View File
@@ -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;
+102
View File
@@ -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;
+381
View File
@@ -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);
}
+210
View File
@@ -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 };
+54
View File
@@ -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,
});
}
+56
View File
@@ -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(),
});
+152
View File
@@ -0,0 +1,152 @@
import assert from "node:assert/strict";
import { describe, it } from "node:test";
import {
fingerprintToolCalls,
isSuccessfulWrite,
summarizeToolTrace,
truncateToolResult,
} from "../../src/modules/agent/server/loop-guards";
import { runAgentChat } from "../../src/modules/agent/server/run";
import type {
ChatCompletionRequest,
ChatCompletionResult,
LlmClient,
} from "../../src/lib/llm/types";
describe("loop-guards", () => {
it("fingerprints tool calls stably regardless of key order", () => {
const a = fingerprintToolCalls([
{ name: "create_event", arguments: '{"title":"Dentist","calendarName":"Family"}' },
]);
const b = fingerprintToolCalls([
{ name: "create_event", arguments: '{"calendarName":"Family","title":"Dentist"}' },
]);
assert.equal(a, b);
});
it("treats create_event 201 as a successful write", () => {
assert.equal(isSuccessfulWrite("create_event", 201), true);
assert.equal(isSuccessfulWrite("list_calendars", 200), false);
assert.equal(
isSuccessfulWrite("call_api", 201, '{"method":"POST","path":"/api/v1/events"}'),
true,
);
assert.equal(
isSuccessfulWrite("call_api", 200, '{"method":"GET","path":"/api/v1/events"}'),
false,
);
});
it("truncates oversized tool results", () => {
const result = truncateToolResult("x".repeat(7000), 100);
assert.ok(result.length < 200);
assert.match(result, /truncated/);
});
it("summarizes tool traces", () => {
assert.equal(
summarizeToolTrace([
{ name: "list_calendars", status: 200 },
{ name: "create_event", status: 201 },
]),
"list_calendars→200, create_event→201",
);
});
});
describe("runAgentChat loop guards", () => {
it("stops after a successful write instead of looping", async () => {
let calls = 0;
const llm: LlmClient = {
async chatCompletion(request: ChatCompletionRequest): Promise<ChatCompletionResult> {
calls += 1;
if (calls === 1) {
return {
message: {
role: "assistant",
content: null,
tool_calls: [
{
id: "1",
type: "function",
function: {
name: "create_event",
arguments: JSON.stringify({
title: "Dentist",
startAt: "2026-07-10T15:00:00.000Z",
endAt: "2026-07-10T16:00:00.000Z",
}),
},
},
],
},
finishReason: "tool_calls",
};
}
assert.equal(request.tools, undefined);
return {
message: { role: "assistant", content: "Added Dentist to your calendar." },
finishReason: "stop",
};
},
};
const result = await runAgentChat({
messages: [{ role: "user", content: "add dentist tomorrow at 10" }],
request: new Request("http://localhost:3000/api/agent/chat"),
llm,
executeTool: async () =>
JSON.stringify({ status: 201, body: { id: "evt-1", title: "Dentist" } }),
});
assert.equal(calls, 2);
assert.equal(result.toolCalls.length, 1);
assert.equal(result.toolCalls[0]?.name, "create_event");
assert.match(result.message.content, /Dentist/);
});
it("breaks duplicate identical tool rounds", async () => {
let calls = 0;
const llm: LlmClient = {
async chatCompletion(): Promise<ChatCompletionResult> {
calls += 1;
if (calls <= 2) {
return {
message: {
role: "assistant",
content: null,
tool_calls: [
{
id: String(calls),
type: "function",
function: {
name: "list_calendars",
arguments: "{}",
},
},
],
},
finishReason: "tool_calls",
};
}
return {
message: { role: "assistant", content: "You have one Family calendar." },
finishReason: "stop",
};
},
};
const result = await runAgentChat({
messages: [{ role: "user", content: "what calendars do I have?" }],
request: new Request("http://localhost:3000/api/agent/chat"),
llm,
executeTool: async () =>
JSON.stringify({ status: 200, body: [{ id: "cal-1", name: "Family" }] }),
});
assert.equal(calls, 3);
assert.equal(result.toolCalls.length, 1);
assert.match(result.message.content, /Family/);
});
});
+60 -6
View File
@@ -1,7 +1,10 @@
import assert from "node:assert/strict";
import { describe, it } from "node:test";
import { appendAgentRuntimeContext, resolveHouseholdTimezone } from "../../src/modules/agent/tools";
import { createApiToolExecutor } from "../../src/modules/agent/tool-executor";
import {
createApiToolExecutor,
resolveInternalApiBase,
} from "../../src/modules/agent/tool-executor";
describe("appendAgentRuntimeContext", () => {
it("appends current time and timezone to the prompt", () => {
@@ -38,6 +41,34 @@ describe("resolveHouseholdTimezone", () => {
});
});
describe("resolveInternalApiBase", () => {
it("uses loopback instead of the public request origin", () => {
const original = process.env.INTERNAL_API_BASE_URL;
const originalPort = process.env.PORT;
delete process.env.INTERNAL_API_BASE_URL;
process.env.PORT = "3000";
const base = resolveInternalApiBase(new Request("https://fam.ginnoir.com/api/agent/chat"));
assert.equal(base, "http://127.0.0.1:3000");
if (original === undefined) delete process.env.INTERNAL_API_BASE_URL;
else process.env.INTERNAL_API_BASE_URL = original;
if (originalPort === undefined) delete process.env.PORT;
else process.env.PORT = originalPort;
});
it("honors INTERNAL_API_BASE_URL when set", () => {
const original = process.env.INTERNAL_API_BASE_URL;
process.env.INTERNAL_API_BASE_URL = "http://127.0.0.1:3010/";
const base = resolveInternalApiBase(new Request("https://fam.ginnoir.com/api/agent/chat"));
assert.equal(base, "http://127.0.0.1:3010");
if (original === undefined) delete process.env.INTERNAL_API_BASE_URL;
else process.env.INTERNAL_API_BASE_URL = original;
});
});
describe("create_event calendar resolution", () => {
it("uses the first calendar when calendarId and calendarName are omitted", async () => {
const originalFetch = globalThis.fetch;
@@ -45,13 +76,13 @@ describe("create_event calendar resolution", () => {
globalThis.fetch = (async (input: RequestInfo | URL, init?: RequestInit) => {
const url = String(input);
if (url.endsWith("/api/v1/calendars") && (!init?.method || init.method === "GET")) {
if (url.includes("/api/v1/calendars") && (!init?.method || init.method === "GET")) {
return Response.json([
{ id: "cal-1", name: "Family" },
{ id: "cal-2", name: "Work" },
]);
}
if (url.endsWith("/api/v1/events") && init?.method === "POST") {
if (url.includes("/api/v1/events") && init?.method === "POST") {
const body = JSON.parse(String(init.body));
posts.push({ path: url, body });
return Response.json({ id: "evt-1", ...body }, { status: 201 });
@@ -59,7 +90,11 @@ describe("create_event calendar resolution", () => {
return new Response("not found", { status: 404 });
}) as typeof fetch;
const execute = createApiToolExecutor(new Request("http://localhost:3000/api/agent/chat"));
const execute = createApiToolExecutor(
new Request("https://fam.ginnoir.com/api/agent/chat", {
headers: { cookie: "authjs.session-token=test" },
}),
);
const result = JSON.parse(
await execute(
"create_event",
@@ -74,6 +109,7 @@ describe("create_event calendar resolution", () => {
assert.equal(result.status, 201);
assert.equal(result.body.calendarId, "cal-1");
assert.equal(posts.length, 1);
assert.match(posts[0]!.path, /^http:\/\/127\.0\.0\.1:3000\/api\/v1\/events/);
globalThis.fetch = originalFetch;
});
@@ -83,13 +119,13 @@ describe("create_event calendar resolution", () => {
globalThis.fetch = (async (input: RequestInfo | URL, init?: RequestInit) => {
const url = String(input);
if (url.endsWith("/api/v1/calendars") && (!init?.method || init.method === "GET")) {
if (url.includes("/api/v1/calendars") && (!init?.method || init.method === "GET")) {
return Response.json([
{ id: "cal-1", name: "Family" },
{ id: "cal-2", name: "Work" },
]);
}
if (url.endsWith("/api/v1/events") && init?.method === "POST") {
if (url.includes("/api/v1/events") && init?.method === "POST") {
const body = JSON.parse(String(init.body));
return Response.json({ id: "evt-1", ...body }, { status: 201 });
}
@@ -114,4 +150,22 @@ describe("create_event calendar resolution", () => {
globalThis.fetch = originalFetch;
});
it("returns a clear error when the internal API is unreachable", async () => {
const originalFetch = globalThis.fetch;
globalThis.fetch = (async () => {
throw new TypeError("fetch failed");
}) as typeof fetch;
const execute = createApiToolExecutor(new Request("https://fam.ginnoir.com/api/agent/chat"));
const result = JSON.parse(await execute("list_calendars", "{}")) as {
status: number;
body: { error?: string };
};
assert.equal(result.status, 502);
assert.match(String(result.body.error), /unreachable/i);
globalThis.fetch = originalFetch;
});
});
+16
View File
@@ -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");
}
});
+8
View File
@@ -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");
});
+59
View File
@@ -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" }),
);
});