Moved direct storage
This commit is contained in:
parent
b54465ba9c
commit
6c3b1ac4bd
|
@ -616,10 +616,14 @@ class Feed
|
||||||
|
|
||||||
$condition = ['uid' => $item['uid'], 'uri' => $item['uri']];
|
$condition = ['uid' => $item['uid'], 'uri' => $item['uri']];
|
||||||
if (!Item::exists($condition) && !Post\Delayed::exists($item["uri"], $item['uid'])) {
|
if (!Item::exists($condition) && !Post\Delayed::exists($item["uri"], $item['uid'])) {
|
||||||
|
if (!$notify) {
|
||||||
|
Post\Delayed::publish($item, $notify, $taglist, $attachments);
|
||||||
|
} else {
|
||||||
$postings[] = ['item' => $item, 'notify' => $notify,
|
$postings[] = ['item' => $item, 'notify' => $notify,
|
||||||
'taglist' => $taglist, 'attachments' => $attachments];
|
'taglist' => $taglist, 'attachments' => $attachments];
|
||||||
|
}
|
||||||
} else {
|
} else {
|
||||||
Logger::info('Post already exists in the delayed posts queue', ['uri' => $item["uri"]]);
|
Logger::info('Post already crated or exists in the delayed posts queue', ['uri' => $item["uri"]]);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -638,11 +642,6 @@ class Feed
|
||||||
$post_delay = 0;
|
$post_delay = 0;
|
||||||
|
|
||||||
foreach ($postings as $posting) {
|
foreach ($postings as $posting) {
|
||||||
if (!$posting['notify']) {
|
|
||||||
Post\Delayed::publish($posting['item'], $posting['notify'], $posting['taglist'], $posting['attachments']);
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
|
|
||||||
if ($delay > 0) {
|
if ($delay > 0) {
|
||||||
$publish_time = time() + $post_delay;
|
$publish_time = time() + $post_delay;
|
||||||
Logger::notice('Got publishing date', ['delay' => $delay, 'cid' => $contact['id'], 'url' => $contact['url']]);
|
Logger::notice('Got publishing date', ['delay' => $delay, 'cid' => $contact['id'], 'url' => $contact['url']]);
|
||||||
|
@ -657,7 +656,9 @@ class Feed
|
||||||
Logger::notice('Adapting publish time',
|
Logger::notice('Adapting publish time',
|
||||||
['last' => date(DateTimeFormat::MYSQL, $last_publish),
|
['last' => date(DateTimeFormat::MYSQL, $last_publish),
|
||||||
'next' => date(DateTimeFormat::MYSQL, $next_publish),
|
'next' => date(DateTimeFormat::MYSQL, $next_publish),
|
||||||
'publish' => date(DateTimeFormat::MYSQL, $publish_time)]);
|
'publish' => date(DateTimeFormat::MYSQL, $publish_time),
|
||||||
|
'uid' => $posting['item']['uid'], 'cid' => $posting['item']['contact-id'],
|
||||||
|
'uri' => $posting['item']["uri"]]);
|
||||||
$publish_time = $next_publish;
|
$publish_time = $next_publish;
|
||||||
}
|
}
|
||||||
$publish_at = date(DateTimeFormat::MYSQL, $publish_time);
|
$publish_at = date(DateTimeFormat::MYSQL, $publish_time);
|
||||||
|
|
Loading…
Reference in New Issue
Block a user