[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_360":361,"_362":363},"routes/_app.x.$handle.$name",{"_97":96,"_32":46,"_105":87,"_27":106,"_13":14,"_107":-5,"_11":108,"_109":110,"_111":112,"_113":114,"_115":116,"_20":-5,"_117":-5,"_118":-5,"_119":25,"_120":121,"_122":59,"_123":-5,"_124":-5,"_125":126},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_44":45,"_32":46,"_39":47,"_48":-5,"_49":25,"_50":51,"_52":51,"_53":-5,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":59,"_61":-5,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":-5,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":80,"_81":82,"_83":84,"_85":25},"version",29,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":33,"_34":35,"_36":38,"_39":40,"_41":14,"_42":43,"_24":25},"previous",{"_30":31,"_32":33,"_34":35,"_36":37},"deleted",false,"deletedHere","path","backend/database/queries.ts","latestPath","fileId","1620be34-3f8c-11f0-bf0e-76b3cceeab13","name","queries.ts","fileType","script","content","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 const result = await sqlite.execute(\n `INSERT INTO ${ORDERS_TABLE} (lead_id, product_name, amount, order_date, status) \n VALUES (?, ?, ?, ?, ?) \n RETURNING id, lead_id, product_name, amount, order_date, status, created_at, updated_at`,\n [leadId, productName, amount, orderDate, status]\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}","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}","createdAt",["D",1748853706453],"branchVersion","branchId","fd3d4d10-3f8b-11f0-b60e-76b3cceeab13","id","fd3ce92e-3f8b-11f0-b60e-76b3cceeab13","Advertapp",["D",1748853093009],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","d7be91c0-3f8b-11f0-b6e9-ab0b2f88b858","pinnedFileId","2d4e12fa-3f8c-11f0-a950-76b3cceeab13","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","1dd89474-29f6-474e-b85f-222707084845","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_97":96,"_104":100},"org",{"_97":96,"_98":-5,"_99":100,"_18":55,"_101":102,"_103":25},"branch",{"_13":86,"_32":87,"_44":43,"_88":45,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":46,"_95":96},"isOwned",31,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","Raj3b","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzJ4d2RLenI2WFJiSU5oVE1tb2FPNkxCc1lIRCJ9","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_44":45,"_32":46,"_39":356,"_48":-5,"_49":25,"_50":51,"_52":51,"_53":-5,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":59,"_61":-5,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":-5,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":357,"_81":358,"_83":359,"_85":25},"tree",[170,182,191,193],"files",[170,171,172,173,174,175,176,177,178,179,180,181,182,183,184,185,186,187,188,189,190,191,192,193],"counts",{"_160":63,"_161":135,"_162":63,"_163":164,"_165":166},"contents",[127,128,129,130],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_44":154,"_32":155,"_30":156,"_134":-5,"_42":43,"_41":157,"_136":59,"_39":158,"_13":63,"_34":146,"_36":-5,"_24":25,"_139":-5,"_27":159},{"_44":148,"_32":149,"_30":150,"_134":-5,"_42":43,"_41":151,"_136":59,"_39":152,"_13":63,"_34":146,"_36":-5,"_24":25,"_139":-5,"_27":153},{"_44":141,"_32":142,"_30":143,"_134":-5,"_42":43,"_41":144,"_136":59,"_39":145,"_13":63,"_34":146,"_36":-5,"_24":25,"_139":-5,"_27":147},{"_44":131,"_32":132,"_30":133,"_134":-5,"_42":43,"_41":135,"_136":59,"_39":137,"_13":63,"_34":20,"_36":138,"_24":25,"_139":-5,"_27":140},"0a78af6a-3f8c-11f0-815e-76b3cceeab13","README.md","0a78b03c-3f8c-11f0-815e-76b3cceeab13","parentId",1,"latest",["D",1748853115184],"# ▲AdFollowUpApp▲\n\nA full-stack TypeScript application for managing ad follow-ups with user authentication.\n\n## Features\n\n- 🔐 User authentication (email/password)\n- 📊 SQLite database with user management\n- 🎨 Modern UI with TailwindCSS\n- ⚡ Built with Hono backend and React frontend\n- 🔒 Secure session management\n\n## Project Structure\n\n```\n├── backend/\n│ ├── database/\n│ │ ├── migrations.ts # Database schema and migrations\n│ │ └── queries.ts # Database query functions\n│ ├── routes/\n│ │ ├── auth.ts # Authentication routes\n│ │ └── static.ts # Static file serving\n│ └── index.ts # Main Hono server\n├── frontend/\n│ ├── components/\n│ │ ├── App.tsx # Main React app\n│ │ ├── Login.tsx # Login component\n│ │ ├── Register.tsx # Registration component\n│ │ └── Dashboard.tsx # User dashboard\n│ ├── index.html # Main HTML template\n│ ├── index.tsx # Frontend entry point\n│ └── style.css # Custom styles\n├── shared/\n│ └── types.ts # Shared TypeScript types\n└── README.md\n```\n\n## Getting Started\n\n1. Set up environment variables (if needed)\n2. The application will automatically create the SQLite database on first run\n3. Navigate to the application URL to see the login/register interface\n\n## API Endpoints\n\n- `POST /api/auth/register` - User registration\n- `POST /api/auth/login` - User login\n- `POST /api/auth/logout` - User logout\n- `GET /api/auth/me` - Get current user info\n\n## Database Schema\n\n- **users** table with id, email, password_hash, created_at, updated_at","label",[132],"0d9afbd0-3f8c-11f0-a9f9-76b3cceeab13","shared","d4b4798f-69ad-4675-8580-5dbdeb0d8719",2,["D",1748853120453],"directory",[142],"31fe8cd0-3f8c-11f0-aba5-76b3cceeab13","frontend","afede950-ef1f-413a-9d23-f541eb749815",8,["D",1748853181512],[149],"10dc9146-3f8c-11f0-985a-76b3cceeab13","backend","e5d7b585-8f8e-4eec-9383-2c985120c6f9",3,["D",1748853125924],[155],"pulls","branches","forks","envVars",{"_167":63,"_169":63},"connections",{"_167":63,"_168":63},"count","unfilledCount","emptyCount",{"_44":154,"_32":155,"_30":156,"_134":-5,"_42":43,"_41":157,"_136":59,"_39":353,"_13":63,"_34":146,"_36":-5,"_24":25,"_139":-5,"_195":354,"_27":355},{"_44":349,"_32":340,"_30":336,"_134":156,"_42":43,"_41":157,"_136":59,"_39":350,"_13":63,"_34":146,"_36":-5,"_24":25,"_139":-5,"_195":351,"_27":352},{"_44":341,"_32":342,"_30":343,"_134":336,"_42":43,"_41":344,"_136":59,"_39":345,"_13":135,"_34":35,"_36":346,"_24":25,"_139":-5,"_195":347,"_27":348},{"_44":335,"_32":33,"_30":31,"_134":336,"_42":43,"_41":14,"_136":59,"_39":337,"_13":285,"_34":35,"_36":38,"_24":25,"_139":-5,"_195":338,"_27":339},{"_44":331,"_32":290,"_30":284,"_134":156,"_42":43,"_41":318,"_136":59,"_39":332,"_13":63,"_34":146,"_36":-5,"_24":25,"_139":-5,"_195":333,"_27":334},{"_44":323,"_32":324,"_30":325,"_134":284,"_42":43,"_41":326,"_136":59,"_39":327,"_13":63,"_34":35,"_36":328,"_24":25,"_139":-5,"_195":329,"_27":330},{"_44":315,"_32":316,"_30":317,"_134":284,"_42":43,"_41":318,"_136":59,"_39":319,"_13":63,"_34":35,"_36":320,"_24":25,"_139":-5,"_195":321,"_27":322},{"_44":307,"_32":308,"_30":309,"_134":284,"_42":43,"_41":310,"_136":59,"_39":311,"_13":63,"_34":35,"_36":312,"_24":25,"_139":-5,"_195":313,"_27":314},{"_44":299,"_32":300,"_30":301,"_134":284,"_42":43,"_41":302,"_136":59,"_39":303,"_13":63,"_34":35,"_36":304,"_24":25,"_139":-5,"_195":305,"_27":306},{"_44":291,"_32":292,"_30":293,"_134":284,"_42":43,"_41":294,"_136":59,"_39":295,"_13":63,"_34":35,"_36":296,"_24":25,"_139":-5,"_195":297,"_27":298},{"_44":281,"_32":282,"_30":283,"_134":284,"_42":43,"_41":285,"_136":59,"_39":286,"_13":63,"_34":35,"_36":287,"_24":25,"_139":-5,"_195":288,"_27":289},{"_44":273,"_32":274,"_30":57,"_134":156,"_42":43,"_41":275,"_136":25,"_39":276,"_13":157,"_34":277,"_36":278,"_24":25,"_139":-5,"_195":279,"_27":280},{"_44":148,"_32":149,"_30":150,"_134":-5,"_42":43,"_41":151,"_136":59,"_39":270,"_13":63,"_34":146,"_36":-5,"_24":25,"_139":-5,"_195":271,"_27":272},{"_44":266,"_32":241,"_30":235,"_134":150,"_42":43,"_41":261,"_136":59,"_39":267,"_13":63,"_34":146,"_36":-5,"_24":25,"_139":-5,"_195":268,"_27":269},{"_44":258,"_32":259,"_30":260,"_134":235,"_42":43,"_41":261,"_136":59,"_39":262,"_13":63,"_34":35,"_36":263,"_24":25,"_139":-5,"_195":264,"_27":265},{"_44":250,"_32":251,"_30":252,"_134":235,"_42":43,"_41":253,"_136":59,"_39":254,"_13":63,"_34":35,"_36":255,"_24":25,"_139":-5,"_195":256,"_27":257},{"_44":242,"_32":243,"_30":244,"_134":235,"_42":43,"_41":245,"_136":59,"_39":246,"_13":63,"_34":35,"_36":247,"_24":25,"_139":-5,"_195":248,"_27":249},{"_44":232,"_32":233,"_30":234,"_134":235,"_42":43,"_41":236,"_136":59,"_39":237,"_13":63,"_34":35,"_36":238,"_24":25,"_139":-5,"_195":239,"_27":240},{"_44":225,"_32":226,"_30":227,"_134":150,"_42":43,"_41":151,"_136":59,"_39":228,"_13":63,"_34":20,"_36":229,"_24":25,"_139":-5,"_195":230,"_27":231},{"_44":217,"_32":218,"_30":219,"_134":150,"_42":43,"_41":220,"_136":59,"_39":221,"_13":63,"_34":35,"_36":222,"_24":25,"_139":-5,"_195":223,"_27":224},{"_44":209,"_32":210,"_30":211,"_134":150,"_42":43,"_41":212,"_136":59,"_39":213,"_13":63,"_34":20,"_36":214,"_24":25,"_139":-5,"_195":215,"_27":216},{"_44":141,"_32":142,"_30":143,"_134":-5,"_42":43,"_41":144,"_136":59,"_39":206,"_13":63,"_34":146,"_36":-5,"_24":25,"_139":-5,"_195":207,"_27":208},{"_44":198,"_32":199,"_30":200,"_134":143,"_42":43,"_41":201,"_136":59,"_39":202,"_13":135,"_34":35,"_36":203,"_24":25,"_139":-5,"_195":204,"_27":205},{"_44":131,"_32":132,"_30":133,"_134":-5,"_42":43,"_41":135,"_136":59,"_39":194,"_13":63,"_34":20,"_36":138,"_24":25,"_139":-5,"_195":196,"_27":197},["D",1748853115184],"children",[],[132],"d033fb92-3f8c-11f0-9107-76b3cceeab13","types.ts","0d9af220-3f8c-11f0-a9f9-76b3cceeab13",17,["D",1748853446944],"// Shared types for ▲AdFollowUpApp▲\n\nexport interface User {\n id: number;\n email: string;\n created_at: string;\n updated_at: string;\n}\n\nexport interface AuthRequest {\n email: string;\n password: string;\n}\n\nexport interface AuthResponse {\n success: boolean;\n user?: User;\n message?: string;\n}\n\nexport interface ApiResponse {\n success: boolean;\n data?: T;\n message?: string;\n}\n\n// ▲Advertisement▲ Model\nexport interface Advertisement {\n id: number;\n title: string;\n description: string;\n start_date: string; // ISO date string\n end_date: string; // ISO date string\n budget: number; // in cents to avoid floating point issues\n created_by: number; // User ID\n created_at: string;\n updated_at: string;\n}\n\n// ▲Lead▲ Model\nexport type LeadStatus = 'New' | 'Contacted' | 'Interested' | 'Converted' | 'Lost';\n\nexport interface Lead {\n id: number;\n name: string;\n email: string;\n phone?: string;\n source_ad_id: number; // Advertisement ID\n status: LeadStatus;\n created_at: string;\n updated_at: string;\n}\n\n// ▲FollowUp▲ Model\nexport type FollowUpMethod = 'Call' | 'Email' | 'SMS' | 'Meeting';\n\nexport interface FollowUp {\n id: number;\n lead_id: number; // Lead ID\n user_id: number; // User ID who did the follow-up\n date: string; // ISO date string\n method: FollowUpMethod;\n notes: string;\n created_at: string;\n updated_at: string;\n}\n\n// ▲Order▲ Model\nexport type OrderStatus = 'Pending' | 'Completed' | 'Cancelled';\n\nexport interface Order {\n id: number;\n lead_id: number; // Lead ID\n product_name: string;\n amount: number; // in cents to avoid floating point issues\n order_date: string; // ISO date string\n status: OrderStatus;\n created_at: string;\n updated_at: string;\n}\n\n// Extended types with relations for queries\nexport interface AdvertisementWithLeads extends Advertisement {\n leads?: Lead[];\n}\n\nexport interface LeadWithDetails extends Lead {\n advertisement?: Advertisement;\n follow_ups?: FollowUp[];\n orders?: Order[];\n}\n\nexport interface FollowUpWithDetails extends FollowUp {\n lead?: Lead;\n user?: User;\n}\n\nexport interface OrderWithDetails extends Order {\n lead?: Lead;\n}\n\n// Request/Response types for API\nexport interface CreateAdvertisementRequest {\n title: string;\n description: string;\n start_date: string;\n end_date: string;\n budget: number;\n}\n\nexport interface CreateLeadRequest {\n name: string;\n email: string;\n phone?: string;\n source_ad_id: number;\n status?: LeadStatus;\n}\n\nexport interface CreateFollowUpRequest {\n lead_id: number;\n date: string;\n method: FollowUpMethod;\n notes: string;\n}\n\nexport interface CreateOrderRequest {\n lead_id: number;\n product_name: string;\n amount: number;\n order_date?: string;\n status?: OrderStatus;\n}",[],[142,199],["D",1748853120453],[192],[142],"36579a1a-3f8c-11f0-9ee6-76b3cceeab13","style.css","36579aec-3f8c-11f0-9ee6-76b3cceeab13",9,["D",1748853188811],"/* Custom styles for ▲AdFollowUpApp▲ */\n\n.app-gradient {\n background: linear-gradient(135deg, #667eea 0%, #764ba2 100%);\n}\n\n.card-shadow {\n box-shadow: 0 10px 25px rgba(0, 0, 0, 0.1);\n}\n\n.btn-primary {\n @apply bg-blue-600 hover:bg-blue-700 text-white font-semibold py-2 px-4 rounded-lg transition-colors duration-200;\n}\n\n.btn-secondary {\n @apply bg-gray-200 hover:bg-gray-300 text-gray-800 font-semibold py-2 px-4 rounded-lg transition-colors duration-200;\n}\n\n.input-field {\n @apply w-full px-3 py-2 border border-gray-300 rounded-lg focus:outline-none focus:ring-2 focus:ring-blue-500 focus:border-transparent;\n}\n\n.error-message {\n @apply text-red-600 text-sm mt-1;\n}\n\n.success-message {\n @apply text-green-600 text-sm mt-1;\n}",[],[149,210],"38ec5edc-3f8c-11f0-b3aa-76b3cceeab13","index.tsx","38ec5fb8-3f8c-11f0-b3aa-76b3cceeab13",10,["D",1748853193139],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React from \"https://esm.sh/react@18.2.0?deps=react@18.2.0\";\nimport { createRoot } from \"https://esm.sh/react-dom@18.2.0/client?deps=react@18.2.0,react-dom@18.2.0\";\nimport App from \"./components/App.tsx\";\n\nconst root = createRoot(document.getElementById('root')!);\nroot.render();",[],[149,218],"31fe82da-3f8c-11f0-aba5-76b3cceeab13","index.html","31fe837a-3f8c-11f0-aba5-76b3cceeab13",["D",1748853181512],"\n\n\n \n \n ▲AdFollowUpApp▲\n \n \n \n\n\n

