From 3d907bfc537445cb7e7562db175b06663906af7f Mon Sep 17 00:00:00 2001 From: Michael Date: Sun, 5 Nov 2017 15:07:52 +0000 Subject: [PATCH] Support for the new worker class --- pumpio/pumpio.php | 6 ++++-- twitter/twitter.php | 6 ++++-- 2 files changed, 8 insertions(+), 4 deletions(-) diff --git a/pumpio/pumpio.php b/pumpio/pumpio.php index f70801a8..787c29b1 100644 --- a/pumpio/pumpio.php +++ b/pumpio/pumpio.php @@ -5,6 +5,9 @@ * Version: 0.2 * Author: Michael Vogel */ + +use Friendica\Core\Worker; + require('addon/pumpio/oauth/http.php'); require('addon/pumpio/oauth/oauth_client.php'); require_once('include/enotify.php'); @@ -688,8 +691,7 @@ function pumpio_sync(&$a) { } function pumpio_cron(&$a,$b) { - //pumpio_sync($a); - proc_run("php","addon/pumpio/pumpio_sync.php"); + Worker::add(PRIORITY_MEDIUM,"addon/pumpio/pumpio_sync.php"); } function pumpio_fetchtimeline(&$a, $uid) { diff --git a/twitter/twitter.php b/twitter/twitter.php index 1fdcb89c..83d07328 100644 --- a/twitter/twitter.php +++ b/twitter/twitter.php @@ -60,6 +60,8 @@ * Requirements: PHP5, curl [Slinky library] */ +use Friendica\Core\Worker; + require_once('include/enotify.php'); require_once("include/socgraph.php"); @@ -643,7 +645,7 @@ function twitter_cron($a,$b) { if(count($r)) { foreach($r as $rr) { logger('twitter: fetching for user '.$rr['uid']); - proc_run(PRIORITY_MEDIUM, "addon/twitter/twitter_sync.php", 1, (int)$rr['uid']); + Worker::add(PRIORITY_MEDIUM, "addon/twitter/twitter_sync.php", 1, (int)$rr['uid']); } } @@ -665,7 +667,7 @@ function twitter_cron($a,$b) { } logger('twitter: importing timeline from user '.$rr['uid']); - proc_run(PRIORITY_MEDIUM, "addon/twitter/twitter_sync.php", 2, (int)$rr['uid']); + Worker::add(PRIORITY_MEDIUM, "addon/twitter/twitter_sync.php", 2, (int)$rr['uid']); /* // To-Do // check for new contacts once a day -- 2.39.5