/// <summary>
  /// 数据到达
  /// </summary>
  TDataAvailable=procedure(Sender:TObject;ReceiveMsg:string;ErrCode:Word) of object;
  /// <summary>
  /// 命令发送
  /// </summary>
  TSendDataComm=procedure(Sender:TObject;SendCom:string) of object;
  /// <summary>
  /// 返回在线好友
  /// </summary>
  TResultLinkman=procedure(Sender:TObject;Linkman:string) of object;
  /// <summary>
  /// 被邀请
  /// </summary>
  TInvites=procedure(InviteObject:string) of object;
  /// <summary>
  /// 会话退出
  /// </summary>
  TByeSession=procedure(TalkUser:string) of object;
  //信息发送标志
  TMsgResult=(Msg_OK,Msg_Miss,Msg_Unknow);

  /// <summary>
  /// 消息到达
  /// </summary>
  TMsgReceive=procedure(Sender:TObject;User,Msg:string) of object;

  { TIMessage }
  /// <summary>
  /// 所有通讯类的基类
  /// </summary>
  TIMessage=class(TObject)
  Private
    FDataAvailable:TDataAvailable;
    FDebugModel:Boolean;
    FDebugFileName:string;
  Protected
    FUserName:string;
    FPassWord:string;
    FSendDataComm:TSendDataComm;
    FLoginError:TNotifyEvent;
    FLoginSucess:TNotifyEvent;
    FRecStr:string;
    FSocket:TObject;
    procedure ProtocalAnalyze(const ProtString:string); Virtual;
    procedure SendComm; Virtual;
    procedure DataAvailable(Sender:TObject;ErrCode:Word); Virtual;
    procedure SockSocksConnected(Sender:TObject;ErrCode:Word);
    property OnLoginError:TNotifyEvent Read FLoginError Write FLoginError;
    property OnLoginSucess:TNotifyEvent Read FLoginSucess Write FLoginSucess;
  Public
    /// <summary>
    /// 登录帐号
    /// </summary>
    property UserName:string Read FUserName Write FUserName;
    /// <summary>
    /// 登录密码
    /// </summary>
    property PassWord:string Read FPassWord Write FPassWord;
    /// <summary>
    /// 协议数据接受(用做调试)
    /// </summary>
    property OnDataAvailable:TDataAvailable Read FDataAvailable Write FDataAvailable;
    /// <summary>
    /// 协议命令发送(用做调试)
    /// </summary>
    property OnSendDataComm:TSendDataComm Read FSendDataComm Write FSendDataComm;
    /// <summary>
    /// 调试模式
    /// </summary>
    property DebugModel:Boolean Read FDebugModel Write FDebugModel;
    /// <summary>
    /// 仅当调试模式时调试文件保存的位置
    /// </summary>
    property DebugFileName:string Read FDebugFileName Write FDebugFileName;

    function ReceiveMsg:string; Virtual;

    procedure AddGroup(GroupName:string); Virtual;
    procedure DelGroup(GroupName:string); Virtual;
    procedure AddFriend(FriendName:string); Virtual;
    procedure DelFriend(FriendName:string); Virtual;
    procedure Login; Virtual;
    procedure Logout; Virtual;

    constructor Create; Virtual;
    destructor Destroy; Override;
  end;

  //MSN信息
  /// <summary>
  /// TMSN类的会话类，主要由内部使用。调用者不应主动调用。
  /// </summary>
  TMSNSession=class(TObject)
  Private
    FRequestSession:Boolean;
    FIN:Integer;
    FCL:string;
    FRN:Integer;
    FSSocket:TWSocket;
    FAddr:string;
    FPort:string;
    FMsgBye:TNotifyEvent;
    FCommString:TStrings;
    FDataAvailable:TDataAvailable;
    FUserObject:string;
    FUser:string;
    FByeSession:TByeSession;
    FInviteAs:TNotifyEvent;
    FInvites:TInvites;
    FMsgReceive:TMsgReceive;
    FMsgKeyDown:TNotifyEvent;
    DataBuf:TStrings;
    FDebugModel:Boolean;
    procedure DataAvailable(Sender:TObject;ErrCode:Word);
    procedure SessionCloseed(Sender:TObject;ErrCode:Word);
  Protected
    procedure ProtocalAnalyze(ProtString:string);
  Public
    /// <summary>
    /// 当前用户
    /// </summary>
    property UserObject:string Read FUserObject Write FUserObject;
    property Addr:string Read FAddr Write FAddr;
    property Port:string Read FPort Write FPort;
    property MsgBye:TNotifyEvent Read FMsgBye Write FMsgBye;
    property CL:string Read FCL Write FCL;
    property RequestSession:Boolean Read FRequestSession Write FRequestSession;
    property OnDataAvailable:TDataAvailable Read FDataAvailable Write FDataAvailable;
    property OnByeSession:TByeSession Read FByeSession Write FByeSession;
    property OnInviteAs:TNotifyEvent Read FInviteAs Write FInviteAs;
    property OnInvites:TInvites Read FInvites Write FInvites;
    property OnMsgReceive:TMsgReceive Read FMsgReceive Write FMsgReceive;
    property OnMsgKeyDown:TNotifyEvent Read FMsgKeyDown Write FMsgKeyDown;
    property DebugModel:Boolean Read FDebugModel Write FDebugModel;

    function Invite(const ID:string):TMsgResult;

    procedure MsgOut;
    procedure SendSession(Msg:string;FontName:string='Tahoma';Color:TColor=clblack;Inclined:Boolean=False;Thick:Boolean=False);

    constructor Create;
    destructor Destroy;
  end;

