toddy/friendica-addons
1
0
Fork 0
forked from friendica/friendica-addons
Code Pull requests Activity

Bug fix for Twitter

Browse source 
remove references and update functions of removed queue_fn
This commit is contained in:
Adam Magness 2018-01-22 17:52:51 -05:00
parent afaa39ed7b
commit 6d88e63f60
1 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
twitter/twitter.php
View file

@ -69,6 +69,7 @@ use Friendica\Core\Worker;
use Friendica\Model\GContact; use Friendica\Model\GContact;
use Friendica\Model\Group; use Friendica\Model\Group;
use Friendica\Model\Photo; use Friendica\Model\Photo;
use Friendica\Model\Queue;
use Friendica\Model\User; use Friendica\Model\User;
use Friendica\Object\Image; use Friendica\Object\Image;
@ -627,8 +628,9 @@ function twitter_post_hook(App $a, &$b)
} }
$s = serialize(['url' => $url, 'item' => $b['id'], 'post' => $post]); $s = serialize(['url' => $url, 'item' => $b['id'], 'post' => $post]);
require_once 'include/queue_fn.php';
add_to_queue($a->contact, NETWORK_TWITTER, $s); Queue::add($a->contact, NETWORK_TWITTER, $s);
notice(t('Twitter post failed. Queued for retry.') . EOL); notice(t('Twitter post failed. Queued for retry.') . EOL);
} elseif ($iscomment) { } elseif ($iscomment) {
logger('twitter_post: Update extid ' . $result->id_str . " for post id " . $b['id']); logger('twitter_post: Update extid ' . $result->id_str . " for post id " . $b['id']);
@ -925,8 +927,6 @@ function twitter_queue_hook(App $a, &$b)
return; return;
} }
require_once 'include/queue_fn.php';
foreach ($qi as $x) { foreach ($qi as $x) {
if ($x['network'] !== NETWORK_TWITTER) { if ($x['network'] !== NETWORK_TWITTER) {
continue; continue;
@ -972,7 +972,7 @@ function twitter_queue_hook(App $a, &$b)
logger('twitter_queue: Send to Twitter failed: "' . print_r($result->errors, true) . '"'); logger('twitter_queue: Send to Twitter failed: "' . print_r($result->errors, true) . '"');
} else { } else {
$success = true; $success = true;
remove_queue_item($x['id']); Queue::removeItem($x['id']);
} }
} else { } else {
logger("twitter_queue: Error getting tokens for user " . $user['uid']); logger("twitter_queue: Error getting tokens for user " . $user['uid']);
@ -980,7 +980,7 @@ function twitter_queue_hook(App $a, &$b)
if (!$success) { if (!$success) {
logger('twitter_queue: delayed'); logger('twitter_queue: delayed');
update_queue_time($x['id']); Queue::updateTime($x['id']);
} }
} }
} }