/** * @file LLIMMgr.h * @brief Container for Instant Messaging * * $LicenseInfo:firstyear=2001&license=viewerlgpl$ * Second Life Viewer Source Code * Copyright (C) 2010, Linden Research, Inc. * * This library is free software; you can redistribute it and/or * modify it under the terms of the GNU Lesser General Public * License as published by the Free Software Foundation; * version 2.1 of the License only. * * This library is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU * Lesser General Public License for more details. * * You should have received a copy of the GNU Lesser General Public * License along with this library; if not, write to the Free Software * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA * * Linden Research, Inc., 945 Battery Street, San Francisco, CA 94111 USA * $/LicenseInfo$ */ #ifndef LL_LLIMVIEW_H #define LL_LLIMVIEW_H #include "../llui/lldockablefloater.h" #include "lleventtimer.h" #include "llinstantmessage.h" #include "lllogchat.h" #include "llvoicechannel.h" #include "llinitdestroyclass.h" #include "llcoros.h" #include "lleventcoro.h" class LLAvatarName; class LLFriendObserver; class LLCallDialogManager; class LLIMSpeakerMgr; /** * Timeout Timer for outgoing Ad-Hoc/Group IM sessions which being initialized by the server */ class LLSessionTimeoutTimer : public LLEventTimer { public: LLSessionTimeoutTimer(const LLUUID& session_id, F32 period) : LLEventTimer(period), mSessionId(session_id) {} virtual ~LLSessionTimeoutTimer() {}; /* virtual */ BOOL tick(); private: LLUUID mSessionId; }; /** * Model (MVC) for IM Sessions */ class LLIMModel : public LLSingleton<LLIMModel> { LLSINGLETON(LLIMModel); public: typedef std::list<LLSD> chat_message_list_t; struct LLIMSession : public boost::signals2::trackable { typedef enum e_session_type { // for now we have 4 predefined types for a session P2P_SESSION, GROUP_SESSION, ADHOC_SESSION, NONE_SESSION, } SType; LLIMSession(const LLUUID& session_id, const std::string& name, const EInstantMessage& type, const LLUUID& other_participant_id, const uuid_vec_t& ids, bool voice, bool has_offline_msg); virtual ~LLIMSession(); void sessionInitReplyReceived(const LLUUID& new_session_id); void addMessagesFromHistoryCache(const std::list<LLSD>& history); // From local file void addMessagesFromServerHistory(const LLSD& history, const std::string& target_from, const std::string& target_message, U32 timestamp); // From chat server void addMessage(const std::string& from, const LLUUID& from_id, const std::string& utf8_text, const std::string& time, const bool is_history, const bool is_region_msg, U32 timestamp); void onVoiceChannelStateChanged(const LLVoiceChannel::EState& old_state, const LLVoiceChannel::EState& new_state, const LLVoiceChannel::EDirection& direction); /** @deprecated */ static void chatFromLogFile(LLLogChat::ELogLineType type, const LLSD& msg, void* userdata); bool isOutgoingAdHoc() const; bool isAdHoc(); bool isP2P(); bool isGroupChat(); bool isP2PSessionType() const { return mSessionType == P2P_SESSION;} bool isAdHocSessionType() const { return mSessionType == ADHOC_SESSION;} bool isGroupSessionType() const { return mSessionType == GROUP_SESSION;} LLUUID generateOutgoingAdHocHash() const; //*TODO make private /** ad-hoc sessions involve sophisticated chat history file naming schemes */ void buildHistoryFileName(); void loadHistory(); LLUUID mSessionID; std::string mName; EInstantMessage mType; SType mSessionType; LLUUID mOtherParticipantID; uuid_vec_t mInitialTargetIDs; std::string mHistoryFileName; // Saved messages from the last minute of history read from the local group chat cache file std::string mLastHistoryCacheDateTime; chat_message_list_t mLastHistoryCacheMsgs; // connection to voice channel state change signal boost::signals2::connection mVoiceChannelStateChangeConnection; //does NOT include system messages and agent's messages S32 mParticipantUnreadMessageCount; // does include all incoming messages S32 mNumUnread; chat_message_list_t mMsgs; LLVoiceChannel* mVoiceChannel; LLIMSpeakerMgr* mSpeakers; bool mSessionInitialized; //true if calling back the session URI after the session has closed is possible. //Currently this will be false only for PSTN P2P calls. bool mCallBackEnabled; bool mTextIMPossible; bool mStartCallOnInitialize; //if IM session is created for a voice call bool mStartedAsIMCall; bool mHasOfflineMessage; bool mIsDNDsend; private: void onAdHocNameCache(const LLAvatarName& av_name); static LLUUID generateHash(const std::set<LLUUID>& sorted_uuids); boost::signals2::connection mAvatarNameCacheConnection; }; /** Session id to session object */ std::map<LLUUID, LLIMSession*> mId2SessionMap; typedef boost::signals2::signal<void(const LLSD&)> session_signal_t; session_signal_t mNewMsgSignal; session_signal_t mNoUnreadMsgsSignal; /** * Find an IM Session corresponding to session_id * Returns NULL if the session does not exist */ LLIMSession* findIMSession(const LLUUID& session_id) const; /** * Find an Ad-Hoc IM Session with specified participants * @return first found Ad-Hoc session or NULL if the session does not exist */ LLIMSession* findAdHocIMSession(const uuid_vec_t& ids); /** * Rebind session data to a new session id. */ void processSessionInitializedReply(const LLUUID& old_session_id, const LLUUID& new_session_id); boost::signals2::connection addNewMsgCallback(const session_signal_t::slot_type& cb ) { return mNewMsgSignal.connect(cb); } boost::signals2::connection addNoUnreadMsgsCallback(const session_signal_t::slot_type& cb ) { return mNoUnreadMsgsSignal.connect(cb); } /** * Create new session object in a model * @param name session name should not be empty, will return false if empty */ bool newSession(const LLUUID& session_id, const std::string& name, const EInstantMessage& type, const LLUUID& other_participant_id, const uuid_vec_t& ids, bool voice = false, bool has_offline_msg = false); bool newSession(const LLUUID& session_id, const std::string& name, const EInstantMessage& type, const LLUUID& other_participant_id, bool voice = false, bool has_offline_msg = false); /** * Remove all session data associated with a session specified by session_id */ bool clearSession(const LLUUID& session_id); /** * Sends no unread messages signal. */ void sendNoUnreadMessages(const LLUUID& session_id); /** * Populate supplied std::list with messages starting from index specified by start_index */ void getMessages(const LLUUID& session_id, std::list<LLSD>& messages, int start_index = 0, const bool sendNoUnreadMsgs = true); /** * Add a message to an IM Model - the message is saved in a message store associated with a session specified by session_id * and also saved into a file if log2file is specified. * It sends new message signal for each added message. */ void addMessage(const LLUUID& session_id, const std::string& from, const LLUUID& other_participant_id, const std::string& utf8_text, bool log2file = true, bool is_region_msg = false, U32 time_stamp = 0); void processAddingMessage(const LLUUID& session_id, const std::string& from, const LLUUID& from_id, const std::string& utf8_text, bool log2file, bool is_region_msg, U32 time_stamp); /** * Similar to addMessage(...) above but won't send a signal about a new message added */ LLIMModel::LLIMSession* addMessageSilently(const LLUUID& session_id, const std::string& from, const LLUUID& from_id, const std::string& utf8_text, bool log2file = true, bool is_region_msg = false, U32 timestamp = 0); /** * Add a system message to an IM Model */ void proccessOnlineOfflineNotification(const LLUUID& session_id, const std::string& utf8_text); /** * Get a session's name. * For a P2P chat - it's an avatar's name, * For a group chat - it's a group's name * For an incoming ad-hoc chat - is received from the server and is in a from of "<Avatar's name> Conference" * It is updated in LLIMModel::LLIMSession's constructor to localize the "Conference". */ const std::string getName(const LLUUID& session_id) const; /** * Get number of unread messages in a session with session_id * Returns -1 if the session with session_id doesn't exist */ const S32 getNumUnread(const LLUUID& session_id) const; /** * Get uuid of other participant in a session with session_id * Returns LLUUID::null if the session doesn't exist * * *TODO what to do with other participants in ad-hoc and group chats? */ const LLUUID& getOtherParticipantID(const LLUUID& session_id) const; /** * Get type of a session specified by session_id * Returns EInstantMessage::IM_COUNT if the session does not exist */ EInstantMessage getType(const LLUUID& session_id) const; /** * Get voice channel for the session specified by session_id * Returns NULL if the session does not exist */ LLVoiceChannel* getVoiceChannel(const LLUUID& session_id) const; /** * Get im speaker manager for the session specified by session_id * Returns NULL if the session does not exist */ LLIMSpeakerMgr* getSpeakerManager(const LLUUID& session_id) const; const std::string& getHistoryFileName(const LLUUID& session_id) const; static void sendLeaveSession(const LLUUID& session_id, const LLUUID& other_participant_id); static bool sendStartSession(const LLUUID& temp_session_id, const LLUUID& other_participant_id, const uuid_vec_t& ids, EInstantMessage dialog); static void sendTypingState(LLUUID session_id, LLUUID other_participant_id, BOOL typing); static void sendMessage(const std::string& utf8_text, const LLUUID& im_session_id, const LLUUID& other_participant_id, EInstantMessage dialog); // Adds people from speakers list (people with whom you are currently speaking) to the Recent People List static void addSpeakersToRecent(const LLUUID& im_session_id); void testMessages(); /** * Saves an IM message into a file */ bool logToFile(const std::string& file_name, const std::string& from, const LLUUID& from_id, const std::string& utf8_text); private: /** * Populate supplied std::list with messages starting from index specified by start_index without * emitting no unread messages signal. */ void getMessagesSilently(const LLUUID& session_id, std::list<LLSD>& messages, int start_index = 0); /** * Add message to a list of message associated with session specified by session_id */ bool addToHistory(const LLUUID& session_id, const std::string& from, const LLUUID& from_id, const std::string& utf8_text, bool is_region_msg, U32 timestamp); }; class LLIMSessionObserver { public: virtual ~LLIMSessionObserver() {} virtual void sessionAdded(const LLUUID& session_id, const std::string& name, const LLUUID& other_participant_id, BOOL has_offline_msg) = 0; virtual void sessionActivated(const LLUUID& session_id, const std::string& name, const LLUUID& other_participant_id) = 0; virtual void sessionVoiceOrIMStarted(const LLUUID& session_id) = 0; virtual void sessionRemoved(const LLUUID& session_id) = 0; virtual void sessionIDUpdated(const LLUUID& old_session_id, const LLUUID& new_session_id) = 0; }; class LLIMMgr : public LLSingleton<LLIMMgr> { LLSINGLETON(LLIMMgr); friend class LLIMModel; public: enum EInvitationType { INVITATION_TYPE_INSTANT_MESSAGE = 0, INVITATION_TYPE_VOICE = 1, INVITATION_TYPE_IMMEDIATE = 2 }; // Add a message to a session. The session can keyed to sesion id // or agent id. void addMessage(const LLUUID& session_id, const LLUUID& target_id, const std::string& from, const std::string& msg, bool is_offline_msg = false, const std::string& session_name = LLStringUtil::null, EInstantMessage dialog = IM_NOTHING_SPECIAL, U32 parent_estate_id = 0, const LLUUID& region_id = LLUUID::null, const LLVector3& position = LLVector3::zero, bool is_region_msg = false, U32 timestamp = 0); void addSystemMessage(const LLUUID& session_id, const std::string& message_name, const LLSD& args); // This adds a session to the talk view. The name is the local // name of the session, dialog specifies the type of // session. Since sessions can be keyed off of first recipient or // initiator, the session can be matched against the id // provided. If the session exists, it is brought forward. This // method accepts a group id or an agent id. Specifying id = NULL // results in an im session to everyone. Returns the uuid of the // session. LLUUID addSession(const std::string& name, EInstantMessage dialog, const LLUUID& other_participant_id, bool voice = false); // Adds a session using a specific group of starting agents // the dialog type is assumed correct. Returns the uuid of the session. // A session can be added to a floater specified by floater_id. LLUUID addSession(const std::string& name, EInstantMessage dialog, const LLUUID& other_participant_id, const std::vector<LLUUID>& ids, bool voice = false, const LLUUID& floater_id = LLUUID::null); /** * Creates a P2P session with the requisite handle for responding to voice calls. * * @param name session name, cannot be null * @param caller_uri - sip URI of caller. It should be always be passed into the method to avoid * incorrect working of LLVoiceChannel instances. See EXT-2985. */ LLUUID addP2PSession(const std::string& name, const LLUUID& other_participant_id, const std::string& voice_session_handle, const std::string& caller_uri); /** * Leave the session with session id. Send leave session notification * to the server and removes all associated session data * @return false if the session with specified id was not exist */ bool leaveSession(const LLUUID& session_id); void inviteToSession( const LLUUID& session_id, const std::string& session_name, const LLUUID& caller, const std::string& caller_name, EInstantMessage type, EInvitationType inv_type, const std::string& session_handle = LLStringUtil::null, const std::string& session_uri = LLStringUtil::null); void processIMTypingStart(const LLUUID& from_id, const EInstantMessage im_type); void processIMTypingStop(const LLUUID& from_id, const EInstantMessage im_type); // automatically start a call once the session has initialized void autoStartCallOnStartup(const LLUUID& session_id); // Calc number of all unread IMs S32 getNumberOfUnreadIM(); /** * Calculates number of unread IMs from real participants in all stored sessions */ S32 getNumberOfUnreadParticipantMessages(); // This method is used to go through all active sessions and // disable all of them. This method is usally called when you are // forced to log out or similar situations where you do not have a // good connection. void disconnectAllSessions(); BOOL hasSession(const LLUUID& session_id); static LLUUID computeSessionID(EInstantMessage dialog, const LLUUID& other_participant_id); void clearPendingInvitation(const LLUUID& session_id); void processAgentListUpdates(const LLUUID& session_id, const LLSD& body); LLSD getPendingAgentListUpdates(const LLUUID& session_id); void addPendingAgentListUpdates( const LLUUID& sessioN_id, const LLSD& updates); void clearPendingAgentListUpdates(const LLUUID& session_id); void addSessionObserver(LLIMSessionObserver *); void removeSessionObserver(LLIMSessionObserver *); //show error statuses to the user void showSessionStartError(const std::string& error_string, const LLUUID session_id); void showSessionEventError(const std::string& event_string, const std::string& error_string, const LLUUID session_id); void showSessionForceClose(const std::string& reason, const LLUUID session_id); static bool onConfirmForceCloseError(const LLSD& notification, const LLSD& response); /** * Start call in a session * @return false if voice channel doesn't exist **/ bool startCall(const LLUUID& session_id, LLVoiceChannel::EDirection direction = LLVoiceChannel::OUTGOING_CALL); /** * End call in a session * @return false if voice channel doesn't exist **/ bool endCall(const LLUUID& session_id); bool isVoiceCall(const LLUUID& session_id); void updateDNDMessageStatus(); bool isDNDMessageSend(const LLUUID& session_id); void setDNDMessageSent(const LLUUID& session_id, bool is_send); void addNotifiedNonFriendSessionID(const LLUUID& session_id); bool isNonFriendSessionNotified(const LLUUID& session_id); private: /** * Remove data associated with a particular session specified by session_id */ void removeSession(const LLUUID& session_id); // This simple method just iterates through all of the ids, and // prints a simple message if they are not online. Used to help // reduce 'hello' messages to the linden employees unlucky enough // to have their calling card in the default inventory. void noteOfflineUsers(const LLUUID& session_id, const std::vector<LLUUID>& ids); void noteMutedUsers(const LLUUID& session_id, const std::vector<LLUUID>& ids); void processIMTypingCore(const LLUUID& from_id, const EInstantMessage im_type, BOOL typing); static void onInviteNameLookup(LLSD payload, const LLUUID& id, const LLAvatarName& name); void notifyObserverSessionAdded(const LLUUID& session_id, const std::string& name, const LLUUID& other_participant_id, bool has_offline_msg); //Triggers when a session has already been added void notifyObserverSessionActivated(const LLUUID& session_id, const std::string& name, const LLUUID& other_participant_id); void notifyObserverSessionVoiceOrIMStarted(const LLUUID& session_id); void notifyObserverSessionRemoved(const LLUUID& session_id); void notifyObserverSessionIDUpdated(const LLUUID& old_session_id, const LLUUID& new_session_id); private: typedef std::list <LLIMSessionObserver *> session_observers_list_t; session_observers_list_t mSessionObservers; // EXP-901 // If "Only friends and groups can IM me" option is ON but the user got message from non-friend, // the user should be notified that to be able to see this message the option should be OFF. // This set stores session IDs in which user was notified. Need to store this IDs so that the user // be notified only one time per session with non-friend. typedef std::set<LLUUID> notified_non_friend_sessions_t; notified_non_friend_sessions_t mNotifiedNonFriendSessions; LLSD mPendingInvitations; LLSD mPendingAgentListUpdates; }; class LLCallDialogManager : public LLSingleton<LLCallDialogManager> { LLSINGLETON(LLCallDialogManager); ~LLCallDialogManager(); public: // static for convinience static void onVoiceChannelChanged(const LLUUID &session_id); static void onVoiceChannelStateChanged(const LLVoiceChannel::EState& old_state, const LLVoiceChannel::EState& new_state, const LLVoiceChannel::EDirection& direction, bool ended_by_agent); private: void initSingleton(); void onVoiceChannelChangedInt(const LLUUID &session_id); void onVoiceChannelStateChangedInt(const LLVoiceChannel::EState& old_state, const LLVoiceChannel::EState& new_state, const LLVoiceChannel::EDirection& direction, bool ended_by_agent); protected: std::string mPreviousSessionlName; std::string mCurrentSessionlName; LLIMModel::LLIMSession* mSession; LLVoiceChannel::EState mOldState; }; class LLCallDialog : public LLDockableFloater { public: LLCallDialog(const LLSD& payload); virtual ~LLCallDialog(); virtual BOOL postBuild(); void dockToToolbarButton(const std::string& toolbarButtonName); // check timer state /*virtual*/ void draw(); /*virtual*/ void onOpen(const LLSD& key); protected: // lifetime timer for a notification LLTimer mLifetimeTimer; // notification's lifetime in seconds S32 mLifetime; static const S32 DEFAULT_LIFETIME = 5; virtual bool lifetimeHasExpired(); virtual void onLifetimeExpired(); /** * Sets icon depend on session. * * If passed session_id is a group id group icon will be shown, otherwise avatar icon for participant_id * * @param session_id - UUID of session * @param participant_id - UUID of other participant */ void setIcon(const LLSD& session_id, const LLSD& participant_id); LLSD mPayload; private: LLDockControl::DocAt getDockControlPos(const std::string& toolbarButtonName); }; class LLIncomingCallDialog : public LLCallDialog { public: LLIncomingCallDialog(const LLSD& payload); ~LLIncomingCallDialog() { if (mAvatarNameCacheConnection.connected()) { mAvatarNameCacheConnection.disconnect(); } } /*virtual*/ BOOL postBuild(); /*virtual*/ void onOpen(const LLSD& key); static void onAccept(void* user_data); static void onReject(void* user_data); static void onStartIM(void* user_data); static void processCallResponse(S32 response, const LLSD& payload); private: void setCallerName(const std::string& ui_title, const std::string& ui_label, const std::string& call_type); void onAvatarNameCache(const LLUUID& agent_id, const LLAvatarName& av_name, const std::string& call_type); boost::signals2::connection mAvatarNameCacheConnection; /*virtual*/ void onLifetimeExpired(); }; class LLOutgoingCallDialog : public LLCallDialog { public: LLOutgoingCallDialog(const LLSD& payload); /*virtual*/ BOOL postBuild(); void show(const LLSD& key); static void onCancel(void* user_data); static const LLUUID OCD_KEY; private: // hide all text boxes void hideAllText(); }; // Globals extern LLIMMgr *gIMMgr; #endif // LL_LLIMView_H