Commit + Herald integration.

Author: epriestley

scripts/__init_env__.php

@@ -33,6 +33,7 @@
 phutil_require_module('phabricator', 'infrastructure/env');
 PhabricatorEnv::setEnvConfig($conf);
 
+phutil_load_library('arcanist/src');
 
 foreach (PhabricatorEnv::getEnvConfig('load-libraries') as $library) {
   phutil_load_library($library);

scripts/__init_script__.php

@@ -26,9 +26,3 @@
 }
 
 phutil_load_library(dirname(__FILE__).'/../src/');
-
-phutil_require_module('phutil', 'symbols');
-
-function __autoload($class) {
-  PhutilSymbolLoader::loadClass($class);
-}

scripts/repository/parse_one_commit.php

@@ -22,7 +22,7 @@
 require_once $root.'/scripts/__init_env__.php';
 
 if (empty($argv[1])) {
-  echo "usage: parse_one_commit.php <commit_name>\n";
+  echo "usage: parse_one_commit.php <commit_name> [--herald]\n";
   die(1);
 }
 
@@ -72,6 +72,10 @@
     throw new Exception("Unknown repository type!");
 }
 
+if (isset($argv[2]) && $argv[2] == '--herald') {
+  $workers[] = new PhabricatorRepositoryCommitHeraldWorker($spec);
+}
+
 ExecFuture::pushEchoMode(true);
 
 foreach ($workers as $worker) {

src/applications/herald/adapter/commit/HeraldCommitAdapter.php

@@ -46,7 +46,7 @@ public function getPHID() {
   }
 
   public function getEmailPHIDs() {
-    return $this->emailPHIDs;
+    return array_keys($this->emailPHIDs);
   }
 
   public function getHeraldName() {
@@ -195,7 +195,7 @@ public function applyHeraldEffects(array $effects) {
           break;
         case HeraldActionConfig::ACTION_EMAIL:
           foreach ($effect->getTarget() as $fbid) {
-            $this->emailPHIDs[] = $fbid;
+            $this->emailPHIDs[$fbid] = true;
           }
           $result[] = new HeraldApplyTranscript(
             $effect,

src/applications/metamta/controller/send/PhabricatorMetaMTASendController.php

@@ -33,7 +33,8 @@ public function processRequest() {
       $mail->setSimulatedFailureCount($request->getInt('failures'));
       $mail->setIsHTML($request->getInt('html'));
       $mail->save();
-      if ($request->getInt('immediately')) {
+      if ($request->getInt('immediately') &&
+          !PhabricatorEnv::getEnvConfig('metamta.send-immediately')) {
         $mail->sendNow($force_send = true);
       }
 

src/applications/metamta/controller/send/__init__.php

@@ -9,6 +9,7 @@
 phutil_require_module('phabricator', 'aphront/response/redirect');
 phutil_require_module('phabricator', 'applications/metamta/controller/base');
 phutil_require_module('phabricator', 'applications/metamta/storage/mail');
+phutil_require_module('phabricator', 'infrastructure/env');
 phutil_require_module('phabricator', 'view/form/base');
 phutil_require_module('phabricator', 'view/form/control/submit');
 phutil_require_module('phabricator', 'view/layout/panel');

src/applications/repository/worker/commitchangeparser/base/PhabricatorRepositoryCommitChangeParserWorker.php

@@ -71,5 +71,17 @@ private function lookupPaths(array $paths) {
     return $result_map;
   }
 
+  protected function finishParse() {
+    $commit = $this->commit;
+    if ($this->shouldQueueFollowupTasks()) {
+      $task = new PhabricatorWorkerTask();
+      $task->setTaskClass('PhabricatorRepositoryCommitHeraldWorker');
+      $task->setData(
+        array(
+          'commitID' => $commit->getID(),
+        ));
+      $task->save();
+    }
+  }
 
 }

src/applications/repository/worker/commitchangeparser/base/__init__.php

@@ -8,6 +8,7 @@
 
 phutil_require_module('phabricator', 'applications/repository/storage/repository');
 phutil_require_module('phabricator', 'applications/repository/worker/base');
+phutil_require_module('phabricator', 'infrastructure/daemon/workers/storage/task');
 phutil_require_module('phabricator', 'storage/qsprintf');
 phutil_require_module('phabricator', 'storage/queryfx');
 

src/applications/repository/worker/commitchangeparser/git/PhabricatorRepositoryGitCommitChangeParserWorker.php

@@ -244,6 +244,8 @@ protected function parseCommit(
         PhabricatorRepository::TABLE_PATHCHANGE,
         implode(', ', $sql_chunk));
     }
+
+    $this->finishParse();
   }
 
 }

src/applications/repository/worker/commitchangeparser/svn/PhabricatorRepositorySvnCommitChangeParserWorker.php

@@ -366,6 +366,8 @@ protected function parseCommit(
 
     $this->writeChanges($repository, $commit, $effects, $path_map, $commit_map);
     $this->writeBrowse($repository, $commit, $effects, $path_map);
+
+    $this->finishParse();
   }
 
   private function writeChanges(