diff --git a/app/api/services/subscription.py b/app/api/services/subscription.py index 46a9892..3d8043e 100644 --- a/app/api/services/subscription.py +++ b/app/api/services/subscription.py @@ -249,44 +249,23 @@ class SubscriptionService(BaseService): # logger.info(f"^^^^^^^^^^ Key: {key}, Value: {value}") - hook_data = data["data"] + hook_data = data["data"]["object"] logger.info(f"***** HOOK Data ALL ==>>>> {hook_data}") # json_hook_output = json.dumps(hook_data["data"]) - for key, value in hook_data["object"].items(): + for key, value in hook_data.items(): logger.info(f"**************** Key: {key}, Value: {value}") - # data_id = hook_data.id - # logger.info(f"HOOK Data ID ==>>>> {data_id}") - # + data_id = hook_data["id"] + logger.info(f"HOOK Data ID ==>>>> {data_id}") + - # logger.info(f"***** HOOK JSON ALL ==>>>> {json_hook_output}") - # data_id = json_hook_output["id"] - # data_id = json_hook_output.id - # logger.info(f"Subscription_Webhook_Start data ==>>>> {hook_data.id}") - # token = validated_data.get('token') - # uid = validated_data.get('uid') - # customerId = validated_data.get('customerId') - # priceId = validated_data.get('priceId') - # member_data = Members.get_member_by_uid(uid) - # member_id = member_data.id - # option_name = validated_data.get('option_name') - # sub_option = SubscriptionOptions.get_subscription_options_by_option_name(option_name) - # - # if sub_option is None: - # logger.error(f"Invalid Option Name") - # return [] - # - # stripe_session = StripeIntegration.create_checkout_session_subscription(priceId, customerId) - # logger.info(f"Inside Stripe_Session ===== : {stripe_session}") - # logger.info(f"Inside Stripe_Session ID ===== : {stripe_session.id}") - # PaymentsSession.add_payment_session(member_id, option_name, 'STRIPE', stripe_session.id) # Simulate processing response_data = { - "stripe_session":"", + "data_id": data_id, "member_id": "", "uid": "", }