OpenSimulator GForge > Projects > Cable Beach Asset Server > SVN

Diff of /trunk/AssetServer/Extensions/OpenSimInventoryFrontend.cs

-revision 49, Mon Dec 15 21:13:28 2008 UTC
+revision 66, Fri Jan  9 23:05:23 2009 UTC
 Line 34
  using System.Xml;
  using ExtensionLoader;
  using OpenMetaverse;
+ using OpenMetaverse.StructuredData;
+ using HttpServer;
  namespace AssetServer.Extensions
  {
-Line 68
+Line 70
          {
          }
-         void GetInventoryHandler(ref HttpListenerContext context)
+         bool GetInventoryHandler(IHttpClientContext client, IHttpRequest request, IHttpResponse response)
          {
              UUID sessionID, agentID;
-             UUID inventoryID = DeserializeUUID(context.Request.InputStream, out agentID, out sessionID);
+             UUID ownerID = DeserializeUUID(request.Body, out agentID, out sessionID);
-             if (inventoryID != UUID.Zero)
+             if (ownerID != UUID.Zero)
              {
                  Logger.Log.Warn("GetInventory is not scalable on some inventory backends, avoid calling it wherever possible");
+                 Uri owner = Utils.GetOpenSimUri(ownerID);
                  InventoryCollection inventory;
-                 StorageResponse response = server.InventoryProvider.TryFetchInventory(inventoryID, sessionID, out inventory);
+                 StorageResponse storageResponse = server.InventoryProvider.TryFetchInventory(owner, sessionID, out inventory);
-                 if (response == StorageResponse.Success)
+                 if (storageResponse == StorageResponse.Success)
                  {
-                     context.Response.StatusCode = (int)HttpStatusCode.OK;
+                     response.Status = HttpStatusCode.OK;
-                     collectionSerializer.Serialize(context.Response.OutputStream, inventory);
+                     collectionSerializer.Serialize(response.Body, inventory);
-                     context.Response.OutputStream.Flush();
+                     response.Body.Flush();
                  }
-                 else if (response == StorageResponse.AuthNeeded)
+                 else if (storageResponse == StorageResponse.AuthNeeded)
                  {
-                     context.Response.StatusCode = (int)HttpStatusCode.Forbidden;
+                     response.Status = HttpStatusCode.Forbidden;
                  }
-                 else if (response == StorageResponse.NotFound)
+                 else if (storageResponse == StorageResponse.NotFound)
                  {
                      // Return an empty inventory set to mimic OpenSim.Grid.InventoryServer.exe
-                     context.Response.StatusCode = (int)HttpStatusCode.OK;
+                     response.Status = HttpStatusCode.OK;
                      inventory = new InventoryCollection();
-                     inventory.UserID = inventoryID;
+                     inventory.UserID = ownerID;
                      inventory.Folders = new Dictionary<UUID,InventoryFolder>();
                      inventory.Items = new Dictionary<UUID,InventoryItem>();
-                     collectionSerializer.Serialize(context.Response.OutputStream, inventory);
+                     collectionSerializer.Serialize(response.Body, inventory);
-                     context.Response.OutputStream.Flush();
+                     response.Body.Flush();
                  }
                  else
                  {
-                     context.Response.StatusCode = (int)HttpStatusCode.InternalServerError;
+                     response.Status = HttpStatusCode.InternalServerError;
                  }
              }
              else
              {
-                 context.Response.StatusCode = (int)HttpStatusCode.BadRequest;
+                 response.Status = HttpStatusCode.BadRequest;
              }
+             return true;
          }
-         void CreateInventoryHandler(ref HttpListenerContext context)
+         bool CreateInventoryHandler(IHttpClientContext client, IHttpRequest request, IHttpResponse response)
          {
-             UUID ownerID = DeserializeUUID(context.Request.InputStream);
+             UUID ownerID = DeserializeUUID(request.Body);
              if (ownerID != UUID.Zero)
              {
-Line 122
+Line 127
                  // Huge gaping security hole
                  UUID sessionID = UUID.Zero;
+                 Uri owner = Utils.GetOpenSimUri(ownerID);
+                 Logger.Log.DebugFormat("Created URI {0} for inventory creation", owner);
                  InventoryFolder rootFolder = new InventoryFolder("My Inventory", ownerID, UUID.Zero, (short)AssetType.Folder);
-                 StorageResponse response = server.InventoryProvider.TryCreateInventory(rootFolder, sessionID);
+                 StorageResponse storageResponse = server.InventoryProvider.TryCreateInventory(owner, rootFolder, sessionID);
-                 if (response == StorageResponse.Success)
+                 if (storageResponse == StorageResponse.Success)
                  {
                      CreateFolder("Animations", ownerID, rootFolder.ID, AssetType.Animation, sessionID);
                      CreateFolder("Body Parts", ownerID, rootFolder.ID, AssetType.Bodypart, sessionID);
-Line 141
+Line 149
                      CreateFolder("Textures", ownerID, rootFolder.ID, AssetType.Texture, sessionID);
                      CreateFolder("Trash", ownerID, rootFolder.ID, AssetType.TrashFolder, sessionID);
-                     context.Response.StatusCode = (int)HttpStatusCode.OK;
+                     response.Status = HttpStatusCode.OK;
-                     SerializeBool(context.Response.OutputStream, true);
+                     SerializeBool(response.Body, true);
-                     return;
+                     response.Body.Flush();
+                     return true;
                  }
              }
-             context.Response.StatusCode = (int)HttpStatusCode.OK;
+             response.Status = HttpStatusCode.OK;
-             SerializeBool(context.Response.OutputStream, false);
+             SerializeBool(response.Body, false);
+             response.Body.Flush();
+             return true;
          }
-         void NewFolderHandler(ref HttpListenerContext context)
+         bool NewFolderHandler(IHttpClientContext client, IHttpRequest request, IHttpResponse response)
          {
              UUID agentID, sessionID;
-             InventoryFolder folder = DeserializeFolder(context.Request.InputStream, out agentID, out sessionID);
+             InventoryFolder folder = DeserializeFolder(request.Body, out agentID, out sessionID);
              if (folder != null)
              {
+                 Uri owner = Utils.GetOpenSimUri(folder.Owner);
                  // Some calls that are moving or updating a folder instead of creating a new one
                  // will pass in an InventoryFolder without the name set. If this is the case we
                  // need to look up the name first
                  if (String.IsNullOrEmpty(folder.Name))
                  {
                      InventoryFolder oldFolder;
-                     if (server.InventoryProvider.TryFetchFolder(folder.Owner, folder.ID, sessionID, out oldFolder) == StorageResponse.Success)
+                     if (server.InventoryProvider.TryFetchFolder(owner, folder.ID, sessionID, out oldFolder) == StorageResponse.Success)
                          folder.Name = oldFolder.Name;
                  }
-                 StorageResponse response = server.InventoryProvider.TryCreateFolder(folder, sessionID);
+                 StorageResponse storageResponse = server.InventoryProvider.TryCreateFolder(owner, folder, sessionID);
-                 if (response == StorageResponse.Success)
+                 if (storageResponse == StorageResponse.Success)
                  {
-                     context.Response.StatusCode = (int)HttpStatusCode.OK;
+                     response.Status = HttpStatusCode.OK;
-                     SerializeBool(context.Response.OutputStream, true);
+                     SerializeBool(response.Body, true);
-                     return;
+                     response.Body.Flush();
+                     return true;
                  }
              }
-             context.Response.StatusCode = (int)HttpStatusCode.OK;
+             response.Status = HttpStatusCode.OK;
-             SerializeBool(context.Response.OutputStream, false);
+             SerializeBool(response.Body, false);
+             response.Body.Flush();
+             return true;
          }
-         void UpdateFolderHandler(ref HttpListenerContext context)
+         bool UpdateFolderHandler(IHttpClientContext client, IHttpRequest request, IHttpResponse response)
          {
-             NewFolderHandler(ref context);
+             return NewFolderHandler(client, request, response);
          }
-         void MoveFolderHandler(ref HttpListenerContext context)
+         bool MoveFolderHandler(IHttpClientContext client, IHttpRequest request, IHttpResponse response)
          {
-             NewFolderHandler(ref context);
+             return NewFolderHandler(client, request, response);
          }
-         void PurgeFolderHandler(ref HttpListenerContext context)
+         bool PurgeFolderHandler(IHttpClientContext client, IHttpRequest request, IHttpResponse response)
          {
              UUID agentID, sessionID;
-             InventoryFolder folder = DeserializeFolder(context.Request.InputStream, out agentID, out sessionID);
+             InventoryFolder folder = DeserializeFolder(request.Body, out agentID, out sessionID);
              if (folder != null)
              {
-                 StorageResponse response = server.InventoryProvider.TryPurgeFolder(folder.Owner, folder.ID, sessionID);
+                 Uri owner = Utils.GetOpenSimUri(folder.Owner);
+                 StorageResponse storageResponse = server.InventoryProvider.TryPurgeFolder(owner, folder.ID, sessionID);
-                 if (response == StorageResponse.Success)
+                 if (storageResponse == StorageResponse.Success)
                  {
-                     context.Response.StatusCode = (int)HttpStatusCode.OK;
+                     response.Status = HttpStatusCode.OK;
-                     SerializeBool(context.Response.OutputStream, true);
+                     SerializeBool(response.Body, true);
-                     return;
+                     response.Body.Flush();
+                     return true;
                  }
              }
-             context.Response.StatusCode = (int)HttpStatusCode.OK;
+             response.Status = HttpStatusCode.OK;
-             SerializeBool(context.Response.OutputStream, false);
+             SerializeBool(response.Body, false);
+             response.Body.Flush();
+             return true;
          }
-         void NewItemHandler(ref HttpListenerContext context)
+         bool NewItemHandler(IHttpClientContext client, IHttpRequest request, IHttpResponse response)
          {
              UUID agentID, sessionID;
-             InventoryItem item = DeserializeItem(context.Request.InputStream, out agentID, out sessionID);
+             InventoryItem item = DeserializeItem(request.Body, out agentID, out sessionID);
              if (item != null)
              {
-                 StorageResponse response = server.InventoryProvider.TryCreateItem(item, sessionID);
+                 Uri owner = Utils.GetOpenSimUri(agentID);
+                 StorageResponse storageResponse = server.InventoryProvider.TryCreateItem(owner, item, sessionID);
-                 if (response == StorageResponse.Success)
+                 if (storageResponse == StorageResponse.Success)
                  {
-                     context.Response.StatusCode = (int)HttpStatusCode.OK;
+                     response.Status = HttpStatusCode.OK;
-                     SerializeBool(context.Response.OutputStream, true);
+                     SerializeBool(response.Body, true);
-                     return;
+                     response.Body.Flush();
+                     return true;
                  }
              }
-             context.Response.StatusCode = (int)HttpStatusCode.OK;
+             response.Status = HttpStatusCode.OK;
-             SerializeBool(context.Response.OutputStream, false);
+             SerializeBool(response.Body, false);
+             response.Body.Flush();
+             return true;
          }
-         void DeleteItemHandler(ref HttpListenerContext context)
+         bool DeleteItemHandler(IHttpClientContext client, IHttpRequest request, IHttpResponse response)
          {
              UUID agentID, sessionID;
-             InventoryItem item = DeserializeItem(context.Request.InputStream, out agentID, out sessionID);
+             InventoryItem item = DeserializeItem(request.Body, out agentID, out sessionID);
              if (item != null)
              {
-                 StorageResponse response = server.InventoryProvider.TryDeleteItem(item.Owner, item.ID, sessionID);
+                 Uri owner = Utils.GetOpenSimUri(item.Owner);
+                 StorageResponse storageResponse = server.InventoryProvider.TryDeleteItem(owner, item.ID, sessionID);
-                 if (response == StorageResponse.Success)
+                 if (storageResponse == StorageResponse.Success)
                  {
-                     context.Response.StatusCode = (int)HttpStatusCode.OK;
+                     response.Status = HttpStatusCode.OK;
-                     SerializeBool(context.Response.OutputStream, true);
+                     SerializeBool(response.Body, true);
-                     return;
+                     response.Body.Flush();
+                     return true;
                  }
              }
-             context.Response.StatusCode = (int)HttpStatusCode.OK;
+             response.Status = HttpStatusCode.OK;
-             SerializeBool(context.Response.OutputStream, false);
+             SerializeBool(response.Body, false);
+             response.Body.Flush();
+             return true;
          }
-         void RootFoldersHandler(ref HttpListenerContext context)
+         bool RootFoldersHandler(IHttpClientContext client, IHttpRequest request, IHttpResponse response)
          {
-             UUID ownerID = DeserializeUUID(context.Request.InputStream);
+             UUID ownerID = DeserializeUUID(request.Body);
              if (ownerID != UUID.Zero)
              {
-Line 265
+Line 293
                  // Huge gaping security hole
                  UUID sessionID = UUID.Zero;
+                 Uri owner = Utils.GetOpenSimUri(ownerID);
                  List<InventoryFolder> skeleton;
-                 StorageResponse response = server.InventoryProvider.TryFetchFolderList(ownerID, sessionID, out skeleton);
+                 StorageResponse storageResponse = server.InventoryProvider.TryFetchFolderList(owner, sessionID, out skeleton);
-                 if (response == StorageResponse.Success)
+                 if (storageResponse == StorageResponse.Success)
                  {
-                     context.Response.StatusCode = (int)HttpStatusCode.OK;
+                     response.Status = HttpStatusCode.OK;
-                     SerializeFolderList(context.Response.OutputStream, skeleton);
+                     SerializeFolderList(response.Body, skeleton);
+                     response.Body.Flush();
                  }
-                 else if (response == StorageResponse.AuthNeeded)
+                 else if (storageResponse == StorageResponse.AuthNeeded)
                  {
-                     context.Response.StatusCode = (int)HttpStatusCode.Forbidden;
+                     response.Status = HttpStatusCode.Forbidden;
                  }
-                 else if (response == StorageResponse.NotFound)
+                 else if (storageResponse == StorageResponse.NotFound)
                  {
                      // Return an empty set of inventory so the requester knows that
                      // an inventory needs to be created for this agent
-                     context.Response.StatusCode = (int)HttpStatusCode.OK;
+                     response.Status = HttpStatusCode.OK;
-                     SerializeFolderList(context.Response.OutputStream, new List<InventoryFolder>(0));
+                     SerializeFolderList(response.Body, new List<InventoryFolder>(0));
                  }
                  else
                  {
-                     context.Response.StatusCode = (int)HttpStatusCode.InternalServerError;
+                     response.Status = HttpStatusCode.InternalServerError;
                  }
              }
              else
              {
-                 context.Response.StatusCode = (int)HttpStatusCode.BadRequest;
+                 response.Status = HttpStatusCode.BadRequest;
              }
+             return true;
          }
-         void ActiveGesturesHandler(ref HttpListenerContext context)
+         bool ActiveGesturesHandler(IHttpClientContext client, IHttpRequest request, IHttpResponse response)
          {
-             UUID inventoryID = DeserializeUUID(context.Request.InputStream);
+             UUID ownerID = DeserializeUUID(request.Body);
-             if (inventoryID != UUID.Zero)
+             if (ownerID != UUID.Zero)
              {
                  // HACK: OpenSim doesn't supply us with any credentials when fetching agent folder lists.
                  // Huge gaping security hole
                  UUID sessionID = UUID.Zero;
+                 Uri owner = Utils.GetOpenSimUri(ownerID);
                  List<InventoryItem> gestures;
-                 StorageResponse response = server.InventoryProvider.TryFetchActiveGestures(inventoryID, sessionID, out gestures);
+                 StorageResponse storageResponse = server.InventoryProvider.TryFetchActiveGestures(owner, sessionID, out gestures);
-                 if (response == StorageResponse.Success)
+                 if (storageResponse == StorageResponse.Success)
                  {
-                     context.Response.StatusCode = (int)HttpStatusCode.OK;
+                     response.Status = HttpStatusCode.OK;
-                     SerializeItemList(context.Response.OutputStream, gestures);
+                     SerializeItemList(response.Body, gestures);
+                     response.Body.Flush();
                  }
-                 else if (response == StorageResponse.AuthNeeded)
+                 else if (storageResponse == StorageResponse.AuthNeeded)
                  {
-                     context.Response.StatusCode = (int)HttpStatusCode.Forbidden;
+                     response.Status = HttpStatusCode.Forbidden;
                  }
-                 else if (response == StorageResponse.NotFound)
+                 else if (storageResponse == StorageResponse.NotFound)
                  {
                      // Return an empty set of gestures to match OpenSim.Grid.InventoryServer.exe behavior
-                     context.Response.StatusCode = (int)HttpStatusCode.OK;
+                     response.Status = HttpStatusCode.OK;
-                     SerializeItemList(context.Response.OutputStream, new List<InventoryItem>(0));
+                     SerializeItemList(response.Body, new List<InventoryItem>(0));
+                     response.Body.Flush();
                  }
                  else
                  {
-                     context.Response.StatusCode = (int)HttpStatusCode.InternalServerError;
+                     response.Status = HttpStatusCode.InternalServerError;
                  }
              }
              else
              {
-                 context.Response.StatusCode = (int)HttpStatusCode.BadRequest;
+                 response.Status = HttpStatusCode.BadRequest;
              }
+             return true;
          }
          StorageResponse CreateFolder(string name, UUID ownerID, UUID parentID, AssetType assetType, UUID sessionID)
          {
              InventoryFolder folder = new InventoryFolder(name, ownerID, parentID, (short)assetType);
-             return server.InventoryProvider.TryCreateFolder(folder, sessionID);
+             Uri owner = Utils.GetOpenSimUri(ownerID);
+             return server.InventoryProvider.TryCreateFolder(owner, folder, sessionID);
          }
          UUID DeserializeUUID(Stream stream)

 Legend:



Removed from v.49
 


changed lines


 
Added in v.66
 Legend:



Removed from v.49
 


changed lines


 
Added in v.66
-Removed from v.49
+Added in v.66

	ViewVC Help
Powered by ViewVC 1.0.0

MyGforge Home

Cable Beach Asset Server

Diff of /trunk/AssetServer/Extensions/OpenSimInventoryFrontend.cs