h@\Uh@\U)(0`s\U@\U?U?U?U@\U`E?U@\Uм@\U@\U@\U@\Uservice/aggregator/fifo_listener/replication-notify-fifo֌?U֌?U?U֌?U?U?U?Uޘ?U?Up@\U@\U@U`@?U@\UH@\UP@\U@\U@\Uservice/pop3@@\U@@\U)(0`s\U@\U@\U@\U)(0`s\U@\U?U?U?U@\U`E?U`@\U@\U@\U@\Uh@\Uservice/pop3/unix_listener/login\spop3?U֌?U?U?Uʘ?U?U?U?U?U@\U8@\U@U`@?U @\UH@\U@\U8@\U@\Uservice/pop3-login@\U@\U100`s\UP@\U@\U@\U@\U100`s\U8@\U@\U֌?U?Un@\UD?U@\U@\U8@\UP@\U@\Uservice/pop3-login/inet_listener/pop3?U?U@\UD?U0@\U@\U@\U@\U@\Uservice/pop3-login/inet_listener/pop3sj?U?U?Uj?U?U?U?U?Uř?U@\U @\U@\U@\U@U`@?U@\UH@\UX@\U@\U@\Uservice/old-statsP@\UP@\U)(0`s\U@\U@\U@\U)(0`s\U@\Uj?U?U?U@\U`E?Up@\U@\U@\U@\Up@\Uservice/old-stats/unix_listener/old-stats@\U@\U100`s\U@\Uh@\Uh@\Uh@\U100`s\U@\UH@\Ut?U?U?U@\U`E?U@\U@\U@\U@\U@\Uservice/old-stats/fifo_listener/old-stats-mail?U?U?U@\U`E?U@\U@\UH@\Uh@\U@\Uservice/old-stats/fifo_listener/old-stats-user?U?U?U?U?U?U?U?U?U@\U@\U@U`@?U@\UH@\U@\U@\U@\Uservice/log@\U@\U)(0`s\U@\U'number' => ( $count - $inprogress_count ), 'status' => 'pending', 'job_id__not_in' => [ 'not_in' => '', ], 'orderby' => 'modified', 'order' => 'asc', ] ); } /** * Increment retries number and change status back to pending. * * @param string $url Url from DB row. * @param boolean $is_mobile Is mobile from DB row. * @param string $error_code error code. * @param string $error_message error message. * * @return bool|int */ public function increment_retries( string $url, bool $is_mobile, string $error_code, string $error_message ) { if ( ! $this->is_allowed() ) { return false; } $db = $this->get_db(); $prefixed_table_name = $db->prefix . $this->table_name; $old = $this->get_row( $url, $is_mobile ); $retries = 0; $previous_message = ''; if ( $old ) { $retries = $old->retries; $previous_message = $old->error_message; } $data = [ 'retries' => $retries + 1, 'status' => 'pending', 'error_message' => $previous_message . ' - ' . current_time( 'mysql', true ) . " {$error_code}: {$error_message}", ]; $where = [ 'url' => untrailingslashit( $url ), 'is_mobile' => $is_mobile, ]; return $db->update( $prefixed_table_name, $data, $where ); } /** * Update Job ID. * * @param int $id DB row ID. * @param int $new_job_id new job id. * * @return bool */ public function update_job_id( $id, $new_job_id ) { if ( ! self::$table_exists && ! $this->table_exists() ) { return false; } $update_data['job_id'] = $new_job_id; return $this->update_item( $id, $update_data ); } /** * Change the status to be in-progress. * * @param string $url Url from DB row. * @param boolean $is_mobile Is mobile from DB row. * @return bool|int */ public function make_status_inprogress( string $url, bool $is_mobile ) { if ( ! $this->is_allowed() ) { return false; } $db = $this->get_db(); $prefixed_table_name = $db->prefix . $this->table_name; $where = [ 'url' => untrailingslashit( $url ), 'is_mobile' => $is_mobile, ]; return $db->update( $prefixed_table_name, [ 'status' => 'in-progress' ], $where ); } /** * Reset the job and add new job_id pending. * * @param int $id DB row ID. * @param string $job_id API job_id. * * @return bool */ public function reset_job( int $id, string $job_id = '' ) { if ( ! self::$table_exists && ! $this->table_exists() ) { return false; } return $this->update_item( $id, [ 'job_id' => $job_id, 'status' => 'to-submit', 'error_code' => '', 'error_message' => '', 'retries' => 0, 'modified' => current_time( 'mysql', true ), 'submitted_at' => current_time( 'mysql', true ), ] ); } /** * Change the status to be failed. * * @param string $url Url from DB row. * @param boolean $is_mobile Is mobile from DB row. * @param string $error_code error code. * @param string $error_message error message. * * @return bool|int */ public function make_status_failed( string $url, bool $is_mobile, string $error_code, string $error_message ) { if ( ! $this->is_allowed() ) { return false; } $db = $this->get_db(); $prefixed_table_name = $db->prefix . $this->table_name; $old = $this->get_row( $url, $is_mobile ); $previous_message = $old ? $old->error_message : ''; $data = [ 'status' => 'failed', 'error_code' => $error_code, 'error_message' => $previous_message . ' - ' . current_time( 'mysql', true ) . " {$error_code}: {$error_message}", ]; $where = [ 'url' => untrailingslashit( $url ), 'is_mobile' => $is_mobile, ]; return $db->update( $prefixed_table_name, $data, $where ); } /** * Update row last_accessed date to current date. * * @param int $id Used CSS id. * * @return bool */ public function update_last_accessed( int $id ): bool { if ( ! self::$table_exists && ! $this->table_exists() ) { return false; } return (bool) $this->update_item( $id, [ 'last_accessed' => current_time( 'mysql', true ), ] ); } /** * Delete DB row by url. * * @param string $url Page url to be deleted. * * @return bool */ public function delete_by_url( string $url ) { if ( ! self::$table_exists && ! $this->table_exists() ) { return false; } $items = $this->get_rows_by_url( $url ); if ( ! $items ) { return false; } $deleted = true; foreach ( $items as $item ) { $deleted = $deleted && $this->delete_item( $item->id ); } return $deleted; } /** * Get the count of not completed rows. * * @return int */ public function get_not_completed_count() { if ( ! self::$table_exists && ! $this->table_exists() ) { return 0; } return $this->query( [ 'count' => true, 'status__in' => [ 'pending', 'in-progress' ], ] ); } /** * Get the count of completed rows. * * @return int */ public function get_completed_count() { if ( ! self::$table_exists && ! $this->table_exists() ) { return 0; } return $this->query( [ 'count' => true, 'status' => 'completed', ] ); } /** * Get all failed rows. * * @param float $delay delay before the urls are deleted. * @param string $unit unit from the delay. * @return array|false */ public function get_failed_rows( float $delay = 3, string $unit = 'days' ) { if ( ! self::$table_exists && ! $this->table_exists() ) { return false; } $query = $this->query( [ 'status' => 'failed', 'date_query' => [ [ 'column' => 'modified', 'before' => "$delay $unit ago", 'inclusive' => true, ], ], ], false ); if ( empty( $query ) ) { return false; } return $query; } /** * Revert status to pending. * * @param integer $id Used CSS id. * @return boolean */ public function revert_to_pending( int $id ): bool { if ( ! self::$table_exists && ! $this->table_exists() ) { return false; } return (bool) $this->update_item( $id, [ 'error_code' => '', 'error_message' => '', 'retries' => 0, 'status' => 'pending', 'modified' => current_time( 'mysql', true ), ] ); } /** * Returns the current status of the table; true if it exists, false otherwise. * * @return boolean */ protected function table_exists(): bool { if ( self::$table_exists ) { return true; } // Get the database interface. $db = $this->get_db(); // Bail if no database interface is available. if ( ! $db ) { return false; } // Query statement. $query = 'SHOW TABLES LIKE %s'; $like = $db->esc_like( $db->{$this->table_name} ); $prepared = $db->prepare( $query, $like ); $result = $db->get_var( $prepared ); // Does the table exist? $exists = $this->is_success( $result ); if ( $exists ) { self::$table_exists = $exists; } return $exists; } /** * Change the status to be pending. * * @param string $url DB row url. * @param string $job_id API job_id. * @param string $queue_name API Queue name. * @param bool $is_mobile if the request is for mobile page. * @return bool|int */ public function make_status_pending( string $url, string $job_id = '', string $queue_name = '', bool $is_mobile = false ) { if ( ! $this->is_allowed() ) { return false; } $db = $this->get_db(); $prefixed_table_name = $db->prefix . $this->table_name; $data = [ 'job_id' => $job_id, 'queue_name' => $queue_name, 'status' => 'pending', 'is_mobile' => $is_mobile, 'submitted_at' => current_time( 'mysql', true ), ]; $where = [ 'url' => untrailingslashit( $url ), 'is_mobile' => $is_mobile, ]; return $db->update( $prefixed_table_name, $data, $where ); } /** * Update the error message. * * @param string $url DB row url. * @param boolean $is_mobile Is mobile from DB row. * @param int $code Response code. * @param string $message Response message. * @param string $previous_message Previous saved message. * * @return bool|int */ public function update_message( string $url, bool $is_mobile, int $code, string $message, string $previous_message = '' ) { if ( ! $this->is_allowed() ) { return false; } $db = $this->get_db(); $prefixed_table_name = $db->prefix . $this->table_name; $data = [ 'error_message' => $previous_message . ' - ' . current_time( 'mysql', true ) . " {$code}: {$message}" ]; $where = [ 'url' => untrailingslashit( $url ), 'is_mobile' => $is_mobile, ]; return $db->update( $prefixed_table_name, $data, $where ); } /** * Updates the next_retry_time field * * @param string $url DB row url. * @param boolean $is_mobile Is mobile from DB row. * @param string|int $next_retry_time timestamp or mysql format date. * * @return bool|int either it is saved or not. */ public function update_next_retry_time( string $url, bool $is_mobile, $next_retry_time ) { if ( ! $this->is_allowed() ) { return false; } $db = $this->get_db(); $prefixed_table_name = $db->prefix . $this->table_name; if ( is_string( $next_retry_time ) && strtotime( $next_retry_time ) ) { // If $next_retry_time is a valid date string, convert it to a timestamp. $next_retry_time = strtotime( $next_retry_time ); } elseif ( ! is_numeric( $next_retry_time ) ) { // If it's not numeric and not a valid date string, return false. return false; } $data = [ 'next_retry_time' => gmdate( 'Y-m-d H:i:s', $next_retry_time ) ]; $where = [ 'url' => untrailingslashit( $url ), 'is_mobile' => $is_mobile, ]; return $db->update( $prefixed_table_name, $data, $where ); } /** * Check if db action can be processed. * * @return boolean */ private function is_allowed() { if ( ! self::$table_exists && ! $this->table_exists() ) { return false; } // Bail if no database interface is available. if ( empty( $this->get_db() ) ) { return false; } return true; } }