2 files changed, 482 insertions, 0 deletions
diff --git a/OpenSim/Region/Environment/Modules/Avatar/Voice/AsterixVoice/AsteriskVoiceModule.cs b/OpenSim/Region/Environment/Modules/Avatar/Voice/AsterixVoice/AsteriskVoiceModule.cs
new file mode 100644
index 0000000..0d7de78
--- /dev/null
+++ b/OpenSim/Region/Environment/Modules/Avatar/Voice/AsterixVoice/AsteriskVoiceModule.cs
@@ -0,0 +1,285 @@
+/*
+ * 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;
+using System.Reflection;
+using libsecondlife;
+using log4net;
+using Nini.Config;
+using Nwc.XmlRpc;
+using OpenSim.Framework;
+using OpenSim.Framework.Communications.Cache;
+using OpenSim.Framework.Servers;
+using OpenSim.Region.Capabilities;
+using OpenSim.Region.Environment.Interfaces;
+using OpenSim.Region.Environment.Scenes;
+using Caps=OpenSim.Region.Capabilities.Caps;
+namespace OpenSim.Region.Environment.Modules.Avatar.Voice.AsterixVoice
+{
+    public class AsteriskVoiceModule : IRegionModule
+    {
+        private static readonly ILog m_log = 
+            LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
+        private Scene m_scene;
+        private IConfig m_config;
+        private string m_asterisk;
+        private string m_asterisk_password;
+        private string m_asterisk_salt;
+        private int m_asterisk_timeout;
+        private string m_sipDomain;
+        private string m_confDomain;
+        private static readonly string m_parcelVoiceInfoRequestPath = "0007/";
+        private static readonly string m_provisionVoiceAccountRequestPath = "0008/";
+        public void Initialise(Scene scene, IConfigSource config)
+        {
+            m_scene = scene;
+            m_config = config.Configs["AsteriskVoice"];
+            if (null == m_config) 
+            {
+                m_log.Info("[ASTERISKVOICE] no config found, plugin disabled");
+                return;
+            }
+            if (!m_config.GetBoolean("enabled", false)) 
+            {
+                m_log.Info("[ASTERISKVOICE] plugin disabled by configuration");
+                return;
+            }
+            m_log.Info("[ASTERISKVOICE] plugin enabled");
+            try {
+                m_sipDomain = m_config.GetString("sip_domain", String.Empty);
+                m_log.InfoFormat("[ASTERISKVOICE] using SIP domain {0}", m_sipDomain);
+                m_confDomain = m_config.GetString("conf_domain", String.Empty);
+                m_log.InfoFormat("[ASTERISKVOICE] using conf domain {0}", m_confDomain);
+                m_asterisk = m_config.GetString("asterisk_frontend", String.Empty);
+                m_asterisk_password = m_config.GetString("asterisk_password", String.Empty);
+                m_asterisk_timeout = m_config.GetInt("asterisk_timeout", 3000);
+                m_asterisk_salt = m_config.GetString("asterisk_salt", "Wuffwuff");
+                if (String.IsNullOrEmpty(m_asterisk)) throw new Exception("missing asterisk_frontend config parameter");
+                if (String.IsNullOrEmpty(m_asterisk_password)) throw new Exception("missing asterisk_password config parameter");
+                m_log.InfoFormat("[ASTERISKVOICE] using asterisk front end {0}", m_asterisk);
+                
+                scene.EventManager.OnRegisterCaps += OnRegisterCaps;
+            }
+            catch (Exception e) 
+            {
+                m_log.ErrorFormat("[ASTERISKVOICE] plugin initialization failed: {0}", e.Message);
+                m_log.DebugFormat("[ASTERISKVOICE] plugin initialization failed: {0}", e.ToString());
+                return;
+            }
+        }
+            
+        public void PostInitialise()
+        {
+        }
+        public void Close()
+        {
+        }
+        public string Name
+        {
+            get { return "AsteriskVoiceModule"; }
+        }
+        public bool IsSharedModule
+        {
+            get { return false; }
+        }
+        public void OnRegisterCaps(LLUUID agentID, Caps caps) 
+        {
+            m_log.DebugFormat("[ASTERISKVOICE] OnRegisterCaps: agentID {0} caps {1}", agentID, caps);
+            string capsBase = "/CAPS/" + caps.CapsObjectPath; 
+            caps.RegisterHandler("ParcelVoiceInfoRequest",
+                                 new RestStreamHandler("POST", capsBase + m_parcelVoiceInfoRequestPath, 
+                                                       delegate(string request, string path, string param) 
+                                                           {
+                                                               return ParcelVoiceInfoRequest(request, path, param, 
+                                                                                             agentID, caps);
+                                                           }));
+            caps.RegisterHandler("ProvisionVoiceAccountRequest",
+                                 new RestStreamHandler("POST", capsBase + m_provisionVoiceAccountRequestPath,
+                                                       delegate(string request, string path, string param)
+                                                           {
+                                                               return ProvisionVoiceAccountRequest(request, path, param,
+                                                                                                   agentID, caps);
+                                                           }));
+        }
+        
+        /// <summary>
+        /// Callback for a client request for ParcelVoiceInfo
+        /// </summary>
+        /// <param name="request"></param>
+        /// <param name="path"></param>
+        /// <param name="param"></param>
+        /// <param name="agentID"></param>
+        /// <param name="caps"></param>
+        /// <returns></returns>
+        public string ParcelVoiceInfoRequest(string request, string path, string param, 
+                                             LLUUID agentID, Caps caps) 
+        {
+            // we need to do:
+            // - send channel_uri: as "sip:regionID@m_sipDomain"
+            try
+            {
+                m_log.DebugFormat("[ASTERISKVOICE][PARCELVOICE]: request: {0}, path: {1}, param: {2}", 
+                                  request, path, param);
+                // setup response to client
+                Hashtable creds = new Hashtable();
+                creds["channel_uri"] = String.Format("sip:{0}@{1}", 
+                                                     m_scene.RegionInfo.RegionID, m_sipDomain);
+                
+                string regionName = m_scene.RegionInfo.RegionName;
+                ScenePresence avatar = m_scene.GetScenePresence(agentID);
+                if (null == m_scene.LandChannel) throw new Exception("land data not yet available");
+                LandData land = m_scene.GetLandData(avatar.AbsolutePosition.X, avatar.AbsolutePosition.Y);
+                                
+                LLSDParcelVoiceInfoResponse parcelVoiceInfo = 
+                    new LLSDParcelVoiceInfoResponse(regionName, land.localID, creds);
+                
+                string r = LLSDHelpers.SerialiseLLSDReply(parcelVoiceInfo);
+                // update region on asterisk-opensim frontend
+                Hashtable requestData = new Hashtable();
+                requestData["admin_password"] = m_asterisk_password;
+                requestData["region"] = m_scene.RegionInfo.RegionID.ToString();
+                if (!String.IsNullOrEmpty(m_confDomain))
+                {
+                    requestData["region"] += String.Format("@{0}", m_confDomain);
+                } 
+                ArrayList SendParams = new ArrayList();
+                SendParams.Add(requestData);
+                XmlRpcRequest updateAccountRequest = new XmlRpcRequest("region_update", SendParams);
+                XmlRpcResponse updateAccountResponse = updateAccountRequest.Send(m_asterisk, m_asterisk_timeout);
+                Hashtable responseData = (Hashtable)updateAccountResponse.Value;
+                
+                if (!responseData.ContainsKey("success")) throw new Exception("region_update call failed");
+                bool success = Convert.ToBoolean((string)responseData["success"]);
+                if (!success) throw new Exception("region_update failed");
+                m_log.DebugFormat("[ASTERISKVOICE][PARCELVOICE]: {0}", r);
+                return r;
+            }
+            catch (Exception e)
+            {
+                m_log.ErrorFormat("[ASTERISKVOICE][CAPS][PARCELVOICE]: {0}, retry later", e.Message);
+                m_log.DebugFormat("[ASTERISKVOICE][CAPS][PARCELVOICE]: {0} failed", e.ToString());
+                return "<llsd>undef</llsd>";
+            }
+        }
+        /// <summary>
+        /// Callback for a client request for Voice Account Details
+        /// </summary>
+        /// <param name="request"></param>
+        /// <param name="path"></param>
+        /// <param name="param"></param>
+        /// <param name="agentID"></param>
+        /// <param name="caps"></param>
+        /// <returns></returns>
+        public string ProvisionVoiceAccountRequest(string request, string path, string param, 
+                                                   LLUUID agentID, Caps caps) 
+        {
+            // we need to 
+            // - get user data from UserProfileCacheService
+            // - generate nonce for user voice account password
+            // - issue XmlRpc request to asterisk opensim front end:
+            //   + user: base 64 encoded user name (otherwise SL
+            //           client is unhappy)
+            //   + password: nonce
+            // - the XmlRpc call to asteris-opensim was successful:
+            //   send account details back to client
+            try
+            {
+                m_log.DebugFormat("[ASTERISKVOICE][PROVISIONVOICE]: request: {0}, path: {1}, param: {2}", 
+                                  request, path, param);
+                // get user data & prepare voice account response
+                string voiceUser = "x" + Convert.ToBase64String(agentID.GetBytes());
+                voiceUser = voiceUser.Replace('+', '-').Replace('/', '_');
+                CachedUserInfo userInfo = m_scene.CommsManager.UserProfileCacheService.GetUserDetails(agentID);
+                if (null == userInfo) throw new Exception("cannot get user details");
+                // we generate a nonce everytime
+                string voicePassword = "$1$" + Util.Md5Hash(DateTime.UtcNow.ToLongTimeString() + m_asterisk_salt);
+                LLSDVoiceAccountResponse voiceAccountResponse = 
+                    new LLSDVoiceAccountResponse(voiceUser, voicePassword);
+                string r = LLSDHelpers.SerialiseLLSDReply(voiceAccountResponse);
+                m_log.DebugFormat("[CAPS][PROVISIONVOICE]: {0}", r);
+                // update user account on asterisk frontend
+                Hashtable requestData = new Hashtable();
+                requestData["admin_password"] = m_asterisk_password;
+                requestData["username"] = voiceUser;
+                if (!String.IsNullOrEmpty(m_sipDomain))
+                {
+                    requestData["username"] += String.Format("@{0}", m_sipDomain);
+                } 
+                requestData["password"] = voicePassword;
+                ArrayList SendParams = new ArrayList();
+                SendParams.Add(requestData);
+                XmlRpcRequest updateAccountRequest = new XmlRpcRequest("account_update", SendParams);
+                XmlRpcResponse updateAccountResponse = updateAccountRequest.Send(m_asterisk, m_asterisk_timeout);
+                Hashtable responseData = (Hashtable)updateAccountResponse.Value;
+                
+                if (!responseData.ContainsKey("success")) throw new Exception("account_update call failed");
+                bool success = Convert.ToBoolean((string)responseData["success"]);
+                if (!success) throw new Exception("account_update failed");
+                return r;
+            }
+            catch (Exception e)
+            {
+                m_log.ErrorFormat("[ASTERISKVOICE][CAPS][PROVISIONVOICE]: {0}, retry later", e.Message);
+                m_log.DebugFormat("[ASTERISKVOICE][CAPS][PROVISIONVOICE]: {0} failed", e.ToString());
+                return "<llsd>undef</llsd>";
+            }
+        }
+    }
+}
+\ No newline at end of file
diff --git a/OpenSim/Region/Environment/Modules/Avatar/Voice/SIPVoice/SIPVoiceModule.cs b/OpenSim/Region/Environment/Modules/Avatar/Voice/SIPVoice/SIPVoiceModule.cs
new file mode 100644
index 0000000..8b7c3d0
--- /dev/null
+++ b/OpenSim/Region/Environment/Modules/Avatar/Voice/SIPVoice/SIPVoiceModule.cs
@@ -0,0 +1,197 @@
+/*
+ * 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;
+using System.Reflection;
+using libsecondlife;
+using log4net;
+using Nini.Config;
+using OpenSim.Framework;
+using OpenSim.Framework.Communications.Cache;
+using OpenSim.Framework.Servers;
+using OpenSim.Region.Capabilities;
+using OpenSim.Region.Environment.Interfaces;
+using OpenSim.Region.Environment.Scenes;
+using Caps=OpenSim.Region.Capabilities.Caps;
+namespace OpenSim.Region.Environment.Modules.Avatar.Voice.SIPVoice
+{
+    public class SIPVoiceModule : IRegionModule
+    {
+        private static readonly ILog m_log = 
+            LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
+        private Scene m_scene;
+        private IConfig m_config;
+        private string m_sipDomain;
+        private static readonly string m_parcelVoiceInfoRequestPath = "0007/";
+        private static readonly string m_provisionVoiceAccountRequestPath = "0008/";
+        public void Initialise(Scene scene, IConfigSource config)
+        {
+            m_scene = scene;
+            m_config = config.Configs["Voice"];
+            if (null == m_config || !m_config.GetBoolean("enabled", false)) 
+            {
+                m_log.Info("[VOICE] plugin disabled");
+                return;
+            }
+            m_log.Info("[VOICE] plugin enabled");
+            m_sipDomain = m_config.GetString("sip_domain", String.Empty);
+            if (String.IsNullOrEmpty(m_sipDomain))
+            {
+                m_log.Error("[VOICE] plugin mis-configured: missing sip_domain configuration");
+                m_log.Info("[VOICE] plugin disabled");
+                return;
+            }
+            m_log.InfoFormat("[VOICE] using SIP domain {0}", m_sipDomain);
+            scene.EventManager.OnRegisterCaps += OnRegisterCaps;
+        }
+        public void PostInitialise()
+        {
+        }
+        public void Close()
+        {
+        }
+        public string Name
+        {
+            get { return "VoiceModule"; }
+        }
+        public bool IsSharedModule
+        {
+            get { return false; }
+        }
+        public void OnRegisterCaps(LLUUID agentID, Caps caps) 
+        {
+            m_log.DebugFormat("[VOICE] OnRegisterCaps: agentID {0} caps {1}", agentID, caps);
+            string capsBase = "/CAPS/" + caps.CapsObjectPath; 
+            caps.RegisterHandler("ParcelVoiceInfoRequest",
+                                 new RestStreamHandler("POST", capsBase + m_parcelVoiceInfoRequestPath, 
+                                                       delegate(string request, string path, string param) 
+                                                           {
+                                                               return ParcelVoiceInfoRequest(request, path, param, 
+                                                                                             agentID, caps);
+                                                           }));
+            caps.RegisterHandler("ProvisionVoiceAccountRequest",
+                                 new RestStreamHandler("POST", capsBase + m_provisionVoiceAccountRequestPath,
+                                                       delegate(string request, string path, string param)
+                                                           {
+                                                               return ProvisionVoiceAccountRequest(request, path, param,
+                                                                                                   agentID, caps);
+                                                           }));
+        }
+        
+        /// <summary>
+        /// Callback for a client request for ParcelVoiceInfo
+        /// </summary>
+        /// <param name="request"></param>
+        /// <param name="path"></param>
+        /// <param name="param"></param>
+        /// <param name="agentID"></param>
+        /// <param name="caps"></param>
+        /// <returns></returns>
+        public string ParcelVoiceInfoRequest(string request, string path, string param, 
+                                             LLUUID agentID, Caps caps) 
+        {
+            try
+            {
+                m_log.DebugFormat("[VOICE][PARCELVOICE]: request: {0}, path: {1}, param: {2}", request, path, param);
+                // FIXME: get the creds from region file or from config
+                Hashtable creds = new Hashtable();
+                creds["channel_uri"] = String.Format("sip:{0}@{1}", agentID, m_sipDomain);
+                
+                string regionName = m_scene.RegionInfo.RegionName;
+                ScenePresence avatar = m_scene.GetScenePresence(agentID);
+                if (null == m_scene.LandChannel) throw new Exception("land data not yet available");
+                LandData land = m_scene.GetLandData(avatar.AbsolutePosition.X, avatar.AbsolutePosition.Y);
+                                
+                LLSDParcelVoiceInfoResponse parcelVoiceInfo = 
+                    new LLSDParcelVoiceInfoResponse(regionName, land.localID, creds);
+                
+                string r = LLSDHelpers.SerialiseLLSDReply(parcelVoiceInfo);
+                m_log.DebugFormat("[VOICE][PARCELVOICE]: {0}", r);
+                return r;
+            }
+            catch (Exception e)
+            {
+                m_log.ErrorFormat("[CAPS]: {0}, try again later", e.ToString());
+            }
+            
+            return null;
+        }
+        /// <summary>
+        /// Callback for a client request for Voice Account Details
+        /// </summary>
+        /// <param name="request"></param>
+        /// <param name="path"></param>
+        /// <param name="param"></param>
+        /// <param name="agentID"></param>
+        /// <param name="caps"></param>
+        /// <returns></returns>
+        public string ProvisionVoiceAccountRequest(string request, string path, string param, 
+                                                   LLUUID agentID, Caps caps) 
+        {
+            try
+            {
+                m_log.DebugFormat("[VOICE][PROVISIONVOICE]: request: {0}, path: {1}, param: {2}", 
+                                  request, path, param);
+                string voiceUser = "x" + Convert.ToBase64String(agentID.GetBytes());
+                voiceUser = voiceUser.Replace('+', '-').Replace('/', '_');
+                CachedUserInfo userInfo = m_scene.CommsManager.UserProfileCacheService.GetUserDetails(agentID);
+                if (null == userInfo) throw new Exception("cannot get user details");
+                LLSDVoiceAccountResponse voiceAccountResponse = 
+                    new LLSDVoiceAccountResponse(voiceUser, "$1$" + userInfo.UserProfile.PasswordHash);
+                string r = LLSDHelpers.SerialiseLLSDReply(voiceAccountResponse);
+                m_log.DebugFormat("[CAPS][PROVISIONVOICE]: {0}", r);
+                return r;
+            }
+            catch (Exception e)
+            {
+                m_log.ErrorFormat("[CAPS][PROVISIONVOICE]: {0}, retry later", e.Message);
+            }
+            return null;
+        }
+    }
+}
+\ No newline at end of file

diff --git a/OpenSim/Region/Environment/Modules/Avatar/Voice/AsterixVoice/AsteriskVoiceModule.cs b/OpenSim/Region/Environment/Modules/Avatar/Voice/AsterixVoice/AsteriskVoiceModule.cs new file mode 100644 index 0000000..0d7de78 --- /dev/null +++ b/OpenSim/Region/Environment/Modules/Avatar/Voice/AsterixVoice/AsteriskVoiceModule.cs
@@ -0,0 +1,285 @@
	1	/*
	2	* Copyright (c) Contributors, http://opensimulator.org/
	3	* See CONTRIBUTORS.TXT for a full list of copyright holders.
	4	*
	5	* Redistribution and use in source and binary forms, with or without
	6	* modification, are permitted provided that the following conditions are met:
	7	* * Redistributions of source code must retain the above copyright
	8	* notice, this list of conditions and the following disclaimer.
	9	* * Redistributions in binary form must reproduce the above copyright
	10	* notice, this list of conditions and the following disclaimer in the
	11	* documentation and/or other materials provided with the distribution.
	12	* * Neither the name of the OpenSim Project nor the
	13	* names of its contributors may be used to endorse or promote products
	14	* derived from this software without specific prior written permission.
	15	*
	16	* THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS'' AND ANY
	17	* EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
	18	* WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
	19	* DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY
	20	* DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
	21	* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
	22	* LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
	23	* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
	24	* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
	25	* SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
	26	*/
	27
	28	using System;
	29	using System.Collections;
	30	using System.Reflection;
	31	using libsecondlife;
	32	using log4net;
	33	using Nini.Config;
	34	using Nwc.XmlRpc;
	35	using OpenSim.Framework;
	36	using OpenSim.Framework.Communications.Cache;
	37	using OpenSim.Framework.Servers;
	38	using OpenSim.Region.Capabilities;
	39	using OpenSim.Region.Environment.Interfaces;
	40	using OpenSim.Region.Environment.Scenes;
	41	using Caps=OpenSim.Region.Capabilities.Caps;
	42
	43	namespace OpenSim.Region.Environment.Modules.Avatar.Voice.AsterixVoice
	44	{
	45	public class AsteriskVoiceModule : IRegionModule
	46	{
	47	private static readonly ILog m_log =
	48	LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
	49
	50	private Scene m_scene;
	51	private IConfig m_config;
	52	private string m_asterisk;
	53	private string m_asterisk_password;
	54	private string m_asterisk_salt;
	55	private int m_asterisk_timeout;
	56	private string m_sipDomain;
	57	private string m_confDomain;
	58
	59	private static readonly string m_parcelVoiceInfoRequestPath = "0007/";
	60	private static readonly string m_provisionVoiceAccountRequestPath = "0008/";
	61
	62	public void Initialise(Scene scene, IConfigSource config)
	63	{
	64	m_scene = scene;
	65	m_config = config.Configs["AsteriskVoice"];
	66
	67	if (null == m_config)
	68	{
	69	m_log.Info("[ASTERISKVOICE] no config found, plugin disabled");
	70	return;
	71	}
	72
	73	if (!m_config.GetBoolean("enabled", false))
	74	{
	75	m_log.Info("[ASTERISKVOICE] plugin disabled by configuration");
	76	return;
	77	}
	78	m_log.Info("[ASTERISKVOICE] plugin enabled");
	79
	80	try {
	81	m_sipDomain = m_config.GetString("sip_domain", String.Empty);
	82	m_log.InfoFormat("[ASTERISKVOICE] using SIP domain {0}", m_sipDomain);
	83
	84	m_confDomain = m_config.GetString("conf_domain", String.Empty);
	85	m_log.InfoFormat("[ASTERISKVOICE] using conf domain {0}", m_confDomain);
	86
	87	m_asterisk = m_config.GetString("asterisk_frontend", String.Empty);
	88	m_asterisk_password = m_config.GetString("asterisk_password", String.Empty);
	89	m_asterisk_timeout = m_config.GetInt("asterisk_timeout", 3000);
	90	m_asterisk_salt = m_config.GetString("asterisk_salt", "Wuffwuff");
	91	if (String.IsNullOrEmpty(m_asterisk)) throw new Exception("missing asterisk_frontend config parameter");
	92	if (String.IsNullOrEmpty(m_asterisk_password)) throw new Exception("missing asterisk_password config parameter");
	93	m_log.InfoFormat("[ASTERISKVOICE] using asterisk front end {0}", m_asterisk);
	94
	95	scene.EventManager.OnRegisterCaps += OnRegisterCaps;
	96	}
	97	catch (Exception e)
	98	{
	99	m_log.ErrorFormat("[ASTERISKVOICE] plugin initialization failed: {0}", e.Message);
	100	m_log.DebugFormat("[ASTERISKVOICE] plugin initialization failed: {0}", e.ToString());
	101	return;
	102	}
	103	}
	104
	105	public void PostInitialise()
	106	{
	107	}
	108
	109	public void Close()
	110	{
	111	}
	112
	113	public string Name
	114	{
	115	get { return "AsteriskVoiceModule"; }
	116	}
	117
	118	public bool IsSharedModule
	119	{
	120	get { return false; }
	121	}
	122
	123	public void OnRegisterCaps(LLUUID agentID, Caps caps)
	124	{
	125	m_log.DebugFormat("[ASTERISKVOICE] OnRegisterCaps: agentID {0} caps {1}", agentID, caps);
	126	string capsBase = "/CAPS/" + caps.CapsObjectPath;
	127	caps.RegisterHandler("ParcelVoiceInfoRequest",
	128	new RestStreamHandler("POST", capsBase + m_parcelVoiceInfoRequestPath,
	129	delegate(string request, string path, string param)
	130	{
	131	return ParcelVoiceInfoRequest(request, path, param,
	132	agentID, caps);
	133	}));
	134	caps.RegisterHandler("ProvisionVoiceAccountRequest",
	135	new RestStreamHandler("POST", capsBase + m_provisionVoiceAccountRequestPath,
	136	delegate(string request, string path, string param)
	137	{
	138	return ProvisionVoiceAccountRequest(request, path, param,
	139	agentID, caps);
	140	}));
	141	}
	142
	143	/// <summary>
	144	/// Callback for a client request for ParcelVoiceInfo
	145	/// </summary>
	146	/// <param name="request"></param>
	147	/// <param name="path"></param>
	148	/// <param name="param"></param>
	149	/// <param name="agentID"></param>
	150	/// <param name="caps"></param>
	151	/// <returns></returns>
	152	public string ParcelVoiceInfoRequest(string request, string path, string param,
	153	LLUUID agentID, Caps caps)
	154	{
	155	// we need to do:
	156	// - send channel_uri: as "sip:regionID@m_sipDomain"
	157	try
	158	{
	159	m_log.DebugFormat("[ASTERISKVOICE][PARCELVOICE]: request: {0}, path: {1}, param: {2}",
	160	request, path, param);
	161
	162
	163	// setup response to client
	164	Hashtable creds = new Hashtable();
	165	creds["channel_uri"] = String.Format("sip:{0}@{1}",
	166	m_scene.RegionInfo.RegionID, m_sipDomain);
	167
	168	string regionName = m_scene.RegionInfo.RegionName;
	169	ScenePresence avatar = m_scene.GetScenePresence(agentID);
	170	if (null == m_scene.LandChannel) throw new Exception("land data not yet available");
	171	LandData land = m_scene.GetLandData(avatar.AbsolutePosition.X, avatar.AbsolutePosition.Y);
	172
	173	LLSDParcelVoiceInfoResponse parcelVoiceInfo =
	174	new LLSDParcelVoiceInfoResponse(regionName, land.localID, creds);
	175
	176	string r = LLSDHelpers.SerialiseLLSDReply(parcelVoiceInfo);
	177
	178
	179	// update region on asterisk-opensim frontend
	180	Hashtable requestData = new Hashtable();
	181	requestData["admin_password"] = m_asterisk_password;
	182	requestData["region"] = m_scene.RegionInfo.RegionID.ToString();
	183	if (!String.IsNullOrEmpty(m_confDomain))
	184	{
	185	requestData["region"] += String.Format("@{0}", m_confDomain);
	186	}
	187
	188	ArrayList SendParams = new ArrayList();
	189	SendParams.Add(requestData);
	190	XmlRpcRequest updateAccountRequest = new XmlRpcRequest("region_update", SendParams);
	191	XmlRpcResponse updateAccountResponse = updateAccountRequest.Send(m_asterisk, m_asterisk_timeout);
	192	Hashtable responseData = (Hashtable)updateAccountResponse.Value;
	193
	194	if (!responseData.ContainsKey("success")) throw new Exception("region_update call failed");
	195
	196	bool success = Convert.ToBoolean((string)responseData["success"]);
	197	if (!success) throw new Exception("region_update failed");
	198
	199
	200	m_log.DebugFormat("[ASTERISKVOICE][PARCELVOICE]: {0}", r);
	201	return r;
	202	}
	203	catch (Exception e)
	204	{
	205	m_log.ErrorFormat("[ASTERISKVOICE][CAPS][PARCELVOICE]: {0}, retry later", e.Message);
	206	m_log.DebugFormat("[ASTERISKVOICE][CAPS][PARCELVOICE]: {0} failed", e.ToString());
	207
	208	return "<llsd>undef</llsd>";
	209	}
	210	}
	211
	212	/// <summary>
	213	/// Callback for a client request for Voice Account Details
	214	/// </summary>
	215	/// <param name="request"></param>
	216	/// <param name="path"></param>
	217	/// <param name="param"></param>
	218	/// <param name="agentID"></param>
	219	/// <param name="caps"></param>
	220	/// <returns></returns>
	221	public string ProvisionVoiceAccountRequest(string request, string path, string param,
	222	LLUUID agentID, Caps caps)
	223	{
	224	// we need to
	225	// - get user data from UserProfileCacheService
	226	// - generate nonce for user voice account password
	227	// - issue XmlRpc request to asterisk opensim front end:
	228	// + user: base 64 encoded user name (otherwise SL
	229	// client is unhappy)
	230	// + password: nonce
	231	// - the XmlRpc call to asteris-opensim was successful:
	232	// send account details back to client
	233	try
	234	{
	235	m_log.DebugFormat("[ASTERISKVOICE][PROVISIONVOICE]: request: {0}, path: {1}, param: {2}",
	236	request, path, param);
	237
	238	// get user data & prepare voice account response
	239	string voiceUser = "x" + Convert.ToBase64String(agentID.GetBytes());
	240	voiceUser = voiceUser.Replace('+', '-').Replace('/', '_');
	241
	242	CachedUserInfo userInfo = m_scene.CommsManager.UserProfileCacheService.GetUserDetails(agentID);
	243	if (null == userInfo) throw new Exception("cannot get user details");
	244
	245	// we generate a nonce everytime
	246	string voicePassword = "$1$" + Util.Md5Hash(DateTime.UtcNow.ToLongTimeString() + m_asterisk_salt);
	247	LLSDVoiceAccountResponse voiceAccountResponse =
	248	new LLSDVoiceAccountResponse(voiceUser, voicePassword);
	249	string r = LLSDHelpers.SerialiseLLSDReply(voiceAccountResponse);
	250	m_log.DebugFormat("[CAPS][PROVISIONVOICE]: {0}", r);
	251
	252
	253	// update user account on asterisk frontend
	254	Hashtable requestData = new Hashtable();
	255	requestData["admin_password"] = m_asterisk_password;
	256	requestData["username"] = voiceUser;
	257	if (!String.IsNullOrEmpty(m_sipDomain))
	258	{
	259	requestData["username"] += String.Format("@{0}", m_sipDomain);
	260	}
	261	requestData["password"] = voicePassword;
	262
	263	ArrayList SendParams = new ArrayList();
	264	SendParams.Add(requestData);
	265	XmlRpcRequest updateAccountRequest = new XmlRpcRequest("account_update", SendParams);
	266	XmlRpcResponse updateAccountResponse = updateAccountRequest.Send(m_asterisk, m_asterisk_timeout);
	267	Hashtable responseData = (Hashtable)updateAccountResponse.Value;
	268
	269	if (!responseData.ContainsKey("success")) throw new Exception("account_update call failed");
	270
	271	bool success = Convert.ToBoolean((string)responseData["success"]);
	272	if (!success) throw new Exception("account_update failed");
	273
	274	return r;
	275	}
	276	catch (Exception e)
	277	{
	278	m_log.ErrorFormat("[ASTERISKVOICE][CAPS][PROVISIONVOICE]: {0}, retry later", e.Message);
	279	m_log.DebugFormat("[ASTERISKVOICE][CAPS][PROVISIONVOICE]: {0} failed", e.ToString());
	280
	281	return "<llsd>undef</llsd>";
	282	}
	283	}
	284	}
	285	} \ No newline at end of file


