friendica
/
friendica-addons
mirror of https://git.friendi.ca/friendica/friendica-addons.git
1
0
Fork 0
Code Issues Releases Wiki Activity

Support for the new worker class

pull/445/head
Michael 2017-11-05 15:07:52 +00:00
parent b534d74e13
commit 3d907bfc53
2 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
pumpio/pumpio.php
View File

@ -5,6 +5,9 @@
* Version: 0.2 * Version: 0.2
* Author: Michael Vogel <http://pirati.ca/profile/heluecht> * Author: Michael Vogel <http://pirati.ca/profile/heluecht>
*/ */
use Friendica\Core\Worker;
require('addon/pumpio/oauth/http.php'); require('addon/pumpio/oauth/http.php');
require('addon/pumpio/oauth/oauth_client.php'); require('addon/pumpio/oauth/oauth_client.php');
require_once('include/enotify.php'); require_once('include/enotify.php');
@ -688,8 +691,7 @@ function pumpio_sync(&$a) {
} }
function pumpio_cron(&$a,$b) { function pumpio_cron(&$a,$b) {
//pumpio_sync($a); Worker::add(PRIORITY_MEDIUM,"addon/pumpio/pumpio_sync.php");
proc_run("php","addon/pumpio/pumpio_sync.php");
} }
function pumpio_fetchtimeline(&$a, $uid) { function pumpio_fetchtimeline(&$a, $uid) {

6
twitter/twitter.php
View File

@ -60,6 +60,8 @@
* Requirements: PHP5, curl [Slinky library] * Requirements: PHP5, curl [Slinky library]
*/ */
use Friendica\Core\Worker;
require_once('include/enotify.php'); require_once('include/enotify.php');
require_once("include/socgraph.php"); require_once("include/socgraph.php");
@ -643,7 +645,7 @@ function twitter_cron($a,$b) {
if(count($r)) { if(count($r)) {
foreach($r as $rr) { foreach($r as $rr) {
logger('twitter: fetching for user '.$rr['uid']); 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']); 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 // To-Do
// check for new contacts once a day // check for new contacts once a day