Heartbeat block

heartbeat.views.inc

@@ -0,0 +1,37 @@
+<?php
+
+/**
+ * @file
+ * Contains heartbeat\heartbeat.views.inc..
+ * Provide a custom views field data that isn't tied to any other module. */
+
+use Drupal\Component\Utility\NestedArray;
+use Drupal\Core\Entity\EntityStorageInterface;
+use Drupal\Core\Entity\Sql\SqlContentEntityStorage;
+use Drupal\Core\Render\Markup;
+use Drupal\field\FieldConfigInterface;
+use Drupal\field\FieldStorageConfigInterface;
+use Drupal\system\ActionConfigEntityInterface;
+
+/**
+* Implements hook_views_data().
+*/
+function heartbeat_views_data() {
+
+    $data['views']['table']['group'] = t('Custom Global');
+    $data['views']['table']['join'] = array(
+      // #global is a special flag which allows a table to appear all the time.
+      '#global' => array(),
+    );
+
+
+    $data['views']['heartbeat_message_field'] = array(
+        'title' => t('Heartbeat message field'),
+        'help' => t('Heartbeat field formatter which allows for rendering of HTML'),
+        'field' => array(
+            'id' => 'heartbeat_message_field',
+        ),
+    );
+
+    return $data;
+}

src/HeartbeatStreamServices.php

@@ -86,4 +86,8 @@ class HeartbeatStreamServices {
     return $this->entityTypeManager->getStorage('heartbeat_stream')->loadMultiple($this->loadAllEntities());
   }
 
+  public function createStreamForUids($uids) {
+    return $this->entityTypeManager->getStorage('heartbeat')->loadMultiple($this->entityQuery->get('heartbeat')->condition('uid', $uids, 'IN')->sort('created', 'DESC')->execute());
+  }
+
 }

src/Plugin/Block/HeartbeatBlock.php

@@ -0,0 +1,108 @@
+<?php
+
+namespace Drupal\heartbeat\Plugin\Block;
+
+use Drupal\Core\Block\BlockBase;
+use Drupal\Core\Plugin\ContainerFactoryPluginInterface;
+use Symfony\Component\DependencyInjection\ContainerInterface;
+use Drupal\Core\Database\Database;
+use Drupal\heartbeat\HeartbeatTypeServices;
+use Drupal\heartbeat\HeartbeatStreamServices;
+use Drupal\heartbeat\HeartbeatService;
+
+//*  deriver = "Drupal\heartbeat\Plugin\Derivative\HeartbeatBlockDeriver
+
+/**
+ * Provides a 'HeartbeatBlock' block.
+ *
+ * @Block(
+ *  id = "heartbeat_block",
+ *  admin_label = @Translation("Heartbeat block"),
+ * )
+ */
+class HeartbeatBlock extends BlockBase implements ContainerFactoryPluginInterface {
+
+  /**
+   * Drupal\heartbeat\HeartbeatTypeServices definition.
+   *
+   * @var \Drupal\heartbeat\HeartbeatTypeServices
+   */
+  protected $heartbeatTypeServices;
+  /**
+   * Drupal\heartbeat\HeartbeatStreamServices definition.
+   *
+   * @var \Drupal\heartbeat\HeartbeatStreamServices
+   */
+  protected $heartbeatStreamServices;
+  /**
+   * Drupal\heartbeat\HeartbeatService definition.
+   *
+   * @var \Drupal\heartbeat\HeartbeatService
+   */
+  protected $heartbeatService;
+  /**
+   * Construct.
+   *
+   * @param array $configuration
+   *   A configuration array containing information about the plugin instance.
+   * @param string $plugin_id
+   *   The plugin_id for the plugin instance.
+   * @param string $plugin_definition
+   *   The plugin implementation definition.
+   */
+  public function __construct(
+        array $configuration,
+        $plugin_id,
+        $plugin_definition,
+        HeartbeatTypeServices $heartbeat_heartbeattype,
+	HeartbeatStreamServices $heartbeatstream,
+	HeartbeatService $heartbeat
+  ) {
+    parent::__construct($configuration, $plugin_id, $plugin_definition);
+    $this->heartbeatTypeServices = $heartbeat_heartbeattype;
+    $this->heartbeatStreamServices = $heartbeatstream;
+    $this->heartbeatService = $heartbeat;
+  }
+  /**
+   * {@inheritdoc}
+   */
+  public static function create(ContainerInterface $container, array $configuration, $plugin_id, $plugin_definition) {
+    return new static(
+      $configuration,
+      $plugin_id,
+      $plugin_definition,
+      $container->get('heartbeat.heartbeattype'),
+      $container->get('heartbeatstream'),
+      $container->get('heartbeat')
+    );
+  }
+  /**
+   * {@inheritdoc}
+   */
+  public function build() {
+
+    $messages = array();
+    $query = Database::getConnection()->select('heartbeat_friendship', 'hf')
+      ->fields('hf',['uid_target'])
+      ->condition('hf.uid', \Drupal::currentUser()->id())->execute();
+
+    if ($result = $query->fetchAll()) {
+      $uids = array();
+      foreach ($result as $uid) {
+        $uids[] = $uid->uid_target;
+      }
+      foreach($this->heartbeatStreamServices->createStreamForUids($uids) as $heartbeat) {
+        $messages[] = $heartbeat->getMessage()->getValue()[0]['value'];
+      }
+
+      return [
+        '#theme' => 'heartbeat_stream',
+        '#messages' => $messages,
+        '#attached' => array('library' => 'heartbeat/heartbeat')
+      ];
+
+    }
+
+  }
+
+}

