<?php

defined('BASEPATH') or exit('No direct script access allowed');

class Newsfeed_model extends App_Model
{
    public $post_likes_limit = 6;

    public $post_comment_likes_limit = 6;

    public $post_comments_limit = 6;

    public $newsfeed_posts_limit = 10;

    public function __construct()
    {
        parent::__construct();
    }

    /**
     * Stick post to top
     * @param  mixed $id post id
     * @return boolean
     */
    public function pin_post($id)
    {
        $this->db->where('postid', $id);
        $this->db->update(db_prefix() . 'newsfeed_posts', [
            'pinned'     => 1,
            'datepinned' => date('Y-m-d H:i:s'),
        ]);
        if ($this->db->affected_rows() > 0) {
            return true;
        }

        return false;
    }

    /**
     * Unpin post from top
     * @param  mixed $id post id
     * @return boolean
     */
    public function unpin_post($id)
    {
        $this->db->where('postid', $id);
        $this->db->update(db_prefix() . 'newsfeed_posts', [
            'pinned'     => 0,
            'datepinned' => null,
        ]);
        if ($this->db->affected_rows() > 0) {
            return true;
        }

        return false;
    }

    /**
     * Get post all attachments
     * @param  mxied $id post id
     * @return array
     */
    public function get_post_attachments($id, $images = false)
    {
        $this->db->where('rel_id', $id);
        $this->db->where('rel_type', 'newsfeed_post');
        if ($images == true) {
            $this->db->like('filetype', 'image');
        } else {
            $this->db->not_like('filetype', 'image');
        }

        return $this->db->get(db_prefix() . 'files')->result_array();
    }

    /**
     * Get all post likes
     * @param  mixed $id post id
     * @return array
     */
    public function get_post_likes($id)
    {
        $this->db->select();
        $this->db->from(db_prefix() . 'newsfeed_post_likes');
        $this->db->join(db_prefix() . 'staff', db_prefix() . 'staff.staffid = ' . db_prefix() . 'newsfeed_post_likes.userid', 'left');
        $this->db->where('userid !=', get_staff_user_id());
        $this->db->where('postid', $id);
        $this->db->order_by('dateliked', 'asc');

        return $this->db->get()->result_array();
    }

    /**
     * Get post likes - used in modal with loading data
     * @param  mixed $offset page
     * @param  mixed $postid post id
     * @return array
     */
    public function load_likes_modal($offset, $postid)
    {
        $offset = ($offset * $this->post_likes_limit);
        $this->db->where('postid', $postid);
        $this->db->order_by('dateliked', 'desc');
        $this->db->limit($this->post_likes_limit, $offset);

        return $this->db->get(db_prefix() . 'newsfeed_post_likes')->result_array();
    }

    /**
     * Get post comments - used in modal with loading data
     * @param  mixed $offset page
     * @param  mixed $commentid commentid id
     * @return array
     */
    public function load_comment_likes_model($offset, $commentid)
    {
        $offset = ($offset * $this->post_comment_likes_limit);
        $this->db->where('commentid', $commentid);
        $this->db->order_by('dateliked', 'desc');
        $this->db->limit($this->post_comment_likes_limit, $offset);

        return $this->db->get(db_prefix() . 'newsfeed_comment_likes')->result_array();
    }

    /**
     * Load news feed / home
     * @param  mixed $offset page
     * @return array
     */
    public function load_newsfeed($offset, $post_id = '')
    {
        $offset = ($offset * $this->newsfeed_posts_limit);

        $this->db->order_by('datecreated', 'desc');
        if ($post_id != '') {
            $this->db->where('postid', $this->input->post('postid'));
        } else {
            $this->db->where('pinned', 0);
            $this->db->limit($this->newsfeed_posts_limit, $offset);
        }

        return $this->db->get(db_prefix() . 'newsfeed_posts')->result_array();
    }

    /**
     * Get all sticked posts to top
     * @return array
     */
    public function get_pinned_posts()
    {
        $this->db->where('pinned', 1);
        $this->db->order_by('datepinned', 'asc');

        return $this->db->get(db_prefix() . 'newsfeed_posts')->result_array();
    }

    /**
     * Get post single post by id
     * @param  mixed $id postid
     * @return object
     */
    public function get_post($id)
    {
        $this->db->where('postid', $id);

        return $this->db->get(db_prefix() . 'newsfeed_posts')->row();
    }

