root/TwitterIrcGateway/trunk/TwitterIrcGatewayCore/Server.cs

using System;
using System.Collections.Generic;
using System.Text;
using System.Net;
using System.Net.Sockets;
using System.Diagnostics;

namespace Misuzilla.Applications.TwitterIrcGateway
{
    public class Server
    {
        private TcpListener _tcpListener;
        private List<Session> _sessions;
        private Encoding _encoding = Encoding.GetEncoding("ISO-2022-JP");
        
        /// <summary>
        /// �`�F�b�N�����u
        /// </summary>
        public Int32 Interval = 60;

        /// <summary>
        /// �_�C���N�g���b�Z�[�W��F�b�N�����u
        /// </summary>
        public Int32 IntervalDirectMessage = 60 * 5;

        /// <summary>
        /// Replies��F�b�N���邩�ǂ���
        /// </summary>
        public Boolean EnableRepliesCheck = false;
        
        /// <summary>
        /// Replies�`�F�b�N�����u
        /// </summary>
        public Int32 IntervalReplies = 60 * 5;

        /// <summary>
        /// �G���[�𖳎����邩�ǂ���
        /// </summary>
        public Boolean IgnoreWatchError = false;

        /// <summary>
        /// TinyURL��J���邩�ǂ���
        /// </summary>
        public Boolean ResolveTinyUrl = true;

        /// <summary>
        /// �����ڂ��h�~�𗘗p���邩�ǂ���
        /// </summary>
        public Boolean EnableDropProtection = true;

        /// <summary>
        /// �X�e�[�^�X��V�����Ƃ��Ƀg�s�b�N��X���邩�ǂ���
        /// </summary>
        public Boolean SetTopicOnStatusChanged = false;

        /// <summary>
        /// �g���[�X����邩�ǂ���
        /// </summary>
        public Boolean EnableTrace = false;

        /// <summary>
        /// Cookie ���O�C���Ń^�C�����C��������邩�ǂ���
        /// </summary>
        public Boolean CookieLoginMode = false;

        /// <summary>
        /// Twitter�̃X�e�[�^�X�������`�����l����
        /// </summary>
        public String ChannelName = "#twitter";

        /// <summary>
        /// ���[�U�ꗗ������邩�ǂ���
        /// </summary>
        public Boolean DisableUserList = false;

        /// <summary>
        /// �A�b�v�f�[�g��ׂẴ`�����l���ɓ����邩�ǂ���
        /// </summary>
        public Boolean BroadcastUpdate = false;

        /// <summary>
        /// �N���C�A���g�Ƀ��b�Z�[�W�𑗐M�������̃E�F�C�g
        /// </summary>
        public Int32 ClientMessageWait = 0;

        /// <summary>
        /// �A�b�v�f�[�g��ׂẴ`�����l���ɓ�������NOTICE�ɂ��邩�ǂ���
        /// </summary>
        public Boolean BroadcastUpdateMessageIsNotice = false;

        /// <summary>
        /// API�A�N�Z�X�ɗ��p�������N�V�T�[�o�̐ݒ�        /// </summary>
        public IWebProxy Proxy = null;

        /// <summary>
        /// �f�[�^�̎擾��OST���\�b�h�𗘗p���邩�ǂ���
        /// </summary>
        public Boolean POSTFetchMode = false;

        public const String ServerName = "localhost";
        public const String ServerNick = "$TwitterIrcGatewayServer$";

        public event EventHandler<SessionStartedEventArgs> SessionStartedReceived;

        void AcceptHandled(IAsyncResult ar)
        {
            if (_tcpListener != null && ar.IsCompleted)
            {
                TcpClient tcpClient = _tcpListener.EndAcceptTcpClient(ar);
                _tcpListener.BeginAcceptTcpClient(AcceptHandled, this);

                Trace.WriteLine(String.Format("Client Connected: RemoteEndPoint={0}", tcpClient.Client.RemoteEndPoint));
                Session session = new Session(this, tcpClient);
                lock (_sessions)
                {
                    _sessions.Add(session);
                }
                session.SessionStarted += new EventHandler<SessionStartedEventArgs>(session_SessionStartedReceived);
                session.SessionEnded += new EventHandler<EventArgs>(session_SessionEnded);
                session.Start();
            }
        }

        void session_SessionEnded(object sender, EventArgs e)
        {
            lock (_sessions)
            {
                _sessions.Remove(sender as Session);
            }
        }

        void session_SessionStartedReceived(object sender, SessionStartedEventArgs e)
        {
            // ���p
            if (SessionStartedReceived != null)
            {
                SessionStartedReceived(sender, e);
            }
        }

        public Encoding Encoding
        {
            get { return _encoding; }
            set { _encoding = value; }
        }
        public Boolean IsRunning
        {
            get { return _tcpListener != null; }
        }

        public void Start(IPAddress ipAddr, Int32 port)
        {
            if (IsRunning)
            {
                throw new InvalidOperationException();
            }

            _sessions = new List<Session>();

            Trace.WriteLine(String.Format("Starting IRC Server: IPAddress = {0}, port = {1}", ipAddr, port));
            _tcpListener = new TcpListener(ipAddr, port);
            _tcpListener.Start();
            _tcpListener.BeginAcceptTcpClient(AcceptHandled, this);
        }

        public void Stop()
        {
            lock (_sessions)
            {
                foreach (Session session in _sessions)
                {
                    session.Close();
                }
            }
            if (_tcpListener != null)
            {
                _tcpListener.Stop();
                _tcpListener = null;
            }
        }
    }
}