83 lines
2.4 KiB
PHP
Executable File
83 lines
2.4 KiB
PHP
Executable File
<?php
|
|
|
|
namespace App\Services\Payments;
|
|
|
|
use Illuminate\Http\Client\Response;
|
|
use Illuminate\Support\Facades\Http;
|
|
use RuntimeException;
|
|
|
|
final class PaddleClient
|
|
{
|
|
public function customer(?string $customerID): ?array
|
|
{
|
|
if (! $customerID || ! config('rsync-studio.paddle.api_key')) {
|
|
return null;
|
|
}
|
|
|
|
$response = $this->request()->get('/customers/'.$customerID);
|
|
|
|
if (! $response->successful()) {
|
|
return null;
|
|
}
|
|
$data = $response->json('data');
|
|
|
|
return is_array($data) ? $data : null;
|
|
}
|
|
|
|
public function updateSubscriptionPrice(string $subscriptionID, string $priceID): array
|
|
{
|
|
$this->requireWritableConfiguration();
|
|
|
|
$response = $this->request()->patch('/subscriptions/'.$subscriptionID, [
|
|
'proration_billing_mode' => 'prorated_immediately',
|
|
'items' => [[
|
|
'price_id' => $priceID,
|
|
'quantity' => 1,
|
|
]],
|
|
]);
|
|
|
|
return $this->subscriptionData($response, 'Paddle could not update the subscription.');
|
|
}
|
|
|
|
public function cancelSubscriptionImmediately(string $subscriptionID): array
|
|
{
|
|
$this->requireWritableConfiguration();
|
|
|
|
$response = $this->request()->post('/subscriptions/'.$subscriptionID.'/cancel', [
|
|
'effective_from' => 'immediately',
|
|
]);
|
|
|
|
return $this->subscriptionData($response, 'Paddle could not cancel the subscription.');
|
|
}
|
|
|
|
private function request()
|
|
{
|
|
return Http::baseUrl((string) config('rsync-studio.paddle.api_url'))
|
|
->withToken((string) config('rsync-studio.paddle.api_key'))
|
|
->acceptJson()
|
|
->timeout(15);
|
|
}
|
|
|
|
private function requireWritableConfiguration(): void
|
|
{
|
|
if (trim((string) config('rsync-studio.paddle.api_key')) === '') {
|
|
throw new RuntimeException('Paddle subscription management is not configured.');
|
|
}
|
|
}
|
|
|
|
private function subscriptionData(Response $response, string $fallback): array
|
|
{
|
|
if (! $response->successful()) {
|
|
$detail = trim((string) ($response->json('error.detail') ?? ''));
|
|
throw new RuntimeException($detail !== '' ? $detail : $fallback);
|
|
}
|
|
|
|
$data = $response->json('data');
|
|
if (! is_array($data)) {
|
|
throw new RuntimeException($fallback);
|
|
}
|
|
|
|
return $data;
|
|
}
|
|
}
|