JetLink

<?php
/**
 * Proxysmart API Client
 * Complete implementation for all API endpoints
 * 
 * @version 1.0.0
 * @author JetLink
 */
class ProxysmartAPI {
    /**
     * @var array Configuration array
     */
    private $config;
    
    /**
     * @var array Current server configuration
     */
    private $serverConfig;
    
    /**
     * @var string|null Last error message
     */
    private $lastError = null;
    
    /**
     * Constructor
     * 
     * @param array|null $config Configuration array or null to load from file
     * @throws Exception If configuration is invalid
     */
    public function __construct($config = null) {
        if ($config === null) {
            if (file_exists('config.php')) {
                $config = include 'config.php';
            } else {
                throw new Exception('Configuration file not found');
            }
        }
        
        if (!isset($config['servers']) || !isset($config['active_server'])) {
            throw new Exception('Invalid configuration structure');
        }
        
        $this->config = $config;
        $this->serverConfig = $config['servers'][$config['active_server']] ?? null;
        
        if (!$this->serverConfig) {
            throw new Exception('Active server configuration not found');
        }
    }
    
    /**
     * Make HTTP request to API
     * 
     * @param string $endpoint API endpoint
     * @param string $method HTTP method (GET/POST)
     * @param mixed $data Request data
     * @return array Response data
     * @throws Exception On request failure
     */
    private function makeRequest($endpoint, $method = 'GET', $data = null) {
        $ch = curl_init();
        $url = $this->serverConfig['url'] . $endpoint;
        
        // Set basic cURL options
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
        curl_setopt($ch, CURLOPT_USERPWD, $this->serverConfig['username'] . ':' . $this->serverConfig['password']);
        curl_setopt($ch, CURLOPT_HTTPAUTH, CURLAUTH_BASIC);
        curl_setopt($ch, CURLOPT_TIMEOUT, $this->config['defaults']['request_timeout'] ?? 30);
        curl_setopt($ch, CURLOPT_FOLLOWLOCATION, true);
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
        
        // Set method-specific options
        if ($method === 'POST') {
            curl_setopt($ch, CURLOPT_POST, true);
            if ($data !== null) {
                curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
            }
        }
        
        // Execute request
        $response = curl_exec($ch);
        $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
        $error = curl_error($ch);
        curl_close($ch);
        
        // Handle cURL errors
        if ($error) {
            $this->lastError = $error;
            throw new Exception("cURL Error: " . $error);
        }
        
        // Parse response
        $decoded = json_decode($response, true);
        
        return [
            'success' => $httpCode === 200,
            'code' => $httpCode,
            'data' => $decoded !== null ? $decoded : $response,
            'raw' => $response
        ];
    }
    
    /**
     * 1. Get all devices
     * Returns complete list of all modems on server
     * 
     * @return array Array of devices
     * @throws Exception On API error
     */
    public function getAllDevices() {
        $result = $this->makeRequest('/apix/show_status_json');
        
        if (!$result['success']) {
            throw new Exception('Failed to get devices');
        }
        
        return $result['data'] ?? [];
    }
    
