12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892 |
- /*
- * Copyright (c) Contributors, http://opensimulator.org/
- * See CONTRIBUTORS.TXT for a full list of copyright holders.
- *
- * Redistribution and use in source and binary forms, with or without
- * modification, are permitted provided that the following conditions are met:
- * * Redistributions of source code must retain the above copyright
- * notice, this list of conditions and the following disclaimer.
- * * Redistributions in binary form must reproduce the above copyright
- * notice, this list of conditions and the following disclaimer in the
- * documentation and/or other materials provided with the distribution.
- * * Neither the name of the OpenSimulator Project nor the
- * names of its contributors may be used to endorse or promote products
- * derived from this software without specific prior written permission.
- *
- * THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS'' AND ANY
- * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
- * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
- * DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY
- * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
- * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
- * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
- * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
- * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
- * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
- */
- using System;
- using System.Collections.Generic;
- using System.Collections.Concurrent;
- using System.Globalization;
- using System.Linq;
- using System.Reflection;
- using System.Threading;
- using OpenMetaverse;
- using OpenMetaverse.StructuredData;
- using log4net;
- using Nini.Config;
- using OpenSim.Framework;
- using OpenSim.Region.Framework.Interfaces;
- using OpenSim.Region.Framework.Scenes;
- using OpenSim.Services.Interfaces;
- using Mono.Addins;
- using OpenSim.Services.Connectors.Hypergrid;
- using OpenSim.Framework.Servers.HttpServer;
- using OpenSim.Services.UserProfilesService;
- using GridRegion = OpenSim.Services.Interfaces.GridRegion;
- using OpenSim.Region.CoreModules.Avatar.Friends;
- namespace OpenSim.Region.CoreModules.Avatar.UserProfiles
- {
- [Extension(Path = "/OpenSim/RegionModules", NodeName = "RegionModule", Id = "UserProfilesModule")]
- public class UserProfileModule : IProfileModule, INonSharedRegionModule
- {
- const double PROFILECACHEEXPIRE = 300;
- /// <summary>
- /// Logging
- /// </summary>
- static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
- // The pair of Dictionaries are used to handle the switching of classified ads
- // by maintaining a cache of classified id to creator id mappings and an interest
- // count. The entries are removed when the interest count reaches 0.
- readonly Dictionary<UUID, UUID> m_classifiedCache = new();
- readonly Dictionary<UUID, int> m_classifiedInterest = new();
- readonly ExpiringCacheOS<UUID, UserProfileCacheEntry> m_profilesCache = new(60000);
- IGroupsModule m_groupsModule = null;
- private readonly JsonRpcRequestManager rpc = new();
- private bool m_allowUserProfileWebURLs = true;
- struct AsyncPropsRequest
- {
- public IClientAPI client;
- public ScenePresence presence;
- public UUID agent;
- public int reqtype;
- }
- private readonly ConcurrentStack<AsyncPropsRequest> m_asyncRequests = new();
- private readonly object m_asyncRequestsLock = new();
- private bool m_asyncRequestsRunning = false;
- private void ProcessRequests()
- {
- lock(m_asyncRequestsLock)
- {
- while (m_asyncRequests.TryPop(out AsyncPropsRequest req))
- {
- try
- {
- IClientAPI client = req.client;
- if(!client.IsActive)
- continue;
- if(req.reqtype == 0)
- {
- ScenePresence p = req.presence;
- bool foreign = GetUserProfileServerURI(req.agent, out string serverURI);
- bool ok = serverURI.Length > 0;
- Byte[] membershipType = new Byte[1];
- string born = string.Empty;
- uint flags = 0x00;
- if (ok && GetUserAccountData(req.agent, out UserAccount acc))
- {
- flags = (uint)(acc.UserFlags & 0xff);
- if (acc.UserTitle.Length == 0)
- membershipType[0] = (byte)((acc.UserFlags & 0x0f00) >> 8);
- else
- membershipType = Utils.StringToBytes(acc.UserTitle);
- int val_born = acc.Created;
- if (val_born != 0)
- born = Util.ToDateTime(val_born).ToString("M/d/yyyy", CultureInfo.InvariantCulture);
- }
- else
- ok = false;
- UserProfileProperties props = new() { UserId = req.agent };
- if (ok)
- ok = GetProfileData(ref props, foreign, serverURI, out string result);
- if (!ok)
- props.AboutText = "Profile not available at this time. User may still be unknown to this grid";
- if (!m_allowUserProfileWebURLs)
- props.WebUrl = "";
- GroupMembershipData[] agentGroups = null;
- if(ok && m_groupsModule is not null)
- agentGroups = m_groupsModule.GetMembershipData(req.agent);
- HashSet<IClientAPI> clients;
- lock (m_profilesCache)
- {
- if (!m_profilesCache.TryGetValue(props.UserId, out UserProfileCacheEntry uce) || uce is null)
- uce = new UserProfileCacheEntry();
- uce.props = props;
- uce.born = born;
- uce.membershipType = membershipType;
- uce.flags = flags;
- clients = uce.ClientsWaitingProps;
- uce.ClientsWaitingProps = null;
- uce.avatarGroups = agentGroups;
- m_profilesCache.AddOrUpdate(props.UserId, uce, PROFILECACHEEXPIRE);
- }
- if (IsFriendOnline(req.client, req.agent))
- flags |= (uint)ProfileFlags.Online;
- else
- flags &= (uint)~ProfileFlags.Online;
- if (clients is null)
- {
- client.SendAvatarProperties(props.UserId, props.AboutText, born, membershipType, props.FirstLifeText, flags,
- props.FirstLifeImageId, props.ImageId, props.WebUrl, props.PartnerId);
- client.SendAvatarInterestsReply(props.UserId, (uint)props.WantToMask, props.WantToText,
- (uint)props.SkillsMask, props.SkillsText, props.Language);
- if (agentGroups is not null)
- client.SendAvatarGroupsReply(req.agent, agentGroups);
- }
- else
- {
- if (!clients.Contains(client) && client.IsActive)
- {
- client.SendAvatarProperties(props.UserId, props.AboutText, born, membershipType, props.FirstLifeText, flags,
- props.FirstLifeImageId, props.ImageId, props.WebUrl, props.PartnerId);
- client.SendAvatarInterestsReply(props.UserId, (uint)props.WantToMask, props.WantToText,
- (uint)props.SkillsMask, props.SkillsText, props.Language);
- if (agentGroups is not null)
- client.SendAvatarGroupsReply(req.agent, agentGroups);
- }
- foreach (IClientAPI cli in clients)
- {
- if (!cli.IsActive)
- continue;
- cli.SendAvatarProperties(props.UserId, props.AboutText, born, membershipType, props.FirstLifeText, flags,
- props.FirstLifeImageId, props.ImageId, props.WebUrl, props.PartnerId);
- cli.SendAvatarInterestsReply(props.UserId, (uint)props.WantToMask, props.WantToText,
- (uint)props.SkillsMask, props.SkillsText, props.Language);
- if (agentGroups is not null)
- cli.SendAvatarGroupsReply(req.agent, agentGroups);
- }
- }
- }
- }
- catch (Exception e)
- {
- m_log.ErrorFormat("[UserProfileModule]: Process fail {0} : {1}", e.Message, e.StackTrace);
- }
- }
- m_asyncRequestsRunning = false;
- }
- }
- public Scene Scene
- {
- get; private set;
- }
- /// <summary>
- /// Gets or sets the ConfigSource.
- /// </summary>
- /// <value>
- /// The configuration
- /// </value>
- public IConfigSource Config
- {
- get;
- set;
- }
- /// <summary>
- /// Gets or sets the URI to the profile server.
- /// </summary>
- /// <value>
- /// The profile server URI.
- /// </value>
- public string ProfileServerUri
- {
- get;
- set;
- }
- IProfileModule ProfileModule
- {
- get; set;
- }
- IUserManagement UserManagementModule
- {
- get; set;
- }
- /// <summary>
- /// Gets or sets a value indicating whether this
- /// <see cref="OpenSim.Region.Coremodules.UserProfiles.UserProfileModule"/> is enabled.
- /// </summary>
- /// <value>
- /// <c>true</c> if enabled; otherwise, <c>false</c>.
- /// </value>
- public bool Enabled
- {
- get;
- set;
- }
- private GridInfo m_thisGridInfo;
- #region IRegionModuleBase implementation
- /// <summary>
- /// This is called to initialize the region module. For shared modules, this is called exactly once, after
- /// creating the single (shared) instance. For non-shared modules, this is called once on each instance, after
- /// the instace for the region has been created.
- /// </summary>
- /// <param name='source'>
- /// Source.
- /// </param>
- public void Initialise(IConfigSource source)
- {
- Config = source;
- ReplaceableInterface = typeof(IProfileModule);
- IConfig profileConfig = Config.Configs["UserProfiles"];
- if (profileConfig is null)
- {
- //m_log.Debug("[PROFILES]: UserProfiles disabled, no configuration");
- Enabled = false;
- return;
- }
- // If we find ProfileURL then we configure for FULL support
- // else we setup for BASIC support
- ProfileServerUri = profileConfig.GetString("ProfileServiceURL", "");
- if (string.IsNullOrEmpty(ProfileServerUri))
- {
- Enabled = false;
- return;
- }
- OSHTTPURI tmp = new(ProfileServerUri, true);
- if (!tmp.IsResolvedHost)
- {
- m_log.ErrorFormat("[UserProfileModule: {0}", tmp.IsValidHost ? "Could not resolve ProfileServiceURL" : "ProfileServiceURL is a invalid host");
- throw new Exception("UserProfileModule init error");
- }
- ProfileServerUri = tmp.URI;
- m_allowUserProfileWebURLs = profileConfig.GetBoolean("AllowUserProfileWebURLs", m_allowUserProfileWebURLs);
- m_log.Debug("[UserProfileModule]: Full Profiles Enabled");
- ReplaceableInterface = null;
- Enabled = true;
- }
- /// <summary>
- /// Adds the region.
- /// </summary>
- /// <param name='scene'>
- /// Scene.
- /// </param>
- public void AddRegion(Scene scene)
- {
- if(!Enabled)
- return;
- Scene = scene;
- m_thisGridInfo ??= scene.SceneGridInfo;
- Scene.RegisterModuleInterface<IProfileModule>(this);
- Scene.EventManager.OnNewClient += OnNewClient;
- Scene.EventManager.OnClientClosed += OnClientClosed;
- UserManagementModule = Scene.RequestModuleInterface<IUserManagement>();
- }
- /// <summary>
- /// Removes the region.
- /// </summary>
- /// <param name='scene'>
- /// Scene.
- /// </param>
- public void RemoveRegion(Scene scene)
- {
- if(!Enabled)
- return;
- m_profilesCache.Clear();
- m_classifiedCache.Clear();
- m_classifiedInterest.Clear();
- }
- /// <summary>
- /// This will be called once for every scene loaded. In a shared module this will be multiple times in one
- /// instance, while a nonshared module instance will only be called once. This method is called after AddRegion
- /// has been called in all modules for that scene, providing an opportunity to request another module's
- /// interface, or hook an event from another module.
- /// </summary>
- /// <param name='scene'>
- /// Scene.
- /// </param>
- public void RegionLoaded(Scene scene)
- {
- if(!Enabled)
- return;
- m_groupsModule = Scene.RequestModuleInterface<IGroupsModule>();
- }
- /// <summary>
- /// If this returns non-null, it is the type of an interface that this module intends to register. This will
- /// cause the loader to defer loading of this module until all other modules have been loaded. If no other
- /// module has registered the interface by then, this module will be activated, else it will remain inactive,
- /// letting the other module take over. This should return non-null ONLY in modules that are intended to be
- /// easily replaceable, e.g. stub implementations that the developer expects to be replaced by third party
- /// provided modules.
- /// </summary>
- /// <value>
- /// The replaceable interface.
- /// </value>
- public Type ReplaceableInterface
- {
- get; private set;
- }
- /// <summary>
- /// Called as the instance is closed.
- /// </summary>
- public void Close()
- {
- m_thisGridInfo = null;
- }
- /// <value>
- /// The name of the module
- /// </value>
- /// <summary>
- /// Gets the module name.
- /// </summary>
- public string Name
- {
- get { return "UserProfileModule"; }
- }
- #endregion IRegionModuleBase implementation
- #region Region Event Handlers
- /// <summary>
- /// Raises the new client event.
- /// </summary>
- /// <param name='client'>
- /// Client.
- /// </param>
- void OnNewClient(IClientAPI client)
- {
- //Profile
- client.OnRequestAvatarProperties += RequestAvatarProperties;
- client.OnUpdateAvatarProperties += AvatarPropertiesUpdate;
- client.OnAvatarInterestUpdate += AvatarInterestsUpdate;
- // Classifieds
- client.AddGenericPacketHandler("avatarclassifiedsrequest", ClassifiedsRequest);
- client.OnClassifiedInfoUpdate += ClassifiedInfoUpdate;
- client.OnClassifiedInfoRequest += ClassifiedInfoRequest;
- client.OnClassifiedDelete += ClassifiedDelete;
- // Picks
- client.AddGenericPacketHandler("avatarpicksrequest", PicksRequest);
- client.AddGenericPacketHandler("pickinforequest", PickInfoRequest);
- client.OnPickInfoUpdate += PickInfoUpdate;
- client.OnPickDelete += PickDelete;
- // Notes
- client.AddGenericPacketHandler("avatarnotesrequest", NotesRequest);
- client.OnAvatarNotesUpdate += NotesUpdate;
- // Preferences
- client.OnUserInfoRequest += UserPreferencesRequest;
- client.OnUpdateUserInfo += UpdateUserPreferences;
- }
- void OnClientClosed(UUID AgentId, Scene scene)
- {
- ScenePresence sp = scene.GetScenePresence(AgentId);
- IClientAPI client = sp.ControllingClient;
- if (client is null)
- return;
- //Profile
- client.OnRequestAvatarProperties -= RequestAvatarProperties;
- client.OnUpdateAvatarProperties -= AvatarPropertiesUpdate;
- client.OnAvatarInterestUpdate -= AvatarInterestsUpdate;
- // Classifieds
- client.OnClassifiedInfoUpdate -= ClassifiedInfoUpdate;
- client.OnClassifiedInfoRequest -= ClassifiedInfoRequest;
- client.OnClassifiedDelete -= ClassifiedDelete;
- // Picks
- client.OnPickInfoUpdate -= PickInfoUpdate;
- client.OnPickDelete -= PickDelete;
- // Notes
- client.OnAvatarNotesUpdate -= NotesUpdate;
- // Preferences
- client.OnUserInfoRequest -= UserPreferencesRequest;
- client.OnUpdateUserInfo -= UpdateUserPreferences;
- }
- #endregion Region Event Handlers
- #region Classified
- ///
- /// <summary>
- /// Handles the avatar classifieds request.
- /// </summary>
- /// <param name='sender'>
- /// Sender.
- /// </param>
- /// <param name='method'>
- /// Method.
- /// </param>
- /// <param name='args'>
- /// Arguments.
- /// </param>
- public void ClassifiedsRequest(Object sender, string method, List<String> args)
- {
- if (sender is not IClientAPI remoteClient)
- return;
- Dictionary<UUID, string> classifieds = new();
- if (!UUID.TryParse(args[0], out UUID targetID) || targetID.IsZero())
- return;
- if (targetID.Equals(Constants.m_MrOpenSimID))
- {
- remoteClient.SendAvatarClassifiedReply(targetID, classifieds);
- return;
- }
- ScenePresence p = FindPresence(targetID);
- if (p is not null && p.IsNPC)
- {
- remoteClient.SendAvatarClassifiedReply(targetID, classifieds);
- return;
- }
- lock(m_profilesCache)
- {
- if(m_profilesCache.TryGetValue(targetID, out UserProfileCacheEntry uce) && uce is not null)
- {
- if(uce.classifiedsLists is not null)
- {
- foreach(KeyValuePair<UUID,string> kvp in uce.classifiedsLists)
- {
- UUID kvpkey = kvp.Key;
- classifieds[kvpkey] = kvp.Value;
- lock (m_classifiedCache)
- {
- if (!m_classifiedCache.ContainsKey(kvpkey))
- {
- m_classifiedCache.Add(kvpkey,targetID);
- m_classifiedInterest.Add(kvpkey, 0);
- }
- m_classifiedInterest[kvpkey]++;
- }
- }
- remoteClient.SendAvatarClassifiedReply(targetID, uce.classifiedsLists);
- return;
- }
- }
- }
- GetUserProfileServerURI(targetID, out string serverURI);
- if(string.IsNullOrWhiteSpace(serverURI))
- {
- remoteClient.SendAvatarClassifiedReply(targetID, classifieds);
- return;
- }
- OSDMap parameters= new()
- {
- {"creatorId", OSD.FromUUID(targetID)}
- };
- OSD osdtmp = parameters;
- if(!rpc.JsonRpcRequest(ref osdtmp, "avatarclassifiedsrequest", serverURI, UUID.Random().ToString()))
- {
- remoteClient.SendAvatarClassifiedReply(targetID, classifieds);
- return;
- }
- parameters = (OSDMap)osdtmp;
- if(!parameters.TryGetValue("result", out osdtmp) || osdtmp is not OSDArray)
- {
- remoteClient.SendAvatarClassifiedReply(targetID, classifieds);
- return;
- }
- OSDArray list = (OSDArray)osdtmp;
- foreach(OSD map in list)
- {
- OSDMap m = (OSDMap)map;
- UUID cid = m["classifieduuid"].AsUUID();
- string name = m["name"].AsString();
- classifieds[cid] = name;
- lock (m_classifiedCache)
- {
- if (!m_classifiedCache.ContainsKey(cid))
- {
- m_classifiedCache.Add(cid,targetID);
- m_classifiedInterest.Add(cid, 0);
- }
- m_classifiedInterest[cid]++;
- }
- }
- lock(m_profilesCache)
- {
- if(!m_profilesCache.TryGetValue(targetID, out UserProfileCacheEntry uce) || uce is null)
- uce = new UserProfileCacheEntry();
- uce.classifiedsLists = classifieds;
- m_profilesCache.AddOrUpdate(targetID, uce, PROFILECACHEEXPIRE);
- }
- remoteClient.SendAvatarClassifiedReply(targetID, classifieds);
- }
- public void ClassifiedInfoRequest(UUID queryClassifiedID, IClientAPI remoteClient)
- {
- UUID target = remoteClient.AgentId;
- UserClassifiedAdd ad = new() { ClassifiedId = queryClassifiedID };
- lock (m_classifiedCache)
- {
- if (m_classifiedCache.ContainsKey(queryClassifiedID))
- {
- target = m_classifiedCache[queryClassifiedID];
- m_classifiedInterest[queryClassifiedID]--;
- if (m_classifiedInterest[queryClassifiedID] == 0)
- {
- m_classifiedInterest.Remove(queryClassifiedID);
- m_classifiedCache.Remove(queryClassifiedID);
- }
- }
- }
- UserProfileCacheEntry uce = null;
- lock(m_profilesCache)
- {
- if(m_profilesCache.TryGetValue(target, out uce) && uce is not null)
- {
- if(uce.classifieds is not null && uce.classifieds.ContainsKey(queryClassifiedID))
- {
- ad = uce.classifieds[queryClassifiedID];
- if(Vector3.TryParse(ad.GlobalPos, out Vector3 gPos))
- {
- remoteClient.SendClassifiedInfoReply(ad.ClassifiedId, ad.CreatorId, (uint)ad.CreationDate,
- (uint)ad.ExpirationDate, (uint)ad.Category, ad.Name, ad.Description,
- ad.ParcelId, (uint)ad.ParentEstate, ad.SnapshotId, ad.SimName,
- gPos, ad.ParcelName, ad.Flags, ad.Price);
- }
- return;
- }
- }
- }
- bool foreign = GetUserProfileServerURI(target, out string serverURI);
- if(string.IsNullOrWhiteSpace(serverURI))
- {
- return;
- }
- object Adobject = ad;
- if(!rpc.JsonRpcRequest(ref Adobject, "classifieds_info_query", serverURI, UUID.Random().ToString()))
- {
- remoteClient.SendAgentAlertMessage(
- "Error getting classified info", false);
- return;
- }
- ad = (UserClassifiedAdd) Adobject;
- if(ad.CreatorId.IsZero())
- return;
- if(foreign)
- cacheForeignImage(target, ad.SnapshotId);
- lock(m_profilesCache)
- {
- if(!m_profilesCache.TryGetValue(target, out uce) || uce is null)
- uce = new UserProfileCacheEntry();
- uce.classifieds ??= new Dictionary<UUID, UserClassifiedAdd>();
- uce.classifieds[ad.ClassifiedId] = ad;
- m_profilesCache.AddOrUpdate(target, uce, PROFILECACHEEXPIRE);
- }
- if(Vector3.TryParse(ad.GlobalPos, out Vector3 globalPos))
- remoteClient.SendClassifiedInfoReply(ad.ClassifiedId, ad.CreatorId, (uint)ad.CreationDate, (uint)ad.ExpirationDate,
- (uint)ad.Category, ad.Name, ad.Description, ad.ParcelId, (uint)ad.ParentEstate,
- ad.SnapshotId, ad.SimName, globalPos, ad.ParcelName, ad.Flags, ad.Price);
- }
- /// <summary>
- /// Classifieds info update.
- /// </summary>
- /// <param name='queryclassifiedID'>
- /// Queryclassified I.
- /// </param>
- /// <param name='queryCategory'>
- /// Query category.
- /// </param>
- /// <param name='queryName'>
- /// Query name.
- /// </param>
- /// <param name='queryDescription'>
- /// Query description.
- /// </param>
- /// <param name='queryParcelID'>
- /// Query parcel I.
- /// </param>
- /// <param name='queryParentEstate'>
- /// Query parent estate.
- /// </param>
- /// <param name='querySnapshotID'>
- /// Query snapshot I.
- /// </param>
- /// <param name='queryGlobalPos'>
- /// Query global position.
- /// </param>
- /// <param name='queryclassifiedFlags'>
- /// Queryclassified flags.
- /// </param>
- /// <param name='queryclassifiedPrice'>
- /// Queryclassified price.
- /// </param>
- /// <param name='remoteClient'>
- /// Remote client.
- /// </param>
- public void ClassifiedInfoUpdate(UUID queryclassifiedID, uint queryCategory, string queryName, string queryDescription, UUID queryParcelID,
- uint queryParentEstate, UUID querySnapshotID, Vector3 queryGlobalPos, byte queryclassifiedFlags,
- int queryclassifiedPrice, IClientAPI remoteClient)
- {
- Scene s = (Scene)remoteClient.Scene;
- Vector3 pos = remoteClient.SceneAgent.AbsolutePosition;
- ILandObject land = s.LandChannel.GetLandObject(pos.X, pos.Y);
- UUID creatorId = remoteClient.AgentId;
- ScenePresence p = FindPresence(creatorId);
- UserProfileCacheEntry uce;
- lock (m_profilesCache)
- m_profilesCache.TryGetValue(remoteClient.AgentId, out uce);
- bool foreign = GetUserProfileServerURI(remoteClient.AgentId, out string serverURI);
- if(string.IsNullOrWhiteSpace(serverURI))
- return;
- if(foreign)
- {
- remoteClient.SendAgentAlertMessage("Please change classifieds on your home grid", true);
- if(uce is not null && uce.classifiedsLists is not null)
- remoteClient.SendAvatarClassifiedReply(remoteClient.AgentId, uce.classifiedsLists);
- return;
- }
- OSDMap parameters = new () { {"creatorId", OSD.FromUUID(creatorId)} };
- OSD osdtmp = parameters;
- if (!rpc.JsonRpcRequest(ref osdtmp, "avatarclassifiedsrequest", serverURI, UUID.Random().ToString()))
- {
- remoteClient.SendAgentAlertMessage("Error fetching classifieds", false);
- return;
- }
- parameters = (OSDMap)osdtmp;
- OSDArray list = (OSDArray)parameters["result"];
- bool exists = list.Cast<OSDMap>().Where(map => map.ContainsKey("classifieduuid"))
- .Any(map => map["classifieduuid"].AsUUID().Equals(queryclassifiedID));
- IMoneyModule money = null;
- if (!exists)
- {
- money = s.RequestModuleInterface<IMoneyModule>();
- if (money is not null)
- {
- if (!money.AmountCovered(remoteClient.AgentId, queryclassifiedPrice))
- {
- remoteClient.SendAgentAlertMessage("You do not have enough money to create this classified.", false);
- if(uce is not null && uce.classifiedsLists is not null)
- remoteClient.SendAvatarClassifiedReply(remoteClient.AgentId, uce.classifiedsLists);
- return;
- }
- }
- }
- UserClassifiedAdd ad = new()
- {
- ParcelName = land == null ? string.Empty : land.LandData.Name,
- CreatorId = remoteClient.AgentId,
- ClassifiedId = queryclassifiedID,
- Category = Convert.ToInt32(queryCategory),
- Name = queryName,
- Description = queryDescription,
- ParentEstate = Convert.ToInt32(queryParentEstate),
- SnapshotId = querySnapshotID,
- SimName = remoteClient.Scene.RegionInfo.RegionName,
- GlobalPos = queryGlobalPos.ToString(),
- Flags = queryclassifiedFlags,
- Price = queryclassifiedPrice,
- ParcelId = p.currentParcelUUID
- };
- object Ad = ad;
- if(!rpc.JsonRpcRequest(ref Ad, "classified_update", serverURI, UUID.Random().ToString()))
- {
- remoteClient.SendAgentAlertMessage("Error updating classified", false);
- if(uce is not null && uce.classifiedsLists is not null)
- remoteClient.SendAvatarClassifiedReply(remoteClient.AgentId, uce.classifiedsLists);
- return;
- }
- // only charge if it worked
- money?.ApplyCharge(remoteClient.AgentId, queryclassifiedPrice, MoneyTransactionType.ClassifiedCharge);
- // just flush cache for now
- lock(m_profilesCache)
- {
- if(m_profilesCache.TryGetValue(remoteClient.AgentId, out uce) && uce is not null)
- {
- uce.classifieds = null;
- uce.classifiedsLists = null;
- }
- }
- }
- /// <summary>
- /// Classifieds delete.
- /// </summary>
- /// <param name='queryClassifiedID'>
- /// Query classified I.
- /// </param>
- /// <param name='remoteClient'>
- /// Remote client.
- /// </param>
- public void ClassifiedDelete(UUID queryClassifiedID, IClientAPI remoteClient)
- {
- bool foreign = GetUserProfileServerURI(remoteClient.AgentId, out string serverURI);
- if(string.IsNullOrWhiteSpace(serverURI))
- return;
- if(foreign)
- {
- remoteClient.SendAgentAlertMessage("Please change classifieds on your home grid", true);
- return;
- }
- if (!UUID.TryParse(queryClassifiedID.ToString(), out UUID classifiedId))
- return;
- OSD Params = new OSDMap() {{ "classifiedId", OSD.FromUUID(classifiedId) }};
- if(!rpc.JsonRpcRequest(ref Params, "classified_delete", serverURI, UUID.Random().ToString()))
- {
- remoteClient.SendAgentAlertMessage(
- "Error deleting classified", false);
- return;
- }
- // flush cache
- lock(m_profilesCache)
- {
- if(m_profilesCache.TryGetValue(remoteClient.AgentId, out UserProfileCacheEntry uce) && uce is not null)
- {
- uce.classifieds = null;
- uce.classifiedsLists = null;
- }
- }
- }
- #endregion Classified
- #region Picks
- /// <summary>
- /// Handles the avatar picks request.
- /// </summary>
- /// <param name='sender'>
- /// Sender.
- /// </param>
- /// <param name='method'>
- /// Method.
- /// </param>
- /// <param name='args'>
- /// Arguments.
- /// </param>
- public void PicksRequest(Object sender, string method, List<String> args)
- {
- if (sender is not IClientAPI remoteClient)
- return;
- if(!UUID.TryParse(args[0], out UUID targetId))
- return;
- Dictionary<UUID, string> picks = new();
- if (targetId.Equals(Constants.m_MrOpenSimID))
- {
- remoteClient.SendAvatarPicksReply(targetId, picks);
- return;
- }
- ScenePresence p = FindPresence(targetId);
- if (p is not null && p.IsNPC)
- {
- remoteClient.SendAvatarPicksReply(targetId, picks);
- return;
- }
- UserProfileCacheEntry uce = null;
- lock(m_profilesCache)
- {
- if(m_profilesCache.TryGetValue(targetId, out uce) && uce is not null)
- {
- if(uce.picksList is not null)
- {
- remoteClient.SendAvatarPicksReply(targetId, uce.picksList);
- return;
- }
- }
- }
- GetUserProfileServerURI(targetId, out string serverURI);
- if(string.IsNullOrWhiteSpace(serverURI))
- {
- remoteClient.SendAvatarPicksReply(targetId, picks);
- return;
- }
- OSDMap parameters= new()
- {
- {"creatorId", OSD.FromUUID(targetId)}
- };
- OSD osdtmp = parameters;
- if(!rpc.JsonRpcRequest(ref osdtmp, "avatarpicksrequest", serverURI, UUID.Random().ToString()))
- {
- remoteClient.SendAvatarPicksReply(targetId, picks);
- return;
- }
- parameters = (OSDMap)osdtmp;
- if(!parameters.TryGetValue("result", out osdtmp) || osdtmp is not OSDArray)
- {
- remoteClient.SendAvatarPicksReply(targetId, picks);
- return;
- }
- OSDArray list = (OSDArray)osdtmp;
- foreach(OSD map in list)
- {
- OSDMap m = (OSDMap)map;
- UUID cid = m["pickuuid"].AsUUID();
- string name = m["name"].AsString();
- picks[cid] = name;
- }
- lock(m_profilesCache)
- {
- if(!m_profilesCache.TryGetValue(targetId, out uce) || uce is null)
- uce = new UserProfileCacheEntry();
- uce.picksList = picks;
- m_profilesCache.AddOrUpdate(targetId, uce, PROFILECACHEEXPIRE);
- }
- remoteClient.SendAvatarPicksReply(targetId, picks);
- }
- /// <summary>
- /// Handles the pick info request.
- /// </summary>
- /// <param name='sender'>
- /// Sender.
- /// </param>
- /// <param name='method'>
- /// Method.
- /// </param>
- /// <param name='args'>
- /// Arguments.
- /// </param>
- public void PickInfoRequest(Object sender, string method, List<String> args)
- {
- if (sender is not IClientAPI)
- return;
- UserProfilePick pick = new();
- if(!UUID.TryParse(args [0], out UUID targetID))
- return;
- pick.CreatorId = targetID;
- if(!UUID.TryParse (args [1], out pick.PickId))
- return;
- IClientAPI remoteClient = (IClientAPI)sender;
- UserProfileCacheEntry uce = null;
- lock(m_profilesCache)
- {
- if(m_profilesCache.TryGetValue(targetID, out uce) && uce is not null)
- {
- if(uce.picks is not null && uce.picks.ContainsKey(pick.PickId))
- {
- pick = uce.picks[pick.PickId];
- if(Vector3.TryParse(pick.GlobalPos, out Vector3 gPos))
- remoteClient.SendPickInfoReply(pick.PickId,pick.CreatorId,pick.TopPick,pick.ParcelId,pick.Name,
- pick.Desc,pick.SnapshotId,pick.ParcelName,pick.OriginalName,pick.SimName,
- gPos,pick.SortOrder,pick.Enabled);
- return;
- }
- }
- }
- bool foreign = GetUserProfileServerURI (targetID, out string serverURI);
- if(string.IsNullOrWhiteSpace(serverURI))
- {
- return;
- }
- object Pick = (object)pick;
- if (!rpc.JsonRpcRequest (ref Pick, "pickinforequest", serverURI, UUID.Random ().ToString ())) {
- remoteClient.SendAgentAlertMessage ("Error selecting pick", false);
- return;
- }
- pick = (UserProfilePick)Pick;
- if(foreign)
- cacheForeignImage(targetID, pick.SnapshotId);
- if(!Vector3.TryParse(pick.GlobalPos, out Vector3 globalPos))
- return;
- if (m_thisGridInfo.IsLocalGrid(pick.Gatekeeper, true) == 0)
- {
- // Setup the illusion
- string region = string.Format("{0} {1}",pick.Gatekeeper,pick.SimName);
- GridRegion target = Scene.GridService.GetRegionByName(Scene.RegionInfo.ScopeID, region);
- if(target is null)
- {
- // This is a unreachable region
- }
- else
- {
- // we have a proxy on map
- if (Util.ParseFakeParcelID(pick.ParcelId, out ulong _, out uint oriX, out uint oriY))
- {
- pick.ParcelId = Util.BuildFakeParcelID(target.RegionHandle, oriX, oriY);
- globalPos.X = target.RegionLocX + oriX;
- globalPos.Y = target.RegionLocY + oriY;
- pick.GlobalPos = globalPos.ToString();
- }
- else
- {
- // this is a fail on large regions
- uint gtmp = (uint)globalPos.X >> 8;
- globalPos.X -= (gtmp << 8);
- gtmp = (uint)globalPos.Y >> 8;
- globalPos.Y -= (gtmp << 8);
- pick.ParcelId = Util.BuildFakeParcelID(target.RegionHandle, (uint)globalPos.X, (uint)globalPos.Y);
- globalPos.X += target.RegionLocX;
- globalPos.Y += target.RegionLocY;
- pick.GlobalPos = globalPos.ToString();
- }
- }
- }
- //m_log.DebugFormat("[PROFILES]: PickInfoRequest: {0} : {1}", pick.Name.ToString(), pick.SnapshotId.ToString());
- lock(m_profilesCache)
- {
- if(!m_profilesCache.TryGetValue(targetID, out uce) || uce is null)
- uce = new UserProfileCacheEntry();
- uce.picks ??= new Dictionary<UUID, UserProfilePick>();
- uce.picks[pick.PickId] = pick;
- m_profilesCache.AddOrUpdate(targetID, uce, PROFILECACHEEXPIRE);
- }
- // Pull the rabbit out of the hat
- remoteClient.SendPickInfoReply(pick.PickId,pick.CreatorId,pick.TopPick,pick.ParcelId,pick.Name,
- pick.Desc,pick.SnapshotId,pick.ParcelName,pick.OriginalName,pick.SimName,
- globalPos,pick.SortOrder,pick.Enabled);
- }
- /// <summary>
- /// Updates the userpicks
- /// </summary>
- /// <param name='remoteClient'>
- /// Remote client.
- /// </param>
- /// <param name='pickID'>
- /// Pick I.
- /// </param>
- /// <param name='creatorID'>
- /// the creator of the pick
- /// </param>
- /// <param name='topPick'>
- /// Top pick.
- /// </param>
- /// <param name='name'>
- /// Name.
- /// </param>
- /// <param name='desc'>
- /// Desc.
- /// </param>
- /// <param name='snapshotID'>
- /// Snapshot I.
- /// </param>
- /// <param name='sortOrder'>
- /// Sort order.
- /// </param>
- /// <param name='enabled'>
- /// Enabled.
- /// </param>
- public void PickInfoUpdate(IClientAPI remoteClient, UUID pickID, UUID creatorID, bool topPick, string name, string desc, UUID snapshotID, int sortOrder, bool enabled)
- {
- //m_log.DebugFormat("[PROFILES]: Start PickInfoUpdate Name: {0} PickId: {1} SnapshotId: {2}", name, pickID.ToString(), snapshotID.ToString());
- UserProfilePick pick = new();
- GetUserProfileServerURI(remoteClient.AgentId, out string serverURI);
- if(string.IsNullOrWhiteSpace(serverURI))
- return;
- ScenePresence p = FindPresence(remoteClient.AgentId);
- Vector3 avaPos = p.AbsolutePosition;
- // Getting the global position for the Avatar
- Vector3 posGlobal = new(remoteClient.Scene.RegionInfo.WorldLocX + avaPos.X,
- remoteClient.Scene.RegionInfo.WorldLocY + avaPos.Y,
- avaPos.Z);
- string landParcelName = "My Parcel";
- // to locate parcels we use a fake id that encodes the region handle
- // since we do not have a global locator
- // this fails on HG
- UUID landParcelID = Util.BuildFakeParcelID(remoteClient.Scene.RegionInfo.RegionHandle, (uint)avaPos.X, (uint)avaPos.Y);
- ILandObject land = p.Scene.LandChannel.GetLandObject(avaPos.X, avaPos.Y);
- if (land is not null)
- {
- // If land found, use parcel uuid from here because the value from SP will be blank if the avatar hasnt moved
- landParcelName = land.LandData.Name;
- }
- else
- {
- m_log.WarnFormat(
- "[PROFILES]: PickInfoUpdate found no parcel info at {0},{1} in {2}",
- avaPos.X, avaPos.Y, p.Scene.Name);
- }
- pick.PickId = pickID;
- pick.CreatorId = creatorID;
- pick.TopPick = topPick;
- pick.Name = name;
- pick.Desc = desc;
- pick.ParcelId = landParcelID;
- pick.SnapshotId = snapshotID;
- pick.ParcelName = landParcelName;
- pick.SimName = remoteClient.Scene.RegionInfo.RegionName;
- pick.Gatekeeper = m_thisGridInfo.GateKeeperURLNoEndSlash;
- pick.GlobalPos = posGlobal.ToString();
- pick.SortOrder = sortOrder;
- pick.Enabled = enabled;
- object Pick = (object)pick;
- if(!rpc.JsonRpcRequest(ref Pick, "picks_update", serverURI, UUID.Random().ToString()))
- {
- remoteClient.SendAgentAlertMessage(
- "Error updating pick", false);
- return;
- }
- UserProfileCacheEntry uce = null;
- lock(m_profilesCache)
- {
- if(!m_profilesCache.TryGetValue(remoteClient.AgentId, out uce) || uce is null)
- uce = new UserProfileCacheEntry();
- uce.picks ??= new Dictionary<UUID, UserProfilePick>();
- uce.picksList ??= new Dictionary<UUID, string>();
- uce.picks[pick.PickId] = pick;
- uce.picksList[pick.PickId] = pick.Name;
- m_profilesCache.AddOrUpdate(remoteClient.AgentId, uce, PROFILECACHEEXPIRE);
- }
- remoteClient.SendAvatarPicksReply(remoteClient.AgentId, uce.picksList);
- remoteClient.SendPickInfoReply(pick.PickId,pick.CreatorId,pick.TopPick,pick.ParcelId,pick.Name,
- pick.Desc,pick.SnapshotId,pick.ParcelName,pick.OriginalName,pick.SimName,
- posGlobal,pick.SortOrder,pick.Enabled);
- //m_log.DebugFormat("[PROFILES]: Finish PickInfoUpdate {0} {1}", pick.Name, pick.PickId.ToString());
- }
- /// <summary>
- /// Delete a Pick
- /// </summary>
- /// <param name='remoteClient'>
- /// Remote client.
- /// </param>
- /// <param name='queryPickID'>
- /// Query pick I.
- /// </param>
- public void PickDelete(IClientAPI remoteClient, UUID queryPickID)
- {
- GetUserProfileServerURI(remoteClient.AgentId, out string serverURI);
- if(string.IsNullOrWhiteSpace(serverURI))
- {
- return;
- }
- OSDMap parameters = new() { { "pickId", OSD.FromUUID(queryPickID) } };
- OSD Params = (OSD)parameters;
- if(!rpc.JsonRpcRequest(ref Params, "picks_delete", serverURI, UUID.Random().ToString()))
- {
- remoteClient.SendAgentAlertMessage(
- "Error picks delete", false);
- return;
- }
- UserProfileCacheEntry uce = null;
- lock(m_profilesCache)
- {
- if(m_profilesCache.TryGetValue(remoteClient.AgentId, out uce) && uce is not null)
- {
- uce.picks?.Remove(queryPickID);
- uce.picksList?.Remove(queryPickID);
- m_profilesCache.AddOrUpdate(remoteClient.AgentId, uce, PROFILECACHEEXPIRE);
- }
- }
- if(uce is not null && uce.picksList is not null)
- remoteClient.SendAvatarPicksReply(remoteClient.AgentId, uce.picksList);
- else
- remoteClient.SendAvatarPicksReply(remoteClient.AgentId, new Dictionary<UUID, string>());
- }
- #endregion Picks
- #region Notes
- /// <summary>
- /// Handles the avatar notes request.
- /// </summary>
- /// <param name='sender'>
- /// Sender.
- /// </param>
- /// <param name='method'>
- /// Method.
- /// </param>
- /// <param name='args'>
- /// Arguments.
- /// </param>
- public void NotesRequest(Object sender, string method, List<String> args)
- {
- if (sender is not IClientAPI remoteClient)
- return;
- UserProfileNotes note = new();
- if (!UUID.TryParse(args[0], out note.TargetId))
- return;
- note.UserId = remoteClient.AgentId;
- GetUserProfileServerURI(remoteClient.AgentId, out string serverURI);
- if(string.IsNullOrWhiteSpace(serverURI))
- {
- remoteClient.SendAvatarNotesReply(note.TargetId, note.Notes);
- return;
- }
- object Note = (object)note;
- if(!rpc.JsonRpcRequest(ref Note, "avatarnotesrequest", serverURI, UUID.Random().ToString()))
- {
- remoteClient.SendAvatarNotesReply(note.TargetId, note.Notes);
- return;
- }
- note = (UserProfileNotes) Note;
- remoteClient.SendAvatarNotesReply(note.TargetId, note.Notes);
- }
- /// <summary>
- /// Avatars the notes update.
- /// </summary>
- /// <param name='remoteClient'>
- /// Remote client.
- /// </param>
- /// <param name='queryTargetID'>
- /// Query target I.
- /// </param>
- /// <param name='queryNotes'>
- /// Query notes.
- /// </param>
- public void NotesUpdate(IClientAPI remoteClient, UUID queryTargetID, string queryNotes)
- {
- if (queryTargetID.Equals(Constants.m_MrOpenSimID))
- return;
- ScenePresence p = FindPresence(queryTargetID);
- if (p is not null && p.IsNPC)
- {
- remoteClient.SendAgentAlertMessage("Notes for NPCs not available", false);
- return;
- }
- UserProfileNotes note = new()
- {
- UserId = remoteClient.AgentId,
- TargetId = queryTargetID,
- Notes = queryNotes
- };
- GetUserProfileServerURI(remoteClient.AgentId, out string serverURI);
- if(string.IsNullOrWhiteSpace(serverURI))
- return;
- object Note = note;
- if(!rpc.JsonRpcRequest(ref Note, "avatar_notes_update", serverURI, UUID.Random().ToString()))
- {
- remoteClient.SendAgentAlertMessage(
- "Error updating note", false);
- return;
- }
- }
- #endregion Notes
- #region User Preferences
- /// <summary>
- /// Updates the user preferences.
- /// </summary>
- /// <param name='imViaEmail'>
- /// Im via email.
- /// </param>
- /// <param name='visible'>
- /// Visible.
- /// </param>
- /// <param name='remoteClient'>
- /// Remote client.
- /// </param>
- public void UpdateUserPreferences(bool imViaEmail, bool visible, IClientAPI remoteClient)
- {
- UserPreferences pref = new()
- {
- UserId = remoteClient.AgentId,
- IMViaEmail = imViaEmail,
- Visible = visible
- };
- _ = GetUserProfileServerURI(remoteClient.AgentId, out string serverURI);
- if(string.IsNullOrWhiteSpace(serverURI))
- return;
- object Pref = pref;
- if(!rpc.JsonRpcRequest(ref Pref, "user_preferences_update", serverURI, UUID.Random().ToString()))
- {
- m_log.InfoFormat("[PROFILES]: UserPreferences update error");
- remoteClient.SendAgentAlertMessage("Error updating preferences", false);
- return;
- }
- }
- /// <summary>
- /// Users the preferences request.
- /// </summary>
- /// <param name='remoteClient'>
- /// Remote client.
- /// </param>
- public void UserPreferencesRequest(IClientAPI remoteClient)
- {
- GetUserProfileServerURI(remoteClient.AgentId, out string serverURI);
- if(string.IsNullOrWhiteSpace(serverURI))
- return;
- UserPreferences pref = new() { UserId = remoteClient.AgentId };
- object Pref = (object)pref;
- if(!rpc.JsonRpcRequest(ref Pref, "user_preferences_request", serverURI, UUID.Random().ToString()))
- {
- //m_log.InfoFormat("[PROFILES]: UserPreferences request error");
- //remoteClient.SendAgentAlertMessage("Error requesting preferences", false);
- return;
- }
- pref = (UserPreferences) Pref;
- remoteClient.SendUserInfoReply(pref.IMViaEmail, pref.Visible, pref.EMail);
- }
- #endregion User Preferences
- #region Avatar Properties
- /// <summary>
- /// Update the avatars interests .
- /// </summary>
- /// <param name='remoteClient'>
- /// Remote client.
- /// </param>
- /// <param name='wantmask'>
- /// Wantmask.
- /// </param>
- /// <param name='wanttext'>
- /// Wanttext.
- /// </param>
- /// <param name='skillsmask'>
- /// Skillsmask.
- /// </param>
- /// <param name='skillstext'>
- /// Skillstext.
- /// </param>
- /// <param name='languages'>
- /// Languages.
- /// </param>
- public void AvatarInterestsUpdate(IClientAPI remoteClient, uint wantmask, string wanttext, uint skillsmask, string skillstext, string languages)
- {
- GetUserProfileServerURI(remoteClient.AgentId, out string serverURI);
- if (string.IsNullOrWhiteSpace(serverURI))
- return;
- object Param = new UserProfileProperties()
- {
- UserId = remoteClient.AgentId,
- WantToMask = (int)wantmask,
- WantToText = wanttext,
- SkillsMask = (int)skillsmask,
- SkillsText = skillstext,
- Language = languages
- };
- if(!rpc.JsonRpcRequest(ref Param, "avatar_interests_update", serverURI, UUID.Random().ToString()))
- {
- remoteClient.SendAgentAlertMessage("Error updating interests", false);
- return;
- }
- // flush cache
- lock(m_profilesCache)
- {
- if(m_profilesCache.TryGetValue(remoteClient.AgentId, out UserProfileCacheEntry uce) && uce is not null)
- {
- uce.props = null;
- uce.ClientsWaitingProps = null;
- }
- }
- RequestAvatarProperties(remoteClient, remoteClient.AgentId);
- }
- public void RequestAvatarProperties(IClientAPI remoteClient, UUID avatarID)
- {
- if (avatarID.IsZero())
- {
- // Looking for a reason that some viewers are sending null Id's
- m_log.Debug("[PROFILES]: got request of null ID");
- return;
- }
- if (avatarID.Equals(Constants.m_MrOpenSimID))
- {
- remoteClient.SendAvatarProperties(avatarID, "Creator of OpenSimulator shared assets library", Constants.m_MrOpenSimBorn.ToString(),
- Utils.StringToBytes("System agent"), "MrOpenSim has no life", 0x10,
- UUID.Zero, UUID.Zero, "", UUID.Zero);
- remoteClient.SendAvatarInterestsReply(avatarID, 0, "",
- 0, "Getting into trouble", "Droidspeak");
- return;
- }
- ScenePresence p = FindPresence(avatarID);
- if (p is not null && p.IsNPC)
- {
- remoteClient.SendAvatarProperties(avatarID, ((INPC)(p.ControllingClient)).profileAbout, ((INPC)(p.ControllingClient)).Born,
- Utils.StringToBytes("Non Player Character (NPC)"), "NPCs have no life", 0x10,
- UUID.Zero, ((INPC)(p.ControllingClient)).profileImage, "", UUID.Zero);
- remoteClient.SendAvatarInterestsReply(avatarID, 0, "",
- 0, "Getting into trouble", "Droidspeak");
- return;
- }
- UserProfileProperties props;
- lock(m_profilesCache)
- {
- if(m_profilesCache.TryGetValue(avatarID, out UserProfileCacheEntry uce) && uce is not null)
- {
- if(uce.props is not null)
- {
- props = uce.props;
- uint cflags = uce.flags;
- if (IsFriendOnline(remoteClient, avatarID))
- cflags = (uint)ProfileFlags.Online;
- else
- cflags &= (uint)~ProfileFlags.Online;
- remoteClient.SendAvatarProperties(props.UserId, props.AboutText,
- uce.born, uce.membershipType , props.FirstLifeText, cflags,
- props.FirstLifeImageId, props.ImageId, props.WebUrl, props.PartnerId);
- remoteClient.SendAvatarInterestsReply(props.UserId, (uint)props.WantToMask,
- props.WantToText, (uint)props.SkillsMask,
- props.SkillsText, props.Language);
- if(uce.avatarGroups is not null)
- remoteClient.SendAvatarGroupsReply(avatarID, uce.avatarGroups);
- return;
- }
- else
- {
- if(uce.ClientsWaitingProps == null)
- uce.ClientsWaitingProps = new HashSet<IClientAPI>();
- else if(uce.ClientsWaitingProps.Contains(remoteClient))
- return;
- uce.ClientsWaitingProps.Add(remoteClient);
- }
- }
- else
- {
- uce = new UserProfileCacheEntry { ClientsWaitingProps = new HashSet<IClientAPI>() };
- uce.ClientsWaitingProps.Add(remoteClient);
- m_profilesCache.AddOrUpdate(avatarID, uce, PROFILECACHEEXPIRE);
- }
- }
- AsyncPropsRequest req = new()
- {
- client = remoteClient,
- presence = p,
- agent = avatarID,
- reqtype = 0
- };
- m_asyncRequests.Push(req);
- if (Monitor.TryEnter(m_asyncRequestsLock))
- {
- if (!m_asyncRequestsRunning)
- {
- m_asyncRequestsRunning = true;
- Util.FireAndForget(x => ProcessRequests());
- }
- Monitor.Exit(m_asyncRequestsLock);
- }
- /*
- string serverURI = string.Empty;
- bool foreign = GetUserProfileServerURI(avatarID, out serverURI);
- UserAccount account = null;
- Dictionary<string,object> userInfo;
- if (!foreign)
- {
- account = Scene.UserAccountService.GetUserAccount(Scene.RegionInfo.ScopeID, avatarID);
- }
- else
- {
- userInfo = new Dictionary<string, object>();
- }
- Byte[] membershipType = new Byte[1];
- string born = string.Empty;
- uint flags = 0x00;
- if (null != account)
- {
- if (account.UserTitle.Length == 0)
- membershipType[0] = (Byte)((account.UserFlags & 0xf00) >> 8);
- else
- membershipType = Utils.StringToBytes(account.UserTitle);
- born = Util.ToDateTime(account.Created).ToString(
- "M/d/yyyy", CultureInfo.InvariantCulture);
- flags = (uint)(account.UserFlags & 0xff);
- }
- else
- {
- if (GetUserAccountData(avatarID, out userInfo) == true)
- {
- if ((string)userInfo["user_title"].Length == 0)
- membershipType[0] = (Byte)(((Byte)userInfo["user_flags"] & 0xf00) >> 8);
- else
- membershipType = Utils.StringToBytes((string)userInfo["user_title"]);
- int val_born = (int)userInfo["user_created"];
- if(val_born != 0)
- born = Util.ToDateTime(val_born).ToString(
- "M/d/yyyy", CultureInfo.InvariantCulture);
- // picky, picky
- int val_flags = (int)userInfo["user_flags"];
- flags = (uint)(val_flags & 0xff);
- }
- }
- props = new UserProfileProperties();
- props.UserId = avatarID;
- string result = string.Empty;
- if(!GetProfileData(ref props, foreign, serverURI, out result))
- {
- props.AboutText ="Profile not available at this time. User may still be unknown to this grid";
- }
- if(!m_allowUserProfileWebURLs)
- props.WebUrl ="";
- HashSet<IClientAPI> clients;
- lock(m_profilesCache)
- {
- if(!m_profilesCache.TryGetValue(props.UserId, out uce) || uce == null)
- uce = new UserProfileCacheEntry();
- uce.props = props;
- uce.born = born;
- uce.membershipType = membershipType;
- uce.flags = flags;
- clients = uce.ClientsWaitingProps;
- uce.ClientsWaitingProps = null;
- m_profilesCache.AddOrUpdate(props.UserId, uce, PROFILECACHEEXPIRE);
- }
- // if on same region force online
- if(p != null && !p.IsDeleted)
- flags |= 0x10;
- if(clients == null)
- {
- remoteClient.SendAvatarProperties(props.UserId, props.AboutText, born, membershipType , props.FirstLifeText, flags,
- props.FirstLifeImageId, props.ImageId, props.WebUrl, props.PartnerId);
- remoteClient.SendAvatarInterestsReply(props.UserId, (uint)props.WantToMask, props.WantToText,
- (uint)props.SkillsMask, props.SkillsText, props.Language);
- }
- else
- {
- if(!clients.Contains(remoteClient))
- clients.Add(remoteClient);
- foreach(IClientAPI cli in clients)
- {
- if(!cli.IsActive)
- continue;
- cli.SendAvatarProperties(props.UserId, props.AboutText, born, membershipType , props.FirstLifeText, flags,
- props.FirstLifeImageId, props.ImageId, props.WebUrl, props.PartnerId);
- cli.SendAvatarInterestsReply(props.UserId, (uint)props.WantToMask, props.WantToText,
- (uint)props.SkillsMask, props.SkillsText, props.Language);
- }
- }
- */
- }
- /// <summary>
- /// Updates the avatar properties.
- /// </summary>
- /// <param name='remoteClient'>
- /// Remote client.
- /// </param>
- /// <param name='newProfile'>
- /// New profile.
- /// </param>
- public void AvatarPropertiesUpdate(IClientAPI remoteClient, UserProfileProperties newProfile)
- {
- GetUserProfileServerURI(remoteClient.AgentId, out string serverURI);
- if (string.IsNullOrWhiteSpace(serverURI))
- return;
- if (!m_allowUserProfileWebURLs)
- newProfile.WebUrl = string.Empty;
- object Prop = newProfile;
- if(!rpc.JsonRpcRequest(ref Prop, "avatar_properties_update", serverURI, UUID.Random().ToString()))
- {
- remoteClient.SendAgentAlertMessage("Error updating properties", false);
- return;
- }
- // flush cache
- lock(m_profilesCache)
- {
- if(m_profilesCache.TryGetValue(remoteClient.AgentId, out UserProfileCacheEntry uce) && uce is not null)
- {
- uce.props = null;
- uce.ClientsWaitingProps = null;
- }
- }
- RequestAvatarProperties(remoteClient, remoteClient.AgentId);
- }
- /// <summary>
- /// Gets the profile data.
- /// </summary>
- /// <returns>
- /// The profile data.
- /// </returns>
- bool GetProfileData(ref UserProfileProperties properties, bool foreign, string serverURI, out string message)
- {
- if (String.IsNullOrEmpty(serverURI))
- {
- message = "User profile service unknown at this time";
- return false;
- }
- object Prop = properties;
- if (!rpc.JsonRpcRequest(ref Prop, "avatar_properties_request", serverURI, UUID.Random().ToString()))
- {
- // If it's a foreign user then try again using OpenProfile, in case that's what the grid is using
- bool secondChanceSuccess = false;
- if (foreign)
- {
- try
- {
- OpenProfileClient client = new(serverURI);
- if (client.RequestAvatarPropertiesUsingOpenProfile(ref properties))
- secondChanceSuccess = true;
- }
- catch (Exception e)
- {
- m_log.Debug(
- $"[PROFILES]: Request using the OpenProfile API for user {properties.UserId} to {serverURI} failed: {e.Message}");
- // Allow the return 'message' to say "JsonRpcRequest" and not "OpenProfile", because
- // the most likely reason that OpenProfile failed is that the remote server
- // doesn't support OpenProfile, and that's not very interesting.
- }
- }
- if (!secondChanceSuccess)
- {
- message = $"JsonRpcRequest for user {properties.UserId} to {serverURI} failed";
- m_log.Debug($"[PROFILES]: {message}");
- return false;
- }
- }
- properties = (UserProfileProperties)Prop;
- if(foreign)
- {
- cacheForeignImage(properties.UserId, properties.ImageId);
- cacheForeignImage(properties.UserId, properties.FirstLifeImageId);
- }
- message = "Success";
- return true;
- }
- #endregion Avatar Properties
- #region Utils
- /// <summary>
- /// Gets the user account data.
- /// </summary>
- /// <returns>
- /// The user profile data.
- /// </returns>
- /// <param name='userID'>
- /// If set to <c>true</c> user I.
- /// </param>
- /// <param name='userInfo'>
- /// If set to <c>true</c> user info.
- /// </param>
- bool GetUserAccountData(UUID userID, out UserAccount account)
- {
- account = null;
- if (UserManagementModule.IsLocalGridUser(userID))
- {
- // Is local
- IUserAccountService uas = Scene.UserAccountService;
- account = uas.GetUserAccount(Scene.RegionInfo.ScopeID, userID);
- return account is not null;
- }
- else
- {
- // Is Foreign
- string home_url = UserManagementModule.GetUserServerURL(userID, "HomeURI", out bool recentFailedWeb);
- if (recentFailedWeb || String.IsNullOrEmpty(home_url))
- return false;
- UserAgentServiceConnector uConn = new(home_url);
- Dictionary<string, object> info;
- try
- {
- info = uConn.GetUserInfo(userID);
- }
- catch (Exception e)
- {
- m_log.Debug("[PROFILES]: GetUserInfo call failed ", e);
- UserManagementModule.UserWebFailed(userID);
- return false;
- }
- if (info.Count == 0)
- return false;
- account = new UserAccount();
- if (info.ContainsKey("user_flags"))
- account.UserFlags = (int)info["user_flags"];
- if (info.ContainsKey("user_created"))
- account.Created = (int)info["user_created"];
- account.UserTitle = "HG Visitor";
- return true;
- }
- }
- /// <summary>
- /// Gets the user profile server UR.
- /// </summary>
- /// <returns>
- /// The user profile server UR.
- /// </returns>
- /// <param name='userID'>
- /// If set to <c>true</c> user I.
- /// </param>
- /// <param name='serverURI'>
- /// If set to <c>true</c> server UR.
- /// </param>
- bool GetUserProfileServerURI(UUID userID, out string serverURI)
- {
- if (!UserManagementModule.IsLocalGridUser(userID))
- {
- serverURI = UserManagementModule.GetUserServerURL(userID, "ProfileServerURI", out bool failed);
- if(failed)
- serverURI = string.Empty;
- // Is Foreign
- return true;
- }
- else
- {
- serverURI = ProfileServerUri;
- // Is local
- return false;
- }
- }
- void cacheForeignImage(UUID agent, UUID imageID)
- {
- if(imageID.IsZero())
- return;
- string assetServerURI = UserManagementModule.GetUserServerURL(agent, "AssetServerURI");
- if(string.IsNullOrWhiteSpace(assetServerURI))
- return;
- Scene.AssetService.Get(imageID.ToString(), assetServerURI, false);
- }
- /// <summary>
- /// Finds the presence.
- /// </summary>
- /// <returns>
- /// The presence.
- /// </returns>
- /// <param name='clientID'>
- /// Client I.
- /// </param>
- ScenePresence FindPresence(UUID clientID)
- {
- ScenePresence p = Scene.GetScenePresence(clientID);
- if (p is not null && !p.IsChildAgent)
- return p;
- return null;
- }
- public virtual bool IsFriendOnline(IClientAPI client, UUID agent)
- {
- // if on same region force online
- ScenePresence p = Scene.GetScenePresence(agent);
- if (p is not null && !p.IsChildAgent && !p.IsDeleted)
- return true;
- IFriendsModule friendsModule = Scene.RequestModuleInterface<IFriendsModule>();
- if (friendsModule is not null && friendsModule.IsFriendOnline(client.AgentId, agent))
- return true;
- if(client.SceneAgent is ScenePresence sp && sp.IsViewerUIGod)
- {
- Services.Interfaces.PresenceInfo[] pi = Scene.PresenceService?.GetAgents(new string[] { agent.ToString() });
- return pi is not null && pi.Length > 0;
- }
- return false;
- }
-
- #endregion Util
- #region Web Util
- /// <summary>
- /// Sends json-rpc request with a serializable type.
- /// </summary>
- /// <returns>
- /// OSD Map.
- /// </returns>
- /// <param name='parameters'>
- /// Serializable type .
- /// </param>
- /// <param name='method'>
- /// Json-rpc method to call.
- /// </param>
- /// <param name='uri'>
- /// URI of json-rpc service.
- /// </param>
- /// <param name='jsonId'>
- /// Id for our call.
- /// </param>
- bool JsonRpcRequest(ref object parameters, string method, string uri, string jsonId)
- {
- return rpc?.JsonRpcRequest(ref parameters, method, uri, jsonId) ?? false;
- }
- /// <summary>
- /// Sends json-rpc request with OSD parameter.
- /// </summary>
- /// <returns>
- /// The rpc request.
- /// </returns>
- /// <param name='data'>
- /// data - incoming as parameters, outgong as result/error
- /// </param>
- /// <param name='method'>
- /// Json-rpc method to call.
- /// </param>
- /// <param name='uri'>
- /// URI of json-rpc service.
- /// </param>
- /// <param name='jsonId'>
- /// If set to <c>true</c> json identifier.
- /// </param>
- bool JsonRpcRequest(ref OSD data, string method, string uri, string jsonId)
- {
- return rpc?.JsonRpcRequest(ref data, method, uri, jsonId) ?? false;
- }
- #endregion Web Util
- }
- }
|