MrPetovan/friendica-addons
1
0
Fork 0
forked from friendica/friendica-addons
Code Issues Pull requests Packages Projects Releases Wiki Activity

Replace the "Queue" mechanism with deferred workers

Browse source
This commit is contained in:
Michael 2019-04-04 14:14:55 +00:00
parent f226a42443
commit d6578733be
3 changed files with 9 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
diaspora/diaspora.php
View file

@ -18,6 +18,7 @@ use Friendica\Core\PConfig;
use Friendica\Core\Protocol; use Friendica\Core\Protocol;
use Friendica\Database\DBA; use Friendica\Database\DBA;
use Friendica\Model\Queue; use Friendica\Model\Queue;
use Friendica\Core\Worker;
function diaspora_install() function diaspora_install()
{ {
@ -402,8 +403,8 @@ function diaspora_send(App $a, array &$b)
$s = serialize(['url' => $url, 'item' => $b['id'], 'post' => $body]); $s = serialize(['url' => $url, 'item' => $b['id'], 'post' => $body]);
Queue::add($a->contact, Protocol::DIASPORA2, $s); Worker::defer();
notice(L10n::t('Diaspora post failed. Queued for retry.').EOL); notice(L10n::t('Diaspora post failed. Deferred for retry.').EOL);
} }
} }
} }

8
pumpio/pumpio.php
View file

@ -617,8 +617,8 @@ function pumpio_send(App $a, array &$b)
$s = serialize(['url' => $url, 'item' => $b['id'], 'post' => $params]); $s = serialize(['url' => $url, 'item' => $b['id'], 'post' => $params]);
Queue::add($a->contact, Protocol::PUMPIO, $s); Worker::defer();
notice(L10n::t('Pump.io post failed. Queued for retry.').EOL); notice(L10n::t('Pump.io post failed. Deferred for retry.').EOL);
} }
} }
} }
@ -694,8 +694,8 @@ function pumpio_action(App $a, $uid, $uri, $action, $content = "")
$s = serialize(['url' => $url, 'item' => $orig_post["id"], 'post' => $params]); $s = serialize(['url' => $url, 'item' => $orig_post["id"], 'post' => $params]);
Queue::add($a->contact, Protocol::PUMPIO, $s); Worker::defer();
notice(L10n::t('Pump.io like failed. Queued for retry.').EOL); notice(L10n::t('Pump.io like failed. Deferred for retry.').EOL);
} }
} }

4
twitter/twitter.php
View file

@ -692,8 +692,8 @@ function twitter_post_hook(App $a, array &$b)
$s = serialize(['url' => $url, 'item' => $b['id'], 'post' => $post]); $s = serialize(['url' => $url, 'item' => $b['id'], 'post' => $post]);
Queue::add($a->contact, Protocol::TWITTER, $s); Worker::defer();
notice(L10n::t('Twitter post failed. Queued for retry.') . EOL); notice(L10n::t('Twitter post failed. Deferred for retry.') . EOL);
} elseif ($iscomment) { } elseif ($iscomment) {
Logger::log('twitter_post: Update extid ' . $result->id_str . " for post id " . $b['id']); Logger::log('twitter_post: Update extid ' . $result->id_str . " for post id " . $b['id']);
Item::update(['extid' => "twitter::" . $result->id_str], ['id' => $b['id']]); Item::update(['extid' => "twitter::" . $result->id_str], ['id' => $b['id']]);