Moved functionality in new model class

src/Model/PushSubscriber.php

@@ -0,0 +1,30 @@
+<?php
+/**
+ * @file src/Model/PushSubscriber.php
+ */
+namespace Friendica\Model;
+
+use Friendica\Core\Worker;
+use dba;
+
+require_once 'include/dba.php';
+
+class PushSubscriber
+{
+	/**
+	 * @param string $priority Priority for push workers
+	 */
+	public static function publishFeed($priority = PRIORITY_HIGH)
+	{
+		// We'll push to each subscriber that has push > 0,
+		// i.e. there has been an update (set in notifier.php).
+		$subscribers = dba::select('push_subscriber', ['id', 'callback_url'], ["`push` > 0 AND `next_try` < UTC_TIMESTAMP()"]);
+
+		while ($subscriber = dba::fetch($subscribers)) {
+			logger("Publish feed to " . $subscriber["callback_url"], LOGGER_DEBUG);
+			Worker::add($priority, 'PubSubPublish', (int)$subscriber["id"]);
+		}
+
+		dba::close($subscribers);
+	}
+}