Replace support thread status with a single archived_at toggle

Inbound mail clears archived_at so a reply restores the thread to the
inbox automatically, removing the need for an open/pending/closed
workflow we weren't using.

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>

Author: bchapuis

apps/api/src/db/migrations/0060_replace_thread_status_with_archived_at.sql

@@ -0,0 +1,16 @@
+-- Replace the open/pending/closed thread status with a single archived_at
+-- timestamp. NULL = active inbox thread, non-null = archived. The inbound
+-- email path clears archived_at when a new message arrives so archived
+-- threads automatically return to the inbox on reply.
+
+ALTER TABLE `threads` ADD COLUMN `archived_at` integer;
+
+-- Map existing closed threads to archived; pending threads fall back to
+-- active since the workflow no longer distinguishes them.
+UPDATE `threads` SET `archived_at` = `updated_at` WHERE `status` = 'closed';
+
+DROP INDEX IF EXISTS `threads_status_idx`;
+
+ALTER TABLE `threads` DROP COLUMN `status`;
+
+CREATE INDEX IF NOT EXISTS `threads_archived_at_idx` ON `threads` (`archived_at`);

apps/api/src/db/schema/index.ts

@@ -122,15 +122,6 @@ export const SubscriptionStatus = {
 export type SubscriptionStatusType =
   (typeof SubscriptionStatus)[keyof typeof SubscriptionStatus];
 
-// Inbox thread status
-export const ThreadStatus = {
-  OPEN: "open",
-  PENDING: "pending",
-  CLOSED: "closed",
-} as const;
-
-export type ThreadStatusType = (typeof ThreadStatus)[keyof typeof ThreadStatus];
-
 // Inbox message direction
 export const MessageDirection = {
   INBOUND: "inbound",
@@ -585,17 +576,14 @@ export const threads = sqliteTable(
     organizationId: text("organization_id").references(() => organizations.id, {
       onDelete: "set null",
     }),
-    status: text("status")
-      .$type<ThreadStatusType>()
-      .notNull()
-      .default(ThreadStatus.OPEN),
+    archivedAt: integer("archived_at", { mode: "timestamp" }),
     lastMessageAt: integer("last_message_at", { mode: "timestamp" }).notNull(),
     createdAt: createCreatedAt(),
     updatedAt: createUpdatedAt(),
   },
   (table) => [
     index("threads_inbox_id_idx").on(table.inboxId),
-    index("threads_status_idx").on(table.status),
+    index("threads_archived_at_idx").on(table.archivedAt),
     index("threads_last_message_at_idx").on(table.lastMessageAt),
     index("threads_from_email_idx").on(table.fromEmail),
     index("threads_user_id_idx").on(table.userId),

apps/api/src/db/support-queries.ts

@@ -12,7 +12,6 @@ import {
   messages,
   type ThreadInsert,
   type ThreadRow,
-  ThreadStatus,
   threads,
   users,
 } from "./index";
@@ -190,9 +189,8 @@ export async function insertAttachments(
 }
 
 /**
- * Reopen and bump `lastMessageAt` on a thread that just received a new
- * inbound message. Closed threads are reopened (user replied to a resolved
- * conversation); pending threads also flip back to open.
+ * Bump `lastMessageAt` on a thread that just received a new inbound message
+ * and clear `archivedAt` so archived threads return to the inbox on reply.
  */
 export async function touchThreadOnInbound(
   db: Database,
@@ -203,7 +201,7 @@ export async function touchThreadOnInbound(
     .update(threads)
     .set({
       lastMessageAt,
-      status: ThreadStatus.OPEN,
+      archivedAt: null,
       updatedAt: new Date(),
     })
     .where(eq(threads.id, threadId));

apps/api/src/routes/admin/support.ts

@@ -1,5 +1,16 @@
 import { zValidator } from "@hono/zod-validator";
-import { and, asc, desc, eq, inArray, isNull, lt, or, sql } from "drizzle-orm";
+import {
+  and,
+  asc,
+  desc,
+  eq,
+  inArray,
+  isNotNull,
+  isNull,
+  lt,
+  or,
+  sql,
+} from "drizzle-orm";
 import { Hono } from "hono";
 import { z } from "zod";
 
@@ -13,8 +24,6 @@ import {
   messages,
   organizations,
   selectLastInboundMessage,
-  ThreadStatus,
-  type ThreadStatusType,
   threadReads,
   threads,
   users,
@@ -24,18 +33,12 @@ import { inboxKeys, SUPPORT_INBOX_ALIAS } from "../../support-storage";
 
 const adminSupportRoutes = new Hono<ApiContext>();
 
-const statusEnum = z.enum([
-  ThreadStatus.OPEN,
-  ThreadStatus.PENDING,
-  ThreadStatus.CLOSED,
-]);
-
 const threadSummaryColumns = {
   id: threads.id,
   subject: threads.subject,
   fromEmail: threads.fromEmail,
   fromName: threads.fromName,
-  status: threads.status,
+  archivedAt: threads.archivedAt,
   lastMessageAt: threads.lastMessageAt,
   createdAt: threads.createdAt,
   updatedAt: threads.updatedAt,
@@ -54,17 +57,21 @@ adminSupportRoutes.get(
     z.object({
       page: z.coerce.number().min(1).default(1),
       limit: z.coerce.number().min(1).max(100).default(20),
-      status: statusEnum.optional(),
+      // "inbox" (default) hides archived; "archived" shows only archived;
+      // "all" shows both. Kept as a string union so the URL stays readable.
+      view: z.enum(["inbox", "archived", "all"]).default("inbox"),
       search: z.string().optional(),
     })
   ),
   async (c) => {
     const db = createDatabase(c.env.DB);
-    const { page, limit, status, search } = c.req.valid("query");
+    const { page, limit, view, search } = c.req.valid("query");
     const offset = (page - 1) * limit;
 
     const conditions = [];
-    if (status) conditions.push(eq(threads.status, status));
+    if (view === "inbox") conditions.push(isNull(threads.archivedAt));
+    else if (view === "archived")
+      conditions.push(isNotNull(threads.archivedAt));
     if (search) {
       const like_ = `%${search}%`;
       conditions.push(
@@ -135,9 +142,12 @@ adminSupportRoutes.get("/unread-count", async (c) => {
       )
     )
     .where(
-      or(
-        isNull(threadReads.lastReadAt),
-        lt(threadReads.lastReadAt, threads.lastMessageAt)
+      and(
+        isNull(threads.archivedAt),
+        or(
+          isNull(threadReads.lastReadAt),
+          lt(threadReads.lastReadAt, threads.lastMessageAt)
+        )
       )
     );
 
@@ -351,7 +361,6 @@ adminSupportRoutes.post(
       fromName: null,
       userId: linkedUser?.id ?? null,
       organizationId: linkedUser?.organizationId ?? null,
-      status: ThreadStatus.OPEN,
       lastMessageAt: now,
     });
 
@@ -440,18 +449,21 @@ adminSupportRoutes.post(
   }
 );
 
-/** PATCH /admin/support/threads/:id — close / reopen. */
+/** PATCH /admin/support/threads/:id — archive / unarchive. */
 adminSupportRoutes.patch(
   "/threads/:id",
-  zValidator("json", z.object({ status: statusEnum })),
+  zValidator("json", z.object({ archived: z.boolean() })),
   async (c) => {
     const db = createDatabase(c.env.DB);
     const id = c.req.param("id");
-    const { status } = c.req.valid("json");
+    const { archived } = c.req.valid("json");
 
     const result = await db
       .update(threads)
-      .set({ status: status as ThreadStatusType, updatedAt: new Date() })
+      .set({
+        archivedAt: archived ? new Date() : null,
+        updatedAt: new Date(),
+      })
       .where(eq(threads.id, id))
       .returning();
 

apps/api/src/support-email.ts

@@ -13,7 +13,6 @@ import {
   insertMessage,
   MessageDirection,
   resolveThreadForInbound,
-  ThreadStatus,
   threads,
   touchThreadOnInbound,
 } from "./db";
@@ -254,7 +253,6 @@ export async function handleSupportEmail(
         fromName: fromName ?? null,
         userId: linkedUser?.id ?? null,
         organizationId: linkedUser?.organizationId ?? null,
-        status: ThreadStatus.OPEN,
         lastMessageAt: now,
       });
       threadId = thread.id;

apps/app/src/pages/admin/admin-support-page.tsx

@@ -1,3 +1,5 @@
+import Archive from "lucide-react/icons/archive";
+import ArchiveRestore from "lucide-react/icons/archive-restore";
 import Inbox from "lucide-react/icons/inbox";
 import Paperclip from "lucide-react/icons/paperclip";
 import PenSquare from "lucide-react/icons/pen-square";
@@ -36,14 +38,14 @@ import { Textarea } from "@/components/ui/textarea";
 import {
   AdminMessageDirection,
   type AdminThreadMessage,
-  type AdminThreadStatus,
   type AdminThreadSummary,
+  type AdminThreadView,
   type AdminUser,
   adminSupportAttachmentUrl,
   createAdminSupportThread,
   fetchAdminSupportMessageBody,
   sendAdminSupportReply,
-  updateAdminSupportThreadStatus,
+  updateAdminSupportThreadArchived,
   useAdminSupportThread,
   useAdminSupportThreads,
   useAdminSupportUnreadCount,
@@ -52,11 +54,10 @@ import {
 import { formatDate } from "@/utils/date";
 import { cn } from "@/utils/utils";
 
-const STATUS_FILTERS: { value: AdminThreadStatus | "all"; label: string }[] = [
+const VIEW_FILTERS: { value: AdminThreadView; label: string }[] = [
+  { value: "inbox", label: "Inbox" },
+  { value: "archived", label: "Archived" },
   { value: "all", label: "All" },
-  { value: "open", label: "Open" },
-  { value: "pending", label: "Pending" },
-  { value: "closed", label: "Closed" },
 ];
 
 export function AdminSupportPage() {
@@ -67,20 +68,13 @@ export function AdminSupportPage() {
   }, [setBreadcrumbs]);
 
   const [page, setPage] = useState(1);
-  const [statusFilter, setStatusFilter] = useState<AdminThreadStatus | "all">(
-    "all"
-  );
+  const [view, setView] = useState<AdminThreadView>("inbox");
   const [searchInput, setSearchInput] = useState("");
   const [search, setSearch] = useState("");
   const limit = 30;
 
   const { threads, pagination, threadsError, isThreadsLoading, mutateThreads } =
-    useAdminSupportThreads(
-      page,
-      limit,
-      statusFilter === "all" ? undefined : statusFilter,
-      search || undefined
-    );
+    useAdminSupportThreads(page, limit, view, search || undefined);
   const { mutateUnreadCount } = useAdminSupportUnreadCount();
 
   const [selectedThreadId, setSelectedThreadId] = useState<string | null>(null);
@@ -134,17 +128,17 @@ export function AdminSupportPage() {
         </form>
 
         <Select
-          value={statusFilter}
+          value={view}
           onValueChange={(v) => {
-            setStatusFilter(v as AdminThreadStatus | "all");
+            setView(v as AdminThreadView);
             setPage(1);
           }}
         >
           <SelectTrigger className="w-36 h-10">
             <SelectValue />
           </SelectTrigger>
           <SelectContent>
-            {STATUS_FILTERS.map((f) => (
+            {VIEW_FILTERS.map((f) => (
               <SelectItem key={f.value} value={f.value}>
                 {f.label}
               </SelectItem>
@@ -214,7 +208,7 @@ function ThreadList({
 }) {
   return (
     <div className="flex flex-col overflow-hidden lg:border-r">
-      <div className="px-4 py-2">
+      <div className="px-4 py-2 border-b">
         <Button className="w-full h-10" onClick={onCompose}>
           <PenSquare className="h-4 w-4 mr-2" />
           New thread
@@ -336,7 +330,7 @@ function ThreadDetail({
 
   const [replyText, setReplyText] = useState("");
   const [isSending, setIsSending] = useState(false);
-  const [isUpdatingStatus, setIsUpdatingStatus] = useState(false);
+  const [isUpdatingArchived, setIsUpdatingArchived] = useState(false);
 
   // Reset the composer when switching threads.
   useEffect(() => {
@@ -373,16 +367,19 @@ function ThreadDetail({
     }
   };
 
-  const onStatusChange = async (status: AdminThreadStatus) => {
-    setIsUpdatingStatus(true);
+  const isArchived = thread.archivedAt !== null;
+  const onToggleArchived = async () => {
+    setIsUpdatingArchived(true);
     try {
-      await updateAdminSupportThreadStatus(threadId, status);
+      await updateAdminSupportThreadArchived(threadId, !isArchived);
       await mutateThread();
       onMutated();
     } catch (e) {
-      toast.error(e instanceof Error ? e.message : "Failed to update status");
+      toast.error(
+        e instanceof Error ? e.message : "Failed to update archive state"
+      );
     } finally {
-      setIsUpdatingStatus(false);
+      setIsUpdatingArchived(false);
     }
   };
 
@@ -414,20 +411,24 @@ function ThreadDetail({
             </p>
           </div>
         </div>
-        <Select
-          value={thread.status}
-          disabled={isUpdatingStatus}
-          onValueChange={(v) => onStatusChange(v as AdminThreadStatus)}
+        <Button
+          variant="outline"
+          className="h-10 w-36 shrink-0"
+          onClick={onToggleArchived}
+          disabled={isUpdatingArchived}
         >
-          <SelectTrigger className="w-36 h-10 shrink-0">
-            <SelectValue />
-          </SelectTrigger>
-          <SelectContent>
-            <SelectItem value="open">Open</SelectItem>
-            <SelectItem value="pending">Pending</SelectItem>
-            <SelectItem value="closed">Closed</SelectItem>
-          </SelectContent>
-        </Select>
+          {isArchived ? (
+            <>
+              <ArchiveRestore className="h-4 w-4 mr-2" />
+              Unarchive
+            </>
+          ) : (
+            <>
+              <Archive className="h-4 w-4 mr-2" />
+              Archive
+            </>
+          )}
+        </Button>
       </div>
 
       <div className="flex-1 overflow-y-auto px-5 py-4 space-y-6">