mirror of
https://we.phorge.it/source/phorge.git
synced 2024-12-01 11:12:42 +01:00
30 lines
663 B
PHP
30 lines
663 B
PHP
|
<?php
|
||
|
|
|
||
|
|
final class DiffusionPullEventGarbageCollector
|
||
|
|
extends PhabricatorGarbageCollector {
|
||
|
|
|
||
|
|
const COLLECTORCONST = 'diffusion.pull';
|
||
|
|
|
||
|
|
public function getCollectorName() {
|
||
|
|
return pht('Repository Pull Events');
|
||
|
|
}
|
||
|
|
|
||
|
|
public function getDefaultRetentionPolicy() {
|
||
|
|
return phutil_units('30 days in seconds');
|
||
|
|
}
|
||
|
|
|
||
|
|
protected function collectGarbage() {
|
||
|
|
$table = new PhabricatorRepositoryPullEvent();
|
||
|
|
$conn_w = $table->establishConnection('w');
|
||
|
|
|
||
|
|
queryfx(
|
||
|
|
$conn_w,
|
||
|
|
'DELETE FROM %T WHERE epoch < %d LIMIT 100',
|
||
|
|
$table->getTableName(),
|
||
|
|
$this->getGarbageEpoch());
|
||
|
|
|
||
|
|
return ($conn_w->getAffectedRows() == 100);
|
||
|
|
}
|
||
|
|
|
||
|
|
}
|