§
     ’jÈ  ã                  óˆ   — d dl mZ d dlZd dlZd dlmZ d dlmZ d dlm	Z	 ddl
mZ ddlmZmZmZ  G d	„ d
e¦  «        Zd„ ZdS )é    )ÚannotationsN)ÚAny)ÚErpDatabaseClient)ÚFourPillarsServiceé   )ÚToolDispatcherMixin)ÚSERVER_NAMEÚSERVER_VERSIONÚTOOLS_DEFINITIONc                  ó"   — e Zd ZdZd	d„Zd
d„ZdS )ÚDSConsMCPServerzDStandard JSON-RPC 2.0 MCP Server handler for DeepSeek Harness (DSH).ÚreturnÚNonec                ó^   — t          ¦   «         | _        t          | j        ¦  «        | _        d S )N)r   Úpostgres_clientr   Úfour_pillars)Úselfs    ú/C:\Projects\DSCons\app\mcp\server_pkg\server.pyÚ__init__zDSConsMCPServer.__init__   s)   € Ý0Ñ2Ô2ˆÔÝ.¨tÔ/CÑDÔDˆÔÐÐó    Úrequestúdict[str, Any]c           	     ó2  — |                      d¦  «        }|                      d¦  «        }|dk    rd|dt          t          dœdi idœd	œS |d
k    rd|dt          id	œS |dk    rª|                      di ¦  «        }|                      d¦  «        }|                      di ¦  «        }	 |                      ||¦  «        }d|dt          j        |ddt          ¬¦  «        dœgddœd	œS # t          $ r}d|dd|› d|›�dœgddœd	œcY d}~S d}~ww xY wd|dd|› �dœdœS )uJ   Xá»­ lÃ½ yÃªu cáº§u JSON-RPC tá»« MCP client (DSH / Claude / Antigravity).ÚmethodÚidÚ
initializeú2.0z
2024-11-05)ÚnameÚversionÚtools)ÚprotocolVersionÚ
serverInfoÚcapabilities)Újsonrpcr   Úresultz
tools/listz
tools/callÚparamsr   Ú	argumentsÚtextFé   )Úensure_asciiÚindentÚdefault)Útyper(   )ÚcontentÚisErroru   Lá»—i thá»±c thi tool z: TNi§€ÿÿzMethod not found: ©ÚcodeÚmessage©r$   r   Úerror)	Úgetr	   r
   r   Ú_execute_toolÚjsonÚdumpsÚstrÚ	Exception)	r   r   r   Úmsg_idr&   r   Úargsr.   Úexcs	            r   Úhandle_requestzDSConsMCPServer.handle_request   sò  € à—’˜XÑ&Ô&ˆØ—’˜TÑ"Ô"ˆà�\Ò!Ð!à Øà'3Ý+6Å>Ð"RÐ"RØ%,¨b Mðð ðð ð ð �|Ò#Ð#à ØØ"Õ$4Ð5ðð ð ð �|Ò#Ð#Ø—[’[ ¨2Ñ.Ô.ˆFØ—:’:˜fÑ%Ô%ˆDØ—:’:˜k¨2Ñ.Ô.ˆDðØ×,Ò,¨T°4Ñ8Ô8�à$Ø ð )/Ý(,¬
Ø$+¸%ÈÕSVð)"ñ )"ô )"ðð ð$ð $)ð
ð 
ðð ð øõ ð ð ð à$Ø ð )/Ø(PÀÐ(PÐ(PÈÐ(PÐ(Pðð ð$ð $(ðð ðð ð ð ð ð ð ð øøøøðøøøð" !ØØ"(Ð5RÈ&Ð5RÐ5RÐSÐSðð ð s   Â%=C# Ã#
D
Ã-DÃ?D
ÄD
N)r   r   )r   r   r   r   )Ú__name__Ú
__module__Ú__qualname__Ú__doc__r   r>   © r   r   r   r      sL   € € € € € ØNÐNðEð Eð Eð EðAð Að Að Að Að Ar   r   c                 óX  — t          ¦   «         } t          j        D �]}|                     ¦   «         }|sŒ	 t	          j        |¦  «        }|                      |¦  «        }t          j                             t	          j	        |d¬¦  «        dz   ¦  «         t          j         
                    ¦   «          Œ™# t          $ ri}dddd|›�dœd	œ}t          j                             t	          j	        |¦  «        dz   ¦  «         t          j         
                    ¦   «          Y d}~�Œd}~ww xY wdS )
uQ   VÃ²ng láº·p Ä‘á»�c JSON-RPC tá»« stdin vÃ  ghi stdout cho DeepSeek Harness (DSH).F)r*   ú
r   NiD€ÿÿzParse error: r0   r3   )r   ÚsysÚstdinÚstripr7   Úloadsr>   ÚstdoutÚwriter8   Úflushr:   )ÚserverÚlineÚreqÚresr=   Úerr_ress         r   Úrun_stdio_serverrR   Y   s7  € åÑÔ€FÝ”	ð ñ ˆØ�zŠz‰|Œ|ˆØð 	Øð	Ý”*˜TÑ"Ô"ˆCØ×'Ò'¨Ñ,Ô,ˆCÝŒJ×Ò�TœZ¨¸%Ð@Ñ@Ô@À4ÑGÑHÔHÐHÝŒJ×ÒÑÔÐÐøÝð 	ð 	ð 	à ØØ"(Ð5LÀSÐ5LÐ5LÐMÐMðð ˆGõ
 ŒJ×Ò�TœZ¨Ñ0Ô0°4Ñ7Ñ8Ô8Ð8ÝŒJ×ÒÑÔÐÐÐÐÐÑøøøøð	øøøðð s   ¶A=B4Â4
D'Â>AD"Ä"D')Ú
__future__r   r7   rF   Útypingr   Úapp.core.postgres.erp_clientr   Ú6app.modules.financial.application.four_pillars_servicer   Útool_dispatcherr   Útools_registryr	   r
   r   r   rR   rC   r   r   ú<module>rY      sÜ   ðØ "Ð "Ð "Ð "Ð "Ð "à €€€Ø 
€
€
€
Ø Ð Ð Ð Ð Ð à :Ð :Ð :Ð :Ð :Ð :Ø UÐ UÐ UÐ UÐ UÐ Uà 0Ð 0Ð 0Ð 0Ð 0Ð 0Ø IÐ IÐ IÐ IÐ IÐ IÐ IÐ IÐ IÐ IðHð Hð Hð Hð HÐ)ñ Hô Hð HðVð ð ð ð r   