20140325.push.3.groups.php
No OneTemporary
Actions

Subscribers

None

File Metadata

	<?php

	$conn_w = id(new PhabricatorRepository())->establishConnection('w');

	echo pht('Adding transaction log event groups...')."\n";

	$logs = queryfx_all(
	$conn_w,
	'SELECT * FROM %T GROUP BY transactionKey ORDER BY id ASC',
	'repository_pushlog');
	foreach ($logs as $log) {
	$id = $log['id'];
	echo pht('Migrating log %d...', $id)."\n";
	if ($log['pushEventPHID']) {
	continue;
	}

	$event_phid = id(new PhabricatorRepositoryPushEvent())->generatePHID();

	queryfx(
	$conn_w,
	'INSERT INTO %T (phid, repositoryPHID, epoch, pusherPHID, remoteAddress,
	remoteProtocol, rejectCode, rejectDetails)
	VALUES (%s, %s, %d, %s, %d, %s, %d, %s)',
	'repository_pushevent',
	$event_phid,
	$log['repositoryPHID'],
	$log['epoch'],
	$log['pusherPHID'],
	$log['remoteAddress'],
	$log['remoteProtocol'],
	$log['rejectCode'],
	$log['rejectDetails']);

	queryfx(
	$conn_w,
	'UPDATE %T SET pushEventPHID = %s WHERE transactionKey = %s',
	'repository_pushlog',
	$event_phid,
	$log['transactionKey']);
	}

	echo pht('Done.')."\n";