Some work on restructuring the namespaces / project names. Note this doesn't compile yet as not all the code has been changed to use the new namespaces. Am committing it now for feedback on the namespaces.

author: MW 2007-06-27 15:28:52 +0000
committer: MW 2007-06-27 15:28:52 +0000
commit: 646bbbc84b8010e0dacbeed5342cdb045f46cc49 (patch)
tree: 770b34d19855363c3c113ab9a0af9a56d821d887 /OpenSim/Framework/Data.MySQL/MySQLGridData.cs
download: opensim-SC-646bbbc84b8010e0dacbeed5342cdb045f46cc49.zip
opensim-SC-646bbbc84b8010e0dacbeed5342cdb045f46cc49.tar.gz
opensim-SC-646bbbc84b8010e0dacbeed5342cdb045f46cc49.tar.bz2
opensim-SC-646bbbc84b8010e0dacbeed5342cdb045f46cc49.tar.xz
1 files changed, 285 insertions, 0 deletions
diff --git a/OpenSim/Framework/Data.MySQL/MySQLGridData.cs b/OpenSim/Framework/Data.MySQL/MySQLGridData.cs
new file mode 100644
index 0000000..4d6cf63
--- /dev/null
+++ b/OpenSim/Framework/Data.MySQL/MySQLGridData.cs
@@ -0,0 +1,285 @@
+/*
+* Copyright (c) Contributors, http://www.openmetaverse.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.Text;
+using OpenGrid.Framework.Data;
+namespace OpenGrid.Framework.Data.MySQL
+{
+    /// <summary>
+    /// A MySQL Interface for the Grid Server
+    /// </summary>
+    public class MySQLGridData : IGridData
+    {
+        /// <summary>
+        /// MySQL Database Manager
+        /// </summary>
+        private MySQLManager database;
+        /// <summary>
+        /// Initialises the Grid Interface
+        /// </summary>
+        public void Initialise()
+        {
+            IniFile GridDataMySqlFile = new IniFile("mysql_connection.ini");
+            string settingHostname = GridDataMySqlFile.ParseFileReadValue("hostname");
+            string settingDatabase = GridDataMySqlFile.ParseFileReadValue("database");
+            string settingUsername = GridDataMySqlFile.ParseFileReadValue("username");
+            string settingPassword = GridDataMySqlFile.ParseFileReadValue("password");
+            string settingPooling = GridDataMySqlFile.ParseFileReadValue("pooling");
+            string settingPort = GridDataMySqlFile.ParseFileReadValue("port");
+            database = new MySQLManager(settingHostname, settingDatabase, settingUsername, settingPassword, settingPooling, settingPort);
+        }
+        /// <summary>
+        /// Shuts down the grid interface
+        /// </summary>
+        public void Close()
+        {
+            database.Close();
+        }
+        /// <summary>
+        /// Returns the plugin name
+        /// </summary>
+        /// <returns>Plugin name</returns>
+        public string getName()
+        {
+            return "MySql OpenGridData";
+        }
+        /// <summary>
+        /// Returns the plugin version
+        /// </summary>
+        /// <returns>Plugin version</returns>
+        public string getVersion()
+        {
+            return "0.1";
+        }
+        /// <summary>
+        /// Returns all the specified region profiles within coordates -- coordinates are inclusive
+        /// </summary>
+        /// <param name="xmin">Minimum X coordinate</param>
+        /// <param name="ymin">Minimum Y coordinate</param>
+        /// <param name="xmax">Maximum X coordinate</param>
+        /// <param name="ymax">Maximum Y coordinate</param>
+        /// <returns></returns>
+        public SimProfileData[] GetProfilesInRange(uint xmin, uint ymin, uint xmax, uint ymax)
+        {
+            try
+            {
+                lock (database)
+                {
+                    Dictionary<string, string> param = new Dictionary<string, string>();
+                    param["?xmin"] = xmin.ToString();
+                    param["?ymin"] = ymin.ToString();
+                    param["?xmax"] = xmax.ToString();
+                    param["?ymax"] = ymax.ToString();
+                    System.Data.IDbCommand result = database.Query("SELECT * FROM regions WHERE locX >= ?xmin AND locX <= ?xmax AND locY >= ?ymin AND locY <= ?ymax", param);
+                    System.Data.IDataReader reader = result.ExecuteReader();
+                    SimProfileData row;
+                    List<SimProfileData> rows = new List<SimProfileData>();
+                    while ((row = database.readSimRow(reader)) != null)
+                    {
+                        rows.Add(row);
+                    }
+                    reader.Close();
+                    result.Dispose();
+                    return rows.ToArray();
+                }
+            }
+            catch (Exception e)
+            {
+                database.Reconnect();
+                Console.WriteLine(e.ToString());
+                return null;
+            }
+        }
+        /// <summary>
+        /// Returns a sim profile from it's location
+        /// </summary>
+        /// <param name="handle">Region location handle</param>
+        /// <returns>Sim profile</returns>
+        public SimProfileData GetProfileByHandle(ulong handle)
+        {
+            try
+            {
+                lock (database)
+                {
+                    Dictionary<string, string> param = new Dictionary<string, string>();
+                    param["?handle"] = handle.ToString();
+                    System.Data.IDbCommand result = database.Query("SELECT * FROM regions WHERE regionHandle = ?handle", param);
+                    System.Data.IDataReader reader = result.ExecuteReader();
+                    SimProfileData row = database.readSimRow(reader);
+                    reader.Close();
+                    result.Dispose();
+                    return row;
+                }
+            }
+            catch (Exception e)
+            {
+                database.Reconnect();
+                Console.WriteLine(e.ToString());
+                return null;
+            }
+        }
+        /// <summary>
+        /// Returns a sim profile from it's UUID
+        /// </summary>
+        /// <param name="uuid">The region UUID</param>
+        /// <returns>The sim profile</returns>
+        public SimProfileData GetProfileByLLUUID(libsecondlife.LLUUID uuid)
+        {
+            try
+            {
+                lock (database)
+                {
+                    Dictionary<string, string> param = new Dictionary<string, string>();
+                    param["?uuid"] = uuid.ToStringHyphenated();
+                    System.Data.IDbCommand result = database.Query("SELECT * FROM regions WHERE uuid = ?uuid", param);
+                    System.Data.IDataReader reader = result.ExecuteReader();
+                    SimProfileData row = database.readSimRow(reader);
+                    reader.Close();
+                    result.Dispose();
+                    return row;
+                }
+            }
+            catch (Exception e)
+            {
+                database.Reconnect();
+                Console.WriteLine(e.ToString());
+                return null;
+            }
+        }
+        /// <summary>
+        /// Adds a new profile to the database
+        /// </summary>
+        /// <param name="profile">The profile to add</param>
+        /// <returns>Successful?</returns>
+        public DataResponse AddProfile(SimProfileData profile)
+        {
+            lock (database)
+            {
+                if (database.insertRegion(profile))
+                {
+                    return DataResponse.RESPONSE_OK;
+                }
+                else
+                {
+                    return DataResponse.RESPONSE_ERROR;
+                }
+            }
+        }
+        /// <summary>
+        /// DEPRECIATED. Attempts to authenticate a region by comparing a shared secret.
+        /// </summary>
+        /// <param name="uuid">The UUID of the challenger</param>
+        /// <param name="handle">The attempted regionHandle of the challenger</param>
+        /// <param name="authkey">The secret</param>
+        /// <returns>Whether the secret and regionhandle match the database entry for UUID</returns>
+        public bool AuthenticateSim(libsecondlife.LLUUID uuid, ulong handle, string authkey)
+        {
+            bool throwHissyFit = false; // Should be true by 1.0
+            if (throwHissyFit)
+                throw new Exception("CRYPTOWEAK AUTHENTICATE: Refusing to authenticate due to replay potential.");
+            SimProfileData data = GetProfileByLLUUID(uuid);
+            return (handle == data.regionHandle && authkey == data.regionSecret);
+        }
+        /// <summary>
+        /// NOT YET FUNCTIONAL. Provides a cryptographic authentication of a region
+        /// </summary>
+        /// <remarks>This requires a security audit.</remarks>
+        /// <param name="uuid"></param>
+        /// <param name="handle"></param>
+        /// <param name="authhash"></param>
+        /// <param name="challenge"></param>
+        /// <returns></returns>
+        public bool AuthenticateSim(libsecondlife.LLUUID uuid, ulong handle, string authhash, string challenge)
+        {
+            System.Security.Cryptography.SHA512Managed HashProvider = new System.Security.Cryptography.SHA512Managed();
+            System.Text.ASCIIEncoding TextProvider = new ASCIIEncoding();
+            byte[] stream = TextProvider.GetBytes(uuid.ToStringHyphenated() + ":" + handle.ToString() + ":" + challenge);
+            byte[] hash = HashProvider.ComputeHash(stream);
+            return false;
+        }
+        public ReservationData GetReservationAtPoint(uint x, uint y)
+        {
+            try
+            {
+                lock (database)
+                {
+                    Dictionary<string, string> param = new Dictionary<string, string>();
+                    param["?x"] = x.ToString();
+                    param["?y"] = y.ToString();
+                    System.Data.IDbCommand result = database.Query("SELECT * FROM reservations WHERE resXMin <= ?x AND resXMax >= ?x AND resYMin <= ?y AND resYMax >= ?y", param);
+                    System.Data.IDataReader reader = result.ExecuteReader();
+                    ReservationData row = database.readReservationRow(reader);
+                    reader.Close();
+                    result.Dispose();
+                    return row;
+                }
+            }
+            catch (Exception e)
+            {
+                database.Reconnect();
+                Console.WriteLine(e.ToString());
+                return null;
+            }
+        }
+    }
+}
author	MW	2007-06-27 15:28:52 +0000
committer	MW	2007-06-27 15:28:52 +0000
commit	646bbbc84b8010e0dacbeed5342cdb045f46cc49 (patch)
tree	770b34d19855363c3c113ab9a0af9a56d821d887 /OpenSim/Framework/Data.MySQL/MySQLGridData.cs
download	opensim-SC-646bbbc84b8010e0dacbeed5342cdb045f46cc49.zip opensim-SC-646bbbc84b8010e0dacbeed5342cdb045f46cc49.tar.gz opensim-SC-646bbbc84b8010e0dacbeed5342cdb045f46cc49.tar.bz2 opensim-SC-646bbbc84b8010e0dacbeed5342cdb045f46cc49.tar.xz

diff --git a/OpenSim/Framework/Data.MySQL/MySQLGridData.cs b/OpenSim/Framework/Data.MySQL/MySQLGridData.cs new file mode 100644 index 0000000..4d6cf63 --- /dev/null +++ b/OpenSim/Framework/Data.MySQL/MySQLGridData.cs
@@ -0,0 +1,285 @@
	1	/*
	2	* Copyright (c) Contributors, http://www.openmetaverse.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.Generic;
	30	using System.Text;
	31	using OpenGrid.Framework.Data;
	32
	33	namespace OpenGrid.Framework.Data.MySQL
	34	{
	35	/// <summary>
	36	/// A MySQL Interface for the Grid Server
	37	/// </summary>
	38	public class MySQLGridData : IGridData
	39	{
	40	/// <summary>
	41	/// MySQL Database Manager
	42	/// </summary>
	43	private MySQLManager database;
	44
	45	/// <summary>
	46	/// Initialises the Grid Interface
	47	/// </summary>
	48	public void Initialise()
	49	{
	50	IniFile GridDataMySqlFile = new IniFile("mysql_connection.ini");
	51	string settingHostname = GridDataMySqlFile.ParseFileReadValue("hostname");
	52	string settingDatabase = GridDataMySqlFile.ParseFileReadValue("database");
	53	string settingUsername = GridDataMySqlFile.ParseFileReadValue("username");
	54	string settingPassword = GridDataMySqlFile.ParseFileReadValue("password");
	55	string settingPooling = GridDataMySqlFile.ParseFileReadValue("pooling");
	56	string settingPort = GridDataMySqlFile.ParseFileReadValue("port");
	57
	58	database = new MySQLManager(settingHostname, settingDatabase, settingUsername, settingPassword, settingPooling, settingPort);
	59	}
	60
	61	/// <summary>
	62	/// Shuts down the grid interface
	63	/// </summary>
	64	public void Close()
	65	{
	66	database.Close();
	67	}
	68
	69	/// <summary>
	70	/// Returns the plugin name
	71	/// </summary>
	72	/// <returns>Plugin name</returns>
	73	public string getName()
	74	{
	75	return "MySql OpenGridData";
	76	}
	77
	78	/// <summary>
	79	/// Returns the plugin version
	80	/// </summary>
	81	/// <returns>Plugin version</returns>
	82	public string getVersion()
	83	{
	84	return "0.1";
	85	}
	86
	87	/// <summary>
	88	/// Returns all the specified region profiles within coordates -- coordinates are inclusive
	89	/// </summary>
	90	/// <param name="xmin">Minimum X coordinate</param>
	91	/// <param name="ymin">Minimum Y coordinate</param>
	92	/// <param name="xmax">Maximum X coordinate</param>
	93	/// <param name="ymax">Maximum Y coordinate</param>
	94	/// <returns></returns>
	95	public SimProfileData[] GetProfilesInRange(uint xmin, uint ymin, uint xmax, uint ymax)
	96	{
	97	try
	98	{
	99	lock (database)
	100	{
	101	Dictionary<string, string> param = new Dictionary<string, string>();
	102	param["?xmin"] = xmin.ToString();
	103	param["?ymin"] = ymin.ToString();
	104	param["?xmax"] = xmax.ToString();
	105	param["?ymax"] = ymax.ToString();
	106
	107	System.Data.IDbCommand result = database.Query("SELECT * FROM regions WHERE locX >= ?xmin AND locX <= ?xmax AND locY >= ?ymin AND locY <= ?ymax", param);
	108	System.Data.IDataReader reader = result.ExecuteReader();
	109
	110	SimProfileData row;
	111
	112	List<SimProfileData> rows = new List<SimProfileData>();
	113
	114	while ((row = database.readSimRow(reader)) != null)
	115	{
	116	rows.Add(row);
	117	}
	118	reader.Close();
	119	result.Dispose();
	120
	121	return rows.ToArray();
	122
	123	}
	124	}
	125	catch (Exception e)
	126	{
	127	database.Reconnect();
	128	Console.WriteLine(e.ToString());
	129	return null;
	130	}
	131	}
	132
	133	/// <summary>
	134	/// Returns a sim profile from it's location
	135	/// </summary>
	136	/// <param name="handle">Region location handle</param>
	137	/// <returns>Sim profile</returns>
	138	public SimProfileData GetProfileByHandle(ulong handle)
	139	{
	140	try
	141	{
	142	lock (database)
	143	{
	144	Dictionary<string, string> param = new Dictionary<string, string>();
	145	param["?handle"] = handle.ToString();
	146
	147	System.Data.IDbCommand result = database.Query("SELECT * FROM regions WHERE regionHandle = ?handle", param);
	148	System.Data.IDataReader reader = result.ExecuteReader();
	149
	150	SimProfileData row = database.readSimRow(reader);
	151	reader.Close();
	152	result.Dispose();
	153
	154	return row;
	155	}
	156	}
	157	catch (Exception e)
	158	{
	159	database.Reconnect();
	160	Console.WriteLine(e.ToString());
	161	return null;
	162	}
	163	}
	164
	165	/// <summary>
	166	/// Returns a sim profile from it's UUID
	167	/// </summary>
	168	/// <param name="uuid">The region UUID</param>
	169	/// <returns>The sim profile</returns>
	170	public SimProfileData GetProfileByLLUUID(libsecondlife.LLUUID uuid)
	171	{
	172	try
	173	{
	174	lock (database)
	175	{
	176	Dictionary<string, string> param = new Dictionary<string, string>();
	177	param["?uuid"] = uuid.ToStringHyphenated();
	178
	179	System.Data.IDbCommand result = database.Query("SELECT * FROM regions WHERE uuid = ?uuid", param);
	180	System.Data.IDataReader reader = result.ExecuteReader();
	181
	182	SimProfileData row = database.readSimRow(reader);
	183	reader.Close();
	184	result.Dispose();
	185
	186	return row;
	187	}
	188	}
	189	catch (Exception e)
	190	{
	191	database.Reconnect();
	192	Console.WriteLine(e.ToString());
	193	return null;
	194	}
	195	}
	196
	197	/// <summary>
	198	/// Adds a new profile to the database
	199	/// </summary>
	200	/// <param name="profile">The profile to add</param>
	201	/// <returns>Successful?</returns>
	202	public DataResponse AddProfile(SimProfileData profile)
	203	{
	204	lock (database)
	205	{
	206	if (database.insertRegion(profile))
	207	{
	208	return DataResponse.RESPONSE_OK;
	209	}
	210	else
	211	{
	212	return DataResponse.RESPONSE_ERROR;
	213	}
	214	}
	215	}
	216
	217	/// <summary>
	218	/// DEPRECIATED. Attempts to authenticate a region by comparing a shared secret.
	219	/// </summary>
	220	/// <param name="uuid">The UUID of the challenger</param>
	221	/// <param name="handle">The attempted regionHandle of the challenger</param>
	222	/// <param name="authkey">The secret</param>
	223	/// <returns>Whether the secret and regionhandle match the database entry for UUID</returns>
	224	public bool AuthenticateSim(libsecondlife.LLUUID uuid, ulong handle, string authkey)
	225	{
	226	bool throwHissyFit = false; // Should be true by 1.0
	227
	228	if (throwHissyFit)
	229	throw new Exception("CRYPTOWEAK AUTHENTICATE: Refusing to authenticate due to replay potential.");
	230
	231	SimProfileData data = GetProfileByLLUUID(uuid);
	232
	233	return (handle == data.regionHandle && authkey == data.regionSecret);
	234	}
	235
	236	/// <summary>
	237	/// NOT YET FUNCTIONAL. Provides a cryptographic authentication of a region
	238	/// </summary>
	239	/// <remarks>This requires a security audit.</remarks>
	240	/// <param name="uuid"></param>
	241	/// <param name="handle"></param>
	242	/// <param name="authhash"></param>
	243	/// <param name="challenge"></param>
	244	/// <returns></returns>
	245	public bool AuthenticateSim(libsecondlife.LLUUID uuid, ulong handle, string authhash, string challenge)
	246	{
	247	System.Security.Cryptography.SHA512Managed HashProvider = new System.Security.Cryptography.SHA512Managed();
	248	System.Text.ASCIIEncoding TextProvider = new ASCIIEncoding();
	249
	250	byte[] stream = TextProvider.GetBytes(uuid.ToStringHyphenated() + ":" + handle.ToString() + ":" + challenge);
	251	byte[] hash = HashProvider.ComputeHash(stream);
	252
	253	return false;
	254	}
	255
	256	public ReservationData GetReservationAtPoint(uint x, uint y)
	257	{
	258	try
	259	{
	260	lock (database)
	261	{
	262	Dictionary<string, string> param = new Dictionary<string, string>();
	263	param["?x"] = x.ToString();
	264	param["?y"] = y.ToString();
	265	System.Data.IDbCommand result = database.Query("SELECT * FROM reservations WHERE resXMin <= ?x AND resXMax >= ?x AND resYMin <= ?y AND resYMax >= ?y", param);
	266	System.Data.IDataReader reader = result.ExecuteReader();
	267
	268	ReservationData row = database.readReservationRow(reader);
	269	reader.Close();
	270	result.Dispose();
	271
	272	return row;
	273	}
	274	}
	275	catch (Exception e)
	276	{
	277	database.Reconnect();
	278	Console.WriteLine(e.ToString());
	279	return null;
	280	}
	281	}
	282	}
	283
	284
	285	}