20130201.revisionunsubscribed.php
2c03cd931bd2production

20130201.revisionunsubscribed.php
View Options

			<?php

			echo "Migrating Differential unsubscribed users to edges...\n";
			$table = new DifferentialRevision();
			$table->openTransaction();

			// We couldn't use new LiskMigrationIterator($table) because the $unsubscribed
			// property gets deleted.
			$revs = queryfx_all(
			$table->establishConnection('w'),
			'SELECT id, phid, unsubscribed FROM differential_revision');

			foreach ($revs as $rev) {
			echo ".";

			$unsubscribed = json_decode($rev['unsubscribed']);
			if (!$unsubscribed) {
			continue;
			}

			$editor = new PhabricatorEdgeEditor();
			$editor->setSuppressEvents(true);
			foreach ($unsubscribed as $user_phid => $_) {
			$editor->addEdge(
			$rev['phid'],
			PhabricatorEdgeConfig::TYPE_OBJECT_HAS_UNSUBSCRIBER,
			$user_phid);
			}
			$editor->save();
			}

			$table->saveTransaction();
			echo "Done.\n";