send push on addMagnetDownload success only

This commit is contained in:
ghost 2023-09-15 04:06:54 +03:00
parent bacb8b17bf
commit 73f353594c

View File

@ -63,29 +63,30 @@ else if (is_null($user->public))
else else
{ {
// Register magnet download // Register magnet download
$magnetDownloadId = $db->addMagnetDownload($magnet->magnetId, $user->userId, time()); if ($magnetDownloadId = $db->addMagnetDownload($magnet->magnetId, $user->userId, time()))
// Push event to other nodes
if (API_EXPORT_ENABLED &&
API_EXPORT_PUSH_ENABLED &&
API_EXPORT_USERS_ENABLED &&
API_EXPORT_MAGNETS_ENABLED &&
API_EXPORT_MAGNET_DOWNLOADS_ENABLED)
{ {
if (!$memoryApiExportPush = $memory->get('api.export.push')) // Push event to other nodes
{ if (API_EXPORT_ENABLED &&
$memoryApiExportPush = []; API_EXPORT_PUSH_ENABLED &&
API_EXPORT_USERS_ENABLED &&
API_EXPORT_MAGNETS_ENABLED &&
API_EXPORT_MAGNET_DOWNLOADS_ENABLED)
{
if (!$memoryApiExportPush = $memory->get('api.export.push'))
{
$memoryApiExportPush = [];
}
$memoryApiExportPush[] = (object)
[
'time' => time(),
'userId' => $user->userId,
'magnetId' => $magnet->magnetId,
'magnetDownloadId' => $magnetDownloadId
];
$memory->set('api.export.push', $memoryApiExportPush, 3600);
} }
$memoryApiExportPush[] = (object)
[
'time' => time(),
'userId' => $user->userId,
'magnetId' => $magnet->magnetId,
'magnetDownloadId' => $magnetDownloadId
];
$memory->set('api.export.push', $memoryApiExportPush, 3600);
} }
// Build magnet link // Build magnet link