Invision Power Services, Inc. * @copyright (c) Invision Power Services, Inc. * @license https://www.invisioncommunity.com/legal/standards/ * @package Invision Community * @subpackage Gallery * @since 23 Sep 2014 */ namespace IPS\gallery\extensions\core\Queue; /* To prevent PHP errors (extending class does not exist) revealing path */ use IPS\Extensions\QueueAbstract; use IPS\gallery\Album; use IPS\gallery\Category; use IPS\gallery\Image; use IPS\Member; use IPS\Theme; use OutOfRangeException; use function defined; use function is_null; if ( !defined( '\IPS\SUITE_UNIQUE_KEY' ) ) { header( ( $_SERVER['SERVER_PROTOCOL'] ?? 'HTTP/1.0' ) . ' 403 Forbidden' ); exit; } /** * Background Task */ class Follow extends QueueAbstract { /** * Run Background Task * * @param mixed $data Data as it was passed to \IPS\Task::queue() * @param int $offset Offset * @return int New offset * @throws \IPS\Task\Queue\OutOfRangeException Indicates offset doesn't exist and thus task is complete */ public function run( array &$data, int $offset ): int { $category = Category::load( $data['category_id'] ); $album = ( !is_null( $data['album_id'] ) ) ? Album::load( $data['album_id'] ) : NULL; $member = Member::load( $data['member_id'] ); $tags = $data['tags'] ?? null; $newOffset = Image::_sendNotificationsBatch( $category, $album, $member, $tags, $offset ); if( $newOffset === NULL ) { throw new \IPS\Task\Queue\OutOfRangeException; } return $newOffset; } /** * Get Progress * * @param mixed $data Data as it was passed to \IPS\Task::queue() * @param int $offset Offset * @return array( 'text' => 'Doing something...', 'complete' => 50 ) Text explaining task and percentage complete * @throws OutOfRangeException Indicates offset doesn't exist and thus task is complete */ public function getProgress( mixed $data, int $offset ): array { $complete = $data['followerCount'] ? round( 100 / $data['followerCount'] * $offset, 2 ) : 100; $directContainer = ( !is_null( $data['album_id'] ) ) ? Album::load( $data['album_id'] ) : Category::load( $data['category_id'] ); return array( 'text' => Member::loggedIn()->language()->addToStack('backgroundQueue_follow', FALSE, array( 'htmlsprintf' => array( Theme::i()->getTemplate( 'global', 'core', 'global' )->basicUrl( $directContainer->url(), TRUE, $directContainer->_title, FALSE ) ) ) ), 'complete' => $complete ); } /** * Parse data before queuing * * @param array $data * @return array|null */ public function preQueueData( array $data ): ?array { return $data; } }