Skip to content

Commit

Permalink
Handle the fact that a user can be removed but have feeds in queue
Browse files Browse the repository at this point in the history
  • Loading branch information
fguillot committed Jan 16, 2017
1 parent 13a6d07 commit 856f5fc
Showing 1 changed file with 13 additions and 7 deletions.
20 changes: 13 additions & 7 deletions worker.php
Original file line number Diff line number Diff line change
Expand Up @@ -19,16 +19,22 @@
$start_time = microtime(true);

echo 'Processing feed_id=', $payload['feed_id'], ' for user_id=', $payload['user_id'];
$user = Model\User\get_user_by_id($payload['user_id']);

$session->flush();
$session->setUser(Model\User\get_user_by_id($payload['user_id']));
if (empty($user)) {
echo ', user not found (removed?)'.PHP_EOL;
} else {
$session->flush();
$session->setUser($user);

Handler\Feed\update_feed($payload['user_id'], $payload['feed_id']);
Model\Item\autoflush_read($payload['user_id']);
Model\Item\autoflush_unread($payload['user_id']);
Handler\Feed\update_feed($payload['user_id'], $payload['feed_id']);
Model\Item\autoflush_read($payload['user_id']);
Model\Item\autoflush_unread($payload['user_id']);

echo ', duration='.(microtime(true) - $start_time).' seconds', PHP_EOL;
echo ', duration='.(microtime(true) - $start_time).' seconds', PHP_EOL;

Miniflux\Helper\write_debug_file();
}

Miniflux\Helper\write_debug_file();
$connection->delete($job);
}

0 comments on commit 856f5fc

Please sign in to comment.