";
+
+ echo "
";
+ echo "";
+
+ echo "
";
+ echo "";
+echo "";
\ No newline at end of file
diff --git a/include/style/css/main.css b/include/style/css/main.css
new file mode 100644
index 0000000..69b90ac
--- /dev/null
+++ b/include/style/css/main.css
@@ -0,0 +1,9 @@
+#chat_container{
+ background-color: #0066ff;
+ height:550px;
+}
+
+
+.not_loaded{
+ display:none;
+}
\ No newline at end of file
diff --git a/include/style/js/main.js b/include/style/js/main.js
new file mode 100644
index 0000000..c409985
--- /dev/null
+++ b/include/style/js/main.js
@@ -0,0 +1,239 @@
+window.onload = start_chat;
+var wsr = null;
+var unsuccessfulLogin = 0;
+var config = [];
+var container = [];
+
+var AjaxRespond = (function() {
+ function AjaxRespond(obj) {
+ this.obj = obj;
+ }
+
+ AjaxRespond.prototype.toText = function() {
+ return this.obj.responseText;
+ };
+
+ AjaxRespond.prototype.toJson = function() {
+ return JSON.parse(this.toText());
+ };
+
+ AjaxRespond.prototype.toXml = function() {
+ return this.obj.responseXML;
+ };
+
+ return AjaxRespond;
+})();
+
+function appendTab(handler){
+ function createTab(handler){
+ var container = document.createElement("span");
+ container.className = "chat_tab";
+
+ if(typeof handler.icon !== "undefined"){
+ //append icon
+ var icon = document.createElement("img");
+ icon.className = "chat_tab_icon";
+ container.appendChild(icon);
+ }
+
+ //control for name
+ if(typeof handler.name !== "undefined"){
+ container.appendChild(document.createTextNode(handler.name));
+ }
+
+ //append it to the tab list
+ document.getElementById("chat_tap_container").appendChild(container);
+ }
+
+ //create tab
+ createTab(handler);
+}
+
+var ChannelHandler = (function(){
+ function ChannelHandler(name){
+ this.name = name;
+ appendTab(this);
+ //wee want to get a title on this channel :)
+ send("TITLE: "+this.name);
+ }
+
+ ChannelHandler.prototype.onBlur = function(){
+
+ };
+
+ ChannelHandler.prototype.onFocus = function(){
+
+ };
+
+ return ChannelHandler;
+})();
+
+function get(url, callback) {
+ var ajax = new XMLHttpRequest();
+ ajax.open("GET", url, true);
+ ajax.send();
+ ajax.onreadystatechange = function() {
+ if (this.readyState == 4 && this.status == 200) {
+ callback(new AjaxRespond(this));
+ }
+ }
+}
+
+function start_chat() {
+ console.log("Chat loading")
+ // wee send a get request to status.php to see what wee should do here :)
+ get("status.php", function(ajax) {
+ var json = ajax.toJson();
+ config = json["config"];
+ if (json['isWebSocket']) {
+ console.log("Chat connect to websocket");
+ startWebSocket(json["host"], json["port"]);
+ } else {
+
+ }
+ });
+}
+
+function startWebSocket(host, port) {
+ websocket = new WebSocket("ws://" + host + ":" + port);
+
+ websocket.onerror = function(evt) {
+ console.log(evt.data);
+ console.log("Error on websocket connecttion: "+evt.data);
+ };
+
+ websocket.onmessage = function(evt) {
+ handleMessage(evt.data);
+ };
+
+ websocket.onopen = function() {
+ console.log("WebSocket connection is now open");
+ init_server();
+ };
+
+ websocket.onclose = function() {
+ console.log("WebSocket connection is now closed");
+ };
+
+ wsr = websocket;
+}
+
+function cookie(name) {
+ var cookieParts = document.cookie.split(";");
+ for (i = 0; i < cookieParts.length; i++) {
+ var data = cookieParts[i].split("=");
+ if (data[0].trim() == name) {
+ return data[1].trim();
+ }
+ }
+
+ return null;
+}
+
+function init_server() {
+ var elemtns = document.getElementsByClassName("not_loaded");
+ for(var i=0;i
"
- + " ";
-
- this.getDom("channel_list").append(botton);
- };
-
- System.prototype.on_closhe_channel_botton = function(id){
- this.getDom("channel_botton").run(function(){
- if(this.attr("cid") === id){
- //vi har nu fået fat i den rigtige channel ;)
- var name = this.getObject().getElementsByClassName("channelNameContainer")[0].innerHTML;
- system.leave_channel(name);
- }
- })
- };
-
- System.prototype.leave_channel = function(name,send_leave,onKick){
- if(typeof send_leave === "undefined"){
- send_leave = true;
- }
-
- if(typeof onKick === "undefined"){
- onKick = false;
- }
-
- var is_botton_found = false;
- var cid = 1;//1 is system brodcast channel. (channel all message some is not in normaly channel get into)
-
- //vi fjerner knappen fra oversigten ;)
- this.getDom("channel_botton").run(function(){
- var bname = this.getObject().getElementsByClassName("channelNameContainer")[0].innerHTML;
- if(name == system.trim(bname)){
- cid = this.attr("cid");
- is_botton_found = this.remove();
- }
- });
-
- if(!is_botton_found){
- alert("Channel not found");
- return;
- }
-
- //vi tømmer cache
- this.get_object("cache").empty_cache(name,cid);
- this.channelCount--;
- //wee got now one less channel wee are in :D
-
- if(this.is_in_this_channel(name)){
- //vi fjerner nu cache af bruger i denne channel
- this.user_in_channel = [];
- //vi tømmer først main ;)
- this.getDom("main").empty();
- //tømmer bruger over sigten :)
- this.getDom("option").run(function(){
- if(this.attr("what") == system.option_name.online){
- this.empty();
- }
- });
- }
-
- if(send_leave){
- //jeg forstår det slet ikke hmm :(
- this.new_ajax_query({
- 'message' : '/leave',
- 'channel' : this.trim(name)
- },'server.php?userBlock=' + this.data.browserBlock+'&sort='+this.data.user.sort+"&li=" + this.get_last_id());
- }
-
- //og vi finder en ny channel at være i :)
- var has_found_new_channel = false;
- var change_to_name = null;
- var cid = 0;
- this.getDom("channel_botton").run(function(){
- change_to_name = this.getObject().getElementsByClassName("channelNameContainer")[0].innerHTML;
- cid = this.attr("cid");
- has_found_new_channel = true;
- });
-
- if(has_found_new_channel){
- this.switch_channel(change_to_name,cid);
- }else{
- if(onKick){
- if(name == this.start_channel()){
- this.chat_name = null;
- this.stop_chat();
- this.timer = null;
- return false;//vi er nu igang med at joine en automatisk kick Hmmmm ikke en god ide :D
- }
- }
- this.chat_name = null;//lige nu er vi jo ikke i en channel!
- //this.send_ping('/join '+this.start_channel(),'Bot'); //this is a bad idé :(
- }
-
- };
-
- System.prototype.switch_channel = function(name,cid){
- //vi kontrollere at vi ikke allerede er i den (spild af kræfter)
- if(this.is_in_this_channel(name)){
- return;
- }
-
- this.chat_name = name;
- this.u_num = 0;
-
-
- this.getDom("main").empty();
- this.getDom("option").run(function(){
- if(this.attr("what") == system.option_name.online){
- this.empty();
- }
- });
-
-
- this.re_paint_channel_botton(cid);
-
- this.user_in_channel = [];
-
- this.handle_in_message({
- 'message' : this.get_object("cache").get_message_in_channel(cid)
- },true);
-
- return;
-
- };
-
- System.prototype.show_user_menu = function(uid){
- this.getDom("user").run(function(){
-
- if(this.getObject().getElementsByClassName("user_menu")[0].style.display == 'block'){
- J(this.getObject().getElementsByClassName("user_menu")[0]).hide();
- return;
- }
-
- if(this.attr("uid") == uid){
- J(this.getObject().getElementsByClassName("user_menu")[0]).show();
- }else{
- J(this.getObject().getElementsByClassName("user_menu")[0]).hide();
- }
- });
- };
-
- System.prototype.add_user_in_user_list = function(img,nick,uid,inaktiv){
- this.user_in_channel.push(uid);
- this.getDom("option").run(function(){
- if(this.attr("what") == system.option_name.online){
- system.u_num++;
- var block = ""
- + "
"
- + "![]("+img+")
"
- + "
"
- + ""
- + (inaktiv == system.data.yesNo.yes ? '[i]' : '')+nick+(inaktiv == system.data.yesNo.yes ? '' : '')
- + "
"
- + ""
- + ""
- + "";
-
- this.append(block);
-
- return;
- }
- });
- };
-
- System.prototype.sendMessage = function(msg,channel){
- if(typeof channel === "undefined"){
- channel = this.chat_name;
- }
-
- this.new_ajax_query({
- 'message' : msg,
- 'channel' : channel
- },'server.php?userBlock=' + this.data.browserBlock+'&sort='+this.data.user.sort+"&li=" + this.get_last_id());
- }
-
- System.prototype.remove_user_from_online_list = function(nick){
- this.getDom("user").run(function(){
- if(system.is_num(nick)){
- if(nick == this.attr("uid")){
- this.remove();
- }
- }else{
- var u_nick = this.getObject().getElementsByClassName("u_nick")[0].innerHTML;
- if(u_nick == nick){
- this.remove();
- }
- }
- });
- };
-
- System.prototype.is_num = function(string){
- return /^[0-9]*?$/.test(string);
- };
-
- System.prototype.prepare_start_socket = function () {
- if (this.is_socket) {
- this.new_ajax_query({
- 'message': '/cookie ' + this.data.cookie,
- 'channel': 'Bot'
- });
- this.ping_socket();
- } else {
- this.is_socket = this.ajax[0].isOpen;
- if (!this.is_socket) {
- setTimeout(function () {
- system.prepare_start_socket();
- }, this.data.timer);
- } else {
- this.prepare_start_socket();
- }
- }
- };
-
- System.prototype.get_time = function () {
- var date = new Date();
- if (typeof this.user_config.time_format === "undefined") {
- this.user_config.time_format = "H:i";
- }
-
- var use = this.user_config.time_format;
-
- var w_zerro = function (int) {
- if (int < 10) {
- return "0" + int;
- } else {
- return int;
- }
- };
-
- var day_of_year = function () {
- var now = new Date();
- var start = new Date(now.getFullYear(), 0, 0);
- var diff = now - start;
- var oneDay = 1000 * 60 * 60 * 24;
- var day = Math.floor(diff / oneDay);
- return day;
- };
-
- var week_of_year = function () {
- var d = new Date(+d);
- d.setHours(0, 0, 0);
- d.setDate(d.getDate() + 4 - (d.getDay() || 7));
- var yearStart = new Date(d.getFullYear(), 0, 1);
- var weekNo = Math.ceil(( ( (d - yearStart) / 86400000) + 1) / 7);
- return weekNo;
- };
-
- var h = date.getHours();
-
- //Day
- use = use.replace(/d/g, w_zerro(date.getDate()));
- use = use.replace(/D/g, this.get_lang().day_short[date.getDay()]);
- use = use.replace(/j/g, date.getDate());
- use = use.replace(/l/g, this.get_lang().day_long[date.getDay()]);
- use = use.replace(/N/g, (date.getDay() + 1));
- //s not supportet
- use = use.replace(/w/g, date.getDay());
- use = use.replace(/z/g, day_of_year());
-
- //Week
- use = use.replace(/W/g, week_of_year());
-
- //Month
- use = use.replace(/F/g, this.get_lang().month_long[date.getMonth()]);
- use = use.replace(/m/g, w_zerro((date.getMonth() + 1)));
- use = use.replace(/M/g, this.get_lang().months_short[date.getMonth()]);
- use = use.replace(/n/g, (date.getMonth() + 1));
- use = use.replace(/t/g, date.getDate());
-
- //Year
- use = use.replace(/L/g, (((date.getFullYear() % 4 == 0) && (date.getFullYear() % 100 != 0)) || (date.getFullYear() % 400 == 0) ? 1 : 0));
- //o not supportet
- use = use.replace(/Y/g, date.getFullYear());
- var fy = new String(date.getFullYear());
- use = use.replace(/y/g, fy.substring(2, 4));
-
- //Time
- use = use.replace(/a/g, (date.getHours() < 12 ? "am" : "pm"));
- use = use.replace(/A/g, (date.getHours() < 12 ? "AM" : "PM"));
- use = use.replace(/B/g, date.getMilliseconds());
- use = use.replace(/g/g, (h > 12 ? h - 12 : h));
- use = use.replace(/G/g, date.getHours());
- use = use.replace(/h/g, (h > 12 ? w_zerro((h - 12)) : w_zerro(h)));
- use = use.replace(/H/g, w_zerro(date.getHours()));
- use = use.replace(/i/g, w_zerro(date.getMinutes()));
- use = use.replace(/s/g, w_zerro(date.getSeconds()));
- use = use.replace(/u/g, date.getTime());
-
- //TimeZone not supportet ;)
-
- return use;
- };
-
- System.prototype.setSmylie = function (smy_name, smy_tag, smy_url, smy_reg_tag) {
- this.smylie[this.smylie.length] = {
- 'smy_name' : smy_name,
- 'smy_tag' : smy_tag,
- 'smy_url' : smy_url,
- 'smy_reg_tag' : smy_reg_tag
- };
- };
-
- System.prototype.return_smylie_dom = function(){
- var html = "";
- for(var i=0;i!["+s[]("+s[ "\"+s[")
\r\n";
- }
-
- return html;
- };
-
- System.prototype.add_smylie_to_string = function(string){
- if(typeof string === "undefined"){
- return this.null;
- }
-
- for(var i=0;i");
- }
- return string;
- };
-
- System.prototype.jsoin_channel_by_click = function(name){
- this.new_ajax_query({
- 'message' : '/join '+name,
- 'channel' : this.chat_name
- },'server.php?userBlock=' + this.data.browserBlock+'&sort='+this.data.user.sort+"&li=" + this.get_last_id());
- };
-
- System.prototype.add_default_item_to_message = function(string){
-
- string = string.replace(/\[(img|image)=(.*?)\]/g,function(all,n,url){
- return "![]("+url+" "User bb image")
";
- });
-
-
- string = string.replace(/\[url=(.*?)\](.*?)\[\/url\]/g,function(all,url,text){
- return ""+text+"";
- });
-
- //finely :)
- return string.replace(new RegExp("(#[a-z0-9][a-z0-9\-_]*)","ig"),function(find){
- return ""+find+"";
- });
- };
-
- System.prototype.smy_click = function(id){
- //vi skal du have fat i context i tekst box :)
- var context = this.getDom("textbox").context();
- var object = this.getDom("textbox").getObject();
- var index = context.length;
- if(object.selectionStart){
- index = object.selectionStart;
- }
-
- var put = {
- 'befor' : context.substring(0,index),
- 'after' : context.substring(index,context.length)
- };
-
- this.getDom("textbox").context(put.befor+this.smylie[id]["smy_tag"]+put.after);
-
- //okay now wee need to focus the text fild :D
- object.focus();
- var c = put.befor.length + this.smylie[id]["smy_tag"].length;
- if(object.createTextRange){
- var r = object.createTextRange();
- r.move('character',c);
- r.select();
- }else{
- object.selectionStart = c;
- object.selectionEnd = c;
- }
- };
-
- System.prototype.init_message = function () {
- this.set_object("message", new Message(this));
- };
-
- System.prototype.set_lang = function () {
- this.set_object("lang", LibLang.English);
- };
-
- System.prototype.get_lang = function () {
- return this.get_object("lang");
- };
-
- System.prototype.new_status = function () {
- this.set_object("status", new Status(this.get_lang()));
- };
-
- System.prototype.new_ajax = function () {
- var id = 0;
- if(this.ajax.length <= 50){
- id = this.ajax.length;
- }
-
- this.get_object("status").call();
-
- this.ajax[id] = new JAjax({
- 'action': 'server.php?userBlock=' + this.data.browserBlock+'&sort='+this.data.user.sort+"&li=" + this.get_last_id(),
- 'method': 'get',
- 'error': function (m) {
- if(system.get_protokol() == "ajax"){
- system.get_object("message").bot_message(m,0,"red");
- }else{
- system.get_object("message").bot_message(system.get_lang().socket_open_fail, 0,"red","socket_open_fail",{});
- }
- system.get_object("status").error();
- },
- 'success': function (json) {
- system.handle_in_message(json,false);
- if(system.changeStatus){
- system.get_object("status").okay();
- }
-
- system.changeStatus = true;
- },
- 'protokol': this.get_protokol(),
- 'host': this.data['socket']['server'],
- 'port': this.data['socket']['port'],
- 'file' : false,
- 'noHeader' : false
- });
- return id;
- };
-
- System.prototype.new_ajax_query = function (post, url) {
-
- if (this.get_protokol() == "socket") {
- if (this.is_socket) {
- this.ajax[0].send(post);
- } else {
- this.ajax[0].enable();
- }
-
- return;
- }else{
- var id = this.new_ajax();
- }
-
- var block = "";
-
- if (typeof post !== "undefined") {
- this.ajax[id].changePost(post);
- block = "&isPost=true";
- this.ajax[id].changeMethod("post");
- }else{
- this.ajax[id].changeMethod("get");
- }
-
- if (typeof url !== "undefined") {
- this.ajax[id].changeUrl(url+block);
- }
-
-
- this.ajax[id].enable();
- };
-
- System.prototype.get_protokol = function () {
- if (this.data.protocol == 'socket') {
- return 'socket';
- }
-
- return 'ajax';
- };
-
- System.prototype.set_object = function (objName, objValue) {
- this.object[objName] = objValue;
- };
-
- System.prototype.get_object = function (objName) {
- if (typeof this.object[objName] === "undefined") {
- return null;
- }
-
- return this.object[objName];
- };
-
- System.prototype.set_background = function (url) {
- this.getDom("main").css("backgroundImage", "url('" + url + "')");
- };
-
- System.prototype.selectOption = function(obj){
- this.show_option(obj.value);
- };
-
- System.prototype.show_option = function (w) {
- this.getDom("option").run(function () {
- if (this.attr("what") == w) {
- this.show();
- } else {
- this.hide();
- }
- });
- };
-
- System.prototype.unset_screen = function () {
- this.getDom("main").empty();
- this.getDom("channel_botton").remove();
- this.show_option(this.option_name.online);
-
- };
-
- System.prototype.getDom = function (domName) {
- if (typeof this.dom[domName] === "undefined") {
- return null;
- }
-
- return this.dom[domName];
- };
-
- System.prototype.setDom = function () {
- this.dom = {
- 'channel_list' : J("#channelList"),
- 'main' : J("#channelMain"),
- 'textbox' : J("#textbox"),
- 'setting' : J("#rightContainer"),
- 'channel_botton' : J(".chanenlContainer"),
- 'option' : J(".option"),
- 'sound_botton' : J("#sound"),
- 'text_color' : J("#textColor"),
- 'avatar' : J("#profilImage"),
- 'lang_select' : J("#langSelect"),
- 'title' : J("#chattitle"),
- 'user' : J(".user"),
- 'time' : J("#time"),
- 'newInChanMessage' : J("#newInChanMessage"),
- 'save' : J("#save"),
- 'upload' : J("#upload"),
- 'fileName' : J("#fileName"),
- 'viewImages' : J("#viewImages"),
- 'viewImage' : J("#viewImage")
- };
- };
-
- System.prototype.init_cache = function () {
- this.set_object("cache", new Cache(this));
- };
-
- System.prototype.update_config = function(){
- this.getDom("sound_botton").getObject().checked = (this.user_config['sound'] == "true" ? true : false);
-
- this.getDom("text_color").getOptions(function(value,text,obj){
- if(value == system.user_config['textColor']){
- obj.selected = true;
- }
- });
-
- this.getDom("textbox").css("color",this.user_config['textColor']);
-
- var secondLang = "English";
-
- if(this.langName !== null){
- secondLang = this.langName;
- }
-
- this.set_object("lang",this.setNewLang(this.user_config['lang'],secondLang));
- this.get_object("status").updateSprog(this.get_object("lang"));
- this.update_screen_lang();
- this.getDom("lang_select").getOptions(function(value,text,obj){
- if(value == system.langName){
- obj.selected = true;
- }
- });
-
- this.getDom("time").context(this.user_config['time']);
-
- };
-
- /**
- * @param string [String] name of lang key
- * @param data [Object] object whit data to convert from ;)
- */
- System.prototype.convert_lang_string = function(string,data){
- var lang = this.get_lang();
-
- if(typeof lang[string] === "undefined"){
- return "Unknown lang key: "+string;
- }
-
- var use = lang[string];
-
- for(var i in data){
- use = use.replace(new RegExp("%"+i),data[i]);
- }
-
- return use;
- };
-
- System.prototype.update_screen_lang = function(){
- J("all").run(function(){
- if(typeof this.attr("langString") !== "undefined" && typeof this.attr("langData") !== "undefined"){
- var l_string = system.get_lang()[this.attr("langString")];
- var l_data = JSON.parse(this.attr("langData"));
-
- for(var i in l_data){
- l_string = l_string.replace(new RegExp("%"+i,"g"),l_data[i]);
- }
-
- this.context(l_string);
- }else if(typeof this.attr("langTitle") !== "undefined" && typeof this.attr("langData") !== "undefined"){
- var l_string = system.get_lang()[this.attr("langTitle")];
- var l_data = JSON.parse(this.attr("langData"));
-
- for(var i in l_data){
- l_string = l_string.replace(new RegExp("%"+i,"g"),l_data[i]);
- }
-
- this.getObject().title = l_string;
- }
- });
- };
-
- System.prototype.start_channel = function(){
- return this.data['startChannel'];
- };
-
- System.prototype.stop_chat = function(){
- if(this.get_protokol() != "ajax"){
- return false;
- }
- clearTimeout(this.timer);
- };
-
- System.prototype.start_chat = function(isStartChannel){
- if(typeof isStartChannel === "undefined"){
- isStartChannel = false;
- }
-
- if(this.get_protokol() != "ajax"){
- return false;
- }
-
- if(!isStartChannel && this.timer === null){
- this.new_ajax_query({
- 'message' : '/ping',
- 'channel' : 'Bot'
- });
- }else{
- this.stop_chat();
- }
-
- this.timer = setTimeout(function(){
- system.new_ajax_query(undefined,'server.php?userBlock=' + system.data.browserBlock+'&sort='+system.data.user.sort+"&li=" + system.get_last_id())
- },this.data.timer);
- };
-
- System.prototype.open_chat = function(){
- this.getDom("main").css("backgroundImage","none");
-
- this.getDom("option").run(function(){
- if(this.attr("what") == system.option_name.smylie){
- this.context(system.return_smylie_dom());
- return;
- }
- });
-
- if(this.get_protokol() == "ajax"){
- this.start_chat(true);
- }
- };
-
- System.prototype.get_channel_botton_color = function(){
- return this.data.channelColor;
- };
-
- System.prototype.ping_socket = function(){
- setTimeout(function(){
- system.new_ajax_query({
- 'message' : '/ping',
- 'channel' : 'Bot'
- });
-
- system.ping_socket();
- },500000);
- };
-
- System.prototype.is_in_this_channel = function(name){
- if(this.chat_name == name){
- return true;
- }
-
- return false;
- };
-
- System.prototype.setNewLang = function(MainLang,SecondLang){
- var l = LibLang;
- if(typeof l[MainLang] === "undefined"){
- return this.setNewLang(SecondLang,"English");
- }
-
- this.langName = MainLang;
- return l[MainLang];
- }
-
- return System;
-
-})();
\ No newline at end of file
diff --git a/lib/client.php b/lib/client.php
deleted file mode 100644
index 3b3669c..0000000
--- a/lib/client.php
+++ /dev/null
@@ -1,111 +0,0 @@
- $value){
- $return[] = urlencode($key)."=".urlencode($value);
- }
- return implode(";",$return);
- }
-
- return "
- 'nick' : '".$userdata['nick']."',
- 'id' : '".$userdata['user_id']."',
- 'sort' : '".(int)$userdata['user_level']."',
- 'mobil' : false,
- 'lang' : '".str_replace("/",null,LOCALESET)."'
- ";
-}
-
-function jugoloChatClientReturnBotStat(){
- global $config;
-
- return "
- 'name' : '".$config['botUserName']."',
- 'color' : '".$config['botUserColor']."',
- 'text' : '".$config['botTextColor']."'
- ";
-}
-
-function jugoloChatClientReturnBoxColorArray(){
- global $config;
-
- return "'".$config['bColorOne']."','".$config['bColorToo']."'";
-}
-
-function jugoloChatClientOnStart(){
- global $userdata;
-
- $sql = dbquery("SELECT `cid` FROM `".DB_CHATMEMBER."` WHERE `uid`='".(int)$userdata['user_id']."' AND `cid` <> '1'");
- while($row = dbarray($sql)){
- dbquery("INSERT INTO `".DB_CHATMESSAGE."` (
- `uid`,
- `cid`,
- `isBot`,
- `time`,
- `message`,
- `messageColor`,
- `isMsg`,
- `msgTo`
- ) VALUE (
- '".(int)$userdata['user_id']."',
- '".(int)$row['cid']."',
- '".No."',
- NOW(),
- '/exit',
- 'red',
- '".No."',
- '0'
- )
- ");
- }
-
- dbquery("DELETE FROM `".DB_CHATMEMBER."` WHERE `uid`='".(int)$userdata['user_id']."' AND `cid`<>'1' AND `ban`='".No."'");
-}
-
-function jugoloChatCLientAddSmylie(){
- global $smiley_cache;
-
- $use = null;
- for($i=0;$ihead = new mysqli($host,$user,$pass,$data);
- if($this->head->connect_error){
- $this->saveError(
- $this->head->connect_error,
- $this->head->connect_errno
- );
- return;
- }
- }
-
- function query($sql){
- $result = $this->head->query($sql);
- if($this->strstwidth($sql,"SELECT")){
- if(!$result){
- $this->saveError(
- $this->head->error,
- $this->head->errno,
- $sql
- );
- }
- }
-
- return new DatabaseResult($sql,$this->head,$result);
- }
-
- function prepare($sql){
- return new DatabasePrepare($sql,$this);
- }
-
- function clean($context){
- return $this->head->escape_string($context);
- }
-
- function saveError($errStr,$errNo,$sql = 'null'){
- $this->isError = true;
- $this->errorData[] = array(
- 'string' => $errStr,
- 'number' => $errNo,
- 'sql' => $sql
- );
- }
-
- function getError(){
- $return = "Error in Database:
"; - for($i=0;$ierrorData);$i++){
- $return .= "Error String: ".$this->errorData[$i]['string']."
- Error Number: ".$this->errorData[$i]['number']."
- Sql: ".$this->errorData[$i]['sql']; - } - - return $return; - } - - function strstwidth($tekst,$exp){ - return (strpos($tekst,$exp) === 0); - } - - function lastIndex(){ - return $this->head->insert_id; - } -} - -class DatabaseResult{ - private $sql = null; - private $main = null; - private $result = null; - - function DatabaseResult($sql,$main,$result){ - $this->main = $main; - $this->sql = $sql; - $this->result = $result; - } - - function get(){ - return @$this->result->fetch_assoc(); - } -} - -class DatabasePrepare{ - private $sql = null; - private $main = null; - - function DatabasePrepare($sql,DatabaseHandler $main){ - $this->sql = $sql; - $this->main = $main; - } - - function add($name,$context){ - $this->sql = str_replace( - "{".$name."}", - "'".$this->main->clean($context)."'", - $this->sql - ); - } - - function done(){ - return $this->main->query($this->sql); - } -} \ No newline at end of file diff --git a/lib/define.php b/lib/define.php deleted file mode 100644 index 4a648c4..0000000 --- a/lib/define.php +++ /dev/null @@ -1,3 +0,0 @@ -user = $array; - } - - function add_ignore($uid){ - $this->ignore[] = $uid; - $this->database->query("INSERT INTO `".DB_PREFIX."chat_ignore` - ( - `uid`, - `ignore` - ) VALUES( - '".$this->user['user_id']."', - '".$uid."' - )"); - } - - function remove_ignore($uid){ - if(($key = array_search($uid,$this->get_ignore())) !== false){ - unset($this->ignore[$key]); - $this->database->query("DELETE FROM `".DB_PREFIX."chat_ignore` WHERE `uid`='".(int)$this->user['user_id']."' AND `ignore`='".$uid."'"); - } - } - - function get_ignore($only_cahce = true){ - if(!$only_cahce || empty($this->ignore)){ - $datas = $this->database->query("SELECT `ignore` FROM `".DB_PREFIX."chat_ignore` WHERE `uid`='".(int)$this->user['user_id']."'"); - while($row = $datas->get()){ - $this->ignore[] = $row['ignore']; - } - } - - return $this->ignore; - } - - function Protokol(DatabaseHandler $mysql,Server $server){ - $this->database = $mysql; - $this->main = $server; - } - - function get_channel_list($onlye_cache = true){ - if(!$onlye_cache){ - $datas = $this->database->query("SELECT * FROM `".DB_PREFIX."chat_name`"); - while($row = $datas->get()){ - $data = $row; - unset($data['id']); - $this->channel[$row['id']] = $data; - } - } - - return $this->channel; - } - - function add_to_channel($cid){ - $this->database->query("INSERT INTO `".DB_PREFIX."chat_member` - (`uid`, - `cid`, - `lastActiv`, - `isInAktiv`, - `ban` - ) VALUE ( - '".(int)$this->user['user_id']."', - '".(int)$cid."', - NOW(), - '".No."', - '".No."' - )"); - - $id = $this->database->lastIndex(); - $this->my_channel[$id] = array( - 'uid' => $this->user['user_id'], - 'cid' => $cid, - 'lastActiv' => time(), - 'isInAktiv' => No, - 'ban' => No - ); - } - - function get_my_channel_list($only_cache = true){ - if($only_cache && !empty($this->my_channel)){ - return $this->my_channel; - } - - $this->my_channel = array();//unset all data :) - - $datas = $this->database->query("SELECT cm.*,cn.name - FROM `".DB_PREFIX."chat_member` AS cm - LEFT JOIN `".DB_PREFIX."chat_name` AS cn ON cn.id = cm.cid - WHERE cm.uid='".$this->user['user_id']."'"); - while($row = $datas->get()){ - $data = $row; - unset($data['id']); - $this->my_channel[$row['id']] = $data; - } - - return $this->my_channel; - } - - - function new_channel($name,$title = null,$isSystem = false){ - if($title === null){ - $title = $name; - } - - $data = $this->database->prepare("INSERT INTO `".DB_PREFIX."chat_name` - ( - `name`, - `isPriv`, - `uid`, - `title`, - `setTitle` - ) VALUE ( - {name}, - '".No."', - '0', - {title}, - '".$this->user['user_id']."' - )"); - - $data->add("name",$name); - $data->add("title",$title); - $data->done(); - - if($this->database->isError){ - exit($this->database->getError()); - } - - $id = $this->database->lastIndex(); - $this->channel[$id] = array( - 'name' => $name, - 'isPriv' => No, - 'uid' => 0, - 'title' => $title, - 'setTitle' => $this->user['user_id'], - ); - - $d = $this->channel[$id]; - $d['id'] = $id; - - return $d; - } - - function remove_ban($uid,$cid,$id,$r = true){ - $this->database->query("DELETE FROM `".DB_PREFIX."chat_member` - WHERE `uid`='".(int)$uid."' - AND `cid`='".(int)$cid."'"); - } - - function get_flood($cid){ - if(!$this->main->session("flood")){ - $flood = array(); - $_SESSION['flood'] = array(); - }else - $flood = $this->main->session("flood"); - - if(empty($flood[$cid])){ - return array(); - } - - return $flood[$cid]; - } - - function update_flood($flood,$cid){ - $_SESSION["flood"][$cid] = $flood; - } - - function update_nick($newNick){ - $this->user['nick'] = $newNick; - } - - function getBannetInChannel($cid){ - $data = $this->database->query("SELECT `uid` FROM `".DB_PREFIX."chat_member` WHERE `ban`='".Yes."' AND `cid`='".(int)$cid."'"); - $bannet = array(); - while($row = $data->get()){ - $bannet[] = $row['uid']; - } - - return $bannet; - } - - function banUser($cid,$uid,$banTo,$save = true){ - $this->database->query("UPDATE `".DB_PREFIX."chat_member` SET - `ban`='".Yes."', - `banTo`='".$banTo."' - WHERE `uid`='".$uid."' AND `cid`='".$cid."'"); - } - - function get_channel_by_id($id){ - if(!empty($this->channel[$id])){ - return $this->channel[$id]['name']; - } - - return "Bot"; - } - - function getUserInChannel($cid,$nick){ - $sql = $this->database->prepare("SELECT user.* - FROM `".DB_PREFIX."users` AS user - LEFT JOIN `".DB_PREFIX."chat_member` AS cm ON cm.uid = user.user_id - WHERE cm.cid='".(int)$cid."' - AND user.nick={nick}"); - - $sql->add("nick",$nick); - $user = $sql->done(); - - if($this->database->isError){ - exit($this->database->getError()); - } - - $user = $user->get(); - - if(empty($user)) - return false; - else - return $user; - } - - function getBanId($cid,$uid){ - $sql = $this->database->query("SELECT `id` - FROM `".DB_PREFIX."chat_member` - WHERE `cid`='".$cid."' - AND `uid`='".$uid."' - AND `ban`='".Yes."'"); - $data = $sql->get(); - - if(empty($data)) - return null; - else - return $data; - } - - function kick($cid,$uid){ - $this->database->query("DELETE FROM `".DB_PREFIX."chat_member` - WHERE `cid`='".$cid."' - AND `uid`='".$uid."'"); - } - - function updateConfig($key,$value){ - $sql = $this->database->prepare("UPDATE `".DB_PREFIX."chat_userConfig` SET `value`={value} WHERE `uid`={uid} AND `key`={key}"); - $sql->add("value",$value); - $sql->add("key",$key); - $sql->add("uid",$this->user['user_id']); - $sql->done(); - } - - function userConfig($key,$id = null){ - if($id === null) - $id = $this->user['user_id']; - - if(empty($this->userconfig[$id])) - $this->userconfig[$id] = $this->getUserConfig($id); - - if(empty($this->userconfig[$id][$key]) || !trim($this->userconfig[$id][$key])) - return null; - return $this->userconfig[$id][$key]; - - } - - private function getUserConfig($id){ - $sql = $this->database->query("SELECT * FROM `".DB_PREFIX."chat_userConfig` WHERE `uid`='".(int)$id."'"); - if($this->database->isError){ - exit($this->database->getError()); - } - $return = array(); - while($row = $sql->get()){ - $return[$row['key']] = $row['value']; - } - - return $return; - } - - function getConfig($key){}//not in use. only for websocket (yey); - function update(){}//not in use -} \ No newline at end of file diff --git a/lib/protokol/websocket.php b/lib/protokol/websocket.php deleted file mode 100644 index 57aa99f..0000000 --- a/lib/protokol/websocket.php +++ /dev/null @@ -1,247 +0,0 @@ -main = $server; - $this->mysql = $mysqli; - } - - function get_channel_by_id($id){ - foreach($this->channel AS $cid => $data){ - if($id == $cid){ - return $data['name']; - } - } - - return "Bot"; - } - - function get_ignore($uid = null){ - if($uid === null) - $uid = $this->user['user_id']; - return $this->client[$uid]->ignore; - } - - function add_ignore($uid){ - $this->client[$this->user['user_id']]->ignore[] = $uid; - } - - function remove_ignore($uid){ - if(($key = array_search($uid,$this->get_ignore())) !== false){ - unset($this->client[$this->user['user_id']]->ignore[$key]); - } - } - - function set_user_data($data,$client){ - $this->user = $data; - $this->client[$data['user_id']] = $client; - } - - function get_channel_list($e=false){ - return $this->channel; - } - - function get_my_channel_list(){ - if(empty($this->user['user_id'])){ - return array(); - } - - if(!empty($this->client[$this->user['user_id']]->channel)){ - return $this->client[$this->user['user_id']]->channel; - }else{ - return array(); - } - } - - function add_to_channel($cid){ - $id = count($this->client[$this->user['user_id']]->channel); - $this->client[$this->user['user_id']]->channel[$cid] = array( - 'id' => $id, - 'uid' => $this->user['user_id'], - 'cid' => $cid, - 'lastActiv' => time(), - 'isInAktiv' => No, - 'ban' => No, - 'name' => $this->channelNameCache[$cid] - ); - echo "\r\n".$this->channelNameCache[$cid]."\r\n\r\n"; - } - - function new_channel($name,$title = null,$isSystem = false){ - if($title === null) - $title = $name; - - $id = count($this->channel); - - if($id === 0 && !$isSystem){ - $this->new_channel("null","null channel",true); - $id = count($this->channel); - - } - if($id === 1 && !$isSystem){ - $this->new_channel("Bot","Global bot system",true); - $id = count($this->channel); - } - - $this->channelNameCache[$id] = $name; - - $this->channel[$id] = array( - 'id' => $id, - 'name' => $name, - 'isPriv' => No, - 'uid' => 0, - 'title' => $title, - 'setTitle' => 0, - 'isPm' => No, - ); - - $this->bannet[$id] = array(); - - return $this->channel[$id]; - } - - function turn($uid){ - if(in_array($uid,array_keys($this->client))){ - $this->user = $this->client[$uid]->user; - } - } - - function get_flood($cid){ - if(empty($this->flood[$this->user['user_id']])){ - $this->flood[$this->user['user_id']] = array(); - } - if(empty($this->flood[$this->user['user_id']][$cid])){ - $this->flood[$this->user['user_id']][$cid] = array(); - } - - return $this->flood[$this->user['user_id']][$cid]; - } - - function update_flood($flood,$cid){ - $this->flood[$this->user['user_id']][$cid] = $flood; - } - - function update_nick($newNick){ - $this->client[$this->user['user_id']]->user['nick'] = $newNick; - $this->user['nick'] = $newNick; - } - - function getUserInChannel($cid,$nick){ - foreach($this->client AS $object){ - if(strtolower($object->user['nick']) == strtolower($nick)){ - foreach($object->channel AS $channelID => $data){ - if($channelID == $cid){ - return $object->user; - } - } - } - } - - return false; - } - - function getBannetInChannel($cid){ - if(empty($this->bannet[$cid])) - return array(); - return $this->bannet[$cid]; - } - - function banUser($cid,$uid,$banTo,$save =true){ - $this->bannet[$cid][] = $uid; - $this->client[$uid]->channel[$cid]['ban'] = Yes; - $this->client[$uid]->channel[$cid]['banTo'] = $banTo; - if($save){ - $this->mysql->query("INSERT INTO `".DB_PREFIX."chat_member` ( - `uid`, - `cid`, - `lastActiv`, - `isInAktiv`, - `ban`, - `banTo` - ) VALUES ( - '".(int)$uid."', - '".(int)$cid."', - NOW(), - '".No."', - '".Yes."', - '".$banTo."' - )"); - } - } - - function remove_ban($uid,$cid,$id,$remove = true){ - unset($this->client[$uid]->channel[$cid]); - $i = array_search($uid,$this->bannet[$cid]); - unset($this->bannet[$cid][$i]); - if($remove){ - $this->mysql->query("DELETE FROM `".DB_PREFIX."chat_member` - WHERE `uid`='".$uid."' - AND `cid`='".$cid."'"); - } - } - - function getBanId($c,$u){return null;}//this protokol dosent need this :) - - function kick($cid,$uid){ - if(empty($this->client[$uid]->channel[$cid])){ - return false; - } - - unset($this->client[$uid]->channel[$cid]); - unset($this->client[$uid]->aktiv[$cid]); - return true; - } - - function updateConfig($key,$value){ - $this->client[$this->user['user_id']]->update_user_config($key,$value); - } - - function getConfig($key){ - $config = $this->client[$this->user['user_id']]->user_config; - if(empty($config[$key])) - return null; - else - return $config[$key]; - } - - function update(){ - foreach($this->bannet as $cid => $data){ - for($i=0;$iremove_ban($data[$i],$cid,0,false);
- }
- }
-
- $this->bannet = array();//protect against fail.
- $sql = $this->mysql->query("SELECT * FROM `".DB_PREFIX."chat_member` WHERE `id`<>'1' AND `ban`='".Yes."'");
- while($row = $sql->get()){
- $this->banUser(
- $row['cid'],
- $row['uid'],
- $row['banTo'],
- false
- );
- }
- }
-
- function userConfig($key,$id = null){
- $sql = $this->database->query("SELECT * FROM `".DB_PREFIX."chat_userconfig` WHERE `uid`='".(int)$id."'");
- $return = array();
- while($row = $sql->get()){
- $return[$row['key']] = $row['value'];
- }
-
- return $return;
- }
-}
\ No newline at end of file
diff --git a/lib/tmp/allow_file.php b/lib/tmp/allow_file.php
deleted file mode 100644
index 1c2f338..0000000
--- a/lib/tmp/allow_file.php
+++ /dev/null
@@ -1,5 +0,0 @@
- $value){
- $return .= "'".$key."' : ";
- if(is_array($value)){
- $return .= PHPArrayToJavaScriptObject($value,false).((count($data)-1) == $i ? null : ',');
- }else{
- $return .= "'".addslashes($value)."'".((count($data)-1) == $i ? null : ',');
- }
- $i++;
- }
-
- return $return."}";
-}
-
-$dir = opendir("./");
-$l = array();
-
-while($file = readdir($dir)){
- if(is_dir($file) && ($file != "." && $file != "..")){
- $l[$file] = getLang($file);
- }
-}
-
-$cache = "var LibLang = ".PHPArrayToJavaScriptObject($l).";";
-
-$obj = fopen("../lib/tmp/lang_js_cache.php","w");
-fwrite($obj,"//this is cache\r\n".$cache);
-fclose($obj);
-
-echo $cache;
\ No newline at end of file
diff --git a/multi_include.php b/multi_include.php
new file mode 100644
index 0000000..e355c87
--- /dev/null
+++ b/multi_include.php
@@ -0,0 +1,25 @@
+");
-add_to_head("");
-add_to_head("");
-add_to_head("");
-add_to_head("");
-add_to_head("");
-add_to_head("");
-add_to_head("");
-add_to_head("");
-
-add_to_head("");
-
-function convert_socket_server($server){
- if (!filter_var($server, FILTER_VALIDATE_IP)) {
- return gethostbyname($server);
- }
-
- return $server;
-}
-
-//vi laver nu en start på systemet :)
-add_to_head("");
-
-//vi har brug for at kunne afspille en lyd ;)
-echo "";
-
-$t = explode(",",$config['textColor']);
-$textColor = array();
-for($i=0;$i".$reg[2]."";
- }
-}
-
-opentable("Jugolo chat");
-echo "remove_client($new);
- echo "Missing Sec-WebSocket-Key\r\n";
- print_r($head);
- return false;
- }
-
- $key = $head['Sec-WebSocket-Key'];
- $hkey = base64_encode(sha1($key.'258EAFA5-E914-47DA-95CA-C5AB0DC85B11', true));
-
- $uhead = array();
-
- $uhead[] = "HTTP/1.1 101 Web Socket Protocol Handshake";
- $uhead[] = "Upgrade: websocket";
- $uhead[] = "Connection: Upgrade";
- $uhead[] = "Sec-WebSocket-Accept: ".$hkey;
-
- $handshake = implode("\r\n",$uhead)."\r\n\r\n";
- //exit($handshake);
-
- if(socket_write($new,$handshake,strlen($handshake))===false){
- exit("Handshake fail");
- }
- echo "New client connected to server\r\n";
- return null;
- }
-
- private function remove_client($socket){
- $i = array_search($socket,$this->client);
- if(empty($i)){
- return false;
- }
- $this->clientObj[$i]->disconnect();
- $this->clientObj = $this->reset_array_sort($this->clientObj,$i);
- $this->client = $this->reset_array_sort($this->client,$i);
- echo "Client disconetet\r\n";
-
- return true;
- }
-
- private function reset_array_sort($array,$removeId = null){
- $cache = $array;
- $array = array();
- for($i=0;$iclient[] = $client;
- $this->clientObj[] = $obj = new socket_user_client($client,$this->database);
- return $obj;
- }
-
- private function get_client($socket){
- foreach($this->clientObj as $c){
- if($c->socket == $socket){
- return $c;
- }
- }
-
- return false;
- }
-
- private function init_lang(){
- $this->setLang($this->get_system_config("locale"));
- }
-
- function setLang($name){
- if(!empty($this->langCache[$name]) && is_array($this->langCache[$name])){
- $this->lang = $this->langCache[$name];
- return;//super :)
- }
- $locale = array();
-
- if($this->websocket)
- $langUse = $this->get_base_part()."locale\\".$name."\\server.php";
- else
- $langUse = "./locale/".$name."/server.php";
-
-
- if(file_exists($langUse)){
- include $langUse;
- $this->lang = $this->langCache[$name] = $locale;
- }else{
- if(!empty($this->langCache['English']) && is_array($this->langCache['English'])){
- $this->lang = $this->langCache['English'];
- return;
- }
- if($this->websocket)
- $url = $this->get_base_part()."locale\\English\\server.php";
- else
- $url = "./locale/English/server.php";
- include $url;
- $this->lang = $this->langCache['English'] = $locale;
- }
- }
-
-
- private function getLangList(){
- $return = array();
- if($this->websocket)
- $dir = $this->get_base_part()."locale\\";
- else
- $dir = "locale/";
-
- $dirObj = opendir($dir);
- while($file = readdir($dirObj)){
- if($file != "." && $file != ".." && is_dir($dir.$file)){
- $return[] = $file;
- }
- }
-
- return $return;
- }
-
- //inaktiv sektion
- private function handle_inaktiv($row){
- if($row['isInAktiv'] == Yes){
- $this->do_leave($row);
- }else{
- $this->do_inaktiv($row);
- }
- }
-
- private function do_leave($row){
- $this->sendBotMessage(
- $row['cid'],
- '/leave',
- false,
- $row['uid']
- );
- $this->database->query("DELETE FROM `".DB_PREFIX."chat_member` WHERE `id`='".(int)$row['id']."'");
- if($this->database->isError){
- exit($this->database->getError());
- }
- $this->sendBotPrivMessage(
- 1,
- "/leave ".$row['name'],
- "red",
- $row['uid']
- );
- }
-
- private function do_inaktiv($row){
- $this->database->query("UPDATE `".DB_PREFIX."chat_member` SET `isInAktiv`='".Yes."' WHERE `id`='".$row['id']."'");
- if($this->database->isError){
- exit($this->database->getError());
- }
-
- $this->sendBotMessage(
- $row['cid'],
- "/inaktiv ".$row['nick'],false,$row['uid']
- );
- }
-
- //message sektion
- private function showMessage(){
- //vi sletter nu pong beskeder som er mere end 1 min gammel :)
- $this->database->query("DELETE FROM `".DB_PREFIX."chat_message` WHERE `cid`='1' AND `message`='/pong' AND DATE_SUB(time, INTERVAL 1 MINUTE) > NOW()");
- if($this->database->isError){
- exit($this->database->getError());
- }
-
- //big sql :D
- $data = $this->database->query("SELECT tm.id AS id, tm.message AS message, tm.isMsg AS isMsg, tm.msgTo AS msgTo, tm.messageColor AS messageColor, tm.isBot AS isBot, user.nick AS nick, tm.time AS time, tn.id AS cid, tn.name AS channel, cm.id AS cmid, user.user_id AS uid, user.user_avatar AS img, tn.isPriv AS isPriv, tn.uid AS privUid
- FROM ".DB_PREFIX."chat_message AS tm
- LEFT JOIN ".DB_PREFIX."chat_member AS cm ON tm.cid = cm.cid
- LEFT JOIN ".DB_PREFIX."users AS user ON user.user_id = tm.uid
- LEFT JOIN ".DB_PREFIX."chat_name AS tn ON tn.id = cm.cid
- WHERE cm.uid = '".(int)$this->protokol->user['user_id']."'
- AND tm.id > '".(int)$this->getVariabel("last_id")."'
- AND cm.ban <> '".Yes."'
- ORDER BY tm.id ASC ");
-
- if($this->database->isError){
- exit($this->database->getError());
- }
-
- $message = array();
- while($row = $data->get()){
- if($row['message'] == null){
- continue;
- }
-
- if($this->may_show_may_show_message($row)){
- $row['time'] = date("H:i",strtotime($row['time']));
- $message[] = $this->messageMakeSafe($row);
- }
- }
-
-
- $this->json['message'] = $message;
-
- $data = $this->database->query("SELECT cm.isInAktiv, cm.id, cm.uid , us.nick, cm.cid, cn.name
- FROM `".DB_PREFIX."chat_member` AS cm
- LEFT JOIN `".DB_PREFIX."users` AS us ON us.user_id = cm.uid
- LEFT JOIN `".DB_PREFIX."chat_name` AS cn ON cn.id=cm.cid
- WHERE cm.cid != '1'
- AND cm.ban = '".No."'
- AND cm.lastActiv < DATE_SUB( now( ) , INTERVAL ".(int)$this->config['inaktiv']." MINUTE )
- AND cm.isInAktiv = '".No."'
- OR cm.cid != '1'
- AND cm.ban = '".No."'
- AND cm.lastActiv < DATE_SUB( now( ) , INTERVAL ".(int)$this->config['leave']." MINUTE )
- AND cm.isInAktiv = '".Yes."'"
- );
-
- while($row = $data->get())
- $this->handle_inaktiv($row);
- }
-
- private function may_show_may_show_message($data){
- if(in_array($data['uid'],$this->protokol->get_ignore()) && $data['isBot'] == No){
- return false;
- }
-
- if($data['isMsg'] == Yes){
- if(
- $data['uid'] != $this->protokol->user['user_id']
- && $data['msgTo'] != $this->protokol->user['user_id']
- ){
- return false;
- }
- }
-
- return true;
- }
-
- private function messageMakeSafe($row){
- $row['message'] = $this->remove_bad_words(htmlentities($row['message']));
- $row['time'] = htmlentities($row['time']);
- $row['nick'] = htmlentities($row['nick']);
- if(empty($row['img'])){
- $row['img'] = "noavatar150.png";
- }
- $row['img'] = "../../images/avatars/".$row['img'];
- return $row;
- }
-
- private function remove_bad_words($word){
- if($this->sConfig['bad_words_enabled'] != '1'){
- return $word;
- }
-
- $block = explode("\r\n",$this->sConfig["bad_words"]);
- for($i=0;$isConfig['bad_word_replace'], $word);
- }
-
- return $word;
- }
-
- private function getUserIdFromNick($nick){
- $sql = $this->database->prepare("SELECT `user_id` FROM `".DB_PREFIX."users` WHERE BINARY `nick`={nick}");
- $sql->add("nick",$nick);
- $data = $sql->done();
- if($this->database->isError)
- exit("Database error");
- $row = $data->get();
- return (empty($row['user_id']) ? 0 : $row['user_id']);
- }
-
- //channel sektion
-
- protected function re_cache_channel_id($name){
- $myChannels = $this->protokol->get_my_channel_list();
- $channel = $this->protokol->get_channel_list();
-
- //og vi får resultatet hurtigt da MySQL ikke er indblandet :D
-
- foreach($channel as $cid => $data){
- if($data['name'] == $name){
- //vi har fundet den. nu er spøgsmålet bare om brugeren er medlem i den :)
- $this->variabel['cid'] = $this->cid = empty($myChannels[$cid]) ? 1 : $cid;
- return $this->cid;
- }
- }
-
- $this->variabel['cid'] = $this->cid = 1;
-
- return $this->cid;
- }
-
- protected function getCidFromChannel($name){
-
- foreach($this->protokol->get_my_channel_list(false) as $data){
- if(!empty($data['name']) && $data['name'] == $name){
- $this->variabel['cid'] = $this->cid = $data['cid'];
- return $data['cid'];
- }
- }
-
- $this->variabel['cid'] = $this->cid = 1;
- return 1;
- }
-
- //post sektion
-
- private function init_get_data(){
- if($this->websocket){
- if(!is_array($this->postData)){
- return $this->remove_client($this->getVariabel("client")->socket);
- }
- return array_merge($this->postData,array(
- 'li' => 0,
- ));
- }else{
- return array(
- 'message' => $this->post("message"),
- 'channel' => $this->post("channel"),
- 'li' => $this->get("li"),
- );
- }
- }
-
- private function handlePost(){
-
- $input = $this->init_get_data();
-
- //WebSocket has a problem. bannet user can write in the channel soo wee control it now :)
- if($this->getVariabel("cid") != 1 && in_array($this->protokol->user['user_id'],$this->protokol->getBannetInChannel($this->getVariabel("cid")))){
- return;
- }
-
- if(preg_match("/^\//", $input['message'])){
- $this->handleCommand();
- if($this->getVariabel("last_id")){
- $this->showMessage();
- }
- }else{
- if($this->is_flood($this->getVariabel("cid"))){
- if($input['message']){
- $this->handleMessage($input);
- }
-
- if($input['channel']){
- $this->updateActivInChannel($input['channel']);
- }
- }else{
- $this->sendBotPrivMessage(
- $this->getVariabel("cid"),
- "/maxFlood",
- 'red'
- );
- }
-
- if($this->getVariabel("last_id")){
- $this->showMessage();
- }else{
- $this->json['message'] = array();
- }
- }
- }
-
- private function is_flood($cid){
- $flood = $this->protokol->get_flood($cid);
-
-
- $count = 0;
- $new_flood = array();
- for($i=0;$isConfig["flood_interval"]){
- $new_flood[] = time();
-
- $this->protokol->update_flood($new_flood,$cid);
- return true;
- }else{
- return false;
- }
- }
-
- private function updateActivInChannel(){
- $data = $this->database->query("SELECT *
- FROM `".DB_PREFIX."chat_member`
- WHERE `uid`='".(int)$this->protokol->user['user_id']."'
- AND `cid`='".(int)$this->getVariabel("cid")."'");
-
- if($this->database->isError){
- exit($this->database->getError());
- }
-
- $row = $data->get();
-
- if($row['isInAktiv'] == Yes){
- $this->sendBotMessage($row['cid'], "/notInaktiv ".$this->protokol->user['nick'], 'green');
- }
-
- $this->database->query("UPDATE `".DB_PREFIX."chat_member` SET `lastActiv`= NOW(), `isInAktiv`='".No."' WHERE `cid`='".(int)$row['cid']."' AND `uid`='".$this->protokol->user['user_id']."'");
-
- if($this->database->isError){
- exit($this->database->getError());
- }
- }
-
- private function handleMessage($data){
- if($this->getVariabel("cid") == 1){
- //exit("Can not send to server 1!"); Fail from my side :( user can not send join command if user is not allow to write to bot channel :)
- return;
- }
-
- if($this->websocket){
- $this->send_message_to_users($data['message']);
- return;//websocket sender direkte til brugerenerne så vi har ikke brug for denne del :)
- }
-
- $datas = $this->database->prepare("INSERT INTO `".DB_PREFIX."chat_message`
- (
- `uid`,
- `cid`,
- `isBot`,
- `time`,
- `message`,
- `messageColor`,
- `isMsg`,
- `msgTo`
- ) VALUE (
- '".(int)$this->protokol->user['user_id']."',
- '".(int)$this->getVariabel("cid")."',
- '".No."',
- NOW(),
- {message},
- {tx},
- '".No."',
- '0'
- )");
-
- $datas->add("message",$data['message']);
- $datas->add("tx",(string)$this->protokol->userConfig("textColor"));
- $datas->done();
-
- if($this->database->isError){
- exit($this->database->getError());
- }
- }
-
- private function get_user_id_from_nick($nick){
- $data = $this->database->prepare("SELECT `user_id` FROM `".DB_PREFIX."users` WHERE `nick`={nick}");
- $data->add("nick",$nick);
- $result = $data->done();
- if($this->database->isError){
- exit("Database error");
- }
-
- $row = $result->get();
-
- if(!empty($row['user_id']))
- return $row['user_id'];
- else
- return false;
- }
-
- private function returnCommandName(){
- $data = $this->init_get_data();
- $ex = explode(" ",$data['message']);
- return preg_replace("/^\//",null,$ex[0]);
- }
-
- private function handleCommand(){
- switch($this->returnCommandName()){
- case 'cookie':
- if(!$this->websocket){
- exit("ERROR");
- }
- $input = $this->init_get_data();
-
- if(!$this->getVariabel("client")->login(str_replace("/cookie ",null,$input['message']))){
- $this->remove_client($this->getVariabel("client")->socket);
- }else{
- $this->getVariabel("client")->user['user_avatar'] = $this->convert_image(
- $this->getVariabel("client")->user['user_avatar']
- );
- $this->sendBotPrivMessage(1,"/cookieOkay","green");
- $this->protokol->set_user_data($this->getVariabel("client")->user,$this->getVariabel("client"));
- }
- break;
- case "getStatus":
- $this->answer_getStatus();
- break;
- case "join":
- $this->answer_join();
- break;
- case "nick":
- $this->answer_nick();
- break;
- case 'msg':
- $this->answer_msg();
- break;
- case "config":
- $this->answer_config();
- break;
- case 'getOnline':
- $this->do_getOnline();
- break;
- case 'title':
- $this->doTitle();
- break;
- case 'exit':
- $this->doExit();
- break;
- case 'getLang':
- $this->answer_getLang();
- break;
- case 'leave':
- $this->answer_leave();
- break;
- case 'kick':
- $this->answer_kick();
- break;
- case 'bot':
- $this->answer_bot();
- break;
- case 'ban':
- $this->answer_ban();
- break;
- case 'unban':
- $this->answer_unban();
- break;
- case 'ignore':
- $this->answer_ignore();
- break;
- case 'unIgnore':
- $this->answer_uningore();
- break;
- case 'ping':
- $this->sendBotPrivMessage(1,"/pong","green");
- break;
- case 'update':
- $this->answer_update();
- break;
- case 'getConfig':
- $this->sendBotPrivMessage(1,"/config ".$this->getUserConfig());
- break;
- case 'clear':
- $this->answer_clear();
- break;
- case 'file':
- $this->answer_file();
- break;
- default:
- $this->sendBotPrivMessage($this->getCidFromChannel($this->post("channel")), "/commandDenaid");
- break;
- }
- }
-
- private function answer_file(){
- //findes filen?
- $input = $this->init_get_data();
- if(preg_match("/^\/file\s([0-9]*?)$/",$input['message'],$reg)){
- $sql = $this->database->query("SELECT * FROM `".DB_PREFIX."chat_file` WHERE `id`='".(int)$reg[1]."'");
- $row = $sql->get();
- if(empty($row)){
- $this->sendBotPrivMessage($this->getVariabel("cid"),"/noFile");
- }else{
- $this->sendBotMessage(
- $this->getVariabel("cid"),
- '/file '.$row['url']
- );
- }
- }else{
- $this->sendBotPrivMessage($this->getVariabel("cid"), "/commandDenaid");
- }
- }
-
- private function answer_clear(){
- if(!$this->iADMIN() && !$this->iSUPERADMIN()){
- $this->sendBotPrivMessage(
- $this->getVariabel("cid"),
- "/error ".sprintf($this->lang['accessDenaidKommando'],"/clear")
- );
- return;
- }
-
- $this->database->query("DELETE FROM ".DB_PREFIX."chat_message");//on this method wee dont reseat id to 0 but only delete all items
- $this->sendBotPrivMessage(
- $this->getVariabel("cid"),
- $this->lang['clearDone'],
- 'green'
- );
- }
-
- private function answer_update(){
- if(!$this->iADMIN() && !$this->iSUPERADMIN()){
- //has nothing to do here idiot :()
- $this->sendBotPrivMessage($this->getVariabel("cid"), "/error ".sprintf($this->lang['accessDenaidKommando'],"/update"));
- return;
- }
-
- //system config :)
- $this->sConfig = array();
- $this->init_system_setting();
-
- //database config :)
- $this->config = array();
- $this->loadDatabaseConfig();
-
- $this->protokol->update();
-
- if($this->getConfig("protokol") != "socket" && $this->websocket){
- exit("Server gooing down!");
- }
-
- //okay now wee can tell user this system is now updatet :)
- $this->sendBotPrivMessage(
- $this->getVariabel("cid"),
- $this->lang['systemUpdatet'],
- "green"
- );
- }
-
- private function answer_uningore(){
- $input = $this->init_get_data();
- if(preg_match("/^\/unIgnore\s([a-zA-Z]*?)$/",$input['message'],$reg)){
- if(($uid = $this->get_user_id_from_nick($reg[1])) !== false){
- if(!in_array($uid,$this->protokol->get_ignore())){
- $this->sendBotPrivMessage($this->getVariabel("cid"),"/error ".$this->lang['isNotIgnore']);
- return;
- }
- $this->protokol->remove_ignore($uid);
- $this->sendBotPrivMessage($this->getVariabel("cid"),"/unIgnore ".$reg[1],"green");
- }else{
- $this->sendBotPrivMessage($this->getVariabel("cid"),"/error ".$this->lang['userNotFound']);
- }
- }else{
- $this->sendBotPrivMessage($this->getVariabel("cid"),"/error ".sprintf($this->lang['invalidCommand'],"unIgnore"));
- }
- }
-
- private function answer_ignore(){
- $input = $this->init_get_data();
- if(preg_match("/^\/ignore\s([a-zA-Z]*?)$/",$input['message'],$reg)){
- if(($uid = $this->get_user_id_from_nick($reg[1])) !== false){
- if(in_array($uid,$this->protokol->get_ignore())){
- $this->sendBotPrivMessage($this->getVariabel("cid"),"/error ".$this->lang['isIgnore'],"red");
- return;
- }
- $this->sendBotPrivMessage($this->getVariabel("cid"),"/ignore ".$reg[1]);
- $this->protokol->add_ignore($uid);
- }else{
- $this->sendBotPrivMessage($this->getVariabel("cid"),"/error ".$this->lang['userNotFound']);
- }
- }else{
- $this->sendBotPrivMessage($this->getVariabel("cid"),"/error ".sprintf($this->lang['invalidCommand'],"ignore"));
- }
- }
-
- private function answer_unban(){
-
- $input = $this->init_get_data();
-
- if(!$this->iADMIN() && !$this->iSUPERADMIN()){
- //has nothing to do here idiot :()
- $this->sendBotPrivMessage($this->getCidFromChannel($input['channel']), "/error ".sprintf($this->lang['accessDenaidKommando'],"/unban"));
- return;
- }
-
- if(preg_match("/^\/unban\s([a-zA-Z]*?)$/",$input['message'],$reg)){
- $userData = $this->protokol->getUserInChannel($this->getVariabel("cid"),$reg[1]);
- if($userData === false){
- $this->sendBotPrivMessage(
- $this->getVariabel("cid"),
- "/error ".$this->lang['userNotFound']
- );
- return;
- }
-
- if(in_array($userData['user_id'],$this->protokol->getBannetInChannel($this->getVariabel("cid")))){
- $this->protokol->remove_ban(
- $userData['user_id'],
- $this->getVariabel("cid"),
- $this->protokol->getBanId($userData['user_id'],$this->getVariabel("cid"))
- );
- $this->sendBotMessage(
- $this->getVariabel("cid"),
- $input['message'],
- "green"
- );
- }else{
- $this->sendBotPrivMessage(
- $this->getVariabel("cid"),
- "/error ".sprintf($this->lang['notBan'],$reg[1])
- );
- }
- }else{
- $this->sendBotPrivMessage($this->getVariabel("cid"),"/error ".$this->lang['unbanBroken']);
- }
- }
-
- private function answer_ban(){
- if(!$this->iADMIN() && !$this->iSUPERADMIN()){
- //has nothing to do here idiot :()
- $this->sendBotPrivMessage($this->getVariabel("cid"), "/error ".sprintf($this->lang['accessDenaidKommando'],"/ban"));
- return;
- }
-
- $input = $this->init_get_data();
-
- if(preg_match("/^\/ban\s([a-zA-Z]*?)\s([0-9]*?)$/",$input['message'],$reg)){
- //vi sætter nu tiden frem til den tidspunkt brugeren ikke længere er bannet ;)
- $to = strtotime("+".(int)$reg[2]." minutes",time());
-
- $userData = $this->protokol->getUserInChannel(
- $this->getVariabel("cid"),
- trim($reg[1])
- );
-
- if($userData !== false && is_array($userData)){
- //you can not ban you self :)
- if($userData['user_id'] === $this->protokol->user['user_id']){
- $this->sendBotPrivMessage(
- $this->getVariabel("cid"),
- '/error '.$this->lang['banSelf']
- );
- return;
- }
-
- $this->ban(
- $input['channel'],
- $userData['user_id'],
- $to,
- trim($reg[1])
- );
- }else{
- $this->sendBotPrivMessage(
- $this->getVariabel("cid"),
- "/error ".sprintf($this->lang['nickNotFound'],$reg[1])
- );
- }
- }else{
- $this->sendBotPrivMessage($this->getVariabel("cid"),"/error ".$this->lang['banBroken']);
- }
- }
-
- private function answer_bot(){
-
- $input = $this->init_get_data();
-
- if(!$this->iADMIN() && !$this->iSUPERADMIN()){
- //has nothing to do here idiot :()
- $this->sendBotPrivMessage($this->getCidFromChannel($input['channel']), "/error ".sprintf($this->lang['accessDenaidKommando'],"/bot"));
- return;
- }
-
- if(preg_match("/^\/bot\s(.*?)$/",$input["message"],$reg)){
- $this->sendBotMessage($this->getVariabel("cid"),$reg[1],($this->websocket ? $this->getVariabel("client")->user_config['textColor'] : $this->userConfig['textColor']));
- }else{
- $this->sendBotPrivMessage($this->getVariabel("cid"),"/error ".$this->lang['botBroken']);
- }
- }
-
- private function answer_leave(){
- if($this->getVariabel("cid") == 1){
- return;
- }
-
- $this->database->query("DELETE FROM `".DB_PREFIX."chat_member` WHERE `cid`='".(int)$this->getVariabel("cid")."' AND `uid`='".($this->websocket ? $this->getVariabel("client")->user['user_id'] : $this->user['user_id'])."'");
- if($this->database->isError){
- exit($this->database->getError());
- }
- //vi skriver til channel at brugeren har forladt channel ;)
- $input = $this->init_get_data();
-
- if($this->websocket){
- unset($this->getVariabel("client")->channel[$this->getVariabel("cid")]);
- unset($this->getVariabel("client")->aktiv[$this->getVariabel("cid")]);
- }
-
- $this->sendBotMessage(
- $this->getVariabel("cid"),
- "/leave ".$input['channel'],
- "red",
- $this->protokol->user['user_id']
- );
- }
-
- private function answer_kick(){
- if(!$this->iADMIN() && !$this->iSUPERADMIN()){
- //has nothing to do here idiot :()
- $this->sendBotPrivMessage($this->getVariabel("cid"), "/error ".sprintf($this->lang['accessDenaidKommando'],"/kick"));
- return;
- }
-
- $input = $this->init_get_data();
-
- if(preg_match("/^\/kick\s([a-zA-Z]*?)\s(.*?)$/",trim($input['message']),$reg)){
- //vi har nu en kick med message
- if(($uid = $this->getUserIdFromNick($reg[1])) != 0){
- $this->kick($input['channel'],$reg[2],$uid);
- }else{
- $this->sendBotPrivMessage($this->getVariabel("cid"), "/error ".$this->lang['kickBroken']);
- }
- }elseif(preg_match("/^\/kick\s([a-zA-Z\s]*?)$/", trim($input['message']),$reg)){
- if(($uid = $this->getUserIdFromNick($reg[1])) != 0){
- $this->kick($input['channel'],null,$uid);
- }else{
- $this->sendBotPrivMessage($this->getVariabel("cid"), "/error ".sprintf($this->lang['nickNotFound'],$reg[1]));
- }
- }else{
- $this->sendBotPrivMessage($this->getVariabel("cid"), "/error ".$this->lang['kickBroken']);
- }
- }
-
- private function answer_getLang(){
- $this->sendBotPrivMessage(1,"/langList ".implode(",",$this->getLangList()));
- }
-
- private function doExit(){
-
- foreach($this->protokol->get_my_channel_list() AS $cid => $data){
- $this->sendBotMessage(
- $cid,
- "/exit"
- );
- }
-
- if($this->websocket){
- $this->remove_client($this->getVariabel("client")->socket);
- }else{
- $this->database->query("DELETE FROM `".DB_PREFIX."chat_member`
- WHERE `uid`='".$this->protokol->user['user_id']."' AND `cid`!='1'");
- }
- }
-
- private function doTitle(){
-
- if(!$this->iADMIN() && !$this->iSUPERADMIN()){
- //has nothing to do here idiot :()
- $this->sendBotPrivMessage($this->getVariabel("cid"), "/error ".sprintf($this->lang['accessDenaidKommando'],"/title"));
- return;
- }
-
- $input = $this->init_get_data();
-
- if(preg_match("/^\/title\s(.*?)$/",$input['message'],$reg)){
- $sql = $this->database->prepare("UPDATE `".DB_PREFIX."chat_name`
- SET `title`={title},
- `setTitle`='".($this->websocket ? (int)$this->getVariabel("client")->user['user_id'] : (int)$this->user['user_id'])."'
- WHERE `id`='".(int)$this->getVariabel("cid")."'");
-
- $sql->add("title",$reg[1]);
- $sql->done();
-
- $this->sendBotMessage($this->getVariabel("cid"), $reg[0],"green");
- }else{
- $this->sendBotPrivMessage($this->getVariabel("cid"), "/error ".$this->lang['titleBroken']);
- }
- }
-
- private function do_getOnline(){
- $input = $this->init_get_data();
- if(preg_match("/^\/getOnline\s(.*?)$/", $input["message"],$reg)){
- $this->sendBotPrivMessage(
- $this->getVariabel("cid"),
- "/online ".implode(" ", $this->getOnline($this->getCidFromChannel($reg[1],true),true))
- );
- }else{
- exit($input['message']);
- }
- }
-
- //config
- private function answer_config(){
- $input = $this->init_get_data();
- if(preg_match("/^\/config\s\[(.*?)\]\[(.*?)\]$/", $input['message'],$reg)){
- switch(trim($reg[1])){
- case 'time':
- case 'sound':
- case 'textColor':
- case 'lang':
-
- $this->protokol->updateConfig($reg[1],$reg[2]);
- if(trim($reg[1]) == "lang"){
- //this is lang and it is importen wee update it so fast :D
- $this->setLang($reg[2]);
- }
-
- $this->sendBotPrivMessage(
- $this->getVariabel("cid"),
- $this->lang['configUpdatet'],
- "green"
- );
-
- $this->sendBotPrivMessage(
- 1,
- "/updateConfig ".$reg[1]." ".$reg[2],
- 'black'
- );
- break;
- default:
- $this->sendBotPrivMessage($this->getVariabel("cid"), "/error Wrong key: ".$reg[1],"red");
- break;
- }
- }else{
- $this->sendBotPrivMessage($this->getVariabel("cid"), "/error ".$this->lang['brokenConfigCommand'], "red");
- }
- }
-
- //msg
- private function answer_msg(){
- $cid = $this->getVariabel("cid");
- $input = $this->init_get_data();
- //vi deler stringen op ;)
- if(preg_match("/^\/msg\s(.*?)\s(.*?)$/", $input['message'],$reg)){
- //vi ser om vi kan finde en bruger med det nick ;)
- $data = $this->database->prepare("SELECT user_id AS id,`nick` FROM `".DB_PREFIX."users` WHERE `nick`={nick}");
- $data->add("nick",$reg[1]);
- $row = $data->done()->get();
- if(!empty($row['id'])){
-
- if($this->websocket){
- for($i=0;$iclientObj);$i++){
- if($this->clientObj[$i]->isLogin && $this->clientObj[$i]->user['user_id'] == $row['id']){
- $this->clientObj[$i]->msg(array(
- 'cid' => $cid,
- 'message' => "/msg ".$this->getVariabel("client")->user['nick']." -> ".$this->clientObj[$i]->user['nick'].": ".$reg[2],
- 'nick' => $this->getVariabel("client")->user['nick'],
- 'channel' => $input['channel'],
- 'uid' => $this->getVariabel("client")->user['user_id'],
- 'img' => $this->getVariabel("client")->user['user_avatar']
- ));
- //vi skal også sende det til afsenderen :)
- $this->getVariabel("client")->msg(array(
- 'cid' => $cid,
- 'message' => "/msg ".$this->getVariabel("client")->user['nick']." -> ".$this->clientObj[$i]->user['nick'].": ".$reg[2],
- 'nick' => $this->getVariabel("client")->user['nick'],
- 'channel' => $input['channel'],
- 'uid' => $this->getVariabel("client")->user['user_id'],
- 'img' => $this->getVariabel("client")->user['user_avatar']
- ));
- return;
- }
- }
-
- $this->sendBotPrivMessage($cid, "/error ".sprintf($this->lang['noNick'], $reg[1]),"red");
- return;
- }
-
- $data = $this->database->prepare("INSERT INTO `".DB_PREFIX."chat_message`
- (
- `uid`,
- `cid`,
- `isBot`,
- `time`,
- `message`,
- `messageColor`,
- `isMsg`,
- `msgTo`
- ) VALUE (
- '".(int)$this->user['user_id']."',
- '".(int)$cid."',
- '".No."',
- NOW(),
- {message},
- 'yellow',
- '".Yes."',
- '".(int)$row['id']."'
- )");
-
- $data->add("message","/msg ".$this->protokol->user['nick']." -> ".$row['nick'].": ".$reg[2]);
- $data->done();
- }else{
- $this->sendBotPrivMessage($cid, "/error ".sprintf($this->lang['noNick'], $reg[1]),"red");
- }
- }else{
- $this->sendBotPrivMessage($cid, "/error broken /msg","red");
- }
- }
-
- //nick
- private function answer_nick(){
- $input = $this->init_get_data();
- if(preg_match("/\/nick\s([a-zA-Z0-9]*?)$/", $input['message'],$reg)){
- if(!$this->nickKontrol($reg[1])){
- $this->sendBotPrivMessage($this->getVariabel("cid"), "/error ".$this->lang['nickTaken'], "red");
- return;
- }
-
- if(($code = $this->is_length_okay($reg[1],1,$this->getConfig("maxNickLengt"))) !== true){
- if($code == self::text_min){
-
- }elseif($code == self::text_max){
- $this->sendBotPrivMessage(
- $this->getVariabel("cid"),
- '/error '.$this->lang['maxNick'],
- 'red'
- );
- }
- }else{
- //wee control if user try to change nick to his nick o.O
- if($this->protokol->user['nick'] == $reg[1]){
- $this->sendBotPrivMessage(
- $this->getVariabel("cid"),
- '/error '.sprintf($this->lang['nickIsYour'],$this->protokol->user['nick']),
- 'red'
- );
- return;
- }
- $oldNick = $this->protokol->user['nick'];
- $data = $this->database->prepare("UPDATE `".DB_PREFIX."users` SET `nick`={nick} WHERE `user_id`='".$this->protokol->user['user_id']."'");
- $data->add("nick",$reg[1]);
- $data->done();
- $this->protokol->update_nick($reg[1]);
- if($this->websocket){
- foreach($this->getVariabel("client")->channel as $id => $name){
- $this->sendBotMessage(
- $id,
- '/nick '.$oldNick,
- 'green'
- );
- }
- }else{
- $data = $this->database->query("SELECT `cid` FROM `".DB_PREFIX."chat_member` WHERE `uid`='".$this->protokol->user['user_id']."' AND `cid`<>'1'");
- while($row = $data->get()){
- $this->sendBotMessage($row['cid'], "/nick ".$oldNick,"green");
- }
- }
- }
- }else{
- $this->json['isOkay'] = "false";
- $this->sendBotPrivMessage($this->getVariabel("cid"), "/error ".$this->lang['nickBroken'], "red");
- }
- }
-
- //join
-
- private function isMemberOfChannel($name){
- foreach($this->protokol->get_my_channel_list(false) as $data){
- if(!empty($data['name']) && $data['name'] == $name){
- return true;
- }
- }
-
- return false;
- }
-
- private function isChannelExists($name){
- foreach($this->protokol->get_channel_list() as $cid => $data){
- if($data['name'] == $name){
- return array_merge($data,array('id' => $cid));
- }
- }
-
- return false;
- }
-
- private function getCannelIDFromChannelName($name){
- foreach($this->protokol->get_channel_list() as $cid => $data){
- if($data['name'] == $name){
- return $cid;
- }
- }
-
- return 1;
- }
-
- private function answer_join(){
- $input = $this->init_get_data();
- if(preg_match("/^\/join #([a-zA-Z0-9]*?)$/", $input['message'], $reg)){
- if(!$this->parseJoinChannelName($reg[1])){
- $this->sendBotPrivMessage($this->getVariabel("cid"),"/error ".$this->lang['invalidJoin']);
- return;
- }
- $channelName = "#".$reg[1];
-
- if($this->isMemberOfChannel($channelName)){
- //vi skal nu se om vi er bannet :)
- if(!in_array($this->protokol->user['user_id'],$this->protokol->getBannetInChannel($this->getCannelIDFromChannelName($channelName)))){
- $this->sendBotPrivMessage($this->getVariabel("cid"),"/error ".sprintf($this->lang['isMember'],$channelName));
- return;
- }else{
- //brugeren er bannet :)
- if(!$this->allowJoinInBannetChannel($this->getCannelIDFromChannelName($channelName))){
- $this->sendBotMessage(
- 1,
- "/bannet ".$channelName,
- "red"
- );
- return;
- }
- }
- }
-
- if($data = $this->isChannelExists($channelName)){
- $this->join_user_in_channel($data);
- }else{
- $data = $this->joinUserInNewChannel($channelName);
- }
-
- $this->sendBotPrivMessage((int)$data['id'], "/title ".$data['title'],"green",null,0);
-
- }else{
- $this->sendBotPrivMessage($this->getVariabel("cid"),"/error ".$this->lang['invalidJoin']);
- }
- }
-
- private function allowJoinInBannetChannel($cid){
- $sql = $this->database->query("SELECT * FROM `".DB_PREFIX."chat_member` WHERE `cid`='".(int)$cid."' AND `uid`='".$this->protokol->user['user_id']."'");
-
- if($this->database->isError){
- exit($this->database->getError());
- }
-
- $result = $sql->get();
-
- if(time() > $result['banTo']){
- $this->protokol->remove_ban(
- $result['uid'],
- $result['cid'],
- 0
- );
- return true;
- }
-
- return false;
- }
-
- private function join_user_in_channel($data){
- $this->protokol->add_to_channel($data['id']);
- $this->sendBotMessage($data['id'],"/join","green");
- $this->sendBotPrivMessage(1,"/join ".$data['name']);
- return $data;
- }
-
- private function parseJoinChannelName($name){
-
- if($this->sConfig['bad_words_enabled'] != '1'){
- return true;
- }
-
- //is ther any bad word??
- $sp = explode("\r\n",$this->sConfig['bad_words']);
- for($i=0;$iprotokol->new_channel($channel);
- $this->channel = $this->protokol->get_channel_list();
- $this->protokol->add_to_channel($data['id']);
-
- $this->sendBotMessage($data['id'],"/join","green");
- $this->sendBotPrivMessage(1,"/join ".$channel);
-
- //join user ;)
- return $data;
- }
-
- private function getOnline($id,$isCommand = false){
- $name = array();
- if($this->websocket){
- for($i=0;$iclientObj);$i++){
- $client = $this->clientObj[$i];
- if($client->isLogin && !empty($client->channel[$id])){
- if($isCommand){
- $name[] = $client->user['user_id']."|".$client->user['nick']."|".$client->user['user_avatar']."|".No;
- }else{
- $name[] = array(
- $client->user['user_id'],
- $client->user['nick'],
- $this->convert_image($client->user['user_avatar']),
- No
- );
- }
- }
- }
- }else{
- $data = $this->database->query("SELECT user.nick AS nick, user.user_id AS id, user.user_avatar AS img, cm.isInAktiv AS isInAktiv
- FROM ".DB_PREFIX."users AS user
- LEFT JOIN ".DB_PREFIX."chat_member AS cm ON user.user_id = cm.uid
- WHERE cm.cid='".(int)$id."' AND cm.ban <> '".Yes."'");
-
- while($row = $data->get()){
- if($isCommand){
- $name[] = $row['id']."|".$row['nick']."|".$this->convert_image($row['img'])."|".$row['isInAktiv'];
- }else{
- $name[] = array($row['id'],$row['nick'],$this->convert_image($row['img']),$row['isInAktiv']);
- }
- }
- }
- return $name;
- }
-
- //getStatus
- private function answer_getStatus(){
- $this->sendBotPrivMessage(1,"/getStatus you are user");
- $this->sendBotPrivMessage($this->getVariabel("cid"),"/profilImage ".$this->convert_image(
- $this->protokol->user['user_avatar']
- ));
- }
-
- //nick control
-
- private function nickKontrol($nick){
- $data = $this->database->prepare("SELECT `user_id` FROM `".DB_PREFIX."users` WHERE `user_name`={nick} AND `user_id`!='".$this->protokol->user['user_id']."' OR `nick`={nick} AND `user_id`!='".$this->protokol->user['user_id']."'");
- $data->add("nick",$nick);
- $row = $data->done()->get();
- return (empty($row['user_id']) ? true : false);
- }
-
- //user config
- private function getUserConfig(){
- $return = array();
-
- $data = $this->database->query("SELECT *
- FROM `".DB_PREFIX."chat_userConfig`
- WHERE `uid`='".$this->protokol->user['user_id']."'");
-
- while($row = $data->get()){
- $return[] = $row['key']."=".$row['value'];
- }
-
- return implode(";",$return);
- }
-
- //load sektion
-
- private function get_base_part($numBack = 0){
- if($this->basepart !== null){
- return $this->basepart;
- }
-
- $file = __FILE__;
- //remove server.php ;)
- $file = preg_replace("/server\.php$/",null,$file);
-
- if($numBack !== 0){
- $block = explode("\\",$file);
-
- for($i=0;$i<$numBack;$i++){
- unset($block[count($block)-1]);
- }
-
- $file = implode("\\",$block)."\\";
- }
-
- return $file;
- }
-
- private function init_protokol(){
- if($this->getConfig("protokol") == "socket"){
- include $this->get_base_part()."lib\\protokol\\websocket.php";
- }else{
- include ("lib/protokol/ajax.php");
- }
- $this->protokol = new Protokol($this->database,$this);
- }
-
- private function init_system_setting(){
- $data = $this->database->query("SELECT * FROM `".DB_PREFIX."settings"."`");
- while($row = $data->get()){
- $this->sConfig[$row['settings_name']] = $row['settings_value'];
- }
- }
-
- private function get_system_config($name){
- if(empty($this->sConfig[$name])){
- return null;
- }
-
- return $this->sConfig[$name];
- }
-
- private function init_db(){
- $this->database = new DatabaseHandler(
- $this->getVariabel("db_host"),
- $this->getVariabel("db_user"),
- $this->getVariabel("db_pass"),
- $this->getVariabel("db_data")
- );
-
- if($this->database->isError){
- exit($this->database->getError());
- }
-
- unset($this->variabel['db_host']);
- unset($this->variabel['db_user']);
- unset($this->variabel['db_pass']);
- unset($this->variabel['db_data']);
- }
-
- private function loadPages(){
- if($this->websocket){
- $load = array(
- $this->get_base_part()."lib\\define.php",
- $this->get_base_part()."lib\\db.php",
- $this->get_base_part()."lib\\protokol\\Protokol.php",
- $this->get_base_part()."lib\\db\\mysqli.php"
- );
- }else{
- $load = array(
- 'lib/define.php',
- 'lib/db.php',
- 'lib/protokol/Protokol.php',
- 'lib/db/mysqli.php'
- );
- }
-
- for($i=0;$iwebsocket)
- include($this->get_base_part(3)."config.php");
- else
- include("../../config.php");
- $this->variabel['db_host'] = $db_host;
- $this->variabel['db_user'] = $db_user;
- $this->variabel['db_pass'] = $db_pass;
- $this->variabel['db_data'] = $db_name;
- }
-
- //user sektion
- private function userInit(){
- $this->initUser();
- $this->loadUserConfig();
- $this->setLang($this->userConfig['lang']);
- $this->variabel["cid"] = $this->post("channel") ? $this->getCidFromChannel($this->post("channel")) : 1;
- }
-
- private function convert_image($img){
- if(empty($img) || !trim($img)){
- $img = "../../images/avatars/noavatar100.png";
- }else{
- $img = "../../images/avatars/".$img;
- }
-
- return $img;
- }
-
- private function initUser(){
- if($this->login()){
- //do nothing :)
- }else{
- $this->json['location'] = "../../index.php?error=sessiong";
- exit(json_encode($this->json));
- }
- }
-
- private function get_nick_from_user_id($uid){
- if($this->websocket){
- foreach($this->clientObj AS $clientOBJ){
- if($clientOBJ->isLogin && $clientOBJ->user['user_id'] == $uid){
- return $clientOBJ->user['nick'];
- }
- }
-
- return null;
- }
- return null;
- }
-
- private function loadUserConfig(){
- $sql = $this->database->query("SELECT * FROM `".DB_PREFIX."chat_userConfig` WHERE `uid`='".($this->websocket ? $this->getVariabel("client")->user['id'] : $this->user['user_id'])."'");
- while($row = $sql->get()){
- $this->userConfig[$row['key']] = $row['value'];
- }
- }
-
- //variabel sektion
-
- private function getVariabel($key){
- if(empty($this->variabel[$key])){
- return null;
- }else{
- if(is_object($this->variabel[$key])){
- return $this->variabel[$key];
- }
- if(!is_array($this->variabel[$key]) && !trim($this->variabel[$key])){
- return null;
- }
-
- }
-
- return $this->variabel[$key];
- }
-
- private function loadVariabel(){
- $this->variabel['isPost'] = $this->get("isPost") ? true : false;
- $this->variabel['last_id'] = $this->get('li') ? (int)$this->get('li') : 0;
- }
-
- private function loadDatabaseConfig(){
- $data = $this->database->query("SELECT * FROM `".DB_PREFIX."settings_inf` WHERE `settings_inf`='chat'");
- while($row = $data->get()){
- $this->config[$row['settings_name']] = $row['settings_value'];
- }
- }
-
- private function getConfig($key){
- if(empty($this->config[$key])){
- return null;
- }
-
- return $this->config[$key];
- }
-
- //session sektion
- private function sessionInit(){
-
- //wee kontrol if header is sendt :)
- if(headers_sent()){
- exit("Header is allray sendt!");
- }
-
- if(!$this->isSessionStarted()){
- $this->startSession();
- }
- }
-
- private function ip(){
- return $_SERVER['REMOTE_ADDR'];
- }
-
- private function login(){
-
- if(empty($_COOKIE[COOKIE_PREFIX."user"])){
- return false;
- }
-
- $ucd = explode(".",$_COOKIE[COOKIE_PREFIX."user"]);
-
- $row = $this->database->query("SELECT * FROM `".DB_PREFIX."users` WHERE
- `user_id`='".(empty($ucd[0]) ? '0' : (int)$ucd[0])."'
- AND `user_status`='0'
- AND `user_actiontime`='0'")->get();
- if($this->database->isError){
- exit("Database error");
- }
-
- if(empty($row)){
- return false;
- }
-
- if($row['user_ip'] != $this->ip()){
- return false;
- }
-
- $this->protokol->set_user_data($row,null);
- $this->user = $row;
- return true;
- }
-
- private function startSession(){
- session_start();
- }
-
- private function isSessionStarted(){
- return (session_id() != '');
- }
-
- private function getSessionId(){
- return session_id();
- }
-
- //header sektion (post get session)
-
- private function get($key){
- if(empty($_GET[$key]) || !trim($_GET[$key])){
- return null;
- }
-
- return $_GET[$key];
- }
-
- private function post($key){
- if(empty($_POST[$key]) || !trim($_POST[$key])){
- return null;
- }
-
- return $_POST[$key];
- }
-
- public function session($name){
- if(empty($_SESSION[$name]) || !is_array($_SESSION[$name]) && !trim($_SESSION[$name])){
- return null;
- }
-
- return $_SESSION[$name];
- }
-
- //send message
-
- private function send_message_to_users($message){
- if($this->websocket){
-
- $input = $this->init_get_data();
-
- $this->display(
- $input['channel'],
- $this->getVariabel('client')->user['nick'],
- $message
- );
-
- for($i=0;$iclientObj);$i++){
- $client = $this->clientObj[$i];
- if(!$client->isLogin){
- continue;
- }
-
- if(!empty($client->channel[$this->getVariabel("cid")]) && !in_array($this->protokol->user['user_id'],$this->protokol->get_ignore($client->user['user_id']))){
- $client->message(array(
- 'cid' => $this->getVariabel("cid"),
- 'message' => $this->remove_bad_words($message),
- 'color' => $this->getVariabel("client")->user_config['textColor'],
- 'uid' => $this->getVariabel("client")->user['user_id'],
- 'nick' => $this->getVariabel("client")->user['nick'],
- 'channel' => $this->protokol->get_channel_by_id($this->getVariabel("cid")),
- 'img' => $this->getVariabel("client")->user['user_avatar']
- ));
- }
- }
- }
- }
-
- private function sendBotMessage($cid,$message,$color = false, $uid = false){
- if($this->websocket){
- $input = $this->init_get_data();
- $this->display(
- $input['channel'],
- 'Bot',
- $message
- );
- for($i=0;$iclientObj);$i++){
- $client = $this->clientObj[$i];
- if(!$client->isLogin){
- continue;
- }
- if(!empty($client->channel[$cid])){
- $client->bot_message(array(
- 'cid' => $cid,
- 'message' => $message,
- 'color' => ($color === false ? $this->getConfig("botTextColor") : $color),
- 'uid' => $uid !== false ? $uid : $this->getVariabel("client")->user['user_id'],
- 'nick' => $uid !== false ? $this->get_nick_from_user_id($uid) : $this->getVariabel("client")->user['nick'],
- 'channel' => $this->protokol->get_channel_by_id($cid),
- 'img' => $this->getVariabel("client")->user['user_avatar']
- ));
- }
- }
- return;
- }
-
- if(!$uid){
- $uid = $this->user['user_id'];
- }
-
- if($color === false){
- $color = $this->getConfig("botTextColor");
- }
-
- $data = $this->database->prepare("INSERT INTO `".DB_PREFIX."chat_message`
- (
- `uid`,
- `cid`,
- `isBot`,
- `time`,
- `message`,
- `messageColor`,
- `isMsg`,
- `msgTo`
- ) VALUE (
- '".(int)$uid."',
- '".(int)$cid."',
- '".Yes."',
- NOW(),
- {message},
- {color},
- '".No."',
- '0'
- )");
-
- $data->add("message",$message);
- $data->add("color",$color);
- $data->done();
- }
-
- private function sendBotPrivMessage($cid,$message,$color = false,$uid=null,$my=null){
-
- if($this->websocket){
- $this->display(
- ($cid === 1 ? 'Globel' : $this->protokol->get_channel_by_id($cid)),
- 'Bot',
- $message
- );
- for($i=0;$iclientObj);$i++){
- $client = $this->clientObj[$i];
- if(!$client->isLogin){
- continue;
- }
- $m = ($uid === null ? $this->getVariabel("client")->user['user_id'] : $uid);
- if(!empty($client->channel[$cid]) || $cid == 1){
- if($m==$client->user['user_id']){
- $client->bot_message(array(
- 'cid' => $cid,
- 'message' => $message,
- 'color' => ($color ? $color : 'yellow'),
- 'uid' => ($my === null ? $this->getVariabel("client")->user['user_id'] : $my),
- 'nick' => $this->getVariabel("client")->user['nick'],
- 'channel' => $this->protokol->get_channel_by_id($cid),
- 'img' => $this->getVariabel("client")->user['user_avatar'],
- ));
- }
- }
- }
- return;
- }
-
- $data = $this->database->prepare("INSERT INTO `".DB_PREFIX."chat_message`
- (
- `uid`,
- `cid`,
- `isBot`,
- `time`,
- `message`,
- `messageColor`,
- `isMsg`,
- `msgTo`
- ) VALUE (
- '".(int)($my === null ? $this->user['user_id'] : $my)."',
- '".(int)$cid."',
- '".Yes."',
- NOW(),
- {message},
- {color},
- '".Yes."',
- '".(int)($uid === null ? $this->user['user_id'] : $uid)."'
- )");
-
- $data->add("message",$message);
- $data->add("color",($color ? $color : 'yellow'));
- $data->done();
-
- if($this->database->isError)
- exit($this->database->getError());
- }
-
- private function ban($channel,$uid,$to,$nick){
- $cid = $this->getCidFromChannel($channel,false);
- $this->sendBotPrivMessage(1,"/ban ".$channel,"red",$uid,0);
-
- //Both Ajax and WebSocket need this (Websocket when admin write /update)
- $this->database->query("UPDATE `".DB_PREFIX."chat_member` SET `ban`='".Yes."', `banTo`='".(int)$to."' WHERE `uid`='".(int)$uid."' AND `cid`='".(int)$cid."'");
-
-
- $this->protokol->banUser($cid,$uid,$to);
- $this->sendBotMessage($cid,"/ban ".$nick,"red");
- }
-
- //Yes my dear :D
- private function kick($channel,$message = null,$uid = 0, $sendMessage = true){
- if($uid === 0){
- $uid = $this->protokol->user['user_id'];
- }
-
- if(!is_numeric($channel)){
- $cid = $this->getCidFromChannel($channel,false);
- }else{
- $cid = (int)$channel;
- }
-
- if($cid == 1){
- return;
- }
-
- if($sendMessage){
- $this->sendBotPrivMessage(
- 1,
- "/kick ".$channel.($message !== null ? ' '.$message : null),
- "red",
- $uid,
- $uid//kun for denne bruger :D
- );
- }
-
- $this->protokol->kick(
- $cid,
- $uid
- );
-
- if($sendMessage){
- $this->sendBotMessage($cid, "/kick".($message !== null ? " ".$message : null),"red",$uid);
- }
- }
-
- private function iADMIN(){
- if($this->protokol->user['user_level'] >= 102)
- return true;
- else
- return false;
- }
-
- private function iSUPERADMIN(){
- if($this->protokol->user['user_level'] == 103)
- return true;
- else
- return false;
- }
-
- private function display($channel,$nick,$msg){
- echo "[".$channel."] ".date("H:i")." ".$nick." ".$msg;
-
- echo "\r\n";
- }
-
- private function is_length_okay($text, $min=0,$max=1000){
- if(strlen($text) < $min){
- return self::text_min;
- }
-
- if(strlen($text) > $max){
- return self::text_max;
- }
-
- return true;
- }
- }
-
-$server = new Server((empty($socket) ? false : true));
\ No newline at end of file
diff --git a/socket.php b/socket.php
deleted file mode 100644
index 94a4543..0000000
--- a/socket.php
+++ /dev/null
@@ -1,304 +0,0 @@
- 0);
- public $user_config = array();
- public $channel = array('1' => array(
- 'id' => 1,
- 'uid' => 0,
- 'cid' => 1,
- 'lastActiv' => 0,
- 'isInAktiv' => No,
- 'ban' => No,
- 'banTo' => 0,
- ));
- private $data = array();
- public $ip = null;
- public $leave_chan = null;
- public $isLogin = false;
- private $cookie = false;
- public $aktiv = array();
- public $ignore = array();
- private $mysql = array();
-
- function kick($cid,$isBan = false){
- if(!empty($this->channel[$cid])){
- if(!$isBan)
- unset($this->channel[$cid]);
- }
- }
-
- function ban($cid){
- $this->kick($cid,true);
- }
-
- function socket_user_client($socket, DatabaseHandler $mysql){
- $this->socket = $socket;
- $this->mysql = $mysql;
- }
-
- function update_my_nick($newNick){
- $this->user['nick'] = $newNick;
- }
-
- function my_turn(){
-
- if(!$this->isLogin){
- return true;
- }
-
- if($this->user['user_ip'] != $this->ip()){
- return false;
- }
-
- return true;
- }
-
- function login($cookie){
- $this->cookie = $this->parseCookie($cookie);
-
- if(!$this->cookie(COOKIE_PREFIX."user")){
- return false;
- }
-
- $user_ip = $this->ip();
- $user_cookie = $this->cookie(COOKIE_PREFIX."user");
- //vi spliter den ad ;)
- $user_cookie_data = explode(".",$user_cookie);
-
- $sql = $this->mysql->query("SELECT * FROM `".DB_PREFIX."users` WHERE
- `user_id`='".(empty($user_cookie_data[0]) ? '0' : (int)$user_cookie_data[0])."'
- AND `user_status`='0'
- AND `user_actiontime`='0'");
- $row = $sql->get();
-
- if(empty($row)){
- echo "empty row";
- return false;
- }
-
- if($row['user_ip'] != $user_ip){
- echo "Fandt bruger men ip passer ikke\r\nIp var '".$user_ip."'\r\n";
- return false;
- }
-
- echo "User is now login: ".$row['nick']."\r\n";
- $this->isLogin = true;
- $this->user = $row;
-
- $this->channel[1]['uid'] = $this->user['user_id'];
-
- $this->get_user_config();
-
- return true;
- }
-
- function read($length = 1024){
- return socket_read($this->socket, $length);
- }
-
- function write($msg,$ishandshake = false,$mask = true){
- if(!$this->isLogin && !$ishandshake){
- echo "Prøvede at skrive til en som ikke er logget ind ";
- return false;
- }
-
- //vi kontrollere nu at brugeren ikke er bannet i denne channel :)
- if(empty($this->channel[$msg['message'][0]['cid']]) || $this->channel[$msg['message'][0]['cid']]['ban'] == Yes)
- return false;
-
- $msg['message'][0]['message'] = htmlentities($msg['message'][0]['message']);
- $msg = json_encode($msg);
-
- if($mask){
- $msg = $this->mask($msg);
- }
-
- socket_write($this->socket,$msg,strlen($msg));
- return true;
- }
-
- function ip(){
- if(!empty($this->data['ip'])){
- return $this->data['ip'];
- }
-
- socket_getpeername($this->socket,$ip);
- $this->data['ip'] = $ip;
- return $this->data['ip'];
- }
-
- function disconnect(){
- socket_close($this->socket);
- }
-
- function get(){
- $respons = socket_recv($this->socket, $buf, 1024, 0);
-
- if($respons >= 1){
- return false;
- }
-
- return $this->unmask($buf);
- }
-
- function message($data){
- Server::$message_id++;
- $this->write(array(
- 'message' => array(
- array(
- 'id' => Server::$message_id,
- 'message' => $data['message'],
- 'isMsg' => No,
- 'msgTo' => 0,
- 'messageColor' => $data['color'],
- 'isBot' => No,
- 'nick' => $data['nick'],
- 'time' => time(),
- 'cid' => $data['cid'],
- 'channel' => $data['channel'],
- 'cmid' => 0,
- 'uid' => $data['uid'],
- 'img' => $data['img'],
- 'isPriv' => No,
- 'privUid' => 0
- ),
- ),
- ));
- }
-
- function msg($data){
- Server::$message_id++;
- if(!$this->isLogin){
- echo "User is not login !\r\n";
- return;
- }
- $this->write(array(
- 'message' => array(
- array(
- 'id' => Server::$message_id,
- 'message' => $data['message'],
- 'isMsg' => Yes,
- 'msgTo' => $this->user['user_id'],
- 'messageColor' => 'yellow',
- 'isBot' => No,
- 'nick' => $data['nick'],
- 'time' => time(),
- 'cid' => $data['cid'],
- 'channel' => $data['channel'],
- 'cmid' => 0,
- 'uid' => $data['uid'],
- 'img' => $data['img'],
- 'isPriv' => No,
- 'privUid' => 0
- )
- )
- ));
- //message is now sendt ;)
- }
-
- function bot_message($data){
- Server::$message_id++;
- $this->write(array(
- 'message' => array(
- array(
- 'id' => Server::$message_id,
- 'message' => $data['message'],
- 'isMsg' => No,
- 'msgTo' => 0,
- 'messageColor' => $data['color'],
- 'isBot' => Yes,
- 'nick' => $data['nick'],
- 'time' => time(),
- 'cid' => $data['cid'],
- 'channel' => $data['channel'],
- 'cmid' => 0,
- 'uid' => $data['uid'],
- 'img' => $data['img'],
- 'isPriv' => No,
- 'privUid' => 0,
- ),
- ),
- ));
- }
-
- function unmask($text) {
- $length = ord($text[1]) & 127;
- if($length == 126) {
- $masks = substr($text, 4, 4);
- $data = substr($text, 8);
- }elseif($length == 127) {
- $masks = substr($text, 10, 4);
- $data = substr($text, 14);
- }else {
- $masks = substr($text, 2, 4);
- $data = substr($text, 6);
- }
- $text = "";
- for ($i = 0; $i < strlen($data); ++$i) {
- $text .= $data[$i] ^ $masks[$i%4];
- }
- return $text;
- }
-
- function update_user_config($key,$value){
- $this->user_config[$key] = $value;
- }
-
- private function get_user_config(){
- $sql = $this->mysql->query("SELECT * FROM `".DB_PREFIX."chat_userConfig` WHERE `uid`='".$this->user['user_id']."'");
- while($row = $sql->get()){
- $this->user_config[$row['key']] = $row['value'];
- }
-
- return $this->user_config;
- }
-
- private function cookie($name){
- if(empty($this->cookie[$name]) || !trim($this->cookie[$name])){
- return null;
- }
-
- return $this->cookie[$name];
- }
-
- private function parseCookie($string){
- $block = explode(";",$string);
- $return = array();
- for($i=0;$i> 8;
- $frame[3] = $data_length & 0xFF;
- }
-
- for($i=0;$i false,
+ 'host' => null,
+ 'port' => null,
+ 'config' => [
+ 'startChannel' => '#start'
+ ]
+);
+
+if(file_exists("include/websocket.txt")){
+ $data = unserialize(file_get_contents("include/websocket.txt"));
+ $json = [
+ 'isWebSocket' => true,
+ 'host' => $data['host'],
+ 'port' => $data['port'],
+ 'config' => $json["config"]
+ ];
+}
+
+init_ajax();
+exit(json_encode($json));
\ No newline at end of file
diff --git a/upload.php b/upload.php
deleted file mode 100644
index e3f06b4..0000000
--- a/upload.php
+++ /dev/null
@@ -1,52 +0,0 @@
-
"; - for($i=0;$i
- Error Number: ".$this->errorData[$i]['number']."
- Sql: ".$this->errorData[$i]['sql']; - } - - return $return; - } - - function strstwidth($tekst,$exp){ - return (strpos($tekst,$exp) === 0); - } - - function lastIndex(){ - return $this->head->insert_id; - } -} - -class DatabaseResult{ - private $sql = null; - private $main = null; - private $result = null; - - function DatabaseResult($sql,$main,$result){ - $this->main = $main; - $this->sql = $sql; - $this->result = $result; - } - - function get(){ - return @$this->result->fetch_assoc(); - } -} - -class DatabasePrepare{ - private $sql = null; - private $main = null; - - function DatabasePrepare($sql,DatabaseHandler $main){ - $this->sql = $sql; - $this->main = $main; - } - - function add($name,$context){ - $this->sql = str_replace( - "{".$name."}", - "'".$this->main->clean($context)."'", - $this->sql - ); - } - - function done(){ - return $this->main->query($this->sql); - } -} \ No newline at end of file diff --git a/lib/define.php b/lib/define.php deleted file mode 100644 index 4a648c4..0000000 --- a/lib/define.php +++ /dev/null @@ -1,3 +0,0 @@ -user = $array; - } - - function add_ignore($uid){ - $this->ignore[] = $uid; - $this->database->query("INSERT INTO `".DB_PREFIX."chat_ignore` - ( - `uid`, - `ignore` - ) VALUES( - '".$this->user['user_id']."', - '".$uid."' - )"); - } - - function remove_ignore($uid){ - if(($key = array_search($uid,$this->get_ignore())) !== false){ - unset($this->ignore[$key]); - $this->database->query("DELETE FROM `".DB_PREFIX."chat_ignore` WHERE `uid`='".(int)$this->user['user_id']."' AND `ignore`='".$uid."'"); - } - } - - function get_ignore($only_cahce = true){ - if(!$only_cahce || empty($this->ignore)){ - $datas = $this->database->query("SELECT `ignore` FROM `".DB_PREFIX."chat_ignore` WHERE `uid`='".(int)$this->user['user_id']."'"); - while($row = $datas->get()){ - $this->ignore[] = $row['ignore']; - } - } - - return $this->ignore; - } - - function Protokol(DatabaseHandler $mysql,Server $server){ - $this->database = $mysql; - $this->main = $server; - } - - function get_channel_list($onlye_cache = true){ - if(!$onlye_cache){ - $datas = $this->database->query("SELECT * FROM `".DB_PREFIX."chat_name`"); - while($row = $datas->get()){ - $data = $row; - unset($data['id']); - $this->channel[$row['id']] = $data; - } - } - - return $this->channel; - } - - function add_to_channel($cid){ - $this->database->query("INSERT INTO `".DB_PREFIX."chat_member` - (`uid`, - `cid`, - `lastActiv`, - `isInAktiv`, - `ban` - ) VALUE ( - '".(int)$this->user['user_id']."', - '".(int)$cid."', - NOW(), - '".No."', - '".No."' - )"); - - $id = $this->database->lastIndex(); - $this->my_channel[$id] = array( - 'uid' => $this->user['user_id'], - 'cid' => $cid, - 'lastActiv' => time(), - 'isInAktiv' => No, - 'ban' => No - ); - } - - function get_my_channel_list($only_cache = true){ - if($only_cache && !empty($this->my_channel)){ - return $this->my_channel; - } - - $this->my_channel = array();//unset all data :) - - $datas = $this->database->query("SELECT cm.*,cn.name - FROM `".DB_PREFIX."chat_member` AS cm - LEFT JOIN `".DB_PREFIX."chat_name` AS cn ON cn.id = cm.cid - WHERE cm.uid='".$this->user['user_id']."'"); - while($row = $datas->get()){ - $data = $row; - unset($data['id']); - $this->my_channel[$row['id']] = $data; - } - - return $this->my_channel; - } - - - function new_channel($name,$title = null,$isSystem = false){ - if($title === null){ - $title = $name; - } - - $data = $this->database->prepare("INSERT INTO `".DB_PREFIX."chat_name` - ( - `name`, - `isPriv`, - `uid`, - `title`, - `setTitle` - ) VALUE ( - {name}, - '".No."', - '0', - {title}, - '".$this->user['user_id']."' - )"); - - $data->add("name",$name); - $data->add("title",$title); - $data->done(); - - if($this->database->isError){ - exit($this->database->getError()); - } - - $id = $this->database->lastIndex(); - $this->channel[$id] = array( - 'name' => $name, - 'isPriv' => No, - 'uid' => 0, - 'title' => $title, - 'setTitle' => $this->user['user_id'], - ); - - $d = $this->channel[$id]; - $d['id'] = $id; - - return $d; - } - - function remove_ban($uid,$cid,$id,$r = true){ - $this->database->query("DELETE FROM `".DB_PREFIX."chat_member` - WHERE `uid`='".(int)$uid."' - AND `cid`='".(int)$cid."'"); - } - - function get_flood($cid){ - if(!$this->main->session("flood")){ - $flood = array(); - $_SESSION['flood'] = array(); - }else - $flood = $this->main->session("flood"); - - if(empty($flood[$cid])){ - return array(); - } - - return $flood[$cid]; - } - - function update_flood($flood,$cid){ - $_SESSION["flood"][$cid] = $flood; - } - - function update_nick($newNick){ - $this->user['nick'] = $newNick; - } - - function getBannetInChannel($cid){ - $data = $this->database->query("SELECT `uid` FROM `".DB_PREFIX."chat_member` WHERE `ban`='".Yes."' AND `cid`='".(int)$cid."'"); - $bannet = array(); - while($row = $data->get()){ - $bannet[] = $row['uid']; - } - - return $bannet; - } - - function banUser($cid,$uid,$banTo,$save = true){ - $this->database->query("UPDATE `".DB_PREFIX."chat_member` SET - `ban`='".Yes."', - `banTo`='".$banTo."' - WHERE `uid`='".$uid."' AND `cid`='".$cid."'"); - } - - function get_channel_by_id($id){ - if(!empty($this->channel[$id])){ - return $this->channel[$id]['name']; - } - - return "Bot"; - } - - function getUserInChannel($cid,$nick){ - $sql = $this->database->prepare("SELECT user.* - FROM `".DB_PREFIX."users` AS user - LEFT JOIN `".DB_PREFIX."chat_member` AS cm ON cm.uid = user.user_id - WHERE cm.cid='".(int)$cid."' - AND user.nick={nick}"); - - $sql->add("nick",$nick); - $user = $sql->done(); - - if($this->database->isError){ - exit($this->database->getError()); - } - - $user = $user->get(); - - if(empty($user)) - return false; - else - return $user; - } - - function getBanId($cid,$uid){ - $sql = $this->database->query("SELECT `id` - FROM `".DB_PREFIX."chat_member` - WHERE `cid`='".$cid."' - AND `uid`='".$uid."' - AND `ban`='".Yes."'"); - $data = $sql->get(); - - if(empty($data)) - return null; - else - return $data; - } - - function kick($cid,$uid){ - $this->database->query("DELETE FROM `".DB_PREFIX."chat_member` - WHERE `cid`='".$cid."' - AND `uid`='".$uid."'"); - } - - function updateConfig($key,$value){ - $sql = $this->database->prepare("UPDATE `".DB_PREFIX."chat_userConfig` SET `value`={value} WHERE `uid`={uid} AND `key`={key}"); - $sql->add("value",$value); - $sql->add("key",$key); - $sql->add("uid",$this->user['user_id']); - $sql->done(); - } - - function userConfig($key,$id = null){ - if($id === null) - $id = $this->user['user_id']; - - if(empty($this->userconfig[$id])) - $this->userconfig[$id] = $this->getUserConfig($id); - - if(empty($this->userconfig[$id][$key]) || !trim($this->userconfig[$id][$key])) - return null; - return $this->userconfig[$id][$key]; - - } - - private function getUserConfig($id){ - $sql = $this->database->query("SELECT * FROM `".DB_PREFIX."chat_userConfig` WHERE `uid`='".(int)$id."'"); - if($this->database->isError){ - exit($this->database->getError()); - } - $return = array(); - while($row = $sql->get()){ - $return[$row['key']] = $row['value']; - } - - return $return; - } - - function getConfig($key){}//not in use. only for websocket (yey); - function update(){}//not in use -} \ No newline at end of file diff --git a/lib/protokol/websocket.php b/lib/protokol/websocket.php deleted file mode 100644 index 57aa99f..0000000 --- a/lib/protokol/websocket.php +++ /dev/null @@ -1,247 +0,0 @@ -main = $server; - $this->mysql = $mysqli; - } - - function get_channel_by_id($id){ - foreach($this->channel AS $cid => $data){ - if($id == $cid){ - return $data['name']; - } - } - - return "Bot"; - } - - function get_ignore($uid = null){ - if($uid === null) - $uid = $this->user['user_id']; - return $this->client[$uid]->ignore; - } - - function add_ignore($uid){ - $this->client[$this->user['user_id']]->ignore[] = $uid; - } - - function remove_ignore($uid){ - if(($key = array_search($uid,$this->get_ignore())) !== false){ - unset($this->client[$this->user['user_id']]->ignore[$key]); - } - } - - function set_user_data($data,$client){ - $this->user = $data; - $this->client[$data['user_id']] = $client; - } - - function get_channel_list($e=false){ - return $this->channel; - } - - function get_my_channel_list(){ - if(empty($this->user['user_id'])){ - return array(); - } - - if(!empty($this->client[$this->user['user_id']]->channel)){ - return $this->client[$this->user['user_id']]->channel; - }else{ - return array(); - } - } - - function add_to_channel($cid){ - $id = count($this->client[$this->user['user_id']]->channel); - $this->client[$this->user['user_id']]->channel[$cid] = array( - 'id' => $id, - 'uid' => $this->user['user_id'], - 'cid' => $cid, - 'lastActiv' => time(), - 'isInAktiv' => No, - 'ban' => No, - 'name' => $this->channelNameCache[$cid] - ); - echo "\r\n".$this->channelNameCache[$cid]."\r\n\r\n"; - } - - function new_channel($name,$title = null,$isSystem = false){ - if($title === null) - $title = $name; - - $id = count($this->channel); - - if($id === 0 && !$isSystem){ - $this->new_channel("null","null channel",true); - $id = count($this->channel); - - } - if($id === 1 && !$isSystem){ - $this->new_channel("Bot","Global bot system",true); - $id = count($this->channel); - } - - $this->channelNameCache[$id] = $name; - - $this->channel[$id] = array( - 'id' => $id, - 'name' => $name, - 'isPriv' => No, - 'uid' => 0, - 'title' => $title, - 'setTitle' => 0, - 'isPm' => No, - ); - - $this->bannet[$id] = array(); - - return $this->channel[$id]; - } - - function turn($uid){ - if(in_array($uid,array_keys($this->client))){ - $this->user = $this->client[$uid]->user; - } - } - - function get_flood($cid){ - if(empty($this->flood[$this->user['user_id']])){ - $this->flood[$this->user['user_id']] = array(); - } - if(empty($this->flood[$this->user['user_id']][$cid])){ - $this->flood[$this->user['user_id']][$cid] = array(); - } - - return $this->flood[$this->user['user_id']][$cid]; - } - - function update_flood($flood,$cid){ - $this->flood[$this->user['user_id']][$cid] = $flood; - } - - function update_nick($newNick){ - $this->client[$this->user['user_id']]->user['nick'] = $newNick; - $this->user['nick'] = $newNick; - } - - function getUserInChannel($cid,$nick){ - foreach($this->client AS $object){ - if(strtolower($object->user['nick']) == strtolower($nick)){ - foreach($object->channel AS $channelID => $data){ - if($channelID == $cid){ - return $object->user; - } - } - } - } - - return false; - } - - function getBannetInChannel($cid){ - if(empty($this->bannet[$cid])) - return array(); - return $this->bannet[$cid]; - } - - function banUser($cid,$uid,$banTo,$save =true){ - $this->bannet[$cid][] = $uid; - $this->client[$uid]->channel[$cid]['ban'] = Yes; - $this->client[$uid]->channel[$cid]['banTo'] = $banTo; - if($save){ - $this->mysql->query("INSERT INTO `".DB_PREFIX."chat_member` ( - `uid`, - `cid`, - `lastActiv`, - `isInAktiv`, - `ban`, - `banTo` - ) VALUES ( - '".(int)$uid."', - '".(int)$cid."', - NOW(), - '".No."', - '".Yes."', - '".$banTo."' - )"); - } - } - - function remove_ban($uid,$cid,$id,$remove = true){ - unset($this->client[$uid]->channel[$cid]); - $i = array_search($uid,$this->bannet[$cid]); - unset($this->bannet[$cid][$i]); - if($remove){ - $this->mysql->query("DELETE FROM `".DB_PREFIX."chat_member` - WHERE `uid`='".$uid."' - AND `cid`='".$cid."'"); - } - } - - function getBanId($c,$u){return null;}//this protokol dosent need this :) - - function kick($cid,$uid){ - if(empty($this->client[$uid]->channel[$cid])){ - return false; - } - - unset($this->client[$uid]->channel[$cid]); - unset($this->client[$uid]->aktiv[$cid]); - return true; - } - - function updateConfig($key,$value){ - $this->client[$this->user['user_id']]->update_user_config($key,$value); - } - - function getConfig($key){ - $config = $this->client[$this->user['user_id']]->user_config; - if(empty($config[$key])) - return null; - else - return $config[$key]; - } - - function update(){ - foreach($this->bannet as $cid => $data){ - for($i=0;$i
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- | - | - - | -
|---|---|
| - | - - | -
| - | - - | -
| - | - |
-
-
-
-
- | - | ![](".IMAGES."php_save.png) |
-
|---|---|
| - - | -|
- ![](".IMAGES."no.png)
-
-
-";
\ No newline at end of file
diff --git a/page/index.php b/page/index.php
deleted file mode 100644
index 5bebbb9..0000000
--- a/page/index.php
+++ /dev/null
@@ -1 +0,0 @@
-Access deniad
\ No newline at end of file
diff --git a/pm.php b/pm.php
deleted file mode 100644
index 2b790be..0000000
--- a/pm.php
+++ /dev/null
@@ -1,8 +0,0 @@
-websocket = $websocket;
-
- $this->loadPages();
- $this->init_db();
- $this->init_system_setting();
- $this->init_lang();
- $this->loadVariabel();
- $this->loadDatabaseConfig();
- $this->init_protokol();
- if($this->protokol->use_session){
- $this->sessionInit();
- }
-
- $this->channel = $this->protokol->get_channel_list(false);
-
- if(!$this->websocket){
- $this->userInit();
- }
-
- if($this->websocket){
- $this->init_websocket();
- }else{
- if("socket" == $this->getConfig("protokol")){
- exit("This is not ajax webserver but WebSocket server!");
- }
- }
-
- //ajax only ;) if it is not ajax it will not work!
- if($this->getVariabel("isPost")){
- $this->handlePost();
- }else{
- $this->showMessage();
- }
-
- if($this->database->isError){
- exit($this->database->getError());
- }
-
- if(empty($this->json['message'])){
- $this->json['message'] = array();
- }
-
- exit(json_encode($this->json));
- }
-
- private function init_websocket(){
-
- if(!function_exists("socket_create")){
- exit("Missing socket create!");
- }
-
- if(($master = socket_create(AF_INET,SOCK_STREAM,SOL_TCP)) === false){
- exit("Denaid to create socket!");
- }
-
- if(socket_set_option($master,SOL_SOCKET,SO_REUSEADDR,1) === false){
- exit("Deinad to create socket");
- }
-
- if (!filter_var($this->getConfig("socketServer"), FILTER_VALIDATE_IP)) {
- $this->config['socketServer'] = gethostbyname($this->getConfig("socketServer"));
- }
-
- if(@socket_bind(
- $master,
- $this->getConfig("socketServer"),
- $this->getConfig("socketPort")
- ) === false){
- exit("Failt to bind socket");
- }
-
- if(socket_listen($master,20) === false){
- exit("Fail to listen socket");
- }
-
- $this->add_socket_client($master);
-
- while($this->websocket){
- $read = $this->client;
- $write = $ex = null;
-
- @socket_select($read,$write,$ex,null);
-
- foreach($read AS $socket){
- if($socket == $master){
- $client = socket_accept($socket);
- if($client < 0){
- echo "Error to accept socket!";
- continue;
- }else{
- $this->handle_new_connect($client);
- }
- continue;
- }
-
- $konto = $this->get_client($socket);
-
- if(!$konto->my_turn()){
- $this->remove_client($socket);
- continue;
- }
-
- $recv = @socket_recv($socket,$buf,1024,0);
- if($recv === false || $recv == 0){
- $this->remove_client($socket);
- continue;
- }
-
- $message = $konto->unmask($buf);
- if(!$message || $message == "undefined"){
- continue;
- }
-
- $this->postData = @json_decode($message,true);
- if(@json_last_error() != JSON_ERROR_NONE){
- $this->remove_client($socket);
- continue;
- }
-
-
- $this->variabel['client'] = $konto;
- if($konto->isLogin){
- $this->protokol->turn($konto->user['user_id']);
- $this->setLang($this->protokol->getConfig("lang"));
- }
- $this->re_cache_channel_id($this->postData['channel']);
- $this->handlePost();
-
- }
- }
- }
-
- private function handle_new_connect($new){
- $user = $this->add_socket_client($new);
-
- $head = array();
- //handshake :)
- $lines = explode("\r\n",$user->read());
- for($i=0;$i