Async Feed Feature Branch

the purpose of this branch is 1. to asynchronously load newer messages at the top of the feed while
2. Appending older messages to the bottom of the feed as the user scrolls down

config/schema/heartbeat.schema.yml

@@ -73,3 +73,14 @@ heartbeat_feed.config:
     message:
       type: text
       label: 'Feed Choice'
+
+heartbeat_update_feed.config:
+  type: config_object
+  label: 'Feed Update Parameters'
+  mapping:
+    timestamp:
+      type: integer
+      label: 'The last timestamp available'
+    update:
+      type: boolean
+      label: 'Assert whether or not to update the feed'

js/heartbeat.js

@@ -25,6 +25,14 @@
               });
               // #block-heartbeatblock
             }
+
+            Drupal.AjaxCommands.prototype.updateFeed = function(ajax, response, status) {
+              feed = response.feed;
+              timestamp = response.timestamp;
+
+            }
+
+
         }
     }
 })(jQuery, Drupal, drupalSettings);

src/Controller/HeartbeatController.php

@@ -170,4 +170,9 @@ class HeartbeatController extends ControllerBase implements ContainerInjectionIn
     return \Drupal\block\BlockViewBuilder::lazyBuilder('heartbeatblock', 'teaser');
   }
 
+
+  public function updateFeed($arg) {
+
+  }
+
 }

src/HeartbeatStreamServices.php

@@ -13,6 +13,11 @@ use Drupal\Core\Entity\Query\QueryFactory;
  */
 class HeartbeatStreamServices {
 
+
+  protected $lastId;
+
+  protected $latestTimestamp;
+
   /**
    * Drupal\Core\Entity\EntityTypeManager definition.
    *
@@ -99,7 +104,20 @@ class HeartbeatStreamServices {
   public function createStreamForUidsByType($uids, $type) {
     $stream = $this->entityTypeManager->getStorage('heartbeat_stream')->load(array_values($this->loadStream($type))[0]);
 
-    return $this->entityTypeManager->getStorage('heartbeat')->loadMultiple($this->entityQuery->get('heartbeat')->condition('status', 1)->condition('type', array_column($stream->getTypes(), 'target_id'), 'IN')->condition('uid', $uids, 'IN')->sort('created', 'DESC')->execute());
+    $beats = $this->entityTypeManager->getStorage('heartbeat')->loadMultiple($this->entityQuery->get('heartbeat')->condition('status', 1)->condition('type', array_column($stream->getTypes(), 'target_id'), 'IN')->condition('uid', $uids, 'IN')->sort('created', 'DESC')->execute());
+
+    $this->lastId = call_user_func('end', array_keys($beats));
+
+    $this->latestTimestamp = array_values($beats)[0]->getRevisionCreationTime();
+
+    return $beats;
+  }
+
+  public function updateStreamForUidsByType($uids, $type) {
+    $stream = $this->entityTypeManager->getStorage('heartbeat_stream')->load(array_values($this->loadStream($type))[0]);
+
+    return $this->entityTypeManager->getStorage('heartbeat')->loadMultiple($this->entityQuery->get('heartbeat')->condition('status', 1)->condition('revision_created', $this->latestTimestamp, '>')->condition('type', array_column($stream->getTypes(), 'target_id'), 'IN')->condition('uid', $uids, 'IN')->sort('created', 'DESC')->execute());
+
   }
 
 }