OpenSimulator GForge > Projects > Cable Beach Asset Server > SVN

Diff of /trunk/AssetClient/AssetClient.cs

-revision 42, Wed Dec  3 01:12:12 2008 UTC
+revision 47, Mon Dec 15 19:27:36 2008 UTC
 Line 30
  using System;
  using System.Net;
  using System.IO;
+ using System.Text;
  using System.Xml;
  using OpenMetaverse;
  using OpenMetaverse.StructuredData;
-Line 38
+Line 39
  {
      public static class AssetClient
      {
-         public static bool TryGetAsset(UUID assetID, string assetURL, out byte[] assetData)
+         public static bool TryGetAuthToken(Uri claimedIdentifier, string firstName, string lastName, string password,
+             Uri serverUrl, out UUID authToken)
+         {
+             authToken = UUID.Zero;
+             serverUrl = new Uri(serverUrl, "authenticate");
+             OSDMap osd = new OSDMap(1);
+             osd.Add("identifier", OSD.FromUri(claimedIdentifier));
+             byte[] postData = Encoding.UTF8.GetBytes(OSDParser.SerializeJson(osd).ToJson());
+             try
+             {
+                 HttpWebRequest request = (HttpWebRequest)WebRequest.Create(serverUrl);
+                 request.Method = "POST";
+                 request.ContentLength = postData.Length;
+                 request.ContentType = "application/json";
+                 using (Stream stream = request.GetRequestStream())
+                     stream.Write(postData, 0, postData.Length);
+                 HttpWebResponse response = (HttpWebResponse)request.GetResponse();
+                 if (response.ResponseUri.Authority == claimedIdentifier.Authority)
+                 {
+                     // This response came from the OpenID provider (user server).
+                     // Send back a form with our filled in data
+                     postData = Encoding.UTF8.GetBytes(
+                         String.Format("first={0}&last={1}&pass={2}", firstName, lastName, Utils.MD5(password)));
+                     request = (HttpWebRequest)WebRequest.Create(response.ResponseUri);
+                     request.Method = "POST";
+                     request.ContentLength = postData.Length;
+                     request.ContentType = "application/x-www-form-urlencoded";
+                     using (Stream stream = request.GetRequestStream())
+                         stream.Write(postData, 0, postData.Length);
+                     response = (HttpWebResponse)request.GetResponse();
+                     if (response.ResponseUri.Authority == serverUrl.Authority)
+                     {
+                         // This response came from the OpenID consumer (asset server)
+                         if (response.StatusCode == HttpStatusCode.OK)
+                         {
+                             using (Stream stream = response.GetResponseStream())
+                             {
+                                 OSDMap map = OSDParser.DeserializeJson(stream) as OSDMap;
+                                 if (map != null && map.ContainsKey("auth_token"))
+                                 {
+                                     authToken = map["auth_token"].AsUUID();
+                                     return true;
+                                 }
+                             }
+                         }
+                     }
+                     else
+                     {
+                     }
+                 }
+             }
+             catch (WebException ex)
+             {
+                 PrintWebException(ex);
+             }
+             return false;
+         }
+         public static bool TryGetAsset(UUID assetID, UUID authToken, Uri assetLocation, out byte[] assetData)
          {
              assetData = null;
              try
              {
-                 HttpWebRequest request = (HttpWebRequest)WebRequest.Create(assetURL);
+                 HttpWebRequest request = (HttpWebRequest)WebRequest.Create(assetLocation);
+                 AddAuthorizeHeader(request, authToken);
                  HttpWebResponse response = (HttpWebResponse)request.GetResponse();
                  if (response.StatusCode == HttpStatusCode.OK)
-Line 65
+Line 136
              catch (WebException ex)
              {
                  if (ex.Response == null || ((HttpWebResponse)ex.Response).StatusCode != HttpStatusCode.NotFound)
-                     Console.WriteLine("[ERROR] " + ex.Message);
+                     PrintWebException(ex);
              }
              return false;
          }
-         public static bool TryGetMetadata(UUID assetID, string serverURL, out byte[] metadata)
+         public static bool TryGetMetadata(UUID assetID, UUID authToken, Uri serverUrl, out byte[] metadata)
          {
              metadata = null;
-             serverURL = serverURL.TrimEnd('/');
+             serverUrl = new Uri(serverUrl, String.Format("{0}/metadata", assetID));
-             string requestURL = String.Format("{0}/{1}/metadata", serverURL, assetID);
              try
              {
-                 HttpWebRequest request = (HttpWebRequest)WebRequest.Create(requestURL);
+                 HttpWebRequest request = (HttpWebRequest)WebRequest.Create(serverUrl);
+                 AddAuthorizeHeader(request, authToken);
                  HttpWebResponse response = (HttpWebResponse)request.GetResponse();
                  if (response.StatusCode == HttpStatusCode.OK)
-Line 100
+Line 171
              catch (WebException ex)
              {
                  if (ex.Response == null || ((HttpWebResponse)ex.Response).StatusCode != HttpStatusCode.NotFound)
-                     Console.WriteLine("[ERROR] " + ex.Message);
+                     PrintWebException(ex);
              }
              return false;
          }
-         public static UUID CreateAsset(string name, string description, string contentType, bool temporary, string serverURL, byte[] assetData)
+         public static UUID CreateAsset(string name, string description, string contentType, bool temporary,
+             UUID authToken, Uri serverUrl, byte[] assetData, UUID assetID)
          {
-             return CreateAsset(name, description, contentType, temporary, serverURL, assetData, UUID.Zero);
+             string requestURL = String.Format("{0}{1}", serverUrl, "createasset");
-         }
-         public static UUID CreateAsset(string name, string description, string contentType, bool temporary, string serverURL, byte[] assetData,
+             OSDMap osd = new OSDMap();
-             UUID assetID)
-         {
-             serverURL = serverURL.TrimEnd('/');
-             string requestURL = serverURL + "/createasset";
-             OSDMap map = new OSDMap();
-             if (assetID != UUID.Zero) map["id"] = OSD.FromUUID(assetID);
+             if (assetID != UUID.Zero) osd["id"] = OSD.FromUUID(assetID);
-             map["name"] = OSD.FromString(name);
+             osd["name"] = OSD.FromString(name);
-             map["description"] = OSD.FromString(description);
+             osd["description"] = OSD.FromString(description);
-             map["type"] = OSD.FromString(contentType);
+             osd["type"] = OSD.FromString(contentType);
-             map["temporary"] = OSD.FromBoolean(temporary);
+             osd["temporary"] = OSD.FromBoolean(temporary);
-             map["data"] = OSD.FromBinary(assetData);
+             osd["data"] = OSD.FromBinary(assetData);
-             LitJson.JsonData jsonData = OSDParser.SerializeJson(map);
+             byte[] postData = Encoding.UTF8.GetBytes(OSDParser.SerializeJson(osd).ToJson());
-             string jsonString = jsonData.ToJson();
-             byte[] postData = System.Text.Encoding.UTF8.GetBytes(jsonString);
              try
              {
                  HttpWebRequest request = (HttpWebRequest)WebRequest.Create(requestURL);
+                 AddAuthorizeHeader(request, authToken);
                  request.Method = "POST";
                  request.ContentLength = postData.Length;
+                 request.ContentType = "application/json";
                  using (Stream stream = request.GetRequestStream())
                  {
-Line 170
+Line 235
              }
              catch (WebException ex)
              {
-                 Console.WriteLine("[ERROR] " + ex.Message);
+                 PrintWebException(ex);
              }
              return UUID.Zero;
          }
+         static void AddAuthorizeHeader(HttpWebRequest request, UUID authToken)
+         {
+             if (authToken != UUID.Zero)
+                 request.Headers.Add(HttpRequestHeader.Authorization, String.Format("OpenGrid {0}", authToken));
+         }
+         static void PrintWebException(WebException ex)
+         {
+             if (ex.Response != null)
+             {
+                 HttpWebResponse response = (HttpWebResponse)ex.Response;
+                 if (!String.IsNullOrEmpty(response.StatusDescription))
+                 {
+                     Console.WriteLine("[ERROR] The remote server returned an error: " + response.StatusDescription);
+                     return;
+                 }
+             }
+             Console.WriteLine("[ERROR] " + ex.Message);
+         }
      }
  }

 Legend:



Removed from v.42
 


changed lines


 
Added in v.47
 Legend:



Removed from v.42
 


changed lines


 
Added in v.47
-Removed from v.42
+Added in v.47

	ViewVC Help
Powered by ViewVC 1.0.0

MyGforge Home

Cable Beach Asset Server

Diff of /trunk/AssetClient/AssetClient.cs