<?php

/**
 * All AJax requests which does not fall in other categories or files
 * are saved here
 * 
 * @author Arslan Hassan
 * @license AAL
 * @since 3.0 
 */
include("../includes/config.inc.php");


//Getting mode..
$mode = $_POST['mode'];

$mode = mysql_clean($mode);


switch ($mode)
{

    //Rating function works with every object in similar manner therefore
    //Using the same code in different files we are using it here...
    case "rating":
        {

            $type = mysql_clean(post('type'));
            $id = mysql_clean(post('id'));
            $rating = mysql_clean(post('rating'));

            switch ($type)
            {
                case "video":
                    {
                        $result = $cbvid->rate_video($id, $rating);
                        echo showRating($result, $type);
                    }
                    break;

                case "photo":
                    {
                        $rating = $_POST['rating'] * 2;
                        $id = $_POST['id'];
                        $result = $cbphoto->rate_photo($id, $rating);
                        $result['is_rating'] = true;
                        $cbvid->show_video_rating($result);

                        $funcs = cb_get_functions('rate_photo');
                        if ($funcs)
                            foreach ($funcs as $func)
                            {
                                $func['func']($id);
                            }
                    }
                    break;
                case "collection":
                    {
                        $rating = $_POST['rating'] * 2;
                        $id = $_POST['id'];
                        $result = $cbcollection->rate_collection($id, $rating);
                        $result['is_rating'] = true;
                        $cbvid->show_video_rating($result);

                        $funcs = cb_get_functions('rate_collection');
                        if ($funcs)
                            foreach ($funcs as $func)
                            {
                                $func['func']($id);
                            }
                    }
                    break;

                case "user":
                    {
                        $rating = $_POST['rating'] * 2;
                        $id = $_POST['id'];
                        $result = $userquery->rate_user($id, $rating);
                        $result['is_rating'] = true;
                        $cbvid->show_video_rating($result);

                        $funcs = cb_get_functions('rate_user');
                        if ($funcs)
                            foreach ($funcs as $func)
                            {
                                $func['func']($id);
                            }
                    }
                    break;
            }
        }
        break;


    case "create_playlist":
        {
            $array = array(
                'name',
                'description',
                'tags',
                'playlist_type',
                'privacy',
                'allow_comments',
                'allow_rating',
                'type',
            );

            $type = post('type');

            $input = array();
            foreach ($array as $ar)
            {
                $input[$ar] = mysql_clean(post($ar));
            }


            if ($type == 'v')
                $pid = $cbvid->action->create_playlist($input);

            if (!$type)
                e(lang("Invalid playlist type"));

            if (error())
            {
                echo json_encode(array('err' => error(), 'rel' => get_rel_list()));
            }
            else
            {
                $playlist = $cbvid->action->get_playlist($pid);
                assign('playlist', $playlist);
                if (post('oid'))
                    assign('oid', post('oid'));
                assign('type', post('type'));

                $template = Fetch('blocks/playlist.html');
                $ul_template = fetch('blocks/playlist-ul.html');
                echo json_encode(array('success' => 'yes', 'rel' => get_rel_list(),
                    'template' => $template, 'pid' => $pid, 'ul_template' => $ul_template,
                    'msg' => msg()));
            }
        }
        break;

    case "delete_playlist":
        {
            $pid = mysql_clean(post('pid'));
            $cbvid->action->delete_playlist($pid);

            if (error())
            {
                echo json_encode(array('err' => error()));
            }
            else
            {
                echo json_encode(array('msg' => array(lang('Playlist has been removed'))));
            }
        }
        break;

    case "add_playlist_item":
        {

            $type = post('v');
            $pid = mysql_clean(post('pid'));
            $id = mysql_clean(post('oid'));
            // $note = mysql_clean(post('note'));

            switch ($type)
            {
                case 'v':
                default:
                    {
                        $item_id = $cbvid->action->add_playlist_item($pid, $id);

                        if (!error())
                        {
                            updateObjectStats('plist', 'video', $id);
                            echo json_encode(array('status' => 'ok',
                                'msg' => msg(), 'item_id' => $item_id, 'updated' => nicetime(now())));
                        }
                        else
                        {
                            echo json_encode(array('err' => error()));
                        }
                    }
            }
        }
        break;

    case "update_playlist_order":
        {
            $pid = mysql_clean(post('playlist_id'));
            $items = post('playlist_item');
            $items = array_map('mysql_clean', $items);

            $cbvid->action->update_playlist_order($pid, $items);

            if (error())
                echo json_encode(array('err' => error()));
            else
                echo json_encode(array('success' => 'yes'));
        }
        break;

    case "save_playlist_item_note":
        {
            $item_id = mysql_clean(post('item_id'));
            $text = mysql_clean(post('text'));

            $cbvid->action->save_playlist_item_note($item_id, $text);

            if (error())
            {
                echo json_encode(array('err' => error()));
            }
            else
            {
                echo json_encode(array('msg' => msg()));
            }
        }
        break;


    case "remove_playlist_item":
        {
            $item_id = mysql_clean(post('item_id'));
            $cbvid->action->delete_playlist_item($item_id);
            if (error())
                echo json_encode(array('err' => error()));
            else
                echo json_encode(array('success' => 'ok'));
        }
        break;

    case 'add_comment';
        {
            $type = $_POST['type'];
            switch ($type)
            {
                case 'v':
                case 'video':
                default:
                    {
                        $id = mysql_clean($_POST['obj_id']);
                        $comment = $_POST['comment'];
                        if ($comment == 'undefined')
                            $comment = '';
                        $reply_to = $_POST['reply_to'];

                        $cid = $cbvid->add_comment($comment, $id, $reply_to);
                    }
                    break;
                case 'u':
                case 'c':
                    {

                        $id = mysql_clean($_POST['obj_id']);
                        $comment = $_POST['comment'];
                        if ($comment == 'undefined')
                            $comment = '';
                        $reply_to = $_POST['reply_to'];

                        $cid = $userquery->add_comment($comment, $id, $reply_to);
                    }
                    break;
                case 't':
                case 'topic':
                    {

                        $id = mysql_clean($_POST['obj_id']);
                        $comment = $_POST['comment'];
                        if ($comment == 'undefined')
                            $comment = '';
                        $reply_to = $_POST['reply_to'];

                        $cid = $cbgroup->add_comment($comment, $id, $reply_to);
                    }
                    break;

                case 'cl':
                case 'collection':
                    {
                        $id = mysql_clean($_POST['obj_id']);
                        $comment = $_POST['comment'];
                        if ($comment == 'undefined')
                            $comment = '';
                        $reply_to = $_POST['reply_to'];

                        $cid = $cbcollection->add_comment($comment, $id, $reply_to);
                    }
                    break;

                case "p":
                case "photo":
                    {
                        $id = mysql_clean($_POST['obj_id']);
                        $comment = $_POST['comment'];
                        if ($comment == 'undefined')
                            $comment = '';
                        $reply_to = $_POST['reply_to'];
                        $cid = $cbphoto->add_comment($comment, $id, $reply_to);
                    }
                    break;
            }


            if (error())
            {
                exit(json_encode(array('err' => error())));
            }

            $comment = $myquery->get_comment($cid);
            assign('comment', $comment);

            if ($type == 't')
                $template = get_template('single_comment');
            else
                $template = get_template('single_topic');

            $array = array(
                'msg' => msg(),
                'comment' => $template,
                'success' => 'ok',
                'cid' => $cid
            );

            echo json_encode($array);
        }
        break;

    case "get_comments":
        {
            $params = array();
            $limit = config('comments_per_page');
            $page = $_POST['page'];
            $params['type'] = mysql_clean($_POST['type']);
            $params['type_id'] = mysql_clean($_POST['type_id']);
            $params['last_update'] = mysql_clean($_POST['last_update']);
            $params['limit'] = create_query_limit($page, $limit);

            $admin = "";
            if ($_POST['admin'] == 'yes' && has_access('admin_access', true))
            {
                $params['cache'] = 'no';
                $admin = "yes";
            }
            $comments = $myquery->getComments($params);
            //Adding Pagination
            $total_pages = count_pages($_POST['total_comments'], $limit);
            assign('object_type', mysql_clean($_POST['object_type']));
            //Pagination
            $pages->paginate($total_pages, $page, NULL, NULL, '<a href="javascript:void(0)" class="btn"
        onClick="get_comments(\'' . $params['type'] . '\',\'' . $params['type_id'] . '\',\'' . $params['last_update'] . '\',
        \'#page#\',\'' . $_POST['total_comments'] . '\',\'' . mysql_clean($_POST['object_type']) . '\',\'' . $admin . '\')">#page#</a>');

            assign('comments', $comments);
            assign('type', $params['type']);
            assign('type_id', $params['type_id']);
            assign('last_update', $params['last_update']);
            assign('total', $_POST['total_comments']);
            assign('total_pages', $total_pages);
            assign('comments_voting', $_POST['comments_voting']);

            if ($_POST['admin'] == 'yes' && has_access('admin_access', true))
            {
                Template(BASEDIR . '/' . ADMINDIR . '/' . TEMPLATEFOLDER . '/cbv3/layout/blocks/comments.html', false);
                exit();
            }
            else
            {
                if ($_POST['type'] == 't')
                {
                    $template = get_template('topics');
                }
                else
                {
                    $template = get_template('comments');
                }
            }

            assign('commentPagination', 'yes');

            $template .= get_template('pagination');

            echo json_encode(array('success' => 'yes', 'output' => $template));
        }
        break;


    case 'rate_comment':
        {
            $thumb = mysql_clean(post('thumb'));
            $cid = mysql_clean(post('cid'));

            if ($thumb != 'down')
                $rate = 1;
            else
                $rate = -1;

            $rating = $myquery->rate_comment($rate, $cid);

            if (error())
            {
                echo json_encode(array('err' => error()));
            }
            else
            {
                echo json_encode(array('success' => 'ok', 'msg' => msg(),
                    'rating' => comment_rating($rating)));
            }


            //updating last update...
            $type = mysql_clean($_POST['type']);
            $typeid = mysql_clean($_POST['typeid']);
            update_last_commented($type, $typeid);
        }
        break;
    case 'spam_comment':
    case 'unspam_comment':
        {
            $cid = mysql_clean($_POST['cid']);

            if ($mode == 'spam_comment')
                $rating = $myquery->spam_comment($cid);
            if ($mode == 'unspam_comment')
                $rating = $myquery->unspam_comment($cid);

            if (!error())
            {

                $type = mysql_clean($_POST['type']);
                $typeid = mysql_clean($_POST['typeid']);
                update_last_commented($type, $typeid);

                //Getting comment again..
                assign('type', $type);
                assign('type_id', $typeid);

                $new_com = $myquery->get_comment($cid);
                assign('comment', $new_com);

                $comment_template = get_template('single_comment');

                echo json_encode(array('success' => 'ok', 'msg' => msg()
                    , 'comment' => $comment_template));
            }
            else
            {
                echo json_encode(array('err' => error()));
            }
        }
        break;

    case 'delete_comment':
        {
            $type = $_POST['type'];
            switch ($type)
            {
                case 'v':
                case 'video':
                default:
                    {
                        $cid = mysql_clean($_POST['cid']);
                        $type_id = $myquery->delete_comment($cid);
                        $cbvid->update_comments_count($type_id);
                    }
                    break;
                case 'u':
                case 'c':
                    {
                        $cid = mysql_clean($_POST['cid']);
                        $type_id = $myquery->delete_comment($cid);
                        $userquery->update_comments_count($type_id);
                    }
                    break;
                case 't':
                case 'topic':
                    {
                        $cid = mysql_clean($_POST['cid']);
                        $type_id = $myquery->delete_comment($cid);
                        $cbgroup->update_comments_count($type_id);
                    }
                    break;
                case 'cl':
                case 'collection':
                    {
                        $cid = mysql_clean($_POST['cid']);
                        $type_id = $myquery->delete_comment($cid);
                        $cbcollection->update_total_comments($type_id);
                    }
            }

            if (!error())
            {
                echo json_encode(array(
                    'success' => 'ok',
                    'msg' => msg(),
                ));
            }
            else
            {
                echo json_encode(array('err' => error()));
            }
        }
        break;

    case 'share_object':
        {

            $type = strtolower($_POST['type']);
            switch ($type)
            {
                case 'v':
                case 'video':
                default:
                    {
                        $id = $_POST['id'];
                        $vdo = $cbvid->get_video($id);
                        $cbvid->set_share_email($vdo);
                        $cbvid->action->share_content($vdo['videoid']);
                        if (!error())
                        {
                            echo json_encode(array(
                                'success' => 'ok',
                                'msg' => msg(),
                            ));
                        }
                        else
                        {
                            echo json_encode(array('err' => error()));
                        }
                    }
                    break;

                case "p":
                case "photo":
                    {
                        $id = $_POST['id'];
                        $ph = $cbphoto->get_photo($id);
                        $cbphoto->set_share_email($ph);
                        $cbphoto->action->share_content($ph['photo_id']);
                        if (msg())
                        {
                            $msg = msg_list();
                            $msg = '<div class="msg">' . $msg[0] . '</div>';
                        }
                        if (error())
                        {
                            $msg = error_list();
                            $msg = '<div class="error">' . $msg[0] . '</div>';
                        }

                        echo $msg;
                    }
                    break;

                case "cl":
                case "collection":
                    {
                        $id = $_POST['id'];
                        $cl = $cbcollection->get_collection($id);
                        $cbcollection->set_share_mail($cl);
                        $cbcollection->action->share_content($cl['collection_id']);
                        if (msg())
                        {
                            $msg = msg_list();
                            $msg = '<div class="msg">' . $msg[0] . '</div>';
                        }
                        if (error())
                        {
                            $msg = error_list();
                            $msg = '<div class="error">' . $msg[0] . '</div>';
                        }

                        echo $msg;
                    }
                    break;
            }
        }
        break;

    case 'flag_object':
        {
            $type = strtolower($_POST['type']);
            switch ($type)
            {
                case 'v':
                case 'video':
                default:
                    {
                        $id = $_POST['id'];
                        $reported = $cbvideo->action->report_it($id);
                    }
                    break;

                case 'g':
                case 'group':
                default:
                    {
                        $id = $_POST['id'];
                        $cbgroup->action->report_it($id);
                    }
                    break;

                case 'u':
                case 'user':
                default:
                    {
                        $id = $_POST['id'];
                        $userquery->action->report_it($id);
                    }
                    break;

                case 'p':
                case 'photo':
                    {
                        $id = $_POST['id'];
                        $cbphoto->action->report_it($id);
                    }
                    break;

                case "cl":
                case "collection":
                    {
                        $id = $_POST['id'];
                        $cbcollection->action->report_it($id);
                    }
                    break;
            }

            if (msg())
            {
                $msg = msg_list();
                echo json_encode(array('success' => 'yes', 'msg' => $msg[0]));
            }
            if (error())
            {
                $msg = error_list();
                echo json_encode(array('err' => $msg[0]));
            }
        }
        break;


    case "get_friends":
        {
            $get_json_friends = $userquery->get_json_friends();
            echo $get_json_friends;
        }

        break;


    case "get_updates":
        {
            $uid = mysql_clean(post('userid'));
            if (!$uid)
                $uid = userid();

            $updates = $userquery->get_updates($uid);

            echo json_encode($updates);
        }
        break;


    case "read_notification":
        {

            //mark notifications read..
            $type = mysql_clean($_POST['type']);
            $uid = userid();
            if ($uid)
            {
                $userquery->read_notification($uid, $type);

                if ($type == 'notifications')
                    $cbfeeds->read_notification($uid);
            }

            //Makring friendship as seen
            if ($type == 'friends')
            {
                $userquery->mark_requests_seen($uid);
            }
        }

        break;

    case 'add_friend':
        {
            $friend = post('uid');
            $userid = userid();

            $message = post('message');

            if ($userid)
            {
                $userquery->add_friend_request(array(
                    'userid' => $userid,
                    'friend_id' => $friend,
                    'message' => $message
                ));

                if (msg())
                {
                    $msg = msg_list();
                    $msg = $msg[0];

                    echo json_encode(array('success' => 'ok', 'msg' => $msg));
                }
                if (error())
                {
                    $msg = error_list();

                    echo json_encode(array('error' => $msg));
                }
                $msg;
            }
            else
            {
                echo json_encode(array('error' => array(lang('You are not logged in'))));
            }
        }
        break;


    case 'confirm_friend':
        {
            $rid = $_POST['rid'];
            $uid = userid();
            $cid = $userquery->confirm_friend($uid, $rid);

            if (error())
            {
                $error = error('single');
                echo json_encode(array('err' => $error));
            }
            else
            {
                $msg = msg('single');
                echo json_encode(array('success' => 'yes', 'msg' => $msg, 'cid' => $cid));
            }

            exit();
        }
    case 'ignore_friend':
        {
            $rid = $_POST['rid'];
            $uid = userid();
            $cid = $userquery->ignore_friend($uid, $rid);

            if (error())
            {
                $error = error('single');
                echo json_encode(array('err' => $error));
            }
            else
            {
                $msg = msg('single');
                echo json_encode(array('success' => 'yes', 'msg' => $msg, 'cid' => $cid));
            }

            exit();
        }

    case "get_new_friends":
        {
            $uid = userid();
            $requests = $userquery->get_friend_requests($uid, array('seen' => 'no'));
            $userquery->mark_requests_seen($uid);
            $userquery->read_notification($uid, 'friends');

            if ($requests)
            {
                $requests_template = '';
                $the_requests = array();

                foreach ($requests as $request)
                {
                    $the_requests['ids'][] = $request['req_id'];

                    $template = assign('request', $request);
                    $requests_template .= get_template('friends_notifications_block');
                }

                $the_requests['template'] = $requests_template;
                $the_requests['new_requests'] = count($requests);

                if ($the_requests)
                    echo json_encode($the_requests);
            }
        }
        break;
    case "get_new_msgs":
        {
            $uid = userid();

            $threads = $cbpm->get_threads(array('unseen' => 'yes'));

            $cbpm->mark_messages_seen($uid);
            $userquery->read_notification($uid, 'msgs');

            if ($threads)
            {
                $thread_template = '';
                $the_threads = array();

                foreach ($threads as $thread)
                {
                    $the_threads['ids'][] = $thread['thread_id'];

                    $template = assign('thread', $thread);
                    $thread_template .= get_template('msgs_notifications_block');
                }

                $the_threads['template'] = $thread_template;
                $the_threads['new_requests'] = count($threads);

                if ($the_threads)
                    echo json_encode($the_threads);
            }
        }
        break;

    case "unfriend":
        {
            $fid = post('fid');
            $uid = userid();

            $userquery->unfriend($fid, $uid);

            if (error())
            {
                echo json_encode(array('err' => error()));
            }
            else
            {
                echo json_encode(array('success' => 'yes', 'msg' => msg()));
            }
        }
        break;


    case "send_message":
        {
            $msg = post('message');
            $tid = post('thread_id');
            $subj = post('subject');

            $mid = $cbpm->send_message(array(
                'message' => $msg,
                'thread_id' => $tid,
                'subject' => $suj
                    ));

            if (error())
            {
                echo json_encode(array('err' => error()));
            }
            else
            {
                $message = $userquery->udetails;
                $message['message_id'] = $mid;
                $message['message'] = message(strip_tags(replacer($msg)));
                $message['time_added'] = time();
                $message['thread_id'] = $tid;
                assign('message', $message);
                $template = get_template('single_message');
                echo json_encode(array('success' => 'yes', 'template' => $template));
            }
        }
        break;
        
        case "fetch_new_msgs":
        {
            $tid = post('thread_id');
            $time = post('time');
            
            $messages = $cbpm->get_new_messages(array(
                'thread_id' => $tid,
                'time'      => $time
            ));
            
            $the_array = array();
            $template = '';
            if($messages){
                foreach($messages as $msg)
                {
                    assign('message', $msg);
                    $template .= get_template('single_message');
                    $the_array['ids'][] = $msg['message_id'];
                }
                
                $the_array['time'] = time();
                $the_array['template'] = $template;
                
                echo json_encode($the_array);
            }
        }
        break;
    default:
        exit(json_encode(array('err' => array(lang('Invalid request')))));
}
?>