diff --git a/OpenSim/Region/Environment/Modules/Avatar/Voice/SIPVoice/SIPVoiceModule.cs b/OpenSim/Region/Environment/Modules/Avatar/Voice/SIPVoice/SIPVoiceModule.cs new file mode 100644 index 0000000..8b7c3d0 --- /dev/null +++ b/OpenSim/Region/Environment/Modules/Avatar/Voice/SIPVoice/SIPVoiceModule.cs
@@ -0,0 +1,197 @@
	1	/*
	2	* Copyright (c) Contributors, http://opensimulator.org/
	3	* See CONTRIBUTORS.TXT for a full list of copyright holders.
	4	*
	5	* Redistribution and use in source and binary forms, with or without
	6	* modification, are permitted provided that the following conditions are met:
	7	* * Redistributions of source code must retain the above copyright
	8	* notice, this list of conditions and the following disclaimer.
	9	* * Redistributions in binary form must reproduce the above copyright
	10	* notice, this list of conditions and the following disclaimer in the
	11	* documentation and/or other materials provided with the distribution.
	12	* * Neither the name of the OpenSim Project nor the
	13	* names of its contributors may be used to endorse or promote products
	14	* derived from this software without specific prior written permission.
	15	*
	16	* THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS'' AND ANY
	17	* EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
	18	* WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
	19	* DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY
	20	* DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
	21	* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
	22	* LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
	23	* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
	24	* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
	25	* SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
	26	*/
	27
	28	using System;
	29	using System.Collections;
	30	using System.Reflection;
	31	using libsecondlife;
	32	using log4net;
	33	using Nini.Config;
	34	using OpenSim.Framework;
	35	using OpenSim.Framework.Communications.Cache;
	36	using OpenSim.Framework.Servers;
	37	using OpenSim.Region.Capabilities;
	38	using OpenSim.Region.Environment.Interfaces;
	39	using OpenSim.Region.Environment.Scenes;
	40	using Caps=OpenSim.Region.Capabilities.Caps;
	41
	42	namespace OpenSim.Region.Environment.Modules.Avatar.Voice.SIPVoice
	43	{
	44	public class SIPVoiceModule : IRegionModule
	45	{
	46	private static readonly ILog m_log =
	47	LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
	48
	49	private Scene m_scene;
	50	private IConfig m_config;
	51	private string m_sipDomain;
	52
	53	private static readonly string m_parcelVoiceInfoRequestPath = "0007/";
	54	private static readonly string m_provisionVoiceAccountRequestPath = "0008/";
	55
	56	public void Initialise(Scene scene, IConfigSource config)
	57	{
	58	m_scene = scene;
	59	m_config = config.Configs["Voice"];
	60
	61	if (null == m_config \|\| !m_config.GetBoolean("enabled", false))
	62	{
	63	m_log.Info("[VOICE] plugin disabled");
	64	return;
	65	}
	66	m_log.Info("[VOICE] plugin enabled");
	67
	68	m_sipDomain = m_config.GetString("sip_domain", String.Empty);
	69	if (String.IsNullOrEmpty(m_sipDomain))
	70	{
	71	m_log.Error("[VOICE] plugin mis-configured: missing sip_domain configuration");
	72	m_log.Info("[VOICE] plugin disabled");
	73	return;
	74	}
	75	m_log.InfoFormat("[VOICE] using SIP domain {0}", m_sipDomain);
	76
	77	scene.EventManager.OnRegisterCaps += OnRegisterCaps;
	78	}
	79
	80	public void PostInitialise()
	81	{
	82	}
	83
	84	public void Close()
	85	{
	86	}
	87
	88	public string Name
	89	{
	90	get { return "VoiceModule"; }
	91	}
	92
	93	public bool IsSharedModule
	94	{
	95	get { return false; }
	96	}
	97
	98	public void OnRegisterCaps(LLUUID agentID, Caps caps)
	99	{
	100	m_log.DebugFormat("[VOICE] OnRegisterCaps: agentID {0} caps {1}", agentID, caps);
	101	string capsBase = "/CAPS/" + caps.CapsObjectPath;
	102	caps.RegisterHandler("ParcelVoiceInfoRequest",
	103	new RestStreamHandler("POST", capsBase + m_parcelVoiceInfoRequestPath,
	104	delegate(string request, string path, string param)
	105	{
	106	return ParcelVoiceInfoRequest(request, path, param,
	107	agentID, caps);
	108	}));
	109	caps.RegisterHandler("ProvisionVoiceAccountRequest",
	110	new RestStreamHandler("POST", capsBase + m_provisionVoiceAccountRequestPath,
	111	delegate(string request, string path, string param)
	112	{
	113	return ProvisionVoiceAccountRequest(request, path, param,
	114	agentID, caps);
	115	}));
	116	}
	117
	118	/// <summary>
	119	/// Callback for a client request for ParcelVoiceInfo
	120	/// </summary>
	121	/// <param name="request"></param>
	122	/// <param name="path"></param>
	123	/// <param name="param"></param>
	124	/// <param name="agentID"></param>
	125	/// <param name="caps"></param>
	126	/// <returns></returns>
	127	public string ParcelVoiceInfoRequest(string request, string path, string param,
	128	LLUUID agentID, Caps caps)
	129	{
	130	try
	131	{
	132	m_log.DebugFormat("[VOICE][PARCELVOICE]: request: {0}, path: {1}, param: {2}", request, path, param);
	133
	134	// FIXME: get the creds from region file or from config
	135	Hashtable creds = new Hashtable();
	136
	137	creds["channel_uri"] = String.Format("sip:{0}@{1}", agentID, m_sipDomain);
	138
	139	string regionName = m_scene.RegionInfo.RegionName;
	140	ScenePresence avatar = m_scene.GetScenePresence(agentID);
	141	if (null == m_scene.LandChannel) throw new Exception("land data not yet available");
	142	LandData land = m_scene.GetLandData(avatar.AbsolutePosition.X, avatar.AbsolutePosition.Y);
	143
	144	LLSDParcelVoiceInfoResponse parcelVoiceInfo =
	145	new LLSDParcelVoiceInfoResponse(regionName, land.localID, creds);
	146
	147	string r = LLSDHelpers.SerialiseLLSDReply(parcelVoiceInfo);
	148	m_log.DebugFormat("[VOICE][PARCELVOICE]: {0}", r);
	149
	150	return r;
	151	}
	152	catch (Exception e)
	153	{
	154	m_log.ErrorFormat("[CAPS]: {0}, try again later", e.ToString());
	155	}
	156
	157	return null;
	158	}
	159
	160	/// <summary>
	161	/// Callback for a client request for Voice Account Details
	162	/// </summary>
	163	/// <param name="request"></param>
	164	/// <param name="path"></param>
	165	/// <param name="param"></param>
	166	/// <param name="agentID"></param>
	167	/// <param name="caps"></param>
	168	/// <returns></returns>
	169	public string ProvisionVoiceAccountRequest(string request, string path, string param,
	170	LLUUID agentID, Caps caps)
	171	{
	172	try
	173	{
	174	m_log.DebugFormat("[VOICE][PROVISIONVOICE]: request: {0}, path: {1}, param: {2}",
	175	request, path, param);
	176
	177	string voiceUser = "x" + Convert.ToBase64String(agentID.GetBytes());
	178	voiceUser = voiceUser.Replace('+', '-').Replace('/', '_');
	179
	180	CachedUserInfo userInfo = m_scene.CommsManager.UserProfileCacheService.GetUserDetails(agentID);
	181	if (null == userInfo) throw new Exception("cannot get user details");
	182
	183	LLSDVoiceAccountResponse voiceAccountResponse =
	184	new LLSDVoiceAccountResponse(voiceUser, "$1$" + userInfo.UserProfile.PasswordHash);
	185	string r = LLSDHelpers.SerialiseLLSDReply(voiceAccountResponse);
	186	m_log.DebugFormat("[CAPS][PROVISIONVOICE]: {0}", r);
	187	return r;
	188	}
	189	catch (Exception e)
	190	{
	191	m_log.ErrorFormat("[CAPS][PROVISIONVOICE]: {0}, retry later", e.Message);
	192	}
	193
	194	return null;
	195	}
	196	}
	197	} \ No newline at end of file