API - Check if user has enough credit/wallet balance to subscribe

Will return error_details object if failed.

apis/onlyfans/classes/create_auth.py

@@ -40,6 +40,7 @@ def __init__(
         self.isPerformer = user.isPerformer
         self.chatMessagesCount = user.chatMessagesCount
         self.subscribesCount = user.subscribesCount
+        self.creditBalance = user.creditBalance
         self.lists = {}
         self.links = content_types()
         self.subscriptions: list[create_user] = []

apis/onlyfans/classes/create_user.py

@@ -488,8 +488,11 @@ async def buy_subscription(self):
             "token": "",
             "unavailablePaymentGates": [],
         }
-        link = endpoint_links().pay
-        result = await self.session_manager.json_request(link, method="POST", payload=x)
+        if self.subscriber.creditBalance >= subscription_price:
+            link = endpoint_links().pay
+            result = await self.session_manager.json_request(link, method="POST", payload=x)
+        else:
+            result = error_details({"code":2011,"message":"Insufficient Credit Balance"})
         return result
 
     def set_scraped(self, name, scraped):

apis/onlyfans/classes/extras.py

@@ -145,7 +145,7 @@ def __init__(
 # Lol?
 class error_details:
     def __init__(self, result) -> None:
-        error = result["error"]
+        error = result["error"] if "error" in result else result
         self.code = error["code"]
         self.message = error["message"]
 

datascraper/main_datascraper.py

@@ -1,3 +1,5 @@
+from apis.onlyfans.classes.create_user import create_user
+from apis.onlyfans.classes.extras import error_details
 import os
 import timeit
 from typing import Optional
@@ -88,6 +90,7 @@ async def start_datascraper(
             auth_count += 1
             subscription_array += subscriptions
             await main_helper.process_webhooks(api, "auth_webhook", "succeeded")
+            # Do stuff with authed user
         subscription_list = module.format_options(
             subscription_array, "usernames", api.auths
         )