Ë âz¦i£ãó®—dZddlmZddlZddlZddlZddlZddlmZm Z ddl m Z m Z m Z eje«ZeGd„d««ZGd„d «Zy) aVLM client for vision-language scene analysis. Sends a JPEG frame plus a text prompt to the OpenAI-compatible vision endpoint (modelapi.klass.dev) and returns the model's text response. Follows the same synchronous ``requests``-with-urllib-fallback pattern as ``LLMClient._post``. é)Ú annotationsN)Ú dataclassÚfield)ÚAnyÚDictÚOptionalcó€—eZdZUdZed„¬«Zded<ed„¬«Zded<ed¬ «Zd ed <d Z d ed<dd„Z y)Ú VLMConfiga|Configuration for the VLM client. Attributes: endpoint: Full URL for the chat completions endpoint. model: Vision model identifier (e.g. the Qwen vision variant on modelapi). api_key: Bearer token for Authorization header. Reads from ``MODELAPI_KEY`` env var if not supplied explicitly. timeout_s: Request timeout in seconds. có.—tjdd«S)NÚ VLM_ENDPOINTz.https://modelapi.klass.dev/v1/chat/completions©ÚosÚgetenv©óúG/home/nelsen/Projects/kognitive/orchestrator/src/services/vlm_client.pyúzVLMConfig.!s€¤§ ¡ Ø Ø <ó! €r)Údefault_factoryÚstrÚendpointcó.—tjdd«S)NÚ VLM_MODELzQwen3.5-122B-A10Br rrrrzVLMConfig.'s€¤§ ¡ ¨+Ð7JÓ K€rÚmodelN)Údefaultz Optional[str]Úapi_keyéÚintÚ timeout_scó®—|j€Itjd«xs,tjd«xstjd«|_yy)NÚ MODELAPI_KEYÚ MODEL_API_KEYÚOPENAI_API_KEY)rrr)Úselfs rÚ __post_init__zVLMConfig.__post_init__,sG€Ø <‰<Ð ä— ‘ ˜.Ó)ò/Ü—9‘9˜_Ó-ò/ä—9‘9Ð-Ó.ð Lð r)ÚreturnÚNone) Ú__name__Ú __module__Ú __qualname__Ú__doc__rrÚ__annotations__rrrr$rrrr r sU…ñññ ô€Hˆcóñ ÙKô€Eˆ3óñ#¨4Ô0€Gˆ]Ó0Ø€IˆsÓôrr có*—eZdZdZddd„Zdd„Zd d„Zy) Ú VLMClienta&Synchronous HTTP client for the vision-language model endpoint. Usage:: client = VLMClient() analysis = client.analyze_scene(jpeg_bytes, "Describe the scene.") # "There are two unconscious workers near a chemical container..." The endpoint accepts an OpenAI-compatible chat completion request with an image embedded as a base64 data URL. This is a *synchronous* method so it can be offloaded to a thread pool from async code via ``loop.run_in_executor(None, client.analyze_scene, frame, prompt)``. Ncó*—|xs t«|_y©N)r Úconfig)r#r0s rÚ__init__zVLMClient.__init__Ds€ØÒ+¤ £ ˆ rcó†—|stjd«y|stjd«ytj|«j d«}|j j dddd|›id œd |d œgd œgd ddddœ} |j|«}|dddd}t|t«rtjd|dd«|Stjd|«y#tttf$r }tjd|«Yd}~yd}~wt$r }tjd|«Yd}~yd}~wwxYw)a3Send a JPEG frame and a text prompt to the VLM; return the reply. Args: jpeg_bytes: Raw JPEG bytes of the frame to analyse. prompt: Natural-language instruction for the model. Returns: The model's text response, or an empty string on any error. u<VLMClient.analyze_scene called with empty bytes — skippingÚu=VLMClient.analyze_scene called with empty prompt — skippingÚasciiÚuserÚ image_urlÚurlzdata:image/jpeg;base64,)Útyper6Útext)r8r9)ÚroleÚcontentgffffffæ?igš™™™™™é?é)rÚmessagesÚ temperatureÚ max_tokensÚtop_pÚtop_kÚchoicesrÚmessager;uVLM response: %s…Néxz(VLM response content is not a string: %rz"Unexpected VLM response format: %szVLM analyze_scene failed: %s)ÚloggerÚwarningÚbase64Ú b64encodeÚdecoder0rÚ_postÚ isinstancerÚinfoÚerrorÚKeyErrorÚ IndexErrorÚ TypeErrorÚ Exception)r#Ú jpeg_bytesÚpromptÚb64ÚpayloadÚresponser;Úexcs rÚ analyze_scenezVLMClient.analyze_sceneGsG€ñÜ N‰NÐYÔ ZØáÜ N‰NÐZÔ [Øä×јzÓ*×1Ñ1°'Ó:ˆð—[‘[×&Ñ&ð#ð%0Ø*/Ð3JÈ3È%Ð1PÐ)Qñð"(°Ñ8ð  ñ ð ðØØØñ## ˆð( Ø—z‘z 'Ó*ˆHؘyÑ)¨!Ñ,¨YÑ7¸ ÑBˆGܘ'¤3Ô'Ü— ‘ Ð1°7¸4¸C°=ÔAØÜ L‰LÐCÀWÔ MØøÜœ*¤iÐ0ò Ü L‰LÐ=¸sÔ CÜûÜò Ü L‰LÐ7¸Ô =Üûð ús+ÂA C%ÃC%Ã%EÃ9DÄ EÄ D;Ä;Ecó.—ddi}|jjrd|jj›|d<tj|«j d«} ddl}|j |jj|||jj¬«}|j«|j«S#t$rYnt$r}td |›«|‚d}~wwxYwddl }ddl}|jj!|jj||d ¬ «} |jj#||jj¬ «5} | j%«j'd«} tj(| «cddd«S#1swYyxYw#|j*j,$rB}|j%«j'dd ¬«} td|j.›d| ›«|‚d}~wt$r}td |›«|‚d}~wwxYw)aPOST JSON payload to the VLM endpoint. Tries ``requests`` first (faster, richer error messages); falls back to stdlib ``urllib`` so the client works without the optional dependency. Args: payload: Dict to serialise as JSON request body. Returns: Parsed JSON response dict. Raises: RuntimeError: On any HTTP or network error. z Content-Typezapplication/jsonzBearer Ú Authorizationzutf-8rN)ÚjsonÚheadersÚtimeoutzVLM request failed: ÚPOST)Údatar\Úmethod)r]Úreplace)ÚerrorszVLM HTTP error z: )r0rr[ÚdumpsÚencodeÚrequestsÚpostrrÚraise_for_statusÚ ImportErrorrQÚ RuntimeErrorÚ urllib.errorÚurllib.requestÚrequestÚRequestÚurlopenÚreadrIÚloadsrMÚ HTTPErrorÚcode) r#rUr\r_rerVrWÚurllibrlÚhandleÚbodyÚdetails rrJzVLMClient._post‚sæ€ð"Ð#5Ð6ˆØ ;‰;× Ò Ø)0°·±×1DÑ1DÐ0EÐ'FˆGOÑ $äz‰z˜'Ó"×)Ñ)¨'Ó2ˆð FÛ à—}‘}Ø— ‘ ×$Ñ$ØØØŸ ™ ×-Ñ-ð %óˆHð × %Ñ %Ô 'Ø—=‘=“?Ð "øÜò Ù Üò FÜÐ!5°c°UÐ;Ó<À#Ð Eûð Fúó Ûà—.‘.×(Ñ(Ø K‰K× Ñ ØØØð )ó ˆð  FØ—‘×'Ñ'¨¸¿¹×9NÑ9NÐ'ÓOð (ÐSYØ—{‘{“}×+Ñ+¨GÓ4Ü—z‘z $Ó'÷ (÷ (ò (ûð|‰|×%Ñ%ò PØ—X‘X“Z×&Ñ& w°yÐ&ÓAˆFÜ °·±° ¸"¸V¸HÐEÓFÈCÐ OûÜò FÜÐ!5°c°UÐ;Ó<À#Ð Eûð FúsaÁA B=Â= C$ÃC$ÃCÃC$Ä#1FÅ4FÆ FÆFÆFÆFÆHÆ7=G4Ç4 HÈHÈHr/)r0zOptional[VLMConfig]r%r&)rRÚbytesrSrr%r)rUúDict[str, Any]r%rx)r'r(r)r*r1rXrJrrrr-r-5s„ñ ô,ó5ôv7Frr-)r*Ú __future__rrGr[ÚloggingrÚ dataclassesrrÚtypingrrrÚ getLoggerr'rEr r-rrrúr~s^ðñõ#ã Û ÛÛ ß(ß&Ñ&à ˆ× Ñ ˜8Ó $€ð ÷ðó ð÷@DFòDFr