Skip to content

Commit 65c4fe4

Browse files
mattqsmattqs
committed
.net test building /not passing
1 parent d5cc588 commit 65c4fe4

File tree

21 files changed

+3854
-0
lines changed

21 files changed

+3854
-0
lines changed

‎Src/EngineIoClientDotNet.Tests.net35/ClientTests/BinaryPollingTest.cs‎

Lines changed: 211 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,211 @@
1+

2+
3+
4+
using System.Collections.Generic;
5+
using Quobject.EngineIoClientDotNet.Client;
6+
using Quobject.EngineIoClientDotNet.Client.Transports;
7+
using Quobject.EngineIoClientDotNet.Modules;
8+
using System.Collections.Concurrent;
9+
using System.Threading;
10+
using Xunit;
11+
12+
namespace Quobject.EngineIoClientDotNet_Tests.ClientTests
13+
{
14+
15+
public class BinaryPollingTest : Connection
16+
{
17+
18+
//[Fact]
19+
//public void PingTest()
20+
//{
21+
22+
// var log = LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod());
23+
// log.Info("Start");
24+
25+
// var binaryData = new byte[5];
26+
// for (int i = 0; i < binaryData.Length; i++)
27+
// {
28+
// binaryData[i] = (byte)i;
29+
// }
30+
31+
// var events = new Queue<object>();
32+
33+
34+
// var options = CreateOptions();
35+
// options.Transports = new List<string>(){"polling"};
36+
37+
// var socket = new Socket(options);
38+
39+
// socket.On(Socket.EVENT_OPEN, () =>
40+
// {
41+
42+
// log.Info("EVENT_OPEN");
43+
44+
// socket.Send(binaryData);
45+
// socket.Send("cash money €€€");
46+
// });
47+
48+
// socket.On(Socket.EVENT_MESSAGE, (d) =>
49+
// {
50+
51+
// var data = d as string;
52+
// log.Info(string.Format("EVENT_MESSAGE data ={0} d = {1} ", data, d));
53+
54+
// if (data == "hi")
55+
// {
56+
// return;
57+
// }
58+
// events.Enqueue(d);
59+
// //socket.Close();
60+
// });
61+
62+
// socket.Open();
63+
// Task.Delay(20000).Wait();
64+
// socket.Close();
65+
// log.Info("ReceiveBinaryData end");
66+
67+
// var binaryData2 = new byte[5];
68+
// for (int i = 0; i < binaryData2.Length; i++)
69+
// {
70+
// binaryData2[i] = (byte)(i + 1);
71+
// }
72+
73+
// object result;
74+
// events.TryDequeue(out result);
75+
// Assert.Equal("1", "1");
76+
//}
77+
78+
private ManualResetEvent _manualResetEvent = null;
79+
80+
[Fact]
81+
public void ReceiveBinaryData()
82+
{
83+
84+
var log = LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod());
85+
log.Info("Start");
86+
_manualResetEvent = new ManualResetEvent(false);
87+
88+
var events = new Queue<object>();
89+
90+
var binaryData = new byte[5];
91+
for (int i = 0; i < binaryData.Length; i++)
92+
{
93+
binaryData[i] = (byte) i;
94+
}
95+
96+
97+
var options = CreateOptions();
98+
options.Transports = new List<string>() { "polling" };
99+
100+
101+
var socket = new Socket(options);
102+
103+
socket.On(Socket.EVENT_OPEN, () =>
104+
{
105+
106+
log.Info("EVENT_OPEN");
107+
108+
socket.Send(binaryData);
109+
//socket.Send("cash money €€€");
110+
111+
});
112+
113+
socket.On(Socket.EVENT_MESSAGE, (d) =>
114+
{
115+
116+
var data = d as string;
117+
log.Info(string.Format("EVENT_MESSAGE data ={0} d = {1} ", data, d));
118+
119+
if (data == "hi")
120+
{
121+
return;
122+
}
123+
events.Enqueue(d);
124+
_manualResetEvent.Set();
125+
});
126+
127+
socket.Open();
128+
_manualResetEvent.WaitOne();
129+
socket.Close();
130+
log.Info("ReceiveBinaryData end");
131+
132+
var binaryData2 = new byte[5];
133+
for (int i = 0; i < binaryData2.Length; i++)
134+
{
135+
binaryData2[i] = (byte) (i + 1);
136+
}
137+
138+
object result;
139+
result = events.Dequeue();
140+
Assert.Equal(binaryData, result);
141+
}
142+
143+
144+
[Fact]
145+
public void ReceiveBinaryDataAndMultibyteUTF8String()
146+
{
147+
148+
var log = LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod());
149+
log.Info("Start");
150+
_manualResetEvent = new ManualResetEvent(false);
151+
152+
var events = new Queue<object>();
153+
154+
var binaryData = new byte[5];
155+
for (int i = 0; i < binaryData.Length; i++)
156+
{
157+
binaryData[i] = (byte) i;
158+
}
159+
const string stringData = "cash money €€€";
160+
161+
var options = CreateOptions();
162+
options.Transports = new List<string>() { "polling" };
163+
164+
165+
var socket = new Socket(options);
166+
167+
socket.On(Socket.EVENT_OPEN, () =>
168+
{
169+
170+
log.Info("EVENT_OPEN");
171+
socket.On(Socket.EVENT_MESSAGE, (d) =>
172+
{
173+
174+
var data = d as string;
175+
log.Info(string.Format("EVENT_MESSAGE data ={0} d = {1} ", data, d));
176+
177+
if (data == "hi")
178+
{
179+
return;
180+
}
181+
events.Enqueue(d);
182+
if (events.Count > 1)
183+
{
184+
_manualResetEvent.Set();
185+
}
186+
});
187+
socket.Send(binaryData);
188+
socket.Send(stringData);
189+
});
190+
191+
socket.Open();
192+
_manualResetEvent.WaitOne();
193+
socket.Close();
194+
var binaryData2 = new byte[5];
195+
for (int i = 0; i < binaryData2.Length; i++)
196+
{
197+
binaryData2[i] = (byte) (i + 1);
198+
}
199+
200+
object result;
201+
result = events.Dequeue();
202+
Assert.Equal(binaryData, result);
203+
result = events.Dequeue();
204+
Assert.Equal(stringData, (string) result);
205+
socket.Close();
206+
207+
}
208+
209+
210+
}
211+
}