    /**
     * 2. Get free devices
     * Returns devices without active ports based on server type logic
     * 
     * @return array Array of free devices
     * @throws Exception On API error
     */
    public function getFreeDevices() {
        $devices = $this->getAllDevices();
        $ports = $this->getAllPorts();
        $serverType = $this->serverConfig['type'];
        $freeDevices = [];
        $currentTime = time();
        
        foreach ($devices as $device) {
            $imei = $device['modem_details']['IMEI'] ?? '';
            if (!$imei) continue;
            
            $devicePorts = isset($ports[$imei]) ? $ports[$imei] : [];
            
            if ($serverType === 'dedicated' || $serverType === 'mix') {
                // Dedicated/Mix: free if no ports or all ports expired
                $isFree = true;
                foreach ($devicePorts as $port) {
                    if (empty($port['PROXY_VALID_BEFORE'])) {
                        $isFree = false;
                        break;
                    }
                    $expiryTime = strtotime($port['PROXY_VALID_BEFORE']);
                    if ($expiryTime > $currentTime) {
                        $isFree = false;
                        break;
                    }
                }
            } else { // shared
                // Shared: free if active ports < max_ports_per_device
                $activePortsCount = 0;
                foreach ($devicePorts as $port) {
                    if (empty($port['PROXY_VALID_BEFORE'])) {
                        $activePortsCount++;
                    } else {
                        $expiryTime = strtotime($port['PROXY_VALID_BEFORE']);
                        if ($expiryTime > $currentTime) {
                            $activePortsCount++;
                        }
                    }
                }
                $maxPorts = $this->serverConfig['max_ports_per_device'] ?? 5;
                $isFree = $activePortsCount < $maxPorts;
            }
            
            if ($isFree) {
                $freeDevices[] = $device;
            }
        }
        
        return $freeDevices;
    }
    
    /**
     * 3. Get busy devices
     * Returns devices with active ports
     * 
     * @return array Array of busy devices
     * @throws Exception On API error
     */
    public function getBusyDevices() {
        $devices = $this->getAllDevices();
        $freeDevices = $this->getFreeDevices();
        $freeImeis = array_column(array_column($freeDevices, 'modem_details'), 'IMEI');
        
        $busyDevices = [];
        foreach ($devices as $device) {
            $imei = $device['modem_details']['IMEI'] ?? '';
            if ($imei && !in_array($imei, $freeImeis)) {
                $busyDevices[] = $device;
            }
        }
        
        return $busyDevices;
    }
    
    /**
     * 4. Create port
     * Creates new port with auto-generated credentials
     * 
     * @param string $imei Device IMEI
     * @param string $portName Port name
     * @param string|null $expiryDate Expiry date in Y-m-d\TH:i format
     * @param string|null $osFingerprint OS fingerprint
     * @return array Operation result
     * @throws Exception On API error
     */
    public function createPort($imei, $portName, $expiryDate = null, $osFingerprint = null) {
        // Validate inputs
        if (!$imei || !$portName) {
            throw new Exception('IMEI and port name are required');
        }
        
        // Generate unique credentials
        $portId = 'port' . $this->generateRandomString(10);
        $login = $this->generateRandomString(8);
        $password = $this->generateRandomString(10);
        $httpPort = rand(
            $this->config['defaults']['http_port_range'][0], 
            $this->config['defaults']['http_port_range'][1]
        );
        $socksPort = rand(
            $this->config['defaults']['socks_port_range'][0], 
            $this->config['defaults']['socks_port_range'][1]
        );
        
        // Build port data
        $portData = [
            'IMEI' => $imei,
            'portID' => $portId,
            'portName' => $portName,
            'proxy_login' => $login,
            'proxy_password' => $password,
            'http_port' => $httpPort,
            'socks_port' => $socksPort
        ];
        
        if ($expiryDate) {
            $portData['PROXY_VALID_BEFORE'] = $expiryDate;
        }
        
        if ($osFingerprint) {
            $portData['OS'] = $osFingerprint;
        }
        
        // Create port
        $result = $this->makeRequest('/crud/store_port', 'POST', 
            'data=' . urlencode(json_encode($portData)));
        
        if (!isset($result['data']['result']) || $result['data']['result'] !== 'success') {
            return [
                'success' => false, 
                'error' => $result['data']['error'] ?? 'Failed to create port'
            ];
        }
        
        // Apply settings
        $this->makeRequest('/apix/apply_port?arg=' . $portId);
        
        return [
            'success' => true,
            'portID' => $portId,
            'credentials' => [
                'login' => $login,
                'password' => $password,
                'http_port' => $httpPort,
                'socks_port' => $socksPort,
                'http_proxy' => sprintf('http://%s:%s@%s:%d', 
                    $login, $password, $this->getServerHost(), $httpPort),
                'socks_proxy' => sprintf('socks5://%s:%s@%s:%d', 
                    $login, $password, $this->getServerHost(), $socksPort)
            ]
        ];
    }
    
