AsyncRestClientTests.cs

using System;
using System.Collections.Generic;
using System.Threading;
using NUnit.Framework;
using ServiceStack.Common.Extensions;
using ServiceStack.Logging;
using ServiceStack.Logging.Support.Logging;
using ServiceStack.Service;
using ServiceStack.ServiceClient.Web;
using ServiceStack.WebHost.Endpoints.Tests.Support.Host;

namespace ServiceStack.WebHost.Endpoints.Tests
{
	public abstract class AsyncRestClientTests
	{
		private const string ListeningOn = "http://localhost:82/";

		ExampleAppHostHttpListener appHost;

		[TestFixtureSetUp]
		public void OnTestFixtureSetUp()
		{
			LogManager.LogFactory = new ConsoleLogFactory();

			appHost = new ExampleAppHostHttpListener();
			appHost.Init();
			appHost.Start(ListeningOn);
		}

		[TestFixtureTearDown]
		public void OnTestFixtureTearDown()
		{
			appHost.Dispose();
		}

		protected abstract IRestClientAsync CreateAsyncRestClient();

		private static void FailOnAsyncError<T>(T response, Exception ex)
		{
			Assert.Fail(ex.Message);
		}

		[Test]
		public void Can_call_GetAsync_on_GetFactorial_using_RestClientAsync()
		{
			var asyncClient = CreateAsyncRestClient();

			GetFactorialResponse response = null;
			asyncClient.GetAsync<GetFactorialResponse>("factorial/3", r => response = r, FailOnAsyncError);

			Thread.Sleep(1000);

			Assert.That(response, Is.Not.Null, "No response received");
			Assert.That(response.Result, Is.EqualTo(GetFactorialService.GetFactorial(3)));
		}

		[Test]
		public void Can_call_GetAsync_on_Movies_using_RestClientAsync()
		{
			var asyncClient = CreateAsyncRestClient();

			MoviesResponse response = null;
			asyncClient.GetAsync<MoviesResponse>("movies", r => response = r, FailOnAsyncError);

			Thread.Sleep(1000);

			Assert.That(response, Is.Not.Null, "No response received");
			Assert.That(response.Movies.EquivalentTo(ResetMoviesService.Top5Movies));
		}

		[Test]
		public void Can_call_GetAsync_on_single_Movie_using_RestClientAsync()
		{
			var asyncClient = CreateAsyncRestClient();

			MovieResponse response = null;
			asyncClient.GetAsync<MovieResponse>("movies/1", r => response = r, FailOnAsyncError);

			Thread.Sleep(1000);

			Assert.That(response, Is.Not.Null, "No response received");
			Assert.That(response.Movie.Id, Is.EqualTo(1));
		}

		[Test]
		public void Can_call_PostAsync_to_add_new_Movie_using_RestClientAsync()
		{
			var asyncClient = CreateAsyncRestClient();

			var newMovie = new Movie
			{
				ImdbId = "tt0450259",
				Title = "Blood Diamond",
				Rating = 8.0m,
				Director = "Edward Zwick",
				ReleaseDate = new DateTime(2007, 1, 26),
				TagLine = "A fisherman, a smuggler, and a syndicate of businessmen match wits over the possession of a priceless diamond.",
				Genres = new List<string> { "Adventure", "Drama", "Thriller" },
			};

			MovieResponse response = null;
			asyncClient.PostAsync<MovieResponse>("movies", newMovie,
				r => response = r, FailOnAsyncError);

			Thread.Sleep(1000);

			Assert.That(response, Is.Not.Null, "No response received");

			var createdMovie = response.Movie;
			Assert.That(createdMovie.Id, Is.GreaterThan(0));
			Assert.That(createdMovie.ImdbId, Is.EqualTo(newMovie.ImdbId));
		}

		[Test]
		public void Can_call_DeleteAsync_to_delete_Movie_using_RestClientAsync()
		{
			var asyncClient = CreateAsyncRestClient();

			var newMovie = new Movie
			{
				ImdbId = "tt0450259",
				Title = "Blood Diamond",
				Rating = 8.0m,
				Director = "Edward Zwick",
				ReleaseDate = new DateTime(2007, 1, 26),
				TagLine = "A fisherman, a smuggler, and a syndicate of businessmen match wits over the possession of a priceless diamond.",
				Genres = new List<string> { "Adventure", "Drama", "Thriller" },
			};

			MovieResponse response = null;
			Movie createdMovie = null;
			asyncClient.PostAsync<MovieResponse>("movies", newMovie,
				r =>
				{
					createdMovie = r.Movie;
					asyncClient.DeleteAsync<MovieResponse>("movies/" + createdMovie.Id, 
						dr => response = dr, FailOnAsyncError);
				}, FailOnAsyncError);

			Thread.Sleep(1000);

			Assert.That(response, Is.Not.Null, "No response received");
			Assert.That(createdMovie, Is.Not.Null);
			Assert.That(response.Movie, Is.Null);
		}

		[TestFixture]
		public class JsonAsyncRestServiceClientTests : AsyncRestClientTests
		{
			protected override IRestClientAsync CreateAsyncRestClient()
			{
				return new JsonRestClientAsync(ListeningOn);
			}
		}

		[TestFixture]
		public class JsvAsyncRestServiceClientTests : AsyncRestClientTests
		{
			protected override IRestClientAsync CreateAsyncRestClient()
			{
				return new JsvRestClientAsync(ListeningOn);
			}
		}

		[TestFixture]
		public class XmlAsyncRestServiceClientTests : AsyncRestClientTests
		{
			protected override IRestClientAsync CreateAsyncRestClient()
			{
				return new XmlRestClientAsync(ListeningOn);
			}
		}
	}
}