package com.beem.project.beem.jingle;

import java.net.UnknownHostException;

import java.util.ArrayList;

import java.util.List;

import org.jivesoftware.smack.ConnectionConfiguration;

import org.jivesoftware.smack.XMPPConnection;

import org.jivesoftware.smack.XMPPException;

import org.jivesoftware.smackx.jingle.JingleManager;

import org.jivesoftware.smackx.jingle.JingleSession;

import org.jivesoftware.smackx.jingle.listeners.JingleSessionListener;

import org.jivesoftware.smackx.jingle.media.JingleMediaManager;

import org.jivesoftware.smackx.jingle.media.PayloadType;

import org.jivesoftware.smackx.jingle.nat.BasicTransportManager;

import org.jivesoftware.smackx.jingle.nat.TransportCandidate;

/**

 * @author darisk

 * 

 */

public class Caller {

	private XMPPConnection con;

	private String login;

	private String password;

	private JingleManager jingleManager;

	private List<JingleMediaManager> mediaManagers;

	private JingleSession out;

	public Caller(final String login, final String pass, String server) {

		if (server == null || server.equals(""))

			server = "localhost";

		//XMPPConnection.DEBUG_ENABLED = true;

		this.login = login;

		this.password = pass;

		ConnectionConfiguration conf = new ConnectionConfiguration(server);

		conf.setRosterLoadedAtLogin(false);

		con = new XMPPConnection(conf);

		try {

			con.connect();

			con.login(this.login, this.password, "Caller");

			initialize();

		} catch (XMPPException e) {

			// TODO Auto-generated catch block

			System.err.println("Echec de la connexion au serveru");

			e.printStackTrace();

		}

	}

	public void call(final String destinataire) {

		try {

			out = jingleManager.createOutgoingJingleSession(destinataire);

			// TODO configure out avec addMediaSession et addNegociator

			out.addListener(new JingleSessionListener() {

				@Override

				public void sessionRedirected(final String redirection,

						final JingleSession jingleSession) {

					// TODO Auto-generated method stub

				}

				@Override

				public void sessionMediaReceived(

						final JingleSession jingleSession,

						final String participant) {

					// TODO Auto-generated method stub

					System.out.println("Session Media received from "

							+ participant);

				}

				@Override

				public void sessionEstablished(final PayloadType pt,

						final TransportCandidate remoteCandidate,

						final TransportCandidate localCandidate,

						final JingleSession jingleSession) {

					System.out.println("Session established");

					String ip = localCandidate.getIp();

					int port = localCandidate.getPort();

					System.out

							.println("Session established waiting connection on "

									+ ip + ":" + port);

					try {

						try {

							FileSender fs = new FileSender(ip, port,

									"/tmp/img.jpeg");

							fs.start();

							fs.join();

							System.out.println("End of transfer");

						} finally {

							jingleSession.terminate();

						}

					} catch (UnknownHostException e) {

						System.err.println("Can't create server");

					} catch (InterruptedException e) {

					} catch (XMPPException e) {

						System.err.println("Probably lost the connection");

						e.printStackTrace();

					}

				}

				@Override

				public void sessionDeclined(final String reason,

						final JingleSession jingleSession) {

					System.out.println("Session "

							+ jingleSession.getResponder()

							+ "declined because " + reason);

				}

				@Override

				public void sessionClosedOnError(final XMPPException e,

						final JingleSession jingleSession) {

					System.out

							.println("Session " + jingleSession.getResponder()

									+ " closed on error");

				}

				@Override

				public void sessionClosed(final String reason,

						final JingleSession jingleSession) {

					System.out.println("Session "

							+ jingleSession.getResponder() + "closed because "

							+ reason);

				}

			});

			out.startOutgoing();

		} catch (XMPPException e) {

			// TODO Auto-generated catch block

			e.printStackTrace();

		}

	}

	private void initialize() {

		mediaManagers = new ArrayList<JingleMediaManager>();

		mediaManagers.add(new SenderMediaManager(new BasicTransportManager()));

		JingleManager.setJingleServiceEnabled();

		jingleManager = new JingleManager(con, mediaManagers);

	}

	/**

	 * @param args

	 *            Program args

	 * @throws InterruptedException

	 *             exception

	 */

	public static void main(final String[] args) throws InterruptedException {

		if (args.length < 3) {

			System.err.println("Not enough parameters");

			System.err.println("Usage : Caller user password server jidtocall");

		}

		Caller test = new Caller(args[0], args[1], args[2]);

		test.call("test2@nikita-rack/TEST");

		Thread.sleep(60000);

	}

}