/**

 * Java RTP Library (jlibrtp)

 * Copyright (C) 2006 Arne Kepp

 * 

 * This library is free software; you can redistribute it and/or

 * modify it under the terms of the GNU Lesser General Public

 * License as published by the Free Software Foundation; either

 * version 2.1 of the License, or (at your option) any later version.

 *

 * This library 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

 * Lesser General Public License for more details.

 * 

 * You should have received a copy of the GNU Lesser General Public

 * License along with this library; if not, write to the Free Software

 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301  USA

 */

package jlibrtp;

import java.net.InetSocketAddress;

/**

 * RTCP packets for Source Descriptions

 * 

 * @author Arne Kepp

 */

public class RtcpPktSDES extends RtcpPkt {

	/** Whether the RTP Session object should be inclduded */

	boolean reportSelf = true;

	/** The parent RTP Session object, holds participant database */

	RTPSession rtpSession = null;

	/** The participants to create SDES packets for */

	protected Participant[] participants = null;

	/**

	 * Constructor to create a new SDES packet

	 * 

	 * TODO: Currently the added participants are not actually encoded because

	 * the library lacks some support for acting as mixer or relay in other

	 * areas.

	 * 

	 * @param reportThisSession

	 *            include information from RTPSession as a participant

	 * @param rtpSession

	 *            the session itself

	 * @param additionalParticipants

	 *            additional participants to include

	 */

	protected RtcpPktSDES(boolean reportThisSession, RTPSession rtpSession,

			Participant[] additionalParticipants) {

		super.packetType = 202;

		// Fetch all the right stuff from the database

		reportSelf = reportThisSession;

		participants = additionalParticipants;

		this.rtpSession = rtpSession;

	}

	/**

	 * Constructor that parses a received packet

	 * 

	 * @param aRawPkt

	 *            the byte[] containing the packet

	 * @param start

	 *            where in the byte[] this packet starts

	 * @param socket

	 *            the address from which the packet was received

	 * @param partDb

	 *            the participant database

	 */

	protected RtcpPktSDES(byte[] aRawPkt, int start, InetSocketAddress socket,

			ParticipantDatabase partDb) {

		if (RTPSession.rtcpDebugLevel > 8) {

			System.out.println("  -> RtcpPktSDES(byte[], ParticipantDabase)");

		}

		rawPkt = aRawPkt;

		if (!super.parseHeaders(start) || packetType != 202) {

			if (RTPSession.rtpDebugLevel > 2) {

				System.out

						.println(" <-> RtcpPktSDES.parseHeaders() etc. problem");

			}

			super.problem = -202;

		} else {

			// System.out.println(" DECODE SIZE: " + super.length +

			// " itemcount " + itemCount );

			int curPos = 4 + start;

			int curLength;

			int curType;

			long ssrc;

			boolean endReached = false;

			boolean newPart;

			this.participants = new Participant[itemCount];

			// Loop over SSRC SDES chunks

			for (int i = 0; i < itemCount; i++) {

				ssrc = StaticProcs.bytesToUIntLong(aRawPkt, curPos);

				Participant part = partDb.getParticipant(ssrc);

				if (part == null) {

					if (RTPSession.rtcpDebugLevel > 1) {

						System.out

								.println("RtcpPktSDES(byte[], ParticipantDabase) adding new participant, ssrc:"

										+ ssrc + " " + socket);

					}

					part = new Participant(socket, socket, ssrc);

					newPart = true;

				} else {

					newPart = false;

				}

				curPos += 4;

				// System.out.println("PRE endReached " + endReached +

				// " curPos: " + curPos + " length:" + this.length +

				// (!endReached && (curPos/4) < this.length));

				while (!endReached && (curPos / 4) <= this.length) {

					// System.out.println("endReached " + endReached +

					// " curPos: " + curPos + " length:" + this.length);

					curType = (int) aRawPkt[curPos];

					if (curType == 0) {

						curPos += 4 - (curPos % 4);

						endReached = true;

					} else {

						curLength = (int) aRawPkt[curPos + 1];

						// System.out.println("curPos:"+curPos+" curType:"+curType+" curLength:"+curLength+" read from:"+(curPos

						// + 1));

						if (curLength > 0) {

							byte[] item = new byte[curLength];

							// System.out.println("curPos:"+curPos+" arawPkt.length:"+aRawPkt.length+" curLength:"+curLength);

							System.arraycopy(aRawPkt, curPos + 2, item, 0,

									curLength);

							switch (curType) {

							case 1:

								part.cname = new String(item);

								break;

							case 2:

								part.name = new String(item);

								break;

							case 3:

								part.email = new String(item);

								break;

							case 4:

								part.phone = new String(item);

								break;

							case 5:

								part.loc = new String(item);

								break;

							case 6:

								part.tool = new String(item);

								break;

							case 7:

								part.note = new String(item);

								break;

							case 8:

								part.priv = new String(item);

								break;

							}

							// System.out.println("TYPE " + curType + " value:"

							// + new String(item) );

						} else {

							switch (curType) {

							case 1:

								part.cname = null;

								break;

							case 2:

								part.name = null;

								break;

							case 3:

								part.email = null;

								break;

							case 4:

								part.phone = null;

								break;

							case 5:

								part.loc = null;

								break;

							case 6:

								part.tool = null;

								break;

							case 7:

								part.note = null;

								break;

							case 8:

								part.priv = null;

								break;

							}

						}

						curPos = curPos + curLength + 2;

					}

				}

				// Save the participant

				this.participants[i] = part;

				if (newPart)

					partDb.addParticipant(2, part);

				// System.out.println("HEPPPPPP " + participants[i].cname );

			}

		}

		if (RTPSession.rtcpDebugLevel > 8) {

			System.out.println("  <- RtcpPktSDES()");

		}

	}

