̯yjdZddlmZddlZddlmZddlmZddlm Z ddl m Z eje ZGdd eZedd Zdd Zdd Zd Zy)uuGoogle Gemini sağlayıcısı — YALNIZCA kamuya açık veri görevleri için. Bu modül `router.Sensitivity.PUBLIC` işaretli görevlerde kullanılır. Gizlilik sınırı `router.TaskSpec` içinde zorlanır: `CONFIDENTIAL` bir görev buraya yönlendirilemez (import anında ValueError). Tasarım kararı — **yumuşak bağımlılık**: Gemini yapılandırılmamışsa veya çağrı başarısız olursa çağıran taraf Claude'a düşer. PUBLIC görevlerde her iki sağlayıcı da hukuken uygun olduğu için fallback güvenlidir; bu sayede `GEMINI_API_KEY` olmayan bir ortamda (CI, yerel geliştirme) hiçbir şey bozulmaz. ) annotationsN) lru_cache)Any BaseModel) get_settingsceZdZdZy)GeminiNotConfiguredErroruHGEMINI_API_KEY tanımlı değil — çağıran taraf Claude'a düşmeli.N)__name__ __module__ __qualname____doc__(/tmp/py-stage/app/services/llm/gemini.pyr r sRrr ct}|js td ddlm}|j |jS#t $r}td|d}~wwxYw)uGlobal async-capable Gemini client. `google-genai` import'u fonksiyon içindedir: paket kurulu değilse modül import'u patlamasın, yalnızca fiilen Gemini çağrılırsa hata versin. u GEMINI_API_KEY tanımlı değil.r)genaiu;google-genai paketi kurulu değil: pip install google-genaiN)api_key)rgemini_api_keyr googler ImportErrorClient)settingsrexcs r_clientrsf~H  " "&'IJJ << 7 7< 88 & I  sA A AAcL ty#t$rYyt$rYywxYw)uMGemini kullanılabilir mi? Çağıran taraf fallback kararı için kullanır.FT)rr Exceptionrrr is_configuredr2s0  $ s ###cliSdfd }|d}|d}t||z d|dd|dS)uGemini `usage_metadata`'yı `record_usage()`'ın beklediği şekle çevirir. Gemini alan adları Anthropic'ten farklı; ortak maliyet borusunu tek formatta tutmak için burada eşliyoruz. Not: Gemini'de `prompt_token_count`, cache kullanıldığında cache'lenmiş token'ları DA içerir. Anthropic'te `input_tokens` cache'lenmemiş kısımdır. Çift sayımı önlemek için cache'li kısmı düşüyoruz. c8tt|dxsdS)Nr)intgetattr)nameusage_metadatas r_getzusage_as_record.._getJs7>438q99rprompt_token_countcached_content_token_countrcandidates_token_count) input_tokens output_tokenscache_creation_input_tokenscache_read_input_tokens)r#strreturnr!)max)r$r%promptcacheds` rusage_as_recordr2=sT :& 'F . /FFVOQ/67'(#)  rc2ddx}f ddcS)TctS)Nrrrrr4r4Wslrc Kddlm}t}|jjj |||j |d||d{}tt|dd}t|dd} | "t| |s |j| } | |fS| |fS7O#t$r%} tjd | d} Yd} ~ | |fSd} ~ wwxYww) uŞema-doğrulanmış JSON üret. Returns: (parsed, usage_record). Parse edilemezse (None, usage). Raises: GeminiNotConfiguredError: yapılandırma yoksa — çağıran Claude'a düşer. r)typeszapplication/json)system_instructionresponse_mime_typeresponse_schemamax_output_tokens)modelcontentsconfigNr$parsedu#Gemini yanıtı şemaya uymadı: %s) google.genair7raiomodelsgenerate_contentGenerateContentConfigr2r" isinstancemodel_validaterloggerwarning) r<systemuserschema max_tokensr7clientresponseusager?rs rgenerate_structuredrPWs # YFZZ&&77**%1"( + 8  H GH.>E FEXx .F *VV"< **62F 5=65=1 (  NN@# FF 5=  s<ACB!5CB# C# C,C C CC) r<r-rIr-rJr-rKztype[T]rLr!r.ztuple[T | None, dict[str, int]]r) .defaultsr4s r+rRWs>l + +  +  +  +%+r)r.r)r.bool)r$rr.zdict[str, int])r __future__rlogging functoolsrtypingrpydanticr app.configr getLoggerr rG RuntimeErrorr rrr2rPrrrr\sf ##   8 $S|S 9 9$4++r