Ошибка при работе с апи Твича

При попытке оформить бесплатную сабку на канал твича с подпиской Amazon Prime приходит ответ:

{'errors': [{'message': 'failed integrity check', 'path': ['purchaseOffer']}], 'data': {'purchaseOffer': None}, 'extensions': {'challenge': {'type': 'integrity'}, 'durationMilliseconds': 3, 'operationName': 'PurchaseOrderContext_PurchaseOffer', 'requestID': '01JQF6K2TPYCZN7STWRR8PPJTX'}}

Код

{'errors': [{'message': 'failed integrity check', 'path': ['purchaseOffer']}], 'data': {'purchaseOffer': None}, 'extensions': {'challenge': {'type': 'integrity'}, 'durationMilliseconds': 3, 'operationName': 'PurchaseOrderContext_PurchaseOffer', 'requestID': '01JQF6K2TPYCZN7STWRR8PPJTX'}}

Как можно исправить эту ошибку?

api.py

from curl_cffi.requests import AsyncSession
from datetime import datetime
import pycountry


class InvalidToken(Exception):
pass


class Twitch:
def __init__(
self,
token: str,
client_id: str = "xxxxxxxxxx",
):
self.token = token
self.client_id = client_id

self._session = AsyncSession(
impersonate="chrome",
allow_redirects=False,
timeout=10,
)

async def _gql_request(
self, operation_name: str, operation_hash: str, variables: dict
):
headers = {
"Client-Id": self.client_id,
"Authorization": f"OAuth {self.token}",
}

data = {
"extensions": {
"persistedQuery": {
"version": 1,
"sha256Hash": operation_hash,
}
},
"operationName": operation_name,
"variables": variables,
}

response = await self._session.post(
"https://gql.twitch.tv/gql",
headers=headers,
json=data,
)

if response.status_code == 401:
raise InvalidToken("Invalid token")

return response.json()

async def get_current_user(self):
response = await self._gql_request(
"CoreActionsCurrentUser",
"6b5b63a013cf66a995d61f71a508ab5c8e4473350c5d4136f846ba65e8101e95",
{},
)
return response["data"]["currentUser"]

async def get_subscription_id(self, login: str):
response = await self._gql_request(
"SupportPanelSubscribeViewFooterPrime",
"02d85dc601efbdf6ac4583bc7e7b1c4b9855dadf1f8f051eef1d76adeb84eac6",
{"login": login},
)
return response

async def purchase_subscription(
self, user_id: str, offer_id: str, product_id: str, channel_id: str
):
variables = {
"input": {
"offerID": offer_id,
"paymentSession": {
"deviceID": "VDTv0bBkeRcFXcqme...",
"localStorageDeviceID": "e5257d...",
"tabSessionID": "97ce11c1...",
"pageSessionID": "6e21fd9ab...",
"checkoutSessionID": "3c5a33f6-83ba-408e-...",
},
"purchasingUserID": user_id,
"quantity": 1,
"tagBindings": [
{"key": "product_id", "value": product_id},
{"key": "channel_id", "value": channel_id},
],
}
}

response = await self._gql_request(
operation_name="PurchaseOrderContext_PurchaseOffer",
operation_hash="703342a16f143f21b238ddab53d1668c8b1fa8cf515310a9c9c3481a88a93b05",
variables=variables,
)

return response

Python

from curl_cffi.requests import AsyncSession
from datetime import datetime
import pycountry


class InvalidToken(Exception):
    pass


class Twitch:
    def __init__(
        self,
        token: str,
        client_id: str = "xxxxxxxxxx",
    ):
        self.token = token
        self.client_id = client_id

        self._session = AsyncSession(
            impersonate="chrome",
            allow_redirects=False,
            timeout=10,
        )

    async def _gql_request(
        self, operation_name: str, operation_hash: str, variables: dict
    ):
        headers = {
            "Client-Id": self.client_id,
            "Authorization": f"OAuth {self.token}",
        }

        data = {
            "extensions": {
                "persistedQuery": {
                    "version": 1,
                    "sha256Hash": operation_hash,
                }
            },
            "operationName": operation_name,
            "variables": variables,
        }

        response = await self._session.post(
            "https://gql.twitch.tv/gql",
            headers=headers,
            json=data,
        )

        if response.status_code == 401:
            raise InvalidToken("Invalid token")

        return response.json()

    async def get_current_user(self):
        response = await self._gql_request(
            "CoreActionsCurrentUser",
            "6b5b63a013cf66a995d61f71a508ab5c8e4473350c5d4136f846ba65e8101e95",
            {},
        )
        return response["data"]["currentUser"]

    async def get_subscription_id(self, login: str):
        response = await self._gql_request(
            "SupportPanelSubscribeViewFooterPrime",
            "02d85dc601efbdf6ac4583bc7e7b1c4b9855dadf1f8f051eef1d76adeb84eac6",
            {"login": login},
        )
        return response

    async def purchase_subscription(
        self, user_id: str, offer_id: str, product_id: str, channel_id: str
    ):
        variables = {
            "input": {
                "offerID": offer_id,
                "paymentSession": {
                    "deviceID": "VDTv0bBkeRcFXcqme...",
                    "localStorageDeviceID": "e5257d...",
                    "tabSessionID": "97ce11c1...",
                    "pageSessionID": "6e21fd9ab...",
                    "checkoutSessionID": "3c5a33f6-83ba-408e-...",
                },
                "purchasingUserID": user_id,
                "quantity": 1,
                "tagBindings": [
                    {"key": "product_id", "value": product_id},
                    {"key": "channel_id", "value": channel_id},
                ],
            }
        }

        response = await self._gql_request(
            operation_name="PurchaseOrderContext_PurchaseOffer",
            operation_hash="703342a16f143f21b238ddab53d1668c8b1fa8cf515310a9c9c3481a88a93b05",
            variables=variables,
        )

        return response

test_twitch.py

import asyncio
from infrastructure.twitch.api import Twitch


async def main():
token = "xxxxxxxxxxx"
twitch = Twitch(token=token)

response = await twitch.get_subscription_id("xrespectrd")
user = await twitch.get_current_user()
node = response["data"]["userResultByLogin"]["subscriptionProductsResult"][
"nodes"
][0]
offer = node["offers"][1]
product_id = node["id"]
offer_id = offer["id"]
channel_id = None
user_id = user["id"]

for tag in offer["tagBindings"]:
if tag["key"] == "channel_id":
channel_id = str(tag["value"])

print(product_id, offer_id, channel_id, user_id)
print()

r = await twitch.purchase_subscription(
user_id, offer_id, product_id, channel_id
)
print(r)


if __name__ == "__main__":
asyncio.run(main())

Python

import asyncio
from infrastructure.twitch.api import Twitch


async def main():
    token = "xxxxxxxxxxx"
    twitch = Twitch(token=token)

    response = await twitch.get_subscription_id("xrespectrd")
    user = await twitch.get_current_user()
    node = response["data"]["userResultByLogin"]["subscriptionProductsResult"][
        "nodes"
    ][0]
    offer = node["offers"][1]
    product_id = node["id"]
    offer_id = offer["id"]
    channel_id = None
    user_id = user["id"]

    for tag in offer["tagBindings"]:
        if tag["key"] == "channel_id":
            channel_id = str(tag["value"])

    print(product_id, offer_id, channel_id, user_id)
    print()

    r = await twitch.purchase_subscription(
        user_id, offer_id, product_id, channel_id
    )
    print(r)


if __name__ == "__main__":
    asyncio.run(main())