	/**

	 * Encode the packet into a byte[], saved in .rawPkt

	 * 

	 * CompRtcpPkt will call this automatically

	 */

	protected void encode() {

		byte[] temp = new byte[1450];

		byte[] someBytes = StaticProcs.uIntLongToByteWord(this.rtpSession.ssrc);

		System.arraycopy(someBytes, 0, temp, 4, 4);

		int pos = 8;

		String tmpString = null;

		for (int i = 1; i < 9; i++) {

			switch (i) {

			case 1:

				tmpString = this.rtpSession.cname;

				break;

			case 2:

				tmpString = this.rtpSession.name;

				break;

			case 3:

				tmpString = this.rtpSession.email;

				break;

			case 4:

				tmpString = this.rtpSession.phone;

				break;

			case 5:

				tmpString = this.rtpSession.loc;

				break;

			case 6:

				tmpString = this.rtpSession.tool;

				break;

			case 7:

				tmpString = this.rtpSession.note;

				break;

			case 8:

				tmpString = this.rtpSession.priv;

				break;

			}

			if (tmpString != null) {

				someBytes = tmpString.getBytes();

				temp[pos] = (byte) i;

				temp[pos + 1] = (byte) someBytes.length;

				System.arraycopy(someBytes, 0, temp, pos + 2, someBytes.length);

				// System.out.println("i: "+i+" pos:"+pos+" someBytes.length:"+someBytes.length);

				pos = pos + someBytes.length + 2;

				// if(i == 1 ) {

				// System.out.println("trueeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeee" +

				// tmpString);

				// }

			}

		}

		int leftover = pos % 4;

		if (leftover == 1) {

			temp[pos] = (byte) 0;

			temp[pos + 1] = (byte) 1;

			pos += 3;

		} else if (leftover == 2) {

			temp[pos] = (byte) 0;

			temp[pos + 1] = (byte) 0;

			pos += 2;

		} else if (leftover == 3) {

			temp[pos] = (byte) 0;

			temp[pos + 1] = (byte) 3;

			pos += 5;

		}

		// TODO Here we ought to loop over participants, if we're doing SDES for

		// other participants.

		super.rawPkt = new byte[pos];

		itemCount = 1;

		// This looks wrong, but appears to be fine..

		System.arraycopy(temp, 0, super.rawPkt, 0, pos);

		writeHeaders();

	}

	/**

	 * Debug purposes only

	 */

	public void debugPrint() {

		System.out.println("RtcpPktSDES.debugPrint() ");

		if (participants != null) {

			for (int i = 0; i < participants.length; i++) {

				Participant part = participants[i];

				System.out.println("     part.ssrc: " + part.ssrc

						+ "  part.cname: " + part.cname + " part.loc: "

						+ part.loc);

			}

		} else {

			System.out

					.println("     nothing to report (only valid for received packets)");

		}

	}

}