12 Commits
5 changed files with 59 additions and 8 deletions
+1 -1
View File
@@ -1,5 +1,5 @@
{ {
"name": "app-vise/laravel-appstore-server-notifications", "name": "rjgonzale/laravel-appstore-server-notifications",
"description": "Handling Appstore server to server notifications", "description": "Handling Appstore server to server notifications",
"keywords": [ "keywords": [
"app-vise", "app-vise",
+3 -1
View File
@@ -7,16 +7,18 @@ use Appvise\AppStoreNotifications\Model\NotificationType;
use Appvise\AppStoreNotifications\Model\AppleNotification; use Appvise\AppStoreNotifications\Model\AppleNotification;
use Appvise\AppStoreNotifications\Exceptions\WebhookFailed; use Appvise\AppStoreNotifications\Exceptions\WebhookFailed;
use Appvise\AppStoreNotifications\Model\NotificationPayload; use Appvise\AppStoreNotifications\Model\NotificationPayload;
use Illuminate\Support\Facades\Log;
class WebhooksController class WebhooksController
{ {
public function __invoke(Request $request) public function __invoke(Request $request)
{ {
$jobConfigKey = NotificationType::{$request->input('notification_type')}(); $jobConfigKey = NotificationType::{$request->input('notification_type')}();
$this->determineValidRequest($request->input('password'));
AppleNotification::storeNotification($jobConfigKey, $request->input()); AppleNotification::storeNotification($jobConfigKey, $request->input());
//$this->determineValidRequest($request->input('password'));
$payload = NotificationPayload::createFromRequest($request); $payload = NotificationPayload::createFromRequest($request);
$jobClass = config("appstore-server-notifications.jobs.{$jobConfigKey}", null); $jobClass = config("appstore-server-notifications.jobs.{$jobConfigKey}", null);
+1 -1
View File
@@ -8,7 +8,7 @@ class WebhookFailed extends Exception
{ {
public static function nonValidRequest() public static function nonValidRequest()
{ {
return new static("Your shared secret does not match password in Apple's request", 400); return new static("Your shared secret does not match password in Apple's request", 500);
} }
public static function jobClassDoesNotExist(string $jobClass) public static function jobClassDoesNotExist(string $jobClass)
+53 -5
View File
@@ -28,6 +28,43 @@ class NotificationPayload
{ {
} }
public static function createFromArray($notification) {
$instance = new self();
$instance->environment = $notification['environment'];
$instance->password = $notification['password'];
$instance->notificationType = $notification['notification_type'];
$instance->cancellationDate = $notification['cancellation_date'] ?? null;
$instance->cancellationDatePst = $notification['cancellation_date_pst'] ?? null;
$instance->cancellationDateMs = $notification['cancellation_date_ms'] ?? null;
$instance->webOrderLineItemId = $notification['web_order_line_item_id'] ?? null;
$instance->latestReceipt = $notification['latest_receipt'] ?? null;
if (isset($notification['latest_receipt_info'])) {
$instance->latestReceiptInfo = Receipt::createFromArray($notification['latest_receipt_info']);
} else {
$instance->latestReceiptInfo = null;
}
$instance->latestExpiredReceipt = $notification['latest_expired_receipt'] ?? null;
if (isset($notification['latest_expired_receipt_info'])) {
$instance->latestExpiredReceiptInfo = Receipt::createFromArray($notification['latest_expired_receipt_info']);
} else {
$instance->latestExpiredReceiptInfo = null;
}
$instance->autoRenewStatus = $notification['auto_renew_status'];
$instance->autoRenewProductId = $notification['auto_renew_product_id'];
$instance->autoRenewStatusChangeDate = $notification['auto_renew_status_change_date'] ?? null;
$instance->autoRenewStatusChangeDatePst = $notification['auto_renew_status_change_date_pst'] ?? null;
$instance->autoRenewStatusChangeDateMs = $notification['auto_renew_status_change_date_ms'] ?? null;
if (isset($notification['pending_renewal_info'])) {
foreach ($notification['pending_renewal_info'] as $pendingRenewalInfo) {
$instance->pendingRenewalInfo[] = RenewalInfo::createFromRequest($pendingRenewalInfo);
}
} else {
$instance->pendingRenewalInfo = null;
}
return $instance;
}
public static function createFromRequest(Request $request) public static function createFromRequest(Request $request)
{ {
$instance = new self(); $instance = new self();
@@ -38,11 +75,22 @@ class NotificationPayload
$instance->cancellationDatePst = $request->input('cancellation_date_pst'); $instance->cancellationDatePst = $request->input('cancellation_date_pst');
$instance->cancellationDateMs = $request->input('cancellation_date_ms'); $instance->cancellationDateMs = $request->input('cancellation_date_ms');
$instance->webOrderLineItemId = $request->input('web_order_line_item_id'); $instance->webOrderLineItemId = $request->input('web_order_line_item_id');
$instance->latestReceipt = $request->input('latest_receipt');
$instance->latestReceiptInfo = Receipt::createFromArray($request->input('latest_receipt_info')); $unified_receipt = $request->input('unified_receipt');
$instance->latestExpiredReceipt = $request->input('latest_expired_receipt');
if ($request->has('latest_expired_receipt_info')) { $instance->latestReceipt = $request->input('unified_receipt.latest_receipt');
$instance->latestExpiredReceiptInfo = Receipt::createFromArray($request->input('latest_expired_receipt_info')); if ($request->has('unified_receipt.latest_receipt_info')) {
if (count($request->input('unified_receipt.latest_receipt_info')) > 0) {
$instance->latestReceiptInfo = Receipt::createFromArray($request->input('unified_receipt.latest_receipt_info')[0]);
}
} else {
$instance->latestReceiptInfo = null;
}
$instance->latestExpiredReceipt = $request->input('unified_receipt.latest_expired_receipt');
if ($request->has('unified_receipt.latest_expired_receipt_info')) {
if (count($request->input('unified_receipt.latest_expired_receipt_info')) > 0) {
$instance->latestExpiredReceiptInfo = Receipt::createFromArray($request->input('unified_receipt.latest_expired_receipt_info')[0]);
}
} else { } else {
$instance->latestExpiredReceiptInfo = null; $instance->latestExpiredReceiptInfo = null;
} }
+1
View File
@@ -15,4 +15,5 @@ class NotificationType extends Enum
const DID_FAIL_TO_RENEW = 'did_fail_to_renew'; const DID_FAIL_TO_RENEW = 'did_fail_to_renew';
const DID_RECOVER = 'did_recover'; // replaces RENEWAL const DID_RECOVER = 'did_recover'; // replaces RENEWAL
const PRICE_INCREASE_CONSENT = 'price_increase_consent'; const PRICE_INCREASE_CONSENT = 'price_increase_consent';
const DID_RENEW = 'did_renew';
} }