<?php
/**
 * The Data class.
 * This class provides methods for data VideoPress access and manipulation.
 *
 * @package automattic/jetpack-videopress
 */

namespace Automattic\Jetpack\VideoPress;

use Automattic\Jetpack\Connection\Manager as Connection_Manager;
use Automattic\Jetpack\Status\Host;
use WP_REST_Request;
/**
 * The Data class.
 */
class Data {

	/**
	 * Gets the Jetpack blog ID
	 *
	 * @return int The blog ID
	 */
	public static function get_blog_id() {
		return VideoPressToken::blog_id();
	}

	/**
	 * Gets the VideoPress site privacy configuration.
	 *
	 * @return boolean If all the videos are private on the site
	 */
	public static function get_videopress_videos_private_for_site() {
		/**
		 * If it's a Simple site, returns the site privacy setting.
		 */
		if ( defined( 'IS_WPCOM' ) && IS_WPCOM ) {
			return video_is_private_wpcom_blog( get_current_blog_id() );
		}
		/**
		 * If it's a private Atomic site, the default setting is private as well.
		 */
		if ( ( new Host() )->is_woa_site() ) {
			if ( ( intval( get_option( 'blog_public', '' ) ) === -1 ) ) {
				return true;
			}
		}

		/* If it's a Jetpack site or a public Atomic site, check the settings */
		return boolval( get_option( 'videopress_private_enabled_for_site', false ) );
	}

	/**
	 * Gets whether auto-generated subtitles are disabled for the site.
	 *
	 * Subtitles are generated by default, so this opt-out option defaults to false.
	 *
	 * @return boolean If auto-generated subtitles should be skipped for new videos.
	 */
	public static function get_videopress_auto_subtitles_disabled() {
		return boolval( get_option( 'videopress_auto_subtitles_disabled', false ) );
	}

	/**
	 * Gets whether player preloading is turned off for every embed on the site.
	 *
	 * Preloading is on by default, so this opt-out option defaults to false.
	 *
	 * @return boolean If embeds should wait for playback before fetching video data and player assets.
	 */
	public static function get_videopress_player_preload_disabled() {
		return boolval( get_option( 'videopress_player_preload_disabled', false ) );
	}

	/**
	 * Gets whether embeds render an inline player instead of one iframe per video.
	 *
	 * Iframes are the default, so this opt-in option defaults to false.
	 *
	 * @return boolean If embeds should mount players in the page from one shared player script.
	 */
	public static function get_videopress_inline_player_enabled() {
		return boolval( get_option( 'videopress_inline_player_enabled', false ) );
	}

	/**
	 * Gets whether the share menu is turned off for every video on the site.
	 *
	 * Sharing follows each video's own setting by default, so this opt-out option defaults to false.
	 *
	 * @return boolean If no video may display the share menu, whatever its own setting.
	 */
	public static function get_videopress_share_menu_disabled() {
		return boolval( get_option( 'videopress_share_menu_disabled', false ) );
	}

	/**
	 * Gets the VideoPress Settings.
	 *
	 * @return array The settings as an associative array.
	 */
	public static function get_videopress_settings() {
		$site_type       = 'jetpack';
		$site_is_private = false;

		if ( defined( 'IS_WPCOM' ) && IS_WPCOM ) {
			$site_type       = 'simple';
			$site_is_private = video_is_private_wpcom_blog( get_current_blog_id() );
		} elseif ( ( new Host() )->is_woa_site() ) {
			$site_type       = 'atomic';
			$site_is_private = intval( get_option( 'blog_public', '' ) ) === -1;
		}

		return array(
			'videopress_videos_private_for_site' => self::get_videopress_videos_private_for_site(),
			'videopress_auto_subtitles_disabled' => self::get_videopress_auto_subtitles_disabled(),
			'videopress_player_preload_disabled' => self::get_videopress_player_preload_disabled(),
			'videopress_inline_player_enabled'   => self::get_videopress_inline_player_enabled(),
			'videopress_share_menu_disabled'     => self::get_videopress_share_menu_disabled(),
			'site_is_private'                    => $site_is_private,
			'site_type'                          => $site_type,
		);
	}