    /**
     * Get post comment by id
     * @param  mixed $id comment id
     * @return objetc
     */
    public function get_comment($id, $return_as_array = false)
    {
        $this->db->where('id', $id);
        if ($return_as_array == false) {
            return $this->db->get(db_prefix() . 'newsfeed_post_comments')->row();
        }

        return $this->db->get(db_prefix() . 'newsfeed_post_comments')->row_array();
    }

    /**
     * Add new post to database
     * @param array $data post data
     */
    public function add($data)
    {
        unset($data['null']);
        $data['datecreated'] = date('Y-m-d H:i:s');
        $data['content']     = nl2br($data['content']);
        $data['creator']     = get_staff_user_id();


        if (!isset($data['visibility'])) {
            $data['visibility'] = 'all';
        } else {
            $data['visibility'] = implode(':', $data['visibility']);
        }
        $this->db->insert(db_prefix() . 'newsfeed_posts', $data);
        $postid = $this->db->insert_id();


        $this->load->model('departments_model');
        $this->load->model('staff_model');

        $staff = $this->staff_model->get('', [
            'active'       => 1,
            'is_not_staff' => 0,
        ]);
        $notifiedUsers = [];
        foreach ($staff as $member) {
            $staff_deparments = $this->departments_model->get_staff_departments($member['staffid'], true);
            $visibility       = explode(':', $data['visibility']);
            if ($visibility[0] != 'all') {
                for ($i = 0; $i < count($visibility); $i++) {
                    if (!in_array($visibility[$i], $staff_deparments)) {
                        // Allow admin to view all posts
                        if (!is_admin($member['staffid'])) {
                            continue 2;
                        }
                    }
                }
            }

            if ($data['creator'] != $member['staffid']) {
                $notified = add_notification([
                    'description' => 'not_published_new_post',
                    'touserid'    => $member['staffid'],
                    'link'        => '#postid=' . $postid,
                ]);

                if ($notified) {
                    array_push($notifiedUsers, $member['staffid']);
                }
            }
        }

        pusher_trigger_notification($notifiedUsers);

        return $postid;
    }

    /**
     * Like post
     * @param  mixed $id postid
     * @return boolean
     */
    public function like_post($id)
    {
        if ($this->user_liked_post($id)) {
            return true;
        }
        $this->db->insert(db_prefix() . 'newsfeed_post_likes', [
            'postid'    => $id,
            'userid'    => get_staff_user_id(),
            'dateliked' => date('Y-m-d H:i:s'),
        ]);
        $likeid = $this->db->insert_id();
        if ($likeid) {
            $post = $this->get_post($id);
            if ($post->creator != get_staff_user_id()) {
                $notified = add_notification([
                    'description'     => 'not_liked_your_post',
                    'touserid'        => $post->creator,
                    'link'            => '#postid=' . $id,
                    'additional_data' => serialize([
                        get_staff_full_name(get_staff_user_id()),
                        strip_tags(mb_substr($post->content, 0, 50)),
                    ]),
                ]);
                if ($notified) {
                    pusher_trigger_notification([$post->creator]);
                }
            }

            return true;
        }

        return false;
    }

    /**
     * Unlike post
     * @param  mixewd $id post id
     * @return boolean
     */
    public function unlike_post($id)
    {
        $this->db->where('userid', get_staff_user_id());
        $this->db->where('postid', $id);
        $this->db->delete(db_prefix() . 'newsfeed_post_likes');
        if ($this->db->affected_rows() > 0) {
            return true;
        }

        return false;
    }

    /**
     * Unlike post comment
     * @param  mixed $id     commentid
     * @param  mixed $postid post id
     * @return boolean
     */
    public function unlike_comment($id, $postid)
    {
        $this->db->where('userid', get_staff_user_id());
        $this->db->where('commentid', $id);
        $this->db->where('postid', $postid);
        $this->db->delete(db_prefix() . 'newsfeed_comment_likes');
        if ($this->db->affected_rows() > 0) {
            return true;
        }

        return false;
    }

    /**
     * Check if current user liked post
     * @param  mixed $id post id
     * @return mixed
     */
    public function user_liked_post($id)
    {
        $this->db->where('userid', get_staff_user_id());
        $this->db->where('postid', $id);

        return $this->db->get(db_prefix() . 'newsfeed_post_likes')->row();
    }

    /**
     * Check if current user liked comment
     * @param  mixed $id comment id
     * @return mixed
     */
    public function user_liked_comment($id)
    {
        $this->db->where('userid', get_staff_user_id());
        $this->db->where('commentid', $id);

        return $this->db->get(db_prefix() . 'newsfeed_comment_likes')->row();
    }

