<?php
class TagSubscription extends Rails\ActiveRecord\Base
{
    protected function associations()
    {
        return [
            'belongs_to' => [
                'user'
            ]
        ];
    }

    protected function callbacks()
    {
        return [
            'before_save' => [
                'normalize_name'
            ],
            'before_create' => [
                'initialize_post_ids'
            ]
        ];
    }

    protected function scopes()
    {
        return [
            'visible' => function() {
                $this->where(['is_visible_on_profile' => true]);
            }
        ];
    }

    public function normalize_name()
    {
        /**
         * MI: \P{Word} doesn't exist in PHP so I used \P{L}, which matches a single letter.
         * In order for \P{L} to work, I had to use mb_conver_encoding
         * which splits a single mb character into two, thus the second replace.
         */
        $this->name = preg_replace(['/\P{L}/', '/_{2,}/'], '_', mb_convert_encoding($this->name, 'ISO-8859-2'));
    }

    public function initialize_post_ids()
    {
        if ($this->user->is_privileged_or_higher()) {
            $this->cached_post_ids = join(',', array_unique(Post::find_by_tags($this->tag_query, ['limit' => ceil(CONFIG()->tag_subscription_post_limit / 3), 'select' => 'p.id', 'order' => 'p.id desc'])->getAttributes('id')));
        }
    }

    static public function find_post_ids($user_id, $name = null, $limit = null)
    {
        if (!$limit) {
            $limit = CONFIG()->tag_subscription_post_limit;
        }

        $post_ids = self::select('cached_post_ids')->where(['user_id' => $user_id]);
        if ($name) {
            $post_ids->where('name LIKE ?', $name . '%');
        }
        $post_ids = $post_ids->take();

        $parsed_ids = [];
        foreach ($post_ids as $subs) {
            $ids = explode(',', $subs->cached_post_ids);
            foreach ($ids as &$id) {
                $id = (int)$id;
            }
            $parsed_ids = array_merge($parsed_ids, $ids);
        }
        sort($parsed_ids);

        return array_slice(array_reverse(array_unique($parsed_ids)), 0, $limit);
    }

    static public function find_posts($user_id, $name = null, $limit = null)
    {
        return Post::available()->where('id IN (?)', self::find_post_ids($user_id, $name, $limit))->order('id DESC')->take();
    }

    static public function process_all()
    {
        foreach (self::all() as $tag_subscription) {
            if ($tag_subscription->user->is_privileged_or_higher()) {
                try {
                    self::transaction(function() use ($tag_subscription) {
                        $tags = preg_split('/\s+/', $tag_subscription->tag_query);
                        $post_ids = [];
                        foreach ($tags as $tag) {
                            $post_ids = array_merge(
                                $post_ids,
                                Post::find_by_tags(
                                    $tag,
                                    [
                                        'limit' => ceil(CONFIG()->tag_subscription_post_limit / 3),
                                        'select' => 'p.id',
                                        'order' => 'p.id desc'
                                    ]
                                )->getAttributes('id')
                            );
                        }
                        sort($post_ids);
                        $tag_subscription->updateAttribute('cached_post_ids', join(',', array_unique(array_slice(array_reverse($post_ids), 0, CONFIG()->tag_subscription_post_limit))));
                    });
                } catch (Exception $e) {
                    # fail silently
                    Rails::log()->exception($e);
                }
                sleep(1);
            }
        }
    }
}