<?php

namespace Podlove\Model;

use Podlove\Modules\Plus\FeedProxy;

class Feed extends Base
{
    use KeepsBlogReferenceTrait;

    const ITEMS_WP_LIMIT = 0;
    const ITEMS_NO_LIMIT = -1;
    const ITEMS_GLOBAL_LIMIT = -2;

    public function __construct()
    {
        $this->set_blog_id();
    }

    public function save()
    {
        global $wpdb;

        set_transient('podlove_needs_to_flush_rewrite_rules', true);
        $this->slug = sanitize_title($this->slug);

        if (!$this->position) {
            $pos = $wpdb->get_var(sprintf('SELECT MAX(position)+1 FROM %s', self::table_name()));
            $this->position = $pos ? $pos : 1;
        }

        parent::save();
    }

    /**
     * Build public url where the feed can be subscribed at.
     *
     * @param null|mixed $taxonomy
     * @param null|mixed $term_id
     *
     * @return string
     */
    public function get_subscribe_url($taxonomy = null, $term_id = null)
    {
        return $this->with_blog_scope(function () use ($taxonomy, $term_id) {
            if ($taxonomy && $term_id) {
                $url = get_term_feed_link($term_id, $taxonomy, $this->slug);
            } else {
                $url = get_feed_link($this->slug);
            }

            return apply_filters('podlove_subscribe_url', $url);
        });
    }

    /**
     * Get subscribe URL for feed or show feed based on query vars.
     *
     * @return string
     */
    public function get_contextual_subscribe_url()
    {
        if ($show_tax_slug = get_query_var('shows')) {
            $show = get_term_by('slug', $show_tax_slug, 'shows');
            $taxonomy = 'shows';
            $term_id = $show->term_id;
        } else {
            $taxonomy = null;
            $term_id = null;
        }

        return $this->get_subscribe_url($taxonomy, $term_id);
    }

    /**
     * Build html link to subscribe.
     *
     * @return string
     */
    public function get_subscribe_link()
    {
        $url = $this->get_subscribe_url();

        return sprintf('<a href="%s">%s</a>', $url, $url);
    }

    public function get_redirect_url()
    {
        if (FeedProxy::is_enabled()) {
            return FeedProxy::get_proxy_url($this->get_contextual_subscribe_url());
        }

        return $this->redirect_url;
    }

    public function get_redirect_http_status_code()
    {
        // most HTTP/1.0 client's don't understand 307, so we fall back to 302
        if (FeedProxy::is_enabled()) {
            return $_SERVER['SERVER_PROTOCOL'] == 'HTTP/1.0' ? 302 : 307;
        }

        return $_SERVER['SERVER_PROTOCOL'] == 'HTTP/1.0' && $this->redirect_http_status == 307 ? 302 : $this->redirect_http_status;
    }

    public function is_redirect_enabled()
    {
        return FeedProxy::is_enabled() || (strlen($this->redirect_url) > 0 && $this->get_redirect_http_status_code() > 0);
    }

    /**
     * Build the title of the feed.
     */
    public function get_title()
    {
        $podcast = Podcast::get();

        if ($this->append_name_to_podcast_title) {
            return $podcast->title.' ('.$this->name.')';
        }

        return $podcast->title;
    }

    /**
     * Get title for browser feed discovery.
     *
     * This title is used by clients to show the user the subscribe option he
     * has. Therefore, the most obvious thing to do is to display the show
     * title and the file extension in paranthesis.
     *
     * Fallback to internal feed name.
     *
     * @return string
     */
    public function title_for_discovery()
    {
        return $this->with_blog_scope(function () {
            $podcast = Podcast::get();

            if (!$episode_asset = $this->episode_asset()) {
                return $this->name;
            }

            if (!$file_type = $episode_asset->file_type()) {
                return $this->name;
            }

            $file_extension = $file_type->extension;

            $title_template = is_feed() ? '%s (%s)' : __('Podcast Feed: %s (%s)', 'podcast');

            $title = sprintf($title_template, $podcast->title, $this->name);

            return apply_filters('podlove_feed_title_for_discovery', $title, $this->title, $file_extension, $this->id);
        });
    }

    /**
     * Find the related episode asset model.
     *
     * @return null|\Podlove\Model\EpisodeAsset
     */
    public function episode_asset()
    {
        return $this->with_blog_scope(function () {
            return $this->episode_asset_id ? EpisodeAsset::find_by_id($this->episode_asset_id) : null;
        });
    }

