forums.smartfoxserver.com

Code: Select all

sendMessage: function () {
        if ($("#chatTextInput").val().length > 0) {
            controlPanel.buttonSound.play();
            var sParams = new SFS2X.SFSObject();
            sParams.putUtfString("playerFunction", "chat");
            sParams.putUtfString("message", $("#chatTextInput").val());
            sParams.putUtfString("type", "text");
            sfs.send(new SFS2X.ExtensionRequest("playerRequest", sParams));
            $("#chatTextInput").val("");
            console.log(sParams.getDump());
        }
    },

Code: Select all

public void handleClientRequest(User user, ISFSObject sfso) {
		SFSExtension ext = getParentExtension();
		String playerFunction = sfso.getUtfString("playerFunction");
		switch (playerFunction) {
		//other cases
		case "chat":
			ChatRequest chr=new ChatRequest(ext);
			chr.request(user, sfso);
			break;
		//other cases
		default:
			trace("no player function " + playerFunction);
			break;

		}

	}

Code: Select all

package com.package;

import java.util.ArrayList;

import com.simoncroft.livecasinohosts.databaseFunctions.DBInsert;
import com.smartfoxserver.v2.entities.Room;
import com.smartfoxserver.v2.entities.User;
import com.smartfoxserver.v2.entities.data.ISFSArray;
import com.smartfoxserver.v2.entities.data.ISFSObject;
import com.smartfoxserver.v2.entities.data.SFSObject;
import com.smartfoxserver.v2.extensions.SFSExtension;

public class ChatRequest {
	SFSExtension ext;

	public ChatRequest(SFSExtension extension) {
		ext = extension;
	}
	
	public void request(User user, ISFSObject sfso) {
		ext.trace("chat request");
		ext.trace(sfso.getDump());
		
		int localUserid = (int) user.getSession().getProperty("localUserid");
		Room room = user.getLastJoinedRoom();
		String messageType = sfso.getUtfString("type");
		ArrayList<User> recipients = new ArrayList<User>();
		ISFSObject msg = new SFSObject();
		msg.putUtfString("sender", user.getName());
		int transid = -1;
		String sql = "";

		Object dbObject = new Object[] {};

		switch (messageType) {
		case "text":
			msg.putUtfString("type", "text");
			for (User resident : room.getUserList()) {
				int userType = (int) resident.getSession().getProperty("userType");
				switch (userType) {
				case 1:
					if (!user.containsVariable("mute")) {
						recipients.add(resident);
					}
					break;
				case 2:
					if (!user.containsVariable("mute")) {
						recipients.add(resident);
					}
					break;
				case 3:
					recipients.add(resident);
					break;
				}
			}
			msg.putUtfString("message", sfso.getUtfString("message"));
			sql = "insert into chat (localUserid, tablename, username, message) values (?,?,?,?)";
			dbObject = new Object[] { localUserid, room.getName(), user.getName(), sfso.getUtfString("message") };
			break;
		case "phrase":
			msg.putUtfString("type", "text");
			recipients = (ArrayList<User>) room.getUserList();
			int phrase_id = Integer.parseInt(sfso.getUtfString("phrase"));
			ISFSArray chatPhrases = room.getVariable("chatPhrases").getSFSArrayValue();
			ISFSObject phraseObj = chatPhrases.getSFSObject(phrase_id);

			msg.putUtfString("message", phraseObj.getUtfString("phrase"));
			sql = "insert into chat (localUserid, tablename, username, message) values (?,?,?,?)";
			dbObject = new Object[] { localUserid, room.getName(), user.getName(), phraseObj.getUtfString("phrase") };

			break;
		case "emoticon":
			msg.putUtfString("type", "emoticon");
			recipients = (ArrayList<User>) room.getUserList();
			msg.putUtfString("emoticon", sfso.getUtfString("emoticon"));
			sql = "insert into chat (localUserid, tablename, username, emoticon) values (?,?,?,?)";
			dbObject = new Object[] { localUserid, room.getName(), user.getName(), sfso.getUtfString("emoticon") };
			break;
		case "private":
			recipients.add(user);
			User recipient = room.getUserByName(sfso.getUtfString("recipient"));
			recipients.add(recipient);
			msg.putUtfString("type", "private");
			msg.putUtfString("message", sfso.getUtfString("message"));
			sql = "insert into chat (localUserid, tablename, username, message) values (?,?,?,?)";
			dbObject = new Object[] { localUserid, room.getName(), user.getName(), sfso.getUtfString("message") };
			break;
		}

		ext.send("chat", msg, recipients);

		DBInsert dbi = new DBInsert(ext);
		transid = dbi.InsertWithID(sql, dbObject, "send chat");
		sql = "insert into chat_recipients (message_id, localUserid, username) values (?,?,?)";
		for (User recipient : recipients) {
			if (user != recipient && !recipient.isNpc()) {
				int rlocalUserid = (int) recipient.getSession().getProperty("localUserid");
				dbObject = new Object[] { transid, rlocalUserid, recipient.getName() };
				dbi.Insert(sql, dbObject, "send chat");
			}
		}
	}
}