src/Plugin/Derivative/HeartbeatBlockDeriver.php

@@ -0,0 +1,88 @@
+<?php
+
+namespace Drupal\heartbeat\Plugin\Derivative;
+
+use Drupal\Component\Plugin\Derivative\DeriverBase;
+use Drupal\Core\Plugin\ContainerFactoryPluginInterface;
+use Drupal\Core\Plugin\Discovery\ContainerDeriverInterface;
+use Symfony\Component\DependencyInjection\ContainerInterface;
+use Drupal\heartbeat\HeartbeatTypeServices;
+use Drupal\heartbeat\HeartbeatStreamServices;
+use Drupal\heartbeat\HeartbeatService;
+
+/**
+ * Provides a block plugin definitions for Heartbeat
+ *
+ */
+class HeartbeatBlockDeriver extends DeriverBase implements ContainerDeriverInterface {
+
+  /**
+   * Drupal\heartbeat\HeartbeatTypeServices definition.
+   *
+   * @var \Drupal\heartbeat\HeartbeatTypeServices
+   */
+  protected $heartbeatTypeService;
+  /**
+   * Drupal\heartbeat\HeartbeatStreamServices definition.
+   *
+   * @var \Drupal\heartbeat\HeartbeatStreamServices
+   */
+  protected $heartbeatStreamService;
+  /**
+   * Drupal\heartbeat\HeartbeatService definition.
+   *
+   * @var \Drupal\heartbeat\HeartbeatService
+   */
+protected $heartbeatService;
+  /**
+   * Construct.
+   *
+   * @param array $configuration
+   *   A configuration array containing information about the plugin instance.
+   * @param string $plugin_id
+   *   The plugin_id for the plugin instance.
+   * @param string $plugin_definition
+   *   The plugin implementation definition.
+   */
+  public function __construct(
+    $plugin_id,
+    HeartbeatTypeServices $heartbeat_heartbeattype,
+    HeartbeatStreamServices $heartbeatstream,
+    HeartbeatService $heartbeat
+  ) {
+    parent::__construct($plugin_id);
+    $this->heartbeatTypeService = $heartbeat_heartbeattype;
+    $this->heartbeatStreamServices = $heartbeatstream;
+    $this->heartbeatService = $heartbeat;
+  }
+  /**
+   * {@inheritdoc}
+   */
+  public static function create(ContainerInterface $container, $plugin_id) {
+    return new static(
+
+
+      $plugin_id,
+
+      $container->get('heartbeat.heartbeattype'),
+      $container->get('heartbeatstream'),
+      $container->get('heartbeat')
+    );
+  }
+  /**
+   * {@inheritdoc}
+   */
+  public function build() {
+    $build = [];
+    $build['heartbeat_block']['#markup'] = 'Implement HeartbeatBlock.';
+
+    return $build;
+  }
+
+  public function getDerivativeDefinitions($base_plugin_definition) {
+    $def2 = parent::getDerivativeDefinitions($base_plugin_definition);
+    return $base_plugin_definition;
+  }
+
+}
+

src/Plugin/Field/FieldFormatter/HeartbeatFieldFormatter.php

