stop(); onEnterFrame = function () { var loaded = Math.ceil(_root.getBytesLoaded()*100/ _root.getBytesTotal()); _root.loading_txt.text="Loading:"+loaded+"%"; if (_root.getBytesLoaded() == _root.getBytesTotal()) { delete onEnterFrame; play(); } };

import User; Stage.scaleMode = "exactFit"; ASSetPropFlags(Object.prototype, "copyProperties", 1); #include "css.as" #include "chat.as" _root.IP="127.0.0.1"; _root.port = 1935; _root.room="chat"; _root.debug = false; if (_root.debug == true) { _root.IP = "127.0.0.1"; _root.port = "1935"; _root.pseudo="yarek"; _root.sexe="f"; } _root.rtmpString = "rtmp://"+_root.IP+':'+_root.port+"/"+_root.room; _root.infos = true; _root.userMustPublishWebcam = true; _root.colorText = '#00000'; _root.playSounds = true; _root.serverMessages = true; _root.showToolTips = true; _root.listenToTalk=true; _root.individualPrivateMessages = true; _root.showAdminsAsNormalUsers = true; // displays infos such: "user has joined the chat": //attachAudio _root.authentificate = false; _root.showMyWebcam = false; _root.authentificateURL = "http://"+_root.IP+"/red5chat/testlogin.php"; _root.infoUserURL = "http://"+_root.IP+"/red5chat/infouser.php"; // this url is to connect to your database page testAutoconnect.php // we will provide the following information $POST["username"] and $POST["password"] // if the result ?result=ok, the user is AUTHETIFCAITED, else it is not ! // look at the testAutoconnect.php provided with the red5chat and edit it ! // //LoadVars _root.autoConnect = false; // if you put the autoconnect to true, make sure to provide the params // pseudo=nickname, status= online, offline..., role=normal, admin..., sexe=m,f,a, // room = name of room, world = world ! // if autoconnect is true, the the login panel will not be shown // PRELOADER init_rooms(); //init_chat(); stop();

function init_rooms() { login_msg(""); _root.Application._visible=false; _root.login._visible=false; TransitionManager.start(rooms_mc, {type:Squeeze, direction:Transition.IN, duration:2, easing:Elastic.easeOut, dimension:1}); }

_root.login.login_txt.addEventListener("enter",loginKeyDown);^M _root.login.password_txt.addEventListener("enter",loginKeyDown);^M function loginKeyDown() {^M if (Key.isDown(Key.ENTER)) {^M _root.pseudo=_root.login.login_txt.text;^M _root.password=_root.login.password_txt.text;^M login_chat();^M } ^M } function checklogin(pseudo) {^M if (pseudo.length<2) return false;^M if (pseudo.length>20) return false;^M for (i=0; i<pseudo.length-1; i++) {^M var c = pseudo.charAt(i);^M x=(ord(c));^M if (x<=32) return false;^M if (x>122) return false;}^M return true ^M }^M ^M ^M _root.login.login_pb.onPress=function() { ^M _root.pseudo=_root.login.login_txt.text;^M _root.password=_root.login.password_txt.text;^M if (checklogin(_root.pseudo)) {^M login_chat();^M }^M }^M