	/**
	 * Gets the video data
	 *
	 * @param boolean $is_videopress - True when getting VideoPress data.
	 * @return array
	 */
	public static function get_video_data( $is_videopress = true ) {
		$video_data = array(
			'videos'     => array(),
			'total'      => 0,
			'totalPages' => 0,
			'query'      => array(
				'order'        => 'desc',
				'orderBy'      => 'date',
				'itemsPerPage' => 6,
				'page'         => 1,
			),
		);

		$args = array(
			'order'    => $video_data['query']['order'],
			'orderby'  => $video_data['query']['orderBy'],
			'per_page' => $video_data['query']['itemsPerPage'],
			'page'     => $video_data['query']['page'],
		);

		if ( $is_videopress ) {
			$args['mime_type'] = 'video/videopress';
		} else {
			$args['media_type']    = 'video';
			$args['no_videopress'] = true;
		}

		// Do an internal request for the media list
		$request = new WP_REST_Request( 'GET', '/wp/v2/media' );
		$request->set_query_params( $args );
		$response = rest_do_request( $request );

		if ( $response->is_error() ) {
			// @todo: error handling
			return $video_data;
		}

		// load the real values
		$video_data['videos'] = $response->get_data();
		$headers              = $response->get_headers();

		if ( isset( $headers['X-WP-Total'] ) ) {
			$video_data['total'] = $headers['X-WP-Total'];
		}

		if ( isset( $headers['X-WP-TotalPages'] ) ) {
			$video_data['totalPages'] = $headers['X-WP-TotalPages'];
		}

		return $video_data;
	}

	/**
	 * Gets the site's newest VideoPress videos as playlist entries, newest first.
	 *
	 * Goes through the media REST endpoint rather than a direct WP_Query so the
	 * package's rest_attachment_query filter resolves VideoPress membership on
	 * every host: by mime off WordPress.com Simple, from wpcom's videos table on it.
	 * The editor's block preview sends the same request.
	 *
	 * @param int $count How many videos to fetch.
	 *
	 * @return array Entries with guid, durationMs and height keys.
	 */
	public static function get_latest_videopress_playlist_entries( $count ) {
		$count = max( 1, (int) $count );
		$args  = array(
			'per_page'            => $count,
			'orderby'             => 'date',
			'order'               => 'desc',
			'videopress_has_guid' => 1,
		);

		// Attachments keep their original mime there, so narrow to videos before the ID-set constraint.
		if ( defined( 'IS_WPCOM' ) && IS_WPCOM ) {
			$args['videopress_only_videos'] = 1;
		}

		$request = new WP_REST_Request( 'GET', '/wp/v2/media' );
		$request->set_query_params( $args );
		$response = rest_do_request( $request );

		// WordPress.com Simple registers the wp/v2 routes only for REST requests, so on a
		// page render the media endpoint does not exist: query the attachments directly.
		if ( $response->is_error() ) {
			return self::query_latest_videopress_playlist_entries( $count );
		}

		$entries = array();
		foreach ( (array) $response->get_data() as $item ) {
			$item = (array) $item;
			$guid = $item['jetpack_videopress_guid'] ?? '';

			// The REST field is empty on a site without a connection; the attachment meta still knows.
			if ( ( ! is_string( $guid ) || '' === $guid ) && ! empty( $item['id'] ) ) {
				$guid = get_post_meta( (int) $item['id'], 'videopress_guid', true );
			}

			$details    = isset( $item['media_details'] ) ? (array) $item['media_details'] : array();
			$videopress = isset( $details['videopress'] ) ? (array) $details['videopress'] : array();
			$entry      = self::playlist_entry( $guid, $videopress['duration'] ?? 0, $details['height'] ?? $videopress['height'] ?? 0 );
			if ( $entry ) {
				$entries[] = $entry;
			}
		}

		return $entries;
	}