@@ -0,0 +1,80 @@
+<?php
+
+namespace Drupal\heartbeat\Plugin\Field\FieldFormatter;
+
+use Drupal\Component\Utility\Html;
+use Drupal\Core\Field\FieldItemInterface;
+use Drupal\Core\Field\FieldItemListInterface;
+use Drupal\Core\Field\FormatterBase;
+use Drupal\Core\Form\FormStateInterface;
+
+/**
+ * Plugin implementation of the 'heartbeat_field_formatter' formatter.
+ *
+ * @FieldFormatter(
+ *   id = "heartbeat_field_formatter",
+ *   label = @Translation("Heartbeat field formatter"),
+ *   field_types = {
+ *     "text_long"
+ *   }
+ * )
+ */
+class HeartbeatFieldFormatter extends FormatterBase {
+
+  /**
+   * {@inheritdoc}
+   */
+  public static function defaultSettings() {
+    return [
+      // Implement default settings.
+    ] + parent::defaultSettings();
+  }
+
+  /**
+   * {@inheritdoc}
+   */
+  public function settingsForm(array $form, FormStateInterface $form_state) {
+    return [
+      // Implement settings form.
+    ] + parent::settingsForm($form, $form_state);
+  }
+
+  /**
+   * {@inheritdoc}
+   */
+  public function settingsSummary() {
+    $summary = [];
+    // Implement settings summary.
+
+    return $summary;
+  }
+
+  /**
+   * {@inheritdoc}
+   */
+  public function viewElements(FieldItemListInterface $items, $langcode) {
+    $elements = [];
+
+    foreach ($items as $delta => $item) {
+      $elements[$delta] = ['#markup' => $this->viewValue($item)];
+    }
+
+    return $elements;
+  }
+
+  /**
+   * Generate the output appropriate for one field item.
+   *
+   * @param \Drupal\Core\Field\FieldItemInterface $item
+   *   One field item.
+   *
+   * @return string
+   *   The textual output generated.
+   */
+  protected function viewValue(FieldItemInterface $item) {
+    // The text value has no text format assigned to it, so the user input
+    // should equal the output, including newlines.
+    return nl2br(Html::escape($item->value));
+  }
+
+}

src/Plugin/views/field/HeartbeatMessageField.php

@@ -0,0 +1,91 @@
+<?php
+
+namespace Drupal\heartbeat\Plugin\views\field;
+
+use Drupal\Core\Form\FormStateInterface;
+use Drupal\Component\Utility\Random;
+use Drupal\views\Plugin\views\field\MultiItemsFieldHandlerInterface;
+use Drupal\views\Plugin\views\field\FieldPluginBase;
+use Drupal\views\ResultRow;
+
+/**
+ * A handler to provide a field that is completely custom by the administrator.
+ *
+ * @ingroup views_field_handlers
+ *
+ * @ViewsField("heartbeat_message_field")
+ */
+class HeartbeatMessageField extends FieldPluginBase implements MultiItemsFieldHandlerInterface {
+
+  /**
+   * {@inheritdoc}
+   */
+  public function usesGroupBy() {
+    return FALSE;
+  }
+
+  /**
+   * {@inheritdoc}
+   */
+  public function query() {
+    // Do nothing -- to override the parent query.
+  }
+
+  /**
+   * {@inheritdoc}
+   */
+  protected function defineOptions() {
+    $options = parent::defineOptions();
+
+    $options['hide_alter_empty'] = ['default' => FALSE];
+    return $options;
+  }
+
+  /**
+   * {@inheritdoc}
+   */
+  public function buildOptionsForm(&$form, FormStateInterface $form_state) {
+    parent::buildOptionsForm($form, $form_state);
+  }
+
+  /**
+   * Renders a single item of a row.
+   *
+   * @param int $count
+   *   The index of the item inside the row.
+   * @param mixed $item
+   *   The item for the field to render.
+   *
+   * @return string
+   *   The rendered output.
+   */
+  public function render_item($count, $item) {
+    return check_markup($item['value'], 'full_html');
+  }
+
+  /**
+   * Gets an array of items for the field.
+   *
+   * @param \Drupal\views\ResultRow $values
+   *   The result row object containing the values.
+   *
+   * @return array
+   *   An array of items for the field.
+   */
+  public function getItems(ResultRow $values) {
+  }
+
+  /**
+   * Render all items in this field together.
+   *
+   * @param array $items
+   *   The items provided by getItems for a single row.
+   *
+   * @return string
+   *   The rendered items.
+   */
+  public function renderItems($items)
+  {
+    // TODO: Implement renderItems() method.
+  }
+}