Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  package examples.tls;
  
  import javax.sip.*;
  import javax.sip.header.*;
 
 import java.util.*;



This class is a UAC template. Shootist is the guy that shoots and shootme is the guy that gets shot.

Author(s):
Daniel Martinez
Ivelin Ivanov
 
 
 public class Shootist implements SipListenerTlsSecurityPolicy {
 
     private static SipProvider tlsProvider;
     private static AddressFactory addressFactory;
     private static MessageFactory messageFactory;
     private static HeaderFactory headerFactory;
     private static SipStack sipStack;
     private int reInviteCount;
     private ContactHeader contactHeader;
     private ListeningPoint tlsListeningPoint;
     private int counter;
 
     protected ClientTransaction inviteTid;
 
     protected static final String usageString =
         "java "
             + "examples.shootistTLS.Shootist \n"
             + ">>>> is your class path set to the root?";
 
     private static void usage() {
         ..println();
         System.exit(0);
 
     }
     private void shutDown() {
         try {
                 try {
                 Thread.sleep(2000);
                  } catch (InterruptedException e) {
                  }
             ..println("nulling reference");
             // This will close down the stack and exit all threads
             .removeSipListener(this);
             while (true) {
               try {
                   .deleteSipProvider();
                   break;
                 } catch (ObjectInUseException  ex)  {
                     try {
                     Thread.sleep(2000);
                      } catch (InterruptedException e) {
                     continue;
                      }
                }
             }
              = null;
              = null;
             this. = null;
             this. = null;
              = null;
              = null;
              = null;
             this. = null;
             this. = 0;
             System.gc();
             //Redo this from the start.
            //  if (counter < 10 )
            //     this.init();
            //  else counter ++;
         } catch (Exception ex) { ex.printStackTrace(); }
     }
 
 
     public void processRequest(RequestEvent requestReceivedEvent) {
         Request request = requestReceivedEvent.getRequest();
         ServerTransaction serverTransactionId =
             requestReceivedEvent.getServerTransaction();
 
         ..println(
             "\n\nRequest "
                 + request.getMethod()
                 + " received at "
                 + .getStackName()
                + " with server transaction id "
                + serverTransactionId);
        // We are the UAC so the only request we get is the BYE.
        if (request.getMethod().equals(.))
            processBye(requestserverTransactionId);
    }
    public void processBye(
        Request request,
        ServerTransaction serverTransactionId) {
        try {
            ..println("shootist:  got a bye .");
            if (serverTransactionId == null) {
                ..println("shootist:  null TID.");
                return;
            }
            Dialog dialog = serverTransactionId.getDialog();
            ..println("Dialog State = " + dialog.getState());
            Response response = .createResponse
                        (200, request);
            serverTransactionId.sendResponse(response);
            ..println("shootist:  Sending OK.");
            ..println("Dialog State = " + dialog.getState());
            this.shutDown();
        } catch (Exception ex) {
            ex.printStackTrace();
            System.exit(0);
        }
    }
    public void processResponse(ResponseEvent responseReceivedEvent) {
        ..println("Got a response");
        Response response = (ResponseresponseReceivedEvent.getResponse();
        Transaction tid = responseReceivedEvent.getClientTransaction();
        CSeqHeader cseq = (CSeqHeaderresponse.getHeader(.);
        ..println(
            "Response received with client transaction id "
                + tid
                + ":\n"
                + response.getStatusCode());
        if (tid == null) {
            ..println("Stray response -- dropping ");
            return;
        }
        ..println("transaction state is " + tid.getState());
        ..println("Dialog = " + tid.getDialog());
        ..println("Dialog State is " + tid.getDialog().getState());
        try {
            if (response.getStatusCode() == .
                && ((CSeqHeaderresponse.getHeader(.))
                    .getMethod()
                    .equals(
                    .)) {
                Dialog dialog = tid.getDialog();
                Request ackRequest = dialog.createAckcseq.getSeqNumber() );
                ..println("Sending ACK");
                dialog.sendAck(ackRequest);
                // Send a Re INVITE
                if ( == 0) {
                    Request inviteRequest = dialog.createRequest(.);
                    //((SipURI)inviteRequest.getRequestURI()).removeParameter("transport");
                    //((ViaHeader)inviteRequest.getHeader(ViaHeader.NAME)).setTransport("tls");
                    // inviteRequest.addHeader(contactHeader);
                    try {Thread.sleep(100); } catch (Exception ex) {}
                    ClientTransaction ct =
                    .getNewClientTransaction(inviteRequest);
                    dialog.sendRequest(ct);
                     ++;
                }
            }
        } catch (Exception ex) {
            ex.printStackTrace();
            System.exit(0);
        }
    }
    public void processTimeout(javax.sip.TimeoutEvent timeoutEvent) {
        ..println("Transaction Time out" );
    }
    public void init() {
        SipFactory sipFactory = null;
         = null;
        sipFactory = SipFactory.getInstance();
        sipFactory.setPathName("gov.nist");
        Properties properties = new Properties();
        String transport = "tls";
        int port = 5061;
        String peerHostPort = "127.0.0.1:5071";
        properties.setProperty(
            "javax.sip.OUTBOUND_PROXY",
            peerHostPort + "/" + transport);
        // If you want to use UDP then uncomment this.
        //properties.setProperty(
        //  "javax.sip.ROUTER_PATH",
        //  "examples.shootistTLS.MyRouter");
        properties.setProperty("javax.sip.STACK_NAME""shootist");
   
        // The following properties are specific to nist-sip
        // and are not necessarily part of any other jain-sip
        // implementation.
        // You can set a max message size for tcp transport to
        // guard against denial of service attack.
        properties.setProperty("gov.nist.javax.sip.MAX_MESSAGE_SIZE",
                    "1048576");
        properties.setProperty(
            "gov.nist.javax.sip.DEBUG_LOG",
            "shootistdebug.txt");
        properties.setProperty(
            "gov.nist.javax.sip.SERVER_LOG",
            "shootistlog.txt");
        properties.setProperty("gov.nist.javax.sip.TLS_SECURITY_POLICY",
                this.getClass().getName());
        // Drop the client connection after we are done with the transaction.
        properties.setProperty("gov.nist.javax.sip.CACHE_CLIENT_CONNECTIONS""false");
        // Set to 0 in your production code for max speed.
        // You need  16 for logging traces. 32 for debug + traces.
        // Your code will limp at 32 but it is best for debugging.
        properties.setProperty("gov.nist.javax.sip.TRACE_LEVEL""32");
        try {
            // Create SipStack object
             = sipFactory.createSipStack(properties);
            ..println("createSipStack " + );
        } catch (PeerUnavailableException e) {
            // could not find
            // gov.nist.jain.protocol.ip.sip.SipStackImpl
            // in the classpath
            e.printStackTrace();
            ..println(e.getMessage());
            System.exit(0);
        }
        try {
             = sipFactory.createHeaderFactory();
             = sipFactory.createAddressFactory();
             = sipFactory.createMessageFactory();
            Shootist listener = this;
                                ("127.0.0.1"port"tls");
            .addSipListener(listener);
            SipProvider sipProvider = ;
            String fromName = "BigGuy";
            String fromSipAddress = "here.com";
            String fromDisplayName = "The Master Blaster";
            String toSipAddress = "there.com";
            String toUser = "LittleGuy";
            String toDisplayName = "The Little Blister";
            // create >From Header
            SipURI fromAddress =
                .createSipURI(fromNamefromSipAddress);
            //fromAddress.setSecure(true);
            Address fromNameAddress = .createAddress(fromAddress);
            fromNameAddress.setDisplayName(fromDisplayName);
            FromHeader fromHeader =
                .createFromHeader(fromNameAddress"12345");
            // create To Header
            SipURI toAddress =
                .createSipURI(toUsertoSipAddress);
            //toAddress.setSecure(true);
            Address toNameAddress = .createAddress(toAddress);
            toNameAddress.setDisplayName(toDisplayName);
            ToHeader toHeader =
                .createToHeader(toNameAddressnull);
            // create Request URI
            SipURI requestURI =
                .createSipURI(toUserpeerHostPort);
            //requestURI.setSecure( true );
            // Create ViaHeaders
           ArrayList viaHeaders = new ArrayList();
           ViaHeader viaHeader =
                .createViaHeader(
                    "127.0.0.1",
                    port,
                    transport,
                    null);
            // add via headers
            viaHeaders.add(viaHeader);
            // Create ContentTypeHeader
            ContentTypeHeader contentTypeHeader =
                .createContentTypeHeader("application""sdp");
            // Create a new CallId header
            CallIdHeader callIdHeader = sipProvider.getNewCallId();
            // Create a new Cseq header
            CSeqHeader cSeqHeader =
                .createCSeqHeader(1L, .);
            // Create a new MaxForwardsHeader
            MaxForwardsHeader maxForwards =
                .createMaxForwardsHeader(70);
            // Create the request.
            Request request =
                .createRequest(
                    requestURI,
                    .,
                    callIdHeader,
                    cSeqHeader,
                    fromHeader,
                    toHeader,
                    viaHeaders,
                    maxForwards);
            // Create contact headers
            String host = "127.0.0.1";
            //SipURI contactUrl = addressFactory.createSipURI(fromName, host);
            //contactUrl.setPort(tlsListeningPoint.getPort());
            // Create the contact name address.
            SipURI contactURI = .createSipURI(fromNamehost);
            //contactURI.setSecure( true );
            contactURI.setPort(port);
            contactURI.setTransportParam("tls");
            Address contactAddress = .createAddress(contactURI);
            // Add the contact address.
            contactAddress.setDisplayName(fromName);
             =
                .createContactHeader(contactAddress);
            request.addHeader();
            // Add the extension header.
            Header extensionHeader =
                .createHeader("My-Header""my header value");
            request.addHeader(extensionHeader);
            String sdpData =
                "v=0\r\n"
                    + "o=4855 13760799956958020 13760799956958020"
                    + " IN IP4  129.6.55.78\r\n"
                    + "s=mysession session\r\n"
                    + "p=+46 8 52018010\r\n"
                    + "c=IN IP4  129.6.55.78\r\n"
                    + "t=0 0\r\n"
                    + "m=audio 6022 RTP/AVP 0 4 18\r\n"
                    + "a=rtpmap:0 PCMU/8000\r\n"
                    + "a=rtpmap:4 G723/8000\r\n"
                    + "a=rtpmap:18 G729A/8000\r\n"
                    + "a=ptime:20\r\n";
            byte[]  contents = sdpData.getBytes();
            //byte[]  contents = sdpBuff.toString().getBytes();
            request.setContent(contentscontentTypeHeader);
            Header callInfoHeader =
                .createHeader(
                    "Call-Info",
                    "<http://www.antd.nist.gov>");
            request.addHeader(callInfoHeader);
            
            SipURI routeUri = (SipURIrequestURI.clone();
            routeUri.setLrParam();
            routeUri.setTransportParam("tls");
            Address peerAddress = .createAddress(requestURI);
           
            
            RouteHeader routeHeader = .createRouteHeader(peerAddress);
            request.setHeader(routeHeader);
            // Create the client transaction.
            listener.inviteTid = sipProvider.getNewClientTransaction(request);
            // send the request out.
            listener.inviteTid.sendRequest();
            
            ..println("isSecure = " + ((ClientTransactionExt)listener.inviteTid).isSecure());
            if ( ((ClientTransactionExt)listener.inviteTid).isSecure() ) {
                ..println("cipherSuite = " + ((ClientTransactionExt)listener.inviteTid).getCipherSuite());
                for ( Certificate cert : ((ClientTransactionExt)listener.inviteTid).getLocalCertificates()) {
                    ..println("localCert =" + cert);
                }
                for ( Certificate cert : ((ClientTransactionExt)listener.inviteTid).getPeerCertificates()) {
                    ..println("remoteCerts = " + cert);
                }
            }
        } catch (Exception ex) {
            ..println(ex.getMessage());
            ex.printStackTrace();
            usage();
        }
    }
    public static void main(String args[]) {
        new Shootist().init();
    }
    public void processIOException(IOExceptionEvent exceptionEvent) {
        ..println("IOException occured while retransmitting requests:" + exceptionEvent);
    }
    public void processTransactionTerminated(TransactionTerminatedEvent transactionTerminatedEvent) {
        ..println("Transaction Terminated event: " + transactionTerminatedEvent );
    }
    public void processDialogTerminated(DialogTerminatedEvent dialogTerminatedEvent) {
        ..println("Dialog Terminated event: " + dialogTerminatedEvent);
    }
    public void enforceTlsPolicy(ClientTransactionExt transactionthrows SecurityException {
        ..println("enforceTlsPolicy");
        List<StringcertIdentities = null;
        try {
            certIdentities = transaction.extractCertIdentities();
        } catch (SSLPeerUnverifiedException e) {
        }
        if ((certIdentities == null) || certIdentities.isEmpty()) {
            ..println("Could not find any identities in the TLS certificate");
        }
        else {
            ..println("found identities: " + certIdentities);
        }
        // the destination IP address should match one of the certIdentities
        boolean foundPeerIdentity = false;
        String expectedIpAddress = ((SipURI)transaction.getRequest().getRequestURI()).getHost();
        for (String identity : certIdentities) {
            // identities must be resolved to dotted quads before comparing: this is faked here
            String peerIpAddress = "10.10.10.0";
            if (identity.equals("localhost")) {
                peerIpAddress = "127.0.0.1";
            }
            if (expectedIpAddress.equals(peerIpAddress)) {
                foundPeerIdentity = true;
            }
        }
        if (!foundPeerIdentity) {
            throw new SecurityException("Certificate identity does not match requested domain");
        }
    }
New to GrepCode? Check out our FAQ X