mirror of
https://we.phorge.it/source/phorge.git
synced 2024-11-27 01:02:42 +01:00
44 lines
1 KiB
PHP
44 lines
1 KiB
PHP
|
<?php
|
||
|
|
|
||
|
|
$conn_w = id(new PhabricatorRepository())->establishConnection('w');
|
||
|
|
|
||
|
|
echo "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 "Migrating log {$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 "Done.\n";
|