TestSipClientCancelpublic class TestSipClientCancel extends com.sun.midp.i3test.TestCase | Tests for initializing and sending CANCEL request. |
| Fields Summary |
|---|
| private String | corrURIURI of other side of SIP session (returns in 200 OK response). | | private static final String | toTagServer tag. |
| Methods Summary |
|---|
| void | Test1()Body of the test 1.
Create CANCEL request and check its fields.
/** Method of original request */
String method = "INVITE";
/** Client connection. */
SipClientConnection sc = null;
/**
* Dialog is created in case of INVITE method (RFC 3261, 12.1)
* or SUBSCRIBE method (RFC 3265, 3.3.4) after provisional requests.
*/
try {
// Open SIP client connection to the local SIP server
sc = (SipClientConnection)
Connector.open(corrURI);
} catch (Exception ex) {
assertNull("Exception during sc open", sc);
}
assertNotNull("sc is null", sc);
try {
sc.initRequest(method, null);
} catch (Throwable e) {
fail("INITIALIZED " +e +" was caused");
}
// Move to PROCEEDING state
try {
sc.send();
} catch (Throwable e) {
fail("PROCEEDING " +e +" was caused");
}
// new SipClientConnection instance with CANCEL request
SipClientConnection scCancel = null;
// try to create scCancel before provisional response
try {
scCancel = sc.initCancel();
fail("No SipException was thrown");
} catch (SipException e) {
assertTrue("Error code is wrong",
e.getErrorCode() == SipException.INVALID_STATE);
} catch (Throwable e) {
fail("PROCEEDING " +e +" was caused");
}
// receive provisional response
sendResponse(sc, Response.TRYING);
// try to create scCancel after provisional response
// and before final response
try {
scCancel = sc.initCancel();
} catch (Throwable e) {
fail("PROCEEDING " +e +" was caused");
}
// check that scCancel != null
assertTrue("CANCEL connection is null", scCancel != null);
// check that the state of scCancel is INITIALIZED
// (JSR 180, initCancel method of SipClientConnection)
assertEquals("State is not INITIALIZED",
((SipClientConnectionImpl)scCancel).getState(),
SipClientConnectionImpl.INITIALIZED);
// check CANCEL request fields
// (RFC 3261, 9.1)
assertTrue("RequestURI is wrong",
sc.getRequestURI().equalsIgnoreCase(
scCancel.getRequestURI()));
assertTrue("Header Call-ID is wrong",
sc.getHeader("Call-ID").equalsIgnoreCase(
scCancel.getHeader("Call-ID")));
assertTrue("Header To is wrong",
sc.getHeader("To").equalsIgnoreCase(
scCancel.getHeader("To")));
assertTrue("Header From is wrong",
sc.getHeader("From").equalsIgnoreCase(
scCancel.getHeader("From")));
// the numeric part of CSeq MUST be equal
// (RFC 3261, 9.1)
Request originalReq = ((SipClientConnectionImpl)sc).getRequest();
Request cancelReq = ((SipClientConnectionImpl)scCancel).getRequest();
CSeqHeader originalCS = (CSeqHeader)originalReq.getHeader("CSeq");
CSeqHeader cancelCS = (CSeqHeader)cancelReq.getHeader("CSeq");
assertTrue("Header CSeq is wrong",
originalCS.getSequenceNumber() == cancelCS.getSequenceNumber());
// A CANCEL constructed by a client MUST have only a single Via header
// field value matching the top Via value in the request
// being cancelled. (RFC 3261, 9.1)
// TBD (the situation with methods setHeader(), getHeader(),
// getHeaders() and removeHeader() is not clear yet
// close connections
try {
scCancel.close();
} catch (Throwable e) {
fail("" +e +" was caused");
}
// receive final response
sendResponse(sc, Response.OK);
// try to create scCancel after final response
try {
scCancel = sc.initCancel();
fail("No SipException was thrown");
} catch (SipException e) {
assertTrue("Error code is wrong",
e.getErrorCode() == SipException.INVALID_STATE);
} catch (Throwable e) {
fail("PROCEEDING " +e +" was caused");
}
// close connections
try {
sc.close();
scCancel.close();
} catch (Throwable e) {
fail("" +e +" was caused");
}
| | public void | runTests()Tests execute
declare("Test CANCEL request");
Test1();
| | private void | sendResponse(SipClientConnection sc, int respCode)Send a response with given code.
// Send a response
Request request = null;
Response response = null;
try {
request = ((SipClientConnectionImpl)sc).getRequest();
// create a response for request
response = request.createResponse(respCode);
// RFC 3261 8.2.6.2 Response must have To tag
ToHeader toHeader = response.getTo();
if (!toHeader.hasTag()) {
// To header has no tag - add server tag
toHeader.setTag(toTag);
response.setTo(toHeader);
}
if (respCode == Response.UNAUTHORIZED) {
WWWAuthenticateHeader authHeader = new WWWAuthenticateHeader();
authHeader.setParameter(AuthenticationHeader.REALM, "realm");
response.setHeader(authHeader);
}
// add Contact header when request is not "MESSAGE"
if ((respCode == Response.OK) &&
(!request.getMethod().equals("MESSAGE"))) {
SipURI contactURI = StackConnector
.addressFactory
.createSipURI("sippy.tester", // name
"localhost:5060");
ContactHeader contactHeader =
StackConnector
.headerFactory
.createContactHeader(
StackConnector
.addressFactory
.createAddress(contactURI));
response.addHeader(contactHeader);
}
((SipClientConnectionImpl)sc).clearResponse();
ClientTransaction clientTransaction =
((SipClientConnectionImpl)sc).getClientTransaction();
SipStack sipStack = ((SipClientConnectionImpl)sc).getSipStack();
SIPServerResponseInterface ssc =
GetSipServerResponse.newSIPServerResponse(sipStack, response,
clientTransaction.getMessageChannel());
ssc.processResponse(response,
clientTransaction.getMessageChannel());
while (((SipClientConnectionImpl)sc).getResponse() == null) {
Thread.yield();
}
} catch (Throwable e) {
fail("sendResponse " +e +" was caused");
}
|
|
