1 files changed, 135 insertions, 0 deletions
diff --git a/OpenSim/Region/GridInterfaces/Remote/RemoteAssetServer.cs b/OpenSim/Region/GridInterfaces/Remote/RemoteAssetServer.cs
new file mode 100644
index 0000000..4652f70
--- /dev/null
+++ b/OpenSim/Region/GridInterfaces/Remote/RemoteAssetServer.cs
@@ -0,0 +1,135 @@
+/*
+* Copyright (c) Contributors, http://www.openmetaverse.org/
+* 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 OpenSim Project nor the
+*       names of its contributors may be used to endorse or promote products
+*       derived from this software without specific prior written permission.
+*
+* THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``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 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 System.Collections.Generic;
+using System.Text;
+using System.Threading;
+using System.Net;
+using System.Net.Sockets;
+using System.IO;
+using libsecondlife;
+using OpenSim.Framework.Interfaces;
+using OpenSim.Framework.Types;
+using OpenSim.Framework.Utilities;
+namespace OpenSim.Region.GridInterfaces.Remote
+{
+    public class RemoteAssetServer : IAssetServer
+    {
+        private IAssetReceiver _receiver;
+        private BlockingQueue<ARequest> _assetRequests;
+        private Thread _remoteAssetServerThread;
+        private string AssetServerUrl;
+        private string AssetSendKey;
+        public RemoteAssetServer()
+        {
+            this._assetRequests = new BlockingQueue<ARequest>();
+            this._remoteAssetServerThread = new Thread(new ThreadStart(RunRequests));
+            this._remoteAssetServerThread.IsBackground = true;
+            this._remoteAssetServerThread.Start();
+            OpenSim.Framework.Console.MainLog.Instance.Verbose("Remote Asset Server class created");
+        }
+        public void SetReceiver(IAssetReceiver receiver)
+        {
+            this._receiver = receiver;
+        }
+        public void RequestAsset(LLUUID assetID, bool isTexture)
+        {
+            ARequest req = new ARequest();
+            req.AssetID = assetID;
+            req.IsTexture = isTexture;
+            this._assetRequests.Enqueue(req);
+        }
+        public void UpdateAsset(AssetBase asset)
+        {
+        }
+        public void UploadNewAsset(AssetBase asset)
+        {
+            Encoding Windows1252Encoding = Encoding.GetEncoding(1252);
+            string ret = Windows1252Encoding.GetString(asset.Data);
+            byte[] buffer = Windows1252Encoding.GetBytes(ret);
+            WebClient client = new WebClient();
+            client.UploadData(this.AssetServerUrl + "assets/" + asset.FullID, buffer);
+        }
+        public void SetServerInfo(string ServerUrl, string ServerKey)
+        {
+            this.AssetServerUrl = ServerUrl;
+            this.AssetSendKey = ServerKey;
+        }
+        private void RunRequests()
+        {
+            while (true)
+            {
+                //we need to add support for the asset server not knowing about a requested asset
+                // 404... THE MAGIC FILE NOT FOUND ERROR, very useful for telling you things such as a file (or asset ;) ) not being found!!!!!!!!!!! it's 2:22AM
+                ARequest req = this._assetRequests.Dequeue();
+                LLUUID assetID = req.AssetID;
+              //  OpenSim.Framework.Console.MainLog.Instance.Verbose(" RemoteAssetServer- Got a AssetServer request, processing it - " + this.AssetServerUrl + "assets/" + assetID);
+                WebRequest AssetLoad = WebRequest.Create(this.AssetServerUrl + "assets/" + assetID);
+                WebResponse AssetResponse = AssetLoad.GetResponse();
+                byte[] idata = new byte[(int)AssetResponse.ContentLength];
+                BinaryReader br = new BinaryReader(AssetResponse.GetResponseStream());
+                idata = br.ReadBytes((int)AssetResponse.ContentLength);
+                br.Close();
+                
+                AssetBase asset = new AssetBase();
+                asset.FullID = assetID;
+                asset.Data = idata;
+                _receiver.AssetReceived(asset, req.IsTexture);
+            }
+        }
+        public void Close()
+        {
+        }
+    }
+    public class RemoteAssetPlugin : IAssetPlugin
+    {
+        public RemoteAssetPlugin()
+        {
+        }
+        public IAssetServer GetAssetServer()
+        {
+            return (new RemoteAssetServer());
+        }
+    }
+}

diff --git a/OpenSim/Region/GridInterfaces/Remote/RemoteAssetServer.cs b/OpenSim/Region/GridInterfaces/Remote/RemoteAssetServer.cs new file mode 100644 index 0000000..4652f70 --- /dev/null +++ b/OpenSim/Region/GridInterfaces/Remote/RemoteAssetServer.cs
@@ -0,0 +1,135 @@
	1	/*
	2	* Copyright (c) Contributors, http://www.openmetaverse.org/
	3	* See CONTRIBUTORS.TXT for a full list of copyright holders.
	4	*
	5	* Redistribution and use in source and binary forms, with or without
	6	* modification, are permitted provided that the following conditions are met:
	7	* * Redistributions of source code must retain the above copyright
	8	* notice, this list of conditions and the following disclaimer.
	9	* * Redistributions in binary form must reproduce the above copyright
	10	* notice, this list of conditions and the following disclaimer in the
	11	* documentation and/or other materials provided with the distribution.
	12	* * Neither the name of the OpenSim Project nor the
	13	* names of its contributors may be used to endorse or promote products
	14	* derived from this software without specific prior written permission.
	15	*
	16	* THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS AND ANY
	17	* EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
	18	* WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
	19	* DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY
	20	* DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
	21	* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
	22	* LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
	23	* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
	24	* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
	25	* SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
	26	*
	27	*/
	28	using System;
	29	using System.Collections.Generic;
	30	using System.Text;
	31	using System.Threading;
	32	using System.Net;
	33	using System.Net.Sockets;
	34	using System.IO;
	35	using libsecondlife;
	36	using OpenSim.Framework.Interfaces;
	37	using OpenSim.Framework.Types;
	38	using OpenSim.Framework.Utilities;
	39
	40	namespace OpenSim.Region.GridInterfaces.Remote
	41	{
	42	public class RemoteAssetServer : IAssetServer
	43	{
	44	private IAssetReceiver _receiver;
	45	private BlockingQueue<ARequest> _assetRequests;
	46	private Thread _remoteAssetServerThread;
	47	private string AssetServerUrl;
	48	private string AssetSendKey;
	49
	50	public RemoteAssetServer()
	51	{
	52	this._assetRequests = new BlockingQueue<ARequest>();
	53	this._remoteAssetServerThread = new Thread(new ThreadStart(RunRequests));
	54	this._remoteAssetServerThread.IsBackground = true;
	55	this._remoteAssetServerThread.Start();
	56	OpenSim.Framework.Console.MainLog.Instance.Verbose("Remote Asset Server class created");
	57	}
	58
	59	public void SetReceiver(IAssetReceiver receiver)
	60	{
	61	this._receiver = receiver;
	62	}
	63
	64	public void RequestAsset(LLUUID assetID, bool isTexture)
	65	{
	66	ARequest req = new ARequest();
	67	req.AssetID = assetID;
	68	req.IsTexture = isTexture;
	69	this._assetRequests.Enqueue(req);
	70	}
	71
	72	public void UpdateAsset(AssetBase asset)
	73	{
	74
	75	}
	76
	77	public void UploadNewAsset(AssetBase asset)
	78	{
	79	Encoding Windows1252Encoding = Encoding.GetEncoding(1252);
	80	string ret = Windows1252Encoding.GetString(asset.Data);
	81	byte[] buffer = Windows1252Encoding.GetBytes(ret);
	82	WebClient client = new WebClient();
	83	client.UploadData(this.AssetServerUrl + "assets/" + asset.FullID, buffer);
	84
	85	}
	86
	87	public void SetServerInfo(string ServerUrl, string ServerKey)
	88	{
	89	this.AssetServerUrl = ServerUrl;
	90	this.AssetSendKey = ServerKey;
	91	}
	92
	93	private void RunRequests()
	94	{
	95	while (true)
	96	{
	97	//we need to add support for the asset server not knowing about a requested asset
	98	// 404... THE MAGIC FILE NOT FOUND ERROR, very useful for telling you things such as a file (or asset ;) ) not being found!!!!!!!!!!! it's 2:22AM
	99	ARequest req = this._assetRequests.Dequeue();
	100	LLUUID assetID = req.AssetID;
	101	// OpenSim.Framework.Console.MainLog.Instance.Verbose(" RemoteAssetServer- Got a AssetServer request, processing it - " + this.AssetServerUrl + "assets/" + assetID);
	102	WebRequest AssetLoad = WebRequest.Create(this.AssetServerUrl + "assets/" + assetID);
	103	WebResponse AssetResponse = AssetLoad.GetResponse();
	104	byte[] idata = new byte[(int)AssetResponse.ContentLength];
	105	BinaryReader br = new BinaryReader(AssetResponse.GetResponseStream());
	106	idata = br.ReadBytes((int)AssetResponse.ContentLength);
	107	br.Close();
	108
	109	AssetBase asset = new AssetBase();
	110	asset.FullID = assetID;
	111	asset.Data = idata;
	112	_receiver.AssetReceived(asset, req.IsTexture);
	113	}
	114	}
	115
	116	public void Close()
	117	{
	118
	119	}
	120	}
	121
	122	public class RemoteAssetPlugin : IAssetPlugin
	123	{
	124	public RemoteAssetPlugin()
	125	{
	126
	127	}
	128
	129	public IAssetServer GetAssetServer()
	130	{
	131	return (new RemoteAssetServer());
	132	}
	133	}
	134
	135	}