Removed the queue/dequeue methodology of queued responses. Now the methods that generate them return them.

Besides simplifying the API somewhat, this change allows for Consumer, ServiceProvider and Channel classes to be entirely threadsafe and reusable.

4 files changed, 22 insertions, 57 deletions

diff --git a/src/DotNetOAuth/ChannelElements/OAuthChannel.cs b/src/DotNetOAuth/ChannelElements/OAuthChannel.cs
index 03db91e..951df05 100644
--- a/src/DotNetOAuth/ChannelElements/OAuthChannel.cs
+++ b/src/DotNetOAuth/ChannelElements/OAuthChannel.cs
@@ -208,10 +208,11 @@ namespace DotNetOAuth.ChannelElements {
 		/// are sent in the response stream in querystring style.

 		/// </summary>

 		/// <param name="response">The message to send as a response.</param>

+		/// <returns>The pending user agent redirect based message to be sent as an HttpResponse.</returns>

 		/// <remarks>

 		/// This method implements spec V1.0 section 5.3.

 		/// </remarks>

-		protected override void SendDirectMessageResponse(IProtocolMessage response) {

+		protected override Response SendDirectMessageResponse(IProtocolMessage response) {

 			MessageSerializer serializer = MessageSerializer.Get(response.GetType());

 			var fields = serializer.Serialize(response);

 			string responseBody = MessagingUtilities.CreateQueryString(fields);

@@ -222,7 +223,7 @@ namespace DotNetOAuth.ChannelElements {
 				Status = HttpStatusCode.OK,

 				Headers = new System.Net.WebHeaderCollection(),

 			};

-			this.QueueIndirectOrResponseMessage(encodedResponse);

+			return encodedResponse;

 		}

 

 		/// <summary>

diff --git a/src/DotNetOAuth/Consumer.cs b/src/DotNetOAuth/Consumer.cs
index ce61e60..bc50d1f 100644
--- a/src/DotNetOAuth/Consumer.cs
+++ b/src/DotNetOAuth/Consumer.cs
@@ -59,11 +59,6 @@ namespace DotNetOAuth {
 		public ITokenManager TokenManager { get; private set; }

 

 		/// <summary>

-		/// Gets the pending user agent redirect based message to be sent as an HttpResponse.

-		/// </summary>

-		public Response PendingRequest { get; private set; }

-

-		/// <summary>

 		/// Gets or sets the object that processes <see cref="HttpWebRequest"/>s.

 		/// </summary>

 		/// <remarks>

@@ -86,7 +81,8 @@ namespace DotNetOAuth {
 		/// User Agent to upon successful authorization.

 		/// </param>

 		/// <param name="extraParameters">Extra parameters to add to the request token message.  Optional.</param>

-		public void RequestUserAuthorization(Uri callback, IDictionary<string, string> extraParameters) {

+		/// <returns>The pending user agent redirect based message to be sent as an HttpResponse.</returns>

+		public Response RequestUserAuthorization(Uri callback, IDictionary<string, string> extraParameters) {

 			// Obtain an unauthorized request token.

 			var requestToken = new RequestTokenMessage(this.ServiceProvider.RequestTokenEndpoint) {

 				ConsumerKey = this.ConsumerKey,

@@ -101,8 +97,7 @@ namespace DotNetOAuth {
 				Callback = callback,

 				RequestToken = requestTokenResponse.RequestToken,

 			};

-			this.Channel.Send(requestAuthorization);

-			this.PendingRequest = this.Channel.DequeueIndirectOrResponseMessage();

+			return this.Channel.Send(requestAuthorization);

 		}

 

 		/// <summary>

diff --git a/src/DotNetOAuth/Messaging/Channel.cs b/src/DotNetOAuth/Messaging/Channel.cs
index d16cdc3..e3e49d8 100644
--- a/src/DotNetOAuth/Messaging/Channel.cs
+++ b/src/DotNetOAuth/Messaging/Channel.cs
@@ -55,11 +55,6 @@ namespace DotNetOAuth.Messaging {
 		private IMessageTypeProvider messageTypeProvider;

 

 		/// <summary>

-		/// Gets or sets the HTTP response to send as a reply to the current incoming HTTP request.

-		/// </summary>

-		private Response queuedIndirectOrResponseMessage;

-

-		/// <summary>

 		/// A list of binding elements in the order they must be applied to outgoing messages.

 		/// </summary>

 		/// <remarks>

@@ -106,21 +101,12 @@ namespace DotNetOAuth.Messaging {
 		}

 

 		/// <summary>

-		/// Retrieves the stored response for sending and clears it from the channel.

-		/// </summary>

-		/// <returns>The response to send as the HTTP response.</returns>

-		internal Response DequeueIndirectOrResponseMessage() {

-			Response response = this.queuedIndirectOrResponseMessage;

-			this.queuedIndirectOrResponseMessage = null;

-			return response;

-		}

-

-		/// <summary>

 		/// Queues an indirect message (either a request or response) 

 		/// or direct message response for transmission to a remote party.

 		/// </summary>

 		/// <param name="message">The one-way message to send</param>

-		internal void Send(IProtocolMessage message) {

+		/// <returns>The pending user agent redirect based message to be sent as an HttpResponse.</returns>

+		internal Response Send(IProtocolMessage message) {

 			if (message == null) {

 				throw new ArgumentNullException("message");

 			}

@@ -130,8 +116,7 @@ namespace DotNetOAuth.Messaging {
 			switch (message.Transport) {

 				case MessageTransport.Direct:

 					// This is a response to a direct message.

-					this.SendDirectMessageResponse(message);

-					break;

+					return this.SendDirectMessageResponse(message);

 				case MessageTransport.Indirect:

 					var directedMessage = message as IDirectedProtocolMessage;

 					if (directedMessage == null) {

@@ -145,8 +130,7 @@ namespace DotNetOAuth.Messaging {
 					if (directedMessage.Recipient == null) {

 						throw new ArgumentException(MessagingStrings.DirectedMessageMissingRecipient, "message");

 					}

-					this.SendIndirectMessage(directedMessage);

-					break;

+					return this.SendIndirectMessage(directedMessage);

 				default:

 					throw new ArgumentException(

 						string.Format(

@@ -363,7 +347,8 @@ namespace DotNetOAuth.Messaging {
 		/// Queues an indirect message for transmittal via the user agent.

 		/// </summary>

 		/// <param name="message">The message to send.</param>

-		protected virtual void SendIndirectMessage(IDirectedProtocolMessage message) {

+		/// <returns>The pending user agent redirect based message to be sent as an HttpResponse.</returns>

+		protected virtual Response SendIndirectMessage(IDirectedProtocolMessage message) {

 			if (message == null) {

 				throw new ArgumentNullException("message");

 			}

@@ -377,7 +362,7 @@ namespace DotNetOAuth.Messaging {
 				response = this.Create301RedirectResponse(message, fields);

 			}

 

-			this.QueueIndirectOrResponseMessage(response);

+			return response;

 		}

 

 		/// <summary>

@@ -474,26 +459,11 @@ namespace DotNetOAuth.Messaging {
 		/// are sent in the response stream in querystring style.

 		/// </summary>

 		/// <param name="response">The message to send as a response.</param>

+		/// <returns>The pending user agent redirect based message to be sent as an HttpResponse.</returns>

 		/// <remarks>

 		/// This method implements spec V1.0 section 5.3.

 		/// </remarks>

-		protected abstract void SendDirectMessageResponse(IProtocolMessage response);

-

-		/// <summary>

-		/// Takes a message and temporarily stores it for sending as the hosting site's

-		/// HTTP response to the current request.

-		/// </summary>

-		/// <param name="response">The message to store for sending.</param>

-		protected void QueueIndirectOrResponseMessage(Response response) {

-			if (response == null) {

-				throw new ArgumentNullException("response");

-			}

-			if (this.queuedIndirectOrResponseMessage != null) {

-				throw new InvalidOperationException(MessagingStrings.QueuedMessageResponseAlreadyExists);

-			}

-

-			this.queuedIndirectOrResponseMessage = response;

-		}

+		protected abstract Response SendDirectMessageResponse(IProtocolMessage response);

 

 		/// <summary>

 		/// Prepares a message for transmit by applying signatures, nonces, etc.

diff --git a/src/DotNetOAuth/ServiceProvider.cs b/src/DotNetOAuth/ServiceProvider.cs
index 778f9df..10ea5a7 100644
--- a/src/DotNetOAuth/ServiceProvider.cs
+++ b/src/DotNetOAuth/ServiceProvider.cs
@@ -53,11 +53,6 @@ namespace DotNetOAuth {
 		public ServiceProviderDescription Description { get; private set; }

 

 		/// <summary>

-		/// Gets the pending user agent redirect based message to be sent as an HttpResponse.

-		/// </summary>

-		public Response PendingRequest { get; private set; }

-

-		/// <summary>

 		/// Gets or sets the channel to use for sending/receiving messages.

 		/// </summary>

 		internal OAuthChannel Channel { get; set; }

@@ -108,12 +103,16 @@ namespace DotNetOAuth {
 			return this.Channel.ReadFromRequest<DirectUserToServiceProviderMessage>(request);

 		}

 

-		internal void SendAuthorizationResponse(DirectUserToServiceProviderMessage request) {

+		/// <summary>

+		/// 

+		/// </summary>

+		/// <param name="request"></param>

+		/// <returns>The pending user agent redirect based message to be sent as an HttpResponse.</returns>

+		internal Response SendAuthorizationResponse(DirectUserToServiceProviderMessage request) {

 			var authorization = new DirectUserToConsumerMessage(request.Callback) {

 				RequestToken = request.RequestToken,

 			};

-			this.Channel.Send(authorization);

-			this.PendingRequest = this.Channel.DequeueIndirectOrResponseMessage();

+			return this.Channel.Send(authorization);

 		}

 

 		internal RequestAccessTokenMessage ReadAccessTokenRequest() {