�
"�jx � �� � S SK r S SKrS SKrS SKrS SKrS SKJr SrSr\" S5 r S\
\ \ 4 4S jr " S S \R 5 rSS
.S \ S \S- S\ 4S
jjrSS
.S \ S \S- S\ 4S jjrg)� N)�PathzKssh -o ConnectTimeout=10 -o ServerAliveInterval=15 -o ServerAliveCountMax=3)�-czhttp.lowSpeedLimit=1000r zhttp.lowSpeedTime=60�/�returnc � � [ [ R 5 n U R S[ 5 U R SS5 U $ )N�GIT_SSH_COMMAND�GIT_TERMINAL_PROMPT�0)�dict�os�environ�
setdefault� _SSH_COMMAND)�envs �A/Users/michael/dev/contexts/ctx/rewrite-it-in-rust/src/ctx/git.py�_envr s3 � �
�r�z�z�
�C��N�N�$�l�3��N�N�(�#�.� �J� c �4 ^ � \ rS rSrSrS\4U 4S jjrSrU =r$ )�GitError� zMA failed git call whose message is git's own error, not just the exit status.r c �x >� U R =( d SR 5 nU=( d [ TU ]
5 $ )N� )�stderr�strip�super�__str__)�self�detail� __class__s �r r �GitError.__str__ s, �� ��+�+�#��*�*�,���*��� �*�*r � ) �__name__�
__module__� __qualname__�__firstlineno__�__doc__�strr �__static_attributes__�
__classcell__)r s @r r r s �� �W�+�� +� +r r )�cwd�argsr* c �� � [ R " S/[ QUQU =( d [ S[ R S[ 5 S9nUR R 5 $ )z�Run git, letting stderr (progress, errors) stream to the terminal.
Every call gets the timeouts, not just the ones that reach a remote: they
are inert for local work, and marking each remote call by hand is a thing
to get wrong.
�gitT)r* �check�stdout�textr )�
subprocess�run�
_STALL_CONFIG� _SAFE_CWD�PIPEr r/ r )r* r+ �results r r- r- $ sQ � � �^�^� �&� �&��&� � �9�����
� �F�
�F� �=�=� � � � r c � � # � S/[ QUQn[ R " UU =( d [ [ 5 [ R
R [ R
R SS.6I Sh v�N n UR 5 I Sh v�N u pEUR$ ( a1 [' UR$ X$R) SS9UR) SS95 eUR) SS9R+ 5 $ N~ Ng! [ R a [ R " [ 5 [ R " UR [ R 5 SSS5 O! , ( d f O= fUR# 5 I Sh v�N e f = f7f)uZ Like `git`, but awaitable, quiet, and safe to cancel mid-transfer.
stderr is captured into the exception rather than streamed: the callers
are UIs that must not be written over. Cancellation kills git's whole
process group — git alone would leave its ssh child holding the
connection — so a caller that stops waiting stops the transfer too.
r- T)r* r r/ r �start_new_sessionN�replace)�errors)r3 �asyncio�create_subprocess_execr4 r r1 r5 � communicate�CancelledError�
contextlib�suppress�OSErrorr �killpg�pid�signal�SIGKILL�wait�
returncoder �decoder )r* r+ �argv�procr/ r s r � git_asyncrK 6 s+ � � �
� )�M� )�D� )�D��/�/�
� � �9� �F��!�!�&�&��!�!�&�&� �
� �D�� #� /� /� 1�1��� ���� �O�O�T�=�=� �=�#B�F�M�M�Yb�M�Dc�
�
� �=�=� �=� *� 0� 0� 2�2�' � 2�� � !� !� �
�
�
��
)� �I�I�d�h�h���� /� *�
)�
)���i�i�k���
� �sa �A.F �0C/�1F �6C3 � C1�
C3 �A F �1C3 �3.F�!0E� F�
E( �$F�>F�?F�F )r; r? r rD r1 �pathlibr r r3 r4 r r' r �CalledProcessErrorr r- rK r! r r �<module>rN s� �� � � �
� � �
]� �O�
�
��I� ��d�3��8�n� �+�z�,�,� +� (,� !�s� !���� !�� !�$ 48� 3�3� 3�T�D�[� 3�C� 3r