Settings saved successfully!
++
+
| API Endpoint: | + |
+
| Active Sessions: | +active / total | +
| Plugin Version: | ++ |
| User | +Device | +Last Activity | +
|---|---|---|
| display_name ?: $session->user_login); ?> | +device_info ?: 'Unknown device'); ?> | +last_used), current_time('timestamp')) . ' ago'); ?> | +
Twilio WordPress Plugin for call management and mobile app support.
', + 'changelog' => '' . esc_html($update_info->changelog) . '', + 'installation' => '
Upload the plugin to your WordPress site and activate it.
' + ); + + return $plugin_info; + } + + /** + * Get latest release information from Gitea + */ + private function get_latest_release() { + // Check cache first (1 hour) + $cache_key = 'twp_latest_release'; + $cached = get_transient($cache_key); + + if ($cached !== false) { + return $cached; + } + + // Use cURL for Gitea API + $ch = curl_init(); + curl_setopt($ch, CURLOPT_URL, $this->gitea_api_url); + curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); + curl_setopt($ch, CURLOPT_HTTPHEADER, array('Accept: application/json')); + curl_setopt($ch, CURLOPT_USERAGENT, 'WordPress/Twilio-WP-Plugin-Updater'); + curl_setopt($ch, CURLOPT_FOLLOWLOCATION, true); + curl_setopt($ch, CURLOPT_TIMEOUT, 10); + + // Add Gitea token if configured (for private repos) + $gitea_token = get_option('twp_gitea_token', ''); + if (!empty($gitea_token)) { + curl_setopt($ch, CURLOPT_HTTPHEADER, array( + 'Accept: application/json', + 'Authorization: token ' . $gitea_token + )); + } + + $response = curl_exec($ch); + $http_code = curl_getinfo($ch, CURLINFO_HTTP_CODE); + curl_close($ch); + + if (!$response || $http_code !== 200) { + error_log("TWP Auto-Updater: Gitea API returned status $http_code"); + return false; + } + + $release = json_decode($response); + + if (!$release || !isset($release->tag_name)) { + error_log('TWP Auto-Updater: Invalid release data from Gitea'); + return false; + } + + // Parse release information + $version = ltrim($release->tag_name, 'v'); // Remove 'v' prefix if present + $download_url = null; + + // Find the zip asset + if (isset($release->assets) && is_array($release->assets)) { + foreach ($release->assets as $asset) { + if (strpos($asset->name, '.zip') !== false) { + $download_url = $asset->browser_download_url; + break; + } + } + } + + // Fallback to zipball if no asset found + if (!$download_url) { + $download_url = $release->zipball_url; + } + + // Format changelog + $changelog = !empty($release->body) ? $release->body : 'No changelog provided for this release.'; + + // Handle empty changelog + if (empty(trim($changelog))) { + $changelog = "Version " . $version . "\n\n" . + "Released on " . date('F j, Y', strtotime($release->published_at)) . "\n\n" . + "* Updated plugin files"; + } + + $update_info = (object) array( + 'version' => $version, + 'download_url' => $download_url, + 'homepage' => $this->gitea_base_url . '/' . $this->gitea_repo, + 'release_date' => $release->published_at, + 'description' => $changelog, + 'changelog' => $changelog + ); + + // Cache for 1 hour + set_transient($cache_key, $update_info, HOUR_IN_SECONDS); + + return $update_info; + } + + /** + * Manual update check (for admin page) + */ + public function manual_check_for_updates() { + // Clear cache + delete_transient('twp_latest_release'); + update_option('twp_last_update_check', 0); + + // Force WordPress to check + wp_clean_plugins_cache(); + delete_site_transient('update_plugins'); + + $update_info = $this->get_latest_release(); + + if (!$update_info) { + return array( + 'success' => false, + 'message' => 'Failed to check for updates. Please check your internet connection and Gitea repository settings.' + ); + } + + if (version_compare($this->current_version, $update_info->version, '<')) { + return array( + 'success' => true, + 'update_available' => true, + 'current_version' => $this->current_version, + 'latest_version' => $update_info->version, + 'message' => "Update available: Version {$update_info->version}. Go to Plugins page to update." + ); + } else { + return array( + 'success' => true, + 'update_available' => false, + 'current_version' => $this->current_version, + 'message' => 'You are running the latest version.' + ); + } + } + + /** + * Get current update status + */ + public function get_update_status() { + $update_info = $this->get_latest_release(); + + return array( + 'current_version' => $this->current_version, + 'latest_version' => $update_info ? $update_info->version : 'Unknown', + 'update_available' => $update_info && version_compare($this->current_version, $update_info->version, '<'), + 'last_check' => get_option('twp_last_update_check', 0), + 'auto_update_enabled' => get_option('twp_auto_update_enabled', '1') === '1' + ); + } +} diff --git a/includes/class-twp-core.php b/includes/class-twp-core.php index e542e5f..2cc9b26 100644 --- a/includes/class-twp-core.php +++ b/includes/class-twp-core.php @@ -33,7 +33,14 @@ class TWP_Core { // API classes require_once TWP_PLUGIN_DIR . 'includes/class-twp-twilio-api.php'; require_once TWP_PLUGIN_DIR . 'includes/class-twp-elevenlabs-api.php'; - + + // Mobile app classes + require_once TWP_PLUGIN_DIR . 'includes/class-twp-mobile-auth.php'; + require_once TWP_PLUGIN_DIR . 'includes/class-twp-mobile-api.php'; + require_once TWP_PLUGIN_DIR . 'includes/class-twp-mobile-sse.php'; + require_once TWP_PLUGIN_DIR . 'includes/class-twp-fcm.php'; + require_once TWP_PLUGIN_DIR . 'includes/class-twp-auto-updater.php'; + // Feature classes require_once TWP_PLUGIN_DIR . 'includes/class-twp-scheduler.php'; require_once TWP_PLUGIN_DIR . 'includes/class-twp-call-queue.php'; @@ -318,6 +325,20 @@ class TWP_Core { // Initialize webhooks $webhooks = new TWP_Webhooks(); $webhooks->register_endpoints(); + + // Initialize mobile app endpoints + $mobile_auth = new TWP_Mobile_Auth(); + $mobile_auth->register_endpoints(); + + $mobile_api = new TWP_Mobile_API(); + $mobile_api->register_endpoints(); + + $mobile_sse = new TWP_Mobile_SSE(); + $mobile_sse->register_endpoints(); + + // Initialize auto-updater + $updater = new TWP_Auto_Updater(); + $updater->init(); // Add custom cron schedules add_filter('cron_schedules', function($schedules) { diff --git a/includes/class-twp-fcm.php b/includes/class-twp-fcm.php new file mode 100644 index 0000000..69a1b2d --- /dev/null +++ b/includes/class-twp-fcm.php @@ -0,0 +1,214 @@ +server_key = get_option('twp_fcm_server_key', ''); + } + + /** + * Send push notification to user's devices + */ + public function send_notification($user_id, $title, $body, $data = array()) { + if (empty($this->server_key)) { + error_log('TWP FCM: Server key not configured'); + return false; + } + + // Get user's FCM tokens + $tokens = $this->get_user_tokens($user_id); + + if (empty($tokens)) { + error_log("TWP FCM: No tokens found for user $user_id"); + return false; + } + + $success_count = 0; + $failed_tokens = array(); + + foreach ($tokens as $token) { + $result = $this->send_to_token($token, $title, $body, $data); + + if ($result['success']) { + $success_count++; + } else { + $failed_tokens[] = $token; + + // If token is invalid, remove it from database + if ($result['error'] === 'invalid_token') { + $this->remove_invalid_token($token); + } + } + } + + error_log("TWP FCM: Sent notification to $success_count/" . count($tokens) . " devices for user $user_id"); + + return $success_count > 0; + } + + /** + * Send notification to specific token + */ + private function send_to_token($token, $title, $body, $data = array()) { + $notification = array( + 'title' => $title, + 'body' => $body, + 'sound' => 'default', + 'priority' => 'high', + 'click_action' => 'FLUTTER_NOTIFICATION_CLICK' + ); + + $payload = array( + 'to' => $token, + 'notification' => $notification, + 'data' => array_merge($data, array( + 'title' => $title, + 'body' => $body, + 'timestamp' => time() + )), + 'priority' => 'high' + ); + + $headers = array( + 'Authorization: key=' . $this->server_key, + 'Content-Type: application/json' + ); + + $ch = curl_init(); + curl_setopt($ch, CURLOPT_URL, $this->fcm_url); + curl_setopt($ch, CURLOPT_POST, true); + curl_setopt($ch, CURLOPT_HTTPHEADER, $headers); + curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); + curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, true); + curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($payload)); + + $response = curl_exec($ch); + $http_code = curl_getinfo($ch, CURLINFO_HTTP_CODE); + curl_close($ch); + + if ($http_code !== 200) { + error_log("TWP FCM: Failed to send notification. HTTP $http_code: $response"); + + // Check if token is invalid + $response_data = json_decode($response, true); + if (isset($response_data['results'][0]['error']) && + in_array($response_data['results'][0]['error'], array('InvalidRegistration', 'NotRegistered'))) { + return array('success' => false, 'error' => 'invalid_token'); + } + + return array('success' => false, 'error' => 'http_error'); + } + + return array('success' => true); + } + + /** + * Get all active FCM tokens for a user + */ + private function get_user_tokens($user_id) { + global $wpdb; + $table = $wpdb->prefix . 'twp_mobile_sessions'; + + return $wpdb->get_col($wpdb->prepare( + "SELECT fcm_token FROM $table + WHERE user_id = %d + AND is_active = 1 + AND fcm_token IS NOT NULL + AND fcm_token != '' + AND expires_at > NOW()", + $user_id + )); + } + + /** + * Remove invalid FCM token from database + */ + private function remove_invalid_token($token) { + global $wpdb; + $table = $wpdb->prefix . 'twp_mobile_sessions'; + + $wpdb->update( + $table, + array('fcm_token' => null), + array('fcm_token' => $token), + array('%s'), + array('%s') + ); + + error_log("TWP FCM: Removed invalid token from database"); + } + + /** + * Send incoming call notification + */ + public function notify_incoming_call($user_id, $from_number, $queue_name, $call_sid) { + $title = 'Incoming Call'; + $body = "Call from $from_number in $queue_name queue"; + + $data = array( + 'type' => 'incoming_call', + 'call_sid' => $call_sid, + 'from_number' => $from_number, + 'queue_name' => $queue_name + ); + + return $this->send_notification($user_id, $title, $body, $data); + } + + /** + * Send queue timeout notification + */ + public function notify_queue_timeout($user_id, $queue_name, $waiting_count) { + $title = 'Queue Alert'; + $body = "$queue_name has $waiting_count waiting call" . ($waiting_count > 1 ? 's' : ''); + + $data = array( + 'type' => 'queue_timeout', + 'queue_name' => $queue_name, + 'waiting_count' => $waiting_count + ); + + return $this->send_notification($user_id, $title, $body, $data); + } + + /** + * Send agent status change notification + */ + public function notify_status_change($user_id, $old_status, $new_status) { + $title = 'Status Changed'; + $body = "Your status changed from $old_status to $new_status"; + + $data = array( + 'type' => 'status_change', + 'old_status' => $old_status, + 'new_status' => $new_status + ); + + return $this->send_notification($user_id, $title, $body, $data); + } + + /** + * Test notification (for settings page) + */ + public function send_test_notification($user_id) { + $title = 'Test Notification'; + $body = 'This is a test notification from Twilio WordPress Plugin'; + + $data = array( + 'type' => 'test', + 'test' => true + ); + + return $this->send_notification($user_id, $title, $body, $data); + } +} diff --git a/includes/class-twp-mobile-api.php b/includes/class-twp-mobile-api.php new file mode 100644 index 0000000..8c1f013 --- /dev/null +++ b/includes/class-twp-mobile-api.php @@ -0,0 +1,684 @@ +auth = new TWP_Mobile_Auth(); + } + + /** + * Register REST API endpoints + */ + public function register_endpoints() { + add_action('rest_api_init', function() { + // Agent status endpoints + register_rest_route('twilio-mobile/v1', '/agent/status', array( + 'methods' => 'GET', + 'callback' => array($this, 'get_agent_status'), + 'permission_callback' => array($this->auth, 'verify_token') + )); + + register_rest_route('twilio-mobile/v1', '/agent/status', array( + 'methods' => 'POST', + 'callback' => array($this, 'update_agent_status'), + 'permission_callback' => array($this->auth, 'verify_token') + )); + + // Queue state endpoint + register_rest_route('twilio-mobile/v1', '/queues/state', array( + 'methods' => 'GET', + 'callback' => array($this, 'get_queue_state'), + 'permission_callback' => array($this->auth, 'verify_token') + )); + + // Queue calls (specific queue) + register_rest_route('twilio-mobile/v1', '/queues/(?P