message_thread-8.x-1.x-dev/src/Plugin/Block/MessageThreadHistory.php

<?php

namespace Drupal\message_thread\Plugin\Block;

use Drupal\Core\Block\BlockBase;
use Drupal\Core\Plugin\ContainerFactoryPluginInterface;
use Symfony\Component\DependencyInjection\ContainerInterface;
use Drupal\Core\Extension\ModuleHandler;

/**
 * Provides a 'Message History' Block with links to message thread.
 *
 * This block differs from the Private Messages New Messages block as follows:
 * Links to the thread and not the message.
 * History is reset when viewing thread and not message.
 *
 * @Block(
 *   id = "message_thread_new_message",
 *   admin_label = @Translation("New Messages"),
 * )
 */
class MessageThreadHistory extends BlockBase implements ContainerFactoryPluginInterface {

  /**
   * The module handler.
   *
   * @var \Drupal\Core\Extension\ModuleHandler
   */
  protected $moduleHandler;

  /**
   * Constructs a MessageHistory object.
   *
   * @param array $configuration
   *   A configuration array containing information about the plugin instance.
   * @param string $plugin_id
   *   The plugin_id for the plugin instance.
   * @param mixed $plugin_definition
   *   The plugin implementation definition.
   * @param \Drupal\Core\Extension\ModuleHandler $module_handler
   *   Drupal module handler.
   */
  public function __construct(array $configuration, $plugin_id, $plugin_definition, ModuleHandler $module_handler) {
    parent::__construct($configuration, $plugin_id, $plugin_definition);
    $this->moduleHandler = $module_handler;
  }

  /**
   * {@inheritdoc}
   */
  public static function create(ContainerInterface $container, array $configuration, $plugin_id, $plugin_definition) {
    return new static(
      $configuration,
      $plugin_id,
      $plugin_definition,
      $container->get('module_handler')
    );
  }

  /**
   * {@inheritdoc}
   */
  public function build() {
    if (!$this->moduleHandler->moduleExists('message_history')) {
      return $this->messageHistoryModuleRequired();
    }
    $result = $this->getUnreadMessages();
    $children = [];
    $threads = [];
    foreach ($result as $row) {
      // Find the message thread.
      $thread_id = message_thread_relationship($row->mid);
      // Only add a thread once.
      if (!in_array($thread_id, $threads)) {
        $children[$row->mid] = [
          'New message' => [
            '#markup' => '<a href="/message/thread/' . $thread_id . '">' . $row->name . '</a>',
            '#wrapper_attributes' => [
              'class' => ['message-history-item'],
            ],
          ],
        ];
      }
      $threads[] = $thread_id;
    }

    if (empty($children)) {
      return [
        '#markup' => t('You have no new messages'),
      ];
    }
    $items[] = [
      '#theme' => 'item_list',
      '#items' => $children,
      '#cache' => [
        'max-age' => 0,
      ],
    ];

    return $items;
  }

  /**
   * Get the unread messages.
   */
  protected function getUnreadMessages() {
    // Find messages for the current user.
    return \Drupal::database()->query("SELECT mfd.mid, mfd.uid, ufd.name
      FROM {message_field_data} mfd
      LEFT JOIN {message__field_message_private_to_user} pu
      ON mfd.mid = pu.entity_id
      LEFT JOIN {users_field_data} ufd
      ON mfd.uid = ufd.uid
      WHERE NOT EXISTS (
        SELECT timestamp FROM message_history
        WHERE  mfd.mid = message_history.mid
        AND message_history.uid = :uid
      )
      AND pu.field_message_private_to_user_target_id = :uid
      AND mfd.created > :limit
      AND mfd.uid != :uid", [
        ':uid' => \Drupal::currentUser()->id(),
        ':limit' => HISTORY_READ_LIMIT,
      ]);
  }

  /**
   * Provide a message.
   */
  protected function messageHistoryModuleRequired() {
    return [
      '#markup' => t('Enable Message History Module to display New Messages block'),
    ];
  }

}