import asyncio

from sqlalchemy import select, func, union
from sqlalchemy.ext.asyncio import AsyncSession
from sqlalchemy.orm import joinedload

from backend.session import session_maker
from external.s3_uploader.uploader import S3Uploader
from models import Deal, DealProduct, Service

import models
import models.secondary


async def main(session: AsyncSession):
    file_bytes = open('photo_2024-04-01 10.26.39.jpeg', 'rb').read()
    uploader = S3Uploader('1cc46590-4532-4046-97aa-baf3e49f20ad-AUF')
    response = await uploader.upload(file_bytes)
    print(response)


async def preload():
    async with session_maker() as session:
        await main(session)


if __name__ == '__main__':
    asyncio.run(preload())