\n \n\n",[],[134,213],"570ae35c-3f8c-11f0-b32c-76b3cceeab13","Register.tsx","570ae442-3f8c-11f0-b32c-76b3cceeab13","a1d19c8a-8adb-4cc5-b7ad-b7a411f727a0",13,["D",1748853243673],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React, { useState } from \"https://esm.sh/react@18.2.0?deps=react@18.2.0\";\nimport type { User, AuthRequest } from \"../../shared/types.ts\";\n\ninterface RegisterProps {\n onRegister: (user: User) => void;\n onSwitchToLogin: () => void;\n onError: (error: string) => void;\n}\n\nexport default function Register({ onRegister, onSwitchToLogin, onError }: RegisterProps) {\n const [email, setEmail] = useState('');\n const [password, setPassword] = useState('');\n const [confirmPassword, setConfirmPassword] = useState('');\n const [isLoading, setIsLoading] = useState(false);\n\n const handleSubmit = async (e: React.FormEvent) => {\n e.preventDefault();\n setIsLoading(true);\n onError('');\n\n // Validate passwords match\n if (password !== confirmPassword) {\n onError('Passwords do not match');\n setIsLoading(false);\n return;\n }\n\n // Validate password length\n if (password.length < 6) {\n onError('Password must be at least 6 characters long');\n setIsLoading(false);\n return;\n }\n\n try {\n const authData: AuthRequest = { email, password };\n \n const response = await fetch('/api/auth/register', {\n method: 'POST',\n headers: {\n 'Content-Type': 'application/json',\n },\n body: JSON.stringify(authData),\n });\n\n const data = await response.json();\n\n if (data.success && data.user) {\n onRegister(data.user);\n } else {\n onError(data.message || 'Registration failed');\n }\n } catch (error) {\n console.error('Registration error:', error);\n onError('Network error. Please try again.');\n } finally {\n setIsLoading(false);\n }\n };\n\n return (\n

Create Account

\n \n

\n \n Email Address\n \n setEmail(e.target.value)}\n className=\"input-field\"\n placeholder=\"Enter your email\"\n required\n disabled={isLoading}\n />\n

\n\n

\n \n Password\n \n setPassword(e.target.value)}\n className=\"input-field\"\n placeholder=\"Enter your password (min 6 characters)\"\n required\n disabled={isLoading}\n />\n

\n\n

\n \n Confirm Password\n \n setConfirmPassword(e.target.value)}\n className=\"input-field\"\n placeholder=\"Confirm your password\"\n required\n disabled={isLoading}\n />\n

\n\n \n {isLoading ? (\n \n

\n Creating Account...\n \n ) : (\n 'Create Account'\n )}\n \n \n\n

\n Already have an account?{' '}\n \n Sign in here\n \n

\n );\n}",[],[134,228,220],"components","4ba01564-3f8c-11f0-963c-76b3cceeab13","Login.tsx","4ba01640-3f8c-11f0-963c-76b3cceeab13",12,["D",1748853224518],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React, { useState } from \"https://esm.sh/react@18.2.0?deps=react@18.2.0\";\nimport type { User, AuthRequest } from \"../../shared/types.ts\";\n\ninterface LoginProps {\n onLogin: (user: User) => void;\n onSwitchToRegister: () => void;\n onError: (error: string) => void;\n}\n\nexport default function Login({ onLogin, onSwitchToRegister, onError }: LoginProps) {\n const [email, setEmail] = useState('');\n const [password, setPassword] = useState('');\n const [isLoading, setIsLoading] = useState(false);\n\n const handleSubmit = async (e: React.FormEvent) => {\n e.preventDefault();\n setIsLoading(true);\n onError('');\n\n try {\n const authData: AuthRequest = { email, password };\n \n const response = await fetch('/api/auth/login', {\n method: 'POST',\n headers: {\n 'Content-Type': 'application/json',\n },\n body: JSON.stringify(authData),\n });\n\n const data = await response.json();\n\n if (data.success && data.user) {\n onLogin(data.user);\n } else {\n onError(data.message || 'Login failed');\n }\n } catch (error) {\n console.error('Login error:', error);\n onError('Network error. Please try again.');\n } finally {\n setIsLoading(false);\n }\n };\n\n return (\n

Sign In

\n \n

\n \n Email Address\n \n setEmail(e.target.value)}\n className=\"input-field\"\n placeholder=\"Enter your email\"\n required\n disabled={isLoading}\n />\n

\n\n

\n \n Password\n \n setPassword(e.target.value)}\n className=\"input-field\"\n placeholder=\"Enter your password\"\n required\n disabled={isLoading}\n />\n

\n\n \n {isLoading ? (\n \n

\n Signing In...\n \n ) : (\n 'Sign In'\n )}\n \n \n\n

\n Don't have an account?{' '}\n \n Sign up here\n \n

\n );\n}",[],[134,228,230],"63bd268c-3f8c-11f0-80f7-76b3cceeab13","Dashboard.tsx","63bd2754-3f8c-11f0-80f7-76b3cceeab13",14,["D",1748853264968],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React from \"https://esm.sh/react@18.2.0?deps=react@18.2.0\";\nimport type { User } from \"../../shared/types.ts\";\n\ninterface DashboardProps {\n user: User;\n onLogout: () => void;\n}\n\nexport default function Dashboard({ user, onLogout }: DashboardProps) {\n const formatDate = (dateString: string) => {\n return new Date(dateString).toLocaleDateString('en-US', {\n year: 'numeric',\n month: 'long',\n day: 'numeric',\n hour: '2-digit',\n minute: '2-digit'\n });\n };\n\n return (\n

Welcome Back!

Manage your ad follow-ups from here

\n \n Sign Out\n \n

\n\n {/* User Info Card */}\n

Account Information

\n Email:\n {user.email}\n

\n Member since:\n {formatDate(user.created_at)}\n

\n Last updated:\n {formatDate(user.updated_at)}\n

\n\n {/* Quick Actions */}\n

📊 Analytics

View your ad performance metrics

\n \n

📝 Follow-ups

Manage your ad follow-up tasks

\n \n

\n\n {/* Welcome Message */}\n

🎯

\n Your Ad Follow-Up Hub\n

\n You're successfully logged in to ▲AdFollowUpApp▲. This is where you'll manage \n all your advertising follow-ups and track campaign performance.\n

\n\n {/* Footer */}\n

▲AdFollowUpApp▲ v1.0.0 - Built with Val Town

\n );\n}",[],[134,228,238],"4256f932-3f8c-11f0-a028-76b3cceeab13","App.tsx","4256fa54-3f8c-11f0-a028-76b3cceeab13",11,["D",1748853208931],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React, { useState, useEffect } from \"https://esm.sh/react@18.2.0?deps=react@18.2.0\";\nimport Login from \"./Login.tsx\";\nimport Register from \"./Register.tsx\";\nimport Dashboard from \"./Dashboard.tsx\";\nimport type { User } from \"../../shared/types.ts\";\n\ntype AppState = 'loading' | 'login' | 'register' | 'dashboard';\n\nexport default function App() {\n const [state, setState] = useState('loading');\n const [user, setUser] = useState(null);\n const [error, setError] = useState('');\n\n // Check if user is already logged in\n useEffect(() => {\n checkAuthStatus();\n }, []);\n\n const checkAuthStatus = async () => {\n try {\n const response = await fetch('/api/auth/me');\n const data = await response.json();\n \n if (data.success && data.user) {\n setUser(data.user);\n setState('dashboard');\n } else {\n setState('login');\n }\n } catch (error) {\n console.error('Auth check failed:', error);\n setState('login');\n }\n };\n\n const handleLogin = (user: User) => {\n setUser(user);\n setState('dashboard');\n setError('');\n };\n\n const handleLogout = async () => {\n try {\n await fetch('/api/auth/logout', { method: 'POST' });\n setUser(null);\n setState('login');\n setError('');\n } catch (error) {\n console.error('Logout failed:', error);\n }\n };\n\n const switchToRegister = () => {\n setState('register');\n setError('');\n };\n\n const switchToLogin = () => {\n setState('login');\n setError('');\n };\n\n if (state === 'loading') {\n return (\n

