; i- d Z ddlZddlZddlZddlZddlZddlZddlZddlm Z m
Z
ddl Z ddl Z ddl
Z ddlmZmZmZ ddlmZ ej( e Z G d d Z G d d
e
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)BaseHTTPRequestHandler
HTTPServer) IPVersion ServiceInfoZeroconf ) AirDropUtilc : e Zd ZdZd Zd Zd Zd Zd Zd Z d Z
y )
AirDropServerzJ
Announces an HTTPS AirDrop server in the local network via mDNS.
c || _ d| j j f| _ t | _ d| j _ t
j | j j d | _ | j _| j j dk( r#t d| j j d t d| j j d t | _ | j | j _ t t | j gt j t# j$ d k(
| _ | j) | _ | j- | _ y ) Nz::FT)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)configport
serveraddress HTTPServerV6 ServerClassallow_reuse_addressr get_ip_for_interface interfaceip_addr RuntimeErrorAirDropServerHandlerHandlerr strr V6Onlyplatformsystemzeroconf _init_server http_server
_init_service service_info)selfr s B/home/ubuntu/myenv/lib/python3.12/site-packages/opendrop/server.py__init__zAirDropServer.__init__+ s3 #DKK$4$4 5'/4,"77 KK ! !
<< {{$$/" !6!6 77wx # !6!6 77UV , "kk DLL)* '' oo'83
,,. . . 0 c | j }| j j dz }| j j dz }t d|| j j
||| j j g }|S )Nz.local.z._airdrop._tcp.local.z_airdrop._tcp.local.)r
propertiesserver addresses)get_propertiesr host_name
service_idr r r packed)r( r- r. service_nameinfos r) r& zAirDropServer._init_serviceL ss ((*
&&2{{--0GG " !!!||**+
r+ c t j d| j j d| j d| j j
| j j | j y )NzAnnouncing service: host z
, address z, port ) loggerr5 r r1 r r r# register_servicer' r( s r)
start_servicezAirDropServer.start_serviceZ s\ ' (=(='>j V]^b^i^i^n^n]o p
&&t'8'89r+ c | j | j | j }| j j dk( rBt j dk( r+|j j t j dd | j j j |j d |_ |S # t $ r| | j j
dz | j _ | j d | j j
f| _ | j | j | j }Y w xY w)Nr r r r i T)sock server_side)r r r OSErrorr r r r! r" socket
setsockopt
SOL_SOCKETget_ssl_context wrap_socket)r( httpds r) r$ zAirDropServer._init_server` s G$$T%7%7 FE ;; G +0AX0M LL # #F$5$5vq A{{224@@ 4 A
G #{{ / /! 3DKK "&"4"4Q"79I9I!JD $$T%7%7 FE Gs &B? ?BEEc b t j d | j j y )NzStarting HTTPS server)r7 r5 r%
serve_foreverr9 s r) start_serverzAirDropServer.start_servers s! +, &&(r+ c l | j j | j j y N)r# unregister_all_servicesr% shutdownr9 s r) stopzAirDropServer.stopw s$
--/ !!#r+ c f dt | j j j d i}|S )Ns flagsutf-8)r r flagsencode)r( r- s r) r0 z AirDropServer.get_properties{ s, DKK$5$5 6 = =g FG
r+ N) __name__
__module__ __qualname____doc__r* r& r: r$ rG rL r0 r+ r) r r & s+ 1B : &)$r+ r c $ e Zd Zej Zy)r N)rQ rR rS r? AF_INET6address_familyrU r+ r) r r s __Nr+ r c H e Zd ZdZdZdZd Zd Zd Zd Z d Z
d Z d
Z d Z
y) r z=
Server which responds to AirDrop HTTP POST requests
zHTTP/1.1Nc j | j d | j d| | j y)zF
Setting the default values for a successful response
Content-LengthN
send_response send_header end_headers)r( content_lengths r)
_set_responsez"AirDropServerHandler._set_response s/
3 )>: r+ c j | j d | j dd | j y)z&
Answer head requests
r[ z Content-typez text/htmlNr] r9 s r) do_HEADz AirDropServerHandler.do_HEAD s.
3 5 r+ c t j d| j dj d }| j t | | j j | y)z%
Answer get requests
zGET request at
rN N)r7 debugpathrP rb lenwfilewrite)r( bodys r) do_GETzAirDropServerHandler.do_GET sM tyyk23{{7# 3t9%
r+ c t | j d }| j j | }t j
| j |d ddi}t j j | }|j d }|| j j | j j d}| j j r| j j |d< t j |t j }t j
| j |d | j! t# | | j$ j' | y )
Nr\ z receive_discover_request.plistVersionr rN )ReceiverMediaCapabilitiesReceiverComputerNameReceiverModelNameReceiverRecordDatafmtz receive_discover_response.plist)intheadersrfilereadr write_debugr json JSONEncoderrP
computer_namecomputer_model record_dataplistlibdumps
FMT_BINARYrb ri rj rk )r( ra post_datamedia_capabilitiesmedia_capabilities_jsonmedia_capabilities_binarydiscover_answerdiscover_answer_binarys r) handle_discoverz$AirDropServerHandler.handle_discover s' T\\*: ;<JJOON3 KK$D
q
8 #'"2"2"4";";.HTTPChunkedReaderc N t | |i | || _ d | _ d| _ y )Nr )superr* rx chunktotal)r( rx argskwargs __class__s r) r* zFAirDropServerHandler.handle_upload..HTTPChunkedReader.__init__ s* $1&1 "
!
r+ c & | j t | j dk( rmt | j j j d }| j j
| | _ | j j y y )Nr )r ri rv rx readlinerstripry )r( lengths r) _next_chunkzIAirDropServerHandler.handle_upload..HTTPChunkedReader._next_chunk sf ::%TZZ A)= !4!4!6!=!=!? DF!% !8DJJJ'') *>r+ c | j t t | j t | }| j d | |d | | j |d | _ | xj |z
c_ |S rI )r minri r r )r( bufr s r) readintozFAirDropServerHandler.handle_upload..HTTPChunkedReader.readinto sa " S_c#h7 #zz'6 2GV !ZZ 0
f$
r+ )rQ rR rS r* r r
__classcell__)r s @r) HTTPChunkedReaderr s
*
r+ r c t j j | 5 }t j j || ddd y# 1 sw Y yxY w)zU
Extracts an archive from memory into the current directory.
N)
libarchivery
stream_readerextractextract_entries)streamrO archives r) extract_streamz:AirDropServerHandler.handle_upload..extract_stream% sG
..v6
C'""227EB
C
C
Cs !A
AzReceiving file(s) ...g @zFile(s) received (size z.02fz MB, speed z MB/s)r[ )r )rw getlowerr7 warningr^ r_ r` io RawIOBaser5 timerx r )r( r r startreader transferredspeeds r)
handle_uploadz"AirDropServerHandler.handle_upload s8 << NB / 5 5 7;O O NN,T\\-=-=n-M,NO
s # ^-A B -q 1 \7 3 << Hb ) / / 1^ C s # -q 1 << / 4 : : < I NN= > s # 0) < -q 1 \7 3 * C +, "4::.v llV+f4 tyy{U 23 %k$%7{5,f U
3 )1- w/ r+ c t j d| j t j d| j | j dk( r| j y | j dk( r| j y | j dk( r| j
y t j d| j | j d | j dd | j y )
z&
Handle post requests
zPOST request at zHeaders
z /Discoverz/Askz/Uploadr r\ r N)
r7 rg rh rw r r r r^ r_ r` r9 s r) do_POSTz AirDropServerHandler.do_POST= s
' {34 y /0 99 # "
YY&
OO
YY)
# LL+DII;7 8 s # -q 1 r+ c z t j | j d d| j d||z y )Nr z - - [z] )r7 rg client_addresslog_date_time_string)r( formatr s r) log_messagez AirDropServerHandler.log_messageQ s= ""1%&fT-F-F-H,IFUYM? [
r+ )rQ rR rS rT protocol_versionr rb rd rm r r r r r rU r+ r) r r s? "
F 91v**FP (
r+ r )rT r r{ loggingr! r r? r http.serverr r r libarchive.extractlibarchive.readr# r r r utilr getLoggerrQ r7 r r r rU r+ r) r sp $
: 5 5 8 $W Wt%: %Q
1 Q
r+