mirror of
https://we.phorge.it/source/phorge.git
synced 2024-11-30 18:52:42 +01:00
5de7774412
Summary: The last commit broke update_phabricator.sh for me when it tried to migrate channel names into its own table. It's a fairly straight forward patch and I'm almost certain I fixed it correctly. :) Test Plan: Made small changes, ran update_phabricator.sh, repeat until the errors went away. Reviewers: epriestley Reviewed By: epriestley CC: aran, Korvin Differential Revision: https://secure.phabricator.com/D5116
64 lines
1.5 KiB
PHP
64 lines
1.5 KiB
PHP
<?php
|
|
|
|
echo "Updating channel IDs of previous chatlog events...\n";
|
|
$event_table = new PhabricatorChatLogEvent();
|
|
$channel_table = new PhabricatorChatLogChannel();
|
|
|
|
$event_table->openTransaction();
|
|
$channel_table->openTransaction();
|
|
|
|
$event_table->beginReadLocking();
|
|
$channel_table->beginReadLocking();
|
|
|
|
$events = new LiskMigrationIterator($event_table);
|
|
$conn_w = $channel_table->establishConnection('w');
|
|
|
|
foreach ($events as $event) {
|
|
if ($event->getChannelID()) {
|
|
continue;
|
|
}
|
|
|
|
$event_row = queryfx_one(
|
|
$conn_w,
|
|
'SELECT channel FROM %T WHERE id = %d',
|
|
$event->getTableName(),
|
|
$event->getID());
|
|
$event_channel = $event_row['channel'];
|
|
|
|
$matched = queryfx_one(
|
|
$conn_w,
|
|
'SELECT * FROM %T WHERE
|
|
channelName = %s AND serviceName = %s AND serviceType = %s',
|
|
$channel_table->getTableName(),
|
|
$event_channel,
|
|
'',
|
|
'');
|
|
|
|
if (!$matched) {
|
|
$matched = id(new PhabricatorChatLogChannel())
|
|
->setChannelName($event_channel)
|
|
->setServiceType('')
|
|
->setServiceName('')
|
|
->setViewPolicy(PhabricatorPolicies::POLICY_USER)
|
|
->setEditPolicy(PhabricatorPolicies::POLICY_USER)
|
|
->save();
|
|
$matched_id = $matched->getID();
|
|
} else {
|
|
$matched_id = $matched['id'];
|
|
}
|
|
|
|
queryfx(
|
|
$event->establishConnection('w'),
|
|
'UPDATE %T SET channelID = %d WHERE id = %d',
|
|
$event->getTableName(),
|
|
$matched_id,
|
|
$event->getID());
|
|
}
|
|
|
|
$event_table->endReadLocking();
|
|
$channel_table->endReadLocking();
|
|
|
|
$event_table->saveTransaction();
|
|
$channel_table->saveTransaction();
|
|
|
|
echo "\nDone.\n";
|