OpenSim
/
MoneyServer
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity
MoneyServer/addon-modules/OpenSim-Modules-Currency/OpenSim.Modules.Currency/DTLNSLMoneyModule.cs

2042 lines
67 KiB
C#
Raw Normal View History

add moneyserver
2020-06-03 15:27:40 +00:00
// * 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
{
/// <summary>
/// Transaction Type
/// </summary>
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;
add try
2021-01-18 22:35:45 +00:00
private NSLCertificateVerify m_certVerify = null;
add moneyserver
2020-06-03 15:27:40 +00:00
/// <summary>
/// Scene dictionary indexed by Region Handle
/// </summary>
private Dictionary<ulong, Scene> m_sceneList = new Dictionary<ulong, Scene>();
/// <summary>
/// To cache the balance data while the money server is not available.
/// </summary>
private Dictionary<UUID, int> m_moneyServer = new Dictionary<UUID, int>();
// 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
/// <summary>
/// Initialise
/// </summary>
/// <param name="scene"></param>
/// <param name="source"></param>
public void Initialise(Scene scene, IConfigSource source)
{
add try
2021-01-18 22:35:45 +00:00
try
{
m_certVerify = new NSLCertificateVerify(); // サーバ認証用
}catch(Exception error)
{
m_log.Error("[MoneyModule] " + error.Message);
m_log.Error("[MoneyModule] " + error.StackTrace);
}
add moneyserver
2020-06-03 15:27:40 +00:00
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]: Initialise:");
// Handle the parameters errors.
if (source==null) return;
try {
m_config = source;
// [Economy] section
IConfig economyConfig = m_config.Configs["Economy"];
m_sellEnabled = economyConfig.GetBoolean("SellEnabled", m_sellEnabled);
m_moneyServURL = economyConfig.GetString("CurrencyServer", m_moneyServURL);
// クライアント証明書
m_certFilename = economyConfig.GetString("ClientCertFilename", m_certFilename);
m_certPassword = economyConfig.GetString("ClientCertPassword", m_certPassword);
if (m_certFilename!="") {
m_cert = new X509Certificate2(m_certFilename, m_certPassword);
//m_cert = new X509Certificate2(m_certFilename, m_certPassword, X509KeyStorageFlags.MachineKeySet);
m_log.InfoFormat("[MONEY]: Issue Authentication of Client. Cert File is " + m_certFilename);
}
// サーバ認証
m_checkServerCert = economyConfig.GetBoolean("CheckServerCert", m_checkServerCert);
m_cacertFilename = economyConfig.GetString("CACertFilename", m_cacertFilename);
if (m_cacertFilename!="") {
m_certVerify.SetPrivateCA(m_cacertFilename);
m_log.InfoFormat("[MONEY]: Execute Authentication of Server. CA Cert File is " + m_cacertFilename);
}
else {
m_checkServerCert = false;
}
ServicePointManager.ServerCertificateValidationCallback = new RemoteCertificateValidationCallback(m_certVerify.ValidateServerCertificate);
// 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]: Initialise: Faile to read configuration file");
}
}
public void AddRegion(Scene scene)
{
//m_log.InfoFormat("[MONEY]: AddRegion:");
if (scene==null) return;
scene.RegisterModuleInterface<IMoneyModule>(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
add money helper
2020-06-24 15:38:08 +00:00
HttpServer.AddXmlRPCHandler("MoveMoney", MoveMoneyHandler); // added
HttpServer.AddXmlRPCHandler("getCurrencyQuote", quote_func);
HttpServer.AddXmlRPCHandler("buyCurrency", buy_func);
HttpServer.AddXmlRPCHandler("preflightBuyLandPrep", preflightBuyLandPrep_func);
HttpServer.AddXmlRPCHandler("buyLandPrep", landBuy_func);
add moneyserver
2020-06-03 15:27:40 +00:00
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]: 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]: PostInitialise:");
}
public void Close()
{
//m_log.InfoFormat("[MONEY]: 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]: 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]: 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]: 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]: ClientClosed:");
if (m_enable_server && client!=null) {
LogoffMoneyServer(client);
}
}
// for OnMakeChildAgent event
private void MakeChildAgent(ScenePresence avatar)
{
//m_log.InfoFormat("[MONEY]: MakeChildAgent:");
}
// for OnMoneyTransfer event
private void MoneyTransferAction(Object sender, EventManager.MoneyTransferArgs moneyEvent)
{
//m_log.InfoFormat("[MONEY]: 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]: 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]: 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]: 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<salePrice) {
remoteClient.SendAgentAlertMessage("Unable to buy now. You don't have sufficient funds", false);
return;
}
Scene scene = GetLocateScene(remoteClient.AgentId);
if (scene!=null) {
SceneObjectPart sceneObj = scene.GetSceneObjectPart(localID);
if (sceneObj!=null) {
IBuySellModule mod = scene.RequestModuleInterface<IBuySellModule>();
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;
}
/// <summary>
/// Sends the the stored money balance to the client
/// </summary>
/// <param name="client"></param>
/// <param name="agentID"></param>
/// <param name="SessionID"></param>
/// <param name="TransactionID"></param>
private void OnMoneyBalanceRequest(IClientAPI client, UUID agentID, UUID SessionID, UUID TransactionID)
{
m_log.InfoFormat("[MONEY]: 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]: 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]: 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]: 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]: 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]: 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]: 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<IDialogModule>();
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]: 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]: 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]: 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]: 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]: 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<IDialogModule>();
if (dlg!=null) {
dlg.SendUrlToUser(bankerUUID, "SYSTEM", UUID.Zero, UUID.Zero, false, m_settle_message, m_settle_url);
}
}
}
}
}
}
}
if (!ret) m_log.ErrorFormat("[MONEY]: 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]: 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]: SendMoneyHandler: SecretCode: {0} + {1} = {2}", secretCode, scriptIP, hash);
ret = SendMoneyTo(agentUUID, amount, type, hash);
}
}
else {
m_log.ErrorFormat("[MONEY]: SendMoneyHandler: amount is missed");
}
}
else {
if (!requestParam.Contains("agentUUID")) {
m_log.ErrorFormat("[MONEY]: SendMoneyHandler: agentUUID is missed");
}
if (!requestParam.Contains("secretAccessCode")) {
m_log.ErrorFormat("[MONEY]: SendMoneyHandler: secretAccessCode is missed");
}
}
}
else {
m_log.ErrorFormat("[MONEY]: SendMoneyHandler: Params count is under 0");
}
if (!ret) m_log.ErrorFormat("[MONEY]: 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]: 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]: MoveMoneyHandler: SecretCode: {0} + {1} = {2}", secretCode, scriptIP, hash);
ret = MoveMoneyFromTo(fromUUID, toUUID, amount, hash);
}
else {
m_log.ErrorFormat("[MONEY]: MoveMoneyHandler: amount is missed");
}
}
else {
if (!requestParam.Contains("fromUUID") && !requestParam.Contains("toUUID")) {
m_log.ErrorFormat("[MONEY]: MoveMoneyHandler: fromUUID and toUUID are missed");
}
if (!requestParam.Contains("secretAccessCode")) {
m_log.ErrorFormat("[MONEY]: MoveMoneyHandler: secretAccessCode is missed");
}
}
}
else {
m_log.ErrorFormat("[MONEY]: MoveMoneyHandler: Params count is under 0");
}
if (!ret) m_log.ErrorFormat("[MONEY]: 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
/// <summary>
/// Transfer the money from one user to another. Need to notify money server to update.
/// </summary>
/// <param name="amount">
/// The amount of money.
/// </param>
/// <returns>
/// return true, if successfully.
/// </returns>
private bool TransferMoney(UUID sender, UUID receiver, int amount, int type, UUID objectID, ulong regionHandle, UUID regionUUID, string description)
{
//m_log.InfoFormat("[MONEY]: TransferMoney:");
bool ret = false;
IClientAPI senderClient = GetLocateClient(sender);
// Handle the illegal transaction.
// receiverClient could be null.
if (senderClient==null) {
m_log.InfoFormat("[MONEY]: TransferMoney: Client {0} not found", sender.ToString());
return false;
}
if (QueryBalanceFromMoneyServer(senderClient)<amount) {
m_log.InfoFormat("[MONEY]: TransferMoney: No insufficient balance in client [{0}]", sender.ToString());
return false;
}
#region 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["senderSessionID"] = senderClient.SessionId.ToString();
paramTable["senderSecureSessionID"] = senderClient.SecureSessionId.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, "TransferMoney");
// 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]: TransferMoney: Can not money transfer request from [{0}] to [{1}]", sender.ToString(), receiver.ToString());
}
//else m_log.ErrorFormat("[MONEY]: TransferMoney: Money Server is not available!!");
#endregion
return ret;
}
/// <summary>
/// Force transfer the money from one user to another.
/// This function does not check sender login.
/// Need to notify money server to update.
/// </summary>
/// <param name="amount">
/// The amount of money.
/// </param>
/// <returns>
/// return true, if successfully.
/// </returns>
private bool ForceTransferMoney(UUID sender, UUID receiver, int amount, int type, UUID objectID, ulong regionHandle, UUID regionUUID, string description)
{
//m_log.InfoFormat("[MONEY]: 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]: ForceTransferMoney: Can not money force transfer request from [{0}] to [{1}]", sender.ToString(), receiver.ToString());
}
//else m_log.ErrorFormat("[MONEY]: ForceTransferMoney: Money Server is not available!!");
#endregion
return ret;
}
/// <summary>
/// Send the money to avatar. Need to notify money server to update.
/// </summary>
/// <param name="amount">
/// The amount of money.
/// </param>
/// <returns>
/// return true, if successfully.
/// </returns>
private bool SendMoneyTo(UUID avatarID, int amount, int type, string secretCode)
{
//m_log.InfoFormat("[MONEY]: 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]: SendMoneyTo: Fail Message is {0}", resultTable["message"]);
}
else m_log.ErrorFormat("[MONEY]: SendMoneyTo: Money Server is not responce");
}
//else m_log.ErrorFormat("[MONEY]: SendMoneyTo: Money Server is not available!!");
return ret;
}
/// <summary>
/// Move the money from avatar to other avatar. Need to notify money server to update.
/// </summary>
/// <param name="amount">
/// The amount of money.
/// </param>
/// <returns>
/// return true, if successfully.
/// </returns>
private bool MoveMoneyFromTo(UUID senderID, UUID receiverID, int amount, string secretCode)
{
//m_log.InfoFormat("[MONEY]: 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]: MoveMoneyFromTo: Fail Message is {0}", resultTable["message"]);
}
else m_log.ErrorFormat("[MONEY]: MoveMoneyFromTo: Money Server is not responce");
}
//else m_log.ErrorFormat("[MONEY]: MoveMoneyFromTo: Money Server is not available!!");
return ret;
}
/// <summary>
/// Add the money to banker avatar. Need to notify money server to update.
/// </summary>
/// <param name="amount">
/// The amount of money.
/// </param>
/// <returns>
/// return true, if successfully.
/// </returns>
private bool AddBankerMoney(UUID bankerID, int amount, ulong regionHandle, UUID regionUUID)
{
//m_log.InfoFormat("[MONEY]: 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]: AddBankerMoney: Avatar is not Banker. Web Settlemrnt is used.");
}
else m_log.ErrorFormat("[MONEY]: AddBankerMoney: Fail Message {0}", resultTable["message"]);
}
}
else m_log.ErrorFormat("[MONEY]: AddBankerMoney: Money Server is not responce");
}
//else m_log.ErrorFormat("[MONEY]: AddBankerMoney: Money Server is not available!!");
return ret;
}
/// <summary>
/// Pay the money of charge.
/// </summary>
/// <param name="amount">
/// The amount of money.
/// </param>
/// <returns>
/// return true, if successfully.
/// </returns>
private bool PayMoneyCharge(UUID sender, int amount, int type, ulong regionHandle, UUID regionUUID, string description)
{
//m_log.InfoFormat("[MONEY]: PayMoneyCharge:");
bool ret = false;
IClientAPI senderClient = GetLocateClient(sender);
// Handle the illegal transaction.
// receiverClient could be null.
if (senderClient==null) {
m_log.InfoFormat("[MONEY]: PayMoneyCharge: Client {0} is not found", sender.ToString());
return false;
}
if (QueryBalanceFromMoneyServer(senderClient)<amount) {
m_log.InfoFormat("[MONEY]: PayMoneyCharge: No insufficient balance in client [{0}]", sender.ToString());
return false;
}
#region Send transaction request to money server and parse the resultes.
if (m_enable_server) {
// Fill parameters for money transfer XML-RPC.
Hashtable paramTable = new Hashtable();
paramTable["senderID"] = sender.ToString();
paramTable["senderSessionID"] = senderClient.SessionId.ToString();
paramTable["senderSecureSessionID"] = senderClient.SecureSessionId.ToString();
paramTable["transactionType"] = type;
paramTable["amount"] = amount;
paramTable["regionHandle"] = regionHandle.ToString();
paramTable["regionUUID"] = regionUUID.ToString();
paramTable["description"] = description;
// Generate the request for transfer.
Hashtable resultTable = genericCurrencyXMLRPCRequest(paramTable, "PayMoneyCharge");
// 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]: PayMoneyCharge: Can not pay money of charge request from [{0}]", sender.ToString());
}
//else m_log.ErrorFormat("[MONEY]: PayMoneyCharge: Money Server is not available!!");
#endregion
return ret;
}
private int QueryBalanceFromMoneyServer(IClientAPI client)
{
//m_log.InfoFormat("[MONEY]: QueryBalanceFromMoneyServer:");
int balance = 0;
#region Send the request to get the balance from money server for cilent.
if (client!=null) {
if (m_enable_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, "GetBalance");
// Handle the return result
if (resultTable!=null && resultTable.Contains("success")) {
if ((bool)resultTable["success"]==true) {
balance = (int)resultTable["clientBalance"];
}
}
}
else {
if (m_moneyServer.ContainsKey(client.AgentId)) {
balance = m_moneyServer[client.AgentId];
}
}
}
#endregion
return balance;
}
/// <summary>
/// Login the money server when the new client login.
/// </summary>
/// <param name="userID">
/// Indicate user ID of the new client.
/// </param>
/// <returns>
/// return true, if successfully.
/// </returns>
private bool LoginMoneyServer(ScenePresence avatar, out int balance)
{
//m_log.InfoFormat("[MONEY]: 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]: LoginMoneyServer: Client [{0}] login Money Server {1}", client.AgentId.ToString(), m_moneyServURL);
ret = true;
}
}
else m_log.ErrorFormat("[MONEY]: LoginMoneyServer: Unable to login Money Server {0} for client [{1}]", m_moneyServURL, client.AgentId.ToString());
}
else m_log.ErrorFormat("[MONEY]: LoginMoneyServer: Money Server is not available!!");
#endregion
// Viewerへ設定を通知する．
if (ret || string.IsNullOrEmpty(m_moneyServURL)) {
OnEconomyDataRequest(client);
}
return ret;
}
/// <summary>
/// Log off from the money server.
/// </summary>
/// <param name="userID">
/// Indicate user ID of the new client.
/// </param>
/// <returns>
/// return true, if successfully.
/// </returns>
private bool LogoffMoneyServer(IClientAPI client)
{
//m_log.InfoFormat("[MONEY]: 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]: 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]: GetTransactionInfo: GetTransactionInfo: Fail to Request. {0}", (string)resultTable["description"]);
}
}
else {
m_log.ErrorFormat("[MONEY]: GetTransactionInfo: Invalid Response");
}
}
else {
m_log.ErrorFormat("[MONEY]: GetTransactionInfo: Invalid Money Server URL");
}
return args;
}
/// <summary>
/// Generic XMLRPC client abstraction
/// </summary>
/// <param name="reqParams">Hashtable containing parameters to the method</param>
/// <param name="method">Method to invoke</param>
/// <returns>Hashtable with success=>bool and other values</returns>
private Hashtable genericCurrencyXMLRPCRequest(Hashtable reqParams, string method)
{
//m_log.InfoFormat("[MONEY]: genericCurrencyXMLRPCRequest:");
if (reqParams.Count<=0 || string.IsNullOrEmpty(method)) return null;
if (m_checkServerCert) {
if (!m_moneyServURL.StartsWith("https://")) {
m_log.InfoFormat("[MONEY]: 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]: 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);
}
catch (Exception ex) {
m_log.ErrorFormat("[MONEY]: genericCurrencyXMLRPCRequest: Unable to connect to Money Server {0}", m_moneyServURL);
m_log.ErrorFormat("[MONEY]: 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
/// </summary>
/// <param name="AgentID"></param>
/// <returns></returns>
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
add money helper
2020-06-24 15:38:08 +00:00
#region moneyhelper
private XmlRpcResponse quote_func(XmlRpcRequest request, IPEndPoint remoteClient)
{
Hashtable requestData = (Hashtable)request.Params[0];
string agentIdStr = requestData["agentId"] as string;
UUID agentId = UUID.Parse(agentIdStr);
UUID sessionId = UUID.Parse(requestData["secureSessionId"] as string);
int amount = (int)requestData["currencyBuy"];
XmlRpcResponse returnval = new XmlRpcResponse();
Hashtable quoteResponse = new Hashtable();
Hashtable currencyResponse = new Hashtable();
currencyResponse.Add("estimatedCost", amount / 2);
currencyResponse.Add("currencyBuy", amount);
quoteResponse.Add("success", true);
quoteResponse.Add("currency", currencyResponse);
// TODO - generate a unique confirmation token
quoteResponse.Add("confirm", "asdfad9fj39ma9fj");
returnval.Value = quoteResponse;
return returnval;
}
private XmlRpcResponse buy_func(XmlRpcRequest request, IPEndPoint remoteClient)
{
Hashtable requestData = (Hashtable)request.Params[0];
UUID agentId = UUID.Parse(requestData["agentId"] as string);
string confirm = requestData["confirm"] as string;
int currencyBuy = (int)requestData["currencyBuy"];
int estimatedCost = (int)requestData["estimatedCost"];
string secureSessionId = requestData["secureSessionId"] as string;
// Fill parameters for money transfer XML-RPC.
Hashtable paramTable = new Hashtable();
paramTable["agentId"] = agentId.ToString();
paramTable["amount"] = currencyBuy;
XmlRpcResponse returnval = new XmlRpcResponse();
Hashtable returnresp = new Hashtable();
// Generate the request for transfer.
Hashtable resultTable = genericCurrencyXMLRPCRequest(paramTable, "GetFreeMoney");
if (resultTable != null && resultTable.Contains("success"))
{
if ((bool)resultTable["success"] == true)
{
returnresp.Add("success", true);
returnresp.Add("errorMessage", "");
returnresp.Add("errorUrl", "http://invaliddomaininvalid.com/");
}
else
{
returnresp.Add("success", false);
returnresp.Add("errorMessage", m_config.Configs["Economy"].GetString("Message_FreePayoutDenied", "Sorry. You cant get money from the system right now!"));
returnresp.Add("errorUrl", m_config.Configs["Economy"].GetString("ErrorURL", "http://127.0.0.1"));
}
}
else
{
returnresp.Add("success", false);
returnresp.Add("errorMessage", "FATAL ERROR. An unexpected fault is happend. Please try again or contact the region owner.");
returnresp.Add("errorUrl", m_config.Configs["Economy"].GetString("ErrorURL", "http://127.0.0.1"));
}
returnval.Value = returnresp;
return returnval;
}
private XmlRpcResponse preflightBuyLandPrep_func(XmlRpcRequest request, IPEndPoint remoteClient)
{
XmlRpcResponse ret = new XmlRpcResponse();
Hashtable retparam = new Hashtable();
Hashtable membershiplevels = new Hashtable();
ArrayList levels = new ArrayList();
Hashtable level = new Hashtable();
level.Add("id", "00000000-0000-0000-0000-000000000000");
level.Add("description", "some level");
levels.Add(level);
//membershiplevels.Add("levels",levels);
Hashtable landuse = new Hashtable();
landuse.Add("upgrade", false);
landuse.Add("action", "http://invaliddomaininvalid.com/");
Hashtable currency = new Hashtable();
currency.Add("estimatedCost", 0);
Hashtable membership = new Hashtable();
membershiplevels.Add("upgrade", false);
membershiplevels.Add("action", "http://invaliddomaininvalid.com/");
membershiplevels.Add("levels", membershiplevels);
retparam.Add("success", true);
retparam.Add("currency", currency);
retparam.Add("membership", membership);
retparam.Add("landuse", landuse);
retparam.Add("confirm", "asdfajsdkfjasdkfjalsdfjasdf");
ret.Value = retparam;
return ret;
}
private XmlRpcResponse landBuy_func(XmlRpcRequest request, IPEndPoint remoteClient)
{
XmlRpcResponse ret = new XmlRpcResponse();
Hashtable retparam = new Hashtable();
// Hashtable requestData = (Hashtable) request.Params[0];
// UUID agentId = UUID.Zero;
// int amount = 0;
retparam.Add("success", true);
ret.Value = retparam;
return ret;
}
#endregion
add moneyserver
2020-06-03 15:27:40 +00:00
}
}