| 34 |
using System.Xml; |
using System.Xml; |
| 35 |
using ExtensionLoader; |
using ExtensionLoader; |
| 36 |
using OpenMetaverse; |
using OpenMetaverse; |
| 37 |
|
using OpenMetaverse.StructuredData; |
| 38 |
using HttpServer; |
using HttpServer; |
| 39 |
|
|
| 40 |
namespace AssetServer.Extensions |
namespace AssetServer.Extensions |
| 79 |
{ |
{ |
| 80 |
Logger.Log.Warn("GetInventory is not scalable on some inventory backends, avoid calling it wherever possible"); |
Logger.Log.Warn("GetInventory is not scalable on some inventory backends, avoid calling it wherever possible"); |
| 81 |
|
|
| 82 |
// Lookup the owner Uri for this ownerID |
Uri owner = Utils.GetOpenSimUri(ownerID); |
|
Uri owner; |
|
|
if (Utils.OwnerMap.TryGetUri(ownerID, out owner)) |
|
|
{ |
|
| 83 |
InventoryCollection inventory; |
InventoryCollection inventory; |
| 84 |
StorageResponse storageResponse = server.InventoryProvider.TryFetchInventory(owner, sessionID, out inventory); |
BackendResponse storageResponse = server.InventoryProvider.TryFetchInventory(owner, out inventory); |
| 85 |
|
|
| 86 |
if (storageResponse == StorageResponse.Success) |
if (storageResponse == BackendResponse.Success) |
| 87 |
{ |
{ |
|
response.Status = HttpStatusCode.OK; |
|
| 88 |
collectionSerializer.Serialize(response.Body, inventory); |
collectionSerializer.Serialize(response.Body, inventory); |
| 89 |
response.Body.Flush(); |
response.Body.Flush(); |
| 90 |
} |
} |
| 91 |
else if (storageResponse == StorageResponse.AuthNeeded) |
else if (storageResponse == BackendResponse.NotFound) |
|
{ |
|
|
response.Status = HttpStatusCode.Forbidden; |
|
|
} |
|
|
else if (storageResponse == StorageResponse.NotFound) |
|
| 92 |
{ |
{ |
| 93 |
// Return an empty inventory set to mimic OpenSim.Grid.InventoryServer.exe |
// Return an empty inventory set to mimic OpenSim.Grid.InventoryServer.exe |
|
response.Status = HttpStatusCode.OK; |
|
| 94 |
inventory = new InventoryCollection(); |
inventory = new InventoryCollection(); |
| 95 |
inventory.UserID = ownerID; |
inventory.UserID = ownerID; |
| 96 |
inventory.Folders = new Dictionary<UUID, InventoryFolder>(); |
inventory.Folders = new Dictionary<UUID, InventoryFolder>(); |
| 105 |
} |
} |
| 106 |
else |
else |
| 107 |
{ |
{ |
|
response.Status = HttpStatusCode.NotFound; |
|
|
} |
|
|
} |
|
|
else |
|
|
{ |
|
| 108 |
response.Status = HttpStatusCode.BadRequest; |
response.Status = HttpStatusCode.BadRequest; |
| 109 |
} |
} |
| 110 |
|
|
| 117 |
|
|
| 118 |
if (ownerID != UUID.Zero) |
if (ownerID != UUID.Zero) |
| 119 |
{ |
{ |
| 120 |
// HACK: OpenSim doesn't supply us with any credentials when creating a new inventory. |
Uri owner = Utils.GetOpenSimUri(ownerID); |
|
// Huge gaping security hole |
|
|
UUID sessionID = UUID.Zero; |
|
|
|
|
|
// HACK: Since OpenSim doesn't pass us identification for this request, build a URL |
|
|
// identifier for the owner of this inventory |
|
|
Uri owner = new Uri("http://opensim/" + ownerID.ToString()); |
|
|
Utils.OwnerMap.Add(ownerID, owner); |
|
| 121 |
Logger.Log.DebugFormat("Created URI {0} for inventory creation", owner); |
Logger.Log.DebugFormat("Created URI {0} for inventory creation", owner); |
| 122 |
|
|
| 123 |
InventoryFolder rootFolder = new InventoryFolder("My Inventory", ownerID, UUID.Zero, (short)AssetType.Folder); |
InventoryFolder rootFolder = new InventoryFolder("My Inventory", ownerID, UUID.Zero, (short)AssetType.Folder); |
| 124 |
StorageResponse storageResponse = server.InventoryProvider.TryCreateInventory(rootFolder, sessionID); |
BackendResponse storageResponse = server.InventoryProvider.TryCreateInventory(owner, rootFolder); |
| 125 |
if (storageResponse == StorageResponse.Success) |
if (storageResponse == BackendResponse.Success) |
| 126 |
{ |
{ |
| 127 |
CreateFolder("Animations", ownerID, rootFolder.ID, AssetType.Animation, sessionID); |
CreateFolder("Animations", ownerID, rootFolder.ID, AssetType.Animation); |
| 128 |
CreateFolder("Body Parts", ownerID, rootFolder.ID, AssetType.Bodypart, sessionID); |
CreateFolder("Body Parts", ownerID, rootFolder.ID, AssetType.Bodypart); |
| 129 |
CreateFolder("Calling Cards", ownerID, rootFolder.ID, AssetType.CallingCard, sessionID); |
CreateFolder("Calling Cards", ownerID, rootFolder.ID, AssetType.CallingCard); |
| 130 |
CreateFolder("Clothing", ownerID, rootFolder.ID, AssetType.Clothing, sessionID); |
CreateFolder("Clothing", ownerID, rootFolder.ID, AssetType.Clothing); |
| 131 |
CreateFolder("Gestures", ownerID, rootFolder.ID, AssetType.Gesture, sessionID); |
CreateFolder("Gestures", ownerID, rootFolder.ID, AssetType.Gesture); |
| 132 |
CreateFolder("Landmarks", ownerID, rootFolder.ID, AssetType.Landmark, sessionID); |
CreateFolder("Landmarks", ownerID, rootFolder.ID, AssetType.Landmark); |
| 133 |
CreateFolder("Lost and Found", ownerID, rootFolder.ID, AssetType.LostAndFoundFolder, sessionID); |
CreateFolder("Lost and Found", ownerID, rootFolder.ID, AssetType.LostAndFoundFolder); |
| 134 |
CreateFolder("Notecards", ownerID, rootFolder.ID, AssetType.Notecard, sessionID); |
CreateFolder("Notecards", ownerID, rootFolder.ID, AssetType.Notecard); |
| 135 |
CreateFolder("Objects", ownerID, rootFolder.ID, AssetType.Object, sessionID); |
CreateFolder("Objects", ownerID, rootFolder.ID, AssetType.Object); |
| 136 |
CreateFolder("Photo Album", ownerID, rootFolder.ID, AssetType.SnapshotFolder, sessionID); |
CreateFolder("Photo Album", ownerID, rootFolder.ID, AssetType.SnapshotFolder); |
| 137 |
CreateFolder("Scripts", ownerID, rootFolder.ID, AssetType.LSLText, sessionID); |
CreateFolder("Scripts", ownerID, rootFolder.ID, AssetType.LSLText); |
| 138 |
CreateFolder("Sounds", ownerID, rootFolder.ID, AssetType.Sound, sessionID); |
CreateFolder("Sounds", ownerID, rootFolder.ID, AssetType.Sound); |
| 139 |
CreateFolder("Textures", ownerID, rootFolder.ID, AssetType.Texture, sessionID); |
CreateFolder("Textures", ownerID, rootFolder.ID, AssetType.Texture); |
| 140 |
CreateFolder("Trash", ownerID, rootFolder.ID, AssetType.TrashFolder, sessionID); |
CreateFolder("Trash", ownerID, rootFolder.ID, AssetType.TrashFolder); |
| 141 |
|
|
|
response.Status = HttpStatusCode.OK; |
|
| 142 |
SerializeBool(response.Body, true); |
SerializeBool(response.Body, true); |
|
response.Body.Flush(); |
|
| 143 |
return true; |
return true; |
| 144 |
} |
} |
| 145 |
} |
} |
| 146 |
|
|
|
response.Status = HttpStatusCode.OK; |
|
| 147 |
SerializeBool(response.Body, false); |
SerializeBool(response.Body, false); |
|
response.Body.Flush(); |
|
| 148 |
return true; |
return true; |
| 149 |
} |
} |
| 150 |
|
|
| 152 |
{ |
{ |
| 153 |
UUID agentID, sessionID; |
UUID agentID, sessionID; |
| 154 |
InventoryFolder folder = DeserializeFolder(request.Body, out agentID, out sessionID); |
InventoryFolder folder = DeserializeFolder(request.Body, out agentID, out sessionID); |
|
Uri owner; |
|
| 155 |
|
|
| 156 |
if (folder != null && Utils.OwnerMap.TryGetUri(folder.Owner, out owner)) |
if (folder != null) |
| 157 |
{ |
{ |
| 158 |
|
Uri owner = Utils.GetOpenSimUri(folder.Owner); |
| 159 |
|
|
| 160 |
// Some calls that are moving or updating a folder instead of creating a new one |
// Some calls that are moving or updating a folder instead of creating a new one |
| 161 |
// will pass in an InventoryFolder without the name set. If this is the case we |
// will pass in an InventoryFolder without the name set. If this is the case we |
| 162 |
// need to look up the name first |
// need to look up the name first |
| 163 |
if (String.IsNullOrEmpty(folder.Name)) |
if (String.IsNullOrEmpty(folder.Name)) |
| 164 |
{ |
{ |
| 165 |
InventoryFolder oldFolder; |
InventoryFolder oldFolder; |
| 166 |
if (server.InventoryProvider.TryFetchFolder(owner, folder.ID, sessionID, out oldFolder) == StorageResponse.Success) |
if (server.InventoryProvider.TryFetchFolder(owner, folder.ID, out oldFolder) == BackendResponse.Success) |
| 167 |
folder.Name = oldFolder.Name; |
folder.Name = oldFolder.Name; |
| 168 |
} |
} |
| 169 |
|
|
| 170 |
StorageResponse storageResponse = server.InventoryProvider.TryCreateFolder(folder, sessionID); |
BackendResponse storageResponse = server.InventoryProvider.TryCreateFolder(owner, folder); |
| 171 |
|
|
| 172 |
if (storageResponse == StorageResponse.Success) |
if (storageResponse == BackendResponse.Success) |
| 173 |
{ |
{ |
|
response.Status = HttpStatusCode.OK; |
|
| 174 |
SerializeBool(response.Body, true); |
SerializeBool(response.Body, true); |
|
response.Body.Flush(); |
|
| 175 |
return true; |
return true; |
| 176 |
} |
} |
| 177 |
} |
} |
| 178 |
|
|
|
response.Status = HttpStatusCode.OK; |
|
| 179 |
SerializeBool(response.Body, false); |
SerializeBool(response.Body, false); |
|
response.Body.Flush(); |
|
| 180 |
return true; |
return true; |
| 181 |
} |
} |
| 182 |
|
|
| 194 |
{ |
{ |
| 195 |
UUID agentID, sessionID; |
UUID agentID, sessionID; |
| 196 |
InventoryFolder folder = DeserializeFolder(request.Body, out agentID, out sessionID); |
InventoryFolder folder = DeserializeFolder(request.Body, out agentID, out sessionID); |
|
Uri owner; |
|
| 197 |
|
|
| 198 |
if (folder != null && Utils.OwnerMap.TryGetUri(folder.Owner, out owner)) |
if (folder != null) |
| 199 |
{ |
{ |
| 200 |
StorageResponse storageResponse = server.InventoryProvider.TryPurgeFolder(owner, folder.ID, sessionID); |
Uri owner = Utils.GetOpenSimUri(folder.Owner); |
| 201 |
|
BackendResponse storageResponse = server.InventoryProvider.TryPurgeFolder(owner, folder.ID); |
| 202 |
|
|
| 203 |
if (storageResponse == StorageResponse.Success) |
if (storageResponse == BackendResponse.Success) |
| 204 |
{ |
{ |
|
response.Status = HttpStatusCode.OK; |
|
| 205 |
SerializeBool(response.Body, true); |
SerializeBool(response.Body, true); |
|
response.Body.Flush(); |
|
| 206 |
return true; |
return true; |
| 207 |
} |
} |
| 208 |
} |
} |
| 209 |
|
|
|
response.Status = HttpStatusCode.OK; |
|
| 210 |
SerializeBool(response.Body, false); |
SerializeBool(response.Body, false); |
|
response.Body.Flush(); |
|
| 211 |
return true; |
return true; |
| 212 |
} |
} |
| 213 |
|
|
| 218 |
|
|
| 219 |
if (item != null) |
if (item != null) |
| 220 |
{ |
{ |
| 221 |
StorageResponse storageResponse = server.InventoryProvider.TryCreateItem(item, sessionID); |
Uri owner = Utils.GetOpenSimUri(agentID); |
| 222 |
|
BackendResponse storageResponse = server.InventoryProvider.TryCreateItem(owner, item); |
| 223 |
|
|
| 224 |
if (storageResponse == StorageResponse.Success) |
if (storageResponse == BackendResponse.Success) |
| 225 |
{ |
{ |
|
response.Status = HttpStatusCode.OK; |
|
| 226 |
SerializeBool(response.Body, true); |
SerializeBool(response.Body, true); |
|
response.Body.Flush(); |
|
| 227 |
return true; |
return true; |
| 228 |
} |
} |
| 229 |
} |
} |
| 230 |
|
|
|
response.Status = HttpStatusCode.OK; |
|
| 231 |
SerializeBool(response.Body, false); |
SerializeBool(response.Body, false); |
|
response.Body.Flush(); |
|
| 232 |
return true; |
return true; |
| 233 |
} |
} |
| 234 |
|
|
| 236 |
{ |
{ |
| 237 |
UUID agentID, sessionID; |
UUID agentID, sessionID; |
| 238 |
InventoryItem item = DeserializeItem(request.Body, out agentID, out sessionID); |
InventoryItem item = DeserializeItem(request.Body, out agentID, out sessionID); |
|
Uri owner; |
|
| 239 |
|
|
| 240 |
if (item != null && Utils.OwnerMap.TryGetUri(item.Owner, out owner)) |
if (item != null) |
| 241 |
{ |
{ |
| 242 |
StorageResponse storageResponse = server.InventoryProvider.TryDeleteItem(owner, item.ID, sessionID); |
Uri owner = Utils.GetOpenSimUri(item.Owner); |
| 243 |
|
BackendResponse storageResponse = server.InventoryProvider.TryDeleteItem(owner, item.ID); |
| 244 |
|
|
| 245 |
if (storageResponse == StorageResponse.Success) |
if (storageResponse == BackendResponse.Success) |
| 246 |
{ |
{ |
|
response.Status = HttpStatusCode.OK; |
|
| 247 |
SerializeBool(response.Body, true); |
SerializeBool(response.Body, true); |
|
response.Body.Flush(); |
|
| 248 |
return true; |
return true; |
| 249 |
} |
} |
| 250 |
} |
} |
| 251 |
|
|
|
response.Status = HttpStatusCode.OK; |
|
| 252 |
SerializeBool(response.Body, false); |
SerializeBool(response.Body, false); |
|
response.Body.Flush(); |
|
| 253 |
return true; |
return true; |
| 254 |
} |
} |
| 255 |
|
|
| 259 |
|
|
| 260 |
if (ownerID != UUID.Zero) |
if (ownerID != UUID.Zero) |
| 261 |
{ |
{ |
| 262 |
// HACK: OpenSim doesn't supply us with any credentials when fetching agent folder lists. |
Uri owner = Utils.GetOpenSimUri(ownerID); |
|
// Huge gaping security hole |
|
|
UUID sessionID = UUID.Zero; |
|
|
|
|
|
Uri owner; |
|
|
if (Utils.OwnerMap.TryGetUri(ownerID, out owner)) |
|
|
{ |
|
| 263 |
List<InventoryFolder> skeleton; |
List<InventoryFolder> skeleton; |
| 264 |
StorageResponse storageResponse = server.InventoryProvider.TryFetchFolderList(owner, sessionID, out skeleton); |
BackendResponse storageResponse = server.InventoryProvider.TryFetchFolderList(owner, out skeleton); |
| 265 |
|
|
| 266 |
if (storageResponse == StorageResponse.Success) |
if (storageResponse == BackendResponse.Success) |
| 267 |
{ |
{ |
|
response.Status = HttpStatusCode.OK; |
|
| 268 |
SerializeFolderList(response.Body, skeleton); |
SerializeFolderList(response.Body, skeleton); |
|
response.Body.Flush(); |
|
|
} |
|
|
else if (storageResponse == StorageResponse.AuthNeeded) |
|
|
{ |
|
|
response.Status = HttpStatusCode.Forbidden; |
|
| 269 |
} |
} |
| 270 |
else if (storageResponse == StorageResponse.NotFound) |
else if (storageResponse == BackendResponse.NotFound) |
| 271 |
{ |
{ |
| 272 |
// Return an empty set of inventory so the requester knows that |
// Return an empty set of inventory so the requester knows that |
| 273 |
// an inventory needs to be created for this agent |
// an inventory needs to be created for this agent |
|
response.Status = HttpStatusCode.OK; |
|
| 274 |
SerializeFolderList(response.Body, new List<InventoryFolder>(0)); |
SerializeFolderList(response.Body, new List<InventoryFolder>(0)); |
| 275 |
} |
} |
| 276 |
else |
else |
| 280 |
} |
} |
| 281 |
else |
else |
| 282 |
{ |
{ |
|
response.Status = HttpStatusCode.NotFound; |
|
|
} |
|
|
} |
|
|
else |
|
|
{ |
|
| 283 |
response.Status = HttpStatusCode.BadRequest; |
response.Status = HttpStatusCode.BadRequest; |
| 284 |
} |
} |
| 285 |
|
|
| 292 |
|
|
| 293 |
if (ownerID != UUID.Zero) |
if (ownerID != UUID.Zero) |
| 294 |
{ |
{ |
| 295 |
// HACK: OpenSim doesn't supply us with any credentials when fetching agent folder lists. |
Uri owner = Utils.GetOpenSimUri(ownerID); |
|
// Huge gaping security hole |
|
|
UUID sessionID = UUID.Zero; |
|
|
|
|
|
Uri owner; |
|
|
if (Utils.OwnerMap.TryGetUri(ownerID, out owner)) |
|
|
{ |
|
| 296 |
List<InventoryItem> gestures; |
List<InventoryItem> gestures; |
| 297 |
StorageResponse storageResponse = server.InventoryProvider.TryFetchActiveGestures(owner, sessionID, out gestures); |
BackendResponse storageResponse = server.InventoryProvider.TryFetchActiveGestures(owner, out gestures); |
| 298 |
|
|
| 299 |
if (storageResponse == StorageResponse.Success) |
if (storageResponse == BackendResponse.Success) |
| 300 |
{ |
{ |
|
response.Status = HttpStatusCode.OK; |
|
| 301 |
SerializeItemList(response.Body, gestures); |
SerializeItemList(response.Body, gestures); |
|
response.Body.Flush(); |
|
| 302 |
} |
} |
| 303 |
else if (storageResponse == StorageResponse.AuthNeeded) |
else if (storageResponse == BackendResponse.NotFound) |
|
{ |
|
|
response.Status = HttpStatusCode.Forbidden; |
|
|
} |
|
|
else if (storageResponse == StorageResponse.NotFound) |
|
| 304 |
{ |
{ |
| 305 |
// Return an empty set of gestures to match OpenSim.Grid.InventoryServer.exe behavior |
// Return an empty set of gestures to match OpenSim.Grid.InventoryServer.exe behavior |
|
response.Status = HttpStatusCode.OK; |
|
| 306 |
SerializeItemList(response.Body, new List<InventoryItem>(0)); |
SerializeItemList(response.Body, new List<InventoryItem>(0)); |
|
response.Body.Flush(); |
|
| 307 |
} |
} |
| 308 |
else |
else |
| 309 |
{ |
{ |
| 312 |
} |
} |
| 313 |
else |
else |
| 314 |
{ |
{ |
|
response.Status = HttpStatusCode.NotFound; |
|
|
} |
|
|
} |
|
|
else |
|
|
{ |
|
| 315 |
response.Status = HttpStatusCode.BadRequest; |
response.Status = HttpStatusCode.BadRequest; |
| 316 |
} |
} |
| 317 |
|
|
| 318 |
return true; |
return true; |
| 319 |
} |
} |
| 320 |
|
|
| 321 |
StorageResponse CreateFolder(string name, UUID ownerID, UUID parentID, AssetType assetType, UUID sessionID) |
BackendResponse CreateFolder(string name, UUID ownerID, UUID parentID, AssetType assetType) |
| 322 |
{ |
{ |
| 323 |
InventoryFolder folder = new InventoryFolder(name, ownerID, parentID, (short)assetType); |
InventoryFolder folder = new InventoryFolder(name, ownerID, parentID, (short)assetType); |
| 324 |
return server.InventoryProvider.TryCreateFolder(folder, sessionID); |
Uri owner = Utils.GetOpenSimUri(ownerID); |
| 325 |
|
return server.InventoryProvider.TryCreateFolder(owner, folder); |
| 326 |
} |
} |
| 327 |
|
|
| 328 |
UUID DeserializeUUID(Stream stream) |
UUID DeserializeUUID(Stream stream) |
| 472 |
} |
} |
| 473 |
|
|
| 474 |
stream.Flush(); |
stream.Flush(); |
|
stream.Close(); |
|
| 475 |
} |
} |
| 476 |
|
|
| 477 |
void SerializeFolderList(Stream stream, List<InventoryFolder> folders) |
void SerializeFolderList(Stream stream, List<InventoryFolder> folders) |
| 500 |
} |
} |
| 501 |
|
|
| 502 |
stream.Flush(); |
stream.Flush(); |
|
stream.Close(); |
|
| 503 |
} |
} |
| 504 |
|
|
| 505 |
void SerializeItemList(Stream stream, List<InventoryItem> items) |
void SerializeItemList(Stream stream, List<InventoryItem> items) |
| 542 |
} |
} |
| 543 |
|
|
| 544 |
stream.Flush(); |
stream.Flush(); |
|
stream.Close(); |
|
| 545 |
} |
} |
| 546 |
|
|
| 547 |
void WriteUUID(XmlWriter writer, string name, UUID id) |
void WriteUUID(XmlWriter writer, string name, UUID id) |