    /**
     * Find all post_ids associated with this feed.
     *
     * @return array
     */
    public function post_ids()
    {
        global $wpdb;

        $allowed_status = ['publish'];
        $allowed_status = apply_filters('podlove_feed_post_ids_allowed_status', $allowed_status);

        $sql = '
			SELECT
				p.ID
			FROM
				'.$wpdb->posts.' p
				INNER JOIN '.Episode::table_name().' e ON e.post_id = p.ID
				INNER JOIN '.MediaFile::table_name().' mf ON mf.`episode_id` = e.id
				INNER JOIN '.EpisodeAsset::table_name().' a ON a.id = mf.`episode_asset_id`
			WHERE
				a.id = %d
				AND
				p.post_status IN ('.implode(',', array_map(function ($s) {
            return "'{$s}'";
        }, $allowed_status)).')
			ORDER BY
				p.post_date DESC
		';

        return $wpdb->get_col(
            $wpdb->prepare(
                $sql,
                $this->episode_asset()->id
            )
        );
    }

    public function get_content_type()
    {
        return 'application/rss+xml';
    }

    public function get_feed_self_link()
    {
        $href = $this->get_contextual_subscribe_url();

        $current_page = (get_query_var('paged')) ? get_query_var('paged') : 1;
        if ($current_page > 1) {
            $href .= '?paged='.$current_page;
        }

        return self::get_link_tag([
            'prefix' => 'atom',
            'rel' => 'self',
            'type' => $this->get_content_type(),
            'title' => \Podlove\Feeds\prepare_for_feed($this->title_for_discovery()),
            'href' => $href,
        ]);
    }

    public function get_alternate_links()
    {
        $html = '';
        foreach (self::find_all_by_discoverable(1) as $feed) {
            if ($feed->id !== $this->id) {
                $html .= "\n\t".self::get_link_tag([
                    'prefix' => 'atom',
                    'rel' => 'alternate',
                    'type' => $feed->get_content_type(),
                    'title' => \Podlove\Feeds\prepare_for_feed($feed->title_for_discovery()),
                    'href' => $feed->get_contextual_subscribe_url(),
                ]);
            }
        }

        return apply_filters('podlove_feed_alternate_links', $html);
    }

    public static function get_link_tag($args = [])
    {
        $defaults = [
            'prefix' => null,
            'rel' => 'alternate',
            'type' => 'application/atom+xml',
            'title' => '',
            'href' => '',
        ];
        $args = wp_parse_args($args, $defaults);

        $tag_name = $args['prefix'] ? $args['prefix'].':link' : 'link';

        return sprintf(
            '<%s%s%s%s href="%s" />',
            $tag_name,
            $args['rel'] ? ' rel="'.$args['rel'].'"' : '',
            $args['type'] ? ' type="'.$args['type'].'"' : '',
            $args['title'] ? ' title="'.$args['title'].'"' : '',
            $args['href']
        );
    }

    /**
     * Get the SQL LIMIT segment for this feed.
     *
     * Depending on settings it can be LIMIT <num> or empty.
     *
     * @param mixed $posts_per_page
     *
     * @return string
     */
    public function get_post_limit_sql($posts_per_page = false)
    {
        if ($posts_per_page === false) {
            $posts_per_page = (int) $this->limit_items;
        }

        if ($posts_per_page === self::ITEMS_WP_LIMIT) {
            $posts_per_page = (int) get_option('posts_per_rss');
        }

        if ($posts_per_page > 0) {
            return $posts_per_page;
        }

        // no limit
        if ($posts_per_page === self::ITEMS_NO_LIMIT) {
            return '';
        }

        if ($posts_per_page === self::ITEMS_GLOBAL_LIMIT) {
            $podcast = Podcast::get();
            if ((int) $podcast->limit_items !== self::ITEMS_GLOBAL_LIMIT) {
                return $this->get_post_limit_sql($podcast->limit_items);
            }
        }

        // default to no limit; however, this should never happen
        return '';
    }

    public static function find_duplicate_slugs()
    {
        global $wpdb;

        $sql = '
		SELECT slug, GROUP_CONCAT(`id`) ids, COUNT(*) cnt
		FROM '.self::table_name().'
		GROUP BY slug
		HAVING cnt > 1';

        if (!$rows = $wpdb->get_results($sql, ARRAY_A)) {
            return [];
        }

        return array_map(function ($row) {
            return [
                'slug' => $row['slug'],
                'feed_ids' => explode(',', $row['ids']),
            ];
        }, $rows);
    }
}

Feed::property('id', 'INT NOT NULL AUTO_INCREMENT PRIMARY KEY');
Feed::property('episode_asset_id', 'INT');
Feed::property('itunes_feed_id', 'INT');
Feed::property('name', 'VARCHAR(255)');
Feed::property('title', 'VARCHAR(255)');
Feed::property('slug', 'VARCHAR(255)');
Feed::property('position', 'FLOAT');
Feed::property('redirect_url', 'VARCHAR(255)');
Feed::property('redirect_http_status', 'INT');
Feed::property('enable', 'INT');
Feed::property('discoverable', 'INT');
Feed::property('limit_items', 'INT');
Feed::property('embed_content_encoded', 'INT');
Feed::property('append_name_to_podcast_title', 'TINYINT(1)');
Feed::property('protected', 'TINYINT(1)');
Feed::property('protection_type', 'TINYINT(1)'); // Protection type: 0: local, 1: WordPress User
Feed::property('protection_user', 'VARCHAR(60)');
Feed::property('protection_password', 'VARCHAR(64)');