	/**
	 * The newest VideoPress videos straight from the posts table, for hosts where the
	 * media endpoint is unavailable. Mirrors what the endpoint does with the package's
	 * query filter: by mime off WordPress.com Simple, from wpcom's videos table on it.
	 *
	 * @param int $count How many videos to fetch.
	 *
	 * @return array Entries with guid, durationMs and height keys.
	 */
	private static function query_latest_videopress_playlist_entries( $count ) {
		$is_wpcom = defined( 'IS_WPCOM' ) && IS_WPCOM;
		$posts    = get_posts(
			array(
				'post_type'      => 'attachment',
				'post_status'    => 'inherit',
				'post_mime_type' => $is_wpcom ? 'video' : 'video/videopress',
				'orderby'        => 'date',
				'order'          => 'DESC',
				'posts_per_page' => $count,
			)
		);

		$entries = array();
		foreach ( $posts as $post ) {
			$guid = get_post_meta( $post->ID, 'videopress_guid', true );
			if ( ( ! is_string( $guid ) || '' === $guid ) && $is_wpcom && function_exists( 'video_get_info_by_blogpostid' ) ) {
				$info = video_get_info_by_blogpostid( get_current_blog_id(), $post->ID );
				$guid = is_object( $info ) && ! empty( $info->guid ) ? (string) $info->guid : '';
			}

			$meta       = wp_get_attachment_metadata( $post->ID );
			$meta       = is_array( $meta ) ? $meta : array();
			$videopress = isset( $meta['videopress'] ) ? (array) $meta['videopress'] : array();
			$duration   = $videopress['duration'] ?? ( isset( $meta['length'] ) && is_numeric( $meta['length'] ) ? (int) $meta['length'] * 1000 : 0 );
			$entry      = self::playlist_entry( $guid, $duration, $meta['height'] ?? $videopress['height'] ?? 0 );
			if ( $entry ) {
				$entries[] = $entry;
			}
		}

		return $entries;
	}

	/**
	 * One playlist entry, or null when the GUID is unusable.
	 *
	 * @param mixed $guid     VideoPress GUID.
	 * @param mixed $duration Duration in ms.
	 * @param mixed $height   Height in px.
	 *
	 * @return array|null
	 */
	private static function playlist_entry( $guid, $duration, $height ) {
		if ( ! is_string( $guid ) || ! preg_match( '/^[a-zA-Z0-9]{8}$/', $guid ) ) {
			return null;
		}
		return array(
			'guid'       => $guid,
			'durationMs' => is_numeric( $duration ) ? max( 0, (int) $duration ) : 0,
			'height'     => is_numeric( $height ) ? max( 0, (int) $height ) : 0,
		);
	}

	/**
	 * Gets the user data
	 *
	 * @return array
	 */
	public static function get_user_data() {
		$user_data = array(
			'items'      => array(),
			'pagination' => array(
				'total'      => 0,
				'totalPages' => 1,
			),
			'query'      => array(
				'order'   => 'asc',
				'orderBy' => 'name',
			),
			'_meta'      => array(
				'relyOnInitialState' => true,
			),
		);

		$args = array(
			'order'   => $user_data['query']['order'],
			'orderby' => $user_data['query']['orderBy'],
		);

		// Do an internal request for the user list
		$request = new WP_REST_Request( 'GET', '/wp/v2/users' );
		$request->set_query_params( $args );
		$response = rest_do_request( $request );

		if ( $response->is_error() ) {
			// @todo: error handling
			return $user_data;
		}

		// load the real values
		$user_data['items'] = $response->get_data();
		$headers            = $response->get_headers();

		if ( isset( $headers['X-WP-Total'] ) ) {
			$user_data['pagination']['total'] = $headers['X-WP-Total'];
		}

		if ( isset( $headers['X-WP-TotalPages'] ) ) {
			$user_data['pagination']['totalPages'] = $headers['X-WP-TotalPages'];
		}

		return $user_data;
	}

	/**
	 * Gets the VideoPress used storage space in bytes
	 *
	 * @return int the used storage space
	 */
	public static function get_storage_used() {
		$site_data = Site::get_site_info();
		if ( is_wp_error( $site_data ) ) {
			return 0;
		}

		if ( isset( $site_data['options'] ) && isset( $site_data['options']['videopress_storage_used'] ) ) {
			return intval( round( $site_data['options']['videopress_storage_used'] * 1024 * 1024 ) );
		} else {
			return 0;
		}
	}

