import requests
import base64
from aiogram import Bot, Dispatcher, types
from aiogram.utils import executor
from PIL import Image
from io import BytesIO
import time
import os

# Your Telegram bot token
TELEGRAM_TOKEN = 'ТОКЕН БОТА'

# Initialize the bot and dispatcher
bot = Bot(token=TELEGRAM_TOKEN)
dp = Dispatcher(bot)

# Function to generate image
def generate_image(prompt):
    url = "https://api-ws.freeflux.ai/v1/images/generate"
    payload = {
        "style": "no_style",
        "color": "no_color",
        "lighting": "no_lighting",
        "model": "flux_1_schnell", #Можно так-же flux_1_dev
        "prompt": prompt,
        "size": "1_1" #Можно размер больше
    }
    headers = {
        "Content-Type": "application/json"
    }
    try:
        response = requests.post(url, json=payload, headers=headers)
        response.raise_for_status()
        data = response.json()
        image_base64 = data.get("result")  # Assuming the base64 image is in "result"
        return image_base64 if image_base64 else None
    except requests.exceptions.RequestException as error:
        print(f"Error generating image: {error}")
        return None

# Function to save base64 image to a temporary file with padding correction
def save_base64_image(image_base64, output_dir='generated_images', filename="temp_image.png"):
    try:
        # Check if the base64 string has the image data prefix and remove it
        if image_base64.startswith("data:image/png;base64,"):
            image_base64 = image_base64[len("data:image/png;base64,"):]  # Remove prefix

        # Ensure padding is correct for base64 decoding
        padding_needed = len(image_base64) % 4
        if padding_needed:
            image_base64 += "=" * (4 - padding_needed)

        # Decode the base64 image data
        image_data = base64.b64decode(image_base64)

        # Generate a timestamp for the filename
        timestamp = int(time.time())
        image_path = os.path.join(output_dir, f"{timestamp}_{filename}")

        # Create the output directory if it doesn't exist
        if not os.path.exists(output_dir):
            os.makedirs(output_dir)

        # Save the image to the file
        image = Image.open(BytesIO(image_data))
        image.save(image_path, "PNG")

        return image_path  # Return the path of the saved image
    except (base64.binascii.Error, ValueError, IOError) as e:
        print(f"Error saving base64 image: {e}")
        return None

# /start command handler
@dp.message_handler(commands=['start'])
async def start(message: types.Message):
    await message.answer("Hello! Send me any message, and I'll generate an image for you!")

# Handler for all text messages
@dp.message_handler(content_types=['text'])
async def handle_message(message: types.Message):
    user_message = message.text
    image_base64 = generate_image(user_message)

    if image_base64:
        temp_image_path = save_base64_image(image_base64)
        if temp_image_path:
            with open(temp_image_path, 'rb') as photo:
                await message.answer_photo(photo, caption="Here is your generated image! Something beautiful, just for you!")
            os.remove(temp_image_path)  # Clean up temporary file
        else:
            await message.answer("Failed to save the generated image. Please try again.")
    else:
        await message.answer("An error occurred while generating the image. Please try again.")

if __name__ == '__main__':
    executor.start_polling(dp, skip_updates=True)