111.commitauditmigration.php
e10fdbe77edaproduction

111.commitauditmigration.php
View Options

			<?php

			echo "Updating old commit authors...\n";
			$table = new PhabricatorRepositoryCommit();
			$table->openTransaction();

			$conn = $table->establishConnection('w');
			$data = new PhabricatorRepositoryCommitData();
			$commits = queryfx_all(
			$conn,
			'SELECT c.id id, c.authorPHID authorPHID, d.commitDetails details
			FROM %T c JOIN %T d ON d.commitID = c.id
			WHERE c.authorPHID IS NULL
			FOR UPDATE',
			$table->getTableName(),
			$data->getTableName());

			foreach ($commits as $commit) {
			$id = $commit['id'];
			$details = json_decode($commit['details'], true);
			$author_phid = idx($details, 'authorPHID');
			if ($author_phid) {
			queryfx(
			$conn,
			'UPDATE %T SET authorPHID = %s WHERE id = %d',
			$table->getTableName(),
			$author_phid,
			$id);
			echo "#{$id}\n";
			}
			}

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


			echo "Updating old commit mailKeys...\n";
			$table->openTransaction();

			$commits = queryfx_all(
			$conn,
			'SELECT id FROM %T WHERE mailKey = %s FOR UPDATE',
			$table->getTableName(),
			'');

			foreach ($commits as $commit) {
			$id = $commit['id'];
			queryfx(
			$conn,
			'UPDATE %T SET mailKey = %s WHERE id = %d',
			$table->getTableName(),
			Filesystem::readRandomCharacters(20),
			$id);
			echo "#{$id}\n";
			}

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