terminatinginvite.java

sipapi 说明文档.用于JAVA的SIP开发及应用.

/*
 * ============================================================================
 *  Copyright (c) 2007 Nokia.
 *  This material, including documentation and any related computer programs,
 *  is protected by copyright controlled by Nokia. All rights are reserved.
 *  Copying, including reproducing, storing, adapting or translating,
 *  any or all of this material requires the prior written consent of Nokia.
 *  This material also contains confidential information, which may not be
 *  disclosed to others without the prior written consent of Nokia.
 * ============================================================================
 */

package examples;

import java.io.*;
import javax.microedition.io.*;
import javax.microedition.midlet.*;
import javax.microedition.lcdui.*;
import javax.microedition.sip.*;

public class TerminatingINVITE extends MIDlet implements CommandListener,
        SipServerConnectionListener {

    private Display display;
    private Form form;
    private TextField receivePort;
    private Command startCmd;
    private Command restartCmd;
    private Command byeCmd;
    private Command answerCmd;
    private Command exitCmd;
    private SipDialog dialog;
    private StringItem str;
    private SipServerConnection ssc = null; // latest request
    private SipServerConnection origSSC = null; // original request
    private final short S_OFFLINE = 0;
    private final short S_CALLING = 1;
    private final short S_RINGING = 2;
    private final short S_ONLINE = 3;
    private short state = S_OFFLINE;

    // using static SDP as an example
    private String sdp = "v=0\no=sippy 2890844730 2890844732 IN IP4 " +
                         "host.example.com\ns=example code\nc=IN IP4" +
                         " host.example.com\nt=0 0\nm=message 54344 " +
                         "SIP/TCP\na=user:sippy";

    SipConnectionNotifier scn = null;

    public TerminatingINVITE() {
        // Initialize MIDlet display
        display = Display.getDisplay(this);
        form = new Form("Session example");
        receivePort = new TextField("SipConnectionNotifier on port:",
                "sip:5070", 30, TextField.LAYOUT_LEFT);
        form.append(receivePort);
        answerCmd = new Command("Answer", Command.OK, 1);
        byeCmd = new Command("Hang-up", Command.CANCEL, 1);
        restartCmd = new Command("Restart", Command.OK, 1);
        startCmd = new Command("Online", Command.OK, 1);
        form.addCommand(startCmd);
        exitCmd = new Command("Exit", Command.EXIT, 2);
        form.addCommand(exitCmd);
        form.setCommandListener(this);

    }

    public void commandAction(Command c, Displayable d) {
        if (c == startCmd) {
            form.deleteAll();
            form.removeCommand(startCmd);

            Thread t = new Thread() {
                public void run() {
                    startListener();
                }
            };
            t.start();

            return;
        } else if (c == exitCmd) {
            if (scn != null) {
                try {
                    scn.close();
                } catch (IOException iox) {
                }
            }
            destroyApp(true);
            return;
        } else if (c == byeCmd) {
            if (state == S_RINGING) {
                try {
                    ssc.initResponse(486); // Busy here
                    ssc.send();
                    str = new StringItem("Session closed: ", "Busy here!");
                    form.append(str);
                } catch (Exception ex) {
                    ex.printStackTrace();
                }
            } else {
                sendBYE();
            }
            form.removeCommand(byeCmd);
            form.removeCommand(answerCmd);
            form.addCommand(restartCmd);
            state = S_OFFLINE;
        } else if (c == answerCmd) {
            form.removeCommand(answerCmd);
            form.addCommand(byeCmd);
            try {
                ssc.initResponse(200);
                ssc.setHeader("Content-Length", "" + sdp.length());
                ssc.setHeader("Content-Type", "application/sdp");
                OutputStream os = ssc.openContentOutputStream();
                os.write(sdp.getBytes());
                os.close(); // close and send
                // save Dialog
                dialog = ssc.getDialog();
                form.append("Dialog state: " + dialog.getState() + "\n");

                // Wait for otherside to ACK
                form.append("Waiting for ACK...");
                ssc.close();
            } catch (Exception ex) {
                ex.printStackTrace();
            }
        } else if (c == restartCmd) {
            if (scn != null) {
                try {
                    scn.close();
                } catch (Exception ex) {
                }
            }
            form.removeCommand(restartCmd);
            form.addCommand(startCmd);
            form.deleteAll();
            form.append(receivePort);
            return;
        }
    }

    public void startApp() {
        display.setCurrent(form);
    }

    private void startListener() {

        try {
            if (scn != null)
                scn.close();
            // start a listener for incoming request
            scn = (SipConnectionNotifier) Connector.open(receivePort
                    .getString());
            scn.setListener(this);
            form.append("Listening on port: " + scn.getLocalPort());
        } catch (Exception ex) {
            ex.printStackTrace();
            // handle IOException
        }
    }

    /**
     * Handle incoming Requests
     */
    public void notifyRequest(SipConnectionNotifier scn) {
        try {
            ssc = scn.acceptAndOpen(); // blocking
            if (ssc.getMethod().equals("INVITE")) {
                origSSC = ssc;
                state = S_CALLING;
                // handle content
                String contentType = ssc.getHeader("Content-Type");
                String contentLength = ssc.getHeader("Content-Length");
                int length = Integer.parseInt(contentLength);
                if (contentType.equals("application/sdp")) {
                    InputStream is = ssc.openContentInputStream();
                    byte content[] = new byte[length];
                    is.read(content);
                    String sc = new String(content);
                    // parse m= line from SDP, as an example
                    int m = sc.indexOf("m=");
                    String media = sc.substring(m, sc.indexOf('\n', m));
                    str = new StringItem("media is: ", media);
                    form.append(str);
                    //
                    // handle media here
                    //

                    // initialize and send 180 response
                    ssc.initResponse(180);
                    ssc.send();
                    // save Dialog
                    dialog = ssc.getDialog();
                    form.append("Dialog state: " + dialog.getState() + "\n");
                    form.addCommand(answerCmd);
                    form.addCommand(byeCmd);
                    // inform user about the session here...
                    form.append("RINGING!!!\n");
                    state = S_RINGING;
                    return;
                }
            } else if (ssc.getMethod().equals("ACK")) {
                str = new StringItem("Session established: ", ssc
                        .getHeader("Call-ID"));
                state = S_ONLINE;
                form.append(str);
                form.append("Dialog state: " + dialog.getState() + "\n");
                // Wait for otherside to send BYE
                form.append("Waiting for BYE...");
                ssc.close();
            } else if (ssc.getMethod().equals("BYE")) {
                ssc.initResponse(200);
                ssc.send();
                state = S_OFFLINE;
                str = new StringItem("Session closed: ", ssc
                        .getHeader("Call-ID"));
                form.append(str);
                form.append("Dialog state: " + dialog.getState());
                ssc.close();
                form.removeCommand(byeCmd);
                form.removeCommand(answerCmd);
                form.addCommand(restartCmd);
            } else if (ssc.getMethod().equals("CANCEL")) {
                ssc.initResponse(200);
                ssc.send();
                origSSC.initResponse(487);
                origSSC.send();
                state = S_OFFLINE;
                str = new StringItem("Session canceled: ", ssc
                        .getHeader("Call-ID"));
                form.append(str);
                ssc.close();
                form.removeCommand(byeCmd);
                form.removeCommand(answerCmd);
                form.addCommand(restartCmd);
            }
        } catch (Exception ex) {
            ex.printStackTrace();
            // handle IOException
        }
    }

    private void sendBYE() {
        if (dialog != null) {
            try {
                SipClientConnection sc = dialog.getNewClientConnection("BYE");
                sc.send();
                str = new StringItem("user hang-up: ", "BYE sent...");
                form.append(str);
                boolean gotit = sc.receive(10000);
                if (gotit) {
                    if (sc.getStatusCode() == 200) {
                        form.append("Session closed successfully...");
                        state = S_OFFLINE;
                    } else
                        form.append("Error: " + sc.getReasonPhrase());
                }
                form.append("Dialog state: " + dialog.getState());
                sc.close();
            } catch (IOException iox) {
                form.append("Exception: " + iox.getMessage());
            }
        } else {
            form.append("No dialog information!");
        }
    }

    public void pauseApp() {
        // pause
    }

    public void destroyApp(boolean b) {
        notifyDestroyed();
    }

}