diff options
Diffstat (limited to 'OpenSim/Services/Connectors/Hypergrid/GatekeeperServiceConnector.cs')
-rw-r--r-- | OpenSim/Services/Connectors/Hypergrid/GatekeeperServiceConnector.cs | 272 |
1 files changed, 272 insertions, 0 deletions
diff --git a/OpenSim/Services/Connectors/Hypergrid/GatekeeperServiceConnector.cs b/OpenSim/Services/Connectors/Hypergrid/GatekeeperServiceConnector.cs new file mode 100644 index 0000000..c426bba --- /dev/null +++ b/OpenSim/Services/Connectors/Hypergrid/GatekeeperServiceConnector.cs | |||
@@ -0,0 +1,272 @@ | |||
1 | /* | ||
2 | * Copyright (c) Contributors, http://opensimulator.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 OpenSimulator 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; | ||
30 | using System.Collections.Generic; | ||
31 | using System.Drawing; | ||
32 | using System.Net; | ||
33 | using System.Reflection; | ||
34 | |||
35 | using OpenSim.Framework; | ||
36 | using OpenSim.Services.Interfaces; | ||
37 | using GridRegion = OpenSim.Services.Interfaces.GridRegion; | ||
38 | |||
39 | using OpenMetaverse; | ||
40 | using OpenMetaverse.Imaging; | ||
41 | using Nwc.XmlRpc; | ||
42 | using log4net; | ||
43 | |||
44 | using OpenSim.Services.Connectors.Simulation; | ||
45 | |||
46 | namespace OpenSim.Services.Connectors.Hypergrid | ||
47 | { | ||
48 | public class GatekeeperServiceConnector : SimulationServiceConnector | ||
49 | { | ||
50 | private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType); | ||
51 | |||
52 | private static UUID m_HGMapImage = new UUID("00000000-0000-1111-9999-000000000013"); | ||
53 | |||
54 | private IAssetService m_AssetService; | ||
55 | |||
56 | public GatekeeperServiceConnector() : base() | ||
57 | { | ||
58 | } | ||
59 | |||
60 | public GatekeeperServiceConnector(IAssetService assService) | ||
61 | { | ||
62 | m_AssetService = assService; | ||
63 | } | ||
64 | |||
65 | protected override string AgentPath() | ||
66 | { | ||
67 | return "/foreignagent/"; | ||
68 | } | ||
69 | |||
70 | protected override string ObjectPath() | ||
71 | { | ||
72 | return "/foreignobject/"; | ||
73 | } | ||
74 | |||
75 | public bool LinkRegion(GridRegion info, out UUID regionID, out ulong realHandle, out string externalName, out string imageURL, out string reason) | ||
76 | { | ||
77 | regionID = UUID.Zero; | ||
78 | imageURL = string.Empty; | ||
79 | realHandle = 0; | ||
80 | externalName = string.Empty; | ||
81 | reason = string.Empty; | ||
82 | |||
83 | Hashtable hash = new Hashtable(); | ||
84 | hash["region_name"] = info.RegionName; | ||
85 | |||
86 | IList paramList = new ArrayList(); | ||
87 | paramList.Add(hash); | ||
88 | |||
89 | XmlRpcRequest request = new XmlRpcRequest("link_region", paramList); | ||
90 | string uri = "http://" + info.ExternalEndPoint.Address + ":" + info.HttpPort + "/"; | ||
91 | //m_log.Debug("[GATEKEEPER SERVICE CONNECTOR]: Linking to " + uri); | ||
92 | XmlRpcResponse response = null; | ||
93 | try | ||
94 | { | ||
95 | response = request.Send(uri, 10000); | ||
96 | } | ||
97 | catch (Exception e) | ||
98 | { | ||
99 | m_log.Debug("[GATEKEEPER SERVICE CONNECTOR]: Exception " + e.Message); | ||
100 | reason = "Error contacting remote server"; | ||
101 | return false; | ||
102 | } | ||
103 | |||
104 | if (response.IsFault) | ||
105 | { | ||
106 | reason = response.FaultString; | ||
107 | m_log.ErrorFormat("[GATEKEEPER SERVICE CONNECTOR]: remote call returned an error: {0}", response.FaultString); | ||
108 | return false; | ||
109 | } | ||
110 | |||
111 | hash = (Hashtable)response.Value; | ||
112 | //foreach (Object o in hash) | ||
113 | // m_log.Debug(">> " + ((DictionaryEntry)o).Key + ":" + ((DictionaryEntry)o).Value); | ||
114 | try | ||
115 | { | ||
116 | bool success = false; | ||
117 | Boolean.TryParse((string)hash["result"], out success); | ||
118 | if (success) | ||
119 | { | ||
120 | UUID.TryParse((string)hash["uuid"], out regionID); | ||
121 | //m_log.Debug(">> HERE, uuid: " + uuid); | ||
122 | if ((string)hash["handle"] != null) | ||
123 | { | ||
124 | realHandle = Convert.ToUInt64((string)hash["handle"]); | ||
125 | //m_log.Debug(">> HERE, realHandle: " + realHandle); | ||
126 | } | ||
127 | if (hash["region_image"] != null) | ||
128 | imageURL = (string)hash["region_image"]; | ||
129 | if (hash["external_name"] != null) | ||
130 | externalName = (string)hash["external_name"]; | ||
131 | } | ||
132 | |||
133 | } | ||
134 | catch (Exception e) | ||
135 | { | ||
136 | reason = "Error parsing return arguments"; | ||
137 | m_log.Error("[GATEKEEPER SERVICE CONNECTOR]: Got exception while parsing hyperlink response " + e.StackTrace); | ||
138 | return false; | ||
139 | } | ||
140 | |||
141 | return true; | ||
142 | } | ||
143 | |||
144 | UUID m_MissingTexture = new UUID("5748decc-f629-461c-9a36-a35a221fe21f"); | ||
145 | |||
146 | public UUID GetMapImage(UUID regionID, string imageURL) | ||
147 | { | ||
148 | if (m_AssetService == null) | ||
149 | return m_MissingTexture; | ||
150 | |||
151 | try | ||
152 | { | ||
153 | |||
154 | WebClient c = new WebClient(); | ||
155 | //m_log.Debug("JPEG: " + imageURL); | ||
156 | string filename = regionID.ToString(); | ||
157 | c.DownloadFile(imageURL, filename + ".jpg"); | ||
158 | Bitmap m = new Bitmap(filename + ".jpg"); | ||
159 | //m_log.Debug("Size: " + m.PhysicalDimension.Height + "-" + m.PhysicalDimension.Width); | ||
160 | byte[] imageData = OpenJPEG.EncodeFromImage(m, true); | ||
161 | AssetBase ass = new AssetBase(UUID.Random(), "region " + filename, (sbyte)AssetType.Texture, regionID.ToString()); | ||
162 | |||
163 | // !!! for now | ||
164 | //info.RegionSettings.TerrainImageID = ass.FullID; | ||
165 | |||
166 | ass.Temporary = true; | ||
167 | ass.Local = true; | ||
168 | ass.Data = imageData; | ||
169 | |||
170 | m_AssetService.Store(ass); | ||
171 | |||
172 | // finally | ||
173 | return ass.FullID; | ||
174 | |||
175 | } | ||
176 | catch // LEGIT: Catching problems caused by OpenJPEG p/invoke | ||
177 | { | ||
178 | m_log.Warn("[GATEKEEPER SERVICE CONNECTOR]: Failed getting/storing map image, because it is probably already in the cache"); | ||
179 | } | ||
180 | return UUID.Zero; | ||
181 | } | ||
182 | |||
183 | public GridRegion GetHyperlinkRegion(GridRegion gatekeeper, UUID regionID) | ||
184 | { | ||
185 | Hashtable hash = new Hashtable(); | ||
186 | hash["region_uuid"] = regionID.ToString(); | ||
187 | |||
188 | IList paramList = new ArrayList(); | ||
189 | paramList.Add(hash); | ||
190 | |||
191 | XmlRpcRequest request = new XmlRpcRequest("get_region", paramList); | ||
192 | string uri = "http://" + gatekeeper.ExternalEndPoint.Address + ":" + gatekeeper.HttpPort + "/"; | ||
193 | m_log.Debug("[GATEKEEPER SERVICE CONNECTOR]: contacting " + uri); | ||
194 | XmlRpcResponse response = null; | ||
195 | try | ||
196 | { | ||
197 | response = request.Send(uri, 10000); | ||
198 | } | ||
199 | catch (Exception e) | ||
200 | { | ||
201 | m_log.Debug("[GATEKEEPER SERVICE CONNECTOR]: Exception " + e.Message); | ||
202 | return null; | ||
203 | } | ||
204 | |||
205 | if (response.IsFault) | ||
206 | { | ||
207 | m_log.ErrorFormat("[GATEKEEPER SERVICE CONNECTOR]: remote call returned an error: {0}", response.FaultString); | ||
208 | return null; | ||
209 | } | ||
210 | |||
211 | hash = (Hashtable)response.Value; | ||
212 | //foreach (Object o in hash) | ||
213 | // m_log.Debug(">> " + ((DictionaryEntry)o).Key + ":" + ((DictionaryEntry)o).Value); | ||
214 | try | ||
215 | { | ||
216 | bool success = false; | ||
217 | Boolean.TryParse((string)hash["result"], out success); | ||
218 | if (success) | ||
219 | { | ||
220 | GridRegion region = new GridRegion(); | ||
221 | |||
222 | UUID.TryParse((string)hash["uuid"], out region.RegionID); | ||
223 | //m_log.Debug(">> HERE, uuid: " + region.RegionID); | ||
224 | int n = 0; | ||
225 | if (hash["x"] != null) | ||
226 | { | ||
227 | Int32.TryParse((string)hash["x"], out n); | ||
228 | region.RegionLocX = n; | ||
229 | //m_log.Debug(">> HERE, x: " + region.RegionLocX); | ||
230 | } | ||
231 | if (hash["y"] != null) | ||
232 | { | ||
233 | Int32.TryParse((string)hash["y"], out n); | ||
234 | region.RegionLocY = n; | ||
235 | //m_log.Debug(">> HERE, y: " + region.RegionLocY); | ||
236 | } | ||
237 | if (hash["region_name"] != null) | ||
238 | { | ||
239 | region.RegionName = (string)hash["region_name"]; | ||
240 | //m_log.Debug(">> HERE, name: " + region.RegionName); | ||
241 | } | ||
242 | if (hash["hostname"] != null) | ||
243 | region.ExternalHostName = (string)hash["hostname"]; | ||
244 | if (hash["http_port"] != null) | ||
245 | { | ||
246 | uint p = 0; | ||
247 | UInt32.TryParse((string)hash["http_port"], out p); | ||
248 | region.HttpPort = p; | ||
249 | } | ||
250 | if (hash["internal_port"] != null) | ||
251 | { | ||
252 | int p = 0; | ||
253 | Int32.TryParse((string)hash["internal_port"], out p); | ||
254 | region.InternalEndPoint = new IPEndPoint(IPAddress.Parse("0.0.0.0"), p); | ||
255 | } | ||
256 | |||
257 | // Successful return | ||
258 | return region; | ||
259 | } | ||
260 | |||
261 | } | ||
262 | catch (Exception e) | ||
263 | { | ||
264 | m_log.Error("[GATEKEEPER SERVICE CONNECTOR]: Got exception while parsing hyperlink response " + e.StackTrace); | ||
265 | return null; | ||
266 | } | ||
267 | |||
268 | return null; | ||
269 | } | ||
270 | |||
271 | } | ||
272 | } | ||