openstackid-resources/app/Repositories/Summit/DoctrineSummitNotificationRepository.php
Sebastian Marcet 651a16d8d2 Refactored endpoint to get summit push notifications
GET /api/v1/summits/{id}/notifications

* Expands
** owner
** approved_by

* Filters
** channel ['=='] (sometimes|in:EVERYONE,SPEAKERS,ATTENDEES,MEMBERS,SUMMIT,EVENT,GROUP)
** sent_date ['>', '<', '<=', '>=', '=='] (sometimes|date_format:U)
** created ['>', '<', '<=', '>=', '=='] (sometimes|date_format:U)
** is_sent ['=='] (sometimes|boolean)
** approved ['=='] (sometimes|boolean)
** event_id ['=='] (sometimes|integer)

* Order
** sent_date
** created
** id

Change-Id: Idb93b9a12817c3385150cbb69914b3a089ace6d1
2018-04-16 13:01:51 -03:00

118 lines
3.5 KiB
PHP

<?php namespace App\Repositories\Summit;
/**
* Copyright 2016 OpenStack Foundation
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
* http://www.apache.org/licenses/LICENSE-2.0
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
**/
use Doctrine\Common\Collections\Criteria;
use Doctrine\ORM\Query\Expr\Join;
use Doctrine\ORM\Tools\Pagination\Paginator;
use models\summit\ISummitNotificationRepository;
use models\summit\Summit;
use models\summit\SummitPushNotification;
use App\Repositories\SilverStripeDoctrineRepository;
use utils\Filter;
use utils\Order;
use utils\PagingInfo;
use utils\PagingResponse;
/**
* Class DoctrineSummitNotificationRepository
* @package App\Repositories\Summit
*/
final class DoctrineSummitNotificationRepository
extends SilverStripeDoctrineRepository
implements ISummitNotificationRepository
{
/**
* @return array
*/
protected function getFilterMappings()
{
return [
'event_id' => 'e.id:json_int',
'channel' => 'n.channel:json_string',
'sent_date' => 'n.sent_date:datetime_epoch',
'created' => 'n.created:datetime_epoch',
'is_sent' => 'n.is_sent:json_boolean',
'approved' => 'n.approved:json_boolean',
];
}
/**
* @return array
*/
protected function getOrderMappings()
{
return [
'sent_date' => 'n.sent_date',
'created' => 'n.created',
'id' => 'n.id',
];
}
/**
* @param Summit $summit
* @param PagingInfo $paging_info
* @param Filter|null $filter
* @param Order|null $order
* @return PagingResponse
*/
public function getAllByPageBySummit(Summit $summit, PagingInfo $paging_info, Filter $filter = null, Order $order = null)
{
$query = $this->getEntityManager()->createQueryBuilder()
->select("n")
->from(SummitPushNotification::class, "n")
->leftJoin('n.summit_event', 'e')
->join('n.summit', 's', Join::WITH, " s.id = :summit_id")
->setParameter('summit_id', $summit->getId());
if (!is_null($filter)) {
$filter->apply2Query($query, $this->getFilterMappings());
}
if (!is_null($order)) {
$order->apply2Query($query, $this->getOrderMappings());
} else {
//default order
$query = $query->orderBy('n.id', Criteria::DESC);
}
$query = $query
->setFirstResult($paging_info->getOffset())->setMaxResults($paging_info->getPerPage());
$paginator = new Paginator($query, $fetchJoinCollection = true);
$total = $paginator->count();
$data = array();
foreach ($paginator as $entity)
array_push($data, $entity);
return new PagingResponse
(
$total,
$paging_info->getPerPage(),
$paging_info->getCurrentPage(),
$paging_info->getLastPage($total),
$data
);
}
/**
* @return string
*/
protected function getBaseEntity()
{
return SummitPushNotification::class;
}
}