subscriptionChangeSaver = $subscriptionChangeSaver; $this->subscriptionChangeRepository = $subscriptionChangeRepository; $this->userId = $UserId; } /** * * @NoAdminRequired * @NoCSRFRequired * * @return void */ public function create($add, $remove) { return $this->subscriptionChangeSaver->saveSubscriptionChanges($add, $remove, $this->userId); } /** * * @NoAdminRequired * @NoCSRFRequired * * @param int $since * @return JSONResponse * @throws \Exception */ public function list(int $since = null): JSONResponse { $sinceDatetime = $this->createDateTimeFromTimestamp($since); return new JSONResponse([ "add" => $this->extractUrlList($this->subscriptionChangeRepository->findAllSubscribed($sinceDatetime, $this->userId)), "remove" => $this->extractUrlList($this->subscriptionChangeRepository->findAllUnSubscribed($sinceDatetime, $this->userId)), "timestamp" => time() ]); } /** * @param int|null $since * * @return DateTime */ private function createDateTimeFromTimestamp(?int $since): DateTime { return ($since) ? (new \DateTime)->setTimestamp($since) : (new \DateTime('-1 week')); } /** * @param array $allSubscribed * * @return mixed */ private function extractUrlList(array $allSubscribed): array { return array_map(function (SubscriptionChangeEntity $subscription) { return $subscription->getUrl(); }, $allSubscribed); } }