package moe.ymc.acron.s2c;

import io.netty.channel.Channel;
import io.netty.channel.group.ChannelGroup;
import io.netty.channel.group.DefaultChannelGroup;
import io.netty.util.concurrent.GlobalEventExecutor;
import moe.ymc.acron.serialization.Serializer;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.jetbrains.annotations.NotNull;

public class EventQueue {
    private static final Logger LOGGER = LogManager.getLogger();

    private static final ChannelGroup sMessageRecipients =
            new DefaultChannelGroup(GlobalEventExecutor.INSTANCE);

    public static void registerMessageRecipient(@NotNull Channel channel) {
        sMessageRecipients.add(channel);
    }

    public static void enqueue(@NotNull Event message) {
        LOGGER.debug("Enqueue: {} ({} channels)",
                message,
                sMessageRecipients.size());
        sMessageRecipients.writeAndFlush(Serializer.serialize(message));
    }
}