{ TIMessage }

/// <summary>
/// 添加好友
/// </summary>
/// <param name="FriendName"> </param>

procedure TIMessage.AddFriend(FriendName:string);
begin
  //
end;

/// <summary>
/// 添加组
/// </summary>
/// <param name="GroupName">组名 </param>

procedure TIMessage.AddGroup(GroupName:string);
begin
  //
end;

constructor TIMessage.Create;
begin
  if not(Assigned(DebugRecord)) then
    DebugRecord:=TStringList.Create;
  FDebugFileName:=ExtractFilePath(ParamStr(0))+'IM_Class_Debug_Log.htm';
end;

procedure TIMessage.DataAvailable(Sender:TObject;ErrCode:Word);
begin
  FRecStr:=TWSocket(FSocket).ReceiveStr;
  if FDebugModel then DebugRecord.Add(SERVER_RESPONSE+FRecStr);
  if Assigned(FDataAvailable) then
    FDataAvailable(Sender,SERVER_RESPONSE+FRecStr,ErrCode);
end;

/// <summary>
/// 删除好友
/// </summary>
/// <param name="FriendName"> </param>

procedure TIMessage.DelFriend(FriendName:string);
begin
  //
end;

/// <summary>
/// 删除组
/// </summary>
/// <param name="GroupName">组名 </param>

procedure TIMessage.DelGroup(GroupName:string);
begin
  //
end;

destructor TIMessage.Destroy;
begin
  DebugRecord.Add(DEBUG_SPLITER);
  DebugRecord.Add(DateToStr(Date)+' '+TimeToStr(Time)+' '+ClassName+' Destroy...');
  if FDebugModel then
    DebugToFile(DebugRecord,FDebugFileName);
  FreeAndNil(DebugRecord);
  inherited Destroy;
end;

/// <summary>
/// 登录
/// </summary>

procedure TIMessage.Login;
begin
  //
end;

/// <summary>
/// 注销
/// </summary>

procedure TIMessage.Logout;
begin
  //
end;

procedure TIMessage.ProtocalAnalyze(const ProtString:string);
begin
  //
end;

///<summary>
/// 接受消息
/// </summary>

