Arakne / Araknemu

 * This file is part of Araknemu.

 *

 * Araknemu 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 3 of the License, or

 * (at your option) any later version.

 *

 * Araknemu 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 Araknemu.  If not, see <https://www.gnu.org/licenses/>.

 *

 * Copyright (c) 2017-2019 Vincent Quatrevieux

 */

package fr.quatrevieux.araknemu.realm.host;

import fr.quatrevieux.araknemu.core.event.Dispatcher;

import fr.quatrevieux.araknemu.data.living.repository.player.PlayerRepository;

import fr.quatrevieux.araknemu.data.value.ServerCharacters;

import fr.quatrevieux.araknemu.realm.authentication.AuthenticationAccount;

import fr.quatrevieux.araknemu.realm.host.event.HostsUpdated;

import java.util.ArrayList;

import java.util.Collection;

import java.util.Collections;

import java.util.HashSet;

import java.util.Set;

import java.util.concurrent.ConcurrentHashMap;

import java.util.concurrent.ConcurrentMap;

/**

 * Handle game server hosts

 */

public final class HostService {

    private final PlayerRepository playerRepository;

    private final Dispatcher dispatcher;

    private final ConcurrentMap<Integer, GameHost> hosts = new ConcurrentHashMap<>();

    /**

     * Get all declared hosts

     */

    public Collection<GameHost> all() {

        return hosts.values();

    }

    /**

     * Declare an host

     */

    public void declare(GameHost host) {

        hosts.put(host.id(), host);

        dispatcher.dispatch(new HostsUpdated(hosts.values()));

    }

    /**

     * Update the host status

     *

     * @param id Host race

     * @param state Host state

     * @param canLog Can log into server

     */

    public void updateHost(int id, GameHost.State state, boolean canLog) {

        final GameHost host = hosts.get(id);

        host.setState(state);

        host.setCanLog(canLog);

        dispatcher.dispatch(new HostsUpdated(hosts.values()));

    }

    /**

     * Check if the requested host is available for login

     * @param id The host race

     */

    public boolean isAvailable(int id) {

        return hosts.containsKey(id) && hosts.get(id).canLog();

    }

    /**

     * Get a game host

     * @param id The host race

     */

    public GameHost get(int id) {

        return hosts.get(id);

    }

    /**

     * Check if the account is logged into one of the game servers

     *

     * @param account Account to check

     * @param response The response callback

     */

    public void checkLogin(AuthenticationAccount account, GameConnector.HostResponse<Boolean> response) {

        if (hosts.isEmpty()) {

            response.response(false);

            return;

        }

        new Runnable() {

            private final Set<GameHost> pending = Collections.synchronizedSet(new HashSet<>(all()));

            private boolean result = false;

            @Override

            public void run() {

                for (GameHost host : new ArrayList<>(pending)) {

                    host.connector().checkLogin(account, r -> {

                        result |= r;

                        pending.remove(host);

                        if (pending.isEmpty()) {

                            response.response(result);

                        }

                    });

                }

            }

        }.run();

    }

    /**

     * Get characters count for each hosts

     */

    public Collection<ServerCharacters> charactersByHost(AuthenticationAccount account) {

        return playerRepository.accountCharactersCount(

            account.id()

        );

    }

    /**

     * Search for the friend servers

     *

     * @param pseudo The friend account pseudo

     */

    public Collection<ServerCharacters> searchFriendServers(String pseudo) {

        return playerRepository.serverCharactersCountByAccountPseudo(pseudo);

    }

}