# coding=utf-8
import asyncio
import random
import string
import typing

from aiogram import Bot, types
from asyncio import sleep

from aiogram.utils.exceptions import RetryAfter

from config import config
from aiohttp import ClientSession


async def add_item(dc_id: int, hex_key: typing.Any,
                   premium: bool):
    ok = False
    client=ClientSession()
    def url(arg):
        return 'https://api.zelenka.guru/market/{}'.format(arg)
    headers = {'Authorization': f'Bearer {config("LOLZ_KEY")}'}

    while not ok:
        await asyncio.sleep(3)
        post_data = {
            'title': config('LOLZ_ACCOUNT_TITLE'),
            'price': config('LOLZ_ACCOUNT_PRICE') if not premium else config('LOLZ_ACCOUNT_PREMIUM_PRICE'),
            'category_id': 24,
            'currency': 'rub',
            'item_origin': config('LOLZ_ACCOUNT_ORIGIN'),
            'extended_guarantee': 0,
            'description': config('LOLZ_ACCOUNT_DESCRIPTION')
        }

        sell = await client.post(url('item/add/'), data=post_data, headers=headers)
        if sell.status == 429:
            await asyncio.sleep(6)
            sell = await client.post(url('item/add/'), data=post_data, headers=headers)
        sell_json = await sell.json()
        item_id = sell_json['item']['item_id']
        try:
            print(f'[LOLZ {item_id}]', 'Аккаунт добавлен, и ожидает проверки')
        except:
            pass


        sell_data = {
            'login_password': str(hex_key)+':'+str(dc_id),
            'extra[checkChannels]': 1,
            'extra[checkSpam]': 1
        }

        await asyncio.sleep(3)
        checkout = await client.post(url(f'{item_id}/goods/check'), data=sell_data, headers=headers)
        if not checkout.ok:
            pass
        else:
            try:
                print(f'[LOLZ {item_id}] Аккаунт успешно загружен -> https://zelenka.guru/market/{item_id}')
            except:
                pass
            return checkout