
    l
j}_                     T   d Z ddlZddlZddlZdZej                  ZdZ	 ddl	m
Z
  e
ee      Zer# ede dd	z   d
e dz   de z   de dz          G d de      Z G d de      Zd Z G d de      Z G d de      Z G d de      Zd Z G d de      Zy# e$ r dZY ww xY w)zEClient and server classes corresponding to protobuf-defined services.    Nz1.73.1F)first_version_is_lowerTz)The grpc package installed is at version ,z6 but the generated code in warp_pb2_grpc.py depends onz	 grpcio>=.z, Please upgrade your grpc module to grpcio>=z6 or downgrade your generated code using grpcio-tools<=c                       e Zd ZdZd Zy)WarpStub************ Important! ***************

    If you change anything here, you *must* run 'generate-protobuf' to update the
    generated stub files.

    Never change the existing members and member values of messages, only add new ones.

    c                 `   |j                  dt        j                  j                  t        j                  j
                  d      | _        |j                  dt        j                  j                  t        j                  j
                  d      | _        |j                  dt        j                  j                  t        j                  j
                  d      | _	        |j                  dt        j                  j                  t        j                  j
                  d      | _        |j                  dt        j                  j                  t        j                  j
                  d      | _        |j                  dt        j                   j                  t        j                  j
                  d      | _        |j                  d	t        j$                  j                  t        j                  j
                  d      | _        |j                  d
t        j                   j                  t        j(                  j
                  d      | _        |j                  dt        j                   j                  t        j                  j
                  d      | _        |j                  dt        j.                  j                  t        j                  j
                  d      | _        |j                  dt        j                  j                  t        j                  j
                  d      | _        y)IConstructor.

        Args:
            channel: A grpc.Channel.
        /Warp/CheckDuplexConnectionTrequest_serializerresponse_deserializer_registered_method/Warp/WaitingForDuplex/Warp/GetRemoteMachineInfo/Warp/GetRemoteMachineAvatar/Warp/ProcessTransferOpRequest/Warp/PauseTransferOp/Warp/SendTextMessage/Warp/StartTransfer/Warp/CancelTransferOpRequest/Warp/StopTransfer
/Warp/PingN)unary_unary	warp__pb2
LookupNameSerializeToString
HaveDuplex
FromStringCheckDuplexConnectionWaitingForDuplexRemoteMachineInfoGetRemoteMachineInfounary_streamRemoteMachineAvatarGetRemoteMachineAvatarTransferOpRequestVoidTypeProcessTransferOpRequestOpInfoPauseTransferOpTextMessageSendTextMessage	FileChunkStartTransferCancelTransferOpRequestStopInfoStopTransferPingselfchannels     (/usr/libexec/warpinator/warp_pb2_grpc.py__init__zWarpStub.__init__&   s    &-%8%8-#,#7#7#I#I&/&:&:&E&E#'	 &9 &)"
 !( 3 3(#,#7#7#I#I&/&:&:&E&E#'	 !4 !)
 %,$7$7,#,#7#7#I#I&/&A&A&L&L#'	 %8 %)!
 '.&:&:.#,#7#7#I#I&/&C&C&N&N#'	 '; ')#
 )0(;(;0#,#>#>#P#P&/&8&8&C&C#'	 )< ))%
  '22'#,#3#3#E#E&/&8&8&C&C#'	  3  )
  '22'#,#8#8#J#J&/&8&8&C&C#'	  3  )
 %11%#,#3#3#E#E&/&9&9&D&D#'	 2 )
 (/':':/#,#3#3#E#E&/&8&8&C&C#'	 (; ()$
 $//$#,#5#5#G#G&/&8&8&C&C#'	 0 )
 ''#,#7#7#I#I&/&8&8&C&C#'	 ( )	    N__name__
__module____qualname____doc__r8    r9   r7   r   r      s    <)r9   r   c                   R    e Zd ZdZd Zd Zd Zd Zd Zd Z	d Z
d	 Zd
 Zd Zd Zy)WarpServicerr   c                     |j                  t        j                  j                         |j	                  d       t        d      )zASender methods
        api v1 duplex method (ping style)
        Method not implemented!set_codegrpc
StatusCodeUNIMPLEMENTEDset_detailsNotImplementedErrorr5   requestcontexts      r7   r    z"WarpServicer.CheckDuplexConnectiono   s7     	66756!";<<r9   c                     |j                  t        j                  j                         |j	                  d       t        d      )z,api v2 duplex method (block/future)
        rC   rD   rK   s      r7   r!   zWarpServicer.WaitingForDuplexw   7     	66756!";<<r9   c                     |j                  t        j                  j                         |j	                  d       t        d      8Missing associated documentation comment in .proto file.rC   rD   rK   s      r7   r#   z!WarpServicer.GetRemoteMachineInfo~   5    66756!";<<r9   c                     |j                  t        j                  j                         |j	                  d       t        d      rQ   rD   rK   s      r7   r&   z#WarpServicer.GetRemoteMachineAvatar   rS   r9   c                     |j                  t        j                  j                         |j	                  d       t        d      rQ   rD   rK   s      r7   r)   z%WarpServicer.ProcessTransferOpRequest   rS   r9   c                     |j                  t        j                  j                         |j	                  d       t        d      rQ   rD   rK   s      r7   r+   zWarpServicer.PauseTransferOp   rS   r9   c                     |j                  t        j                  j                         |j	                  d       t        d      rQ   rD   rK   s      r7   r-   zWarpServicer.SendTextMessage   rS   r9   c                     |j                  t        j                  j                         |j	                  d       t        d      )zReceiver methods
        rC   rD   rK   s      r7   r/   zWarpServicer.StartTransfer   rO   r9   c                     |j                  t        j                  j                         |j	                  d       t        d      )zBoth
        rC   rD   rK   s      r7   r0   z$WarpServicer.CancelTransferOpRequest   rO   r9   c                     |j                  t        j                  j                         |j	                  d       t        d      rQ   rD   rK   s      r7   r2   zWarpServicer.StopTransfer   rS   r9   c                     |j                  t        j                  j                         |j	                  d       t        d      rQ   rD   rK   s      r7   r3   zWarpServicer.Ping   rS   r9   N)r;   r<   r=   r>   r    r!   r#   r&   r)   r+   r-   r/   r0   r2   r3   r?   r9   r7   rA   rA   e   s>    ===========r9   rA   c                 t   t        j                  | j                  t        j                  j
                  t        j                  j                        t        j                  | j                  t        j                  j
                  t        j                  j                        t        j                  | j                  t        j                  j
                  t        j                  j                        t        j                  | j                  t        j                  j
                  t        j                  j                        t        j                  | j                  t        j                  j
                  t        j                   j                        t        j                  | j"                  t        j$                  j
                  t        j                   j                        t        j                  | j&                  t        j(                  j
                  t        j                   j                        t        j                  | j*                  t        j$                  j
                  t        j,                  j                        t        j                  | j.                  t        j$                  j
                  t        j                   j                        t        j                  | j0                  t        j2                  j
                  t        j                   j                        t        j                  | j4                  t        j                  j
                  t        j                   j                        d}t        j6                  d|      }|j9                  |f       |j;                  d|       y )Nrequest_deserializerresponse_serializer)r    r!   r#   r&   r)   r+   r-   r/   r0   r2   r3   Warp)rF   unary_unary_rpc_method_handlerr    r   r   r   r   r   r!   r#   r"   unary_stream_rpc_method_handlerr&   r%   r)   r'   r(   r+   r*   r-   r,   r/   r.   r0   r2   r1   r3   method_handlers_generic_handleradd_generic_rpc_handlersadd_registered_method_handlersservicerserverrpc_method_handlersgeneric_handlers       r7   add_WarpServicer_to_serverrk      s   %)%H%H22)2)=)=)H)H(1(<(<(N(N&
 !% C C--)2)=)=)H)H(1(<(<(N(N!
 %)$G$G11)2)=)=)H)H(1(C(C(U(U%
 '+&J&J33)2)=)=)H)H(1(E(E(W(W'
 )-(K(K55)2)D)D)O)O(1(:(:(L(L)
  $BB,,)2)9)9)D)D(1(:(:(L(L 
  $BB,,)2)>)>)I)I(1(:(:(L(L 
 "AA**)2)9)9)D)D(1(;(;(M(M
 (,'J'J44)2)9)9)D)D(1(:(:(L(L(
 !??)))2););)F)F(1(:(:(L(L
 77MM)2)=)=)H)H(1(:(:(L(Lg8r ::')O
##_$67
))&2EFr9   c                      e Zd ZdZe	 	 	 	 	 	 	 	 dd       Ze	 	 	 	 	 	 	 	 dd       Ze	 	 	 	 	 	 	 	 dd       Ze	 	 	 	 	 	 	 	 dd       Ze	 	 	 	 	 	 	 	 dd       Z	e	 	 	 	 	 	 	 	 dd       Z
e	 	 	 	 	 	 	 	 dd	       Ze	 	 	 	 	 	 	 	 dd
       Ze	 	 	 	 	 	 	 	 dd       Ze	 	 	 	 	 	 	 	 dd       Ze	 	 	 	 	 	 	 	 dd       Zy)r`   r   Nc
                     t         j                  j                  | |dt        j                  j
                  t        j                  j                  ||||||||	d      S )Nr   Tr   rF   experimentalr   r   r   r   r   r   
