easystream-main/f_modules/m_frontend/m_donations/donate.php

<?php
define('_ISVALID', true);
include_once '../../../f_core/config.core.php';

// Load Square configuration
$square_config = require_once __DIR__ . '/config.square.php';

// Include Square SDK
require_once __DIR__ . '/vendor/autoload.php';

use Square\SquareClient;
use Square\Environment;
use Square\Models\CreatePaymentRequest;
use Square\Models\Money;

class DonationHandler {
    private $square_client;
    private $config;
    private $class_database;
    
    public function __construct($class_database) {
        $this->class_database = $class_database;
        $this->config = require __DIR__ . '/config.square.php';
        
        // Initialize Square client
        $this->square_client = new SquareClient([
            'accessToken' => $this->config['square']['access_token'],
            'environment' => $this->config['square']['environment'] === 'production' ? Environment::PRODUCTION : Environment::SANDBOX
        ]);
    }
    
    public function createDonation($streamer_id, $amount, $donor_name = '', $message = '') {
        try {
            // Validate amount
            if ($amount < $this->config['square']['min_donation'] || $amount > $this->config['square']['max_donation']) {
                return ['success' => false, 'message' => 'Invalid donation amount'];
            }
            
            // Create payment request
            $money = new Money();
            $money->setAmount($amount * 100); // Convert to cents
            $money->setCurrency($this->config['square']['currency']);
            
            $payment_request = new CreatePaymentRequest();
            $payment_request->setSourceId('EXTERNAL');
            $payment_request->setAmountMoney($money);
            $payment_request->setLocationId($this->config['square']['location_id']);
            
            // Add metadata
            $payment_request->setMetadata([
                'streamer_id' => $streamer_id,
                'donor_name' => $donor_name,
                'message' => $message
            ]);
            
            // Create payment
            $payment = $this->square_client->getPaymentsApi()->createPayment($payment_request);
            
            if ($payment->isSuccess()) {
                // Record donation in database
                $this->recordDonation($streamer_id, $amount, $donor_name, $message, $payment->getResult()->getPayment()->getId());
                
                return [
                    'success' => true,
                    'payment_id' => $payment->getResult()->getPayment()->getId(),
                    'message' => 'Donation processed successfully'
                ];
            } else {
                return [
                    'success' => false,
                    'message' => 'Failed to process donation: ' . $payment->getErrors()[0]->getDetail()
                ];
            }
        } catch (Exception $e) {
            return [
                'success' => false,
                'message' => 'Error processing donation: ' . $e->getMessage()
            ];
        }
    }
    
    private function recordDonation($streamer_id, $amount, $donor_name, $message, $payment_id) {
        $sql = "INSERT INTO donations (
            streamer_id, amount, donor_name, message, payment_id, status, created_at
        ) VALUES (?, ?, ?, ?, ?, 'completed', NOW())";
        
        $params = [$streamer_id, $amount, $donor_name, $message, $payment_id];
        $this->class_database->executeQuery($sql, $params);
        
        // Update streamer's balance
        $sql = "UPDATE users SET donation_balance = donation_balance + ? WHERE user_id = ?";
        $this->class_database->executeQuery($sql, [$amount, $streamer_id]);
    }
    
    public function getStreamerBalance($streamer_id) {
        $sql = "SELECT donation_balance FROM users WHERE user_id = ?";
        $result = $this->class_database->getRow($sql, [$streamer_id]);
        return $result['donation_balance'] ?? 0;
    }
    
    public function requestPayout($streamer_id) {
        try {
            $balance = $this->getStreamerBalance($streamer_id);
            
            if ($balance < $this->config['streamer']['min_balance']) {
                return [
                    'success' => false,
                    'message' => 'Insufficient balance for payout'
                ];
            }
            
            // Calculate fees
            $fee_amount = ($balance * ($this->config['streamer']['payout_fee'] / 100)) + $this->config['streamer']['payout_fee_fixed'];
            $payout_amount = $balance - $fee_amount;
            
            // Create payout request
            $payout = $this->square_client->getPayoutsApi()->createPayout([
                'amount_money' => [
                    'amount' => $payout_amount * 100, // Convert to cents
                    'currency' => $this->config['square']['currency']
                ],
                'location_id' => $this->config['square']['location_id']
            ]);
            
            if ($payout->isSuccess()) {
                // Record payout in database
                $this->recordPayout($streamer_id, $payout_amount, $fee_amount, $payout->getResult()->getPayout()->getId());
                
                return [
                    'success' => true,
                    'message' => 'Payout processed successfully',
                    'amount' => $payout_amount
                ];
            } else {
                return [
                    'success' => false,
                    'message' => 'Failed to process payout: ' . $payout->getErrors()[0]->getDetail()
                ];
            }
        } catch (Exception $e) {
            return [
                'success' => false,
                'message' => 'Error processing payout: ' . $e->getMessage()
            ];
        }
    }
    
    private function recordPayout($streamer_id, $amount, $fee, $payout_id) {
        // Record payout
        $sql = "INSERT INTO payouts (
            streamer_id, amount, fee, payout_id, status, created_at
        ) VALUES (?, ?, ?, ?, 'completed', NOW())";
        
        $params = [$streamer_id, $amount, $fee, $payout_id];
        $this->class_database->executeQuery($sql, $params);
        
        // Reset streamer's balance
        $sql = "UPDATE users SET donation_balance = 0 WHERE user_id = ?";
        $this->class_database->executeQuery($sql, [$streamer_id]);
    }
    
    public function getDonationHistory($streamer_id, $limit = 10) {
        $sql = "SELECT d.*, u.username as streamer_name 
                FROM donations d 
                JOIN users u ON d.streamer_id = u.user_id 
                WHERE d.streamer_id = ? 
                ORDER BY d.created_at DESC 
                LIMIT ?";
        
        return $this->class_database->getRows($sql, [$streamer_id, $limit]);
    }
}