From: Mikael Nordfeldth <mmn@hethane.se>
Date: Thu, 5 Nov 2015 15:16:02 +0000 (+0100)
Subject: Merge branch 'master' of git.gnu.io:gnu/gnu-social into nightly
X-Git-Url: https://git.mxchange.org/?a=commitdiff_plain;h=7ccd36849e945260bb8169c816d96901e90f6a26;p=quix0rs-gnu-social.git

Merge branch 'master' of git.gnu.io:gnu/gnu-social into nightly

Conflicts:
	plugins/OStatus/OStatusPlugin.php

master vs. nightly thing
---

7ccd36849e945260bb8169c816d96901e90f6a26
diff --cc plugins/OStatus/OStatusPlugin.php
index 5a871f322b,bc08a62eff..e8a3c2d666
--- a/plugins/OStatus/OStatusPlugin.php
+++ b/plugins/OStatus/OStatusPlugin.php
@@@ -1366,34 -1355,19 +1369,50 @@@ class OStatusPlugin extends Plugi
          return true;
      }
  
 +    public function onSalmonSlap($endpoint_uri, MagicEnvelope $magic_env, Profile $target=null)
 +    {
 +        $envxml = $magic_env->toXML($target);
 +
 +        $headers = array('Content-Type: application/magic-envelope+xml');
 +
 +        try {
 +            $client = new HTTPClient();
 +            $client->setBody($envxml);
 +            $response = $client->post($endpoint_uri, $headers);
 +        } catch (HTTP_Request2_Exception $e) {
 +            common_log(LOG_ERR, "Salmon post to $endpoint_uri failed: " . $e->getMessage());
 +            return false;
 +        }
 +        if ($response->getStatus() === 422) {
 +            common_debug(sprintf('Salmon (from profile %d) endpoint %s returned status %s. We assume it is a Diaspora seed; will adapt and try again if that plugin is enabled!', $magic_env->getActor()->getID(), $endpoint_uri, $response->getStatus()));
 +            return true;
 +        }
 +
 +        // 200 OK is the best response
 +        // 202 Accepted is what we get from Diaspora for example
 +        if (!in_array($response->getStatus(), array(200, 202))) {
 +            common_log(LOG_ERR, sprintf('Salmon (from profile %d) endpoint %s returned status %s: %s',
 +                                $magic_env->getActor()->getID(), $endpoint_uri, $response->getStatus(), $response->getBody()));
 +            return true;
 +        }
 +
 +        // Since we completed the salmon slap, we discontinue the event
 +        return false;
 +    }
++
+     public function onCronDaily()
+     {
+         try {
+             $sub = FeedSub::renewalCheck();
+         } catch (NoResultException $e) {
+             common_log(LOG_INFO, "There were no expiring feeds.");
+             return;
+         }
+ 
+         $qm = QueueManager::get();
+         while ($sub->fetch()) {
+             $item = array('feedsub_id' => $sub->id);
+             $qm->enqueue($item, 'pushrenew');
+         }
+     }
  }