function TIMessage.ReceiveMsg:string;
begin
  //
end;

procedure TIMessage.SendComm;
begin
  //
end;

procedure TIMessage.SockSocksConnected(Sender:TObject;ErrCode:Word);
begin
  DebugRecord.Add(DateToStr(Date)+' '+TimeToStr(Time)+' '+'Socket Connected '+'Host: '+TWSocket(FSocket).Addr+' Port: '+TWSocket(FSocket).Port);
end;

{ TMSN }

constructor TMSN.Create(Owner:TComponent);
begin
  inherited Create;
  DebugRecord.Add(DateToStr(Date)+' '+TimeToStr(Time)+' '+Self.ClassName+DEBUG_Create);
  DebugRecord.Add(DEBUG_SPLITER);
  try
    FCurrentSession:=-1;
    FSessionList:=TClassList.Create;
    FSocket:=TWSocket.Create(nil);
    TWSocket(FSocket).MultiThreaded:=True;
    FCommString:=TStringList.Create;
{$IFNDEF DllMode}
    FAntiFreeze:=TIdAntiFreeze.Create(Owner);
    FAntiFreeze.OnlyWhenIdle:=False;
{$ENDIF}
    FSynInfo:=TStringList.Create;
    FRN:=-1;
    FMsnVer:='7.0.0816';
    FOSVer:='5.0';
    FMSNProtocol:=10;//默认协议版本号，关系到服务器验证的实现
    with FSocket as TWSocket do
    begin
      Close;
      FCommString.Clear;
      OnSessionConnected:=Self.SockSocksConnected;
      Addr:=MSN_LOGINDISPATCH;
      Port:=MSN_LOGINNETPORT;
      OnDataAvailable:=Self.DataAvailable;
    end;
  except
    DebugRecord.Add(DateToStr(Date)+' '+TimeToStr(Time)+' '+Self.ClassName+DEBUG_Create_ERROR);
  end;

end;

procedure TMSN.DataAvailable(Sender:TObject;ErrCode:Word);
begin
  inherited DataAvailable(Sender,ErrCode);
  EventProcess;

end;

destructor TMSN.Destroy;
var
  i:Integer;
begin
  FreeAndNil(FSynInfo);
  { for i:=0 to FSessionTotal do
     if Assigned(FSessionList[i]) then
      TMSNSession(FSessionList[i]).Free;}
{$IFNDEF DllMode}
  FreeAndNil(FAntiFreeze);
{$ENDIF}
  TWSocket(FSocket).Close;
  FreeAndNil(FCommString);
  FreeAndNil(FSocket);
  FreeAndNil(FSessionList);
  inherited Destroy;
end;

//获取NetPassPort的Ticket

procedure TMSN.GetTicket(const URL:string;const Host:string='';const Authorization:string='');
var
  FHttp:TidHttp;
  OpenSSL:TIdSSLIOHandlerSocketOpenSSL;
  s:string;
  t:string;
  tempstring:TStrings;
begin
  FHttp:=TidHttp.Create(nil);
  OpenSSL:=TIdSSLIOHandlerSocketOpenSSL.Create(nil);
  try
    if Host='' then FHttp.ProtocolVersion:=pv1_0;

    OpenSSL.SSLOptions.Method:=sslvSSLv23;
    FHttp.IOHandler:=OpenSSL;
    FHttp.Request.Host:=Host;
    FHttp.Request.CustomHeaders.Add(Authorization);

    try
      FHttp.Get(URL);
    except
      //302
    end;

    s:=FHttp.Response.Location;

    if LowerCase(LeftStr(s,8))=SSL_HEAD then
    begin
      inc(FRefTag);
      FRef:=FRefTag;
      FHttp.Disconnect;
      GetTicket(s,Host,Authorization);
      Dec(FRefTag);
    end;
    t:=FHttp.Response.RawHeaders.Values[TICKET_HEAD];

  finally
    FreeAndNil(OpenSSL);
    FreeAndNil(FHttp);
  end;
  if FRef=FRefTag then
    if Pos('=''t=',t)=0 then
    begin
      if (Assigned(FLoginError)) then
        FLoginError(Self);
    end
    else
    begin
      tempstring:=SplitString(t,',');
      try
        Fticket:=MidStr(tempstring[1],10,Length(tempstring[1])-10);

      finally
        FreeAndNil(tempstring);
      end;
    end;
