[Summary view] [Print] [Text view]

   1  <?php
   2  
   3  $table = new PhabricatorRepositoryAuditRequest();
   4  $conn_w = $table->establishConnection('w');
   5  
   6  echo "Migrating Audit subscribers to subscriptions...\n";
   7  foreach (new LiskMigrationIterator($table) as $request) {
   8    $id = $request->getID();
   9  
  10    echo "Migrating auditor {$id}...\n";
  11  
  12    if ($request->getAuditStatus() != 'cc') {
  13      // This isn't a "subscriber", so skip it.
  14      continue;
  15    }
  16  
  17    queryfx(
  18      $conn_w,
  19      'INSERT IGNORE INTO %T (src, type, dst) VALUES (%s, %d, %s)',
  20      PhabricatorEdgeConfig::TABLE_NAME_EDGE,
  21      $request->getCommitPHID(),
  22      PhabricatorEdgeConfig::TYPE_OBJECT_HAS_SUBSCRIBER,
  23      $request->getAuditorPHID());
  24  
  25  
  26    // Wipe the row.
  27    $request->delete();
  28  }
  29  
  30  echo "Done.\n";