WorkgroupUserSender::send

public function send(array $pushList, array $notVisibleGroupsUsers): void
{
	if (
		!ModuleManager::isModuleInstalled('pull')
		|| !Loader::includeModule('pull')
	)
	{
		return;
	}

	$tagList = [];
	foreach ($pushList as $push)
	{
		$tagList[] = PullDictionary::PULL_WORKGROUP_USERS_TAG_PREFIX . '_' . (int)$push['GROUP_ID'];
	}

	$tagList = array_unique($tagList);

	$query = BitrixPullModelWatchTable::query();
	$query->addSelect('USER_ID');
	$query->addSelect('TAG');
	$query->whereIn('TAG', $tagList);
	$records = $query->fetchAll();

	$subscribedUsers = [];
	foreach ($records as $record)
	{
		if (!preg_match('/^'. PullDictionary::PULL_WORKGROUP_USERS_TAG_PREFIX . '(d+)$/i', $record['TAG'], $matches))
		{
			continue;
		}

		$groupId = (int)$matches[1];

		if (!isset($subscribedUsers[$groupId]))
		{
			$subscribedUsers[$groupId] = [];
		}

		$subscribedUsers[$groupId][] = (int)$record['USER_ID'];
	}

	foreach ($pushList as $push)
	{
		$pushCommand = PushEventDictionary::getPushEventType($push['EVENT']);
		$groupId = (int)$push['GROUP_ID'];
		$userId = (int)$push['USER_ID'];
		$role = (int)$push['ROLE'];

		$pushParams = [
			'module_id' => 'socialnetwork',
			'command' => $pushCommand,
			'params' => [ 'GROUP_ID' => $groupId ],
		];

		if ($role === UserToGroupTable::ROLE_REQUEST)
		{
			$recipients = [ $userId ];
		}
		elseif (!empty($subscribedUsers[$groupId]))
		{
			$recipients = (
				isset($notVisibleGroupsUsers[$groupId])
					? array_intersect($subscribedUsers[$groupId], $notVisibleGroupsUsers[$groupId])
					: $subscribedUsers[$groupId]
			);
		}

		PushSender::sendPersonalEvent($recipients, $pushCommand, $pushParams);
	}
}