Infrastructure Software

import java.io.*;
import javax.sip.*;
import javax.sip.address.*;
import javax.sip.header.*;
import javax.sip.message.*;
import java.util.*;

public class sipClient implements SipListener {

	private static AddressFactory addressFactory;
	private static MessageFactory messageFactory;
	private static HeaderFactory headerFactory;
	private static Address address;
	private static SipStack sipStack;
	private int port;
	protected SipProvider udpProvider;
	protected Dialog dialog;
	protected int notifyCount = 0;
	public static final int PORT_5060 = 5070;	
	protected final String serverIP = "192.168.1.99";

	
	class MyEventSource implements Runnable {
		private sipClient st;
		private EventHeader eventHeader;

		public MyEventSource(sipClient notifier, EventHeader eventHeader ) {
			this.st = notifier;
			this.eventHeader = eventHeader;
		}

		public void run() {
			try {
				for (int i = 0; i < 100; i++) {

					Thread.sleep(100);
					Request request = this.st.dialog.createRequest(Request.NOTIFY);
					SubscriptionStateHeader subscriptionState = headerFactory.createSubscriptionStateHeader(SubscriptionStateHeader.ACTIVE);
					request.addHeader(subscriptionState);
					request.addHeader(eventHeader);
					
					// Lets mark our Contact
					((SipURI)dialog.getLocalParty().getURI()).setParameter("id","not2");
					
					ClientTransaction ct = udpProvider.getNewClientTransaction(request);
					System.out.println("NOTIFY Branch ID "+((ViaHeader)request.getHeader(ViaHeader.NAME)).getParameter("branch"));
					this.st.dialog.sendRequest(ct);
					System.out.println("Dialog " + dialog);
					System.out.println("Dialog state after active NOTIFY: " + dialog.getState());
					synchronized (sipClient.this) {
					notifyCount ++;
					}
				}
			} catch (Throwable e) {
				e.printStackTrace();
			}
		}
	}


	private static void usage() {
		System.exit(0);

	}

	public void processRequest(RequestEvent requestEvent) {
		Request request = requestEvent.getRequest();
		ServerTransaction serverTransactionId = requestEvent.getServerTransaction();

		System.out.println("\n\nRequest " + request.getMethod()+" received at " + sipStack.getStackName()+" with server transaction id " + serverTransactionId+" and dialog id "+requestEvent.getDialog());
		if (request.getMethod().equals(Request.SUBSCRIBE)) {
			processSubscribe(requestEvent, serverTransactionId);
		}

	}

	/**
	 * Process the invite request.
	 */
	public void processSubscribe(RequestEvent requestEvent,
			ServerTransaction serverTransaction) {
		SipProvider sipProvider = (SipProvider) requestEvent.getSource();
		Request request = requestEvent.getRequest();
		try {
			System.out.println("notifier: got an Subscribe sending OK");
			System.out.println("notifier:  " + request);
			System.out.println("notifier : dialog = " + requestEvent.getDialog());
			EventHeader eventHeader = (EventHeader) request.getHeader(EventHeader.NAME);
			if ( eventHeader == null) {
				System.out.println("Cannot find event header.... dropping request.");
				return;
			}
						
			// Always create a ServerTransaction, best as early as possible in the code
			Response response = null;
			ServerTransaction st = requestEvent.getServerTransaction();			
			if (st == null) {
				st = sipProvider.getNewServerTransaction(request);
			}
			
			// Check if it is an initial SUBSCRIBE or a refresh / unsubscribe
			boolean isInitial = requestEvent.getDialog() == null;
			if ( isInitial ) {
				// need random tags to test forking
				String toTag = Integer.toHexString( (int) (Math.random() * Integer.MAX_VALUE) );
				response = messageFactory.createResponse(202, request);
				ToHeader toHeader = (ToHeader) response.getHeader(ToHeader.NAME);
				
				// Sanity check: to header should not ahve a tag. Else the dialog 
				// should have matched
				if (toHeader.getTag()!=null) {
					System.err.println( "####ERROR: To-tag!=null but no dialog match! My dialog=" + dialog.getState() );
				}				
				toHeader.setTag(toTag); // Application is supposed to set.
				
				this.dialog = st.getDialog();
				// subscribe dialogs do not terminate on bye.
				this.dialog.terminateOnBye(false);
				if (dialog != null) {
					System.out.println("Dialog " + dialog);
					System.out.println("Dialog state " + dialog.getState());
				}
			} else {
				response = messageFactory.createResponse(200, request);
			}

			// Both 2xx response need a Contact
			address = addressFactory.createAddress("xTrade <sip:192.168.1.99>");
			((SipURI)address.getURI()).setPort( udpProvider.getListeningPoint("udp").getPort() );				
			ContactHeader contactHeader = headerFactory.createContactHeader(address);			
			response.addHeader(contactHeader);
			
			// Expires header is mandatory in 2xx responses to SUBSCRIBE
			ExpiresHeader expires = (ExpiresHeader) request.getHeader( ExpiresHeader.NAME );
			if (expires==null) {
				expires = headerFactory.createExpiresHeader(30);	// rather short
			}
			response.addHeader( expires );
			st.sendResponse(response);
						
			/*
			 * NOTIFY requests MUST contain a "Subscription-State" header with a
			 * value of "active", "pending", or "terminated". The "active" value
			 * indicates that the subscription has been accepted and has been
			 * authorized (in most cases; see section 5.2.). The "pending" value
			 * indicates that the subscription has been received, but that
			 * policy information is insufficient to accept or deny the
			 * subscription at this time. The "terminated" value indicates that
			 * the subscription is not active.
			 */
		
			Request notifyRequest = dialog.createRequest( "NOTIFY" );
			
			// Mark the contact header, to check that the remote contact is updated
			((SipURI)contactHeader.getAddress().getURI()).setParameter("id","not");
			
			// Initial state is pending, second time we assume terminated (Expires==0)
			SubscriptionStateHeader sstate = headerFactory.createSubscriptionStateHeader(
					isInitial ? SubscriptionStateHeader.PENDING : SubscriptionStateHeader.TERMINATED );
			
			// Need a reason for terminated
			if ( sstate.getState().equalsIgnoreCase("terminated") ) {
				sstate.setReasonCode( "deactivated" );
			}
			
			notifyRequest.addHeader(sstate);
			notifyRequest.setHeader(eventHeader);
			notifyRequest.setHeader(contactHeader);
			// notifyRequest.setHeader(routeHeader);
			ClientTransaction ct = udpProvider.getNewClientTransaction(notifyRequest);

			// Let the other side know that the tx is pending acceptance
			//
			dialog.sendRequest(ct);
			System.out.println("NOTIFY Branch ID " +
				((ViaHeader)request.getHeader(ViaHeader.NAME)).getParameter("branch"));
			System.out.println("Dialog " + dialog);
			System.out.println("Dialog state after pending NOTIFY: " + dialog.getState());
			
			if (isInitial) {
				Thread myEventSource = new Thread(new MyEventSource(this,eventHeader));
				myEventSource.start();
			}
		} catch (Throwable ex) {
			ex.printStackTrace();
			// System.exit(0);
		}
	}