end;

/// <summary>
/// 登录MSN
/// </summary>

procedure TMSN.Login;
var
  i,j:Integer;
begin
  inherited Login;
  TWSocket(FSocket).Connect;
  LoginInit;
  SendComm;

end;

procedure TMSN.LoginInit;
begin
  with FCommString as TStringList do
  begin
    Add(MSN_COMM_VER+IntToStr(Count)+MSN_COMM_PROTOCOL+IntToStr(FMSNProtocol)+MSN_COMM_NAME+MSN_COMM_ENTER);
    Add(MSN_COMM_CVR+IntToStr(Count)+' '+MSN_COMM_LANGUAGE_GB+MSN_COMM_OSTAG+FOSVer+MSN_COMM_OSTAG1+MSN_COMM_MSNVER+FMsnVer+' '+MSN_COMM_USER+UserName+MSN_COMM_ENTER);
    Add(MSN_COMM_USR+IntToStr(Count)+MSN_COMM_TWN_I+UserName+MSN_COMM_ENTER);
  end;
end;

/// <summary>
/// 注销
/// </summary>

procedure TMSN.Logout;
begin
  inherited Logout;
  TWSocket(FSocket).SendStr(MSN_COMM_USR+IntToStr(FCommString.Count+1)+MSN_COMM_OUT+MSN_COMM_ENTER);
end;

/// <summary>
/// 会话退出
/// </summary>
/// <param name="TalkUser">需要退出会话的用户(默认为最后进行对话的用户) </param>

procedure TMSN.MsgOut(TalkUser:string='');
var
  i,j:Integer;
begin
  j:=FSessionList.Count;
  if j=0 then Exit;
  Dec(j);
  for i:=0 to j do
    if TMSNSession(FSessionList[i]).FUser=TalkUser then
      TMSNSession(FSessionList[i]).MsgOut;
  // FreeAndNil(FMSNSession);
end;

//对返回的信息进行分析

procedure TMSN.ProtocalAnalyze(const ProtString:string);
var
  s,t,ck:string;
  xaddr:TStrings;
  i:Integer;
  PS:string;
