/* * Copyright (c) Contributors, http://opensimulator.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 OpenSimulator 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; using System.Collections.Generic; using System.Net; using log4net.Config; using Nini.Config; using NUnit.Framework; using OpenMetaverse; using OpenMetaverse.Packets; using OpenMetaverse.StructuredData; using OpenSim.Framework; using OpenSim.Framework.Servers; using OpenSim.Framework.Servers.HttpServer; using OpenSim.Region.ClientStack.Linden; using OpenSim.Region.CoreModules.Framework; using OpenSim.Region.Framework.Scenes; using OpenSim.Region.OptionalModules.World.NPC; using OpenSim.Tests.Common; namespace OpenSim.Region.ClientStack.Linden.Tests { [TestFixture] public class EventQueueTests : OpenSimTestCase { private TestScene m_scene; private EventQueueGetModule m_eqgMod; private NPCModule m_npcMod; [SetUp] public override void SetUp() { base.SetUp(); uint port = 9999; // This is an unfortunate bit of clean up we have to do because MainServer manages things through static // variables and the VM is not restarted between tests. MainServer.RemoveHttpServer(port); BaseHttpServer server = new BaseHttpServer(port, false, "","",""); MainServer.AddHttpServer(server); MainServer.Instance = server; IConfigSource config = new IniConfigSource(); config.AddConfig("Startup"); CapabilitiesModule capsModule = new CapabilitiesModule(); m_eqgMod = new EventQueueGetModule(); // For NPC test support config.AddConfig("NPC"); config.Configs["NPC"].Set("Enabled", "true"); m_npcMod = new NPCModule(); m_scene = new SceneHelpers().SetupScene(); SceneHelpers.SetupSceneModules(m_scene, config, capsModule, m_eqgMod, m_npcMod); } [Test] public void TestAddForClient() { TestHelpers.InMethod(); // log4net.Config.XmlConfigurator.Configure(); SceneHelpers.AddScenePresence(m_scene, TestHelpers.ParseTail(0x1)); // TODO: Add more assertions for the other aspects of event queues Assert.That(MainServer.Instance.GetPollServiceHandlerKeys().Count, Is.EqualTo(1)); } [Test] public void TestRemoveForClient() { TestHelpers.InMethod(); // TestHelpers.EnableLogging(); UUID spId = TestHelpers.ParseTail(0x1); SceneHelpers.AddScenePresence(m_scene, spId); m_scene.CloseAgent(spId, false); // TODO: Add more assertions for the other aspects of event queues Assert.That(MainServer.Instance.GetPollServiceHandlerKeys().Count, Is.EqualTo(0)); } [Test] public void TestEnqueueMessage() { TestHelpers.InMethod(); // log4net.Config.XmlConfigurator.Configure(); ScenePresence sp = SceneHelpers.AddScenePresence(m_scene, TestHelpers.ParseTail(0x1)); string messageName = "TestMessage"; m_eqgMod.Enqueue(m_eqgMod.BuildEvent(messageName, new OSDMap()), sp.UUID); Hashtable eventsResponse = m_eqgMod.GetEvents(UUID.Zero, sp.UUID); // initial queue as null events eventsResponse = m_eqgMod.GetEvents(UUID.Zero, sp.UUID); if((int)eventsResponse["int_response_code"] != (int)HttpStatusCode.OK) { eventsResponse = m_eqgMod.GetEvents(UUID.Zero, sp.UUID); if((int)eventsResponse["int_response_code"] != (int)HttpStatusCode.OK) eventsResponse = m_eqgMod.GetEvents(UUID.Zero, sp.UUID); } Assert.That((int)eventsResponse["int_response_code"], Is.EqualTo((int)HttpStatusCode.OK)); // Console.WriteLine("Response [{0}]", (string)eventsResponse["str_response_string"]); OSDMap rawOsd = (OSDMap)OSDParser.DeserializeLLSDXml((string)eventsResponse["str_response_string"]); OSDArray eventsOsd = (OSDArray)rawOsd["events"]; bool foundUpdate = false; foreach (OSD osd in eventsOsd) { OSDMap eventOsd = (OSDMap)osd; if (eventOsd["message"] == messageName) foundUpdate = true; } Assert.That(foundUpdate, Is.True, string.Format("Did not find {0} in response", messageName)); } /// /// Test an attempt to put a message on the queue of a user that is not in the region. /// [Test] public void TestEnqueueMessageNoUser() { TestHelpers.InMethod(); TestHelpers.EnableLogging(); string messageName = "TestMessage"; m_eqgMod.Enqueue(m_eqgMod.BuildEvent(messageName, new OSDMap()), TestHelpers.ParseTail(0x1)); Hashtable eventsResponse = m_eqgMod.GetEvents(UUID.Zero, TestHelpers.ParseTail(0x1)); Assert.That((int)eventsResponse["int_response_code"], Is.EqualTo((int)HttpStatusCode.BadGateway)); } /// /// NPCs do not currently have an event queue but a caller may try to send a message anyway, so check behaviour. /// [Test] public void TestEnqueueMessageToNpc() { TestHelpers.InMethod(); // TestHelpers.EnableLogging(); UUID npcId = m_npcMod.CreateNPC( "John", "Smith", new Vector3(128, 128, 30), UUID.Zero, true, m_scene, new AvatarAppearance()); ScenePresence npc = m_scene.GetScenePresence(npcId); string messageName = "TestMessage"; m_eqgMod.Enqueue(m_eqgMod.BuildEvent(messageName, new OSDMap()), npc.UUID); Hashtable eventsResponse = m_eqgMod.GetEvents(UUID.Zero, npc.UUID); Assert.That((int)eventsResponse["int_response_code"], Is.EqualTo((int)HttpStatusCode.BadGateway)); } } }