alxmsl\Google\AndroidPublisher\Purchases\Subscriptions\SubscriptionsClient

Complexity

Total Complexity

12

Size/Duplication

Total Lines	107
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

42.55%

Importance

Changes	2
Bugs	1	Features	1

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	cancel()	0	4	1
A	defer()	0	12	1
A	refund()	0	4	1
A	revokeSubscription()	0	4	1
A	sendRequest()	0	3	1
B	makeRequest()	0	19	5
A	createRequest()	0	10	1

<?php
/*
 * Copyright 2015 Alexey Maslov <alexey.y.maslov@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 alxmsl\Google\AndroidPublisher\Purchases\Subscriptions;

use alxmsl\Google\AndroidPublisher\Purchases\Client;
use alxmsl\Google\AndroidPublisher\Exception\ErrorException;
use alxmsl\Google\AndroidPublisher\Exception\InvalidCredentialsException;
use alxmsl\Network\Exception\HttpClientErrorCodeException;
use alxmsl\Network\Exception\HttpServerErrorCodeException;
use alxmsl\Network\Exception\TransportException;
use alxmsl\Network\Http\Request;
use UnexpectedValueException;

/**
 * Client for Google Play subscriptions API
 * @author alxmsl
 */
final class SubscriptionsClient extends Client implements SubscriptionsClientInterface {
    public function __construct() {
        parent::__construct(self::TYPE_SUBSCRIPTIONS);
    }

    /**
     * @inheritdoc
     */
    public function cancel($productId, $token) {
        $this->sendRequest('cancel', $productId, $token);
        return true;
    }

    /**
     * @inheritdoc
     */
    public function defer($productId, $expectedTimeMillis, $desiredTimeMillis, $token) {
        $Request = $this->createRequest('defer', $productId, $token)
            ->setPostData(json_encode([
                'deferralInfo' => [
                    'expectedExpiryTimeMillis' => $expectedTimeMillis,
                    'desiredExpiryTimeMillis'  => $desiredTimeMillis,
                ],
            ]));
        $response = $this->makeRequest($Request);
        $Object   = json_decode($response);
        return $Object->newExpiryTimeMillis;
    }

    /**
     * @inheritdoc
     */
    public function refund($productId, $token) {
        $this->sendRequest('refund', $productId, $token);
        return true;
    }

    /**
     * @inheritdoc
     */
    public function revokeSubscription($productId, $token) {
        $this->sendRequest('revoke', $productId, $token);
        return true;
    }

    /**
     * Send command for Purchases Subscriptions API
     * @param string $command subscriptions API command
     * @param string $productId product identifier
     * @param string $token purchase product token
     * @return string API response body
     * @throws InvalidCredentialsException when access grants is not granted
     * @throws ErrorException when API error acquired
     * @throws TransportException when HTTP transport error occurred
     * @throws UnexpectedValueException when access token is empty for client
     */
    private function sendRequest($command, $productId, $token) {
        return $this->makeRequest($this->createRequest($command, $productId, $token));
    }

    /**
     * Send command for Purchases Subscriptions API
     * @param Request $Request request instance
     * @return string API response body
     * @throws InvalidCredentialsException when access grants is not granted
     * @throws ErrorException when API error acquired
     * @throws TransportException when HTTP transport error occurred
     * @throws UnexpectedValueException when access token is empty for client
     */
    private function makeRequest(Request $Request) {
        $accessToken = $this->getAccessToken();
        if (!empty($accessToken)) {
            try {
                return $Request->send();
            } catch (HttpClientErrorCodeException $Ex) {
                switch ($Ex->getCode()) {
                    case 401:
                        throw InvalidCredentialsException::initializeByString($Ex->getMessage());
                    default:
                        throw ErrorException::initializeByString($Ex->getMessage());
                }
            } catch (HttpServerErrorCodeException $Ex) {
                throw ErrorException::initializeByString($Ex->getMessage());
            }
        } else {
            throw new UnexpectedValueException('access token is empty');
        }
    }

    /**
     * Create request instance for command
     * @param string $command subscriptions API command
     * @param string $productId product identifier
     * @param string $token purchase product token
     * @return Request HTTP request instance
     */
    private function createRequest($command, $productId, $token) {
        $Request = $this->getRequest(self::ENDPOINT_PURCHASES)
            ->addUrlField('applications', $this->getPackage())
            ->addUrlField(self::URI_SUBSCRIPTIONS, '')
            ->addUrlField('products', $productId)
            ->addUrlField('tokens', sprintf('%s:%s', $token, $command))
            ->addGetField('access_token', $this->getAccessToken());
        $Request->setMethod(Request::METHOD_POST);
        return $Request;
    }
}