    /**
     * Add new post comment
     * @param array $data comment data
     */
    public function add_comment($data)
    {
        $data['dateadded'] = date('Y-m-d H:i:s');
        $data['userid']    = get_staff_user_id();
        $data['content']   = nl2br($data['content']);
        $this->db->insert(db_prefix() . 'newsfeed_post_comments', $data);
        $insert_id = $this->db->insert_id();
        if ($insert_id) {
            $post = $this->get_post($data['postid']);
            if ($post->creator != get_staff_user_id()) {
                $notified = add_notification([
                    'description'     => 'not_commented_your_post',
                    'touserid'        => $post->creator,
                    'link'            => '#postid=' . $data['postid'],
                    'additional_data' => serialize([
                        get_staff_full_name(get_staff_user_id()),
                        substr($post->content, 0, 50),
                    ]),
                ]);
                if ($notified) {
                    pusher_trigger_notification([$post->creator]);
                }
            }

            return $insert_id;
        }

        return false;
    }

    /**
     * Like post comment
     * @param  mixed $id     comment id
     * @param  mixed $postid post id
     * @return mixed
     */
    public function like_comment($id, $postid)
    {
        if ($this->user_liked_comment($id)) {
            return;
        }
        $data['dateliked'] = date('Y-m-d H:i:s');
        $data['userid']    = get_staff_user_id();
        $data['commentid'] = $id;
        $data['postid']    = $postid;
        $this->db->insert(db_prefix() . 'newsfeed_comment_likes', $data);
        if ($this->db->affected_rows() > 0) {
            $comment = $this->get_comment($id);
            if ($comment->userid != get_staff_user_id()) {
                $notified = add_notification([
                    'description'     => 'not_liked_your_comment',
                    'touserid'        => $comment->userid,
                    'link'            => '#postid=' . $postid,
                    'additional_data' => serialize([
                        get_staff_full_name(get_staff_user_id()),
                        substr($comment->content, 0, 50),
                    ]),
                ]);
                if ($notified) {
                    pusher_trigger_notification([$comment->userid]);
                }
            }

            return true;
        }

        return false;
    }

    /**
     * Remove post comment from database
     * @param  mixed $id     comment id
     * @param  mixed $postid post id
     * @return boolean
     */
    public function remove_post_comment($id, $postid)
    {
        // First check if this user created the comment
        if (total_rows(db_prefix() . 'newsfeed_post_comments', [
            'postid' => $postid,
            'userid' => get_staff_user_id(),
            'id' => $id,
        ]) > 0) {
            $this->db->where('id', $id);
            $this->db->where('postid', $postid);
            $this->db->where('userid', get_staff_user_id());
            $this->db->delete(db_prefix() . 'newsfeed_post_comments');
            if ($this->db->affected_rows() > 0) {
                return true;
            }

            return false;
        }

        return false;
    }

    /**
     * Delete all and all connections
     * @param  mixed $postid post id
     * @return boolean
     */
    public function delete_post($postid)
    {
        // First check if this user creator of the post
        if (total_rows(db_prefix() . 'newsfeed_posts', [
            'postid' => $postid,
            'creator' => get_staff_user_id(),
        ]) > 0 || is_admin()) {
            $this->db->where('postid', $postid);
            $this->db->delete(db_prefix() . 'newsfeed_posts');
            if ($this->db->affected_rows() > 0) {
                $this->db->where('postid', $postid);
                $this->db->delete(db_prefix() . 'newsfeed_post_likes');

                $this->db->where('postid', $postid);
                $this->db->delete(db_prefix() . 'newsfeed_post_comments');

                $this->db->where('postid', $postid);
                $this->db->delete(db_prefix() . 'newsfeed_comment_likes');

                $this->db->where('rel_id', $postid);
                $this->db->where('rel_type', 'newsfeed_post');
                $this->db->delete(db_prefix() . 'files');

                if (is_dir(get_upload_path_by_type('newsfeed') . $postid)) {
                    delete_dir(get_upload_path_by_type('newsfeed') . $postid);
                }

                return true;
            }
        }

        return false;
    }

    /**
     * Get all comments from post / using loader
     * @param  mixed $postid psot id
     * @param  mixed $offset page
     * @return array
     */
    public function get_post_comments($postid, $offset)
    {
        $this->db->where('postid', $postid);
        $this->db->order_by('dateadded', 'desc');
        $offset = ($offset * $this->post_comments_limit);
        $this->db->limit($this->post_comments_limit, $offset);

        return $this->db->get(db_prefix() . 'newsfeed_post_comments')->result_array();
    }
}