begin
  inherited ProtocalAnalyze(ProtString);
  s:=GetFirstWord(FRecStr);
  if (s=TrimRight(MSN_COMM_XFR))and(Pos('SB',ProtString)=0) then
  begin
    LoginInit;
    with FSocket as TWSocket do
    begin
      try
        xaddr:=SplitString(ProtString,' ');
        xaddr:=SplitString(xaddr[3],'.');

        with FSocket as TWSocket do
        begin
          Close;
          Addr:=xaddr[0]+'.'+xaddr[1]+'.'+xaddr[2]+'.'+MidStr(xaddr[3],0,Pos(':',xaddr[3])-1);
          Port:=RightStr(xaddr[3],Length(xaddr[3])-Pos(':',xaddr[3]));
          Connect;
        end;
      finally
        FreeAndNil(xaddr);
      end;
    end;
  end;

  if s=TrimRight(MSN_COMM_CHL) then
  begin
    TWSocket(FSocket).SendStr(MSN_COMM_QRY+IntToStr(FCommString.Count+1)+MSN_CLIENT_ID+MSN_CLIENT_VER+MSN_COMM_ENTER+LowerCase(StrMD5(Trim(SplitString(ProtString,' ')[2])+MSN_CLIENT_KEY)));
    if Assigned(FQryFinish) then FQryFinish(Self);
  end;

  if (s=TrimRight(MSN_COMM_XFR))and(Pos('SB',ProtString)<>0) then
  begin
    PS:=Trim(ProtString);
    SessionCreate;
    with TMSNSession(FSessionList[FCurrentSession]) do
    begin
      RequestSession:=False;
      CL:=Trim(SplitString(PS,' ')[5]);
      Addr:=MidStr(PS,Pos('SB',PS)+2,Pos(':',PS)-Pos('SB',PS)-2);
      Port:=MSN_LOGINNETPORT;
      FUser:=FTalkID;
      Invite(FTalkID);
    end;
  end;

  if s=TrimRight(MSN_COMM_RNG) then
  begin
    PS:=Trim(ProtString);
    SessionCreate;
    with TMSNSession(FSessionList[FCurrentSession]) do
    begin
      RequestSession:=True;
      CL:=Trim(SplitString(PS,' ')[4])+' '+Trim(SplitString(PS,' ')[1]);
      Addr:=Trim(LeftStr(SplitString(PS,' ')[2],Length(SplitString(PS,' ')[2])-5));
      Port:=MSN_LOGINNETPORT;
      FUser:=Trim(SplitString(PS,' ')[5]);
      Invite('');
    end;
  end;

  if (s=TrimRight(MSN_COMM_USR))and(Pos('TWN S',ProtString)<>0) then
  begin
    xaddr:=SplitString(ProtString,',');
    try
      Ftlc:=xaddr[0];
      Ftid:=xaddr[1];
      Fttw:=xaddr[2];
      Ftfs:=xaddr[3];
      Ftru:=xaddr[4];
      Ftct:=xaddr[5];
      Ftkpp:=xaddr[6];
      Ftkv:=xaddr[7];
      Ftver:=xaddr[8];
      Ftrn:=xaddr[9];
      Fttpf:=xaddr[xaddr.count-1];     //Modify
      //连接保留
      t:=MSN_Author_TAG+HttpEncode(FUserName)+MSN_PAW_TAG+HttpEncode(FPassWord)+','+Ftlc+','+Ftid+','+Fttw+','+Ftfs+MSN_SERVER_TAG+Ftct+','+Ftkpp+','+Ftkv+','+Ftver+','+Fttpf+#13#10;
      GetTicket(SSL_HEAD+MSN_PASSPORTSERVER,MSN_HOST,t);
      if Fticket<>'' then
      begin
        FCommString.Add(MSN_COMM_USR+IntToStr(FCommString.Count)+MSN_COMM_TWN_S+Fticket+MSN_COMM_ENTER);
        // FCommString.Add(MSN_COMM_SYN+IntToStr(FCommString.Count)+' 0 0'+MSN_COMM_ENTER);
        FCommString.Add(MSN_COMM_CHG+IntToStr(FCommString.Count)+' NLN'+MSN_CLIENT_VER+MSN_COMM_ENTER);
        //FCommString.Add(MSN_COMM_PNG+MSN_COMM_ENTER);
      end;
    finally
      FreeAndNil(xaddr);
    end;
  end;

  if s=MSN_RESPONSE_ADC then
  begin
    TWSocket(FSocket).SendStr('ADC '+IntToStr(FCommString.Count)+' NLN'+MSN_CLIENT_VER+MSN_COMM_ENTER);

    //        ShowMessage('ADD '+IntToStr(FCommString.Count)+' FL '+SplitString(PS,' ')[3]+' '+SplitString(PS,' ')[4]+MSN_COMM_ENTER);
      // TWSocket(FSocket).SendStr('ADD '+IntToStr(FCommString.Count)+' FL '+SplitString(FRecStr,' ')[3]+' '+SplitString(FRecStr,' ')[4]+MSN_COMM_ENTER);
  end;

  //发送下一条协议命令
  SendComm;

end;

procedure TMSN.SendComm;
var
  s:string;
