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