diff options
author | Jeff Ames | 2009-06-09 17:48:22 +0000 |
---|---|---|
committer | Jeff Ames | 2009-06-09 17:48:22 +0000 |
commit | 135ff63c3dd2a2c68351669afbd2f57c2fe64d2d (patch) | |
tree | 4bb44c0e0a61289d6405de30eb140b8a7b1f6e42 /OpenSim/Server/Handlers | |
parent | ARGH!!!! note to self: ALWAYS use String.IsNullOrEmpty(...)! (diff) | |
download | opensim-SC-135ff63c3dd2a2c68351669afbd2f57c2fe64d2d.zip opensim-SC-135ff63c3dd2a2c68351669afbd2f57c2fe64d2d.tar.gz opensim-SC-135ff63c3dd2a2c68351669afbd2f57c2fe64d2d.tar.bz2 opensim-SC-135ff63c3dd2a2c68351669afbd2f57c2fe64d2d.tar.xz |
Update svn properties.
Diffstat (limited to 'OpenSim/Server/Handlers')
-rw-r--r-- | OpenSim/Server/Handlers/Inventory/InventoryServerInConnector.cs | 552 |
1 files changed, 276 insertions, 276 deletions
diff --git a/OpenSim/Server/Handlers/Inventory/InventoryServerInConnector.cs b/OpenSim/Server/Handlers/Inventory/InventoryServerInConnector.cs index c8d08de..3e3064a 100644 --- a/OpenSim/Server/Handlers/Inventory/InventoryServerInConnector.cs +++ b/OpenSim/Server/Handlers/Inventory/InventoryServerInConnector.cs | |||
@@ -1,276 +1,276 @@ | |||
1 | /* | 1 | /* |
2 | * Copyright (c) Contributors, http://opensimulator.org/ | 2 | * Copyright (c) Contributors, http://opensimulator.org/ |
3 | * See CONTRIBUTORS.TXT for a full list of copyright holders. | 3 | * See CONTRIBUTORS.TXT for a full list of copyright holders. |
4 | * | 4 | * |
5 | * Redistribution and use in source and binary forms, with or without | 5 | * Redistribution and use in source and binary forms, with or without |
6 | * modification, are permitted provided that the following conditions are met: | 6 | * modification, are permitted provided that the following conditions are met: |
7 | * * Redistributions of source code must retain the above copyright | 7 | * * Redistributions of source code must retain the above copyright |
8 | * notice, this list of conditions and the following disclaimer. | 8 | * notice, this list of conditions and the following disclaimer. |
9 | * * Redistributions in binary form must reproduce the above copyright | 9 | * * Redistributions in binary form must reproduce the above copyright |
10 | * notice, this list of conditions and the following disclaimer in the | 10 | * notice, this list of conditions and the following disclaimer in the |
11 | * documentation and/or other materials provided with the distribution. | 11 | * documentation and/or other materials provided with the distribution. |
12 | * * Neither the name of the OpenSimulator Project nor the | 12 | * * Neither the name of the OpenSimulator Project nor the |
13 | * names of its contributors may be used to endorse or promote products | 13 | * names of its contributors may be used to endorse or promote products |
14 | * derived from this software without specific prior written permission. | 14 | * derived from this software without specific prior written permission. |
15 | * | 15 | * |
16 | * THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS'' AND ANY | 16 | * THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS'' AND ANY |
17 | * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED | 17 | * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED |
18 | * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE | 18 | * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE |
19 | * DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY | 19 | * DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY |
20 | * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES | 20 | * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES |
21 | * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; | 21 | * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; |
22 | * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND | 22 | * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND |
23 | * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT | 23 | * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
24 | * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS | 24 | * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS |
25 | * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. | 25 | * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
26 | */ | 26 | */ |
27 | 27 | ||
28 | using System; | 28 | using System; |
29 | using System.Collections; | 29 | using System.Collections; |
30 | using System.Collections.Generic; | 30 | using System.Collections.Generic; |
31 | using System.Net; | 31 | using System.Net; |
32 | using System.Reflection; | 32 | using System.Reflection; |
33 | using log4net; | 33 | using log4net; |
34 | using Nini.Config; | 34 | using Nini.Config; |
35 | using Nwc.XmlRpc; | 35 | using Nwc.XmlRpc; |
36 | using OpenSim.Server.Base; | 36 | using OpenSim.Server.Base; |
37 | using OpenSim.Services.Interfaces; | 37 | using OpenSim.Services.Interfaces; |
38 | using OpenSim.Framework; | 38 | using OpenSim.Framework; |
39 | using OpenSim.Framework.Servers.HttpServer; | 39 | using OpenSim.Framework.Servers.HttpServer; |
40 | using OpenSim.Server.Handlers.Base; | 40 | using OpenSim.Server.Handlers.Base; |
41 | using OpenMetaverse; | 41 | using OpenMetaverse; |
42 | 42 | ||
43 | namespace OpenSim.Server.Handlers.Inventory | 43 | namespace OpenSim.Server.Handlers.Inventory |
44 | { | 44 | { |
45 | public class InventoryServiceInConnector : ServiceConnector | 45 | public class InventoryServiceInConnector : ServiceConnector |
46 | { | 46 | { |
47 | private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType); | 47 | private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType); |
48 | 48 | ||
49 | private IInventoryService m_InventoryService; | 49 | private IInventoryService m_InventoryService; |
50 | 50 | ||
51 | private bool m_doLookup = false; | 51 | private bool m_doLookup = false; |
52 | 52 | ||
53 | //private static readonly int INVENTORY_DEFAULT_SESSION_TIME = 30; // secs | 53 | //private static readonly int INVENTORY_DEFAULT_SESSION_TIME = 30; // secs |
54 | //private AuthedSessionCache m_session_cache = new AuthedSessionCache(INVENTORY_DEFAULT_SESSION_TIME); | 54 | //private AuthedSessionCache m_session_cache = new AuthedSessionCache(INVENTORY_DEFAULT_SESSION_TIME); |
55 | 55 | ||
56 | private string m_userserver_url; | 56 | private string m_userserver_url; |
57 | 57 | ||
58 | public InventoryServiceInConnector(IConfigSource config, IHttpServer server) : | 58 | public InventoryServiceInConnector(IConfigSource config, IHttpServer server) : |
59 | base(config, server) | 59 | base(config, server) |
60 | { | 60 | { |
61 | IConfig serverConfig = config.Configs["InventoryService"]; | 61 | IConfig serverConfig = config.Configs["InventoryService"]; |
62 | if (serverConfig == null) | 62 | if (serverConfig == null) |
63 | throw new Exception("No section 'InventoryService' in config file"); | 63 | throw new Exception("No section 'InventoryService' in config file"); |
64 | 64 | ||
65 | string inventoryService = serverConfig.GetString("LocalServiceModule", | 65 | string inventoryService = serverConfig.GetString("LocalServiceModule", |
66 | String.Empty); | 66 | String.Empty); |
67 | 67 | ||
68 | if (inventoryService == String.Empty) | 68 | if (inventoryService == String.Empty) |
69 | throw new Exception("No InventoryService in config file"); | 69 | throw new Exception("No InventoryService in config file"); |
70 | 70 | ||
71 | Object[] args = new Object[] { config }; | 71 | Object[] args = new Object[] { config }; |
72 | m_InventoryService = | 72 | m_InventoryService = |
73 | ServerUtils.LoadPlugin<IInventoryService>(inventoryService, args); | 73 | ServerUtils.LoadPlugin<IInventoryService>(inventoryService, args); |
74 | 74 | ||
75 | m_userserver_url = serverConfig.GetString("UserServerURI", String.Empty); | 75 | m_userserver_url = serverConfig.GetString("UserServerURI", String.Empty); |
76 | m_doLookup = serverConfig.GetBoolean("SessionAuthentication", false); | 76 | m_doLookup = serverConfig.GetBoolean("SessionAuthentication", false); |
77 | 77 | ||
78 | AddHttpHandlers(server); | 78 | AddHttpHandlers(server); |
79 | } | 79 | } |
80 | 80 | ||
81 | protected virtual void AddHttpHandlers(IHttpServer m_httpServer) | 81 | protected virtual void AddHttpHandlers(IHttpServer m_httpServer) |
82 | { | 82 | { |
83 | m_httpServer.AddStreamHandler( | 83 | m_httpServer.AddStreamHandler( |
84 | new RestDeserialiseSecureHandler<Guid, InventoryCollection>( | 84 | new RestDeserialiseSecureHandler<Guid, InventoryCollection>( |
85 | "POST", "/GetInventory/", GetUserInventory, CheckAuthSession)); | 85 | "POST", "/GetInventory/", GetUserInventory, CheckAuthSession)); |
86 | 86 | ||
87 | m_httpServer.AddStreamHandler( | 87 | m_httpServer.AddStreamHandler( |
88 | new RestDeserialiseSecureHandler<InventoryFolderBase, bool>( | 88 | new RestDeserialiseSecureHandler<InventoryFolderBase, bool>( |
89 | "POST", "/UpdateFolder/", m_InventoryService.UpdateFolder, CheckAuthSession)); | 89 | "POST", "/UpdateFolder/", m_InventoryService.UpdateFolder, CheckAuthSession)); |
90 | 90 | ||
91 | m_httpServer.AddStreamHandler( | 91 | m_httpServer.AddStreamHandler( |
92 | new RestDeserialiseSecureHandler<InventoryFolderBase, bool>( | 92 | new RestDeserialiseSecureHandler<InventoryFolderBase, bool>( |
93 | "POST", "/MoveFolder/", m_InventoryService.MoveFolder, CheckAuthSession)); | 93 | "POST", "/MoveFolder/", m_InventoryService.MoveFolder, CheckAuthSession)); |
94 | 94 | ||
95 | m_httpServer.AddStreamHandler( | 95 | m_httpServer.AddStreamHandler( |
96 | new RestDeserialiseSecureHandler<InventoryFolderBase, bool>( | 96 | new RestDeserialiseSecureHandler<InventoryFolderBase, bool>( |
97 | "POST", "/PurgeFolder/", m_InventoryService.PurgeFolder, CheckAuthSession)); | 97 | "POST", "/PurgeFolder/", m_InventoryService.PurgeFolder, CheckAuthSession)); |
98 | 98 | ||
99 | m_httpServer.AddStreamHandler( | 99 | m_httpServer.AddStreamHandler( |
100 | new RestDeserialiseSecureHandler<InventoryItemBase, bool>( | 100 | new RestDeserialiseSecureHandler<InventoryItemBase, bool>( |
101 | "POST", "/DeleteItem/", m_InventoryService.DeleteItem, CheckAuthSession)); | 101 | "POST", "/DeleteItem/", m_InventoryService.DeleteItem, CheckAuthSession)); |
102 | 102 | ||
103 | m_httpServer.AddStreamHandler( | 103 | m_httpServer.AddStreamHandler( |
104 | new RestDeserialiseSecureHandler<InventoryItemBase, InventoryItemBase>( | 104 | new RestDeserialiseSecureHandler<InventoryItemBase, InventoryItemBase>( |
105 | "POST", "/QueryItem/", m_InventoryService.QueryItem, CheckAuthSession)); | 105 | "POST", "/QueryItem/", m_InventoryService.QueryItem, CheckAuthSession)); |
106 | 106 | ||
107 | m_httpServer.AddStreamHandler( | 107 | m_httpServer.AddStreamHandler( |
108 | new RestDeserialiseSecureHandler<InventoryFolderBase, InventoryFolderBase>( | 108 | new RestDeserialiseSecureHandler<InventoryFolderBase, InventoryFolderBase>( |
109 | "POST", "/QueryFolder/", m_InventoryService.QueryFolder, CheckAuthSession)); | 109 | "POST", "/QueryFolder/", m_InventoryService.QueryFolder, CheckAuthSession)); |
110 | 110 | ||
111 | m_httpServer.AddStreamHandler( | 111 | m_httpServer.AddStreamHandler( |
112 | new RestDeserialiseTrustedHandler<Guid, bool>( | 112 | new RestDeserialiseTrustedHandler<Guid, bool>( |
113 | "POST", "/CreateInventory/", CreateUsersInventory, CheckTrustSource)); | 113 | "POST", "/CreateInventory/", CreateUsersInventory, CheckTrustSource)); |
114 | 114 | ||
115 | m_httpServer.AddStreamHandler( | 115 | m_httpServer.AddStreamHandler( |
116 | new RestDeserialiseSecureHandler<InventoryFolderBase, bool>( | 116 | new RestDeserialiseSecureHandler<InventoryFolderBase, bool>( |
117 | "POST", "/NewFolder/", m_InventoryService.AddFolder, CheckAuthSession)); | 117 | "POST", "/NewFolder/", m_InventoryService.AddFolder, CheckAuthSession)); |
118 | 118 | ||
119 | m_httpServer.AddStreamHandler( | 119 | m_httpServer.AddStreamHandler( |
120 | new RestDeserialiseTrustedHandler<InventoryFolderBase, bool>( | 120 | new RestDeserialiseTrustedHandler<InventoryFolderBase, bool>( |
121 | "POST", "/CreateFolder/", m_InventoryService.AddFolder, CheckTrustSource)); | 121 | "POST", "/CreateFolder/", m_InventoryService.AddFolder, CheckTrustSource)); |
122 | 122 | ||
123 | m_httpServer.AddStreamHandler( | 123 | m_httpServer.AddStreamHandler( |
124 | new RestDeserialiseSecureHandler<InventoryItemBase, bool>( | 124 | new RestDeserialiseSecureHandler<InventoryItemBase, bool>( |
125 | "POST", "/NewItem/", m_InventoryService.AddItem, CheckAuthSession)); | 125 | "POST", "/NewItem/", m_InventoryService.AddItem, CheckAuthSession)); |
126 | 126 | ||
127 | m_httpServer.AddStreamHandler( | 127 | m_httpServer.AddStreamHandler( |
128 | new RestDeserialiseTrustedHandler<InventoryItemBase, bool>( | 128 | new RestDeserialiseTrustedHandler<InventoryItemBase, bool>( |
129 | "POST", "/AddNewItem/", m_InventoryService.AddItem, CheckTrustSource)); | 129 | "POST", "/AddNewItem/", m_InventoryService.AddItem, CheckTrustSource)); |
130 | 130 | ||
131 | m_httpServer.AddStreamHandler( | 131 | m_httpServer.AddStreamHandler( |
132 | new RestDeserialiseTrustedHandler<Guid, List<InventoryItemBase>>( | 132 | new RestDeserialiseTrustedHandler<Guid, List<InventoryItemBase>>( |
133 | "POST", "/GetItems/", GetFolderItems, CheckTrustSource)); | 133 | "POST", "/GetItems/", GetFolderItems, CheckTrustSource)); |
134 | 134 | ||
135 | // for persistent active gestures | 135 | // for persistent active gestures |
136 | m_httpServer.AddStreamHandler( | 136 | m_httpServer.AddStreamHandler( |
137 | new RestDeserialiseTrustedHandler<Guid, List<InventoryItemBase>> | 137 | new RestDeserialiseTrustedHandler<Guid, List<InventoryItemBase>> |
138 | ("POST", "/ActiveGestures/", GetActiveGestures, CheckTrustSource)); | 138 | ("POST", "/ActiveGestures/", GetActiveGestures, CheckTrustSource)); |
139 | 139 | ||
140 | // WARNING: Root folders no longer just delivers the root and immediate child folders (e.g | 140 | // WARNING: Root folders no longer just delivers the root and immediate child folders (e.g |
141 | // system folders such as Objects, Textures), but it now returns the entire inventory skeleton. | 141 | // system folders such as Objects, Textures), but it now returns the entire inventory skeleton. |
142 | // It would have been better to rename this request, but complexities in the BaseHttpServer | 142 | // It would have been better to rename this request, but complexities in the BaseHttpServer |
143 | // (e.g. any http request not found is automatically treated as an xmlrpc request) make it easier | 143 | // (e.g. any http request not found is automatically treated as an xmlrpc request) make it easier |
144 | // to do this for now. | 144 | // to do this for now. |
145 | m_httpServer.AddStreamHandler( | 145 | m_httpServer.AddStreamHandler( |
146 | new RestDeserialiseTrustedHandler<Guid, List<InventoryFolderBase>> | 146 | new RestDeserialiseTrustedHandler<Guid, List<InventoryFolderBase>> |
147 | ("POST", "/RootFolders/", GetInventorySkeleton, CheckTrustSource)); | 147 | ("POST", "/RootFolders/", GetInventorySkeleton, CheckTrustSource)); |
148 | } | 148 | } |
149 | 149 | ||
150 | #region Wrappers for converting the Guid parameter | 150 | #region Wrappers for converting the Guid parameter |
151 | 151 | ||
152 | public InventoryCollection GetUserInventory(Guid guid) | 152 | public InventoryCollection GetUserInventory(Guid guid) |
153 | { | 153 | { |
154 | UUID userID = new UUID(guid); | 154 | UUID userID = new UUID(guid); |
155 | return m_InventoryService.GetUserInventory(userID); | 155 | return m_InventoryService.GetUserInventory(userID); |
156 | } | 156 | } |
157 | 157 | ||
158 | public List<InventoryItemBase> GetFolderItems(Guid folderID) | 158 | public List<InventoryItemBase> GetFolderItems(Guid folderID) |
159 | { | 159 | { |
160 | List<InventoryItemBase> allItems = new List<InventoryItemBase>(); | 160 | List<InventoryItemBase> allItems = new List<InventoryItemBase>(); |
161 | 161 | ||
162 | List<InventoryItemBase> items = m_InventoryService.GetFolderItems(new UUID(folderID)); | 162 | List<InventoryItemBase> items = m_InventoryService.GetFolderItems(new UUID(folderID)); |
163 | 163 | ||
164 | if (items != null) | 164 | if (items != null) |
165 | { | 165 | { |
166 | allItems.InsertRange(0, items); | 166 | allItems.InsertRange(0, items); |
167 | } | 167 | } |
168 | return allItems; | 168 | return allItems; |
169 | } | 169 | } |
170 | 170 | ||
171 | public bool CreateUsersInventory(Guid rawUserID) | 171 | public bool CreateUsersInventory(Guid rawUserID) |
172 | { | 172 | { |
173 | UUID userID = new UUID(rawUserID); | 173 | UUID userID = new UUID(rawUserID); |
174 | 174 | ||
175 | 175 | ||
176 | return m_InventoryService.CreateUserInventory(userID); | 176 | return m_InventoryService.CreateUserInventory(userID); |
177 | } | 177 | } |
178 | 178 | ||
179 | public List<InventoryItemBase> GetActiveGestures(Guid rawUserID) | 179 | public List<InventoryItemBase> GetActiveGestures(Guid rawUserID) |
180 | { | 180 | { |
181 | UUID userID = new UUID(rawUserID); | 181 | UUID userID = new UUID(rawUserID); |
182 | 182 | ||
183 | return m_InventoryService.GetActiveGestures(userID); | 183 | return m_InventoryService.GetActiveGestures(userID); |
184 | } | 184 | } |
185 | 185 | ||
186 | public List<InventoryFolderBase> GetInventorySkeleton(Guid rawUserID) | 186 | public List<InventoryFolderBase> GetInventorySkeleton(Guid rawUserID) |
187 | { | 187 | { |
188 | UUID userID = new UUID(rawUserID); | 188 | UUID userID = new UUID(rawUserID); |
189 | return m_InventoryService.GetInventorySkeleton(userID); | 189 | return m_InventoryService.GetInventorySkeleton(userID); |
190 | } | 190 | } |
191 | 191 | ||
192 | #endregion | 192 | #endregion |
193 | 193 | ||
194 | /// <summary> | 194 | /// <summary> |
195 | /// Check that the source of an inventory request is one that we trust. | 195 | /// Check that the source of an inventory request is one that we trust. |
196 | /// </summary> | 196 | /// </summary> |
197 | /// <param name="peer"></param> | 197 | /// <param name="peer"></param> |
198 | /// <returns></returns> | 198 | /// <returns></returns> |
199 | public bool CheckTrustSource(IPEndPoint peer) | 199 | public bool CheckTrustSource(IPEndPoint peer) |
200 | { | 200 | { |
201 | if (m_doLookup) | 201 | if (m_doLookup) |
202 | { | 202 | { |
203 | m_log.InfoFormat("[INVENTORY IN CONNECTOR]: Checking trusted source {0}", peer); | 203 | m_log.InfoFormat("[INVENTORY IN CONNECTOR]: Checking trusted source {0}", peer); |
204 | UriBuilder ub = new UriBuilder(m_userserver_url); | 204 | UriBuilder ub = new UriBuilder(m_userserver_url); |
205 | IPAddress[] uaddrs = Dns.GetHostAddresses(ub.Host); | 205 | IPAddress[] uaddrs = Dns.GetHostAddresses(ub.Host); |
206 | foreach (IPAddress uaddr in uaddrs) | 206 | foreach (IPAddress uaddr in uaddrs) |
207 | { | 207 | { |
208 | if (uaddr.Equals(peer.Address)) | 208 | if (uaddr.Equals(peer.Address)) |
209 | { | 209 | { |
210 | return true; | 210 | return true; |
211 | } | 211 | } |
212 | } | 212 | } |
213 | 213 | ||
214 | m_log.WarnFormat( | 214 | m_log.WarnFormat( |
215 | "[INVENTORY IN CONNECTOR]: Rejecting request since source {0} was not in the list of trusted sources", | 215 | "[INVENTORY IN CONNECTOR]: Rejecting request since source {0} was not in the list of trusted sources", |
216 | peer); | 216 | peer); |
217 | 217 | ||
218 | return false; | 218 | return false; |
219 | } | 219 | } |
220 | else | 220 | else |
221 | { | 221 | { |
222 | return true; | 222 | return true; |
223 | } | 223 | } |
224 | } | 224 | } |
225 | 225 | ||
226 | /// <summary> | 226 | /// <summary> |
227 | /// Check that the source of an inventory request for a particular agent is a current session belonging to | 227 | /// Check that the source of an inventory request for a particular agent is a current session belonging to |
228 | /// that agent. | 228 | /// that agent. |
229 | /// </summary> | 229 | /// </summary> |
230 | /// <param name="session_id"></param> | 230 | /// <param name="session_id"></param> |
231 | /// <param name="avatar_id"></param> | 231 | /// <param name="avatar_id"></param> |
232 | /// <returns></returns> | 232 | /// <returns></returns> |
233 | public bool CheckAuthSession(string session_id, string avatar_id) | 233 | public bool CheckAuthSession(string session_id, string avatar_id) |
234 | { | 234 | { |
235 | if (m_doLookup) | 235 | if (m_doLookup) |
236 | { | 236 | { |
237 | m_log.InfoFormat("[INVENTORY IN CONNECTOR]: checking authed session {0} {1}", session_id, avatar_id); | 237 | m_log.InfoFormat("[INVENTORY IN CONNECTOR]: checking authed session {0} {1}", session_id, avatar_id); |
238 | 238 | ||
239 | //if (m_session_cache.getCachedSession(session_id, avatar_id) == null) | 239 | //if (m_session_cache.getCachedSession(session_id, avatar_id) == null) |
240 | //{ | 240 | //{ |
241 | // cache miss, ask userserver | 241 | // cache miss, ask userserver |
242 | Hashtable requestData = new Hashtable(); | 242 | Hashtable requestData = new Hashtable(); |
243 | requestData["avatar_uuid"] = avatar_id; | 243 | requestData["avatar_uuid"] = avatar_id; |
244 | requestData["session_id"] = session_id; | 244 | requestData["session_id"] = session_id; |
245 | ArrayList SendParams = new ArrayList(); | 245 | ArrayList SendParams = new ArrayList(); |
246 | SendParams.Add(requestData); | 246 | SendParams.Add(requestData); |
247 | XmlRpcRequest UserReq = new XmlRpcRequest("check_auth_session", SendParams); | 247 | XmlRpcRequest UserReq = new XmlRpcRequest("check_auth_session", SendParams); |
248 | XmlRpcResponse UserResp = UserReq.Send(m_userserver_url, 3000); | 248 | XmlRpcResponse UserResp = UserReq.Send(m_userserver_url, 3000); |
249 | 249 | ||
250 | Hashtable responseData = (Hashtable)UserResp.Value; | 250 | Hashtable responseData = (Hashtable)UserResp.Value; |
251 | if (responseData.ContainsKey("auth_session") && responseData["auth_session"].ToString() == "TRUE") | 251 | if (responseData.ContainsKey("auth_session") && responseData["auth_session"].ToString() == "TRUE") |
252 | { | 252 | { |
253 | m_log.Info("[INVENTORY IN CONNECTOR]: got authed session from userserver"); | 253 | m_log.Info("[INVENTORY IN CONNECTOR]: got authed session from userserver"); |
254 | //// add to cache; the session time will be automatically renewed | 254 | //// add to cache; the session time will be automatically renewed |
255 | //m_session_cache.Add(session_id, avatar_id); | 255 | //m_session_cache.Add(session_id, avatar_id); |
256 | return true; | 256 | return true; |
257 | } | 257 | } |
258 | //} | 258 | //} |
259 | //else | 259 | //else |
260 | //{ | 260 | //{ |
261 | // // cache hits | 261 | // // cache hits |
262 | // m_log.Info("[GRID AGENT INVENTORY]: got authed session from cache"); | 262 | // m_log.Info("[GRID AGENT INVENTORY]: got authed session from cache"); |
263 | // return true; | 263 | // return true; |
264 | //} | 264 | //} |
265 | 265 | ||
266 | m_log.Warn("[INVENTORY IN CONNECTOR]: unknown session_id, request rejected"); | 266 | m_log.Warn("[INVENTORY IN CONNECTOR]: unknown session_id, request rejected"); |
267 | return false; | 267 | return false; |
268 | } | 268 | } |
269 | else | 269 | else |
270 | { | 270 | { |
271 | return true; | 271 | return true; |
272 | } | 272 | } |
273 | } | 273 | } |
274 | 274 | ||
275 | } | 275 | } |
276 | } | 276 | } |