[{"_1":2,"_266":-5,"_267":-5},"loaderData",{"_3":4,"_92":93,"_230":231},"root",{"_5":6,"_35":36,"_65":66},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":22,"_29":22,"_30":22,"_31":32,"_33":22,"_34":22},"auth",{"_9":10,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":-5,"_20":-5,"_21":22},"tokenType","session_token","sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","notificationCount",0,"flagDenols","isTeamOrgMember","ENV",{"_37":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},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","20d05c705b6097b8b67aaed22e5ff0a688314dca","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","API_URL","https://api.val.town","clerkState",{"_67":68},"__internal_clerk_state",{"_69":70,"_71":46,"_72":73,"_74":73,"_75":22,"_76":73,"_77":73,"_78":73,"_79":73,"_80":81,"_90":22,"_91":22},"__clerk_ssr_state",{"_9":10,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":-5,"_20":-5,"_21":22},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_82":22,"_21":22,"_83":73,"_84":85,"_86":73,"_87":46,"_88":22,"_89":73},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/_app.x.$handle.$name",{"_94":95,"_96":97,"_98":44,"_99":73,"_100":101,"_102":103,"_149":150,"_198":199,"_200":201,"_209":210,"_223":-5,"_224":-5,"_225":-5,"_226":22,"_227":22,"_228":229},"handle","kliv","name","tes28e8v4fq374494f9t2543t09seet24q","branchName","path","version",4,"project",{"_104":105,"_96":97,"_106":107,"_108":-5,"_109":22,"_110":111,"_112":-5,"_113":-5,"_14":114,"_115":-5,"_116":22,"_117":-5,"_118":-5,"_119":32,"_16":120,"_121":122,"_123":122,"_124":125,"_126":125,"_127":125,"_128":122,"_129":122,"_23":130,"_133":134,"_136":137,"_148":22},"id","7d96e66e-d781-11f0-8f41-42dde27851f2","createdAt",["D",1765561160624],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","0199d9f9-8fb9-705d-a1be-150ee5ea0145","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","0199d9f9-8fb9-705d-a1be-18ed6d1d02d7","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_94":95,"_131":132},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzMzeW9MdTZSSlZXdUFyNHFTckJtSlg1b3paYiJ9","org",{"_94":95,"_135":132,"_14":114},"avatar","branch",{"_100":138,"_96":44,"_104":139,"_140":105,"_141":-5,"_142":-5,"_143":-5,"_144":-5,"_145":-5,"_146":97,"_147":95},6,"7d972782-d781-11f0-8f41-42dde27851f2","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","tree",[151,172,181,189],{"_104":152,"_96":153,"_154":155,"_156":-5,"_157":139,"_158":159,"_160":161,"_106":162,"_100":32,"_163":164,"_165":166,"_167":22,"_168":-5,"_169":170,"_99":171},"cfedb64a-d781-11f0-a2e1-42dde27851f2","fu332649s068254eq08919q63vf43fss4e.ts","fileId","cfedb6fe-d781-11f0-a2e1-42dde27851f2","parentId","branchId","branchVersion",3,"latest",true,["D",1765561298761],"fileType","http","content","export default async function(req: Request): Promise {\n // Read secrets from x-secrets header\n const __secrets = JSON.parse(req.headers.get('x-secrets') || '{}');\n\n const userUuid = req.headers.get(\"x-user-uuid\");\n const method = req.method;\n const url = new URL(req.url);\n const action = url.searchParams.get('action');\n\n // Initialize database connection\n const { connect } = await import(\"npm:@tursodatabase/serverless\");\n const conn = connect({\n url: req.headers.get(\"x-database-url\"),\n authToken: req.headers.get(\"x-database-token\")\n });\n\n // Initialize platform client\n const sdkUrl = req.headers.get(\"x-sdk-url\");\n const { PlatformClient } = await import(sdkUrl);\n const platform = new PlatformClient(\n req.headers.get(\"x-platform-token\"),\n req.headers.get(\"x-api-base-url\")\n );\n\n try {\n // Require authentication\n if (!userUuid) {\n return Response.json({\n success: false,\n message: 'Authentication required'\n }, { status: 401 });\n }\n\n // Get user info and verify seller status\n const userStmt = conn.prepare(\"SELECT metadata FROM users WHERE user_uuid = ?\");\n const user = await userStmt.get([userUuid]);\n \n if (!user || !user.metadata) {\n return Response.json({\n success: false,\n message: 'User not found'\n }, { status: 404 });\n }\n\n const userMetadata = JSON.parse(user.metadata);\n\n if (userMetadata.accountType !== 'seller') {\n return Response.json({\n success: false,\n message: 'Only sellers can access this dashboard'\n }, { status: 403 });\n }\n\n // Get seller profile\n const sellerStmt = conn.prepare(\"SELECT * FROM seller_profiles WHERE seller_uuid = ?\");\n const sellerProfile = await sellerStmt.get([userUuid]);\n\n if (!sellerProfile) {\n return Response.json({\n success: false,\n message: 'Seller profile not found'\n }, { status: 404 });\n }\n\n // Get dashboard overview stats\n if (method === 'GET' && action === 'overview') {\n // Get sales stats\n const salesStmt = conn.prepare(`\n SELECT \n COUNT(*) as total_sales,\n COALESCE(SUM(oi.seller_earnings), 0) as total_earnings,\n COUNT(DISTINCT oi.order_id) as unique_orders,\n COUNT(DISTINCT oi.buyer_uuid) as unique_buyers\n FROM order_items oi\n WHERE oi.seller_uuid = ?\n `);\n const salesStats = await salesStmt.get([userUuid]);\n\n // Get beat stats\n const beatsStmt = conn.prepare(`\n SELECT \n COUNT(*) as total_beats,\n SUM(CASE WHEN active = true THEN 1 ELSE 0 END) as active_beats,\n SUM(COALESCE(plays, 0)) as total_plays\n FROM beats \n WHERE seller_uuid = ?\n `);\n const beatStats = await beatsStmt.get([userUuid]);\n\n // Get monthly earnings (last 12 months)\n const monthlyEarningsStmt = conn.prepare(`\n SELECT \n strftime('%Y-%m', datetime(_created_at, 'unixepoch')) as month,\n SUM(oi.seller_earnings) as earnings\n FROM order_items oi\n WHERE oi.seller_uuid = ? \n AND oi._created_at > ?\n GROUP BY strftime('%Y-%m', datetime(_created_at, 'unixepoch'))\n ORDER BY month DESC\n LIMIT 12\n `);\n\n const twelveMonthsAgo = Math.floor((Date.now() - 365 * 24 * 60 * 60 * 1000) / 1000);\n const monthlyEarnings = await monthlyEarningsStmt.all([userUuid, twelveMonthsAgo]);\n\n // Get top selling beats\n const topBeatsStmt = conn.prepare(`\n SELECT \n b._row_id as beat_id,\n b.title,\n b.genre,\n b.price,\n COUNT(oi._row_id) as sales_count,\n SUM(oi.seller_earnings) as total_earnings\n FROM beats b\n LEFT JOIN order_items oi ON b._row_id = oi.beat_id\n WHERE b.seller_uuid = ?\n GROUP BY b._row_id\n ORDER BY sales_count DESC, total_earnings DESC\n LIMIT 5\n `);\n const topBeats = await topBeatsStmt.all([userUuid]);\n\n // Get recent sales\n const recentSalesStmt = conn.prepare(`\n SELECT \n oi._created_at as sale_date,\n b.title as beat_title,\n oi.seller_earnings,\n o.buyer_name,\n o.order_number\n FROM order_items oi\n JOIN beats b ON oi.beat_id = b._row_id\n JOIN orders o ON oi.order_id = o._row_id\n WHERE oi.seller_uuid = ?\n ORDER BY oi._created_at DESC\n LIMIT 10\n `);\n const recentSales = await recentSalesStmt.all([userUuid]);\n\n // Get membership info\n const membershipStmt = conn.prepare(`\n SELECT sm.*, mps.plan_name, mps.max_beats_allowed\n FROM seller_memberships sm\n LEFT JOIN membership_plan_settings mps ON sm.plan_type = mps.plan_name\n WHERE sm.seller_uuid = ? AND sm.status = 'active'\n ORDER BY sm._created_at DESC\n LIMIT 1\n `);\n const membership = await membershipStmt.get([userUuid]);\n\n // Check if membership is expired\n const currentTimestamp = Math.floor(Date.now() / 1000);\n const isExpired = membership && membership.expires_at && membership.expires_at < currentTimestamp;\n\n return Response.json({\n success: true,\n overview: {\n sales: {\n totalSales: salesStats.total_sales,\n totalEarnings: salesStats.total_earnings,\n uniqueOrders: salesStats.unique_orders,\n uniqueBuyers: salesStats.unique_buyers\n },\n beats: {\n totalBeats: beatStats.total_beats,\n activeBeats: beatStats.active_beats,\n totalPlays: beatStats.total_plays\n },\n monthlyEarnings: monthlyEarnings.reverse(), // Show oldest to newest\n topBeats,\n recentSales,\n membership: membership ? {\n ...membership,\n isExpired,\n daysUntilExpiry: membership.expires_at ? \n Math.max(0, Math.floor((membership.expires_at - currentTimestamp) / (24 * 60 * 60))) : null\n } : null,\n balance: {\n current: sellerProfile.current_balance || 0,\n pendingWithdrawals: sellerProfile.pending_withdrawals || 0,\n available: (sellerProfile.current_balance || 0) - (sellerProfile.pending_withdrawals || 0)\n }\n }\n });\n }\n\n // Get earnings report with filters\n if (method === 'GET' && action === 'earnings') {\n const startDate = url.searchParams.get('startDate');\n const endDate = url.searchParams.get('endDate');\n const period = url.searchParams.get('period') || 'month'; // day, week, month, year\n\n let dateFilter = '';\n let params = [userUuid];\n\n if (startDate && endDate) {\n dateFilter = 'AND oi._created_at >= ? AND oi._created_at <= ?';\n params.push(parseInt(startDate), parseInt(endDate));\n } else {\n // Default to last 12 months\n const twelveMonthsAgo = Math.floor((Date.now() - 365 * 24 * 60 * 60 * 1000) / 1000);\n dateFilter = 'AND oi._created_at >= ?';\n params.push(twelveMonthsAgo);\n }\n\n let dateFormat;\n switch (period) {\n case 'day':\n dateFormat = '%Y-%m-%d';\n break;\n case 'week':\n dateFormat = '%Y-%W';\n break;\n case 'month':\n dateFormat = '%Y-%m';\n break;\n case 'year':\n dateFormat = '%Y';\n break;\n default:\n dateFormat = '%Y-%m';\n }\n\n const earningsStmt = conn.prepare(`\n SELECT \n strftime('${dateFormat}', datetime(oi._created_at, 'unixepoch')) as period,\n COUNT(*) as sales_count,\n COALESCE(SUM(oi.seller_earnings), 0) as earnings,\n COALESCE(SUM(oi.beat_price), 0) as gross_revenue,\n COUNT(DISTINCT oi.order_id) as orders\n FROM order_items oi\n WHERE oi.seller_uuid = ? ${dateFilter}\n GROUP BY strftime('${dateFormat}', datetime(oi._created_at, 'unixepoch'))\n ORDER BY period DESC\n `);\n\n const earnings = await earningsStmt.all(params);\n\n // Get summary statistics\n const summaryStmt = conn.prepare(`\n SELECT \n COUNT(*) as total_sales,\n COALESCE(SUM(oi.seller_earnings), 0) as total_earnings,\n COUNT(DISTINCT oi.order_id) as total_orders,\n COALESCE(AVG(oi.seller_earnings), 0) as avg_earning_per_sale\n FROM order_items oi\n WHERE oi.seller_uuid = ? ${dateFilter}\n `);\n\n const summary = await summaryStmt.get(params);\n\n return Response.json({\n success: true,\n earnings: earnings.reverse(), // Show oldest to newest\n summary\n });\n }\n\n // Get sales analytics\n if (method === 'GET' && action === 'analytics') {\n // Genre performance\n const genreStmt = conn.prepare(`\n SELECT \n b.genre,\n COUNT(*) as sales_count,\n SUM(oi.seller_earnings) as earnings,\n AVG(oi.beat_price) as avg_price\n FROM order_items oi\n JOIN beats b ON oi.beat_id = b._row_id\n WHERE oi.seller_uuid = ?\n GROUP BY b.genre\n ORDER BY earnings DESC\n `);\n const genrePerformance = await genreStmt.all([userUuid]);\n\n // Price range performance\n const priceRangeStmt = conn.prepare(`\n SELECT \n CASE \n WHEN b.price < 50 THEN 'Under ZMW 50'\n WHEN b.price < 100 THEN 'ZMW 50-100'\n WHEN b.price < 200 THEN 'ZMW 100-200'\n WHEN b.price < 500 THEN 'ZMW 200-500'\n ELSE 'Over ZMW 500'\n END as price_range,\n COUNT(*) as sales_count,\n SUM(oi.seller_earnings) as earnings\n FROM order_items oi\n JOIN beats b ON oi.beat_id = b._row_id\n WHERE oi.seller_uuid = ?\n GROUP BY price_range\n ORDER BY earnings DESC\n `);\n const pricePerformance = await priceRangeStmt.all([userUuid]);\n\n // Customer geography (if available)\n const geographyStmt = conn.prepare(`\n SELECT \n o.buyer_email,\n COUNT(*) as purchase_count,\n SUM(oi.seller_earnings) as total_spent\n FROM order_items oi\n JOIN orders o ON oi.order_id = o._row_id\n WHERE oi.seller_uuid = ?\n GROUP BY o.buyer_email\n ORDER BY total_spent DESC\n LIMIT 10\n `);\n const topCustomers = await geographyStmt.all([userUuid]);\n\n // Conversion funnel\n const funnelStmt = conn.prepare(`\n SELECT \n 'total_beats' as metric,\n COUNT(*) as value\n FROM beats WHERE seller_uuid = ?\n \n UNION ALL\n \n SELECT \n 'active_beats' as metric,\n COUNT(*) as value\n FROM beats WHERE seller_uuid = ? AND active = true\n \n UNION ALL\n \n SELECT \n 'total_plays' as metric,\n COALESCE(SUM(plays), 0) as value\n FROM beats WHERE seller_uuid = ?\n \n UNION ALL\n \n SELECT \n 'total_sales' as metric,\n COUNT(*) as value\n FROM order_items WHERE seller_uuid = ?\n `);\n const funnel = await funnelStmt.all([userUuid, userUuid, userUuid, userUuid]);\n\n return Response.json({\n success: true,\n analytics: {\n genrePerformance,\n pricePerformance,\n topCustomers,\n conversionFunnel: funnel\n }\n });\n }\n\n // Get customer insights\n if (method === 'GET' && action === 'customers') {\n const page = parseInt(url.searchParams.get('page') || '1');\n const limit = parseInt(url.searchParams.get('limit') || '20');\n\n const customersStmt = conn.prepare(`\n SELECT \n o.buyer_email,\n o.buyer_name,\n COUNT(DISTINCT o._row_id) as order_count,\n COUNT(oi._row_id) as beat_count,\n SUM(oi.seller_earnings) as total_spent,\n MAX(oi._created_at) as last_purchase,\n MIN(oi._created_at) as first_purchase\n FROM order_items oi\n JOIN orders o ON oi.order_id = o._row_id\n WHERE oi.seller_uuid = ?\n GROUP BY o.buyer_email, o.buyer_name\n ORDER BY total_spent DESC\n LIMIT ? OFFSET ?\n `);\n\n const customers = await customersStmt.all([userUuid, limit, (page - 1) * limit]);\n\n // Get customer count for pagination\n const countStmt = conn.prepare(`\n SELECT COUNT(DISTINCT o.buyer_email) as total_customers\n FROM order_items oi\n JOIN orders o ON oi.order_id = o._row_id\n WHERE oi.seller_uuid = ?\n `);\n const countResult = await countStmt.get([userUuid]);\n\n return Response.json({\n success: true,\n customers,\n pagination: {\n currentPage: page,\n totalPages: Math.ceil(countResult.total_customers / limit),\n totalCustomers: countResult.total_customers\n }\n });\n }\n\n // Get inventory management data\n if (method === 'GET' && action === 'inventory') {\n const beatsStmt = conn.prepare(`\n SELECT \n b.*,\n COUNT(oi._row_id) as sales_count,\n SUM(oi.seller_earnings) as total_earnings,\n COUNT(DISTINCT oi.buyer_uuid) as unique_buyers\n FROM beats b\n LEFT JOIN order_items oi ON b._row_id = oi.beat_id\n WHERE b.seller_uuid = ?\n GROUP BY b._row_id\n ORDER BY b._created_at DESC\n `);\n const beats = await beatsStmt.all([userUuid]);\n\n // Get inventory summary\n const summaryStmt = conn.prepare(`\n SELECT \n COUNT(*) as total_beats,\n SUM(CASE WHEN active = true THEN 1 ELSE 0 END) as active_beats,\n SUM(CASE WHEN active = false THEN 1 ELSE 0 END) as inactive_beats,\n SUM(COALESCE(plays, 0)) as total_plays,\n AVG(price) as avg_price,\n MIN(price) as min_price,\n MAX(price) as max_price\n FROM beats \n WHERE seller_uuid = ?\n `);\n const summary = await summaryStmt.get([userUuid]);\n\n return Response.json({\n success: true,\n inventory: {\n beats,\n summary\n }\n });\n }\n\n // Update seller profile\n if (method === 'PUT' && action === 'profile') {\n const {\n displayName,\n bio,\n profileImageUrl,\n socialLinks,\n currency,\n paymentSettings\n } = await req.json();\n\n const updateStmt = conn.prepare(`\n UPDATE seller_profiles \n SET \n display_name = COALESCE(?, display_name),\n bio = COALESCE(?, bio),\n profile_image_url = COALESCE(?, profile_image_url),\n social_links = COALESCE(?, social_links),\n currency = COALESCE(?, currency),\n payment_settings = COALESCE(?, payment_settings),\n _updated_at = ?\n WHERE seller_uuid = ?\n `);\n\n const timestamp = Math.floor(Date.now() / 1000);\n await updateStmt.run([\n displayName, bio, profileImageUrl, \n JSON.stringify(socialLinks || {}), \n currency, \n JSON.stringify(paymentSettings || {}),\n timestamp, \n userUuid\n ]);\n\n return Response.json({\n success: true,\n message: 'Profile updated successfully'\n });\n }\n\n // Update bank details for withdrawals\n if (method === 'PUT' && action === 'bank-details') {\n const {\n bankName,\n accountNumber,\n accountName,\n routingNumber,\n swiftCode,\n bankAddress\n } = await req.json();\n\n const bankDetails = {\n bankName,\n accountNumber,\n accountName,\n routingNumber,\n swiftCode,\n bankAddress\n };\n\n const updateStmt = conn.prepare(`\n UPDATE seller_profiles \n SET \n bank_details = ?,\n _updated_at = ?\n WHERE seller_uuid = ?\n `);\n\n const timestamp = Math.floor(Date.now() / 1000);\n await updateStmt.run([\n JSON.stringify(bankDetails), \n timestamp, \n userUuid\n ]);\n\n return Response.json({\n success: true,\n message: 'Bank details updated successfully'\n });\n }\n\n // Get withdrawal history\n if (method === 'GET' && action === 'withdrawals') {\n const withdrawalsStmt = conn.prepare(`\n SELECT * FROM withdrawal_requests \n WHERE seller_uuid = ? \n ORDER BY _created_at DESC\n LIMIT 20\n `);\n const withdrawals = await withdrawalsStmt.all([userUuid]);\n\n return Response.json({\n success: true,\n withdrawals\n });\n }\n\n return Response.json({\n success: false,\n message: 'Invalid action or method'\n }, { status: 400 });\n\n } catch (error) {\n console.error('Seller dashboard error:', error);\n return Response.json({\n success: false,\n message: 'Internal server error'\n }, { status: 500 });\n }\n}","deleted","label","children",[],[153],{"_104":173,"_96":174,"_154":175,"_156":-5,"_157":139,"_158":176,"_160":161,"_106":177,"_100":32,"_163":164,"_165":178,"_167":22,"_168":-5,"_169":179,"_99":180},"7da6fd06-d781-11f0-8f41-42dde27851f2","fu76et0q1fve0s4v53q537f93q8t1ss847.ts","7da6fdba-d781-11f0-8f41-42dde27851f2",1,["D",1765561160722],"export default async function(req: Request): Promise {\n // Read secrets from x-secrets header\n const __secrets = JSON.parse(req.headers.get('x-secrets') || '{}');\n\n const userUuid = req.headers.get(\"x-user-uuid\");\n const method = req.method;\n const url = new URL(req.url);\n const action = url.searchParams.get('action');\n\n // Initialize database connection\n const { connect } = await import(\"npm:@tursodatabase/serverless\");\n const conn = connect({\n url: req.headers.get(\"x-database-url\"),\n authToken: req.headers.get(\"x-database-token\")\n });\n\n // Initialize platform client\n const sdkUrl = req.headers.get(\"x-sdk-url\");\n const { PlatformClient } = await import(sdkUrl);\n const platform = new PlatformClient(\n req.headers.get(\"x-platform-token\"),\n req.headers.get(\"x-api-base-url\")\n );\n\n try {\n // Require authentication\n if (!userUuid) {\n return Response.json({\n success: false,\n message: 'Authentication required'\n }, { status: 401 });\n }\n\n // Get user info\n const userStmt = conn.prepare(\"SELECT metadata FROM users WHERE user_uuid = ?\");\n const user = await userStmt.get([userUuid]);\n \n if (!user || !user.metadata) {\n return Response.json({\n success: false,\n message: 'User not found'\n }, { status: 404 });\n }\n\n const userMetadata = JSON.parse(user.metadata);\n\n // Create payment intent for checkout\n if (method === 'POST' && action === 'create-payment-intent') {\n const { beatIds, couponCode } = await req.json();\n\n if (userMetadata.accountType !== 'buyer') {\n return Response.json({\n success: false,\n message: 'Only buyers can make payments'\n }, { status: 403 });\n }\n\n if (!beatIds || beatIds.length === 0) {\n return Response.json({\n success: false,\n message: 'No beats selected'\n }, { status: 400 });\n }\n\n // Validate and get beat details safely\n const beats = [];\n for (const beatId of beatIds) {\n const beatStmt = conn.prepare(`\n SELECT b.*, sp.display_name as seller_name\n FROM beats b\n JOIN seller_profiles sp ON b.seller_uuid = sp.seller_uuid\n WHERE b._row_id = ? AND b.active = true\n `);\n const beat = await beatStmt.get([beatId]);\n \n if (!beat) {\n return Response.json({\n success: false,\n message: `Beat ${beatId} not found or unavailable`\n }, { status: 404 });\n }\n \n beats.push(beat);\n }\n\n // Calculate totals\n let subtotal = beats.reduce((sum, beat) => sum + beat.price, 0);\n let discountAmount = 0;\n let platformCommissionRate = 0.1;\n\n // Get platform commission rate\n const settingsStmt = conn.prepare(\"SELECT platform_commission_rate FROM platform_settings LIMIT 1\");\n const settings = await settingsStmt.get([]);\n if (settings) {\n platformCommissionRate = settings.platform_commission_rate;\n }\n\n // Apply coupon if provided\n let coupon = null;\n if (couponCode) {\n const couponStmt = conn.prepare(`\n SELECT * FROM coupons \n WHERE code = ? AND active = true AND (expires_at IS NULL OR expires_at > ?)\n `);\n const timestamp = Math.floor(Date.now() / 1000);\n coupon = await couponStmt.get([couponCode, timestamp]);\n\n if (!coupon) {\n return Response.json({\n success: false,\n message: 'Invalid or expired coupon code'\n }, { status: 400 });\n }\n\n // Check if coupon applies to these beats\n if (coupon.seller_uuid && !beats.every(beat => beat.seller_uuid === coupon.seller_uuid)) {\n return Response.json({\n success: false,\n message: 'Coupon does not apply to these beats'\n }, { status: 400 });\n }\n\n discountAmount = Math.round(subtotal * (coupon.discount_percentage / 100));\n }\n\n const finalTotal = subtotal - discountAmount;\n\n // In a real implementation, you would integrate with Stripe/PayPal/etc.\n // For this example, we'll create a simple payment intent\n const paymentIntent = {\n id: `pi_${Date.now()}_${Math.random().toString(36).substr(2, 9)}`,\n amount: finalTotal,\n currency: 'ZMW',\n status: 'requires_payment_method',\n client_secret: `pi_${Date.now()}_${Math.random().toString(36).substr(2, 9)}_secret_${Math.random().toString(36).substr(2, 9)}`\n };\n\n return Response.json({\n success: true,\n paymentIntent,\n orderSummary: {\n beats: beats.map(b => ({\n id: b._row_id,\n title: b.title,\n price: b.price,\n sellerName: b.seller_name\n })),\n subtotal,\n discountAmount,\n totalAmount: finalTotal,\n platformCommissionRate\n }\n });\n }\n\n // Process payment webhook (for payment processors like Stripe)\n if (method === 'POST' && action === 'webhook') {\n const signature = req.headers.get('stripe-signature');\n const webhookSecret = __secrets['STRIPE_WEBHOOK_SECRET'];\n \n // In a real implementation, verify webhook signature\n // const event = stripe.webhooks.constructEvent(await req.text(), signature, webhookSecret);\n \n // For this example, we'll simulate a successful payment event\n const event = {\n type: 'payment_intent.succeeded',\n data: {\n object: {\n id: 'pi_test_123',\n metadata: {\n orderId: '123',\n buyerUuid: userUuid\n }\n }\n }\n };\n\n if (event.type === 'payment_intent.succeeded') {\n const paymentIntent = event.data.object;\n const orderId = paymentIntent.metadata.orderId;\n\n // Update order status\n const updateStmt = conn.prepare(`\n UPDATE orders SET \n status = 'completed', \n payment_intent_id = ?,\n completed_at = ?,\n _updated_at = ?\n WHERE _row_id = ?\n `);\n\n const timestamp = Math.floor(Date.now() / 1000);\n await updateStmt.run([paymentIntent.id, timestamp, timestamp, parseInt(orderId)]);\n\n // Log the payment\n await platform.log('info', 'Payment completed', {\n orderId,\n paymentIntentId: paymentIntent.id,\n amount: paymentIntent.amount\n });\n\n return Response.json({ received: true });\n }\n\n return Response.json({ received: true });\n }\n\n // Save payment method\n if (method === 'POST' && action === 'save-payment-method') {\n const { type, last4, expiryMonth, expiryYear, isDefault } = await req.json();\n\n // Validate input\n if (!type || !last4 || !expiryMonth || !expiryYear) {\n return Response.json({\n success: false,\n message: 'Missing required payment method fields'\n }, { status: 400 });\n }\n\n // If setting as default, unset other default methods\n if (isDefault) {\n const unsetDefaultStmt = conn.prepare(`\n UPDATE buyer_payment_methods \n SET is_default = false, _updated_at = ?\n WHERE buyer_uuid = ?\n `);\n const timestamp = Math.floor(Date.now() / 1000);\n await unsetDefaultStmt.run([timestamp, userUuid]);\n }\n\n // Insert new payment method\n const paymentMethodStmt = conn.prepare(`\n INSERT INTO buyer_payment_methods (\n buyer_uuid, payment_type, last4, expiry_month, expiry_year, \n is_default, _created_by, _created_at\n ) VALUES (?, ?, ?, ?, ?, ?, ?, ?)\n `);\n\n const timestamp = Math.floor(Date.now() / 1000);\n const result = await paymentMethodStmt.run([\n userUuid, type, last4, expiryMonth, expiryYear,\n isDefault || false, userUuid, timestamp\n ]);\n\n return Response.json({\n success: true,\n message: 'Payment method saved successfully',\n paymentMethodId: result.lastInsertRowid\n });\n }\n\n // Get saved payment methods\n if (method === 'GET' && action === 'payment-methods') {\n if (userMetadata.accountType !== 'buyer') {\n return Response.json({\n success: false,\n message: 'Only buyers can view payment methods'\n }, { status: 403 });\n }\n\n const methodsStmt = conn.prepare(`\n SELECT * FROM buyer_payment_methods \n WHERE buyer_uuid = ? \n ORDER BY is_default DESC, _created_at DESC\n `);\n const methods = await methodsStmt.all([userUuid]);\n\n // Mask sensitive data\n const safeMethods = methods.map(method => ({\n id: method._row_id,\n type: method.payment_type,\n last4: method.last4,\n expiryMonth: method.expiry_month,\n expiryYear: method.expiry_year,\n isDefault: method.is_default\n }));\n\n return Response.json({\n success: true,\n paymentMethods: safeMethods\n });\n }\n\n // Delete payment method\n if (method === 'DELETE' && action === 'payment-method') {\n const paymentMethodId = url.searchParams.get('id');\n \n if (!paymentMethodId) {\n return Response.json({\n success: false,\n message: 'Payment method ID required'\n }, { status: 400 });\n }\n\n // Verify ownership\n const verifyStmt = conn.prepare(`\n SELECT * FROM buyer_payment_methods \n WHERE _row_id = ? AND buyer_uuid = ?\n `);\n const method = await verifyStmt.get([paymentMethodId, userUuid]);\n\n if (!method) {\n return Response.json({\n success: false,\n message: 'Payment method not found'\n }, { status: 404 });\n }\n\n // Delete the payment method\n const deleteStmt = conn.prepare(\"DELETE FROM buyer_payment_methods WHERE _row_id = ?\");\n await deleteStmt.run([paymentMethodId]);\n\n return Response.json({\n success: true,\n message: 'Payment method deleted successfully'\n });\n }\n\n // Set default payment method\n if (method === 'PUT' && action === 'default-payment-method') {\n const { paymentMethodId } = await req.json();\n\n if (!paymentMethodId) {\n return Response.json({\n success: false,\n message: 'Payment method ID required'\n }, { status: 400 });\n }\n\n // Verify ownership\n const verifyStmt = conn.prepare(`\n SELECT * FROM buyer_payment_methods \n WHERE _row_id = ? AND buyer_uuid = ?\n `);\n const method = await verifyStmt.get([paymentMethodId, userUuid]);\n\n if (!method) {\n return Response.json({\n success: false,\n message: 'Payment method not found'\n }, { status: 404 });\n }\n\n const timestamp = Math.floor(Date.now() / 1000);\n\n // Unset all other methods\n const unsetStmt = conn.prepare(`\n UPDATE buyer_payment_methods \n SET is_default = false, _updated_at = ?\n WHERE buyer_uuid = ?\n `);\n await unsetStmt.run([timestamp, userUuid]);\n\n // Set as default\n const setStmt = conn.prepare(`\n UPDATE buyer_payment_methods \n SET is_default = true, _updated_at = ?\n WHERE _row_id = ?\n `);\n await setStmt.run([timestamp, paymentMethodId]);\n\n return Response.json({\n success: true,\n message: 'Default payment method updated'\n });\n }\n\n // Process withdrawal request (for sellers)\n if (method === 'POST' && action === 'request-withdrawal') {\n if (userMetadata.accountType !== 'seller') {\n return Response.json({\n success: false,\n message: 'Only sellers can request withdrawals'\n }, { status: 403 });\n }\n\n const { amount, bankDetails } = await req.json();\n\n if (!amount || amount <= 0) {\n return Response.json({\n success: false,\n message: 'Invalid withdrawal amount'\n }, { status: 400 });\n }\n\n // Get seller balance\n const sellerStmt = conn.prepare(\"SELECT current_balance FROM seller_profiles WHERE seller_uuid = ?\");\n const seller = await sellerStmt.get([userUuid]);\n\n if (!seller || seller.current_balance < amount) {\n return Response.json({\n success: false,\n message: 'Insufficient balance'\n }, { status: 400 });\n }\n\n // Check for pending withdrawals\n const pendingStmt = conn.prepare(`\n SELECT COUNT(*) as count FROM withdrawal_requests \n WHERE seller_uuid = ? AND status = 'pending'\n `);\n const pending = await pendingStmt.get([userUuid]);\n\n if (pending.count > 0) {\n return Response.json({\n success: false,\n message: 'You already have a pending withdrawal request'\n }, { status: 400 });\n }\n\n // Create withdrawal request\n const withdrawalStmt = conn.prepare(`\n INSERT INTO withdrawal_requests (\n seller_uuid, amount, bank_details, status, _created_by, _created_at\n ) VALUES (?, ?, ?, ?, ?, ?)\n `);\n\n const timestamp = Math.floor(Date.now() / 1000);\n const result = await withdrawalStmt.run([\n userUuid, amount, JSON.stringify(bankDetails), 'pending', userUuid, timestamp\n ]);\n\n // Update seller balance (temporarily - will be processed by admin)\n const updateBalanceStmt = conn.prepare(`\n UPDATE seller_profiles \n SET current_balance = current_balance - ?, \n pending_withdrawals = COALESCE(pending_withdrawals, 0) + ?,\n _updated_at = ?\n WHERE seller_uuid = ?\n `);\n await updateBalanceStmt.run([amount, amount, timestamp, userUuid]);\n\n return Response.json({\n success: true,\n message: 'Withdrawal request submitted successfully',\n withdrawalId: result.lastInsertRowid\n });\n }\n\n // Get withdrawal history\n if (method === 'GET' && action === 'withdrawal-history') {\n if (userMetadata.accountType !== 'seller') {\n return Response.json({\n success: false,\n message: 'Only sellers can view withdrawal history'\n }, { status: 403 });\n }\n\n const withdrawalsStmt = conn.prepare(`\n SELECT * FROM withdrawal_requests \n WHERE seller_uuid = ? \n ORDER BY _created_at DESC\n `);\n const withdrawals = await withdrawalsStmt.all([userUuid]);\n\n return Response.json({\n success: true,\n withdrawals\n });\n }\n\n return Response.json({\n success: false,\n message: 'Invalid action or method'\n }, { status: 400 });\n\n } catch (error) {\n console.error('Payment processing error:', error);\n return Response.json({\n success: false,\n message: 'Internal server error'\n }, { status: 500 });\n }\n}",[],[174],{"_104":182,"_96":183,"_154":184,"_156":-5,"_157":139,"_158":101,"_160":161,"_106":185,"_100":32,"_163":164,"_165":186,"_167":22,"_168":-5,"_169":187,"_99":188},"f5a0e006-d781-11f0-afb4-42dde27851f2","fuvf5f5s1811s84ts49f6e0s3382286ev3.ts","f5a0e09c-d781-11f0-afb4-42dde27851f2",["D",1765561362014],"export default async function(req: Request): Promise {\n // Read secrets from x-secrets header\n const __secrets = JSON.parse(req.headers.get('x-secrets') || '{}');\n\n const userUuid = req.headers.get(\"x-user-uuid\");\n const method = req.method;\n const url = new URL(req.url);\n const action = url.searchParams.get('action');\n\n // Initialize database connection\n const { connect } = await import(\"npm:@tursodatabase/serverless\");\n const conn = connect({\n url: req.headers.get(\"x-database-url\"),\n authToken: req.headers.get(\"x-database-token\")\n });\n\n // Initialize platform client for notifications\n const sdkUrl = req.headers.get(\"x-sdk-url\");\n const { PlatformClient } = await import(sdkUrl);\n const platform = new PlatformClient(\n req.headers.get(\"x-platform-token\"),\n req.headers.get(\"x-api-base-url\")\n );\n\n try {\n // Require authentication\n if (!userUuid) {\n return Response.json({\n success: false,\n message: 'Authentication required'\n }, { status: 401 });\n }\n\n // Get user info\n const userStmt = conn.prepare(\"SELECT metadata FROM users WHERE user_uuid = ?\");\n const user = await userStmt.get([userUuid]);\n \n if (!user || !user.metadata) {\n return Response.json({\n success: false,\n message: 'User not found'\n }, { status: 404 });\n }\n\n const userMetadata = JSON.parse(user.metadata);\n\n // Get chat conversations (inbox)\n if (method === 'GET' && action === 'conversations') {\n const conversationsStmt = conn.prepare(`\n SELECT \n c._row_id as conversation_id,\n c.seller_uuid,\n c.buyer_uuid,\n c.last_message,\n c.last_message_at,\n c.unread_seller_count,\n c.unread_buyer_count,\n sp.display_name as seller_name,\n sp.profile_image_url as seller_avatar,\n bp.name as buyer_name,\n bp.avatar_url as buyer_avatar\n FROM conversations c\n LEFT JOIN seller_profiles sp ON c.seller_uuid = sp.seller_uuid\n LEFT JOIN buyer_profiles bp ON c.buyer_uuid = bp.buyer_uuid\n WHERE (c.seller_uuid = ? OR c.buyer_uuid = ?)\n ORDER BY c.last_message_at DESC\n `);\n\n const conversations = await conversationsStmt.all([userUuid, userUuid]);\n\n // Mark conversations as read for current user\n for (const conv of conversations) {\n const updateReadStmt = conn.prepare(`\n UPDATE conversations \n SET \n unread_seller_count = CASE WHEN ? = seller_uuid THEN 0 ELSE unread_seller_count END,\n unread_buyer_count = CASE WHEN ? = buyer_uuid THEN 0 ELSE unread_buyer_count END,\n _updated_at = ?\n WHERE _row_id = ?\n `);\n\n const timestamp = Math.floor(Date.now() / 1000);\n await updateReadStmt.run([userUuid, userUuid, timestamp, conv.conversation_id]);\n }\n\n return Response.json({\n success: true,\n conversations: conversations.map(conv => ({\n id: conv.conversation_id,\n sellerId: conv.seller_uuid,\n buyerId: conv.buyer_uuid,\n sellerName: conv.seller_name,\n sellerAvatar: conv.seller_avatar,\n buyerName: conv.buyer_name,\n buyerAvatar: conv.buyer_avatar,\n lastMessage: conv.last_message,\n lastMessageAt: conv.last_message_at,\n unreadCount: userMetadata.accountType === 'seller' ? conv.unread_seller_count : conv.unread_buyer_count,\n isSeller: userMetadata.accountType === 'seller',\n otherParty: userMetadata.accountType === 'seller' ? {\n id: conv.buyer_uuid,\n name: conv.buyer_name,\n avatar: conv.buyer_avatar\n } : {\n id: conv.seller_uuid,\n name: conv.seller_name,\n avatar: conv.seller_avatar\n }\n }))\n });\n }\n\n // Get messages for a specific conversation\n if (method === 'GET' && action === 'messages') {\n const conversationId = url.searchParams.get('conversationId');\n \n if (!conversationId) {\n return Response.json({\n success: false,\n message: 'Conversation ID required'\n }, { status: 400 });\n }\n\n // Verify user is part of this conversation\n const verifyStmt = conn.prepare(`\n SELECT * FROM conversations \n WHERE _row_id = ? AND (seller_uuid = ? OR buyer_uuid = ?)\n `);\n const conversation = await verifyStmt.get([conversationId, userUuid, userUuid]);\n\n if (!conversation) {\n return Response.json({\n success: false,\n message: 'Conversation not found'\n }, { status: 404 });\n }\n\n // Get messages\n const messagesStmt = conn.prepare(`\n SELECT \n cm.*,\n u.first_name,\n u.last_name,\n sp.display_name as seller_name,\n bp.name as buyer_name\n FROM chat_messages cm\n LEFT JOIN users u ON cm.sender_uuid = u.user_uuid\n LEFT JOIN seller_profiles sp ON cm.sender_uuid = sp.seller_uuid\n LEFT JOIN buyer_profiles bp ON cm.sender_uuid = bp.buyer_uuid\n WHERE cm.conversation_id = ?\n ORDER BY cm._created_at ASC\n `);\n\n const messages = await messagesStmt.all([conversationId]);\n\n return Response.json({\n success: true,\n messages: messages.map(msg => ({\n id: msg._row_id,\n senderId: msg.sender_uuid,\n message: msg.message,\n messageType: msg.message_type,\n sentAt: msg._created_at,\n isRead: msg.is_read,\n senderName: msg.sender_name || \n msg.seller_name || \n msg.buyer_name || \n 'Unknown',\n isOwnMessage: msg.sender_uuid === userUuid\n }))\n });\n }\n\n // Send a message\n if (method === 'POST' && action === 'send-message') {\n const { conversationId, message, messageType = 'text' } = await req.json();\n\n if (!conversationId || !message) {\n return Response.json({\n success: false,\n message: 'Conversation ID and message are required'\n }, { status: 400 });\n }\n\n // Verify user is part of this conversation\n const verifyStmt = conn.prepare(`\n SELECT * FROM conversations \n WHERE _row_id = ? AND (seller_uuid = ? OR buyer_uuid = ?)\n `);\n const conversation = await verifyStmt.get([conversationId, userUuid, userUuid]);\n\n if (!conversation) {\n return Response.json({\n success: false,\n message: 'Conversation not found'\n }, { status: 404 });\n }\n\n const timestamp = Math.floor(Date.now() / 1000);\n\n // Insert message\n const messageStmt = conn.prepare(`\n INSERT INTO chat_messages (\n conversation_id, sender_uuid, message, message_type, \n is_read, _created_by, _created_at\n ) VALUES (?, ?, ?, ?, ?, ?, ?)\n `);\n\n const result = await messageStmt.run([\n conversationId, userUuid, message, messageType, \n false, userUuid, timestamp\n ]);\n\n // Update conversation\n const updateConvStmt = conn.prepare(`\n UPDATE conversations \n SET \n last_message = ?,\n last_message_at = ?,\n unread_seller_count = CASE WHEN ? = seller_uuid THEN unread_seller_count ELSE unread_seller_count + 1 END,\n unread_buyer_count = CASE WHEN ? = buyer_uuid THEN unread_buyer_count ELSE unread_buyer_count + 1 END,\n _updated_at = ?\n WHERE _row_id = ?\n `);\n\n await updateConvStmt.run([\n message, timestamp, userUuid, userUuid, timestamp, conversationId\n ]);\n\n // Get other party's email for notification\n const otherPartyUuid = conversation.seller_uuid === userUuid ? conversation.buyer_uuid : conversation.seller_uuid;\n const otherPartyStmt = conn.prepare(`\n SELECT u.email, \n CASE \n WHEN sp.display_name IS NOT NULL THEN sp.display_name\n WHEN bp.name IS NOT NULL THEN bp.name\n ELSE u.first_name\n END as display_name,\n sp.seller_uuid IS NOT NULL as is_seller\n FROM users u\n LEFT JOIN seller_profiles sp ON u.user_uuid = sp.seller_uuid\n LEFT JOIN buyer_profiles bp ON u.user_uuid = bp.buyer_uuid\n WHERE u.user_uuid = ?\n `);\n const otherParty = await otherPartyStmt.get([otherPartyUuid]);\n\n // Send email notification if enabled\n if (otherParty) {\n await platform.sendEmail({\n templateName: 'new_message_notification',\n recipientEmail: otherParty.email,\n recipientName: otherParty.display_name,\n customVariables: {\n senderName: userMetadata.firstName || userMetadata.email.split('@')[0],\n message: message.length > 100 ? message.substring(0, 100) + '...' : message,\n conversationId: conversationId,\n isSeller: otherParty.is_seller\n }\n });\n }\n\n return Response.json({\n success: true,\n messageId: result.lastInsertRowid,\n message: 'Message sent successfully'\n });\n }\n\n // Start a new conversation\n if (method === 'POST' && action === 'start-conversation') {\n const { sellerId, initialMessage } = await req.json();\n\n if (!sellerId || !initialMessage) {\n return Response.json({\n success: false,\n message: 'Seller ID and initial message are required'\n }, { status: 400 });\n }\n\n if (userMetadata.accountType !== 'buyer') {\n return Response.json({\n success: false,\n message: 'Only buyers can start conversations'\n }, { status: 403 });\n }\n\n // Check if conversation already exists\n const existingConvStmt = conn.prepare(`\n SELECT _row_id FROM conversations \n WHERE seller_uuid = ? AND buyer_uuid = ?\n `);\n const existingConv = await existingConvStmt.get([sellerId, userUuid]);\n\n if (existingConv) {\n return Response.json({\n success: false,\n message: 'Conversation already exists',\n conversationId: existingConv._row_id\n }, { status: 409 });\n }\n\n const timestamp = Math.floor(Date.now() / 1000);\n\n // Create new conversation\n const convStmt = conn.prepare(`\n INSERT INTO conversations (\n seller_uuid, buyer_uuid, last_message, last_message_at,\n unread_seller_count, unread_buyer_count, _created_by, _created_at\n ) VALUES (?, ?, ?, ?, ?, ?, ?, ?)\n `);\n\n const convResult = await convStmt.run([\n sellerId, userUuid, initialMessage, timestamp,\n 1, 0, userUuid, timestamp\n ]);\n\n const conversationId = convResult.lastInsertRowid;\n\n // Send initial message\n const messageStmt = conn.prepare(`\n INSERT INTO chat_messages (\n conversation_id, sender_uuid, message, message_type,\n is_read, _created_by, _created_at\n ) VALUES (?, ?, ?, ?, ?, ?, ?)\n `);\n\n await messageStmt.run([\n conversationId, userUuid, initialMessage, 'text',\n false, userUuid, timestamp\n ]);\n\n // Get seller info for notification\n const sellerStmt = conn.prepare(`\n SELECT u.email, sp.display_name\n FROM users u\n JOIN seller_profiles sp ON u.user_uuid = sp.seller_uuid\n WHERE u.user_uuid = ?\n `);\n const seller = await sellerStmt.get([sellerId]);\n\n // Notify seller\n if (seller) {\n await platform.sendEmail({\n templateName: 'new_conversation_notification',\n recipientEmail: seller.email,\n recipientName: seller.display_name,\n customVariables: {\n buyerName: userMetadata.firstName || userMetadata.email.split('@')[0],\n initialMessage: initialMessage.length > 100 ? initialMessage.substring(0, 100) + '...' : initialMessage,\n conversationId: conversationId\n }\n });\n }\n\n return Response.json({\n success: true,\n conversationId,\n message: 'Conversation started successfully'\n });\n }\n\n // Mark messages as read\n if (method === 'PUT' && action === 'mark-read') {\n const { messageIds } = await req.json();\n\n if (!messageIds || !Array.isArray(messageIds)) {\n return Response.json({\n success: false,\n message: 'Message IDs array is required'\n }, { status: 400 });\n }\n\n const timestamp = Math.floor(Date.now() / 1000);\n\n // Update messages\n for (const messageId of messageIds) {\n const updateStmt = conn.prepare(`\n UPDATE chat_messages \n SET is_read = true, _updated_at = ?\n WHERE _row_id = ? AND sender_uuid != ?\n `);\n await updateStmt.run([timestamp, messageId, userUuid]);\n }\n\n return Response.json({\n success: true,\n message: 'Messages marked as read'\n });\n }\n\n // Delete a message\n if (method === 'DELETE' && action === 'message') {\n const messageId = url.searchParams.get('messageId');\n \n if (!messageId) {\n return Response.json({\n success: false,\n message: 'Message ID required'\n }, { status: 400 });\n }\n\n // Verify message ownership\n const verifyStmt = conn.prepare(`\n SELECT cm.*, c.seller_uuid, c.buyer_uuid\n FROM chat_messages cm\n JOIN conversations c ON cm.conversation_id = c._row_id\n WHERE cm._row_id = ? AND (c.seller_uuid = ? OR c.buyer_uuid = ?)\n `);\n const message = await verifyStmt.get([messageId, userUuid, userUuid]);\n\n if (!message) {\n return Response.json({\n success: false,\n message: 'Message not found'\n }, { status: 404 });\n }\n\n // Only allow sender to delete their own messages\n if (message.sender_uuid !== userUuid) {\n return Response.json({\n success: false,\n message: 'Cannot delete other user\\'s messages'\n }, { status: 403 });\n }\n\n // Soft delete by updating message content\n const deleteStmt = conn.prepare(`\n UPDATE chat_messages \n SET message = '[Message deleted]', message_type = 'deleted', _updated_at = ?\n WHERE _row_id = ?\n `);\n\n const timestamp = Math.floor(Date.now() / 1000);\n await deleteStmt.run([timestamp, messageId]);\n\n return Response.json({\n success: true,\n message: 'Message deleted successfully'\n });\n }\n\n // Get unread message count\n if (method === 'GET' && action === 'unread-count') {\n const countStmt = conn.prepare(`\n SELECT COUNT(*) as unread_count\n FROM chat_messages cm\n JOIN conversations c ON cm.conversation_id = c._row_id\n WHERE cm.is_read = false \n AND cm.sender_uuid != ?\n AND (c.seller_uuid = ? OR c.buyer_uuid = ?)\n `);\n const result = await countStmt.get([userUuid, userUuid, userUuid]);\n\n return Response.json({\n success: true,\n unreadCount: result.unread_count\n });\n }\n\n // Search conversations\n if (method === 'GET' && action === 'search') {\n const query = url.searchParams.get('q');\n \n if (!query || query.length < 2) {\n return Response.json({\n success: false,\n message: 'Search query must be at least 2 characters'\n }, { status: 400 });\n }\n\n const searchStmt = conn.prepare(`\n SELECT DISTINCT\n c._row_id as conversation_id,\n c.seller_uuid,\n c.buyer_uuid,\n c.last_message,\n c.last_message_at,\n sp.display_name as seller_name,\n bp.name as buyer_name,\n COUNT(cm._row_id) as matching_messages\n FROM conversations c\n LEFT JOIN seller_profiles sp ON c.seller_uuid = sp.seller_uuid\n LEFT JOIN buyer_profiles bp ON c.buyer_uuid = bp.buyer_uuid\n JOIN chat_messages cm ON c._row_id = cm.conversation_id\n WHERE (c.seller_uuid = ? OR c.buyer_uuid = ?)\n AND (cm.message LIKE ? OR sp.display_name LIKE ? OR bp.name LIKE ?)\n GROUP BY c._row_id\n ORDER BY c.last_message_at DESC\n LIMIT 20\n `);\n\n const searchQuery = `%${query}%`;\n const results = await searchStmt.all([userUuid, userUuid, searchQuery, searchQuery, searchQuery]);\n\n return Response.json({\n success: true,\n results: results.map(conv => ({\n id: conv.conversation_id,\n sellerId: conv.seller_uuid,\n buyerId: conv.buyer_uuid,\n sellerName: conv.seller_name,\n buyerName: conv.buyer_name,\n lastMessage: conv.last_message,\n lastMessageAt: conv.last_message_at,\n matchingMessages: conv.matching_messages,\n otherParty: userMetadata.accountType === 'seller' ? {\n id: conv.buyer_uuid,\n name: conv.buyer_name\n } : {\n id: conv.seller_uuid,\n name: conv.seller_name\n }\n }))\n });\n }\n\n return Response.json({\n success: false,\n message: 'Invalid action or method'\n }, { status: 400 });\n\n } catch (error) {\n console.error('Messaging error:', error);\n return Response.json({\n success: false,\n message: 'Internal server error'\n }, { status: 500 });\n }\n}",[],[183],{"_104":190,"_96":191,"_154":192,"_156":-5,"_157":139,"_158":193,"_160":161,"_106":194,"_100":32,"_163":164,"_165":195,"_167":22,"_168":-5,"_169":196,"_99":197},"90d0cc86-d781-11f0-947e-42dde27851f2","fuvtfq3ef8s011461e87t365f81s7tv145.ts","90d0cd6c-d781-11f0-947e-42dde27851f2",2,["D",1765561192877],"export default async function(req: Request): Promise {\n // Read secrets from x-secrets header\n const __secrets = JSON.parse(req.headers.get('x-secrets') || '{}');\n\n const userUuid = req.headers.get(\"x-user-uuid\");\n const method = req.method;\n const url = new URL(req.url);\n const action = url.searchParams.get('action');\n\n // Initialize database connection\n const { connect } = await import(\"npm:@tursodatabase/serverless\");\n const conn = connect({\n url: req.headers.get(\"x-database-url\"),\n authToken: req.headers.get(\"x-database-token\")\n });\n\n // Initialize platform client\n const sdkUrl = req.headers.get(\"x-sdk-url\");\n const { PlatformClient } = await import(sdkUrl);\n const platform = new PlatformClient(\n req.headers.get(\"x-platform-token\"),\n req.headers.get(\"x-api-base-url\")\n );\n\n try {\n // Require authentication\n if (!userUuid) {\n return Response.json({\n success: false,\n message: 'Authentication required'\n }, { status: 401 });\n }\n\n // Get user info\n const userStmt = conn.prepare(\"SELECT metadata FROM users WHERE user_uuid = ?\");\n const user = await userStmt.get([userUuid]);\n \n if (!user || !user.metadata) {\n return Response.json({\n success: false,\n message: 'User not found'\n }, { status: 404 });\n }\n\n const userMetadata = JSON.parse(user.metadata);\n\n // Only sellers can manage memberships\n if (userMetadata.accountType !== 'seller') {\n return Response.json({\n success: false,\n message: 'Only sellers can manage memberships'\n }, { status: 403 });\n }\n\n // Get available membership plans\n if (method === 'GET' && action === 'available-plans') {\n const plansStmt = conn.prepare(`\n SELECT * FROM membership_plan_settings \n WHERE active = true \n ORDER BY sort_order ASC\n `);\n const plans = await plansStmt.all([]);\n\n return Response.json({\n success: true,\n plans\n });\n }\n\n // Get current seller membership\n if (method === 'GET' && action === 'current-membership') {\n const membershipStmt = conn.prepare(`\n SELECT sm.*, mps.plan_name, mps.description, mps.max_beats_allowed,\n mps.features, mps.sort_order\n FROM seller_memberships sm\n LEFT JOIN membership_plan_settings mps ON sm.plan_type = mps.plan_name\n WHERE sm.seller_uuid = ? AND sm.status = 'active'\n ORDER BY sm._created_at DESC\n LIMIT 1\n `);\n const membership = await membershipStmt.get([userUuid]);\n\n if (!membership) {\n return Response.json({\n success: false,\n message: 'No active membership found'\n }, { status: 404 });\n }\n\n // Check if membership is expired\n const currentTimestamp = Math.floor(Date.now() / 1000);\n const isExpired = membership.expires_at && membership.expires_at < currentTimestamp;\n\n return Response.json({\n success: true,\n membership: {\n ...membership,\n isExpired,\n daysUntilExpiry: membership.expires_at ? \n Math.max(0, Math.floor((membership.expires_at - currentTimestamp) / (24 * 60 * 60))) : null\n }\n });\n }\n\n // Subscribe to a plan\n if (method === 'POST' && action === 'subscribe') {\n const { planType, paymentMethodId } = await req.json();\n\n if (!planType) {\n return Response.json({\n success: false,\n message: 'Plan type is required'\n }, { status: 400 });\n }\n\n // Get plan details\n const planStmt = conn.prepare(`\n SELECT * FROM membership_plan_settings \n WHERE plan_name = ? AND active = true\n `);\n const plan = await planStmt.get([planType]);\n\n if (!plan) {\n return Response.json({\n success: false,\n message: 'Plan not found or inactive'\n }, { status: 404 });\n }\n\n // Get current membership\n const currentMembershipStmt = conn.prepare(`\n SELECT * FROM seller_memberships \n WHERE seller_uuid = ? AND status = 'active'\n `);\n const currentMembership = await currentMembershipStmt.get([userUuid]);\n\n // Handle commission-based plan (no expiry)\n if (planType === 'commission_based') {\n const timestamp = Math.floor(Date.now() / 1000);\n\n if (currentMembership) {\n // Update existing membership\n const updateStmt = conn.prepare(`\n UPDATE seller_memberships \n SET plan_type = ?, expires_at = NULL, _updated_at = ?\n WHERE seller_uuid = ?\n `);\n await updateStmt.run([planType, timestamp, userUuid]);\n } else {\n // Create new membership\n const insertStmt = conn.prepare(`\n INSERT INTO seller_memberships (\n seller_uuid, plan_type, status, beats_uploaded, _created_by, _created_at\n ) VALUES (?, ?, 'active', 0, ?, ?)\n `);\n await insertStmt.run([userUuid, planType, userUuid, timestamp]);\n }\n\n return Response.json({\n success: true,\n message: 'Successfully subscribed to commission-based plan',\n membership: {\n planType: 'commission_based',\n expiresAt: null,\n maxBeatsAllowed: null\n }\n });\n }\n\n // For paid plans, calculate expiry date\n const timestamp = Math.floor(Date.now() / 1000);\n let expiresAt = null;\n\n if (planType === 'monthly') {\n expiresAt = timestamp + (30 * 24 * 60 * 60); // 30 days\n } else if (planType === 'yearly') {\n expiresAt = timestamp + (365 * 24 * 60 * 60); // 365 days\n }\n\n // Process payment (in real implementation, integrate with payment processor)\n const paymentSuccess = true; // Simulate payment success\n if (!paymentSuccess) {\n return Response.json({\n success: false,\n message: 'Payment failed'\n }, { status: 400 });\n }\n\n // Update or create membership\n if (currentMembership) {\n const updateStmt = conn.prepare(`\n UPDATE seller_memberships \n SET plan_type = ?, expires_at = ?, beats_uploaded = 0, _updated_at = ?\n WHERE seller_uuid = ?\n `);\n await updateStmt.run([planType, expiresAt, timestamp, userUuid]);\n } else {\n const insertStmt = conn.prepare(`\n INSERT INTO seller_memberships (\n seller_uuid, plan_type, status, expires_at, beats_uploaded, _created_by, _created_at\n ) VALUES (?, ?, 'active', ?, 0, ?, ?)\n `);\n await insertStmt.run([userUuid, planType, expiresAt, userUuid, timestamp]);\n }\n\n // Send confirmation email\n const sellerProfileStmt = conn.prepare(\"SELECT email FROM seller_profiles WHERE seller_uuid = ?\");\n const sellerProfile = await sellerProfileStmt.get([userUuid]);\n\n if (sellerProfile) {\n await platform.sendEmail({\n templateName: 'membership_confirmation',\n recipientEmail: sellerProfile.email,\n recipientName: sellerProfile.display_name || 'Seller',\n customVariables: {\n planName: plan.plan_name,\n planPrice: plan.price,\n expiryDate: expiresAt ? new Date(expiresAt * 1000).toLocaleDateString() : 'Never',\n maxBeats: plan.max_beats_allowed\n }\n });\n }\n\n return Response.json({\n success: true,\n message: `Successfully subscribed to ${plan.plan_name}`,\n membership: {\n planType,\n expiresAt,\n maxBeatsAllowed: plan.max_beats_allowed\n }\n });\n }\n\n // Cancel membership\n if (method === 'POST' && action === 'cancel') {\n const membershipStmt = conn.prepare(`\n UPDATE seller_memberships \n SET status = 'cancelled', _updated_at = ?\n WHERE seller_uuid = ? AND status = 'active'\n `);\n\n const timestamp = Math.floor(Date.now() / 1000);\n const result = await membershipStmt.run([timestamp, userUuid]);\n\n if (result.changes === 0) {\n return Response.json({\n success: false,\n message: 'No active membership found'\n }, { status: 404 });\n }\n\n // Send cancellation confirmation\n const sellerProfileStmt = conn.prepare(\"SELECT email FROM seller_profiles WHERE seller_uuid = ?\");\n const sellerProfile = await sellerProfileStmt.get([userUuid]);\n\n if (sellerProfile) {\n await platform.sendEmail({\n templateName: 'membership_cancellation',\n recipientEmail: sellerProfile.email,\n recipientName: sellerProfile.display_name || 'Seller',\n customVariables: {\n cancellationDate: new Date(timestamp * 1000).toLocaleDateString()\n }\n });\n }\n\n return Response.json({\n success: true,\n message: 'Membership cancelled successfully'\n });\n }\n\n // Upgrade/downgrade plan\n if (method === 'POST' && action === 'change-plan') {\n const { newPlanType, paymentMethodId } = await req.json();\n\n if (!newPlanType) {\n return Response.json({\n success: false,\n message: 'New plan type is required'\n }, { status: 400 });\n }\n\n // Get current membership\n const currentMembershipStmt = conn.prepare(`\n SELECT * FROM seller_memberships \n WHERE seller_uuid = ? AND status = 'active'\n `);\n const currentMembership = await currentMembershipStmt.get([userUuid]);\n\n if (!currentMembership) {\n return Response.json({\n success: false,\n message: 'No active membership found'\n }, { status: 404 });\n }\n\n // Get new plan details\n const newPlanStmt = conn.prepare(`\n SELECT * FROM membership_plan_settings \n WHERE plan_name = ? AND active = true\n `);\n const newPlan = await newPlanStmt.get([newPlanType]);\n\n if (!newPlan) {\n return Response.json({\n success: false,\n message: 'New plan not found or inactive'\n }, { status: 404 });\n }\n\n // Process payment for plan change if needed\n let requiresPayment = false;\n if (newPlanType !== 'commission_based' && newPlanType !== 'pay_as_you_go') {\n requiresPayment = true;\n }\n\n if (requiresPayment) {\n const paymentSuccess = true; // Simulate payment\n if (!paymentSuccess) {\n return Response.json({\n success: false,\n message: 'Payment failed for plan change'\n }, { status: 400 });\n }\n }\n\n // Calculate new expiry date\n const timestamp = Math.floor(Date.now() / 1000);\n let expiresAt = null;\n\n if (newPlanType === 'monthly') {\n expiresAt = timestamp + (30 * 24 * 60 * 60);\n } else if (newPlanType === 'yearly') {\n expiresAt = timestamp + (365 * 24 * 60 * 60);\n }\n\n // Update membership\n const updateStmt = conn.prepare(`\n UPDATE seller_memberships \n SET plan_type = ?, expires_at = ?, _updated_at = ?\n WHERE seller_uuid = ?\n `);\n await updateStmt.run([newPlanType, expiresAt, timestamp, userUuid]);\n\n // Send plan change confirmation\n const sellerProfileStmt = conn.prepare(\"SELECT email FROM seller_profiles WHERE seller_uuid = ?\");\n const sellerProfile = await sellerProfileStmt.get([userUuid]);\n\n if (sellerProfile) {\n await platform.sendEmail({\n templateName: 'membership_plan_change',\n recipientEmail: sellerProfile.email,\n recipientName: sellerProfile.display_name || 'Seller',\n customVariables: {\n oldPlan: currentMembership.plan_type.replace('_', ' ').toUpperCase(),\n newPlan: newPlanType.replace('_', ' ').toUpperCase(),\n effectiveDate: new Date(timestamp * 1000).toLocaleDateString(),\n newExpiryDate: expiresAt ? new Date(expiresAt * 1000).toLocaleDateString() : 'Never'\n }\n });\n }\n\n return Response.json({\n success: true,\n message: `Successfully changed to ${newPlan.plan_name}`,\n membership: {\n planType: newPlanType,\n expiresAt,\n maxBeatsAllowed: newPlan.max_beats_allowed\n }\n });\n }\n\n // Get membership usage statistics\n if (method === 'GET' && action === 'usage-stats') {\n const membershipStmt = conn.prepare(`\n SELECT sm.*, mps.max_beats_allowed, mps.plan_name\n FROM seller_memberships sm\n LEFT JOIN membership_plan_settings mps ON sm.plan_type = mps.plan_name\n WHERE sm.seller_uuid = ? AND sm.status = 'active'\n `);\n const membership = await membershipStmt.get([userUuid]);\n\n if (!membership) {\n return Response.json({\n success: false,\n message: 'No active membership found'\n }, { status: 404 });\n }\n\n // Get additional usage stats\n const beatsStmt = conn.prepare(`\n SELECT COUNT(*) as total_beats,\n SUM(CASE WHEN active = true THEN 1 ELSE 0 END) as active_beats,\n SUM(CASE WHEN _created_at > ? THEN 1 ELSE 0 END) as beats_this_month\n FROM beats \n WHERE seller_uuid = ?\n `);\n\n const oneMonthAgo = Math.floor((Date.now() - 30 * 24 * 60 * 60 * 1000) / 1000);\n const beatsStats = await beatsStmt.get([oneMonthAgo, userUuid]);\n\n const currentTimestamp = Math.floor(Date.now() / 1000);\n const isExpired = membership.expires_at && membership.expires_at < currentTimestamp;\n const daysUntilExpiry = membership.expires_at ? \n Math.max(0, Math.floor((membership.expires_at - currentTimestamp) / (24 * 60 * 60))) : null;\n\n return Response.json({\n success: true,\n usage: {\n currentPlan: membership.plan_name,\n planType: membership.plan_type,\n maxBeatsAllowed: membership.max_beats_allowed,\n beatsUploaded: membership.beats_uploaded || 0,\n totalBeats: beatsStats.total_beats,\n activeBeats: beatsStats.active_beats,\n beatsThisMonth: beatsStats.beats_this_month,\n isExpired,\n daysUntilExpiry,\n expiresAt: membership.expires_at\n }\n });\n }\n\n // Get payment history for memberships\n if (method === 'GET' && action === 'payment-history') {\n const historyStmt = conn.prepare(`\n SELECT * FROM membership_payments \n WHERE seller_uuid = ? \n ORDER BY _created_at DESC\n LIMIT 50\n `);\n const history = await historyStmt.all([userUuid]);\n\n return Response.json({\n success: true,\n history\n });\n }\n\n return Response.json({\n success: false,\n message: 'Invalid action or method'\n }, { status: 400 });\n\n } catch (error) {\n console.error('Membership management error:', error);\n return Response.json({\n success: false,\n message: 'Internal server error'\n }, { status: 500 });\n }\n}",[],[191],"files",[151,172,181,189],"counts",{"_202":32,"_203":176,"_204":32,"_205":206},"pulls","branches","forks","envVars",{"_207":32,"_208":32},"count","emptyCount","contents",[211,214,217,220],{"_104":152,"_96":153,"_154":155,"_156":-5,"_157":139,"_158":159,"_160":161,"_106":212,"_100":32,"_163":164,"_165":166,"_167":22,"_168":-5,"_99":213},["D",1765561298761],[153],{"_104":173,"_96":174,"_154":175,"_156":-5,"_157":139,"_158":176,"_160":161,"_106":215,"_100":32,"_163":164,"_165":178,"_167":22,"_168":-5,"_99":216},["D",1765561160722],[174],{"_104":182,"_96":183,"_154":184,"_156":-5,"_157":139,"_158":101,"_160":161,"_106":218,"_100":32,"_163":164,"_165":186,"_167":22,"_168":-5,"_99":219},["D",1765561362014],[183],{"_104":190,"_96":191,"_154":192,"_156":-5,"_157":139,"_158":193,"_160":161,"_106":221,"_100":32,"_163":164,"_165":195,"_167":22,"_168":-5,"_99":222},["D",1765561192877],[191],"file","upstreamProject","upstreamBranch","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.branch.$branch.version.$version.code.$",{"_94":95,"_96":97,"_98":44,"_100":101,"_99":73,"_102":232,"_149":237,"_198":250,"_223":-7,"_209":251,"_260":-5,"_261":-5,"_262":-5,"_263":-5,"_264":265,"_205":-5},{"_104":105,"_96":97,"_106":233,"_108":-5,"_109":22,"_110":111,"_112":-5,"_113":-5,"_14":114,"_115":-5,"_116":22,"_117":-5,"_118":-5,"_119":32,"_16":120,"_121":122,"_123":122,"_124":125,"_126":125,"_127":125,"_128":122,"_129":122,"_23":234,"_133":235,"_136":236,"_148":22},["D",1765561160624],{"_94":95,"_131":132},{"_94":95,"_135":132,"_14":114},{"_100":138,"_96":44,"_104":139,"_140":105,"_141":-5,"_142":-5,"_143":-5,"_144":-5,"_145":-5,"_146":97,"_147":95},[238,241,244,247],{"_104":152,"_96":153,"_154":155,"_156":-5,"_157":139,"_158":159,"_160":161,"_106":162,"_100":32,"_163":164,"_165":166,"_167":22,"_168":-5,"_169":239,"_99":240},[],[153],{"_104":173,"_96":174,"_154":175,"_156":-5,"_157":139,"_158":176,"_160":161,"_106":177,"_100":32,"_163":164,"_165":178,"_167":22,"_168":-5,"_169":242,"_99":243},[],[174],{"_104":182,"_96":183,"_154":184,"_156":-5,"_157":139,"_158":101,"_160":161,"_106":185,"_100":32,"_163":164,"_165":186,"_167":22,"_168":-5,"_169":245,"_99":246},[],[183],{"_104":190,"_96":191,"_154":192,"_156":-5,"_157":139,"_158":193,"_160":161,"_106":194,"_100":32,"_163":164,"_165":195,"_167":22,"_168":-5,"_169":248,"_99":249},[],[191],[238,241,244,247],[252,254,256,258],{"_104":152,"_96":153,"_154":155,"_156":-5,"_157":139,"_158":159,"_160":161,"_106":212,"_100":32,"_163":164,"_165":166,"_167":22,"_168":-5,"_99":253},[153],{"_104":173,"_96":174,"_154":175,"_156":-5,"_157":139,"_158":176,"_160":161,"_106":215,"_100":32,"_163":164,"_165":178,"_167":22,"_168":-5,"_99":255},[174],{"_104":182,"_96":183,"_154":184,"_156":-5,"_157":139,"_158":101,"_160":161,"_106":218,"_100":32,"_163":164,"_165":186,"_167":22,"_168":-5,"_99":257},[183],{"_104":190,"_96":191,"_154":192,"_156":-5,"_157":139,"_158":193,"_160":161,"_106":221,"_100":32,"_163":164,"_165":195,"_167":22,"_168":-5,"_99":259},[191],"upstream","pull","ahead","behind","templates",[],"actionData","errors"]