SyncContainerAccessHandler.php

Go to the documentation of this file.

<?php
 
namespace Elgg\Comments;
 
class SyncContainerAccessHandler {
    
    public function __invoke(\Elgg\Event $event) {
        $entity = $event->getObject();
        if (!$entity instanceof \ElggEntity) {
            return;
        }
        
        // only need update query if access_id of entity has been changed
        if (!array_key_exists('access_id', $entity->getOriginalAttributes())) {
            return;
        }
        
        // need to override access in case comments ended up with ACCESS_PRIVATE
        // and to ensure write permissions
        elgg_call(ELGG_IGNORE_ACCESS, function() use ($entity) {
            $comments = elgg_get_entities([
                'type' => 'object',
                'subtype' => 'comment',
                'container_guid' => $entity->guid,
                'wheres' => [
                    function(\Elgg\Database\QueryBuilder $qb, $main_alias) use ($entity) {
                        return $qb->compare("{$main_alias}.access_id", '!=', $entity->access_id, ELGG_VALUE_INTEGER);
                    },
                ],
                'limit' => false,
                'batch' => true,
                'batch_inc_offset' => false,
            ]);
            
            foreach ($comments as $comment) {
                // Update comment access_id
                $comment->access_id = $entity->access_id;
                $comment->save();
            }
        });
    }
}