PhabricatorFeedStoryNotification.php
No OneTemporary
Actions

Subscribers

None

File Metadata

	<?php

	final class PhabricatorFeedStoryNotification extends PhabricatorFeedDAO {

	protected $userPHID;
	protected $primaryObjectPHID;
	protected $chronologicalKey;
	protected $hasViewed;

	protected function getConfiguration() {
	return array(
	self::CONFIG_IDS => self::IDS_MANUAL,
	self::CONFIG_TIMESTAMPS => false,
	self::CONFIG_COLUMN_SCHEMA => array(
	'chronologicalKey' => 'uint64',
	'hasViewed' => 'bool',
	'id' => null,
	),
	self::CONFIG_KEY_SCHEMA => array(
	'PRIMARY' => null,
	'userPHID' => array(
	'columns' => array('userPHID', 'chronologicalKey'),
	'unique' => true,
	),
	'userPHID_2' => array(
	'columns' => array('userPHID', 'hasViewed', 'primaryObjectPHID'),
	),
	'key_object' => array(
	'columns' => array('primaryObjectPHID'),
	),
	'key_chronological' => array(
	'columns' => array('chronologicalKey'),
	),
	),
	) + parent::getConfiguration();
	}

	public static function updateObjectNotificationViews(
	PhabricatorUser $user,
	$object_phid) {

	if (PhabricatorEnv::isReadOnly()) {
	return;
	}

	$unguarded = AphrontWriteGuard::beginScopedUnguardedWrites();

	$notification_table = new PhabricatorFeedStoryNotification();
	$conn = $notification_table->establishConnection('w');

	queryfx(
	$conn,
	'UPDATE %T
	SET hasViewed = 1
	WHERE userPHID = %s
	AND primaryObjectPHID = %s
	AND hasViewed = 0',
	$notification_table->getTableName(),
	$user->getPHID(),
	$object_phid);

	unset($unguarded);

	$count_key = PhabricatorUserNotificationCountCacheType::KEY_COUNT;
	PhabricatorUserCache::clearCache($count_key, $user->getPHID());
	$user->clearCacheData($count_key);
	}

	}