Listen to potential defer/flush requests of the Talk app

Talk app, good guys, they know what they are doing. Trust me.

Signed-off-by: Joas Schilling <coding@schilljs.com>

lib/App.php

@@ -90,4 +90,12 @@ public function markProcessed(INotification $notification): void {
 			$this->push->flushPayloads();
 		}
 	}
+
+	public function defer(): void {
+		$this->push->deferPayloads();
+	}
+
+	public function flush(): void {
+		$this->push->flushPayloads();
+	}
 }

lib/AppInfo/Application.php

@@ -26,7 +26,10 @@
 use OCA\Notifications\Capabilities;
 use OCA\Notifications\Handler;
 use OCA\Notifications\Notifier\AdminNotifications;
+use OCA\Notifications\Push;
 use OCP\AppFramework\IAppContainer;
+use OCP\EventDispatcher\IEventDispatcher;
+use OCP\Notification\IApp;
 use OCP\Util;
 
 class Application extends \OCP\AppFramework\App {
@@ -44,6 +47,7 @@ public function __construct() {
 
 	public function register(): void {
 		$this->registerNotificationApp();
+		$this->registerTalkDeferPushing();
 		$this->registerAdminNotifications();
 		$this->registerUserInterface();
 		$this->registerUserDeleteHook();
@@ -77,6 +81,22 @@ protected function registerUserInterface(): void {
 		}
 	}
 
+	protected function registerTalkDeferPushing(): void {
+		/** @var IEventDispatcher $dispatcher */
+		$dispatcher = $this->getContainer()->getServer()->query(IEventDispatcher::class);
+
+		$dispatcher->addListener(IApp::class . '::defer', function() {
+			/** @var App $app */
+			$app = $this->getContainer()->query(App::class);
+			$app->defer();
+		});
+		$dispatcher->addListener(IApp::class . '::flush', function() {
+			/** @var App $app */
+			$app = $this->getContainer()->query(App::class);
+			$app->flush();
+		});
+	}
+
 	protected function registerUserDeleteHook(): void {
 		Util::connectHook('OC_User', 'post_deleteUser', $this, 'deleteUser');
 	}