Merge pull request #4962 from astifter/fix_cropped_find_button

[friendica.git] / src / Worker / PubSubPublish.php

diff --git a/src/Worker/PubSubPublish.php b/src/Worker/PubSubPublish.php
index 2656cef24b7af5b07adfcd97a5873537b445e6c5..bd4aa0390b953b1b952d648254314aee8409730d 100644 (file)
--- a/src/Worker/PubSubPublish.php
+++ b/src/Worker/PubSubPublish.php
@@ -11,6 +11,8 @@ use Friendica\Core\Config;
 use Friendica\Core\Worker;
 use Friendica\Database\DBM;
 use Friendica\Protocol\OStatus;
+use Friendica\Util\Network;
+use dba;
 
 require_once 'include/items.php';
 
@@ -66,18 +68,17 @@ class PubSubPublish {
                                        $rr['topic']),
                                "X-Hub-Signature: sha1=".$hmac_sig];
 
-               logger('POST '.print_r($headers, true)."\n".$params, LOGGER_DEBUG);
+               logger('POST '.print_r($headers, true)."\n".$params, LOGGER_DATA);
 
-               post_url($rr['callback_url'], $params, $headers);
+               Network::post($rr['callback_url'], $params, $headers);
                $ret = $a->get_curl_code();
 
                if ($ret >= 200 && $ret <= 299) {
                        logger('successfully pushed to '.$rr['callback_url']);
 
                        // set last_update to the "created" date of the last item, and reset push=0
-                       q("UPDATE `push_subscriber` SET `push` = 0, last_update = '%s' WHERE id = %d",
-                               dbesc($last_update),
-                               intval($rr['id']));
+                       $fields = ['push' => 0, 'last_update' => $last_update];
+                       dba::update('push_subscriber', $fields, ['id' => $rr['id']]);
 
                } else {
                        logger('error when pushing to '.$rr['callback_url'].' HTTP: '.$ret);
@@ -89,9 +90,7 @@ class PubSubPublish {
                        if ($new_push > 30) // OK, let's give up
                                $new_push = 0;
 
-                       q("UPDATE `push_subscriber` SET `push` = %d WHERE id = %d",
-                               $new_push,
-                               intval($rr['id']));
+                       dba::update('push_subscriber', ['push' => $new_push], ['id' => $rr['id']]);
                }
        }
 }