[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_197":198,"_199":200},"routes/_app.x.$handle.$name",{"_92":91,"_31":43,"_100":82,"_26":101,"_13":14,"_102":-5,"_11":103,"_104":105,"_106":107,"_108":109,"_110":111,"_20":-5,"_112":-5,"_113":-5,"_114":24,"_115":116,"_117":118,"_119":-5,"_120":-5,"_121":122},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_41":42,"_31":43,"_36":44,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":-5,"_51":-5,"_18":52,"_53":-5,"_54":24,"_55":-5,"_56":-5,"_57":58,"_59":60,"_61":-5,"_62":-5,"_63":-5,"_64":-5,"_65":66,"_67":66,"_68":69,"_70":69,"_71":69,"_72":66,"_73":66,"_74":75,"_76":77,"_78":79,"_80":24},"version",5,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":27,"_32":33,"_34":35,"_36":37,"_38":14,"_39":40,"_23":24},"previous","deleted",false,"deletedHere","path","fu7t4q06s57est42419585v1367t75v7tq.ts","latestPath","fileId","0e8a07fa-d782-11f0-969f-42dde27851f2","name","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 // Verify admin access\n const adminStmt = conn.prepare(`\n SELECT * FROM admin_accounts \n WHERE user_uuid = ? AND active = 1\n `);\n const admin = await adminStmt.get([userUuid]);\n\n if (!admin) {\n return Response.json({\n success: false,\n message: 'Admin access required'\n }, { status: 403 });\n }\n\n const isMainAdmin = admin.is_main_admin === 1;\n\n // Get platform statistics\n if (method === 'GET' && action === 'stats') {\n // User statistics\n const userStatsStmt = conn.prepare(`\n SELECT \n COUNT(*) as total_users,\n COUNT(CASE WHEN u.metadata LIKE '%\"accountType\":\"seller\"%' THEN 1 END) as sellers,\n COUNT(CASE WHEN u.metadata LIKE '%\"accountType\":\"buyer\"%' THEN 1 END) as buyers\n FROM users u\n `);\n const userStats = await userStatsStmt.get([]);\n\n // Beat statistics\n const beatStatsStmt = conn.prepare(`\n SELECT \n COUNT(*) as total_beats,\n COUNT(CASE WHEN active = true THEN 1 END) as active_beats,\n SUM(COALESCE(plays, 0)) as total_plays,\n AVG(price) as avg_price\n FROM beats\n `);\n const beatStats = await beatStatsStmt.get([]);\n\n // Order statistics\n const orderStatsStmt = conn.prepare(`\n SELECT \n COUNT(*) as total_orders,\n COALESCE(SUM(total_amount), 0) as total_revenue,\n COALESCE(SUM(platform_commission), 0) as total_commission,\n COUNT(CASE WHEN status = 'completed' THEN 1 END) as completed_orders\n FROM orders\n `);\n const orderStats = await orderStatsStmt.get([]);\n\n // Membership statistics\n const membershipStatsStmt = conn.prepare(`\n SELECT \n plan_type,\n COUNT(*) as count,\n COUNT(CASE WHEN status = 'active' THEN 1 END) as active_count\n FROM seller_memberships\n GROUP BY plan_type\n `);\n const membershipStats = await membershipStatsStmt.all([]);\n\n // Withdrawal statistics\n const withdrawalStatsStmt = conn.prepare(`\n SELECT \n COUNT(*) as total_withdrawals,\n COUNT(CASE WHEN status = 'pending' THEN 1 END) as pending_withdrawals,\n COALESCE(SUM(CASE WHEN status = 'approved' THEN amount ELSE 0 END), 0) as total_paid\n FROM withdrawal_requests\n `);\n const withdrawalStats = await withdrawalStatsStmt.get([]);\n\n return Response.json({\n success: true,\n stats: {\n users: userStats,\n beats: beatStats,\n orders: orderStats,\n memberships: membershipStats,\n withdrawals: withdrawalStats\n }\n });\n }\n\n // Get all sellers with filtering\n if (method === 'GET' && action === 'sellers') {\n const page = parseInt(url.searchParams.get('page') || '1');\n const limit = parseInt(url.searchParams.get('limit') || '20');\n const status = url.searchParams.get('status'); // active, inactive, all\n const search = url.searchParams.get('search');\n\n let whereClause = 'WHERE 1=1';\n const params = [];\n\n if (status && status !== 'all') {\n whereClause += ' AND sp.active = ?';\n params.push(status === 'active' ? 1 : 0);\n }\n\n if (search) {\n whereClause += ' AND (sp.display_name LIKE ? OR sp.bio LIKE ? OR u.email LIKE ?)';\n const searchQuery = `%${search}%`;\n params.push(searchQuery, searchQuery, searchQuery);\n }\n\n const sellersStmt = conn.prepare(`\n SELECT \n sp.*,\n u.email,\n u.created_at as user_created_at,\n sm.plan_type,\n sm.status as membership_status,\n COUNT(b._row_id) as beat_count,\n COALESCE(SUM(oi.seller_earnings), 0) as total_earnings\n FROM seller_profiles sp\n JOIN users u ON sp.seller_uuid = u.user_uuid\n LEFT JOIN seller_memberships sm ON sp.seller_uuid = sm.seller_uuid AND sm.status = 'active'\n LEFT JOIN beats b ON sp.seller_uuid = b.seller_uuid\n LEFT JOIN order_items oi ON sp.seller_uuid = oi.seller_uuid\n ${whereClause}\n GROUP BY sp._row_id\n ORDER BY sp._created_at DESC\n LIMIT ? OFFSET ?\n `);\n\n const sellers = await sellersStmt.all([...params, limit, (page - 1) * limit]);\n\n // Get total count\n const countStmt = conn.prepare(`\n SELECT COUNT(DISTINCT sp._row_id) as total\n FROM seller_profiles sp\n JOIN users u ON sp.seller_uuid = u.user_uuid\n ${whereClause}\n `);\n const countResult = await countStmt.get(params);\n\n return Response.json({\n success: true,\n sellers,\n pagination: {\n currentPage: page,\n totalPages: Math.ceil(countResult.total / limit),\n totalSellers: countResult.total\n }\n });\n }\n\n // Get all buyers with filtering\n if (method === 'GET' && action === 'buyers') {\n const page = parseInt(url.searchParams.get('page') || '1');\n const limit = parseInt(url.searchParams.get('limit') || '20');\n const search = url.searchParams.get('search');\n\n let whereClause = 'WHERE 1=1';\n const params = [];\n\n if (search) {\n whereClause += ' AND (bp.name LIKE ? OR bp.email LIKE ? OR u.email LIKE ?)';\n const searchQuery = `%${search}%`;\n params.push(searchQuery, searchQuery, searchQuery);\n }\n\n const buyersStmt = conn.prepare(`\n SELECT \n bp.*,\n u.email,\n u.created_at as user_created_at,\n COUNT(DISTINCT o._row_id) as order_count,\n COALESCE(SUM(o.total_amount), 0) as total_spent\n FROM buyer_profiles bp\n JOIN users u ON bp.buyer_uuid = u.user_uuid\n LEFT JOIN orders o ON bp.buyer_uuid = o.buyer_uuid\n ${whereClause}\n GROUP BY bp._row_id\n ORDER BY bp._created_at DESC\n LIMIT ? OFFSET ?\n `);\n\n const buyers = await buyersStmt.all([...params, limit, (page - 1) * limit]);\n\n // Get total count\n const countStmt = conn.prepare(`\n SELECT COUNT(DISTINCT bp._row_id) as total\n FROM buyer_profiles bp\n JOIN users u ON bp.buyer_uuid = u.user_uuid\n ${whereClause}\n `);\n const countResult = await countStmt.get(params);\n\n return Response.json({\n success: true,\n buyers,\n pagination: {\n currentPage: page,\n totalPages: Math.ceil(countResult.total / limit),\n totalBuyers: countResult.total\n }\n });\n }\n\n // Manage withdrawal requests\n if (method === 'GET' && action === 'withdrawals') {\n const status = url.searchParams.get('status') || 'pending'; // pending, approved, rejected\n\n const withdrawalsStmt = conn.prepare(`\n SELECT \n wr.*,\n sp.display_name as seller_name,\n sp.email as seller_email,\n u.created_at as user_created_at\n FROM withdrawal_requests wr\n JOIN seller_profiles sp ON wr.seller_uuid = sp.seller_uuid\n JOIN users u ON wr.seller_uuid = u.user_uuid\n WHERE wr.status = ?\n ORDER BY wr._created_at DESC\n `);\n\n const withdrawals = await withdrawalsStmt.all([status]);\n\n return Response.json({\n success: true,\n withdrawals\n });\n }\n\n // Process withdrawal (approve/reject)\n if (method === 'POST' && action === 'process-withdrawal') {\n if (!isMainAdmin) {\n return Response.json({\n success: false,\n message: 'Only main admin can process withdrawals'\n }, { status: 403 });\n }\n\n const { withdrawalId, action: withdrawalAction, reason } = await req.json();\n\n if (!withdrawalId || !withdrawalAction) {\n return Response.json({\n success: false,\n message: 'Withdrawal ID and action are required'\n }, { status: 400 });\n }\n\n if (!['approve', 'reject'].includes(withdrawalAction)) {\n return Response.json({\n success: false,\n message: 'Action must be approve or reject'\n }, { status: 400 });\n }\n\n // Get withdrawal details\n const withdrawalStmt = conn.prepare(`\n SELECT wr.*, sp.email as seller_email, sp.display_name as seller_name\n FROM withdrawal_requests wr\n JOIN seller_profiles sp ON wr.seller_uuid = sp.seller_uuid\n WHERE wr._row_id = ? AND wr.status = 'pending'\n `);\n const withdrawal = await withdrawalStmt.get([withdrawalId]);\n\n if (!withdrawal) {\n return Response.json({\n success: false,\n message: 'Withdrawal not found or already processed'\n }, { status: 404 });\n }\n\n const timestamp = Math.floor(Date.now() / 1000);\n\n if (withdrawalAction === 'approve') {\n // Update withdrawal status\n const approveStmt = conn.prepare(`\n UPDATE withdrawal_requests \n SET status = 'approved', approved_by = ?, approved_at = ?, _updated_at = ?\n WHERE _row_id = ?\n `);\n await approveStmt.run([userUuid, timestamp, timestamp, withdrawalId]);\n\n // Update seller balance\n const updateSellerStmt = conn.prepare(`\n UPDATE seller_profiles \n SET pending_withdrawals = COALESCE(pending_withdrawals, 0) - ?,\n _updated_at = ?\n WHERE seller_uuid = ?\n `);\n await updateSellerStmt.run([withdrawal.amount, timestamp, withdrawal.seller_uuid]);\n\n // Send approval email\n await platform.sendEmail({\n templateName: 'withdrawal_approved',\n recipientEmail: withdrawal.seller_email,\n recipientName: withdrawal.seller_name,\n customVariables: {\n amount: (withdrawal.amount / 100).toFixed(2), // Assuming cents\n approvalDate: new Date(timestamp * 1000).toLocaleDateString()\n }\n });\n\n // Log the action\n await platform.log('info', 'Withdrawal approved', {\n withdrawalId,\n sellerUuid: withdrawal.seller_uuid,\n amount: withdrawal.amount\n });\n\n } else {\n // Reject withdrawal\n const rejectStmt = conn.prepare(`\n UPDATE withdrawal_requests \n SET status = 'rejected', rejected_by = ?, rejected_at = ?, \n rejection_reason = ?, _updated_at = ?\n WHERE _row_id = ?\n `);\n await rejectStmt.run([userUuid, timestamp, reason || 'Rejected by admin', timestamp, withdrawalId]);\n\n // Update seller balance (add back the amount)\n const updateSellerStmt = conn.prepare(`\n UPDATE seller_profiles \n SET current_balance = COALESCE(current_balance, 0) + ?,\n pending_withdrawals = COALESCE(pending_withdrawals, 0) - ?,\n _updated_at = ?\n WHERE seller_uuid = ?\n `);\n await updateSellerStmt.run([withdrawal.amount, withdrawal.amount, timestamp, withdrawal.seller_uuid]);\n\n // Send rejection email\n await platform.sendEmail({\n templateName: 'withdrawal_rejected',\n recipientEmail: withdrawal.seller_email,\n recipientName: withdrawal.seller_name,\n customVariables: {\n amount: (withdrawal.amount / 100).toFixed(2),\n reason: reason || 'Rejected by admin',\n rejectionDate: new Date(timestamp * 1000).toLocaleDateString()\n }\n });\n\n // Log the action\n await platform.log('info', 'Withdrawal rejected', {\n withdrawalId,\n sellerUuid: withdrawal.seller_uuid,\n amount: withdrawal.amount,\n reason\n });\n }\n\n return Response.json({\n success: true,\n message: `Withdrawal ${withdrawalAction}d successfully`\n });\n }\n\n // Update platform settings\n if (method === 'PUT' && action === 'settings') {\n if (!isMainAdmin) {\n return Response.json({\n success: false,\n message: 'Only main admin can update settings'\n }, { status: 403 });\n }\n\n const settings = await req.json();\n\n // Validate settings\n const allowedSettings = [\n 'platform_commission_rate',\n 'default_affiliate_commission_rate',\n 'admin_registration_enabled',\n 'affiliate_system_enabled',\n 'auto_withdrawal_enabled',\n 'min_withdrawal_amount'\n ];\n\n for (const key of Object.keys(settings)) {\n if (!allowedSettings.includes(key)) {\n return Response.json({\n success: false,\n message: `Invalid setting: ${key}`\n }, { status: 400 });\n }\n }\n\n // Update or insert settings\n const timestamp = Math.floor(Date.now() / 1000);\n \n for (const [key, value] of Object.entries(settings)) {\n const upsertStmt = conn.prepare(`\n INSERT INTO platform_settings (setting_key, setting_value, _created_by, _created_at, _updated_at)\n VALUES (?, ?, ?, ?, ?)\n ON CONFLICT(setting_key) DO UPDATE SET\n setting_value = ?,\n _updated_at = ?,\n _updated_by = ?\n `);\n await upsertStmt.run([key, value, userUuid, timestamp, timestamp, value, timestamp, userUuid]);\n }\n\n return Response.json({\n success: true,\n message: 'Settings updated successfully'\n });\n }\n\n // Get platform settings\n if (method === 'GET' && action === 'settings') {\n const settingsStmt = conn.prepare(\"SELECT setting_key, setting_value FROM platform_settings\");\n const settings = await settingsStmt.all([]);\n\n const settingsObj = {};\n settings.forEach(setting => {\n settingsObj[setting.setting_key] = setting.setting_value;\n });\n\n return Response.json({\n success: true,\n settings: settingsObj\n });\n }\n\n // Create/update membership plan\n if (method === 'POST' && action === 'membership-plan') {\n if (!isMainAdmin) {\n return Response.json({\n success: false,\n message: 'Only main admin can manage membership plans'\n }, { status: 403 });\n }\n\n const {\n planName,\n description,\n price,\n maxBeatsAllowed,\n features,\n active = true,\n sortOrder = 0\n } = await req.json();\n\n if (!planName || !description || price === undefined || maxBeatsAllowed === undefined) {\n return Response.json({\n success: false,\n message: 'Missing required fields'\n }, { status: 400 });\n }\n\n const timestamp = Math.floor(Date.now() / 1000);\n\n // Insert or update plan\n const planStmt = conn.prepare(`\n INSERT OR REPLACE INTO membership_plan_settings (\n plan_name, description, price, max_beats_allowed, \n features, active, sort_order, _created_by, _created_at, _updated_at\n ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)\n `);\n\n await planStmt.run([\n planName, description, price, maxBeatsAllowed,\n JSON.stringify(features || []), active, sortOrder,\n userUuid, timestamp, timestamp\n ]);\n\n return Response.json({\n success: true,\n message: 'Membership plan saved successfully'\n });\n }\n\n // Get membership plans\n if (method === 'GET' && action === 'membership-plans') {\n const plansStmt = conn.prepare(`\n SELECT * FROM membership_plan_settings \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 system logs\n if (method === 'GET' && action === 'logs') {\n const level = url.searchParams.get('level') || 'info';\n const limit = parseInt(url.searchParams.get('limit') || '100');\n\n // This would integrate with the platform logging system\n // For now, return a placeholder\n return Response.json({\n success: true,\n logs: [],\n message: 'System logging integration required'\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('Admin backend error:', error);\n return Response.json({\n success: false,\n message: 'Internal server error'\n }, { status: 500 });\n }\n}","createdAt",["D",1765561403804],"branchVersion","branchId","7d972782-d781-11f0-8f41-42dde27851f2","id","7d96e66e-d781-11f0-8f41-42dde27851f2","tes28e8v4fq374494f9t2543t09seet24q",["D",1765561160624],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","0199d9f9-8fb9-705d-a1be-150ee5ea0145","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","0199d9f9-8fb9-705d-a1be-18ed6d1d02d7","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_92":91,"_99":95},"org",{"_92":91,"_93":-5,"_94":95,"_18":52,"_96":97,"_98":24},"branch",{"_13":81,"_31":82,"_41":40,"_83":42,"_84":-5,"_85":-5,"_86":-5,"_87":-5,"_88":-5,"_89":43,"_90":91},"isOwned",6,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","kliv","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzMzeW9MdTZSSlZXdUFyNHFTckJtSlg1b3paYiJ9","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_41":42,"_31":43,"_36":193,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":-5,"_51":-5,"_18":52,"_53":-5,"_54":24,"_55":-5,"_56":-5,"_57":58,"_59":60,"_61":-5,"_62":-5,"_63":-5,"_64":-5,"_65":66,"_67":66,"_68":69,"_70":69,"_71":69,"_72":66,"_73":66,"_74":194,"_76":195,"_78":196,"_80":24},"tree",[172,173,174,175,176],"files",[172,173,174,175,176],"counts",{"_162":58,"_163":151,"_164":58,"_165":166,"_167":168},"contents",[123,124,125,126,127],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_41":155,"_31":156,"_29":157,"_131":-5,"_39":40,"_38":158,"_133":118,"_36":159,"_13":58,"_32":33,"_34":160,"_23":24,"_136":-5,"_26":161},{"_41":148,"_31":149,"_29":150,"_131":-5,"_39":40,"_38":151,"_133":118,"_36":152,"_13":58,"_32":33,"_34":153,"_23":24,"_136":-5,"_26":154},{"_41":145,"_31":27,"_29":30,"_131":-5,"_39":40,"_38":14,"_133":118,"_36":146,"_13":58,"_32":33,"_34":35,"_23":24,"_136":-5,"_26":147},{"_41":138,"_31":139,"_29":140,"_131":-5,"_39":40,"_38":141,"_133":118,"_36":142,"_13":58,"_32":33,"_34":143,"_23":24,"_136":-5,"_26":144},{"_41":128,"_31":129,"_29":130,"_131":-5,"_39":40,"_38":132,"_133":118,"_36":134,"_13":58,"_32":33,"_34":135,"_23":24,"_136":-5,"_26":137},"90d0cc86-d781-11f0-947e-42dde27851f2","fuvtfq3ef8s011461e87t365f81s7tv145.ts","90d0cd6c-d781-11f0-947e-42dde27851f2","parentId",2,"latest",["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}","label",[129],"f5a0e006-d781-11f0-afb4-42dde27851f2","fuvf5f5s1811s84ts49f6e0s3382286ev3.ts","f5a0e09c-d781-11f0-afb4-42dde27851f2",4,["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}",[139],"0e8a0728-d782-11f0-969f-42dde27851f2",["D",1765561403804],[27],"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}",[149],"cfedb64a-d781-11f0-a2e1-42dde27851f2","fu332649s068254eq08919q63vf43fss4e.ts","cfedb6fe-d781-11f0-a2e1-42dde27851f2",3,["D",1765561298761],"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}",[156],"pulls","branches","forks","envVars",{"_169":58,"_171":58},"connections",{"_169":58,"_170":58},"count","unfilledCount","emptyCount",{"_41":155,"_31":156,"_29":157,"_131":-5,"_39":40,"_38":158,"_133":118,"_36":190,"_13":58,"_32":33,"_34":160,"_23":24,"_136":-5,"_178":191,"_26":192},{"_41":148,"_31":149,"_29":150,"_131":-5,"_39":40,"_38":151,"_133":118,"_36":187,"_13":58,"_32":33,"_34":153,"_23":24,"_136":-5,"_178":188,"_26":189},{"_41":145,"_31":27,"_29":30,"_131":-5,"_39":40,"_38":14,"_133":118,"_36":184,"_13":58,"_32":33,"_34":35,"_23":24,"_136":-5,"_178":185,"_26":186},{"_41":138,"_31":139,"_29":140,"_131":-5,"_39":40,"_38":141,"_133":118,"_36":181,"_13":58,"_32":33,"_34":143,"_23":24,"_136":-5,"_178":182,"_26":183},{"_41":128,"_31":129,"_29":130,"_131":-5,"_39":40,"_38":132,"_133":118,"_36":177,"_13":58,"_32":33,"_34":135,"_23":24,"_136":-5,"_178":179,"_26":180},["D",1765561192877],"children",[],[129],["D",1765561362014],[],[139],["D",1765561403804],[],[27],["D",1765561160722],[],[149],["D",1765561298761],[],[156],["D",1765561160624],{"_92":91,"_99":95},{"_92":91,"_93":-5,"_94":95,"_18":52,"_96":97,"_98":24},{"_13":81,"_31":82,"_41":40,"_83":42,"_84":-5,"_85":-5,"_86":-5,"_87":-5,"_88":-5,"_89":43,"_90":91},"ctx",{"_74":-5,"_120":230,"_231":232,"_233":234,"_235":24,"_236":24,"_237":24,"_238":118,"_239":-5,"_240":-7,"_241":-7,"_242":58,"_243":24,"_244":24,"_245":-5,"_246":24,"_247":24,"_248":24,"_249":-5},"ENV",{"_201":202,"_203":204,"_205":82,"_206":207,"_208":209,"_210":211,"_212":213,"_214":215,"_216":217,"_218":219,"_220":221,"_222":223,"_224":225,"_226":227,"_228":229},"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",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v5