Your collaborative webinar ${data.productTitle} just made a sale.
+Your wallet has been credited. Log in to your dashboard to view your earnings.
+Keep up the great work!
+Best regards,
WithDwindi Team
A collaborator has requested a withdrawal:
+Please review and process in admin dashboard.
+ `; + break; + + case 'withdrawal_completed': + const { data: user } = await supabase + .from('profiles') + .select('email, name, full_name') + .eq('id', data.userId) + .single(); + + recipientEmail = user?.email || ''; + subject = `✅ Withdrawal Completed: Rp ${data.amount.toLocaleString()}`; + + htmlContent = ` +Your withdrawal request has been processed.
+The funds have been transferred to your bank account.
+Thank you for your collaboration!
+ `; + break; + + case 'withdrawal_rejected': + const { data: rejectedUser } = await supabase + .from('profiles') + .select('email, name, full_name') + .eq('id', data.userId) + .single(); + + recipientEmail = rejectedUser?.email || ''; + subject = `❌ Withdrawal Request Returned`; + + htmlContent = ` +Hi ${rejectedUser?.full_name || rejectedUser?.name || 'Partner'},
+Your withdrawal request of Rp ${data.amount.toLocaleString()} has been returned to your wallet.
+Reason: ${data.reason || 'Contact admin for details'}
+You can request a new withdrawal anytime.
+ `; + break; + + default: + return new Response(JSON.stringify({ error: 'Unknown notification type' }), { + status: 400, + headers: { 'Content-Type': 'application/json' } + }); + } + + if (!recipientEmail) { + return new Response(JSON.stringify({ error: 'Recipient email not found' }), { + status: 400, + headers: { 'Content-Type': 'application/json' } + }); + } + + // Send email using existing direct email function + await supabase.functions.invoke('send-email-v2', { + body: { + recipient: recipientEmail, + subject, + content: htmlContent + } + }); + + return new Response(JSON.stringify({ success: true }), { + status: 200, + headers: { 'Content-Type': 'application/json' } + }); + + } catch (error) { + console.error('Notification error:', error); + return new Response(JSON.stringify({ error: error.message }), { + status: 500, + headers: { 'Content-Type': 'application/json' } + }); + } +}); +``` + +**Deploy:** +```bash +supabase functions deploy send-collaboration-notification +``` + +--- + +## Edge Function 3: Create Withdrawal Request + +**Folder:** `supabase/functions/create-withdrawal` + +**Command:** +```bash +mkdir -p supabase/functions/create-withdrawal +``` + +**File:** `supabase/functions/create-withdrawal/index.ts` + +```typescript +import { serve } from 'https://deno.land/std@0.168.0/http/server.ts'; +import { createClient } from 'https://esm.sh/@supabase/supabase-js@2'; + +serve(async (req) => { + try { + const supabase = createClient( + Deno.env.get('SUPABASE_URL')!, + Deno.env.get('SUPABASE_SERVICE_ROLE_KEY')! + ); + + const { amount, notes } = await req.json(); + const authHeader = req.headers.get('Authorization'); + if (!authHeader) { + return new Response(JSON.stringify({ error: 'Unauthorized' }), { + status: 401, + headers: { 'Content-Type': 'application/json' } + }); + } + + const { data: { user } } = await supabase.auth.getUser(authHeader.replace('Bearer ', '')); + + if (!user) { + return new Response(JSON.stringify({ error: 'Unauthorized' }), { + status: 401, + headers: { 'Content-Type': 'application/json' } + }); + } + + // Get wallet balance + const { data: wallet } = await supabase + .rpc('get_collaborator_wallet', { p_user_id: user.id }); + + const currentBalance = wallet[0]?.current_balance || 0; + const pendingBalance = wallet[0]?.pending_balance || 0; + + // Get collaboration settings + const { data: settings } = await supabase + .rpc('get_collaboration_settings'); + + const minWithdrawal = settings[0]?.min_withdrawal_amount || 100000; + const maxPendingWithdrawals = settings[0]?.max_pending_withdrawals || 1; + + // Validations + if (currentBalance < minWithdrawal) { + return new Response( + JSON.stringify({ + error: `Minimum withdrawal is Rp ${minWithdrawal.toLocaleString()}` + }), + { + status: 400, + headers: { 'Content-Type': 'application/json' } + } + ); + } + + if (amount > currentBalance) { + return new Response( + JSON.stringify({ + error: 'Insufficient available balance', + available: currentBalance + }), + { + status: 400, + headers: { 'Content-Type': 'application/json' } + } + ); + } + + // Check for existing pending withdrawals + const { data: existingWithdrawals } = await supabase + .from('withdrawals') + .select('id') + .eq('user_id', user.id) + .eq('status', 'pending'); + + if (existingWithdrawals && existingWithdrawals.length >= maxPendingWithdrawals) { + return new Response( + JSON.stringify({ + error: `Maximum ${maxPendingWithdrawals} pending withdrawal(s) allowed` + }), + { + status: 400, + headers: { 'Content-Type': 'application/json' } + } + ); + } + + // Get collaborator bank info + const { data: profile } = await supabase + .from('profiles') + .select('bank_account_name, bank_account_number, bank_name') + .eq('id', user.id) + .single(); + + if (!profile?.bank_account_number || !profile?.bank_account_name || !profile?.bank_name) { + return new Response( + JSON.stringify({ + error: 'Please complete your bank account information in profile settings' + }), + { + status: 400, + headers: { 'Content-Type': 'application/json' } + } + ); + } + + // Create withdrawal record first + const { data: withdrawal, error: withdrawalError } = await supabase + .from('withdrawals') + .insert({ + user_id: user.id, + amount, + status: 'pending', + payment_method: 'bank_transfer', + payment_reference: `${profile.bank_name} - ${profile.bank_account_number} (${profile.bank_account_name})`, + notes, + created_by: user.id + }) + .select() + .single(); + + if (withdrawalError) throw withdrawalError; + + // Hold amount in wallet + const { data: holdResult, error: holdError } = await supabase + .rpc('hold_withdrawal_amount', { + p_user_id: user.id, + p_withdrawal_id: withdrawal.id, + p_amount: amount + }); + + if (holdError) { + // Rollback withdrawal creation + await supabase.from('withdrawals').delete().eq('id', withdrawal.id); + throw holdError; + } + + // Update withdrawal with wallet transaction reference + await supabase + .from('withdrawals') + .update({ wallet_transaction_id: holdResult }) + .eq('id', withdrawal.id); + + // Send notifications + await supabase.functions.invoke('send-collaboration-notification', { + body: { + type: 'withdrawal_requested', + withdrawalId: withdrawal.id, + userId: user.id, + amount, + bankInfo: { + bankName: profile.bank_name, + accountNumber: profile.bank_account_number, + accountName: profile.bank_account_name + } + } + }); + + return new Response(JSON.stringify({ + success: true, + withdrawal: { + ...withdrawal, + wallet_transaction_id: holdResult + } + }), { + status: 201, + headers: { 'Content-Type': 'application/json' } + }); + + } catch (error) { + return new Response(JSON.stringify({ error: error.message }), { + status: 500, + headers: { 'Content-Type': 'application/json' } + }); + } +}); +``` + +**Deploy:** +```bash +supabase functions deploy create-withdrawal +``` + +--- + +## Edge Function 4: Process Withdrawal + +**Folder:** `supabase/functions/process-withdrawal` + +**Command:** +```bash +mkdir -p supabase/functions/process-withdrawal +``` + +**File:** `supabase/functions/process-withdrawal/index.ts` + +```typescript +import { serve } from 'https://deno.land/std@0.168.0/http/server.ts'; +import { createClient } from 'https://esm.sh/@supabase/supabase-js@2'; + +serve(async (req) => { + try { + const supabase = createClient( + Deno.env.get('SUPABASE_URL')!, + Deno.env.get('SUPABASE_SERVICE_ROLE_KEY')! + ); + + const { withdrawalId, status, payment_reference, admin_notes, reason } = await req.json(); + const authHeader = req.headers.get('Authorization'); + if (!authHeader) { + return new Response(JSON.stringify({ error: 'Unauthorized' }), { + status: 401, + headers: { 'Content-Type': 'application/json' } + }); + } + + const { data: { user } } = await supabase.auth.getUser(authHeader.replace('Bearer ', '')); + + if (!user) { + return new Response(JSON.stringify({ error: 'Unauthorized' }), { + status: 401, + headers: { 'Content-Type': 'application/json' } + }); + } + + // Verify admin role + const { data: isAdmin } = await supabase + .from('user_roles') + .select('role') + .eq('user_id', user.id) + .eq('role', 'admin') + .single(); + + if (!isAdmin) { + return new Response(JSON.stringify({ error: 'Forbidden - Admin only' }), { + status: 403, + headers: { 'Content-Type': 'application/json' } + }); + } + + // Get withdrawal details + const { data: withdrawal } = await supabase + .from('withdrawals') + .select('*, user:profiles(full_name, email)') + .eq('id', withdrawalId) + .single(); + + if (!withdrawal) { + return new Response(JSON.stringify({ error: 'Withdrawal not found' }), { + status: 404, + headers: { 'Content-Type': 'application/json' } + }); + } + + if (withdrawal.status !== 'pending') { + return new Response(JSON.stringify({ error: 'Withdrawal already processed' }), { + status: 400, + headers: { 'Content-Type': 'application/json' } + }); + } + + if (!['completed', 'rejected'].includes(status)) { + return new Response(JSON.stringify({ error: 'Invalid status. Use completed or rejected.' }), { + status: 400, + headers: { 'Content-Type': 'application/json' } + }); + } + + if (status === 'completed') { + // Complete withdrawal + await supabase.rpc('complete_withdrawal', { + p_user_id: withdrawal.user_id, + p_withdrawal_id: withdrawalId, + p_amount: withdrawal.amount, + p_payment_reference: payment_reference + }); + + // Update withdrawal record + await supabase + .from('withdrawals') + .update({ + status: 'completed', + processed_at: new Date().toISOString(), + payment_reference, + admin_notes, + updated_by: user.id, + updated_at: new Date().toISOString() + }) + .eq('id', withdrawalId); + + // Send completion notification + await supabase.functions.invoke('send-collaboration-notification', { + body: { + type: 'withdrawal_completed', + userId: withdrawal.user_id, + amount: withdrawal.amount, + paymentReference: payment_reference + } + }); + + } else if (status === 'rejected') { + // Reject withdrawal - return funds + await supabase.rpc('reject_withdrawal', { + p_user_id: withdrawal.user_id, + p_withdrawal_id: withdrawalId, + p_amount: withdrawal.amount, + p_reason: reason || 'Withdrawal rejected by admin' + }); + + // Update withdrawal record + await supabase + .from('withdrawals') + .update({ + status: 'rejected', + processed_at: new Date().toISOString(), + admin_notes, + updated_by: user.id, + updated_at: new Date().toISOString() + }) + .eq('id', withdrawalId); + + // Send rejection notification + await supabase.functions.invoke('send-collaboration-notification', { + body: { + type: 'withdrawal_rejected', + userId: withdrawal.user_id, + amount: withdrawal.amount, + reason: admin_notes || reason || 'Withdrawal rejected' + } + }); + } + + return new Response(JSON.stringify({ success: true }), { + status: 200, + headers: { 'Content-Type': 'application/json' } + }); + + } catch (error) { + return new Response(JSON.stringify({ error: error.message }), { + status: 500, + headers: { 'Content-Type': 'application/json' } + }); + } +}); +``` + +**Deploy:** +```bash +supabase functions deploy process-withdrawal +``` + +--- + +## Edge Function 5: Modify Handle Order Paid + +**Folder:** `supabase/functions/handle-order-paid` (EXISTS) + +**Add this after access granting section:** +> Make sure `order_items` selected in `handle-order-paid` includes at least: `id`, `product_id`, `unit_price`. + +```typescript +// ============================================ +// COLLABORATION: Credit collaborator wallets +// ============================================ + +// Check if any order items have collaborator products +for (const item of orderItems) { + // Fetch product with collaboration details + const { data: product } = await supabase + .from('products') + .select('collaborator_user_id, profit_share_percentage, auto_grant_access, title') + .eq('id', item.product_id) + .single(); + + if (!product?.collaborator_user_id) continue; + + // Calculate profit splits + const itemPrice = item.unit_price || 0; + const hostShare = itemPrice * ((100 - product.profit_share_percentage) / 100); + const collaboratorShare = itemPrice * (product.profit_share_percentage / 100); + + // Update order_item with calculated shares + await supabase + .from('order_items') + .update({ + host_share: hostShare, + collaborator_share: collaboratorShare + }) + .eq('id', item.id); + + // Credit collaborator wallet + const { data: transactionId } = await supabase + .rpc('credit_collaborator_wallet', { + p_user_id: product.collaborator_user_id, + p_order_item_id: item.id, + p_amount: collaboratorShare, + p_description: `Profit from sale: ${product.title}` + }); + + console.log(`Credited wallet: ${product.collaborator_user_id} + Rp ${collaboratorShare}, Transaction: ${transactionId}`); + + // Grant access to collaborator if auto_grant_access is true + if (product.auto_grant_access) { + await supabase + .from('user_access') + .upsert({ + user_id: product.collaborator_user_id, + product_id: item.product_id, + access_type: 'collaborator', + granted_by: order.user_id + }, { onConflict: 'user_id,product_id' }); + } + + // Send notification to collaborator + await supabase.functions.invoke('send-collaboration-notification', { + body: { + type: 'new_sale', + collaboratorUserId: product.collaborator_user_id, + productTitle: product.title, + profitAmount: collaboratorShare, + profitSharePercentage: product.profit_share_percentage, + saleDate: order.created_at + } + }); +} +``` + +**Deploy:** +```bash +supabase functions deploy handle-order-paid +``` + +--- + +# Phase 3: Verification Tests + +## Test 1: Verify Wallet Tables + +```sql +-- Check if tables exist +SELECT table_name +FROM information_schema.tables +WHERE table_schema = 'public' + AND table_name IN ('collaborator_wallets', 'wallet_transactions') +ORDER BY table_name; + +-- Should return both tables +``` + +## Test 2: Verify Wallet Functions + +```sql +-- Test collaboration settings retrieval (reads from platform_settings) +SELECT * FROM get_collaboration_settings(); + +-- Should return all 5 collaboration settings with correct types +``` + +## Test 3: Test Wallet Creation Trigger + +```sql +-- This should auto-create a wallet for the collaborator +INSERT INTO products (title, slug, type, description, price, collaborator_user_id, profit_share_percentage) +VALUES ('Test Collab', 'test-collab', 'webinar', 'Test', 100000, 'YOUR_USER_ID', 50); + +-- Check if wallet was created +SELECT * FROM collaborator_wallets WHERE user_id = 'YOUR_USER_ID'; + +-- Should return: user_id with 0 balances +``` + +## Test 4: Test Credit Function + +```sql +-- You'll need a real order_item_id for this +SELECT credit_collaborator_wallet( + 'YOUR_USER_ID', -- p_user_id + 'YOUR_ORDER_ITEM_ID', -- p_order_item_id + 50000, -- p_amount + 'Test profit credit' -- p_description +); + +-- Check wallet balance +SELECT * FROM get_collaborator_wallet('YOUR_USER_ID'); + +-- Check transaction history +SELECT * FROM wallet_transactions WHERE user_id = 'YOUR_USER_ID' ORDER BY created_at DESC; +``` + +## Test 5: Test Owner Identity Function + +```bash +# Via curl +curl https://YOUR_PROJECT_REF.supabase.co/functions/v1/get-owner-identity + +# Should return: +# {"owner_name":"Dwindi","owner_avatar_url":""} +``` + +--- + +# Quick Deploy Commands + +```bash +# Create all folders +mkdir -p supabase/functions/get-owner-identity +mkdir -p supabase/functions/send-collaboration-notification +mkdir -p supabase/functions/create-withdrawal +mkdir -p supabase/functions/process-withdrawal + +# Deploy all functions +supabase functions deploy get-owner-identity +supabase functions deploy send-collaboration-notification +supabase functions deploy create-withdrawal +supabase functions deploy process-withdrawal +supabase functions deploy handle-order-paid +``` + +--- + +# Completion Checklist + +**Database Migrations (IN ORDER!):** +- [x] Migration 1: Platform settings extension (owner + collaboration) +- [x] Migration 2: Profile bank fields +- [x] Migration 3: User access enhancement +- [x] Migration 4: Products collaboration fields +- [x] Migration 5: **Wallet tables** (DO THIS FIRST!) +- [ ] Migration 6: Wallet functions +- [ ] Migration 7: Order items profit fields +- [ ] Migration 8: Withdrawals table +- [ ] Migration 9: Collaborator profits view +- [ ] Migration 10: Auto wallet triggers + +**Edge Functions:** +- [ ] Get Owner Identity +- [ ] Send Collaboration Notification +- [ ] Create Withdrawal +- [ ] Process Withdrawal +- [ ] Modify Handle Order Paid + +**Verification:** +- [ ] Test wallet tables exist +- [ ] Test wallet functions +- [ ] Test wallet creation trigger +- [ ] Test credit function +- [ ] Test collaboration settings retrieval +- [ ] Test owner identity endpoint +- [ ] Test profits view + +--- + +## Dependency Flow + +``` +Migration 5: Wallet Tables (creates collaborator_wallets, wallet_transactions) + ↓ +Migration 6: Wallet Functions (uses wallet tables) + ↓ +Migration 7: Order Items (references wallet_transactions) + ↓ +Migration 8: Withdrawals (references wallet_transactions) + ↓ +Migration 9: Profits View (references wallet_transactions) + ↓ +Migration 10: Triggers (uses products + wallet tables) +``` + +--- + +**Next:** Once all migrations and edge functions are complete, we'll implement the frontend components! 🚀 diff --git a/src/App.tsx b/src/App.tsx index da9cbfb..1af8b8c 100644 --- a/src/App.tsx +++ b/src/App.tsx @@ -28,6 +28,7 @@ import MemberAccess from "./pages/member/MemberAccess"; import MemberOrders from "./pages/member/MemberOrders"; import MemberProfile from "./pages/member/MemberProfile"; import OrderDetail from "./pages/member/OrderDetail"; +import MemberProfit from "./pages/member/MemberProfit"; // Admin pages import AdminDashboard from "./pages/admin/AdminDashboard"; @@ -40,6 +41,7 @@ import AdminSettings from "./pages/admin/AdminSettings"; import AdminConsulting from "./pages/admin/AdminConsulting"; import AdminReviews from "./pages/admin/AdminReviews"; import ProductCurriculum from "./pages/admin/ProductCurriculum"; +import AdminWithdrawals from "./pages/admin/AdminWithdrawals"; const queryClient = new QueryClient(); @@ -108,6 +110,14 @@ const App = () => ( } /> +Aktifkan fitur kolaborasi
+Jika nonaktif, alur profit sharing dimatikan
+Konfigurasi platform
Kelola permintaan pencairan kolaborator
+