begin
  inherited SendComm;
  inc(FRN);
  if FRN>=FCommString.Count then
    Exit;

  if Assigned(FSendDataComm) then
    FSendDataComm(Self,CLIENT_REQUEST+FCommString[FRN]);
  if DebugModel then DebugRecord.Add(CLIENT_REQUEST+FCommString[FRN]);
  while TWSocket(FSocket).State<>wsConnected do
    Application.ProcessMessages;

  TWSocket(FSocket).SendStr(FCommString[FRN]);
  // if LeftStr(FCommString[FRN],3)='QRY' then
   //showmessage(fcommstring[frn]);

end;

//发出邀请

/// <summary>
/// 邀请好友加入当前会话
/// </summary>
/// <param name="ID">需要邀请者的帐号 </param>

procedure TMSN.Invite(const ID:string);
begin
  FTalkID:=ID;
  TWSocket(FSocket).SendStr(MSN_COMM_XFR+IntToStr(FRN+FCommString.Count+1)+' SB'+MSN_COMM_ENTER);
end;

/// <summary>
/// 向指定好友发送消息(需成功邀请到好友)
/// </summary>
/// <param name="Msg">消息内容 </param>
/// <param name="SendUser">发送的好友对象 </param>
/// <param name="FontName">字体(默认为Tahoma) </param>
/// <param name="Color">字体颜色(默认为黑色) </param>
/// <param name="Inclined">是否是斜体 </param>
/// <param name="Thick">是否加粗 </param>

procedure TMSN.SendMsg(Msg:string;SendUser:string='';FontName:string='Tahoma';Color:TColor=clblack;Inclined:Boolean=False;Thick:Boolean=False);
var
  i,j:Integer;
begin
  j:=FSessionList.Count;
  if j=0 then Exit;
  Dec(j);
  if SendUser<>'' then
  begin
    for i:=0 to j do
    begin
      if TMSNSession(FSessionList.Items[i]).FUser=SendUser then
        CoreSendMsg(i,Msg,FontName,Color,Inclined,Thick);
    end;
  end
  else
    CoreSendMsg(FCurrentSession,Msg,FontName,Color,Inclined,Thick);

end;

procedure TMSN.EventProcess;
var
  tmp:TStringList;
  i,j:Integer;
  s:string;
begin
  if (Assigned(FLoginError))and(LeftStr(FRecStr,3)='911') then
    FLoginError(Self);
  if (Assigned(FLoginSucess))and(Pos('OK',FRecStr)<>0) then
    FLoginSucess(Self);
  if (Pos('LST N=',FRecStr)<>0)and(Assigned(FResultLinkman)) then
  begin
    tmp:=SplitString(FRecStr,MSN_COMM_ENTER);
    for i:=0 to tmp.Count-1 do
    begin
      if Pos(MSN_LINK_LST,tmp[i])<>0 then
      begin
        s:=SplitString(tmp[i],' ')[1];
        FResultLinkman(Self,Copy(s,3,Length(s)-1));
      end;
    end;
    tmp.Free;
  end;
  if (Assigned(FSynFinish))and(LeftStr(FRecStr,3)=MSN_COMM_QNG) then
    FSynFinish(Self);
  if FRecStr<>'' then ProtocalAnalyze(FRecStr);
end;

/// <summary>
/// 获取好友列表
/// </summary>

procedure TMSN.GetSynList;
begin
  TWSocket(FSocket).SendStr(MSN_COMM_SYN+IntToStr(FCommString.Count)+' 0 0'+MSN_COMM_ENTER);
end;

procedure TMSN.Ping;
begin
  TWSocket(FSocket).SendStr(MSN_COMM_PNG+MSN_COMM_ENTER);
end;

