Wala shell

Advanced PHP File Manager

Server IP: 127.0.0.1 | PHP Version: 8.3.30 | Domains Hosted: 54

Name	Size	Last Modified	Actions
📁 ..	-	2026-03-21 15:51
📄 Api.php <?php /** * Copyright (с) Cloud Linux GmbH & Cloud Linux Software, Inc 2010-2022 All Rights Reserved * * Licensed under CLOUD LINUX LICENSE AGREEMENT * https://www.cloudlinux.com/legal/ / namespace CloudLinux\SmartAdvice\App\Advice; /* * SmartAdvice Api. / abstract class Api { /* * Apply advice. * * @param string $advice_id id. * * @return string\|bool / abstract public function apply( $advice_id ); /* * Rollback advice. * * @param string $advice_id id. * @param ?string $reason advice rollback reason. * * @return string\|bool / abstract public function rollback( $advice_id, $reason ); /* * Status advice. * * @param string $advice_id id. * * @return string\|bool / abstract public function status( $advice_id ); /* * Details advice. * * @param string $advice_id id. * * @return string / abstract public function details( $advice_id ); /* * Subscription. * * @param string $advice_id id. * * @return string / abstract public function subscription( $advice_id ); /* * Agreement. * * @param string $type advice type string, e.g. 'cdn'. * * @return string / abstract public function agreement( $type ); /* * Get options. * * @param string $user system name. * * @return string */ abstract public function get_options( $user ); }	1.33 KB	2026-02-23 14:52
📄 ApiSocket.php <?php /** * Copyright (с) Cloud Linux GmbH & Cloud Linux Software, Inc 2010-2022 All Rights Reserved * * Licensed under CLOUD LINUX LICENSE AGREEMENT * https://www.cloudlinux.com/legal/ / namespace CloudLinux\SmartAdvice\App\Advice; /* * SmartAdvice socket. / class ApiSocket extends Api { /* * Sock. * * @var string / private $sock = 'unix:///opt/alt/php-xray/run/xray-user.sock'; /* * Socket resource. * * @var resource / private $resource = null; /* * Connect. * * @return bool / private function connect() { $this->resource = stream_socket_client( $this->sock, $error_code, $error_msg, 10 ); if ( ! $this->resource ) { // @phpcs:ignore WordPress.PHP.DevelopmentFunctions.error_log_trigger_error, WordPress.Security.EscapeOutput.OutputNotEscaped trigger_error( "Can't connect to socket [$error_code]: $error_msg", E_USER_WARNING ); return false; } return true; } /* * Send. * * @param array $data params. * * @return bool / private function send( $data ) { $json = wp_json_encode( $data ); if ( false === stream_socket_sendto( $this->resource, $json ) ) { // @phpcs:ignore WordPress.PHP.DevelopmentFunctions.error_log_trigger_error, WordPress.Security.EscapeOutput.OutputNotEscaped trigger_error( "Can't send data to " . $this->sock, E_USER_WARNING ); return false; } return true; } /* * Read. * * @return bool\|string / private function read() { $response = stream_get_contents( $this->resource, 4, 0 ); if ( empty( $response ) ) { // @phpcs:ignore WordPress.PHP.DevelopmentFunctions.error_log_trigger_error, WordPress.Security.EscapeOutput.OutputNotEscaped trigger_error( "Can't read 4b", E_USER_WARNING ); return false; } $unpack = unpack( 'N', $response ); if ( ! is_array( $unpack ) \|\| ! array_key_exists( 1, $unpack ) ) { // @phpcs:ignore WordPress.PHP.DevelopmentFunctions.error_log_trigger_error, WordPress.Security.EscapeOutput.OutputNotEscaped trigger_error( "Can't unpack response", E_USER_WARNING ); return false; } $length = $unpack[1]; $json = stream_get_contents( $this->resource, $length, 4 ); if ( false === $json ) { // @phpcs:ignore WordPress.PHP.DevelopmentFunctions.error_log_trigger_error, WordPress.Security.EscapeOutput.OutputNotEscaped trigger_error( "Can't read response", E_USER_WARNING ); return false; } return $json; } /* * Close. * * @return void / private function close() { if ( is_resource( $this->resource ) ) { // @phpcs:ignore WordPress.WP.AlternativeFunctions.file_system_read_fclose fclose( $this->resource ); } } /* * Exec command. * * @param array $data send. * @param bool $read response. * * @return string\|bool / public function exec( $data, $read = false ) { $result = false; do_action( 'cl_smart_advice_set_error_handler' ); if ( ! function_exists( 'stream_socket_client' ) ) { // @phpcs:ignore WordPress.PHP.DevelopmentFunctions.error_log_trigger_error, WordPress.Security.EscapeOutput.OutputNotEscaped trigger_error( "Function stream_socket_client doesn't exist", E_USER_WARNING ); } else { if ( $this->connect() && $this->send( $data ) ) { $result = true; if ( true === $read ) { $result = $this->read(); } $this->close(); } elseif ( true === $read ) { $result = '{"result": "X-Ray User Plugin is not enabled. Please, contact your server administrator"}'; } } do_action( 'cl_smart_advice_restore_error_handler' ); return $result; } /* * Apply advice. * * @param string $advice_id Advice ID. * * @return string / public function apply( $advice_id ) { /* * Allows filtering of data before sending it to X-Ray socket. * * @param array $data Data to send to socket. * @param string $method Method name. * @param array $args Original method arguments. * * @return array / $data = apply_filters( 'cl_smart_advice_socket_data', array( 'runner' => 'smart_advice', 'command' => 'apply', 'advice_id' => (string) $advice_id, 'async_mode' => true, 'source' => 'WORDPRESS_PLUGIN', 'accept_license_terms' => true, ), 'apply', func_get_args() ); return $this->exec( $data, true ); } /* * Rollback advice. * * @param string $advice_id Advice ID. * @param ?string $reason Advice rollback reason. * * @return string / public function rollback( $advice_id, $reason ) { /* * Allows filtering of data before sending it to X-Ray socket. * * @param array $data Data to send to socket. * @param string $method Method name. * @param array $args Original method arguments. * * @return array / $data = apply_filters( 'cl_smart_advice_socket_data', array( 'runner' => 'smart_advice', 'command' => 'rollback', 'advice_id' => (string) $advice_id, 'async_mode' => true, 'source' => 'WORDPRESS_PLUGIN', 'reason' => (string) $reason, ), 'rollback', func_get_args() ); return $this->exec( $data, true ); } /* * Status advice. * * @param string $advice_id id. * * @return string / public function status( $advice_id ) { $data = array( 'runner' => 'smart_advice', 'command' => 'status', 'advice_id' => (string) $advice_id, ); return $this->exec( $data, true ); } /* * Details advice. * * @param string $advice_id id. * * @return string / public function details( $advice_id ) { $data = array( 'runner' => 'smart_advice', 'command' => 'details', 'advice_id' => (string) $advice_id, ); return $this->exec( $data, true ); } /* * Subscription. * * @param string $advice_id id. * * @return string / public function subscription( $advice_id ) { $data = array( 'runner' => 'smart_advice', 'command' => 'subscription', 'advice_id' => (string) $advice_id, 'listen' => true, ); return $this->exec( $data ); } /* * Agreement. * * @param string $type advice type string, e.g. 'cdn'. * * @return string / public function agreement( $type ) { $data = array( 'runner' => 'smart_advice', 'command' => 'agreement', 'text' => (string) $type, ); return $this->exec( $data, true ); } /* * Get options. * * @param string $user system name. * * @return string */ public function get_options( $user ) { $data = array( 'runner' => 'smart_advice', 'command' => 'get-options', 'username' => (string) $user, ); return $this->exec( $data, true ); } }	6.54 KB	2026-02-23 14:52
📄 LogModel.php <?php /** * Copyright (с) Cloud Linux GmbH & Cloud Linux Software, Inc 2010-2022 All Rights Reserved * * Licensed under CLOUD LINUX LICENSE AGREEMENT * https://www.cloudlinux.com/legal/ / namespace CloudLinux\SmartAdvice\App\Advice; use CloudLinux\SmartAdvice\App\Model as BaseModel; /* * Mail Send Date model / class LogModel extends BaseModel { /* * Advice ID. * * @var string / public $id = ''; /* * Log type. * * @var string / public $type = ''; /* * Created at. * * @var int / public $created_at = 0; /* * Get uid. * * @return string / public function uid() { return $this->id; } /* * Is valid model. * * @return bool / public function isValid() { return ! empty( $this->id ) && ! empty( $this->type ) && ! empty( $this->created_at ); } /* * To array. * * @return array */ public function toArray() { return array( 'id' => $this->id, 'type' => $this->type, 'created_at' => $this->created_at, ); } }	1 KB	2026-02-23 14:52
📄 Manager.php <?php /** * Copyright (с) Cloud Linux GmbH & Cloud Linux Software, Inc 2010-2022 All Rights Reserved * * Licensed under CLOUD LINUX LICENSE AGREEMENT * https://www.cloudlinux.com/legal/ / namespace CloudLinux\SmartAdvice\App\Advice; use CloudLinux\SmartAdvice\App\Option; use CloudLinux\SmartAdvice\App\Notice\Model as NoticeModel; /* * Advice manager / class Manager { /* * Notification status enabled. / const NOTIFICATION_STATUS_ENABLED = 'enabled'; /* * Reminder period in days. / const REMINDERS_PERIOD = 30; /* * Api. * * @var Api / private $api; /* * Option. * * @var Option / private $option; /* * Site home URL. * * @var string / private $home = ''; /* * Site domain. * * @var string / private $domain = ''; /* * WordPress path. * * @var string / private $website = ''; /* * Advices. * * @var array<Model> / protected $advices; /* * User options. * * @var array<string,array> / protected $user_options = array(); /* * Constructor. * * @param Api $api api. * @param Option $option api. / public function __construct( Api $api, Option $option ) { $this->api = $api; $this->option = $option; $this->advices = $this->cache(); $this->env(); add_action( 'cl_smart_advice_sync', array( $this, 'sync' ), 10, 1 ); add_action( 'cl_smart_advice_sync_statuses', array( $this, 'syncStatuses' ), 10, 1 ); add_action( 'cl_smart_advice_status', array( $this, 'status' ), 10, 2 ); add_action( 'cl_smart_advice_apply', array( $this, 'apply' ), 10, 2 ); add_action( 'cl_smart_advice_apply_type', array( $this, 'applyType' ), 10, 2 ); add_action( 'cl_smart_advice_rollback', array( $this, 'rollback' ), 10, 3 ); add_action( 'cl_smart_advice_subscription', array( $this, 'subscription' ), 10, 1 ); add_action( 'cl_smart_advice_email_new_advices', array( $this, 'email_new_advices' ), 10, 1 ); add_action( 'cl_smart_advice_email_reminders', array( $this, 'email_reminders' ), 10, 0 ); add_filter( 'cl_smart_advice_js_data', array( $this, 'js_data' ), 10, 1 ); $this->create_cron_jobs(); } /* * Maybe create cron event. / protected function create_cron_jobs() { if ( false === wp_next_scheduled( 'cl_smart_advice_email_reminders' ) ) { $timestamp = strtotime( 'today midnight' ); if ( false !== $timestamp ) { wp_schedule_event( $timestamp, 'daily', 'cl_smart_advice_email_reminders' ); } } } /* * Evn info. * * @return void / protected function env() { $home = $this->home(); $parse = wp_parse_url( $home ); if ( ! is_array( $parse ) ) { $parse = array(); } $domain = array_key_exists( 'host', $parse ) ? $parse['host'] : ''; $path = array_key_exists( 'path', $parse ) ? $parse['path'] : ''; $this->domain = str_replace( 'www.', '', $domain ); $this->website = ! empty( $path ) ? $path : '/'; } /* * Domain. * * @return string / public function domain() { return $this->domain; } /* * Website. * * @return string / public function website() { return $this->website; } /* * Home url. * * @return string / public function home() { if ( ! empty( $this->home ) ) { return $this->home; } if ( defined( 'WP_HOME' ) ) { $home = (string) WP_HOME; } else { $home = (string) get_option( 'home' ); } $this->home = $home; return $this->home; } /* * Api interface. * * @return Api / protected function api() { return $this->api; } /* * Option instance. * * @return Option / protected function option() { return $this->option; } /* * Advices array. * * @return array<Model> / public function advices() { $advices = $this->advices; uasort( $advices, function ( $a, $b ) { if ( 'review' === $a->status ) { return - 1; } return 1; } ); return $advices; } /* * Get advice by uID. * * @param string $advice_uid Advice uID. * @param bool $fresh Get fresh data of advice. * * @return ?Model * @since 0.1-6 / public function get( $advice_uid, $fresh = false ) { $advices = $this->advices(); foreach ( $advices as $key => $advice ) { if ( (string) $advice->uid() === (string) $advice_uid ) { if ( true === $fresh ) { $this->setDetails( $advice ); $this->advices[ $key ] = $advice; $this->save(); } return $advice; } } return null; } /* * Get advice by type. * * @param string $advice_type Advice type. * * @return ?Model * @since 0.1-6 / public function get_advice_by_type( $advice_type ) { $advices = $this->advices(); foreach ( $advices as $advice ) { if ( $advice->type === $advice_type ) { return $advice; } } return null; } /* * Check domain and WordPress path. * * @param array $item data. * * @return boolean / protected function checkMetadata( $item ) { if ( strtolower( $this->domain() ) !== strtolower( $item['metadata']['domain'] ) ) { do_action( 'cl_smart_advice_set_error', E_WARNING, 'Received wrong advice. Domain mismatch.', __FILE__, __LINE__, array( 'advice' => $item, 'domain' => $this->domain(), ) ); return false; } if ( strtolower( $this->website() ) !== strtolower( $item['metadata']['website'] ) ) { do_action( 'cl_smart_advice_set_error', E_WARNING, 'Received wrong advice. Website mismatch.', __FILE__, __LINE__, array( 'advice' => $item, 'website' => $this->website(), ) ); return false; } return true; } /* * Check advice. * * @param array $advice advice. * * @return boolean / private function checkAdvice( $advice ) { if ( 'outdated' === $advice['status'] ) { return false; } return true; } /* * Add or update advice. * * @param array $advice data. * * @return Model / private function set( $advice ) { $model = new Model(); $model->fill( $advice ); if ( array_key_exists( $model->uid(), $this->advices() ) ) { $model = $this->advices()[ $model->uid() ]; } $this->advices[ $model->uid() ] = $model; return $model; } /* * Sync advice. * * @param array $response advices. * * @return void / public function sync( $response ) { if ( is_array( $response ) && array_key_exists( 'data', $response ) ) { $this->setAdvices( $response ); $this->notifyNew(); $this->save(); } else { add_filter( 'cl_smart_advice_sync_failed', '__return_true' ); } } /* * Set advices. * * @param mixed $response advices. * * @return void / public function setAdvices( $response ) { $this->advices = array(); $items = array_filter( $response['data'], array( $this, 'checkMetadata' ) ); foreach ( $items as $item ) { $advice = $item['advice']; $advice['username'] = $item['metadata']['username']; foreach ( array( 'created_at', 'updated_at' ) as $key ) { $advice[ $key ] = array_key_exists( $key, $item ) ? $item[ $key ] : ''; } if ( ! $this->checkAdvice( $advice ) ) { continue; } $model = $this->set( $advice ); $this->setDetails( $model ); } } /* * Set details. * * @param Model $advice advice. * * @return void / public function setDetails( $advice ) { if ( true === $advice->is_imunify() ) { return; } $json = $this->api()->details( $advice->id ); if ( ! empty( $json ) ) { $details = json_decode( $json, true ); if ( is_array( $details ) && array_key_exists( 'data', $details ) && array_key_exists( 'advice', $details['data'] ) && is_array( $details['data']['advice'] ) ) { $data = $details['data']['advice']; if ( isset( $details['data']['created_at'] ) ) { $advice->created_at = $details['data']['created_at']; } if ( isset( $details['data']['updated_at'] ) ) { $advice->updated_at = $details['data']['updated_at']; } if ( isset( $details['data']['metadata']['username'] ) ) { $advice->username = $details['data']['metadata']['username']; } if ( isset( $data['status'] ) ) { $advice->status = $data['status']; } if ( isset( $data['description'] ) ) { $advice->description = $data['description']; } if ( isset( $data['detailed_description'] ) ) { $advice->detailed_description = $data['detailed_description']; } if ( isset( $data['apply_advice_button_text'] ) ) { $advice->apply_advice_button_text = $data['apply_advice_button_text']; } if ( isset( $data['upgrade_to_apply_button_text'] ) ) { $advice->upgrade_to_apply_button_text = $data['upgrade_to_apply_button_text']; } if ( isset( $data['email_view_advice_text'] ) ) { $advice->email_view_advice_text = $data['email_view_advice_text']; } if ( isset( $data['email_subject'] ) ) { $advice->email_subject = $data['email_subject']; } $advice->requests = array(); if ( array_key_exists( 'requests', $data ) && is_array( $data['requests'] ) ) { foreach ( $data['requests'] as $request ) { $advice->requests[ $request['id'] ] = $request['url']; } } } } } /* * Sync statuses. * * @param ?string $advice_uid id. * * @return void / public function syncStatuses( $advice_uid = '' ) { if ( ! empty( $advice_uid ) ) { $this->status( $advice_uid, true ); } else { $advices = $this->advices(); foreach ( $advices as $advice ) { $this->status( $advice->uid(), false ); } $this->save(); } } /* * Advice modifier. * * @param string $advice_uid advice. * @param callable $callback command. * @param bool $save advice. * @param string $reason advice rollback reason. * * @return void / private function modifier( $advice_uid, $callback, $save = true, $reason = '' ) { $advices = $this->advices(); if ( ! array_key_exists( $advice_uid, $advices ) ) { do_action( 'cl_smart_advice_notice_add', $advice_uid, NoticeModel::ERROR_ADVICE_NOT_FOUND['type'], array( 'advice_uid' => $advice_uid ) ); return; } $advice = $advices[ $advice_uid ]; if ( is_callable( $callback ) ) { $callback( $advice, $reason ); } $this->set( $advice->toArray() ); if ( true === $save ) { $this->save(); } } /* * Apply advice, set status pending. * * @param string $advice_uid to apply. * @param bool $save advices. * * @return void / public function apply( $advice_uid, $save = true ) { $this->modifier( $advice_uid, function ( $advice ) { if ( true === $advice->is_imunify() ) { return; } $json = $this->api()->apply( $advice->id ); if ( ! $json ) { do_action( 'cl_smart_advice_set_error', E_USER_WARNING, 'Advice manager: failed modifier apply for ' . $advice->uid(), __FILE__, __LINE__ ); do_action( 'cl_smart_advice_notice_add', $advice->uid(), NoticeModel::ERROR_ADVICE_APPLY['type'], array( 'advice_type' => $advice->type ) ); } else { $response = json_decode( $json, true ); $this->errorHandler( $response, $advice, NoticeModel::ERROR_ADVICE_APPLY['type'] ); $advice->status = 'pending'; } }, $save ); } /* * Apply advice by type, set status pending. * * @param string $type to apply. * @param bool $save advices. * * @return void / public function applyType( $type, $save = true ) { $advice = current( array_filter( $this->advices(), function ( $advice ) use ( $type ) { return strtolower( $advice->type ) === strtolower( $type ); } ) ); if ( $advice ) { $this->apply( $advice->uid(), $save ); } } /* * Rollback advice, set status pending. * * @param string $advice_uid id. * @param bool $save advices. * @param string $reason advice rollback reason. * * @return void / public function rollback( $advice_uid, $save = true, $reason = '' ) { $this->modifier( $advice_uid, function ( $advice, $reason ) { if ( true === $advice->is_imunify() ) { return; } $json = $this->api()->rollback( $advice->id, $reason ); if ( ! $json ) { do_action( 'cl_smart_advice_set_error', E_USER_WARNING, 'Advice manager: failed modifier rollback for ' . $advice->uid(), __FILE__, __LINE__ ); do_action( 'cl_smart_advice_notice_add', $advice->uid(), NoticeModel::ERROR_ADVICE_ROLLBACK['type'], array( 'advice_type' => $advice->type ) ); } else { $response = json_decode( $json, true ); $this->errorHandler( $response, $advice, NoticeModel::ERROR_ADVICE_ROLLBACK['type'] ); $advice->status = 'pending'; } }, $save, $reason ); } /* * Subscription advice payment status. * * @param string $advice_uid id. * * @return void / public function subscription( $advice_uid ) { $advice = $this->get( $advice_uid ); if ( $advice->is_imunify() ) { $advice->status = 'applied'; $this->set( $advice->toArray() ); $this->save(); } else { $this->api()->subscription( $advice->id ); } } /* * Update advice status. * * @param string $advice_uid id. * @param bool $save advices. * * @return void / public function status( $advice_uid, $save = true ) { $this->modifier( $advice_uid, function ( $advice ) { if ( true === $advice->is_imunify() ) { return; } $json = $this->api()->status( $advice->id ); $response = json_decode( $json, true ); if ( is_array( $response ) ) { if ( array_key_exists( 'status', $response ) ) { $advice->status = $response['status']; } if ( array_key_exists( 'total_stages', $response ) ) { $advice->total_stages = $response['total_stages']; } if ( array_key_exists( 'completed_stages', $response ) ) { $advice->completed_stages = $response['completed_stages']; } if ( array_key_exists( 'subscription', $response ) ) { $module_name = ! empty( $advice->module_name ) ? $advice->module_name : strtolower( $advice->type ); if ( array_key_exists( $module_name, $response['subscription'] ) ) { $advice->subscription_status = $response['subscription'][ $module_name ]; } } if ( array_key_exists( 'upgrade_url', $response ) ) { $advice->subscription_upgrade_url = $response['upgrade_url']; } $this->errorHandler( $response, $advice, NoticeModel::ERROR_ADVICE_STATUS['type'] ); } }, $save ); } /* * Error handler. * * @param array $response data. * @param Model $advice advice. * @param string $error_type type. * * @return void / private function errorHandler( $response, $advice, $error_type ) { if ( ! is_array( $response ) ) { return; } $errors = array(); // Result. if ( array_key_exists( 'result', $response ) && 'success' !== $response['result'] ) { $context = array(); $description = $response['result']; if ( array_key_exists( 'context', $response ) && is_array( $response['context'] ) ) { $context = $response['context']; } $errors[] = $this->errorContext( $description, $context ); } // Features. $this->errorFeature( $response, $errors ); // Data result. if ( array_key_exists( 'data', $response ) && array_key_exists( 'result', $response['data'] ) && 'success' !== $response['data']['result'] ) { $context = array(); $description = $response['data']['result']; if ( 'PAYMENT_REQUIRED' !== $description ) { if ( array_key_exists( 'context', $response['data'] ) && is_array( $response['data']['context'] ) ) { $context = $response['data']['context']; } $errors[] = $this->errorContext( $description, $context ); // Data features. if ( array_key_exists( 'feature', $response['data'] ) ) { $this->errorFeature( $response['data'], $errors ); } } } // Warning. if ( array_key_exists( 'warning', $response ) && ! empty( $response['warning'] ) ) { $context = array(); $description = $response['warning']; if ( array_key_exists( 'context', $response ) && is_array( $response['context'] ) ) { $context = $response['context']; } $errors[] = $this->errorContext( $description, $context ); } $error = implode( PHP_EOL, $errors ); if ( ! empty( $error ) ) { do_action( 'cl_smart_advice_notice_add', $advice->uid(), $error_type, array( 'advice_type' => $advice->type, 'description' => $error, ) ); } } /* * Find error features. * * @param array $response data. * @param array $errors output. * * @return void / private function errorFeature( $response, &$errors ) { if ( array_key_exists( 'feature', $response ) && array_key_exists( 'issues', $response['feature'] ) && ! empty( $response['feature']['issues'] ) ) { foreach ( $response['feature']['issues'] as $issue ) { $context = array(); $descriptions = array(); if ( array_key_exists( 'header', $issue ) ) { $descriptions[] = $issue['header']; } if ( array_key_exists( 'description', $issue ) ) { // Too long to show. if ( strpos( $issue['description'], 'wp-cli' ) === false ) { $descriptions[] = PHP_EOL . $issue['description']; } } if ( array_key_exists( 'fix_tip', $issue ) ) { $descriptions[] = PHP_EOL . $issue['fix_tip']; } if ( array_key_exists( 'context', $issue ) && is_array( $issue['context'] ) ) { $context = $issue['context']; } $description = implode( PHP_EOL, $descriptions ); $errors[] = $this->errorContext( $description, $context ); } } } /* * Error parse. * * @param string $description error string. * @param array $context context. * * @return string / private function errorContext( $description, $context = array() ) { $search = array(); $replace = array(); foreach ( $context as $key => $val ) { $search[] = '%(' . $key . ')s'; $replace[] = $val; } return str_replace( $search, $replace, $description ); } /* * All cached advices. * * @return array<Model> / private function cache() { return $this->option()->get( 'advices', true ); } /* * Time sync at. * * @return int\|null / public function syncAt() { return $this->option()->get( 'sync_at' ); } /* * Update advices' cache. * * @return void / public function save() { $advices = $this->advices(); $this->option()->save( 'advices', $advices ); $this->option()->save( 'sync_at', time() ); } /* * Notify if advice is new * * @return void / private function notifyNew() { $current = array_map( function ( $advice ) { return $advice->uid(); }, $this->cache() ); $new = array( 'awp' => array(), 'imunify' => array(), ); $advice_uids = array(); array_filter( $this->advices(), function ( $advice ) use ( &$new, $current, &$advice_uids ) { if ( ! in_array( $advice->uid(), $current ) ) { if ( $advice->is_imunify() ) { $new['imunify'][] = $advice->uid(); } else { $new['awp'][] = $advice->uid(); } $advice_uids[] = $advice->uid(); return true; } return true; } ); if ( ! empty( $new['awp'] ) ) { do_action( 'cl_smart_advice_notice_add', NoticeModel::NEW_ADVICES['type'], NoticeModel::NEW_ADVICES['type'], array( 'count' => count( $new['awp'] ), 'list' => implode( ',', $new['awp'] ), ) ); } if ( ! empty( $new['imunify'] ) ) { do_action( 'cl_smart_advice_notice_add', NoticeModel::NEW_ADVICES_IMUNIFY['type'], NoticeModel::NEW_ADVICES_IMUNIFY['type'], array( 'count' => count( $new['imunify'] ), 'list' => implode( ',', $new['imunify'] ), ) ); } if ( ! empty( $advice_uids ) ) { do_action( 'cl_smart_advice_email_new_advices', $advice_uids ); } } /* * Get options by user via SmartAdvice api. * * @param string $user name. * * @return array / protected function user_options( $user ) { if ( ! array_key_exists( $user, $this->user_options ) ) { $response = $this->api()->get_options( $user ); $data = json_decode( $response, true ); if ( is_array( $data ) ) { $this->user_options[ $user ] = $data; } else { return array(); } } return $this->user_options[ $user ]; } /* * Notification email status. * * @param string $user name. * * @return string\|null / public function notifications_email_status( $user ) { $data = $this->user_options( $user ); if ( ! isset( $data['notifications']['email_status'] ) ) { return null; } return (string) $data['notifications']['email_status']; } /* * Notification email status imunify. * * @param string $user name. * * @return string\|null / public function notifications_imunify_email_status( $user ) { $data = $this->user_options( $user ); if ( ! isset( $data['notifications']['imunify_email_status'] ) ) { return null; } return (string) $data['notifications']['imunify_email_status']; } /* * Notification reminders status. * * @param string $user name. * * @return string\|null / public function notifications_reminders_status( $user ) { $data = $this->user_options( $user ); if ( ! isset( $data['notifications']['reminders_status'] ) ) { return null; } return (string) $data['notifications']['reminders_status']; } /* * Notification reminders status imunify. * * @param string $user name. * * @return string\|null / public function notifications_imunify_reminders_status( $user ) { $data = $this->user_options( $user ); if ( ! isset( $data['notifications']['imunify_email_status'] ) ) { return null; } return (string) $data['notifications']['imunify_email_status']; } /* * Checks if a reminder should be sent for advice. * * @param Model $advice advice. * * @return bool / public function is_reminder_needed( $advice ) { if ( false === $advice->is_email_available() ) { return false; } $timestamp = $this->get_sending_timestamp( $advice->uid() ); if ( false === $timestamp ) { $timestamp = strtotime( $advice->created_at ); } $window = DAY_IN_SECONDS self::REMINDERS_PERIOD; if ( defined( 'CL_SMART_ADVICE_REMINDER_WINDOW' ) ) { $window = (int) CL_SMART_ADVICE_REMINDER_WINDOW; } if ( time() - $timestamp > $window ) { return true; } return false; } /** * Get email sending timestamp. * * @param string $advice_uid Advice uID. * * @return false\|int / public function get_sending_timestamp( $advice_uid ) { /* * All logs. * * @var LogModel[] $items / $items = $this->option()->get( 'logs', true ); if ( is_array( $items ) ) { foreach ( $items as $item ) { if ( 'mailer' === $item->type && (string) $item->id === (string) $advice_uid ) { return $item->created_at; } } } return false; } /* * Send email notifications. * * @param array $uids of advice. * * @return void / public function email_new_advices( $uids ) { if ( ! is_array( $uids ) \|\| empty( $uids ) ) { return; } foreach ( $uids as $key => $uid ) { $advice = $this->get( $uid, false ); unset( $uids[ $key ] ); if ( ! $this->is_email_notifications_enabled( $advice ) ) { continue; } // Only one letter. do_action( 'cl_smart_advice_email', 'advices', array( 'advice' => $advice ) ); $this->set_sending_timestamp( $advice, time() ); break; } if ( ! empty( $uids ) ) { wp_schedule_single_event( time() + DAY_IN_SECONDS, 'cl_smart_advice_email_new_advices', array( array_values( $uids ) ) ); } } /* * Notify if advice is in review status for more than 30 days * * @return void / public function email_reminders() { $advices = $this->cache(); foreach ( $advices as $advice ) { $advice = $this->get( $advice->uid(), true ); if ( ! $this->is_email_notifications_enabled( $advice, true ) \|\| ! $this->is_reminder_needed( $advice ) ) { continue; } // Only one letter. do_action( 'cl_smart_advice_email', 'reminders', array( 'advice' => $advice ) ); $this->set_sending_timestamp( $advice, time() ); break; } } /* * Is email notifications enabled, globally and with reminders. * * @param ?Model $advice model. * @param bool $with_reminders with reminders status. * * @return bool / public function is_email_notifications_enabled( $advice = null, $with_reminders = false ) { if ( is_null( $advice ) ) { do_action( 'cl_smart_advice_set_error', E_WARNING, 'Email notifications are disabled: advice is empty', __FILE__, __LINE__, array( 'is_reminder' => $with_reminders, ) ); return false; } if ( ! $advice->is_email_available() ) { return false; } if ( empty( $advice->username ) ) { do_action( 'cl_smart_advice_set_error', E_WARNING, 'Email notifications are disabled: no username in advice', __FILE__, __LINE__, array( 'advice_data' => wp_json_encode( $advice->toArray() ), 'advice_id' => $advice->id, 'advice_type' => $advice->type, 'advice_status' => $advice->status, 'is_reminder' => $with_reminders, ) ); return false; } if ( $advice->is_imunify() ) { $emails_status = $this->notifications_imunify_email_status( $advice->username ); } else { $emails_status = $this->notifications_email_status( $advice->username ); } if ( null === $emails_status ) { do_action( 'cl_smart_advice_set_error', E_WARNING, 'Email notifications are disabled: no emails status in user options', __FILE__, __LINE__, array( 'advice_id' => $advice->id, 'advice_type' => $advice->type, 'advice_status' => $advice->status, 'is_reminder' => $with_reminders, ) ); } if ( self::NOTIFICATION_STATUS_ENABLED !== $emails_status ) { return false; } if ( true === $with_reminders ) { if ( $advice->is_imunify() ) { $reminders_status = $this->notifications_imunify_reminders_status( $advice->username ); } else { $reminders_status = $this->notifications_reminders_status( $advice->username ); } if ( null === $reminders_status ) { do_action( 'cl_smart_advice_set_error', E_WARNING, 'Email notifications are disabled: no reminders status in user options', __FILE__, __LINE__, array( 'advice_id' => $advice->id, 'advice_type' => $advice->type, 'advice_status' => $advice->status, 'is_reminder' => true, ) ); } if ( self::NOTIFICATION_STATUS_ENABLED !== $reminders_status ) { return false; } } return true; } /* * Has pending advices. * * @return bool / public function hasPending() { $advices = $this->advices(); $pending = array_filter( $advices, function ( $advice ) { return 'pending' === $advice->statusUi(); } ); return count( $pending ) > 0; } /* * Get subscription upgrade url. * * @param string $advice_uid id. * * @return false\|string / public function subscriptionUpgradeUrl( $advice_uid ) { $advices = $this->advices(); if ( array_key_exists( $advice_uid, $advices ) ) { $advice = $advices[ $advice_uid ]; if ( 'no' === $advice->subscription_status ) { return $advice->subscriptionUpgradeUrl(); } } return false; } /* * Need agreement. * * @param string $advice_uid id. * * @return false\|string / public function agreementType( $advice_uid ) { $advices = $this->advices(); if ( array_key_exists( $advice_uid, $advices ) ) { return $advices[ $advice_uid ]->agreementType(); } return false; } /* * Plugin compatible. * * @return bool / public function compatible() { return function_exists( 'stream_socket_client' ); } /* * Agreement text. * * @param string $type advice type string, e.g. 'cdn'. * * @return string / public function agreementText( $type ) { $json = $this->api()->agreement( $type ); if ( ! empty( $json ) ) { $data = json_decode( $json, true ); if ( is_array( $data ) && array_key_exists( 'text', $data ) ) { return $data['text']; } } return ''; } /* * Save time to send an advice letter. * * @param Model $advice Model. * @param int $timestamp Timestamp. * * @return void / public function set_sending_timestamp( $advice, $timestamp ) { $ids = array(); /* * All logs. * * @var LogModel[] $items / $items = $this->option()->get( 'logs', true ); if ( ! $items ) { $items = array(); } else { foreach ( $items as $key => $item ) { $ids[ $item->id ] = $key; if ( 'mailer' !== $item->type ) { unset( $items[ $key ] ); } } } if ( array_key_exists( $advice->uid(), $ids ) ) { $items[ $ids[ $advice->uid() ] ]->created_at = $timestamp; } else { $items[] = ( new LogModel() )->fill( array( 'id' => $advice->uid(), 'type' => 'mailer', 'created_at' => $timestamp, ) ); } $this->option()->save( 'logs', $items ); } /* * Filter admin js data. * * @param array $data for js. * * @return array */ public function js_data( $data ) { $data['advices'] = array(); $advices = $this->cache(); foreach ( $advices as $advice ) { $data['advices'][ $advice->uid() ] = array( 'id' => $advice->id, 'uid' => $advice->uid(), 'type' => $advice->type, 'module' => $advice->module_name, 'is_analytics_available' => $advice->is_analytics_available(), ); } return $data; } }	29.03 KB	2026-02-23 14:52
📄 Model.php <?php /** * Copyright (с) Cloud Linux GmbH & Cloud Linux Software, Inc 2010-2022 All Rights Reserved * * Licensed under CLOUD LINUX LICENSE AGREEMENT * https://www.cloudlinux.com/legal/ / namespace CloudLinux\SmartAdvice\App\Advice; use CloudLinux\SmartAdvice\App\Model as BaseModel; /* * Advice model / class Model extends BaseModel { /* * Advice ID. * * @var string / public $id = ''; /* * Advice type. * * @var string / public $type = ''; /* * Advice status. * * @var string / public $status = ''; /* * Advice short description. * * @var string / public $description = ''; /* * Advice detail description. * * @var string / public $detailed_description = ''; /* * CTA text for the "Apply advice" button. * * @var string / public $apply_advice_button_text = ''; /* * CTA text for the "Upgrade to apply" button. * * @var string / public $upgrade_to_apply_button_text = ''; /* * CTA email text for the "Show advice" button in email. * * @var string / public $email_view_advice_text = ''; /* * The subject of the email letter with 1 possible substitution - website URL ({url}) * * @var string / public $email_subject = ''; /* * Advice note. * * @var string / public $note = ''; /* * Is premium. * * @var bool / public $is_premium = false; /* * Module name. * * @var string / public $module_name = ''; /* * License status. * * @var string / public $license_status = ''; /* * Requests. * * @var array / public $requests = array(); /* * Advice total stages. * * @var int / public $total_stages = 0; /* * Advice completed stages. * * @var int / public $completed_stages = 0; /* * Subscription status. * no = need subscription. * * @var string / public $subscription_status = ''; /* * Subscription upgrade url. * * @var string / public $subscription_upgrade_url = ''; /* * Username. * * @var string / public $username = ''; /* * Advice created at. * * @var string / public $created_at = ''; /* * Advice updated at. * * @var string / public $updated_at = ''; /* * Fill properties. * * @param array $data data. * * @return self / public function fill( $data ) { if ( array_key_exists( 'subscription', $data ) ) { if ( array_key_exists( 'status', $data['subscription'] ) ) { $data['subscription_status'] = $data['subscription']['status']; } if ( array_key_exists( 'upgrade_url', $data['subscription'] ) ) { $data['subscription_upgrade_url'] = $data['subscription']['upgrade_url']; } } parent::fill( $data ); return $this; } /* * Is valid model. * * @return bool / public function isValid() { return ! empty( $this->id ) && ! empty( $this->type ) && ! empty( $this->status ); } /* * To array. * * @return array / public function toArray() { return array( 'id' => $this->id, 'uid' => $this->uid(), 'type' => $this->type, 'status' => $this->status, 'description' => $this->description, 'detailed_description' => $this->detailed_description, 'apply_advice_button_text' => $this->apply_advice_button_text, 'upgrade_to_apply_button_text' => $this->upgrade_to_apply_button_text, 'email_view_advice_text' => $this->email_view_advice_text, 'email_subject' => $this->email_subject, 'note' => $this->note, 'is_premium' => $this->is_premium, 'module_name' => $this->module_name, 'license_status' => $this->license_status, 'requests' => $this->requests, 'total_stages' => $this->total_stages, 'completed_stages' => $this->completed_stages, 'subscription_status' => $this->subscription_status, 'subscription_upgrade_url' => $this->subscription_upgrade_url, 'username' => $this->username, 'created_at' => $this->created_at, 'updated_at' => $this->updated_at, ); } /* * Returns a unique identifier for sharing advice between AccelerateWp/Imunify modules * * @return string / public function uid() { if ( $this->is_imunify() ) { return 'imunify_' . $this->id; } return 'awp_' . $this->id; } /* * Get stage percent. * * @return float / public function stagePercent() { $total = $this->total_stages; $completed = $this->completed_stages; if ( $total > 0 ) { return round( $completed / $total 100 ); } return 0; } /** * Get spinner percent. * * @return string / public function spinnerPercent() { $percent = $this->stagePercent(); if ( $percent > 0 ) { return round( $percent / 10 ) . '0'; } return '0'; } /* * Status for ui logic. * * @return string / public function statusUi() { $status = $this->status; if ( 'pending' === $this->subscription_status ) { $status = 'pending'; } return $status; } /* * Need subscription. * * @return string / public function subscriptionUpgradeUrl() { return (string) $this->subscription_upgrade_url; } /* * Need agreement. * * @return false\|string / public function agreementType() { $statuses = array( 'NOT_REQUIRED' => false, 'NOT_APPROVED' => true, 'UPDATE_REQUIRED' => true, 'APPROVED' => false, ); if ( array_key_exists( $this->license_status, $statuses ) && true === $statuses[ $this->license_status ] ) { if ( 'cdn' === strtolower( $this->type ) ) { return 'cdn'; } } return false; } /* * Determines the CTA text for the "Apply advice" button. * * @return string * @since 0.1-8 / public function get_apply_advice_button_text() { return empty( $this->apply_advice_button_text ) ? esc_html__( 'Apply', 'cl-smart-advice' ) : $this->apply_advice_button_text; } /* * Determines the CTA text for the "Upgrade to apply" button. * * @return string * @since 0.1-8 / public function get_upgrade_to_apply_button_text() { if ( $this->is_imunify() ) { return esc_html__( 'Buy now', 'cl-smart-advice' ); } return empty( $this->upgrade_to_apply_button_text ) ? esc_html__( 'Upgrade to apply', 'cl-smart-advice' ) : $this->upgrade_to_apply_button_text; } /* * Determines the CTA email text for the "Show advice" button in email. * * @return string * @since 0.1-8 / public function get_email_view_advice_text() { return empty( $this->email_view_advice_text ) ? esc_html__( 'View advice', 'cl-smart-advice' ) : $this->email_view_advice_text; } /* * Determines the subject of the email letter with 1 possible substitution - website URL ({url}). * * @param string $site_url Site URL. * * @return string * * @since 0.1-8 / public function get_email_subject( $site_url ) { if ( empty( $this->email_subject ) ) { // Default email subject is defined by the mailer. return ''; } return preg_replace( '/{url}/', $site_url, $this->email_subject ); } /* * Is Imunify advice. * * @return bool / public function is_imunify() { return false !== strpos( strtolower( $this->type ), 'imunify' ); } /* * Send email notifications on this advice. * * @return bool / public function is_email_available() { if ( 'review' !== $this->status ) { return false; } return true; } /* * Is analytics available for this advice. * * @return bool */ public function is_analytics_available() { return $this->is_imunify() === false; } }	7.63 KB	2026-02-23 14:52

Terminal