subscribepresenceaction.cs

破解的飞信源代码

namespace Imps.Client.Core
{
    using Imps.Client.Core.Login;
    using Imps.Utils;
    using System;
    using System.Threading;

    public sealed class SubscribePresenceAction : LoginAction
    {
        private const string errorMessage = "订阅联系人状态出现错误";
        private bool result;
        private AutoResetEvent waitSubscribe;

        public SubscribePresenceAction(User user, ILoginListner listner) : base(user, listner)
        {
        }

        public override void Cancel()
        {
        }

        public override void Clear()
        {
            this.result = false;
            base.User.SubscribePresenceOK = false;
            base.User.BeenSubscribedPresence = false;
        }

        public override void Dispose()
        {
        }

        public override bool Execute()
        {
            try
            {
                this.result = false;
                base.NotifyMessage("开始订阅联系人状态");
                AsyncBizOperation op = new AsyncBizOperation(base.User);
                op.ImpsError += new EventHandler<ImpsErrorEventArgs>(this, (IntPtr) this.op_ImpsError);
                op.Successed += new EventHandler(this.op_Successed);
                if (this.waitSubscribe == null)
                {
                    this.waitSubscribe = new AutoResetEvent(false);
                }
                base.User.ContactList.AsyncSubscribePresenceBatchAll(true, op);
                if (!this.waitSubscribe.WaitOne(this.TimeOut, false))
                {
                    ReflectionHelper.ClearAllEvents(op);
                    base.NotifyLoginFailed("订阅联系人状态出现错误", ExceptionType.CommonException, null);
                }
                base.NotifyMessage("订阅联系人状态结束");
            }
            catch (Exception exception)
            {
                base.NotifyLoginFailed("订阅联系人状态出现错误", ExceptionType.CommonException, exception);
            }
            return this.result;
        }

        private void op_ImpsError(object sender, ImpsErrorEventArgs e)
        {
            base.NotifyLoginFailed("订阅联系人状态出现错误", ExceptionType.CommonException, null);
            this.result = false;
            this.waitSubscribe.Set();
        }

        private void op_Successed(object sender, EventArgs e)
        {
            this.result = true;
            this.waitSubscribe.Set();
        }

        public override void Retry(RetryResult result)
        {
            base.User.ContactList.RetrySubscribe(result);
        }

        public override bool LocalCacheHit
        {
            get
            {
                return true;
            }
        }

        public override Imps.Client.Core.LoginStage LoginStage
        {
            get
            {
                return Imps.Client.Core.LoginStage.SubscribePresence;
            }
        }

        public override int TimeOut
        {
            get
            {
                return 0x2bf20;
            }
        }
    }
}