Add industrial read workflow and alias readiness checks

Author: lucaomul

frontend/src/hooks/use-ops.ts

@@ -7,6 +7,7 @@ import {
   runMailboxClassification,
   runMailboxBackfill,
   runAutoLabel,
+  runIndustrialReadWorkflow,
   runLabelCleanup,
   runFullAnchorWorkflow,
   runOpsScan,
@@ -150,6 +151,20 @@ export function useRunSafeCleanupWorkflow() {
   });
 }
 
+export function useRunIndustrialReadWorkflow() {
+  const invalidate = useInvalidateWorkspace();
+  return useMutation({
+    mutationFn: (timeRange: MailboxTimeRange) => runIndustrialReadWorkflow(timeRange),
+    onSuccess: (result) => {
+      invalidate();
+      toast.success("Unread mail marked as read", {
+        description: `${result.count || 0} cached unread emails were marked as read in the live inbox.`,
+      });
+    },
+    onError: (err) => toast.error(`Failed to mark unread mail as read: ${err.message}`),
+  });
+}
+
 export function useRunFullAnchorWorkflow() {
   const invalidate = useInvalidateWorkspace();
   return useMutation({

frontend/src/lib/api-client.ts

@@ -513,6 +513,17 @@ export interface OpsOverview {
   hydratedEmailsCount: number;
   oldestCachedAt: string | null;
   newestCachedAt: string | null;
+  mailboxMemory?: {
+    targetCount: number;
+    processedTotal: number;
+    resumeOffset: number;
+    remainingCount: number;
+    completed: boolean;
+    fullMailboxMode?: boolean;
+    includeBody: boolean;
+    unreadOnly: boolean;
+    lastBackfillAt: string | null;
+  };
   categoryCounts: Record<string, number>;
   summary: string;
   liveConnected: boolean;
@@ -527,6 +538,10 @@ export interface WorkflowMutationResult {
   cleanupApplied?: number;
   cachedCount?: number;
   hydratedCount?: number;
+  processedTotal?: number;
+  resumeOffset?: number;
+  remainingCount?: number;
+  completed?: boolean;
   deletedLabelCount?: number;
   deletedLabels?: string[];
   overview: OpsOverview;
@@ -588,7 +603,7 @@ export async function runMailboxBackfill(timeRange?: MailboxTimeRange): Promise<
     method: "POST",
     body: JSON.stringify({
       force_refresh: false,
-      limit: 20000,
+      limit: null,
       batch_size: 250,
       include_body: false,
       unread_only: false,
@@ -629,6 +644,15 @@ export async function runSafeCleanupWorkflow(
   });
 }
 
+export async function runIndustrialReadWorkflow(
+  timeRange?: MailboxTimeRange,
+): Promise<WorkflowMutationResult> {
+  return apiFetch<WorkflowMutationResult>("/ops/industrial-read", {
+    method: "POST",
+    body: JSON.stringify({ force_refresh: false, time_range: timeRange }),
+  });
+}
+
 export async function runFullAnchorWorkflow(
   timeRange?: MailboxTimeRange,
 ): Promise<WorkflowMutationResult> {
@@ -659,6 +683,10 @@ export interface EmailAliasListResponse {
   mode?: "plus" | "managed";
   domain?: string | null;
   managed_enabled?: boolean;
+  managed_ready?: boolean;
+  managed_resolver_configured?: boolean;
+  managed_inbound_ready?: boolean;
+  managed_blockers?: string[];
   plus_fallback_enabled?: boolean;
 }
 

frontend/src/routes/index.tsx

@@ -13,6 +13,7 @@ import {
   useRunLabelCleanup,
   useRunMailboxBackfill,
   useRunFullAnchorWorkflow,
+  useRunIndustrialReadWorkflow,
   useRunOpsScan,
   useRunSafeCleanupWorkflow,
 } from "@/hooks/use-ops";
@@ -27,6 +28,7 @@ import {
   Inbox,
   Layers3,
   LogOut,
+  MailOpen,
   Palette,
   Settings,
   ShieldCheck,
@@ -77,6 +79,7 @@ function CommandCenter() {
   const autoLabelMutation = useRunAutoLabel();
   const cleanLabelsMutation = useRunLabelCleanup();
   const cleanupMutation = useRunSafeCleanupWorkflow();
+  const industrialReadMutation = useRunIndustrialReadWorkflow();
   const fullAnchorMutation = useRunFullAnchorWorkflow();
   const overviewError = error instanceof Error ? error.message : "InboxAnchor could not load the live mailbox overview yet.";
 
@@ -87,6 +90,7 @@ function CommandCenter() {
     autoLabelMutation.isPending ||
     cleanLabelsMutation.isPending ||
     cleanupMutation.isPending ||
+    industrialReadMutation.isPending ||
     fullAnchorMutation.isPending;
   const shouldPollProgress =
     isLoading ||
@@ -329,7 +333,9 @@ function CommandCenter() {
                       </div>
                       <div className="flex flex-wrap gap-2">
                         <Badge variant="outline">
-                          {progress.processed_count} / {progress.target_count} cached
+                          {progress.target_count > 0
+                            ? `${progress.processed_count} / ${progress.target_count} cached`
+                            : `${progress.processed_count} cached`}
                         </Badge>
                         <Button
                           variant="outline"
@@ -483,6 +489,15 @@ function CommandCenter() {
                 loading={cleanLabelsMutation.isPending}
                 onClick={() => cleanLabelsMutation.mutate(timeRange)}
               />
+              <WorkflowCard
+                title="Industrial mark as read"
+                icon={<MailOpen className="h-4 w-4" />}
+                description="Mark the full cached unread working set as read in batched provider calls, no matter what category the emails fall into."
+                impact={overview?.workflows.find((item) => item.slug === "industrial-read")?.impact}
+                cta="Mark all read"
+                loading={industrialReadMutation.isPending}
+                onClick={() => industrialReadMutation.mutate(timeRange)}
+              />
               <WorkflowCard
                 title="Safe cleanup"
                 icon={<ShieldCheck className="h-4 w-4" />}

frontend/src/routes/settings.tsx

@@ -49,6 +49,10 @@ function SettingsPage() {
   const [aliasMode, setAliasMode] = useState<"plus" | "managed">("plus");
   const [aliasDomain, setAliasDomain] = useState("");
   const [managedAliasEnabled, setManagedAliasEnabled] = useState(false);
+  const [managedAliasReady, setManagedAliasReady] = useState(false);
+  const [managedAliasResolverConfigured, setManagedAliasResolverConfigured] = useState(false);
+  const [managedAliasInboundReady, setManagedAliasInboundReady] = useState(false);
+  const [managedAliasBlockers, setManagedAliasBlockers] = useState<string[]>([]);
   const [plusFallbackEnabled, setPlusFallbackEnabled] = useState(false);
   const [aliasItems, setAliasItems] = useState<Array<{
     id: number;
@@ -122,6 +126,10 @@ function SettingsPage() {
       setAliasMode(response.mode === "managed" ? "managed" : "plus");
       setAliasDomain(response.domain || "");
       setManagedAliasEnabled(Boolean(response.managed_enabled));
+      setManagedAliasReady(Boolean(response.managed_ready));
+      setManagedAliasResolverConfigured(Boolean(response.managed_resolver_configured));
+      setManagedAliasInboundReady(Boolean(response.managed_inbound_ready));
+      setManagedAliasBlockers(response.managed_blockers || []);
       setPlusFallbackEnabled(Boolean(response.plus_fallback_enabled));
       setAliasError("");
     } catch (err) {
@@ -440,7 +448,7 @@ function SettingsPage() {
               InboxAnchor can also auto-label alias mail and keep it out of the primary inbox.
             </p>
             <div className="rounded-md border border-border bg-secondary/30 p-3 text-xs leading-5 text-muted-foreground">
-              {managedAliasEnabled ? (
+              {managedAliasEnabled && managedAliasReady ? (
                 <>
                   InboxAnchor is using its managed alias domain
                   {" "}
@@ -452,6 +460,20 @@ function SettingsPage() {
                     travel1234567@{aliasDomain}
                   </span>.
                 </>
+              ) : managedAliasEnabled ? (
+                <>
+                  InboxAnchor sees the managed alias domain
+                  {" "}
+                  <span className="font-medium text-foreground">{aliasDomain}</span>
+                  {" "}
+                  but the inbound path is not fully live yet, so product-owned aliases like
+                  {" "}
+                  <span className="font-medium text-foreground">
+                    travel1234567@{aliasDomain}
+                  </span>
+                  {" "}
+                  will not forward until the remaining setup is finished.
+                </>
               ) : (
                 <>
                   InboxAnchor alias domain is not configured yet.
@@ -476,6 +498,21 @@ function SettingsPage() {
                 </>
               )}
             </div>
+            {managedAliasEnabled && !managedAliasReady ? (
+              <div className="rounded-md border border-warning/30 bg-warning/5 p-3 text-[11px] leading-5 text-warning space-y-2">
+                <p>
+                  Managed aliases are not live yet.
+                  {" "}
+                  {!managedAliasResolverConfigured ? "The backend resolver secret is missing. " : ""}
+                  {!managedAliasInboundReady ? "Cloudflare inbound routing still needs to be marked ready. " : ""}
+                </p>
+                {managedAliasBlockers.map((item) => (
+                  <p key={item}>
+                    {item}
+                  </p>
+                ))}
+              </div>
+            ) : null}
             {!managedAliasEnabled ? (
               <div className="rounded-md border border-warning/30 bg-warning/5 p-3 text-[11px] leading-5 text-warning">
                 To get product-owned aliases like
@@ -513,12 +550,18 @@ function SettingsPage() {
                 </div>
                 <Button
                   onClick={handleGenerateAlias}
-                  disabled={aliasLoading || (!managedAliasEnabled && !plusFallbackEnabled)}
+                  disabled={
+                    aliasLoading ||
+                    (managedAliasEnabled && !managedAliasReady) ||
+                    (!managedAliasEnabled && !plusFallbackEnabled)
+                  }
                 >
                   {aliasLoading
                     ? "Generating..."
-                    : managedAliasEnabled
+                    : managedAliasEnabled && managedAliasReady
                       ? "Generate InboxAnchor alias"
+                      : managedAliasEnabled
+                        ? "Managed alias setup incomplete"
                       : plusFallbackEnabled
                         ? "Generate Gmail fallback alias"
                         : "Managed alias domain required"}