/*
 * 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.game.chat.channel;

import fr.quatrevieux.araknemu.core.network.session.SessionFactory;
import fr.quatrevieux.araknemu.core.network.util.DummyChannel;
import fr.quatrevieux.araknemu.data.living.entity.account.Account;
import fr.quatrevieux.araknemu.data.living.entity.player.PlayerItem;
import fr.quatrevieux.araknemu.data.living.entity.player.PlayerSpell;
import fr.quatrevieux.araknemu.game.GameBaseCase;
import fr.quatrevieux.araknemu.game.account.AccountService;
import fr.quatrevieux.araknemu.game.account.GameAccount;
import fr.quatrevieux.araknemu.game.chat.ChannelType;
import fr.quatrevieux.araknemu.game.chat.ChatException;
import fr.quatrevieux.araknemu.game.chat.ChatService;
import fr.quatrevieux.araknemu.game.chat.event.BroadcastedMessage;
import fr.quatrevieux.araknemu.game.player.GamePlayer;
import fr.quatrevieux.araknemu.game.player.PlayerService;
import fr.quatrevieux.araknemu.network.game.GameSession;
import fr.quatrevieux.araknemu.network.game.in.chat.Message;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;

import java.util.HashSet;
import java.util.Set;

import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertFalse;
import static org.junit.jupiter.api.Assertions.assertTrue;
import static org.junit.jupiter.api.Assertions.fail;

/**
 *
 */
class GlobalChannelTest extends GameBaseCase {
    private PlayerService service;
    private Set<GamePlayer> receivers;

    private GamePlayer gp1, gp2, gp3, gp4, gp5;

    @BeforeEach
    @Override
    public void setUp() throws Exception {
        super.setUp();

        dataSet
            .pushRaces()
            .pushSpells()
            .use(PlayerSpell.class)
            .use(PlayerItem.class)
        ;

        receivers = new HashSet<>();

        service = container.get(PlayerService.class);

        GameSession session1 = (GameSession) container.get(SessionFactory.class).create(new DummyChannel());
        session1.attach(new GameAccount(new Account(1), container.get(AccountService.class), 2));
        gp1 = service.load(session1, session1.account(), dataSet.pushPlayer("Bob", 1, 2).id());
        gp1.dispatcher().add(BroadcastedMessage.class, e -> receivers.add(gp1));
        session1.setPlayer(gp1);

        GameSession session2 = (GameSession) container.get(SessionFactory.class).create(new DummyChannel());
        session2.attach(new GameAccount(new Account(2), container.get(AccountService.class), 2));
        gp2 = service.load(session2, session2.account(), dataSet.pushPlayer("Robert", 2, 2).id());
        gp2.dispatcher().add(BroadcastedMessage.class, e -> receivers.add(gp2));
        session2.setPlayer(gp2);

        GameSession session3 = (GameSession) container.get(SessionFactory.class).create(new DummyChannel());
        session3.attach(new GameAccount(new Account(3), container.get(AccountService.class), 2));
        gp3 = service.load(session3, session3.account(), dataSet.pushPlayer("Jean", 3, 2).id());
        gp3.dispatcher().add(BroadcastedMessage.class, e -> receivers.add(gp3));
        session3.setPlayer(gp3);

        GameSession session4 = (GameSession) container.get(SessionFactory.class).create(new DummyChannel());
        session4.attach(new GameAccount(new Account(4), container.get(AccountService.class), 2));
        gp4 = service.load(session4, session4.account(), dataSet.pushPlayer("Kevin", 4, 2).id());
        gp4.dispatcher().add(BroadcastedMessage.class, e -> receivers.add(gp4));
        session4.setPlayer(gp4);

        GameSession session5 = (GameSession) container.get(SessionFactory.class).create(new DummyChannel());
        session5.attach(new GameAccount(new Account(5), container.get(AccountService.class), 2));
        gp5 = service.load(session5, session5.account(), dataSet.pushPlayer("Louis", 5, 2).id());
        gp5.dispatcher().add(BroadcastedMessage.class, e -> receivers.add(gp5));
        session5.setPlayer(gp5);
    }

    @Test
    void sendToAll() throws ChatException {
        GlobalChannel channel = new GlobalChannel(ChannelType.TRADE, service);

        channel.send(
            gp1,
            new Message(
                ChannelType.TRADE,
                null,
                "My message",
                ""
            )
        );

        assertCount(5, receivers);
        assertContains(gp1, receivers);
        assertContains(gp2, receivers);
        assertContains(gp3, receivers);
        assertContains(gp4, receivers);
        assertContains(gp5, receivers);
    }

    @Test
    void authorized() {
        GlobalChannel channel = new GlobalChannel(ChannelType.TRADE, player -> false, service);
        assertFalse(channel.authorized(gp1));

        channel = new GlobalChannel(ChannelType.TRADE, player -> true, service);
        assertTrue(channel.authorized(gp1));
    }

    @Test
    void notAuthorized() {
        GlobalChannel channel = new GlobalChannel(ChannelType.TRADE, player -> false, service);
        ChatService service = new ChatService(configuration.chat(), new Channel[] {channel});

        try {
            service.send(
                gp1,
                new Message(
                    ChannelType.TRADE,
                    null,
                    "My message",
                    ""
                )
            );

            fail("Exception must be thrown");
        } catch (ChatException e) {
            assertEquals(ChatException.Error.UNAUTHORIZED, e.error());
        }
    }

    @Test
    void filter() throws ChatException {
        GlobalChannel channel = new GlobalChannel(ChannelType.TRADE, player -> player.name().contains("o"), service);

        channel.send(
            gp1,
            new Message(
                ChannelType.TRADE,
                null,
                "My message",
                ""
            )
        );

        assertCount(3, receivers);

        assertContains(gp1, receivers);
        assertContains(gp2, receivers);
        assertContains(gp5, receivers);
    }
}