‎Src/EngineIoClientDotNet.Tests.net35/ClientTests/BinaryWebSocketTest.cs‎

Lines changed: 154 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,154 @@
1+

2+
3+
using System.Collections.Generic;
4+
using Quobject.EngineIoClientDotNet.Client;
5+
using Quobject.EngineIoClientDotNet.Modules;
6+
using System.Collections.Concurrent;
7+
using System.Threading;
8+
using Xunit;
9+
10+
namespace Quobject.EngineIoClientDotNet_Tests.ClientTests
11+
{
12+
public class BinaryWebSocketTest : Connection
13+
{
14+
private ManualResetEvent _manualResetEvent = null;
15+
[Fact]
16+
public void ReceiveBinaryData()
17+
{
18+
19+
var log = LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod());
20+
log.Info("Start");
21+
_manualResetEvent = new ManualResetEvent(false);
22+
23+
var events = new Queue<object>();
24+
25+
var binaryData = new byte[5];
26+
for (int i = 0; i < binaryData.Length; i++)
27+
{
28+
binaryData[i] = (byte) (i + 0);
29+
}
30+
31+
32+
var options = CreateOptions();
33+
34+
var socket = new Socket(options);
35+
36+
socket.On(Socket.EVENT_OPEN, () =>
37+
{
38+
log.Info(Socket.EVENT_OPEN);
39+
});
40+
41+
socket.On(Socket.EVENT_UPGRADE, () =>
42+
{
43+
log.Info(Socket.EVENT_UPGRADE);
44+
socket.Send(binaryData);
45+
});
46+
47+
48+
socket.On(Socket.EVENT_MESSAGE, (d) =>
49+
{
50+
51+
var data = d as string;
52+
log.Info(string.Format("EVENT_MESSAGE data ={0} d = {1} ", data, d));
53+
54+
if (data == "hi")
55+
{
56+
return;
57+
}
58+
events.Enqueue(d);
59+
_manualResetEvent.Set();
60+
});
61+
62+
socket.Open();
63+
_manualResetEvent.WaitOne();
64+
socket.Close();
65+
log.Info("ReceiveBinaryData end");
66+
67+
var binaryData2 = new byte[5];
68+
for (int i = 0; i < binaryData2.Length; i++)
69+
{
70+
binaryData2[i] = (byte) (i + 1);
71+
}
72+
73+
object result;
74+
result = events.Dequeue();
75+
Assert.Equal(binaryData, result);
76+
77+
}
78+
79+
80+
[Fact]
81+
public void ReceiveBinaryDataAndMultibyteUTF8String()
82+
{
83+
84+
var log = LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod());
85+
log.Info("Start");
86+
_manualResetEvent = new ManualResetEvent(false);
87+
88+
var events = new Queue<object>();
89+
90+
var binaryData = new byte[5];
91+
for (int i = 0; i < binaryData.Length; i++)
92+
{
93+
binaryData[i] = (byte) i;
94+
}
95+
const string stringData = "Ä ä Ü ü ß";
96+
97+
var options = CreateOptions();
98+
99+
var socket = new Socket(options);
100+
101+
socket.On(Socket.EVENT_OPEN, () =>
102+
{
103+
104+
log.Info("EVENT_OPEN");
105+
106+
107+
108+
});
109+
110+
socket.On(Socket.EVENT_UPGRADE, () =>
111+
{
112+
log.Info(Socket.EVENT_UPGRADE);
113+
socket.Send(binaryData);
114+
socket.Send(stringData);
115+
});
116+
117+
socket.On(Socket.EVENT_MESSAGE, (d) =>
118+
{
119+
120+
var data = d as string;
121+
log.Info(string.Format("EVENT_MESSAGE data ={0} d = {1} ", data, d));
122+
123+
if (data == "hi")
124+
{
125+
return;
126+
}
127+
events.Enqueue(d);
128+
if (events.Count > 1)
129+
{
130+
_manualResetEvent.Set();
131+
}
132+
});
133+
134+
socket.Open();
135+
_manualResetEvent.WaitOne();
136+
socket.Close();
137+
138+
var binaryData2 = new byte[5];
139+
for (int i = 0; i < binaryData2.Length; i++)
140+
{
141+
binaryData2[i] = (byte) (i + 1);
142+
}
143+
144+
object result;
145+
result = events.Dequeue();
146+
Assert.Equal(binaryData, result);
147+
result = events.Dequeue();
148+
Assert.Equal(stringData, (string) result);
149+
log.Info("ReceiveBinaryDataAndMultibyteUTF8String end");
150+
}
151+
152+
153+
}
154+
}

0 commit comments

Comments
 (0)