| 41 |
{ |
{ |
| 42 |
public class OpenSimInventoryFrontend : IExtension<AssetServer> |
public class OpenSimInventoryFrontend : IExtension<AssetServer> |
| 43 |
{ |
{ |
|
const string URI_UUID_MAP = "uri_uuid_map.txt"; |
|
|
|
|
| 44 |
AssetServer server; |
AssetServer server; |
| 45 |
Utils.InventoryItemSerializer itemSerializer = new Utils.InventoryItemSerializer(); |
Utils.InventoryItemSerializer itemSerializer = new Utils.InventoryItemSerializer(); |
| 46 |
Utils.InventoryFolderSerializer folderSerializer = new Utils.InventoryFolderSerializer(); |
Utils.InventoryFolderSerializer folderSerializer = new Utils.InventoryFolderSerializer(); |
| 54 |
{ |
{ |
| 55 |
this.server = server; |
this.server = server; |
| 56 |
|
|
|
// Load Utils.OwnerMap from disk |
|
|
try |
|
|
{ |
|
|
OSDMap osd = OSDParser.DeserializeJson(new FileStream(URI_UUID_MAP, FileMode.Open, FileAccess.Read)) as OSDMap; |
|
|
Utils.OwnerMap.FromOSD(osd); |
|
|
} |
|
|
catch (Exception) { } |
|
|
|
|
|
Logger.Log.InfoFormat("Loaded {0} entries for the legacy URI to UUID mapping", Utils.OwnerMap.Count); |
|
|
|
|
| 57 |
server.HttpServer.AddHandler("post", null, @"^/GetInventory/", GetInventoryHandler); |
server.HttpServer.AddHandler("post", null, @"^/GetInventory/", GetInventoryHandler); |
| 58 |
server.HttpServer.AddHandler("post", null, @"^/CreateInventory/", CreateInventoryHandler); |
server.HttpServer.AddHandler("post", null, @"^/CreateInventory/", CreateInventoryHandler); |
| 59 |
server.HttpServer.AddHandler("post", null, @"^/NewFolder/", NewFolderHandler); |
server.HttpServer.AddHandler("post", null, @"^/NewFolder/", NewFolderHandler); |
| 68 |
|
|
| 69 |
public void Stop() |
public void Stop() |
| 70 |
{ |
{ |
|
// Write Utils.OwnerMap to disk |
|
|
LitJson.JsonData json = OSDParser.SerializeJson(Utils.OwnerMap.ToOSD()); |
|
|
|
|
|
try |
|
|
{ |
|
|
StreamWriter streamWriter = new StreamWriter(URI_UUID_MAP); |
|
|
LitJson.JsonWriter writer = new LitJson.JsonWriter(streamWriter); |
|
|
writer.PrettyPrint = true; |
|
|
json.ToJson(writer); |
|
|
streamWriter.Close(); |
|
|
|
|
|
Logger.Log.Info("Saved legacy URI to UUID mapping to " + URI_UUID_MAP); |
|
|
} |
|
|
catch (Exception ex) |
|
|
{ |
|
|
Logger.Log.ErrorFormat("Failed to write {0} to disk: {1}", URI_UUID_MAP, ex.Message); |
|
|
} |
|
| 71 |
} |
} |
| 72 |
|
|
| 73 |
bool GetInventoryHandler(IHttpClientContext client, IHttpRequest request, IHttpResponse response) |
bool GetInventoryHandler(IHttpClientContext client, IHttpRequest request, IHttpResponse response) |
| 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); |
StorageResponse storageResponse = server.InventoryProvider.TryFetchInventory(owner, sessionID, out inventory); |
| 85 |
|
|
| 111 |
} |
} |
| 112 |
else |
else |
| 113 |
{ |
{ |
|
response.Status = HttpStatusCode.NotFound; |
|
|
} |
|
|
} |
|
|
else |
|
|
{ |
|
| 114 |
response.Status = HttpStatusCode.BadRequest; |
response.Status = HttpStatusCode.BadRequest; |
| 115 |
} |
} |
| 116 |
|
|
| 127 |
// Huge gaping security hole |
// Huge gaping security hole |
| 128 |
UUID sessionID = UUID.Zero; |
UUID sessionID = UUID.Zero; |
| 129 |
|
|
| 130 |
// HACK: Since OpenSim doesn't pass us identification for this request, build a URL |
Uri owner = Utils.GetOpenSimUri(ownerID); |
|
// identifier for the owner of this inventory |
|
|
Uri owner = new Uri("http://opensim/" + ownerID.ToString()); |
|
|
Utils.OwnerMap.Add(ownerID, owner); |
|
| 131 |
Logger.Log.DebugFormat("Created URI {0} for inventory creation", owner); |
Logger.Log.DebugFormat("Created URI {0} for inventory creation", owner); |
| 132 |
|
|
| 133 |
InventoryFolder rootFolder = new InventoryFolder("My Inventory", ownerID, UUID.Zero, (short)AssetType.Folder); |
InventoryFolder rootFolder = new InventoryFolder("My Inventory", ownerID, UUID.Zero, (short)AssetType.Folder); |
| 134 |
StorageResponse storageResponse = server.InventoryProvider.TryCreateInventory(rootFolder, sessionID); |
StorageResponse storageResponse = server.InventoryProvider.TryCreateInventory(owner, rootFolder, sessionID); |
| 135 |
if (storageResponse == StorageResponse.Success) |
if (storageResponse == StorageResponse.Success) |
| 136 |
{ |
{ |
| 137 |
CreateFolder("Animations", ownerID, rootFolder.ID, AssetType.Animation, sessionID); |
CreateFolder("Animations", ownerID, rootFolder.ID, AssetType.Animation, sessionID); |
| 166 |
{ |
{ |
| 167 |
UUID agentID, sessionID; |
UUID agentID, sessionID; |
| 168 |
InventoryFolder folder = DeserializeFolder(request.Body, out agentID, out sessionID); |
InventoryFolder folder = DeserializeFolder(request.Body, out agentID, out sessionID); |
|
Uri owner; |
|
| 169 |
|
|
| 170 |
if (folder != null && Utils.OwnerMap.TryGetUri(folder.Owner, out owner)) |
if (folder != null) |
| 171 |
{ |
{ |
| 172 |
|
Uri owner = Utils.GetOpenSimUri(folder.Owner); |
| 173 |
|
|
| 174 |
// 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 |
| 175 |
// 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 |
| 176 |
// need to look up the name first |
// need to look up the name first |
| 181 |
folder.Name = oldFolder.Name; |
folder.Name = oldFolder.Name; |
| 182 |
} |
} |
| 183 |
|
|
| 184 |
StorageResponse storageResponse = server.InventoryProvider.TryCreateFolder(folder, sessionID); |
StorageResponse storageResponse = server.InventoryProvider.TryCreateFolder(owner, folder, sessionID); |
| 185 |
|
|
| 186 |
if (storageResponse == StorageResponse.Success) |
if (storageResponse == StorageResponse.Success) |
| 187 |
{ |
{ |
| 212 |
{ |
{ |
| 213 |
UUID agentID, sessionID; |
UUID agentID, sessionID; |
| 214 |
InventoryFolder folder = DeserializeFolder(request.Body, out agentID, out sessionID); |
InventoryFolder folder = DeserializeFolder(request.Body, out agentID, out sessionID); |
|
Uri owner; |
|
| 215 |
|
|
| 216 |
if (folder != null && Utils.OwnerMap.TryGetUri(folder.Owner, out owner)) |
if (folder != null) |
| 217 |
{ |
{ |
| 218 |
|
Uri owner = Utils.GetOpenSimUri(folder.Owner); |
| 219 |
StorageResponse storageResponse = server.InventoryProvider.TryPurgeFolder(owner, folder.ID, sessionID); |
StorageResponse storageResponse = server.InventoryProvider.TryPurgeFolder(owner, folder.ID, sessionID); |
| 220 |
|
|
| 221 |
if (storageResponse == StorageResponse.Success) |
if (storageResponse == StorageResponse.Success) |
| 240 |
|
|
| 241 |
if (item != null) |
if (item != null) |
| 242 |
{ |
{ |
| 243 |
StorageResponse storageResponse = server.InventoryProvider.TryCreateItem(item, sessionID); |
Uri owner = Utils.GetOpenSimUri(agentID); |
| 244 |
|
StorageResponse storageResponse = server.InventoryProvider.TryCreateItem(owner, item, sessionID); |
| 245 |
|
|
| 246 |
if (storageResponse == StorageResponse.Success) |
if (storageResponse == StorageResponse.Success) |
| 247 |
{ |
{ |
| 262 |
{ |
{ |
| 263 |
UUID agentID, sessionID; |
UUID agentID, sessionID; |
| 264 |
InventoryItem item = DeserializeItem(request.Body, out agentID, out sessionID); |
InventoryItem item = DeserializeItem(request.Body, out agentID, out sessionID); |
|
Uri owner; |
|
| 265 |
|
|
| 266 |
if (item != null && Utils.OwnerMap.TryGetUri(item.Owner, out owner)) |
if (item != null) |
| 267 |
{ |
{ |
| 268 |
|
Uri owner = Utils.GetOpenSimUri(item.Owner); |
| 269 |
StorageResponse storageResponse = server.InventoryProvider.TryDeleteItem(owner, item.ID, sessionID); |
StorageResponse storageResponse = server.InventoryProvider.TryDeleteItem(owner, item.ID, sessionID); |
| 270 |
|
|
| 271 |
if (storageResponse == StorageResponse.Success) |
if (storageResponse == StorageResponse.Success) |
| 293 |
// Huge gaping security hole |
// Huge gaping security hole |
| 294 |
UUID sessionID = UUID.Zero; |
UUID sessionID = UUID.Zero; |
| 295 |
|
|
| 296 |
Uri owner; |
Uri owner = Utils.GetOpenSimUri(ownerID); |
|
if (Utils.OwnerMap.TryGetUri(ownerID, out owner)) |
|
|
{ |
|
| 297 |
List<InventoryFolder> skeleton; |
List<InventoryFolder> skeleton; |
| 298 |
StorageResponse storageResponse = server.InventoryProvider.TryFetchFolderList(owner, sessionID, out skeleton); |
StorageResponse storageResponse = server.InventoryProvider.TryFetchFolderList(owner, sessionID, out skeleton); |
| 299 |
|
|
| 321 |
} |
} |
| 322 |
else |
else |
| 323 |
{ |
{ |
|
response.Status = HttpStatusCode.NotFound; |
|
|
} |
|
|
} |
|
|
else |
|
|
{ |
|
| 324 |
response.Status = HttpStatusCode.BadRequest; |
response.Status = HttpStatusCode.BadRequest; |
| 325 |
} |
} |
| 326 |
|
|
| 337 |
// Huge gaping security hole |
// Huge gaping security hole |
| 338 |
UUID sessionID = UUID.Zero; |
UUID sessionID = UUID.Zero; |
| 339 |
|
|
| 340 |
Uri owner; |
Uri owner = Utils.GetOpenSimUri(ownerID); |
|
if (Utils.OwnerMap.TryGetUri(ownerID, out owner)) |
|
|
{ |
|
| 341 |
List<InventoryItem> gestures; |
List<InventoryItem> gestures; |
| 342 |
StorageResponse storageResponse = server.InventoryProvider.TryFetchActiveGestures(owner, sessionID, out gestures); |
StorageResponse storageResponse = server.InventoryProvider.TryFetchActiveGestures(owner, sessionID, out gestures); |
| 343 |
|
|
| 365 |
} |
} |
| 366 |
else |
else |
| 367 |
{ |
{ |
|
response.Status = HttpStatusCode.NotFound; |
|
|
} |
|
|
} |
|
|
else |
|
|
{ |
|
| 368 |
response.Status = HttpStatusCode.BadRequest; |
response.Status = HttpStatusCode.BadRequest; |
| 369 |
} |
} |
| 370 |
|
|
| 374 |
StorageResponse CreateFolder(string name, UUID ownerID, UUID parentID, AssetType assetType, UUID sessionID) |
StorageResponse CreateFolder(string name, UUID ownerID, UUID parentID, AssetType assetType, UUID sessionID) |
| 375 |
{ |
{ |
| 376 |
InventoryFolder folder = new InventoryFolder(name, ownerID, parentID, (short)assetType); |
InventoryFolder folder = new InventoryFolder(name, ownerID, parentID, (short)assetType); |
| 377 |
return server.InventoryProvider.TryCreateFolder(folder, sessionID); |
Uri owner = Utils.GetOpenSimUri(ownerID); |
| 378 |
|
return server.InventoryProvider.TryCreateFolder(owner, folder, sessionID); |
| 379 |
} |
} |
| 380 |
|
|
| 381 |
UUID DeserializeUUID(Stream stream) |
UUID DeserializeUUID(Stream stream) |