AppsPlansController::onConstruct() - Code Metrics - Inspection of "Feature cli trial validator" - bakaphp/phalcon-api - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Pull Request — master (#52)

by Rafael

created 2019-02-25 21:12 UTC

AppsPlansController::onConstruct() A

↳ Parent: AppsPlansController

Complexity

Conditions	1
Paths	1

Size

Total Lines	6
Code Lines	4

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	5
CRAP Score	1

Importance

Changes

Metric	Value
cc	1
eloc	4
nc	1
nop	0
dl	0
loc	6
ccs	5
cts	5
cp	1
crap	1
rs	10
c	0
b	0
f	0

<?php

declare(strict_types=1);

namespace Gewaer\Api\Controllers;

use Gewaer\Models\AppsPlans;
use Gewaer\Exception\UnauthorizedHttpException;
use Gewaer\Exception\NotFoundHttpException;
use Stripe\Token as StripeToken;
use Phalcon\Http\Response;
use Phalcon\Validation;
use Phalcon\Validation\Validator\PresenceOf;
use Gewaer\Exception\UnprocessableEntityHttpException;
use Phalcon\Cashier\Subscription;
use Gewaer\Models\UserCompanyApps;
use function Gewaer\Core\paymentGatewayIsActive;

/**
 * Class LanguagesController
 *
 * @package Gewaer\Api\Controllers
 *
 * @property Users $userData
 * @property Request $request
 * @property Config $config
 * @property Apps $app
 * @property \Phalcon\Db\Adapter\Pdo\Mysql $db
 */
class AppsPlansController extends BaseController
{
    /*
     * fields we accept to create
     *
     * @var array
     */
    protected $createFields = [];

    /*
     * fields we accept to create
     *
     * @var array
     */
    protected $updateFields = [];

    /**
     * set objects
     *
     * @return void
     */
    public function onConstruct()
    {
        $this->model = new AppsPlans();
        $this->additionalSearchFields = [
            ['is_deleted', ':', '0'],
            ['apps_id', ':', $this->app->getId()],
        ];
    }

    /**
     * Given the app plan stripe id , subscribe the current company to this aps
     *
     * @return Response
     */
    public function create(): Response
    {
        if (!$this->userData->hasRole('Default.Admins')) {
            throw new UnauthorizedHttpException(_('You dont have permission to subscribe this apps'));
        }

        //Ok let validate user password
        $validation = new Validation();
        $validation->add('stripe_id', new PresenceOf(['message' => _('The plan is required.')]));
        $validation->add('number', new PresenceOf(['message' => _('Credit Card Number is required.')]));
        $validation->add('exp_month', new PresenceOf(['message' => _('Credit Card Number is required.')]));
        $validation->add('exp_year', new PresenceOf(['message' => _('Credit Card Number is required.')]));
        $validation->add('cvc', new PresenceOf(['message' => _('CVC is required.')]));

        //validate this form for password
        $messages = $validation->validate($this->request->getPost());
        if (count($messages)) {
            foreach ($messages as $message) {
                throw new UnprocessableEntityHttpException((string) $message);
            }
        }

        $stripeId = $this->request->getPost('stripe_id');
        $company = $this->userData->defaultCompany;
        $cardNumber = $this->request->getPost('number');
        $expMonth = $this->request->getPost('exp_month');
        $expYear = $this->request->getPost('exp_year');
        $cvc = $this->request->getPost('cvc');

        $appPlan = $this->model->findFirstByStripeId($stripeId);

        if (!is_object($appPlan)) {
            throw new NotFoundHttpException(_('This plan doesnt exist'));
        }

        $userSubscription = Subscription::findFirst([
            'conditions' => 'user_id = ?0 and companies_id = ?1 and apps_id = ?2 and is_deleted  = 0',
            'bind' => [$this->userData->getId(), $this->userData->currentCompanyId(), $this->app->getId()]
        ]);

        //we can only run stripe paymenta gateway if we have the key
        if (paymentGatewayIsActive()) {
            $card = StripeToken::create([
                'card' => [
                    'number' => $cardNumber,
                    'exp_month' => $expMonth,
                    'exp_year' => $expYear,
                    'cvc' => $cvc,
                ],
            ], [
                'api_key' => $this->config->stripe->secret
            ])->id;

            $this->db->begin();

            if ($appPlan->free_trial_dates == 0) {
                $this->userData->newSubscription($appPlan->name, $appPlan->stripe_id, $company, $this->app)->create($card);
            } else {
                $this->userData->newSubscription($appPlan->name, $appPlan->stripe_id, $company, $this->app)->trialDays($appPlan->free_trial_dates)->create($card);
            }

            //update company app
            $companyApp = UserCompanyApps::getCurrentApp();

            if ($userSubscription) {

                $userSubscription->stripe_id = $this->userData->active_subscription_id;
                if (!$userSubscription->update()) {
                    $this->db->rollback();
                    throw new UnprocessableEntityHttpException((string)current($userSubscription->getMessages()));
                }
            }

            //update the company app to the new plan
            if (is_object($companyApp)) {
                $subscription = $this->userData->subscription($appPlan->stripe_plan);
                $companyApp->stripe_id = $stripeId;
                $companyApp->subscriptions_id = $subscription->getId();
                if (!$companyApp->update()) {
                    $this->db->rollback();
                    throw new UnprocessableEntityHttpException((string)current($companyApp->getMessages()));
                }

                //update the subscription with the plan
                $subscription->apps_plans_id = $appPlan->getId();
                if (!$subscription->update()) {
                    $this->db->rollback();
                    throw new UnprocessableEntityHttpException((string)current($subscription->getMessages()));
                }
            }

            $this->db->commit();
        }

        //sucess
        return $this->response($appPlan);
    }

    /**
     * Update a given subscription
     *
     * @param string $stripeId
     * @return Response
     */
    public function edit($stripeId) : Response
    {
        $appPlan = $this->model->findFirstByStripeId($stripeId);

        if (!is_object($appPlan)) {
            throw new NotFoundHttpException(_('This plan doesnt exist'));
        }

        $userSubscription = Subscription::findFirst([
            'conditions' => 'user_id = ?0 and companies_id = ?1 and apps_id = ?2 and is_deleted  = 0',
            'bind' => [$this->userData->getId(), $this->userData->currentCompanyId(), $this->app->getId()]
        ]);

        if (!is_object($userSubscription)) {
            throw new NotFoundHttpException(_('No current subscription found'));
        }

        $this->db->begin();

        $subscription = $this->userData->subscription($userSubscription->name);

        if ($subscription->onTrial()) {
            $subscription->name = $appPlan->name;
            $subscription->stripe_plan = $appPlan->stripe_plan;
        } else {
            $subscription->swap($stripeId);
        }

        //update company app
        $companyApp = UserCompanyApps::getCurrentApp();

        //update the company app to the new plan
        if (is_object($companyApp)) {
            $subscription->name = $stripeId;
            $subscription->save();

            $companyApp->stripe_id = $stripeId;
            $companyApp->subscriptions_id = $subscription->getId();
            if (!$companyApp->update()) {
                $this->db->rollback();
                throw new UnprocessableEntityHttpException((string) current($companyApp->getMessages()));
            }

            //update the subscription with the plan
            $subscription->apps_plans_id = $appPlan->getId();
            if (!$subscription->update()) {
                $this->db->rollback();

                throw new UnprocessableEntityHttpException((string) current($subscription->getMessages()));
            }
        }

        $this->db->commit();

        //return the new subscription plan
        return $this->response($appPlan);
    }

    /**
     * Cancel a given subscription
     *
     * @param string $stripeId
     * @return Response
     */
    public function delete($stripeId): Response
    {
        $appPlan = $this->model->findFirstByStripeId($stripeId);

        if (!is_object($appPlan)) {
            throw new NotFoundHttpException(_('This plan doesnt exist'));
        }

        $userSubscription = Subscription::findFirst([
            'conditions' => 'user_id = ?0 and companies_id = ?1 and apps_id = ?2 and is_deleted  = 0',
            'bind' => [$this->userData->getId(), $this->userData->currentCompanyId(), $this->app->getId()]
        ]);

        if (!is_object($userSubscription)) {
            throw new NotFoundHttpException(_('No current subscription found'));
        }

        $subscription = $this->userData->subscription($userSubscription->name);

        //if on trial you can cancel without going to stripe
        if (!$subscription->onTrial()) {
            $subscription->cancel();
        }

        $subscription->is_deleted = 1;
        $subscription->update();

        return $this->response($appPlan);
    }

    /**
     * Update payment method
     * @return Response
     */
    public function updatePaymentMethod(): Response
    {
        //Ok let validate user password
        $validation = new Validation();
        $validation->add('number', new PresenceOf(['message' => _('Credit Card Number is required.')]));
        $validation->add('exp_month', new PresenceOf(['message' => _('Credit Card Number is required.')]));
        $validation->add('exp_year', new PresenceOf(['message' => _('Credit Card Number is required.')]));
        $validation->add('cvc', new PresenceOf(['message' => _('CVC is required.')]));

        //validate this form for password
        $messages = $validation->validate($this->request->getPost());
        if (count($messages)) {
            foreach ($messages as $message) {
                throw new UnprocessableEntityHttpException((string) $message);
            }
        }

        $cardNumber = $this->request->getPost('number');
        $expMonth = $this->request->getPost('exp_month');
        $expYear = $this->request->getPost('exp_year');
        $cvc = $this->request->getPost('cvc');

        $customerId = $this->userData->stripe_id;

        //Create a new card token
        $token = StripeToken::create([
            'card' => [
                'number' => $cardNumber,
                'exp_month' => $expMonth,
                'exp_year' => $expYear,
                'cvc' => $cvc,
            ],
        ], [
            'api_key' => $this->config->stripe->secret
        ])->id;

        return $this->userData->updatePaymentMethod($customerId, $token);
    }
}


1		<?php
2
3		declare(strict_types=1);
4
5		namespace Gewaer\Api\Controllers;
6
7		use Gewaer\Models\AppsPlans;
8		use Gewaer\Exception\UnauthorizedHttpException;
9		use Gewaer\Exception\NotFoundHttpException;
10		use Stripe\Token as StripeToken;
11		use Phalcon\Http\Response;
12		use Phalcon\Validation;
13		use Phalcon\Validation\Validator\PresenceOf;
14		use Gewaer\Exception\UnprocessableEntityHttpException;
15		use Phalcon\Cashier\Subscription;
16		use Gewaer\Models\UserCompanyApps;
17		use function Gewaer\Core\paymentGatewayIsActive;
18
19		/**
20		* Class LanguagesController
21		*
22		* @package Gewaer\Api\Controllers
23		*
24		* @property Users $userData
25		* @property Request $request
26		* @property Config $config
27		* @property Apps $app
28		* @property \Phalcon\Db\Adapter\Pdo\Mysql $db
29		*/
30		class AppsPlansController extends BaseController
31		{
32		/*
33		* fields we accept to create
34		*
35		* @var array
36		*/
37		protected $createFields = [];
38
39		/*
40		* fields we accept to create
41		*
42		* @var array
43		*/
44		protected $updateFields = [];
45
46		/**
47		* set objects
48		*
49		* @return void
50		*/
51	4	public function onConstruct()
52		{
53	4	$this->model = new AppsPlans();
54	4	$this->additionalSearchFields = [
55	4	['is_deleted', ':', '0'],
56	4	['apps_id', ':', $this->app->getId()],
57		];
58	4	}
59
60		/**
61		* Given the app plan stripe id , subscribe the current company to this aps
62		*
63		* @return Response
64		*/
65	1	public function create(): Response
66		{
67	1	if (!$this->userData->hasRole('Default.Admins')) {
68		throw new UnauthorizedHttpException(_('You dont have permission to subscribe this apps'));
69		}
70
71		//Ok let validate user password
72	1	$validation = new Validation();
73	1	$validation->add('stripe_id', new PresenceOf(['message' => _('The plan is required.')]));
74	1	$validation->add('number', new PresenceOf(['message' => _('Credit Card Number is required.')]));
75	1	$validation->add('exp_month', new PresenceOf(['message' => _('Credit Card Number is required.')]));
76	1	$validation->add('exp_year', new PresenceOf(['message' => _('Credit Card Number is required.')]));
77	1	$validation->add('cvc', new PresenceOf(['message' => _('CVC is required.')]));
78
79		//validate this form for password
80	1	$messages = $validation->validate($this->request->getPost());
81	1	if (count($messages)) {
82		foreach ($messages as $message) {
83		throw new UnprocessableEntityHttpException((string) $message);
84		}
85		}
86
87	1	$stripeId = $this->request->getPost('stripe_id');
88	1	$company = $this->userData->defaultCompany;
89	1	$cardNumber = $this->request->getPost('number');
90	1	$expMonth = $this->request->getPost('exp_month');
91	1	$expYear = $this->request->getPost('exp_year');
92	1	$cvc = $this->request->getPost('cvc');
93
94	1	$appPlan = $this->model->findFirstByStripeId($stripeId);
95
96	1	if (!is_object($appPlan)) {
97		throw new NotFoundHttpException(_('This plan doesnt exist'));
98		}
99
100	1	$userSubscription = Subscription::findFirst([
101	1	'conditions' => 'user_id = ?0 and companies_id = ?1 and apps_id = ?2 and is_deleted = 0',
102	1	'bind' => [$this->userData->getId(), $this->userData->currentCompanyId(), $this->app->getId()]
103		]);
104
105		//we can only run stripe paymenta gateway if we have the key
106	1	if (paymentGatewayIsActive()) {
107		$card = StripeToken::create([
108		'card' => [
109		'number' => $cardNumber,
110		'exp_month' => $expMonth,
111		'exp_year' => $expYear,
112		'cvc' => $cvc,
113		],
114		], [
115		'api_key' => $this->config->stripe->secret
116		])->id;
117
118		$this->db->begin();
119
120		if ($appPlan->free_trial_dates == 0) {
121		$this->userData->newSubscription($appPlan->name, $appPlan->stripe_id, $company, $this->app)->create($card);
122		} else {
123		$this->userData->newSubscription($appPlan->name, $appPlan->stripe_id, $company, $this->app)->trialDays($appPlan->free_trial_dates)->create($card);
124		}
125
126		//update company app
127		$companyApp = UserCompanyApps::getCurrentApp();
128
129		if ($userSubscription) {
		0 ignored issues – show introduced 2019-02-14 15:53 UTC by Report Bug Copy Issue Report `$userSubscription` is of type `Phalcon\Mvc\Model`, thus it always evaluated to `true`. Loading history...
130		$userSubscription->stripe_id = $this->userData->active_subscription_id;
131		if (!$userSubscription->update()) {
132		$this->db->rollback();
133		throw new UnprocessableEntityHttpException((string)current($userSubscription->getMessages()));
134		}
135		}
136
137		//update the company app to the new plan
138		if (is_object($companyApp)) {
139		$subscription = $this->userData->subscription($appPlan->stripe_plan);
140		$companyApp->stripe_id = $stripeId;
141		$companyApp->subscriptions_id = $subscription->getId();
142		if (!$companyApp->update()) {
143		$this->db->rollback();
144		throw new UnprocessableEntityHttpException((string)current($companyApp->getMessages()));
145		}
146
147		//update the subscription with the plan
148		$subscription->apps_plans_id = $appPlan->getId();
149		if (!$subscription->update()) {
150		$this->db->rollback();
151		throw new UnprocessableEntityHttpException((string)current($subscription->getMessages()));
152		}
153		}
154
155		$this->db->commit();
156		}
157
158		//sucess
159	1	return $this->response($appPlan);
160		}
161
162		/**
163		* Update a given subscription
164		*
165		* @param string $stripeId
166		* @return Response
167		*/
168	2	public function edit($stripeId) : Response
169		{
170	2	$appPlan = $this->model->findFirstByStripeId($stripeId);
171
172	2	if (!is_object($appPlan)) {
173		throw new NotFoundHttpException(_('This plan doesnt exist'));
174		}
175
176	2	$userSubscription = Subscription::findFirst([
177	2	'conditions' => 'user_id = ?0 and companies_id = ?1 and apps_id = ?2 and is_deleted = 0',
178	2	'bind' => [$this->userData->getId(), $this->userData->currentCompanyId(), $this->app->getId()]
179		]);
180
181	2	if (!is_object($userSubscription)) {
182		throw new NotFoundHttpException(_('No current subscription found'));
183		}
184
185	2	$this->db->begin();
186
187	2	$subscription = $this->userData->subscription($userSubscription->name);
188
189	2	if ($subscription->onTrial()) {
190	2	$subscription->name = $appPlan->name;
191	2	$subscription->stripe_plan = $appPlan->stripe_plan;
192		} else {
193		$subscription->swap($stripeId);
194		}
195
196		//update company app
197	2	$companyApp = UserCompanyApps::getCurrentApp();
198
199		//update the company app to the new plan
200	2	if (is_object($companyApp)) {
201	2	$subscription->name = $stripeId;
202	2	$subscription->save();
203
204	2	$companyApp->stripe_id = $stripeId;
205	2	$companyApp->subscriptions_id = $subscription->getId();
206	2	if (!$companyApp->update()) {
207		$this->db->rollback();
208		throw new UnprocessableEntityHttpException((string) current($companyApp->getMessages()));
209		}
210
211		//update the subscription with the plan
212	2	$subscription->apps_plans_id = $appPlan->getId();
213	2	if (!$subscription->update()) {
214		$this->db->rollback();
215
216		throw new UnprocessableEntityHttpException((string) current($subscription->getMessages()));
217		}
218		}
219
220	2	$this->db->commit();
221
222		//return the new subscription plan
223	2	return $this->response($appPlan);
224		}
225
226		/**
227		* Cancel a given subscription
228		*
229		* @param string $stripeId
230		* @return Response
231		*/
232	1	public function delete($stripeId): Response
233		{
234	1	$appPlan = $this->model->findFirstByStripeId($stripeId);
235
236	1	if (!is_object($appPlan)) {
237		throw new NotFoundHttpException(_('This plan doesnt exist'));
238		}
239
240	1	$userSubscription = Subscription::findFirst([
241	1	'conditions' => 'user_id = ?0 and companies_id = ?1 and apps_id = ?2 and is_deleted = 0',
242	1	'bind' => [$this->userData->getId(), $this->userData->currentCompanyId(), $this->app->getId()]
243		]);
244
245	1	if (!is_object($userSubscription)) {
246		throw new NotFoundHttpException(_('No current subscription found'));
247		}
248
249	1	$subscription = $this->userData->subscription($userSubscription->name);
250
251		//if on trial you can cancel without going to stripe
252	1	if (!$subscription->onTrial()) {
253		$subscription->cancel();
254		}
255
256	1	$subscription->is_deleted = 1;
257	1	$subscription->update();
258
259	1	return $this->response($appPlan);
260		}
261
262		/**
263		* Update payment method
264		* @return Response
265		*/
266		public function updatePaymentMethod(): Response
267		{
268		//Ok let validate user password
269		$validation = new Validation();
270		$validation->add('number', new PresenceOf(['message' => _('Credit Card Number is required.')]));
271		$validation->add('exp_month', new PresenceOf(['message' => _('Credit Card Number is required.')]));
272		$validation->add('exp_year', new PresenceOf(['message' => _('Credit Card Number is required.')]));
273		$validation->add('cvc', new PresenceOf(['message' => _('CVC is required.')]));
274
275		//validate this form for password
276		$messages = $validation->validate($this->request->getPost());
277		if (count($messages)) {
278		foreach ($messages as $message) {
279		throw new UnprocessableEntityHttpException((string) $message);
280		}
281		}
282
283		$cardNumber = $this->request->getPost('number');
284		$expMonth = $this->request->getPost('exp_month');
285		$expYear = $this->request->getPost('exp_year');
286		$cvc = $this->request->getPost('cvc');
287
288		$customerId = $this->userData->stripe_id;
289
290		//Create a new card token
291		$token = StripeToken::create([
292		'card' => [
293		'number' => $cardNumber,
294		'exp_month' => $expMonth,
295		'exp_year' => $expYear,
296		'cvc' => $cvc,
297		],
298		], [
299		'api_key' => $this->config->stripe->secret
300		])->id;
301
302		return $this->userData->updatePaymentMethod($customerId, $token);
303		}
304		}
305

bakaphp / phalcon-api

Pull Request — master (#52)

AppsPlansController::onConstruct() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like