j ldZddlmZddlmZmZddlmZddlm Z m Z GddeZ Gdd eZ y ) z$Mixins for common SDK functionality.) annotations)ABCabstractmethod)Any)Field validate_callceZdZUdZded<ded<eddZeddZeddZeddZ e dd Z dd Z e e d d f ddZddZe e d d f ddZddZy)MetadataConfigMixina Mixin providing get/set/refresh methods for metadata and configuration. Classes using this mixin must implement: - _get_http_client() -> HTTPClientProtocol - _get_fetch_route() -> str - _get_update_route() -> str - _get_fetch_body() -> dict[str, Any] - _parse_response(data: dict[str, Any]) -> tuple[dict, dict] And must have these attributes: - _metadata: dict[str, object] | None - _configuration: dict[str, object] | None zdict[str, object] | None _metadata_configurationcy)z(Get the HTTP client for making requests.Nselfs /home/cube/projects/richard/traning coach/.omo/evidence/nutricoach-v150-combined/st_01a0560c-r63-installed-wheel-first-claim-qa/venv/lib/python3.12/site-packages/honcho/mixins.py_get_http_clientz$MetadataConfigMixin._get_http_client cyz2Get the route for fetching metadata/configuration.Nrrs r_get_fetch_routez$MetadataConfigMixin._get_fetch_route#rrcyz2Get the route for updating metadata/configuration.Nrrs r_get_update_routez%MetadataConfigMixin._get_update_route(rrcyz1Get the body for fetching metadata/configuration.Nrrs r_get_fetch_bodyz#MetadataConfigMixin._get_fetch_body-rrcyz9Parse the response to extract metadata and configuration.Nrrdatas r_parse_responsez#MetadataConfigMixin._parse_response2 rc|jj|j|j}|j |\}}||_||_|j S)z Get metadata from the server and update the cache. Returns: A dictionary containing the metadata. Returns an empty dictionary if no metadata is set. bodyrpostrrr"r r rr!metadata configurations r get_metadataz MetadataConfigMixin.get_metadata9si$$&++  ! ! #$*>*>*@, #'"6"6t"<-!+~~r.zMetadata dictionary to set) descriptionct|jj|jd|i||_y)z Set metadata on the server and update the cache. Args: metadata: A dictionary of metadata to set. Keys must be strings, values can be any JSON-serializable type. r*r%N)rputrr rr*s r set_metadataz MetadataConfigMixin.set_metadataIs= ##  " " $h' $ "rc|jj|j|j}|j |\}}||_||_|j S)z Get configuration from the server and update the cache. Returns: A dictionary containing the configuration. Returns an empty dictionary if no configuration is set. r%r'r)s rget_configurationz%MetadataConfigMixin.get_configuration]sk$$&++  ! ! #$*>*>*@, #'"6"6t"<-!+"""rzConfiguration dictionary to setct|jj|jd|i||_y)z Set configuration on the server and update the cache. Args: configuration: A dictionary of configuration to set. Keys must be strings, values can be any JSON-serializable type. r+r%N)rr/rr rr+s rset_configurationz%MetadataConfigMixin.set_configurationms> ##  " " $!=1 $ ,rc|jj|j|j}|j |\}}||_||_y)z Refresh cached metadata and configuration from the server. Makes a single API call to retrieve the latest metadata and configuration and updates the cached attributes. r%Nr'r)s rrefreshzMetadataConfigMixin.refreshs_$$&++  ! ! #$*>*>*@, #'"6"6t"<-!+rNreturnrr:strr:dict[str, Any]r!r>r:z+tuple[dict[str, object], dict[str, object]]r:dict[str, object]r*rAr:Noner+rAr:rCr:rC)__name__ __module__ __qualname____doc____annotations__rrrrrr"r,rrr1r3r6r8rrrr r s (',,         " 4   ', 9' "#"  ""&# ,1 >, ,(,  ,,& ,rr ceZdZdZeddZeddZeddZeddZe ddZ eddZ eddZ edd Z edd Z dd Zdd Zdd ZddZddZy)AsyncMetadataConfigMixina Async mixin providing get/set/refresh methods for metadata and configuration. Classes using this mixin must implement: - _get_async_http_client() -> AsyncHTTPClientProtocol - _get_fetch_route() -> str - _get_update_route() -> str - _get_fetch_body() -> dict[str, Any] - _parse_response(data: dict[str, Any]) -> tuple[dict, dict] - _set_metadata(metadata: dict[str, object]) -> None - _set_configuration(configuration: dict[str, object]) -> None cy)z.Get the async HTTP client for making requests.Nrrs r_get_async_http_clientz/AsyncMetadataConfigMixin._get_async_http_clientrrcyrrrs rrz)AsyncMetadataConfigMixin._get_fetch_routerrcyrrrs rrz*AsyncMetadataConfigMixin._get_update_routerrcyrrrs rrz(AsyncMetadataConfigMixin._get_fetch_bodyrrcyrrr s rr"z(AsyncMetadataConfigMixin._parse_responser#rcy)z"Set metadata on the parent object.Nrr0s r _set_metadataz&AsyncMetadataConfigMixin._set_metadatarrcy)z'Set configuration on the parent object.Nrr5s r_set_configurationz+AsyncMetadataConfigMixin._set_configurationrrcy)z+Get cached metadata from the parent object.Nrrs r _get_metadataz&AsyncMetadataConfigMixin._get_metadatarrcy)z0Get cached configuration from the parent object.Nrrs r_get_configurationz+AsyncMetadataConfigMixin._get_configurationrrc$K|jj|j|jd{}|j |\}}|j ||j ||jS7Jw)z,Get metadata from the server asynchronously.r%N)rNr(rrr"rTrVrXr)s rr,z%AsyncMetadataConfigMixin.get_metadatas00277  ! ! #$*>*>*@8  #'"6"6t"<- 8$  .!!##  ABBA BcK|jj|jd|id{|j|y7w)z*Set metadata on the server asynchronously.r*r%N)rNr/rrTr0s rr1z%AsyncMetadataConfigMixin.set_metadatasU))+//  " " $h'0    8$  5AAAc$K|jj|j|jd{}|j |\}}|j ||j ||jS7Jw)z1Get configuration from the server asynchronously.r%N)rNr(rrr"rTrVrZr)s rr3z*AsyncMetadataConfigMixin.get_configurations00277  ! ! #$*>*>*@8  #'"6"6t"<- 8$  .&&((  r\cK|jj|jd|id{|j|y7w)z/Set configuration on the server asynchronously.r+r%N)rNr/rrVr5s rr6z*AsyncMetadataConfigMixin.set_configurationsU))+//  " " $!=10     .  r^cK|jj|j|jd{}|j |\}}|j ||j |y7;w)z9Refresh cached metadata and configuration asynchronously.r%N)rNr(rrr"rTrVr)s rr8z AsyncMetadataConfigMixin.refreshsx00277  ! ! #$*>*>*@8  #'"6"6t"<- 8$  .  sABA?rfs1*"#)B,#B,Jh/sh/r