1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
|
//-----------------------------------------------------------------------
// <copyright file="ChannelTests.cs" company="Andrew Arnott">
// Copyright (c) Andrew Arnott. All rights reserved.
// </copyright>
//-----------------------------------------------------------------------
namespace DotNetOAuth.Test.Messaging {
using System;
using System.Collections.Generic;
using System.IO;
using System.Net;
using DotNetOAuth.Messaging;
using DotNetOAuth.Test.Mocks;
using Microsoft.VisualStudio.TestTools.UnitTesting;
[TestClass]
public class ChannelTests : TestBase {
private Channel channel;
[TestInitialize]
public override void SetUp() {
base.SetUp();
this.channel = new TestChannel();
}
[TestMethod, ExpectedException(typeof(ArgumentNullException))]
public void CtorNull() {
// This bad channel is deliberately constructed to pass null to
// its protected base class' constructor.
new TestBadChannel();
}
[TestMethod]
public void DequeueIndirectOrResponseMessageReturnsNull() {
Assert.IsNull(this.channel.DequeueIndirectOrResponseMessage());
}
[TestMethod]
public void ReceiveFromQueryString() {
Uri requestUri = new Uri("http://localhost/path?age=15&Name=Andrew&Location=http%3A%2F%2Fhostb%2FpathB");
WebHeaderCollection headers = new WebHeaderCollection();
HttpRequestInfo request = new HttpRequestInfo {
HttpMethod = "GET",
Url = requestUri,
Headers = headers,
InputStream = new MemoryStream(),
};
IProtocolMessage requestMessage = this.channel.ReadFromRequest(request);
Assert.IsNotNull(requestMessage);
Assert.IsInstanceOfType(requestMessage, typeof(TestMessage));
TestMessage testMessage = (TestMessage)requestMessage;
Assert.AreEqual(15, testMessage.Age);
Assert.AreEqual("Andrew", testMessage.Name);
Assert.AreEqual("http://hostb/pathB", testMessage.Location.AbsoluteUri);
}
[TestMethod]
public void ReceiveFromForm() {
Uri requestUri = new Uri("http://localhost/path");
WebHeaderCollection headers = new WebHeaderCollection();
headers.Add(HttpRequestHeader.ContentType, "application/x-www-form-urlencoded");
MemoryStream ms = new MemoryStream();
StreamWriter sw = new StreamWriter(ms);
sw.Write("age=15&Name=Andrew&Location=http%3A%2F%2Fhostb%2FpathB");
sw.Flush();
ms.Position = 0;
HttpRequestInfo request = new HttpRequestInfo {
HttpMethod = "POST",
Url = requestUri,
Headers = headers,
InputStream = ms,
};
IProtocolMessage requestMessage = this.channel.ReadFromRequest(request);
Assert.IsNotNull(requestMessage);
Assert.IsInstanceOfType(requestMessage, typeof(TestMessage));
TestMessage testMessage = (TestMessage)requestMessage;
Assert.AreEqual(15, testMessage.Age);
Assert.AreEqual("Andrew", testMessage.Name);
Assert.AreEqual("http://hostb/pathB", testMessage.Location.AbsoluteUri);
}
private static HttpRequestInfo CreateHttpRequest(string method, IDictionary<string, string> fields) {
string query = MessagingUtilities.CreateQueryString(fields);
UriBuilder requestUri = new UriBuilder("http://localhost/path");
WebHeaderCollection headers = new WebHeaderCollection();
MemoryStream ms = new MemoryStream();
if (method == "POST") {
headers.Add(HttpRequestHeader.ContentType, "application/x-www-form-urlencoded");
StreamWriter sw = new StreamWriter(ms);
sw.Write(query);
sw.Flush();
ms.Position = 0;
} else if (method == "GET") {
requestUri.Query = query;
}
HttpRequestInfo request = new HttpRequestInfo {
HttpMethod = method,
Url = requestUri.Uri,
Headers = headers,
InputStream = ms,
};
return request;
}
}
}
|