    /**
     * 5. Get port details
     * Returns complete access data for port
     * 
     * @param string $portId Port ID
     * @return array Port details
     * @throws Exception On API error
     */
    public function getPortDetails($portId) {
        $ports = $this->getAllPorts();
        
        foreach ($ports as $imei => $devicePorts) {
            foreach ($devicePorts as $port) {
                if ($port['portID'] === $portId) {
                    return [
                        'success' => true,
                        'port' => $port,
                        'http_proxy' => $port['http_creds'] ?? null,
                        'socks_proxy' => $port['socks5_creds'] ?? null,
                        'reset_link' => $port['RESET_SECURE_LINK']['URL'] ?? null,
                        'reset_valid_until' => $port['RESET_SECURE_LINK']['VALID_UNTIL'] ?? null,
                        'vpn_link' => $this->serverConfig['url'] . "/get_vpn_profile/{$portId}.ovpn",
                        'imei' => $imei
                    ];
                }
            }
        }
        
        return ['success' => false, 'error' => 'Port not found'];
    }
    
    /**
     * 6. Change OS fingerprint
     * Updates OS fingerprint without changing other parameters
     * 
     * @param string $portId Port ID
     * @param string $newOS New OS fingerprint
     * @return array Operation result
     * @throws Exception On API error
     */
    public function changeOSFingerprint($portId, $newOS) {
        // Get current port details
        $portDetails = $this->getPortDetails($portId);
        if (!$portDetails['success']) {
            return $portDetails;
        }
        
        $port = $portDetails['port'];
        $imei = $portDetails['imei'];
        
        // Preserve all existing parameters
        $portData = [
            'IMEI' => $imei,
            'portID' => $portId,
            'portName' => $port['portName'],
            'proxy_login' => $port['LOGIN'],
            'proxy_password' => $port['PASSWORD'],
            'http_port' => $port['HTTP_PORT'],
            'socks_port' => $port['SOCKS_PORT']
        ];
        
        // Add new OS if specified
        if ($newOS) {
            $portData['OS'] = $newOS;
        }
        
        // Preserve optional parameters
        if (!empty($port['PROXY_VALID_BEFORE'])) {
            $portData['PROXY_VALID_BEFORE'] = $port['PROXY_VALID_BEFORE'];
        }
        
        // Update port
        $result = $this->makeRequest('/crud/store_port', 'POST', 
            'data=' . urlencode(json_encode($portData)));
        
        if ($result['data']['result'] === 'success') {
            $this->makeRequest('/apix/apply_port?arg=' . $portId);
            return ['success' => true, 'message' => 'OS fingerprint updated'];
        }
        
        return ['success' => false, 'error' => 'Failed to update OS fingerprint'];
    }
    
