src/applications/calendar/worker/PhabricatorCalendarImportReloadWorker.php

   1 <?php
   2
   3 final class PhabricatorCalendarImportReloadWorker extends PhabricatorWorker {
   4
   5   const VIA_TRIGGER = 'trigger';
   6   const VIA_BACKGROUND = 'background';
   7
   8   protected function doWork() {
   9     $import = $this->loadImport();
  10     $viewer = PhabricatorUser::getOmnipotentUser();
  11
  12     if ($import->getIsDisabled()) {
  13       return;
  14     }
  15
  16     $author = id(new PhabricatorPeopleQuery())
  17       ->setViewer($viewer)
  18       ->withPHIDs(array($import->getAuthorPHID()))
  19       ->needUserSettings(true)
  20       ->executeOne();
  21
  22     $import_engine = $import->getEngine();
  23
  24     $data = $this->getTaskData();
  25     $import->newLogMessage(
  26       PhabricatorCalendarImportTriggerLogType::LOGTYPE,
  27       array(
  28         'via' => idx($data, 'via', self::VIA_TRIGGER),
  29       ));
  30
  31     $import_engine->importEventsFromSource($author, $import, false);
  32   }
  33
  34   private function loadImport() {
  35     $viewer = PhabricatorUser::getOmnipotentUser();
  36
  37     $data = $this->getTaskData();
  38     $import_phid = idx($data, 'importPHID');
  39
  40     $import = id(new PhabricatorCalendarImportQuery())
  41       ->setViewer($viewer)
  42       ->withPHIDs(array($import_phid))
  43       ->executeOne();
  44     if (!$import) {
  45       throw new PhabricatorWorkerPermanentFailureException(
  46         pht(
  47           'Failed to load import with PHID "%s".',
  48           $import_phid));
  49     }
  50
  51     return $import;
  52   }
  53
  54 }