function login_chat() { // _root.login.login_pb.enabled=false; _root.user=new User(_root.pseudo,_root.webcam,_root.password,"true",_root.role, _root.sex,_root.room,_root.world); //trace("_root.user.onlinseStatus="+_root.user.onlineStatus); //trace("_root.user.pseudo="+_root.user.pseudo); if (_root.user.pseudo=="") { login_msg("UserName is not valid !"); _root.login.login_pb.enabled=true; return; } if (_root.authentificate==true) { if (_root.user.password=="") { login_msg("Password is not valid !"); _root.login.login_pb.enabled=true; return; } login_msg(""); // authetificate : please check _root.authentificateURL and testlogin.php var myVars = new LoadVars(); myVars.pseudo = _root.user.pseudo; myVars.password = _root.user.password; //trace("*pseudo:"+myVars.pseudo+" pass="+myVars.password); //trace("authentificateURL="+_root.authentificateURL); myVars.sendAndLoad(_root.authentificateURL, myVars, ""); myVars.onLoad = function(success) { trace("myVars.status="+myVars.status); if (myVars.status=="ok") { _root.user.sex=myVars.sex; _root.user.role=myVars.role; //trace("myVars.sex="+myVars.sex); connect_chat(); } else { login_msg("Incorrect User or password "); _root.login.login_pb.enabled=true; return; } } } else { // no authentification ! if (_root.role!="a") _root.role="n"; _root.user.role=_root.role; _root.user.sex="m"; if (_root.login.female_rb.selected==true) _root.user.sex="f"; connect_chat(); } }

function connect_chat() { //trace("connecting to chat"); //params = pseudo status role sexe room world //trace(_root.rtmpString+"-"+_root.user.pseudo+"-"+_root.user.status+ "-"+_root.user.role+"-"+_root.user.sex+"-"+_root.user.room+"-"+_root.user.world); _root.user.webcam=!(Camera.get().muted); trace("_root.user.webcam="+_root.user.webcam); nc.connect(_root.rtmpString,_root.user.pseudo,_root.user.webcam,_root.user.onlineStatus, _root.user.role,_root.user.sex,_root.user.room,_root.user.world); nc.onStatus = function(info){ //trace("info.code="+info.code); if (info.code == "NetConnection.Connect.Success") { enter_chat(); } else if(info.code=="NetConnection.Connect.Rejected") { login_msg("UserName already in use !"); _root.login.login_pb.enabled=true; return; } else { //login_msg("**UserName already in use !"); _root.login.login_pb.enabled=true; return; } }; }

tcheun@enk:~/Chat/chat/src/org/red5/core$ diff Application.java /home/tcheun/chat/JAVA-RED5/src/chat/Application.java 1c1 < package org.red5.core; --- > package chat; 8c8,12 < --- > import org.red5.server.api.so.ISharedObject; > import org.red5.server.api.ScopeUtils; > import org.red5.server.api.so.ISharedObjectService; > import org.red5.server.api.*; > import org.red5.server.api.scheduling.*; 9a14 > import org.red5.server.api.service.ServiceUtils; 10a16 > import org.red5.server.api.service.IPendingServiceCallback; 16a23,25 > import java.util.HashMap; > // > // 157d165 < /* 168,181d175 < */ < Collection<Set<IConnection>> conCollection = scope.getConnections(); < for (Set<IConnection> cons : conCollection) { < for (IConnection conn : cons) { < if (conn != null) { < //do something with the connection < if (conn.equals(current)) continue; < if (conn instanceof IServiceCapableConnection) { < ((IServiceCapableConnection) conn).invoke("someClientMethod", new Object[]{"Hello World"}); < log.debug("sending notification to "+conn); < } < } < } < } 238d231 < /* 253,270d245 < */ < Collection<Set<IConnection>> conCollection = scope.getConnections(); < log.debug("send_private to "+sendToId+" "+msg); < for (Set<IConnection> cons : conCollection) { < for (IConnection conn : cons) { < if (conn != null) { < //do something with the connection < String id=conn.getClient().getId(); < if (!(sendToId.equals(id))) continue; < log.info("receive_private "+sendToId+" "+msg); < if (conn instanceof IServiceCapableConnection) { < ((IServiceCapableConnection) conn).invoke("receive_private", new Object[]{msg}); < log.info("received_private "+sendToId+" "+msg); < return; < } < } < } < } 279d253 < /* 293,310d266 < */ < Collection<Set<IConnection>> conCollection = scope.getConnections(); < log.debug("watches "+UserId); < for (Set<IConnection> cons : conCollection) { < for (IConnection conn : cons) { < if (conn != null) { < //do something with the connection < String id=conn.getClient().getId(); < < if (!(UserId.equals(id))) continue; < if (conn instanceof IServiceCapableConnection) { < ((IServiceCapableConnection) conn).invoke("watches", new Object[]{uid}); < log.info(uid+" is watching "+UserId); < return; < } < } < } < } 316d271 < /* 328,342d282 < */ < Collection<Set<IConnection>> conCollection = scope.getConnections(); < for (Set<IConnection> cons : conCollection) { < for (IConnection conn : cons) { < if (conn != null) { < //do something with the connection < String id=conn.getClient().getId(); < if (!(_id.equals(id))) continue; < if (conn instanceof IServiceCapableConnection) { < ((IServiceCapableConnection) conn).invoke("IhaveBeenBanned", new Object[]{_id}); < log.info("ban "+_id); < } < } < } < } 348d287 < /* 360,374d298 < */ < Collection<Set<IConnection>> conCollection = scope.getConnections(); < for (Set<IConnection> cons : conCollection) { < for (IConnection conn : cons) { < if (conn != null) { < //do something with the connection < String id=conn.getClient().getId(); < if (!(_id.equals(id))) continue; < if (conn instanceof IServiceCapableConnection) { < ((IServiceCapableConnection) conn).invoke("IhaveBeenKicked", new Object[]{_id}); < log.info("kick "+_id); < } < } < } < } 381d304 < /* 398,416d320 < */ < Collection<Set<IConnection>> conCollection = scope.getConnections(); < for (Set<IConnection> cons : conCollection) { < for (IConnection conn : cons) { < if (conn != null) { < //do something with the connection < String id=conn.getClient().getId(); < log.debug("id="+id+ " senTO="+DestinationID); < //if (sendTo.equals(id)) log.info("PAREIL"); else log.info("differents"); < < if (!(DestinationID.equals(id))) continue; < log.info("receive_private "+DestinationID+" "+msg); < if (conn instanceof IServiceCapableConnection) { < ((IServiceCapableConnection) conn).invoke("receivePrivateMsg", new Object[]{fromPseudo, msg}); < log.info("received_private "+DestinationID+" "+msg); < } < } < } < } 465a370 > IScope scope = conn.getScope(); 485c390 < // cherche si user d&#65533;j&#65533; dans la liste --- > // cherche si user d&#65533;j&#65533; dans la liste 488c393 < application.rejectConnection(newClient, {msg:"Nom d&#65533;j&#65533; utilis&#65533;, essayez de nouveau."}); --- > application.rejectConnection(newClient, {msg:"Nom d&#65533;j&#65533; utilis&#65533;, essayez de nouveau."});