[TASK] Mail queue only for root page id

Classes/Controller/QueueController.php

@@ -24,6 +24,7 @@ namespace SGalinski\SgMail\Controller;
  *
  *  This copyright notice MUST APPEAR in all copies of the script!
  ***************************************************************/
+use SGalinski\SgMail\Service\BackendService;
 use SGalinski\SgMail\Service\MailTemplateService;
 use TYPO3\CMS\Backend\Template\Components\ButtonBar;
 use TYPO3\CMS\Backend\Template\Components\DocHeaderComponent;
@@ -68,10 +69,13 @@ class QueueController extends ActionController {
 			$selectedExtension = key($registerArray);
 			$selectedTemplate = key($registerArray[$selectedExtension]);
 		}
-		$queue = $this->mailRepository->findAllEntries($selectedExtension, $selectedTemplate);
 
-		// create doc header component
 		$pageUid = (int) GeneralUtility::_GP('id');
+		$siteRootId = BackendService::getSiteRoot($pageUid)['uid'];
+		debug($siteRootId);
+		$queue = $this->mailRepository->findAllEntries($selectedExtension, $selectedTemplate, $siteRootId);
+
+		// create doc header component
 		$pageInfo = BackendUtility::readPageAccess($pageUid, $GLOBALS['BE_USER']->getPagePermsClause(1));
 		$this->docHeaderComponent = GeneralUtility::makeInstance(DocHeaderComponent::class);
 

Classes/Domain/Repository/MailRepository.php

@@ -55,10 +55,11 @@ class MailRepository extends AbstractRepository {
 	 *
 	 * @param string $extensionKey
 	 * @param string $templateName
+	 * @param int siteroot
 	 * @param int $limit
 	 * @return array|QueryResultInterface
 	 */
-	public function findAllEntries($extensionKey, $templateName, $limit = NULL) {
+	public function findAllEntries($extensionKey, $templateName, $siteroot = 0, $limit = NULL) {
 		$query = $this->createQuery();
 		if ($limit) {
 			$query->setLimit($limit);
@@ -66,6 +67,7 @@ class MailRepository extends AbstractRepository {
 
 		$constraintsAnd[] = $query->equals('extension_key', $extensionKey);
 		$constraintsAnd[] = $query->equals('template_name', $templateName);
+		$constraintsAnd[] = $query->equals('site_root_id', (int) $siteroot);
 
 		$query->setOrderings(['tstamp' => Query::ORDER_DESCENDING]);
 		return $query->matching($query->logicalAnd($constraintsAnd))->execute(TRUE);