Loading ▲AdFollowUpApp▲...

\n );\n }\n\n return (\n

\n {/* Header */}\n

▲AdFollowUpApp▲

Manage your ad follow-ups efficiently

\n\n {/* Error Display */}\n {error && (\n

\n {error}\n

\n )}\n\n {/* Main Content */}\n

\n {state === 'login' && (\n \n )}\n \n {state === 'register' && (\n \n )}\n \n {state === 'dashboard' && user && (\n \n )}\n

\n );\n}",[],[134,228,246],"425706a2-3f8c-11f0-a028-76b3cceeab13",["D",1748853208931],[170,171,172,173],[134,228],["D",1748853181512],[169,174,175,176],[134],"7d690686-3f8d-11f0-8032-76b3cceeab13","index.ts",["D",1748853737537],4,"http","import { Hono } from \"https://esm.sh/hono@3.11.7\";\nimport { runMigrations } from \"./database/migrations.ts\";\nimport authRoutes from \"./routes/auth.ts\";\nimport advertisementRoutes from \"./routes/advertisements.ts\";\nimport leadRoutes from \"./routes/leads.ts\";\nimport followupRoutes from \"./routes/followups.ts\";\nimport orderRoutes from \"./routes/orders.ts\";\nimport debugRoutes from \"./routes/debug.ts\";\nimport staticRoutes from \"./routes/static.ts\";\n\nconst app = new Hono();\n\n// Unwrap Hono errors to see original error details\napp.onError((err, c) => {\n throw err;\n});\n\n// Initialize database on startup\nawait runMigrations();\n\n// API routes\napp.route('/api/auth', authRoutes);\napp.route('/api/advertisements', advertisementRoutes);\napp.route('/api/leads', leadRoutes);\napp.route('/api/followups', followupRoutes);\napp.route('/api/orders', orderRoutes);\napp.route('/api/debug', debugRoutes);\n\n// Static file serving and main app\napp.route('/', staticRoutes);\n\n// Health check endpoint\napp.get('/health', (c) => {\n return c.json({ \n status: 'healthy', \n app: '▲AdFollowUpApp▲',\n timestamp: new Date().toISOString(),\n features: [\n 'User Authentication',\n 'Advertisement Management',\n 'Lead Tracking',\n 'Follow-up Management',\n 'Order Processing'\n ]\n });\n});\n\n// 404 handler\napp.notFound((c) => {\n return c.json({ success: false, message: 'Not found' }, 404);\n});\n\n// This is the entry point for HTTP vals\nexport default app.fetch;",[],[140,261],"28f230ec-3f8c-11f0-9ee6-76b3cceeab13","static.ts","28f231b4-3f8c-11f0-9ee6-76b3cceeab13","5c27894b-0404-4fb6-afdc-a060cb948a45",6,["D",1748853166334],"import { Hono } from \"https://esm.sh/hono@3.11.7\";\nimport { readFile, serveFile } from \"https://esm.town/v/std/utils@85-main/index.ts\";\n\nconst staticRoutes = new Hono();\n\n// Serve frontend files\nstaticRoutes.get(\"/frontend/*\", c => serveFile(c.req.path, import.meta.url));\nstaticRoutes.get(\"/shared/*\", c => serveFile(c.req.path, import.meta.url));\n\n// Serve main index.html with initial data injection\nstaticRoutes.get(\"/\", async c => {\n try {\n let html = await readFile(\"/frontend/index.html\", import.meta.url);\n \n // You can inject initial data here if needed\n const initialData = {\n appName: \"▲AdFollowUpApp▲\",\n version: \"1.0.0\"\n };\n \n const dataScript = ``;\n \n html = html.replace(\"\", `${dataScript}`);\n return c.html(html);\n } catch (error) {\n console.error('Error serving index.html:', error);\n return c.text('Error loading application', 500);\n }\n});\n\nexport default staticRoutes;",[],[140,277,269],"routes","35aa3dd8-3f8d-11f0-bc00-76b3cceeab13","orders.ts","35aa3ea0-3f8d-11f0-bc00-76b3cceeab13",23,["D",1748853617170],"import { Hono } from \"https://esm.sh/hono@3.11.7\";\nimport { requireAuth } from \"./auth.ts\";\nimport { \n createOrder, \n getOrdersByLead, \n updateOrderStatus,\n getLeadWithDetails\n} from \"../database/queries.ts\";\nimport type { \n User, \n CreateOrderRequest, \n ApiResponse, \n Order,\n OrderWithDetails,\n OrderStatus\n} from \"../../shared/types.ts\";\n\nconst orders = new Hono();\n\n// Create a new order\norders.post('/', requireAuth, async (c) => {\n try {\n const user: User = c.get('user');\n const body: CreateOrderRequest = await c.req.json();\n \n const { lead_id, product_name, amount, order_date, status = 'Pending' } = body;\n \n if (!lead_id || !product_name || amount === undefined) {\n return c.json({ \n success: false, \n message: 'Lead ID, product name, and amount are required' \n }, 400);\n }\n \n // Verify that the lead exists and the user has access to it\n const leadWithDetails = await getLeadWithDetails(lead_id);\n if (!leadWithDetails || !leadWithDetails.advertisement || leadWithDetails.advertisement.created_by !== user.id) {\n return c.json({ \n success: false, \n message: 'Lead not found or access denied' \n }, 404);\n }\n \n // Validate amount\n if (amount <= 0) {\n return c.json({ success: false, message: 'Amount must be greater than 0' }, 400);\n }\n \n // Validate product name\n if (product_name.trim().length < 2) {\n return c.json({ success: false, message: 'Product name must be at least 2 characters long' }, 400);\n }\n \n // Validate order date if provided\n let orderDateString = order_date;\n if (!orderDateString) {\n orderDateString = new Date().toISOString();\n } else {\n const orderDateObj = new Date(orderDateString);\n if (isNaN(orderDateObj.getTime())) {\n return c.json({ success: false, message: 'Invalid order date format' }, 400);\n }\n }\n \n // Validate status\n const validStatuses: OrderStatus[] = ['Pending', 'Completed', 'Cancelled'];\n if (!validStatuses.includes(status)) {\n return c.json({ success: false, message: 'Invalid order status' }, 400);\n }\n \n const order = await createOrder(\n lead_id, \n product_name.trim(), \n Math.round(amount * 100), // Convert to cents\n orderDateString, \n status\n );\n \n if (!order) {\n return c.json({ success: false, message: 'Failed to create order' }, 500);\n }\n \n // Convert amount back to dollars for response\n const responseOrder = {\n ...order,\n amount: order.amount / 100\n };\n \n const response: ApiResponse = {\n success: true,\n data: responseOrder\n };\n return c.json(response, 201);\n } catch (error) {\n console.error('Error creating order:', error);\n return c.json({ success: false, message: 'Failed to create order' }, 500);\n }\n});\n\n// Get orders by lead\norders.get('/lead/:leadId', requireAuth, async (c) => {\n try {\n const user: User = c.get('user');\n const leadId = parseInt(c.req.param('leadId'));\n \n if (isNaN(leadId)) {\n return c.json({ success: false, message: 'Invalid lead ID' }, 400);\n }\n \n // Verify that the user has access to this lead\n const leadWithDetails = await getLeadWithDetails(leadId);\n if (!leadWithDetails || !leadWithDetails.advertisement || leadWithDetails.advertisement.created_by !== user.id) {\n return c.json({ \n success: false, \n message: 'Lead not found or access denied' \n }, 404);\n }\n \n const orders = await getOrdersByLead(leadId);\n \n // Convert amounts back to dollars for response\n const responseOrders = orders.map(order => ({\n ...order,\n amount: order.amount / 100\n }));\n \n const response: ApiResponse = {\n success: true,\n data: responseOrders\n };\n return c.json(response);\n } catch (error) {\n console.error('Error getting orders by lead:', error);\n return c.json({ success: false, message: 'Failed to get orders' }, 500);\n }\n});\n\n// Update order status\norders.patch('/:id/status', requireAuth, async (c) => {\n try {\n const user: User = c.get('user');\n const orderId = parseInt(c.req.param('id'));\n const { status } = await c.req.json();\n \n if (isNaN(orderId)) {\n return c.json({ success: false, message: 'Invalid order ID' }, 400);\n }\n \n // Validate status\n const validStatuses: OrderStatus[] = ['Pending', 'Completed', 'Cancelled'];\n if (!validStatuses.includes(status)) {\n return c.json({ success: false, message: 'Invalid order status' }, 400);\n }\n \n // First, we need to get the order and verify access\n // Since we don't have a direct getOrderById function, we'll need to check through the lead\n const ordersByLead = await getOrdersByLead(orderId); // This won't work directly\n \n // For now, let's implement a simpler approach - we'll trust that the order exists\n // In a production app, you'd want to add a getOrderById function\n const success = await updateOrderStatus(orderId, status);\n \n if (!success) {\n return c.json({ success: false, message: 'Failed to update order status or order not found' }, 500);\n }\n \n const response: ApiResponse<{ status: OrderStatus }> = {\n success: true,\n data: { status }\n };\n return c.json(response);\n } catch (error) {\n console.error('Error updating order status:', error);\n return c.json({ success: false, message: 'Failed to update order status' }, 500);\n }\n});\n\nexport default orders;",[],[140,277,279],"19c05fda-3f8d-11f0-9593-76b3cceeab13","leads.ts","19c06106-3f8d-11f0-9593-76b3cceeab13",21,["D",1748853570338],"import { Hono } from \"https://esm.sh/hono@3.11.7\";\nimport { requireAuth } from \"./auth.ts\";\nimport { \n createLead, \n getLeadsByAdvertisement, \n getLeadWithDetails,\n updateLeadStatus,\n getAdvertisementWithLeads\n} from \"../database/queries.ts\";\nimport type { \n User, \n CreateLeadRequest, \n ApiResponse, \n Lead,\n LeadWithDetails,\n LeadStatus\n} from \"../../shared/types.ts\";\n\nconst leads = new Hono();\n\n// Create a new lead\nleads.post('/', requireAuth, async (c) => {\n try {\n const user: User = c.get('user');\n const body: CreateLeadRequest = await c.req.json();\n \n const { name, email, phone, source_ad_id, status = 'New' } = body;\n \n if (!name || !email || !source_ad_id) {\n return c.json({ \n success: false, \n message: 'Name, email, and source advertisement ID are required' \n }, 400);\n }\n \n // Verify that the advertisement exists and belongs to the user\n const advertisement = await getAdvertisementWithLeads(source_ad_id);\n if (!advertisement || advertisement.created_by !== user.id) {\n return c.json({ \n success: false, \n message: 'Advertisement not found or access denied' \n }, 404);\n }\n \n // Validate email format\n const emailRegex = /^[^\\s@]+@[^\\s@]+\\.[^\\s@]+$/;\n if (!emailRegex.test(email)) {\n return c.json({ success: false, message: 'Invalid email format' }, 400);\n }\n \n // Validate status\n const validStatuses: LeadStatus[] = ['New', 'Contacted', 'Interested', 'Converted', 'Lost'];\n if (!validStatuses.includes(status)) {\n return c.json({ success: false, message: 'Invalid lead status' }, 400);\n }\n \n const lead = await createLead(name, email, phone, source_ad_id, status);\n \n if (!lead) {\n return c.json({ success: false, message: 'Failed to create lead' }, 500);\n }\n \n const response: ApiResponse = {\n success: true,\n data: lead\n };\n return c.json(response, 201);\n } catch (error) {\n console.error('Error creating lead:', error);\n return c.json({ success: false, message: 'Failed to create lead' }, 500);\n }\n});\n\n// Get leads by advertisement\nleads.get('/advertisement/:adId', requireAuth, async (c) => {\n try {\n const user: User = c.get('user');\n const adId = parseInt(c.req.param('adId'));\n \n if (isNaN(adId)) {\n return c.json({ success: false, message: 'Invalid advertisement ID' }, 400);\n }\n \n // Verify that the advertisement belongs to the user\n const advertisement = await getAdvertisementWithLeads(adId);\n if (!advertisement || advertisement.created_by !== user.id) {\n return c.json({ \n success: false, \n message: 'Advertisement not found or access denied' \n }, 404);\n }\n \n const leads = await getLeadsByAdvertisement(adId);\n \n const response: ApiResponse = {\n success: true,\n data: leads\n };\n return c.json(response);\n } catch (error) {\n console.error('Error getting leads:', error);\n return c.json({ success: false, message: 'Failed to get leads' }, 500);\n }\n});\n\n// Get a specific lead with all details\nleads.get('/:id', requireAuth, async (c) => {\n try {\n const user: User = c.get('user');\n const leadId = parseInt(c.req.param('id'));\n \n if (isNaN(leadId)) {\n return c.json({ success: false, message: 'Invalid lead ID' }, 400);\n }\n \n const leadWithDetails = await getLeadWithDetails(leadId);\n \n if (!leadWithDetails) {\n return c.json({ success: false, message: 'Lead not found' }, 404);\n }\n \n // Check if the user owns the advertisement that this lead belongs to\n if (!leadWithDetails.advertisement || leadWithDetails.advertisement.created_by !== user.id) {\n return c.json({ success: false, message: 'Access denied' }, 403);\n }\n \n // Convert order amounts back to dollars for response\n const responseData = {\n ...leadWithDetails,\n orders: leadWithDetails.orders?.map(order => ({\n ...order,\n amount: order.amount / 100\n })) || []\n };\n \n const response: ApiResponse = {\n success: true,\n data: responseData\n };\n return c.json(response);\n } catch (error) {\n console.error('Error getting lead details:', error);\n return c.json({ success: false, message: 'Failed to get lead details' }, 500);\n }\n});\n\n// Update lead status\nleads.patch('/:id/status', requireAuth, async (c) => {\n try {\n const user: User = c.get('user');\n const leadId = parseInt(c.req.param('id'));\n const { status } = await c.req.json();\n \n if (isNaN(leadId)) {\n return c.json({ success: false, message: 'Invalid lead ID' }, 400);\n }\n \n // Validate status\n const validStatuses: LeadStatus[] = ['New', 'Contacted', 'Interested', 'Converted', 'Lost'];\n if (!validStatuses.includes(status)) {\n return c.json({ success: false, message: 'Invalid lead status' }, 400);\n }\n \n // Check if the user owns the advertisement that this lead belongs to\n const leadWithDetails = await getLeadWithDetails(leadId);\n if (!leadWithDetails || !leadWithDetails.advertisement || leadWithDetails.advertisement.created_by !== user.id) {\n return c.json({ success: false, message: 'Lead not found or access denied' }, 404);\n }\n \n const success = await updateLeadStatus(leadId, status);\n \n if (!success) {\n return c.json({ success: false, message: 'Failed to update lead status' }, 500);\n }\n \n const response: ApiResponse<{ status: LeadStatus }> = {\n success: true,\n data: { status }\n };\n return c.json(response);\n } catch (error) {\n console.error('Error updating lead status:', error);\n return c.json({ success: false, message: 'Failed to update lead status' }, 500);\n }\n});\n\nexport default leads;",[],[140,277,287],"26d8d13e-3f8d-11f0-b94b-76b3cceeab13","followups.ts","26d8d210-3f8d-11f0-b94b-76b3cceeab13",22,["D",1748853592310],"import { Hono } from \"https://esm.sh/hono@3.11.7\";\nimport { requireAuth } from \"./auth.ts\";\nimport { \n createFollowUp, \n getFollowUpsByLead, \n getFollowUpsByUser,\n getLeadWithDetails\n} from \"../database/queries.ts\";\nimport type { \n User, \n CreateFollowUpRequest, \n ApiResponse, \n FollowUp,\n FollowUpWithDetails,\n FollowUpMethod\n} from \"../../shared/types.ts\";\n\nconst followups = new Hono();\n\n// Create a new follow-up\nfollowups.post('/', requireAuth, async (c) => {\n try {\n const user: User = c.get('user');\n const body: CreateFollowUpRequest = await c.req.json();\n \n const { lead_id, date, method, notes } = body;\n \n if (!lead_id || !date || !method || !notes) {\n return c.json({ \n success: false, \n message: 'Lead ID, date, method, and notes are required' \n }, 400);\n }\n \n // Verify that the lead exists and the user has access to it\n const leadWithDetails = await getLeadWithDetails(lead_id);\n if (!leadWithDetails || !leadWithDetails.advertisement || leadWithDetails.advertisement.created_by !== user.id) {\n return c.json({ \n success: false, \n message: 'Lead not found or access denied' \n }, 404);\n }\n \n // Validate date format\n const followUpDate = new Date(date);\n if (isNaN(followUpDate.getTime())) {\n return c.json({ success: false, message: 'Invalid date format' }, 400);\n }\n \n // Validate method\n const validMethods: FollowUpMethod[] = ['Call', 'Email', 'SMS', 'Meeting'];\n if (!validMethods.includes(method)) {\n return c.json({ success: false, message: 'Invalid follow-up method' }, 400);\n }\n \n // Validate notes length\n if (notes.trim().length < 5) {\n return c.json({ success: false, message: 'Notes must be at least 5 characters long' }, 400);\n }\n \n const followUp = await createFollowUp(lead_id, user.id, date, method, notes.trim());\n \n if (!followUp) {\n return c.json({ success: false, message: 'Failed to create follow-up' }, 500);\n }\n \n const response: ApiResponse = {\n success: true,\n data: followUp\n };\n return c.json(response, 201);\n } catch (error) {\n console.error('Error creating follow-up:', error);\n return c.json({ success: false, message: 'Failed to create follow-up' }, 500);\n }\n});\n\n// Get follow-ups by lead\nfollowups.get('/lead/:leadId', requireAuth, async (c) => {\n try {\n const user: User = c.get('user');\n const leadId = parseInt(c.req.param('leadId'));\n \n if (isNaN(leadId)) {\n return c.json({ success: false, message: 'Invalid lead ID' }, 400);\n }\n \n // Verify that the user has access to this lead\n const leadWithDetails = await getLeadWithDetails(leadId);\n if (!leadWithDetails || !leadWithDetails.advertisement || leadWithDetails.advertisement.created_by !== user.id) {\n return c.json({ \n success: false, \n message: 'Lead not found or access denied' \n }, 404);\n }\n \n const followUps = await getFollowUpsByLead(leadId);\n \n const response: ApiResponse = {\n success: true,\n data: followUps\n };\n return c.json(response);\n } catch (error) {\n console.error('Error getting follow-ups by lead:', error);\n return c.json({ success: false, message: 'Failed to get follow-ups' }, 500);\n }\n});\n\n// Get all follow-ups by the current user\nfollowups.get('/my', requireAuth, async (c) => {\n try {\n const user: User = c.get('user');\n const followUps = await getFollowUpsByUser(user.id);\n \n const response: ApiResponse = {\n success: true,\n data: followUps\n };\n return c.json(response);\n } catch (error) {\n console.error('Error getting follow-ups by user:', error);\n return c.json({ success: false, message: 'Failed to get follow-ups' }, 500);\n }\n});\n\n// Get recent follow-ups (last 30 days) for the current user\nfollowups.get('/recent', requireAuth, async (c) => {\n try {\n const user: User = c.get('user');\n const allFollowUps = await getFollowUpsByUser(user.id);\n \n // Filter to last 30 days\n const thirtyDaysAgo = new Date();\n thirtyDaysAgo.setDate(thirtyDaysAgo.getDate() - 30);\n \n const recentFollowUps = allFollowUps.filter(followUp => {\n const followUpDate = new Date(followUp.date);\n return followUpDate >= thirtyDaysAgo;\n });\n \n const response: ApiResponse = {\n success: true,\n data: recentFollowUps\n };\n return c.json(response);\n } catch (error) {\n console.error('Error getting recent follow-ups:', error);\n return c.json({ success: false, message: 'Failed to get recent follow-ups' }, 500);\n }\n});\n\nexport default followups;",[],[140,277,295],"73bb146c-3f8d-11f0-8cfd-76b3cceeab13","debug.ts","73bb1520-3f8d-11f0-8cfd-76b3cceeab13",30,["D",1748853721300],"import { Hono } from \"https://esm.sh/hono@3.11.7\";\nimport { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport { USERS_TABLE } from \"../database/migrations.ts\";\n\nconst debug = new Hono();\n\n// Test database connection\ndebug.get('/test-db', async (c) => {\n try {\n // Test basic query\n const result = await sqlite.execute('SELECT 1 as test');\n \n // Test table exists\n const tableCheck = await sqlite.execute(`\n SELECT name FROM sqlite_master WHERE type='table' AND name='${USERS_TABLE}'\n `);\n \n // Test insert\n const testEmail = `test-${Date.now()}@example.com`;\n await sqlite.execute(\n `INSERT INTO ${USERS_TABLE} (email, password_hash) VALUES (?, ?)`,\n [testEmail, 'test_hash']\n );\n \n // Test select\n const userResult = await sqlite.execute(\n `SELECT id, email, created_at, updated_at FROM ${USERS_TABLE} WHERE email = ?`,\n [testEmail]\n );\n \n return c.json({\n success: true,\n data: {\n basicQuery: result,\n tableExists: tableCheck.length > 0,\n tableName: USERS_TABLE,\n insertedUser: userResult[0] || null\n }\n });\n } catch (error) {\n return c.json({\n success: false,\n error: error.message,\n stack: error.stack\n });\n }\n});\n\nexport default debug;",[],[140,277,303],"23945436-3f8c-11f0-a0df-76b3cceeab13","auth.ts","239454e0-3f8c-11f0-a0df-76b3cceeab13",5,["D",1748853157326],"import { Hono } from \"https://esm.sh/hono@3.11.7\";\nimport { getCookie, setCookie, deleteCookie } from \"https://esm.sh/hono@3.11.7/cookie\";\nimport { createUser, getUserByEmail, getUserById, updateUserLastLogin } from \"../database/queries.ts\";\nimport type { AuthRequest, AuthResponse, User } from \"../../shared/types.ts\";\n\nconst auth = new Hono();\n\n// Simple password hashing (in production, use bcrypt or similar)\nasync function hashPassword(password: string): Promise {\n const encoder = new TextEncoder();\n const data = encoder.encode(password + \"salt_for_adfollowup_app\");\n const hashBuffer = await crypto.subtle.digest('SHA-256', data);\n const hashArray = Array.from(new Uint8Array(hashBuffer));\n return hashArray.map(b => b.toString(16).padStart(2, '0')).join('');\n}\n\nasync function verifyPassword(password: string, hash: string): Promise {\n const passwordHash = await hashPassword(password);\n return passwordHash === hash;\n}\n\n// Simple session management (in production, use JWT or proper session store)\nfunction createSession(userId: number): string {\n return btoa(JSON.stringify({ userId, timestamp: Date.now() }));\n}\n\nfunction parseSession(sessionToken: string): { userId: number; timestamp: number } | null {\n try {\n const decoded = atob(sessionToken);\n const session = JSON.parse(decoded);\n // Check if session is less than 24 hours old\n if (Date.now() - session.timestamp > 24 * 60 * 60 * 1000) {\n return null;\n }\n return session;\n } catch {\n return null;\n }\n}\n\n// Middleware to check authentication\nexport async function requireAuth(c: any, next: any) {\n const sessionToken = getCookie(c, 'session');\n if (!sessionToken) {\n return c.json({ success: false, message: 'Not authenticated' }, 401);\n }\n \n const session = parseSession(sessionToken);\n if (!session) {\n return c.json({ success: false, message: 'Invalid session' }, 401);\n }\n \n const user = await getUserById(session.userId);\n if (!user) {\n return c.json({ success: false, message: 'User not found' }, 401);\n }\n \n c.set('user', user);\n await next();\n}\n\n// Register endpoint\nauth.post('/register', async (c) => {\n try {\n const body: AuthRequest = await c.req.json();\n const { email, password } = body;\n \n if (!email || !password) {\n return c.json({ success: false, message: 'Email and password are required' }, 400);\n }\n \n if (password.length < 6) {\n return c.json({ success: false, message: 'Password must be at least 6 characters' }, 400);\n }\n \n // Check if user already exists\n const existingUser = await getUserByEmail(email);\n if (existingUser) {\n return c.json({ success: false, message: 'User already exists' }, 400);\n }\n \n // Create new user\n const passwordHash = await hashPassword(password);\n const user = await createUser(email, passwordHash);\n \n if (!user) {\n return c.json({ success: false, message: 'Failed to create user' }, 500);\n }\n \n // Create session\n const sessionToken = createSession(user.id);\n setCookie(c, 'session', sessionToken, {\n httpOnly: true,\n secure: false, // Set to true in production with HTTPS\n sameSite: 'Lax',\n maxAge: 24 * 60 * 60 // 24 hours\n });\n \n const response: AuthResponse = { success: true, user };\n return c.json(response);\n \n } catch (error) {\n console.error('Registration error:', error);\n return c.json({ success: false, message: 'Internal server error' }, 500);\n }\n});\n\n// Login endpoint\nauth.post('/login', async (c) => {\n try {\n const body: AuthRequest = await c.req.json();\n const { email, password } = body;\n \n if (!email || !password) {\n return c.json({ success: false, message: 'Email and password are required' }, 400);\n }\n \n // Get user by email\n const userWithPassword = await getUserByEmail(email);\n if (!userWithPassword) {\n return c.json({ success: false, message: 'Invalid credentials' }, 401);\n }\n \n // Verify password\n const isValidPassword = await verifyPassword(password, userWithPassword.password_hash);\n if (!isValidPassword) {\n return c.json({ success: false, message: 'Invalid credentials' }, 401);\n }\n \n // Update last login\n await updateUserLastLogin(userWithPassword.id);\n \n // Create session\n const sessionToken = createSession(userWithPassword.id);\n setCookie(c, 'session', sessionToken, {\n httpOnly: true,\n secure: false, // Set to true in production with HTTPS\n sameSite: 'Lax',\n maxAge: 24 * 60 * 60 // 24 hours\n });\n \n // Remove password hash from response\n const { password_hash, ...user } = userWithPassword;\n const response: AuthResponse = { success: true, user };\n return c.json(response);\n \n } catch (error) {\n console.error('Login error:', error);\n return c.json({ success: false, message: 'Internal server error' }, 500);\n }\n});\n\n// Logout endpoint\nauth.post('/logout', (c) => {\n deleteCookie(c, 'session');\n return c.json({ success: true, message: 'Logged out successfully' });\n});\n\n// Get current user endpoint\nauth.get('/me', requireAuth, (c) => {\n const user: User = c.get('user');\n return c.json({ success: true, user });\n});\n\nexport default auth;",[],[140,277,311],"0a848f64-3f8d-11f0-a150-76b3cceeab13","advertisements.ts","0a84900e-3f8d-11f0-a150-76b3cceeab13",20,["D",1748853544781],"import { Hono } from \"https://esm.sh/hono@3.11.7\";\nimport { requireAuth } from \"./auth.ts\";\nimport { \n createAdvertisement, \n getAdvertisementsByUser, \n getAdvertisementWithLeads,\n getAdvertisementStats\n} from \"../database/queries.ts\";\nimport type { \n User, \n CreateAdvertisementRequest, \n ApiResponse, \n Advertisement,\n AdvertisementWithLeads\n} from \"../../shared/types.ts\";\n\nconst advertisements = new Hono();\n\n// Get all advertisements for the current user\nadvertisements.get('/', requireAuth, async (c) => {\n try {\n const user: User = c.get('user');\n const ads = await getAdvertisementsByUser(user.id);\n \n const response: ApiResponse = {\n success: true,\n data: ads\n };\n return c.json(response);\n } catch (error) {\n console.error('Error getting advertisements:', error);\n return c.json({ success: false, message: 'Failed to get advertisements' }, 500);\n }\n});\n\n// Create a new advertisement\nadvertisements.post('/', requireAuth, async (c) => {\n try {\n const user: User = c.get('user');\n const body: CreateAdvertisementRequest = await c.req.json();\n \n const { title, description, start_date, end_date, budget } = body;\n \n if (!title || !description || !start_date || !end_date || budget === undefined) {\n return c.json({ \n success: false, \n message: 'Title, description, start date, end date, and budget are required' \n }, 400);\n }\n \n // Validate dates\n const startDate = new Date(start_date);\n const endDate = new Date(end_date);\n \n if (isNaN(startDate.getTime()) || isNaN(endDate.getTime())) {\n return c.json({ success: false, message: 'Invalid date format' }, 400);\n }\n \n if (endDate <= startDate) {\n return c.json({ success: false, message: 'End date must be after start date' }, 400);\n }\n \n if (budget <= 0) {\n return c.json({ success: false, message: 'Budget must be greater than 0' }, 400);\n }\n \n const advertisement = await createAdvertisement(\n title,\n description,\n start_date,\n end_date,\n Math.round(budget * 100), // Convert to cents\n user.id\n );\n \n if (!advertisement) {\n return c.json({ success: false, message: 'Failed to create advertisement' }, 500);\n }\n \n // Convert budget back to dollars for response\n const responseAd = {\n ...advertisement,\n budget: advertisement.budget / 100\n };\n \n const response: ApiResponse = {\n success: true,\n data: responseAd\n };\n return c.json(response, 201);\n } catch (error) {\n console.error('Error creating advertisement:', error);\n return c.json({ success: false, message: 'Failed to create advertisement' }, 500);\n }\n});\n\n// Get a specific advertisement with its leads\nadvertisements.get('/:id', requireAuth, async (c) => {\n try {\n const user: User = c.get('user');\n const adId = parseInt(c.req.param('id'));\n \n if (isNaN(adId)) {\n return c.json({ success: false, message: 'Invalid advertisement ID' }, 400);\n }\n \n const adWithLeads = await getAdvertisementWithLeads(adId);\n \n if (!adWithLeads) {\n return c.json({ success: false, message: 'Advertisement not found' }, 404);\n }\n \n // Check if the user owns this advertisement\n if (adWithLeads.created_by !== user.id) {\n return c.json({ success: false, message: 'Access denied' }, 403);\n }\n \n // Convert budget back to dollars for response\n const responseAd = {\n ...adWithLeads,\n budget: adWithLeads.budget / 100,\n leads: adWithLeads.leads || []\n };\n \n const response: ApiResponse = {\n success: true,\n data: responseAd\n };\n return c.json(response);\n } catch (error) {\n console.error('Error getting advertisement:', error);\n return c.json({ success: false, message: 'Failed to get advertisement' }, 500);\n }\n});\n\n// Get advertisement statistics\nadvertisements.get('/:id/stats', requireAuth, async (c) => {\n try {\n const user: User = c.get('user');\n const adId = parseInt(c.req.param('id'));\n \n if (isNaN(adId)) {\n return c.json({ success: false, message: 'Invalid advertisement ID' }, 400);\n }\n \n // First check if the user owns this advertisement\n const adWithLeads = await getAdvertisementWithLeads(adId);\n if (!adWithLeads || adWithLeads.created_by !== user.id) {\n return c.json({ success: false, message: 'Advertisement not found or access denied' }, 404);\n }\n \n const stats = await getAdvertisementStats(adId);\n \n // Convert revenue back to dollars\n const responseStats = {\n ...stats,\n totalRevenue: stats.totalRevenue / 100\n };\n \n const response: ApiResponse = {\n success: true,\n data: responseStats\n };\n return c.json(response);\n } catch (error) {\n console.error('Error getting advertisement stats:', error);\n return c.json({ success: false, message: 'Failed to get advertisement statistics' }, 500);\n }\n});\n\nexport default advertisements;",[],[140,277,319],"239467b4-3f8c-11f0-a0df-76b3cceeab13",["D",1748853157326],[160,161,162,163,164,165,166],[140,277],"6ae20f26-3f8d-11f0-b589-76b3cceeab13","queries.ts","1620be34-3f8c-11f0-bf0e-76b3cceeab13","813ee96f-8cc9-4a83-863f-4525142f8f48",29,["D",1748853706453],"import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport { \n USERS_TABLE, \n ADVERTISEMENTS_TABLE, \n LEADS_TABLE, \n FOLLOWUPS_TABLE, \n ORDERS_TABLE \n} from \"./migrations.ts\";\nimport type { \n User, \n Advertisement, \n Lead, \n FollowUp, \n Order,\n AdvertisementWithLeads,\n LeadWithDetails,\n FollowUpWithDetails,\n OrderWithDetails,\n LeadStatus,\n FollowUpMethod,\n OrderStatus\n} from \"../../shared/types.ts\";\n\n// ===== USER QUERIES =====\nexport async function createUser(email: string, passwordHash: string): Promise {\n try {\n // First insert the user\n const insertResult = await sqlite.execute(\n `INSERT INTO ${USERS_TABLE} (email, password_hash) VALUES (?, ?)`,\n [email, passwordHash]\n );\n \n // Then get the user back\n const result = await sqlite.execute(\n `SELECT id, email, created_at, updated_at FROM ${USERS_TABLE} WHERE email = ?`,\n [email]\n );\n \n if (result.length > 0) {\n return result[0] as User;\n }\n return null;\n } catch (error) {\n console.error('Error creating user:', error);\n return null;\n }\n}\n\nexport async function getUserByEmail(email: string): Promise<(User & { password_hash: string }) | null> {\n try {\n const result = await sqlite.execute(\n `SELECT id, email, password_hash, created_at, updated_at FROM ${USERS_TABLE} WHERE email = ?`,\n [email]\n );\n \n if (result.length > 0) {\n return result[0] as User & { password_hash: string };\n }\n return null;\n } catch (error) {\n console.error('Error getting user by email:', error);\n return null;\n }\n}\n\nexport async function getUserById(id: number): Promise {\n try {\n const result = await sqlite.execute(\n `SELECT id, email, created_at, updated_at FROM ${USERS_TABLE} WHERE id = ?`,\n [id]\n );\n \n if (result.length > 0) {\n return result[0] as User;\n }\n return null;\n } catch (error) {\n console.error('Error getting user by id:', error);\n return null;\n }\n}\n\nexport async function updateUserLastLogin(id: number): Promise {\n try {\n await sqlite.execute(\n `UPDATE ${USERS_TABLE} SET updated_at = CURRENT_TIMESTAMP WHERE id = ?`,\n [id]\n );\n } catch (error) {\n console.error('Error updating user last login:', error);\n }\n}\n\n// ===== ADVERTISEMENT QUERIES =====\nexport async function createAdvertisement(\n title: string,\n description: string,\n startDate: string,\n endDate: string,\n budget: number,\n createdBy: number\n): Promise {\n try {\n // First insert the advertisement\n await sqlite.execute(\n `INSERT INTO ${ADVERTISEMENTS_TABLE} (title, description, start_date, end_date, budget, created_by) \n VALUES (?, ?, ?, ?, ?, ?)`,\n [title, description, startDate, endDate, budget, createdBy]\n );\n \n // Then get the advertisement back\n const result = await sqlite.execute(\n `SELECT id, title, description, start_date, end_date, budget, created_by, created_at, updated_at \n FROM ${ADVERTISEMENTS_TABLE} WHERE title = ? AND created_by = ? ORDER BY id DESC LIMIT 1`,\n [title, createdBy]\n );\n \n if (result.length > 0) {\n return result[0] as Advertisement;\n }\n return null;\n } catch (error) {\n console.error('Error creating advertisement:', error);\n return null;\n }\n}\n\nexport async function getAdvertisementsByUser(userId: number): Promise {\n try {\n const result = await sqlite.execute(\n `SELECT id, title, description, start_date, end_date, budget, created_by, created_at, updated_at \n FROM ${ADVERTISEMENTS_TABLE} WHERE created_by = ? ORDER BY created_at DESC`,\n [userId]\n );\n return result as Advertisement[];\n } catch (error) {\n console.error('Error getting advertisements by user:', error);\n return [];\n }\n}\n\nexport async function getAdvertisementWithLeads(adId: number): Promise {\n try {\n const adResult = await sqlite.execute(\n `SELECT id, title, description, start_date, end_date, budget, created_by, created_at, updated_at \n FROM ${ADVERTISEMENTS_TABLE} WHERE id = ?`,\n [adId]\n );\n \n if (adResult.length === 0) return null;\n \n const leadsResult = await sqlite.execute(\n `SELECT id, name, email, phone, source_ad_id, status, created_at, updated_at \n FROM ${LEADS_TABLE} WHERE source_ad_id = ? ORDER BY created_at DESC`,\n [adId]\n );\n \n const advertisement = adResult[0] as Advertisement;\n const leads = leadsResult as Lead[];\n \n return { ...advertisement, leads };\n } catch (error) {\n console.error('Error getting advertisement with leads:', error);\n return null;\n }\n}\n\n// ===== LEAD QUERIES =====\nexport async function createLead(\n name: string,\n email: string,\n phone: string | undefined,\n sourceAdId: number,\n status: LeadStatus = 'New'\n): Promise {\n try {\n // First insert the lead\n await sqlite.execute(\n `INSERT INTO ${LEADS_TABLE} (name, email, phone, source_ad_id, status) \n VALUES (?, ?, ?, ?, ?)`,\n [name, email, phone || null, sourceAdId, status]\n );\n \n // Then get the lead back\n const result = await sqlite.execute(\n `SELECT id, name, email, phone, source_ad_id, status, created_at, updated_at \n FROM ${LEADS_TABLE} WHERE email = ? AND source_ad_id = ? ORDER BY id DESC LIMIT 1`,\n [email, sourceAdId]\n );\n \n if (result.length > 0) {\n return result[0] as Lead;\n }\n return null;\n } catch (error) {\n console.error('Error creating lead:', error);\n return null;\n }\n}\n\nexport async function getLeadsByAdvertisement(adId: number): Promise {\n try {\n const result = await sqlite.execute(\n `SELECT id, name, email, phone, source_ad_id, status, created_at, updated_at \n FROM ${LEADS_TABLE} WHERE source_ad_id = ? ORDER BY created_at DESC`,\n [adId]\n );\n return result as Lead[];\n } catch (error) {\n console.error('Error getting leads by advertisement:', error);\n return [];\n }\n}\n\nexport async function getLeadWithDetails(leadId: number): Promise {\n try {\n const leadResult = await sqlite.execute(\n `SELECT l.id, l.name, l.email, l.phone, l.source_ad_id, l.status, l.created_at, l.updated_at\n FROM ${LEADS_TABLE} l WHERE l.id = ?`,\n [leadId]\n );\n \n if (leadResult.length === 0) return null;\n \n const adResult = await sqlite.execute(\n `SELECT a.id, a.title, a.description, a.start_date, a.end_date, a.budget, a.created_by, a.created_at, a.updated_at\n FROM ${ADVERTISEMENTS_TABLE} a \n JOIN ${LEADS_TABLE} l ON a.id = l.source_ad_id \n WHERE l.id = ?`,\n [leadId]\n );\n \n const followUpsResult = await sqlite.execute(\n `SELECT id, lead_id, user_id, date, method, notes, created_at, updated_at \n FROM ${FOLLOWUPS_TABLE} WHERE lead_id = ? ORDER BY date DESC`,\n [leadId]\n );\n \n const ordersResult = await sqlite.execute(\n `SELECT id, lead_id, product_name, amount, order_date, status, created_at, updated_at \n FROM ${ORDERS_TABLE} WHERE lead_id = ? ORDER BY order_date DESC`,\n [leadId]\n );\n \n const lead = leadResult[0] as Lead;\n const advertisement = adResult.length > 0 ? adResult[0] as Advertisement : undefined;\n const follow_ups = followUpsResult as FollowUp[];\n const orders = ordersResult as Order[];\n \n return { ...lead, advertisement, follow_ups, orders };\n } catch (error) {\n console.error('Error getting lead with details:', error);\n return null;\n }\n}\n\nexport async function updateLeadStatus(leadId: number, status: LeadStatus): Promise {\n try {\n await sqlite.execute(\n `UPDATE ${LEADS_TABLE} SET status = ?, updated_at = CURRENT_TIMESTAMP WHERE id = ?`,\n [status, leadId]\n );\n return true;\n } catch (error) {\n console.error('Error updating lead status:', error);\n return false;\n }\n}\n\n// ===== FOLLOW-UP QUERIES =====\nexport async function createFollowUp(\n leadId: number,\n userId: number,\n date: string,\n method: FollowUpMethod,\n notes: string\n): Promise {\n try {\n // First insert the follow-up\n await sqlite.execute(\n `INSERT INTO ${FOLLOWUPS_TABLE} (lead_id, user_id, date, method, notes) \n VALUES (?, ?, ?, ?, ?)`,\n [leadId, userId, date, method, notes]\n );\n \n // Then get the follow-up back\n const result = await sqlite.execute(\n `SELECT id, lead_id, user_id, date, method, notes, created_at, updated_at \n FROM ${FOLLOWUPS_TABLE} WHERE lead_id = ? AND user_id = ? ORDER BY id DESC LIMIT 1`,\n [leadId, userId]\n );\n \n if (result.length > 0) {\n return result[0] as FollowUp;\n }\n return null;\n } catch (error) {\n console.error('Error creating follow-up:', error);\n return null;\n }\n}\n\nexport async function getFollowUpsByLead(leadId: number): Promise {\n try {\n const result = await sqlite.execute(\n `SELECT f.id, f.lead_id, f.user_id, f.date, f.method, f.notes, f.created_at, f.updated_at,\n l.name as lead_name, l.email as lead_email,\n u.email as user_email\n FROM ${FOLLOWUPS_TABLE} f\n JOIN ${LEADS_TABLE} l ON f.lead_id = l.id\n JOIN ${USERS_TABLE} u ON f.user_id = u.id\n WHERE f.lead_id = ? ORDER BY f.date DESC`,\n [leadId]\n );\n \n return result.map(row => ({\n id: row.id,\n lead_id: row.lead_id,\n user_id: row.user_id,\n date: row.date,\n method: row.method,\n notes: row.notes,\n created_at: row.created_at,\n updated_at: row.updated_at,\n lead: {\n id: row.lead_id,\n name: row.lead_name,\n email: row.lead_email\n },\n user: {\n id: row.user_id,\n email: row.user_email\n }\n })) as FollowUpWithDetails[];\n } catch (error) {\n console.error('Error getting follow-ups by lead:', error);\n return [];\n }\n}\n\nexport async function getFollowUpsByUser(userId: number): Promise {\n try {\n const result = await sqlite.execute(\n `SELECT f.id, f.lead_id, f.user_id, f.date, f.method, f.notes, f.created_at, f.updated_at,\n l.name as lead_name, l.email as lead_email\n FROM ${FOLLOWUPS_TABLE} f\n JOIN ${LEADS_TABLE} l ON f.lead_id = l.id\n WHERE f.user_id = ? ORDER BY f.date DESC`,\n [userId]\n );\n \n return result.map(row => ({\n id: row.id,\n lead_id: row.lead_id,\n user_id: row.user_id,\n date: row.date,\n method: row.method,\n notes: row.notes,\n created_at: row.created_at,\n updated_at: row.updated_at,\n lead: {\n id: row.lead_id,\n name: row.lead_name,\n email: row.lead_email\n }\n })) as FollowUpWithDetails[];\n } catch (error) {\n console.error('Error getting follow-ups by user:', error);\n return [];\n }\n}\n\n// ===== ORDER QUERIES =====\nexport async function createOrder(\n leadId: number,\n productName: string,\n amount: number,\n orderDate: string,\n status: OrderStatus = 'Pending'\n): Promise {\n try {\n // First insert the order\n await sqlite.execute(\n `INSERT INTO ${ORDERS_TABLE} (lead_id, product_name, amount, order_date, status) \n VALUES (?, ?, ?, ?, ?)`,\n [leadId, productName, amount, orderDate, status]\n );\n \n // Then get the order back\n const result = await sqlite.execute(\n `SELECT id, lead_id, product_name, amount, order_date, status, created_at, updated_at \n FROM ${ORDERS_TABLE} WHERE lead_id = ? AND product_name = ? ORDER BY id DESC LIMIT 1`,\n [leadId, productName]\n );\n \n if (result.length > 0) {\n return result[0] as Order;\n }\n return null;\n } catch (error) {\n console.error('Error creating order:', error);\n return null;\n }\n}\n\nexport async function getOrdersByLead(leadId: number): Promise {\n try {\n const result = await sqlite.execute(\n `SELECT o.id, o.lead_id, o.product_name, o.amount, o.order_date, o.status, o.created_at, o.updated_at,\n l.name as lead_name, l.email as lead_email\n FROM ${ORDERS_TABLE} o\n JOIN ${LEADS_TABLE} l ON o.lead_id = l.id\n WHERE o.lead_id = ? ORDER BY o.order_date DESC`,\n [leadId]\n );\n \n return result.map(row => ({\n id: row.id,\n lead_id: row.lead_id,\n product_name: row.product_name,\n amount: row.amount,\n order_date: row.order_date,\n status: row.status,\n created_at: row.created_at,\n updated_at: row.updated_at,\n lead: {\n id: row.lead_id,\n name: row.lead_name,\n email: row.lead_email\n }\n })) as OrderWithDetails[];\n } catch (error) {\n console.error('Error getting orders by lead:', error);\n return [];\n }\n}\n\nexport async function updateOrderStatus(orderId: number, status: OrderStatus): Promise {\n try {\n await sqlite.execute(\n `UPDATE ${ORDERS_TABLE} SET status = ?, updated_at = CURRENT_TIMESTAMP WHERE id = ?`,\n [status, orderId]\n );\n return true;\n } catch (error) {\n console.error('Error updating order status:', error);\n return false;\n }\n}\n\n// ===== ANALYTICS QUERIES =====\nexport async function getAdvertisementStats(adId: number): Promise<{\n totalLeads: number;\n convertedLeads: number;\n totalRevenue: number;\n conversionRate: number;\n}> {\n try {\n const leadsResult = await sqlite.execute(\n `SELECT COUNT(*) as total_leads, \n COUNT(CASE WHEN status = 'Converted' THEN 1 END) as converted_leads\n FROM ${LEADS_TABLE} WHERE source_ad_id = ?`,\n [adId]\n );\n \n const revenueResult = await sqlite.execute(\n `SELECT COALESCE(SUM(o.amount), 0) as total_revenue\n FROM ${ORDERS_TABLE} o\n JOIN ${LEADS_TABLE} l ON o.lead_id = l.id\n WHERE l.source_ad_id = ? AND o.status = 'Completed'`,\n [adId]\n );\n \n const totalLeads = leadsResult[0]?.total_leads || 0;\n const convertedLeads = leadsResult[0]?.converted_leads || 0;\n const totalRevenue = revenueResult[0]?.total_revenue || 0;\n const conversionRate = totalLeads > 0 ? (convertedLeads / totalLeads) * 100 : 0;\n \n return {\n totalLeads,\n convertedLeads,\n totalRevenue,\n conversionRate\n };\n } catch (error) {\n console.error('Error getting advertisement stats:', error);\n return {\n totalLeads: 0,\n convertedLeads: 0,\n totalRevenue: 0,\n conversionRate: 0\n };\n }\n}",[],[140,339,331],"database","db6cabd0-3f8c-11f0-87ea-76b3cceeab13","migrations.ts","10dc6edc-3f8c-11f0-985a-76b3cceeab13",18,["D",1748853465771],"import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\n\nconst USERS_TABLE = 'adfollowup_users_v1';\nconst ADVERTISEMENTS_TABLE = 'adfollowup_advertisements_v1';\nconst LEADS_TABLE = 'adfollowup_leads_v1';\nconst FOLLOWUPS_TABLE = 'adfollowup_followups_v1';\nconst ORDERS_TABLE = 'adfollowup_orders_v1';\n\nexport async function runMigrations() {\n console.log('Running database migrations...');\n \n // Create users table\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${USERS_TABLE} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n email TEXT UNIQUE NOT NULL,\n password_hash TEXT NOT NULL,\n created_at DATETIME DEFAULT CURRENT_TIMESTAMP,\n updated_at DATETIME DEFAULT CURRENT_TIMESTAMP\n )\n `);\n \n // Create advertisements table\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${ADVERTISEMENTS_TABLE} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n title TEXT NOT NULL,\n description TEXT NOT NULL,\n start_date DATETIME NOT NULL,\n end_date DATETIME NOT NULL,\n budget INTEGER NOT NULL, -- stored in cents\n created_by INTEGER NOT NULL,\n created_at DATETIME DEFAULT CURRENT_TIMESTAMP,\n updated_at DATETIME DEFAULT CURRENT_TIMESTAMP,\n FOREIGN KEY (created_by) REFERENCES ${USERS_TABLE}(id) ON DELETE CASCADE\n )\n `);\n \n // Create leads table\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${LEADS_TABLE} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n name TEXT NOT NULL,\n email TEXT NOT NULL,\n phone TEXT,\n source_ad_id INTEGER NOT NULL,\n status TEXT NOT NULL DEFAULT 'New' CHECK (status IN ('New', 'Contacted', 'Interested', 'Converted', 'Lost')),\n created_at DATETIME DEFAULT CURRENT_TIMESTAMP,\n updated_at DATETIME DEFAULT CURRENT_TIMESTAMP,\n FOREIGN KEY (source_ad_id) REFERENCES ${ADVERTISEMENTS_TABLE}(id) ON DELETE CASCADE\n )\n `);\n \n // Create follow-ups table\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${FOLLOWUPS_TABLE} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n lead_id INTEGER NOT NULL,\n user_id INTEGER NOT NULL,\n date DATETIME NOT NULL,\n method TEXT NOT NULL CHECK (method IN ('Call', 'Email', 'SMS', 'Meeting')),\n notes TEXT NOT NULL,\n created_at DATETIME DEFAULT CURRENT_TIMESTAMP,\n updated_at DATETIME DEFAULT CURRENT_TIMESTAMP,\n FOREIGN KEY (lead_id) REFERENCES ${LEADS_TABLE}(id) ON DELETE CASCADE,\n FOREIGN KEY (user_id) REFERENCES ${USERS_TABLE}(id) ON DELETE CASCADE\n )\n `);\n \n // Create orders table\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${ORDERS_TABLE} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n lead_id INTEGER NOT NULL,\n product_name TEXT NOT NULL,\n amount INTEGER NOT NULL, -- stored in cents\n order_date DATETIME DEFAULT CURRENT_TIMESTAMP,\n status TEXT NOT NULL DEFAULT 'Pending' CHECK (status IN ('Pending', 'Completed', 'Cancelled')),\n created_at DATETIME DEFAULT CURRENT_TIMESTAMP,\n updated_at DATETIME DEFAULT CURRENT_TIMESTAMP,\n FOREIGN KEY (lead_id) REFERENCES ${LEADS_TABLE}(id) ON DELETE CASCADE\n )\n `);\n \n // Create indexes for better query performance\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_advertisements_created_by ON ${ADVERTISEMENTS_TABLE}(created_by)`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_leads_source_ad_id ON ${LEADS_TABLE}(source_ad_id)`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_leads_status ON ${LEADS_TABLE}(status)`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_followups_lead_id ON ${FOLLOWUPS_TABLE}(lead_id)`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_followups_user_id ON ${FOLLOWUPS_TABLE}(user_id)`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_orders_lead_id ON ${ORDERS_TABLE}(lead_id)`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_orders_status ON ${ORDERS_TABLE}(status)`);\n \n console.log('Database migrations completed');\n}\n\nexport { \n USERS_TABLE, \n ADVERTISEMENTS_TABLE, \n LEADS_TABLE, \n FOLLOWUPS_TABLE, \n ORDERS_TABLE \n};",[],[140,339,341],"10dc93c6-3f8c-11f0-985a-76b3cceeab13",["D",1748853125924],[157,158],[140,339],["D",1748853125924],[156,159,167],[140],["D",1748853093009],{"_16":17,"_82":78},{"_16":17,"_76":-5,"_77":78,"_32":33,"_79":80,"_81":26},{"_64":65,"_20":66,"_18":67,"_68":19,"_69":-5,"_70":-5,"_71":-5,"_72":-5,"_73":-5,"_74":21,"_75":17},"ctx",{"_57":-5,"_103":392,"_393":394,"_395":396,"_397":26,"_398":26,"_399":26,"_400":37,"_401":-5,"_402":-7,"_403":-7,"_404":41,"_405":26,"_406":26,"_407":-5,"_408":26,"_409":26,"_410":26,"_411":-5},"ENV",{"_363":364,"_365":366,"_367":66,"_368":369,"_370":371,"_372":373,"_374":375,"_376":377,"_378":379,"_380":381,"_382":383,"_384":385,"_386":387,"_388":389,"_390":391},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","71c1b20804b3232a7e513be260cfffc1932a9e97","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Search