Michael Bayne
61168c737c
the only circumstance where we're not getting sent our own message back to us. git-svn-id: svn+ssh://src.earth.threerings.net/narya/trunk@2654 542714f4-19e9-0310-aa3c-eee0fc999fb1
315 lines
12 KiB
Java
315 lines
12 KiB
Java
//
|
|
// $Id: SpeakProvider.java,v 1.8 2003/06/14 00:55:19 mdb Exp $
|
|
|
|
package com.threerings.crowd.chat.server;
|
|
|
|
import java.util.ArrayList;
|
|
import java.util.HashMap;
|
|
|
|
import com.samskivert.util.ObserverList;
|
|
|
|
import com.threerings.presents.data.ClientObject;
|
|
import com.threerings.presents.dobj.DObject;
|
|
import com.threerings.presents.dobj.MessageEvent;
|
|
import com.threerings.presents.server.InvocationProvider;
|
|
|
|
import com.threerings.crowd.Log;
|
|
import com.threerings.crowd.data.BodyObject;
|
|
import com.threerings.crowd.server.CrowdServer;
|
|
|
|
import com.threerings.crowd.chat.data.ChatCodes;
|
|
import com.threerings.crowd.chat.data.ChatMessage;
|
|
import com.threerings.crowd.chat.data.SpeakObject;
|
|
import com.threerings.crowd.chat.data.SystemMessage;
|
|
import com.threerings.crowd.chat.data.UserMessage;
|
|
|
|
/**
|
|
* Provides the back-end of the chat speaking facilities. A server entity
|
|
* can make "speech" available among the subscribers of a particular
|
|
* distributed object by constructing a speak provider and registering it
|
|
* with the invocation manager, then placing the resulting marshaller into
|
|
* the distributed object in question so that subscribers to that object
|
|
* can use it to generate "speak" requests on that object.
|
|
*/
|
|
public class SpeakProvider
|
|
implements InvocationProvider, ChatCodes
|
|
{
|
|
/**
|
|
* Used to prevent abitrary users from issuing speak requests.
|
|
*/
|
|
public static interface SpeakerValidator
|
|
{
|
|
/**
|
|
* Should return true if the supplied speaker is allowed to speak
|
|
* via the speak provider with which this validator was
|
|
* registered.
|
|
*/
|
|
public boolean isValidSpeaker (DObject speakObj, ClientObject speaker);
|
|
}
|
|
|
|
/**
|
|
* Creates a speak provider that will provide speech on the supplied
|
|
* distributed object.
|
|
*
|
|
* @param speakObj the object for which speech requests will be
|
|
* processed.
|
|
* @param validator an optional validator that can be used to prevent
|
|
* arbitrary users from using the speech services on this object.
|
|
*/
|
|
public SpeakProvider (DObject speakObj, SpeakerValidator validator)
|
|
{
|
|
_speakObj = speakObj;
|
|
_validator = validator;
|
|
}
|
|
|
|
/**
|
|
* Handles a {@link SpeakService#speak} request.
|
|
*/
|
|
public void speak (ClientObject caller, String message, byte mode)
|
|
{
|
|
// ensure that the speaker is valid
|
|
// TODO: broadcast should be handled more like a system message
|
|
// rather than as a mode for a user message so that we don't
|
|
// have to do this validation here. Or not.
|
|
if ((mode == BROADCAST_MODE) ||
|
|
!_validator.isValidSpeaker(_speakObj, caller)) {
|
|
Log.warning("Refusing invalid speak request " +
|
|
"[caller=" + caller.who() +
|
|
", speakObj=" + _speakObj.which() +
|
|
", message=" + message + ", mode=" + mode + "].");
|
|
|
|
} else {
|
|
// issue the speak message on our speak object
|
|
sendSpeak(_speakObj, ((BodyObject)caller).username,
|
|
null, message, mode);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Sends a speak notification to the specified place object
|
|
* originating with the specified speaker (the speaker optionally
|
|
* being a server entity that wishes to fake a "speak" message) and
|
|
* with the supplied message content.
|
|
*
|
|
* @param speakObj the object on which to generate the speak message.
|
|
* @param speaker the username of the user that generated the message
|
|
* (or some special speaker name for server messages).
|
|
* @param bundle null when the message originates from a real human,
|
|
* the bundle identifier that will be used by the client to translate
|
|
* the message text when the message originates from a server entity
|
|
* "faking" a chat message.
|
|
* @param message the text of the speak message.
|
|
*/
|
|
public static void sendSpeak (DObject speakObj, String speaker,
|
|
String bundle, String message)
|
|
{
|
|
sendSpeak(speakObj, speaker, bundle, message, ChatCodes.DEFAULT_MODE);
|
|
}
|
|
|
|
/**
|
|
* Sends a speak notification to the specified place object
|
|
* originating with the specified speaker (the speaker optionally
|
|
* being a server entity that wishes to fake a "speak" message) and
|
|
* with the supplied message content.
|
|
*
|
|
* @param speakObj the object on which to generate the speak message.
|
|
* @param speaker the username of the user that generated the message
|
|
* (or some special speaker name for server messages).
|
|
* @param bundle null when the message originates from a real human,
|
|
* the bundle identifier that will be used by the client to translate
|
|
* the message text when the message originates from a server entity
|
|
* "faking" a chat message.
|
|
* @param message the text of the speak message.
|
|
* @param mode the mode of the message, see {@link
|
|
* ChatCodes#DEFAULT_MODE}.
|
|
*/
|
|
public static void sendSpeak (DObject speakObj, String speaker,
|
|
String bundle, String message, byte mode)
|
|
{
|
|
sendMessage(speakObj, new UserMessage(message, bundle, speaker, mode));
|
|
}
|
|
|
|
/**
|
|
* Sends a system INFO message notification to the specified object with
|
|
* the supplied message content. A system message is one that will be
|
|
* rendered where the speak messages are rendered, but in a way that
|
|
* makes it clear that it is a message from the server.
|
|
*
|
|
* Info messages are sent when something happens that was neither
|
|
* directly triggered by the user, nor requires direct action.
|
|
*
|
|
* @param speakObj the object on which to deliver the message.
|
|
* @param bundle the name of the localization bundle that should be
|
|
* used to translate this system message prior to displaying it to the
|
|
* client.
|
|
* @param message the text of the message.
|
|
*/
|
|
public static void sendInfo (
|
|
DObject speakObj, String bundle, String message)
|
|
{
|
|
sendSystem(speakObj, bundle, message, SystemMessage.INFO);
|
|
}
|
|
|
|
/**
|
|
* Sends a system FEEDBACK message notification to the specified
|
|
* object with the supplied message content. A system message is one
|
|
* that will be rendered where the speak messages are rendered,
|
|
* but in a way that makes it clear that it is a message from the server.
|
|
*
|
|
* Feedback messages are sent in direct response to a user action,
|
|
* usually to indicate success or failure of the user's action.
|
|
*
|
|
* @param speakObj the object on which to deliver the message.
|
|
* @param bundle the name of the localization bundle that should be
|
|
* used to translate this system message prior to displaying it to the
|
|
* client.
|
|
* @param message the text of the message.
|
|
*/
|
|
public static void sendFeedback (
|
|
DObject speakObj, String bundle, String message)
|
|
{
|
|
sendSystem(speakObj, bundle, message, SystemMessage.FEEDBACK);
|
|
}
|
|
|
|
/**
|
|
* Sends a system ATTENTION message notification to the specified
|
|
* object with the supplied message content. A system message is one
|
|
* that will be rendered where the speak messages are rendered,
|
|
* but in a way that makes it clear that it is a message from the server.
|
|
*
|
|
* Attention messages are sent when something requires user action
|
|
* that did not result from direct action by the user.
|
|
*
|
|
* @param speakObj the object on which to deliver the message.
|
|
* @param bundle the name of the localization bundle that should be
|
|
* used to translate this system message prior to displaying it to the
|
|
* client.
|
|
* @param message the text of the message.
|
|
*/
|
|
public static void sendAttention (
|
|
DObject speakObj, String bundle, String message)
|
|
{
|
|
sendSystem(speakObj, bundle, message, SystemMessage.ATTENTION);
|
|
}
|
|
|
|
/**
|
|
* Send the specified system message on the specified dobj.
|
|
*/
|
|
protected static void sendSystem (
|
|
DObject speakObj, String bundle, String message, byte attLevel)
|
|
{
|
|
sendMessage(speakObj, new SystemMessage(message, bundle, attLevel));
|
|
}
|
|
|
|
/**
|
|
* Send the specified message on the specified object.
|
|
*/
|
|
public static void sendMessage (DObject speakObj, ChatMessage msg)
|
|
{
|
|
// post the message to the relevant object
|
|
speakObj.postMessage(CHAT_NOTIFICATION, new Object[] { msg });
|
|
|
|
// determine to whom this message will be delivered and register
|
|
// the message with all parties
|
|
if (speakObj instanceof SpeakObject) {
|
|
_messageMapper.message = msg;
|
|
((SpeakObject)speakObj).applyToListeners(_messageMapper);
|
|
_messageMapper.message = null;
|
|
} else {
|
|
Log.info("Unable to note listeners [dclass=" + speakObj.getClass() +
|
|
", msg=" + msg + "].");
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Returns a list of {@link ChatMessage} objects to which this user
|
|
* has been privy in the recent past.
|
|
*/
|
|
public static ArrayList getChatHistory (String username)
|
|
{
|
|
ArrayList history = getHistoryList(username);
|
|
pruneHistory(System.currentTimeMillis(), history);
|
|
return history;
|
|
}
|
|
|
|
/**
|
|
* Called to clear the chat history for the specified user.
|
|
*/
|
|
public static void clearHistory (String username)
|
|
{
|
|
// Log.info("Clearing history for " + username + ".");
|
|
_histories.remove(username);
|
|
}
|
|
|
|
/**
|
|
* Notes that the specified user was privy to the specified
|
|
* message. If {@link ChatMessage#timestamp} is not already filled in,
|
|
* it will be.
|
|
*/
|
|
protected static void noteMessage (String username, ChatMessage msg)
|
|
{
|
|
if (msg.timestamp == 0L) {
|
|
msg.timestamp = System.currentTimeMillis();
|
|
}
|
|
getHistoryList(username).add(msg);
|
|
// Log.info("Noted that " + username + " heard " + msg + ".");
|
|
}
|
|
|
|
/**
|
|
* Returns this user's chat history, creating one if necessary.
|
|
*/
|
|
protected static ArrayList getHistoryList (String username)
|
|
{
|
|
ArrayList history = (ArrayList)_histories.get(username);
|
|
if (history == null) {
|
|
_histories.put(username, history = new ArrayList());
|
|
}
|
|
return history;
|
|
}
|
|
|
|
/**
|
|
* Prunes all messages from this history which are expired.
|
|
*/
|
|
protected static void pruneHistory (long now, ArrayList history)
|
|
{
|
|
for (int ii = history.size()-1; ii >= 0; ii++) {
|
|
ChatMessage msg = (ChatMessage)history.get(ii);
|
|
if (now - msg.timestamp > HISTORY_EXPIRATION) {
|
|
Log.info("Expiring from history " + msg + ".");
|
|
history.remove(ii);
|
|
}
|
|
}
|
|
}
|
|
|
|
/** Used to note the recipients of a chat message. */
|
|
protected static class MessageMapper implements SpeakObject.ListenerOp
|
|
{
|
|
public ChatMessage message;
|
|
|
|
public void apply (int bodyOid) {
|
|
DObject dobj = CrowdServer.omgr.getObject(bodyOid);
|
|
if (dobj != null && dobj instanceof BodyObject) {
|
|
noteMessage(((BodyObject)dobj).username, message);
|
|
}
|
|
}
|
|
}
|
|
|
|
/** Our speech object. */
|
|
protected DObject _speakObj;
|
|
|
|
/** The entity that will validate our speakers. */
|
|
protected SpeakerValidator _validator;
|
|
|
|
/** Recent chat history for the server. */
|
|
protected static HashMap _histories = new HashMap();
|
|
|
|
/** Maintains a mapping of listener identifiers. */
|
|
protected static HashMap _identers = new HashMap();
|
|
|
|
/** Used to note the recipients of a chat message. */
|
|
protected static MessageMapper _messageMapper = new MessageMapper();
|
|
|
|
/** The amount of time before chat history becomes... history. */
|
|
protected static final long HISTORY_EXPIRATION = 5L * 60L * 1000L;
|
|
}
|