procedure TMSN.SessionCreate;
begin
  inc(FCurrentSession);
  FMSNSession:=TMSNSession.Create;
  try
    FSessionList.Add(TClass(FMSNSession));
    with TMSNSession(FSessionList[FCurrentSession]) do
    begin
      FUser:=Self.FTalkID;
      UserObject:=Self.FUserName;
      OnMsgKeyDown:=Self.FMsgKeyDown;
      OnMsgReceive:=Self.FMsgReceive;
      OnInviteAs:=Self.FInviteAs;
      OnByeSession:=Self.OnAfterByeSession;
      OnDataAvailable:=Self.FDataAvailable;
      OnInvites:=Self.FInvites;
      DebugModel:=Self.FDebugModel;
    end;
  finally
    inc(FSessionTotal);
  end;
end;

procedure TMSN.OnAfterByeSession(TalkUser:string);
var
  i,j:Integer;
begin
  //  FSessionList[FSessionList.Count-1].Free;
{  if Assigned(FMSNSession[FCurrentSession]) then
  begin
  FMSNSession[FCurrentSession].Free;
  Dec(FCurrentSession);
  end;}
{ try
    j:=FSessionList.Count;
    if j<>0 then
      for i:=0 to j-1 do
        if TMSNSession(FSessionList[i]).FUser=TalkUser then
          FSessionList.Delete(i);
  except
    //
  end;}
  if Assigned(FByeSession) then FByeSession(TalkUser);
end;

procedure TMSN.CoreSendMsg(Index:Integer;Msg,FontName:string;Color:TColor;
  Inclined,Thick:Boolean);
begin
  try
    if Assigned(TMSNSession(FSessionList[Index])) then
      TMSNSession(FSessionList[Index]).SendSession(Msg,FontName,Color,Inclined,Thick);
  except
    //
  end;
end;

{ TMSNSession }

constructor TMSNSession.Create;
begin
  if FDebugModel then
    DebugRecord.Add(DateToStr(Date)+' '+TimeToStr(Time)+' '+Self.ClassName+DEBUG_Create);

  DataBuf:=TStringList.Create;
  FSSocket:=TWSocket.Create(nil);
  FSSocket.MultiThreaded:=True;
  FSSocket.OnSessionClosed:=SessionCloseed;
  FCommString:=TStringList.Create;
  FSSocket.OnDataAvailable:=DataAvailable;
  FreeAndNil(DataBuf);

end;

procedure TMSNSession.DataAvailable(Sender:TObject;ErrCode:Word);
var
  tmp:string;
  i:Integer;
begin

  tmp:=FSSocket.ReceiveStr;
  //DataBuf.Add(tmp);
  // tmp:=Utf8ToAnsi(tmp);
  if FDebugModel then DebugRecord.Add(SERVER_RESPONSE+tmp);

  if Assigned(FDataAvailable) then
    FDataAvailable(Sender,tmp,ErrCode);
  //form1.Memo1.Lines.Add(utf8toansi(tmp));

  //for i:=0 to DataBuf.Count-1 do
  ProtocalAnalyze(tmp);

  //DataBuf.Clear;

end;

destructor TMSNSession.Destroy;
begin
  FreeAndNil(FCommString);
  FreeAndNil(FSSocket);
  if FDebugModel then DebugRecord.Add(DateToStr(Date)+' '+TimeToStr(Time)+' '+Self.ClassName+DEBUG_DESTROY);
end;

procedure TMSNSession.MsgOut;
begin
  FSSocket.SendStr(MSN_SESSION_OUT+MSN_COMM_ENTER);
end;

procedure TMSNSession.ProtocalAnalyze(ProtString:string);
var
  PS:string;
  PSTag:string;
  s:string;
  i:Integer;
