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
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
|
package com.smartdevicelink.test.streaming;
import java.io.BufferedInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.URL;
import java.net.URLConnection;
import junit.framework.TestCase;
import com.smartdevicelink.SdlConnection.ISdlConnectionListener;
import com.smartdevicelink.SdlConnection.SdlSession;
import com.smartdevicelink.protocol.ProtocolMessage;
import com.smartdevicelink.protocol.enums.SessionType;
import com.smartdevicelink.proxy.RPCRequest;
import com.smartdevicelink.streaming.AbstractPacketizer;
import com.smartdevicelink.streaming.IStreamListener;
import com.smartdevicelink.test.Test;
import com.smartdevicelink.transport.BTTransportConfig;
import com.smartdevicelink.transport.BaseTransportConfig;
/**
* This is a unit test class for the SmartDeviceLink library project class :
* {@link com.smartdevicelink.streaming.AbstractPacketizer}
*/
public class AbstractPacketizerTests extends TestCase {
/**
* This is a unit test for the following methods :
* {@link com.smartdevicelink.streaming.AbstractPacketizer#AbstractPacketizer(IStreamListener, InputStream, SessionType, byte)}
* {@link com.smartdevicelink.streaming.AbstractPacketizer#AbstractPacketizer(IStreamListener, InputStream, RPCRequest, SessionType, byte, byte)}
*/
public void testConstructors () {
// Test Values
byte testSessionId = (byte) 0x0A;
byte testWiproVersion = (byte) 0x0B;
RPCRequest testRpcRequest = new RPCRequest("test");
SessionType testSessionType = SessionType.RPC;
SdlSession testSdlSession = null;
InputStream testInputStream = null;
MockPacketizer testPacketizer1 = null;
MockPacketizer testPacketizer2 = null;
MockPacketizer testPacketizer3 = null;
MockPacketizer testPacketizer4 = null;
IStreamListener testListener = new MockStreamListener();
try {
URL url = new URL("ftp://mirror.csclub.uwaterloo.ca/index.html");
URLConnection urlConnection = url.openConnection();
testInputStream = new BufferedInputStream(urlConnection.getInputStream());
MockInterfaceBroker _interfaceBroker = new MockInterfaceBroker();
BaseTransportConfig _transportConfig = new BTTransportConfig(true);
testSdlSession = SdlSession.createSession(testWiproVersion,_interfaceBroker, _transportConfig);
testPacketizer1 = new MockPacketizer(testListener, testInputStream, testSessionType, testSessionId, testSdlSession);
testPacketizer2 = new MockPacketizer(null, null, null, testSessionId, testSdlSession);
testPacketizer3 = new MockPacketizer(testListener, testInputStream, testRpcRequest, testSessionType, testSessionId, testWiproVersion, testSdlSession);
try {
new MockPacketizer(null, null, null, null, testSessionId, testWiproVersion, null);
fail("Exception should be thrown");
}catch(Exception e) {
assertTrue(e instanceof IllegalArgumentException);
}
// Valid Tests
assertNotNull(Test.NOT_NULL, testPacketizer1);
assertNotNull(Test.NOT_NULL, testPacketizer2);
assertNotNull(Test.NOT_NULL, testPacketizer3);
assertEquals(Test.MATCH, testListener, testPacketizer1.getListener());
assertEquals(Test.MATCH, testInputStream, testPacketizer1.getInputStream());
assertEquals(Test.MATCH, testSessionType, testPacketizer1.getSessionType());
assertEquals(Test.MATCH, testSessionId, testPacketizer1.getSessionId());
assertEquals(Test.MATCH, testListener, testPacketizer3.getListener());
assertEquals(Test.MATCH, testInputStream, testPacketizer3.getInputStream());
assertEquals(Test.MATCH, testSessionType, testPacketizer3.getSessionType());
assertEquals(Test.MATCH, testSessionId, testPacketizer3.getSessionId());
assertEquals(Test.MATCH, testWiproVersion, testPacketizer3.getWiproVersion());
assertEquals(Test.MATCH, testRpcRequest.getFunctionName(), testPacketizer3.getRPCRequest().getFunctionName());
assertEquals(Test.MATCH, testSdlSession, testPacketizer3.getSdlSession());
// Invalid/Null Tests
assertNull(Test.NULL, testPacketizer2.getListener());
assertNull(Test.NULL, testPacketizer2.getInputStream());
assertNull(Test.NULL, testPacketizer2.getSessionType());
} catch (IOException e) {
fail("IOException was thrown.");
}
}
}
/**
* This is a mock class for testing the following :
* {@link com.smartdevicelink.streaming.AbstractPacketizer}
*/
class MockStreamListener implements IStreamListener {
public MockStreamListener () { }
@Override public void sendStreamPacket(ProtocolMessage pm) { }
}
/**
* This is a mock class for testing the following :
* {@link com.smartdevicelink.streaming.AbstractPacketizer}
*/
class MockInterfaceBroker implements ISdlConnectionListener {
public MockInterfaceBroker () { }
@Override
public void onTransportDisconnected(String info) {
}
@Override
public void onTransportError(String info, Exception e) {
}
@Override
public void onProtocolMessageReceived(ProtocolMessage msg) {
}
@Override
public void onProtocolSessionStartedNACKed(SessionType sessionType,
byte sessionID, byte version, String correlationID) {
}
@Override
public void onProtocolSessionStarted(SessionType sessionType,
byte sessionID, byte version, String correlationID, int hashID,
boolean isEncrypted) {
}
@Override
public void onProtocolSessionEnded(SessionType sessionType, byte sessionID,
String correlationID) {
}
@Override
public void onProtocolSessionEndedNACKed(SessionType sessionType,
byte sessionID, String correlationID) {
}
@Override
public void onProtocolError(String info, Exception e) {
}
@Override
public void onHeartbeatTimedOut(byte sessionID) {
}
@Override
public void onProtocolServiceDataACK(SessionType sessionType, int dataSize,
byte sessionID) {
}
}
/**
* This is a mock class for testing the following :
* {@link com.smartdevicelink.streaming.AbstractPacketizer}
*/
class MockPacketizer extends AbstractPacketizer {
public MockPacketizer (IStreamListener l, InputStream i, SessionType s, byte sid, SdlSession sdlsession) throws IOException { super (l, i, s, sid, sdlsession); }
public MockPacketizer (IStreamListener l, InputStream i, RPCRequest r, SessionType s, byte sid, byte w, SdlSession sdlsession) throws IOException { super (l, i, r, s, sid, w, sdlsession); }
@Override public void start() throws IOException { }
@Override public void stop() { }
public IStreamListener getListener () { return _streamListener; }
public InputStream getInputStream () { return is; }
public SessionType getSessionType () { return _serviceType; }
public SdlSession getSdlSession () { return _session; }
public byte getSessionId () { return _rpcSessionID; }
public RPCRequest getRPCRequest () { return _request; }
public byte getWiproVersion () { return _wiproVersion; }
@Override public void pause() { }
@Override public void resume() { }
}
|