rL   targetoptionschannel_credentialscall_credentialsinsecurecompressionwait_for_readytimeoutmetadatas
             r7   r    zWarp.CheckDuplexConnection  sd       ,,)  22  ++# - % 	%r9   c
                     t         j                  j                  | |dt        j                  j
                  t        j                  j                  ||||||||	d      S )Nr   Trn   ro   rq   s
             r7   r!   zWarp.WaitingForDuplex  sd       ,,$  22  ++# - % 	%r9   c
                     t         j                  j                  | |dt        j                  j
                  t        j                  j                  ||||||||	d      S )Nr   Trn   )rF   rp   r   r   r   r   r"   r   rq   s
             r7   r#   zWarp.GetRemoteMachineInfo8  sd       ,,(  22''22# - % 	%r9   c
                     t         j                  j                  | |dt        j                  j
                  t        j                  j                  ||||||||	d      S )Nr   Trn   )rF   rp   r$   r   r   r   r%   r   rq   s
             r7   r&   zWarp.GetRemoteMachineAvatarS  sd       --*  22))44# . % 	%r9   c
                     t         j                  j                  | |dt        j                  j
                  t        j                  j                  ||||||||	d      S )Nr   Trn   )rF   rp   r   r   r'   r   r(   r   rq   s
             r7   r)   zWarp.ProcessTransferOpRequestn  sd       ,,,''99))# - % 	%r9   c
                     t         j                  j                  | |dt        j                  j
                  t        j                  j                  ||||||||	d      S )Nr   Trn   rF   rp   r   r   r*   r   r(   r   rq   s
             r7   r+   zWarp.PauseTransferOp  sd       ,,#..))# - % 	%r9   c
                     t         j                  j                  | |dt        j                  j
                  t        j                  j                  ||||||||	d      S )Nr   Trn   )rF   rp   r   r   r,   r   r(   r   rq   s
             r7   r-   zWarp.SendTextMessage  sd       ,,#!!33))# - % 	%r9   c
                     t         j                  j                  | |dt        j                  j
                  t        j                  j                  ||||||||	d      S )Nr   Trn   )rF   rp   r$   r   r*   r   r.   r   rq   s
             r7   r/   zWarp.StartTransfer  sd       --!..**# . % 	%r9   c
                     t         j                  j                  | |dt        j                  j
                  t        j                  j                  ||||||||	d      S )Nr   Trn   r   rq   s
             r7   r0   zWarp.CancelTransferOpRequest  sd       ,,+..))# - % 	%r9   c
                     t         j                  j                  | |dt        j                  j
                  t        j                  j                  ||||||||	d      S )Nr   Trn   )rF   rp   r   r   r1   r   r(   r   rq   s
             r7   r2   zWarp.StopTransfer  sd       ,, 00))# - % 	%r9   c
                     t         j                  j                  | |dt        j                  j
                  t        j                  j                  ||||||||	d      S )Nr   Trn   )rF   rp   r   r   r   r   r(   r   rq   s
             r7   r3   z	Warp.Ping  sd       ,,  22))# - % 	%r9   r?   NNFNNNN)r;   r<   r=   r>   staticmethodr    r!   r#   r&   r)   r+   r-   r/   r0   r2   r3   r?   r9   r7   r`   r`      s      $!% %4   $!% %4   $!% %4   $!% %4   $!% %4   $!% %4   $!% %4   $!% %4   $!% %4   $!% %4   $!% %r9   r`   c                       e Zd ZdZd Zy)WarpRegistrationStubrR   c                 ,   |j                  dt        j                  j                  t        j                  j
                  d      | _        |j                  dt        j                  j                  t        j                  j
                  d      | _        y)r
   $/WarpRegistration/RequestCertificateTr   !/WarpRegistration/RegisterServiceN)	r   r   