    /**
     * 7. Extend port
     * Extends port validity with optional device rotation
     * 
     * @param string $portId Port ID
     * @param string $newExpiryDate New expiry date
     * @param bool $rotateDevice Whether to rotate to new device
     * @return array Operation result
     * @throws Exception On API error
     */
    public function extendPort($portId, $newExpiryDate, $rotateDevice = true) {
        // Get current port details
        $portDetails = $this->getPortDetails($portId);
        if (!$portDetails['success']) {
            return $portDetails;
        }
        
        $port = $portDetails['port'];
        $currentImei = $portDetails['imei'];
        $newImei = $currentImei;
        
        // Find new device if rotation requested
        if ($rotateDevice) {
            $freeDevices = $this->getFreeDevices();
            foreach ($freeDevices as $device) {
                $deviceImei = $device['modem_details']['IMEI'];
                if ($deviceImei !== $currentImei && 
                    $device['net_details']['IS_ONLINE'] === 'yes') {
                    $newImei = $deviceImei;
                    break;
                }
            }
        }
        
        // Recreate port with new parameters
        $portData = [
            'IMEI' => $newImei,
            'portID' => $portId,
            'portName' => $port['portName'],
            'proxy_login' => $port['LOGIN'],
            'proxy_password' => $port['PASSWORD'],
            'http_port' => $port['HTTP_PORT'],
            'socks_port' => $port['SOCKS_PORT'],
            'PROXY_VALID_BEFORE' => $newExpiryDate
        ];
        
        // Preserve OS if exists
        if (isset($port['OS'])) {
            $portData['OS'] = $port['OS'];
        }
        
        $result = $this->makeRequest('/crud/store_port', 'POST', 
            'data=' . urlencode(json_encode($portData)));
        
        if ($result['data']['result'] === 'success') {
            $this->makeRequest('/apix/apply_port?arg=' . $portId);
            
            return [
                'success' => true,
                'message' => $newImei !== $currentImei ? 
                    "Port moved from {$currentImei} to {$newImei}" : 
                    "Port extended on the same device",
                'device_changed' => $newImei !== $currentImei,
                'new_imei' => $newImei,
                'old_imei' => $currentImei
            ];
        }
        
        return ['success' => false, 'error' => 'Failed to extend port'];
    }
    
    /**
     * 8. Delete ports
     * Deletes specific port or all expired ports
     * 
     * @param string|array $portIds Port ID(s) or 'expired'
     * @return array Operation result
     * @throws Exception On API error
     */
    public function deletePorts($portIds = 'expired') {
        $deletedPorts = [];
        
        if ($portIds === 'expired') {
            // Delete all expired ports
            $ports = $this->getAllPorts();
            $currentTime = time();
            
            foreach ($ports as $imei => $devicePorts) {
                foreach ($devicePorts as $port) {
                    if (!empty($port['PROXY_VALID_BEFORE'])) {
                        $expiryTime = strtotime($port['PROXY_VALID_BEFORE']);
                        if ($expiryTime < $currentTime) {
                            $result = $this->makeRequest('/apix/purge_port?arg=' . $port['portID']);
                            if ($result['data']['result'] === 'ok') {
                                $deletedPorts[] = $port['portID'];
                            }
                        }
                    }
                }
            }
        } else {
            // Delete specific ports
            $portIds = is_array($portIds) ? $portIds : [$portIds];
            foreach ($portIds as $portId) {
                $result = $this->makeRequest('/apix/purge_port?arg=' . $portId);
                if ($result['data']['result'] === 'ok') {
                    $deletedPorts[] = $portId;
                }
            }
        }
        
        return [
            'success' => true,
            'deleted_count' => count($deletedPorts),
            'deleted_ports' => $deletedPorts
        ];
    }
    
    /**
     * 9. Get active ports
     * Returns all ports with valid expiry date
     * 
     * @return array Array of active ports
     * @throws Exception On API error
     */
    public function getActivePorts() {
        $ports = $this->getAllPorts();
        $activePorts = [];
        $currentTime = time();
        
        foreach ($ports as $imei => $devicePorts) {
            foreach ($devicePorts as $port) {
                // Active = has expiry date and it's in future
                if (!empty($port['PROXY_VALID_BEFORE'])) {
                    $expiryTime = strtotime($port['PROXY_VALID_BEFORE']);
                    if ($expiryTime > $currentTime) {
                        $port['imei'] = $imei;
                        $port['expires_in_seconds'] = $expiryTime - $currentTime;
                        $activePorts[] = $port;
                    }
                }
            }
        }
        
        return $activePorts;
    }
    
    /**
     * 10. Reboot device by port
     * Reboots device that hosts the specified port
     * 
     * @param string $portId Port ID
     * @return array Operation result
     * @throws Exception On API error
     */
    public function rebootDeviceByPort($portId) {
        // Get device IMEI through port
        $portDetails = $this->getPortDetails($portId);
        if (!$portDetails['success']) {
            return $portDetails;
        }
        
        $imei = $portDetails['imei'];
        $result = $this->makeRequest('/apix/reboot_modem_by_imei?IMEI=' . $imei);
        
        return [
            'success' => isset($result['data']['result']) && 
                         $result['data']['result'] === 'success',
            'data' => $result['data'],
            'imei' => $imei
        ];
    }
    
