From 8ea28ef717091fb43dd5154a467bdf78959e55cd Mon Sep 17 00:00:00 2001 From: ManfredAabye Date: Wed, 30 Jul 2025 15:25:49 +0200 Subject: [PATCH] Delete addon-modules/OpenSim.Data.MySQL.MySQLMoneyDataWrapper directory --- .../IMoneyManager.cs | 135 -- .../MySQLMoneyManager.cs | 1955 ----------------- .../MySQLSuperManager.cs | 99 - .../Properties/AssemblyInfo.cs | 32 - .../TransactionData.cs | 291 --- 5 files changed, 2512 deletions(-) delete mode 100644 addon-modules/OpenSim.Data.MySQL.MySQLMoneyDataWrapper/IMoneyManager.cs delete mode 100644 addon-modules/OpenSim.Data.MySQL.MySQLMoneyDataWrapper/MySQLMoneyManager.cs delete mode 100644 addon-modules/OpenSim.Data.MySQL.MySQLMoneyDataWrapper/MySQLSuperManager.cs delete mode 100644 addon-modules/OpenSim.Data.MySQL.MySQLMoneyDataWrapper/Properties/AssemblyInfo.cs delete mode 100644 addon-modules/OpenSim.Data.MySQL.MySQLMoneyDataWrapper/TransactionData.cs diff --git a/addon-modules/OpenSim.Data.MySQL.MySQLMoneyDataWrapper/IMoneyManager.cs b/addon-modules/OpenSim.Data.MySQL.MySQLMoneyDataWrapper/IMoneyManager.cs deleted file mode 100644 index def1de6..0000000 --- a/addon-modules/OpenSim.Data.MySQL.MySQLMoneyDataWrapper/IMoneyManager.cs +++ /dev/null @@ -1,135 +0,0 @@ -/* - * 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. - - Funktion - Die Datei definiert das C#-Interface IMoneyManager. - Sie legt die Methoden fest, die eine Klasse zur Verwaltung von Geldtransaktionen, Guthaben und Benutzerinformationen implementieren muss. - Typische Aufgaben des Interfaces: - Abfragen und Ändern von Benutzer-Guthaben (getBalance, withdrawMoney, giveMoney) - Hinzufügen und Abfragen von Transaktionen (addTransaction, FetchTransaction) - Verwaltung von Benutzern (addUser, addUserInfo, fetchUserInfo, updateUserInfo) - Validierung und Ablauf von Transaktionen (ValidateTransfer, SetTransExpired) - -NullPointer-Checks & Fehlerquellen - - Interface selbst: - Das Interface enthält keine Implementierung. Es ist lediglich eine Methodendefinition. Das bedeutet: - Es gibt keine Logik, also auch keine Möglichkeit für NullPointer-Fehler innerhalb dieser Datei. - Fehlerquellen oder NullPointer-Probleme hängen ausschließlich von den konkreten Implementierungen dieser Methoden ab. - - Parameter: - Die Methoden nehmen meist Strings, UUIDs, Ints und komplexe Typen wie TransactionData oder UserInfo als Parameter. - In einer späteren Implementierung sollte geprüft werden, ob übergebene Objekte (z.B. user, transaction) null sind, bevor darauf zugegriffen wird. - Rückgabewerte wie TransactionData oder UserInfo könnten null sein, wenn nichts gefunden wird – auch das ist Sache der Implementierung. - - Rückgabewerte: - Methoden, die Objekte zurückgeben (FetchTransaction, fetchUserInfo), haben keine Angaben, ob sie null zurückgeben dürfen. - Das sollte dokumentiert oder in der Implementierung behandelt werden. - -Zusammenfassung - NullPointer-Gefahr: - Im Interface selbst nicht möglich, da keine Ausführung erfolgt. - Fehlerquellen: - Keine im Interface; alle Fehlerquellen und NullPointer-Risiken entstehen erst in den Klassen, die dieses Interface implementieren. - Funktion: - Definition aller nötigen Methoden zur Verwaltung von Geldtransaktionen und Benutzerinformationen im OpenSim-Kontext. - -Fazit: -Die Datei IMoneyManager.cs ist ein reines Methoden-Interface und enthält keine Logik, die zu NullPointer-Fehlern führen kann. -Typische Fehlerquellen und NullPointer sollten in den konkreten Implementierungen der Methoden sorgfältig behandelt werden (z.B. Nullprüfungen auf Parameter, Rückgabewerte). - */ - -#pragma warning disable IDE1006 - -using OpenMetaverse; - -namespace OpenSim.Data.MySQL.MySQLMoneyDataWrapper -{ - public interface IMoneyManager - { - /// Gets the balance. - /// The user identifier. - int getBalance(string userID); - - /// Withdraws the money. - /// The transaction identifier. - /// The sender identifier. - /// The amount. - bool withdrawMoney(UUID transactionID, string senderID, int amount); - - /// Gives the money. - /// The transaction identifier. - /// The receiver identifier. - /// The amount. - bool giveMoney(UUID transactionID, string receiverID, int amount); - - /// Adds the transaction. - /// The transaction. - bool addTransaction(TransactionData transaction); - - /// Updates the transaction status. - /// The transaction identifier. - /// The status. - /// The description. - bool updateTransactionStatus(UUID transactionID, int status, string description); - - /// Fetches the transaction. - /// The transaction identifier. - TransactionData FetchTransaction(UUID transactionID); - - /// Fetches the transaction. - /// The user identifier. - /// The start time. - /// The end time. - /// The index. - /// The ret number. - TransactionData[] FetchTransaction(string userID, int startTime, int endTime, uint index, uint retNum); - - /// Gets the transaction number. - /// The user identifier. - /// The start time. - /// The end time. - int getTransactionNum(string userID, int startTime, int endTime); - - /// Adds the user. - /// The user identifier. - /// The balance. - /// The status. - /// The type. - bool addUser(string userID, int balance, int status, int type); - - /// Sets the trans expired. - /// The dead time. - bool SetTransExpired(int deadTime); - - /// Validates the transfer. - /// The secure code. - /// The transaction identifier. - bool ValidateTransfer(string secureCode, UUID transactionID); - - /// Adds the user information. - /// The user. - bool addUserInfo(UserInfo user); - - /// Fetches the user information. - /// The user identifier. - UserInfo fetchUserInfo(string userID); - - /// Updates the user information. - /// The user. - bool updateUserInfo(UserInfo user); - } -} diff --git a/addon-modules/OpenSim.Data.MySQL.MySQLMoneyDataWrapper/MySQLMoneyManager.cs b/addon-modules/OpenSim.Data.MySQL.MySQLMoneyDataWrapper/MySQLMoneyManager.cs deleted file mode 100644 index 4a7104d..0000000 --- a/addon-modules/OpenSim.Data.MySQL.MySQLMoneyDataWrapper/MySQLMoneyManager.cs +++ /dev/null @@ -1,1955 +0,0 @@ -/* - * Copyright (c) Contributors, http://opensimulator.org/, http://www.nsl.tuis.ac.jp/ 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. - -Funktion -Die Klasse MySQLMoneyManager implementiert das Interface IMoneyManager und ist das zentrale Datenbank-Backend für das OpenSim-Money-Modul (MySQL). Sie verwaltet: - - Verbindungen zur MySQL-Datenbank - Kontostände (balances) - Transaktionen (transactions) - Benutzerdaten (userinfo) - Verkaufstatistiken (totalsales) - Methoden zum Ein-/Auszahlen, Übertragen, Anlegen und Aktualisieren von Werten - -Null Pointer Checks & Fehlerquellen -Initialisierung und DB-Verbindung - Die Constructoren prüfen per .Any(p => string.IsNullOrEmpty(p)), ob alle benötigten Parameter gesetzt sind. Bei Fehlwerten gibt es einen klaren Exception-Throw. - Beim Öffnen der Datenbankverbindung wird jeder Fehler per Exception behandelt. - In allen Methoden, die auf die DB-Verbindung zugreifen, wird dbcon verwendet, das zentral initialisiert wird. - -Datenbankoperationen - Try-Catch-Blöcke sind an allen kritischen Stellen vorhanden, etwa beim Table-Setup, bei der Reconnect-Logik und bei Datenbankzugriffen. - Nach jedem Datenbankzugriff wird das Command-Objekt mit Dispose() freigegeben. - Beim Lesen von Datenbankwerten wird mit DBNull geprüft, ob ein Wert gesetzt ist, bevor er als String oder int gecastet wird. - Bei Methoden, die Objekte zurückgeben (z.B. FetchTransaction, fetchUserInfo), wird im Fehlerfall null zurückgegeben und im Catch geloggt. - -Null Pointer Checks - Bei Methoden wie addTransaction werden Objekteigenschaften vor Benutzung auf null geprüft und ggf. mit Defaultwerten gefüllt. - Bei Übergabeobjekten wie UserInfo wird vor dem Zugriff geprüft, ob z.B. Avatar null ist. - Rückgabewerte wie bei fetchUserInfo werden nur dann zurückgegeben, wenn die UserID wirklich gefunden wurde – sonst gibt es null. - Bei Methoden, die Listen zurückgeben (z.B. FetchTransaction(string userID, ...)), wird bei DB-Lesefehlern null oder ein leeres Array zurückgegeben. - -Fehlerquellen - Fehlerhafte oder fehlende DB-Verbindung: Exception und Logging. - SQL-Befehle mit Fehlern: Exception und Logging. - Ungültige Eingabewerte (z.B. null bei Strings/Objekten): Entweder direkter Return, Exception oder Logging. - Potentielle Race-Conditions werden durch lock (dbcon) reduziert. - Ressourcenlecks werden durch konsequentes .Dispose() der Commands/Reader vermieden. - -Positive Beispiele für Fehlerbehandlung - - Parameter-Checks: - C# - -if (requiredParameters.Any(p => string.IsNullOrEmpty(p))) { throw new ArgumentException(...); } - -DB-Reader mit Exception Handling: -C# - -catch (Exception e) { - m_log.Error("[MONEY MANAGER]: Fetching transaction failed 1: " + e.ToString()); - r.Close(); cmd.Dispose(); return null; -} - -Null/Default-Initialisierung: -C# - - if (transaction.ObjectUUID == null) transaction.ObjectUUID = UUID.Zero.ToString(); - if (transaction.ObjectName == null) transaction.ObjectName = string.Empty; - -Zusammenfassung/Fazit - Null Pointer: Das Risiko ist im Code durch Checks, Defaultwerte und Exception-Handling weitgehend minimiert. - Fehlerquellen: Vor allem externe Faktoren (DB-Verbindung, SQL-Syntax). Im Code wird alles sauber abgefangen und geloggt. - Funktion: Umfassende Datenbank-Backend-Klasse für OpenSim-Money, mit Methoden für alle wichtigen Operationen (Balance, Transaktionen, User, Verkauf). - -Empfehlung: -Der Code ist für produktiven Einsatz geeignet, robust gegen NullPointer-Fehler und typische Fehlerquellen. -Bei zukünftigen Erweiterungen empfiehlt sich: Bei allen Methoden, die Objekte oder komplexe Werte zurückgeben, weiterhin konsequent auf null prüfen und Exceptions sauber loggen. - */ - -using System; -using System.Data; -using System.Reflection; -using System.Collections.Generic; -using System.Text.RegularExpressions; -using log4net; -using MySql.Data.MySqlClient; -using OpenMetaverse; -using System.Linq; - -namespace OpenSim.Data.MySQL.MySQLMoneyDataWrapper -{ - public class MySQLMoneyManager : IMoneyManager - { - private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType); - - private string Table_of_Balances = "balances"; - private string Table_of_Transactions = "transactions"; - private string Table_of_TotalSales = "totalsales"; - private string Table_of_UserInfo = "userinfo"; - private int balances_rev = 0; - private int userinfo_rev = 0; - - private string connectString; - public MySqlConnection dbcon; - - - // Korrigierte Initialisierung des Connection-Strings mit Pooling-Check - public MySQLMoneyManager(string hostname, string database, string username, string password, string cpooling, string port) - { - var requiredParameters = new[] { hostname, database, username, password, cpooling, port }; - - if (requiredParameters.Any(p => string.IsNullOrEmpty(p))) - { - throw new ArgumentException("All connection parameters must be provided."); - } - - // Pooling-Parameter prüfen und ggf. setzen - string poolingValue = cpooling?.Trim().ToLower(); - if (string.IsNullOrEmpty(poolingValue) || poolingValue == "true" || poolingValue == "yes" || poolingValue == "1") - { - poolingValue = "true"; - } - else if (poolingValue == "false" || poolingValue == "no" || poolingValue == "0") - { - poolingValue = "false"; - } - else - { - // Fallback auf Standardwert - poolingValue = "true"; - } - - string connectionString = $"Server={hostname};Port={port};Database={database};User ID={username};Password={password};Pooling={poolingValue};"; - Initialise(connectionString); - } - - public MySQLMoneyManager(string connect) - { - Initialise(connect); - } - - private void Initialise(string connect) - { - // 1. Initialisiere Verbindungen - InitialiseConnection(connect); - - // 2. Überprüfe und erstelle Tabellen - CheckAndCreateTables(); - } - - // 1. Initialisiere Verbindungen - private void InitialiseConnection(string connect) - { - try - { - connectString = connect; - dbcon = new MySqlConnection(connectString); - dbcon.Open(); - } - catch (Exception e) - { - throw new Exception("[MONEY MANAGER]: Error initializing MySql Database: " + e.ToString()); - } - } - - // 2. Überprüfe und erstelle Tabellen - private void CheckAndCreateTables() - { - try - { - Dictionary tableList = CheckTables(); - - InitialiseBalancesTable(tableList); - InitialiseUserInfoTable(tableList); - InitialiseTransactionsTable(tableList); - InitialiseTotalSalesTable(tableList); - } - catch (Exception e) - { - m_log.Error("[MONEY MANAGER]: Error checking or creating tables: " + e.ToString()); - throw new Exception("[MONEY MANAGER]: Error checking or creating tables: " + e.ToString()); - } - } - - private void InitialiseBalancesTable(Dictionary tableList) - { - if (!tableList.ContainsKey(Table_of_Balances)) - { - try - { - CreateBalancesTable(); - } - catch (Exception e) - { - throw new Exception("[MONEY MANAGER]: Error creating balances table: " + e.ToString()); - } - } - else - { - string version = tableList[Table_of_Balances].Trim(); - int nVer = getTableVersionNum(version); - balances_rev = nVer; - switch (nVer) - { - case 1: //Rev.1 - UpdateBalancesTable1(); - UpdateBalancesTable2(); - UpdateBalancesTable3(); - break; - case 2: //Rev.2 - UpdateBalancesTable2(); - UpdateBalancesTable3(); - break; - case 3: //Rev.3 - UpdateBalancesTable3(); - break; - } - } - } - - private void InitialiseUserInfoTable(Dictionary tableList) - { - if (!tableList.ContainsKey(Table_of_UserInfo)) - { - try - { - CreateUserInfoTable(); - } - catch (Exception e) - { - throw new Exception("[MONEY MANAGER]: Error creating userinfo table: " + e.ToString()); - } - } - else - { - string version = tableList[Table_of_UserInfo].Trim(); - int nVer = getTableVersionNum(version); - userinfo_rev = nVer; - switch (nVer) - { - case 1: //Rev.1 - UpdateUserInfoTable1(); - UpdateUserInfoTable2(); - break; - case 2: //Rev.2 - UpdateUserInfoTable2(); - break; - } - } - } - - private void InitialiseTransactionsTable(Dictionary tableList) - { - if (!tableList.ContainsKey(Table_of_Transactions)) - { - try - { - CreateTransactionsTable(); - } - catch (Exception e) - { - throw new Exception("[MONEY MANAGER]: Error creating transactions table: " + e.ToString()); - } - } - else - { - string version = tableList[Table_of_Transactions].Trim(); - int nVer = getTableVersionNum(version); - switch (nVer) - { - case 2: //Rev.2 - UpdateTransactionsTable2(); - UpdateTransactionsTable3(); - UpdateTransactionsTable4(); - UpdateTransactionsTable5(); - UpdateTransactionsTable6(); - UpdateTransactionsTable7(); - UpdateTransactionsTable8(); - UpdateTransactionsTable9(); - UpdateTransactionsTable10(); - UpdateTransactionsTable11(); - break; - case 3: //Rev.3 - UpdateTransactionsTable3(); - UpdateTransactionsTable4(); - UpdateTransactionsTable5(); - UpdateTransactionsTable6(); - UpdateTransactionsTable7(); - UpdateTransactionsTable8(); - UpdateTransactionsTable9(); - UpdateTransactionsTable10(); - UpdateTransactionsTable11(); - break; - case 4: //Rev.4 - UpdateTransactionsTable4(); - UpdateTransactionsTable5(); - UpdateTransactionsTable6(); - UpdateTransactionsTable7(); - UpdateTransactionsTable8(); - UpdateTransactionsTable9(); - UpdateTransactionsTable10(); - UpdateTransactionsTable11(); - break; - case 5: //Rev.5 - UpdateTransactionsTable5(); - UpdateTransactionsTable6(); - UpdateTransactionsTable7(); - UpdateTransactionsTable8(); - UpdateTransactionsTable9(); - UpdateTransactionsTable10(); - UpdateTransactionsTable11(); - break; - case 6: //Rev.6 - UpdateTransactionsTable6(); - UpdateTransactionsTable7(); - UpdateTransactionsTable8(); - UpdateTransactionsTable9(); - UpdateTransactionsTable10(); - UpdateTransactionsTable11(); - break; - case 7: //Rev.7 - UpdateTransactionsTable7(); - UpdateTransactionsTable8(); - UpdateTransactionsTable9(); - UpdateTransactionsTable10(); - UpdateTransactionsTable11(); - break; - case 8: //Rev.8 - UpdateTransactionsTable8(); - UpdateTransactionsTable9(); - UpdateTransactionsTable10(); - UpdateTransactionsTable11(); - break; - case 9: //Rev.9 - UpdateTransactionsTable9(); - UpdateTransactionsTable10(); - UpdateTransactionsTable11(); - break; - case 10: //Rev.10 - UpdateTransactionsTable10(); - UpdateTransactionsTable11(); - break; - case 11: //Rev.11 - UpdateTransactionsTable11(); - break; - } - } - } - - private void InitialiseTotalSalesTable(Dictionary tableList) - { - if (!tableList.ContainsKey(Table_of_TotalSales)) - { - try - { - CreateTotalSalesTable(); - } - catch (Exception e) - { - throw new Exception("[MONEY MANAGER]: Error creating totalsales table: " + e.ToString()); - } - } - else - { - string version = tableList[Table_of_TotalSales].Trim(); - int nVer = getTableVersionNum(version); - switch (nVer) - { - case 1: //Rev.1 - UpdateTotalSalesTable1(); - UpdateTotalSalesTable2(); - break; - case 2: //Rev.2 - UpdateTotalSalesTable2(); - break; - } - } - } - - - - /// Gets the table version number. - /// The version. - private int getTableVersionNum(string version) - { - int nVer = 0; - - Regex _commentPattenRegex = new Regex(@"\w+\.(?\d+)"); - Match m = _commentPattenRegex.Match(version); - if (m.Success) - { - string ver = m.Groups["ver"].Value; - nVer = Convert.ToInt32(ver); - } - return nVer; - } - - /// Creates the balances table. - private void CreateBalancesTable() - { - string sql = string.Empty; - - sql = "CREATE TABLE `" + Table_of_Balances + "` ("; - sql += "`user` varchar(36) NOT NULL,"; - sql += "`balance` int(10) NOT NULL,"; - sql += "`status` tinyint(2) DEFAULT NULL,"; - sql += "`type` tinyint(2) NOT NULL DEFAULT 0,"; - sql += "PRIMARY KEY(`user`))"; - sql += "Engine=InnoDB DEFAULT CHARSET=utf8 "; - - sql += "COMMENT='Rev.4';"; - MySqlCommand cmd = new MySqlCommand(sql, dbcon); - cmd.ExecuteNonQuery(); - cmd.Dispose(); - } - - - /// Creates the user information table. - private void CreateUserInfoTable() - { - string sql = string.Empty; - - sql = "CREATE TABLE `" + Table_of_UserInfo + "` ("; - sql += "`user` varchar(36) NOT NULL,"; - sql += "`simip` varchar(64) NOT NULL,"; - sql += "`avatar` varchar(50) NOT NULL,"; - sql += "`pass` varchar(36) NOT NULL DEFAULT '',"; - sql += "`type` tinyint(2) NOT NULL DEFAULT 0,"; - sql += "`class` tinyint(2) NOT NULL DEFAULT 0,"; - sql += "`serverurl` varchar(255) NOT NULL DEFAULT '',"; - sql += "PRIMARY KEY(`user`))"; - sql += "Engine=InnoDB DEFAULT CHARSET=utf8 "; - - sql += "COMMENT='Rev.3';"; - MySqlCommand cmd = new MySqlCommand(sql, dbcon); - cmd.ExecuteNonQuery(); - cmd.Dispose(); - } - - - /// Creates the transactions table. - private void CreateTransactionsTable() - { - string sql = string.Empty; - - sql = "CREATE TABLE `" + Table_of_Transactions + "`("; - sql += "`UUID` varchar(36) NOT NULL,"; - sql += "`sender` varchar(36) NOT NULL,"; - sql += "`receiver` varchar(36) NOT NULL,"; - sql += "`amount` int(10) NOT NULL,"; - sql += "`senderBalance` int(10) NOT NULL DEFAULT -1,"; - sql += "`receiverBalance` int(10) NOT NULL DEFAULT -1,"; - sql += "`objectUUID` varchar(36) DEFAULT NULL,"; - sql += "`objectName` varchar(255) DEFAULT NULL,"; - sql += "`regionHandle` varchar(36) NOT NULL,"; - sql += "`regionUUID` varchar(36) NOT NULL,"; - sql += "`type` int(10) NOT NULL,"; - sql += "`time` int(11) NOT NULL,"; - sql += "`secure` varchar(36) NOT NULL,"; - sql += "`status` tinyint(1) NOT NULL,"; - sql += "`commonName` varchar(128) NOT NULL,"; - sql += "`description` varchar(255) DEFAULT NULL,"; - sql += "PRIMARY KEY(`UUID`))"; - sql += "Engine=InnoDB DEFAULT CHARSET=utf8 "; - - sql += "COMMENT='Rev.12';"; - MySqlCommand cmd = new MySqlCommand(sql, dbcon); - cmd.ExecuteNonQuery(); - cmd.Dispose(); - } - - - /// Creates the total sales table. - private void CreateTotalSalesTable() - { - string sql = string.Empty; - - sql = "CREATE TABLE `" + Table_of_TotalSales + "` ("; - sql += "`UUID` varchar(36) NOT NULL,"; - sql += "`user` varchar(36) NOT NULL,"; - sql += "`objectUUID` varchar(36) NOT NULL,"; - sql += "`type` int(10) NOT NULL,"; - sql += "`TotalCount` int(10) NOT NULL DEFAULT 0,"; - sql += "`TotalAmount` int(10) NOT NULL DEFAULT 0,"; - sql += "`time` int(11) NOT NULL,"; - sql += "PRIMARY KEY(`UUID`))"; - sql += "Engine=InnoDB DEFAULT CHARSET=utf8 "; - - sql += "COMMENT='Rev.3';"; - MySqlCommand cmd = new MySqlCommand(sql, dbcon); - cmd.ExecuteNonQuery(); - cmd.Dispose(); - - initTotalSalesTable(); - } - - - /// Updates the balances table1. - private void UpdateBalancesTable1() - { - m_log.Info("[MONEY MANAGER]: Converting Balance Table..."); - string sql = string.Empty; - - sql = "SELECT COUNT(*) FROM " + Table_of_Balances; - MySqlCommand cmd = new MySqlCommand(sql, dbcon); - int resultCount = int.Parse(cmd.ExecuteScalar().ToString()); - cmd.Dispose(); - - sql = "SELECT * FROM " + Table_of_Balances; - cmd = new MySqlCommand(sql, dbcon); - MySqlDataReader dbReader = cmd.ExecuteReader(); - - int l = 0; - string[,] row = new string[resultCount, dbReader.FieldCount]; - while (dbReader.Read()) - { - for (int i = 0; i < dbReader.FieldCount; i++) - { - row[l, i] = dbReader.GetString(i); - } - l++; - } - dbReader.Close(); - cmd.Dispose(); - - bool updatedb = true; - for (int i = 0; i < resultCount; i++) - { - string uuid = Regex.Replace(row[i, 0], @"@.+$", ""); - if (uuid != row[i, 0]) - { - int amount = int.Parse(row[i, 1]); - int balance = getBalance(uuid); - if (balance >= 0) - { - amount += balance; - updatedb = updateBalance(uuid, amount); - } - else - { - updatedb = addUser(uuid, amount, int.Parse(row[i, 2]), 0); - } - if (!updatedb) break; - } - } - - // Delete - if (updatedb) - { - for (int i = 0; i < resultCount; i++) - { - string uuid = Regex.Replace(row[i, 0], @"@.+$", ""); - if (uuid != row[i, 0]) - { - sql = "DELETE FROM " + Table_of_Balances + " WHERE user = ?uuid"; - cmd = new MySqlCommand(sql, dbcon); - cmd.Parameters.AddWithValue("?uuid", row[i, 0]); - cmd.ExecuteNonQuery(); - cmd.Dispose(); - } - } - - - sql = "BEGIN;"; - sql += "ALTER TABLE `" + Table_of_Balances + "` "; - sql += "COMMENT = 'Rev.2';"; - sql += "COMMIT;"; - cmd = new MySqlCommand(sql, dbcon); - cmd.ExecuteNonQuery(); - cmd.Dispose(); - } - } - - - /// Updates the balances table2. - private void UpdateBalancesTable2() - { - string sql = string.Empty; - - sql = "BEGIN;"; - sql += "ALTER TABLE `" + Table_of_Balances + "` "; - sql += "MODIFY COLUMN `user` varchar(36) NOT NULL,"; - sql += "COMMENT = 'Rev.3';"; - sql += "COMMIT;"; - MySqlCommand cmd = new MySqlCommand(sql, dbcon); - cmd.ExecuteNonQuery(); - cmd.Dispose(); - } - - - /// Updates the balances table3. - private void UpdateBalancesTable3() - { - string sql = string.Empty; - - sql = "BEGIN;"; - sql += "ALTER TABLE `" + Table_of_Balances + "` "; - sql += "ADD `type` tinyint(2) NOT NULL DEFAULT 0 AFTER `status`,"; - sql += "COMMENT = 'Rev.4';"; - sql += "COMMIT;"; - MySqlCommand cmd = new MySqlCommand(sql, dbcon); - cmd.ExecuteNonQuery(); - cmd.Dispose(); - } - - /// Updates the user information table1. - private void UpdateUserInfoTable1() - { - //m_log.Info("[MONEY MANAGER]: Converting UserInfo Table..."); - string sql = string.Empty; - - sql = "SELECT COUNT(*) FROM " + Table_of_UserInfo; - MySqlCommand cmd = new MySqlCommand(sql, dbcon); - int resultCount = int.Parse(cmd.ExecuteScalar().ToString()); - cmd.Dispose(); - - sql = "SELECT * FROM " + Table_of_UserInfo; - cmd = new MySqlCommand(sql, dbcon); - MySqlDataReader dbReader = cmd.ExecuteReader(); - - int l = 0; - string[,] row = new string[resultCount, dbReader.FieldCount]; - while (dbReader.Read()) - { - for (int i = 0; i < dbReader.FieldCount; i++) - { - row[l, i] = dbReader.GetString(i); - } - l++; - } - dbReader.Close(); - cmd.Dispose(); - - // UniversalID -> uuid, url, name, pass - bool updatedb = true; - for (int i = 0; i < resultCount; i++) - { - string uuid = Regex.Replace(row[i, 0], @"@.+$", ""); - if (uuid != row[i, 0]) - { - UserInfo userInfo = fetchUserInfo(uuid); - if (userInfo == null) - { - userInfo = new UserInfo(); - userInfo.UserID = uuid; - userInfo.SimIP = row[i, 1]; - userInfo.Avatar = row[i, 2]; - userInfo.PswHash = row[i, 3]; - updatedb = addUserInfo(userInfo); - } - } - } - - // Delete - if (updatedb) - { - for (int i = 0; i < resultCount; i++) - { - string uuid = Regex.Replace(row[i, 0], @"@.+$", ""); - if (uuid != row[i, 0]) - { - sql = "DELETE FROM " + Table_of_UserInfo + " WHERE user = ?uuid"; - cmd = new MySqlCommand(sql, dbcon); - cmd.Parameters.AddWithValue("?uuid", row[i, 0]); - cmd.ExecuteNonQuery(); - cmd.Dispose(); - } - } - - // - sql = "BEGIN;"; - sql += "ALTER TABLE `" + Table_of_UserInfo + "` "; - sql += "COMMENT = 'Rev.2';"; - sql += "COMMIT;"; - cmd = new MySqlCommand(sql, dbcon); - cmd.ExecuteNonQuery(); - cmd.Dispose(); - } - } - - /// Updates the user information table2. - private void UpdateUserInfoTable2() - { - string sql = string.Empty; - - sql = "BEGIN;"; - sql += "ALTER TABLE `" + Table_of_UserInfo + "` "; - sql += "MODIFY COLUMN `user` varchar(36) NOT NULL,"; - sql += "MODIFY COLUMN `pass` varchar(36) NOT NULL DEFAULT '',"; - sql += "ADD `type` tinyint(2) NOT NULL DEFAULT 0 AFTER `pass`,"; - sql += "ADD `class` tinyint(2) NOT NULL DEFAULT 0 AFTER `type`,"; - sql += "ADD `serverurl` varchar(255) NOT NULL DEFAULT '' AFTER `class`,"; - sql += "COMMENT = 'Rev.3';"; - sql += "COMMIT;"; - MySqlCommand cmd = new MySqlCommand(sql, dbcon); - cmd.ExecuteNonQuery(); - cmd.Dispose(); - } - - - // update Transactions Table - - /// - /// update transactions table from Rev.2 to Rev.3 - /// - private void UpdateTransactionsTable2() - { - string sql = string.Empty; - - sql = "BEGIN;"; - sql += "ALTER TABLE `" + Table_of_Transactions + "` "; - sql += "ADD(`objectUUID` varchar(36) DEFAULT NULL AFTER `amount`),"; - sql += "COMMENT = 'Rev.3';"; - sql += "COMMIT;"; - MySqlCommand cmd = new MySqlCommand(sql, dbcon); - cmd.ExecuteNonQuery(); - cmd.Dispose(); - } - - - /// - /// update transactions table from Rev.3 to Rev.4 - /// - private void UpdateTransactionsTable3() - { - string sql = string.Empty; - - sql = "BEGIN;"; - sql += "ALTER TABLE `" + Table_of_Transactions + "` "; - sql += "ADD(`secure` varchar(36) NOT NULL AFTER `time`),"; - sql += "COMMENT = 'Rev.4';"; - sql += "COMMIT;"; - MySqlCommand cmd = new MySqlCommand(sql, dbcon); - cmd.ExecuteNonQuery(); - cmd.Dispose(); - } - - - /// - /// update transactions table from Rev.4 to Rev.5 - /// - private void UpdateTransactionsTable4() - { - string sql = string.Empty; - - sql = "BEGIN;"; - sql += "ALTER TABLE `" + Table_of_Transactions + "` "; - sql += "ADD(`regionHandle` varchar(36) NOT NULL AFTER `objectUUID`),"; - sql += "COMMENT = 'Rev.5';"; - sql += "COMMIT;"; - MySqlCommand cmd = new MySqlCommand(sql, dbcon); - cmd.ExecuteNonQuery(); - cmd.Dispose(); - } - - - /// - /// update transactions table from Rev.5 to Rev.6 - /// - private void UpdateTransactionsTable5() - { - string sql = string.Empty; - - sql = "BEGIN;"; - sql += "ALTER TABLE `" + Table_of_Transactions + "` "; - sql += "ADD(`commonName` varchar(128) NOT NULL AFTER `status`),"; - sql += "COMMENT = 'Rev.6';"; - sql += "COMMIT;"; - MySqlCommand cmd = new MySqlCommand(sql, dbcon); - cmd.ExecuteNonQuery(); - cmd.Dispose(); - } - - - /// - /// update transactions table from Rev.6 to Rev.7 - /// - private void UpdateTransactionsTable6() - { - string sql = string.Empty; - - sql = "SELECT COUNT(*) FROM " + Table_of_Transactions; - MySqlCommand cmd = new MySqlCommand(sql, dbcon); - int resultCount = int.Parse(cmd.ExecuteScalar().ToString()); - cmd.Dispose(); - - sql = "SELECT UUID,sender,receiver FROM " + Table_of_Transactions; - cmd = new MySqlCommand(sql, dbcon); - MySqlDataReader dbReader = cmd.ExecuteReader(); - - int l = 0; - string[,] row = new string[resultCount, dbReader.FieldCount]; - while (dbReader.Read()) - { - for (int i = 0; i < dbReader.FieldCount; i++) - { - row[l, i] = dbReader.GetString(i); - } - l++; - } - dbReader.Close(); - cmd.Dispose(); - - sql = "UPDATE " + Table_of_Transactions + " SET sender = ?sender , receiver = ?receiver WHERE UUID = ?uuid;"; - for (int i = 0; i < resultCount; i++) - { - string sender = Regex.Replace(row[i, 1], @"@.+$", ""); - string receiver = Regex.Replace(row[i, 2], @"@.+$", ""); - cmd = new MySqlCommand(sql, dbcon); - cmd.Parameters.AddWithValue("?uuid", row[i, 0]); - cmd.Parameters.AddWithValue("?sender", sender); - cmd.Parameters.AddWithValue("?receiver", receiver); - cmd.ExecuteNonQuery(); - cmd.Dispose(); - } - - sql = "BEGIN;"; - sql += "ALTER TABLE `" + Table_of_Transactions + "` "; - sql += "COMMENT = 'Rev.7';"; - sql += "COMMIT;"; - cmd = new MySqlCommand(sql, dbcon); - cmd.ExecuteNonQuery(); - cmd.Dispose(); - } - - - /// - /// update transactions table from Rev.7 to Rev.8 - /// - private void UpdateTransactionsTable7() - { - string sql = string.Empty; - - sql = "BEGIN;"; - sql += "ALTER TABLE `" + Table_of_Transactions + "` "; - sql += "ADD `objectName` varchar(255) DEFAULT NULL AFTER `objectUUID`,"; - sql += "COMMENT = 'Rev.8';"; - sql += "COMMIT;"; - MySqlCommand cmd = new MySqlCommand(sql, dbcon); - cmd.ExecuteNonQuery(); - cmd.Dispose(); - } - - - /// - /// update transactions table from Rev.8 to Rev.9 - /// - private void UpdateTransactionsTable8() - { - string sql = string.Empty; - - sql = "BEGIN;"; - sql += "ALTER TABLE `" + Table_of_Transactions + "` "; - sql += "ADD `senderBalance` int(10) NOT NULL DEFAULT -1 AFTER `amount`,"; - sql += "ADD `receiverBalance` int(10) NOT NULL DEFAULT -1 AFTER `senderBalance`,"; - sql += "COMMENT = 'Rev.9';"; - sql += "COMMIT;"; - MySqlCommand cmd = new MySqlCommand(sql, dbcon); - cmd.ExecuteNonQuery(); - cmd.Dispose(); - } - - - /// - /// update transactions table from Rev.9 to Rev.10 - /// - private void UpdateTransactionsTable9() - { - string sql = string.Empty; - - sql = "BEGIN;"; - sql += "ALTER TABLE `" + Table_of_Transactions + "` "; - sql += "MODIFY COLUMN `sender` varchar(36) NOT NULL,"; - sql += "MODIFY COLUMN `receiver` varchar(36) NOT NULL,"; - sql += "COMMENT = 'Rev.10';"; - sql += "COMMIT;"; - MySqlCommand cmd = new MySqlCommand(sql, dbcon); - cmd.ExecuteNonQuery(); - cmd.Dispose(); - } - - - /// - /// update transactions table from Rev.10 to Rev.11 - /// change type of BirthGift from 1000 to 900 - /// - private void UpdateTransactionsTable10() - { - string sql = string.Empty; - - sql = "SELECT COUNT(*) FROM `" + Table_of_Transactions + "` WHERE type=1000"; - MySqlCommand cmd = new MySqlCommand(sql, dbcon); - int resultCount = int.Parse(cmd.ExecuteScalar().ToString()); - cmd.Dispose(); - - if (resultCount > 0) - { - sql = "SELECT UUID FROM `" + Table_of_Transactions + "` WHERE type=1000"; - cmd = new MySqlCommand(sql, dbcon); - MySqlDataReader dbReader = cmd.ExecuteReader(); - - int l = 0; - string[] row = new string[resultCount]; - while (dbReader.Read()) - { - row[l] = dbReader.GetString(0); - l++; - } - dbReader.Close(); - cmd.Dispose(); - - sql = "UPDATE `" + Table_of_Transactions + "` SET type=900 WHERE UUID=?uuid"; - for (int i = 0; i < resultCount; i++) - { - cmd = new MySqlCommand(sql, dbcon); - cmd.Parameters.AddWithValue("?uuid", row[i]); - cmd.ExecuteNonQuery(); - cmd.Dispose(); - } - } - - sql = "BEGIN;"; - sql += "ALTER TABLE `" + Table_of_Transactions + "` "; - sql += "COMMENT = 'Rev.11';"; - sql += "COMMIT;"; - cmd = new MySqlCommand(sql, dbcon); - cmd.ExecuteNonQuery(); - cmd.Dispose(); - } - - - /// - /// update transactions table from Rev.11 to Rev.12 - /// - private void UpdateTransactionsTable11() - { - string sql = string.Empty; - - sql = "BEGIN;"; - sql += "ALTER TABLE `" + Table_of_Transactions + "` "; - sql += "ADD `regionUUID` varchar(36) NOT NULL AFTER `regionHandle`,"; - sql += "COMMENT = 'Rev.12';"; - sql += "COMMIT;"; - MySqlCommand cmd = new MySqlCommand(sql, dbcon); - cmd.ExecuteNonQuery(); - cmd.Dispose(); - } - - - // update Total Sales Table - - /// Updates the total sales table1. - private void UpdateTotalSalesTable1() - { - string sql = string.Empty; - - sql = "BEGIN;"; - sql += "ALTER TABLE `" + Table_of_TotalSales + "` "; - sql += "ADD `time` int(11) NOT NULL AFTER `TotalAmount`,"; - sql += "COMMENT = 'Rev.2';"; - sql += "COMMIT;"; - MySqlCommand cmd = new MySqlCommand(sql, dbcon); - cmd.ExecuteNonQuery(); - cmd.Dispose(); - - deleteTotalSalesTable(); - initTotalSalesTable(); - } - - /// Updates the total sales table2. - private void UpdateTotalSalesTable2() - { - string sql = string.Empty; - - sql = "BEGIN;"; - sql += "ALTER TABLE `" + Table_of_TotalSales + "` "; - sql += "MODIFY COLUMN `user` varchar(36) NOT NULL,"; - sql += "COMMENT = 'Rev.3';"; - sql += "COMMIT;"; - MySqlCommand cmd = new MySqlCommand(sql, dbcon); - cmd.ExecuteNonQuery(); - cmd.Dispose(); - } - - - /// Checks the tables. - /// - ///
- /// - /// [MONEY MANAGER]: Error checking tables" + e.ToString() - private Dictionary CheckTables() - { - Dictionary tableDic = new Dictionary(); - - lock (dbcon) - { - string sql = string.Empty; - - sql = "SELECT TABLE_NAME,TABLE_COMMENT FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_SCHEMA=?dbname"; - MySqlCommand cmd = new MySqlCommand(sql, dbcon); - cmd.Parameters.AddWithValue("?dbname", dbcon.Database); - - using (MySqlDataReader r = cmd.ExecuteReader()) - { - while (r.Read()) - { - try - { - string tableName = (string)r["TABLE_NAME"]; - string comment = (string)r["TABLE_COMMENT"]; - tableDic.Add(tableName, comment); - } - catch (Exception e) - { - throw new Exception("[MONEY MANAGER]: Error checking tables" + e.ToString()); - } - } - r.Close(); - } - - cmd.Dispose(); - return tableDic; - } - } - - - public void Reconnect() - { - m_log.Info("[MONEY MANAGER]: Reconnecting database"); - lock (dbcon) - { - try - { - dbcon.Close(); - dbcon = new MySqlConnection(connectString); - dbcon.Open(); - m_log.Info("[MONEY MANAGER]: Reconnected database"); - } - catch (Exception e) - { - m_log.Error("[MONEY MANAGER]: Unable to reconnect to database: " + e.ToString()); - } - } - } - - /// - /// Get balance from database. returns -1 if failed. - /// - /// - public int getBalance(string userID) - { - if (userID == UUID.Zero.ToString()) return 999999999; // System - - int retValue = -1; - string sql = string.Empty; - - sql = "SELECT balance FROM " + Table_of_Balances + " WHERE user = ?userid"; - MySqlCommand cmd = new MySqlCommand(sql, dbcon); - cmd.Parameters.AddWithValue("?userid", userID); - - using (MySqlDataReader dbReader = cmd.ExecuteReader(CommandBehavior.SingleRow)) - { - try - { - if (dbReader.Read()) - { - retValue = Convert.ToInt32(dbReader["balance"]); - } - } - catch (Exception e) - { - e.ToString(); - m_log.ErrorFormat("[MoneyDB]: MySql failed to fetch balance {0}.", userID); - retValue = -2; - } - - dbReader.Close(); - } - cmd.Dispose(); - - return retValue; - } - - - /// Updates the balance. - /// The user identifier. - /// The amount. - public bool updateBalance(string userID, int amount) - { - if (userID == UUID.Zero.ToString()) return true; // System - - bool bRet = false; - string sql = string.Empty; - - sql = "UPDATE " + Table_of_Balances + " SET balance = ?amount WHERE user = ?userID;"; - MySqlCommand cmd = new MySqlCommand(sql, dbcon); - cmd.Parameters.AddWithValue("?amount", amount); - cmd.Parameters.AddWithValue("?userID", userID); - - if (cmd.ExecuteNonQuery() > 0) bRet = true; - - cmd.Dispose(); - return bRet; - } - - - /// Adds the user. - /// The user identifier. - /// The balance. - /// The status. - /// The type. - public bool addUser(string userID, int balance, int status, int type) - { - if (userID == UUID.Zero.ToString()) return true; // System - - bool bRet = false; - string sql = string.Empty; - - if (balances_rev >= 4) - { - sql = "INSERT INTO " + Table_of_Balances + " (`user`,`balance`,`status`,`type`) VALUES "; - sql += " (?userID,?balance,?status,?type);"; - } - else - { - sql = "INSERT INTO " + Table_of_Balances + " (`user`,`balance`,`status`) VALUES "; - sql += " (?userID,?balance,?status);"; - } - MySqlCommand cmd = new MySqlCommand(sql, dbcon); - - cmd.Parameters.AddWithValue("?userID", userID); - cmd.Parameters.AddWithValue("?balance", balance); - cmd.Parameters.AddWithValue("?status", status); - if (balances_rev >= 4) - { - cmd.Parameters.AddWithValue("?type", type); - } - - if (cmd.ExecuteNonQuery() > 0) bRet = true; - cmd.Dispose(); - - return bRet; - } - - - /// - /// Here we'll make a withdraw from the sender and update transaction status - /// - /// - /// - /// - public bool withdrawMoney(UUID transactionID, string senderID, int amount) - { - bool bRet = false; - string sql = string.Empty; - MySqlCommand cmd = null; - - // System - if (senderID == UUID.Zero.ToString()) - { - sql = "BEGIN;"; - sql += "UPDATE " + Table_of_Transactions; - sql += " SET senderBalance = 0, status = ?status WHERE UUID = ?tranid;"; - sql += "COMMIT;"; - - cmd = new MySqlCommand(sql, dbcon); - cmd.Parameters.AddWithValue("?status", (int)Status.PENDING_STATUS); //pending - cmd.Parameters.AddWithValue("?tranid", transactionID.ToString()); - } - else - { - sql = "BEGIN;"; - sql += "UPDATE " + Table_of_Transactions + "," + Table_of_Balances; - sql += " SET senderBalance = balance - ?amount, " + Table_of_Transactions + ".status = ?status, balance = balance - ?amount "; - sql += " WHERE UUID = ?tranid AND user = sender AND user = ?userid;"; - sql += "COMMIT;"; - - cmd = new MySqlCommand(sql, dbcon); - cmd.Parameters.AddWithValue("?amount", amount); - cmd.Parameters.AddWithValue("?userid", senderID); - cmd.Parameters.AddWithValue("?status", (int)Status.PENDING_STATUS); //pending - cmd.Parameters.AddWithValue("?tranid", transactionID.ToString()); - } - - if (cmd.ExecuteNonQuery() > 0) bRet = true; - - cmd.Dispose(); - return bRet; - } - - - /// - /// Give money to the receiver and change the transaction status to success. - /// - /// - /// - /// - public bool giveMoney(UUID transactionID, string receiverID, int amount) - { - string sql = string.Empty; - bool bRet = false; - MySqlCommand cmd = null; - - // System - if (receiverID == UUID.Zero.ToString()) - { - sql = "BEGIN;"; - sql += "UPDATE " + Table_of_Transactions; - sql += " SET receiverBalance = 0, status = ?status WHERE UUID = ?tranid;"; - sql += "COMMIT;"; - - cmd = new MySqlCommand(sql, dbcon); - cmd.Parameters.AddWithValue("?status", (int)Status.SUCCESS_STATUS); //Success - cmd.Parameters.AddWithValue("?tranid", transactionID.ToString()); - } - else - { - sql = "BEGIN;"; - sql += "UPDATE " + Table_of_Transactions + "," + Table_of_Balances; - sql += " SET receiverBalance = balance + ?amount, " + Table_of_Transactions + ".status = ?status, balance = balance + ?amount "; - sql += " WHERE UUID = ?tranid AND user = receiver AND user = ?userid;"; - sql += "COMMIT;"; - - cmd = new MySqlCommand(sql, dbcon); - cmd.Parameters.AddWithValue("?amount", amount); - cmd.Parameters.AddWithValue("?userid", receiverID); - cmd.Parameters.AddWithValue("?status", (int)Status.SUCCESS_STATUS); //Success - cmd.Parameters.AddWithValue("?tranid", transactionID.ToString()); - } - - if (cmd.ExecuteNonQuery() > 0) bRet = true; - - cmd.Dispose(); - return bRet; - } - - public bool BuyMoney(UUID transactionID, string userID, int amount) - { - string sql = string.Empty; - bool bRet = false; - MySqlCommand cmd = null; - - try - { - sql = "BEGIN;"; - sql += "UPDATE Transactions, Balances"; - sql += " SET balance = balance + ?amount, Transactions.status = ?status "; - sql += " WHERE Transactions.UUID = ?tranid AND Balances.user = ?userid;"; - sql += "COMMIT;"; - - cmd = new MySqlCommand(sql, dbcon); - cmd.Parameters.AddWithValue("?amount", amount); - cmd.Parameters.AddWithValue("?userid", userID); - cmd.Parameters.AddWithValue("?status", (int)Status.SUCCESS_STATUS); - cmd.Parameters.AddWithValue("?tranid", transactionID.ToString()); - - if (cmd.ExecuteNonQuery() > 0) - { - bRet = true; - } - } - catch (Exception ex) - { - m_log.ErrorFormat("[BuyMoney]: Exception occurred during SQL execution: {0}", ex.Message); - } - finally - { - if (cmd != null) - { - cmd.Dispose(); - } - } - - m_log.InfoFormat("[BuyMoney]: SQL command executed successfully: {0}", bRet); - - return bRet; - } - - - /// Initializes the total sales table. - private void initTotalSalesTable() - { - m_log.Info("[MONEY MANAGER]: Initailising TotalSales Table..."); - string sql = string.Empty; - - sql = "SELECT SQL_CALC_FOUND_ROWS receiver,objectUUID,type,COUNT(*),SUM(amount),MIN(time) FROM " + Table_of_Transactions; - sql += " WHERE sender != receiver AND status = ?status AND sender != ?system"; - sql += " GROUP BY receiver,objectUUID,type;"; - - MySqlCommand cmd = new MySqlCommand(sql, dbcon); - cmd.Parameters.AddWithValue("?status", (int)Status.SUCCESS_STATUS); - cmd.Parameters.AddWithValue("?system", UUID.Zero.ToString()); - cmd.ExecuteNonQuery(); - - MySqlCommand cmd2 = new MySqlCommand("SELECT FOUND_ROWS();", dbcon); - int lineCount = int.Parse(cmd2.ExecuteScalar().ToString()); - cmd2.Dispose(); - - if (lineCount <= 0) - { - cmd.Dispose(); - return; - } - - MySqlDataReader r = cmd.ExecuteReader(); - int l = 0; - string[,] row = new string[lineCount, r.FieldCount]; - while (r.Read()) - { - for (int i = 0; i < r.FieldCount; i++) - { - row[l, i] = r.GetString(i); - } - l++; - } - r.Close(); - cmd.Dispose(); - - for (int i = 0; i < lineCount; i++) - { - string receiver = (string)row[i, 0]; // receiver - string objUUID = (string)row[i, 1]; // objectUUID - int type = Convert.ToInt32(row[i, 2]); // type - int count = Convert.ToInt32(row[i, 3]); // COUNT(*) - int amount = Convert.ToInt32(row[i, 4]); // SUM(amount) - int tmstamp = Convert.ToInt32(row[i, 5]); // MIN(time) - // - setTotalSale(receiver, objUUID, type, count, amount, tmstamp); - } - } - - - /// Deletes the total sales table. - private void deleteTotalSalesTable() - { - string sql = string.Empty; - - sql = "DELETE FROM " + Table_of_TotalSales; - - MySqlCommand cmd = new MySqlCommand(sql, dbcon); - cmd.Parameters.AddWithValue("?status", (int)Status.SUCCESS_STATUS); - cmd.ExecuteNonQuery(); - cmd.Dispose(); - - return; - } - - - /// Adds the total sale. - /// The user UUID. - /// The object UUID. - /// The type. - /// The count. - /// The amount. - /// The tmstamp. - public bool addTotalSale(string userUUID, string objectUUID, int type, int count, int amount, int tmstamp) - { - bool bRet = false; - string sql = string.Empty; - UUID uuid = UUID.Random(); - - // Record only transactions involving objects - // if (objectUUID==UUID.Zero.ToString()) return bRet; - - sql = "INSERT INTO " + Table_of_TotalSales; - sql += " (`UUID`,`user`,`objectUUID`,`type`,`TotalCount`,`TotalAmount`,`time`) VALUES"; - sql += " (?ID,?userID,?objID,?type,?count,?amount,?time)"; - - MySqlCommand cmd = new MySqlCommand(sql, dbcon); - cmd.Parameters.AddWithValue("?ID", uuid.ToString()); - cmd.Parameters.AddWithValue("?userID", userUUID); - cmd.Parameters.AddWithValue("?objID", objectUUID); - cmd.Parameters.AddWithValue("?type", type); - cmd.Parameters.AddWithValue("?count", count); - cmd.Parameters.AddWithValue("?amount", amount); - cmd.Parameters.AddWithValue("?time", tmstamp); - - if (cmd.ExecuteNonQuery() > 0) bRet = true; - - cmd.Dispose(); - return bRet; - } - - - /// Updates the total sale. - /// The sale UUID. - /// The count. - /// The amount. - /// The tmstamp. - public bool updateTotalSale(UUID saleUUID, int count, int amount, int tmstamp) - { - bool bRet = false; - string sql = string.Empty; - - sql = "UPDATE " + Table_of_TotalSales; - sql += " SET TotalCount = TotalCount + ?count, TotalAmount = TotalAmount + ?amount, time = ?time "; - sql += " WHERE UUID = ?uuid;"; - MySqlCommand cmd = new MySqlCommand(sql, dbcon); - - cmd.Parameters.AddWithValue("?uuid", saleUUID.ToString()); - cmd.Parameters.AddWithValue("?count", count); - cmd.Parameters.AddWithValue("?amount", amount); - cmd.Parameters.AddWithValue("?time", tmstamp); - - if (cmd.ExecuteNonQuery() > 0) bRet = true; - - cmd.Dispose(); - return bRet; - - } - - /// Sets the total sale. - /// The user UUID. - /// The object UUID. - /// The type. - /// The count. - /// The amount. - /// The tmstamp. - public bool setTotalSale(string userUUID, string objectUUID, int type, int count, int amount, int tmstamp) - { - bool bRet = false; - string sql = string.Empty; - string uuid = string.Empty; - int dbtm = 0; - - sql = "SELECT UUID,time FROM " + Table_of_TotalSales; - sql += " WHERE user = ?userid AND objectUUID = ?objID AND type = ?type;"; - MySqlCommand cmd = new MySqlCommand(sql, dbcon); - - cmd.Parameters.AddWithValue("?userid", userUUID); - cmd.Parameters.AddWithValue("?objID", objectUUID); - cmd.Parameters.AddWithValue("?type", type); - - using (MySqlDataReader r = cmd.ExecuteReader()) - { - if (r.Read()) - { - try - { - uuid = (string)r["UUID"]; - dbtm = Convert.ToInt32(r["time"]); - } - catch (Exception e) - { - m_log.Error("[MONEY MANAGER]: Get sale data from DB failed: " + e.ToString()); - r.Close(); - cmd.Dispose(); - return false; - } - } - r.Close(); - } - - if (uuid != string.Empty) - { - UUID saleUUID = UUID.Zero; - UUID.TryParse(uuid, out saleUUID); - if (dbtm < tmstamp) tmstamp = dbtm; - bRet = updateTotalSale(saleUUID, count, amount, tmstamp); - } - else - { - bRet = addTotalSale(userUUID, objectUUID, type, count, amount, tmstamp); - } - - cmd.Dispose(); - return bRet; - } - - - // - // transactions - // - /// Adds the transaction. - /// The transaction. - public bool addTransaction(TransactionData transaction) - { - bool bRet = false; - string sql = string.Empty; - - if (transaction.ObjectUUID == null) transaction.ObjectUUID = UUID.Zero.ToString(); - if (transaction.ObjectName == null) transaction.ObjectName = string.Empty; - if (transaction.Description == null) transaction.Description = string.Empty; - - sql = "INSERT INTO " + Table_of_Transactions; - sql += " (`UUID`,`sender`,`receiver`,`amount`,`senderBalance`,`receiverBalance`,`objectUUID`,`objectName`,"; - sql += " `regionHandle`,`regionUUID`,`type`,`time`,`secure`,`status`,`commonName`,`description`) VALUES"; - sql += " (?transID,?sender,?receiver,?amount,?senderBalance,?receiverBalance,?objID,?objName,?regionHandle,?regionUUID,?type,?time,?secure,?status,?cname,?desc)"; - - MySqlCommand cmd = new MySqlCommand(sql, dbcon); - cmd.Parameters.AddWithValue("?transID", transaction.TransUUID.ToString()); - cmd.Parameters.AddWithValue("?sender", transaction.Sender); - cmd.Parameters.AddWithValue("?receiver", transaction.Receiver); - cmd.Parameters.AddWithValue("?amount", transaction.Amount); - cmd.Parameters.AddWithValue("?senderBalance", -1); - cmd.Parameters.AddWithValue("?receiverBalance", -1); - cmd.Parameters.AddWithValue("?objID", transaction.ObjectUUID); - cmd.Parameters.AddWithValue("?objName", transaction.ObjectName); - cmd.Parameters.AddWithValue("?regionHandle", transaction.RegionHandle); - cmd.Parameters.AddWithValue("?regionUUID", transaction.RegionUUID); - cmd.Parameters.AddWithValue("?type", transaction.Type); - cmd.Parameters.AddWithValue("?time", transaction.Time); - cmd.Parameters.AddWithValue("?secure", transaction.SecureCode); - cmd.Parameters.AddWithValue("?status", transaction.Status); - cmd.Parameters.AddWithValue("?cname", transaction.CommonName); - cmd.Parameters.AddWithValue("?desc", transaction.Description); - - if (cmd.ExecuteNonQuery() > 0) bRet = true; - - cmd.Dispose(); - return bRet; - } - - - /// Updates the transaction status. - /// The transaction identifier. - /// The status. - /// The description. - public bool updateTransactionStatus(UUID transactionID, int status, string description) - { - bool bRet = false; - string sql = string.Empty; - - sql = "UPDATE " + Table_of_Transactions + " SET status = ?status,description = ?desc WHERE UUID = ?tranid;"; - MySqlCommand cmd = new MySqlCommand(sql, dbcon); - cmd.Parameters.AddWithValue("?status", status); - cmd.Parameters.AddWithValue("?desc", description); - cmd.Parameters.AddWithValue("?tranid", transactionID); - - if (cmd.ExecuteNonQuery() > 0) bRet = true; - - cmd.Dispose(); - return bRet; - } - - - /// Sets the trans expired. - /// The dead time. - public bool SetTransExpired(int deadTime) - { - bool bRet = false; - string sql = string.Empty; - - sql = "UPDATE " + Table_of_Transactions; - sql += " SET status = ?failedstatus,description = ?desc WHERE time <= ?deadTime AND status = ?pendingstatus;"; - MySqlCommand cmd = new MySqlCommand(sql, dbcon); - cmd.Parameters.AddWithValue("?failedstatus", (int)Status.FAILED_STATUS); - cmd.Parameters.AddWithValue("?desc", "expired"); - cmd.Parameters.AddWithValue("?deadTime", deadTime); - cmd.Parameters.AddWithValue("?pendingstatus", (int)Status.PENDING_STATUS); - - if (cmd.ExecuteNonQuery() > 0) bRet = true; - - cmd.Dispose(); - return bRet; - } - - - /// - /// Validate if the transacion is legal - /// - /// - /// - public bool ValidateTransfer(string secureCode, UUID transactionID) - { - bool bRet = false; - string secure = string.Empty; - string sql = string.Empty; - - sql = "SELECT secure FROM " + Table_of_Transactions + " WHERE UUID = ?transID;"; - MySqlCommand cmd = new MySqlCommand(sql, dbcon); - cmd.Parameters.AddWithValue("?transID", transactionID.ToString()); - - using (MySqlDataReader r = cmd.ExecuteReader()) - { - if (r.Read()) - { - try - { - secure = (string)r["secure"]; - } - catch (Exception e) - { - m_log.Error("[MONEY MANAGER]: Get transaction from DB failed: " + e.ToString()); - } - if (secureCode == secure) bRet = true; - else bRet = false; - } - r.Close(); - } - - cmd.Dispose(); - return bRet; - } - - - /// Fetches the transaction. - /// The transaction identifier. - public TransactionData FetchTransaction(UUID transactionID) - { - TransactionData transactionData = new TransactionData(); - transactionData.TransUUID = transactionID; - string sql = string.Empty; - - sql = "SELECT * FROM " + Table_of_Transactions + " WHERE UUID = ?transID;"; - MySqlCommand cmd = new MySqlCommand(sql, dbcon); - cmd.Parameters.AddWithValue("?transID", transactionID.ToString()); - - using (MySqlDataReader r = cmd.ExecuteReader()) - { - if (r.Read()) - { - try - { - transactionData.Sender = (string)r["sender"]; - transactionData.Receiver = (string)r["receiver"]; - transactionData.Amount = Convert.ToInt32(r["amount"]); - transactionData.SenderBalance = Convert.ToInt32(r["senderBalance"]); - transactionData.ReceiverBalance = Convert.ToInt32(r["receiverBalance"]); - transactionData.Type = Convert.ToInt32(r["type"]); - transactionData.Time = Convert.ToInt32(r["time"]); - transactionData.Status = Convert.ToInt32(r["status"]); - transactionData.CommonName = (string)r["commonName"]; - transactionData.RegionHandle = (string)r["regionHandle"]; - transactionData.RegionUUID = (string)r["regionUUID"]; - // - if (r["objectUUID"] is System.DBNull) transactionData.ObjectUUID = UUID.Zero.ToString(); - else transactionData.ObjectUUID = (string)r["objectUUID"]; - if (r["objectName"] is System.DBNull) transactionData.ObjectName = string.Empty; - else transactionData.ObjectName = (string)r["objectName"]; - if (r["description"] is System.DBNull) transactionData.Description = string.Empty; - else transactionData.Description = (string)r["description"]; - } - catch (Exception e) - { - m_log.Error("[MONEY MANAGER]: Fetching transaction failed 1: " + e.ToString()); - r.Close(); - cmd.Dispose(); - return null; - } - - } - r.Close(); - } - - cmd.Dispose(); - return transactionData; - } - - - /// Fetches the transaction. - /// The user identifier. - /// The start time. - /// The end time. - /// The index. - /// The ret number. - public TransactionData[] FetchTransaction(string userID, int startTime, int endTime, uint index, uint retNum) - { - List rows = new List(); - string sql = string.Empty; - - sql = "SELECT * FROM " + Table_of_Transactions + " WHERE time>=?start AND time<=?end "; - sql += "AND (sender=?user OR receiver=?user) ORDER BY time ASC LIMIT ?index,?num;"; - MySqlCommand cmd = new MySqlCommand(sql, dbcon); - - cmd.Parameters.AddWithValue("?start", startTime); - cmd.Parameters.AddWithValue("?end", endTime); - cmd.Parameters.AddWithValue("?user", userID); - cmd.Parameters.AddWithValue("?index", index); - cmd.Parameters.AddWithValue("?num", retNum); - - using (MySqlDataReader r = cmd.ExecuteReader()) - { - for (int i = 0; i < retNum; i++) - { - if (r.Read()) - { - try - { - TransactionData transactionData = new TransactionData(); - string uuid = (string)r["UUID"]; - UUID transUUID; - UUID.TryParse(uuid, out transUUID); - - transactionData.TransUUID = transUUID; - transactionData.Sender = (string)r["sender"]; - transactionData.Receiver = (string)r["receiver"]; - transactionData.Amount = Convert.ToInt32(r["amount"]); - transactionData.SenderBalance = Convert.ToInt32(r["senderBalance"]); - transactionData.ReceiverBalance = Convert.ToInt32(r["receiverBalance"]); - transactionData.Type = Convert.ToInt32(r["type"]); - transactionData.Time = Convert.ToInt32(r["time"]); - transactionData.Status = Convert.ToInt32(r["status"]); - transactionData.CommonName = (string)r["commonName"]; - transactionData.RegionHandle = (string)r["regionHandle"]; - transactionData.RegionUUID = (string)r["regionUUID"]; - // - if (r["objectUUID"] is System.DBNull) transactionData.ObjectUUID = UUID.Zero.ToString(); - else transactionData.ObjectUUID = (string)r["objectUUID"]; - if (r["objectName"] is System.DBNull) transactionData.ObjectName = string.Empty; - else transactionData.ObjectName = (string)r["objectName"]; - if (r["description"] is System.DBNull) transactionData.Description = string.Empty; - else transactionData.Description = (string)r["description"]; - // - rows.Add(transactionData); - } - catch (Exception e) - { - m_log.Error("[MONEY MANAGER]: Fetching transaction failed 2: " + e.ToString()); - r.Close(); - cmd.Dispose(); - return null; - } - } - } - r.Close(); - } - - cmd.Dispose(); - return rows.ToArray(); - } - - - /// Gets the transaction number. - /// The user identifier. - /// The start time. - /// The end time. - public int getTransactionNum(string userID, int startTime, int endTime) - { - int iRet = -1; - string sql = string.Empty; - - sql = "SELECT COUNT(*) AS number FROM " + Table_of_Transactions + " WHERE time>=?start AND time<=?end "; - sql += "AND (sender=?user OR receiver=?user);"; - MySqlCommand cmd = new MySqlCommand(sql, dbcon); - - cmd.Parameters.AddWithValue("?start", startTime); - cmd.Parameters.AddWithValue("?end", endTime); - cmd.Parameters.AddWithValue("?user", userID); - - using (MySqlDataReader r = cmd.ExecuteReader()) - { - if (r.Read()) - { - try - { - iRet = Convert.ToInt32(r["number"]); - } - catch (Exception e) - { - m_log.Error("[MONEY MANAGER]: Unable to get transaction info: " + e.ToString()); - } - } - r.Close(); - } - - cmd.Dispose(); - return iRet; - } - - - // - // userinfo - // - /// Adds the user information. - /// - public bool addUserInfo(UserInfo userInfo) - { - bool bRet = false; - string sql = string.Empty; - - if (userInfo.Avatar == null) return false; - - if (userinfo_rev >= 3) - { - sql = "INSERT INTO " + Table_of_UserInfo + "(`user`,`simip`,`avatar`,`pass`,`type`,`class`,`serverurl`) VALUES"; - sql += "(?user,?simip,?avatar,?password,?type,?class,?serverurl);"; - } - else - { - sql = "INSERT INTO " + Table_of_UserInfo + "(`user`,`simip`,`avatar`,`pass`) VALUES"; - sql += "(?user,?simip,?avatar,?password);"; - } - - MySqlCommand cmd = new MySqlCommand(sql, dbcon); - cmd.Parameters.AddWithValue("?user", userInfo.UserID); - cmd.Parameters.AddWithValue("?simip", userInfo.SimIP); - cmd.Parameters.AddWithValue("?avatar", userInfo.Avatar); - cmd.Parameters.AddWithValue("?password", userInfo.PswHash); - if (userinfo_rev >= 3) - { - cmd.Parameters.AddWithValue("?type", userInfo.Type); - cmd.Parameters.AddWithValue("?class", userInfo.Class); - cmd.Parameters.AddWithValue("?serverurl", userInfo.ServerURL); - } - - if (cmd.ExecuteNonQuery() > 0) bRet = true; - - cmd.Dispose(); - return bRet; - } - - - /// Fetches the user information. - /// The user identifier. - public UserInfo fetchUserInfo(string userID) - { - UserInfo userInfo = new UserInfo(); - userInfo.UserID = null; - string sql = string.Empty; - - sql = "SELECT * FROM " + Table_of_UserInfo + " WHERE user = ?userID;"; - MySqlCommand cmd = new MySqlCommand(sql, dbcon); - cmd.Parameters.AddWithValue("?userID", userID); - - using (MySqlDataReader r = cmd.ExecuteReader()) - { - if (r.Read()) - { - try - { - userInfo.UserID = (string)r["user"]; - userInfo.SimIP = (string)r["simip"]; - userInfo.Avatar = (string)r["avatar"]; - userInfo.PswHash = (string)r["pass"]; - userInfo.Type = Convert.ToInt32(r["type"]); - userInfo.Class = Convert.ToInt32(r["class"]); - userInfo.ServerURL = (string)r["serverurl"]; - } - catch (Exception e) - { - m_log.Error("[MONEY MANAGER]: Fetching UserInfo failed: " + e.ToString()); - r.Close(); - cmd.Dispose(); - return null; - } - } - r.Close(); - } - cmd.Dispose(); - - if (userInfo.UserID != userID) return null; - return userInfo; - } - - - /// Updates the user information. - /// - public bool updateUserInfo(UserInfo userInfo) - { - bool bRet = false; - string sql = string.Empty; - - sql = "UPDATE " + Table_of_UserInfo + " SET simip=?simip,pass=?pass,class=?class,serverurl=?serverurl WHERE user=?user;"; - MySqlCommand cmd = new MySqlCommand(sql, dbcon); - cmd.Parameters.AddWithValue("?simip", userInfo.SimIP); - cmd.Parameters.AddWithValue("?pass", userInfo.PswHash); - cmd.Parameters.AddWithValue("?class", userInfo.Class); - cmd.Parameters.AddWithValue("?serverurl", userInfo.ServerURL); - cmd.Parameters.AddWithValue("?user", userInfo.UserID); - - if (cmd.ExecuteNonQuery() > 0) bRet = true; - - cmd.Dispose(); - return bRet; - } - - public bool UserExists(string userID) - { - try - { - UserInfo userInfo = fetchUserInfo(userID); - return userInfo != null; - } - catch (Exception ex) - { - m_log.Error(ex); - return false; - } - } - - public bool UpdateUserInfo(string userID, UserInfo updatedInfo) - { - UserInfo existingInfo = fetchUserInfo(userID); - if (existingInfo != null) - { - updatedInfo.UserID = userID; // Ensure the userID is updated correctly - return updateUserInfo(updatedInfo); - } - else - { - return false; // User not found - } - } - - public bool DeleteUser(string userID) - { - string sql = "DELETE FROM " + Table_of_UserInfo + " WHERE user = ?userID;"; - MySqlCommand cmd = new MySqlCommand(sql, dbcon); - cmd.Parameters.AddWithValue("?userID", userID); - - return cmd.ExecuteNonQuery() > 0; - } - - public void LogTransactionError(UUID transactionID, string errorMessage) - { - m_log.ErrorFormat("[MONEY MODULE]: Transaction {0} failed with error: {1}", transactionID, errorMessage); - } - - public IEnumerable GetTransactionHistory(string userID, int startTime, int endTime) - { - List transactionHistory = new List(); - - // Assuming you have a database connection and a query to fetch transactions - string sql = "SELECT * FROM " + Table_of_Transactions + " WHERE user = ?userID AND time >= ?startTime AND time <= ?endTime;"; - MySqlCommand cmd = new MySqlCommand(sql, dbcon); - cmd.Parameters.AddWithValue("?userID", userID); - cmd.Parameters.AddWithValue("?startTime", startTime); - cmd.Parameters.AddWithValue("?endTime", endTime); - - using (MySqlDataReader r = cmd.ExecuteReader()) - { - while (r.Read()) - { - TransactionData transaction = new TransactionData(); - // Assuming you have properties in TransactionData class to match the columns in the database table - transaction.TransUUID = UUID.Parse((string)r["transuuid"]); - transaction.Sender = (string)r["sender"]; - transaction.Receiver = (string)r["receiver"]; - transaction.Amount = Convert.ToInt32(r["amount"]); - transaction.ObjectUUID = (string)r["objectuuid"]; - transaction.ObjectName = (string)r["objectname"]; - transaction.RegionHandle = (string)r["regionhandle"]; - transaction.Type = Convert.ToInt32(r["type"]); - transaction.Time = Convert.ToInt32(r["time"]); - transaction.Status = Convert.ToInt32(r["status"]); - transaction.SecureCode = (string)r["securecode"]; - transaction.CommonName = (string)r["commonname"]; - transaction.Description = (string)r["description"]; - - transactionHistory.Add(transaction); - } - r.Close(); - } - cmd.Dispose(); - - return transactionHistory; - } - - - } -} diff --git a/addon-modules/OpenSim.Data.MySQL.MySQLMoneyDataWrapper/MySQLSuperManager.cs b/addon-modules/OpenSim.Data.MySQL.MySQLMoneyDataWrapper/MySQLSuperManager.cs deleted file mode 100644 index 8e31f88..0000000 --- a/addon-modules/OpenSim.Data.MySQL.MySQLMoneyDataWrapper/MySQLSuperManager.cs +++ /dev/null @@ -1,99 +0,0 @@ -/* - * 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. - -Funktion - Die Klasse MySQLSuperManager dient als Wrapper/Manager für einen Thread-Sicherheitsmechanismus (Mutex) und kapselt eine Instanz von MySQLMoneyManager. - Sie enthält: - Ein Mutex-Objekt für Thread-Synchronisation. - Ein Flag Locked zur Statusanzeige. - Eine öffentliche Instanz von MySQLMoneyManager namens Manager. - Die Methode GetLock() blockiert, bis der Mutex verfügbar ist. - Die Methode Release() gibt den Mutex frei und behandelt freigabe-bezogene Fehler. - Ein String Running (wird hier aber nicht verwendet). - -Null Pointer Checks - Manager: Im Konstruktor wird garantiert, dass Manager immer initialisiert ist (niemals null nach Konstruktion). - m_lock: Wird direkt beim Feld-Deklaration erstellt, kann also nie null sein. - Locked: Ist ein bool, daher nie null. - Running: Ist public, aber im Code nicht direkt verwendet. Wenn er von außen auf null gesetzt wird, kann das keinen Fehler verursachen, da er nicht verwendet wird. - -Fehlerquellen - Mutex-Handling: - In Release() wird das Freigeben des Mutex von einem Try-Catch-Block umschlossen. Sollte ein Fehler beim Freigeben auftreten (z.B. Freigabe von einem Thread, der den Mutex nicht besitzt), wird die Exception geloggt und erneut geworfen. - In GetLock() wird WaitOne() direkt aufgerufen, was blockiert, bis der Lock verfügbar ist. Es gibt hier keine Exception-Absicherung, aber üblicherweise ist dies sicher, solange das Objekt korrekt verwendet wird. - - Thread-Safety: - Die Klasse ist thread-safe bezüglich des Mutex, nicht aber bezüglich der Instanzvariablen (Running ist public ohne Schutz, aber nicht verwendet). - Es wird kein expliziter Null-Check auf Manager benötigt, da sie im Konstruktor immer initialisiert wird. - - Unbenutzte Variable: - Das Feld Running ist nicht implementiert/genutzt. Das ist kein Fehler, aber ein Hinweis auf evtl. toten Code. - -Zusammenfassung - Null Pointer: Keine Gefahr für NullPointer-Exceptions im aktuellen Code. - Fehlerquellen: Einzige potenzielle Fehlerquelle ist das Freigeben des Mutex in Release(), aber dies wird per Exception abgefangen und geloggt. - Funktion: Thread-Safe-Manager/Wrapper für den Zugriff auf einen MySQLMoneyManager. - -Fazit: -Die Klasse ist solide und sicher gegen NullPointer-Fehler. Fehler beim Mutex-Handling werden korrekt behandelt. Es gibt keine offensichtlichen Schwachstellen. -Lediglich das Feld Running ist ungenutzt und könnte entfernt oder implementiert werden. - */ - -using System; -using System.Diagnostics; -using System.Runtime.ConstrainedExecution; -using System.Threading; - -namespace OpenSim.Data.MySQL.MySQLMoneyDataWrapper -{ - public class MySQLSuperManager - { - public bool Locked { get; private set; } - private readonly Mutex m_lock = new(false); - public MySQLMoneyManager Manager { get; } - public string Running; - - public MySQLSuperManager(string connectionString) - { - Manager = new MySQLMoneyManager(connectionString); - } - - /// Erwirbt die exklusive Sperre für kritische Operationen. - public void GetLock() - { - m_lock.WaitOne(); - Locked = true; - } - - /// Gibt die Sperre wieder frei. - public void Release() - { - try - { - m_lock.ReleaseMutex(); - } - catch (Exception ex) - { - Console.WriteLine($"An error occurred while releasing the mutex: {ex.Message}"); - throw; - } - finally - { - Locked = false; - } - } - } -} diff --git a/addon-modules/OpenSim.Data.MySQL.MySQLMoneyDataWrapper/Properties/AssemblyInfo.cs b/addon-modules/OpenSim.Data.MySQL.MySQLMoneyDataWrapper/Properties/AssemblyInfo.cs deleted file mode 100644 index 7ae9f91..0000000 --- a/addon-modules/OpenSim.Data.MySQL.MySQLMoneyDataWrapper/Properties/AssemblyInfo.cs +++ /dev/null @@ -1,32 +0,0 @@ -using System.Reflection; -using System.Runtime.InteropServices; - -// General Information about an assembly is controlled through the following -// set of attributes. Change these attribute values to modify the information -// associated with an assembly. -[assembly: AssemblyTitle("OpenSim.Data.MySQL.MySQLMoneyDataWrapper")] -[assembly: AssemblyDescription("")] -[assembly: AssemblyConfiguration("")] -[assembly: AssemblyCompany("Microsoft")] -[assembly: AssemblyProduct("OpenSim.Data.MySQL.MySQLMoneyDataWrapper")] -[assembly: AssemblyCopyright("Copyright © Microsoft 2009")] -[assembly: AssemblyTrademark("")] -[assembly: AssemblyCulture("")] - -// Setting ComVisible to false makes the types in this assembly not visible -// to COM components. If you need to access a type in this assembly from -// COM, set the ComVisible attribute to true on that type. -[assembly: ComVisible(false)] - -// The following GUID is for the ID of the typelib if this project is exposed to COM -[assembly: Guid("03f4a266-2e30-47e4-b785-ff02cdb4bbb9")] - -// Version information for an assembly consists of the following four values: -// -// Major Version -// Minor Version -// Build Number -// Revision -// -[assembly: AssemblyVersion("1.0.0.0")] -[assembly: AssemblyFileVersion("1.0.0.0")] diff --git a/addon-modules/OpenSim.Data.MySQL.MySQLMoneyDataWrapper/TransactionData.cs b/addon-modules/OpenSim.Data.MySQL.MySQLMoneyDataWrapper/TransactionData.cs deleted file mode 100644 index bb9a313..0000000 --- a/addon-modules/OpenSim.Data.MySQL.MySQLMoneyDataWrapper/TransactionData.cs +++ /dev/null @@ -1,291 +0,0 @@ -/* - * 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. - -Funktion - TransactionData ist eine reine Datenklasse (POCO/DTO), die alle relevanten Felder für eine Finanztransaktion im OpenSim-Money-Modul kapselt. - Felder: UUIDs, Beträge, Balances, Typen, Zeiten, Status, Objekt- und Regionsdaten, Sicherheitscode, Beschreibung usw. - Für alle Felder gibt es Properties mit Getter/Setter. - Zwei Enums: - Status (SUCCESS, PENDING, FAILED, ERROR) - AvatarType (diverse Avatar-Typen, z.B. LOCAL, HG, GUEST, NPC) - UserInfo ist ebenfalls eine reine Datenklasse für Benutzerinformationen, mit Properties für UserID, SimIP, Name, Passwort-Hash, Typ, Klasse, ServerURL. - -Null Pointer & Fehlerquellen -Null Pointer - Felder vom Typ string werden grundsätzlich mit string.Empty initialisiert (niemals null im Standardzustand). - UUIDs werden (soweit gesetzt) aus dem Typ OpenMetaverse.UUID initialisiert – dieser Typ ist ein struct und kann daher nie null sein. - Es gibt keine Methoden mit Logik, daher auch keine Parameterprüfungen oder komplexe Objekt-Manipulationen, bei denen NullPointer auftreten könnten. - Setter/Getter der Properties geben direkt das Feld zurück oder setzen es, ohne Logik. - Die Enums können nicht null sein. - -Fehlerquellen - Keine Methoden mit Logik, also keine klassische Fehlerquelle wie Division durch 0, Indexfehler o.ä. - Setter führen keine Validierung durch (z.B. auf gültige UUIDs, Wertebereiche), - was bei fehlerhafter Nutzung zu inkonsistenten Daten führen könnte – das ist aber kein NullPointer und im Kontext von Datenklassen üblich. - UserInfo: Alle Felder sind mit sinnvollen Defaultwerten versehen (string.Empty oder ein Enum-Wert). - -Zusammenfassung - Null Pointer: Es gibt im aktuellen Code keine Gefahr für NullPointer-Exceptions, da alle Felder mit Defaultwerten belegt sind und keine Logik existiert. - Fehlerquellen: Keine Methoden, keine Validierung – klassisch für Datenklassen. - Fehler können nur entstehen, wenn von außen ungültige Werte gesetzt werden, aber das verursacht keine NullPointer-Fehler. - Funktion: Kapselt Daten für Transaktionen und Benutzer im OpenSim-Money-System. - -Fazit: -Die Datei ist eine reine Datenstruktur und sicher gegenüber NullPointer-Fehlern. Es gibt keine gefährlichen Stellen im Code. -Die Nutzung ist robust, solange von außen sinnvolle Werte gesetzt werden. - */ - -using OpenMetaverse; - - -namespace OpenSim.Data.MySQL.MySQLMoneyDataWrapper -{ - public class TransactionData - { - UUID m_uuid; - string m_sender = string.Empty; - string m_receiver = string.Empty; - int m_amount; - int m_senderBalance; - int m_receiverBalance; - int m_type; - int m_time; - int m_status; - string m_objectID = UUID.Zero.ToString(); - string m_objectName = string.Empty; - string m_regionHandle = string.Empty; - string m_regionUUID = string.Empty; - string m_secureCode = string.Empty; - string m_commonName = string.Empty; - string m_description = string.Empty; - - /// Gets or sets the trans UUID. - /// The trans UUID. - public UUID TransUUID - { - get { return m_uuid; } - set { m_uuid = value; } - } - - /// Gets or sets the sender. - /// The sender. - public string Sender - { - get { return m_sender; } - set { m_sender = value; } - } - - /// Gets or sets the receiver. - /// The receiver. - public string Receiver - { - get { return m_receiver; } - set { m_receiver = value; } - } - - /// Gets or sets the amount. - /// The amount. - public int Amount - { - get { return m_amount; } - set { m_amount = value; } - } - - /// Gets or sets the sender balance. - /// The sender balance. - public int SenderBalance - { - get { return m_senderBalance; } - set { m_senderBalance = value; } - } - - /// Gets or sets the receiver balance. - /// The receiver balance. - public int ReceiverBalance - { - get { return m_receiverBalance; } - set { m_receiverBalance = value; } - } - - /// Gets or sets the type. - /// The type. - public int Type - { - get { return m_type; } - set { m_type = value; } - } - - /// Gets or sets the time. - /// The time. - public int Time - { - get { return m_time; } - set { m_time = value; } - } - - /// Gets or sets the status. - /// The status. - public int Status - { - get { return m_status; } - set { m_status = value; } - } - - /// Gets or sets the description. - /// The description. - public string Description - { - get { return m_description; } - set { m_description = value; } - } - - /// Gets or sets the object UUID. - /// The object UUID. - public string ObjectUUID - { - get { return m_objectID; } - set { m_objectID = value; } - } - - /// Gets or sets the name of the object. - /// The name of the object. - public string ObjectName - { - get { return m_objectName; } - set { m_objectName = value; } - } - - /// Gets or sets the region handle. - /// The region handle. - public string RegionHandle - { - get { return m_regionHandle; } - set { m_regionHandle = value; } - } - - /// Gets or sets the region UUID. - /// The region UUID. - public string RegionUUID - { - get { return m_regionUUID; } - set { m_regionUUID = value; } - } - - /// Gets or sets the secure code. - /// The secure code. - public string SecureCode - { - get { return m_secureCode; } - set { m_secureCode = value; } - } - - /// Gets or sets the name of the common. - /// The name of the common. - public string CommonName - { - get { return m_commonName; } - set { m_commonName = value; } - } - } - - - public enum Status - { - SUCCESS_STATUS = 0, - PENDING_STATUS = 1, - FAILED_STATUS = 2, - ERROR_STATUS = 9 - } - - - public enum AvatarType - { - LOCAL_AVATAR = 0, - HG_AVATAR = 1, - NPC_AVATAR = 2, - GUEST_AVATAR = 3, - FOREIGN_AVATAR = 8, - UNKNOWN_AVATAR = 9 - } - - - public class UserInfo - { - string m_userID = string.Empty; - string m_simIP = string.Empty; - string m_avatarName = string.Empty; - string m_passwordHash = string.Empty; - int m_avatarType = (int)AvatarType.LOCAL_AVATAR; - int m_avatarClass = (int)AvatarType.LOCAL_AVATAR; - string m_serverURL = string.Empty; - - /// Gets or sets the user identifier. - /// The user identifier. - public string UserID - { - get { return m_userID; } - set { m_userID = value; } - } - - /// Gets or sets the sim ip. - /// The sim ip. - public string SimIP - { - get { return m_simIP; } - set { m_simIP = value; } - } - - /// Gets or sets the avatar. - /// The avatar. - public string Avatar - { - get { return m_avatarName; } - set { m_avatarName = value; } - } - - /// Gets or sets the PSW hash. - /// The PSW hash. - public string PswHash - { - get { return m_passwordHash; } - set { m_passwordHash = value; } - } - - /// Gets or sets the type. - /// The type. - public int Type - { - get { return m_avatarType; } - set { m_avatarType = value; } - } - - /// Gets or sets the class. - /// The class. - public int Class - { - get { return m_avatarClass; } - set { m_avatarClass = value; } - } - - /// Gets or sets the server URL. - /// The server URL. - public string ServerURL - { - get { return m_serverURL; } - set { m_serverURL = value; } - } - } -}