/* * MessageProcessor.java * * Created on November 17, 2003, 5:52 PM */package gov.nist.applet.phone.ua;import java.text.ParseException;import javax.sip.SipException;import javax.sip.Transaction;import javax.sip.SipFactory;import javax.sip.ServerTransaction;import javax.sip.ClientTransaction;import javax.sip.message.Request;import javax.sip.message.Response;import javax.sip.message.MessageFactory;import javax.sip.address.AddressFactory;import javax.sip.address.Address;import javax.sip.address.SipURI;import javax.sip.address.URI;import javax.sip.header.AcceptHeader;import javax.sip.header.CallInfoHeader;import javax.sip.header.ContentTypeHeader;import javax.sip.header.HeaderFactory;import javax.sip.header.FromHeader;import javax.sip.header.ToHeader;import javax.sip.header.ExpiresHeader;import java.util.ListIterator;import gov.nist.applet.phone.media.MediaManager;import gov.nist.applet.phone.media.messaging.VoicePlayer;import gov.nist.applet.phone.media.messaging.VoiceRecorder;import gov.nist.applet.phone.ua.call.*;import gov.nist.applet.phone.ua.pidf.parser.PresenceTag;import gov.nist.applet.phone.ua.pidf.parser.XMLpidfParser;import gov.nist.applet.phone.ua.presence.*;/** * Handler of a major part of sip messages *  * @author  DERUELLE Jean */public class MessageProcessor {	/**	 * The SipFactory instance used to create the SipStack and the Address	 * Message and Header Factories.	 */	SipFactory sipFactory;	/**	 * The AddressFactory used to create URLs ans Address objects.	 */	AddressFactory addressFactory;	/**	 * The HeaderFactory used to create SIP message headers.	 */	HeaderFactory headerFactory;	/**	 * The Message Factory used to create SIP messages.	 */	MessageFactory messageFactory;	/**	 * The MessageListener used to handle incoming messages	 */	MessageListener messageListener;	/**	 * the configuration	 */	private Configuration configuration;	VoicePlayer voicePlayer = null;	/**	 * 	 */	MessengerManager messengerManager;	VoiceMessagingTask voiceMessagingTask;	class VoiceMessagingTask implements Runnable {		Thread voiceMessagingThread = null;		String contactAddress = null;		protected static final String STARTED = "Started";		protected static final String STOPPED = "Stopped";		String state = STOPPED;		public VoiceMessagingTask(String contactAddress) {			this.contactAddress = contactAddress;		}		public synchronized void start() {			if (voiceMessagingThread == null) {				voiceMessagingThread = new Thread(this);			}			state = STARTED;			voiceMessagingThread.start();		}		public synchronized void stop() {			state = STOPPED;		}		public void run() {<<<<<<< MessageProcessor.java			while(state.equals(STARTED)){								try{				   byte[] buffer=VoiceRecorder.getInstance().getRecord();				   if(buffer!=null)					   messengerManager.sendVoiceMessage(					   		contactAddress,buffer);<<<<<<< MessageProcessor.java				   voiceMessagingThread.sleep(5000);=======				   voiceMessagingThread.sleep(Configuration.latency4VoiceMessaging);>>>>>>> 1.18=======			while (state.equals(STARTED)) {				try {					byte[] buffer = VoiceRecorder.getInstance().getRecord();					if (buffer != null)						messengerManager.sendVoiceMessage(							contactAddress,							buffer);					voiceMessagingThread.sleep(						Configuration.latency4VoiceMessaging);>>>>>>> 1.20				} catch (Exception ex) {					ex.printStackTrace();				}			}		}	}	/**	 * 	 */	protected void startVoiceMessagingSchedule(String callee) {		//schedule to send the voice messages every 2 sec.		VoiceRecorder.getInstance().initialize();		VoiceRecorder.getInstance().start();		voiceMessagingTask = new VoiceMessagingTask(callee);		voiceMessagingTask.start();	}	/**	 * 	 */	protected void stopVoiceMessagingSchedule() {		//Stop the voice messages schedule and the voiceRecorder						voiceMessagingTask.stop();		VoiceRecorder.getInstance().stop();		if (!VoiceRecorder.isClosed())			VoiceRecorder.getInstance().close();	}	/** Creates a new instance of MessageProcessor 	 * @param callListener - the sip Listener used to handle incoming messages	 */	public MessageProcessor(MessageListener messageListener) {		voicePlayer = new VoicePlayer();		this.messageListener = messageListener;		addressFactory = MessageListener.addressFactory;		sipFactory = MessageListener.sipFactory;		headerFactory = MessageListener.headerFactory;		messageFactory = MessageListener.messageFactory;		configuration = messageListener.getConfiguration();		messengerManager = messageListener.sipMeetingManager;	}	/**********************************************************************/	/*                                                                    */	/*                    Handling request messages                       */	/*                                                                    */	/**********************************************************************/	/**	 * Process the INVITE received request	 * @param serverTransaction - the server transaction associated with the request	 * @param invite - the request 	 */	public void processInvite(		ServerTransaction serverTransaction,		Request invite) {		//Strip out the callee		SipURI calleeURI =			(SipURI) ((FromHeader) invite.getHeader(FromHeader.NAME))				.getAddress()				.getURI();		String callee =			"sip:" + calleeURI.getUser() + "@" + calleeURI.getHost();		try {			CallManager callManager =				messageListener.sipMeetingManager.getCallManager();			/*//Getting the content type to know in which type of 			//session the user is invited to						ContentTypeHeader contentTypeHeader=				(ContentTypeHeader)invite.getHeader(ContentTypeHeader.NAME);			String subType = null;			if (contentTypeHeader != null) 				subType=contentTypeHeader.getContentSubType();			System.out.println("the other end invite us to "+subType);						//Accept automatically the instant messaging session			if(subType == null ){				IMCall call=new IMCall(callee); 				call.setDialog(serverTransaction.getDialog());				callManager.addIMCall(call);				System.out.println("IM Call created : "+					call.getDialog().getDialogId());				Response ok = (Response) MessageListener.messageFactory.createResponse(					Response.OK,invite);				//Put a tag on the To Header				((ToHeader)ok.getHeader(ToHeader.NAME)).setTag(					MessengerManager.generateTag());				//Specify the contact Header				SipURI contactURI=MessageListener.addressFactory.createSipURI(							messageListener.sipMeetingManager.getUserURI().getUser(),							configuration.contactIPAddress);				contactURI.setTransportParam(					configuration.signalingTransport);				ContactHeader contactHeader = 					MessageListener.headerFactory.createContactHeader(						MessageListener.addressFactory.createAddress(contactURI)); 				contactURI.setPort(					messageListener.sipProvider.getListeningPoint().getPort());                    				ok.addHeader(contactHeader);				//Content			  				  	ok.addHeader(contentTypeHeader);				//Send the ok				serverTransaction.sendResponse(ok);				// Voice messaging.				AudioCall audioCall=new AudioCall(messageListener);											audioCall.setCallee(callee);				audioCall.setDialog(serverTransaction.getDialog());				audioCall.setStatus(AudioCall.INCOMING_CALL);				System.out.println("Audio Call created : "+					audioCall.getDialog().getDialogId());				callManager.addAudioCall(audioCall);			                      				audioCall.setVoiceMesaging(true);			}			else{*/			//The audio device cannot be shared so if the user is already			//in a call, a busy here is sent back			if (callManager.isAlreadyInAudioCall()) {				Response busyHere =					(Response) MessageListener.messageFactory.createResponse(						Response.BUSY_HERE,						invite);				//If the user has put an URL for the BUSY we add i in the CALL-Info			  	if(messageListener.getConfiguration().httpBusy!=null){					CallInfoHeader callInfoHeader=						MessageListener.headerFactory.createCallInfoHeader(					  	MessageListener.addressFactory.createURI(					  	messageListener.getConfiguration().httpBusy));				  	busyHere.addHeader(callInfoHeader);							  }				System.out.println("send response : " + busyHere.toString());				serverTransaction.sendResponse(busyHere);			} else {				Response ringing =					(Response) MessageListener.messageFactory.createResponse(						Response.RINGING,						invite);				// System.out.println("send response : "+ringing.toString());				serverTransaction.sendResponse(ringing);				AudioCall audioCall = new AudioCall(messageListener);				audioCall.setCallee(callee);				audioCall.setDialog(serverTransaction.getDialog());				audioCall.setStatus(AudioCall.INCOMING_CALL);				System.out.println(					"Audio Call created : "						+ audioCall.getDialog().getDialogId());				callManager.addAudioCall(audioCall);				//Check if someone is inviting us to voice messaging				//or regular RTP media session				boolean voiceMessaging = false;				ContentTypeHeader contentTypeHeader =					(ContentTypeHeader) invite.getHeader(						ContentTypeHeader.NAME);				if (contentTypeHeader == null) {					ListIterator acceptHeaderList =						invite.getHeaders(AcceptHeader.NAME);					while (acceptHeaderList.hasNext() && !voiceMessaging) {						AcceptHeader acceptHeader =							(AcceptHeader) acceptHeaderList.next();						if (acceptHeader							.getContentSubType()							.equalsIgnoreCase("gsm")							|| acceptHeader.getContentSubType().equalsIgnoreCase(								"x-gsm"))							voiceMessaging = true;					}				}				audioCall.setVoiceMesaging(voiceMessaging);				// The SDP tool will be created when you send OK.				messageListener.sipMeetingManager.notifyObserversNewCallStatus(					audioCall);			}			//}            		} catch (SipException se) {			se.printStackTrace();		} catch (ParseException pe) {			pe.printStackTrace();		}	}	/**	 * Process the BYE received request	 * @param serverTransaction - the server transaction associated with the request	 * @param bye - the bye request 	 */	public void processBye(ServerTransaction serverTransaction, Request bye) {		CallManager callManager =			messageListener.sipMeetingManager.getCallManager();		//Find the matching call		Call call =			callManager.findCall(serverTransaction.getDialog().getDialogId());		//Send OK		try {			Response ok =				(Response) MessageListener.messageFactory.createResponse(					Response.OK,					bye);			serverTransaction.sendResponse(ok);			if (call instanceof AudioCall) {				AudioCall audioCall = (AudioCall) call;				audioCall.setStatus(AudioCall.NOT_IN_A_CALL);				messageListener.sipMeetingManager.notifyObserversNewCallStatus(					audioCall);				if (audioCall.getVoiceMessaging()) {					stopVoiceMessagingSchedule();				} else {					audioCall.getMediaManager().stopMediaSession();				}				//Remove the call				System.out.println(					"Audio Call removed : " + call.getDialog().getDialogId());				callManager.removeAudioCall(audioCall);			} else {				IMCall imCall = (IMCall) call;				//Remove the call				System.out.println(					"IM Call removed : " + call.getDialog().getDialogId());				callManager.removeIMCall(imCall);			}		} catch (SipException se) {			se.printStackTrace();		} catch (ParseException pe) {			pe.printStackTrace();