openstackid-resources/app/Services/Model/MemberScheduleWorkQueueManager.php

<?php namespace App\Services\Model;
/**
 * Copyright 2017 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 models\summit\CalendarSync\WorkQueue\AbstractCalendarSyncWorkRequest;
use models\summit\CalendarSync\WorkQueue\MemberCalendarScheduleSummitActionSyncWorkRequest;
use models\summit\CalendarSync\WorkQueue\MemberEventScheduleSummitActionSyncWorkRequest;
use models\summit\CalendarSync\WorkQueue\MemberScheduleSummitActionSyncWorkRequest;
/**
 * Class MemberScheduleWorkQueueManager
 * @package services\model
 */
final class MemberScheduleWorkQueueManager
implements ICalendarSyncWorkRequestQueueManager
{
    /**
     * @var array
     */
    private $registered_requests          = [];

    /**
     * @var array
     */
    private $registered_requests_2_delete = [];
    /**
     * @var array
     */
    private $calendars_events             = [];

    /**
     * @param AbstractCalendarSyncWorkRequest $request
     * @param string|null $type
     * @return string
     */
    private function getKey(AbstractCalendarSyncWorkRequest $request, $type = null){
        $event_id = null;
        if($request instanceof MemberEventScheduleSummitActionSyncWorkRequest){
            $event_id = $request->getSummitEventId();
        }
        if(empty($type)) $type = $request->getType();
        return $this->generateKey($type, $request->getCalendarSyncInfo()->getId(), $event_id);
    }

    /**
     * @param string $type
     * @param int $calendar_id
     * @param null|int $event_id
     * @return string
     */
    private function generateKey($type, $calendar_id, $event_id = null){
        $sub_type = is_null($event_id) ? MemberCalendarScheduleSummitActionSyncWorkRequest::SubType : MemberEventScheduleSummitActionSyncWorkRequest::SubType;
        $key      = "{$sub_type}_{$type}_{$calendar_id}";
        if(!is_null($event_id)){
            $key .= "_{$event_id}";
        }
        return $key;
    }

    /**
     * @param AbstractCalendarSyncWorkRequest $request
     * @return bool
     */
    public function registerRequest(AbstractCalendarSyncWorkRequest $request){
        $key = $this->getKey($request);
        if(isset($this->registered_requests[$key])) return false;
        $this->registered_requests[$key] = $request;
        // register request per member calendar
        if($request instanceof MemberEventScheduleSummitActionSyncWorkRequest) {
            $calendar_info_id = $request->getCalendarSyncInfo()->getId();
            if (!isset($this->calendars_events[$calendar_info_id]))
                $this->calendars_events[$calendar_info_id] = [];
            $this->calendars_events[$calendar_info_id][] = $request;
        }

        return true;
    }

    /**
     * @param int $calendar_info_id
     * @return MemberEventScheduleSummitActionSyncWorkRequest[]
     */
    public function getPendingEventsForCalendar($calendar_info_id){
        if (isset($this->calendars_events[$calendar_info_id])){
            return $this->calendars_events[$calendar_info_id];
        }
        return [];
    }

    /**
     * @param int $calendar_info_id
     * @return bool
     */
    public function clearPendingEventsForCalendar($calendar_info_id){
        if (isset($this->calendars_events[$calendar_info_id])){
            unset($this->calendars_events[$calendar_info_id]);
            return true;
        }
        return false;
    }

    /**
     * @param int $calendar_id
     * @param int $event_id
     * @param string $type
     * @return MemberEventScheduleSummitActionSyncWorkRequest[]
     */
    public function getSummitEventRequestFor($calendar_id, $event_id, $type = null){
        $types = [
            AbstractCalendarSyncWorkRequest::TypeAdd,
            AbstractCalendarSyncWorkRequest::TypeRemove,
            AbstractCalendarSyncWorkRequest::TypeUpdate,
        ];

        if(!empty($type)) $types = [$type];
        $list = [];
        foreach ($types as $t){
            $key = $this->generateKey($t, $calendar_id, $event_id);
            if(isset($this->registered_requests[$key]) && !isset($this->registered_requests_2_delete[$key]) ){
                $list[] = $this->registered_requests[$key];
            }
        }
        return $list;
    }

    /**
     * @param int $calendar_id
     * @param string $type
     * @return MemberCalendarScheduleSummitActionSyncWorkRequest|null
     */
    public function getCalendarRequestFor($calendar_id, $type){
        $key = $this->generateKey($type, $calendar_id);
        return isset($this->registered_requests[$key]) ? $this->registered_requests[$key] : null;
    }

    /**
     * @param AbstractCalendarSyncWorkRequest $request
     * @return bool
     */
    public function removeRequest(AbstractCalendarSyncWorkRequest $request){
        $key = $this->getKey($request);
        if(isset($this->registered_requests[$key])){
            unset($this->registered_requests[$key]);
            if($request instanceof MemberEventScheduleSummitActionSyncWorkRequest) {
                $calendar_info_id = $request->getCalendarSyncInfo()->getId();
                if (isset($this->calendars_events[$calendar_info_id])) {
                    // remove from calendar events
                    $key = array_search($request, $this->calendars_events[$calendar_info_id]);
                    if($key!==false){
                        unset($this->calendars_events[$calendar_info_id][$key]);
                        if(isset($this->calendars_events[$calendar_info_id])){
                            unset($this->calendars_events[$calendar_info_id]);
                        }
                    }
                }
            }
            return true;
        }
        return false;
    }

    /**
     * @param AbstractCalendarSyncWorkRequest $request
     * @return bool
     */
    public function registerRequestForDelete(AbstractCalendarSyncWorkRequest $request){
        $key = $this->getKey($request);
        if(isset($this->registered_requests_2_delete[$key])) return false;
        $this->registerRequest($request);
        $this->registered_requests_2_delete[$key] = $request;
        return true;
    }

    /**
     * @return array
     */
    public function getPurgedRequests(){
        $list = [];
        foreach($this->registered_requests as $key => $request){
            if(isset($this->registered_requests_2_delete[$key])) continue;
            $list[] = $request;
        };
        return $list;
    }

    /**
     * @return array
     */
    public function getRequestsToDelete(){
        return array_values($this->registered_requests_2_delete);
    }

    /**
     * @param MemberScheduleSummitActionSyncWorkRequest $request
     * @param string|null $type
     * @return bool
     */
    public function unRegisterRequestForDelete(MemberScheduleSummitActionSyncWorkRequest $request , $type = null){
        $key = $this->getKey($request, $type);
        if(!isset($this->registered_requests_2_delete[$key])) return false;
        unset($this->registered_requests_2_delete[$key]);
        return true;
    }
}