RemoteClientTest.cs

//-----------------------------------------------------------------------
// <copyright file="RemoteClientTest.cs" company="Hibernating Rhinos LTD">
//     Copyright (c) Hibernating Rhinos LTD. All rights reserved.
// </copyright>
//-----------------------------------------------------------------------
using System;
using System.Diagnostics;
using System.IO;
using System.Threading;
using Raven.Abstractions;
using Raven.Client.Document;
using Raven.Client.Indexes;
using Raven.Database.Config;
using Raven.Database.Extensions;
using Raven.Http;
using Raven.Json.Linq;
using Raven.Server;
using System.Reflection;
using Raven.Tests.Document;

namespace Raven.Tests
{
	public class RemoteClientTest : WithNLog
	{
		protected const string DbDirectory = @".\TestDb\";
		protected const string DbName = DbDirectory + @"DocDb.esb";

		

		protected void WaitForAllRequestsToComplete(RavenDbServer server)
		{
			while (server.Server.HasPendingRequests)
				Thread.Sleep(25);
		}

        protected RavenDbServer GetNewServer(bool initializeDocumentsByEntitiyName = true)
        {
        	var ravenConfiguration = new RavenConfiguration
        	{
        		Port = 8080,
        		RunInMemory = true,
        		DataDirectory = "Data",
        		AnonymousUserAccessMode = AnonymousUserAccessMode.All
        	};

        	ConfigureServer(ravenConfiguration);

			if(ravenConfiguration.RunInMemory == false)
				IOExtensions.DeleteDirectory(ravenConfiguration.DataDirectory);

        	var ravenDbServer = new RavenDbServer(ravenConfiguration);

            if (initializeDocumentsByEntitiyName)
            {
                using (var documentStore = new DocumentStore
				{
					Url = "http://localhost:8080"
				}.Initialize())
				{
					new RavenDocumentsByEntityName().Execute(documentStore);
				}
			}

            return ravenDbServer;
        }

        protected virtual void ConfigureServer(RavenConfiguration ravenConfiguration)
        {
        }

        protected void WaitForUserToContinueTheTest()
        {
            if (Debugger.IsAttached == false)
                return;

            using (var documentStore = new DocumentStore
            {
                Url = "http://localhost:8080"
            })
            {
                documentStore.Initialize();
                documentStore.DatabaseCommands.Put("Pls Delete Me", null,
                                                   RavenJObject.FromObject(new { StackTrace = new StackTrace(true) }), new RavenJObject());

                Process.Start(documentStore.Url);// start the server

                do
                {
                    Thread.Sleep(100);
                } while (documentStore.DatabaseCommands.Get("Pls Delete Me") != null);
            }

        }

        protected RavenDbServer GetNewServer(int port, string path)
        {
            var ravenDbServer = new RavenDbServer(new RavenConfiguration
            {
                Port = port,
                DataDirectory = path,
                RunInMemory = true,
                AnonymousUserAccessMode = AnonymousUserAccessMode.All
            });

            using (var documentStore = new DocumentStore
            {
                Url = "http://localhost:" + port
            }.Initialize())
            {
                new RavenDocumentsByEntityName().Execute(documentStore);
            }
            return ravenDbServer;
        }

        protected RavenDbServer GetNewServerWithoutAnonymousAccess(int port, string path)
		{
			RavenDbServer newServerWithoutAnonymousAccess = new RavenDbServer(new RavenConfiguration { Port = port, DataDirectory = path, AnonymousUserAccessMode = AnonymousUserAccessMode.None });
			using (var documentStore = new DocumentStore
			{
				Url = "http://localhost:" + port
			}.Initialize())
			{
				new RavenDocumentsByEntityName().Execute(documentStore);
			}
			return newServerWithoutAnonymousAccess;
		}

        protected string GetPath(string subFolderName)
        {
            string retPath = Path.GetDirectoryName(Assembly.GetAssembly(typeof(DocumentStoreServerTests)).CodeBase);
            return Path.Combine(retPath, subFolderName).Substring(6); //remove leading file://
        }

        public RemoteClientTest()
        {
            try
            {
                new Uri("http://fail/first/time?only=%2bplus");
            }
            catch (Exception)
            {
            }

            ClearDatabaseDirectory();

            Directory.CreateDirectory(DbDirectory);
        }

        protected void ClearDatabaseDirectory()
        {
            IOExtensions.DeleteDirectory(DbName);
            IOExtensions.DeleteDirectory(DbDirectory);
        }

		public double Timer(Action action)
		{
			var startTime = SystemTime.Now;
			action.Invoke();
			var timeTaken = SystemTime.Now.Subtract(startTime);
			Console.WriteLine("Time take (ms)- " + timeTaken.TotalMilliseconds);
			return timeTaken.TotalMilliseconds;
		}
	}
}