\n \n\n",[],[149,226],"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}",[],[149,241,233],"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}",[],[149,241,243],"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}",[],[149,241,251],"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}",[],[149,241,259],"425706a2-3f8c-11f0-a028-76b3cceeab13",["D",1748853208931],[184,185,186,187],[149,241],["D",1748853181512],[183,188,189,190],[149],"3ef42034-3f8d-11f0-be6a-76b3cceeab13","index.ts",24,["D",1748853632750],"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 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);\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;",[],[155,274],"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;",[],[155,290,282],"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;",[],[155,290,292],"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;",[],[155,290,300],"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;",[],[155,290,308],"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;",[],[155,290,316],"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;",[],[155,290,324],"239467b4-3f8c-11f0-a0df-76b3cceeab13",["D",1748853157326],[175,176,177,178,179,180],[155,290],"6ae20f26-3f8d-11f0-b589-76b3cceeab13","813ee96f-8cc9-4a83-863f-4525142f8f48",["D",1748853706453],[],[155,340,33],"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};",[],[155,340,342],"10dc93c6-3f8c-11f0-985a-76b3cceeab13",["D",1748853125924],[172,173],[155,340],["D",1748853125924],[171,174,181],[155],["D",1748853093009],{"_97":96,"_104":100},{"_97":96,"_98":-5,"_99":100,"_18":55,"_101":102,"_103":25},{"_13":86,"_32":87,"_44":43,"_88":45,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":46,"_95":96},"ctx",{"_79":-5,"_124":393,"_394":395,"_396":397,"_398":25,"_399":25,"_400":25,"_401":59,"_402":-5,"_403":-7,"_404":-7,"_405":63,"_406":25,"_407":25,"_408":-5,"_409":25,"_410":25,"_411":25,"_412":-5},"ENV",{"_364":365,"_366":367,"_368":87,"_369":370,"_371":372,"_373":374,"_375":376,"_377":378,"_379":380,"_381":382,"_383":384,"_385":386,"_387":388,"_389":390,"_391":392},"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"]

Diff · v29