src/amule-remote-gui.h

   1 //
   2 // This file is part of the aMule Project.
   3 //
   4 // Copyright (c) 2005-2008 aMule Team ( admin@amule.org / http://www.amule.org )
   5 //
   6 // Any parts of this program derived from the xMule, lMule or eMule project,
   7 // or contributed by third-party developers are copyrighted by their
   8 // respective authors.
   9 //
  10 // This program is free software; you can redistribute it and/or modify
  11 // it under the terms of the GNU General Public License as published by
  12 // the Free Software Foundation; either version 2 of the License, or
  13 // (at your option) any later version.
  14 //
  15 // This program is distributed in the hope that it will be useful,
  16 // but WITHOUT ANY WARRANTY; without even the implied warranty of
  17 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  18 // GNU General Public License for more details.
  19 //
  20 // You should have received a copy of the GNU General Public License
  21 // along with this program; if not, write to the Free Software
  22 // Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301, USA
  23 //
  24
  25 #ifndef AMULE_REMOTE_GUI_H
  26 #define AMULE_REMOTE_GUI_H
  27
  28
  29 #include <ec/cpp/RemoteConnect.h>               // Needed for CRemoteConnect
  30
  31
  32 #include "Statistics.h"
  33 #include "Preferences.h"
  34 #include "Statistics.h"
  35 #include "RLE.h"
  36 #include "SearchList.h"                 // Needed for CSearchFile
  37
  38
  39 class CED2KFileLink;
  40 class CServer;
  41 class CKnownFile;
  42 class CSearchFile;
  43 class CPartFile;
  44 class CUpDownClient;
  45 class CStatistics;
  46 class CPath;
  47
  48 class wxEvtHandler;
  49 class wxTimer;
  50 class wxTimerEvent;
  51
  52 #include <wx/dialog.h>
  53
  54 class CEConnectDlg : public wxDialog {
  55         wxString host;
  56         int port;
  57
  58         wxString pwd_hash;
  59         wxString login, passwd;
  60         bool m_save_user_pass;
  61
  62         void OnOK(wxCommandEvent& event);
  63
  64         DECLARE_EVENT_TABLE()
  65 public:
  66         CEConnectDlg();
  67
  68         wxString Host() { return host; }
  69         int Port() { return port; }
  70
  71         wxString Login() { return login; }
  72         wxString PassHash();
  73         bool SaveUserPass() { return m_save_user_pass; }
  74 };
  75
  76 DECLARE_LOCAL_EVENT_TYPE(wxEVT_EC_INIT_DONE, wxEVT_USER_FIRST + 1001)
  77
  78 class wxECInitDoneEvent : public wxEvent {
  79 public:
  80         wxECInitDoneEvent() : wxEvent(-1, wxEVT_EC_INIT_DONE)
  81         {
  82         }
  83
  84         wxEvent *Clone(void) const
  85         {
  86                 return new wxECInitDoneEvent(*this);
  87         }
  88 };
  89
  90 class CPreferencesRem : public CPreferences, public CECPacketHandlerBase {
  91         CRemoteConnect *m_conn;
  92         uint32 m_exchange_send_selected_prefs;
  93         uint32 m_exchange_recv_selected_prefs;
  94
  95         virtual void HandlePacket(const CECPacket *packet);
  96 public:
  97         CPreferencesRem(CRemoteConnect *);
  98
  99         Category_Struct *CreateCategory(const wxString& name, const CPath& path,
 100                                                 const wxString& comment, uint32 color, uint8 prio);
 101         void UpdateCategory(uint8 cat, const wxString& name, const CPath& path,
 102                                                 const wxString& comment, uint32 color, uint8 prio);
 103
 104         void RemoveCat(uint8 cat);
 105
 106         bool LoadRemote();
 107         void SendToRemote();
 108 };
 109
 110 //
 111 // T - type if item in container
 112 // I - type of id of item
 113 // G - type of tag used to create/update items
 114 //
 115 template <class T, class I, class G = CECTag>
 116 class CRemoteContainer : public CECPacketHandlerBase {
 117 protected:
 118         enum {
 119                 IDLE,            // no request in the air
 120                 STATUS_REQ_SENT, // sent request for item status
 121                 FULL_REQ_SENT    // sent request for full info
 122         } m_state;
 123
 124         CRemoteConnect *m_conn;
 125
 126         std::list<T *> m_items;
 127         std::map<I, T *> m_items_hash;
 128
 129         // for GetByIndex
 130         std::vector<T *> m_idx_items;
 131
 132         // .size() is O(N) operation in stl
 133         int m_item_count;
 134
 135         // use incremental tags algorithm
 136         bool m_inc_tags;
 137
 138         // command that will be used in full request
 139         int m_full_req_cmd, m_full_req_tag;
 140
 141         virtual void HandlePacket(const CECPacket *packet)
 142         {
 143                 switch(this->m_state) {
 144                         case IDLE: wxFAIL; // not expecting anything
 145                         case STATUS_REQ_SENT:
 146                                 // if derived class choose not to proceed, return - but with good status
 147                                 this->m_state = IDLE;
 148                                 if ( this->Phase1Done(packet) ) {
 149                                         CECPacket req_full(this->m_full_req_cmd);
 150
 151                                         ProcessUpdate(packet, &req_full, m_full_req_tag);
 152
 153                                         if ( !this->m_inc_tags ) {
 154                                                 // Phase 3: request full info about files we don't have yet
 155                                                 if ( req_full.GetTagCount() ) {
 156                                                         m_conn->SendRequest(this, &req_full);
 157                                                         this->m_state = FULL_REQ_SENT;
 158                                                 }
 159                                         }
 160                                 }
 161                                 break;
 162                         case FULL_REQ_SENT:
 163                                 ProcessFull(packet);
 164                                 m_state = IDLE;
 165                                 break;
 166                 }
 167         }
 168 public:
 169         CRemoteContainer(CRemoteConnect *conn, bool /*inc_tags*/ = false)
 170         {
 171                 m_state = IDLE;
 172
 173                 m_conn = conn;
 174                 m_item_count = 0;
 175
 176                 // FIXME:
 177                 // The CRemoteContainer has two ways of transfer: with "inc_tags" or without.
 178                 // I found that with inc_tags the update of transferred/completed is broken,
 179                 // therefore I disabled them.
 180                 // Either the inc-tag-mode should be fixed (but I can't to that without some
 181                 // more insight how it's supposed to be working), or removed alltogether.
 182                 //m_inc_tags = inc_tags;
 183                 m_inc_tags = false;
 184         }
 185
 186         virtual ~CRemoteContainer()
 187         {
 188         }
 189
 190         uint32 GetCount()
 191         {
 192                 return m_item_count;
 193         }
 194
 195         void AddItem(T *item)
 196         {
 197                 m_items.push_back(item);
 198                 m_items_hash[GetItemID(item)] = item;
 199                 m_idx_items.resize(m_item_count+1);
 200                 m_idx_items[m_item_count] = item;
 201                 m_item_count++;
 202         }
 203
 204         T *GetByID(I id)
 205         {
 206                 // avoid creating nodes
 207                 return m_items_hash.count(id) ? m_items_hash[id] : NULL;
 208         }
 209
 210         T *GetByIndex(int index)
 211         {
 212                 return ( (index >= 0) && (index < m_item_count) ) ? m_idx_items[index] : NULL;
 213         }
 214
 215         void Flush()
 216         {
 217                 m_items.erase(this->m_items.begin(), this->m_items.end());
 218                 m_items_hash.erase(this->m_items_hash.begin(), this->m_items_hash.end());
 219                 m_item_count = 0;
 220         }
 221
 222         //
 223         // Flush & reload
 224         //
 225         /*
 226         bool FullReload(int cmd)
 227         {
 228                 CECPacket req(cmd);
 229                 CScopedPtr<const CECPacket> reply(this->m_conn->SendRecvPacket(&req));
 230                 if ( !reply.get() ) {
 231                         return false;
 232                 }
 233                 for(typename std::list<T *>::iterator j = this->m_items.begin(); j != this->m_items.end(); j++) {
 234                         this->DeleteItem(*j);
 235                 }
 236
 237                 Flush();
 238
 239                 ProcessFull(reply.get());
 240
 241                 return true;
 242         }
 243         */
 244         void FullReload(int cmd)
 245         {
 246                 if ( this->m_state != IDLE ) {
 247                         return;
 248                 }
 249
 250                 for(typename std::list<T *>::iterator j = this->m_items.begin(); j != this->m_items.end(); j++) {
 251                         this->DeleteItem(*j);
 252                 }
 253
 254                 Flush();
 255
 256                 CECPacket req(cmd);
 257                 this->m_conn->SendRequest(this, &req);
 258                 this->m_state = FULL_REQ_SENT;
 259                 this->m_full_req_cmd = cmd;
 260         }
 261
 262         //
 263         // Following are like basicly same code as in webserver. Eventually it must
 264         // be same class
 265         //
 266         void DoRequery(int cmd, int tag)
 267         {
 268                 if ( this->m_state != IDLE ) {
 269                         return;
 270                 }
 271                 CECPacket req_sts(cmd, m_inc_tags ? EC_DETAIL_INC_UPDATE : EC_DETAIL_UPDATE);
 272                 this->m_conn->SendRequest(this, &req_sts);
 273                 this->m_state = STATUS_REQ_SENT;
 274                 this->m_full_req_cmd = cmd;
 275                 this->m_full_req_tag = tag;
 276         }
 277         /*
 278         bool DoRequery(int cmd, int tag)
 279         {
 280                 CECPacket req_sts(cmd, m_inc_tags ? EC_DETAIL_INC_UPDATE : EC_DETAIL_UPDATE);
 281
 282                 //
 283                 // Phase 1: request status
 284                 CScopedPtr<const CECPacket> reply(this->m_conn->SendRecvPacket(&req_sts));
 285                 if ( !reply.get() ) {
 286                         return false;
 287                 }
 288
 289                 if ( !this->Phase1Done(reply.get()) ) {
 290                         // if derived class choose not to proceed, return - but with good status
 291                         return true;
 292                 }
 293                 //
 294                 // Phase 2: update status, mark new files for subsequent query
 295                 CECPacket req_full(cmd);
 296
 297                 ProcessUpdate(reply.get(), &req_full, tag);
 298
 299                 reply.reset();
 300
 301                 if ( !m_inc_tags ) {
 302                         // Phase 3: request full info about files we don't have yet
 303                         if ( req_full.GetTagCount() ) {
 304                                 reply.reset(this->m_conn->SendRecvPacket(&req_full));
 305                                 if ( !reply.get() ) {
 306                                         return false;
 307                                 }
 308                                 ProcessFull(reply.get());
 309                         }
 310                 }
 311                 return true;
 312         }
 313         */
 314
 315         void ProcessFull(const CECPacket *reply)
 316         {
 317                 for (size_t i = 0;i < reply->GetTagCount();i++) {
 318                         G *tag = (G *)reply->GetTagByIndex(i);
 319                         // initialize item data from EC tag
 320                         T *item = this->CreateItem(tag);
 321                         AddItem(item);
 322                 }
 323         }
 324
 325         void ProcessUpdate(const CECPacket *reply, CECPacket *full_req, int req_type)
 326         {
 327                 std::set<I> core_files;
 328                 for (size_t i = 0;i < reply->GetTagCount();i++) {
 329                         G *tag = (G *)reply->GetTagByIndex(i);
 330                         if ( tag->GetTagName() != req_type ) {
 331                                 continue;
 332                         }
 333
 334                         core_files.insert(tag->ID());
 335                         if ( m_items_hash.count(tag->ID()) ) {
 336                                 T *item = m_items_hash[tag->ID()];
 337                                 ProcessItemUpdate(tag, item);
 338                         } else {
 339                                 if ( m_inc_tags ) {
 340                                         T *item = this->CreateItem(tag);
 341                                         AddItem(item);
 342                                 } else {
 343                                         full_req->AddTag(CECTag(req_type, tag->ID()));
 344                                 }
 345                         }
 346                 }
 347                 std::list<I> del_ids;
 348                 for(typename std::list<T *>::iterator j = this->m_items.begin(); j != this->m_items.end(); j++) {
 349                         I item_id = GetItemID(*j);
 350                         if ( core_files.count(item_id) == 0 ) {
 351                                 del_ids.push_back(item_id);
 352                         }
 353                 }
 354                 for(typename std::list<I>::iterator j = del_ids.begin(); j != del_ids.end(); j++) {
 355                         for(int idx = 0;idx < m_item_count;idx++) {
 356                                 if ( this->GetItemID(m_idx_items[idx]) == *j ) {
 357                                         m_idx_items[idx] = m_idx_items[m_item_count-1];
 358                                         break;
 359                                 }
 360                         }
 361                         m_item_count--;
 362                         m_items_hash.erase(*j);
 363                         for(typename std::list<T *>::iterator k = this->m_items.begin(); k != this->m_items.end(); k++) {
 364                                 if ( *j == GetItemID(*k) ) {
 365                                         // item may contain data that need to be freed externally, before
 366                                         // dtor is called and memory freed
 367                                         this->DeleteItem(*k);
 368
 369                                         this->m_items.erase(k);
 370
 371                                         break;
 372                                 }
 373                         }
 374                 }
 375         }
 376
 377         virtual T *CreateItem(G *)
 378         {
 379                 return 0;
 380         }
 381         virtual void DeleteItem(T *)
 382         {
 383         }
 384         virtual I GetItemID(T *)
 385         {
 386                 return I();
 387         }
 388         virtual void ProcessItemUpdate(G *, T *)
 389         {
 390         }
 391
 392         virtual bool Phase1Done(const CECPacket *)
 393         {
 394                 return true;
 395         }
 396 };
 397
 398 class CServerConnectRem : public CECPacketHandlerBase {
 399         CRemoteConnect *m_Conn;
 400         uint32 m_ID;
 401
 402         CServer *m_CurrServer;
 403
 404         virtual void HandlePacket(const CECPacket *packet);
 405
 406 public:
 407         CServerConnectRem(CRemoteConnect *);
 408         bool ReQuery();
 409
 410         bool IsConnected() { return (m_ID != 0) && (m_ID != 0xffffffff); }
 411         bool IsConnecting() { return m_ID == 0xffffffff; }
 412         bool IsLowID() { return m_ID < 16777216; }
 413         uint32 GetClientID() { return m_ID; }
 414         CServer *GetCurrentServer() { return m_CurrServer; }
 415
 416         //
 417         // Actions
 418         //
 419         void ConnectToServer(CServer* server);
 420         void ConnectToAnyServer();
 421         void StopConnectionTry();
 422         void Disconnect();
 423 };
 424
 425 class CServerListRem : public CRemoteContainer<CServer, uint32, CEC_Server_Tag> {
 426         uint32 m_TotalUser, m_TotalFile;
 427
 428         virtual void HandlePacket(const CECPacket *packet);
 429 public:
 430         CServerListRem(CRemoteConnect *);
 431         void GetUserFileStatus(uint32 &total_user, uint32 &total_file)
 432         {
 433                 total_user = m_TotalUser;
 434                 total_file = m_TotalFile;
 435         }
 436
 437         void UpdateUserFileStatus(CServer *server);
 438
 439         CServer* GetServerByAddress(const wxString& address, uint16 port) const;
 440         CServer* GetServerByIPTCP(uint32 nIP, uint16 nPort) const;
 441
 442         void ReloadControl();
 443
 444         //
 445         // Actions
 446         //
 447         void RemoveServer(CServer* server);
 448         void UpdateServerMetFromURL(wxString url);
 449         void SaveServerMet();
 450         void FilterServers();
 451
 452         //
 453         // template
 454         //
 455         CServer *CreateItem(CEC_Server_Tag *);
 456         void DeleteItem(CServer *);
 457         uint32 GetItemID(CServer *);
 458         void ProcessItemUpdate(CEC_Server_Tag *, CServer *);
 459 };
 460
 461 class CUpDownClientListRem : public CRemoteContainer<CUpDownClient, uint32, CEC_UpDownClient_Tag> {
 462         int m_viewtype;
 463 public:
 464         CUpDownClientListRem(CRemoteConnect *, int viewtype);
 465
 466         const CClientPtrList& GetList() const { return m_items; };
 467
 468         //
 469         // template
 470         //
 471         CUpDownClient *CreateItem(CEC_UpDownClient_Tag *);
 472         void DeleteItem(CUpDownClient *);
 473         uint32 GetItemID(CUpDownClient *);
 474         void ProcessItemUpdate(CEC_UpDownClient_Tag *, CUpDownClient *);
 475 };
 476
 477 class CUpQueueRem {
 478         CUpDownClientListRem m_up_list, m_wait_list;
 479 public:
 480         CUpQueueRem(CRemoteConnect *);
 481
 482         void ReQueryUp() { m_up_list.DoRequery(EC_OP_GET_ULOAD_QUEUE, EC_TAG_CLIENT); }
 483         void ReQueryWait() { m_wait_list.DoRequery(EC_OP_GET_WAIT_QUEUE, EC_TAG_CLIENT); }
 484
 485         const CClientPtrList& GetWaitingList() const { return m_wait_list.GetList(); }
 486         const CClientPtrList& GetUploadingList() const { return m_up_list.GetList(); }
 487         uint16 GetWaitingPosition(const CUpDownClient *client) const;
 488 };
 489
 490 class CDownQueueRem : public CRemoteContainer<CPartFile, CMD4Hash, CEC_PartFile_Tag> {
 491         std::map<CMD4Hash, PartFileEncoderData> m_enc_map;
 492 public:
 493         CDownQueueRem(CRemoteConnect *);
 494
 495         uint32 GetFileCount() { return GetCount(); }
 496         CPartFile* GetFileByID(const CMD4Hash& id) { return GetByID(id); }
 497         CPartFile* GetFileByIndex(unsigned int idx) { return GetByIndex(idx); }
 498
 499         bool IsPartFile(const CKnownFile* totest) const;
 500         void OnConnectionState(bool bConnected);
 501
 502         //
 503         // User actions
 504         //
 505         void Prio(CPartFile *file, uint8 prio);
 506         void AutoPrio(CPartFile *file, bool flag);
 507         void Category(CPartFile *file, uint8 cat);
 508
 509         void SendFileCommand(CPartFile *file, ec_tagname_t cmd);
 510         //
 511         // Actions
 512         //
 513         void StopUDPRequests();
 514         void AddFileLinkToDownload(CED2KFileLink*, uint8);
 515         bool AddLink(const wxString &link, int category = 0);
 516         void UnsetCompletedFilesExist();
 517         void ResetCatParts(int cat);
 518         void AddSearchToDownload(CSearchFile* toadd, uint8 category);
 519
 520         //
 521         // template
 522         //
 523         CPartFile *CreateItem(CEC_PartFile_Tag *);
 524         void DeleteItem(CPartFile *);
 525         CMD4Hash GetItemID(CPartFile *);
 526         void ProcessItemUpdate(CEC_PartFile_Tag *, CPartFile *);
 527         bool Phase1Done(const CECPacket *);
 528 };
 529
 530 class CSharedFilesRem : public CRemoteContainer<CKnownFile, CMD4Hash, CEC_SharedFile_Tag> {
 531         std::map<CMD4Hash, RLE_Data> m_enc_map;
 532
 533         virtual void HandlePacket(const CECPacket *);
 534
 535         //
 536         // For file renaming operation
 537         //
 538         CKnownFile* m_rename_file;
 539         wxString m_new_name;
 540 public:
 541         CSharedFilesRem(CRemoteConnect *);
 542
 543         CKnownFile *GetFileByID(CMD4Hash id) { return GetByID(id); }
 544
 545         void SetFilePrio(CKnownFile *file, uint8 prio);
 546
 547         //
 548         // Actions
 549         //
 550         void AddFilesFromDirectory(const CPath&);
 551         void Reload(bool sendtoserver = true, bool firstload = false);
 552         bool RenameFile(CKnownFile* file, const CPath& newName);
 553
 554         //
 555         // template
 556         //
 557         CKnownFile *CreateItem(CEC_SharedFile_Tag *);
 558         void DeleteItem(CKnownFile *);
 559         CMD4Hash GetItemID(CKnownFile *);
 560         void ProcessItemUpdate(CEC_SharedFile_Tag *, CKnownFile *);
 561         bool Phase1Done(const CECPacket *);
 562 };
 563
 564 class CKnownFilesRem {
 565         CSharedFilesRem *m_shared_files;
 566 public:
 567         CKnownFilesRem(CSharedFilesRem *shared)
 568         {
 569                 m_shared_files = shared;
 570
 571                 requested = 0;
 572                 transferred = 0;
 573                 accepted = 0;
 574         }
 575
 576         CKnownFile *FindKnownFileByID(const CMD4Hash& id)
 577         {
 578                 return m_shared_files->GetByID(id);
 579         }
 580
 581         uint16 requested;
 582         uint32 transferred;
 583         uint16 accepted;
 584 };
 585
 586 class CClientListRem {
 587         CRemoteConnect *m_conn;
 588
 589         //
 590         // map of user_ID -> client
 591         std::multimap<uint32, CUpDownClient*> m_client_list;
 592 public:
 593         CClientListRem(CRemoteConnect *);
 594
 595         const std::multimap<uint32, CUpDownClient*>& GetClientList() { return m_client_list; }
 596
 597         //
 598         // Actions
 599         //
 600         void AddClient(CUpDownClient *);
 601         void FilterQueues();
 602 };
 603
 604 class CIPFilterRem {
 605         CRemoteConnect *m_conn;
 606 public:
 607         CIPFilterRem(CRemoteConnect *conn);
 608
 609         //
 610         // Actions
 611         //
 612         void Reload();
 613         void Update(wxString strURL = wxEmptyString);
 614 };
 615
 616 class CSearchListRem : public CRemoteContainer<CSearchFile, CMD4Hash, CEC_SearchFile_Tag> {
 617         virtual void HandlePacket(const CECPacket *);
 618 public:
 619         CSearchListRem(CRemoteConnect *);
 620
 621         int m_curr_search;
 622         typedef std::map<long, CSearchResultList> ResultMap;
 623         ResultMap m_results;
 624
 625         const CSearchResultList& GetSearchResults(long nSearchID);
 626         void RemoveResults(long nSearchID);
 627         const CSearchResultList& GetSearchResults(long nSearchID) const;
 628         //
 629         // Actions
 630         //
 631
 632         wxString StartNewSearch(uint32* nSearchID, SearchType search_type,
 633                 const CSearchList::CSearchParams& params);
 634
 635         void StopGlobalSearch();
 636
 637         //
 638         // template
 639         //
 640         CSearchFile *CreateItem(CEC_SearchFile_Tag *);
 641         void DeleteItem(CSearchFile *);
 642         CMD4Hash GetItemID(CSearchFile *);
 643         void ProcessItemUpdate(CEC_SearchFile_Tag *, CSearchFile *);
 644         bool Phase1Done(const CECPacket *);
 645 };
 646
 647 class CStatsUpdaterRem : public CECPacketHandlerBase {
 648         virtual void HandlePacket(const CECPacket *);
 649 public:
 650         CStatsUpdaterRem() {}
 651 };
 652
 653 class CListenSocketRem {
 654         uint32 m_peak_connections;
 655 public:
 656         uint32 GetPeakConnections() { return m_peak_connections; }
 657 };
 658
 659 class CamuleRemoteGuiApp : public wxApp, public CamuleGuiBase {
 660         wxTimer* poll_timer;
 661
 662         virtual int InitGui(bool geometry_enable, wxString &geometry_string);
 663
 664         bool OnInit();
 665
 666         int OnExit();
 667
 668         void OnPollTimer(wxTimerEvent& evt);
 669
 670         void OnECConnection(wxEvent& event);
 671         void OnECInitDone(wxEvent& event);
 672         void OnNotifyEvent(CMuleGUIEvent& evt);
 673         void OnFinishedHTTPDownload(CMuleInternalEvent& event);
 674
 675         CStatsUpdaterRem m_stats_updater;
 676 public:
 677
 678         void Startup();
 679
 680         bool ShowConnectionDialog();
 681
 682         class CRemoteConnect *m_connect;
 683
 684         CEConnectDlg *dialog;
 685
 686         bool CopyTextToClipboard(wxString strText);
 687
 688         virtual void ShowAlert(wxString msg, wxString title, int flags);
 689
 690         void ShutDown(wxCloseEvent &evt);
 691
 692         CPreferencesRem *glob_prefs;
 693         wxString ConfigDir;
 694
 695         //
 696         // Provide access to core data thru EC
 697         CServerConnectRem *serverconnect;
 698         CServerListRem *serverlist;
 699         CUpQueueRem *uploadqueue;
 700         CDownQueueRem *downloadqueue;
 701         CSharedFilesRem *sharedfiles;
 702         CKnownFilesRem *knownfiles;
 703         CClientListRem *clientlist;
 704         CIPFilterRem *ipfilter;
 705         CSearchListRem *searchlist;
 706         CListenSocketRem *listensocket;
 707
 708         CStatistics *m_statistics;
 709
 710         bool AddServer(CServer *srv, bool fromUser = false);
 711
 712         uint32 GetPublicIP();
 713         wxString CreateMagnetLink(const CAbstractFile *f);
 714         wxString CreateED2kLink(const CAbstractFile* f, bool add_source = false, bool use_hostname = false, bool addcryptoptions = false);
 715         wxString CreateED2kAICHLink(const CKnownFile* f);
 716
 717         wxString GetLog(bool reset = false);
 718         wxString GetServerLog(bool reset = false);
 719
 720         void AddServerMessageLine(wxString &msg);
 721         void AddRemoteLogLine(const wxString& line);
 722
 723         void SetOSFiles(wxString ) { /* onlinesig is created on remote side */ }
 724
 725         bool IsConnected() const { return IsConnectedED2K() || IsConnectedKad(); }
 726         bool IsFirewalled() const;
 727         bool IsConnectedED2K() const;
 728         bool IsConnectedKad() const
 729         {
 730                 return ((m_ConnState & CONNECTED_KAD_OK)
 731                                 || (m_ConnState & CONNECTED_KAD_FIREWALLED));
 732         }
 733         bool IsFirewalledKad() const { return (m_ConnState & CONNECTED_KAD_FIREWALLED) != 0; }
 734
 735         bool IsKadRunning() const { return ((m_ConnState & CONNECTED_KAD_OK)
 736                                 || (m_ConnState & CONNECTED_KAD_FIREWALLED)
 737                                 || (m_ConnState & CONNECTED_KAD_NOT)); }
 738
 739         // Check Kad state (UDP)
 740         bool IsFirewalledKadUDP() const         { return theStats::IsFirewalledKadUDP(); }
 741         // Kad stats
 742         uint32 GetKadUsers() const                      { return theStats::GetKadUsers(); }
 743         uint32 GetKadFiles() const                      { return theStats::GetKadFiles(); }
 744         uint32 GetKadIndexedSources() const     { return theStats::GetKadIndexedSources(); }
 745         uint32 GetKadIndexedKeywords() const{ return theStats::GetKadIndexedKeywords(); }
 746         uint32 GetKadIndexedNotes() const       { return theStats::GetKadIndexedNotes(); }
 747         uint32 GetKadIndexedLoad() const        { return theStats::GetKadIndexedLoad(); }
 748         // True IP of machine
 749         uint32 GetKadIPAdress() const           { return theStats::GetKadIPAdress(); }
 750         // Buddy status
 751         uint8   GetBuddyStatus() const          { return theStats::GetBuddyStatus(); }
 752         uint32  GetBuddyIP() const                      { return theStats::GetBuddyIP(); }
 753         uint32  GetBuddyPort() const            { return theStats::GetBuddyPort(); }
 754
 755         void StartKad();
 756         void StopKad();
 757
 758         /** Bootstraps kad from the specified IP (must be in hostorder). */
 759         void BootstrapKad(uint32 ip, uint16 port);
 760         /** Updates the nodes.dat file from the specified url. */
 761         void UpdateNotesDat(const wxString& str);
 762
 763         void DisconnectED2K();
 764
 765         bool CryptoAvailable() const;
 766
 767         uint32 GetED2KID() const;
 768         uint32 GetID() const;
 769         void ShowUserCount();
 770
 771         uint8 m_ConnState;
 772         uint32 m_clientID;
 773
 774         wxLocale        m_locale;
 775
 776         DECLARE_EVENT_TABLE()
 777 };
 778
 779 DECLARE_APP(CamuleRemoteGuiApp)
 780 #ifdef AMULE_REMOTE_GUI_CPP
 781         CamuleRemoteGuiApp *theApp;
 782 #else
 783         extern CamuleRemoteGuiApp *theApp;
 784 #endif
 785
 786
 787 #endif /* AMULE_REMOTE_GUI_H */
 788
 789 // File_checked_for_headers