[{"_1":2,"_180":-5,"_181":-5},"loaderData",{"_3":4,"_95":96},"root",{"_5":6,"_36":37,"_68":69},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":-5,"_32":33,"_34":20,"_35":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesChatPanelState","notificationCount",0,"flagDenols","isBusinessOrgMember","ENV",{"_38":39,"_40":41,"_42":43,"_44":45,"_46":47,"_48":49,"_50":51,"_52":53,"_54":55,"_56":57,"_58":59,"_60":61,"_62":63,"_64":65,"_66":67},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","f33c6f02e3b9304fe5cb194294cedf6a64b697a5","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","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","API_URL","https://api.val.town","clerkState",{"_70":71},"__internal_clerk_state",{"_72":73,"_74":47,"_75":76,"_77":76,"_78":20,"_79":76,"_80":76,"_81":76,"_82":76,"_83":84,"_93":20,"_94":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_85":20,"_19":20,"_86":76,"_87":88,"_89":76,"_90":47,"_91":20,"_92":76},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_97":98,"_99":100,"_101":102,"_103":104,"_157":158,"_177":178,"_179":-5},"handle","abhishekplating","name","PlatingPro","path","ppSalesAI.ts","project",{"_105":106,"_99":100,"_107":108,"_109":-5,"_110":20,"_111":112,"_113":114,"_115":-5,"_12":116,"_117":-5,"_118":20,"_119":-5,"_120":-5,"_121":33,"_14":122,"_123":-5,"_124":-5,"_125":-5,"_126":127,"_128":127,"_129":130,"_131":130,"_132":130,"_133":127,"_134":127,"_23":135,"_138":139,"_143":144,"_156":20},"id","1fffa610-245e-11f1-b73d-42dde27851f2","createdAt",["D",1774012210756],"deletedAt","legacyEnvVars","privacy","public","description","V1","imageUrl","019ca7d6-bbec-76d6-822b-6e2c39ed1dbd","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","019ca7d6-bbec-76d6-822b-72f395b7c435","tursoName","tursoHostname","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_97":98,"_136":137},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzNBS1hsRkxLQ2d3eHdUMVYzU3p3YTNmakRRbSJ9","org",{"_97":98,"_140":137,"_12":116,"_141":142},"avatar","tier","free","branch",{"_145":146,"_99":45,"_105":147,"_148":106,"_149":-5,"_150":-5,"_151":-5,"_152":-5,"_153":-5,"_154":100,"_155":98},"version",104,"20008210-245e-11f1-b73d-42dde27851f2","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_105":159,"_99":102,"_160":161,"_162":-5,"_163":147,"_164":165,"_166":167,"_107":168,"_145":169,"_170":171,"_172":173,"_174":20,"_175":-5,"_101":176},"4f4d5fda-2c6e-11f1-a7fe-42dde27851f2","fileId","0fbbf532-2810-11f1-a8a8-42dde27851f2","parentId","branchId","branchVersion",102,"latest",true,["D",1774898771350],7,"fileType","http","content","// PlatingPro — Sales AI: Gemini Scan + Gmail Sync + Bulk PDF (V20)\nimport { sql, ok, err, rateLimit, isValidDate } from \"./ppShared.ts\";\n\nconst GEMINI_INVOICE_PROMPT = 'Extract ALL data from this GST sales invoice. Return ONLY valid JSON: {\"inv_no\":\"\",\"inv_date\":\"YYYY-MM-DD\",\"customer_name\":\"\",\"gstin\":\"\",\"items\":[{\"product_name\":\"\",\"hsn\":\"\",\"qty\":0,\"unit\":\"PCS\",\"rate\":0,\"amount\":0,\"color\":\"\"}],\"taxable\":0,\"cgst\":0,\"sgst\":0,\"igst\":0,\"total\":0}. Extract EVERY line item. Return ONLY JSON, no markdown.';\n\nasync function getGeminiKey(): Promise {\n const r = await sql`SELECT value FROM pp_settings WHERE key='gemini_api_key'`;\n return r[0]?.value || null;\n}\n\nasync function callGemini(apiKey: string, body: any): Promise<{ok:boolean,text:string}> {\n const resp = await fetch(`https://generativelanguage.googleapis.com/v1beta/models/gemini-2.5-flash:generateContent?key=${apiKey}`, {\n method: 'POST', headers: { 'Content-Type': 'application/json' }, body: JSON.stringify(body)\n });\n if (!resp.ok) { const t = await resp.text(); return { ok: false, text: t }; }\n const d = await resp.json();\n let text = d.candidates?.[0]?.content?.parts?.[0]?.text || '';\n text = text.replace(/```json\\s*/g,'').replace(/```\\s*/g,'').trim();\n return { ok: true, text };\n}\n\n// Scan a single PDF/image/text invoice via Gemini — returns scanned fields\nexport async function scanSalesInvoice(b: any, req?: Request): Promise {\n var content = b.content; var type = b.type || 'text';\n if (!content) return err(\"content required\", 400, req);\n // Reject oversized payloads before they crash Val Town (limit: ~3.5MB base64)\n if (typeof content === 'string' && content.length > 8 * 1024 * 1024) {\n return err(\"File too large even after compression (max ~6MB). Try uploading fewer pages at once.\", 413, req);\n }\n const apiKey = await getGeminiKey();\n if (!apiKey) return err(\"Gemini API key not configured\", 503, req);\n try {\n var gBody: any;\n if (type === 'pdf' || type === 'image') {\n var mimeType = type === 'pdf' ? 'application/pdf' : 'image/jpeg';\n gBody = { contents: [{ parts: [{ inline_data: { mime_type: mimeType, data: content } }, { text: GEMINI_INVOICE_PROMPT }] }], generationConfig: { temperature: 0.1, maxOutputTokens: 4000 } };\n } else {\n gBody = { contents: [{ parts: [{ text: GEMINI_INVOICE_PROMPT + '\\n\\nContent:\\n' + (typeof content === 'string' ? content : JSON.stringify(content)) }] }], generationConfig: { temperature: 0.1, maxOutputTokens: 4000 } };\n }\n const res = await callGemini(apiKey, gBody);\n if (!res.ok) return err('Gemini error: ' + res.text, 502, req);\n try {\n const parsed = JSON.parse(res.text);\n if (parsed.customer_name) {\n const cm = await sql`SELECT factory FROM pp_sales_customers WHERE LOWER(TRIM(name))=LOWER(TRIM(${parsed.customer_name}))`;\n parsed.factory = cm[0]?.factory || null;\n parsed.is_new_customer = cm.length === 0;\n }\n return ok({ scanned: parsed }, req);\n } catch (pe) { return err('Failed to parse Gemini response', 502, req); }\n } catch (e: any) { return err('Scan error: ' + e.message, 500, req); }\n}\n\n// Process a single email PDF via Gemini → save invoice to DB\nexport async function gmailSyncOne(b: any, req?: Request): Promise {\n var msgId = b.gmail_msg_id; var subject = b.gmail_subject || ''; var gmailDate = b.gmail_date || '';\n var attachName = b.attachment_name || ''; var pdfBase64 = b.pdf_base64;\n if (!msgId || !pdfBase64) return err(\"gmail_msg_id and pdf_base64 required\", 400, req);\n if (pdfBase64.length > 5*1024*1024) return err(\"PDF too large (max ~4MB). File: \" + (attachName||msgId), 400, req);\n\n // Check if already synced\n var dup = await sql`SELECT id,status,inv_no FROM pp_gmail_sync WHERE gmail_msg_id=${msgId}`;\n if (dup.length > 0) return ok({ skipped: true, reason: 'Already synced', inv_no: dup[0].inv_no, status: dup[0].status }, req);\n\n await sql`INSERT INTO pp_gmail_sync(gmail_msg_id,gmail_subject,gmail_date,attachment_name,status)VALUES(${msgId},${subject},${gmailDate},${attachName},'scanning')`;\n\n const apiKey = await getGeminiKey();\n if (!apiKey) {\n await sql`UPDATE pp_gmail_sync SET status='error',error='No Gemini API key' WHERE gmail_msg_id=${msgId}`;\n return err('Gemini API key not configured', 503, req);\n }\n\n try {\n const gBody = { contents: [{ parts: [{ inline_data: { mime_type: 'application/pdf', data: pdfBase64 } }, { text: GEMINI_INVOICE_PROMPT }] }], generationConfig: { temperature: 0.1, maxOutputTokens: 4000 } };\n const res = await callGemini(apiKey, gBody);\n if (!res.ok) {\n await sql`UPDATE pp_gmail_sync SET status='error',error=${'Gemini HTTP error'} WHERE gmail_msg_id=${msgId}`;\n return ok({ status: 'error', error: 'Gemini error', detail: res.text }, req);\n }\n\n var parsed: any;\n try { parsed = JSON.parse(res.text); }\n catch (pe) {\n await sql`UPDATE pp_gmail_sync SET status='error',error='JSON parse failed',scanned_data=${JSON.stringify({ raw: res.text.slice(0,500) })} WHERE gmail_msg_id=${msgId}`;\n return ok({ status: 'error', error: 'Failed to parse Gemini response', raw: res.text.slice(0,200) }, req);\n }\n\n await sql`UPDATE pp_gmail_sync SET scanned_data=${JSON.stringify(parsed)},inv_no=${parsed.inv_no||null} WHERE gmail_msg_id=${msgId}`;\n\n // Check duplicate invoice number\n if (parsed.inv_no) {\n var invDup = await sql`SELECT id FROM pp_sales_invoices WHERE inv_no=${parsed.inv_no.trim()}`;\n if (invDup.length > 0) {\n await sql`UPDATE pp_gmail_sync SET status='duplicate',invoice_id=${invDup[0].id} WHERE gmail_msg_id=${msgId}`;\n return ok({ status: 'duplicate', inv_no: parsed.inv_no, existing_id: invDup[0].id }, req);\n }\n }\n\n // Look up customer factory\n if (parsed.customer_name) {\n var cm = await sql`SELECT factory FROM pp_sales_customers WHERE LOWER(TRIM(name))=LOWER(TRIM(${parsed.customer_name}))`;\n parsed.factory = cm[0]?.factory || null;\n }\n\n if (!parsed.inv_no || !parsed.inv_date || !parsed.customer_name) {\n await sql`UPDATE pp_gmail_sync SET status='error',error='Missing required fields (inv_no/date/customer)' WHERE gmail_msg_id=${msgId}`;\n return ok({ status: 'error', error: 'Incomplete scan', parsed: parsed }, req);\n }\n\n // FIX 3: Save customer + invoice + items in a real DB transaction\n var custName = parsed.customer_name.trim().replace(/\\s+/g, \" \");\n var custNameNorm = custName.toLowerCase();\n var invNo = parsed.inv_no.trim();\n var custId = 0;\n\n try {\n await sql`BEGIN`;\n var exC = await sql`SELECT id,factory FROM pp_sales_customers WHERE LOWER(TRIM(name))=${custNameNorm} AND COALESCE(is_deleted,false)=false`;\n if (exC.length > 0) { custId = exC[0].id; if (!parsed.factory) parsed.factory = exC[0].factory; }\n else {\n var crC = await sql`INSERT INTO pp_sales_customers(name,gstin,factory,created_by) VALUES(${custName},${(parsed.gstin||'').toUpperCase()},${parsed.factory||null},${'gmail-sync'}) RETURNING id`;\n custId = crC[0].id;\n }\n var taxable = Number(parsed.taxable) || 0;\n if (parsed.items && Array.isArray(parsed.items) && parsed.items.length > 0 && taxable === 0) {\n for (var ii = 0; ii < parsed.items.length; ii++) taxable += Number(parsed.items[ii].amount||0);\n }\n var cgst = Number(parsed.cgst)||0, sgst = Number(parsed.sgst)||0, igst = Number(parsed.igst)||0;\n var total = Number(parsed.total) || (taxable+cgst+sgst+igst);\n var inv = await sql`INSERT INTO pp_sales_invoices(inv_no,inv_date,customer_id,customer_name,factory,taxable,cgst,sgst,igst,total,source,notes,created_by) VALUES(${invNo},${parsed.inv_date},${custId},${custName},${parsed.factory||null},${taxable},${cgst},${sgst},${igst},${total},${'gmail-sync'},${subject},${b.synced_by||'system'}) RETURNING id`;\n var invId = inv[0].id;\n if (parsed.items && Array.isArray(parsed.items)) {\n for (var j = 0; j < parsed.items.length; j++) {\n var it = parsed.items[j]; var amt = Number(it.amount)||(Number(it.qty||0)*Number(it.rate||0));\n await sql`INSERT INTO pp_sales_items(invoice_id,product_name,hsn,qty,unit,rate,amount,color,description) VALUES(${invId},${it.product_name||it.name||''},${it.hsn||''},${Number(it.qty)||0},${it.unit||'PCS'},${Number(it.rate)||0},${amt},${it.color||''},${it.description||''})`;\n }\n }\n await sql`COMMIT`;\n await sql`UPDATE pp_gmail_sync SET status='saved',invoice_id=${invId} WHERE gmail_msg_id=${msgId}`;\n return ok({ status: 'saved', inv_no: invNo, invoice_id: invId, customer: custName, total: total, items_count: parsed.items?.length||0 }, req);\n } catch (txErr: any) {\n try { await sql`ROLLBACK`; } catch (_) {}\n var txErrMsg = String(txErr?.message||txErr||'Unknown').slice(0,500);\n try { await sql`UPDATE pp_gmail_sync SET status='error',error=${txErrMsg} WHERE gmail_msg_id=${msgId}`; } catch (_) {}\n return ok({ status: 'error', error: 'Save failed: ' + txErrMsg }, req);\n }\n\n } catch (e: any) {\n var errMsg = String(e?.message||e||'Unknown error').slice(0,500);\n try { await sql`UPDATE pp_gmail_sync SET status='error',error=${errMsg} WHERE gmail_msg_id=${msgId}`; } catch (e2) {}\n return ok({ status: 'error', error: 'Sync error: ' + errMsg }, req);\n }\n}\n\n// Bulk sync multiple emails (calls gmailSyncOne for each)\nexport async function gmailSyncBulk(b: any, req?: Request): Promise {\n var emails = b.emails;\n if (!emails || !Array.isArray(emails) || emails.length === 0) return err(\"No emails provided\", 400, req);\n if (emails.length > 50) return err(\"Max 50 emails per batch\", 400, req);\n var results: any[] = []; var saved = 0; var skipped = 0; var errors = 0;\n for (var i = 0; i < emails.length; i++) {\n try {\n var email = emails[i];\n var dup = await sql`SELECT id,status,inv_no FROM pp_gmail_sync WHERE gmail_msg_id=${email.gmail_msg_id}`;\n if (dup.length > 0) { skipped++; results.push({ i, status: 'skipped', inv_no: dup[0].inv_no }); continue; }\n var resp = await gmailSyncOne(email);\n var respBody = await resp.json();\n if (respBody.error) { errors++; results.push({ i, status: 'error', error: respBody.error, attachment: email.attachment_name }); }\n else if (respBody.skipped || respBody.status === 'duplicate') { skipped++; results.push({ i, status: respBody.status||'skipped', inv_no: respBody.inv_no }); }\n else { saved++; results.push({ i, status: 'saved', inv_no: respBody.inv_no, total: respBody.total }); }\n } catch (e: any) { errors++; results.push({ i, status: 'error', error: e.message }); }\n }\n return ok({ saved, skipped, errors, total: emails.length, results }, req);\n}\n\nexport async function getGmailSyncLog(p: URLSearchParams, req?: Request): Promise {\n var limit = Number(p.get(\"limit\")) || 50;\n var status = p.get(\"status\") || \"\";\n try {\n var r: any[];\n if (status) { r = await sql`SELECT id,gmail_msg_id,gmail_subject,gmail_date,attachment_name,inv_no,status,error,invoice_id,created_at FROM pp_gmail_sync WHERE status=${status} ORDER BY created_at DESC LIMIT ${limit}`; }\n else { r = await sql`SELECT id,gmail_msg_id,gmail_subject,gmail_date,attachment_name,inv_no,status,error,invoice_id,created_at FROM pp_gmail_sync ORDER BY created_at DESC LIMIT ${limit}`; }\n return ok({ log: r }, req);\n } catch (e: any) { return ok({ log: [] }, req); }\n}\n\nexport async function getGmailSyncStats(req?: Request): Promise {\n try {\n var [r, total] = await Promise.all([\n sql`SELECT status,COUNT(*)::int as count FROM pp_gmail_sync GROUP BY status`,\n sql`SELECT COUNT(*)::int as total,MIN(created_at)as first_sync,MAX(created_at)as last_sync FROM pp_gmail_sync`\n ]);\n return ok({ stats: r, meta: total[0] }, req);\n } catch (e: any) { return ok({ stats: [], meta: { total: 0 } }, req); }\n}\n\nexport async function gmailSyncRetry(b: any, req?: Request): Promise {\n if (!b.id) return err(\"id required\", 400, req);\n await sql`UPDATE pp_gmail_sync SET status='pending',error=NULL WHERE id=${b.id}`;\n return ok({ success: true }, req);\n}\n\nexport async function gmailSyncDelete(b: any, req?: Request): Promise {\n if (!b.id) return err(\"id required\", 400, req);\n await sql`DELETE FROM pp_gmail_sync WHERE id=${b.id}`;\n return ok({ success: true }, req);\n}\n\n// Bulk scan multiple PDF invoices via Gemini, save all\nexport async function bulkScanInvoices(b: any, req?: Request): Promise {\n var pdfs = b.pdfs;\n if (!pdfs || !Array.isArray(pdfs) || pdfs.length === 0) return err(\"No PDFs provided\", 400, req);\n if (pdfs.length > 20) return err(\"Max 20 PDFs per batch\", 400, req);\n\n const apiKey = await getGeminiKey();\n if (!apiKey) return err('Gemini API key not configured', 503, req);\n\n var results: any[] = []; var saved = 0; var errors = 0;\n for (var i = 0; i < pdfs.length; i++) {\n var pdf = pdfs[i];\n try {\n if (!pdf.base64 || pdf.base64.length > 5*1024*1024) { errors++; results.push({ i, file: pdf.filename, status: 'error', error: 'PDF too large or empty (max ~4MB)' }); continue; }\n\n const gBody = { contents: [{ parts: [{ inline_data: { mime_type: 'application/pdf', data: pdf.base64 } }, { text: GEMINI_INVOICE_PROMPT }] }], generationConfig: { temperature: 0.1, maxOutputTokens: 4000 } };\n const res = await callGemini(apiKey, gBody);\n if (!res.ok) { errors++; results.push({ i, file: pdf.filename, status: 'error', error: 'Gemini HTTP error' }); continue; }\n\n var parsed: any;\n try { parsed = JSON.parse(res.text); }\n catch (pe) { errors++; results.push({ i, file: pdf.filename, status: 'error', error: 'JSON parse failed' }); continue; }\n\n if (!parsed.inv_no || !parsed.inv_date || !parsed.customer_name) { errors++; results.push({ i, file: pdf.filename, status: 'error', error: 'Missing fields', parsed: parsed }); continue; }\n\n // Check duplicate\n var invDup = await sql`SELECT id FROM pp_sales_invoices WHERE inv_no=${parsed.inv_no.trim()}`;\n if (invDup.length > 0) { results.push({ i, file: pdf.filename, status: 'duplicate', inv_no: parsed.inv_no }); continue; }\n\n // FIX 3: Save customer + invoice + items atomically per PDF\n var custName = parsed.customer_name.trim().replace(/\\s+/g,\" \"); var custId = 0;\n try {\n await sql`BEGIN`;\n var exB = await sql`SELECT id,factory FROM pp_sales_customers WHERE LOWER(TRIM(name))=${custName.toLowerCase()} AND COALESCE(is_deleted,false)=false`;\n if (exB.length > 0) { custId = exB[0].id; if (!parsed.factory) parsed.factory = exB[0].factory; }\n else { var crB = await sql`INSERT INTO pp_sales_customers(name,gstin,factory,created_by) VALUES(${custName},${(parsed.gstin||'').toUpperCase()},${parsed.factory||null},${'bulk-upload'}) RETURNING id`; custId = crB[0].id; }\n var taxable = Number(parsed.taxable)||0;\n if (parsed.items && Array.isArray(parsed.items) && taxable===0) { for (var ii=0;ii r.status === 'duplicate').length, total: pdfs.length, results }, req);\n}\n","deleted","label",[102],"permalink","https://www.val.town/x/abhishekplating/PlatingPro/code/ppSalesAI.ts","extension","actionData","errors"]