    /**
     * 11. Enable automatic IP rotation
     * Enables automatic IP address change at specified interval
     * 
     * @param string $portId Port ID
     * @param int $intervalMinutes Rotation interval in minutes
     * @return array Operation result
     * @throws Exception On API error
     */
    public function enableAutoRotation($portId, $intervalMinutes) {
        // Step 1: Get IMEI through port
        $portDetails = $this->getPortDetails($portId);
        if (!$portDetails['success']) {
            return $portDetails;
        }
        
        $imei = $portDetails['imei'];
        
        // Step 2: Get modem details including NICK
        $modemResult = $this->makeRequest('/apix/show_single_status_json?arg=' . $imei);
        
        if (!$modemResult['success'] || empty($modemResult['data'])) {
            return ['success' => false, 'error' => 'Failed to get modem details'];
        }
        
        // API returns object directly, not array
        $modemData = $modemResult['data'];
        
        if (!isset($modemData['modem_details']['NICK'])) {
            return ['success' => false, 'error' => 'Modem nickname not found'];
        }
        
        $modemNick = $modemData['modem_details']['NICK'];
        
        // Step 3: Save modem settings with AUTO_IP_ROTATION
        // IMPORTANT: IMEI must be passed as string
        // The API now automatically removes previous entries with same IMEI
        $modemStoreData = [
            'IMEI' => (string)$imei, // Ensure IMEI is string
            'name' => $modemNick,    // name field = NICK
            'AUTO_IP_ROTATION' => intval($intervalMinutes)
        ];
        
        $result = $this->makeRequest('/crud/store_modem', 'POST', 
            'data=' . urlencode(json_encode($modemStoreData)));
        
        if ($result['data']['result'] !== 'success') {
            return ['success' => false, 'error' => 'Failed to store modem settings'];
        }
        
        // Apply settings
        $this->makeRequest('/modem/settings', 'POST', 'imei=' . $imei);
        
        return [
            'success' => true, 
            'message' => "Auto rotation enabled every {$intervalMinutes} minutes",
            'imei' => $imei,
            'nick' => $modemNick
        ];
    }
    
    /**
     * 12. Get server statistics
     * Returns complete statistics for devices and ports
     * 
     * @return array Statistics data
     * @throws Exception On API error
     */
    public function getServerStatistics() {
        $devices = $this->getAllDevices();
        $ports = $this->getAllPorts();
        $currentTime = time();
        
        // Device statistics
        $totalDevices = count($devices);
        $onlineDevices = 0;
        $offlineDevices = 0;
        $availableDevices = count($this->getFreeDevices());
        
        // Port statistics
        $totalPorts = 0;
        $activePorts = 0;
        $expiredPorts = 0;
        
        // Operators and models
        $operators = [];
        $models = [];
        
        // Process devices
        foreach ($devices as $device) {
            // Online/Offline status
            if ($device['net_details']['IS_ONLINE'] === 'yes') {
                $onlineDevices++;
            } else {
                $offlineDevices++;
            }
            
            // Operators
            $operator = $device['net_details']['CELLOP'] ?? 'Unknown';
            if (!isset($operators[$operator])) {
                $operators[$operator] = 0;
            }
            $operators[$operator]++;
            
            // Models
            $model = $device['modem_details']['MODEL'] ?? 'Unknown';
            if (!isset($models[$model])) {
                $models[$model] = 0;
            }
            $models[$model]++;
        }
        
        // Process ports
        foreach ($ports as $devicePorts) {
            foreach ($devicePorts as $port) {
                $totalPorts++;
                
                if (!empty($port['PROXY_VALID_BEFORE'])) {
                    $expiryTime = strtotime($port['PROXY_VALID_BEFORE']);
                    if ($expiryTime > $currentTime) {
                        $activePorts++;
                    } else {
                        $expiredPorts++;
                    }
                } else {
                    $activePorts++; // Ports without expiry are considered active
                }
            }
        }
        
        return [
            'device_statistics' => [
                'total' => $totalDevices,
                'online' => $onlineDevices,
                'offline' => $offlineDevices,
                'available' => $availableDevices
            ],
            'port_statistics' => [
                'active' => $activePorts,
                'expired' => $expiredPorts,
                'total' => $totalPorts
            ],
            'network_operators' => $operators,
            'device_models' => $models
        ];
    }
    
