Fixed 2FA

apis/api_helper.py

@@ -1,6 +1,7 @@
 import asyncio
 import copy
 import hashlib
+import json
 import os
 import re
 import threading
@@ -164,6 +165,8 @@ async def json_request(
         headers = self.session_rules(link)
         headers["accept"] = "application/json, text/plain, */*"
         headers["Connection"] = "keep-alive"
+        temp_payload = payload.copy()
+
         request_method = None
         result = None
         if method == "HEAD":
@@ -172,13 +175,15 @@ async def json_request(
             request_method = session.get
         elif method == "POST":
             request_method = session.post
+            headers["content-type"] = "application/json"
+            temp_payload = json.dumps(payload)
         elif method == "DELETE":
             request_method = session.delete
         else:
             return None
         while True:
             try:
-                response = await request_method(link, headers=headers, data=payload)
+                response = await request_method(link, headers=headers, data=temp_payload)
                 if method == "HEAD":
                     result = response
                 else:

apis/onlyfans/classes/create_auth.py

@@ -99,13 +99,14 @@ async def resolve_auth(auth: create_auth):
                                 response = await self.session_manager.json_request(
                                     link, method="POST", payload=data
                                 )
-                                if "error" in response:
-                                    error.message = response["error"]["message"]
+                                if isinstance(response, error_details):
+                                    error.message = response.message
                                     count += 1
                                 else:
                                     print("Success")
-                                    auth.active = True
+                                    auth.active = False
                                     auth.errors.remove(error)
+                                    await self.get_authed()
                                     break
 
             await resolve_auth(self)
@@ -313,7 +314,7 @@ async def multi(item):
                     continue
                 link = endpoint_links(identifier=identifier).users
                 result = await self.session_manager.json_request(link)
-                if isinstance(result,error_details) or not result["subscribedBy"]:
+                if isinstance(result, error_details) or not result["subscribedBy"]:
                     continue
                 subscription = create_user(result, self)
                 if subscription.isBlocked: