package org.red5.confDemo;

import java.util.HashMap;
import java.util.Iterator;
import java.util.Set;

import org.red5.server.adapter.*;
import org.red5.server.api.*;
import org.red5.server.api.service.*;

public class Application extends ApplicationAdapter implements
		IPendingServiceCallback {

	protected HashMap<String, User> users = new HashMap<String, User>();

	@Override
	public boolean appStart(IScope scope) {
		return true;
	}

	@Override
	public boolean appConnect(IConnection conn, Object[] params) {
		// quem não envia nome, não ganha conexão
		if (params.length != 1) {
			rejectClient("Sem permissão de acesso ao sistema!");
			return false;
		}
		String username = params[0].toString();
		String uid = conn.getClient().getId();
		IServiceCapableConnection service = (IServiceCapableConnection) conn;

		User user = new User(uid, username);
		users.put(uid, user);

		service.invoke("listaUsuarios", new Object[] { listaUsuarios() }, this);
		enviarNovosUsuarios();

		System.out.println("Novo usuario: " + uid);
		return true;
	}

	@Override
	public boolean appJoin(IClient client, IScope scope) {

		super.appJoin(client, scope);

		// envia a lista de usuários conectados a todos os conectados
		enviarNovosUsuarios();

		return true;
	}

	@Override
	public synchronized void disconnect(IConnection conn, IScope scope) {
		// ID da conexão do usuário
		String uid = conn.getClient().getId();
		// O usuário que desconectou
		users.remove(uid);
		enviarNovosUsuarios();

		System.out.println("Desconectado: " + uid);
		super.disconnect(conn, scope);
	}

	@Override
	public void resultReceived(IPendingServiceCall call) {
		System.out.println(call);
	}

	/**
	 * Envia a lista de usuários conectados a todos os usuarios
	 */
	protected void enviarNovosUsuarios() {
		Object[] params = new Object[] { listaUsuarios() };
		ServiceUtils.invokeOnAllConnections(scope, "listaUsuarios", params);
	}

	/**
	 * Retorna a lista de usuários sem os campos nulos
	 */
	protected HashMap<Integer, User> listaUsuarios() {
		HashMap<Integer, User> params = new HashMap<Integer, User>();
		Integer key = 0;
		Set<String> s = users.keySet();
		for (Iterator<String> it = s.iterator(); it.hasNext();) {
			User value = users.get(it.next());
			if (value != null) {
				params.put(key, value);
				key++;
			}
		}
		return params;
	}
}