a "i=L @sdZddlZddlZddlZddlZddlmZddlmZmZm Z m Z ddl Z ddl m Z ddl mZzddlmZdZWneydZd ZYn0eeZe jZe jZe jZe jZd ZGd d d Zd+eeeeeeeeeeeee eeed ddZ d,eeeeeeeedddZ!ddd defeeeeeeeeeedddZ"d-edddZ#eddd Z$ddd edfeeeeeeee%eed!d"d#Z&d.eeeeed$d%d&Z'd'd(Z(ed)krej)ej*d*e+e(dS)/z BaoLife AI Image Generation Module Handles automated image generation using Google Imagen 4 Ultra (primary), FLUX 1.1 Pro, and DALL-E 3 APIs. Supports caching, queue management, and cozy cartoon style generation. N)datetime)OptionalDictListTuple)config)get_database_connection) AsyncOpenAITFzcozy cartoon style, illustration, warm colors, friendly atmosphere, high quality digital art, clean lines, --no words, text, letters, facec @seZdZdZefedddZdeeeeee ee efddd Z eeeeee ee efdd d Z eeeeee ee efdd d Z eeeeee ee efdddZ eeedddZdS)ImageGeneratorz)Base class for image generation providersprovidercCs&||_trtrttd|_nd|_dS)N)Zapi_key)r OPENAI_AVAILABLEOPENAI_API_KEYr openai_client)selfr r1/var/www/lichun.app/lichun/ws/image_generation.py__init__6szImageGenerator.__init__ cozy_cartoon)promptstylewidthheightreturncst|jdkr |||||IdHS|jdkr@|||||IdHS|jdkr`|||||IdHSdd|jfSdS)z Generate an image using the specified provider. Returns: Tuple[image_url, error_message] dalle3Nfluximagen4zUnknown provider: )r _generate_dalle3_generate_flux_generate_imagen4)rrrrrrrrgenerate_image>s   zImageGenerator.generate_imagec stsdS|jsdSz|||}d}|dkr:|dkr:d}n|dkrN|dkrNd}td|d d d |jjjd ||d ddId H}|jdj}td||d fWSt y} z,dt | } t | d | fWYd } ~ Sd } ~ 00d S)z$Generate image using OpenAI DALL-E 3)NzHOpenAI library not installed. Install with: pip install --upgrade openai)NzOpenAI API key not configuredZ 1024x1024riZ 1024x1792Z 1792x1024zGenerating DALL-E 3 image: Nd...zdall-e-3Zstandard)modelrsizeZqualitynrzDALL-E 3 image generated: zDALL-E 3 generation failed: ) r r _apply_styleloggerinfoimagesgeneratedataurl Exceptionstrerror) rrrrr full_promptr&response image_urle error_msgrrrrTs4     zImageGenerator._generate_dalle3c s6tsdSz|||}td|dddt4IdH}dtdd}|||d d d d d ddd}|jd||d4IdH} | jdkr| IdH} dd| jd| fWdIdHWdIdHWS| IdH} d| vrbt | ddkrb| ddd} td| | dfWdIdHWdIdHWSWdIdHWdIdHWdSWdIdHq1IdHs0YWdIdHq1IdHs0YWnFt y0} z,dt | }t |d|fWYd} ~ Sd} ~ 00dS)z,Generate image using FLUX 1.1 Pro via fal.aiNzfal.ai API key not configuredzGenerating FLUX 1.1 Pro image: Nr"r#Key application/jsonZ Authorizationz Content-Type)rrg @r$TZjpeg2)r image_sizeZnum_inference_stepsZguidance_scale num_imagesenable_safety_checkerZ output_formatsafety_tolerancez$https://fal.run/fal-ai/flux-pro/v1.1headersjsonzFLUX API error : r+rr.zFLUX image generated: )NzNo image returned from FLUX APIzFLUX generation failed:  FAL_AI_KEYr(r)r*aiohttpZ ClientSessionZpoststatustextrClenr/r0r1rrrrrr2sessionrBZpayloadr3Z error_textresultr4r5r6rrrrsN  @2 zImageGenerator._generate_fluxc sXtsdSz|||}td|dddt4IdH}dtdd}|d d d d d }||krxd|d<n||krd |d<nd|d<|jd||d4IdH} | jdkr| IdH} dd| jd| fWdIdHWdIdHWS| IdH} d| vrt | ddkr| ddd} td| | dfWdIdHWdIdHWSWdIdHWdIdHWdSWdIdHq1IdHs0YWdIdHq 1IdHs0YWnFt yR} z,dt | }t |d|fWYd} ~ Sd} ~ 00dS)z5Generate image using Google Imagen 4 Ultra via fal.air7z!Generating Imagen 4 Ultra image: Nr"r#r8r9r:Zlandscape_16_9r$F6)rr=r>r?r@Zsquarer=Z portrait_3_4z,https://fal.run/fal-ai/imagen4/preview/ultrarArDzImagen 4 API error rEr+rr.z Imagen 4 Ultra image generated: )Nz#No image returned from Imagen 4 APIzImagen 4 generation failed: rFrLrrrr sN     @2 z ImageGenerator._generate_imagen4)rrrcCs|dkr|dtS|S)zApply style preset to promptrz, )COZY_CARTOON_STYLE)rrrrrrr(szImageGenerator._apply_styleN)rrr)__name__ __module__ __qualname____doc__DEFAULT_PROVIDERr0rintrrr!rrr r(rrrrr 3s>   - @ @r rr{Gz?) r4rr event_typeevent_category style_presetrrcosttagsrc  s0d} d} zzt} | } | r*t| nd} | d|||||||||| f | | j} td| d|| WW| r| | r| St y}zDt d|| r| WYd}~W| r| | r| dSd}~00W| r| | r,| n| r| | r*| 0dS)z Save generated image to databaseNa INSERT INTO generated_images (image_url, prompt, style_preset, event_type, event_category, provider, generation_cost, image_width, image_height, tags) VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s) zSaved generated image rEz Failed to save generated image: ) rcursorrCdumpsexecutecommit lastrowidr)r*closer/r1Zrollback)r4rr rXrYrZrrr[r\dbr]Z tags_jsonimage_idr5rrrsave_generated_imagesL     re)rXrYprompt_keywordsrc szt}|jdd}d}g}|r2|d7}|||rH|d7}|||r^|d7}|||d7}||||}|rtd|d |WSty}ztd |WYd }~d Sd }~00d S) z Retrieve a cached image from database. Args: event_type: Exact event type match event_category: Event category match prompt_keywords: Keywords to search in prompt Returns: Dict with image data or None TZ dictionaryz5SELECT * FROM generated_images WHERE is_active = TRUEz AND event_type = %sz AND event_category = %sz7 AND MATCH(prompt) AGAINST(%s IN NATURAL LANGUAGE MODE)z! ORDER BY created_at DESC LIMIT 1zFound cached image: idz!Failed to retrieve cached image: N) rr]appendr_fetchoner)r*r/r1) rXrYrfrcr]queryparamsrNr5rrrget_cached_image6s.     rm)rrXrYrZpriorityr rc szJt}|}|d||||||f||j}td||WSty} ztd| WYd} ~ dSd} ~ 00dS)z%Add image generation request to queuez INSERT INTO image_generation_queue (prompt, style_preset, event_type, event_category, priority, provider) VALUES (%s, %s, %s, %s, %s, %s) zAdded to generation queue: z#Failed to add to generation queue: N) rr]r_r`rar)r*r/r1) rrXrYrZror rcr]Zqueue_idr5rrradd_to_generation_queuehs rp ) batch_sizec sznt}|jdd}|d|f|}|s>tdWdStdt|d|D]}t|IdHqXWn4ty}zt d|WYd}~n d}~00dS) z4Process pending image generation requests from queueTrgz SELECT * FROM image_generation_queue WHERE status = 'pending' AND attempts < max_attempts ORDER BY priority DESC, created_at ASC LIMIT %s zNo pending images in queueNz Processing z images from queuez$Failed to process generation queue: ) rr]r_Zfetchallr)r*rKprocess_queue_itemr/r1)rrrcr]itemsitemr5rrrprocess_generation_queues  rv)ruc s<zt}|}|d|df|t|dd}|j|d|ddIdH\}}|rt||d|d|d |d |dd IdH}|d ||df|td |ddn6|d||df|t d |dd|Wn@t y6}z&t d|dd|WYd}~n d}~00dS)zProcess a single queue itemz UPDATE image_generation_queue SET status = 'processing', attempts = attempts + 1, updated_at = NOW() WHERE id = %s rhr r rrZ)rrNrXrYr4rr rXrYrZz UPDATE image_generation_queue SET status = 'completed', generated_image_id = %s, completed_at = NOW(), updated_at = NOW() WHERE id = %s z Queue item z completed successfullyz UPDATE image_generation_queue SET status = 'failed', error_message = %s, updated_at = NOW() WHERE id = %s z failed: zFailed to process queue item rE) rr]r_r`r r!rer)r*r1r/)rurcr] generatorr4r1rdr5rrrrssB   rs)rrXrYrr use_cacherc s|r6t||dIdH}|r6td|d|dSt|d}|||IdH\}} |rxt||||||dIdH|Std| dSdS)zx Generate an image and cache it, or return cached version if available. Returns: Image URL or None )rXrYNzUsing cached image: r4r rwzImage generation failed: )rmr)r*r r!rer1) rrXrYrr rycachedrxr4r1rrrgenerate_and_cache_images,   r{)rXrYrc Csvz:t}|jdd}|d|f|}|r6|dndWStyp}ztd|WYd}~dSd}~00dS)zp Get image URL for an event (synchronous for use in event functions). Returns cached image or None. Trga SELECT gi.image_url FROM event_images ei JOIN generated_images gi ON ei.generated_image_id = gi.id WHERE ei.event_type = %s AND gi.is_active = TRUE ORDER BY ei.is_primary DESC, ei.display_order ASC LIMIT 1 r4NzFailed to get event image: )rr]r_rjr/r)r1)rXrYrcr]rNr5rrrget_event_image_urls  r|csdddddddddd d dg}|D]r}td |d t|d |d |ddIdH}|rttd|ntd|d tdIdHq&dS)z)Test image generation with sample promptsz=large contemporary architecture high school building exteriorZschool_exteriorZ education)rrXrYz1cozy bedroom with desk and computer, teenage roomZbedroomhomez3happy family having dinner together at dining tableZ family_dinnerfamilyz Testing: rrXrYNu✓ Generated: u ✗ Failed: )r)r*r{r1asynciosleep)Z test_promptstestr4rrrtest_generation-s0 r__main__)level)NNrrrrWN)NNN)rq)N),rTosrrCloggingrtypingrrrrrHrdatabase.db_operationsrZopenair r ImportError getLoggerrQr)rrGZREPLICATE_API_TOKENZIMAGE_GENERATION_PROVIDERrUrPr r0rVfloatrermrprvrsboolr{r|r basicConfigINFOrunrrrrs        Z  / 4 ? 0$