    /**
     * 13. Transfer port to another device
     * Moves port to different device keeping all settings
     * 
     * @param string $portId Port ID
     * @param string $newImei New device IMEI
     * @return array Operation result
     * @throws Exception On API error
     */
    public function transferPort($portId, $newImei) {
        // Get current port details
        $portDetails = $this->getPortDetails($portId);
        if (!$portDetails['success']) {
            return $portDetails;
        }
        
        $port = $portDetails['port'];
        $oldImei = $portDetails['imei'];
        
        // Create port on new device
        $portData = [
            'IMEI' => $newImei,
            'portID' => $portId,
            'portName' => $port['portName'],
            'proxy_login' => $port['LOGIN'],
            'proxy_password' => $port['PASSWORD'],
            'http_port' => $port['HTTP_PORT'],
            'socks_port' => $port['SOCKS_PORT']
        ];
        
        // Preserve all additional parameters
        if (!empty($port['PROXY_VALID_BEFORE'])) {
            $portData['PROXY_VALID_BEFORE'] = $port['PROXY_VALID_BEFORE'];
        }
        if (isset($port['OS'])) {
            $portData['OS'] = $port['OS'];
        }
        
        $result = $this->makeRequest('/crud/store_port', 'POST', 
            'data=' . urlencode(json_encode($portData)));
        
        if ($result['data']['result'] === 'success') {
            $this->makeRequest('/apix/apply_port?arg=' . $portId);
            
            return [
                'success' => true,
                'message' => "Port transferred from {$oldImei} to {$newImei}",
                'old_imei' => $oldImei,
                'new_imei' => $newImei
            ];
        }
        
        return ['success' => false, 'error' => 'Failed to transfer port'];
    }
    
    /**
     * Helper: Get all ports
     * 
     * @return array All ports grouped by IMEI
     * @throws Exception On API error
     */
    private function getAllPorts() {
        $result = $this->makeRequest('/apix/list_ports_json');
        return $result['data'] ?? [];
    }
    
    /**
     * Helper: Get server host from URL
     * 
     * @return string Server host with port
     */
    private function getServerHost() {
        $url = parse_url($this->serverConfig['url']);
        return $url['host'] . (isset($url['port']) ? ':' . $url['port'] : '');
    }
    
    /**
     * Helper: Generate random string
     * 
     * @param int $length String length
     * @return string Random string
     */
    private function generateRandomString($length) {
        $chars = 'abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789';
        $result = '';
        for ($i = 0; $i < $length; $i++) {
            $result .= $chars[rand(0, strlen($chars) - 1)];
        }
        return $result;
    }
    
    /**
     * Get last error message
     * 
     * @return string|null Last error or null
     */
    public function getLastError() {
        return $this->lastError;
    }
    
    /**
     * Get current server configuration
     * 
     * @return array Server config
     */
    public function getServerInfo() {
        return $this->serverConfig;
    }
    
    /**
     * Set active server
     * 
     * @param string $serverKey Server key from config
     * @return bool Success
     */
    public function setActiveServer($serverKey) {
        if (!isset($this->config['servers'][$serverKey])) {
            return false;
        }
        
        $this->config['active_server'] = $serverKey;
        $this->serverConfig = $this->config['servers'][$serverKey];
        return true;
    }
}