Initial submit for the OpenSimProfile

Not working code at this moment git-svn-id: http://forge.opensimulator.org/svn/osprofile/trunk@2 19860011-0018-435d-96ae-4a7b0aaa3128
2026-08-14 09:02:00 +00:00 · 2008-12-24 14:59:47 +00:00
parent 8f9d4f1f59
commit 5c84a11ba6
1 changed files with 211 additions and 0 deletions
@@ -0,0 +1,211 @@
+using System;
+using System.Collections;
+using System.Collections.Generic;
+using System.Globalization;
+using System.Net;
+using System.Net.Sockets;
+using System.Reflection;
+using System.Xml;
+using OpenMetaverse;
+using log4net;
+using Nini.Config;
+using Nwc.XmlRpc;
+using OpenSim.Framework;
+using OpenSim.Region.Interfaces;
+using OpenSim.Region.Environment.Interfaces;
+using OpenSim.Region.Environment.Scenes;
+using OpenSim.Framework.Communications.Cache;
+
+namespace OpenSimProfile.Modules.OpenProfile
+{
+	public class OpenProfileModule : IRegionModule
+	{
+		//
+		// Log module
+		//
+		private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
+
+		//
+		// Module vars
+		//
+		private IConfigSource m_gConfig;
+		private List<Scene> m_Scenes = new List<Scene>();
+		private string m_ProfileServer = "";
+		private bool m_Enabled = true;
+
+		public void Initialise(Scene scene, IConfigSource config)
+		{
+			if (!m_Enabled)
+				return;
+
+			IConfig profileConfig = config.Configs["Profile"];
+
+			if (m_Scenes.Count == 0) // First time
+			{
+				if (profileConfig == null)
+				{
+					m_log.Info("[PROFILE] Not configured, disabling");
+					m_Enabled = false;
+					return;
+				}
+				m_ProfileServer = profileConfig.GetString("ProfileURL", "");
+				if (m_ProfileServer == "")
+				{
+					m_log.Error("[PROFILE] No profile server, disabling profiles");
+					m_Enabled = false;
+					return;
+				}
+				else
+				{
+					m_log.Info("[PROFILE] Profile module is activated");
+					m_Enabled = true;
+				}
+			}
+
+			if (!m_Scenes.Contains(scene))
+				m_Scenes.Add(scene);
+
+			m_gConfig = config;
+
+			// Hook up events
+			scene.EventManager.OnNewClient += OnNewClient;
+		}
+
+		public void PostInitialise()
+		{
+			if (!m_Enabled)
+				return;
+		}
+
+		public void Close()
+		{
+		}
+
+		public string Name
+		{
+			get { return "ProfileModule"; }
+		}
+
+		public bool IsSharedModule
+		{
+			get { return true; }
+		}
+
+		/// New Client Event Handler
+		private void OnNewClient(IClientAPI client)
+		{
+			// Subscribe to messages
+			client.AddGenericPacketHandler("method", handler) 
+
+		}
+
+		//
+		// Make external XMLRPC request
+		//
+		private Hashtable GenericXMLRPCRequest(Hashtable ReqParams, string method)
+		{
+			ArrayList SendParams = new ArrayList();
+			SendParams.Add(ReqParams);
+
+			// Send Request
+			XmlRpcResponse Resp;
+			try
+			{
+				XmlRpcRequest Req = new XmlRpcRequest(method, SendParams);
+				Resp = Req.Send(m_ProfileServer, 30000);
+			}
+			catch (WebException ex)
+			{
+				m_log.ErrorFormat("[PROFILE]: Unable to connect to Profile " +
+						"Server {0}.  Exception {1}", m_SearchServer, ex);
+
+				Hashtable ErrorHash = new Hashtable();
+				ErrorHash["success"] = false;
+				ErrorHash["errorMessage"] = "Unable to search at this time. ";
+				ErrorHash["errorURI"] = "";
+
+				return ErrorHash;
+			}
+			catch (SocketException ex)
+			{
+				m_log.ErrorFormat(
+						"[SEARCH]: Unable to connect to Profile Server {0}. " +
+						"Exception {1}", m_SearchServer, ex);
+
+				Hashtable ErrorHash = new Hashtable();
+				ErrorHash["success"] = false;
+				ErrorHash["errorMessage"] = "Unable to search at this time. ";
+				ErrorHash["errorURI"] = "";
+
+				return ErrorHash;
+			}
+			catch (XmlException ex)
+			{
+				m_log.ErrorFormat(
+						"[SEARCH]: Unable to connect to Profile Server {0}. " +
+						"Exception {1}", m_SearchServer, ex);
+
+				Hashtable ErrorHash = new Hashtable();
+				ErrorHash["success"] = false;
+				ErrorHash["errorMessage"] = "Unable to search at this time. ";
+				ErrorHash["errorURI"] = "";
+
+				return ErrorHash;
+			}
+			if (Resp.IsFault)
+			{
+				Hashtable ErrorHash = new Hashtable();
+				ErrorHash["success"] = false;
+				ErrorHash["errorMessage"] = "Unable to search at this time. ";
+				ErrorHash["errorURI"] = "";
+				return ErrorHash;
+			}
+			Hashtable RespData = (Hashtable)Resp.Value;
+
+			return RespData;
+		}
+
+		public delegate void GenericMessage(Object sender, string method, List<String> args); 
+		{
+			Hashtable ReqHash = new Hashtable();
+			ReqHash["text"] = queryText;
+			
+			Hashtable result = GenericXMLRPCRequest(ReqHash,
+					"dir_places_query");
+
+			if (!Convert.ToBoolean(result["success"]))
+			{
+				remoteClient.SendAgentAlertMessage(
+						result["errorMessage"].ToString(), false);
+				return;
+			}
+
+			ArrayList dataArray = (ArrayList)result["data"];
+
+			int count = dataArray.Count;
+			if (count > 100)
+				count = 101;
+
+			DirPlacesReplyData[] data = new DirPlacesReplyData[count];
+
+			int i = 0;
+
+			foreach (Object o in dataArray)
+			{
+				Hashtable d = (Hashtable)o;
+
+				data[i] = new DirPlacesReplyData();
+				data[i].parcelID = new UUID(d["parcel_id"].ToString());
+				data[i].name = d["name"].ToString();
+				data[i].forSale = Convert.ToBoolean(d["for_sale"]);
+				data[i].auction = Convert.ToBoolean(d["auction"]);
+				data[i].dwell = Convert.ToSingle(d["dwell"]);
+				i++;
+				if (i >= count)
+					break;
+			}
+
+			remoteClient.<packet>(data);
+		}
+	}
+}