using System;
using System.Threading.Tasks;
using Microsoft.Extensions.Hosting;
using Microsoft.Extensions.Logging;
using Microsoft.Extensions.Options;
using SuperSocket;
using SuperSocket.Channel;
using SuperSocket.ProtoBase;
using SuperSocket.Server;

namespace IStation.Server
{
    internal class MyServer : SuperSocketService<PackageInfo>
    {

        public MyServer(IServiceProvider serviceProvider, IOptions<ServerOptions> serverOptions)
          : base(serviceProvider, serverOptions)
        {
        }

        protected override async ValueTask OnSessionConnectedAsync(IAppSession session)
        {
            await base.OnSessionConnectedAsync(session);
        }

        protected override async ValueTask OnSessionClosedAsync(IAppSession session, CloseEventArgs e)
        {
            await base.OnSessionClosedAsync(session, e);
        }

        protected override ValueTask OnStartedAsync()
        {
            LogHelper.Info($"苏州金庭肯特流量仪数据对接,端口:{this.Options.Listeners.First().Port},开启！");
            return base.OnStartedAsync();
        }

        protected override ValueTask OnStopAsync()
        {
            LogHelper.Info($"苏州金庭肯特流量仪数据对接,端口:{this.Options.Listeners.First().Port},关闭！");
            return base.OnStopAsync();
        }



    }
}