	/**
	 * Return all the initial state that depends on a valid site connection
	 *
	 * @return array
	 */
	public static function get_connected_initial_state() {
		return array(
			'videos'    => array(
				'storageUsed' => self::get_storage_used(),
			),
			'purchases' => array(
				'items'      => Site::get_purchases(),
				'isFetching' => false,
			),
		);
	}

	/**
	 * Checks if the site has as connected owner
	 */
	public static function has_connected_owner() {
		if ( defined( 'IS_WPCOM' ) && IS_WPCOM ) {
			return true;
		}

		if ( ( new Connection_Manager() )->has_connected_owner() ) {
			return true;
		}

		return false;
	}

	/**
	 * Checks if the user is able to perform actions that modify data
	 */
	public static function can_perform_action() {
		if ( defined( 'IS_WPCOM' ) && IS_WPCOM ) {
			return true;
		}

		$connection = new Connection_Manager();

		return (
			$connection->is_connected() &&
			self::has_connected_owner() &&
			$connection->is_user_connected()
		);
	}

	/**
	 * Return the initial state of the VideoPress app,
	 * used to render initially the app in the frontend.
	 *
	 * @return array
	 */
	public static function get_initial_state() {
		$videopress_data   = self::get_video_data();
		$local_videos_data = self::get_video_data( false );

		// Tweak local videos data.
		$local_videos = array_map(
			function ( $video ) {
				$video              = (array) $video;
				$id                 = $video['id'];
				$media_details      = $video['media_details'];
				$jetpack_videopress = $video['jetpack_videopress'];
				$read_error         = null;

				// In malformed files, the media_details or jetpack_videopress properties are not arrays.
				if ( ! is_array( $media_details ) || ! is_array( $jetpack_videopress ) ) {
					$media_details      = (array) $media_details;
					$jetpack_videopress = (array) $jetpack_videopress;
					$read_error         = Upload_Exception::ERROR_MALFORMED_FILE;
				}

				// Check if video is already uploaded to VideoPress or has some error.
				try {
					$uploader                  = new Uploader( $id );
					$is_uploaded_to_videopress = $uploader->is_uploaded();
				} catch ( Upload_Exception $e ) {
					$is_uploaded_to_videopress = false;
					$read_error                = $e->getCode();
				}

				$upload_date = $video['date'];
				$url         = $video['source_url'];

				$title       = $jetpack_videopress['title'];
				$description = $jetpack_videopress['description'];
				$caption     = $jetpack_videopress['caption'];

				$width    = $media_details['width'] ?? null;
				$height   = $media_details['height'] ?? null;
				$duration = $media_details['length'] ?? null;

				return array(
					'id'                     => $id,
					'title'                  => $title,
					'description'            => $description,
					'caption'                => $caption,
					'width'                  => $width,
					'height'                 => $height,
					'url'                    => $url,
					'uploadDate'             => $upload_date,
					'duration'               => $duration,
					'isUploadedToVideoPress' => $is_uploaded_to_videopress,
					'readError'              => $read_error,
				);
			},
			$local_videos_data['videos']
		);

		// Tweak VideoPress videos data.
		$videos = array_map(
			array( __CLASS__, 'prepare_videopress_video_data' ),
			$videopress_data['videos']
		);

		$site_settings = self::get_videopress_settings();

		$initial_state = array(
			'users'        => self::get_user_data(),
			'siteSettings' => array(
				'videoPressVideosPrivateForSite' => $site_settings['videopress_videos_private_for_site'],
				'siteIsPrivate'                  => $site_settings['site_is_private'],
				'siteType'                       => $site_settings['site_type'],
			),
			'videos'       => array(
				'uploadedVideoCount'           => $videopress_data['total'],
				'items'                        => $videos,
				'isFetching'                   => false,
				'isFetchingUploadedVideoCount' => false,
				'pagination'                   => array(
					'totalPages' => $videopress_data['totalPages'],
					'total'      => $videopress_data['total'],
				),
				'query'                        => $videopress_data['query'],
				'_meta'                        => array(
					'processedAllVideosBeingRemoved' => true,
					'relyOnInitialState'             => true,
				),
			),
			'localVideos'  => array(
				'uploadedVideoCount'           => $local_videos_data['total'],
				'items'                        => $local_videos,
				'isFetching'                   => false,
				'isFetchingUploadedVideoCount' => false,
				'pagination'                   => array(
					'totalPages' => $local_videos_data['totalPages'],
					'total'      => $local_videos_data['total'],
				),
				'query'                        => $local_videos_data['query'],
				'_meta'                        => array(
					'relyOnInitialState' => true,
				),
			),
		);

		if ( self::has_connected_owner() ) {
			return array_merge_recursive( $initial_state, self::get_connected_initial_state() );
		}

		return $initial_state;
	}

