testing

NuanceItemUpdateWorker.php
View Options

			<?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();
			}

			}