/*
    This file is part of Peers.

    This program is free software: you can redistribute it and/or modify
    it under the terms of the GNU General Public License as published by
    the Free Software Foundation, either version 3 of the License, or
    any later version.

    This program is distributed in the hope that it will be useful,
    but WITHOUT ANY WARRANTY; without even the implied warranty of
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
    GNU General Public License for more details.

    You should have received a copy of the GNU General Public License
    along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    Copyright 2007, 2008 Yohann Martineau 
*/

package net.sourceforge.peers.sdp;

import gov.nist.jrtp.RtpException;

import java.io.IOException;

import net.sourceforge.peers.media.CaptureRtpSender;
import net.sourceforge.peers.media.IncomingRtpReader;
import net.sourceforge.peers.sip.Utils;
import net.sourceforge.peers.sip.core.useragent.UserAgent;

//TODO ekiga -d 4 > ekiga-debug.txt 2>&1
public class SDPManager {

    public static String SUCCESS_MODEL =
        "v=0\r\n" +
        "o=user1 53655765 2353687637 IN IP4 "
            + Utils.getInstance().getMyAddress().getHostAddress() + "\r\n" +
        "s=-\r\n" +
        "c=IN IP4 " + Utils.getInstance().getMyAddress().getHostAddress() + "\r\n" +
        "t=0 0\r\n" +
        "m=audio " + Utils.getInstance().getRtpPort() + " RTP/AVP 0\r\n" +
        "a=rtpmap:0 PCMU/8000\r\n";

    public static String FAILURE_MODEL =
        "v=0\r\n" +
        "o=user1 53655765 2353687637 IN IP4 "
            + Utils.getInstance().getMyAddress().getHostAddress() + "\r\n" +
        "s=-\r\n" +
        "c=IN IP4 " + Utils.getInstance().getMyAddress().getHostAddress() + "\r\n" +
        "t=0 0\r\n" +
        "a=inactive\r\n" +
        "m=audio " + Utils.getInstance().getRtpPort() + " RTP/AVP 0\r\n" +
        "a=rtpmap:0 PCMU/8000\r\n";
    
    private SdpParser sdpParser;
    
    public SDPManager() {
        sdpParser = new SdpParser();
    }
    
    public SessionDescription handleAnswer(byte[] answer) {
        try {
            return sdpParser.parse(answer);
        } catch (IOException e) {
            e.printStackTrace();
        }
        return null;
    }
    
    public String handleOffer(byte[] offer) throws NoCodecException {
        // TODO generate dynamic content
        SessionDescription sessionDescription;
        try {
            sessionDescription = sdpParser.parse(offer);
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
            return null;
        }
        String destAddress = sessionDescription.getIpAddress().getHostAddress();
        int destPort = sessionDescription.getMedias().get(0).getPort();
        
        //FIXME move this to InviteHandler
        //TODO this could be optimized, create captureRtpSender at stack init
        //     and just retrieve it here
        CaptureRtpSender captureRtpSender;
        try {
            captureRtpSender = new CaptureRtpSender(
                    Utils.getInstance().getMyAddress().getHostAddress(),
                    Utils.getInstance().getRtpPort(),
                    destAddress, destPort);
        } catch (IOException e) {
            e.printStackTrace();
            return null;
        }
        UserAgent.getInstance().setCaptureRtpSender(captureRtpSender);

        try {
            captureRtpSender.start();
        } catch (IOException e) {
            e.printStackTrace();
        }
        
        IncomingRtpReader incomingRtpReader;
        try {
            //TODO retrieve port from SDP offer
//                incomingRtpReader = new IncomingRtpReader(localAddress,
//                        Utils.getInstance().getRtpPort(),
//                        remoteAddress, remotePort);
            //FIXME RTP sessions can be different !
            incomingRtpReader = new IncomingRtpReader(captureRtpSender.getRtpSession());
        } catch (IOException e1) {
            e1.printStackTrace();
            return null;
        }
        UserAgent.getInstance().setIncomingRtpReader(incomingRtpReader);

        try {
            incomingRtpReader.start();
        } catch (IOException e1) {
            e1.printStackTrace();
        } catch (RtpException e1) {
            e1.printStackTrace();
        }
        
        return SUCCESS_MODEL;
    }
    
    public String generateErrorResponse() {
        // TODO generate dynamic content
        return FAILURE_MODEL;
    }
    
    public String generateOffer() {
        return SUCCESS_MODEL;
    }
}