	/**
	 * Maps a single VideoPress video, as returned by the media REST endpoint, to
	 * the shape consumed by the VideoPress dashboard app.
	 *
	 * Videos that are still processing (or otherwise have partial metadata) come
	 * back without `videopress`, `width` or `height` in their media_details, so
	 * every nested access is coalesced to avoid undefined-key and offset-on-null
	 * warnings.
	 *
	 * @param array|object $video A single video entry from the media REST endpoint.
	 * @return array The video data formatted for the dashboard app.
	 */
	private static function prepare_videopress_video_data( $video ) {
		$video              = (array) $video;
		$id                 = $video['id'];
		$guid               = $video['jetpack_videopress_guid'];
		$media_details      = (array) $video['media_details'];
		$jetpack_videopress = (array) $video['jetpack_videopress'];

		$videopress_media_details = $media_details['videopress'] ?? array();
		$width                    = $media_details['width'] ?? null;
		$height                   = $media_details['height'] ?? null;

		$title                = $jetpack_videopress['title'];
		$description          = $jetpack_videopress['description'];
		$caption              = $jetpack_videopress['caption'];
		$rating               = $jetpack_videopress['rating'];
		$allow_download       = $jetpack_videopress['allow_download'];
		$display_embed        = $jetpack_videopress['display_embed'];
		$privacy_setting      = $jetpack_videopress['privacy_setting'];
		$needs_playback_token = $jetpack_videopress['needs_playback_token'];
		$is_private           = $jetpack_videopress['is_private'];

		$original      = $videopress_media_details['original'] ?? null;
		$poster        = ( ! $needs_playback_token ) ? ( $videopress_media_details['poster'] ?? null ) : null;
		$upload_date   = $videopress_media_details['upload_date'] ?? null;
		$duration      = $videopress_media_details['duration'] ?? null;
		$file_url_base = $videopress_media_details['file_url_base'] ?? null;
		$finished      = $videopress_media_details['finished'] ?? null;
		$files         = $videopress_media_details['files'] ?? null;
		$filename      = $original !== null ? basename( $original ) : null;

		if ( isset( $files['dvd']['original_img'] ) && isset( $file_url_base['https'] ) && $privacy_setting !== 1 ) {
			$thumbnail = $file_url_base['https'] . $files['dvd']['original_img'];
		} else {
			$thumbnail = null;
		}

		return array(
			'id'                 => $id,
			'guid'               => $guid,
			'title'              => $title,
			'description'        => $description,
			'caption'            => $caption,
			'url'                => $original,
			'uploadDate'         => $upload_date,
			'duration'           => $duration,
			'isPrivate'          => $is_private,
			'posterImage'        => $poster,
			'allowDownload'      => $allow_download,
			'displayEmbed'       => $display_embed,
			'rating'             => $rating,
			'privacySetting'     => $privacy_setting,
			'needsPlaybackToken' => $needs_playback_token,
			'width'              => $width,
			'height'             => $height,
			'poster'             => array(
				'src' => $poster,
			),
			'thumbnail'          => $thumbnail,
			'finished'           => $finished,
			'filename'           => $filename,
		);
	}
}