Black Fixes

Author: srhinos

experiment.py

@@ -17,39 +17,28 @@
 }
 
 
-async def claim_offer(
-    offer_id: str, item: dict, client: httpx.AsyncClient, headers: dict
-) -> True:
+async def claim_offer(offer_id: str, item: dict, client: httpx.AsyncClient, headers: dict) -> True:
     if not item["offers"][0]["offerSelfConnection"]["eligibility"]["isClaimed"]:
         if (
             item["offers"][0]["offerSelfConnection"]["eligibility"]["canClaim"] is False
-            and item["offers"][0]["offerSelfConnection"]["eligibility"][
-                "missingRequiredAccountLink"
-            ]
-            is True
+            and item["offers"][0]["offerSelfConnection"]["eligibility"]["missingRequiredAccountLink"] is True
         ):
-            log.error(
-                f"Cannot collect game `{item['game']['assets']['title']}`, account link required."
-            )
+            log.error(f"Cannot collect game `{item['game']['assets']['title']}`, account link required.")
             return
         log.info(f"Collecting offer for {item['game']['assets']['title']}")
         claim_payload = {
             "operationName": "placeOrdersDetailPage",
             "variables": {
                 "input": {
                     "offerIds": [offer_id],
-                    "attributionChannel": '{"eventId":"ItemDetailRootPage:'
-                    + offer_id
-                    + '","page":"ItemDetailPage"}',
+                    "attributionChannel": '{"eventId":"ItemDetailRootPage:' + offer_id + '","page":"ItemDetailPage"}',
                 }
             },
             "extensions": {},
             "query": "fragment Place_Orders_Payload_Order_Information on OfferOrderInformation {\n  catalogOfferId\n  claimCode\n  entitledAccountId\n  entitledAccountName\n  id\n  orderDate\n  orderState\n  __typename\n}\n\nmutation placeOrdersDetailPage($input: PlaceOrdersInput!) {\n  placeOrders(input: $input) {\n    error {\n      code\n      __typename\n    }\n    orderInformation {\n      ...Place_Orders_Payload_Order_Information\n      __typename\n    }\n    __typename\n  }\n}\n",  # noqa: E501 TODO: This needs to become a non \n formatted string somewhere, just not doing it now
         }
 
-        response = await client.post(
-            gql_url, headers=headers, data=json.dumps(claim_payload)
-        )
+        response = await client.post(gql_url, headers=headers, data=json.dumps(claim_payload))
         if response.json()["data"]["placeOrders"]["error"] is not None:
             log.error(f"Error: {response.json()['data']['placeOrders']['error']}")
 
@@ -68,22 +57,15 @@ async def primelooter(cookie_file):
         for _c in jar:
             client.cookies.jar.set_cookie(_c)
 
-        html_body = (
-            await client.get("https://gaming.amazon.com/home", headers=base_headers)
-        ).text
+        html_body = (await client.get("https://gaming.amazon.com/home", headers=base_headers)).text
         matches = re.findall(r"name='csrf-key' value='(.*)'", html_body)
         json_headers["csrf-token"] = matches[0]
 
-        response = await client.post(
-            gql_url, headers=json_headers, data=json.dumps(offers_payload)
-        )
+        response = await client.post(gql_url, headers=json_headers, data=json.dumps(offers_payload))
         data = response.json()["data"]["inGameLoot"]["items"]
 
         # although insanely low, python WILL garbage collect running coroutines if their references
         # aren't stored somewhere, therefore we noqa the Flake8 issue yelling at us about it.
         coros = await asyncio.gather(  # noqa: F841
-            *[
-                claim_offer(item["offers"][0]["id"], item, client, json_headers)
-                for item in data
-            ]
+            *[claim_offer(item["offers"][0]["id"], item, client, json_headers) for item in data]
         )