diff options
Diffstat (limited to '')
-rw-r--r-- | OpenSim/Server/Handlers/Hypergrid/AgentHandlers.cs (renamed from OpenSim/Region/Communications/Hypergrid/HGCommunicationsGridMode.cs) | 51 | ||||
-rw-r--r-- | OpenSim/Server/Handlers/Hypergrid/GatekeeperServerConnector.cs | 82 | ||||
-rw-r--r-- | OpenSim/Server/Handlers/Hypergrid/HGInventoryServerInConnector.cs | 104 | ||||
-rw-r--r-- | OpenSim/Server/Handlers/Hypergrid/HomeAgentHandlers.cs | 181 | ||||
-rw-r--r-- | OpenSim/Server/Handlers/Hypergrid/HypergridHandlers.cs | 117 | ||||
-rw-r--r-- | OpenSim/Server/Handlers/Hypergrid/UserAgentServerConnector.cs | 195 |
6 files changed, 709 insertions, 21 deletions
diff --git a/OpenSim/Region/Communications/Hypergrid/HGCommunicationsGridMode.cs b/OpenSim/Server/Handlers/Hypergrid/AgentHandlers.cs index e80f6ab..c951653 100644 --- a/OpenSim/Region/Communications/Hypergrid/HGCommunicationsGridMode.cs +++ b/OpenSim/Server/Handlers/Hypergrid/AgentHandlers.cs | |||
@@ -25,36 +25,45 @@ | |||
25 | * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. | 25 | * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
26 | */ | 26 | */ |
27 | 27 | ||
28 | using System; | ||
29 | using System.Collections; | ||
30 | using System.IO; | ||
28 | using System.Reflection; | 31 | using System.Reflection; |
29 | using log4net; | 32 | using System.Net; |
30 | using OpenSim.Data; | 33 | using System.Text; |
34 | |||
35 | using OpenSim.Server.Base; | ||
36 | using OpenSim.Server.Handlers.Base; | ||
37 | using OpenSim.Services.Interfaces; | ||
38 | using GridRegion = OpenSim.Services.Interfaces.GridRegion; | ||
31 | using OpenSim.Framework; | 39 | using OpenSim.Framework; |
32 | using OpenSim.Framework.Communications; | ||
33 | using OpenSim.Framework.Communications.Cache; | ||
34 | using OpenSim.Framework.Servers; | ||
35 | using OpenSim.Framework.Servers.HttpServer; | 40 | using OpenSim.Framework.Servers.HttpServer; |
36 | using OpenSim.Region.Communications.OGS1; | 41 | using OpenSim.Server.Handlers.Simulation; |
37 | using OpenSim.Region.Framework.Scenes; | 42 | using Utils = OpenSim.Server.Handlers.Simulation.Utils; |
43 | |||
44 | using OpenMetaverse; | ||
45 | using OpenMetaverse.StructuredData; | ||
46 | using Nini.Config; | ||
47 | using log4net; | ||
48 | |||
38 | 49 | ||
39 | namespace OpenSim.Region.Communications.Hypergrid | 50 | namespace OpenSim.Server.Handlers.Hypergrid |
40 | { | 51 | { |
41 | public class HGCommunicationsGridMode : CommunicationsManager // CommunicationsOGS1 | 52 | public class GatekeeperAgentHandler : OpenSim.Server.Handlers.Simulation.AgentHandler |
42 | { | 53 | { |
54 | private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType); | ||
55 | private IGatekeeperService m_GatekeeperService; | ||
43 | 56 | ||
44 | public HGCommunicationsGridMode( | 57 | public GatekeeperAgentHandler(IGatekeeperService gatekeeper) |
45 | NetworkServersInfo serversInfo, | ||
46 | SceneManager sman, LibraryRootFolder libraryRootFolder) | ||
47 | : base(serversInfo, libraryRootFolder) | ||
48 | { | 58 | { |
59 | m_GatekeeperService = gatekeeper; | ||
60 | } | ||
49 | 61 | ||
50 | HGUserServices userServices = new HGUserServices(this); | 62 | protected override bool CreateAgent(GridRegion destination, AgentCircuitData aCircuit, uint teleportFlags, out string reason) |
51 | // This plugin arrangement could eventually be configurable rather than hardcoded here. | 63 | { |
52 | userServices.AddPlugin(new TemporaryUserProfilePlugin()); | 64 | return m_GatekeeperService.LoginAgent(aCircuit, destination, out reason); |
53 | userServices.AddPlugin(new HGUserDataPlugin(this, userServices)); | ||
54 | |||
55 | m_userService = userServices; | ||
56 | m_messageService = userServices; | ||
57 | m_avatarService = userServices; | ||
58 | } | 65 | } |
66 | |||
59 | } | 67 | } |
68 | |||
60 | } | 69 | } |
diff --git a/OpenSim/Server/Handlers/Hypergrid/GatekeeperServerConnector.cs b/OpenSim/Server/Handlers/Hypergrid/GatekeeperServerConnector.cs new file mode 100644 index 0000000..f2d9321 --- /dev/null +++ b/OpenSim/Server/Handlers/Hypergrid/GatekeeperServerConnector.cs | |||
@@ -0,0 +1,82 @@ | |||
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.Generic; | ||
30 | using System.Reflection; | ||
31 | using Nini.Config; | ||
32 | using OpenSim.Framework; | ||
33 | using OpenSim.Server.Base; | ||
34 | using OpenSim.Services.Interfaces; | ||
35 | using OpenSim.Framework.Servers.HttpServer; | ||
36 | using OpenSim.Server.Handlers.Base; | ||
37 | |||
38 | using log4net; | ||
39 | |||
40 | namespace OpenSim.Server.Handlers.Hypergrid | ||
41 | { | ||
42 | public class GatekeeperServiceInConnector : ServiceConnector | ||
43 | { | ||
44 | private static readonly ILog m_log = | ||
45 | LogManager.GetLogger( | ||
46 | MethodBase.GetCurrentMethod().DeclaringType); | ||
47 | |||
48 | private IGatekeeperService m_GatekeeperService; | ||
49 | public IGatekeeperService GateKeeper | ||
50 | { | ||
51 | get { return m_GatekeeperService; } | ||
52 | } | ||
53 | |||
54 | public GatekeeperServiceInConnector(IConfigSource config, IHttpServer server, ISimulationService simService) : | ||
55 | base(config, server, String.Empty) | ||
56 | { | ||
57 | IConfig gridConfig = config.Configs["GatekeeperService"]; | ||
58 | if (gridConfig != null) | ||
59 | { | ||
60 | string serviceDll = gridConfig.GetString("LocalServiceModule", string.Empty); | ||
61 | Object[] args = new Object[] { config, simService }; | ||
62 | m_GatekeeperService = ServerUtils.LoadPlugin<IGatekeeperService>(serviceDll, args); | ||
63 | |||
64 | } | ||
65 | if (m_GatekeeperService == null) | ||
66 | throw new Exception("Gatekeeper server connector cannot proceed because of missing service"); | ||
67 | |||
68 | HypergridHandlers hghandlers = new HypergridHandlers(m_GatekeeperService); | ||
69 | server.AddXmlRPCHandler("link_region", hghandlers.LinkRegionRequest, false); | ||
70 | server.AddXmlRPCHandler("get_region", hghandlers.GetRegion, false); | ||
71 | |||
72 | server.AddHTTPHandler("/foreignagent/", new GatekeeperAgentHandler(m_GatekeeperService).Handler); | ||
73 | |||
74 | } | ||
75 | |||
76 | public GatekeeperServiceInConnector(IConfigSource config, IHttpServer server) | ||
77 | : this(config, server, null) | ||
78 | { | ||
79 | } | ||
80 | |||
81 | } | ||
82 | } | ||
diff --git a/OpenSim/Server/Handlers/Hypergrid/HGInventoryServerInConnector.cs b/OpenSim/Server/Handlers/Hypergrid/HGInventoryServerInConnector.cs new file mode 100644 index 0000000..41897eb --- /dev/null +++ b/OpenSim/Server/Handlers/Hypergrid/HGInventoryServerInConnector.cs | |||
@@ -0,0 +1,104 @@ | |||
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.Net; | ||
32 | using System.Reflection; | ||
33 | using log4net; | ||
34 | using Nini.Config; | ||
35 | using Nwc.XmlRpc; | ||
36 | using OpenSim.Server.Base; | ||
37 | using OpenSim.Server.Handlers.Inventory; | ||
38 | using OpenSim.Services.Interfaces; | ||
39 | using OpenSim.Framework; | ||
40 | using OpenSim.Framework.Servers.HttpServer; | ||
41 | using OpenSim.Server.Handlers.Base; | ||
42 | using OpenMetaverse; | ||
43 | |||
44 | namespace OpenSim.Server.Handlers.Hypergrid | ||
45 | { | ||
46 | public class HGInventoryServiceInConnector : InventoryServiceInConnector | ||
47 | { | ||
48 | private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType); | ||
49 | |||
50 | //private static readonly int INVENTORY_DEFAULT_SESSION_TIME = 30; // secs | ||
51 | //private AuthedSessionCache m_session_cache = new AuthedSessionCache(INVENTORY_DEFAULT_SESSION_TIME); | ||
52 | |||
53 | private IUserAgentService m_UserAgentService; | ||
54 | |||
55 | public HGInventoryServiceInConnector(IConfigSource config, IHttpServer server, string configName) : | ||
56 | base(config, server, configName) | ||
57 | { | ||
58 | IConfig serverConfig = config.Configs[m_ConfigName]; | ||
59 | if (serverConfig == null) | ||
60 | throw new Exception(String.Format("No section '{0}' in config file", m_ConfigName)); | ||
61 | |||
62 | string userAgentService = serverConfig.GetString("UserAgentService", string.Empty); | ||
63 | string m_userserver_url = serverConfig.GetString("UserAgentURI", String.Empty); | ||
64 | if (m_userserver_url != string.Empty) | ||
65 | { | ||
66 | Object[] args = new Object[] { m_userserver_url }; | ||
67 | m_UserAgentService = ServerUtils.LoadPlugin<IUserAgentService>(userAgentService, args); | ||
68 | } | ||
69 | |||
70 | AddHttpHandlers(server); | ||
71 | m_log.Debug("[HG INVENTORY HANDLER]: handlers initialized"); | ||
72 | } | ||
73 | |||
74 | /// <summary> | ||
75 | /// Check that the source of an inventory request for a particular agent is a current session belonging to | ||
76 | /// that agent. | ||
77 | /// </summary> | ||
78 | /// <param name="session_id"></param> | ||
79 | /// <param name="avatar_id"></param> | ||
80 | /// <returns></returns> | ||
81 | public override bool CheckAuthSession(string session_id, string avatar_id) | ||
82 | { | ||
83 | //m_log.InfoFormat("[HG INVENTORY IN CONNECTOR]: checking authed session {0} {1}", session_id, avatar_id); | ||
84 | // This doesn't work | ||
85 | |||
86 | // if (m_session_cache.getCachedSession(session_id, avatar_id) == null) | ||
87 | // { | ||
88 | // //cache miss, ask userserver | ||
89 | // m_UserAgentService.VerifyAgent(session_id, ???); | ||
90 | // } | ||
91 | // else | ||
92 | // { | ||
93 | // // cache hits | ||
94 | // m_log.Info("[HG INVENTORY IN CONNECTOR]: got authed session from cache"); | ||
95 | // return true; | ||
96 | // } | ||
97 | |||
98 | // m_log.Warn("[HG INVENTORY IN CONNECTOR]: unknown session_id, request rejected"); | ||
99 | // return false; | ||
100 | |||
101 | return true; | ||
102 | } | ||
103 | } | ||
104 | } | ||
diff --git a/OpenSim/Server/Handlers/Hypergrid/HomeAgentHandlers.cs b/OpenSim/Server/Handlers/Hypergrid/HomeAgentHandlers.cs new file mode 100644 index 0000000..17d7850 --- /dev/null +++ b/OpenSim/Server/Handlers/Hypergrid/HomeAgentHandlers.cs | |||
@@ -0,0 +1,181 @@ | |||
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.IO; | ||
31 | using System.Reflection; | ||
32 | using System.Net; | ||
33 | using System.Text; | ||
34 | |||
35 | using OpenSim.Server.Base; | ||
36 | using OpenSim.Server.Handlers.Base; | ||
37 | using OpenSim.Services.Interfaces; | ||
38 | using GridRegion = OpenSim.Services.Interfaces.GridRegion; | ||
39 | using OpenSim.Framework; | ||
40 | using OpenSim.Framework.Servers.HttpServer; | ||
41 | using OpenSim.Server.Handlers.Simulation; | ||
42 | using Utils = OpenSim.Server.Handlers.Simulation.Utils; | ||
43 | |||
44 | using OpenMetaverse; | ||
45 | using OpenMetaverse.StructuredData; | ||
46 | using Nini.Config; | ||
47 | using log4net; | ||
48 | |||
49 | |||
50 | namespace OpenSim.Server.Handlers.Hypergrid | ||
51 | { | ||
52 | public class HomeAgentHandler | ||
53 | { | ||
54 | private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType); | ||
55 | private IUserAgentService m_UserAgentService; | ||
56 | |||
57 | public HomeAgentHandler(IUserAgentService userAgentService) | ||
58 | { | ||
59 | m_UserAgentService = userAgentService; | ||
60 | } | ||
61 | |||
62 | public Hashtable Handler(Hashtable request) | ||
63 | { | ||
64 | m_log.Debug("[CONNECTION DEBUGGING]: HomeAgentHandler Called"); | ||
65 | |||
66 | m_log.Debug("---------------------------"); | ||
67 | m_log.Debug(" >> uri=" + request["uri"]); | ||
68 | m_log.Debug(" >> content-type=" + request["content-type"]); | ||
69 | m_log.Debug(" >> http-method=" + request["http-method"]); | ||
70 | m_log.Debug("---------------------------\n"); | ||
71 | |||
72 | Hashtable responsedata = new Hashtable(); | ||
73 | responsedata["content_type"] = "text/html"; | ||
74 | responsedata["keepalive"] = false; | ||
75 | |||
76 | |||
77 | UUID agentID; | ||
78 | UUID regionID; | ||
79 | string action; | ||
80 | if (!Utils.GetParams((string)request["uri"], out agentID, out regionID, out action)) | ||
81 | { | ||
82 | m_log.InfoFormat("[HOME AGENT HANDLER]: Invalid parameters for agent message {0}", request["uri"]); | ||
83 | responsedata["int_response_code"] = 404; | ||
84 | responsedata["str_response_string"] = "false"; | ||
85 | |||
86 | return responsedata; | ||
87 | } | ||
88 | |||
89 | // Next, let's parse the verb | ||
90 | string method = (string)request["http-method"]; | ||
91 | if (method.Equals("POST")) | ||
92 | { | ||
93 | DoAgentPost(request, responsedata, agentID); | ||
94 | return responsedata; | ||
95 | } | ||
96 | else | ||
97 | { | ||
98 | m_log.InfoFormat("[HOME AGENT HANDLER]: method {0} not supported in agent message", method); | ||
99 | responsedata["int_response_code"] = HttpStatusCode.MethodNotAllowed; | ||
100 | responsedata["str_response_string"] = "Method not allowed"; | ||
101 | |||
102 | return responsedata; | ||
103 | } | ||
104 | |||
105 | } | ||
106 | |||
107 | protected void DoAgentPost(Hashtable request, Hashtable responsedata, UUID id) | ||
108 | { | ||
109 | OSDMap args = Utils.GetOSDMap((string)request["body"]); | ||
110 | if (args == null) | ||
111 | { | ||
112 | responsedata["int_response_code"] = HttpStatusCode.BadRequest; | ||
113 | responsedata["str_response_string"] = "Bad request"; | ||
114 | return; | ||
115 | } | ||
116 | |||
117 | // retrieve the input arguments | ||
118 | int x = 0, y = 0; | ||
119 | UUID uuid = UUID.Zero; | ||
120 | string regionname = string.Empty; | ||
121 | string gatekeeper_host = string.Empty; | ||
122 | int gatekeeper_port = 0; | ||
123 | |||
124 | if (args.ContainsKey("gatekeeper_host") && args["gatekeeper_host"] != null) | ||
125 | gatekeeper_host = args["gatekeeper_host"].AsString(); | ||
126 | if (args.ContainsKey("gatekeeper_port") && args["gatekeeper_port"] != null) | ||
127 | Int32.TryParse(args["gatekeeper_port"].AsString(), out gatekeeper_port); | ||
128 | |||
129 | GridRegion gatekeeper = new GridRegion(); | ||
130 | gatekeeper.ExternalHostName = gatekeeper_host; | ||
131 | gatekeeper.HttpPort = (uint)gatekeeper_port; | ||
132 | gatekeeper.InternalEndPoint = new IPEndPoint(IPAddress.Parse("0.0.0.0"), 0); | ||
133 | |||
134 | if (args.ContainsKey("destination_x") && args["destination_x"] != null) | ||
135 | Int32.TryParse(args["destination_x"].AsString(), out x); | ||
136 | else | ||
137 | m_log.WarnFormat(" -- request didn't have destination_x"); | ||
138 | if (args.ContainsKey("destination_y") && args["destination_y"] != null) | ||
139 | Int32.TryParse(args["destination_y"].AsString(), out y); | ||
140 | else | ||
141 | m_log.WarnFormat(" -- request didn't have destination_y"); | ||
142 | if (args.ContainsKey("destination_uuid") && args["destination_uuid"] != null) | ||
143 | UUID.TryParse(args["destination_uuid"].AsString(), out uuid); | ||
144 | if (args.ContainsKey("destination_name") && args["destination_name"] != null) | ||
145 | regionname = args["destination_name"].ToString(); | ||
146 | |||
147 | GridRegion destination = new GridRegion(); | ||
148 | destination.RegionID = uuid; | ||
149 | destination.RegionLocX = x; | ||
150 | destination.RegionLocY = y; | ||
151 | destination.RegionName = regionname; | ||
152 | |||
153 | AgentCircuitData aCircuit = new AgentCircuitData(); | ||
154 | try | ||
155 | { | ||
156 | aCircuit.UnpackAgentCircuitData(args); | ||
157 | } | ||
158 | catch (Exception ex) | ||
159 | { | ||
160 | m_log.InfoFormat("[HOME AGENT HANDLER]: exception on unpacking ChildCreate message {0}", ex.Message); | ||
161 | responsedata["int_response_code"] = HttpStatusCode.BadRequest; | ||
162 | responsedata["str_response_string"] = "Bad request"; | ||
163 | return; | ||
164 | } | ||
165 | |||
166 | OSDMap resp = new OSDMap(2); | ||
167 | string reason = String.Empty; | ||
168 | |||
169 | bool result = m_UserAgentService.LoginAgentToGrid(aCircuit, gatekeeper, destination, out reason); | ||
170 | |||
171 | resp["reason"] = OSD.FromString(reason); | ||
172 | resp["success"] = OSD.FromBoolean(result); | ||
173 | |||
174 | // TODO: add reason if not String.Empty? | ||
175 | responsedata["int_response_code"] = HttpStatusCode.OK; | ||
176 | responsedata["str_response_string"] = OSDParser.SerializeJsonString(resp); | ||
177 | } | ||
178 | |||
179 | } | ||
180 | |||
181 | } | ||
diff --git a/OpenSim/Server/Handlers/Hypergrid/HypergridHandlers.cs b/OpenSim/Server/Handlers/Hypergrid/HypergridHandlers.cs new file mode 100644 index 0000000..0b65245 --- /dev/null +++ b/OpenSim/Server/Handlers/Hypergrid/HypergridHandlers.cs | |||
@@ -0,0 +1,117 @@ | |||
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 | using System; | ||
28 | using System.Collections; | ||
29 | using System.Collections.Generic; | ||
30 | using System.Net; | ||
31 | using System.Reflection; | ||
32 | |||
33 | using OpenSim.Services.Interfaces; | ||
34 | using GridRegion = OpenSim.Services.Interfaces.GridRegion; | ||
35 | |||
36 | using log4net; | ||
37 | using Nwc.XmlRpc; | ||
38 | using OpenMetaverse; | ||
39 | |||
40 | namespace OpenSim.Server.Handlers.Hypergrid | ||
41 | { | ||
42 | public class HypergridHandlers | ||
43 | { | ||
44 | private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType); | ||
45 | |||
46 | private IGatekeeperService m_GatekeeperService; | ||
47 | |||
48 | public HypergridHandlers(IGatekeeperService gatekeeper) | ||
49 | { | ||
50 | m_GatekeeperService = gatekeeper; | ||
51 | } | ||
52 | |||
53 | /// <summary> | ||
54 | /// Someone wants to link to us | ||
55 | /// </summary> | ||
56 | /// <param name="request"></param> | ||
57 | /// <returns></returns> | ||
58 | public XmlRpcResponse LinkRegionRequest(XmlRpcRequest request, IPEndPoint remoteClient) | ||
59 | { | ||
60 | Hashtable requestData = (Hashtable)request.Params[0]; | ||
61 | //string host = (string)requestData["host"]; | ||
62 | //string portstr = (string)requestData["port"]; | ||
63 | string name = (string)requestData["region_name"]; | ||
64 | |||
65 | UUID regionID = UUID.Zero; | ||
66 | string externalName = string.Empty; | ||
67 | string imageURL = string.Empty; | ||
68 | ulong regionHandle = 0; | ||
69 | string reason = string.Empty; | ||
70 | |||
71 | bool success = m_GatekeeperService.LinkRegion(name, out regionID, out regionHandle, out externalName, out imageURL, out reason); | ||
72 | |||
73 | Hashtable hash = new Hashtable(); | ||
74 | hash["result"] = success.ToString(); | ||
75 | hash["uuid"] = regionID.ToString(); | ||
76 | hash["handle"] = regionHandle.ToString(); | ||
77 | hash["region_image"] = imageURL; | ||
78 | hash["external_name"] = externalName; | ||
79 | |||
80 | XmlRpcResponse response = new XmlRpcResponse(); | ||
81 | response.Value = hash; | ||
82 | return response; | ||
83 | } | ||
84 | |||
85 | public XmlRpcResponse GetRegion(XmlRpcRequest request, IPEndPoint remoteClient) | ||
86 | { | ||
87 | Hashtable requestData = (Hashtable)request.Params[0]; | ||
88 | //string host = (string)requestData["host"]; | ||
89 | //string portstr = (string)requestData["port"]; | ||
90 | string regionID_str = (string)requestData["region_uuid"]; | ||
91 | UUID regionID = UUID.Zero; | ||
92 | UUID.TryParse(regionID_str, out regionID); | ||
93 | |||
94 | GridRegion regInfo = m_GatekeeperService.GetHyperlinkRegion(regionID); | ||
95 | |||
96 | Hashtable hash = new Hashtable(); | ||
97 | if (regInfo == null) | ||
98 | hash["result"] = "false"; | ||
99 | else | ||
100 | { | ||
101 | hash["result"] = "true"; | ||
102 | hash["uuid"] = regInfo.RegionID.ToString(); | ||
103 | hash["x"] = regInfo.RegionLocX.ToString(); | ||
104 | hash["y"] = regInfo.RegionLocY.ToString(); | ||
105 | hash["region_name"] = regInfo.RegionName; | ||
106 | hash["hostname"] = regInfo.ExternalHostName; | ||
107 | hash["http_port"] = regInfo.HttpPort.ToString(); | ||
108 | hash["internal_port"] = regInfo.InternalEndPoint.Port.ToString(); | ||
109 | } | ||
110 | XmlRpcResponse response = new XmlRpcResponse(); | ||
111 | response.Value = hash; | ||
112 | return response; | ||
113 | |||
114 | } | ||
115 | |||
116 | } | ||
117 | } | ||
diff --git a/OpenSim/Server/Handlers/Hypergrid/UserAgentServerConnector.cs b/OpenSim/Server/Handlers/Hypergrid/UserAgentServerConnector.cs new file mode 100644 index 0000000..6b1152b --- /dev/null +++ b/OpenSim/Server/Handlers/Hypergrid/UserAgentServerConnector.cs | |||
@@ -0,0 +1,195 @@ | |||
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.Net; | ||
32 | using System.Reflection; | ||
33 | |||
34 | using Nini.Config; | ||
35 | using OpenSim.Framework; | ||
36 | using OpenSim.Server.Base; | ||
37 | using OpenSim.Services.Interfaces; | ||
38 | using OpenSim.Framework.Servers.HttpServer; | ||
39 | using OpenSim.Server.Handlers.Base; | ||
40 | using GridRegion = OpenSim.Services.Interfaces.GridRegion; | ||
41 | |||
42 | using log4net; | ||
43 | using Nwc.XmlRpc; | ||
44 | using OpenMetaverse; | ||
45 | |||
46 | namespace OpenSim.Server.Handlers.Hypergrid | ||
47 | { | ||
48 | public class UserAgentServerConnector : ServiceConnector | ||
49 | { | ||
50 | private static readonly ILog m_log = | ||
51 | LogManager.GetLogger( | ||
52 | MethodBase.GetCurrentMethod().DeclaringType); | ||
53 | |||
54 | private IUserAgentService m_HomeUsersService; | ||
55 | |||
56 | public UserAgentServerConnector(IConfigSource config, IHttpServer server) : | ||
57 | base(config, server, String.Empty) | ||
58 | { | ||
59 | IConfig gridConfig = config.Configs["UserAgentService"]; | ||
60 | if (gridConfig != null) | ||
61 | { | ||
62 | string serviceDll = gridConfig.GetString("LocalServiceModule", string.Empty); | ||
63 | Object[] args = new Object[] { config }; | ||
64 | m_HomeUsersService = ServerUtils.LoadPlugin<IUserAgentService>(serviceDll, args); | ||
65 | } | ||
66 | if (m_HomeUsersService == null) | ||
67 | throw new Exception("UserAgent server connector cannot proceed because of missing service"); | ||
68 | |||
69 | server.AddXmlRPCHandler("agent_is_coming_home", AgentIsComingHome, false); | ||
70 | server.AddXmlRPCHandler("get_home_region", GetHomeRegion, false); | ||
71 | server.AddXmlRPCHandler("verify_agent", VerifyAgent, false); | ||
72 | server.AddXmlRPCHandler("verify_client", VerifyClient, false); | ||
73 | server.AddXmlRPCHandler("logout_agent", LogoutAgent, false); | ||
74 | |||
75 | server.AddHTTPHandler("/homeagent/", new HomeAgentHandler(m_HomeUsersService).Handler); | ||
76 | } | ||
77 | |||
78 | public XmlRpcResponse GetHomeRegion(XmlRpcRequest request, IPEndPoint remoteClient) | ||
79 | { | ||
80 | Hashtable requestData = (Hashtable)request.Params[0]; | ||
81 | //string host = (string)requestData["host"]; | ||
82 | //string portstr = (string)requestData["port"]; | ||
83 | string userID_str = (string)requestData["userID"]; | ||
84 | UUID userID = UUID.Zero; | ||
85 | UUID.TryParse(userID_str, out userID); | ||
86 | |||
87 | Vector3 position = Vector3.UnitY, lookAt = Vector3.UnitY; | ||
88 | GridRegion regInfo = m_HomeUsersService.GetHomeRegion(userID, out position, out lookAt); | ||
89 | |||
90 | Hashtable hash = new Hashtable(); | ||
91 | if (regInfo == null) | ||
92 | hash["result"] = "false"; | ||
93 | else | ||
94 | { | ||
95 | hash["result"] = "true"; | ||
96 | hash["uuid"] = regInfo.RegionID.ToString(); | ||
97 | hash["x"] = regInfo.RegionLocX.ToString(); | ||
98 | hash["y"] = regInfo.RegionLocY.ToString(); | ||
99 | hash["region_name"] = regInfo.RegionName; | ||
100 | hash["hostname"] = regInfo.ExternalHostName; | ||
101 | hash["http_port"] = regInfo.HttpPort.ToString(); | ||
102 | hash["internal_port"] = regInfo.InternalEndPoint.Port.ToString(); | ||
103 | hash["position"] = position.ToString(); | ||
104 | hash["lookAt"] = lookAt.ToString(); | ||
105 | } | ||
106 | XmlRpcResponse response = new XmlRpcResponse(); | ||
107 | response.Value = hash; | ||
108 | return response; | ||
109 | |||
110 | } | ||
111 | |||
112 | public XmlRpcResponse AgentIsComingHome(XmlRpcRequest request, IPEndPoint remoteClient) | ||
113 | { | ||
114 | Hashtable requestData = (Hashtable)request.Params[0]; | ||
115 | //string host = (string)requestData["host"]; | ||
116 | //string portstr = (string)requestData["port"]; | ||
117 | string sessionID_str = (string)requestData["sessionID"]; | ||
118 | UUID sessionID = UUID.Zero; | ||
119 | UUID.TryParse(sessionID_str, out sessionID); | ||
120 | string gridName = (string)requestData["externalName"]; | ||
121 | |||
122 | bool success = m_HomeUsersService.AgentIsComingHome(sessionID, gridName); | ||
123 | |||
124 | Hashtable hash = new Hashtable(); | ||
125 | hash["result"] = success.ToString(); | ||
126 | XmlRpcResponse response = new XmlRpcResponse(); | ||
127 | response.Value = hash; | ||
128 | return response; | ||
129 | |||
130 | } | ||
131 | |||
132 | public XmlRpcResponse VerifyAgent(XmlRpcRequest request, IPEndPoint remoteClient) | ||
133 | { | ||
134 | Hashtable requestData = (Hashtable)request.Params[0]; | ||
135 | //string host = (string)requestData["host"]; | ||
136 | //string portstr = (string)requestData["port"]; | ||
137 | string sessionID_str = (string)requestData["sessionID"]; | ||
138 | UUID sessionID = UUID.Zero; | ||
139 | UUID.TryParse(sessionID_str, out sessionID); | ||
140 | string token = (string)requestData["token"]; | ||
141 | |||
142 | bool success = m_HomeUsersService.VerifyAgent(sessionID, token); | ||
143 | |||
144 | Hashtable hash = new Hashtable(); | ||
145 | hash["result"] = success.ToString(); | ||
146 | XmlRpcResponse response = new XmlRpcResponse(); | ||
147 | response.Value = hash; | ||
148 | return response; | ||
149 | |||
150 | } | ||
151 | |||
152 | public XmlRpcResponse VerifyClient(XmlRpcRequest request, IPEndPoint remoteClient) | ||
153 | { | ||
154 | Hashtable requestData = (Hashtable)request.Params[0]; | ||
155 | //string host = (string)requestData["host"]; | ||
156 | //string portstr = (string)requestData["port"]; | ||
157 | string sessionID_str = (string)requestData["sessionID"]; | ||
158 | UUID sessionID = UUID.Zero; | ||
159 | UUID.TryParse(sessionID_str, out sessionID); | ||
160 | string token = (string)requestData["token"]; | ||
161 | |||
162 | bool success = m_HomeUsersService.VerifyClient(sessionID, token); | ||
163 | |||
164 | Hashtable hash = new Hashtable(); | ||
165 | hash["result"] = success.ToString(); | ||
166 | XmlRpcResponse response = new XmlRpcResponse(); | ||
167 | response.Value = hash; | ||
168 | return response; | ||
169 | |||
170 | } | ||
171 | |||
172 | public XmlRpcResponse LogoutAgent(XmlRpcRequest request, IPEndPoint remoteClient) | ||
173 | { | ||
174 | Hashtable requestData = (Hashtable)request.Params[0]; | ||
175 | //string host = (string)requestData["host"]; | ||
176 | //string portstr = (string)requestData["port"]; | ||
177 | string sessionID_str = (string)requestData["sessionID"]; | ||
178 | UUID sessionID = UUID.Zero; | ||
179 | UUID.TryParse(sessionID_str, out sessionID); | ||
180 | string userID_str = (string)requestData["userID"]; | ||
181 | UUID userID = UUID.Zero; | ||
182 | UUID.TryParse(userID_str, out userID); | ||
183 | |||
184 | m_HomeUsersService.LogoutAgent(userID, sessionID); | ||
185 | |||
186 | Hashtable hash = new Hashtable(); | ||
187 | hash["result"] = "true"; | ||
188 | XmlRpcResponse response = new XmlRpcResponse(); | ||
189 | response.Value = hash; | ||
190 | return response; | ||
191 | |||
192 | } | ||
193 | |||
194 | } | ||
195 | } | ||