PHP 多端同步聊天系统.zip

<?php namespace App; /* This class is handling all the ajax requests */ class ajaxController{ function __construct() { // Verify CSFR if ($_SERVER['REQUEST_METHOD'] === 'POST') { if(! app('csfr')->verifyToken(SECRET_KEY) ){ header('HTTP/1.0 403 Forbidden'); exit(); } } } // Saving received messages public function save_message(){ $post_data = app('request')->body; $profanity_found = false; if (in_array($post_data['message_type'], array(2,6,7))) { $message_content = app('purify')->xss_clean($post_data['message_content']); }elseif ($post_data['message_type'] == 8) { $content = json_decode($post_data['message_content'], true); if (in_array($content['new_message']['new_type'], array(2,6,7))) { $content['new_message']['new_content'] = app('purify')->xss_clean($content['new_message']['new_content']); $message_content = json_encode($content); }else if ($content['new_message']['new_type'] == 1) { preg_match('/\b(?:(?:https?):\/\/|www\.)[-a-z0-9+&@#\/%?=~_|!:,.;]*[-a-z0-9+&@#\/%=~_|]/i', $content['new_message']['new_content'], $message_links); if (!empty($message_links[0])) { $url_data = get_url_data($message_links[0]); $url_data['url'] = $message_links[0]; $link_message_content = array(); $link_message_content['message'] = app('purify')->xss_clean($content['new_message']['new_content']); $content['new_message']['new_content'] = array_merge($link_message_content,$url_data); $content['new_message']['new_type'] = 5; $message_content = json_encode($content,JSON_UNESCAPED_UNICODE); }else{ // Check profanity if (isset(SETTINGS['profanity_filter']) && SETTINGS['profanity_filter'] == true) { $message_content_filtered = profanity_filter($content['new_message']['new_content']); if ($message_content_filtered != $content['new_message']['new_content']) { $content['new_message']['new_content'] = $message_content_filtered; $profanity_found = true; } } $content['new_message']['new_content'] = app('purify')->xss_clean(clean($content['new_message']['new_content'])); $message_content = json_encode($content); } }else{ $content['new_message']['new_content'] = app('purify')->xss_clean(clean($content['new_message']['new_content'])); $message_content = json_encode($content); } }else{ $message_content = app('purify')->xss_clean(clean($post_data['message_content'])); } // Check profanity if(!in_array($post_data['message_type'], array(2,6,7,8))){ if (isset(SETTINGS['profanity_filter']) && SETTINGS['profanity_filter'] == true) { $message_content_filtered = profanity_filter($message_content); if ($message_content_filtered != $message_content) { $message_content = $message_content_filtered; $profanity_found = true; } } } // get links inside message if ($post_data['message_type'] == 1) { preg_match('/\b(?:(?:https?):\/\/|www\.)[-a-z0-9+&@#\/%?=~_|!:,.;]*[-a-z0-9+&@#\/%=~_|]/i', $post_data['message_content'], $message_links); if (!empty($message_links[0])) { $url_data = get_url_data($message_links[0]); $url_data['url'] = $message_links[0]; $link_message_content = array(); $link_message_content['message'] = app('purify')->xss_clean($post_data['message_content']); $link_message_content = array_merge($link_message_content,$url_data); $message_content = json_encode($link_message_content,JSON_UNESCAPED_UNICODE); $post_data['message_type'] = 5; // message with links } } $chat_save = app('chat')->saveNewMessage( app('auth')->user()['id'], $message_content, app('purify')->xss_clean(clean($post_data['active_user'])), app('purify')->xss_clean(clean($post_data['active_group'])), app('purify')->xss_clean(clean($post_data['active_room'])), app('purify')->xss_clean(clean($post_data['message_type'])), app('purify')->xss_clean(clean($post_data['chat_meta_id'])) ); $chat_save['random_id'] = $post_data['random_id']; if ($profanity_found) { if ($post_data['message_type'] == 8){ $chat_save['profanity_filtered'] = json_decode($message_content, true)['new_message']['new_content']; }else{ $chat_save['profanity_filtered'] = $message_content; } }else{ $chat_save['profanity_filtered'] = null; } return json_response($chat_save); } // main heartbeat function to keep the chat alive. public function heartbeat(){ $last_seen_data = Array ( 'last_seen' => app('db')->now()); app('db')->where ('id', app('auth')->user()['id']); app('db')->update ('users', $last_seen_data); $post_data = app('request')->body; $data = array(); if($post_data['active_user']) { if($post_data['active_user'] > app('auth')->user()['id']) { $user_1 = app('auth')->user()['id']; $user_2 = $post_data['active_user']; }else{ $user_1 = $post_data['active_user']; $user_2 = app('auth')->user()['id']; } $data['chat_type'] = "user"; // get new messages app('db')->join("users u", "c.sender_id=u.id", "LEFT"); app('db')->where ('c.id', $post_data['last_chat_id'], ">"); app('db')->where ('c.user_1', $user_1); app('db')->where ('c.user_2', $user_2); app('db')->where ('c.room_id', $post_data['active_room']); app('db')->where ("c.sender_id != " . app('auth')->user()['id']); $chats = app('db')->get('private_chats c', null, 'c.*, u.user_name, u.first_name, u.avatar, "private" as chat_type'); $update_meta = array(); $update_meta['chat_meta_id'] = $post_data['chat_meta_id']; $update_meta['is_typing'] = $post_data['is_typing']; app('chat')->updateChatMetaData($update_meta); $active_user = app('auth')->user($post_data['active_user']); $last_seen = strtotime($active_user['last_seen']); $seconds10 = strtotime("-10 seconds"); //active user chat meta $active_user_chat_meta_data = app('chat')->getChatMetaData($post_data['active_user'], app('auth')->user()['id'], $post_data['active_room']); $data['last_seen'] = date('Y-m-d H:i:s', $last_seen); $data['seconds10'] = date('Y-m-d H:i:s', $seconds10); if($active_user_chat_meta_data['is_typing']){ $active_user = app('auth')->user($post_data['active_user']); if($last_seen > $seconds10){ $data['typing_user'] = "typing..."; }else{ $data['typing_user'] = 0; } }else{ $data['typing_user'] = 0; } $from_user_chat_meta_data = app('chat')->getChatMetaData(app('auth')->user()['