123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871 |
- /*
- * 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 OpenSimulator 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.IO;
- using System.Net;
- using System.Net.Security;
- using System.Web;
- using System.Security.Cryptography.X509Certificates;
- using System.Text;
- using System.Xml;
- using System.Collections;
- using System.Collections.Generic;
- using System.Reflection;
- using OpenMetaverse;
- using log4net;
- using Nini.Config;
- using Nwc.XmlRpc;
- using OpenSim.Framework;
- using OpenSim.Framework.Communications.Cache;
- using OpenSim.Framework.Capabilities;
- using OpenSim.Framework.Servers;
- using OpenSim.Framework.Servers.HttpServer;
- using OpenSim.Region.Framework.Interfaces;
- using OpenSim.Region.Framework.Scenes;
- using Caps = OpenSim.Framework.Capabilities.Caps;
- using System.Text.RegularExpressions;
- namespace OpenSim.Region.OptionalModules.Avatar.Voice.FreeSwitchVoice
- {
- public class FreeSwitchVoiceModule : IRegionModule, IVoiceModule
- {
- private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
- private bool UseProxy = false;
- // Capability string prefixes
- private static readonly string m_parcelVoiceInfoRequestPath = "0007/";
- private static readonly string m_provisionVoiceAccountRequestPath = "0008/";
- private static readonly string m_chatSessionRequestPath = "0009/";
- // Control info
- private static bool m_WOF = true;
- private static bool m_pluginEnabled = false;
- // FreeSwitch server is going to contact us and ask us all
- // sorts of things.
- private static string m_freeSwitchServerUser;
- private static string m_freeSwitchServerPass;
- // SLVoice client will do a GET on this prefix
- private static string m_freeSwitchAPIPrefix;
- // We need to return some information to SLVoice
- // figured those out via curl
- // http://vd1.vivox.com/api2/viv_get_prelogin.php
- //
- // need to figure out whether we do need to return ALL of
- // these...
- private static string m_freeSwitchRealm;
- private static string m_freeSwitchSIPProxy;
- private static bool m_freeSwitchAttemptUseSTUN;
- // private static string m_freeSwitchSTUNServer;
- private static string m_freeSwitchEchoServer;
- private static int m_freeSwitchEchoPort;
- private static string m_freeSwitchDefaultWellKnownIP;
- private static int m_freeSwitchDefaultTimeout;
- // private static int m_freeSwitchSubscribeRetry;
- private static string m_freeSwitchUrlResetPassword;
- // private static IPEndPoint m_FreeSwitchServiceIP;
- private int m_freeSwitchServicePort;
- private string m_openSimWellKnownHTTPAddress;
- private string m_freeSwitchContext;
- private FreeSwitchDirectory m_FreeSwitchDirectory;
- private FreeSwitchDialplan m_FreeSwitchDialplan;
- private readonly Dictionary<string, string> m_UUIDName = new Dictionary<string, string>();
- private Dictionary<string, string> m_ParcelAddress = new Dictionary<string, string>();
-
- private Scene m_scene;
-
- private IConfig m_config;
- public void Initialise(Scene scene, IConfigSource config)
- {
- m_scene = scene;
- m_config = config.Configs["FreeSwitchVoice"];
- if (null == m_config)
- {
- m_log.Info("[FreeSwitchVoice] no config found, plugin disabled");
- return;
- }
- if (!m_config.GetBoolean("enabled", false))
- {
- m_log.Info("[FreeSwitchVoice] plugin disabled by configuration");
- return;
- }
- // This is only done the FIRST time this method is invoked.
- if (m_WOF)
- {
- m_pluginEnabled = true;
- m_WOF = false;
- try
- {
- m_freeSwitchServerUser = m_config.GetString("freeswitch_server_user", String.Empty);
- m_freeSwitchServerPass = m_config.GetString("freeswitch_server_pass", String.Empty);
- m_freeSwitchAPIPrefix = m_config.GetString("freeswitch_api_prefix", String.Empty);
-
- // XXX: get IP address of HTTP server. (This can be this OpenSim server or another, or could be a dedicated grid service or may live on the freeswitch server)
-
- string serviceIP = m_config.GetString("freeswitch_service_server", String.Empty);
- int servicePort = m_config.GetInt("freeswitch_service_port", 80);
- IPAddress serviceIPAddress = IPAddress.Parse(serviceIP);
- // m_FreeSwitchServiceIP = new IPEndPoint(serviceIPAddress, servicePort);
- m_freeSwitchServicePort = servicePort;
- m_freeSwitchRealm = m_config.GetString("freeswitch_realm", String.Empty);
- m_freeSwitchSIPProxy = m_config.GetString("freeswitch_sip_proxy", m_freeSwitchRealm);
- m_freeSwitchAttemptUseSTUN = m_config.GetBoolean("freeswitch_attempt_stun", true);
- // m_freeSwitchSTUNServer = m_config.GetString("freeswitch_stun_server", m_freeSwitchRealm);
- m_freeSwitchEchoServer = m_config.GetString("freeswitch_echo_server", m_freeSwitchRealm);
- m_freeSwitchEchoPort = m_config.GetInt("freeswitch_echo_port", 50505);
- m_freeSwitchDefaultWellKnownIP = m_config.GetString("freeswitch_well_known_ip", m_freeSwitchRealm);
- m_openSimWellKnownHTTPAddress = m_config.GetString("opensim_well_known_http_address", serviceIPAddress.ToString());
- m_freeSwitchDefaultTimeout = m_config.GetInt("freeswitch_default_timeout", 5000);
- // m_freeSwitchSubscribeRetry = m_config.GetInt("freeswitch_subscribe_retry", 120);
- m_freeSwitchUrlResetPassword = m_config.GetString("freeswitch_password_reset_url", String.Empty);
- m_freeSwitchContext = m_config.GetString("freeswitch_context", "default");
-
- if (String.IsNullOrEmpty(m_freeSwitchServerUser) ||
- String.IsNullOrEmpty(m_freeSwitchServerPass) ||
- String.IsNullOrEmpty(m_freeSwitchRealm) ||
- String.IsNullOrEmpty(m_freeSwitchAPIPrefix))
- {
- m_log.Error("[FreeSwitchVoice] plugin mis-configured");
- m_log.Info("[FreeSwitchVoice] plugin disabled: incomplete configuration");
- return;
- }
- // set up http request handlers for
- // - prelogin: viv_get_prelogin.php
- // - signin: viv_signin.php
- // - buddies: viv_buddy.php
- // - ???: viv_watcher.php
- // - signout: viv_signout.php
- if (UseProxy)
- {
- MainServer.Instance.AddHTTPHandler(String.Format("{0}/", m_freeSwitchAPIPrefix),
- ForwardProxyRequest);
- }
- else
- {
- MainServer.Instance.AddHTTPHandler(String.Format("{0}/viv_get_prelogin.php", m_freeSwitchAPIPrefix),
- FreeSwitchSLVoiceGetPreloginHTTPHandler);
-
- // RestStreamHandler h = new
- // RestStreamHandler("GET",
- // String.Format("{0}/viv_get_prelogin.php", m_freeSwitchAPIPrefix), FreeSwitchSLVoiceGetPreloginHTTPHandler);
- // MainServer.Instance.AddStreamHandler(h);
- MainServer.Instance.AddHTTPHandler(String.Format("{0}/viv_signin.php", m_freeSwitchAPIPrefix),
- FreeSwitchSLVoiceSigninHTTPHandler);
- // set up http request handlers to provide
- // on-demand FreeSwitch configuration to
- // FreeSwitch's mod_curl_xml
- MainServer.Instance.AddHTTPHandler(String.Format("{0}/freeswitch-config", m_freeSwitchAPIPrefix),
- FreeSwitchConfigHTTPHandler);
- MainServer.Instance.AddHTTPHandler(String.Format("{0}/viv_buddy.php", m_freeSwitchAPIPrefix),
- FreeSwitchSLVoiceBuddyHTTPHandler);
- }
-
-
-
- m_log.InfoFormat("[FreeSwitchVoice] using FreeSwitch server {0}", m_freeSwitchRealm);
-
- m_FreeSwitchDirectory = new FreeSwitchDirectory();
- m_FreeSwitchDialplan = new FreeSwitchDialplan();
- m_pluginEnabled = true;
- m_WOF = false;
- m_log.Info("[FreeSwitchVoice] plugin enabled");
- }
- catch (Exception e)
- {
- m_log.ErrorFormat("[FreeSwitchVoice] plugin initialization failed: {0}", e.Message);
- m_log.DebugFormat("[FreeSwitchVoice] plugin initialization failed: {0}", e.ToString());
- return;
- }
- }
- if (m_pluginEnabled)
- {
- // we need to capture scene in an anonymous method
- // here as we need it later in the callbacks
- scene.EventManager.OnRegisterCaps += delegate(UUID agentID, Caps caps)
- {
- OnRegisterCaps(scene, agentID, caps);
- };
-
-
- try
- {
- ServicePointManager.ServerCertificateValidationCallback += CustomCertificateValidation;
- }
- catch (NotImplementedException)
- {
- try
- {
- #pragma warning disable 0612, 0618
- // Mono does not implement the ServicePointManager.ServerCertificateValidationCallback yet! Don't remove this!
- ServicePointManager.CertificatePolicy = new MonoCert();
- #pragma warning restore 0612, 0618
- }
- catch (Exception)
- {
- m_log.Error("[FreeSwitchVoice]: Certificate validation handler change not supported. You may get ssl certificate validation errors teleporting from your region to some SSL regions.");
- }
- }
-
- }
- }
-
- public void PostInitialise()
- {
- if (m_pluginEnabled)
- {
- m_log.Info("[FreeSwitchVoice] registering IVoiceModule with the scene");
-
- // register the voice interface for this module, so the script engine can call us
- m_scene.RegisterModuleInterface<IVoiceModule>(this);
- }
- }
- public void Close()
- {
- }
- public string Name
- {
- get { return "FreeSwitchVoiceModule"; }
- }
- public bool IsSharedModule
- {
- get { return true; }
- }
-
- // <summary>
- // implementation of IVoiceModule, called by osSetParcelSIPAddress script function
- // </summary>
- public void setLandSIPAddress(string SIPAddress,UUID GlobalID)
- {
- m_log.DebugFormat("[FreeSwitchVoice]: setLandSIPAddress parcel id {0}: setting sip address {1}",
- GlobalID, SIPAddress);
-
- lock (m_ParcelAddress)
- {
- if (m_ParcelAddress.ContainsKey(GlobalID.ToString()))
- {
- m_ParcelAddress[GlobalID.ToString()] = SIPAddress;
- }
- else
- {
- m_ParcelAddress.Add(GlobalID.ToString(), SIPAddress);
- }
- }
- }
-
- // <summary>
- // OnRegisterCaps is invoked via the scene.EventManager
- // everytime OpenSim hands out capabilities to a client
- // (login, region crossing). We contribute two capabilities to
- // the set of capabilities handed back to the client:
- // ProvisionVoiceAccountRequest and ParcelVoiceInfoRequest.
- //
- // ProvisionVoiceAccountRequest allows the client to obtain
- // the voice account credentials for the avatar it is
- // controlling (e.g., user name, password, etc).
- //
- // ParcelVoiceInfoRequest is invoked whenever the client
- // changes from one region or parcel to another.
- //
- // Note that OnRegisterCaps is called here via a closure
- // delegate containing the scene of the respective region (see
- // Initialise()).
- // </summary>
- public void OnRegisterCaps(Scene scene, UUID agentID, Caps caps)
- {
- m_log.DebugFormat("[FreeSwitchVoice] OnRegisterCaps: agentID {0} caps {1}", agentID, caps);
- string capsBase = "/CAPS/" + caps.CapsObjectPath;
- caps.RegisterHandler("ProvisionVoiceAccountRequest",
- new RestStreamHandler("POST", capsBase + m_provisionVoiceAccountRequestPath,
- delegate(string request, string path, string param,
- OSHttpRequest httpRequest, OSHttpResponse httpResponse)
- {
- return ProvisionVoiceAccountRequest(scene, request, path, param,
- agentID, caps);
- }));
- caps.RegisterHandler("ParcelVoiceInfoRequest",
- new RestStreamHandler("POST", capsBase + m_parcelVoiceInfoRequestPath,
- delegate(string request, string path, string param,
- OSHttpRequest httpRequest, OSHttpResponse httpResponse)
- {
- return ParcelVoiceInfoRequest(scene, request, path, param,
- agentID, caps);
- }));
- caps.RegisterHandler("ChatSessionRequest",
- new RestStreamHandler("POST", capsBase + m_chatSessionRequestPath,
- delegate(string request, string path, string param,
- OSHttpRequest httpRequest, OSHttpResponse httpResponse)
- {
- return ChatSessionRequest(scene, request, path, param,
- agentID, caps);
- }));
- }
- /// <summary>
- /// Callback for a client request for Voice Account Details
- /// </summary>
- /// <param name="scene">current scene object of the client</param>
- /// <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(Scene scene, string request, string path, string param,
- UUID agentID, Caps caps)
- {
- ScenePresence avatar = scene.GetScenePresence(agentID);
- if (avatar == null)
- {
- System.Threading.Thread.Sleep(2000);
- avatar = scene.GetScenePresence(agentID);
-
- if (avatar == null)
- return "<llsd>undef</llsd>";
- }
- string avatarName = avatar.Name;
- try
- {
- m_log.DebugFormat("[FreeSwitchVoice][PROVISIONVOICE]: request: {0}, path: {1}, param: {2}",
- request, path, param);
- //XmlElement resp;
- string agentname = "x" + Convert.ToBase64String(agentID.GetBytes());
- string password = "1234";//temp hack//new UUID(Guid.NewGuid()).ToString().Replace('-','Z').Substring(0,16);
- // XXX: we need to cache the voice credentials, as
- // FreeSwitch is later going to come and ask us for
- // those
- agentname = agentname.Replace('+', '-').Replace('/', '_');
- lock (m_UUIDName)
- {
- if (m_UUIDName.ContainsKey(agentname))
- {
- m_UUIDName[agentname] = avatarName;
- }
- else
- {
- m_UUIDName.Add(agentname, avatarName);
- }
- }
- // LLSDVoiceAccountResponse voiceAccountResponse =
- // new LLSDVoiceAccountResponse(agentname, password, m_freeSwitchRealm, "http://etsvc02.hursley.ibm.com/api");
- LLSDVoiceAccountResponse voiceAccountResponse =
- new LLSDVoiceAccountResponse(agentname, password, m_freeSwitchRealm,
- String.Format("http://{0}:{1}{2}/", m_openSimWellKnownHTTPAddress,
- m_freeSwitchServicePort, m_freeSwitchAPIPrefix));
- string r = LLSDHelpers.SerialiseLLSDReply(voiceAccountResponse);
- m_log.DebugFormat("[FreeSwitchVoice][PROVISIONVOICE]: avatar \"{0}\": {1}", avatarName, r);
- return r;
- }
- catch (Exception e)
- {
- m_log.ErrorFormat("[FreeSwitchVoice][PROVISIONVOICE]: avatar \"{0}\": {1}, retry later", avatarName, e.Message);
- m_log.DebugFormat("[FreeSwitchVoice][PROVISIONVOICE]: avatar \"{0}\": {1} failed", avatarName, e.ToString());
- return "<llsd>undef</llsd>";
- }
- }
- /// <summary>
- /// Callback for a client request for ParcelVoiceInfo
- /// </summary>
- /// <param name="scene">current scene object of the client</param>
- /// <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(Scene scene, string request, string path, string param,
- UUID agentID, Caps caps)
- {
- ScenePresence avatar = scene.GetScenePresence(agentID);
- string avatarName = avatar.Name;
- // - check whether we have a region channel in our cache
- // - if not:
- // create it and cache it
- // - send it to the client
- // - send channel_uri: as "sip:regionID@m_sipDomain"
- try
- {
- LLSDParcelVoiceInfoResponse parcelVoiceInfo;
- string channelUri;
- if (null == scene.LandChannel)
- throw new Exception(String.Format("region \"{0}\": avatar \"{1}\": land data not yet available",
- scene.RegionInfo.RegionName, avatarName));
- // get channel_uri: check first whether estate
- // settings allow voice, then whether parcel allows
- // voice, if all do retrieve or obtain the parcel
- // voice channel
- LandData land = scene.GetLandData(avatar.AbsolutePosition.X, avatar.AbsolutePosition.Y);
- m_log.DebugFormat("[FreeSwitchVoice][PARCELVOICE]: region \"{0}\": Parcel \"{1}\" ({2}): avatar \"{3}\": request: {4}, path: {5}, param: {6}",
- scene.RegionInfo.RegionName, land.Name, land.LocalID, avatarName, request, path, param);
- // TODO: EstateSettings don't seem to get propagated...
- // if (!scene.RegionInfo.EstateSettings.AllowVoice)
- // {
- // m_log.DebugFormat("[FreeSwitchVoice][PARCELVOICE]: region \"{0}\": voice not enabled in estate settings",
- // scene.RegionInfo.RegionName);
- // channel_uri = String.Empty;
- // }
- // else
- if ((land.Flags & (uint)ParcelFlags.AllowVoiceChat) == 0)
- {
- m_log.DebugFormat("[FreeSwitchVoice][PARCELVOICE]: region \"{0}\": Parcel \"{1}\" ({2}): avatar \"{3}\": voice not enabled for parcel",
- scene.RegionInfo.RegionName, land.Name, land.LocalID, avatarName);
- channelUri = String.Empty;
- }
- else
- {
- channelUri = ChannelUri(scene, land);
- }
- // fill in our response to the client
- Hashtable creds = new Hashtable();
- creds["channel_uri"] = channelUri;
- parcelVoiceInfo = new LLSDParcelVoiceInfoResponse(scene.RegionInfo.RegionName, land.LocalID, creds);
- string r = LLSDHelpers.SerialiseLLSDReply(parcelVoiceInfo);
- m_log.DebugFormat("[FreeSwitchVoice][PARCELVOICE]: region \"{0}\": Parcel \"{1}\" ({2}): avatar \"{3}\": {4}",
- scene.RegionInfo.RegionName, land.Name, land.LocalID, avatarName, r);
- return r;
- }
- catch (Exception e)
- {
- m_log.ErrorFormat("[FreeSwitchVoice][PARCELVOICE]: region \"{0}\": avatar \"{1}\": {2}, retry later",
- scene.RegionInfo.RegionName, avatarName, e.Message);
- m_log.DebugFormat("[FreeSwitchVoice][PARCELVOICE]: region \"{0}\": avatar \"{1}\": {2} failed",
- scene.RegionInfo.RegionName, avatarName, e.ToString());
- return "<llsd>undef</llsd>";
- }
- }
- /// <summary>
- /// Callback for a client request for ChatSessionRequest
- /// </summary>
- /// <param name="scene">current scene object of the client</param>
- /// <param name="request"></param>
- /// <param name="path"></param>
- /// <param name="param"></param>
- /// <param name="agentID"></param>
- /// <param name="caps"></param>
- /// <returns></returns>
- public string ChatSessionRequest(Scene scene, string request, string path, string param,
- UUID agentID, Caps caps)
- {
- ScenePresence avatar = scene.GetScenePresence(agentID);
- string avatarName = avatar.Name;
- m_log.DebugFormat("[FreeSwitchVoice][CHATSESSION]: avatar \"{0}\": request: {1}, path: {2}, param: {3}",
- avatarName, request, path, param);
- return "<llsd>true</llsd>";
- }
- public Hashtable ForwardProxyRequest(Hashtable request)
- {
- m_log.Debug("[PROXYING]: -------------------------------proxying request");
- Hashtable response = new Hashtable();
- response["content_type"] = "text/xml";
- response["str_response_string"] = "";
- response["int_response_code"] = 200;
- string forwardaddress = "https://www.bhr.vivox.com/api2/";
- string body = (string)request["body"];
- string method = (string) request["http-method"];
- string contenttype = (string) request["content-type"];
- string uri = (string) request["uri"];
- uri = uri.Replace("/api/", "");
- forwardaddress += uri;
- string fwdresponsestr = "";
- int fwdresponsecode = 200;
- string fwdresponsecontenttype = "text/xml";
-
- HttpWebRequest forwardreq = (HttpWebRequest)WebRequest.Create(forwardaddress);
- forwardreq.Method = method;
- forwardreq.ContentType = contenttype;
- forwardreq.KeepAlive = false;
- if (method == "POST")
- {
- byte[] contentreq = Util.UTF8.GetBytes(body);
- forwardreq.ContentLength = contentreq.Length;
- Stream reqStream = forwardreq.GetRequestStream();
- reqStream.Write(contentreq, 0, contentreq.Length);
- reqStream.Close();
- }
- HttpWebResponse fwdrsp = (HttpWebResponse)forwardreq.GetResponse();
- Encoding encoding = Util.UTF8;
- StreamReader fwdresponsestream = new StreamReader(fwdrsp.GetResponseStream(), encoding);
- fwdresponsestr = fwdresponsestream.ReadToEnd();
- fwdresponsecontenttype = fwdrsp.ContentType;
- fwdresponsecode = (int)fwdrsp.StatusCode;
- fwdresponsestream.Close();
- response["content_type"] = fwdresponsecontenttype;
- response["str_response_string"] = fwdresponsestr;
- response["int_response_code"] = fwdresponsecode;
-
- return response;
- }
- public Hashtable FreeSwitchSLVoiceGetPreloginHTTPHandler(Hashtable request)
- {
- m_log.Debug("[FreeSwitchVoice] FreeSwitchSLVoiceGetPreloginHTTPHandler called");
-
- Hashtable response = new Hashtable();
- response["content_type"] = "text/xml";
- response["keepalive"] = false;
-
- response["str_response_string"] = String.Format(
- "<?xml version=\"1.0\" encoding=\"utf-8\"?>\r\n" +
- "<VCConfiguration>\r\n"+
- "<DefaultRealm>{0}</DefaultRealm>\r\n" +
- "<DefaultSIPProxy>{1}</DefaultSIPProxy>\r\n"+
- "<DefaultAttemptUseSTUN>{2}</DefaultAttemptUseSTUN>\r\n"+
- "<DefaultEchoServer>{3}</DefaultEchoServer>\r\n"+
- "<DefaultEchoPort>{4}</DefaultEchoPort>\r\n"+
- "<DefaultWellKnownIP>{5}</DefaultWellKnownIP>\r\n"+
- "<DefaultTimeout>{6}</DefaultTimeout>\r\n"+
- "<UrlResetPassword>{7}</UrlResetPassword>\r\n"+
- "<UrlPrivacyNotice>{8}</UrlPrivacyNotice>\r\n"+
- "<UrlEulaNotice/>\r\n"+
- "<App.NoBottomLogo>false</App.NoBottomLogo>\r\n"+
- "</VCConfiguration>",
- m_freeSwitchRealm, m_freeSwitchSIPProxy, m_freeSwitchAttemptUseSTUN,
- m_freeSwitchEchoServer, m_freeSwitchEchoPort,
- m_freeSwitchDefaultWellKnownIP, m_freeSwitchDefaultTimeout,
- m_freeSwitchUrlResetPassword, "");
-
- response["int_response_code"] = 200;
- m_log.DebugFormat("[FreeSwitchVoice] FreeSwitchSLVoiceGetPreloginHTTPHandler return {0}",response["str_response_string"]);
- return response;
- }
- public Hashtable FreeSwitchSLVoiceBuddyHTTPHandler(Hashtable request)
- {
- Hashtable response = new Hashtable();
- response["int_response_code"] = 200;
- response["str_response_string"] = string.Empty;
- response["content-type"] = "text/xml";
- Hashtable requestBody = parseRequestBody((string)request["body"]);
-
- if (!requestBody.ContainsKey("auth_token"))
- return response;
- string auth_token = (string)requestBody["auth_token"];
- //string[] auth_tokenvals = auth_token.Split(':');
- //string username = auth_tokenvals[0];
- int strcount = 0;
-
- string[] ids = new string[strcount];
- int iter = -1;
- lock (m_UUIDName)
- {
- strcount = m_UUIDName.Count;
- ids = new string[strcount];
- foreach (string s in m_UUIDName.Keys)
- {
- iter++;
- ids[iter] = s;
- }
- }
- StringBuilder resp = new StringBuilder();
- resp.Append("<?xml version=\"1.0\" encoding=\"iso-8859-1\" ?><response xmlns=\"http://www.vivox.com\" xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\" xsi:schemaLocation= \"/xsd/buddy_list.xsd\">");
-
- resp.Append(string.Format(@"<level0>
- <status>OK</status>
- <cookie_name>lib_session</cookie_name>
- <cookie>{0}</cookie>
- <auth_token>{0}</auth_token>
- <body>
- <buddies>",auth_token));
- /*
- <cookie_name>lib_session</cookie_name>
- <cookie>{0}:{1}:9303959503950::</cookie>
- <auth_token>{0}:{1}:9303959503950::</auth_token>
- */
- for (int i=0;i<ids.Length;i++)
- {
- DateTime currenttime = DateTime.Now;
- string dt = currenttime.ToString("yyyy-MM-dd HH:mm:ss.0zz");
- resp.Append(
- string.Format(@"<level3>
- <bdy_id>{1}</bdy_id>
- <bdy_data></bdy_data>
- <bdy_uri>sip:{0}@{2}</bdy_uri>
- <bdy_nickname>{0}</bdy_nickname>
- <bdy_username>{0}</bdy_username>
- <bdy_domain>{2}</bdy_domain>
- <bdy_status>A</bdy_status>
- <modified_ts>{3}</modified_ts>
- <b2g_group_id></b2g_group_id>
- </level3>", ids[i],i,m_freeSwitchRealm,dt));
- }
-
- resp.Append("</buddies><groups></groups></body></level0></response>");
- response["str_response_string"] = resp.ToString();
- Regex normalizeEndLines = new Regex(@"\r\n", RegexOptions.Compiled | RegexOptions.Singleline | RegexOptions.Multiline);
- m_log.DebugFormat("[FREESWITCH]: {0}", normalizeEndLines.Replace((string)response["str_response_string"],""));
- return response;
- }
- public Hashtable FreeSwitchSLVoiceSigninHTTPHandler(Hashtable request)
- {
- m_log.Debug("[FreeSwitchVoice] FreeSwitchSLVoiceSigninHTTPHandler called");
- string requestbody = (string)request["body"];
- string uri = (string)request["uri"];
- string contenttype = (string)request["content-type"];
-
- Hashtable requestBody = parseRequestBody((string)request["body"]);
- //string pwd = (string) requestBody["pwd"];
- string userid = (string) requestBody["userid"];
- string avatarName = string.Empty;
- int pos = -1;
- lock (m_UUIDName)
- {
- if (m_UUIDName.ContainsKey(userid))
- {
- avatarName = m_UUIDName[userid];
- foreach (string s in m_UUIDName.Keys)
- {
- pos++;
- if (s == userid)
- break;
-
- }
- }
- }
- m_log.DebugFormat("[FreeSwitchVoice]: AUTH, URI: {0}, Content-Type:{1}, Body{2}", uri, contenttype,
- requestbody);
- Hashtable response = new Hashtable();
- response["str_response_string"] = string.Format(@"<response xsi:schemaLocation=""/xsd/signin.xsd"">
- <level0>
- <status>OK</status>
- <body>
- <code>200</code>
- <cookie_name>lib_session</cookie_name>
- <cookie>{0}:{1}:9303959503950::</cookie>
- <auth_token>{0}:{1}:9303959503950::</auth_token>
- <primary>1</primary>
- <account_id>{1}</account_id>
- <displayname>{2}</displayname>
- <msg>auth successful</msg>
- </body>
- </level0>
- </response>", userid, pos, avatarName);
-
- response["int_response_code"] = 200;
- return response;
- /*
- <level0>
- <status>OK</status><body><status>Ok</status><cookie_name>lib_session</cookie_name>
- * <cookie>xMj1QJSc7TA-G7XqcW6QXAg==:1290551700:050d35c6fef96f132f780d8039ff7592::</cookie>
- * <auth_token>xMj1QJSc7TA-G7XqcW6QXAg==:1290551700:050d35c6fef96f132f780d8039ff7592::</auth_token>
- * <primary>1</primary>
- * <account_id>7449</account_id>
- * <displayname>Teravus Ousley</displayname></body></level0>
- */
- }
- public Hashtable FreeSwitchConfigHTTPHandler(Hashtable request)
- {
- m_log.DebugFormat("[FreeSwitchVoice] FreeSwitchConfigHTTPHandler called with {0}", (string)request["body"]);
-
- Hashtable response = new Hashtable();
- response["str_response_string"] = string.Empty;
- // all the params come as NVPs in the request body
- Hashtable requestBody = parseRequestBody((string) request["body"]);
- // is this a dialplan or directory request
- string section = (string) requestBody["section"];
- if (section == "directory")
- response = m_FreeSwitchDirectory.HandleDirectoryRequest(m_freeSwitchContext, m_freeSwitchRealm, requestBody);
- else if (section == "dialplan")
- response = m_FreeSwitchDialplan.HandleDialplanRequest(m_freeSwitchContext, m_freeSwitchRealm, requestBody);
- else
- m_log.WarnFormat("[FreeSwitchVoice]: section was {0}", section);
-
- // XXX: re-generate dialplan:
- // - conf == region UUID
- // - conf number = region port
- // -> TODO Initialise(): keep track of regions via events
- // re-generate accounts for all avatars
- // -> TODO Initialise(): keep track of avatars via events
- Regex normalizeEndLines = new Regex(@"\r\n", RegexOptions.Compiled | RegexOptions.Singleline | RegexOptions.Multiline);
- m_log.DebugFormat("[FreeSwitchVoice] FreeSwitchConfigHTTPHandler return {0}",normalizeEndLines.Replace(((string)response["str_response_string"]), ""));
- return response;
- }
-
- public Hashtable parseRequestBody(string body)
- {
- Hashtable bodyParams = new Hashtable();
- // split string
- string [] nvps = body.Split(new Char [] {'&'});
- foreach (string s in nvps) {
-
- if (s.Trim() != "")
- {
- string [] nvp = s.Split(new Char [] {'='});
- bodyParams.Add(HttpUtility.UrlDecode(nvp[0]), HttpUtility.UrlDecode(nvp[1]));
- }
- }
-
- return bodyParams;
- }
- private string ChannelUri(Scene scene, LandData land)
- {
- string channelUri = null;
- string landUUID;
- string landName;
- // Create parcel voice channel. If no parcel exists, then the voice channel ID is the same
- // as the directory ID. Otherwise, it reflects the parcel's ID.
-
- lock (m_ParcelAddress)
- {
- if (m_ParcelAddress.ContainsKey(land.GlobalID.ToString()))
- {
- m_log.DebugFormat("[FreeSwitchVoice]: parcel id {0}: using sip address {1}",
- land.GlobalID, m_ParcelAddress[land.GlobalID.ToString()]);
- return m_ParcelAddress[land.GlobalID.ToString()];
- }
- }
- if (land.LocalID != 1 && (land.Flags & (uint)ParcelFlags.UseEstateVoiceChan) == 0)
- {
- landName = String.Format("{0}:{1}", scene.RegionInfo.RegionName, land.Name);
- landUUID = land.GlobalID.ToString();
- m_log.DebugFormat("[FreeSwitchVoice]: Region:Parcel \"{0}\": parcel id {1}: using channel name {2}",
- landName, land.LocalID, landUUID);
- }
- else
- {
- landName = String.Format("{0}:{1}", scene.RegionInfo.RegionName, scene.RegionInfo.RegionName);
- landUUID = scene.RegionInfo.RegionID.ToString();
- m_log.DebugFormat("[FreeSwitchVoice]: Region:Parcel \"{0}\": parcel id {1}: using channel name {2}",
- landName, land.LocalID, landUUID);
- }
- System.Text.ASCIIEncoding encoding = new System.Text.ASCIIEncoding();
-
- // slvoice handles the sip address differently if it begins with confctl, hiding it from the user in the friends list. however it also disables
- // the personal speech indicators as well unless some siren14-3d codec magic happens. we dont have siren143d so we'll settle for the personal speech indicator.
- channelUri = String.Format("sip:conf-{0}@{1}", "x" + Convert.ToBase64String(encoding.GetBytes(landUUID)), m_freeSwitchRealm);
-
- lock (m_ParcelAddress)
- {
- if (!m_ParcelAddress.ContainsKey(land.GlobalID.ToString()))
- {
- m_ParcelAddress.Add(land.GlobalID.ToString(),channelUri);
- }
- }
- return channelUri;
- }
-
- private static bool CustomCertificateValidation(object sender, X509Certificate cert, X509Chain chain, SslPolicyErrors error)
- {
-
- return true;
-
- }
- }
- public class MonoCert : ICertificatePolicy
- {
- #region ICertificatePolicy Members
- public bool CheckValidationResult(ServicePoint srvPoint, X509Certificate certificate, WebRequest request, int certificateProblem)
- {
- return true;
- }
- #endregion
- }
- }
|