2 files changed, 154 insertions, 0 deletions

diff --git a/OpenSim/Framework/Communications/Clients/InventoryClient.cs b/OpenSim/Framework/Communications/Clients/InventoryClient.cs
new file mode 100644
index 0000000..8fe4268
--- /dev/null
+++ b/OpenSim/Framework/Communications/Clients/InventoryClient.cs
@@ -0,0 +1,78 @@
+/**
+ * Copyright (c), Contributors. All rights reserved.
+ * See CONTRIBUTORS.TXT for a full list of copyright holders.
+ *
+ * Redistribution and use in source and binary forms, with or without modification,
+ * are permitted provided that the following conditions are met:
+ *
+ *     * Redistributions of source code must retain the above copyright notice,
+ *       this list of conditions and the following disclaimer.
+ *     * Redistributions in binary form must reproduce the above copyright notice,
+ *       this list of conditions and the following disclaimer in the documentation
+ *       and/or other materials provided with the distribution.
+ *     * Neither the name of the Organizations nor the names of Individual
+ *       Contributors may be used to endorse or promote products derived from
+ *       this software without specific prior written permission.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND
+ * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
+ * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL
+ * THE COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
+ * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE
+ * GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
+ * AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
+ * NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED
+ * OF THE POSSIBILITY OF SUCH DAMAGE.
+ *
+ */
+
+using System;
+using OpenSim.Framework.Servers;
+
+using OpenMetaverse;
+
+namespace OpenSim.Framework.Communications.Clients
+{
+    public class InventoryClient
+    {
+        private string ServerURL;
+
+        public InventoryClient(string url)
+        {
+            ServerURL = url;
+        }
+
+        public void GetInventoryItemAsync(InventoryItemBase item, ReturnResponse<InventoryItemBase> callBack)
+        {
+            System.Console.WriteLine("[HGrid] GetInventory from " + ServerURL);
+            try
+            {
+                RestSessionObjectPosterResponse<InventoryItemBase, InventoryItemBase> requester
+                        = new RestSessionObjectPosterResponse<InventoryItemBase, InventoryItemBase>();
+                requester.ResponseCallback = callBack;
+
+                requester.BeginPostObject(ServerURL + "/GetItem/", item, string.Empty, string.Empty);
+            }
+            catch (Exception e)
+            {
+                System.Console.WriteLine("[HGrid]: Exception posting to inventory: " + e);
+            }
+        }
+
+        public InventoryItemBase GetInventoryItem(InventoryItemBase item)
+        {
+            System.Console.WriteLine("[HGrid] GetInventory " + item.ID + " from " + ServerURL);
+            try
+            {
+                item = SynchronousRestSessionObjectPoster<Guid, InventoryItemBase>.BeginPostObject("POST", ServerURL + "/GetItem/", item.ID.Guid, "", "");
+                return item;
+            }
+            catch (Exception e)
+            {
+                System.Console.WriteLine("[HGrid]: Exception posting to inventory: " + e);
+            }
+            return null;
+        }
+
+    }
+}
diff --git a/OpenSim/Framework/Communications/Clients/RegionClient.cs b/OpenSim/Framework/Communications/Clients/RegionClient.cs
index d98852b..196bcf9 100644
--- a/OpenSim/Framework/Communications/Clients/RegionClient.cs
+++ b/OpenSim/Framework/Communications/Clients/RegionClient.cs
@@ -417,6 +417,82 @@ namespace OpenSim.Framework.Communications.Clients
 

         }

 

+        public bool DoCreateObjectCall(RegionInfo region, UUID userID, UUID itemID)

+        {

+            ulong regionHandle = GetRegionHandle(region.RegionHandle);

+            string uri = "http://" + region.ExternalEndPoint.Address + ":" + region.HttpPort + "/object/" + UUID.Zero + "/" + regionHandle.ToString() + "/";

+            //m_log.Debug("   >>> DoCreateChildAgentCall <<< " + uri);

+

+            WebRequest ObjectCreateRequest = WebRequest.Create(uri);

+            ObjectCreateRequest.Method = "PUT";

+            ObjectCreateRequest.ContentType = "application/json";

+            ObjectCreateRequest.Timeout = 10000;

+

+            OSDMap args = new OSDMap(2);

+            args["userid"] = OSD.FromUUID(userID);

+            args["itemid"] = OSD.FromUUID(itemID);

+

+            string strBuffer = "";

+            byte[] buffer = new byte[1];

+            try

+            {

+                strBuffer = OSDParser.SerializeJsonString(args);

+                UTF8Encoding str = new UTF8Encoding();

+                buffer = str.GetBytes(strBuffer);

+

+            }

+            catch (Exception e)

+            {

+                m_log.WarnFormat("[REST COMMS]: Exception thrown on serialization of CreateObject: {0}", e.Message);

+                // ignore. buffer will be empty, caller should check.

+            }

+

+            Stream os = null;

+            try

+            { // send the Post

+                ObjectCreateRequest.ContentLength = buffer.Length;   //Count bytes to send

+                os = ObjectCreateRequest.GetRequestStream();

+                os.Write(buffer, 0, strBuffer.Length);         //Send it

+                os.Close();

+                //m_log.InfoFormat("[REST COMMS]: Posted CreateObject request to remote sim {0}", uri);

+            }

+            //catch (WebException ex)

+            catch

+            {

+                // m_log.InfoFormat("[REST COMMS]: Bad send on CreateObject {0}", ex.Message);

+

+                return false;

+            }

+

+            // Let's wait for the response

+            //m_log.Info("[REST COMMS]: Waiting for a reply after DoCreateChildAgentCall");

+

+            try

+            {

+                WebResponse webResponse = ObjectCreateRequest.GetResponse();

+                if (webResponse == null)

+                {

+                    m_log.Info("[REST COMMS]: Null reply on DoCreateObjectCall post");

+                }

+

+                StreamReader sr = new StreamReader(webResponse.GetResponseStream());

+                sr.ReadToEnd().Trim();

+                sr.ReadToEnd().Trim();

+                sr.Close();

+                

+                //m_log.InfoFormat("[REST COMMS]: DoCreateChildAgentCall reply was {0} ", reply);

+

+            }

+            catch (WebException ex)

+            {

+                m_log.InfoFormat("[REST COMMS]: exception on reply of DoCreateObjectCall {0}", ex.Message);

+                // ignore, really

+            }

+

+            return true;

+

+        }

+

         public bool DoHelloNeighbourCall(RegionInfo region, RegionInfo thisRegion)

         {

             string uri = "http://" + region.ExternalEndPoint.Address + ":" + region.HttpPort + "/region/" + thisRegion.RegionID + "/";