­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ '~^.*(?:youtu\.be/|youtube(?:-nocookie)?\.com/channel/)([A-Za-z0-9_-]+)~', 'yt_user' => '~^.*(?:youtu\.be/|youtube(?:-nocookie)?\.com/user/)([A-Za-z0-9_-]+)~', 'yt_playlist' => '~^.*(?:youtu\.be/|youtube(?:-nocookie)?\.com/playlist\?list=)([A-Za-z0-9_-]+)~', 'yt_videos' => '~^.*(?:youtu\.be/|youtube(?:-nocookie)?\.com/)@([A-Za-z0-9_-]+)~', ); /** * Initialize handler * * @return void */ public function init() { $this->youtube_api_key = jet_blog_settings()->get( 'youtube_api_key' ); } /** * Get data for passed video. * * @param string $url Video url. * @param bool $caching Caching. * @return array */ public function get( $url = '', $caching = true ) { $key = $this->transient_key( $url ); if ( $caching ) { $cached = get_transient( $key ); if ( false !== $cached && ! empty( $cached ) ) { return $cached; } } $data = $this->fetch_embed_data( $url ); if ( empty( $data['provider_name'] ) || empty( $data['video_id'] ) ) { return $data; } $data = $this->merge_api_data( $data, $caching ); if ( $caching && ! empty( $data ) ) { set_transient( $key, $data, $this->get_ttl( 'video' ) ); } return $data; } /** * Get video list from source. * * @param string $url Url. * @param int $max_results Number of videos. * @param bool $caching Caching. * * @return array|mixed */ public function get_video_list_from_source( $url = '', $max_results = 10, $caching = true ) { if ( empty( $url ) ) { return array(); } $key = $this->transient_key( $url ) . $max_results; if ( $caching ) { $cached = get_transient( $key ); if ( false !== $cached ) { return $cached; } } $source_props = $this->get_video_source_properties( $url ); if ( empty( $source_props ) ) { return array(); } $video_list = array(); $source = $source_props['source']; $source_id = $source_props['source_id']; switch ( $source ) { case 'yt_channel': $video_list = $this->get_youtube_channel_video_list( $source_id, $max_results, null, $caching ); break; case 'yt_user': $video_list = $this->get_youtube_channel_video_list( null, $max_results, $source_id, $caching ); break; case 'yt_playlist': $video_list = $this->get_youtube_playlist_video_list( $source_id, $max_results, $caching ); break; case 'yt_videos': $video_list = $this->get_youtube_channelid_video_list( $source_id, $max_results, $caching); break; } if ( $caching && ! empty( $video_list ) ) { set_transient( $key, $video_list, $this->get_ttl( 'list' ) ); } return $video_list; } /** * Get video source properties. * * @param string $url Url. * * @return array|bool */ public function get_video_source_properties( $url ) { foreach ( $this->video_source_match_masks as $provider => $match_mask ) { preg_match( $match_mask, $url, $matches ); if ( $matches ) { return array( 'source' => $provider, 'source_id' => $matches[1], ); } } return false; } private function detect_provider_from_url( $url ) { $u = (string) $url; if ( stripos( $u, 'youtube' ) !== false || stripos( $u, 'youtu.be' ) !== false ) { return 'YouTube'; } if ( stripos( $u, 'vimeo' ) !== false ) { return 'Vimeo'; } return ''; } private function get_id_from_url( $url ) { $u = (string) $url; if ( preg_match( '~(?:v=|youtu\.be/|embed/)([A-Za-z0-9_-]{6,})~', $u, $m ) ) { return $m[1]; } if ( preg_match( '~vimeo\.com/(\d+)~', $u, $m ) ) { return $m[1]; } return false; } /** * Fetch data from oembed provider * * @param string $url Video url. * @return array */ public function fetch_embed_data( $url ) { $url = trim( (string) $url ); if ( $url === '' ) { return array( 'url' => '', 'title' => '', 'video_id' => '', 'provider_name' => '', 'html' => '', 'thumbnail_default' => '', ); } $oembed = _wp_oembed_get_object(); $data = $oembed->get_data( $url ); if ( ! $data || ! is_object( $data ) ) { $this->api_error = 'oEmbed: no data returned'; return array( 'url' => $url, 'title' => '', 'video_id' => $this->get_id_from_url( $url ) ?: '', 'provider_name' => $this->detect_provider_from_url( $url ), 'html' => '', 'thumbnail_default' => '', ); } $pattern = '~["\'](https?://.*?)["\']~'; $this->current_provider = property_exists( $data, 'provider_name' ) ? (string) $data->provider_name : ''; $raw_html = ( property_exists( $data, 'html' ) && is_string( $data->html ) ) ? $data->html : ''; $html = $raw_html !== '' ? preg_replace_callback( $pattern, array( $this, 'add_embed_args' ), $raw_html ) : ''; $this->current_provider = null; return array( 'url' => $url, 'title' => property_exists( $data, 'title' ) && is_string( $data->title ) ? str_replace( "'", ''', $data->title ) : '', 'video_id' => $this->get_id_from_html( (string) $html ) ?: ( ( preg_match( '~(?:v=|youtu\.be/|embed/)([A-Za-z0-9_-]{6,})~', (string) $url, $m ) ? $m[1] : ( preg_match( '~vimeo\.com/(\d+)~', (string) $url, $m2 ) ? $m2[1] : '' ) ) ), 'provider_name' => property_exists( $data, 'provider_name' ) ? (string) $data->provider_name : $this->detect_provider_from_url( $url ), 'html' => $this->replace_quots( (string) $html ), 'thumbnail_default' => property_exists( $data, 'thumbnail_url' ) && is_string( $data->thumbnail_url ) ? $data->thumbnail_url : '', ); } /** * Add data from main provider API to already fetched data. * * @param array $data * @return array */ public function merge_api_data( $data, $caching = true ) { $id = $data['video_id']; if ( ! $id ) { return $data; } $provider = $data['provider_name']; $api_data = array(); switch ( $provider ) { case 'YouTube': $api_data = $this->get_youtube_data( $id, $caching ); break; case 'Vimeo': $api_data = $this->get_vimeo_data( $id ); break; } if ( is_wp_error( $api_data ) ) { $this->api_error = $api_data->get_error_message(); return $data; } return array_merge( $data, $api_data ); } /** * Fetches YouTube specific data * * @param string $id Video ID. * @return array */ public function get_youtube_data( $id, $caching = true ) { if ( empty( $this->youtube_api_key ) ) { return array(); } $tkey = $this->k( 'yt_video', $id ); if ( $caching ) { $cached = get_transient( $tkey ); if ( false !== $cached ) { return $cached; } } $response = wp_remote_get( add_query_arg( array( 'id' => $id, 'part' => 'contentDetails,snippet', 'key' => $this->youtube_api_key, ), sprintf( $this->youtube_base, 'videos' ) ) ); if ( is_wp_error( $response ) ) { $this->api_error = $response->get_error_message(); return $response; } $body = json_decode( wp_remote_retrieve_body( $response ), true ); if ( isset( $body['error'] ) ) { $error_message = isset( $body['error']['message'] ) ? $body['error']['message'] : 'Unknown API error'; $this->api_error = $error_message; return array( 'error' => $error_message ); } if ( empty( $body['items'][0]['contentDetails']['duration'] ) ) { return []; } $duration = $this->convert_duration( $body['items'][0]['contentDetails']['duration'] ); $publication_date = $body['items'][0]['snippet']['publishedAt'] ?? false; $result = [ 'duration' => $duration, 'publication_date' => $publication_date, ]; if ( $caching ) { set_transient( $tkey, $result, $this->get_ttl( 'video' ) ); } return $result; } /** * Get YouTube video list by playlist ID * * @param string $id Playlist ID. * @param int $max_results Number of videos. * @return array */ public function get_youtube_playlist_video_list( $id = null, $max_results = 10, $caching = true ) { if ( empty( $this->youtube_api_key ) ) { return array(); } $tkey = $this->k( 'yt_playlist_items', $id . '|' . absint( $max_results ) ); if ( $caching ) { $cached = get_transient( $tkey ); if ( false !== $cached ) { return $cached; } } $response = wp_remote_get( add_query_arg( array( 'playlistId' => $id, 'part' => 'contentDetails,status', 'fields' => 'items(contentDetails(videoId),status(privacyStatus))', 'maxResults' => absint( $max_results ), 'key' => $this->youtube_api_key, ), sprintf( $this->youtube_base, 'playlistItems' ) ) ); if ( is_wp_error( $response ) ) { return []; } $body = json_decode( wp_remote_retrieve_body( $response ), true ); if ( ! isset( $body['items'] ) ) { return array(); } $video_list = array(); foreach ( $body['items'] as $item ) { $privacy = isset( $item['status']['privacyStatus'] ) ? $item['status']['privacyStatus'] : 'public'; if ( 'private' === $privacy ) { continue; } if ( isset( $item['contentDetails']['videoId'] ) ) { $vid = $item['contentDetails']['videoId']; $video_list[] = array( '_id' => strtolower( $vid ), 'url' => sprintf( $this->yt_video_base_url, $vid ), ); } } if ( $caching ) { set_transient( $tkey, $video_list, $this->get_ttl( 'list' ) ); } return $video_list; } /** * Get YouTube channel id by user name * * @param string $id User Name. * @param int $max_results Number of videos. * @return array */ public function get_youtube_channelid_video_list( $id = null, $max_results = 10, $caching = true ) { if ( empty( $this->youtube_api_key ) ) { return array(); } $tkey = $this->k( 'yt_channel_by_name', $id ); if ( $caching ) { $cached = get_transient( $tkey ); if ( false !== $cached && ! empty( $cached['channel_id'] ) ) { return $this->get_youtube_channel_video_list( $cached['channel_id'], $max_results, null, $caching ); } } $args = array( 'part' => 'id', 'type' => 'channel', 'q' => $id, 'key' => $this->youtube_api_key, ); $response = wp_remote_get( add_query_arg( $args, sprintf( $this->youtube_base, 'search' ) ) ); if ( is_wp_error( $response ) ) { return []; } $body = json_decode( wp_remote_retrieve_body( $response ), true ); if ( empty( $body['items'][0]['id']['channelId'] ) ) { return []; } $channel_id = $body['items'][0]['id']['channelId']; if ( $caching ) { set_transient( $tkey, [ 'channel_id' => $channel_id ], $this->get_ttl( 'list' ) ); } return $this->get_youtube_channel_video_list( $channel_id, $max_results, null, $caching ); } /** * Get YouTube video list by Channel ID * * @param string $id Channel ID. * @param int $max_results Number of videos. * @param string $user User ID. * @return array */ public function get_youtube_channel_video_list( $id = null, $max_results = 10, $user = null, $caching = true ) { if ( empty( $this->youtube_api_key ) ) { return array(); } $sig = wp_json_encode( [ 'id' => $id, 'user' => $user, 'max' => absint( $max_results ) ] ); $tkey = $this->k( 'yt_channel_uploads', $sig ); if ( $caching ) { $cached = get_transient( $tkey ); if ( false !== $cached ) { return $cached; } } $args = array( 'part' => 'contentDetails', 'fields' => 'items(contentDetails)', 'key' => $this->youtube_api_key, ); if ( ! empty( $id ) ) { $args['id'] = $id; } if ( ! empty( $user ) ) { $args['forUsername'] = $user; } $response = wp_remote_get( add_query_arg( $args, sprintf( $this->youtube_base, 'channels' ) ) ); if ( is_wp_error( $response ) ) { return []; } $body = json_decode( wp_remote_retrieve_body( $response ), true ); if ( empty( $body['items'][0]['contentDetails']['relatedPlaylists']['uploads'] ) ) { return []; } $playlist_id = $body['items'][0]['contentDetails']['relatedPlaylists']['uploads']; $list = $this->get_youtube_playlist_video_list( $playlist_id, $max_results, $caching ); if ( $caching ) { set_transient( $tkey, $list, $this->get_ttl( 'list' ) ); } return $list; } /** * Fetches Vimeo specific data * * @param int $id video ID. * @return array */ public function get_vimeo_data( $id ) { $response = wp_remote_get( sprintf( $this->vimeo_base, $id ) ); $body = wp_remote_retrieve_body( $response ); $body = json_decode( $body, true ); if ( ! isset( $body[0] ) ) { return array(); } $result = array( 'thumbnail_small' => isset( $body[0]['thumbnail_small'] ) ? $body[0]['thumbnail_small'] : false, 'thumbnail_medium' => isset( $body[0]['thumbnail_medium'] ) ? $body[0]['thumbnail_medium'] : false, 'duration' => isset( $body[0]['duration'] ) ? $body[0]['duration'] : false, ); $result = array_filter( $result ); if ( ! empty( $result['duration'] ) ) { $result['duration'] = $this->convert_duration( $result['duration'] ); } return $result; } /** * Calculates cache TTL (in seconds) for video meta or video lists. * * @param string $type Cache type. Accepts 'video' or 'list'. Default 'video'. * @return int TTL value in seconds. */ private function get_ttl( $type = 'video' ) { $default_hours = (int) jet_blog_settings()->get( 'video_cache_ttl_hours', 6 ); $hours = max( 1, min( 168, $default_hours ) ); $filter = ( 'list' === $type ) ? 'jet-blog/list-cache/ttl-hours' : 'jet-blog/video-cache/ttl-hours'; $hours = (int) apply_filters( $filter, $hours ); return HOUR_IN_SECONDS * $hours; } /** * Builds a versioned, namespaced cache key for transients/options. * * @param string $prefix Key namespace. * @param string $suffix Arbitrary unique payload (ID, concatenated args, JSON, etc). * @return string Final cache key. */ private function k( $prefix, $suffix ) { return sprintf( '%s_%s_%s', $prefix, jet_blog()->get_version(), md5( $suffix ) ); } public function convert_duration( $duration ) { if ( 0 < absint( $duration ) ) { $items = array( zeroise( floor( $duration / 60 ), 2 ), zeroise( ( $duration % 60 ), 2 ), ); } else { $interval = new DateInterval( $duration ); $items = array( ( 0 < $interval->h ) ? zeroise( $interval->h, 2 ) : false, ( 0 < $interval->i ) ? zeroise( $interval->i, 2 ) : false, ( 0 < $interval->s ) ? zeroise( $interval->s, 2 ) : false, ); } return implode( ':', array_filter( $items ) ); } /** * Find in passed embed string video ID. * * @param string $html * @return mixed */ public function get_id_from_html( $html ) { if ( preg_match( '~https?://[A-Za-z0-9./]+(?:video|embed)/([A-Za-z0-9_-]+)~', (string) $html, $m ) ) { return $m[1]; } return false; } /** * Callback to add required argumnets to passed video * * @param array $matches * @return string */ public function add_embed_args( $matches ) { $args = array(); switch ( $this->current_provider ) { case 'YouTube': $args = array( 'enablejsapi' => 1, ); break; case 'Vimeo': $args = array( 'api' => 1, 'byline' => 0, 'title' => 0, ); break; } return sprintf( '"%s"', add_query_arg( $args, $matches[1] ) ); } /** * Returns a html without single quotes and " * * @param string $html * @return string */ public function replace_quots( $html ) { $html = str_replace("'", "'", $html ); $html = str_replace('"', '', $html ); return $html; } /** * Returns appropriate transient key for passed URL * * @param string $url * @return string */ public function transient_key( $url ) { return 'video_data_' . jet_blog()->get_version() . md5( $url ); } /** * Returns the instance. * * @since 1.0.0 * @return object */ public static function get_instance() { // If the single instance hasn't been set, set it now. if ( null == self::$instance ) { self::$instance = new self; } return self::$instance; } } } /** * Returns instance of Jet_Blog_Video_Data * * @return object */ function jet_blog_video_data() { return Jet_Blog_Video_Data::get_instance(); }