Invision Power Services, Inc. * @copyright (c) Invision Power Services, Inc. * @license https://www.invisioncommunity.com/legal/standards/ * @package Invision Community * @since 27 Aug 2013 */ namespace IPS\core\modules\front\system; /* To prevent PHP errors (extending class does not exist) revealing path */ use Exception; use IPS\Api\Webhook; use IPS\Application; use IPS\Content; use IPS\Content\Item; use IPS\core\DataLayer; use IPS\core\Followed\Follow; use IPS\Db; use IPS\Dispatcher\Controller; use IPS\Events\Event; use IPS\Helpers\Form; use IPS\Helpers\Form\Checkbox; use IPS\Helpers\Form\Radio; use IPS\Http\Url; use IPS\IPS; use IPS\Member; use IPS\Member\Club; use IPS\Member\Device; use IPS\Node\Model; use IPS\Notification; use IPS\Notification\Table; use IPS\Output; use IPS\Platform\Bridge; use IPS\Request; use IPS\Session; use IPS\Settings; use IPS\Theme; use OutOfRangeException; use UnderflowException; use function count; use function defined; use function in_array; use function md5; use const IPS\REBUILD_QUICK; if ( !defined( '\IPS\SUITE_UNIQUE_KEY' ) ) { header( ( $_SERVER['SERVER_PROTOCOL'] ?? 'HTTP/1.0' ) . ' 403 Forbidden' ); exit; } /** * Notification Settings Controller */ class notifications extends Controller { /** * Execute */ protected function _checkLoggedIn() : void { if ( !Member::loggedIn()->member_id ) { Output::i()->error( 'no_module_permission_guest', '2C154/2', 403, '' ); } Output::i()->jsFiles = array_merge( Output::i()->jsFiles, Output::i()->js('front_system.js', 'core' ) ); Output::i()->cssFiles = array_merge( Output::i()->cssFiles, Theme::i()->css( 'styles/notification_settings.css' ) ); } /** * View Notifications * * @return void */ protected function manage() : void { $this->_checkLoggedIn(); /* Init table */ $urlObject = Url::internal( 'app=core&module=system&controller=notifications', 'front', 'notifications' ); $table = new Table( $urlObject ); $table->setMember( Member::loggedIn() ); $notifications = $table->getRows(); Db::i()->update( 'core_notifications', array( 'read_time' => time() ), array( '`member`=?', Member::loggedIn()->member_id ) ); Member::loggedIn()->recountNotifications(); if ( Request::i()->isAjax() ) { Output::i()->json( array( 'data' => Theme::i()->getTemplate( 'system' )->notificationsAjax( $notifications ) ) ); } else { Output::i()->metaTags['robots'] = 'noindex'; Output::i()->title = Member::loggedIn()->language()->addToStack('notifications'); Output::i()->breadcrumb[] = array( NULL, Output::i()->title ); Output::i()->output = (string) $table; } } /** * Subscribe a user's device to push notifications * * @return void */ protected function subscribeToPush() : void { $this->_checkLoggedIn(); Session::i()->csrfCheck(); if ( isset( Request::i()->subscription ) AND $subscription = json_decode( Request::i()->subscription, TRUE ) ) { $device = Device::loadOrCreate( Member::loggedIn(), FALSE ); /* If a subscription already exists, then just return */ try { Db::i()->select( '*', 'core_notifications_pwa_keys', array( "`member`=? AND p256dh=? AND auth=?", Member::loggedIn()->member_id, $subscription['keys']['p256dh'], $subscription['keys']['auth'] ) )->first(); /* Make sure encoding and device is up to date, though since it's needed for encryption transfer. */ Db::i()->update( 'core_notifications_pwa_keys', array( 'encoding' => Request::i()->encoding, 'device' => $device->device_key ), array( "`member`=? AND p256dh=? AND auth=?", Member::loggedIn()->member_id, $subscription['keys']['p256dh'], $subscription['keys']['auth'] ) ); } catch( UnderflowException $e ) { Db::i()->insert( 'core_notifications_pwa_keys', array( 'member' => Member::loggedIn()->member_id, 'endpoint' => $subscription['endpoint'], 'p256dh' => $subscription['keys']['p256dh'], 'auth' => $subscription['keys']['auth'], 'encoding' => Request::i()->encoding, 'device' => $device->device_key ) ); /* The expectation is to receive some push notifications, so let's add them to follower_content, new_content and new_comment and they can be removed manually if the user doesn't want them */ $notificationTypes = array( 'follower_content', 'new_content', 'new_comment' ); foreach ( $notificationTypes as $notificationKey ) { try { /* See if we have a row in preferences already */ $currentRow = Db::i()->select( '*', 'core_notification_preferences', array( 'member_id=? AND notification_key=?', Member::loggedIn()->member_id, $notificationKey ) )->first(); /* Does this row have a preference of push? */ $prefs = explode( ',', $currentRow['preference'] ); if ( !in_array( 'push', $prefs ) ) { $prefs[] = 'push'; } Db::i()->update( 'core_notification_preferences', [ 'preference' => implode( ',', $prefs ), ], array( 'member_id=? AND notification_key=?', Member::loggedIn()->member_id, $notificationKey ) ); } catch( UnderflowException $e ) { Db::i()->insert( 'core_notification_preferences', [ 'member_id' => Member::loggedIn()->member_id, 'notification_key' => $notificationKey, 'preference' => implode( ',', [ 'inline', 'push' ] ) ], true ); } } } Output::i()->json( 'OK' ); } else { Output::i()->error( 'invalid_push_subscription', '2C154/H', 403, '' ); } } /** * Verify a subscription with the provided key exists for the logged-in user * * @return void */ protected function verifySubscription() : void { $this->_checkLoggedIn(); Session::i()->csrfCheck(); if ( isset( Request::i()->key ) ) { /* See if a subscription already exists */ try { Db::i()->select( '*', 'core_notifications_pwa_keys', array( "`member`=? AND p256dh=?", Member::loggedIn()->member_id, Request::i()->key ) )->first(); Output::i()->json( 'OK' ); } catch( UnderflowException $e ) { // Just let it return the error below } } Output::i()->error( 'invalid_push_subscription', '2C154/I', 403, '' ); } /** * Options: Dispatcher * * @return void */ protected function options() : void { /* Check we're logged in */ $this->_checkLoggedIn(); /* Init breadcrumb */ $extensions = Application::allExtensions( 'core', 'Notifications' ); Output::i()->breadcrumb[] = array( Url::internal( 'app=core&module=system&controller=notifications', 'front', 'notifications' ), Member::loggedIn()->language()->addToStack('notifications') ); Output::i()->breadcrumb[] = array( Url::internal( 'app=core&module=system&controller=notifications&do=options', 'front', 'notifications_options' ), Member::loggedIn()->language()->addToStack('options') ); /* Are we viewing a particular type? */ if ( isset( Request::i()->type ) and array_key_exists( Request::i()->type, $extensions ) ) { Output::i()->title = Member::loggedIn()->language()->addToStack( "notifications__" . Request::i()->type ); Output::i()->breadcrumb[] = array( NULL, Member::loggedIn()->language()->addToStack( "notifications__" . Request::i()->type ) ); $this->_optionsType( Request::i()->type, $extensions[ Request::i()->type ] ); } /* Nope, viewing the index */ else { $this->_optionsIndex( $extensions ); } } /** * Options: Index * * @param array $extensions The extensions * @return void */ protected function _optionsIndex( array $extensions ) : void { Output::i()->title = Member::loggedIn()->language()->addToStack('notification_options'); Output::i()->output = Theme::i()->getTemplate('system')->notificationSettingsIndex( Notification::membersOptionCategories( Member::loggedIn(), $extensions ) ); Output::i()->globalControllers[] = 'core.front.system.notificationSettings'; } /** * Options: Index * * @param string $extensionKey The extension key * @param object $extension The extension * @return void */ protected function _optionsType( string $extensionKey, object $extension ) : void { $form = Notification::membersTypeForm( Member::loggedIn(), $extension ); if ( $form === TRUE ) { if ( Request::i()->isAjax() ) { $categories = Notification::membersOptionCategories( Member::loggedIn(), array( $extensionKey => $extension ) ); Output::i()->sendOutput( Theme::i()->getTemplate('system')->notificationSettingsIndexRowDetails( $extensionKey, $categories[ $extensionKey ] ), 200, 'text/html', Output::i()->httpHeaders ); } else { Output::i()->redirect( Url::internal( 'app=core&module=system&controller=notifications&do=options', 'front', 'notifications_options' ), 'saved' ); } } elseif ( $form ) { $form->class = 'ipsForm--vertical ipsForm--notification-options'; } if ( Request::i()->isAjax() and ! isset( Request::i()->fromFollowButton ) ) { $form->actionButtons = array(); Output::i()->sendOutput( Theme::i()->getTemplate('system')->notificationSettingsType( Member::loggedIn()->language()->addToStack("notifications__{$extensionKey}"), $form, TRUE ), 200, 'text/html', Output::i()->httpHeaders ); } else { /* If it's not ajax, or come via the follow button, then we want to show the form with the save button */ Output::i()->output = Theme::i()->getTemplate('system')->notificationSettingsType( Member::loggedIn()->language()->addToStack("notifications__{$extensionKey}"), $form, FALSE ); } } /** * Stop receiving all notifications to a particular method * * @return void */ protected function disable() : void { $this->_checkLoggedIn(); Session::i()->csrfCheck(); foreach ( Application::allExtensions( 'core', 'Notifications' ) as $extension ) { $options = Notification::availableOptions( Member::loggedIn(), $extension ); foreach ( $options as $option ) { if ( $option['type'] === 'standard' ) { $value = array(); foreach ( $option['options'] as $k => $optionDetails ) { if ( ( $optionDetails['editable'] and $k !== Request::i()->type and $optionDetails['value'] ) or ( !$optionDetails['editable'] and $optionDetails['value'] ) ) { $value[] = $k; } } foreach ( $option['notificationTypes'] as $notificationKey ) { Db::i()->insert( 'core_notification_preferences', array( 'member_id' => Member::loggedIn()->member_id, 'notification_key' => $notificationKey, 'preference' => implode( ',', $value ) ), TRUE ); } } } $extension::disableExtra( Member::loggedIn(), Request::i()->type ); } if ( Request::i()->type === 'push' ) { Member::loggedIn()->clearPwaAuths(); } /* Digests */ Db::i()->update( 'core_follow', array( 'follow_notify_freq' => 'none'), array( 'follow_member_id=? AND follow_notify_freq IN(?,?)', Member::loggedIn()->member_id, "daily", "weekly" ) ); if ( Request::i()->isAjax() ) { Output::i()->json( 'ok' ); } else { Output::i()->redirect( Url::internal( 'app=core&module=system&controller=notifications&do=options', 'front', 'notifications_options' ) ); } } /** * Follow Something * * @return void */ protected function follow() : void { $this->_checkLoggedIn(); try { $application = Application::load( Request::i()->follow_app ); } catch( OutOfRangeException $e ) { Output::i()->error( 'error_no_app', '3C154/F', 404, '' ); } /* Get class */ $class = Follow::getClassToFollow( Request::i()->follow_app, Request::i()->follow_area ); if( Request::i()->follow_app == 'core' and Request::i()->follow_area == 'member' ) { /* You can't follow yourself */ if( Request::i()->follow_id == Member::loggedIn()->member_id ) { Output::i()->error( 'cant_follow_self', '3C154/7', 403, '' ); } /* Following disabled */ $member = Member::load( Request::i()->follow_id ); if( !$member->member_id ) { Output::i()->error( 'cant_follow_member', '3C154/9', 403, '' ); } if( $member->members_bitoptions['pp_setting_moderate_followers'] and !Member::loggedIn()->following( 'core', 'member', $member->member_id ) ) { Output::i()->error( 'cant_follow_member', '3C154/8', 403, '' ); } } if ( !$class ) { Output::i()->error( 'node_error', '2C154/3', 404, '' ); } /* Get thing */ $thing = NULL; try { if ( in_array( 'IPS\Node\Model', class_parents( $class ) ) ) { /* @var Model $class */ $thing = $class::loadAndCheckPerms( (int) Request::i()->follow_id ); Output::i()->title = Member::loggedIn()->language()->addToStack( 'follow_thing', FALSE, array( 'sprintf' => array( $thing->_title ) ) ); /* Set navigation */ try { foreach ( $thing->parents() as $parent ) { Output::i()->breadcrumb[] = array( $parent->url(), $parent->_title ); } Output::i()->breadcrumb[] = array( NULL, $thing->_title ); } catch ( Exception $e ) { } } elseif ( $class == 'IPS\Member\Club' ) { /* @var Club $class */ $thing = $class::loadAndCheckPerms( (int) Request::i()->follow_id ); Output::i()->title = Member::loggedIn()->language()->addToStack( 'follow_thing', FALSE, array( 'sprintf' => array( $thing->_title ) ) ); Output::i()->breadcrumb = array( array( Url::internal( 'app=core&module=clubs&controller=directory', 'front', 'clubs_list' ), Member::loggedIn()->language()->addToStack('module__core_clubs') ), array( $thing->url(), $thing->name ) ); } elseif ( $class != "IPS\Member" ) { if( !IPS::classUsesTrait( $class, 'IPS\Content\Followable' ) ) { throw new OutOfRangeException; } /* @var Item $class */ $thing = $class::loadAndCheckPerms( (int) Request::i()->follow_id ); Output::i()->title = Member::loggedIn()->language()->addToStack( 'follow_thing', FALSE, array( 'sprintf' => array( $thing->mapped('title') ) ) ); /* Set navigation */ $container = NULL; try { $container = $thing->container(); foreach ( $container->parents() as $parent ) { Output::i()->breadcrumb[] = array( $parent->url(), $parent->_title ); } Output::i()->breadcrumb[] = array( $container->url(), $container->_title ); } catch ( Exception $e ) { } /* Set meta tags */ Output::i()->breadcrumb[] = array( NULL, $thing->mapped('title') ); } else { $thing = $class::load( (int) Request::i()->follow_id ); Output::i()->title = Member::loggedIn()->language()->addToStack('follow_thing', FALSE, array( 'sprintf' => array( $thing->name ) ) ); /* Set navigation */ Output::i()->breadcrumb[] = array( NULL, $thing->name ); } } catch ( OutOfRangeException $e ) { Output::i()->error( 'node_error', '2C154/4', 404, '' ); } /* Do we follow it? */ try { $current = Db::i()->select( '*', 'core_follow', array( 'follow_app=? AND follow_area=? AND follow_rel_id=? AND follow_member_id=?', Request::i()->follow_app, Request::i()->follow_area, Request::i()->follow_id, Member::loggedIn()->member_id ) )->first(); } catch ( UnderflowException $e ) { $current = FALSE; } /* How do we receive notifications? */ if ( $class == 'IPS\Member' ) { $type = 'follower_content'; } elseif ( $class == 'IPS\Member\Club' or in_array( 'IPS\Content\Item', class_parents( $class ) ) ) { $type = 'new_comment'; } else { $type = 'new_content'; } $notificationConfiguration = Member::loggedIn()->notificationsConfiguration(); $notificationConfiguration = $notificationConfiguration[$type] ?? array(); $lang = 'follow_type_immediate'; if ( in_array( 'email', $notificationConfiguration ) and in_array( 'inline', $notificationConfiguration ) ) { $lang = 'follow_type_immediate_inline_email'; } elseif ( in_array( 'email', $notificationConfiguration ) ) { $lang = 'follow_type_immediate_email'; } if ( $class == "IPS\Member" ) { Member::loggedIn()->language()->words[ $lang ] = Member::loggedIn()->language()->addToStack( $lang . '_member', FALSE, array( 'sprintf' => array( $thing->name ) ) ); } if ( empty( $notificationConfiguration ) ) { Member::loggedIn()->language()->words[ $lang . '_desc' ] = Member::loggedIn()->language()->addToStack( 'follow_type_immediate_none', FALSE ) . ' ' . Member::loggedIn()->language()->addToStack( 'notification_options', FALSE ) . ''; } else { Member::loggedIn()->language()->words[ $lang . '_desc' ] = '' . Member::loggedIn()->language()->addToStack( 'follow_type_immediate_change', FALSE ) . ''; } /* Build form */ $form = new Form( 'follow', ( $current ) ? 'update_follow' : 'follow', NULL, array( 'data-followApp' => Request::i()->follow_app, 'data-followArea' => Request::i()->follow_area, 'data-followID' => Request::i()->follow_id ) ); $form->class = 'ipsForm--vertical ipsForm--notifications-follow'; $options = array(); if( $class != "IPS\Content\Tag" ) { $options['immediate'] = $lang; } if ( $class != "IPS\Member" ) { if ( $class != "IPS\Member\Club" ) { $options['daily'] = Member::loggedIn()->language()->addToStack('follow_type_daily'); $options['weekly'] = Member::loggedIn()->language()->addToStack('follow_type_weekly'); } $options['none'] = Member::loggedIn()->language()->addToStack('follow_type_no_notification'); } if ( count( $options ) > 1 ) { $form->add( new Radio( 'follow_type', $current ? $current['follow_notify_freq'] : NULL, TRUE, array( 'options' => $options, 'disabled' => empty( $notificationConfiguration ) ? array( 'immediate' ) : array() ) ) ); } else { foreach ( $options as $k => $v ) { $form->hiddenValues[ 'follow_type' ] = $k; if ( empty( $notificationConfiguration ) ) { $type = $type == 'follower_content' ? 'core_Content' : $type; $form->addMessage( Member::loggedIn()->language()->addToStack( 'follow_type_no_config' ) . ' ' . Member::loggedIn()->language()->addToStack( 'notification_options', FALSE ) . '', ' ', FALSE ); } else { $form->addMessage( Member::loggedIn()->language()->addToStack( $v ) . '
' . Member::loggedIn()->language()->addToStack( $lang . '_desc' ), ' ', FALSE ); } } } $form->add( new Checkbox( 'follow_public', $current ? !$current['follow_is_anon'] : TRUE, FALSE, array( 'label' => ( $class != "IPS\Member" ) ? Member::loggedIn()->language()->addToStack( 'follow_public' ) : Member::loggedIn()->language()->addToStack('follow_public_member', FALSE, array( 'sprintf' => array( $thing->name ) ) ) ) ) ); if ( $current ) { $unfollowUrl = Url::internal( "app=core&module=system&controller=notifications&do=unfollow&id={$current['follow_id']}&follow_app={$current['follow_app']}&follow_area={$current['follow_area']}" )->csrf(); if ( method_exists( $thing, 'url' ) AND $thing->url() ) { $unfollowUrl = $unfollowUrl->addRef( (string) $thing->url() ); } $form->addButton( 'unfollow', 'link', $unfollowUrl, 'ipsButton ipsButton--text ipsButton--icon', array('data-action' => 'unfollow') ); } /* Handle submissions */ if ( $values = $form->values() ) { $class = Follow::getClassToFollow( Request::i()->follow_app, Request::i()->follow_area ); try { $useDataLayer = Member::loggedIn()->member_id and DataLayer::enabled( 'analytics_full' ); $alreadyFollowing = $useDataLayer ? Db::i()->select( 'count(*)', 'core_follow', [ 'follow_app=? AND follow_area=? AND follow_rel_id=? AND follow_member_id=?', Request::i()->follow_app, Request::i()->follow_area, Request::i()->follow_id, Member::loggedIn()->member_id ] )->first() : false; $thing = $class::load( Request::i()->follow_id ); $thing->follow( $values['follow_type'], $values['follow_public'] ); if ( $useDataLayer and !$alreadyFollowing ) { DataLayer::i()->addEvent( 'follow', [ 'follow_app' => Request::i()->follow_app, 'follow_area' => Request::i()->follow_area, 'follow_id' => Request::i()->follow_id ]); } } catch( OutOfRangeException ){} /* Boink */ if ( Request::i()->isAjax() ) { Output::i()->json( 'ok' ); } else { Output::i()->redirect( $thing->url() ); } } /* Display */ $output = $form->customTemplate( array( Theme::i()->getTemplate( 'system', 'core' ), 'followForm' ) ); if( Request::i()->isAjax() ) { Output::i()->sendOutput( $output ); } else { Output::i()->output = $output; } } /** * Unfollow * * @return void */ protected function unfollow() : void { $this->_checkLoggedIn(); Session::i()->csrfCheck(); try { $follow = Follow::load( Request::i()->id ); if( $follow->member_id != Member::loggedIn()->member_id ) { throw new OutOfRangeException; } } catch ( OutOfRangeException $e ) { Output::i()->error( 'cant_find_unfollow', '2C154/D', 404, '' ); } /* We call the unfollow on the object, not on the follow record. This is so that we can handle object-specific actions (e.g. unfollow a club unfollow club nodes) It's a bit circular, but we'll live. */ if( $item = $follow->_item ) { $item->unfollow( Member::loggedIn(), $follow->id ); if ( DataLayer::enabled( 'analytics_full' ) ) { DataLayer::i()->addEvent( 'unfollow', [ 'follow_app' => $follow->app, 'follow_area' => $follow->area, 'follow_id' => $follow->rel_id, ]); } } if ( Request::i()->isAjax() ) { Output::i()->json( 'ok' ); } else { Output::i()->redirect( Request::i()->referrer() ?: Url::internal( '' ) ); } } /** * Show Followers * * @return void */ protected function followers() : void { $perPage = 50; $thisPage = isset( Request::i()->followerPage ) ? Request::i()->followerPage : 1; $thisPage = ( $thisPage > 0 ) ? $thisPage : 1; if( !Member::loggedIn()->group['g_view_followers'] ) { Output::i()->error( 'module_no_permission', '2C154/16', 403 ); } if( !Request::i()->follow_app OR !Request::i()->follow_area ) { Output::i()->error( 'node_error', '2C154/E', 404, '' ); } /* Get class */ if( Request::i()->follow_app == 'core' and Request::i()->follow_area == 'member' ) { $class = 'IPS\Member'; } else if( Request::i()->follow_app == 'core' and Request::i()->follow_area == 'club' ) { $class = 'IPS\Member\Club'; } elseif( Request::i()->follow_app == 'core' and Request::i()->follow_area == 'tag' ) { $class = 'IPS\Content\Tag'; } else { $class = 'IPS\\' . Request::i()->follow_app . '\\' . IPS::mb_ucfirst( Request::i()->follow_area ); } if ( !class_exists( $class ) or !array_key_exists( Request::i()->follow_app, Application::applications() ) ) { Output::i()->error( 'node_error', '2C154/5', 404, '' ); } /* Get thing */ $thing = NULL; $anonymous = 0; try { if ( $class == "IPS\Member\Club" or $class == 'IPS\Content\Tag' ) { $thing = $class::loadAndCheckPerms( (int) Request::i()->follow_id ); $followers = $thing->followers( Content::FOLLOW_PUBLIC, array( 'none', 'immediate', 'daily', 'weekly' ), NULL, array( ( $thisPage - 1 ) * $perPage, $perPage ), 'name' ); $followersCount = $thing->followersCount(); $anonymous = $thing->followersCount( Content::FOLLOW_ANONYMOUS ); $title = $thing->_title; } elseif ( in_array( 'IPS\Node\Model', class_parents( $class ) ) ) { $classname = $class::$contentItemClass; $containerClass = $class; $thing = $containerClass::loadAndCheckPerms( (int) Request::i()->follow_id ); $followers = $classname::containerFollowers( $thing, Content::FOLLOW_PUBLIC, array( 'none', 'immediate', 'daily', 'weekly' ), NULL, array( ( $thisPage - 1 ) * $perPage, $perPage ), 'name' ); $followersCount = $classname::containerFollowerCount( $thing ); $anonymous = $classname::containerFollowerCount( $thing, Content::FOLLOW_ANONYMOUS ); $title = $thing->_title; } else if ( $class != "IPS\Member" ) { /* @var Item $thing */ $thing = $class::loadAndCheckPerms( (int) Request::i()->follow_id ); $followers = $thing->followers( Content::FOLLOW_PUBLIC, array( 'none', 'immediate', 'daily', 'weekly' ), NULL, array( ( $thisPage - 1 ) * $perPage, $perPage ), 'name' ); $followersCount = $thing->followersCount(); $anonymous = $thing->followersCount( Content::FOLLOW_ANONYMOUS ); $title = $thing->mapped('title'); } else { $thing = $class::load( (int) Request::i()->follow_id ); $followers = $thing->followers( Content::FOLLOW_PUBLIC, array( 'none', 'immediate', 'daily', 'weekly' ), NULL, array( ( $thisPage - 1 ) * $perPage, $perPage ), 'name' ); $followersCount = $thing->followersCount(); $anonymous = $thing->followersCount( Content::FOLLOW_ANONYMOUS ); $title = $thing->name; } } catch ( OutOfRangeException $e ) { Output::i()->error( 'node_error', '2C154/6', 404, '' ); } /* Display */ if ( Request::i()->isAjax() and isset( Request::i()->_infScroll ) ) { Output::i()->sendOutput( Theme::i()->getTemplate( 'system' )->followersRows( $followers ) ); } else { $url = Url::internal( "app=core&module=system&controller=notifications&do=followers&follow_app=". Request::i()->follow_app ."&follow_area=". Request::i()->follow_area ."&follow_id=" . Request::i()->follow_id . "&_infScroll=1" ); $removeAllUrl = Url::internal( "app=core&module=system&controller=notifications&do=removeFollowers&follow_app=". Request::i()->follow_app ."&follow_area=". Request::i()->follow_area ."&follow_id=" . Request::i()->follow_id )->csrf(); if ( method_exists( $thing, 'url' ) AND $thing->url() ) { $removeAllUrl = $removeAllUrl->addRef( (string) $thing->url() ); } $pagination = Theme::i()->getTemplate( 'global', 'core', 'global' )->pagination( $url, ceil( $followersCount / $perPage ), $thisPage, $perPage, FALSE, 'followerPage' ); /* Instruct bots not to index this page */ Output::i()->metaTags['robots'] = 'noindex'; Output::i()->title = Member::loggedIn()->language()->addToStack('item_followers', FALSE, array( 'sprintf' => array( $title ) ) ); Output::i()->breadcrumb[] = array( $thing->url(), $title ); Output::i()->breadcrumb[] = array( NULL, Member::loggedIn()->language()->addToStack('who_follows_this') ); Output::i()->output = Theme::i()->getTemplate( 'system' )->followers( $url, $pagination, $followers, $anonymous, $removeAllUrl ); } } /** * Unfollow from email * If we're logged in, we can send them right to the normal follow form. * Otherwise, they get a special guest page using the gkey as an authentication key. * * @return void */ protected function unfollowFromEmail() : void { /* Logged in? */ if ( Member::loggedIn()->member_id and ! isset( Request::i()->listunsubscribe ) ) { /* Go to the normal page */ Output::i()->redirect( Url::internal( "app=core&module=system&controller=notifications&do=follow&follow_app=". Request::i()->follow_app ."&follow_area=". Request::i()->follow_area ."&follow_id=" . Request::i()->follow_id ) ); } if ( ! empty( Request::i()->gkey ) ) { [ $followKey, $memberKey ] = explode( '-', Request::i()->gkey ); /* Do we follow it? */ try { $current = Db::i()->select( '*', 'core_follow', array( 'MD5( CONCAT_WS( \';\', follow_app, follow_area, follow_rel_id, follow_member_id, follow_added ) )=?', $followKey ) )->first(); /* Already no subs? */ if ( $current['follow_notify_freq'] === 'none' ) { Output::i()->error( 'follow_guest_not_notified', '2C154/C', 404, '' ); } $member = Member::load( $current['follow_member_id'] ); if ( md5( $member->email . ';' . $member->ip_address . ';' . $member->joined->getTimestamp() ) != $memberKey ) { throw new Exception; } if( !array_key_exists( Request::i()->follow_app, Application::applications() ) ) { throw new Exception; } $class = Follow::getClassToFollow( Request::i()->follow_app, Request::i()->follow_area ); if ( !class_exists( $class ) ) { throw new Exception; } /* Get thing */ $thing = NULL; if ( in_array( 'IPS\Node\Model', class_parents( $class ) ) ) { $classname = $class::$contentItemClass; /* @var Model $containerClass */ $containerClass = $class; $thing = $containerClass::load( (int) Request::i()->follow_id ); $title = $thing->_title; } else if ( $class == "IPS\Member\Club" ) { $thing = $class::load( (int) Request::i()->follow_id ); $title = $thing->_title; } else if ( $class != "IPS\Member" ) { $thing = $class::load( (int) Request::i()->follow_id ); $title = $thing->mapped('title'); } else { $thing = $class::load( (int) Request::i()->follow_id ); $title = $thing->name; } /* Grab a count */ $count = Db::i()->select( 'COUNT(*)', 'core_follow', array( 'follow_member_id=? and follow_notify_freq != ?', $member->member_id, 'none' ) )->first(); if ( isset( Request::i()->listunsubscribe ) and Request::i()->requestMethod() == 'POST' ) { /* Unsubscribe them now as it's come from clicking the list-unsubscribe header in the email which contains List-Unsubscribe-Post:List-Unsubscribe=One-Click which sends via POST to prevent links being crawled and activated */ $thing->follow( 'none', !$current['follow_is_anon'], $member ); /* Done */ Output::i()->output = Member::loggedIn()->language()->addToStack('unsubscribed'); return; } $form = new Form( 'unfollowFromEmail', 'update_follow' ); $form->class = 'ipsForm--vertical ipsForm--notifications-unfollow-email'; if ( $count == 1 ) { $form->add( new Checkbox( 'guest_unfollow_single', 'single', FALSE, array( 'disabled' => true ) ) ); Member::loggedIn()->language()->words['guest_unfollow_single'] = Member::loggedIn()->language()->addToStack('follow_guest_unfollow_thing', FALSE, array( 'sprintf' => array( $title ) ) ); } else { $form->add( new Radio( 'guest_unfollow_choice', 'single', FALSE, array( 'options' => array( 'single' => Member::loggedIn()->language()->addToStack('follow_guest_unfollow_thing', FALSE, array( 'sprintf' => array( $title ) ) ), 'all' => Member::loggedIn()->language()->addToStack('follow_guest_unfollow_all', FALSE, array( 'pluralize' => array( $count ) ) ), ), 'descriptions' => array( 'single' => Member::loggedIn()->language()->addToStack('follow_guest_unfollow_thing_desc'), 'all' => Member::loggedIn()->language()->addToStack('follow_guest_unfollow_all_desc', FALSE, array( 'sprintf' => array( base64_encode( Url::internal( "app=core&module=system&controller=followed" ) ) ) ) ) ) ) ) ); } if ( $values = $form->values() ) { if ( $values['guest_unfollow_choice'] == 'single' or isset( $values['guest_unfollow_single'] ) ) { $thing->follow( 'none', !$current['follow_is_anon'], $member ); } else { Db::i()->update( 'core_follow', array( 'follow_notify_freq' => 'none' ), array( 'follow_member_id=?', $member->member_id ) ); } } Output::i()->sidebar['enabled'] = FALSE; Output::i()->bodyClasses[] = 'ipsLayout_minimal'; Output::i()->output = Theme::i()->getTemplate( 'system' )->unfollowFromEmail( $title, $member, $form, ! isset( Request::i()->guest_unfollow_choice ) ? FALSE : Request::i()->guest_unfollow_choice ); Output::i()->title = Member::loggedIn()->language()->addToStack('follow_guest_unfollow_thing', FALSE, array( 'sprintf' => array( $title ) ) ); } catch ( Exception $e ) { Output::i()->error( 'follow_guest_key_not_found', '2C154/B', 404, '' ); } } } /** * Follow button * * @return void */ protected function button() : void { /* Get class */ if( Request::i()->follow_app == 'core' and Request::i()->follow_area == 'member' ) { $class = 'IPS\\Member'; } elseif( Request::i()->follow_app == 'core' and Request::i()->follow_area == 'club' ) { $class = 'IPS\\Member\Club'; } elseif( Request::i()->follow_app == 'core' and Request::i()->follow_area == 'tag' ) { $class = 'IPS\Content\Tag'; } else { $class = 'IPS\\' . Request::i()->follow_app . '\\' . IPS::mb_ucfirst( Request::i()->follow_area ); } if ( !class_exists( $class ) or !array_key_exists( Request::i()->follow_app, Application::applications() ) ) { Output::i()->error( 'node_error', '2C154/5', 404, '' ); } /* Get thing */ $thing = NULL; try { if ( in_array( 'IPS\Node\Model', class_parents( $class ) ) and $class != 'IPS\Content\Tag' ) { $classname = $class::$contentItemClass; $containerClass = $class; $thing = $containerClass::loadAndCheckPerms( (int) Request::i()->follow_id ); $count = $classname::containerFollowerCount( $thing ); } else if ( $class != "IPS\Member" ) { $thing = $class::loadAndCheckPerms( (int) Request::i()->follow_id ); $count = $thing->followersCount(); } else { if( !IPS::classUsesTrait( $class, 'IPS\Content\Followable' ) AND $class != "IPS\Member" ) { Output::i()->error( 'node_error', '2C154/J', 404, '' ); } $thing = $class::load( (int) Request::i()->follow_id ); $count = $thing->followersCount(); } } catch ( OutOfRangeException $e ) { Output::i()->error( 'node_error', '2C154/6', 404, '' ); } if ( Request::i()->follow_area == 'member' && ( !isset( Request::i()->button_type ) || Request::i()->button_type === 'search' ) ) { $size = isset( Request::i()->button_size ) ? Request::i()->button_size : 'normal'; if ( isset( Request::i()->button_type ) && Request::i()->button_type === 'search' ) { Output::i()->sendOutput( Theme::i()->getTemplate( 'profile' )->memberSearchFollowButton( Request::i()->follow_app, Request::i()->follow_area, Request::i()->follow_id, $count, $size ) ); } else { Output::i()->sendOutput( Theme::i()->getTemplate( 'profile' )->memberFollowButton( Request::i()->follow_app, Request::i()->follow_area, Request::i()->follow_id, $count, $size ) ); } } else { if ( Request::i()->button_type == 'manage' ) { Output::i()->sendOutput( Theme::i()->getTemplate( 'system' )->manageFollowButton( Request::i()->follow_app, Request::i()->follow_area, Request::i()->follow_id ) ); } else { Output::i()->sendOutput( Theme::i()->getTemplate( 'global' )->followButton( Request::i()->follow_app, Request::i()->follow_area, Request::i()->follow_id, $count ) ); } } } /** * Remove all followers * * @return void */ protected function removeFollowers() : void { Session::i()->csrfCheck(); if ( !Member::loggedIn()->modPermission('can_remove_followers') ) { Output::i()->error( 'cant_remove_followers', '2C154/A', 403, 'cant_remove_followers_admin' ); } Db::i()->delete( 'core_follow', array( 'follow_app=? AND follow_area=? AND follow_rel_id=?', Request::i()->follow_app, Request::i()->follow_area, Request::i()->follow_id ) ); Db::i()->delete( 'core_follow_count_cache', array( 'id=? AND class=?', Request::i()->follow_id, 'IPS\\' . Request::i()->follow_app . '\\' . IPS::mb_ucfirst( Request::i()->follow_area ) ) ); if( Request::i()->follow_area == 'club' ) { try { $club = Club::load( Request::i()->follow_id ); foreach ( $club->nodes() as $node ) { $itemClass = $node['node_class']::$contentItemClass; $followApp = $itemClass::$application; $followArea = mb_strtolower( mb_substr( $node['node_class'], mb_strrpos( $node['node_class'], '\\' ) + 1 ) ); Db::i()->delete( 'core_follow', array( 'follow_app=? AND follow_area=? AND follow_rel_id=?', $followApp, $followArea, $node['node_id'] ) ); } } catch ( OutOfRangeException $e ) { } } Session::i()->modLog( 'modlog__item_follow_removed', array( Request::i()->follow_app => FALSE, Request::i()->follow_area=> FALSE, Request::i()->follow_id => FALSE ) ); Output::i()->redirect( Request::i()->referrer() ?: Url::internal( '' ), 'followers_removed' ); } /** * Retrieve notification data and return it to the service worker * * @return void */ protected function fetchNotification() : void { /* Got the ID? */ if( !Request::i()->id ) { Output::i()->json( array( 'error' => 'missing_id' ), 404 ); } /* Got the notification? */ try { $notification = Db::i()->select( '*', 'core_notifications_pwa_queue', array( 'id=?', Request::i()->id ) )->first(); } catch( UnderflowException $e ) { Output::i()->json( array( 'error' => 'not_found' ), 404 ); } $data = json_decode( $notification['notification_data'], true ); if ( ! is_array( $data ) ) { Output::i()->json( array( 'error' => 'invalid_data' ), 400 ); } $data['unreadCount'] = Member::loggedIn()->notification_cnt; if( !isset( $data['member'] ) OR $data['member'] != Member::loggedIn()->member_id ) { Output::i()->json( array( 'error' => 'no_permission' ), 403 ); } /* Send the data */ Output::i()->json( $data ); } }