§
    t�’jN  ã                  ób  — d Z ddlmZ ddlmZ ddlmZmZ ddlm	Z	 ddl
mZ  G d„ de¦  «        Z G d	„ d
e¦  «        Z G d„ de¦  «        Z G d„ de¦  «        Z G d„ de¦  «        Z G d„ de¦  «        Z G d„ de¦  «        Z G d„ de¦  «        Z G d„ de¦  «        Z G d„ de¦  «        ZdS )z*Knowledge ingestion and retrieval schemas.é    )Úannotations)ÚAny)Ú	BaseModelÚField)ÚRetrievalFilterSet)ÚSUPPORTED_TASK_TYPESc                  óZ   — e Zd ZU dZ edd¬¦  «        Zded<    ee¬¦  «        Zded	<   d
S )ÚKnowledgeChunkPayloadz%Single knowledge chunk for ingestion..é   ©Ú
min_lengthÚstrÚtext©Údefault_factoryúdict[str, Any]ÚmetadataN)	Ú__name__Ú
__module__Ú__qualname__Ú__doc__r   r   Ú__annotations__Údictr   © ó    ú:C:\Projects\DSCons\app\models\knowledge_runtime_schemas.pyr
   r
      sV   € € € € € € Ø/Ð/à��c aÐ(Ñ(Ô(€DÐ(Ð(Ð(Ñ(Ø$˜u°TÐ:Ñ:Ô:€HÐ:Ð:Ð:Ñ:Ð:Ð:r   r
   c                  óª   — e Zd ZU dZ eddd                     e¦  «        › �¬¦  «        Zded<    edd¬	¦  «        Z	d
ed<    ee
¬¦  «        Zded<   dS )ÚKnowledgeIngestRequestzKnowledge ingestion request..úOne of: ú, ©Údescriptionr   Ú	task_typer   r   zlist[KnowledgeChunkPayload]Úchunksr   r   Údefault_metadataN)r   r   r   r   r   Újoinr   r#   r   r$   r   r%   r   r   r   r   r      sž   € € € € € € Ø&Ð&à�UØÐE D§I¢IÐ.BÑ$CÔ$CÐEÐEðñ ô €Ið ð ð ñ ð +0¨%°ÀÐ*BÑ*BÔ*B€FÐBÐBÐBÑBØ', u¸TÐ'BÑ'BÔ'BÐÐBÐBÐBÑBÐBÐBr   r   c                  ó(   — e Zd ZU dZded<   ded<   dS )ÚKnowledgeIngestResponsezKnowledge ingestion response.r   ÚstatusÚintÚingested_countN©r   r   r   r   r   r   r   r   r(   r(      s-   € € € € € € Ø'Ð'à€K€K�KØÐÐÑÐÐr   r(   c                  ó~   — e Zd ZU dZ edd¬¦  «        Zded<    edd¬	¦  «        Zd
ed<    ee¬¦  «        Z	ded<   dS )ÚReviewMemoryIngestRequestzORequest payload for converting a dossier review session into RAG memory chunks..r   r   r   Ú	review_idNu*   TÃ¹y chá»�n override task_type khi ingest.©Údefaultr"   ú
str | Noner#   r   r   r%   )
r   r   r   r   r   r/   r   r#   r   r%   r   r   r   r.   r.   %   s‰   € € € € € € ØYÐYà�U˜3¨1Ð-Ñ-Ô-€IÐ-Ð-Ð-Ñ-Ø!˜EØÐ"Nðñ ô €Ið ð ð ñ ð (- u¸TÐ'BÑ'BÔ'BÐÐBÐBÐBÑBÐBÐBr   r.   c                  ó  — e Zd ZU dZ edd¬¦  «        Zded<   dZded	<    edd¬¦  «        Zded
<   dZ	ded<   dZ
ded<   dZded<    edd¬¦  «        Zded<   dZded<   dZded<   dZded<   dZded<    ee¬¦  «        Zded<   dS )ÚProjectMemoryEventPayloadzDSingle operational event to be converted into project memory chunks..r   r   r   Ú
event_typeNr2   ÚtitleÚsummaryÚdetailsÚoutcomeÚnext_actionÚproject_codeÚagent_scopeÚdocument_typeÚsource_tableÚevent_idr   r   r   )r   r   r   r   r   r5   r   r6   r7   r8   r9   r:   r;   r<   r=   r>   r?   r   r   r   r   r   r4   r4   /   s  € € € € € € ØNÐNà�e˜C¨AÐ.Ñ.Ô.€JÐ.Ð.Ð.Ñ.Ø€EÐÐÐÑØ�5˜¨Ð+Ñ+Ô+€GÐ+Ð+Ð+Ñ+Ø€GÐÐÐÑØ€GÐÐÐÑØ"€KÐ"Ð"Ð"Ñ"Ø˜˜c¨aÐ0Ñ0Ô0€LÐ0Ð0Ð0Ñ0Ø"€KÐ"Ð"Ð"Ñ"Ø $€MÐ$Ð$Ð$Ñ$Ø#€LÐ#Ð#Ð#Ñ#Ø€HÐÐÐÑØ$˜u°TÐ:Ñ:Ô:€HÐ:Ð:Ð:Ñ:Ð:Ð:r   r4   c                  ód   — e Zd ZU dZded<    edd¬¦  «        Zded<    ee¬	¦  «        Zd
ed<   dS )ÚProjectMemoryIngestRequestzTRequest payload for converting project operational events into RAG knowledge chunks.r   r#   .r   r   zlist[ProjectMemoryEventPayload]Úeventsr   r   r%   N)	r   r   r   r   r   r   rB   r   r%   r   r   r   rA   rA   @   s`   € € € € € € Ø^Ð^à€N€N�NØ.3¨e°CÀAÐ.FÑ.FÔ.F€FÐFÐFÐFÑFØ', u¸TÐ'BÑ'BÔ'BÐÐBÐBÐBÑBÐBÐBr   rA   c                  ó2   — e Zd ZU dZded<   ded<   ded<   dS )ÚMemoryIngestResponsez?Response payload for review/project memory ingestion endpoints.r   r)   r*   r+   Úchunk_countNr,   r   r   r   rD   rD   H   s9   € € € € € € ØIÐIà€K€K�KØÐÐÑØÐÐÑÐÐr   rD   c                  óÒ   — e Zd ZU dZ eddd                     e¦  «        › �¬¦  «        Zded<    edd¬	¦  «        Z	ded
<    eddd¬¦  «        Z
ded<    edd¬¦  «        Zded<   dS )ÚKnowledgeSearchRequestzKnowledge search request..r   r    r!   r   r#   r   r   Úqueryé   é   )r1   ÚgeÚler*   Útop_kNz$Optional metadata retrieval filters.r0   zRetrievalFilterSet | NoneÚfilters)r   r   r   r   r   r&   r   r#   r   rH   rM   rN   r   r   r   rG   rG   P   sÕ   € € € € € € Ø#Ð#à�UØÐE D§I¢IÐ.BÑ$CÔ$CÐEÐEðñ ô €Ið ð ð ñ ð ��s qÐ)Ñ)Ô)€EÐ)Ð)Ð)Ñ)Ø�˜q Q¨2Ð.Ñ.Ô.€EÐ.Ð.Ð.Ñ.Ø).¨ØÐ"Hð*ñ *ô *€Gð ð ð ñ ð ð r   rG   c                  óT   — e Zd ZU dZded<   ded<   ded<    ee¬¦  «        Zded	<   d
S )ÚKnowledgeSearchResultzSingle search hit.r   Úidr   ÚfloatÚscorer   r   r   N)r   r   r   r   r   r   r   r   r   r   r   rP   rP   ]   sQ   € € € € € € ØÐà€G€G�GØ€I€I�IØ€L€L�LØ$˜u°TÐ:Ñ:Ô:€HÐ:Ð:Ð:Ñ:Ð:Ð:r   rP   c                  ó   — e Zd ZU dZded<   dS )ÚKnowledgeSearchResponsezKnowledge search response.zlist[KnowledgeSearchResult]ÚresultsNr,   r   r   r   rU   rU   f   s$   € € € € € € Ø$Ð$à(Ð(Ð(Ñ(Ð(Ð(r   rU   N)r   Ú
__future__r   Útypingr   Úpydanticr   r   Úapp.models.health_agent_schemasr   Úapp.models.schema_constantsr   r
   r   r(   r.   r4   rA   rD   rG   rP   rU   r   r   r   ú<module>r\      s1  ðØ 0Ð 0à "Ð "Ð "Ð "Ð "Ð "à Ð Ð Ð Ð Ð à %Ð %Ð %Ð %Ð %Ð %Ð %Ð %à >Ð >Ð >Ð >Ð >Ð >Ø <Ð <Ð <Ð <Ð <Ð <ð;ð ;ð ;ð ;ð ;˜Iñ ;ô ;ð ;ðCð Cð Cð Cð C˜Yñ Cô Cð Cðð ð ð ð ˜iñ ô ð ðCð Cð Cð Cð C 	ñ Cô Cð Cð;ð ;ð ;ð ;ð ; 	ñ ;ô ;ð ;ð"Cð Cð Cð Cð C ñ Cô Cð Cðð ð ð ð ˜9ñ ô ð ð
ð 
ð 
ð 
ð 
˜Yñ 
ô 
ð 
ð;ð ;ð ;ð ;ð ;˜Iñ ;ô ;ð ;ð)ð )ð )ð )ð )˜iñ )ô )ð )ð )ð )r   