wvp-gb28181-pro/src/main/java/com/genersoft/iot/vmp/gb28181/sdp/SdpParser.java

/*
    This file is part of Peers, a java SIP softphone.

    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, 2009, 2010 Yohann Martineau 
*/

package com.genersoft.iot.vmp.gb28181.sdp;

import java.io.BufferedReader;
import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.InetAddress;
import java.util.ArrayList;
import java.util.Hashtable;
import java.util.List;

public class SdpParser {

	public SessionDescription parse(byte[] body) throws IOException {
		if (body == null || body.length == 0) {
			return null;
		}
		ByteArrayInputStream in = new ByteArrayInputStream(body);
		InputStreamReader inputStreamReader = new InputStreamReader(in);
		BufferedReader reader = new BufferedReader(inputStreamReader);
		SessionDescription sessionDescription = new SessionDescription();
		
		//version
		
		String line = reader.readLine();
		if (line.length() < 3) {
			return null;
		}
		if (line.charAt(0) != RFC4566_28181.TYPE_VERSION
				|| line.charAt(1) != RFC4566_28181.SEPARATOR
				|| line.charAt(2) != RFC4566_28181.VERSION) {
			return null;
		}

		//origin
		
		line = reader.readLine();
		if (line.length() < 3) {
			return null;
		}
		if (line.charAt(0) != RFC4566_28181.TYPE_ORIGIN
				|| line.charAt(1) != RFC4566_28181.SEPARATOR) {
			return null;
		}
		line = line.substring(2);
		String[] originArr = line.split(" ");
		if (originArr == null || originArr.length != 6) {
			return null;
		}
		sessionDescription.setUsername(originArr[0]);
		sessionDescription.setId(Long.parseLong(originArr[1]));
		sessionDescription.setVersion(Long.parseLong(originArr[2]));
		sessionDescription.setIpAddress(InetAddress.getByName(originArr[5]));

		//name
		
		line = reader.readLine();
		if (line.length() < 3) {
			return null;
		}
		if (line.charAt(0) != RFC4566_28181.TYPE_SUBJECT
				|| line.charAt(1) != RFC4566_28181.SEPARATOR) {
			return null;
		}
		sessionDescription.setName(line.substring(2));
		
		//session connection and attributes
        Hashtable<String, String> sessionAttributes = new Hashtable<String, String>();
        sessionDescription.setAttributes(sessionAttributes);
		
		while ((line = reader.readLine()) != null
				&& line.charAt(0) != RFC4566_28181.TYPE_MEDIA) {
			if (line.length() > 3
					&& line.charAt(0) == RFC4566_28181.TYPE_CONNECTION
					&& line.charAt(1) == RFC4566_28181.SEPARATOR) {
				String connection = parseConnection(line.substring(2));
				if (connection == null) {
					continue;
				}
				sessionDescription.setIpAddress(InetAddress.getByName(connection));
			} else if (line.length() > 3
                    && line.charAt(0) == RFC4566_28181.TYPE_ATTRIBUTE
                    && line.charAt(1) == RFC4566_28181.SEPARATOR) {
                String value = line.substring(2);
                int pos = value.indexOf(RFC4566_28181.ATTR_SEPARATOR);
                if (pos > -1) {
                    sessionAttributes.put(value.substring(0, pos),
                            value.substring(pos + 1));
                } else {
                    sessionAttributes.put(value, "");
                }
            }
		}
		if (line == null) {
			return null;
		}
		//we are at the first media line
        
        ArrayList<SdpLine> mediaLines = new ArrayList<SdpLine>();
        do {
            if (line.length() < 2) {
                return null;
            }
            if (line.charAt(1) != RFC4566_28181.SEPARATOR) {
                return null;
            }
            if (line.charAt(0) == RFC4566_28181.TYPE_SSRC) {
                sessionDescription.setSsrc(line.length() >=2 ?line.substring(2):"");
            }else if (line.charAt(0) == RFC4566_28181.TYPE_MEDIA_DES) {
                sessionDescription.setGbMediaDescriptions(line.length() >=2 ?line.substring(2):"");
            }else {
                SdpLine mediaLine = new SdpLine();
                mediaLine.setType(line.charAt(0));
                mediaLine.setValue(line.substring(2));
                mediaLines.add(mediaLine);
            }

        }
        while ((line = reader.readLine()) != null );
        
        ArrayList<MediaDescription> mediaDescriptions = new ArrayList<MediaDescription>();
        sessionDescription.setMediaDescriptions(mediaDescriptions);
        
        for (SdpLine sdpLine : mediaLines) {
            MediaDescription mediaDescription;
            if (sdpLine.getType() == RFC4566_28181.TYPE_MEDIA) {
                String[] mediaArr = sdpLine.getValue().split(" ");
                if (mediaArr == null || mediaArr.length < 4) {
                    return null;
                }
                mediaDescription = new MediaDescription();
                mediaDescription.setType(mediaArr[0]);
                //TODO manage port range
                mediaDescription.setPort(Integer.parseInt(mediaArr[1]));
                mediaDescription.setAttributes(new Hashtable<String, String>());
                List<Codec> codecs = new ArrayList<Codec>();
                for (int i = 3; i < mediaArr.length; ++i) {
                    int payloadType = Integer.parseInt(mediaArr[i]);
                    Codec codec = new Codec();
                    codec.setPayloadType(payloadType);
                    codec.setName("unsupported");
                    codecs.add(codec);
                }
                mediaDescription.setCodecs(codecs);
                mediaDescriptions.add(mediaDescription);
            } else {
                mediaDescription = mediaDescriptions.get(mediaDescriptions.size() - 1);
                String sdpLineValue = sdpLine.getValue();
                if (sdpLine.getType() == RFC4566_28181.TYPE_CONNECTION) {
                    String ipAddress = parseConnection(sdpLineValue);
                    mediaDescription.setIpAddress(InetAddress.getByName(ipAddress));
                } else if (sdpLine.getType() == RFC4566_28181.TYPE_ATTRIBUTE) {
                    Hashtable<String, String> attributes = mediaDescription.getAttributes();
                    int pos = sdpLineValue.indexOf(RFC4566_28181.ATTR_SEPARATOR);
                    if (pos > -1) {
                        String name = sdpLineValue.substring(0, pos);
                        String value = sdpLineValue.substring(pos + 1);
                        pos = value.indexOf(" ");
                        if (pos > -1) {
                            int payloadType;
                            try {
                                payloadType = Integer.parseInt(value.substring(0, pos));
                                List<Codec> codecs = mediaDescription.getCodecs();
                                for (Codec codec: codecs) {
                                    if (codec.getPayloadType() == payloadType) {
                                        value = value.substring(pos + 1);
                                        pos = value.indexOf("/");
                                        if (pos > -1) {
                                            value = value.substring(0, pos);
                                            codec.setName(value);
                                        }
                                        break;
                                    }
                                }
                            } catch (NumberFormatException e) {
                                attributes.put(name, value);
                            }
                        } else {
                            attributes.put(name, value);
                        }
                    } else {
                        attributes.put(sdpLineValue, "");
                    }
                }
            }
        }
        sessionDescription.setMediaDescriptions(mediaDescriptions);

        for (MediaDescription description : mediaDescriptions) {
            if (description.getIpAddress() == null) {
                InetAddress sessionAddress = sessionDescription.getIpAddress();
                if (sessionAddress == null) {
                    return null;
                }
                description.setIpAddress(sessionAddress);
            }
        }


		return sessionDescription;
	}
	
	private String parseConnection(String line) {
		String[] connectionArr = line.split(" ");
		if (connectionArr == null || connectionArr.length != 3) {
			return null;
		}
		return connectionArr[2];
	}
	
}