	public synchronized void processResponse(ResponseEvent responseReceivedEvent) {
		Response response = (Response) responseReceivedEvent.getResponse();
		Transaction tid = responseReceivedEvent.getClientTransaction();

		if ( response.getStatusCode() !=  200 ) {
			this.notifyCount --;
		} else {
		    System.out.println("Notify Count = " + this.notifyCount);
		}

	}

	public void processTimeout(javax.sip.TimeoutEvent timeoutEvent) {
		Transaction transaction;
		if (timeoutEvent.isServerTransaction()) {
			transaction = timeoutEvent.getServerTransaction();
		} else {
			transaction = timeoutEvent.getClientTransaction();
		}
		System.out.println("state = " + transaction.getState());
		System.out.println("dialog = " + transaction.getDialog());
		System.out.println("dialogState = "
				+ transaction.getDialog().getState());
		System.out.println("Transaction Time out");
	}
	
    private static void initFactories ( int port ) throws Exception {
    	
		SipFactory sipFactory = SipFactory.getInstance();
		sipFactory.setPathName("gov.nist");
		Properties properties = new Properties();

		properties.setProperty("javax.sip.STACK_NAME", "notifier" + port );
		// 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");
		properties.setProperty("gov.nist.javax.sip.DEBUG_LOG","Xtradedebug_"+port+".txt");
		properties.setProperty("gov.nist.javax.sip.SERVER_LOG","Xtradelog_"+port+".txt");
		properties.setProperty("javax.sip.OUTBOUND_PROXY","192.168.1.99:5070/UDP");
		properties.setProperty("javax.sip.USE_ROUTER_FOR_ALL_URIS", "true");
		properties.setProperty("javax.sip.AUTOMATIC_DIALOG_SUPPORT","ON");
		try {
			// Create SipStack object
			sipStack = sipFactory.createSipStack(properties);
			System.out.println("sipStack = " + sipStack);
		} catch (PeerUnavailableException e) {
			// could not find
			// gov.nist.jain.protocol.ip.sip.SipStackImpl
			// in the classpath
			e.printStackTrace();
			System.err.println(e.getMessage());
			if (e.getCause() != null)
				e.getCause().printStackTrace();
			System.exit(0);
		}

		try {
			headerFactory = sipFactory.createHeaderFactory();
			addressFactory = sipFactory.createAddressFactory();
			messageFactory = sipFactory.createMessageFactory();
		} catch  (Exception ex) {
			ex.printStackTrace();
			System.exit(0);
		}
    }

	public void createProvider() {
		
		try {
			System.out.println("sipStack = " + sipStack);
			System.out.println("SipProviders: "+sipStack.getSipProviders().toString());
			System.out.println("AddressFactory: "+addressFactory.getClass());
			ListeningPoint lp = sipStack.createListeningPoint(this.serverIP, 5070, ListeningPoint.UDP);
			this.udpProvider = sipStack.createSipProvider(lp);
			System.out.println("udp provider " + udpProvider);
			
		}catch(SipException e){
			System.out.print("SipException "+e.getMessage());
			e.printStackTrace();
		}
		/*catch(TransportNotSupportedException e){
			System.out.print("TransportNotSupportedException "+e.getMessage());
		}*/
		catch (InvalidArgumentException e){
			System.out.print("InvalidArgumentException "+e.getMessage());
			e.printStackTrace();
		}
		catch (Exception ex) {
			System.err.println((ex.getMessage()));
			ex.printStackTrace();
			usage();
		}

	}

	public sipClient( int port ) {
		this.port = port;
	}

	public sipClient(){
		
	}

	public static void main(String args[]) throws Exception {
		int port = args.length > 0 ? Integer.parseInt(args[0]) : 5070;
		initFactories( port );
		sipClient st = new sipClient( port );
		st.createProvider();
		st.udpProvider.addSipListener(st);
	}

	public void processIOException(IOExceptionEvent exceptionEvent) {

	}

	public void processTransactionTerminated(
			TransactionTerminatedEvent transactionTerminatedEvent) {

	}

	public void processDialogTerminated(
			DialogTerminatedEvent dialogTerminatedEvent) {
		// TODO Auto-generated method stub

	}

}