package cn.org.hentai.jtt1078.app;

import cn.org.hentai.jtt1078.server.audio.Jt1078AudioEncoder;
import cn.org.hentai.jtt1078.server.talk.Jt1078TalkHandler;
import cn.org.hentai.jtt1078.server.talk.Jt1078TalkMessageDecoder;
import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.Channel;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelPipeline;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import javax.annotation.PreDestroy;

@Slf4j
@Component
public class TalkServer {


    @Value("${jt1078.talk.port}")
    private int port;

    private EventLoopGroup bossGroup;
    private EventLoopGroup workerGroup;


    public void start() throws Exception {
        bossGroup = new NioEventLoopGroup();
        workerGroup = new NioEventLoopGroup();

        ServerBootstrap bootstrap = new ServerBootstrap();
        bootstrap.group(bossGroup, workerGroup)
                 .channel(NioServerSocketChannel.class)
                 .childHandler(new ChannelInitializer<SocketChannel>() {
                     @Override
                     protected void initChannel(SocketChannel ch) {
                         ChannelPipeline p = ch.pipeline();
                         p.addLast(new Jt1078TalkMessageDecoder());//解码器
                         p.addLast(new Jt1078AudioEncoder());//音频编码器
                         p.addLast(new Jt1078TalkHandler());//语音对讲处理器
                     }
                 });

        Channel ch = bootstrap.bind(port).sync().channel();
        log.info("🎤 Talk Server started on port {}", port);
    }

    @PreDestroy
    public void shutdown() {
        bossGroup.shutdownGracefully();
        workerGroup.shutdownGracefully();
    }
}