OpenSimulator GForge > Projects > Cable Beach Asset Server > SVN

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

-revision 56, Wed Dec 17 23:26:58 2008 UTC
+revision 57, Tue Dec 30 03:01:04 2008 UTC
 Line 34
  using System.Xml;
  using ExtensionLoader;
  using OpenMetaverse;
+ using HttpServer;
  namespace AssetServer.Extensions
  {
-Line 50
+Line 51
              this.server = server;
              // Asset request
-             server.HttpServer.AddHandler("get", null, @"^/assets/",
+             server.HttpServer.AddHandler("get", null, @"^/assets/", AssetRequestHandler);
-                 AssetRequestHandler);
              // Asset creation
-             server.HttpServer.AddHandler("post", null, @"^/assets/",
+             server.HttpServer.AddHandler("post", null, @"^/assets/", AssetPostHandler);
-                 AssetPostHandler);
          }
          public void Stop()
          {
          }
-         void AssetRequestHandler(ref HttpListenerContext context)
+         bool AssetRequestHandler(IHttpClientContext client, IHttpRequest request, IHttpResponse response)
          {
              UUID assetID;
              // Split the URL up to get the asset ID out
-             string[] rawUrl = context.Request.RawUrl.Split('/');
+             string[] rawUrl = request.Uri.PathAndQuery.Split('/');
              if (rawUrl.Length >= 3 && rawUrl[2].Length >= 36 && UUID.TryParse(rawUrl[2].Substring(0, 36), out assetID))
              {
-Line 120
+Line 119
                          writer.Flush();
                          byte[] buffer = stream.GetBuffer();
-                         context.Response.StatusCode = (int)HttpStatusCode.OK;
+                         response.Status = HttpStatusCode.OK;
-                         context.Response.ContentType = "application/xml";
+                         response.ContentType = "application/xml";
-                         context.Response.ContentLength64 = (int)stream.Length;
+                         response.ContentLength = stream.Length;
-                         context.Response.OutputStream.Write(buffer, 0, (int)stream.Length);
+                         response.Body.Write(buffer, 0, (int)stream.Length);
+                         response.Body.Flush();
-                         return;
+                         return true;
                      }
                      else
                      {
 Line 138
                  }
              }
-             context.Response.StatusCode = (int)HttpStatusCode.NotFound;
+             response.Status = HttpStatusCode.NotFound;
+             return true;
          }
-         void AssetPostHandler(ref HttpListenerContext context)
+         bool AssetPostHandler(IHttpClientContext client, IHttpRequest request, IHttpResponse response)
          {
              byte[] assetData = null;
              Metadata metadata = new Metadata();
              try
              {
-                 using (XmlReader reader = XmlReader.Create(context.Request.InputStream))
+                 using (XmlReader reader = XmlReader.Create(request.Body))
                  {
                      reader.MoveToContent();
                      reader.ReadStartElement("AssetBase");
-Line 186
+Line 187
                      metadata.SHA1 = OpenMetaverse.Utils.SHA1(assetData);
                      metadata.CreationDate = DateTime.Now;
-                     StorageResponse response = server.StorageProvider.TryCreateAsset(metadata, assetData, UUID.Zero);
+                     StorageResponse storageResponse = server.StorageProvider.TryCreateAsset(metadata, assetData, UUID.Zero);
-                     switch (response)
+                     switch (storageResponse)
                      {
                          case StorageResponse.Success:
-                             context.Response.StatusCode = (int)HttpStatusCode.Created;
+                             response.Status = HttpStatusCode.Created;
                              break;
                          case StorageResponse.NotFound:
-                             context.Response.StatusCode = (int)HttpStatusCode.NotFound;
+                             response.Status = HttpStatusCode.NotFound;
                              break;
                          case StorageResponse.AuthNeeded:
-                             context.Response.StatusCode = (int)HttpStatusCode.Forbidden;
+                             response.Status = HttpStatusCode.Forbidden;
                              break;
                          case StorageResponse.Failure:
                          default:
-                             context.Response.StatusCode = (int)HttpStatusCode.InternalServerError;
+                             response.Status = HttpStatusCode.InternalServerError;
                              break;
                      }
                  }
                  else
                  {
                      Logger.Log.Warn("AssetPostHandler called with no asset data");
-                     context.Response.StatusCode = (int)HttpStatusCode.BadRequest;
+                     response.Status = HttpStatusCode.BadRequest;
                  }
              }
              catch (Exception ex)
              {
                  Logger.Log.Warn("Failed to parse POST data (expecting AssetBase): " + ex.Message);
-                 context.Response.StatusCode = (int)HttpStatusCode.BadRequest;
+                 response.Status = HttpStatusCode.BadRequest;
              }
+             return true;
          }
      }
  }

 Legend:



Removed from v.56
 


changed lines


 
Added in v.57
 Legend:



Removed from v.56
 


changed lines


 
Added in v.57
-Removed from v.56
+Added in v.57

	ViewVC Help
Powered by ViewVC 1.0.0

MyGforge Home

Cable Beach Asset Server

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