From c9ae883b4b46edf37556abfd7b3adfc174713aa2 Mon Sep 17 00:00:00 2001 From: Prasiddhi Shetty Date: Mon, 6 Jul 2026 16:13:56 +0530 Subject: [PATCH] Implement Diagnostics and Run Pipeline button functionality --- backend/src/server.ts | 13 ++++-- frontend/src/App.tsx | 105 +++++++++++++++++++++++++++++++++++++++++- 2 files changed, 112 insertions(+), 6 deletions(-) diff --git a/backend/src/server.ts b/backend/src/server.ts index a09d9a7..88a1902 100644 --- a/backend/src/server.ts +++ b/backend/src/server.ts @@ -6,7 +6,7 @@ dotenv.config({ path: path.resolve(__dirname, '../.env') }); import express, { Request, Response } from 'express'; import cookieParser from 'cookie-parser'; -import { PrismaClient } from '@prisma/client'; +import { PrismaClient,Prisma } from '@prisma/client'; import { z } from 'zod'; import { AuthService } from './services/auth.service'; import { @@ -28,10 +28,14 @@ import { WebSocketService } from './services/websocket.service'; import { TelegramBotService } from './services/telegram-bot.service'; import { TelegramNotificationService } from './services/telegram-notification.service'; +console.log("1"); const app = express(); +console.log("2"); const prisma = new PrismaClient(); +console.log("3"); const PORT = process.env.PORT || 8000; +console.log("4"); app.use((req, res, next) => { const origin = req.headers.origin; if ( @@ -774,7 +778,7 @@ app.get( const hooks = await prisma.webhookEndpoint.findMany({ where: { userId }, }); - const formatted = hooks.map((h) => ({ + const formatted = hooks.map((h: (typeof hooks)[number]) => ({ id: h.id, targetUrl: h.targetUrl, events: JSON.parse(h.events), @@ -1297,7 +1301,7 @@ app.put( validation.data; // Run delete-then-create inside a transaction - const updatedRule = await prisma.$transaction(async (tx) => { + const updatedRule = await prisma.$transaction(async (tx:Prisma.TransactionClient) => { await tx.ruleCondition.deleteMany({ where: { ruleId: id } }); await tx.ruleAction.deleteMany({ where: { ruleId: id } }); @@ -1411,8 +1415,9 @@ app.get('/api/auth/google', (req: Request, res: Response) => { }); // Start Server - +console.log("Reached app.listen"); const server = app.listen(PORT, () => { + console.log("Server started"); logger.info(`Auth service running on port ${PORT}`); // Register EventBus fallback handler AFTER server is listening diff --git a/frontend/src/App.tsx b/frontend/src/App.tsx index 927de5d..702355a 100644 --- a/frontend/src/App.tsx +++ b/frontend/src/App.tsx @@ -32,6 +32,7 @@ import { Radio, Bell, } from 'lucide-react'; +import { Modal } from './components/Modal'; const API_BASE = import.meta.env.VITE_API_BASE_URL || 'http://localhost:8000'; @@ -77,6 +78,36 @@ const MetricCard: React.FC = ({ // Extracted Dashboard Component to protect via ProtectedRoute const DashboardContent: React.FC = () => { + const [isDiagnosticOpen, setIsDiagnosticOpen] = useState(false); + const [diagnosticData, setDiagnosticData] = useState(null); + const [loading, setLoading] = useState(false); + + const handleDiagnostic = async () => { + try { + setLoading(true); + + const response = await fetch(`${API_BASE}/api/health`); + + if (!response.ok) { + throw new Error('Failed to fetch diagnostics'); + } + + const data = await response.json(); + + setDiagnosticData(data); + setIsDiagnosticOpen(true); + } catch (err) { + console.error(err); + } finally { + setLoading(false); + } + }; + + const [isPipelineOpen, setIsPipelineOpen] = useState(false); + const handleRunPipeline = () => { + setIsPipelineOpen(true); + }; + const location = useLocation(); const navigate = useNavigate(); const { socket } = useSocket(); @@ -776,10 +807,16 @@ const DashboardContent: React.FC = () => {

- - @@ -898,6 +935,70 @@ const DashboardContent: React.FC = () => {
+ + setIsPipelineOpen(false)} + title="InboxOS Pipeline" + className="max-w-3xl w-full" + > +
+

+ This illustrates how an email moves through the InboxOS processing + pipeline. +

+ + {[ + { + title: 'Layer 1 — Inbox Ingestion', + description: + 'Connects to Gmail, Outlook, or IMAP and converts incoming emails into a standard internal format.', + }, + { + title: 'Layer 2 — Intelligence Engine', + description: + 'AI classifies the email, determines its importance, extracts entities, deadlines, and action items.', + }, + { + title: 'Layer 3 — Decision Engine', + description: + 'Rules combined with AI determine what should happen next, such as notifications, tasks, or calendar events.', + }, + { + title: 'Layer 4 — Action Engine', + description: + 'Executes the selected action, such as creating tasks, sending WhatsApp alerts, or labeling emails.', + }, + { + title: 'Layer 5 — Delivery Channels', + description: + 'Sends the final output to Slack, Telegram, WhatsApp, the dashboard, or other configured channels.', + }, + ].map((layer, index) => ( +
+
{layer.title}
+ +
+ {layer.description} +
+
+ ))} + +
+
+ Pipeline Flow +
+ +
+ Raw Email → Inbox Ingestion → Intelligence Engine → Decision + Engine → Action Engine → Delivery Channels +
+
+
+ ); };