diff --git a/app/(app)/companies/[id]/deals/page.tsx b/app/(app)/companies/[id]/deals/page.tsx index a75cb15..0cc387d 100644 --- a/app/(app)/companies/[id]/deals/page.tsx +++ b/app/(app)/companies/[id]/deals/page.tsx @@ -3,6 +3,7 @@ import { db } from "@/db/client"; import { deals, stages } from "@/db/schema/deals"; import { StagePill } from "@/components/pills"; import { money, relativeTime } from "@/lib/format"; +import { DeleteDealButton } from "@/app/(app)/deals/delete-deal-button"; export default async function DealsTab({ params }: { params: Promise<{ id: string }> }) { const { id } = await params; @@ -41,13 +42,14 @@ export default async function DealsTab({ params }: { params: Promise<{ id: strin {h} ))} + {rows.map((d) => ( {d.name} @@ -62,6 +64,9 @@ export default async function DealsTab({ params }: { params: Promise<{ id: strin {relativeTime(d.expectedCloseDate)} + + + ))} diff --git a/app/(app)/companies/[id]/layout.tsx b/app/(app)/companies/[id]/layout.tsx index 99cc490..a652d6b 100644 --- a/app/(app)/companies/[id]/layout.tsx +++ b/app/(app)/companies/[id]/layout.tsx @@ -6,6 +6,7 @@ import { TemperaturePill } from "@/components/pills"; import { CompanyTabs } from "./tabs"; import { getCompanyById } from "@/lib/data"; import { requireOrgSession } from "@/lib/session"; +import { DeleteCompanyButton } from "../delete-company-button"; export default async function CompanyDetailLayout({ children, @@ -64,6 +65,7 @@ export default async function CompanyDetailLayout({ + diff --git a/app/(app)/companies/[id]/notes/actions.ts b/app/(app)/companies/[id]/notes/actions.ts index 49d027e..abeb823 100644 --- a/app/(app)/companies/[id]/notes/actions.ts +++ b/app/(app)/companies/[id]/notes/actions.ts @@ -5,6 +5,7 @@ import { z } from "zod"; import { db } from "@/db/client"; import { notes } from "@/db/schema/notes"; import { recordAudit, userActor } from "@/lib/audit"; +import { deleteNote } from "@/lib/notes"; import { requireOrgSession } from "@/lib/session"; const Schema = z.object({ @@ -39,3 +40,28 @@ export async function addCompanyNoteAction(formData: FormData): Promise { revalidatePath(`/companies/${companyId}/notes`); revalidatePath(`/companies/${companyId}`); } + +export async function deleteNoteAction(input: { + noteId: string; +}): Promise<{ ok: true } | { ok: false; message: string }> { + const session = await requireOrgSession(); + const noteId = z.string().uuid().parse(input.noteId); + + const result = await deleteNote(db(), session.organizationId, noteId); + if (!result) return { ok: false, message: "Note not found" }; + + await recordAudit(db(), { + organizationId: session.organizationId, + actor: userActor(session.user.id, session.user.name ?? null), + entityType: "note", + entityId: noteId, + action: "delete", + changes: { before: result.before }, + }); + + if (result.before.companyId) { + revalidatePath(`/companies/${result.before.companyId}/notes`); + revalidatePath(`/companies/${result.before.companyId}`); + } + return { ok: true }; +} diff --git a/app/(app)/companies/[id]/notes/delete-note-button.tsx b/app/(app)/companies/[id]/notes/delete-note-button.tsx new file mode 100644 index 0000000..c6be299 --- /dev/null +++ b/app/(app)/companies/[id]/notes/delete-note-button.tsx @@ -0,0 +1,30 @@ +"use client"; + +import { Trash2 } from "lucide-react"; +import { useState } from "react"; +import { DeleteConfirmDialog } from "@/components/delete-confirm-dialog"; +import { deleteNoteAction } from "./actions"; + +export function DeleteNoteButton({ noteId }: { noteId: string }) { + const [open, setOpen] = useState(false); + + return ( + <> + + deleteNoteAction({ noteId })} + /> + + ); +} diff --git a/app/(app)/companies/[id]/notes/page.tsx b/app/(app)/companies/[id]/notes/page.tsx index e36f4a8..0a74f22 100644 --- a/app/(app)/companies/[id]/notes/page.tsx +++ b/app/(app)/companies/[id]/notes/page.tsx @@ -3,6 +3,7 @@ import { db } from "@/db/client"; import { notes } from "@/db/schema/notes"; import { Avatar } from "@/components/avatar-init"; import { relativeTime } from "@/lib/format"; +import { DeleteNoteButton } from "./delete-note-button"; import { NoteComposer } from "./note-composer"; export default async function NotesTab({ params }: { params: Promise<{ id: string }> }) { @@ -23,12 +24,15 @@ export default async function NotesTab({ params }: { params: Promise<{ id: strin {rows.map((n) => (
  • {n.author} {relativeTime(n.createdAt)} + + +

    {n.body} diff --git a/app/(app)/companies/[id]/people/page.tsx b/app/(app)/companies/[id]/people/page.tsx index 7b21591..cf4ea4a 100644 --- a/app/(app)/companies/[id]/people/page.tsx +++ b/app/(app)/companies/[id]/people/page.tsx @@ -5,6 +5,7 @@ import { people } from "@/db/schema/companies"; import { AvatarSquare } from "@/components/avatar-init"; import { EngagementPill, PersonaPill } from "@/components/pills"; import { relativeTime } from "@/lib/format"; +import { DeletePersonButton } from "@/app/(app)/people/delete-person-button"; export default async function PeopleTab({ params }: { params: Promise<{ id: string }> }) { const { id } = await params; @@ -37,7 +38,7 @@ export default async function PeopleTab({ params }: { params: Promise<{ id: stri {rows.map((p) => ( - {p.linkedinUrl ? ( - - - - - - ) : null} +

    + {p.linkedinUrl ? ( + + + + + + ) : null} + +
    ))} diff --git a/app/(app)/companies/[id]/signals/actions.ts b/app/(app)/companies/[id]/signals/actions.ts new file mode 100644 index 0000000..bb473a5 --- /dev/null +++ b/app/(app)/companies/[id]/signals/actions.ts @@ -0,0 +1,32 @@ +"use server"; + +import { revalidatePath } from "next/cache"; +import { z } from "zod"; +import { db } from "@/db/client"; +import { recordAudit, userActor } from "@/lib/audit"; +import { requireOrgSession } from "@/lib/session"; +import { deleteSignal } from "@/lib/signals"; + +export async function deleteSignalAction(input: { + signalId: string; +}): Promise<{ ok: true } | { ok: false; message: string }> { + const session = await requireOrgSession(); + const signalId = z.string().uuid().parse(input.signalId); + + const result = await deleteSignal(db(), session.organizationId, signalId); + if (!result) return { ok: false, message: "Signal not found" }; + + await recordAudit(db(), { + organizationId: session.organizationId, + actor: userActor(session.user.id, session.user.name ?? null), + entityType: "signal", + entityId: signalId, + action: "delete", + changes: { before: result.before }, + }); + + revalidatePath(`/companies/${result.before.companyId}/signals`); + revalidatePath(`/companies/${result.before.companyId}`); + revalidatePath("/companies"); + return { ok: true }; +} diff --git a/app/(app)/companies/[id]/signals/delete-signal-button.tsx b/app/(app)/companies/[id]/signals/delete-signal-button.tsx new file mode 100644 index 0000000..42c2120 --- /dev/null +++ b/app/(app)/companies/[id]/signals/delete-signal-button.tsx @@ -0,0 +1,40 @@ +"use client"; + +import { Trash2 } from "lucide-react"; +import { useState } from "react"; +import { DeleteConfirmDialog } from "@/components/delete-confirm-dialog"; +import { deleteSignalAction } from "./actions"; + +export function DeleteSignalButton({ + signalId, + signalTitle, +}: { + signalId: string; + signalTitle: string; +}) { + const [open, setOpen] = useState(false); + + return ( + <> + + + “{signalTitle}” will be permanently deleted. This cannot be undone. + + } + onConfirm={() => deleteSignalAction({ signalId })} + /> + + ); +} diff --git a/app/(app)/companies/[id]/signals/page.tsx b/app/(app)/companies/[id]/signals/page.tsx index b727c5b..2f99809 100644 --- a/app/(app)/companies/[id]/signals/page.tsx +++ b/app/(app)/companies/[id]/signals/page.tsx @@ -2,6 +2,7 @@ import { desc, eq } from "drizzle-orm"; import { db } from "@/db/client"; import { signals } from "@/db/schema/signals"; import { relativeTime } from "@/lib/format"; +import { DeleteSignalButton } from "./delete-signal-button"; export default async function SignalsTab({ params }: { params: Promise<{ id: string }> }) { const { id } = await params; @@ -22,7 +23,7 @@ export default async function SignalsTab({ params }: { params: Promise<{ id: str return (
      {rows.map((s) => ( -
    1. +

    2. {s.title}

      - - {relativeTime(s.occurredAt)} - +
      + + {relativeTime(s.occurredAt)} + + +
      {s.type.replace(/_/g, " ")} diff --git a/app/(app)/companies/actions.ts b/app/(app)/companies/actions.ts new file mode 100644 index 0000000..9a1ac3e --- /dev/null +++ b/app/(app)/companies/actions.ts @@ -0,0 +1,70 @@ +"use server"; + +import { revalidatePath } from "next/cache"; +import { z } from "zod"; +import { db } from "@/db/client"; +import { recordAudit, userActor, type EntityType } from "@/lib/audit"; +import { + deleteCompany, + previewCompanyDelete, + type CompanyCascadeCounts, +} from "@/lib/companies"; +import { requireOrgSession } from "@/lib/session"; + +export async function previewCompanyDeleteAction(input: { + companyId: string; +}): Promise<{ ok: true; data: CompanyCascadeCounts } | { ok: false; message: string }> { + const session = await requireOrgSession(); + const companyId = z.string().uuid().parse(input.companyId); + const data = await previewCompanyDelete(db(), session.organizationId, companyId); + if (!data) return { ok: false, message: "Company not found" }; + return { ok: true, data }; +} + +export async function deleteCompanyAction(input: { + companyId: string; +}): Promise<{ ok: true } | { ok: false; message: string }> { + const session = await requireOrgSession(); + const companyId = z.string().uuid().parse(input.companyId); + + const result = await deleteCompany(db(), session.organizationId, companyId); + if (!result) return { ok: false, message: "Company not found" }; + + const actor = userActor(session.user.id, session.user.name ?? null); + const beforeStub = { companyId }; + const fanouts: Array<{ entityType: EntityType; ids: string[] }> = [ + { entityType: "deal", ids: result.children.dealIds }, + { entityType: "signal", ids: result.children.signalIds }, + { entityType: "meeting", ids: result.children.meetingIds }, + { entityType: "note", ids: result.children.noteIds }, + { entityType: "task", ids: result.children.taskIds }, + ]; + for (const { entityType, ids } of fanouts) { + for (const id of ids) { + await recordAudit(db(), { + organizationId: session.organizationId, + actor, + entityType, + entityId: id, + action: "delete", + changes: { before: beforeStub }, + }); + } + } + await recordAudit(db(), { + organizationId: session.organizationId, + actor, + entityType: "company", + entityId: companyId, + action: "delete", + changes: { before: result.before }, + }); + + revalidatePath("/companies"); + revalidatePath("/deals"); + revalidatePath("/meetings"); + revalidatePath("/tasks"); + revalidatePath("/people"); + revalidatePath("/"); + return { ok: true }; +} diff --git a/app/(app)/companies/delete-company-button.tsx b/app/(app)/companies/delete-company-button.tsx new file mode 100644 index 0000000..7a7fb7e --- /dev/null +++ b/app/(app)/companies/delete-company-button.tsx @@ -0,0 +1,84 @@ +"use client"; + +import { Trash2 } from "lucide-react"; +import { useRouter } from "next/navigation"; +import { useEffect, useState } from "react"; +import { DeleteConfirmDialog } from "@/components/delete-confirm-dialog"; +import { Button } from "@/components/ui/button"; +import { deleteCompanyAction, previewCompanyDeleteAction } from "./actions"; + +type Counts = { + deals: number; + signals: number; + meetings: number; + notes: number; + tasks: number; +}; + +export function DeleteCompanyButton({ + companyId, + companyName, +}: { + companyId: string; + companyName: string; +}) { + const router = useRouter(); + const [open, setOpen] = useState(false); + const [counts, setCounts] = useState(null); + + useEffect(() => { + if (!open) return; + let cancelled = false; + void previewCompanyDeleteAction({ companyId }).then((res) => { + if (cancelled) return; + if (res.ok) setCounts(res.data); + }); + return () => { + cancelled = true; + }; + }, [open, companyId]); + + async function onConfirm() { + const result = await deleteCompanyAction({ companyId }); + if (result.ok) router.push("/companies"); + return result; + } + + const description = counts + ? buildDescription(companyName, counts) + : `Counting related items for ${companyName}…`; + + return ( + <> + + + + ); +} + +function buildDescription(name: string, c: Counts): string { + const parts: string[] = []; + if (c.deals) parts.push(`${c.deals} deal${c.deals === 1 ? "" : "s"}`); + if (c.signals) parts.push(`${c.signals} signal${c.signals === 1 ? "" : "s"}`); + if (c.meetings) parts.push(`${c.meetings} meeting${c.meetings === 1 ? "" : "s"}`); + if (c.notes) parts.push(`${c.notes} note${c.notes === 1 ? "" : "s"}`); + if (c.tasks) parts.push(`${c.tasks} task${c.tasks === 1 ? "" : "s"}`); + if (parts.length === 0) { + return `${name} will be permanently deleted. People at ${name} will remain but lose the company link.`; + } + return `${name} will be permanently deleted along with ${parts.join(", ")}. People at ${name} will remain but lose the company link. This cannot be undone.`; +} diff --git a/app/(app)/deals/actions.ts b/app/(app)/deals/actions.ts index d8ecd27..41734a7 100644 --- a/app/(app)/deals/actions.ts +++ b/app/(app)/deals/actions.ts @@ -6,6 +6,7 @@ import { z } from "zod"; import { db } from "@/db/client"; import { deals, stages } from "@/db/schema/deals"; import { diffChangedFields, recordAudit, userActor } from "@/lib/audit"; +import { deleteDeal } from "@/lib/deals"; import { requireOrgSession } from "@/lib/session"; const Schema = z.object({ @@ -53,3 +54,29 @@ export async function moveDealStageAction(input: { revalidatePath("/deals"); return { ok: true }; } + +export async function deleteDealAction(input: { + dealId: string; +}): Promise<{ ok: true } | { ok: false; message: string }> { + const session = await requireOrgSession(); + const dealId = z.string().uuid().parse(input.dealId); + + const result = await deleteDeal(db(), session.organizationId, dealId); + if (!result) return { ok: false, message: "Deal not found" }; + + await recordAudit(db(), { + organizationId: session.organizationId, + actor: userActor(session.user.id, session.user.name ?? null), + entityType: "deal", + entityId: dealId, + action: "delete", + changes: { before: result.before }, + }); + + revalidatePath("/deals"); + revalidatePath("/tasks"); + revalidatePath(`/companies/${result.before.companyId}/deals`); + revalidatePath(`/companies/${result.before.companyId}`); + revalidatePath("/companies"); + return { ok: true }; +} diff --git a/app/(app)/deals/deals-view.tsx b/app/(app)/deals/deals-view.tsx index 05499a4..438ce30 100644 --- a/app/(app)/deals/deals-view.tsx +++ b/app/(app)/deals/deals-view.tsx @@ -5,6 +5,7 @@ import { useMemo, useState } from "react"; import { CompanyLogo } from "@/components/avatar-init"; import { StagePill, TemperaturePill } from "@/components/pills"; import { money, relativeTime } from "@/lib/format"; +import { DeleteDealButton } from "./delete-deal-button"; import { KanbanBoard, type KanbanDeal, type KanbanStage } from "./kanban"; type DealRow = KanbanDeal; @@ -191,13 +192,14 @@ export function DealsView({ Temp + {filtered.map((d) => ( + + + ))} {filtered.length === 0 ? ( No deals match this filter. diff --git a/app/(app)/deals/delete-deal-button.tsx b/app/(app)/deals/delete-deal-button.tsx new file mode 100644 index 0000000..7e5f793 --- /dev/null +++ b/app/(app)/deals/delete-deal-button.tsx @@ -0,0 +1,60 @@ +"use client"; + +import { Trash2 } from "lucide-react"; +import { useState, type MouseEvent } from "react"; +import { DeleteConfirmDialog } from "@/components/delete-confirm-dialog"; +import { deleteDealAction } from "./actions"; + +export function DeleteDealButton({ + dealId, + dealName, + className, + onDeleted, +}: { + dealId: string; + dealName: string; + className?: string; + onDeleted?: () => void; +}) { + const [open, setOpen] = useState(false); + + function onClick(e: MouseEvent) { + e.preventDefault(); + e.stopPropagation(); + setOpen(true); + } + + async function onConfirm() { + const result = await deleteDealAction({ dealId }); + if (result.ok) onDeleted?.(); + return result; + } + + return ( + <> + + + “{dealName}” will be permanently deleted. Notes and tasks attached to + this deal will also be removed. This cannot be undone. + + } + onConfirm={onConfirm} + /> + + ); +} diff --git a/app/(app)/deals/kanban.tsx b/app/(app)/deals/kanban.tsx index e2dc87f..598a09a 100644 --- a/app/(app)/deals/kanban.tsx +++ b/app/(app)/deals/kanban.tsx @@ -7,6 +7,7 @@ import { StagePill, TemperaturePill } from "@/components/pills"; import { money, relativeTime } from "@/lib/format"; import { cn } from "@/lib/utils"; import { moveDealStageAction } from "./actions"; +import { DeleteDealButton } from "./delete-deal-button"; export type KanbanDeal = { id: string; @@ -107,29 +108,43 @@ export function KanbanBoard({
      ) : ( list.map((d) => ( - onDragStart(e, d.id)} - onDragEnd={onDragEnd} className={cn( - "block cursor-grab rounded-md border border-border bg-card/40 p-3 transition hover:bg-card/70 active:cursor-grabbing", + "group relative rounded-md border border-border bg-card/40 transition hover:bg-card/70", draggingId === d.id ? "opacity-40" : "", )} > -
      - {d.companyName} - + onDragStart(e, d.id)} + onDragEnd={onDragEnd} + className="block cursor-grab p-3 active:cursor-grabbing" + > +
      + {d.companyName} + +
      +
      {d.name}
      +
      + {money(d.value)} + + {relativeTime(d.stageEnteredAt)} + +
      + +
      + { + setDeals((cur) => cur.filter((x) => x.id !== d.id)); + router.refresh(); + }} + />
      -
      {d.name}
      -
      - {money(d.value)} - - {relativeTime(d.stageEnteredAt)} - -
      - +
      )) )}
      diff --git a/app/(app)/meetings/actions.ts b/app/(app)/meetings/actions.ts new file mode 100644 index 0000000..6ddc3ad --- /dev/null +++ b/app/(app)/meetings/actions.ts @@ -0,0 +1,31 @@ +"use server"; + +import { revalidatePath } from "next/cache"; +import { z } from "zod"; +import { db } from "@/db/client"; +import { recordAudit, userActor } from "@/lib/audit"; +import { deleteMeeting } from "@/lib/meetings"; +import { requireOrgSession } from "@/lib/session"; + +export async function deleteMeetingAction(input: { + meetingId: string; +}): Promise<{ ok: true } | { ok: false; message: string }> { + const session = await requireOrgSession(); + const meetingId = z.string().uuid().parse(input.meetingId); + + const result = await deleteMeeting(db(), session.organizationId, meetingId); + if (!result) return { ok: false, message: "Meeting not found" }; + + await recordAudit(db(), { + organizationId: session.organizationId, + actor: userActor(session.user.id, session.user.name ?? null), + entityType: "meeting", + entityId: meetingId, + action: "delete", + changes: { before: result.before }, + }); + + revalidatePath("/meetings"); + revalidatePath(`/companies/${result.before.companyId}`); + return { ok: true }; +} diff --git a/app/(app)/meetings/delete-meeting-button.tsx b/app/(app)/meetings/delete-meeting-button.tsx new file mode 100644 index 0000000..3ac4f1a --- /dev/null +++ b/app/(app)/meetings/delete-meeting-button.tsx @@ -0,0 +1,43 @@ +"use client"; + +import { Trash2 } from "lucide-react"; +import { useState } from "react"; +import { DeleteConfirmDialog } from "@/components/delete-confirm-dialog"; +import { deleteMeetingAction } from "./actions"; + +export function DeleteMeetingButton({ + meetingId, + meetingTitle, +}: { + meetingId: string; + meetingTitle: string; +}) { + const [open, setOpen] = useState(false); + + return ( + <> + + + “{meetingTitle}” will be permanently deleted. This cannot be undone. + + } + onConfirm={() => deleteMeetingAction({ meetingId })} + /> + + ); +} diff --git a/app/(app)/meetings/page.tsx b/app/(app)/meetings/page.tsx index 0c08176..7b7a669 100644 --- a/app/(app)/meetings/page.tsx +++ b/app/(app)/meetings/page.tsx @@ -6,6 +6,7 @@ import { meetingAttendees, meetings } from "@/db/schema/meetings"; import { AvatarStack, CompanyLogo } from "@/components/avatar-init"; import { relativeTime } from "@/lib/format"; import { requireOrgSession } from "@/lib/session"; +import { DeleteMeetingButton } from "./delete-meeting-button"; const ROW_LIMIT = 100; @@ -84,13 +85,14 @@ export default async function MeetingsPage() { {h} ))} + {rows.map((m) => (
      @@ -131,6 +133,9 @@ export default async function MeetingsPage() {
      {m.summary ?? "—"}
      + + + ))} diff --git a/app/(app)/people/[id]/page.tsx b/app/(app)/people/[id]/page.tsx index 897bfa0..390ad64 100644 --- a/app/(app)/people/[id]/page.tsx +++ b/app/(app)/people/[id]/page.tsx @@ -12,6 +12,7 @@ import { EngagementPill, PersonaPill } from "@/components/pills"; import { TaskRow, type TaskRowData } from "@/components/task-row"; import { relativeTime } from "@/lib/format"; import { requireOrgSession } from "@/lib/session"; +import { DeletePersonButton } from "../delete-person-button"; export default async function PersonDetailPage({ params, @@ -70,9 +71,10 @@ export default async function PersonDetailPage({ / {person.name}
      -
      - -
      +
      +
      + +

      ) : null}

      +
      +
      diff --git a/app/(app)/people/actions.ts b/app/(app)/people/actions.ts new file mode 100644 index 0000000..41bad5f --- /dev/null +++ b/app/(app)/people/actions.ts @@ -0,0 +1,66 @@ +"use server"; + +import { revalidatePath } from "next/cache"; +import { z } from "zod"; +import { db } from "@/db/client"; +import { recordAudit, userActor } from "@/lib/audit"; +import { deletePerson, previewPersonDelete, type PersonCascadeCounts } from "@/lib/people"; +import { requireOrgSession } from "@/lib/session"; + +export async function previewPersonDeleteAction(input: { + personId: string; +}): Promise<{ ok: true; data: PersonCascadeCounts } | { ok: false; message: string }> { + const session = await requireOrgSession(); + const personId = z.string().uuid().parse(input.personId); + const data = await previewPersonDelete(db(), session.organizationId, personId); + if (!data) return { ok: false, message: "Person not found" }; + return { ok: true, data }; +} + +export async function deletePersonAction(input: { + personId: string; +}): Promise<{ ok: true } | { ok: false; message: string }> { + const session = await requireOrgSession(); + const personId = z.string().uuid().parse(input.personId); + + const result = await deletePerson(db(), session.organizationId, personId); + if (!result) return { ok: false, message: "Person not found" }; + + const actor = userActor(session.user.id, session.user.name ?? null); + for (const taskId of result.children.taskIds) { + await recordAudit(db(), { + organizationId: session.organizationId, + actor, + entityType: "task", + entityId: taskId, + action: "delete", + changes: { before: { personId } }, + }); + } + for (const noteId of result.children.noteIds) { + await recordAudit(db(), { + organizationId: session.organizationId, + actor, + entityType: "note", + entityId: noteId, + action: "delete", + changes: { before: { personId } }, + }); + } + await recordAudit(db(), { + organizationId: session.organizationId, + actor, + entityType: "person", + entityId: personId, + action: "delete", + changes: { before: result.before }, + }); + + revalidatePath("/people"); + revalidatePath("/tasks"); + if (result.before.companyId) { + revalidatePath(`/companies/${result.before.companyId}/people`); + revalidatePath(`/companies/${result.before.companyId}`); + } + return { ok: true }; +} diff --git a/app/(app)/people/delete-person-button.tsx b/app/(app)/people/delete-person-button.tsx new file mode 100644 index 0000000..4e5914f --- /dev/null +++ b/app/(app)/people/delete-person-button.tsx @@ -0,0 +1,109 @@ +"use client"; + +import { Trash2 } from "lucide-react"; +import { useRouter } from "next/navigation"; +import { useEffect, useState, type MouseEvent } from "react"; +import { DeleteConfirmDialog } from "@/components/delete-confirm-dialog"; +import { Button } from "@/components/ui/button"; +import { deletePersonAction, previewPersonDeleteAction } from "./actions"; + +type Counts = { tasks: number; notes: number }; + +export function DeletePersonButton({ + personId, + personName, + variant = "row", + redirectTo, +}: { + personId: string; + personName: string; + variant?: "row" | "header"; + redirectTo?: string; +}) { + const router = useRouter(); + const [open, setOpen] = useState(false); + const [counts, setCounts] = useState(null); + + useEffect(() => { + if (!open) return; + let cancelled = false; + void previewPersonDeleteAction({ personId }).then((res) => { + if (cancelled) return; + if (res.ok) setCounts(res.data); + }); + return () => { + cancelled = true; + }; + }, [open, personId]); + + function stop(e: MouseEvent) { + e.preventDefault(); + e.stopPropagation(); + } + + async function onConfirm() { + const result = await deletePersonAction({ personId }); + if (result.ok && redirectTo) router.push(redirectTo); + return result; + } + + const description = counts + ? buildDescription(personName, counts) + : `Counting related items for ${personName}…`; + + if (variant === "header") { + return ( + <> + + + + ); + } + + return ( + <> + + + + ); +} + +function buildDescription(name: string, c: Counts): string { + const parts: string[] = []; + if (c.tasks) parts.push(`${c.tasks} task${c.tasks === 1 ? "" : "s"}`); + if (c.notes) parts.push(`${c.notes} note${c.notes === 1 ? "" : "s"}`); + if (parts.length === 0) { + return `${name} will be permanently deleted. Signals attributed to them will remain but lose the person link.`; + } + return `${name} will be permanently deleted along with ${parts.join(", ")}. Signals attributed to them will remain but lose the person link.`; +} diff --git a/app/(app)/people/page.tsx b/app/(app)/people/page.tsx index 66fa05c..6999a88 100644 --- a/app/(app)/people/page.tsx +++ b/app/(app)/people/page.tsx @@ -7,6 +7,7 @@ import { AvatarSquare, CompanyLogo } from "@/components/avatar-init"; import { EngagementPill, LifecyclePill, PersonaPill } from "@/components/pills"; import { relativeTime } from "@/lib/format"; import { requireOrgSession } from "@/lib/session"; +import { DeletePersonButton } from "./delete-person-button"; const ROW_LIMIT = 200; @@ -82,7 +83,7 @@ export default async function PeoplePage() { {rows.slice(0, ROW_LIMIT).map((p) => ( @@ -113,18 +114,21 @@ export default async function PeoplePage() { {p.email ?? "—"} - {p.linkedinUrl ? ( - - - - - - ) : null} +
      + {p.linkedinUrl ? ( + + + + + + ) : null} + +
      ))} diff --git a/app/(app)/tasks/actions.ts b/app/(app)/tasks/actions.ts index 8ab19e7..530a79f 100644 --- a/app/(app)/tasks/actions.ts +++ b/app/(app)/tasks/actions.ts @@ -7,6 +7,7 @@ import { db } from "@/db/client"; import { tasks } from "@/db/schema/tasks"; import { diffChangedFields, recordAudit, userActor } from "@/lib/audit"; import { requireOrgSession } from "@/lib/session"; +import { deleteTask } from "@/lib/tasks"; const StatusSchema = z.enum(["open", "done", "dismissed"]); @@ -42,3 +43,31 @@ export async function setTaskStatusAction(formData: FormData): Promise { revalidatePath("/tasks"); revalidatePath("/companies"); } + +export async function deleteTaskAction(input: { + taskId: string; +}): Promise<{ ok: true } | { ok: false; message: string }> { + const session = await requireOrgSession(); + const taskId = z.string().uuid().parse(input.taskId); + + const result = await deleteTask(db(), session.organizationId, taskId); + if (!result) return { ok: false, message: "Task not found" }; + + await recordAudit(db(), { + organizationId: session.organizationId, + actor: userActor(session.user.id, session.user.name ?? null), + entityType: "task", + entityId: taskId, + action: "delete", + changes: { before: result.before }, + }); + + revalidatePath("/"); + revalidatePath("/tasks"); + revalidatePath("/companies"); + if (result.before.companyId) { + revalidatePath(`/companies/${result.before.companyId}/tasks`); + revalidatePath(`/companies/${result.before.companyId}`); + } + return { ok: true }; +} diff --git a/components/delete-confirm-dialog.tsx b/components/delete-confirm-dialog.tsx new file mode 100644 index 0000000..0173d45 --- /dev/null +++ b/components/delete-confirm-dialog.tsx @@ -0,0 +1,85 @@ +"use client"; + +import { useState, useTransition, type ReactNode } from "react"; +import { + Dialog, + DialogContent, + DialogDescription, + DialogFooter, + DialogHeader, + DialogTitle, +} from "@/components/ui/dialog"; +import { Button } from "@/components/ui/button"; + +export type DeleteResult = { ok: true } | { ok: false; message: string }; + +export function DeleteConfirmDialog({ + open, + onOpenChange, + title, + description, + confirmLabel = "Delete", + onConfirm, +}: { + open: boolean; + onOpenChange: (open: boolean) => void; + title: string; + description: ReactNode; + confirmLabel?: string; + onConfirm: () => Promise; +}) { + const [error, setError] = useState(null); + const [pending, startTransition] = useTransition(); + + function onConfirmClick() { + setError(null); + startTransition(async () => { + const result = await onConfirm(); + if (!result.ok) { + setError(result.message); + return; + } + onOpenChange(false); + }); + } + + return ( + { + if (!next) setError(null); + onOpenChange(next); + }} + > + + + {title} + {description} + + {error ? ( +

      {error}

      + ) : null} + + + + +       +       + ); +} diff --git a/components/task-actions.tsx b/components/task-actions.tsx index e7ee2fb..5a0d74f 100644 --- a/components/task-actions.tsx +++ b/components/task-actions.tsx @@ -1,38 +1,68 @@ "use client"; -import { Check, X } from "lucide-react"; -import { setTaskStatusAction } from "@/app/(app)/tasks/actions"; +import { Check, Trash2, X } from "lucide-react"; +import { useState } from "react"; +import { deleteTaskAction, setTaskStatusAction } from "@/app/(app)/tasks/actions"; +import { DeleteConfirmDialog } from "@/components/delete-confirm-dialog"; import { Button } from "@/components/ui/button"; -export function TaskActions({ taskId }: { taskId: string }) { +export function TaskActions({ + taskId, + showStatusActions = true, +}: { + taskId: string; + showStatusActions?: boolean; +}) { + const [confirmOpen, setConfirmOpen] = useState(false); return (
      -
      - - - -
      -
      - - - -
      + {showStatusActions ? ( + <> +
      + + + +
      +
      + + + +
      + + ) : null} + + deleteTaskAction({ taskId })} + />
      ); } diff --git a/components/task-row.tsx b/components/task-row.tsx index 5976c92..9b87556 100644 --- a/components/task-row.tsx +++ b/components/task-row.tsx @@ -70,11 +70,9 @@ export function TaskRow({ task }: { task: TaskRowData }) { {relativeTime(task.dueDate)} - {task.status === "open" ? ( -
      - -
      - ) : null} +
      + +
      ); diff --git a/lib/companies.ts b/lib/companies.ts new file mode 100644 index 0000000..1c7f27b --- /dev/null +++ b/lib/companies.ts @@ -0,0 +1,87 @@ +import { and, count, eq } from "drizzle-orm"; +import type { Database } from "@/db/client"; +import { companies } from "@/db/schema/companies"; +import { deals } from "@/db/schema/deals"; +import { meetings } from "@/db/schema/meetings"; +import { notes } from "@/db/schema/notes"; +import { signals } from "@/db/schema/signals"; +import { tasks } from "@/db/schema/tasks"; + +export type Company = typeof companies.$inferSelect; + +export type CompanyCascadeChildren = { + dealIds: string[]; + signalIds: string[]; + meetingIds: string[]; + noteIds: string[]; + taskIds: string[]; +}; + +export type CompanyCascadeCounts = { + deals: number; + signals: number; + meetings: number; + notes: number; + tasks: number; +}; + +export async function previewCompanyDelete( + db: Database, + organizationId: string, + companyId: string, +): Promise { + const [exists] = await db + .select({ id: companies.id }) + .from(companies) + .where(and(eq(companies.id, companyId), eq(companies.organizationId, organizationId))) + .limit(1); + if (!exists) return null; + const [dealRows, signalRows, meetingRows, noteRows, taskRows] = await Promise.all([ + db.select({ n: count() }).from(deals).where(eq(deals.companyId, companyId)), + db.select({ n: count() }).from(signals).where(eq(signals.companyId, companyId)), + db.select({ n: count() }).from(meetings).where(eq(meetings.companyId, companyId)), + db.select({ n: count() }).from(notes).where(eq(notes.companyId, companyId)), + db.select({ n: count() }).from(tasks).where(eq(tasks.companyId, companyId)), + ]); + return { + deals: dealRows[0]?.n ?? 0, + signals: signalRows[0]?.n ?? 0, + meetings: meetingRows[0]?.n ?? 0, + notes: noteRows[0]?.n ?? 0, + tasks: taskRows[0]?.n ?? 0, + }; +} + +export async function deleteCompany( + db: Database, + organizationId: string, + companyId: string, +): Promise<{ before: Company; children: CompanyCascadeChildren } | null> { + return db.transaction(async (tx) => { + const [before] = await tx + .select() + .from(companies) + .where(and(eq(companies.id, companyId), eq(companies.organizationId, organizationId))) + .limit(1); + if (!before) return null; + + const [dealIds, signalIds, meetingIds, noteIds, taskIds] = await Promise.all([ + tx.select({ id: deals.id }).from(deals).where(eq(deals.companyId, companyId)), + tx.select({ id: signals.id }).from(signals).where(eq(signals.companyId, companyId)), + tx.select({ id: meetings.id }).from(meetings).where(eq(meetings.companyId, companyId)), + tx.select({ id: notes.id }).from(notes).where(eq(notes.companyId, companyId)), + tx.select({ id: tasks.id }).from(tasks).where(eq(tasks.companyId, companyId)), + ]); + await tx.delete(companies).where(eq(companies.id, companyId)); + return { + before, + children: { + dealIds: dealIds.map((r) => r.id), + signalIds: signalIds.map((r) => r.id), + meetingIds: meetingIds.map((r) => r.id), + noteIds: noteIds.map((r) => r.id), + taskIds: taskIds.map((r) => r.id), + }, + }; + }); +} diff --git a/lib/deals.ts b/lib/deals.ts new file mode 100644 index 0000000..e1a921e --- /dev/null +++ b/lib/deals.ts @@ -0,0 +1,17 @@ +import { and, eq } from "drizzle-orm"; +import type { Database } from "@/db/client"; +import { deals } from "@/db/schema/deals"; + +export type Deal = typeof deals.$inferSelect; + +export async function deleteDeal( + db: Database, + organizationId: string, + dealId: string, +): Promise<{ before: Deal } | null> { + const [before] = await db + .delete(deals) + .where(and(eq(deals.id, dealId), eq(deals.organizationId, organizationId))) + .returning(); + return before ? { before } : null; +} diff --git a/lib/meetings.ts b/lib/meetings.ts new file mode 100644 index 0000000..d5a74e0 --- /dev/null +++ b/lib/meetings.ts @@ -0,0 +1,17 @@ +import { and, eq } from "drizzle-orm"; +import type { Database } from "@/db/client"; +import { meetings } from "@/db/schema/meetings"; + +export type Meeting = typeof meetings.$inferSelect; + +export async function deleteMeeting( + db: Database, + organizationId: string, + meetingId: string, +): Promise<{ before: Meeting } | null> { + const [before] = await db + .delete(meetings) + .where(and(eq(meetings.id, meetingId), eq(meetings.organizationId, organizationId))) + .returning(); + return before ? { before } : null; +} diff --git a/lib/notes.ts b/lib/notes.ts new file mode 100644 index 0000000..09fec17 --- /dev/null +++ b/lib/notes.ts @@ -0,0 +1,17 @@ +import { and, eq } from "drizzle-orm"; +import type { Database } from "@/db/client"; +import { notes } from "@/db/schema/notes"; + +export type Note = typeof notes.$inferSelect; + +export async function deleteNote( + db: Database, + organizationId: string, + noteId: string, +): Promise<{ before: Note } | null> { + const [before] = await db + .delete(notes) + .where(and(eq(notes.id, noteId), eq(notes.organizationId, organizationId))) + .returning(); + return before ? { before } : null; +} diff --git a/lib/people.ts b/lib/people.ts new file mode 100644 index 0000000..7a27e98 --- /dev/null +++ b/lib/people.ts @@ -0,0 +1,66 @@ +import { and, count, eq } from "drizzle-orm"; +import type { Database } from "@/db/client"; +import { people } from "@/db/schema/companies"; +import { notes } from "@/db/schema/notes"; +import { tasks } from "@/db/schema/tasks"; + +export type Person = typeof people.$inferSelect; + +export type PersonCascadeChildren = { + taskIds: string[]; + noteIds: string[]; +}; + +export type PersonCascadeCounts = { + tasks: number; + notes: number; +}; + +export async function previewPersonDelete( + db: Database, + organizationId: string, + personId: string, +): Promise { + const [exists] = await db + .select({ id: people.id }) + .from(people) + .where(and(eq(people.id, personId), eq(people.organizationId, organizationId))) + .limit(1); + if (!exists) return null; + const [taskCount, noteCount] = await Promise.all([ + db.select({ n: count() }).from(tasks).where(eq(tasks.personId, personId)), + db.select({ n: count() }).from(notes).where(eq(notes.personId, personId)), + ]); + return { + tasks: taskCount[0]?.n ?? 0, + notes: noteCount[0]?.n ?? 0, + }; +} + +export async function deletePerson( + db: Database, + organizationId: string, + personId: string, +): Promise<{ before: Person; children: PersonCascadeChildren } | null> { + return db.transaction(async (tx) => { + const [before] = await tx + .select() + .from(people) + .where(and(eq(people.id, personId), eq(people.organizationId, organizationId))) + .limit(1); + if (!before) return null; + + const [taskIds, noteIds] = await Promise.all([ + tx.select({ id: tasks.id }).from(tasks).where(eq(tasks.personId, personId)), + tx.select({ id: notes.id }).from(notes).where(eq(notes.personId, personId)), + ]); + await tx.delete(people).where(eq(people.id, personId)); + return { + before, + children: { + taskIds: taskIds.map((r) => r.id), + noteIds: noteIds.map((r) => r.id), + }, + }; + }); +} diff --git a/lib/signals.ts b/lib/signals.ts new file mode 100644 index 0000000..ebbdaba --- /dev/null +++ b/lib/signals.ts @@ -0,0 +1,17 @@ +import { and, eq } from "drizzle-orm"; +import type { Database } from "@/db/client"; +import { signals } from "@/db/schema/signals"; + +export type Signal = typeof signals.$inferSelect; + +export async function deleteSignal( + db: Database, + organizationId: string, + signalId: string, +): Promise<{ before: Signal } | null> { + const [before] = await db + .delete(signals) + .where(and(eq(signals.id, signalId), eq(signals.organizationId, organizationId))) + .returning(); + return before ? { before } : null; +} diff --git a/lib/tasks.ts b/lib/tasks.ts new file mode 100644 index 0000000..521bd23 --- /dev/null +++ b/lib/tasks.ts @@ -0,0 +1,17 @@ +import { and, eq } from "drizzle-orm"; +import type { Database } from "@/db/client"; +import { tasks } from "@/db/schema/tasks"; + +export type Task = typeof tasks.$inferSelect; + +export async function deleteTask( + db: Database, + organizationId: string, + taskId: string, +): Promise<{ before: Task } | null> { + const [before] = await db + .delete(tasks) + .where(and(eq(tasks.id, taskId), eq(tasks.organizationId, organizationId))) + .returning(); + return before ? { before } : null; +} diff --git a/tests/companies.test.ts b/tests/companies.test.ts new file mode 100644 index 0000000..e2612cc --- /dev/null +++ b/tests/companies.test.ts @@ -0,0 +1,119 @@ +import { eq } from "drizzle-orm"; +import { beforeEach, describe, expect, test } from "bun:test"; +import { createDb } from "@/db/client"; +import { organization } from "@/db/schema/auth"; +import { companies, people } from "@/db/schema/companies"; +import { deals, pipelines, stages } from "@/db/schema/deals"; +import { meetings } from "@/db/schema/meetings"; +import { notes } from "@/db/schema/notes"; +import { signals } from "@/db/schema/signals"; +import { tasks } from "@/db/schema/tasks"; +import { deleteCompany, previewCompanyDelete } from "@/lib/companies"; +import { resetDb } from "./setup"; + +const db = createDb(process.env.TEST_DATABASE_URL!); + +async function seed(orgId = "org_companies") { + await db.insert(organization).values({ id: orgId, name: "Cos", slug: orgId }); + const companyId = crypto.randomUUID(); + await db.insert(companies).values({ id: companyId, organizationId: orgId, name: "Acme" }); + + const pipelineId = crypto.randomUUID(); + await db.insert(pipelines).values({ id: pipelineId, organizationId: orgId, name: "Sales" }); + const stageId = crypto.randomUUID(); + await db.insert(stages).values({ id: stageId, pipelineId, name: "Lead", order: 0 }); + await db.insert(deals).values([ + { id: crypto.randomUUID(), organizationId: orgId, companyId, pipelineId, stageId, name: "D1" }, + { id: crypto.randomUUID(), organizationId: orgId, companyId, pipelineId, stageId, name: "D2" }, + ]); + + await db.insert(signals).values({ + id: crypto.randomUUID(), + organizationId: orgId, + companyId, + type: "news", + title: "Funding", + occurredAt: new Date(), + }); + + await db.insert(meetings).values({ + id: crypto.randomUUID(), + organizationId: orgId, + companyId, + title: "Kickoff", + scheduledAt: new Date(), + }); + + await db.insert(notes).values({ + id: crypto.randomUUID(), + organizationId: orgId, + companyId, + body: "First call notes", + }); + + await db.insert(tasks).values({ + id: crypto.randomUUID(), + organizationId: orgId, + companyId, + title: "Send proposal", + }); + + const personId = crypto.randomUUID(); + await db.insert(people).values({ + id: personId, + organizationId: orgId, + companyId, + name: "Alice", + }); + + return { orgId, companyId, personId }; +} + +describe("lib/companies", () => { + beforeEach(async () => { + await resetDb(); + }); + + test("previewCompanyDelete counts cascading children correctly", async () => { + const { orgId, companyId } = await seed(); + const preview = await previewCompanyDelete(db, orgId, companyId); + expect(preview).toEqual({ deals: 2, signals: 1, meetings: 1, notes: 1, tasks: 1 }); + }); + + test("previewCompanyDelete returns null for cross-org company", async () => { + const { companyId } = await seed("org_a"); + await db.insert(organization).values({ id: "org_b", name: "B", slug: "org_b" }); + const preview = await previewCompanyDelete(db, "org_b", companyId); + expect(preview).toBeNull(); + }); + + test("deleteCompany cascades children and returns their IDs; people.company_id nullified", async () => { + const { orgId, companyId, personId } = await seed(); + const result = await deleteCompany(db, orgId, companyId); + expect(result).not.toBeNull(); + expect(result!.children.dealIds).toHaveLength(2); + expect(result!.children.signalIds).toHaveLength(1); + expect(result!.children.meetingIds).toHaveLength(1); + expect(result!.children.noteIds).toHaveLength(1); + expect(result!.children.taskIds).toHaveLength(1); + + expect(await db.select().from(companies).where(eq(companies.id, companyId))).toHaveLength(0); + expect(await db.select().from(deals).where(eq(deals.companyId, companyId))).toHaveLength(0); + expect(await db.select().from(signals).where(eq(signals.companyId, companyId))).toHaveLength(0); + expect(await db.select().from(meetings).where(eq(meetings.companyId, companyId))).toHaveLength(0); + expect(await db.select().from(notes).where(eq(notes.companyId, companyId))).toHaveLength(0); + expect(await db.select().from(tasks).where(eq(tasks.companyId, companyId))).toHaveLength(0); + + const personRow = await db.select().from(people).where(eq(people.id, personId)); + expect(personRow).toHaveLength(1); + expect(personRow[0]!.companyId).toBeNull(); + }); + + test("deleteCompany returns null for cross-org company", async () => { + const { companyId } = await seed("org_a"); + await db.insert(organization).values({ id: "org_b", name: "B", slug: "org_b" }); + const result = await deleteCompany(db, "org_b", companyId); + expect(result).toBeNull(); + expect(await db.select().from(companies).where(eq(companies.id, companyId))).toHaveLength(1); + }); +}); diff --git a/tests/deals.test.ts b/tests/deals.test.ts new file mode 100644 index 0000000..06ffc89 --- /dev/null +++ b/tests/deals.test.ts @@ -0,0 +1,51 @@ +import { eq } from "drizzle-orm"; +import { beforeEach, describe, expect, test } from "bun:test"; +import { createDb } from "@/db/client"; +import { organization } from "@/db/schema/auth"; +import { companies } from "@/db/schema/companies"; +import { deals, pipelines, stages } from "@/db/schema/deals"; +import { deleteDeal } from "@/lib/deals"; +import { resetDb } from "./setup"; + +const db = createDb(process.env.TEST_DATABASE_URL!); + +async function seed(orgId = "org_deals") { + await db.insert(organization).values({ id: orgId, name: "Deals", slug: orgId }); + const companyId = crypto.randomUUID(); + await db.insert(companies).values({ id: companyId, organizationId: orgId, name: "Acme" }); + const pipelineId = crypto.randomUUID(); + await db.insert(pipelines).values({ id: pipelineId, organizationId: orgId, name: "Sales" }); + const stageId = crypto.randomUUID(); + await db.insert(stages).values({ id: stageId, pipelineId, name: "Lead", order: 0 }); + const dealId = crypto.randomUUID(); + await db.insert(deals).values({ + id: dealId, + organizationId: orgId, + companyId, + pipelineId, + stageId, + name: "Acme Q3 deal", + }); + return { orgId, dealId }; +} + +describe("lib/deals", () => { + beforeEach(async () => { + await resetDb(); + }); + + test("deleteDeal removes the row and returns the prior snapshot", async () => { + const { orgId, dealId } = await seed(); + const result = await deleteDeal(db, orgId, dealId); + expect(result?.before.id).toBe(dealId); + const remaining = await db.select().from(deals).where(eq(deals.id, dealId)); + expect(remaining).toHaveLength(0); + }); + + test("deleteDeal returns null for cross-org deals", async () => { + const { dealId } = await seed("org_a"); + await db.insert(organization).values({ id: "org_b", name: "B", slug: "org_b" }); + const result = await deleteDeal(db, "org_b", dealId); + expect(result).toBeNull(); + }); +}); diff --git a/tests/meetings.test.ts b/tests/meetings.test.ts new file mode 100644 index 0000000..ec5f949 --- /dev/null +++ b/tests/meetings.test.ts @@ -0,0 +1,46 @@ +import { eq } from "drizzle-orm"; +import { beforeEach, describe, expect, test } from "bun:test"; +import { createDb } from "@/db/client"; +import { organization } from "@/db/schema/auth"; +import { companies } from "@/db/schema/companies"; +import { meetings } from "@/db/schema/meetings"; +import { deleteMeeting } from "@/lib/meetings"; +import { resetDb } from "./setup"; + +const db = createDb(process.env.TEST_DATABASE_URL!); + +async function seed(orgId = "org_meetings") { + await db.insert(organization).values({ id: orgId, name: "Meetings", slug: orgId }); + const companyId = crypto.randomUUID(); + await db.insert(companies).values({ id: companyId, organizationId: orgId, name: "Acme" }); + const meetingId = crypto.randomUUID(); + await db.insert(meetings).values({ + id: meetingId, + organizationId: orgId, + companyId, + title: "Quarterly review", + scheduledAt: new Date(), + }); + return { orgId, meetingId }; +} + +describe("lib/meetings", () => { + beforeEach(async () => { + await resetDb(); + }); + + test("deleteMeeting removes the row and returns the prior snapshot", async () => { + const { orgId, meetingId } = await seed(); + const result = await deleteMeeting(db, orgId, meetingId); + expect(result?.before.id).toBe(meetingId); + const remaining = await db.select().from(meetings).where(eq(meetings.id, meetingId)); + expect(remaining).toHaveLength(0); + }); + + test("deleteMeeting returns null for cross-org meetings", async () => { + const { meetingId } = await seed("org_a"); + await db.insert(organization).values({ id: "org_b", name: "B", slug: "org_b" }); + const result = await deleteMeeting(db, "org_b", meetingId); + expect(result).toBeNull(); + }); +}); diff --git a/tests/notes.test.ts b/tests/notes.test.ts new file mode 100644 index 0000000..ab4d464 --- /dev/null +++ b/tests/notes.test.ts @@ -0,0 +1,45 @@ +import { eq } from "drizzle-orm"; +import { beforeEach, describe, expect, test } from "bun:test"; +import { createDb } from "@/db/client"; +import { organization } from "@/db/schema/auth"; +import { companies } from "@/db/schema/companies"; +import { notes } from "@/db/schema/notes"; +import { deleteNote } from "@/lib/notes"; +import { resetDb } from "./setup"; + +const db = createDb(process.env.TEST_DATABASE_URL!); + +async function seed(orgId = "org_notes") { + await db.insert(organization).values({ id: orgId, name: "Notes", slug: orgId }); + const companyId = crypto.randomUUID(); + await db.insert(companies).values({ id: companyId, organizationId: orgId, name: "Acme" }); + const noteId = crypto.randomUUID(); + await db.insert(notes).values({ + id: noteId, + organizationId: orgId, + companyId, + body: "First contact email sent", + }); + return { orgId, noteId }; +} + +describe("lib/notes", () => { + beforeEach(async () => { + await resetDb(); + }); + + test("deleteNote removes the row and returns the prior snapshot", async () => { + const { orgId, noteId } = await seed(); + const result = await deleteNote(db, orgId, noteId); + expect(result?.before.id).toBe(noteId); + const remaining = await db.select().from(notes).where(eq(notes.id, noteId)); + expect(remaining).toHaveLength(0); + }); + + test("deleteNote returns null for cross-org notes", async () => { + const { noteId } = await seed("org_a"); + await db.insert(organization).values({ id: "org_b", name: "B", slug: "org_b" }); + const result = await deleteNote(db, "org_b", noteId); + expect(result).toBeNull(); + }); +}); diff --git a/tests/people.test.ts b/tests/people.test.ts new file mode 100644 index 0000000..cac7d55 --- /dev/null +++ b/tests/people.test.ts @@ -0,0 +1,99 @@ +import { eq } from "drizzle-orm"; +import { beforeEach, describe, expect, test } from "bun:test"; +import { createDb } from "@/db/client"; +import { organization } from "@/db/schema/auth"; +import { companies, people } from "@/db/schema/companies"; +import { meetingAttendees, meetings } from "@/db/schema/meetings"; +import { notes } from "@/db/schema/notes"; +import { signals } from "@/db/schema/signals"; +import { tasks } from "@/db/schema/tasks"; +import { deletePerson, previewPersonDelete } from "@/lib/people"; +import { resetDb } from "./setup"; + +const db = createDb(process.env.TEST_DATABASE_URL!); + +async function seed(orgId = "org_people") { + await db.insert(organization).values({ id: orgId, name: "People", slug: orgId }); + const companyId = crypto.randomUUID(); + await db.insert(companies).values({ id: companyId, organizationId: orgId, name: "Acme" }); + const personId = crypto.randomUUID(); + await db.insert(people).values({ + id: personId, + organizationId: orgId, + companyId, + name: "Alice Engineer", + }); + await db.insert(tasks).values([ + { id: crypto.randomUUID(), organizationId: orgId, personId, title: "Send recap" }, + { id: crypto.randomUUID(), organizationId: orgId, personId, title: "Schedule call" }, + ]); + await db.insert(notes).values({ + id: crypto.randomUUID(), + organizationId: orgId, + personId, + body: "Loves Postgres", + }); + const meetingId = crypto.randomUUID(); + await db.insert(meetings).values({ + id: meetingId, + organizationId: orgId, + companyId, + title: "Kickoff", + scheduledAt: new Date(), + }); + await db.insert(meetingAttendees).values({ meetingId, personId }); + const signalId = crypto.randomUUID(); + await db.insert(signals).values({ + id: signalId, + organizationId: orgId, + companyId, + personId, + type: "email", + title: "Replied to outreach", + occurredAt: new Date(), + }); + return { orgId, personId, signalId }; +} + +describe("lib/people", () => { + beforeEach(async () => { + await resetDb(); + }); + + test("previewPersonDelete counts cascading children correctly", async () => { + const { orgId, personId } = await seed(); + const preview = await previewPersonDelete(db, orgId, personId); + expect(preview).toEqual({ tasks: 2, notes: 1 }); + }); + + test("previewPersonDelete returns null for cross-org person", async () => { + const { personId } = await seed("org_a"); + await db.insert(organization).values({ id: "org_b", name: "B", slug: "org_b" }); + const preview = await previewPersonDelete(db, "org_b", personId); + expect(preview).toBeNull(); + }); + + test("deletePerson cascades tasks/notes/attendances and returns child IDs", async () => { + const { orgId, personId, signalId } = await seed(); + const result = await deletePerson(db, orgId, personId); + expect(result).not.toBeNull(); + expect(result!.children.taskIds).toHaveLength(2); + expect(result!.children.noteIds).toHaveLength(1); + + expect(await db.select().from(people).where(eq(people.id, personId))).toHaveLength(0); + expect(await db.select().from(tasks).where(eq(tasks.personId, personId))).toHaveLength(0); + expect(await db.select().from(notes).where(eq(notes.personId, personId))).toHaveLength(0); + + const signalRow = await db.select().from(signals).where(eq(signals.id, signalId)); + expect(signalRow).toHaveLength(1); + expect(signalRow[0]!.personId).toBeNull(); + }); + + test("deletePerson returns null for cross-org person", async () => { + const { personId } = await seed("org_a"); + await db.insert(organization).values({ id: "org_b", name: "B", slug: "org_b" }); + const result = await deletePerson(db, "org_b", personId); + expect(result).toBeNull(); + expect(await db.select().from(people).where(eq(people.id, personId))).toHaveLength(1); + }); +}); diff --git a/tests/signals.test.ts b/tests/signals.test.ts new file mode 100644 index 0000000..7451794 --- /dev/null +++ b/tests/signals.test.ts @@ -0,0 +1,72 @@ +import { and, eq } from "drizzle-orm"; +import { beforeEach, describe, expect, test } from "bun:test"; +import { createDb } from "@/db/client"; +import { organization, user } from "@/db/schema/auth"; +import { auditLog } from "@/db/schema/audit"; +import { companies } from "@/db/schema/companies"; +import { signals } from "@/db/schema/signals"; +import { deleteSignal } from "@/lib/signals"; +import { recordAudit, userActor } from "@/lib/audit"; +import { resetDb } from "./setup"; + +const db = createDb(process.env.TEST_DATABASE_URL!); + +async function seed(orgId = "org_signals") { + await db.insert(organization).values({ id: orgId, name: "Signals", slug: orgId }); + const companyId = crypto.randomUUID(); + await db.insert(companies).values({ id: companyId, organizationId: orgId, name: "Acme" }); + const signalId = crypto.randomUUID(); + await db.insert(signals).values({ + id: signalId, + organizationId: orgId, + companyId, + type: "news", + title: "Acme raised $10M", + occurredAt: new Date(), + }); + return { orgId, companyId, signalId }; +} + +describe("lib/signals", () => { + beforeEach(async () => { + await resetDb(); + }); + + test("deleteSignal removes the row and returns the prior snapshot", async () => { + const { orgId, signalId } = await seed(); + const result = await deleteSignal(db, orgId, signalId); + expect(result?.before.id).toBe(signalId); + const remaining = await db.select().from(signals).where(eq(signals.id, signalId)); + expect(remaining).toHaveLength(0); + }); + + test("deleteSignal returns null for cross-org signals", async () => { + const { signalId } = await seed("org_a"); + await db.insert(organization).values({ id: "org_b", name: "B", slug: "org_b" }); + const result = await deleteSignal(db, "org_b", signalId); + expect(result).toBeNull(); + const remaining = await db.select().from(signals).where(eq(signals.id, signalId)); + expect(remaining).toHaveLength(1); + }); + + test("delete + audit fan-out leaves a delete audit row", async () => { + const { orgId, signalId } = await seed(); + await db.insert(user).values({ id: "u_alice", name: "Alice", email: "alice@example.com" }); + const result = await deleteSignal(db, orgId, signalId); + expect(result).not.toBeNull(); + await recordAudit(db, { + organizationId: orgId, + actor: userActor("u_alice", "Alice"), + entityType: "signal", + entityId: signalId, + action: "delete", + changes: { before: result!.before }, + }); + const rows = await db + .select() + .from(auditLog) + .where(and(eq(auditLog.entityType, "signal"), eq(auditLog.action, "delete"))); + expect(rows).toHaveLength(1); + expect(rows[0]!.entityId).toBe(signalId); + }); +}); diff --git a/tests/tasks.test.ts b/tests/tasks.test.ts new file mode 100644 index 0000000..2f5a9af --- /dev/null +++ b/tests/tasks.test.ts @@ -0,0 +1,45 @@ +import { eq } from "drizzle-orm"; +import { beforeEach, describe, expect, test } from "bun:test"; +import { createDb } from "@/db/client"; +import { organization } from "@/db/schema/auth"; +import { companies } from "@/db/schema/companies"; +import { tasks } from "@/db/schema/tasks"; +import { deleteTask } from "@/lib/tasks"; +import { resetDb } from "./setup"; + +const db = createDb(process.env.TEST_DATABASE_URL!); + +async function seed(orgId = "org_tasks") { + await db.insert(organization).values({ id: orgId, name: "Tasks", slug: orgId }); + const companyId = crypto.randomUUID(); + await db.insert(companies).values({ id: companyId, organizationId: orgId, name: "Acme" }); + const taskId = crypto.randomUUID(); + await db.insert(tasks).values({ + id: taskId, + organizationId: orgId, + companyId, + title: "Follow up with Acme", + }); + return { orgId, taskId }; +} + +describe("lib/tasks", () => { + beforeEach(async () => { + await resetDb(); + }); + + test("deleteTask removes the row and returns the prior snapshot", async () => { + const { orgId, taskId } = await seed(); + const result = await deleteTask(db, orgId, taskId); + expect(result?.before.id).toBe(taskId); + const remaining = await db.select().from(tasks).where(eq(tasks.id, taskId)); + expect(remaining).toHaveLength(0); + }); + + test("deleteTask returns null for cross-org tasks", async () => { + const { taskId } = await seed("org_a"); + await db.insert(organization).values({ id: "org_b", name: "B", slug: "org_b" }); + const result = await deleteTask(db, "org_b", taskId); + expect(result).toBeNull(); + }); +});