[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_111":112,"_113":114},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","alshell7","name","aflabs-pm","path","growth.ts","project",{"_22":45,"_11":12,"_33":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":53,"_54":55,"_56":57,"_58":59,"_60":32,"_61":-5,"_62":-5,"_63":64,"_65":66,"_67":68,"_69":70,"_71":72,"_73":-5,"_74":75,"_76":75,"_77":78,"_79":78,"_80":78,"_81":75,"_82":75,"_83":84,"_85":86,"_87":88,"_89":42},"file",{"_22":23,"_11":14,"_24":25,"_26":-5,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":-5,"_13":44},"permalink","https://www.val.town/x/alshell7/aflabs-pm/code/growth.ts","extension","id","6654af85-f525-4c02-b927-6763bee1533a","fileId","1723cc22-9756-11f1-bd2f-1607ee4eb77e","parentId","branchId","ec297ab1-9bec-46a6-a3e9-7163c0e2fcfa","branchVersion",122,"latest",true,"createdAt",["D",1786662430541],"version",1,"fileType","script","content","type GrowthActor = {\n actorType: \"internal\" | \"partner\" | \"client\";\n actorId: string;\n projectId?: string | null;\n name: string;\n role: string;\n permissions: Record;\n allProjectAccess?: boolean;\n};\n\ntype DbStatement = string | { sql: string; args?: unknown[] };\ntype GrowthDeps = {\n db: {\n execute(statement: DbStatement): Promise<{ rows: any[]; rowsAffected: number }>;\n batch(statements: DbStatement[]): Promise>;\n };\n actor(c: any): Promise;\n admin(actor: GrowthActor): boolean;\n body(c: any): Promise;\n uid(): string;\n now(): string;\n str(value: unknown): string;\n int(value: unknown): number;\n allowedProject(projectId: string, actor: GrowthActor): Promise;\n projectInsertStatements(projectId: string, data: any, context: {\n actorType: string;\n actorId: string;\n ownerId: string;\n partnerId: string | null;\n status?: string;\n }): { statements: DbStatement[]; clientPin: string };\n openai: any;\n};\n\nconst LEAD_STAGES = [\"new\", \"contacted\", \"qualified\", \"discovery\", \"proposal\", \"negotiation\", \"won\", \"lost\"];\nconst IDEA_PROMPT = \"You are a Forward Deployed Engineer, technical sales expert, and business development leader. Create a practical, ROI-driven business idea pitch for tailor-made software, AI, automation, Voice AI, WhatsApp, or the most appropriate combination. Understand the business context deeply. Be direct, credible, commercially strong, and specific. Explain the operational pain, recommended solution, implementation path, measurable value, risks, assumptions, and next action. Do not invent facts or guaranteed ROI. Label assumptions and give a realistic ROI model using ranges where inputs are incomplete. Return polished Markdown.\";\nconst PROPOSAL_PROMPT = \"Turn the supplied business context into a concise, convincing, implementation-ready custom software proposal. Write as a Forward Deployed Engineer and technical sales leader. Include executive summary, current pain, proposed solution, scope, phased implementation, integrations, measurable outcomes, ROI model, timeline assumptions, investment framing, risks, success criteria, and a clear next step. Preserve supplied facts, label assumptions, and do not invent customer data. Return polished Markdown.\";\n\nfunction monthBounds(month?: string) {\n const normalized = /^\\d{4}-\\d{2}$/.test(String(month || \"\")) ? String(month) : new Date().toISOString().slice(0, 7);\n const start = normalized + \"-01T00:00:00.000Z\";\n const date = new Date(start);\n date.setUTCMonth(date.getUTCMonth() + 1);\n return { month: normalized, start, end: date.toISOString() };\n}\n\nexport function createGrowthSuite(deps: GrowthDeps) {\n const { db, actor, admin, body, uid, now, str, int, allowedProject, projectInsertStatements, openai } = deps;\n let migration: Promise | null = null;\n\n const json = (value: unknown, fallback: T): T => {\n try { return value ? JSON.parse(String(value)) : fallback; } catch { return fallback; }\n };\n const requireTeam = (a: GrowthActor) => {\n if (a.actorType === \"client\") throw new Error(\"This action is not available\");\n };\n const requirePartnerPermission = (a: GrowthActor, key: string) => {\n if (a.actorType === \"partner\" && a.permissions[key] !== true) {\n throw new Error(\"You do not have permission for this action\");\n }\n };\n const bool = (value: unknown) => Boolean(Number(value));\n const safeDateTime = (value: unknown) => {\n const parsed = new Date(str(value));\n if (Number.isNaN(parsed.getTime())) throw new Error(\"Select a valid date and time\");\n return parsed.toISOString();\n };\n const alter = async (sql: string) => {\n try { await db.execute(sql); } catch (error) {\n const message = error instanceof Error ? error.message : String(error);\n if (!/duplicate column|already exists/i.test(message)) throw error;\n }\n };\n const setting = async (key: string, fallback: string) => {\n const result = await db.execute({ sql: \"SELECT setting_value FROM app_settings WHERE setting_key=?\", args: [key] });\n return str(result.rows[0]?.setting_value) || fallback;\n };\n const saveSetting = async (key: string, value: string) => {\n await db.execute({\n sql: \"INSERT INTO app_settings(setting_key,setting_value,updated_at) VALUES(?,?,?) ON CONFLICT(setting_key) DO UPDATE SET setting_value=excluded.setting_value,updated_at=excluded.updated_at\",\n args: [key, value, now()],\n });\n };\n\n async function migrate() {\n if (migration) return migration;\n migration = (async () => {\n await db.batch([\n \"CREATE TABLE IF NOT EXISTS leads (id TEXT PRIMARY KEY,title TEXT NOT NULL,company_name TEXT NOT NULL DEFAULT '',contact_name TEXT NOT NULL DEFAULT '',contact_email TEXT NOT NULL DEFAULT '',contact_phone TEXT NOT NULL DEFAULT '',category TEXT NOT NULL DEFAULT '',business_type TEXT NOT NULL DEFAULT '',source TEXT NOT NULL DEFAULT '',stage TEXT NOT NULL DEFAULT 'new',priority TEXT NOT NULL DEFAULT 'medium',expected_budget REAL NOT NULL DEFAULT 0,currency TEXT NOT NULL DEFAULT 'INR',partner_id TEXT REFERENCES partners(id),owner_user_id TEXT REFERENCES internal_users(id),requirements_markdown TEXT NOT NULL DEFAULT '',pain_points TEXT NOT NULL DEFAULT '',inside_info TEXT NOT NULL DEFAULT '',use_case_hint TEXT NOT NULL DEFAULT '',next_follow_up_at TEXT,lost_reason TEXT,created_by_type TEXT NOT NULL,created_by_id TEXT NOT NULL,created_at TEXT NOT NULL,updated_at TEXT NOT NULL)\",\n \"CREATE TABLE IF NOT EXISTS lead_events (id TEXT PRIMARY KEY,lead_id TEXT NOT NULL REFERENCES leads(id) ON DELETE CASCADE,event_type TEXT NOT NULL,title TEXT NOT NULL,details TEXT NOT NULL DEFAULT '',metadata TEXT NOT NULL DEFAULT '{}',actor_type TEXT NOT NULL,actor_id TEXT NOT NULL,actor_name TEXT NOT NULL,occurred_at TEXT NOT NULL,created_at TEXT NOT NULL)\",\n \"CREATE TABLE IF NOT EXISTS lead_followups (id TEXT PRIMARY KEY,lead_id TEXT NOT NULL REFERENCES leads(id) ON DELETE CASCADE,note TEXT NOT NULL,due_at TEXT NOT NULL,status TEXT NOT NULL DEFAULT 'open',completed_at TEXT,created_by_type TEXT NOT NULL,created_by_id TEXT NOT NULL,created_at TEXT NOT NULL,updated_at TEXT NOT NULL)\",\n \"CREATE TABLE IF NOT EXISTS conversations (id TEXT PRIMARY KEY,context_type TEXT NOT NULL,context_id TEXT NOT NULL,partner_id TEXT NOT NULL REFERENCES partners(id),internal_user_id TEXT NOT NULL REFERENCES internal_users(id),subject TEXT NOT NULL,status TEXT NOT NULL DEFAULT 'open',last_message_at TEXT,last_read_partner_at TEXT,last_read_internal_at TEXT,created_at TEXT NOT NULL,updated_at TEXT NOT NULL)\",\n \"CREATE TABLE IF NOT EXISTS conversation_messages (id TEXT PRIMARY KEY,conversation_id TEXT NOT NULL REFERENCES conversations(id) ON DELETE CASCADE,sender_type TEXT NOT NULL,sender_id TEXT NOT NULL,sender_name TEXT NOT NULL,body TEXT NOT NULL,created_at TEXT NOT NULL)\",\n \"CREATE TABLE IF NOT EXISTS mou_templates (id TEXT PRIMARY KEY,name TEXT NOT NULL,terms_markdown TEXT NOT NULL,benefits_markdown TEXT NOT NULL DEFAULT '',active INTEGER NOT NULL DEFAULT 1,created_by_id TEXT NOT NULL,created_at TEXT NOT NULL,updated_at TEXT NOT NULL)\",\n \"CREATE TABLE IF NOT EXISTS partner_mous (id TEXT PRIMARY KEY,partner_id TEXT NOT NULL REFERENCES partners(id),template_id TEXT REFERENCES mou_templates(id),terms_markdown TEXT NOT NULL,benefits_markdown TEXT NOT NULL DEFAULT '',effective_from TEXT NOT NULL,status TEXT NOT NULL DEFAULT 'active',created_by_id TEXT NOT NULL,created_at TEXT NOT NULL)\",\n \"CREATE TABLE IF NOT EXISTS partner_targets (id TEXT PRIMARY KEY,partner_id TEXT NOT NULL REFERENCES partners(id),target_month TEXT NOT NULL,leads_target INTEGER NOT NULL DEFAULT 0,projects_target INTEGER NOT NULL DEFAULT 0,revenue_target REAL NOT NULL DEFAULT 0,revenue_currency TEXT NOT NULL DEFAULT 'INR',meetings_allowed INTEGER NOT NULL DEFAULT 0,note TEXT NOT NULL DEFAULT '',created_by_id TEXT NOT NULL,created_at TEXT NOT NULL)\",\n \"CREATE TABLE IF NOT EXISTS meeting_slots (id TEXT PRIMARY KEY,slot_type TEXT NOT NULL DEFAULT 'available',starts_at TEXT NOT NULL,ends_at TEXT NOT NULL,note TEXT NOT NULL DEFAULT '',created_by_id TEXT NOT NULL,created_at TEXT NOT NULL)\",\n \"CREATE TABLE IF NOT EXISTS meetings (id TEXT PRIMARY KEY,partner_id TEXT NOT NULL REFERENCES partners(id),internal_user_id TEXT REFERENCES internal_users(id),context_type TEXT NOT NULL DEFAULT 'other',context_id TEXT,agenda TEXT NOT NULL,starts_at TEXT NOT NULL,ends_at TEXT NOT NULL,join_url TEXT,place TEXT,status TEXT NOT NULL DEFAULT 'booked',created_by_type TEXT NOT NULL,created_by_id TEXT NOT NULL,created_at TEXT NOT NULL,updated_at TEXT NOT NULL)\",\n \"CREATE TABLE IF NOT EXISTS business_ideas (id TEXT PRIMARY KEY,title TEXT NOT NULL,input_data TEXT NOT NULL,generated_markdown TEXT NOT NULL,partner_id TEXT REFERENCES partners(id),proposal_id TEXT REFERENCES proposals(id),created_by_type TEXT NOT NULL,created_by_id TEXT NOT NULL,created_at TEXT NOT NULL,updated_at TEXT NOT NULL)\",\n \"CREATE INDEX IF NOT EXISTS idx_leads_stage_updated ON leads(stage,updated_at)\",\n \"CREATE INDEX IF NOT EXISTS idx_leads_partner_stage ON leads(partner_id,stage,updated_at)\",\n \"CREATE INDEX IF NOT EXISTS idx_lead_events_lead_date ON lead_events(lead_id,occurred_at)\",\n \"CREATE INDEX IF NOT EXISTS idx_followups_lead_due ON lead_followups(lead_id,status,due_at)\",\n \"CREATE INDEX IF NOT EXISTS idx_conversations_partner ON conversations(partner_id,last_message_at)\",\n \"CREATE INDEX IF NOT EXISTS idx_messages_conversation ON conversation_messages(conversation_id,created_at)\",\n \"CREATE INDEX IF NOT EXISTS idx_targets_partner_month ON partner_targets(partner_id,target_month,created_at)\",\n \"CREATE INDEX IF NOT EXISTS idx_meetings_time ON meetings(starts_at,ends_at,status)\",\n \"CREATE INDEX IF NOT EXISTS idx_slots_time ON meeting_slots(starts_at,ends_at,slot_type)\",\n \"CREATE INDEX IF NOT EXISTS idx_ideas_partner ON business_ideas(partner_id,created_at)\",\n ]);\n await alter(\"ALTER TABLE projects ADD COLUMN lead_id TEXT REFERENCES leads(id)\");\n await alter(\"ALTER TABLE projects ADD COLUMN markdown_details TEXT NOT NULL DEFAULT ''\");\n await alter(\"ALTER TABLE partners ADD COLUMN permission_level TEXT NOT NULL DEFAULT 'basic'\");\n await alter(\"ALTER TABLE partners ADD COLUMN permissions TEXT NOT NULL DEFAULT '{}'\");\n await alter(\"ALTER TABLE invoices ADD COLUMN items TEXT NOT NULL DEFAULT '[]'\");\n await alter(\"ALTER TABLE invoices ADD COLUMN subtotal REAL NOT NULL DEFAULT 0\");\n await alter(\"ALTER TABLE invoices ADD COLUMN discount REAL NOT NULL DEFAULT 0\");\n await alter(\"ALTER TABLE invoices ADD COLUMN arrears REAL NOT NULL DEFAULT 0\");\n await alter(\"ALTER TABLE invoices ADD COLUMN tax_label TEXT NOT NULL DEFAULT 'Tax'\");\n await alter(\"ALTER TABLE invoices ADD COLUMN tax_rate REAL NOT NULL DEFAULT 0\");\n await alter(\"ALTER TABLE invoices ADD COLUMN tax_amount REAL NOT NULL DEFAULT 0\");\n await alter(\"ALTER TABLE invoices ADD COLUMN total REAL NOT NULL DEFAULT 0\");\n await db.execute(\"CREATE INDEX IF NOT EXISTS idx_projects_lead ON projects(lead_id,updated_at)\");\n })().catch((error) => {\n migration = null;\n throw error;\n });\n return migration;\n }\n\n async function getLead(id: string, a: GrowthActor) {\n let sql = \"SELECT l.*,p.name partner_name,u.name owner_name FROM leads l LEFT JOIN partners p ON p.id=l.partner_id LEFT JOIN internal_users u ON u.id=l.owner_user_id WHERE l.id=?\";\n const args: unknown[] = [id];\n if (a.actorType === \"partner\") {\n sql += \" AND l.partner_id=?\";\n args.push(a.actorId);\n } else if (a.actorType === \"internal\" && !admin(a) && !a.allProjectAccess) {\n sql += \" AND l.owner_user_id=?\";\n args.push(a.actorId);\n }\n return (await db.execute({ sql, args })).rows[0] as any;\n }\n\n async function logLead(leadId: string, a: GrowthActor, eventType: string, title: string, details = \"\", metadata: any = {}) {\n const stamp = now();\n await db.execute({\n sql: \"INSERT INTO lead_events(id,lead_id,event_type,title,details,metadata,actor_type,actor_id,actor_name,occurred_at,created_at) VALUES(?,?,?,?,?,?,?,?,?,?,?)\",\n args: [uid(), leadId, eventType, title, details, JSON.stringify(metadata || {}), a.actorType, a.actorId, a.name, stamp, stamp],\n });\n }\n\n async function optionsFor(a: GrowthActor) {\n requireTeam(a);\n let leadSql = \"SELECT id,title,company_name,partner_id,stage FROM leads WHERE 1=1\";\n let projectSql = \"SELECT id,title,partner_id,status,lead_id FROM projects WHERE archived=0\";\n const leadArgs: unknown[] = [];\n const projectArgs: unknown[] = [];\n if (a.actorType === \"partner\") {\n leadSql += \" AND partner_id=?\";\n projectSql += \" AND partner_id=?\";\n leadArgs.push(a.actorId);\n projectArgs.push(a.actorId);\n } else if (!admin(a) && !a.allProjectAccess) {\n leadSql += \" AND owner_user_id=?\";\n projectSql += \" AND EXISTS(SELECT 1 FROM user_project_access x WHERE x.project_id=projects.id AND x.user_id=?)\";\n leadArgs.push(a.actorId);\n projectArgs.push(a.actorId);\n }\n const [leads, projects, partners, users] = await Promise.all([\n db.execute({ sql: leadSql + \" ORDER BY updated_at DESC\", args: leadArgs }),\n db.execute({ sql: projectSql + \" ORDER BY updated_at DESC\", args: projectArgs }),\n a.actorType === \"partner\"\n ? db.execute({ sql: \"SELECT id,name FROM partners WHERE id=?\", args: [a.actorId] })\n : db.execute(\"SELECT id,name FROM partners WHERE active=1 ORDER BY name\"),\n db.execute(\"SELECT id,name,role FROM internal_users WHERE active=1 ORDER BY name\"),\n ]);\n return { leads: leads.rows, projects: projects.rows, partners: partners.rows, users: users.rows };\n }\n\n async function targetSnapshot(partnerId: string, month?: string) {\n const bounds = monthBounds(month);\n const targetResult = await db.execute({\n sql: \"SELECT * FROM partner_targets WHERE partner_id=? AND target_month=? ORDER BY created_at DESC LIMIT 1\",\n args: [partnerId, bounds.month],\n });\n const [leadCount, projectCount, revenue, meetingCount] = await Promise.all([\n db.execute({ sql: \"SELECT COUNT(*) count FROM leads WHERE partner_id=? AND created_at>=? AND created_at=? AND created_at=? AND pm.created_at=? AND starts_at'cancelled'\", args: [partnerId, bounds.start, bounds.end] }),\n ]);\n const target = targetResult.rows[0] || null;\n return {\n month: bounds.month,\n target,\n achieved: {\n leads: Number(leadCount.rows[0]?.count || 0),\n projects: Number(projectCount.rows[0]?.count || 0),\n revenue: Number(revenue.rows[0]?.amount || 0),\n meetings: Number(meetingCount.rows[0]?.count || 0),\n },\n };\n }\n\n const meetingScheduleFallback = { days: [1, 2, 3, 4, 5], start: \"10:00\", end: \"18:00\", duration: 30, horizon_days: 21, timezone: \"Asia/Kolkata\" };\n const indiaDate = (value: Date | string = new Date()) => {\n const date = value instanceof Date ? value : new Date(value);\n const parts = new Intl.DateTimeFormat(\"en-CA\", { timeZone: \"Asia/Kolkata\", year: \"numeric\", month: \"2-digit\", day: \"2-digit\" }).formatToParts(date);\n const read = (type: string) => parts.find((part) => part.type === type)?.value || \"\";\n return read(\"year\") + \"-\" + read(\"month\") + \"-\" + read(\"day\");\n };\n const addDate = (date: string, days: number) => {\n const value = new Date(date + \"T12:00:00Z\");\n value.setUTCDate(value.getUTCDate() + days);\n return value.toISOString().slice(0, 10);\n };\n const indiaIso = (date: string, time: string) => new Date(date + \"T\" + time + \":00+05:30\").toISOString();\n const timeMinutes = (time: string) => {\n const parts = String(time || \"\").split(\":\").map(Number);\n return Number.isFinite(parts[0]) && Number.isFinite(parts[1]) ? parts[0] * 60 + parts[1] : 0;\n };\n const minuteTime = (minutes: number) => String(Math.floor(minutes / 60)).padStart(2, \"0\") + \":\" + String(minutes % 60).padStart(2, \"0\");\n const overlaps = (startA: string, endA: string, startB: string, endB: string) => Date.parse(startA) < Date.parse(endB) && Date.parse(endA) > Date.parse(startB);\n async function meetingScheduleData() {\n const stored = json(await setting(\"meeting_schedule\", JSON.stringify(meetingScheduleFallback)), meetingScheduleFallback);\n const schedule = {\n days: Array.isArray(stored.days) ? [...new Set(stored.days.map(Number).filter((day: number) => Number.isInteger(day) && day >= 0 && day <= 6))] : meetingScheduleFallback.days,\n start: /^\\d{2}:\\d{2}$/.test(String(stored.start || \"\")) ? stored.start : meetingScheduleFallback.start,\n end: /^\\d{2}:\\d{2}$/.test(String(stored.end || \"\")) ? stored.end : meetingScheduleFallback.end,\n duration: [15, 30, 45, 60, 90, 120].includes(Number(stored.duration)) ? Number(stored.duration) : meetingScheduleFallback.duration,\n horizon_days: Math.min(60, Math.max(7, Number(stored.horizon_days) || meetingScheduleFallback.horizon_days)),\n timezone: \"Asia/Kolkata\",\n };\n const startDate = indiaDate();\n const endDate = addDate(startDate, schedule.horizon_days - 1);\n const results = await Promise.all([\n db.execute({ sql: \"SELECT id,name,holiday_date FROM holidays WHERE holiday_date>=? AND holiday_date<=? ORDER BY holiday_date\", args: [startDate, endDate] }),\n db.execute(\"SELECT weekly_days FROM holiday_settings WHERE id='default'\"),\n db.execute({ sql: \"SELECT * FROM meeting_slots WHERE slot_type='blocked' AND ends_at>=? ORDER BY starts_at\", args: [now()] }),\n db.execute({ sql: \"SELECT m.*,p.name partner_name FROM meetings m JOIN partners p ON p.id=m.partner_id WHERE m.status<>'cancelled' AND m.ends_at>=? ORDER BY m.starts_at\", args: [now()] }),\n ]);\n const holidayRows = results[0], weeklyResult = results[1], blockRows = results[2], bookingRows = results[3];\n const weeklyDays = json(weeklyResult.rows[0]?.weekly_days, [5, 6]).map(Number);\n const oneOff = new Map(holidayRows.rows.map((item: any) => [String(item.holiday_date), String(item.name)]));\n const allSlots: any[] = [];\n const calendar = Array.from({ length: schedule.horizon_days }, (_, index) => {\n const date = addDate(startDate, index);\n const day = new Date(date + \"T12:00:00Z\").getUTCDay();\n const holidayName = oneOff.get(date) || (weeklyDays.includes(day) ? \"Weekly holiday\" : \"\");\n const scheduled = schedule.days.includes(day);\n const slots: any[] = [];\n if (scheduled && !holidayName) {\n const startMinutes = timeMinutes(schedule.start);\n const endMinutes = timeMinutes(schedule.end);\n for (let cursor = startMinutes; cursor + schedule.duration <= endMinutes; cursor += schedule.duration) {\n const starts_at = indiaIso(date, minuteTime(cursor));\n const ends_at = indiaIso(date, minuteTime(cursor + schedule.duration));\n const blocked = blockRows.rows.find((item: any) => overlaps(starts_at, ends_at, item.starts_at, item.ends_at));\n const meeting = bookingRows.rows.find((item: any) => overlaps(starts_at, ends_at, item.starts_at, item.ends_at));\n const status = Date.parse(ends_at) <= Date.now() ? \"blocked\" : blocked ? \"blocked\" : meeting ? \"booked\" : \"available\";\n const slot = { id: \"schedule-\" + date + \"-\" + cursor, starts_at, ends_at, slot_type: \"available\", generated: true, status, note: blocked?.note || \"\", meeting_id: meeting?.id || null, partner_name: meeting?.partner_name || \"\" };\n slots.push(slot);\n allSlots.push(slot);\n }\n }\n return { date, day, holiday: Boolean(holidayName), holiday_name: holidayName, scheduled, slots, available: slots.filter((slot) => slot.status === \"available\").length, booked: slots.filter((slot) => slot.status === \"booked\").length, blocked: slots.filter((slot) => slot.status === \"blocked\").length };\n });\n const manualAvailable = (await db.execute({ sql: \"SELECT * FROM meeting_slots WHERE slot_type='available' AND ends_at>=? ORDER BY starts_at\", args: [now()] })).rows\n .filter((item: any) => !bookingRows.rows.some((meeting: any) => overlaps(item.starts_at, item.ends_at, meeting.starts_at, meeting.ends_at)) && !blockRows.rows.some((block: any) => overlaps(item.starts_at, item.ends_at, block.starts_at, block.ends_at)));\n return { schedule, holidays: holidayRows.rows, weekly_days: weeklyDays, blocks: blockRows.rows, calendar, allSlots, availableSlots: [...allSlots.filter((slot) => slot.status === \"available\"), ...manualAvailable] };\n }\n function register(app: any) {\n app.get(\"/api/growth/options\", async (c: any) => c.json(await optionsFor(await actor(c))));\n\n app.get(\"/api/leads\", async (c: any) => {\n const a = await actor(c);\n requireTeam(a);\n requirePartnerPermission(a, \"view_leads\");\n let sql = \"SELECT l.*,p.name partner_name,u.name owner_name,(SELECT COUNT(*) FROM projects x WHERE x.lead_id=l.id) project_count,(SELECT COUNT(*) FROM lead_followups f WHERE f.lead_id=l.id AND f.status='open') open_followups FROM leads l LEFT JOIN partners p ON p.id=l.partner_id LEFT JOIN internal_users u ON u.id=l.owner_user_id WHERE 1=1\";\n const args: unknown[] = [];\n if (a.actorType === \"partner\") {\n sql += \" AND l.partner_id=?\";\n args.push(a.actorId);\n } else if (!admin(a) && !a.allProjectAccess) {\n sql += \" AND l.owner_user_id=?\";\n args.push(a.actorId);\n }\n sql += \" ORDER BY l.updated_at DESC\";\n const result = await db.execute({ sql, args });\n const stages = Object.fromEntries(LEAD_STAGES.map((stage) => [stage, result.rows.filter((lead: any) => lead.stage === stage).length]));\n return c.json({ leads: result.rows, stages, stage_order: LEAD_STAGES, options: await optionsFor(a) });\n });\n\n app.get(\"/api/leads/:id\", async (c: any) => {\n const a = await actor(c);\n requireTeam(a);\n requirePartnerPermission(a, \"view_leads\");\n const lead = await getLead(c.req.param(\"id\"), a);\n if (!lead) throw new Error(\"Lead not found\");\n const [events, followups, projects] = await Promise.all([\n db.execute({ sql: \"SELECT * FROM lead_events WHERE lead_id=? ORDER BY occurred_at DESC,created_at DESC\", args: [lead.id] }),\n db.execute({ sql: \"SELECT * FROM lead_followups WHERE lead_id=? ORDER BY CASE status WHEN 'open' THEN 0 ELSE 1 END,due_at\", args: [lead.id] }),\n db.execute({ sql: \"SELECT id,title,status,progress,end_date,project_type,updated_at FROM projects WHERE lead_id=? ORDER BY updated_at DESC\", args: [lead.id] }),\n ]);\n const chronological = [...events.rows].reverse();\n const gaps = new Map();\n chronological.forEach((event: any, index: number) => {\n const previous = chronological[index - 1];\n gaps.set(String(event.id), previous ? Math.max(0, Math.floor((Date.parse(event.occurred_at) - Date.parse(previous.occurred_at)) / 86400000)) : 0);\n });\n return c.json({\n lead,\n events: events.rows.map((event: any) => ({\n ...event,\n metadata: json(event.metadata, {}),\n days_since_previous: gaps.get(String(event.id)) || 0,\n days_ago: Math.max(0, Math.floor((Date.now() - Date.parse(event.occurred_at)) / 86400000)),\n })),\n followups: followups.rows.map((item: any) => ({ ...item, overdue: item.status === \"open\" && Date.parse(item.due_at) < Date.now() })),\n projects: projects.rows,\n options: await optionsFor(a),\n });\n });\n\n app.post(\"/api/leads\", async (c: any) => {\n const a = await actor(c);\n requireTeam(a);\n requirePartnerPermission(a, \"create_leads\");\n const data = await body(c);\n const title = str(data.title || data.company_name || data.contact_name);\n if (!title) throw new Error(\"Lead title or company name is required\");\n const leadId = uid();\n const stamp = now();\n const partnerId = a.actorType === \"partner\" ? a.actorId : str(data.partner_id) || null;\n let ownerId = a.actorType === \"internal\" ? str(data.owner_user_id) || a.actorId : str(data.owner_user_id) || null;\n if (!ownerId) {\n const owner = await db.execute(\"SELECT id FROM internal_users WHERE active=1 ORDER BY CASE role WHEN 'admin' THEN 0 ELSE 1 END,name LIMIT 1\");\n ownerId = str(owner.rows[0]?.id) || null;\n }\n await db.batch([\n {\n sql: \"INSERT INTO leads(id,title,company_name,contact_name,contact_email,contact_phone,category,business_type,source,stage,priority,expected_budget,currency,partner_id,owner_user_id,requirements_markdown,pain_points,inside_info,use_case_hint,next_follow_up_at,created_by_type,created_by_id,created_at,updated_at) VALUES(?,?,?,?,?,?,?,?,?,'new',?,?,?,?,?,?,?,?,?,?,?,?,?,?)\",\n args: [leadId, title, str(data.company_name), str(data.contact_name), str(data.contact_email), str(data.contact_phone), str(data.category), str(data.business_type), str(data.source), [\"low\", \"medium\", \"high\", \"urgent\"].includes(data.priority) ? data.priority : \"medium\", Number(data.expected_budget) || 0, str(data.currency) || \"INR\", partnerId, ownerId, str(data.requirements_markdown), str(data.pain_points), str(data.inside_info), str(data.use_case_hint), str(data.next_follow_up_at) || null, a.actorType, a.actorId, stamp, stamp],\n },\n {\n sql: \"INSERT INTO lead_events(id,lead_id,event_type,title,details,metadata,actor_type,actor_id,actor_name,occurred_at,created_at) VALUES(?,?,'created','Lead created',?,'{}',?,?,?,?,?)\",\n args: [uid(), leadId, title, a.actorType, a.actorId, a.name, stamp, stamp],\n },\n ]);\n return c.json({ ok: true, id: leadId }, 201);\n });\n\n app.patch(\"/api/leads/:id\", async (c: any) => {\n const a = await actor(c);\n requireTeam(a);\n requirePartnerPermission(a, \"edit_leads\");\n const lead = await getLead(c.req.param(\"id\"), a);\n if (!lead) throw new Error(\"Lead not found\");\n const data = await body(c);\n const nextStage = data.stage === undefined ? lead.stage : LEAD_STAGES.includes(data.stage) ? data.stage : (() => { throw new Error(\"Invalid lead stage\"); })();\n const changed: string[] = [];\n if (nextStage !== lead.stage) changed.push(\"Stage: \" + lead.stage + \" → \" + nextStage);\n for (const key of [\"requirements_markdown\", \"next_follow_up_at\", \"expected_budget\", \"partner_id\", \"owner_user_id\"]) {\n if (data[key] !== undefined && String(data[key] ?? \"\") !== String(lead[key] ?? \"\")) changed.push(key.replaceAll(\"_\", \" \") + \" updated\");\n }\n await db.execute({\n sql: \"UPDATE leads SET title=?,company_name=?,contact_name=?,contact_email=?,contact_phone=?,category=?,business_type=?,source=?,stage=?,priority=?,expected_budget=?,currency=?,partner_id=?,owner_user_id=?,requirements_markdown=?,pain_points=?,inside_info=?,use_case_hint=?,next_follow_up_at=?,lost_reason=?,updated_at=? WHERE id=?\",\n args: [str(data.title ?? lead.title) || lead.title, str(data.company_name ?? lead.company_name), str(data.contact_name ?? lead.contact_name), str(data.contact_email ?? lead.contact_email), str(data.contact_phone ?? lead.contact_phone), str(data.category ?? lead.category), str(data.business_type ?? lead.business_type), str(data.source ?? lead.source), nextStage, [\"low\", \"medium\", \"high\", \"urgent\"].includes(data.priority) ? data.priority : lead.priority, data.expected_budget === undefined ? Number(lead.expected_budget) : Number(data.expected_budget) || 0, str(data.currency ?? lead.currency) || \"INR\", a.actorType === \"partner\" ? a.actorId : data.partner_id === undefined ? lead.partner_id : str(data.partner_id) || null, data.owner_user_id === undefined ? lead.owner_user_id : str(data.owner_user_id) || null, str(data.requirements_markdown ?? lead.requirements_markdown), str(data.pain_points ?? lead.pain_points), str(data.inside_info ?? lead.inside_info), str(data.use_case_hint ?? lead.use_case_hint), data.next_follow_up_at === undefined ? lead.next_follow_up_at : str(data.next_follow_up_at) || null, str(data.lost_reason ?? lead.lost_reason), now(), lead.id],\n });\n await logLead(lead.id, a, nextStage !== lead.stage ? \"stage\" : \"updated\", nextStage !== lead.stage ? \"Lead moved to \" + nextStage : \"Lead details updated\", changed.join(\"\\n\"));\n return c.json({ ok: true });\n });\n\n app.post(\"/api/leads/:id/followups\", async (c: any) => {\n const a = await actor(c);\n requireTeam(a);\n requirePartnerPermission(a, \"edit_leads\");\n const lead = await getLead(c.req.param(\"id\"), a);\n if (!lead) throw new Error(\"Lead not found\");\n const data = await body(c);\n const note = str(data.note);\n if (!note) throw new Error(\"Follow-up note is required\");\n const dueAt = safeDateTime(data.due_at);\n const id = uid();\n const stamp = now();\n await db.batch([\n { sql: \"INSERT INTO lead_followups(id,lead_id,note,due_at,status,created_by_type,created_by_id,created_at,updated_at) VALUES(?,?,?,?,'open',?,?,?,?)\", args: [id, lead.id, note, dueAt, a.actorType, a.actorId, stamp, stamp] },\n { sql: \"UPDATE leads SET next_follow_up_at=?,updated_at=? WHERE id=?\", args: [dueAt, stamp, lead.id] },\n ]);\n await logLead(lead.id, a, \"follow_up\", \"Follow-up scheduled\", note, { due_at: dueAt });\n return c.json({ ok: true, id }, 201);\n });\n\n app.patch(\"/api/lead-followups/:id\", async (c: any) => {\n const a = await actor(c);\n requireTeam(a);\n requirePartnerPermission(a, \"edit_leads\");\n const result = await db.execute({ sql: \"SELECT * FROM lead_followups WHERE id=?\", args: [c.req.param(\"id\")] });\n const followup = result.rows[0];\n const lead = followup ? await getLead(String(followup.lead_id), a) : null;\n if (!followup || !lead) throw new Error(\"Follow-up not found\");\n const data = await body(c);\n const completed = data.status === \"completed\" || data.completed === true;\n await db.execute({\n sql: \"UPDATE lead_followups SET note=?,due_at=?,status=?,completed_at=?,updated_at=? WHERE id=?\",\n args: [str(data.note ?? followup.note) || followup.note, data.due_at === undefined ? followup.due_at : safeDateTime(data.due_at), completed ? \"completed\" : \"open\", completed ? now() : null, now(), followup.id],\n });\n await logLead(lead.id, a, \"follow_up\", completed ? \"Follow-up completed\" : \"Follow-up updated\", str(data.note ?? followup.note));\n return c.json({ ok: true });\n });\n\n app.post(\"/api/leads/:id/attach-project\", async (c: any) => {\n const a = await actor(c);\n requireTeam(a);\n requirePartnerPermission(a, \"edit_leads\");\n const lead = await getLead(c.req.param(\"id\"), a);\n const data = await body(c);\n const project = lead ? await allowedProject(str(data.project_id), a) : null;\n if (!lead || !project) throw new Error(\"Lead or project not found\");\n if (project.lead_id && String(project.lead_id) !== String(lead.id)) throw new Error(\"Project is already attached to another lead\");\n const statements: DbStatement[] = [{ sql: \"UPDATE projects SET lead_id=?,partner_id=COALESCE(partner_id,?),updated_at=? WHERE id=?\", args: [lead.id, lead.partner_id, now(), project.id] }];\n if (data.copy_stakeholder !== false && str(lead.contact_name) && str(lead.contact_phone) && str(lead.contact_email)) {\n statements.push({\n sql: \"INSERT INTO stakeholders(id,project_id,name,phone,email,role,is_main_poc,email_cc,created_at) SELECT ?,?,?,?,?,?,CASE WHEN EXISTS(SELECT 1 FROM stakeholders WHERE project_id=?) THEN 0 ELSE 1 END,0,? WHERE NOT EXISTS(SELECT 1 FROM stakeholders WHERE project_id=? AND email=?)\",\n args: [uid(), project.id, lead.contact_name, lead.contact_phone, lead.contact_email, \"Lead contact\", project.id, now(), project.id, lead.contact_email],\n });\n }\n await db.batch(statements);\n await logLead(lead.id, a, \"project\", \"Existing project attached\", String(project.title), { project_id: project.id });\n return c.json({ ok: true });\n });\n\n app.post(\"/api/leads/:id/projects\", async (c: any) => {\n const a = await actor(c);\n requireTeam(a);\n requirePartnerPermission(a, \"convert_leads\");\n requirePartnerPermission(a, \"create_projects\");\n const lead = await getLead(c.req.param(\"id\"), a);\n if (!lead) throw new Error(\"Lead not found\");\n const data = await body(c);\n if (!str(data.title)) throw new Error(\"Project title is required\");\n let ownerId = str(data.owner_user_id || lead.owner_user_id);\n if (!ownerId) {\n const owner = await db.execute(\"SELECT id FROM internal_users WHERE active=1 ORDER BY CASE role WHEN 'admin' THEN 0 ELSE 1 END,name LIMIT 1\");\n ownerId = str(owner.rows[0]?.id);\n }\n const partnerId = a.actorType === \"partner\" ? a.actorId : str(data.partner_id || lead.partner_id) || null;\n const projectId = uid();\n const projectData = {\n ...data,\n lead_id: lead.id,\n markdown_details: str(data.markdown_details || lead.requirements_markdown),\n description: str(data.description || lead.pain_points || lead.use_case_hint).split(/\\r?\\n/)[0].slice(0, 240),\n stakeholders: data.copy_stakeholder === false ? [] : [{\n name: lead.contact_name,\n phone: lead.contact_phone,\n email: lead.contact_email,\n role: \"Lead contact\",\n email_cc: false,\n }],\n };\n const built = projectInsertStatements(projectId, projectData, {\n actorType: a.actorType,\n actorId: a.actorId,\n ownerId,\n partnerId,\n status: a.actorType === \"partner\" ? \"backlog\" : str(data.status) || \"backlog\",\n });\n built.statements.push({ sql: \"UPDATE leads SET stage='won',updated_at=? WHERE id=?\", args: [now(), lead.id] });\n await db.batch(built.statements);\n await logLead(lead.id, a, \"project\", \"Project created from lead\", str(data.title), { project_id: projectId });\n return c.json({ ok: true, id: projectId, client_pin: built.clientPin }, 201);\n });\n\n app.get(\"/api/conversations\", async (c: any) => {\n const a = await actor(c);\n requireTeam(a);\n requirePartnerPermission(a, \"chat\");\n let sql = \"SELECT c.*,p.name partner_name,u.name internal_name,CASE WHEN c.context_type='lead' THEN (SELECT title FROM leads WHERE id=c.context_id) ELSE (SELECT title FROM projects WHERE id=c.context_id) END context_title,(SELECT body FROM conversation_messages m WHERE m.conversation_id=c.id ORDER BY m.created_at DESC LIMIT 1) last_message FROM conversations c JOIN partners p ON p.id=c.partner_id JOIN internal_users u ON u.id=c.internal_user_id WHERE 1=1\";\n const args: unknown[] = [];\n if (a.actorType === \"partner\") {\n sql += \" AND c.partner_id=?\";\n args.push(a.actorId);\n } else if (!admin(a)) {\n sql += \" AND c.internal_user_id=?\";\n args.push(a.actorId);\n }\n sql += \" ORDER BY COALESCE(c.last_message_at,c.created_at) DESC\";\n const result = await db.execute({ sql, args });\n return c.json({ conversations: result.rows.map((item: any) => ({\n ...item,\n unread: a.actorType === \"partner\"\n ? Boolean(item.last_message_at && (!item.last_read_partner_at || item.last_message_at > item.last_read_partner_at))\n : Boolean(item.last_message_at && (!item.last_read_internal_at || item.last_message_at > item.last_read_internal_at)),\n })), options: await optionsFor(a) });\n });\n\n app.post(\"/api/conversations\", async (c: any) => {\n const a = await actor(c);\n requireTeam(a);\n requirePartnerPermission(a, \"chat\");\n const data = await body(c);\n const contextType = data.context_type === \"lead\" ? \"lead\" : data.context_type === \"project\" ? \"project\" : \"\";\n if (!contextType) throw new Error(\"Select a lead or project context\");\n const contextId = str(data.context_id);\n const subject = str(data.subject);\n if (!subject) throw new Error(\"Thread subject is required\");\n const partnerId = a.actorType === \"partner\" ? a.actorId : str(data.partner_id);\n const internalUserId = a.actorType === \"internal\" ? a.actorId : str(data.internal_user_id);\n if (!partnerId || !internalUserId) throw new Error(\"Select the partner and AFLABS user\");\n const context = contextType === \"lead\"\n ? (await db.execute({ sql: \"SELECT id,partner_id FROM leads WHERE id=?\", args: [contextId] })).rows[0]\n : (await db.execute({ sql: \"SELECT id,partner_id FROM projects WHERE id=?\", args: [contextId] })).rows[0];\n if (!context || String(context.partner_id || \"\") !== partnerId) throw new Error(\"The selected context does not belong to this partner\");\n const id = uid();\n const stamp = now();\n await db.execute({\n sql: \"INSERT INTO conversations(id,context_type,context_id,partner_id,internal_user_id,subject,status,created_at,updated_at) VALUES(?,?,?,?,?,?,'open',?,?)\",\n args: [id, contextType, contextId, partnerId, internalUserId, subject, stamp, stamp],\n });\n if (str(data.message)) {\n await db.execute({ sql: \"INSERT INTO conversation_messages(id,conversation_id,sender_type,sender_id,sender_name,body,created_at) VALUES(?,?,?,?,?,?,?)\", args: [uid(), id, a.actorType, a.actorId, a.name, str(data.message), stamp] });\n await db.execute({ sql: \"UPDATE conversations SET last_message_at=?,updated_at=? WHERE id=?\", args: [stamp, stamp, id] });\n }\n return c.json({ ok: true, id }, 201);\n });\n\n app.get(\"/api/conversations/:id/messages\", async (c: any) => {\n const a = await actor(c);\n requireTeam(a);\n requirePartnerPermission(a, \"chat\");\n let sql = \"SELECT c.*, CASE WHEN c.context_type='lead' THEN (SELECT title FROM leads WHERE id=c.context_id) ELSE (SELECT title FROM projects WHERE id=c.context_id) END context_title FROM conversations c WHERE c.id=?\";\n const args: unknown[] = [c.req.param(\"id\")];\n if (a.actorType === \"partner\") {\n sql += \" AND c.partner_id=?\";\n args.push(a.actorId);\n } else if (!admin(a)) {\n sql += \" AND c.internal_user_id=?\";\n args.push(a.actorId);\n }\n const conversation = (await db.execute({ sql, args })).rows[0];\n if (!conversation) throw new Error(\"Conversation not found\");\n const stamp = now();\n await db.execute({\n sql: a.actorType === \"partner\" ? \"UPDATE conversations SET last_read_partner_at=? WHERE id=?\" : \"UPDATE conversations SET last_read_internal_at=? WHERE id=?\",\n args: [stamp, conversation.id],\n });\n const messages = await db.execute({ sql: \"SELECT * FROM conversation_messages WHERE conversation_id=? ORDER BY created_at\", args: [conversation.id] });\n return c.json({ conversation, messages: messages.rows });\n });\n\n app.patch(\"/api/conversations/:id\", async (c: any) => {\n const a = await actor(c);\n requireTeam(a);\n requirePartnerPermission(a, \"chat\");\n let sql = \"SELECT * FROM conversations WHERE id=?\";\n const args: unknown[] = [c.req.param(\"id\")];\n if (a.actorType === \"partner\") {\n sql += \" AND partner_id=?\";\n args.push(a.actorId);\n } else if (!admin(a)) {\n sql += \" AND internal_user_id=?\";\n args.push(a.actorId);\n }\n const conversation = (await db.execute({ sql, args })).rows[0];\n if (!conversation) throw new Error(\"Conversation not found\");\n const data = await body(c);\n const status = data.status === \"closed\" ? \"closed\" : data.status === \"open\" ? \"open\" : \"\";\n if (!status) throw new Error(\"Select open or closed status\");\n await db.execute({ sql: \"UPDATE conversations SET status=?,updated_at=? WHERE id=?\", args: [status, now(), conversation.id] });\n return c.json({ ok: true, status });\n });\n app.post(\"/api/conversations/:id/messages\", async (c: any) => {\n const a = await actor(c);\n requireTeam(a);\n requirePartnerPermission(a, \"chat\");\n let sql = \"SELECT * FROM conversations WHERE id=?\";\n const args: unknown[] = [c.req.param(\"id\")];\n if (a.actorType === \"partner\") {\n sql += \" AND partner_id=?\";\n args.push(a.actorId);\n } else if (!admin(a)) {\n sql += \" AND internal_user_id=?\";\n args.push(a.actorId);\n }\n const conversation = (await db.execute({ sql, args })).rows[0];\n if (!conversation) throw new Error(\"Conversation not found\");\n if (conversation.status === \"closed\") throw new Error(\"Reopen this thread before replying\");\n const data = await body(c);\n const message = str(data.body);\n if (!message) throw new Error(\"Message is required\");\n const stamp = now();\n await db.batch([\n { sql: \"INSERT INTO conversation_messages(id,conversation_id,sender_type,sender_id,sender_name,body,created_at) VALUES(?,?,?,?,?,?,?)\", args: [uid(), conversation.id, a.actorType, a.actorId, a.name, message, stamp] },\n { sql: \"UPDATE conversations SET last_message_at=?,updated_at=? WHERE id=?\", args: [stamp, stamp, conversation.id] },\n ]);\n return c.json({ ok: true }, 201);\n });\n\n app.get(\"/api/meetings\", async (c: any) => {\n const a = await actor(c);\n requireTeam(a);\n requirePartnerPermission(a, \"book_meetings\");\n const partnerId = a.actorType === \"partner\" ? a.actorId : str(c.req.query(\"partner_id\"));\n let meetingSql = \"SELECT m.*,p.name partner_name,u.name internal_name FROM meetings m JOIN partners p ON p.id=m.partner_id LEFT JOIN internal_users u ON u.id=m.internal_user_id WHERE m.ends_at>=?\";\n const args: unknown[] = [now()];\n if (a.actorType === \"partner\") {\n meetingSql += \" AND m.partner_id=?\";\n args.push(a.actorId);\n } else if (!admin(a)) {\n meetingSql += \" AND (m.internal_user_id=? OR m.created_by_id=?)\";\n args.push(a.actorId, a.actorId);\n }\n meetingSql += \" ORDER BY m.starts_at\";\n const results = await Promise.all([\n db.execute({ sql: meetingSql, args }),\n meetingScheduleData(),\n partnerId ? targetSnapshot(partnerId) : Promise.resolve(null),\n optionsFor(a),\n ]);\n const meetings = results[0], scheduleData: any = results[1], snapshot = results[2], options = results[3];\r\n const calendar = a.actorType === \"partner\" ? scheduleData.calendar.map((day: any) => ({ ...day, slots: day.slots.map((slot: any) => ({ ...slot, meeting_id: null, partner_name: \"\", note: \"\" })) })) : scheduleData.calendar;\n return c.json({\n slots: scheduleData.availableSlots,\n calendar,\n schedule: scheduleData.schedule,\n blocks: admin(a) ? scheduleData.blocks : [],\n holidays: scheduleData.holidays,\n weekly_days: scheduleData.weekly_days,\n meetings: meetings.rows,\n target: snapshot,\n options,\n });\n });\n\n app.patch(\"/api/admin/meeting-schedule\", async (c: any) => {\n const a = await actor(c);\n if (!admin(a)) throw new Error(\"Admins only can manage meeting hours\");\n const data = await body(c);\n const days = (Array.isArray(data.days) ? data.days : []).map(Number).filter((day: number) => Number.isInteger(day) && day >= 0 && day <= 6);\n const start = /^\\d{2}:\\d{2}$/.test(str(data.start)) ? str(data.start) : \"\";\n const end = /^\\d{2}:\\d{2}$/.test(str(data.end)) ? str(data.end) : \"\";\n const duration = Number(data.duration);\n if (!days.length) throw new Error(\"Select at least one available day\");\n if (!start || !end || timeMinutes(end) <= timeMinutes(start)) throw new Error(\"Business hours must end after they start\");\n if (![15, 30, 45, 60, 90, 120].includes(duration)) throw new Error(\"Select a valid meeting duration\");\n const schedule = { days: [...new Set(days)], start, end, duration, horizon_days: Math.min(60, Math.max(7, Number(data.horizon_days) || 21)), timezone: \"Asia/Kolkata\" };\n await saveSetting(\"meeting_schedule\", JSON.stringify(schedule));\n return c.json({ ok: true, schedule });\n });\n app.post(\"/api/admin/meeting-slots\", async (c: any) => {\n const a = await actor(c);\n if (!admin(a)) throw new Error(\"Admins only can manage availability\");\n const data = await body(c);\n const startsAt = safeDateTime(data.starts_at);\n const endsAt = safeDateTime(data.ends_at);\n if (Date.parse(endsAt) <= Date.parse(startsAt)) throw new Error(\"End time must be after start time\");\r\n if (data.slot_type === \"blocked\") {\n const date = indiaDate(startsAt);\n const day = new Date(date + \"T12:00:00Z\").getUTCDay();\n const holidayResults = await Promise.all([\n db.execute({ sql: \"SELECT name FROM holidays WHERE holiday_date=? LIMIT 1\", args: [date] }),\n db.execute(\"SELECT weekly_days FROM holiday_settings WHERE id='default'\"),\n ]);\n const weeklyDays = json(holidayResults[1].rows[0]?.weekly_days, [5, 6]).map(Number);\n const holidayName = holidayResults[0].rows[0]?.name || (weeklyDays.includes(day) ? \"Weekly holiday\" : \"\");\n if (holidayName) throw new Error(\"This date is already unavailable: \" + holidayName);\n }\n await db.execute({\n sql: \"INSERT INTO meeting_slots(id,slot_type,starts_at,ends_at,note,created_by_id,created_at) VALUES(?,?,?,?,?,?,?)\",\n args: [uid(), data.slot_type === \"blocked\" ? \"blocked\" : \"available\", startsAt, endsAt, str(data.note), a.actorId, now()],\n });\n return c.json({ ok: true }, 201);\n });\n\n app.delete(\"/api/admin/meeting-slots/:id\", async (c: any) => {\n const a = await actor(c);\n if (!admin(a)) throw new Error(\"Admins only can manage availability\");\n await db.execute({ sql: \"DELETE FROM meeting_slots WHERE id=?\", args: [c.req.param(\"id\")] });\n return c.json({ ok: true });\n });\n\n app.post(\"/api/meetings\", async (c: any) => {\n const a = await actor(c);\n requireTeam(a);\n requirePartnerPermission(a, \"book_meetings\");\n const data = await body(c);\n const partnerId = a.actorType === \"partner\" ? a.actorId : str(data.partner_id);\n if (!partnerId) throw new Error(\"Select a partner\");\n const startsAt = safeDateTime(data.starts_at);\n const endsAt = safeDateTime(data.ends_at);\n if (Date.parse(endsAt) <= Date.parse(startsAt) || Date.parse(startsAt) < Date.now()) throw new Error(\"Select a valid future time\");\n if (a.actorType === \"partner\") {\n const availability = await db.execute({ sql: \"SELECT id FROM meeting_slots WHERE slot_type='available' AND starts_at<=? AND ends_at>=? LIMIT 1\", args: [startsAt, endsAt] });\n const generated = await meetingScheduleData();\n const scheduleMatch = generated.allSlots.some((item: any) => item.status === \"available\" && item.starts_at === startsAt && item.ends_at === endsAt);\n if (!availability.rows[0] && !scheduleMatch) throw new Error(\"Select an available business-hours slot\");\n const blocked = await db.execute({ sql: \"SELECT id FROM meeting_slots WHERE slot_type='blocked' AND starts_at? LIMIT 1\", args: [endsAt, startsAt] });\n if (blocked.rows[0]) throw new Error(\"This time is blocked\");\n const snapshot = await targetSnapshot(partnerId, startsAt.slice(0, 7));\n const limit = Number(snapshot.target?.meetings_allowed || 0);\n if (!limit || snapshot.achieved.meetings >= limit) throw new Error(\"Monthly meeting allowance has been used\");\n }\n const collision = await db.execute({ sql: \"SELECT id FROM meetings WHERE status<>'cancelled' AND starts_at? LIMIT 1\", args: [endsAt, startsAt] });\n if (collision.rows[0]) throw new Error(\"That time is already booked\");\n const contextType = [\"lead\", \"project\", \"other\"].includes(data.context_type) ? data.context_type : \"other\";\n const contextId = contextType === \"other\" ? null : str(data.context_id);\n if (contextId) {\n const context = contextType === \"lead\"\n ? (await db.execute({ sql: \"SELECT partner_id FROM leads WHERE id=?\", args: [contextId] })).rows[0]\n : (await db.execute({ sql: \"SELECT partner_id FROM projects WHERE id=?\", args: [contextId] })).rows[0];\n if (!context || String(context.partner_id || \"\") !== partnerId) throw new Error(\"Selected context does not belong to this partner\");\n }\n const id = uid();\n const stamp = now();\n await db.execute({\n sql: \"INSERT INTO meetings(id,partner_id,internal_user_id,context_type,context_id,agenda,starts_at,ends_at,join_url,place,status,created_by_type,created_by_id,created_at,updated_at) VALUES(?,?,?,?,?,?,?,?,?,?,'booked',?,?,?,?)\",\n args: [id, partnerId, str(data.internal_user_id) || null, contextType, contextId, str(data.agenda) || \"Partner meeting\", startsAt, endsAt, /^https?:\\/\\//.test(str(data.join_url)) ? str(data.join_url) : null, str(data.place) || null, a.actorType, a.actorId, stamp, stamp],\n });\n return c.json({ ok: true, id }, 201);\n });\n\n app.patch(\"/api/meetings/:id\", async (c: any) => {\n const a = await actor(c);\n requireTeam(a);\n const result = await db.execute({ sql: \"SELECT * FROM meetings WHERE id=?\", args: [c.req.param(\"id\")] });\n const meeting = result.rows[0];\n if (!meeting || (a.actorType === \"partner\" && String(meeting.partner_id) !== a.actorId)) throw new Error(\"Meeting not found\");\n const data = await body(c);\n const status = [\"booked\", \"confirmed\", \"completed\", \"cancelled\"].includes(data.status) ? data.status : meeting.status;\n if (a.actorType === \"partner\" && ![\"booked\", \"cancelled\"].includes(status)) throw new Error(\"Only AFLABS can confirm or complete meetings\");\n await db.execute({\n sql: \"UPDATE meetings SET internal_user_id=?,join_url=?,place=?,status=?,updated_at=? WHERE id=?\",\n args: [a.actorType === \"partner\" ? meeting.internal_user_id : str(data.internal_user_id ?? meeting.internal_user_id) || null, data.join_url === undefined ? meeting.join_url : /^https?:\\/\\//.test(str(data.join_url)) ? str(data.join_url) : null, data.place === undefined ? meeting.place : str(data.place) || null, status, now(), meeting.id],\n });\n return c.json({ ok: true });\n });\n\n app.get(\"/api/mou\", async (c: any) => {\n const a = await actor(c);\n requireTeam(a);\n const partnerId = a.actorType === \"partner\" ? a.actorId : str(c.req.query(\"partner_id\"));\n if (a.actorType !== \"partner\" && !admin(a)) throw new Error(\"Admins only can manage partner agreements\");\n const partners = admin(a) ? await db.execute(\"SELECT id,name FROM partners WHERE active=1 ORDER BY name\") : { rows: [] };\n const templates = admin(a) ? await db.execute(\"SELECT * FROM mou_templates WHERE active=1 ORDER BY updated_at DESC\") : { rows: [] };\n if (!partnerId) return c.json({ partners: partners.rows, templates: templates.rows, mou: null, targets: [], snapshot: null });\n const [partner, mou, targets] = await Promise.all([\n db.execute({ sql: \"SELECT id,name,brand_name FROM partners WHERE id=?\", args: [partnerId] }),\n db.execute({ sql: \"SELECT * FROM partner_mous WHERE partner_id=? ORDER BY created_at DESC LIMIT 1\", args: [partnerId] }),\n db.execute({ sql: \"SELECT * FROM partner_targets WHERE partner_id=? ORDER BY target_month DESC,created_at DESC\", args: [partnerId] }),\n ]);\n if (!partner.rows[0] || (a.actorType === \"partner\" && partnerId !== a.actorId)) throw new Error(\"Partner not found\");\n return c.json({ partners: partners.rows, templates: templates.rows, partner: partner.rows[0], mou: mou.rows[0] || null, targets: targets.rows, snapshot: await targetSnapshot(partnerId) });\n });\n\n app.post(\"/api/admin/mou-templates\", async (c: any) => {\n const a = await actor(c);\n if (!admin(a)) throw new Error(\"Admins only can manage MoU templates\");\n const data = await body(c);\n if (!str(data.name) || !str(data.terms_markdown)) throw new Error(\"Template name and terms are required\");\n const stamp = now();\n await db.execute({ sql: \"INSERT INTO mou_templates(id,name,terms_markdown,benefits_markdown,active,created_by_id,created_at,updated_at) VALUES(?,?,?,?,1,?,?,?)\", args: [uid(), str(data.name), str(data.terms_markdown), str(data.benefits_markdown), a.actorId, stamp, stamp] });\n return c.json({ ok: true }, 201);\n });\n\n app.post(\"/api/admin/partners/:id/mou\", async (c: any) => {\n const a = await actor(c);\n if (!admin(a)) throw new Error(\"Admins only can manage partner agreements\");\n const data = await body(c);\n let terms = str(data.terms_markdown);\n let benefits = str(data.benefits_markdown);\n const templateId = str(data.template_id) || null;\n if (templateId && (!terms || !benefits)) {\n const template = (await db.execute({ sql: \"SELECT * FROM mou_templates WHERE id=?\", args: [templateId] })).rows[0];\n if (!template) throw new Error(\"MoU template not found\");\n terms ||= str(template.terms_markdown);\n benefits ||= str(template.benefits_markdown);\n }\n if (!terms) throw new Error(\"MoU terms are required\");\n await db.batch([\n { sql: \"UPDATE partner_mous SET status='superseded' WHERE partner_id=? AND status='active'\", args: [c.req.param(\"id\")] },\n { sql: \"INSERT INTO partner_mous(id,partner_id,template_id,terms_markdown,benefits_markdown,effective_from,status,created_by_id,created_at) VALUES(?,?,?,?,?,?,'active',?,?)\", args: [uid(), c.req.param(\"id\"), templateId, terms, benefits, str(data.effective_from) || now().slice(0, 10), a.actorId, now()] },\n ]);\n return c.json({ ok: true }, 201);\n });\n\n app.post(\"/api/admin/partners/:id/targets\", async (c: any) => {\n const a = await actor(c);\n if (!admin(a)) throw new Error(\"Admins only can manage partner targets\");\n const data = await body(c);\n const month = monthBounds(data.target_month).month;\n await db.execute({\n sql: \"INSERT INTO partner_targets(id,partner_id,target_month,leads_target,projects_target,revenue_target,revenue_currency,meetings_allowed,note,created_by_id,created_at) VALUES(?,?,?,?,?,?,?,?,?,?,?)\",\n args: [uid(), c.req.param(\"id\"), month, Math.max(0, Number(data.leads_target) || 0), Math.max(0, Number(data.projects_target) || 0), Math.max(0, Number(data.revenue_target) || 0), str(data.revenue_currency) || \"INR\", Math.max(0, Number(data.meetings_allowed) || 0), str(data.note), a.actorId, now()],\n });\n return c.json({ ok: true }, 201);\n });\n\n app.get(\"/api/business-ideas\", async (c: any) => {\n const a = await actor(c);\n requireTeam(a);\n requirePartnerPermission(a, \"use_ai\");\n let sql = \"SELECT i.*,p.name partner_name FROM business_ideas i LEFT JOIN partners p ON p.id=i.partner_id WHERE 1=1\";\n const args: unknown[] = [];\n if (a.actorType === \"partner\") {\n sql += \" AND i.partner_id=?\";\n args.push(a.actorId);\n } else if (!admin(a)) {\n sql += \" AND i.created_by_type='internal' AND i.created_by_id=?\";\n args.push(a.actorId);\n }\n sql += \" ORDER BY i.created_at DESC\";\n const result = await db.execute({ sql, args });\n return c.json({ ideas: result.rows.map((idea: any) => ({ ...idea, input_data: json(idea.input_data, {}) })), options: await optionsFor(a) });\n });\n\n app.post(\"/api/business-ideas\", async (c: any) => {\n const a = await actor(c);\n requireTeam(a);\n requirePartnerPermission(a, \"use_ai\");\n const data = await body(c);\n for (const key of [\"customer_name\", \"category\", \"business_type\", \"pain_points\", \"use_case_hint\"]) {\n if (!str(data[key])) throw new Error(key.replaceAll(\"_\", \" \") + \" is required\");\n }\n const prompt = await setting(\"business_pitch_prompt\", IDEA_PROMPT);\n const input = {\n customer_name: str(data.customer_name),\n category: str(data.category),\n business_type: str(data.business_type),\n pain_points: str(data.pain_points),\n inside_info: str(data.inside_info),\n use_case_hint: str(data.use_case_hint),\n budget: Number(data.budget) || 0,\n currency: str(data.currency) || \"INR\",\n };\n const response = await openai.responses.create({\n model: \"gpt-5.4-mini\",\n instructions: prompt,\n input: \"Build the pitch around these verified inputs:\\n\" + JSON.stringify(input, null, 2),\n });\n const generated = str(response.output_text);\n if (!generated) throw new Error(\"AI did not return a pitch\");\n const id = uid();\n const partnerId = a.actorType === \"partner\" ? a.actorId : str(data.partner_id) || null;\n const stamp = now();\n await db.execute({\n sql: \"INSERT INTO business_ideas(id,title,input_data,generated_markdown,partner_id,created_by_type,created_by_id,created_at,updated_at) VALUES(?,?,?,?,?,?,?,?,?)\",\n args: [id, str(data.title) || input.customer_name + \" growth pitch\", JSON.stringify(input), generated, partnerId, a.actorType, a.actorId, stamp, stamp],\n });\n return c.json({ ok: true, id, generated_markdown: generated }, 201);\n });\n\n app.post(\"/api/business-ideas/:id/proposal\", async (c: any) => {\n const a = await actor(c);\n requireTeam(a);\n requirePartnerPermission(a, \"use_ai\");\n let sql = \"SELECT * FROM business_ideas WHERE id=?\";\n const args: unknown[] = [c.req.param(\"id\")];\n if (a.actorType === \"partner\") {\n sql += \" AND partner_id=?\";\n args.push(a.actorId);\n } else if (!admin(a)) {\n sql += \" AND created_by_id=?\";\n args.push(a.actorId);\n }\n const idea = (await db.execute({ sql, args })).rows[0];\n if (!idea) throw new Error(\"Business idea not found\");\n if (idea.proposal_id) return c.json({ ok: true, id: idea.proposal_id, existing: true });\n const prompt = await setting(\"proposal_prompt\", PROPOSAL_PROMPT);\n const response = await openai.responses.create({\n model: \"gpt-5.4-mini\",\n instructions: prompt,\n input: \"Create the proposal from this approved idea pitch:\\n\\n\" + idea.generated_markdown + \"\\n\\nVerified input:\\n\" + idea.input_data,\n });\n const markdown = str(response.output_text);\n const input = json(idea.input_data, {});\n const proposalId = uid();\n const stamp = now();\n await db.batch([\n { sql: \"INSERT INTO proposals(id,title,markdown_content,structured_data,partner_id,currency,total,status,created_by_id,created_at,updated_at) VALUES(?,?,?,?,?,?,?,'draft',?,?,?)\", args: [proposalId, idea.title, markdown, JSON.stringify({ project: { title: idea.title, description: str(input.pain_points).split(/\\r?\\n/)[0], markdown_details: markdown, currency: input.currency, regular_cost: input.budget }, source_business_idea_id: idea.id }), idea.partner_id, input.currency || \"INR\", Number(input.budget) || 0, a.actorId, stamp, stamp] },\n { sql: \"UPDATE business_ideas SET proposal_id=?,updated_at=? WHERE id=?\", args: [proposalId, stamp, idea.id] },\n ]);\n return c.json({ ok: true, id: proposalId }, 201);\n });\n\n app.get(\"/api/admin/ai-prompts\", async (c: any) => {\n const a = await actor(c);\n if (!admin(a)) throw new Error(\"Admins only can manage AI prompts\");\n return c.json({\n business_pitch_prompt: await setting(\"business_pitch_prompt\", IDEA_PROMPT),\n proposal_prompt: await setting(\"proposal_prompt\", PROPOSAL_PROMPT),\n });\n });\n\n app.patch(\"/api/admin/ai-prompts\", async (c: any) => {\n const a = await actor(c);\n if (!admin(a)) throw new Error(\"Admins only can manage AI prompts\");\n const data = await body(c);\n if (str(data.business_pitch_prompt)) await saveSetting(\"business_pitch_prompt\", str(data.business_pitch_prompt));\n if (str(data.proposal_prompt)) await saveSetting(\"proposal_prompt\", str(data.proposal_prompt));\n return c.json({ ok: true });\n });\n\n app.get(\"/api/growth/dashboard\", async (c: any) => {\n const a = await actor(c);\n requireTeam(a);\n let leadSql = \"SELECT * FROM leads WHERE 1=1\";\n let projectSql = \"SELECT p.*,COALESCE((SELECT SUM(amount) FROM payments pm WHERE pm.project_id=p.id),0) paid FROM projects p WHERE p.archived=0\";\n const leadArgs: unknown[] = [];\n const projectArgs: unknown[] = [];\n if (a.actorType === \"partner\") {\n leadSql += \" AND partner_id=?\";\n projectSql += \" AND partner_id=?\";\n leadArgs.push(a.actorId);\n projectArgs.push(a.actorId);\n } else if (!admin(a) && !a.allProjectAccess) {\n leadSql += \" AND owner_user_id=?\";\n projectSql += \" AND EXISTS(SELECT 1 FROM user_project_access x WHERE x.project_id=p.id AND x.user_id=?)\";\n leadArgs.push(a.actorId);\n projectArgs.push(a.actorId);\n }\n const [leads, projects, meetings, conversations] = await Promise.all([\n db.execute({ sql: leadSql, args: leadArgs }),\n db.execute({ sql: projectSql, args: projectArgs }),\n db.execute({ sql: \"SELECT COUNT(*) count FROM meetings WHERE status IN ('booked','confirmed') AND starts_at>=? \" + (a.actorType === \"partner\" ? \"AND partner_id=?\" : \"\"), args: a.actorType === \"partner\" ? [now(), a.actorId] : [now()] }),\n db.execute({ sql: \"SELECT COUNT(*) count FROM conversations WHERE last_message_at IS NOT NULL \" + (a.actorType === \"partner\" ? \"AND partner_id=? AND (last_read_partner_at IS NULL OR last_message_at>last_read_partner_at)\" : admin(a) ? \"AND (last_read_internal_at IS NULL OR last_message_at>last_read_internal_at)\" : \"AND internal_user_id=? AND (last_read_internal_at IS NULL OR last_message_at>last_read_internal_at)\"), args: a.actorType === \"partner\" ? [a.actorId] : admin(a) ? [] : [a.actorId] }),\n ]);\n const pipelineValue = leads.rows.filter((lead: any) => ![\"won\", \"lost\"].includes(lead.stage)).reduce((sum: number, lead: any) => sum + Number(lead.expected_budget || 0), 0);\n const won = leads.rows.filter((lead: any) => lead.stage === \"won\").length;\n const overdue = projects.rows.filter((project: any) => project.status !== \"done\" && project.end_date && Date.parse(project.end_date) < Date.now()).length;\n const snapshot = a.actorType === \"partner\" ? await targetSnapshot(a.actorId) : null;\n return c.json({\n leads_total: leads.rows.length,\n leads_won: won,\n conversion_rate: leads.rows.length ? Math.round(won / leads.rows.length * 100) : 0,\n pipeline_value: pipelineValue,\n pipeline_currency: str(leads.rows.find((lead: any) => Number(lead.expected_budget))?.currency) || \"INR\",\n active_projects: projects.rows.filter((project: any) => project.status !== \"done\").length,\n overdue_projects: overdue,\n upcoming_meetings: Number(meetings.rows[0]?.count || 0),\n unread_conversations: Number(conversations.rows[0]?.count || 0),\n target: snapshot,\n });\n });\n }\n\n return { migrate, register };\n}\n","deleted",false,"label",[14],"754e49f1-03b3-49a5-b751-be0ab27dd211",["D",1785324724390],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","AFLABS PM — projects, partners, and client timelines","imageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/7fb3e06c-d9ab-432f-445c-6f2687afb500/square512?exp=1789545599&sig=731ad733058e9c25e531a9524067abaaa43e5b631deb568e4634b46709c339f3","userId","1c0af5f4-5486-4207-b370-2ccd83bc1dcf","pinnedFileId","019fada5-614d-738d-bbb2-8ce609465f5b","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019f90d7-9872-7518-b6a7-7f6420c76125","tursoName","754e49f103b349a5b751be0ab27dd211","tursoHostname","754e49f103b349a5b751be0ab27dd211-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789492855745],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_110":106},"org",{"_9":10,"_103":104,"_105":106,"_56":57,"_107":108,"_109":42},"branch",{"_35":30,"_11":90,"_22":28,"_91":45,"_92":93,"_94":95,"_96":50,"_97":98,"_99":100,"_101":12,"_102":10},"isOwned","main","projectId","forkedBranchId","961078ea-f528-11ef-aa68-569c3dd06744","forkedBranchVersion",89,"forkedProjectPrivacy","forkedProjectId","96102714-f528-11ef-aa68-569c3dd06744","forkedProjectOrgId","019aa807-52c2-709c-928b-2029bae9a558","projectName","userHandle","displayName","alshell 7","avatar","https://lh3.googleusercontent.com/a/ACg8ocIgzGkcs1h98if29Hwf_aAP4jTjWQLgwQAaxKmdWUK166qTecxnAw=s96-c","tier","free","canRestrictVals","profileImageUrl","ctx",{"_83":-5,"_144":145,"_146":147,"_148":149,"_150":42,"_151":42,"_152":42,"_153":32,"_154":-5,"_155":-7,"_156":-7,"_157":64,"_158":42,"_159":42,"_160":-5,"_161":42,"_162":42,"_163":42,"_164":-5},"ENV",{"_115":116,"_117":118,"_119":90,"_120":121,"_122":123,"_124":125,"_126":127,"_128":129,"_130":131,"_132":133,"_134":135,"_136":137,"_138":139,"_140":141,"_142":143},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","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","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]