// * Modified by Fumi.Iseki for Unix/Linix http://www.nsl.tuis.ac.jp // * // * 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. // */ using System; using System.Collections; using System.Collections.Generic; using System.Text; using System.Reflection; using System.Net; using System.Net.Security; using System.Security.Cryptography; using System.Security.Cryptography.X509Certificates; using log4net; using Nini.Config; using Nwc.XmlRpc; using Mono.Addins; using OpenMetaverse; using OpenSim.Framework; using OpenSim.Framework.Servers; using OpenSim.Framework.Servers.HttpServer; using OpenSim.Services.Interfaces; using OpenSim.Region.Framework; using OpenSim.Region.Framework.Interfaces; using OpenSim.Region.Framework.Scenes; using OpenSim.Data.MySQL.MySQLMoneyDataWrapper; using NSL.Certificate.Tools; using NSL.Network.XmlRpc; [assembly: Addin("DTLNSLMoneyModule", "1.0")] [assembly: AddinDependency("OpenSim.Region.Framework", OpenSim.VersionInfo.VersionNumber)] namespace OpenSim.Modules.Currency { /// /// Transaction Type /// public enum TransactionType : int { None = 0, // Extend BirthGift = 900, AwardPoints = 901, // One-Time Charges ObjectClaim = 1000, LandClaim = 1001, GroupCreate = 1002, GroupJoin = 1004, TeleportCharge = 1100, UploadCharge = 1101, LandAuction = 1102, ClassifiedCharge = 1103, // Recurrent Charges ObjectTax = 2000, LandTax = 2001, LightTax = 2002, ParcelDirFee = 2003, GroupTax = 2004, ClassifiedRenew = 2005, ScheduledFee = 2900, // Inventory Transactions GiveInventory = 3000, // Transfers Between Users ObjectSale = 5000, Gift = 5001, LandSale = 5002, ReferBonus = 5003, InvntorySale = 5004, RefundPurchase = 5005, LandPassSale = 5006, DwellBonus = 5007, PayObject = 5008, ObjectPays = 5009, BuyMoney = 5010, MoveMoney = 5011, SendMoney = 5012, // Group Transactions GroupLandDeed = 6001, GroupObjectDeed = 6002, GroupLiability = 6003, GroupDividend = 6004, GroupMembershipDues = 6005, // Stipend Credits StipendBasic = 10000 } /* // Refer to OpenMetaverse public enum OpenMetaverse.MoneyTransactionType : int { None = 0, FailSimulatorTimeout = 1, FailDataserverTimeout = 2, ObjectClaim = 1000, LandClaim = 1001, GroupCreate = 1002, ObjectPublicClaim = 1003, GroupJoin = 1004, TeleportCharge = 1100, UploadCharge = 1101, LandAuction = 1102, ClassifiedCharge = 1103, ObjectTax = 2000, LandTax = 2001, LightTax = 2002, ParcelDirFee = 2003, GroupTax = 2004, ClassifiedRenew = 2005, GiveInventory = 3000, ObjectSale = 5000, Gift = 5001, LandSale = 5002, ReferBonus = 5003, InventorySale = 5004, RefundPurchase = 5005, LandPassSale = 5006, DwellBonus = 5007, PayObject = 5008, ObjectPays = 5009, GroupLandDeed = 6001, GroupObjectDeed = 6002, GroupLiability = 6003, GroupDividend = 6004, GroupMembershipDues = 6005, ObjectRelease = 8000, LandRelease = 8001, ObjectDelete = 8002, ObjectPublicDecay = 8003, ObjectPublicDelete = 8004, LindenAdjustment = 9000, LindenGrant = 9001, LindenPenalty = 9002, EventFee = 9003, EventPrize = 9004, StipendBasic = 10000, StipendDeveloper = 10001, StipendAlways = 10002, StipendDaily = 10003, StipendRating = 10004, StipendDelta = 10005 } */ [Extension(Path = "/OpenSim/RegionModules", NodeName = "RegionModule", Id = "DTLNSLMoneyModule")] public class DTLNSLMoneyModule : IMoneyModule, ISharedRegionModule { #region Constant numbers and members. // Constant memebers private const int MONEYMODULE_REQUEST_TIMEOUT = 10000; // Private data members. private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType); //private bool m_enabled = true; private bool m_sellEnabled = false; private bool m_enable_server = true; // enable Money Server private IConfigSource m_config; private string m_moneyServURL = string.Empty; public BaseHttpServer HttpServer; private string m_certFilename = ""; private string m_certPassword = ""; private bool m_checkServerCert = false; private string m_cacertFilename = ""; //private X509Certificate2 m_cert = null; private bool m_use_web_settle = false; private string m_settle_url = ""; private string m_settle_message = ""; private bool m_settle_user = false; private int m_hg_avatarClass = (int)AvatarType.HG_AVATAR; private NSLCertificateVerify m_certVerify = new NSLCertificateVerify(); // For server authentication /// /// Scene dictionary indexed by Region Handle /// private Dictionary m_sceneList = new Dictionary(); /// /// To cache the balance data while the money server is not available. /// private Dictionary m_moneyServer = new Dictionary(); // Events public event ObjectPaid OnObjectPaid; // Price private int ObjectCount = 0; private int PriceEnergyUnit = 100; private int PriceObjectClaim = 10; private int PricePublicObjectDecay = 4; private int PricePublicObjectDelete = 4; private int PriceParcelClaim = 1; private float PriceParcelClaimFactor = 1.0f; private int PriceUpload = 0; private int PriceRentLight = 5; private float PriceObjectRent = 1.0f; private float PriceObjectScaleFactor = 10.0f; private int PriceParcelRent = 1; private int PriceGroupCreate = 0; private int TeleportMinPrice = 2; private float TeleportPriceExponent = 2.0f; private float EnergyEfficiency = 1.0f; #endregion /// /// Initialise /// /// /// public void Initialise(Scene scene, IConfigSource source) { Initialise(source); if (string.IsNullOrEmpty(m_moneyServURL)) m_enable_server = false; // AddRegion(scene); } #region ISharedRegionModule interface public void Initialise(IConfigSource source) { //m_log.InfoFormat("[MONEY MODULE]: Initialise:"); // Handle the parameters errors. if (source==null) return; try { m_config = source; // [Economy] section IConfig economyConfig = m_config.Configs["Economy"]; if (economyConfig.GetString("EconomyModule")!=Name && economyConfig.GetString("economymodule")!=Name) { //m_enabled = false; m_log.InfoFormat("[MONEY MODULE]: Initialise: The DTL/NSL MoneyModule is disabled"); return; } else { m_log.InfoFormat("[MONEY MODULE]: Initialise: The DTL/NSL MoneyModule is enabled"); } m_sellEnabled = economyConfig.GetBoolean("SellEnabled", m_sellEnabled); m_moneyServURL = economyConfig.GetString("CurrencyServer", m_moneyServURL); // Client Certification // クライアント証明書 m_certFilename = economyConfig.GetString("ClientCertFilename", m_certFilename); m_certPassword = economyConfig.GetString("ClientCertPassword", m_certPassword); if (m_certFilename!="") { m_certVerify.SetPrivateCert(m_certFilename, m_certPassword); //m_cert = new X509Certificate2(m_certFilename, m_certPassword); //m_cert = new X509Certificate2(m_certFilename, m_certPassword, X509KeyStorageFlags.MachineKeySet); m_log.Info("[MONEY MODULE]: Initialise: Issue Authentication of Client. Cert File is " + m_certFilename); } // Server Authentication // MoneyServer のサーバ証明書のチェック m_checkServerCert = economyConfig.GetBoolean("CheckServerCert", m_checkServerCert); m_cacertFilename = economyConfig.GetString ("CACertFilename", m_cacertFilename); if (m_cacertFilename != "") { m_certVerify.SetPrivateCA(m_cacertFilename); } else { m_checkServerCert = false; } if (m_checkServerCert) { m_log.Info("[MONEY MODULE]: Initialise: Execute Authentication of Server. CA Cert File is " + m_cacertFilename); } else { m_log.Info("[MONEY MODULE]: Initialise: No check Money Server or CACertFilename is empty. CheckServerCert is false."); } //ServicePointManager.ServerCertificateValidationCallback = new RemoteCertificateValidationCallback(m_certVerify.ValidateServerCertificate); //ServicePointManager.UseNagleAlgorithm = false; //ServicePointManager.Expect100Continue = false; // Settlement m_use_web_settle = economyConfig.GetBoolean("SettlementByWeb", m_use_web_settle); m_settle_url = economyConfig.GetString ("SettlementURL", m_settle_url); m_settle_message = economyConfig.GetString ("SettlementMessage", m_settle_message); // Price PriceEnergyUnit = economyConfig.GetInt ("PriceEnergyUnit", PriceEnergyUnit); PriceObjectClaim = economyConfig.GetInt ("PriceObjectClaim", PriceObjectClaim); PricePublicObjectDecay = economyConfig.GetInt ("PricePublicObjectDecay", PricePublicObjectDecay); PricePublicObjectDelete = economyConfig.GetInt ("PricePublicObjectDelete", PricePublicObjectDelete); PriceParcelClaim = economyConfig.GetInt ("PriceParcelClaim", PriceParcelClaim); PriceParcelClaimFactor = economyConfig.GetFloat("PriceParcelClaimFactor", PriceParcelClaimFactor); PriceUpload = economyConfig.GetInt ("PriceUpload", PriceUpload); PriceRentLight = economyConfig.GetInt ("PriceRentLight", PriceRentLight); PriceObjectRent = economyConfig.GetFloat("PriceObjectRent", PriceObjectRent); PriceObjectScaleFactor = economyConfig.GetFloat("PriceObjectScaleFactor", PriceObjectScaleFactor); PriceParcelRent = economyConfig.GetInt ("PriceParcelRent", PriceParcelRent); PriceGroupCreate = economyConfig.GetInt ("PriceGroupCreate", PriceGroupCreate); TeleportMinPrice = economyConfig.GetInt ("TeleportMinPrice", TeleportMinPrice); TeleportPriceExponent = economyConfig.GetFloat("TeleportPriceExponent", TeleportPriceExponent); EnergyEfficiency = economyConfig.GetFloat("EnergyEfficiency", EnergyEfficiency); // for HG Avatar string avatar_class = economyConfig.GetString("HGAvatarAs", "HGAvatar").ToLower(); if (avatar_class=="localavatar") m_hg_avatarClass = (int)AvatarType.LOCAL_AVATAR; else if (avatar_class=="guestavatar") m_hg_avatarClass = (int)AvatarType.GUEST_AVATAR; else if (avatar_class=="hgavatar") m_hg_avatarClass = (int)AvatarType.HG_AVATAR; else if (avatar_class=="foreignavatar") m_hg_avatarClass = (int)AvatarType.FOREIGN_AVATAR; else m_hg_avatarClass = (int)AvatarType.UNKNOWN_AVATAR; } catch { m_log.ErrorFormat("[MONEY MODULE]: Initialise: Faile to read configuration file"); } } public void AddRegion(Scene scene) { //m_log.InfoFormat("[MONEY MODULE]: AddRegion:"); if (scene==null) return; scene.RegisterModuleInterface(this); // 競合するモジュールの排除 lock (m_sceneList) { if (m_sceneList.Count==0) { if (m_enable_server) { HttpServer = new BaseHttpServer(9000); HttpServer.AddStreamHandler(new Region.Framework.Scenes.RegionStatsHandler(scene.RegionInfo)); HttpServer.AddXmlRPCHandler("OnMoneyTransfered", OnMoneyTransferedHandler); HttpServer.AddXmlRPCHandler("UpdateBalance", BalanceUpdateHandler); HttpServer.AddXmlRPCHandler("UserAlert", UserAlertHandler); HttpServer.AddXmlRPCHandler("GetBalance", GetBalanceHandler); // added HttpServer.AddXmlRPCHandler("AddBankerMoney", AddBankerMoneyHandler); // added HttpServer.AddXmlRPCHandler("SendMoney", SendMoneyHandler); // added HttpServer.AddXmlRPCHandler("MoveMoney", MoveMoneyHandler); // added MainServer.Instance.AddXmlRPCHandler("OnMoneyTransfered", OnMoneyTransferedHandler); MainServer.Instance.AddXmlRPCHandler("UpdateBalance", BalanceUpdateHandler); MainServer.Instance.AddXmlRPCHandler("UserAlert", UserAlertHandler); MainServer.Instance.AddXmlRPCHandler("GetBalance", GetBalanceHandler); // added MainServer.Instance.AddXmlRPCHandler("AddBankerMoney", AddBankerMoneyHandler); // added MainServer.Instance.AddXmlRPCHandler("SendMoney", SendMoneyHandler); // added MainServer.Instance.AddXmlRPCHandler("MoveMoney", MoveMoneyHandler); // added } } if (m_sceneList.ContainsKey(scene.RegionInfo.RegionHandle)) { m_sceneList[scene.RegionInfo.RegionHandle] = scene; } else { m_sceneList.Add(scene.RegionInfo.RegionHandle, scene); } } scene.EventManager.OnNewClient += OnNewClient; scene.EventManager.OnMakeRootAgent += OnMakeRootAgent; scene.EventManager.OnMakeChildAgent += MakeChildAgent; // for OpenSim scene.EventManager.OnMoneyTransfer += MoneyTransferAction; scene.EventManager.OnValidateLandBuy += ValidateLandBuy; scene.EventManager.OnLandBuy += processLandBuy; } public void RemoveRegion(Scene scene) { if (scene==null) return; lock (m_sceneList) { scene.EventManager.OnNewClient -= OnNewClient; scene.EventManager.OnMakeRootAgent -= OnMakeRootAgent; scene.EventManager.OnMakeChildAgent -= MakeChildAgent; // for OpenSim scene.EventManager.OnMoneyTransfer -= MoneyTransferAction; scene.EventManager.OnValidateLandBuy -= ValidateLandBuy; scene.EventManager.OnLandBuy -= processLandBuy; } } public void RegionLoaded(Scene scene) { //m_log.InfoFormat("[MONEY MODULE]: RegionLoaded:"); } public Type ReplaceableInterface { //get { return typeof(IMoneyModule); } get { return null; } } public bool IsSharedModule { get { return true; } } public string Name { get { return "DTLNSLMoneyModule"; } } public void PostInitialise() { //m_log.InfoFormat("[MONEY MODULE]: PostInitialise:"); } public void Close() { //m_log.InfoFormat("[MONEY MODULE]: Close:"); } #endregion #region IMoneyModule interface. // for LSL llGiveMoney() function public bool ObjectGiveMoney(UUID objectID, UUID fromID, UUID toID, int amount, UUID txn, out string result) { //m_log.InfoFormat("[MONEY MODULE]: ObjectGiveMoney: LSL ObjectGiveMoney. UUID = {0}", objectID.ToString()); result = string.Empty; if (!m_sellEnabled) { result = "LINDENDOLLAR_INSUFFICIENTFUNDS"; return false; } string objName = string.Empty; string avatarName = string.Empty; SceneObjectPart sceneObj = GetLocatePrim(objectID); if (sceneObj==null) { result = "LINDENDOLLAR_INSUFFICIENTFUNDS"; return false; } objName = sceneObj.Name; Scene scene = GetLocateScene(toID); if (scene!=null) { UserAccount account = scene.UserAccountService.GetUserAccount(scene.RegionInfo.ScopeID, toID); if (account!=null) { avatarName = account.FirstName + " " + account.LastName; } } bool ret = false; string description = String.Format("Object {0} pays {1}", objName, avatarName); if (sceneObj.OwnerID==fromID) { ulong regionHandle = sceneObj.RegionHandle; UUID regionUUID = sceneObj.RegionID; if (GetLocateClient(fromID)!=null) { ret = TransferMoney(fromID, toID, amount, (int)TransactionType.ObjectPays, objectID, regionHandle, regionUUID, description); } else { ret = ForceTransferMoney(fromID, toID, amount, (int)TransactionType.ObjectPays, objectID, regionHandle, regionUUID, description); } } if (!ret) result = "LINDENDOLLAR_INSUFFICIENTFUNDS"; return ret; } // public int UploadCharge { get { return PriceUpload; } } // public int GroupCreationCharge { get { return PriceGroupCreate; } } public int GetBalance(UUID agentID) { IClientAPI client = GetLocateClient(agentID); return QueryBalanceFromMoneyServer(client); } public bool UploadCovered(UUID agentID, int amount) { IClientAPI client = GetLocateClient(agentID); if (m_enable_server || string.IsNullOrEmpty(m_moneyServURL)) { int balance = QueryBalanceFromMoneyServer(client); if (balance>=amount) return true; } return false; } public bool AmountCovered(UUID agentID, int amount) { IClientAPI client = GetLocateClient(agentID); if (m_enable_server || string.IsNullOrEmpty(m_moneyServURL)) { int balance = QueryBalanceFromMoneyServer(client); if (balance>=amount) return true; } return false; } public void ApplyUploadCharge(UUID agentID, int amount, string text) { ulong regionHandle = GetLocateScene(agentID).RegionInfo.RegionHandle; UUID regionUUID = GetLocateScene(agentID).RegionInfo.RegionID; PayMoneyCharge(agentID, amount, (int)TransactionType.UploadCharge, regionHandle, regionUUID, text); } public void ApplyCharge(UUID agentID, int amount, MoneyTransactionType type) { ApplyCharge(agentID, amount, type, string.Empty); } public void ApplyCharge(UUID agentID, int amount, MoneyTransactionType type, string text) { ulong regionHandle = GetLocateScene(agentID).RegionInfo.RegionHandle; UUID regionUUID = GetLocateScene(agentID).RegionInfo.RegionID; PayMoneyCharge(agentID, amount, (int)type, regionHandle, regionUUID, text); } public bool Transfer(UUID fromID, UUID toID, int regionHandle, int amount, MoneyTransactionType type, string text) { return TransferMoney(fromID, toID, amount, (int)type, UUID.Zero, (ulong)regionHandle, UUID.Zero, text); } public bool Transfer(UUID fromID, UUID toID, UUID objectID, int amount, MoneyTransactionType type, string text) { SceneObjectPart sceneObj = GetLocatePrim(objectID); if (sceneObj==null) return false; ulong regionHandle = sceneObj.ParentGroup.Scene.RegionInfo.RegionHandle; UUID regionUUID = sceneObj.ParentGroup.Scene.RegionInfo.RegionID; return TransferMoney(fromID, toID, amount, (int)type, objectID, (ulong)regionHandle, regionUUID, text); } // for 0.8.3 over public void MoveMoney(UUID fromAgentID, UUID toAgentID, int amount, string text) { ForceTransferMoney(fromAgentID, toAgentID, amount, (int)TransactionType.MoveMoney, UUID.Zero, (ulong)0, UUID.Zero, text); } // for 0.9.1 over public bool MoveMoney(UUID fromAgentID, UUID toAgentID, int amount, MoneyTransactionType type, string text) { bool ret = ForceTransferMoney(fromAgentID, toAgentID, amount, (int)type, UUID.Zero, (ulong)0, UUID.Zero, text); return ret; } #endregion #region MoneyModule event handlers // private void OnNewClient(IClientAPI client) { //m_log.InfoFormat("[MONEY MODULE]: OnNewClient"); client.OnEconomyDataRequest += OnEconomyDataRequest; client.OnLogout += ClientClosed; client.OnMoneyBalanceRequest += OnMoneyBalanceRequest; client.OnRequestPayPrice += OnRequestPayPrice; client.OnObjectBuy += OnObjectBuy; } public void OnMakeRootAgent(ScenePresence agent) { //m_log.InfoFormat("[MONEY MODULE]: OnMakeRootAgent:"); int balance = 0; IClientAPI client = agent.ControllingClient; m_enable_server = LoginMoneyServer(agent, out balance); client.SendMoneyBalance(UUID.Zero, true, new byte[0], balance, 0, UUID.Zero, false, UUID.Zero, false, 0, String.Empty); //client.OnMoneyBalanceRequest += OnMoneyBalanceRequest; //client.OnRequestPayPrice += OnRequestPayPrice; //client.OnObjectBuy += OnObjectBuy; } // for OnClientClosed event private void ClientClosed(IClientAPI client) { //m_log.InfoFormat("[MONEY MODULE]: ClientClosed:"); if (m_enable_server && client!=null) { LogoffMoneyServer(client); } } // for OnMakeChildAgent event private void MakeChildAgent(ScenePresence avatar) { //m_log.InfoFormat("[MONEY MODULE]: MakeChildAgent:"); } // for OnMoneyTransfer event private void MoneyTransferAction(Object sender, EventManager.MoneyTransferArgs moneyEvent) { //m_log.InfoFormat("[MONEY MODULE]: MoneyTransferAction: type = {0}", moneyEvent.transactiontype); if (!m_sellEnabled) return; // Check the money transaction is necessary. if (moneyEvent.sender==moneyEvent.receiver) { return; } UUID receiver = moneyEvent.receiver; // Pay for the object. if (moneyEvent.transactiontype==(int)TransactionType.PayObject) { SceneObjectPart sceneObj = GetLocatePrim(moneyEvent.receiver); if (sceneObj!=null) { receiver = sceneObj.OwnerID; } else { return; } } // Before paying for the object, save the object local ID for current transaction. UUID objectID = UUID.Zero; ulong regionHandle = 0; UUID regionUUID = UUID.Zero; if (sender is Scene) { Scene scene = (Scene)sender; regionHandle = scene.RegionInfo.RegionHandle; regionUUID = scene.RegionInfo.RegionID; if (moneyEvent.transactiontype==(int)TransactionType.PayObject) { objectID = scene.GetSceneObjectPart(moneyEvent.receiver).UUID; } } TransferMoney(moneyEvent.sender, receiver, moneyEvent.amount, moneyEvent.transactiontype, objectID, regionHandle, regionUUID, "OnMoneyTransfer event"); return; } // for OnValidateLandBuy event private void ValidateLandBuy(Object sender, EventManager.LandBuyArgs landBuyEvent) { //m_log.InfoFormat("[MONEY MODULE]: ValidateLandBuy:"); IClientAPI senderClient = GetLocateClient(landBuyEvent.agentId); if (senderClient!=null) { int balance = QueryBalanceFromMoneyServer(senderClient); if (balance >= landBuyEvent.parcelPrice) { lock(landBuyEvent) { landBuyEvent.economyValidated = true; } } } return; } // for LandBuy even private void processLandBuy(Object sender, EventManager.LandBuyArgs landBuyEvent) { //m_log.InfoFormat("[MONEY MODULE]: processLandBuy:"); if (!m_sellEnabled) return; lock(landBuyEvent) { if (landBuyEvent.economyValidated==true && landBuyEvent.transactionID==0) { landBuyEvent.transactionID = Util.UnixTimeSinceEpoch(); ulong parcelID = (ulong)landBuyEvent.parcelLocalID; UUID regionUUID = UUID.Zero; if (sender is Scene) regionUUID = ((Scene)sender).RegionInfo.RegionID; if (TransferMoney(landBuyEvent.agentId, landBuyEvent.parcelOwnerID, landBuyEvent.parcelPrice, (int)TransactionType.LandSale, regionUUID, parcelID, regionUUID, "Land Purchase")) { landBuyEvent.amountDebited = landBuyEvent.parcelPrice; } } } return; } // for OnObjectBuy event public void OnObjectBuy(IClientAPI remoteClient, UUID agentID, UUID sessionID, UUID groupID, UUID categoryID, uint localID, byte saleType, int salePrice) { m_log.InfoFormat("[MONEY MODULE]: OnObjectBuy: agent = {0}, {1}", agentID, remoteClient.AgentId); // Handle the parameters error. if (!m_sellEnabled) return; if (remoteClient==null || salePrice<0) return; // Get the balance from money server. int balance = QueryBalanceFromMoneyServer(remoteClient); if (balance(); if (mod!=null) { UUID receiverId = sceneObj.OwnerID; ulong regionHandle = sceneObj.RegionHandle; UUID regionUUID = sceneObj.RegionID; bool ret = false; // if (salePrice>=0) { if (!string.IsNullOrEmpty(m_moneyServURL)) { ret = TransferMoney(remoteClient.AgentId, receiverId, salePrice, (int)TransactionType.PayObject, sceneObj.UUID, regionHandle, regionUUID, "Object Buy"); } else if (salePrice==0) { // amount is 0 with No Money Server ret = true; } } if (ret) { mod.BuyObject(remoteClient, categoryID, localID, saleType, salePrice); } } } else { remoteClient.SendAgentAlertMessage("Unable to buy now. The object was not found", false); return; } } return; } /// /// Sends the the stored money balance to the client /// /// /// /// /// private void OnMoneyBalanceRequest(IClientAPI client, UUID agentID, UUID SessionID, UUID TransactionID) { m_log.InfoFormat("[MONEY MODULE]: OnMoneyBalanceRequest:"); if (client.AgentId==agentID && client.SessionId==SessionID) { int balance = 0; // if (m_enable_server) { balance = QueryBalanceFromMoneyServer(client); } client.SendMoneyBalance(TransactionID, true, new byte[0], balance, 0, UUID.Zero, false, UUID.Zero, false, 0, String.Empty); } else { client.SendAlertMessage("Unable to send your money balance"); } } private void OnRequestPayPrice(IClientAPI client, UUID objectID) { m_log.InfoFormat("[MONEY MODULE]: OnRequestPayPrice:"); Scene scene = GetLocateScene(client.AgentId); if (scene==null) return; SceneObjectPart sceneObj = scene.GetSceneObjectPart(objectID); if (sceneObj==null) return; SceneObjectGroup group = sceneObj.ParentGroup; SceneObjectPart root = group.RootPart; client.SendPayPrice(objectID, root.PayPrice); } // //private void OnEconomyDataRequest(UUID agentId) private void OnEconomyDataRequest(IClientAPI user) { //m_log.InfoFormat("[MONEY MODULE]: OnEconomyDataRequest:"); //IClientAPI user = GetLocateClient(agentId); if (user!=null) { if (m_enable_server || string.IsNullOrEmpty(m_moneyServURL)) { //Scene s = GetLocateScene(user.AgentId); Scene s = (Scene)user.Scene; user.SendEconomyData(EnergyEfficiency, s.RegionInfo.ObjectCapacity, ObjectCount, PriceEnergyUnit, PriceGroupCreate, PriceObjectClaim, PriceObjectRent, PriceObjectScaleFactor, PriceParcelClaim, PriceParcelClaimFactor, PriceParcelRent, PricePublicObjectDecay, PricePublicObjectDelete, PriceRentLight, PriceUpload, TeleportMinPrice, TeleportPriceExponent); } } } #endregion #region MoneyModule XML-RPC Handler // "OnMoneyTransfered" RPC from MoneyServer public XmlRpcResponse OnMoneyTransferedHandler(XmlRpcRequest request, IPEndPoint remoteClient) { m_log.InfoFormat("[MONEY MODULE]: OnMoneyTransferedHandler:"); bool ret = false; if (request.Params.Count>0) { Hashtable requestParam = (Hashtable)request.Params[0]; if (requestParam.Contains("clientUUID") && requestParam.Contains("clientSessionID") && requestParam.Contains("clientSecureSessionID")) { UUID clientUUID = UUID.Zero; UUID.TryParse((string)requestParam["clientUUID"], out clientUUID); if (clientUUID!=UUID.Zero) { IClientAPI client = GetLocateClient(clientUUID); string sessionid = (string)requestParam["clientSessionID"]; string secureid = (string)requestParam["clientSecureSessionID"]; if (client!=null && secureid==client.SecureSessionId.ToString() && (sessionid==UUID.Zero.ToString()||sessionid==client.SessionId.ToString())) { if (requestParam.Contains("transactionType") && requestParam.Contains("objectID") && requestParam.Contains("amount")) { //m_log.InfoFormat("[MONEY MODULE]: OnMoneyTransferedHandler: type = {0}", requestParam["transactionType"]); // Pay for the object. if ((int)requestParam["transactionType"]==(int)TransactionType.PayObject) { // Send notify to the client(viewer) for Money Event Trigger. ObjectPaid handlerOnObjectPaid = OnObjectPaid; if (handlerOnObjectPaid!=null) { UUID objectID = UUID.Zero; UUID.TryParse((string)requestParam["objectID"], out objectID); handlerOnObjectPaid(objectID, clientUUID, (int)requestParam["amount"]); // call Script Engine for LSL money() } ret = true; } } } } } } // Send the response to money server. XmlRpcResponse resp = new XmlRpcResponse(); Hashtable paramTable = new Hashtable(); paramTable["success"] = ret; if (!ret) { m_log.ErrorFormat("[MONEY MODULE]: OnMoneyTransferedHandler: Transaction is failed. MoneyServer will rollback"); } resp.Value = paramTable; return resp; } // "UpdateBalance" RPC from MoneyServer or Script public XmlRpcResponse BalanceUpdateHandler(XmlRpcRequest request, IPEndPoint remoteClient) { //m_log.InfoFormat("[MONEY MODULE]: BalanceUpdateHandler:"); bool ret = false; #region Update the balance from money server. if (request.Params.Count>0) { Hashtable requestParam = (Hashtable)request.Params[0]; if (requestParam.Contains("clientUUID") && requestParam.Contains("clientSessionID") && requestParam.Contains("clientSecureSessionID")) { UUID clientUUID = UUID.Zero; UUID.TryParse((string)requestParam["clientUUID"], out clientUUID); // if (clientUUID!=UUID.Zero) { IClientAPI client = GetLocateClient(clientUUID); string sessionid = (string)requestParam["clientSessionID"]; string secureid = (string)requestParam["clientSecureSessionID"]; if (client!=null && secureid==client.SecureSessionId.ToString() && (sessionid==UUID.Zero.ToString()||sessionid==client.SessionId.ToString())) { // if (requestParam.Contains("Balance")) { // Send notify to the client. string msg = ""; if (requestParam.Contains("Message")) msg = (string)requestParam["Message"]; client.SendMoneyBalance(UUID.Random(), true, Utils.StringToBytes(msg), (int)requestParam["Balance"], 0, UUID.Zero, false, UUID.Zero, false, 0, String.Empty); // Dialog if (msg!="") { Scene scene = (Scene)client.Scene; IDialogModule dlg = scene.RequestModuleInterface(); dlg.SendAlertToUser(client.AgentId, msg); } ret = true; } } } } } #endregion // Send the response to money server. XmlRpcResponse resp = new XmlRpcResponse(); Hashtable paramTable = new Hashtable(); paramTable["success"] = ret; if (!ret) { m_log.ErrorFormat("[MONEY MODULE]: BalanceUpdateHandler: Cannot update client balance from MoneyServer"); } resp.Value = paramTable; return resp; } // "UserAlert" RPC from Script public XmlRpcResponse UserAlertHandler(XmlRpcRequest request, IPEndPoint remoteClient) { //m_log.InfoFormat("[MONEY MODULE]: UserAlertHandler:"); bool ret = false; #region confirm the request and show the notice from money server. if (request.Params.Count>0) { Hashtable requestParam = (Hashtable)request.Params[0]; if (requestParam.Contains("clientUUID") && requestParam.Contains("clientSessionID") && requestParam.Contains("clientSecureSessionID")) { UUID clientUUID = UUID.Zero; UUID.TryParse((string)requestParam["clientUUID"], out clientUUID); // if (clientUUID!=UUID.Zero) { IClientAPI client = GetLocateClient(clientUUID); string sessionid = (string)requestParam["clientSessionID"]; string secureid = (string)requestParam["clientSecureSessionID"]; if (client!=null && secureid==client.SecureSessionId.ToString() && (sessionid==UUID.Zero.ToString()||sessionid==client.SessionId.ToString())) { if (requestParam.Contains("Description")) { string description = (string)requestParam["Description"]; // Show the notice dialog with money server message. GridInstantMessage gridMsg = new GridInstantMessage(null, UUID.Zero, "MonyServer", new UUID(clientUUID.ToString()), (byte)InstantMessageDialog.MessageFromAgent, description, false, new Vector3()); client.SendInstantMessage(gridMsg); ret = true; } } } } } // #endregion // Send the response to money server. XmlRpcResponse resp = new XmlRpcResponse(); Hashtable paramTable = new Hashtable(); paramTable["success"] = ret; resp.Value = paramTable; return resp; } // "GetBalance" RPC from Script public XmlRpcResponse GetBalanceHandler(XmlRpcRequest request, IPEndPoint remoteClient) { //m_log.InfoFormat("[MONEY MODULE]: GetBalanceHandler:"); bool ret = false; int balance = -1; if (request.Params.Count>0) { Hashtable requestParam = (Hashtable)request.Params[0]; if (requestParam.Contains("clientUUID") && requestParam.Contains("clientSessionID") && requestParam.Contains("clientSecureSessionID")) { UUID clientUUID = UUID.Zero; UUID.TryParse((string)requestParam["clientUUID"], out clientUUID); // if (clientUUID!=UUID.Zero) { IClientAPI client = GetLocateClient(clientUUID); string sessionid = (string)requestParam["clientSessionID"]; string secureid = (string)requestParam["clientSecureSessionID"]; if (client!=null && secureid==client.SecureSessionId.ToString() && (sessionid==UUID.Zero.ToString()||sessionid==client.SessionId.ToString())) { balance = QueryBalanceFromMoneyServer(client); } } } } // Send the response to caller. if (balance<0) { m_log.ErrorFormat("[MONEY MODULE]: GetBalanceHandler: GetBalance transaction is failed"); ret = false; } XmlRpcResponse resp = new XmlRpcResponse(); Hashtable paramTable = new Hashtable(); paramTable["success"] = ret; paramTable["balance"] = balance; resp.Value = paramTable; return resp; } // "AddBankerMoney" RPC from Script public XmlRpcResponse AddBankerMoneyHandler(XmlRpcRequest request, IPEndPoint remoteClient) { //m_log.InfoFormat("[MONEY MODULE]: AddBankerMoneyHandler:"); bool ret = false; if (request.Params.Count>0) { Hashtable requestParam = (Hashtable)request.Params[0]; if (requestParam.Contains("clientUUID") && requestParam.Contains("clientSessionID") && requestParam.Contains("clientSecureSessionID")) { UUID bankerUUID = UUID.Zero; UUID.TryParse((string)requestParam["clientUUID"], out bankerUUID); // if (bankerUUID!=UUID.Zero) { IClientAPI client = GetLocateClient(bankerUUID); string sessionid = (string)requestParam["clientSessionID"]; string secureid = (string)requestParam["clientSecureSessionID"]; if (client!=null && secureid==client.SecureSessionId.ToString() && (sessionid==UUID.Zero.ToString()||sessionid==client.SessionId.ToString())) { if (requestParam.Contains("amount")) { Scene scene = (Scene)client.Scene; int amount = (int)requestParam["amount"]; ulong regionHandle = scene.RegionInfo.RegionHandle; UUID regionUUID = scene.RegionInfo.RegionID; ret = AddBankerMoney(bankerUUID, amount, regionHandle, regionUUID); if (m_use_web_settle && m_settle_user) { ret = true; IDialogModule dlg = scene.RequestModuleInterface(); if (dlg!=null) { dlg.SendUrlToUser(bankerUUID, "SYSTEM", UUID.Zero, UUID.Zero, false, m_settle_message, m_settle_url); } } } } } } } if (!ret) m_log.ErrorFormat("[MONEY MODULE]: AddBankerMoneyHandler: Add Banker Money transaction is failed"); // Send the response to caller. XmlRpcResponse resp = new XmlRpcResponse(); Hashtable paramTable = new Hashtable(); paramTable["settle"] = false; paramTable["success"] = ret; if (m_use_web_settle && m_settle_user) paramTable["settle"] = true; resp.Value = paramTable; return resp; } // "SendMoney" RPC from Script public XmlRpcResponse SendMoneyHandler(XmlRpcRequest request, IPEndPoint remoteClient) { //m_log.InfoFormat("[MONEY MODULE]: SendMoneyHandler:"); bool ret = false; if (request.Params.Count>0) { Hashtable requestParam = (Hashtable)request.Params[0]; if (requestParam.Contains("agentUUID") && requestParam.Contains("secretAccessCode")) { UUID agentUUID = UUID.Zero; UUID.TryParse((string)requestParam["agentUUID"], out agentUUID); if (agentUUID!=UUID.Zero) { if (requestParam.Contains("amount")) { int amount = (int)requestParam["amount"]; int type = -1; if (requestParam.Contains("type")) type = (int)requestParam["type"]; string secretCode = (string)requestParam["secretAccessCode"]; string scriptIP = remoteClient.Address.ToString(); MD5 md5 = MD5.Create(); byte[] code = md5.ComputeHash(ASCIIEncoding.Default.GetBytes(secretCode + "_" + scriptIP)); string hash = BitConverter.ToString(code).ToLower().Replace("-",""); //m_log.InfoFormat("[MONEY MODULE]: SendMoneyHandler: SecretCode: {0} + {1} = {2}", secretCode, scriptIP, hash); ret = SendMoneyTo(agentUUID, amount, type, hash); } } else { m_log.ErrorFormat("[MONEY MODULE]: SendMoneyHandler: amount is missed"); } } else { if (!requestParam.Contains("agentUUID")) { m_log.ErrorFormat("[MONEY MODULE]: SendMoneyHandler: agentUUID is missed"); } if (!requestParam.Contains("secretAccessCode")) { m_log.ErrorFormat("[MONEY MODULE]: SendMoneyHandler: secretAccessCode is missed"); } } } else { m_log.ErrorFormat("[MONEY MODULE]: SendMoneyHandler: Params count is under 0"); } if (!ret) m_log.ErrorFormat("[MONEY MODULE]: SendMoneyHandler: Send Money transaction is failed"); // Send the response to caller. XmlRpcResponse resp = new XmlRpcResponse(); Hashtable paramTable = new Hashtable(); paramTable["success"] = ret; resp.Value = paramTable; return resp; } // "MoveMoney" RPC from Script public XmlRpcResponse MoveMoneyHandler(XmlRpcRequest request, IPEndPoint remoteClient) { //m_log.InfoFormat("[MONEY MODULE]: MoveMoneyHandler:"); bool ret = false; if (request.Params.Count>0) { Hashtable requestParam = (Hashtable)request.Params[0]; if ((requestParam.Contains("fromUUID") || requestParam.Contains("toUUID")) && requestParam.Contains("secretAccessCode")) { UUID fromUUID = UUID.Zero; UUID toUUID = UUID.Zero; // UUID.Zero means System if (requestParam.Contains("fromUUID")) UUID.TryParse((string)requestParam["fromUUID"], out fromUUID); if (requestParam.Contains("toUUID")) UUID.TryParse((string)requestParam["toUUID"], out toUUID); if (requestParam.Contains("amount")) { int amount = (int)requestParam["amount"]; string secretCode = (string)requestParam["secretAccessCode"]; string scriptIP = remoteClient.Address.ToString(); MD5 md5 = MD5.Create(); byte[] code = md5.ComputeHash(ASCIIEncoding.Default.GetBytes(secretCode + "_" + scriptIP)); string hash = BitConverter.ToString(code).ToLower().Replace("-",""); //m_log.InfoFormat("[MONEY MODULE]: MoveMoneyHandler: SecretCode: {0} + {1} = {2}", secretCode, scriptIP, hash); ret = MoveMoneyFromTo(fromUUID, toUUID, amount, hash); } else { m_log.ErrorFormat("[MONEY MODULE]: MoveMoneyHandler: amount is missed"); } } else { if (!requestParam.Contains("fromUUID") && !requestParam.Contains("toUUID")) { m_log.ErrorFormat("[MONEY MODULE]: MoveMoneyHandler: fromUUID and toUUID are missed"); } if (!requestParam.Contains("secretAccessCode")) { m_log.ErrorFormat("[MONEY MODULE]: MoveMoneyHandler: secretAccessCode is missed"); } } } else { m_log.ErrorFormat("[MONEY MODULE]: MoveMoneyHandler: Params count is under 0"); } if (!ret) m_log.ErrorFormat("[MONEY MODULE]: MoveMoneyHandler: Move Money transaction is failed"); // Send the response to caller. XmlRpcResponse resp = new XmlRpcResponse(); Hashtable paramTable = new Hashtable(); paramTable["success"] = ret; resp.Value = paramTable; return resp; } #endregion #region MoneyModule private help functions /// /// Transfer the money from one user to another. Need to notify money server to update. /// /// /// The amount of money. /// /// /// return true, if successfully. /// private bool TransferMoney(UUID sender, UUID receiver, int amount, int type, UUID objectID, ulong regionHandle, UUID regionUUID, string description) { //m_log.InfoFormat("[MONEY MODULE]: TransferMoney:"); bool ret = false; IClientAPI senderClient = GetLocateClient(sender); // Handle the illegal transaction. // receiverClient could be null. if (senderClient==null) { m_log.InfoFormat("[MONEY MODULE]: TransferMoney: Client {0} not found", sender.ToString()); return false; } if (QueryBalanceFromMoneyServer(senderClient) /// Force transfer the money from one user to another. /// This function does not check sender login. /// Need to notify money server to update. /// /// /// The amount of money. /// /// /// return true, if successfully. /// private bool ForceTransferMoney(UUID sender, UUID receiver, int amount, int type, UUID objectID, ulong regionHandle, UUID regionUUID, string description) { //m_log.InfoFormat("[MONEY MODULE]: ForceTransferMoney:"); bool ret = false; #region Force send transaction request to money server and parse the resultes. if (m_enable_server) { string objName = string.Empty; SceneObjectPart sceneObj = GetLocatePrim(objectID); if (sceneObj!=null)objName = sceneObj.Name; // Fill parameters for money transfer XML-RPC. Hashtable paramTable = new Hashtable(); paramTable["senderID"] = sender.ToString(); paramTable["receiverID"] = receiver.ToString(); paramTable["transactionType"] = type; paramTable["objectID"] = objectID.ToString(); paramTable["objectName"] = objName; paramTable["regionHandle"] = regionHandle.ToString(); paramTable["regionUUID"] = regionUUID.ToString(); paramTable["amount"] = amount; paramTable["description"] = description; // Generate the request for transfer. Hashtable resultTable = genericCurrencyXMLRPCRequest(paramTable, "ForceTransferMoney"); // Handle the return values from Money Server. if (resultTable!=null && resultTable.Contains("success")) { if ((bool)resultTable["success"]==true) { ret = true; } } else m_log.ErrorFormat("[MONEY MODULE]: ForceTransferMoney: Can not money force transfer request from [{0}] to [{1}]", sender.ToString(), receiver.ToString()); } //else m_log.ErrorFormat("[MONEY MODULE]: ForceTransferMoney: Money Server is not available!!"); #endregion return ret; } /// /// Send the money to avatar. Need to notify money server to update. /// /// /// The amount of money. /// /// /// return true, if successfully. /// private bool SendMoneyTo(UUID avatarID, int amount, int type, string secretCode) { //m_log.InfoFormat("[MONEY MODULE]: SendMoneyTo:"); bool ret = false; if (m_enable_server) { // Fill parameters for money transfer XML-RPC. if (type<0) type = (int)TransactionType.ReferBonus; Hashtable paramTable = new Hashtable(); paramTable["receiverID"] = avatarID.ToString(); paramTable["transactionType"] = type; paramTable["amount"] = amount; paramTable["secretAccessCode"] = secretCode; paramTable["description"] = "Bonus to Avatar"; // Generate the request for transfer. Hashtable resultTable = genericCurrencyXMLRPCRequest(paramTable, "SendMoney"); // Handle the return values from Money Server. if (resultTable!=null && resultTable.Contains("success")) { if ((bool)resultTable["success"]==true) { ret = true; } else m_log.ErrorFormat("[MONEY MODULE]: SendMoneyTo: Fail Message is {0}", resultTable["message"]); } else m_log.ErrorFormat("[MONEY MODULE]: SendMoneyTo: Money Server is not responce"); } //else m_log.ErrorFormat("[MONEY MODULE]: SendMoneyTo: Money Server is not available!!"); return ret; } /// /// Move the money from avatar to other avatar. Need to notify money server to update. /// /// /// The amount of money. /// /// /// return true, if successfully. /// private bool MoveMoneyFromTo(UUID senderID, UUID receiverID, int amount, string secretCode) { //m_log.InfoFormat("[MONEY MODULE]: MoveMoneyFromTo:"); bool ret = false; if (m_enable_server) { // Fill parameters for money transfer XML-RPC. Hashtable paramTable = new Hashtable(); paramTable["senderID"] = senderID.ToString(); paramTable["receiverID"] = receiverID.ToString(); paramTable["transactionType"] = (int)TransactionType.MoveMoney; paramTable["amount"] = amount; paramTable["secretAccessCode"] = secretCode; paramTable["description"] = "Move Money"; // Generate the request for transfer. Hashtable resultTable = genericCurrencyXMLRPCRequest(paramTable, "MoveMoney"); // Handle the return values from Money Server. if (resultTable!=null && resultTable.Contains("success")) { if ((bool)resultTable["success"]==true) { ret = true; } else m_log.ErrorFormat("[MONEY MODULE]: MoveMoneyFromTo: Fail Message is {0}", resultTable["message"]); } else m_log.ErrorFormat("[MONEY MODULE]: MoveMoneyFromTo: Money Server is not responce"); } //else m_log.ErrorFormat("[MONEY MODULE]: MoveMoneyFromTo: Money Server is not available!!"); return ret; } /// /// Add the money to banker avatar. Need to notify money server to update. /// /// /// The amount of money. /// /// /// return true, if successfully. /// private bool AddBankerMoney(UUID bankerID, int amount, ulong regionHandle, UUID regionUUID) { //m_log.InfoFormat("[MONEY MODULE]: AddBankerMoney:"); bool ret = false; m_settle_user = false; if (m_enable_server) { // Fill parameters for money transfer XML-RPC. Hashtable paramTable = new Hashtable(); paramTable["bankerID"] = bankerID.ToString(); paramTable["transactionType"] = (int)TransactionType.BuyMoney; paramTable["amount"] = amount; paramTable["regionHandle"] = regionHandle.ToString(); paramTable["regionUUID"] = regionUUID.ToString(); paramTable["description"] = "Add Money to Avatar"; // Generate the request for transfer. Hashtable resultTable = genericCurrencyXMLRPCRequest(paramTable, "AddBankerMoney"); // Handle the return values from Money Server. if (resultTable!=null) { if (resultTable.Contains("success") && (bool)resultTable["success"]==true) { ret = true; } else { if (resultTable.Contains("banker")) { m_settle_user = !(bool)resultTable["banker"]; // If avatar is not banker, Web Settlement is used. if (m_settle_user && m_use_web_settle) m_log.ErrorFormat("[MONEY MODULE]: AddBankerMoney: Avatar is not Banker. Web Settlemrnt is used."); } else m_log.ErrorFormat("[MONEY MODULE]: AddBankerMoney: Fail Message {0}", resultTable["message"]); } } else m_log.ErrorFormat("[MONEY MODULE]: AddBankerMoney: Money Server is not responce"); } //else m_log.ErrorFormat("[MONEY MODULE]: AddBankerMoney: Money Server is not available!!"); return ret; } /// /// Pay the money of charge. /// /// /// The amount of money. /// /// /// return true, if successfully. /// private bool PayMoneyCharge(UUID sender, int amount, int type, ulong regionHandle, UUID regionUUID, string description) { //m_log.InfoFormat("[MONEY MODULE]: PayMoneyCharge:"); bool ret = false; IClientAPI senderClient = GetLocateClient(sender); // Handle the illegal transaction. // receiverClient could be null. if (senderClient==null) { m_log.InfoFormat("[MONEY MODULE]: PayMoneyCharge: Client {0} is not found", sender.ToString()); return false; } if (QueryBalanceFromMoneyServer(senderClient) /// Login the money server when the new client login. /// /// /// Indicate user ID of the new client. /// /// /// return true, if successfully. /// private bool LoginMoneyServer(ScenePresence avatar, out int balance) { //m_log.InfoFormat("[MONEY MODULE]: LoginMoneyServer:"); balance = 0; bool ret = false; bool isNpc = avatar.IsNPC; IClientAPI client = avatar.ControllingClient; #region Send money server the client info for login. if (!string.IsNullOrEmpty(m_moneyServURL)) { Scene scene = (Scene)client.Scene; string userName = string.Empty; // Get the username for the login user. if (client.Scene is Scene) { if (scene!=null) { UserAccount account = scene.UserAccountService.GetUserAccount(scene.RegionInfo.ScopeID, client.AgentId); if (account!=null) { userName = account.FirstName + " " + account.LastName; } } } ////////////////////////////////////////////////////////////// // User Universal Identifer for Grid Avatar, HG Avatar or NPC string universalID = string.Empty; string firstName = string.Empty; string lastName = string.Empty; string serverURL = string.Empty; int avatarType = (int)AvatarType.LOCAL_AVATAR; int avatarClass = (int)AvatarType.LOCAL_AVATAR; AgentCircuitData agent = scene.AuthenticateHandler.GetAgentCircuitData(client.AgentId); if (agent!=null) { universalID = Util.ProduceUserUniversalIdentifier(agent); if (!String.IsNullOrEmpty(universalID)) { UUID uuid; string tmp; Util.ParseUniversalUserIdentifier(universalID, out uuid, out serverURL, out firstName, out lastName, out tmp); } // if serverURL is empty, avatar is a NPC if (isNpc || String.IsNullOrEmpty(serverURL)) { avatarType = (int)AvatarType.NPC_AVATAR; } // if ((agent.teleportFlags & (uint)Constants.TeleportFlags.ViaHGLogin)!=0 || String.IsNullOrEmpty(userName)) { avatarType = (int)AvatarType.HG_AVATAR; } } if (String.IsNullOrEmpty(userName)) { userName = firstName + " " + lastName; } // avatarClass = avatarType; if (avatarType==(int)AvatarType.NPC_AVATAR) return false; if (avatarType==(int)AvatarType.HG_AVATAR) avatarClass = m_hg_avatarClass; // // Login the Money Server. Hashtable paramTable = new Hashtable(); paramTable["openSimServIP"] = scene.RegionInfo.ServerURI.Replace(scene.RegionInfo.InternalEndPoint.Port.ToString(), scene.RegionInfo.HttpPort.ToString()); paramTable["avatarType"] = avatarType.ToString(); paramTable["avatarClass"] = avatarClass.ToString(); paramTable["userName"] = userName; paramTable["universalID"] = universalID; paramTable["clientUUID"] = client.AgentId.ToString(); paramTable["clientSessionID"] = client.SessionId.ToString(); paramTable["clientSecureSessionID"] = client.SecureSessionId.ToString(); // Generate the request for transfer. Hashtable resultTable = genericCurrencyXMLRPCRequest(paramTable, "ClientLogin"); // Handle the return result if (resultTable!=null && resultTable.Contains("success")) { if ((bool)resultTable["success"]==true) { balance = (int)resultTable["clientBalance"]; m_log.InfoFormat("[MONEY MODULE]: LoginMoneyServer: Client [{0}] login Money Server {1}", client.AgentId.ToString(), m_moneyServURL); ret = true; } } else m_log.ErrorFormat("[MONEY MODULE]: LoginMoneyServer: Unable to login Money Server {0} for client [{1}]", m_moneyServURL, client.AgentId.ToString()); } else m_log.ErrorFormat("[MONEY MODULE]: LoginMoneyServer: Money Server is not available!! Server URL is Null or empty!!"); #endregion // Viewerへ設定を通知する. if (ret || string.IsNullOrEmpty(m_moneyServURL)) { OnEconomyDataRequest(client); } return ret; } /// /// Log off from the money server. /// /// /// Indicate user ID of the new client. /// /// /// return true, if successfully. /// private bool LogoffMoneyServer(IClientAPI client) { //m_log.InfoFormat("[MONEY MODULE]: LogoffMoneyServer:"); bool ret = false; if (!string.IsNullOrEmpty(m_moneyServURL)) { // Log off from the Money Server. Hashtable paramTable = new Hashtable(); paramTable["clientUUID"] = client.AgentId.ToString(); paramTable["clientSessionID"] = client.SessionId.ToString(); paramTable["clientSecureSessionID"] = client.SecureSessionId.ToString(); // Generate the request for transfer. Hashtable resultTable = genericCurrencyXMLRPCRequest(paramTable, "ClientLogout"); // Handle the return result if (resultTable!=null && resultTable.Contains("success")) { if ((bool)resultTable["success"]==true) { ret = true; } } } return ret; } // private EventManager.MoneyTransferArgs GetTransactionInfo(IClientAPI client, string transactionID) { //m_log.InfoFormat("[MONEY MODULE]: GetTransactionInfo:"); EventManager.MoneyTransferArgs args = null; if (m_enable_server) { Hashtable paramTable = new Hashtable(); paramTable["clientUUID"] = client.AgentId.ToString(); paramTable["clientSessionID"] = client.SessionId.ToString(); paramTable["clientSecureSessionID"] = client.SecureSessionId.ToString(); paramTable["transactionID"] = transactionID; // Generate the request for transfer. Hashtable resultTable = genericCurrencyXMLRPCRequest(paramTable, "GetTransaction"); // Handle the return result if (resultTable!=null && resultTable.Contains("success")) { if ((bool)resultTable["success"]==true) { int amount = (int)resultTable["amount"]; int type = (int)resultTable["type"]; string desc = (string)resultTable["description"]; UUID sender = UUID.Zero; UUID recver = UUID.Zero; UUID.TryParse((string)resultTable["sender"], out sender); UUID.TryParse((string)resultTable["receiver"], out recver); args = new EventManager.MoneyTransferArgs(sender, recver, amount, type, desc); } else { m_log.ErrorFormat("[MONEY MODULE]: GetTransactionInfo: GetTransactionInfo: Fail to Request. {0}", (string)resultTable["description"]); } } else { m_log.ErrorFormat("[MONEY MODULE]: GetTransactionInfo: Invalid Response"); } } else { m_log.ErrorFormat("[MONEY MODULE]: GetTransactionInfo: Invalid Money Server URL"); } return args; } /// /// Generic XMLRPC client abstraction /// /// Hashtable containing parameters to the method /// Method to invoke /// Hashtable with success=>bool and other values private Hashtable genericCurrencyXMLRPCRequest(Hashtable reqParams, string method) { //m_log.InfoFormat("[MONEY MODULE]: genericCurrencyXMLRPCRequest:"); if (reqParams.Count<=0 || string.IsNullOrEmpty(method)) return null; if (m_checkServerCert) { if (!m_moneyServURL.StartsWith("https://")) { m_log.InfoFormat("[MONEY MODULE]: genericCurrencyXMLRPCRequest: CheckServerCert is true, but protocol is not HTTPS. Please check INI file"); //return null; } } else { if (!m_moneyServURL.StartsWith("https://") && !m_moneyServURL.StartsWith("http://")) { m_log.ErrorFormat("[MONEY MODULE]: genericCurrencyXMLRPCRequest: Invalid Money Server URL: {0}", m_moneyServURL); return null; } } // ArrayList arrayParams = new ArrayList(); arrayParams.Add(reqParams); XmlRpcResponse moneyServResp = null; try { NSLXmlRpcRequest moneyModuleReq = new NSLXmlRpcRequest(method, arrayParams); //moneyServResp = moneyModuleReq.certSend(m_moneyServURL, m_cert, m_checkServerCert, MONEYMODULE_REQUEST_TIMEOUT); moneyServResp = moneyModuleReq.certSend(m_moneyServURL, m_certVerify, m_checkServerCert, MONEYMODULE_REQUEST_TIMEOUT); } catch (Exception ex) { m_log.ErrorFormat("[MONEY MODULE]: genericCurrencyXMLRPCRequest: Unable to connect to Money Server {0}", m_moneyServURL); m_log.ErrorFormat("[MONEY MODULE]: genericCurrencyXMLRPCRequest: {0}", ex); Hashtable ErrorHash = new Hashtable(); ErrorHash["success"] = false; ErrorHash["errorMessage"] = "Unable to manage your money at this time. Purchases may be unavailable"; ErrorHash["errorURI"] = ""; return ErrorHash; } if (moneyServResp==null || moneyServResp.IsFault) { Hashtable ErrorHash = new Hashtable(); ErrorHash["success"] = false; ErrorHash["errorMessage"] = "Unable to manage your money at this time. Purchases may be unavailable"; ErrorHash["errorURI"] = ""; return ErrorHash; } Hashtable moneyRespData = (Hashtable)moneyServResp.Value; return moneyRespData; } /////////////////////////////////////////////////////////////////////////////////////////////////////////////// /// Locates a IClientAPI for the client specified /// /// /// private IClientAPI GetLocateClient(UUID AgentID) { IClientAPI client = null; lock (m_sceneList) { if (m_sceneList.Count>0) { foreach (Scene _scene in m_sceneList.Values) { ScenePresence tPresence = (ScenePresence)_scene.GetScenePresence(AgentID); if (tPresence!=null && !tPresence.IsChildAgent) { IClientAPI rclient = tPresence.ControllingClient; if (rclient!=null) { client = rclient; break; } } } } } return client; } private Scene GetLocateScene(UUID AgentId) { Scene scene = null; lock (m_sceneList) { if (m_sceneList.Count>0) { foreach (Scene _scene in m_sceneList.Values) { ScenePresence tPresence = (ScenePresence)_scene.GetScenePresence(AgentId); if (tPresence!=null && !tPresence.IsChildAgent) { scene = _scene; break; } } } } return scene; } private SceneObjectPart GetLocatePrim(UUID objectID) { SceneObjectPart sceneObj = null; lock (m_sceneList) { if (m_sceneList.Count>0) { foreach (Scene _scene in m_sceneList.Values) { SceneObjectPart part = (SceneObjectPart)_scene.GetSceneObjectPart(objectID); if (part!=null) { sceneObj = part; break; } } } } return sceneObj; } #endregion } }