; i* d Z ddlZddlZddlZddlZddlZddlZddlZddlm Z ddl
Z
ddl Z ddl m
Z
mZmZ ddlmZmZ ej& e Z G d d Z G d d
Z G d d e Zy)
a
OpenDrop: an open source AirDrop implementation
Copyright (C) 2018 Milan Stute
Copyright (C) 2018 Alexander Heinrich
This program is free software: you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation, either version 3 of the License, or
(at your option) any later version.
This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU General Public License for more details.
You should have received a copy of the GNU General Public License
along with this program. If not, see .
N)HTTPSConnection) IPVersionServiceBrowserZeroconf )AbsArchiveWrite AirDropUtilc , e Zd Zd ZddZd Zd Zd Zy)AirDropBrowserc t j |j d | _ | j A|j dk( rt d|j d t d|j d t t
| j gt j t j dk( | _ d | _ d | _
d | _ y ) NT)ipv6awdl0z
Interface z@ does not have an IPv6 address. Make sure that `owl` is running.z does not have an IPv6 addressDarwin)
interfaces
ip_version apple_p2p)r get_ip_for_interface interfaceip_addr RuntimeErrorr strr V6Onlyplatformsystemzeroconf callback_addcallback_removebrowser)selfconfigs B/home/ubuntu/myenv/lib/python3.12/site-packages/opendrop/client.py__init__zAirDropBrowser.__init__' s "778H8HtT << 7*" !1!1 22rs # !1!1 22PQ !DLL)* '' oo'83
! # Nc r | j y|| _ || _ t | j d| | _ y)zL
Start the AirDropBrowser to discover other AirDrop devices
Nz_airdrop._tcp.local.)r r r r r )r r r s r! startzAirDropBrowser.start= s6 << # ( . %dmm5KTR r# c z | j j d | _ | j j y N)r cancelr close)r s r! stopzAirDropBrowser.stopG s)
r# c |j || }t j d| | j | j | y y )Nz Add service )get_service_infologgerdebugr r r service_typenameinfos r! add_servicezAirDropBrowser.add_serviceL sF (( t< |D6*+ ( d # )r# c |j || }t j d| | j | j | y y )NzRemove service )r, r- r. r r/ s r! remove_servicez AirDropBrowser.remove_serviceR sF (( t< tf-. + & ,r# )NN)__name__
__module__ __qualname__r" r% r* r3 r5 r# r! r r & s ,S
$ 'r# r c 6 e Zd Zd ZddZd Zd dZd
dZd Zy)
AirDropClientc H || _ |d | _ |d | _ d | _ y )Nr r )r
receiver_host
receiver_port http_conn)r r receivers r! r" zAirDropClient.__init__Z s( %a[ %a[ r# Nc t j d| d t j | j |d|j j
d d | j }| |j D ]
\ }}|||< | j Tt | j | j | j j | j j | _ | j j d||| | j j! }|j# }t j | j |d|j j
d d |j$ d
k7 r*d } t j | d |j$ | |fS d
} t j | d | |fS )NzSend z requestsend_/z_request.plist)interface_namecontextPOST)bodyheadersz_response.plist Fz request failed: Tz request successful)r- r. r write_debugr lowerstrip _get_headersitemsr? HTTPSConnectionAWDLr= r> r get_ssl_contextrequest getresponsereadstatus)
r urlrG rH _headerskeyval http_respresponse_bytesrT s
r! send_POSTzAirDropClient.send_POST` s uSE*+ KKsyy{'8'8'=&>n M
$$& #MMO
$S #
$ >> ! 0"""" #{{ 4 4 335 DN
vsx HNN..0 " ) KK CIIK%%c*+? ;
s "F LLC5 1)2B2B1CD E ~%% F LLC5 34 5~%%r# c $ i }| j j r| j j |d< t j |t j }| j d| \ }}t j | }|j d S )NSenderRecordDatafmtz /DiscoverReceiverComputerName)r record_dataplistlibdumps
FMT_BINARYr[ loadsget)r
discover_bodydiscover_plist_binary_rZ responses r!
send_discoverzAirDropClient.send_discover s{
;; " "04 0G0GM, - ( x 2 2!
!NN;8M N>>>.1 || 233r# c | j j d| j j | j j dd}| j j r| j j |d< fd}t |t r|g}|r||d< nt |d d 5 }|j d }t j | |sHt j dkD r0d
j d v r t j |j }d d d || D cg c] }| c}|d < |r||d < t! j" |t j$
} | j' d| \ }
} |
S # 1 sw Y exY wc c}w )Nzcom.apple.finderF)SenderComputerNameBundleIDSenderModelNameSenderIDConvertMediaFormatsr] c 3 K | D ]{ }t j j | }|t j t j j d| t j j
| dd}| } y w)N.r )FileNameFileType FileBomPathFileIsDirectoryrq )ospathbasenamer get_uti_typejoinisdir)filesfile file_name
file_entryflps r! file_entriesz,AirDropClient.send_ask..file_entries so
! GG , ,T 2 ) + 8 8 =#%77<<Y#?')ww}}Y'?+,
!
!s BBItemsr rb imageFilesFileIconr^ z/Ask)r
computer_namecomputer_model
service_idra
isinstancer openrS fleeprf lenmimer generate_file_iconr1 rb rc rd r[ )
r file_pathis_urliconask_bodyr f file_headere
ask_binarysuccessri r s
@r! send_askzAirDropClient.send_ask s] "&++";";* #{{ 9 9 ..#(
;; " "+/;;+B+BH' (
! i %" I )HW ilD)
BQ ffSk ii ,CHH
1g!6L&99!&&AD
B
-9,C Dq DHW #'HZ ^^ (--
^^FJ7
B
B
!Es $A1E9' F9Fc |ryddi}t j }t j |j ddt
5 }|fD ]Q }t j j | }|j |t j j d| S ddd |j d | j d ||
\ }} |S # 1 sw Y 3xY w) z,
Send a file to a receiver.
N Content-Typezapplication/x-cpiocpiogzip) filter_namearchive_write_classrs r z/Upload)rH )
ioBytesIO
libarchive
custom_writerwriter rx ry rz add_abs_filer| seekr[ )
r r r rH streamarchiver ffr ri s
r! send_uploadzAirDropClient.send_upload s
0
%
% LL /
?
[
?WW%%a($$Q S"(=>
?
? A ^^Ivw^G
! ? ?s
ACCc ddddddd}|S )z3
Get the headers for requests sent
zapplication/octet-streamz
keep-alivez*/*z AirDrop/1.0zen-uszbr, gzip, deflate)r
ConnectionAcceptz
User-AgentzAccept-LanguagezAccept-Encodingr9 )r rH s r! rM zAirDropClient._get_headers s$
7&' & 2
r# r' )FN)F) r6 r7 r8 r" r[ rk r r rM r9 r# r! r; r; Y s# #&J 4 +Z @ r# r; c b e Zd ZdZ ddddd fd Z ej dfdZ xZS )rO zV
This class allows to bind the HTTPConnection to a specific network interface
N)rE check_hostnamerD c
| 9d|vr5t t j | t j r|dz | z }|t j
}t t | # |||||||| | | _ | j | _ y )N%)hostportkey_file cert_filetimeoutsource_addressrE r ) r ipaddress
ip_address IPv6AddresssocketgetdefaulttimeoutsuperrO r" rD create_connection_awdl_create_connection) r r r r r r r rE r rD __class__s r! r" z HTTPSConnectionAWDL.__init__ s %$ i 2 24 8):O:OP #:6D ? ..0G
!41 )) 2
-"&"="= r# c p |\ }}d}t j ||dt j D ] }|\ }} }
} } d}
t j || |
}
|t j ur|
j | | j
dk( r8t
j dk( r!|
j t j dd |r|
j | |
j | |
c S ||t j d # t j $ r } | }|
|
j Y d} ~ d} ~ ww xY w)a Connect to *address* and return the socket object.
Convenience function. Connect to *address* (a 2-tuple ``(host,
port)``) and return the socket object. Passing the optional
*timeout* parameter will set the timeout on the socket instance
before attempting to connect. If no *timeout* is supplied, the
global default timeout setting returned by :func:`getdefaulttimeout`
is used. If *source_address* is set it must be a tuple of (host, port)
for the socket to bind as a source address before making the connection.
A host of '' or port 0 tells the OS to use the default.
Nr r r i r z!getaddrinfo returns an empty list)r getaddrinfo SOCK_STREAMr
settimeoutrD r r
setsockopt
SOL_SOCKETbindconnecterrorr) )r addressr r r r errresafsocktypeprotori sasocks r! r z*HTTPSConnectionAWDL.create_connection_awdl s
d%%dD!V5G5GH !C), &B%BD
! }}R59&":":"<<OOG,&&'1hoo6G86SOOF$5$5vqA!IIn- R !( ?I,, BC C <<
!#JJL
!s B*DD5D00D5)NNNNN) r6 r7 r8 __doc__r" r r r
__classcell__)r s @r! rO rO sG "> ">J 8v 7 7 9$(Dr# rO )r r r loggingrx r rb r http.clientr r r r r r r utilr r getLoggerr6 r- r r; rO r9 r# r! r sm &
' 8 8 . 8 $0' 0'fS SlQD/ QDr#