RegRequestr   RegResponser   RequestCertificateServiceRegistrationRegisterServicer4   s     r7   r8   zWarpRegistrationStub.__init__/  s~     #*"5"56#,#7#7#I#I&/&;&;&F&F#'	 #6 #)
  '223#,#@#@#R#R&/&C&C&N&N#'	  3  )r9   Nr:   r?   r9   r7   r   r   ,  s
    B)r9   r   c                       e Zd ZdZd Zd Zy)WarpRegistrationServicerrR   c                     |j                  t        j                  j                         |j	                  d       t        d      rQ   rD   rK   s      r7   r   z+WarpRegistrationServicer.RequestCertificateD  rS   r9   c                     |j                  t        j                  j                         |j	                  d       t        d      rQ   rD   rK   s      r7   r   z(WarpRegistrationServicer.RegisterServiceJ  rS   r9   N)r;   r<   r=   r>   r   r   r?   r9   r7   r   r   A  s    B==r9   r   c                    t        j                  | j                  t        j                  j
                  t        j                  j                        t        j                  | j                  t        j                  j
                  t        j                  j                        d}t        j                  d|      }|j                  |f       |j                  d|       y )Nr]   )r   r   WarpRegistration)rF   ra   r   r   r   r   r   r   r   r   rc   rd   re   rf   s       r7   &add_WarpRegistrationServicer_to_serverr   Q  s    "&"E"E//)2)=)=)H)H(1(=(=(O(O#
  $BB,,)2)F)F)Q)Q(1(E(E(W(W  :: 35O
##_$67
))*<>QRr9   c                   T    e Zd ZdZe	 	 	 	 	 	 	 	 dd       Ze	 	 	 	 	 	 	 	 dd       Zy)r   rR   Nc
                     t         j                  j                  | |dt        j                  j
                  t        j                  j                  ||||||||	d      S )Nr   Trn   )rF   rp   r   r   r   r   r   r   rq   s
             r7   r   z#WarpRegistration.RequestCertificateh  sd       ,,2  22!!,,# - % 	%r9   c
                     t         j                  j                  | |dt        j                  j
                  t        j                  j                  ||||||||	d      S )Nr   Trn   )rF   rp   r   r   r   r   r   rq   s
             r7   r   z WarpRegistration.RegisterService  sd       ,,/));;))44# - % 	%r9   r   )r;   r<   r=   r>   r   r   r   r?   r9   r7   r   r   e  s_    B  $!% %4   $!% %r9   r   )r>   rF   warningswarp_pb2r   GRPC_GENERATED_VERSION__version__GRPC_VERSION_version_not_supportedgrpc._utilitiesr   ImportErrorRuntimeErrorobjectr   rA   rk   r`   r   r   r   r   r?   r9   r7   <module>r      s   K   !  "63LBXY 

3L>CB	D,-Q
/	0 99O8P
Q	R C<.PQ
R		S F)v F)RO=6 O=d=GBq%6 q%h	)6 )*=v = S(7%v 7%m  "!"s   B B'&B'