From 1f5df847966de7e0388bfcba757e0b6ad7d0cbcf Mon Sep 17 00:00:00 2001
From: Maxence Lange <maxence@artificial-owl.com>
Date: Mon, 12 Aug 2019 17:37:21 -0100
Subject: [PATCH] generating events

Signed-off-by: Maxence Lange <maxence@artificial-owl.com>
---
 lib/Service/PushService.php | 16 ++++++++++++++++
 1 file changed, 16 insertions(+)

diff --git a/lib/Service/PushService.php b/lib/Service/PushService.php
index 23124197..c070bb86 100644
--- a/lib/Service/PushService.php
+++ b/lib/Service/PushService.php
@@ -32,6 +32,7 @@ namespace OCA\Social\Service;
 
 
 use daita\MySmallPhpTools\Traits\TAsync;
+use OC\Stratos\Model\Helper\StratosEvent;
 use OCA\Social\Exceptions\SocialAppConfigException;
 use OCA\Social\Model\ActivityPub\Actor\Person;
 use OCA\Social\Model\ActivityPub\Stream;
@@ -40,6 +41,7 @@ use OCP\Stratos\Exceptions\StratosInstallException;
 use OCP\Stratos\IStratosManager;
 use OCP\Stratos\Model\IStratosWrapper;
 
+
 /**
  * Class PushService
  *
@@ -86,6 +88,7 @@ class PushService {
 	 * @param Stream $stream
 	 *
 	 * @throws SocialAppConfigException
+	 * @throws StratosInstallException
 	 */
 	public function onNewStream(Stream $stream) {
 		// FIXME: remove in nc18
@@ -97,17 +100,30 @@ class PushService {
 			return;
 		}
 
+		$stratosHelper = $this->stratosManager->getStratosHelper();
+
 		$details = $this->detailsService->generateDetailsFromStream($stream);
 		$home = array_map(
 			function(Person $item): string {
 				return $item->getUserId();
 			}, $details->getHomeViewers()
 		);
+
+		$event = new StratosEvent('social', 'Social.timeline.home');
+		$event->addUsers($home);
+		$event->setPayloadSerializable($stream);
+		$stratosHelper->broadcastEvent($event);
+
 		$direct = array_map(
 			function(Person $item): string {
 				return $item->getUserId();
 			}, $details->getDirectViewers()
 		);
+
+		$event = new StratosEvent('social', 'Social.timeline.direct');
+		$event->addUsers($direct);
+		$event->setPayloadSerializable($stream);
+		$stratosHelper->broadcastEvent($event);
 	}