PhabricatorRepositoryPullLocalDaemonModule.php
No OneTemporary
Actions

Subscribers

None

File Metadata

	<?php

	final class PhabricatorRepositoryPullLocalDaemonModule
	extends PhutilDaemonOverseerModule {

	private $cursor = 0;

	public function shouldWakePool(PhutilDaemonPool $pool) {
	$class = $pool->getPoolDaemonClass();
	if ($class != 'PhabricatorRepositoryPullLocalDaemon') {
	return false;
	}

	if ($this->shouldThrottle($class, 1)) {
	return false;
	}

	$table = new PhabricatorRepositoryStatusMessage();
	$table_name = $table->getTableName();
	$conn = $table->establishConnection('r');

	$row = queryfx_one(
	$conn,
	'SELECT id FROM %T WHERE statusType = %s
	AND id > %d ORDER BY id DESC LIMIT 1',
	$table_name,
	PhabricatorRepositoryStatusMessage::TYPE_NEEDS_UPDATE,
	$this->cursor);

	if (!$row) {
	return false;
	}

	$this->cursor = (int)$row['id'];
	return true;
	}

	}