begin
  PS:=Trim(ProtString);
  PSTag:=LeftStr(PS,3);

  if (PSTag=MSN_RESPONSE_BYE)and(Assigned(FByeSession)) then
    FByeSession(FUser);

  if (LeftStr(PS,3)=TrimRight(MSN_COMM_USR))and(Pos(MSN_RESPONSE_OK,PS)<>0) then
    FSSocket.SendStr(FCommString[FIN]);

  if PSTag=MSN_RESPONSE_NAK then Exit;//会话关闭

  if Assigned(FInviteAs)and(Pos(MSN_COMM_JOI,PS)<>0) then
    FInviteAs(Self);

  if PSTag=MSN_SESSION_IRO then
  begin
    s:=SplitString(PS,' ')[SplitString(PS,' ').Count-1];
    if Assigned(FInvites) then FInvites(s);
  end;

  if (PSTag=TrimRight(MSN_COMM_MSG)) then
  begin
    if (Assigned(FMsgKeyDown)) then
      FMsgKeyDown(Self);
    if (Pos('PF=',PS)<>0)and(Assigned(FMsgReceive)) then
    begin
      s:=MidStr(PS,Pos(MSN_MSG_ENTER,PS)+Length(MSN_MSG_ENTER),Length(PS)-Pos(MSN_MSG_ENTER,PS)+Length(MSN_MSG_ENTER));
      if Pos(TrimRight(MSN_COMM_MSG),s)=0 then
        FMsgReceive(Self,FUser,Utf8ToAnsi(s))
      else
        //包错误
        ;
    end;
  end;
end;

function TMSNSession.Invite(const ID:string):TMsgResult;
begin
  if FSSocket.State<>wsConnected then
  begin
    if not(FRequestSession) then
    begin
      FCommString.Add(MSN_COMM_USR+IntToStr(FRN+FCommString.Count+1)+' '+FUserObject+' '+FCL+MSN_COMM_ENTER);
      FCommString.Add(MSN_COMM_CAL+IntToStr(FRN+FCommString.Count+1)+' '+ID+MSN_COMM_ENTER);
    end
    else
      FCommString.Add(MSN_COMM_ANS+IntToStr(FRN+FCommString.Count+1)+' '+FUserObject+' '+FCL+MSN_COMM_ENTER);

    FSSocket.Close;
    FSSocket.Addr:=FAddr;
    FSSocket.Port:=FPort;
    FSSocket.Connect;
    FRN:=100;
  end;
  if FDebugModel then DebugRecord.Add(DateToStr(Date)+' '+TimeToStr(Time)+' '+Self.ClassName+'Connection... Host: '+FAddr+'Port: '+FPort);
  while FSSocket.State<>wsConnected do
    Application.ProcessMessages;

  if FIN<FCommString.Count then
    FSSocket.SendStr(FCommString[FIN]);

  if FDebugModel then DebugRecord.Add(DateToStr(Date)+' '+TimeToStr(Time)+' '+CLIENT_REQUEST+FCommString[FIN]);

  inc(FIN);
  inc(FRN,100);
end;

procedure TMSNSession.SendSession(Msg:string;FontName:string='Tahoma';Color:TColor=clblack;Inclined:Boolean=False;Thick:Boolean=False);
var
  MsgHead:string;
  i:Integer;
  B:string;
begin
  if Inclined then B:='I';
  if Thick then B:='B'+B;
  Msg:=AnsiToUtf8(Msg);
  MsgHead:=MSN_MSG_HEAD+HtmlEncode(FontName)+MSN_MSG_FONTSTYLE+B+MSN_MSG_COLOR+IntToHex(ColorToRGB(Color),6)+MSN_MSG_FONTCHARSET+MSN_MSG_FONTGB+MSN_MSG_FONSTSIZE+MSN_MSG_ENTER;
  i:=Length(MsgHead)+Length(Msg);
  FSSocket.SendStr(MSN_COMM_MSG+IntToStr(FRN)+' N '+IntToStr(i)+MSN_COMM_ENTER+MsgHead+Msg);
end;

procedure TMSNSession.SessionCloseed(Sender:TObject;ErrCode:Word);
begin
  if Assigned(FByeSession) then FByeSession(FUser);
  if FDebugModel then DebugRecord.Add(DateToStr(Date)+' '+TimeToStr(Time)+' '+'Session Closed...');
end;