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                 CardDAV2 *ConnObject = new CardDAV2(AccountAddress.ToStdString(), AccountPort, AccountUsername.ToStdString(), AccountPassword.ToStdString(), AccountSSL, AccountPrefix.ToStdString(), AccountDir.ToStdString());
 121                 ConnObject->SetupConnectionObject();
 122
 123                 ActivityListType.insert(std::make_pair(ActivityTaskID, 0));
 124                 ActivityListData.insert(std::make_pair(ActivityTaskID, TaskData));
 125                 ActivityListURL.insert(std::make_pair(ActivityTaskID, TaskURL));
 126                 ActivityListEditMode.insert(std::make_pair(ActivityTaskID, false));
 127                 ActivityListConn.insert(std::make_pair(ActivityTaskID, CardDAVConn));
 128                 ActivityListConnObject.insert(std::make_pair(ActivityTaskID, ConnObject));
 129                 ActivityListIndex.insert(std::make_pair(ActivityTaskID, itemindex));
 130                 ActivityListTaskDetail.insert(std::make_pair(ActivityTaskID, TaskDetail));
 131                 ActivityListAccount.insert(std::make_pair(ActivityTaskID, TaskAccount));
 132                 ActivityListFilename.insert(std::make_pair(ActivityTaskID, TaskFilename));
 133                 ActivityListFullFilename.insert(std::make_pair(ActivityTaskID, TaskFullFilename));
 134                 ActivityListAccSettings.insert(std::make_pair(ActivityTaskID, AccountSettings));
 135
 136                 ActivityListETag.insert(std::make_pair(ActivityTaskID, ETagDBPtr->GetETag(TaskFilename)));
 137                 ActivityListETagOriginal.insert(std::make_pair(ActivityTaskID, ETagDBPtr->GetETagOriginal(TaskFilename)));
 138                 ActivityList.insert(std::make_pair(ActivityTaskID, 0));
 139
 140         } else if (TaskType == 1){
 141
 142                 coldata.SetText(_("Updating Contact '") + TaskDetail + _("'"));
 143                 itemindex = lstActivity->InsertItem(coldata);
 144
 145                 lstActivity->SetItem(itemindex, 1, AccountName);
 146                 lstActivity->SetItem(itemindex, 2, _("Queued"));
 147
 148                 ETagDB *ETagDBPtr = ETagTmrPtr->GetPointer(AccountDir);
 149
 150                 CardDAV2 *ConnObject = new CardDAV2(AccountAddress.ToStdString(), AccountPort, AccountUsername.ToStdString(), AccountPassword.ToStdString(), AccountSSL, AccountPrefix.ToStdString(), AccountDir.ToStdString());
 151                 ConnObject->SetupConnectionObject();
 152
 153                 ActivityListType.insert(std::make_pair(ActivityTaskID, 1));
 154                 ActivityListData.insert(std::make_pair(ActivityTaskID, TaskData));
 155                 ActivityListURL.insert(std::make_pair(ActivityTaskID, TaskURL));
 156                 ActivityListEditMode.insert(std::make_pair(ActivityTaskID, true));
 157                 ActivityListConnObject.insert(std::make_pair(ActivityTaskID, ConnObject));
 158                 ActivityListIndex.insert(std::make_pair(ActivityTaskID, itemindex));
 159                 ActivityListTaskDetail.insert(std::make_pair(ActivityTaskID, TaskDetail));
 160                 ActivityListAccount.insert(std::make_pair(ActivityTaskID, TaskAccount));
 161                 ActivityListFilename.insert(std::make_pair(ActivityTaskID, TaskFilename));
 162                 ActivityListFullFilename.insert(std::make_pair(ActivityTaskID, TaskFullFilename));
 163                 ActivityListAccSettings.insert(std::make_pair(ActivityTaskID, AccountSettings));
 164
 165                 ActivityListETag.insert(std::make_pair(ActivityTaskID, ETagDBPtr->GetETag(TaskFilename)));
 166                 ActivityListETagOriginal.insert(std::make_pair(ActivityTaskID, ETagDBPtr->GetETagOriginal(TaskFilename)));
 167                 ActivityList.insert(std::make_pair(ActivityTaskID, 0));
 168
 169         } else if (TaskType == 2){
 170
 171                 coldata.SetText(_("Deleting Contact '") + TaskDetail + _("'"));
 172                 itemindex = lstActivity->InsertItem(coldata);
 173
 174                 lstActivity->SetItem(itemindex, 1, AccountName);
 175                 lstActivity->SetItem(itemindex, 2, _("Queued"));
 176
 177                 ETagDB *ETagDBPtr = ETagTmrPtr->GetPointer(AccountDir);
 178
 179                 ActivityList.insert(std::make_pair(ActivityTaskID, 0));
 180                 ActivityListType.insert(std::make_pair(ActivityTaskID, 2));
 181                 ActivityListData.insert(std::make_pair(ActivityTaskID, TaskData));
 182                 ActivityListAccount.insert(std::make_pair(ActivityTaskID, TaskAccount));
 183                 ActivityListFilename.insert(std::make_pair(ActivityTaskID, TaskFilename));
 184                 ActivityListIndex.insert(std::make_pair(ActivityTaskID, itemindex));
 185                 ActivityListAccSettings.insert(std::make_pair(ActivityTaskID, AccountSettings));
 186
 187         } else if (TaskType == 3){
 188
 189                 coldata.SetText(_("Syncronising All Contacts"));
 190                 itemindex = lstActivity->InsertItem(coldata);
 191
 192                 lstActivity->SetItem(itemindex, 1, AccountName);
 193                 lstActivity->SetItem(itemindex, 2, _("Queued"));
 194
 195                 ActivityList.insert(std::make_pair(ActivityTaskID, 0));
 196                 ActivityListType.insert(std::make_pair(ActivityTaskID, 3));
 197                 ActivityListData.insert(std::make_pair(ActivityTaskID, TaskData));
 198                 ActivityListConn.insert(std::make_pair(ActivityTaskID, CardDAVConn));
 199                 ActivityListTaskDetail.insert(std::make_pair(ActivityTaskID, AccountPrefix));
 200                 ActivityListAccount.insert(std::make_pair(ActivityTaskID, TaskAccount));
 201                 ActivityListIndex.insert(std::make_pair(ActivityTaskID, itemindex));
 202                 ActivityListAccSettings.insert(std::make_pair(ActivityTaskID, AccountSettings));
 203
 204         }
 205
 206         ProcessTasksData = TRUE;
 207
 208         if (!ActProcessTimer.IsRunning() && ApplicationSleepMode == FALSE) {
 209
 210                 wxCommandEvent event(ACTMGR_STARTTIMER);
 211                 wxPostEvent(this, event);
 212
 213                 wxCommandEvent eventp(ACTMGR_STARTPROCESSTIMER);
 214                 wxPostEvent(this, eventp);
 215
 216                 //ActProcessTimer.Start(1000, FALSE);
 217                 //ActListProcTimer.Start(1000, FALSE);
 218
 219         }
 220
 221         // Update the recovery database.
 222
 223         return ActivityTaskID;
 224
 225 }
 226
 227 void frmActivityMgr::RemoveTask(){
 228
 229         // Remove task from the recovery database.
 230
 231 }
 232
 233 void frmActivityMgr::StopTask( wxCommandEvent& event ){
 234
 235         // Check if activity has been completed already before stopping.
 236
 237         long longSelected = -1;
 238         int intSelectedData = 0;
 239
 240         longSelected = lstActivity->GetNextItem(longSelected,
 241                 wxLIST_NEXT_ALL,
 242                 wxLIST_STATE_SELECTED);
 243
 244         intSelectedData = (int)lstActivity->GetItemData(longSelected);
 245
 246         if (longSelected == -1){
 247                 return;
 248         }
 249
 250         std::map<int,CardDAV*>::iterator CDAVter;
 251
 252         CDAVter = ActivityListConn.find(intSelectedData);
 253
 254         CDAVter->second->Abort();
 255
 256         lstActivity->SetItem(longSelected, 2, _("Stopped"));
 257
 258 }
 259
 260 void frmActivityMgr::StopAllTasks( wxCommandEvent& event ){
 261
 262         // Check if activity has been completed already before stopping.
 263
 264         // TODO: Look through for '1' and stop the running task(s).
 265
 266         long longSelected = -1;
 267         int intSelectedData = 0;
 268
 269         longSelected = lstActivity->GetNextItem(longSelected,
 270                 wxLIST_NEXT_ALL,
 271                 wxLIST_STATE_SELECTED);
 272
 273         intSelectedData = (int)lstActivity->GetItemData(longSelected);
 274
 275         if (longSelected == -1){
 276                 return;
 277         }
 278
 279         std::map<int,CardDAV*>::iterator CDAVter;
 280
 281         CDAVter = ActivityListConn.find(intSelectedData);
 282
 283         CDAVter->second->Abort();
 284
 285         lstActivity->SetItem(longSelected, 2, _("Stopped"));
 286         AnimationTimer.StopAnimation();
 287         bmpActivity->SetBitmap(SleepBitmap);
 288         lblDetails->SetLabel(_("No activity."));
 289
 290 }
 291
 292 void frmActivityMgr::RetryTask( wxCommandEvent& event ){
 293
 294         // Check if activity has been completed already before retrying.
 295
 296         long longSelected = -1;
 297         int intSelectedData = 0;
 298
 299         longSelected = lstActivity->GetNextItem(longSelected,
 300                 wxLIST_NEXT_ALL,
 301                 wxLIST_STATE_SELECTED);
 302
 303         intSelectedData = (int)lstActivity->GetItemData(longSelected);
 304
 305         if (longSelected == -1){
 306                 return;
 307         }
 308
 309         std::map<int,CardDAV*>::iterator CDAVter;
 310
 311         CDAVter = ActivityListConn.find(intSelectedData);
 312
 313         // Restart the task.
 314
 315         //CDAVter->second.Abort();
 316
 317         std::map<int,int>::iterator Iter;
 318         Iter = ActivityList.find(intSelectedData);
 319
 320         Iter->second = 0;
 321
 322         AnimationTimer.StartAnimation();
 323
 324         if (!ActProcessTimer.IsRunning()) {
 325
 326                 ActProcessTimer.Start(150, FALSE);
 327                 ActListProcTimer.Start(150, FALSE);
 328
 329         }
 330
 331         //lstActivity->SetItem(longSelected, 2, _("Processing..."));
 332
 333 }
 334
 335 int frmActivityMgr::GetTaskStatus(int intTaskID){
 336
 337         int intResult = 2;
 338
 339         if (ActivityList.find(intTaskID) == ActivityList.end()){
 340
 341                 return intResult;
 342
 343         }
 344
 345         std::map<int,int>::iterator taskiter = ActivityList.find(intTaskID);
 346         intResult = taskiter->second;
 347
 348         return intResult;
 349
 350 }