use Friendica\Database\DBA;
use BadMethodCallException;
use Friendica\Database\Database;
+use Friendica\DI;
use Friendica\Model\ItemURI;
class Delivery
* @param integer $uri_id
* @param string $inbox
* @param string $created
+ * @param array %receivers
*/
- public static function add(int $uri_id, int $uid, string $inbox, string $created, string $command)
+ public static function add(int $uri_id, int $uid, string $inbox, string $created, string $command, array $receivers)
{
if (empty($uri_id)) {
throw new BadMethodCallException('Empty URI_id');
}
- $fields = ['uri-id' => $uri_id, 'uid' => $uid, 'inbox-id' => ItemURI::getIdByURI($inbox), 'created' => $created, 'command' => $command];
+ $fields = ['uri-id' => $uri_id, 'uid' => $uid, 'inbox-id' => ItemURI::getIdByURI($inbox),
+ 'created' => $created, 'command' => $command, 'receivers' => json_encode($receivers)];
DBA::insert('post-delivery', $fields, Database::INSERT_IGNORE);
}
DBA::delete('post-delivery', ['uri-id' => $uri_id, 'inbox-id' => ItemURI::getIdByURI($inbox)]);
}
+ /**
+ * Remove failed posts for an inbox
+ *
+ * @param string $inbox
+ */
+ public static function removeFailed(string $inbox)
+ {
+ DBA::delete('post-delivery', ["`inbox-id` = ? AND `failed` >= ?", ItemURI::getIdByURI($inbox), DI::config()->get('system', 'worker_defer_limit')]);
+ }
+
/**
* Increment "failed" counter for the given inbox and post
*
public static function selectForInbox(string $inbox)
{
- return DBA::selectToArray('post-delivery', [], ["`inbox-id` = ? AND `failed` < ?", ItemURI::getIdByURI($inbox), 15], ['order' => ['created']]);
+ $rows = DBA::select('post-delivery', [], ["`inbox-id` = ? AND `failed` < ?", ItemURI::getIdByURI($inbox), DI::config()->get('system', 'worker_defer_limit')], ['order' => ['created']]);
+ $deliveries = [];
+ while ($row = DBA::fetch($rows)) {
+ if (!empty($row['receivers'])) {
+ $row['receivers'] = json_decode($row['receivers'], true);
+ } else {
+ $row['receivers'] = [];
+ }
+ $deliveries[] = $row;
+ }
+ DBA::close($rows);
+
+ return $deliveries;
}
}