/* * 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.header.AcceptHeader;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() {			while(state.equals(STARTED)){								try{				   byte[] buffer=VoiceRecorder.getInstance().getRecord();				   if(buffer!=null)					   messengerManager.sendVoiceMessage(					   		contactAddress,buffer);				   voiceMessagingThread.sleep(5000);				} 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);					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);			}