source/actmgr/frmActivityMgr-tasks.cpp

   1 // frmActivityMgr-addtask.cpp - Activity Manager add task subroutines.
   2 //
   3 // (c) 2012-2015 Xestia Software Development.
   4 //
   5 // This file is part of Xestia Address Book.
   6 //
   7 // Xestia Address Book is free software: you can redistribute it and/or modify
   8 // it under the terms of the GNU General Public License as published by the
   9 // Free Software Foundation, version 3 of the license.
  10 //
  11 // Xestia Address Book is distributed in the hope that it will be useful,
  12 // but WITHOUT ANY WARRANTY; without even the implied warranty of
  13 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  14 // GNU General Public License for more details.
  15 //
  16 // You should have received a copy of the GNU General Public License along
  17 // with Xestia Address Book. If not, see <http://www.gnu.org/licenses/>
  18
  19 #include "frmActivityMgr.h"
  20
  21 int frmActivityMgr::AddTask(int TaskType, wxString TaskDetail, wxString TaskAccount,
  22         wxString TaskURL, wxString TaskFilename, wxString TaskFullFilename,
  23         wxString TaskData){
  24
  25         ActivityTaskID++;
  26
  27         wxListItem coldata;
  28         long itemindex = -1;
  29         CardDAV* CardDAVConn = new CardDAV;
  30
  31         coldata.SetId(ActivityTaskID);
  32         coldata.SetData(ActivityTaskID);
  33
  34         AnimationTimer.StartAnimation();
  35
  36         // Get the preferences file.
  37
  38         wxString PrefFilename = GetUserPrefDir();
  39
  40         XABPreferences PrefData(PrefFilename);
  41
  42         wxString AccountName;
  43         wxString AccountDir;
  44         wxString AccountAddress;
  45         int AccountPort = 0;
  46         wxString AccountUsername;
  47         wxString AccountPassword;
  48         bool AccountSSL = FALSE;
  49         wxString AccountPrefix;
  50
  51         // Look for the account and get the friendly name for the account.
  52
  53         for (int i = 0; i < PrefData.accounts.GetCount(); i++){
  54
  55                 AccountDir = PrefData.accounts.GetAccountDirectory(i);
  56
  57                 AccountDir.Trim();
  58                 AccountDir.Append(wxT(".carddav"));
  59
  60                 if (AccountDir == TaskAccount){
  61
  62                         AccountName = PrefData.accounts.GetAccountName(i);
  63                         AccountAddress = PrefData.accounts.GetAccountAddress(i);
  64                         AccountPort = PrefData.accounts.GetAccountPort(i);
  65                         AccountUsername = PrefData.accounts.GetAccountUsername(i);
  66                         AccountPassword = PrefData.accounts.GetAccountPassword(i);
  67                         AccountPrefix = PrefData.accounts.GetAccountDirPrefix(i);
  68                         AccountSSL = PrefData.accounts.GetAccountSSL(i);
  69
  70                         AccountName.Trim();
  71                         AccountAddress.Trim();
  72                         //AccountPort.Trim();
  73                         AccountUsername.Trim();
  74                         AccountPassword.Trim();
  75                         AccountPrefix.Trim();
  76                         break;
  77
  78                 }
  79
  80         }
  81
  82         ActivityMgrAccountSettings AccountSettings;
  83         AccountSettings.Address = AccountAddress;
  84         AccountSettings.Port = AccountPort;
  85         AccountSettings.Username = AccountUsername;
  86         AccountSettings.Password = AccountPassword;
  87         AccountSettings.SSL = AccountSSL;
  88         AccountSettings.Prefix = AccountPrefix;
  89         AccountSettings.Dir = AccountDir;
  90
  91         CardDAVConn->SetupConnection(AccountAddress, AccountPort, AccountUsername, AccountPassword, AccountSSL, AccountPrefix, AccountDir);
  92         CardDAVConn->SetupVariables(&ActivityList, ActivityTaskID);
  93         CardDAVConn->SetupResultBools(&BlankBool, &BlankBool);
  94
  95         // TaskType:
  96         // 0 - Add a contact.
  97         // 1 - Update a contact.
  98         // 2 - Delete a contact.
  99         // 3 - Account syncronisation.
 100
 101         if (TaskType == 0){
 102
 103                 coldata.SetText(_("Adding Contact '") + TaskDetail + _("'"));
 104                 itemindex = lstActivity->InsertItem(coldata);
 105
 106                 lstActivity->SetItem(itemindex, 1, AccountName);
 107                 lstActivity->SetItem(itemindex, 2, _("Queued"));
 108
 109                 CardDAVConn->SetUploadMode(TRUE);
 110                 CardDAVConn->SetupData(wxT("PUT"), TaskURL, TaskData);
 111
 112                 // Setup all of the task details.
 113
 114                 ETagDB *ETagDBPtr = ETagTmrPtr->GetPointer(AccountDir);
 115
 116                 ActivityListType.insert(std::make_pair(ActivityTaskID, 0));
 117                 ActivityListData.insert(std::make_pair(ActivityTaskID, TaskData));
 118                 ActivityListURL.insert(std::make_pair(ActivityTaskID, TaskURL));
 119                 ActivityListEditMode.insert(std::make_pair(ActivityTaskID, false));
 120                 ActivityListConn.insert(std::make_pair(ActivityTaskID, CardDAVConn));
 121                 ActivityListIndex.insert(std::make_pair(ActivityTaskID, itemindex));
 122                 ActivityListTaskDetail.insert(std::make_pair(ActivityTaskID, TaskDetail));
 123                 ActivityListAccount.insert(std::make_pair(ActivityTaskID, TaskAccount));
 124                 ActivityListFilename.insert(std::make_pair(ActivityTaskID, TaskFilename));
 125                 ActivityListFullFilename.insert(std::make_pair(ActivityTaskID, TaskFullFilename));
 126                 ActivityListAccSettings.insert(std::make_pair(ActivityTaskID, AccountSettings));
 127
 128                 ActivityListETag.insert(std::make_pair(ActivityTaskID, ETagDBPtr->GetETag(TaskFilename)));
 129                 ActivityListETagOriginal.insert(std::make_pair(ActivityTaskID, ETagDBPtr->GetETagOriginal(TaskFilename)));
 130                 ActivityList.insert(std::make_pair(ActivityTaskID, 0));
 131
 132         } else if (TaskType == 1){
 133
 134                 coldata.SetText(_("Updating Contact '") + TaskDetail + _("'"));
 135                 itemindex = lstActivity->InsertItem(coldata);
 136
 137                 lstActivity->SetItem(itemindex, 1, AccountName);
 138                 lstActivity->SetItem(itemindex, 2, _("Queued"));
 139
 140                 ETagDB *ETagDBPtr = ETagTmrPtr->GetPointer(AccountDir);
 141
 142                 ActivityListType.insert(std::make_pair(ActivityTaskID, 1));
 143                 ActivityListData.insert(std::make_pair(ActivityTaskID, TaskData));
 144                 ActivityListURL.insert(std::make_pair(ActivityTaskID, TaskURL));
 145                 ActivityListEditMode.insert(std::make_pair(ActivityTaskID, true));
 146                 ActivityListIndex.insert(std::make_pair(ActivityTaskID, itemindex));
 147                 ActivityListTaskDetail.insert(std::make_pair(ActivityTaskID, TaskDetail));
 148                 ActivityListAccount.insert(std::make_pair(ActivityTaskID, TaskAccount));
 149                 ActivityListFilename.insert(std::make_pair(ActivityTaskID, TaskFilename));
 150                 ActivityListFullFilename.insert(std::make_pair(ActivityTaskID, TaskFullFilename));
 151                 ActivityListAccSettings.insert(std::make_pair(ActivityTaskID, AccountSettings));
 152
 153                 ActivityListETag.insert(std::make_pair(ActivityTaskID, ETagDBPtr->GetETag(TaskFilename)));
 154                 ActivityListETagOriginal.insert(std::make_pair(ActivityTaskID, ETagDBPtr->GetETagOriginal(TaskFilename)));
 155                 ActivityList.insert(std::make_pair(ActivityTaskID, 0));
 156
 157         } else if (TaskType == 2){
 158
 159                 coldata.SetText(_("Deleting Contact '") + TaskDetail + _("'"));
 160                 itemindex = lstActivity->InsertItem(coldata);
 161
 162                 lstActivity->SetItem(itemindex, 1, AccountName);
 163                 lstActivity->SetItem(itemindex, 2, _("Queued"));
 164
 165                 ETagDB *ETagDBPtr = ETagTmrPtr->GetPointer(AccountDir);
 166
 167                 ActivityList.insert(std::make_pair(ActivityTaskID, 0));
 168                 ActivityListType.insert(std::make_pair(ActivityTaskID, 2));
 169                 ActivityListData.insert(std::make_pair(ActivityTaskID, TaskData));
 170                 ActivityListAccount.insert(std::make_pair(ActivityTaskID, TaskAccount));
 171                 ActivityListFilename.insert(std::make_pair(ActivityTaskID, TaskFilename));
 172                 ActivityListIndex.insert(std::make_pair(ActivityTaskID, itemindex));
 173                 ActivityListAccSettings.insert(std::make_pair(ActivityTaskID, AccountSettings));
 174
 175         } else if (TaskType == 3){
 176
 177                 coldata.SetText(_("Syncronising All Contacts"));
 178                 itemindex = lstActivity->InsertItem(coldata);
 179
 180                 lstActivity->SetItem(itemindex, 1, AccountName);
 181                 lstActivity->SetItem(itemindex, 2, _("Queued"));
 182
 183                 ActivityList.insert(std::make_pair(ActivityTaskID, 0));
 184                 ActivityListType.insert(std::make_pair(ActivityTaskID, 3));
 185                 ActivityListData.insert(std::make_pair(ActivityTaskID, TaskData));
 186                 ActivityListConn.insert(std::make_pair(ActivityTaskID, CardDAVConn));
 187                 ActivityListTaskDetail.insert(std::make_pair(ActivityTaskID, AccountPrefix));
 188                 ActivityListAccount.insert(std::make_pair(ActivityTaskID, TaskAccount));
 189                 ActivityListIndex.insert(std::make_pair(ActivityTaskID, itemindex));
 190                 ActivityListAccSettings.insert(std::make_pair(ActivityTaskID, AccountSettings));
 191
 192         }
 193
 194         ProcessTasksData = TRUE;
 195
 196         if (!ActProcessTimer.IsRunning()) {
 197
 198                 wxCommandEvent event(ACTMGR_STARTTIMER);
 199                 wxPostEvent(this, event);
 200
 201                 wxCommandEvent eventp(ACTMGR_STARTPROCESSTIMER);
 202                 wxPostEvent(this, eventp);
 203
 204                 //ActProcessTimer.Start(1000, FALSE);
 205                 //ActListProcTimer.Start(1000, FALSE);
 206
 207         }
 208
 209         // Update the recovery database.
 210
 211         return ActivityTaskID;
 212
 213 }
 214
 215 void frmActivityMgr::RemoveTask(){
 216
 217         // Remove task from the recovery database.
 218
 219 }
 220
 221 void frmActivityMgr::StopTask( wxCommandEvent& event ){
 222
 223         // Check if activity has been completed already before stopping.
 224
 225         long longSelected = -1;
 226         int intSelectedData = 0;
 227
 228         longSelected = lstActivity->GetNextItem(longSelected,
 229                 wxLIST_NEXT_ALL,
 230                 wxLIST_STATE_SELECTED);
 231
 232         intSelectedData = (int)lstActivity->GetItemData(longSelected);
 233
 234         if (longSelected == -1){
 235                 return;
 236         }
 237
 238         std::map<int,CardDAV*>::iterator CDAVter;
 239
 240         CDAVter = ActivityListConn.find(intSelectedData);
 241
 242         CDAVter->second->Abort();
 243
 244         lstActivity->SetItem(longSelected, 2, _("Stopped"));
 245
 246 }
 247
 248 void frmActivityMgr::StopAllTasks( wxCommandEvent& event ){
 249
 250         // Check if activity has been completed already before stopping.
 251
 252         // TODO: Look through for '1' and stop the running task(s).
 253
 254         long longSelected = -1;
 255         int intSelectedData = 0;
 256
 257         longSelected = lstActivity->GetNextItem(longSelected,
 258                 wxLIST_NEXT_ALL,
 259                 wxLIST_STATE_SELECTED);
 260
 261         intSelectedData = (int)lstActivity->GetItemData(longSelected);
 262
 263         if (longSelected == -1){
 264                 return;
 265         }
 266
 267         std::map<int,CardDAV*>::iterator CDAVter;
 268
 269         CDAVter = ActivityListConn.find(intSelectedData);
 270
 271         CDAVter->second->Abort();
 272
 273         lstActivity->SetItem(longSelected, 2, _("Stopped"));
 274         AnimationTimer.StopAnimation();
 275         bmpActivity->SetBitmap(SleepBitmap);
 276         lblDetails->SetLabel(_("No activity."));
 277
 278 }
 279
 280 void frmActivityMgr::RetryTask( wxCommandEvent& event ){
 281
 282         // Check if activity has been completed already before retrying.
 283
 284         long longSelected = -1;
 285         int intSelectedData = 0;
 286
 287         longSelected = lstActivity->GetNextItem(longSelected,
 288                 wxLIST_NEXT_ALL,
 289                 wxLIST_STATE_SELECTED);
 290
 291         intSelectedData = (int)lstActivity->GetItemData(longSelected);
 292
 293         if (longSelected == -1){
 294                 return;
 295         }
 296
 297         std::map<int,CardDAV*>::iterator CDAVter;
 298
 299         CDAVter = ActivityListConn.find(intSelectedData);
 300
 301         // Restart the task.
 302
 303         //CDAVter->second.Abort();
 304
 305         std::map<int,int>::iterator Iter;
 306         Iter = ActivityList.find(intSelectedData);
 307
 308         Iter->second = 0;
 309
 310         AnimationTimer.StartAnimation();
 311
 312         if (!ActProcessTimer.IsRunning()) {
 313
 314                 ActProcessTimer.Start(150, FALSE);
 315                 ActListProcTimer.Start(150, FALSE);
 316
 317         }
 318
 319         //lstActivity->SetItem(longSelected, 2, _("Processing..."));
 320
 321 }
 322
 323 int frmActivityMgr::GetTaskStatus(int intTaskID){
 324
 325         int intResult = 2;
 326
 327         if (ActivityList.find(intTaskID) == ActivityList.end()){
 328
 329                 return intResult;
 330
 331         }
 332
 333         std::map<int,int>::iterator taskiter = ActivityList.find(intTaskID);
 334         intResult = taskiter->second;
 335
 336         return intResult;
 337
 338 }