[{"_1":2,"_274":-5,"_275":-5},"loaderData",{"_3":4,"_92":93,"_238":239},"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":-7,"_99":100,"_101":-7,"_102":103,"_149":150,"_215":216,"_217":218,"_226":227,"_228":229,"_232":-5,"_233":-5,"_234":22,"_235":22,"_236":237},"handle","kliv","name","tes28e8v4fq374494f9t2543t09seet24q","branchName","path","fuvf5f5s1811s84ts49f6e0s3382286ev3.ts","version","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",{"_101":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,171,180,189,198,206],{"_104":152,"_96":153,"_154":155,"_156":-5,"_157":139,"_158":138,"_159":160,"_106":161,"_101":32,"_162":163,"_164":165,"_166":22,"_167":-5,"_168":169,"_99":170},"2016495c-d782-11f0-9e2f-42dde27851f2","fu0s3s0352t74t49s39e8f260qtt13sq9t.ts","fileId","20164a1a-d782-11f0-9e2f-42dde27851f2","parentId","branchId","branchVersion","latest",true,["D",1765561433245],"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 manage collaborations'\n }, { status: 403 });\n }\n\n // Get available sellers for collaboration\n if (method === 'GET' && action === 'available-collaborators') {\n const search = url.searchParams.get('search');\n\n let whereClause = 'WHERE sp.seller_uuid != ? AND sp.active = 1';\n const params = [userUuid];\n\n if (search) {\n whereClause += ' AND (sp.display_name LIKE ? OR sp.bio LIKE ?)';\n const searchQuery = `%${search}%`;\n params.push(searchQuery, searchQuery);\n }\n\n const sellersStmt = conn.prepare(`\n SELECT \n sp.seller_uuid,\n sp.display_name,\n sp.bio,\n sp.profile_image_url,\n COUNT(b._row_id) as beat_count,\n AVG(b.price) as avg_price,\n sp._created_at as member_since\n FROM seller_profiles sp\n LEFT JOIN beats b ON sp.seller_uuid = b.seller_uuid AND b.active = true\n ${whereClause}\n GROUP BY sp.seller_uuid\n ORDER BY sp.display_name ASC\n LIMIT 50\n `);\n\n const sellers = await sellersStmt.all(params);\n\n return Response.json({\n success: true,\n sellers: sellers.map(seller => ({\n id: seller.seller_uuid,\n name: seller.display_name,\n bio: seller.bio,\n avatar: seller.profile_image_url,\n beatCount: seller.beat_count,\n averagePrice: seller.avg_price ? parseFloat(seller.avg_price).toFixed(2) : '0.00',\n memberSince: seller.member_since\n }))\n });\n }\n\n // Send collaboration request\n if (method === 'POST' && action === 'send-request') {\n const { collaboratorUuid, beatTitle, message, proposedSplit } = await req.json();\n\n if (!collaboratorUuid || !beatTitle || !proposedSplit) {\n return Response.json({\n success: false,\n message: 'Collaborator UUID, beat title, and proposed split are required'\n }, { status: 400 });\n }\n\n if (collaboratorUuid === userUuid) {\n return Response.json({\n success: false,\n message: 'Cannot collaborate with yourself'\n }, { status: 400 });\n }\n\n // Validate split percentage\n if (!Array.isArray(proposedSplit) || proposedSplit.length !== 2) {\n return Response.json({\n success: false,\n message: 'Split must be an array of 2 percentages'\n }, { status: 400 });\n }\n\n const totalPercentage = proposedSplit.reduce((sum, percent) => sum + percent, 0);\n if (totalPercentage !== 100) {\n return Response.json({\n success: false,\n message: 'Split percentages must total 100%'\n }, { status: 400 });\n }\n\n // Check if collaborator exists and is active\n const collaboratorStmt = conn.prepare(`\n SELECT sp.display_name, sp.email \n FROM seller_profiles sp\n WHERE sp.seller_uuid = ? AND sp.active = 1\n `);\n const collaborator = await collaboratorStmt.get([collaboratorUuid]);\n\n if (!collaborator) {\n return Response.json({\n success: false,\n message: 'Collaborator not found or inactive'\n }, { status: 404 });\n }\n\n // Check for existing pending requests\n const existingStmt = conn.prepare(`\n SELECT _row_id FROM collaboration_requests \n WHERE ((requester_uuid = ? AND collaborator_uuid = ?) OR \n (requester_uuid = ? AND collaborator_uuid = ?))\n AND status = 'pending'\n `);\n const existing = await existingStmt.get([userUuid, collaboratorUuid, collaboratorUuid, userUuid]);\n\n if (existing) {\n return Response.json({\n success: false,\n message: 'A pending collaboration request already exists'\n }, { status: 409 });\n }\n\n const timestamp = Math.floor(Date.now() / 1000);\n\n // Create collaboration request\n const requestStmt = conn.prepare(`\n INSERT INTO collaboration_requests (\n requester_uuid, collaborator_uuid, beat_title, message,\n proposed_split, status, _created_by, _created_at\n ) VALUES (?, ?, ?, ?, ?, ?, ?, ?)\n `);\n\n const result = await requestStmt.run([\n userUuid, collaboratorUuid, beatTitle, message,\n JSON.stringify(proposedSplit), 'pending', userUuid, timestamp\n ]);\n\n // Get requester info for email\n const requesterStmt = conn.prepare(`\n SELECT display_name FROM seller_profiles WHERE seller_uuid = ?\n `);\n const requester = await requesterStmt.get([userUuid]);\n\n // Send notification email to collaborator\n await platform.sendEmail({\n templateName: 'collaboration_request',\n recipientEmail: collaborator.email,\n recipientName: collaborator.display_name,\n customVariables: {\n requesterName: requester.display_name,\n beatTitle: beatTitle,\n message: message || '',\n split: `You: ${proposedSplit[1]}%, Them: ${proposedSplit[0]}%`,\n requestId: result.lastInsertRowid\n }\n });\n\n // Log the collaboration request\n await platform.log('info', 'Collaboration request sent', {\n requestId: result.lastInsertRowid,\n requesterUuid: userUuid,\n collaboratorUuid,\n beatTitle\n });\n\n return Response.json({\n success: true,\n message: 'Collaboration request sent successfully',\n requestId: result.lastInsertRowid\n });\n }\n\n // Get collaboration requests (sent and received)\n if (method === 'GET' && action === 'requests') {\n const type = url.searchParams.get('type'); // sent, received, all\n\n let whereClause = 'WHERE cr.requester_uuid = ? OR cr.collaborator_uuid = ?';\n const params = [userUuid, userUuid];\n\n if (type === 'sent') {\n whereClause = 'WHERE cr.requester_uuid = ?';\n params.pop();\n } else if (type === 'received') {\n whereClause = 'WHERE cr.collaborator_uuid = ?';\n params.shift();\n }\n\n const requestsStmt = conn.prepare(`\n SELECT \n cr.*,\n requester.display_name as requester_name,\n requester.profile_image_url as requester_avatar,\n collaborator.display_name as collaborator_name,\n collaborator.profile_image_url as collaborator_avatar\n FROM collaboration_requests cr\n LEFT JOIN seller_profiles requester ON cr.requester_uuid = requester.seller_uuid\n LEFT JOIN seller_profiles collaborator ON cr.collaborator_uuid = collaborator.seller_uuid\n ${whereClause}\n ORDER BY cr._created_at DESC\n `);\n\n const requests = await requestsStmt.all(params);\n\n return Response.json({\n success: true,\n requests: requests.map(req => ({\n id: req._row_id,\n requesterId: req.requester_uuid,\n requesterName: req.requester_name,\n requesterAvatar: req.requester_avatar,\n collaboratorId: req.collaborator_uuid,\n collaboratorName: req.collaborator_name,\n collaboratorAvatar: req.collaborator_avatar,\n beatTitle: req.beat_title,\n message: req.message,\n proposedSplit: JSON.parse(req.proposed_split),\n status: req.status,\n createdAt: req._created_at,\n isOwnRequest: req.requester_uuid === userUuid\n }))\n });\n }\n\n // Respond to collaboration request\n if (method === 'PUT' && action === 'respond-request') {\n const { requestId, action: responseAction, message: responseMessage } = await req.json();\n\n if (!requestId || !responseAction) {\n return Response.json({\n success: false,\n message: 'Request ID and action are required'\n }, { status: 400 });\n }\n\n if (!['accept', 'reject', 'counter'].includes(responseAction)) {\n return Response.json({\n success: false,\n message: 'Action must be accept, reject, or counter'\n }, { status: 400 });\n }\n\n // Get request details and verify user is the collaborator\n const requestStmt = conn.prepare(`\n SELECT cr.*, \n requester.display_name as requester_name,\n requester.email as requester_email,\n collaborator.display_name as collaborator_name,\n collaborator.email as collaborator_email\n FROM collaboration_requests cr\n LEFT JOIN seller_profiles requester ON cr.requester_uuid = requester.seller_uuid\n LEFT JOIN seller_profiles collaborator ON cr.collaborator_uuid = collaborator.seller_uuid\n WHERE cr._row_id = ? AND cr.collaborator_uuid = ?\n `);\n const request = await requestStmt.get([requestId, userUuid]);\n\n if (!request) {\n return Response.json({\n success: false,\n message: 'Request not found or access denied'\n }, { status: 404 });\n }\n\n if (request.status !== 'pending') {\n return Response.json({\n success: false,\n message: 'Request has already been processed'\n }, { status: 400 });\n }\n\n const timestamp = Math.floor(Date.now() / 1000);\n\n if (responseAction === 'accept') {\n // Accept the request\n const acceptStmt = conn.prepare(`\n UPDATE collaboration_requests \n SET status = 'accepted', response_message = ?, responded_at = ?, _updated_at = ?\n WHERE _row_id = ?\n `);\n await acceptStmt.run([responseMessage, timestamp, timestamp, requestId]);\n\n // Send acceptance email to requester\n await platform.sendEmail({\n templateName: 'collaboration_accepted',\n recipientEmail: request.requester_email,\n recipientName: request.requester_name,\n customVariables: {\n collaboratorName: request.collaborator_name,\n beatTitle: request.beat_title,\n responseMessage: responseMessage || ''\n }\n });\n\n } else if (responseAction === 'reject') {\n // Reject the request\n const rejectStmt = conn.prepare(`\n UPDATE collaboration_requests \n SET status = 'rejected', response_message = ?, responded_at = ?, _updated_at = ?\n WHERE _row_id = ?\n `);\n await rejectStmt.run([responseMessage, timestamp, timestamp, requestId]);\n\n // Send rejection email to requester\n await platform.sendEmail({\n templateName: 'collaboration_rejected',\n recipientEmail: request.requester_email,\n recipientName: request.requester_name,\n customVariables: {\n collaboratorName: request.collaborator_name,\n beatTitle: request.beat_title,\n responseMessage: responseMessage || ''\n }\n });\n\n } else if (responseAction === 'counter') {\n // Counter offer (not implemented in this example)\n return Response.json({\n success: false,\n message: 'Counter offers not implemented yet'\n }, { status: 501 });\n }\n\n // Log the response\n await platform.log('info', 'Collaboration request responded', {\n requestId,\n action: responseAction,\n userUuid\n });\n\n return Response.json({\n success: true,\n message: `Collaboration request ${responseAction}ed successfully`\n });\n }\n\n // Get active collaborations\n if (method === 'GET' && action === 'active-collaborations') {\n const collaborationsStmt = conn.prepare(`\n SELECT \n c.*,\n b.title as beat_title,\n b.artwork_path as beat_artwork,\n requester.display_name as collaborator_name,\n requester.profile_image_url as collaborator_avatar\n FROM collaborations c\n JOIN beats b ON c.beat_id = b._row_id\n JOIN seller_profiles requester ON c.collaborator_uuid = requester.seller_uuid\n WHERE (c.owner_uuid = ? OR c.collaborator_uuid = ?) AND c.status = 'active'\n ORDER BY c._created_at DESC\n `);\n\n const collaborations = await collaborationsStmt.all([userUuid, userUuid]);\n\n return Response.json({\n success: true,\n collaborations: collaborations.map(collab => ({\n id: collab._row_id,\n beatId: collab.beat_id,\n beatTitle: collab.beat_title,\n beatArtwork: collab.beat_artwork,\n collaboratorId: collab.collaborator_uuid,\n collaboratorName: collab.collaborator_name,\n collaboratorAvatar: collab.collaborator_avatar,\n percentage: collab.percentage,\n status: collab.status,\n createdAt: collab._created_at,\n isOwner: collab.owner_uuid === userUuid\n }))\n });\n }\n\n // Get collaboration history\n if (method === 'GET' && action === 'history') {\n const page = parseInt(url.searchParams.get('page') || '1');\n const limit = parseInt(url.searchParams.get('limit') || '20');\n\n const historyStmt = conn.prepare(`\n SELECT \n c.*,\n b.title as beat_title,\n CASE \n WHEN c.owner_uuid = ? THEN sp.display_name\n ELSE cp.display_name\n END as other_party_name,\n CASE \n WHEN c.owner_uuid = ? THEN sp.profile_image_url\n ELSE cp.profile_image_url\n END as other_party_avatar,\n o.order_number,\n o.total_amount as order_amount,\n o._created_at as order_date\n FROM collaborations c\n JOIN beats b ON c.beat_id = b._row_id\n LEFT JOIN seller_profiles sp ON c.collaborator_uuid = sp.seller_uuid\n LEFT JOIN seller_profiles cp ON c.owner_uuid = cp.seller_uuid\n LEFT JOIN order_items oi ON c.beat_id = oi.beat_id\n LEFT JOIN orders o ON oi.order_id = o._row_id\n WHERE (c.owner_uuid = ? OR c.collaborator_uuid = ?)\n ORDER BY c._created_at DESC\n LIMIT ? OFFSET ?\n `);\n\n const history = await historyStmt.all([userUuid, userUuid, userUuid, userUuid, limit, (page - 1) * limit]);\n\n return Response.json({\n success: true,\n history: history.map(item => ({\n id: item._row_id,\n beatId: item.beat_id,\n beatTitle: item.beat_title,\n otherPartyId: item.owner_uuid === userUuid ? item.collaborator_uuid : item.owner_uuid,\n otherPartyName: item.other_party_name,\n otherPartyAvatar: item.other_party_avatar,\n percentage: item.percentage,\n status: item.status,\n orderNumber: item.order_number,\n orderAmount: item.order_amount,\n orderDate: item.order_date,\n createdAt: item._created_at,\n isOwner: item.owner_uuid === userUuid\n }))\n });\n }\n\n // Update collaboration split\n if (method === 'PUT' && action === 'update-split') {\n const { collaborationId, percentage } = await req.json();\n\n if (!collaborationId || percentage === undefined) {\n return Response.json({\n success: false,\n message: 'Collaboration ID and percentage are required'\n }, { status: 400 });\n }\n\n if (percentage < 0 || percentage > 100) {\n return Response.json({\n success: false,\n message: 'Percentage must be between 0 and 100'\n }, { status: 400 });\n }\n\n // Verify collaboration ownership\n const verifyStmt = conn.prepare(`\n SELECT * FROM collaborations \n WHERE _row_id = ? AND owner_uuid = ?\n `);\n const collaboration = await verifyStmt.get([collaborationId, userUuid]);\n\n if (!collaboration) {\n return Response.json({\n success: false,\n message: 'Collaboration not found or access denied'\n }, { status: 404 });\n }\n\n // Update percentage\n const updateStmt = conn.prepare(`\n UPDATE collaborations \n SET percentage = ?, _updated_at = ?\n WHERE _row_id = ?\n `);\n\n const timestamp = Math.floor(Date.now() / 1000);\n await updateStmt.run([percentage, timestamp, collaborationId]);\n\n return Response.json({\n success: true,\n message: 'Collaboration split updated successfully'\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('Collaboration manager error:', error);\n return Response.json({\n success: false,\n message: 'Internal server error'\n }, { status: 500 });\n }\n}","deleted","label","children",[],[153],{"_104":172,"_96":173,"_154":174,"_156":-5,"_157":139,"_158":175,"_159":160,"_106":176,"_101":32,"_162":163,"_164":177,"_166":22,"_167":-5,"_168":178,"_99":179},"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}",[],[173],{"_104":181,"_96":182,"_154":183,"_156":-5,"_157":139,"_158":184,"_159":160,"_106":185,"_101":32,"_162":163,"_164":186,"_166":22,"_167":-5,"_168":187,"_99":188},"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}",[],[182],{"_104":190,"_96":191,"_154":192,"_156":-5,"_157":139,"_158":193,"_159":160,"_106":194,"_101":32,"_162":163,"_164":195,"_166":22,"_167":-5,"_168":196,"_99":197},"0e8a0728-d782-11f0-969f-42dde27851f2","fu7t4q06s57est42419585v1367t75v7tq.ts","0e8a07fa-d782-11f0-969f-42dde27851f2",5,["D",1765561403804],"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}",[],[191],{"_104":199,"_96":100,"_154":200,"_156":-5,"_157":139,"_158":201,"_159":160,"_106":202,"_101":32,"_162":163,"_164":203,"_166":22,"_167":-5,"_168":204,"_99":205},"f5a0e006-d781-11f0-afb4-42dde27851f2","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}",[],[100],{"_104":207,"_96":208,"_154":209,"_156":-5,"_157":139,"_158":210,"_159":160,"_106":211,"_101":32,"_162":163,"_164":212,"_166":22,"_167":-5,"_168":213,"_99":214},"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}",[],[208],"files",[151,171,180,189,198,206],"counts",{"_219":32,"_220":184,"_221":32,"_222":223},"pulls","branches","forks","envVars",{"_224":32,"_225":32},"count","emptyCount","contents",[],"file",{"_104":199,"_96":100,"_154":200,"_156":-5,"_157":139,"_158":201,"_159":160,"_106":230,"_101":32,"_162":163,"_164":203,"_166":22,"_167":-5,"_99":231},["D",1765561362014],[100],"upstreamProject","upstreamBranch","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.code.$",{"_94":95,"_96":97,"_98":44,"_101":-7,"_99":100,"_102":240,"_149":245,"_215":264,"_228":265,"_226":267,"_268":-5,"_269":-5,"_270":-5,"_271":-5,"_272":273,"_222":-5},{"_104":105,"_96":97,"_106":241,"_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":242,"_133":243,"_136":244,"_148":22},["D",1765561160624],{"_94":95,"_131":132},{"_94":95,"_135":132,"_14":114},{"_101":138,"_96":44,"_104":139,"_140":105,"_141":-5,"_142":-5,"_143":-5,"_144":-5,"_145":-5,"_146":97,"_147":95},[246,249,252,255,258,261],{"_104":152,"_96":153,"_154":155,"_156":-5,"_157":139,"_158":138,"_159":160,"_106":161,"_101":32,"_162":163,"_164":165,"_166":22,"_167":-5,"_168":247,"_99":248},[],[153],{"_104":172,"_96":173,"_154":174,"_156":-5,"_157":139,"_158":175,"_159":160,"_106":176,"_101":32,"_162":163,"_164":177,"_166":22,"_167":-5,"_168":250,"_99":251},[],[173],{"_104":181,"_96":182,"_154":183,"_156":-5,"_157":139,"_158":184,"_159":160,"_106":185,"_101":32,"_162":163,"_164":186,"_166":22,"_167":-5,"_168":253,"_99":254},[],[182],{"_104":190,"_96":191,"_154":192,"_156":-5,"_157":139,"_158":193,"_159":160,"_106":194,"_101":32,"_162":163,"_164":195,"_166":22,"_167":-5,"_168":256,"_99":257},[],[191],{"_104":199,"_96":100,"_154":200,"_156":-5,"_157":139,"_158":201,"_159":160,"_106":202,"_101":32,"_162":163,"_164":203,"_166":22,"_167":-5,"_168":259,"_99":260},[],[100],{"_104":207,"_96":208,"_154":209,"_156":-5,"_157":139,"_158":210,"_159":160,"_106":211,"_101":32,"_162":163,"_164":212,"_166":22,"_167":-5,"_168":262,"_99":263},[],[208],[246,249,252,255,258,261],{"_104":199,"_96":100,"_154":200,"_156":-5,"_157":139,"_158":201,"_159":160,"_106":230,"_101":32,"_162":163,"_164":203,"_166":22,"_167":-5,"_99":266},[100],[],"upstream","pull","ahead","behind","templates",[],"actionData","errors"]