| @@ -582,12 +582,12 @@ | ||
| 582 | 582 | |
| 583 | 583 | return acym_loadObjectList('SELECT * FROM #__acym_followup WHERE `trigger` IN ('.implode(',', $safeTriggers).') AND active = 1'); |
| 584 | 584 | } |
| 585 | 585 | |
| 586 | - public function queueForSubscribers(int $emailId): bool | |
| 586 | + public function queueForSubscribers(int $emailId): ?int | |
| 587 | 587 | { |
| 588 | 588 | if (empty($emailId)) { |
| 589 | - return false; | |
| 589 | + return null; | |
| 590 | 590 | } |
| 591 | 591 | |
| 592 | 592 | $mailInfo = acym_loadObject( |
| 593 | 593 | 'SELECT map.*, followup.list_id |
| @@ -595,9 +595,9 @@ | ||
| 595 | 595 | JOIN #__acym_followup AS followup |
| 596 | 596 | ON followup.id = map.followup_id |
| 597 | 597 | WHERE map.mail_id = '.intval($emailId) |
| 598 | 598 | ); |
| 599 | - if (empty($mailInfo)) return false; | |
| 599 | + if (empty($mailInfo)) return null; | |
| 600 | 600 | |
| 601 | 601 | $this->addMailStat($mailInfo->mail_id); |
| 602 | 602 | |
| 603 | 603 | $delay = intval($mailInfo->delay) * intval($mailInfo->delay_unit); |
| @@ -606,9 +606,11 @@ | ||
| 606 | 606 | FROM #__acym_user_has_list |
| 607 | 607 | WHERE status = 1 |
| 608 | 608 | AND list_id = '.intval($mailInfo->list_id); |
| 609 | 609 | |
| 610 | - return (bool)acym_query($query); | |
| 610 | + $addedEmails = acym_query($query); | |
| 611 | + | |
| 612 | + return $addedEmails === false || $addedEmails === null ? null : intval($addedEmails); | |
| 611 | 613 | } |
| 612 | 614 | |
| 613 | 615 | public function getXFollowups(array $options): array |
| 614 | 616 | { |
