NuanceItemUpdateWorker.php
No OneTemporary
Actions

Subscribers

None

File Metadata

	<?php

	final class NuanceItemUpdateWorker
	extends NuanceWorker {

	protected function doWork() {
	$item_phid = $this->getTaskDataValue('itemPHID');

	$hash = PhabricatorHash::digestForIndex($item_phid);
	$lock_key = "nuance.item.{$hash}";
	$lock = PhabricatorGlobalLock::newLock($lock_key);

	$lock->lock(1);
	try {
	$item = $this->loadItem($item_phid);
	$this->updateItem($item);
	$this->routeItem($item);
	} catch (Exception $ex) {
	$lock->unlock();
	throw $ex;
	}

	$lock->unlock();
	}

	private function updateItem(NuanceItem $item) {
	$impl = $item->getImplementation();
	if ($impl->canUpdateItems()) {
	$impl->updateItem($item);
	}
	}

	private function routeItem(NuanceItem $item) {
	$status = $item->getStatus();
	if ($status != NuanceItem::STATUS_ROUTING) {
	return;
	}

	$source = $item->getSource();

	// For now, always route items into the source's default queue.

	$item
	->setQueuePHID($source->getDefaultQueuePHID())
	->setStatus(NuanceItem::STATUS_OPEN)
	->save();
	}

	}