From 404bfdc9a6828638b7b4f7851602e3fe77044025 Mon Sep 17 00:00:00 2001 From: Melanie Thielker Date: Sun, 29 Mar 2009 00:48:34 +0000 Subject: Finish the offline IM module (still needs a server). Add rudimentary support for the mute list (no functionality yet, but allows the RetrieveInstantMessages event to fire now). --- .../Avatar/InstantMessage/MuteListModule.cs | 138 +++++++++++++++++++++ .../Avatar/InstantMessage/OfflineMessageModule.cs | 69 +++++++++-- 2 files changed, 199 insertions(+), 8 deletions(-) create mode 100644 OpenSim/Region/CoreModules/Avatar/InstantMessage/MuteListModule.cs (limited to 'OpenSim/Region/CoreModules') diff --git a/OpenSim/Region/CoreModules/Avatar/InstantMessage/MuteListModule.cs b/OpenSim/Region/CoreModules/Avatar/InstantMessage/MuteListModule.cs new file mode 100644 index 0000000..41441b3 --- /dev/null +++ b/OpenSim/Region/CoreModules/Avatar/InstantMessage/MuteListModule.cs @@ -0,0 +1,138 @@ +/* + * Copyright (c) Contributors, http://opensimulator.org/ + * See CONTRIBUTORS.TXT for a full list of copyright holders. + * + * Redistribution and use in source and binary forms, with or without + * modification, are permitted provided that the following conditions are met: + * * Redistributions of source code must retain the above copyright + * notice, this list of conditions and the following disclaimer. + * * Redistributions in binary form must reproduce the above copyright + * notice, this list of conditions and the following disclaimer in the + * documentation and/or other materials provided with the distribution. + * * Neither the name of the OpenSim Project nor the + * names of its contributors may be used to endorse or promote products + * derived from this software without specific prior written permission. + * + * THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS'' AND ANY + * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED + * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE + * DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY + * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES + * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; + * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND + * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT + * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS + * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. + */ +using System; +using System.Collections.Generic; +using System.Reflection; +using log4net; +using Nini.Config; +using OpenMetaverse; +using OpenSim.Framework; +using OpenSim.Framework.Communications; +using OpenSim.Framework.Servers; +using OpenSim.Framework.Client; +using OpenSim.Region.Framework.Interfaces; +using OpenSim.Region.Framework.Scenes; + +namespace OpenSim.Region.CoreModules.Avatar.MuteList +{ + public class MuteListModule : IRegionModule + { + private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType); + + private bool enabled = true; + private List m_SceneList = new List(); + private string m_RestURL = String.Empty; + + public void Initialise(Scene scene, IConfigSource config) + { + if (!enabled) + return; + + IConfig cnf = config.Configs["Messaging"]; + if (cnf != null && cnf.GetString( + "MuteListModule", "None") != + "MuteListModule") + { + enabled = false; + return; + } + + lock (m_SceneList) + { + if (m_SceneList.Count == 0) + { + m_RestURL = cnf.GetString("MuteListURL", ""); + if (m_RestURL == "") + { + m_log.Error("[MUTE LIST] Module was enabled, but no URL is given, disabling"); + enabled = false; + return; + } + } + if (!m_SceneList.Contains(scene)) + m_SceneList.Add(scene); + + scene.EventManager.OnNewClient += OnNewClient; + } + } + + public void PostInitialise() + { + if (!enabled) + return; + + if (m_SceneList.Count == 0) + return; + + m_log.Debug("[MUTE LIST] Mute list enabled"); + } + + public string Name + { + get { return "MuteListModule"; } + } + + public bool IsSharedModule + { + get { return true; } + } + + public void Close() + { + } + + private IClientAPI FindClient(UUID agentID) + { + foreach (Scene s in m_SceneList) + { + ScenePresence presence = s.GetScenePresence(agentID); + if (presence != null && !presence.IsChildAgent) + return presence.ControllingClient; + } + return null; + } + + private void OnNewClient(IClientAPI client) + { + client.OnMuteListRequest += OnMuteListRequest; + } + + private void OnMuteListRequest(IClientAPI client, uint crc) + { + m_log.DebugFormat("[MUTE LIST] Got mute list requestg for crc {0}", crc); + string filename = "mutes"+client.AgentId.ToString(); + + IXfer xfer = client.Scene.RequestModuleInterface(); + if (xfer != null) + { + xfer.AddNewFile(filename, new Byte[0]); + client.SendMuteListUpdate(filename); + } + } + } +} + diff --git a/OpenSim/Region/CoreModules/Avatar/InstantMessage/OfflineMessageModule.cs b/OpenSim/Region/CoreModules/Avatar/InstantMessage/OfflineMessageModule.cs index 77bc9d7..814b2de 100644 --- a/OpenSim/Region/CoreModules/Avatar/InstantMessage/OfflineMessageModule.cs +++ b/OpenSim/Region/CoreModules/Avatar/InstantMessage/OfflineMessageModule.cs @@ -24,12 +24,15 @@ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. */ +using System; using System.Collections.Generic; using System.Reflection; using log4net; using Nini.Config; using OpenMetaverse; using OpenSim.Framework; +using OpenSim.Framework.Communications; +using OpenSim.Framework.Servers; using OpenSim.Framework.Client; using OpenSim.Region.Framework.Interfaces; using OpenSim.Region.Framework.Scenes; @@ -40,21 +43,36 @@ namespace OpenSim.Region.CoreModules.Avatar.InstantMessage { private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType); - private bool enabled = false; + private bool enabled = true; private List m_SceneList = new List(); + private string m_RestURL = String.Empty; public void Initialise(Scene scene, IConfigSource config) { + if (!enabled) + return; + IConfig cnf = config.Configs["Messaging"]; if (cnf != null && cnf.GetString( "OfflineMessageModule", "None") != "OfflineMessageModule") + { + enabled = false; return; - - enabled = true; + } lock (m_SceneList) { + if (m_SceneList.Count == 0) + { + m_RestURL = cnf.GetString("OfflineMessageURL", ""); + if (m_RestURL == "") + { + m_log.Error("[OFFLINE MESSAGING] Module was enabled, but no URL is given, disabling"); + enabled = false; + return; + } + } if (!m_SceneList.Contains(scene)) m_SceneList.Add(scene); @@ -64,6 +82,9 @@ namespace OpenSim.Region.CoreModules.Avatar.InstantMessage public void PostInitialise() { + if (!enabled) + return; + if (m_SceneList.Count == 0) return; @@ -80,6 +101,7 @@ namespace OpenSim.Region.CoreModules.Avatar.InstantMessage m_SceneList.Clear(); } + m_log.Error("[OFFLINE MESSAGING] No message transfer module is enabled. Diabling offline messages"); return; } @@ -107,7 +129,7 @@ namespace OpenSim.Region.CoreModules.Avatar.InstantMessage foreach (Scene s in m_SceneList) { ScenePresence presence = s.GetScenePresence(agentID); - if (!presence.IsChildAgent) + if (presence != null && !presence.IsChildAgent) return presence.ControllingClient; } return null; @@ -116,18 +138,49 @@ namespace OpenSim.Region.CoreModules.Avatar.InstantMessage private void OnNewClient(IClientAPI client) { client.OnRetrieveInstantMessages += RetrieveInstantMessages; + // TODO:: Remove when mute lists are supported + // + //client.OnEconomyDataRequest += OnEconomyDataRequest; } + // TODO: Remove method when mute lists are supported + // + //private void OnEconomyDataRequest(UUID agentID) + //{ + // IClientAPI client = FindClient(agentID); + // if (client == null) + // { + // m_log.ErrorFormat("[OFFLINE MESSAGING] Can't find client {0}", agentID.ToString()); + // return; + // } + // RetrieveInstantMessages(client); + //} + private void RetrieveInstantMessages(IClientAPI client) { - m_log.Debug("[OFFLINE MESSAGING] RetrieveInstantMessages called"); + m_log.DebugFormat("[OFFLINE MESSAGING] Retrieving stored messages for {0}", client.AgentId); + + Listmsglist = SynchronousRestObjectPoster.BeginPostObject>( + "POST", m_RestURL+"/RetrieveMessages/", client.AgentId); + + foreach (GridInstantMessage im in msglist) + { + DateTime saved = Util.ToDateTime((uint)im.timestamp); + + client.SendInstantMessage(new UUID(im.toAgentID), + "(saved " + saved.ToString() + ") " + im.message, + new UUID(im.fromAgentID), im.fromAgentName, + (byte)im.dialog, + (uint)im.timestamp); + } } private void UndeliveredMessage(GridInstantMessage im) { if (im.offline != 0) { - // TODO: Actually save it + bool success = SynchronousRestObjectPoster.BeginPostObject( + "POST", m_RestURL+"/SaveMessage/", im); if(im.dialog == (byte)InstantMessageDialog.MessageFromAgent) { @@ -137,9 +190,9 @@ namespace OpenSim.Region.CoreModules.Avatar.InstantMessage client.SendInstantMessage(new UUID(im.fromAgentID), "User is not logged in. "+ - "Message saved.", + (success ? "Message saved." : "Message not saved"), new UUID(im.toAgentID), "System", - (byte)InstantMessageDialog.BusyAutoResponse, + (byte)InstantMessageDialog.MessageFromAgent, (uint)Util.UnixTimeSinceEpoch()); } } -- cgit v1.1