phparia\Api\Events

Complexity

Total Complexity

4

Size/Duplication

Total Lines	54
Duplicated Lines	27.78 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

0%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	getEvents()	0	17	2
A	createUserEvent()	15	15	2

<?php

/*
 * Copyright 2014 Brian Smith <wormling@gmail.com>.
 *
 * 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.
 */

namespace phparia\Api;

use GuzzleHttp\Exception\RequestException;
use phparia\Client\AriClientAware;
use phparia\Events\Event;
use phparia\Events\EventInterface;
use phparia\Exception\InvalidParameterException;
use phparia\Exception\NotFoundException;
use phparia\Exception\UnprocessableEntityException;

/**
 * Events API
 *
 * @author Brian Smith <wormling@gmail.com>
 */
class Events extends AriClientAware
{
    /**
     * WebSocket connection for events.
     *
     * @param string $app (required) Applications to subscribe to.  Allows comma separated values.
     * @param boolean $subscribeAll Subscribe to all Asterisk events. If provided, the applications listed will be subscribed to all events, effectively disabling the application specific subscriptions. Default is 'false'.
     * @return EventInterface[]
     */
    public function getEvents($app, $subscribeAll = false)
    {
        $uri = 'events';
        $response = $this->client->getEndpoint()->get($uri, [
            'form_params' => [
                'app' => $app,
                'subscribeAll' => $subscribeAll,
            ]
        ]);

        $events = [];
        foreach (\GuzzleHttp\json_decode($response->getBody()) as $event) {
            $events[] = new Event($this->client, $event);
        }

        return $events;
    }

    /**
     *
     * @param string $eventName Event name
     * @param string $application (required) The name of the application that will receive this event
     * @param string $source URI for event source (channel:{channelId}, bridge:{bridgeId}, endpoint:{tech}/{resource}, deviceState:{deviceName}  Allows comma separated values.
     * @param array $variables The "variables" key in the body object holds custom key/value pairs to add to the user event. Ex. { "variables": { "key": "value" }
     * }
     * @throws InvalidParameterException
     * @throws NotFoundException
     * @throws UnprocessableEntityException
     */
    public function createUserEvent($eventName, $application, $source, $variables = array())
    {
        $uri = "events/user/$eventName";
        try {
            $this->client->getEndpoint()->post($uri, [
                'form_params' => [
                    'application' => $application,
                    'source' => $source,
                    'variables' => array_map('strval', $variables),
                ]
            ]);
        } catch (RequestException $e) {
            $this->processRequestException($e);
        }
    }
}