o 9A_T2@sdZddlZddlZddlZddlZddlZddlZddlmZm Z ddl m Z ddl m Z ddlmZddlmZddlmZdd lmZdd lmZd d lmZmZd d lmZmZd dlmZddlmZmZddl Z e j!dksye j!j"dkr~ddl#Z#nddlm#Z#e j!dkre j$dkrddl%Z%e%&e%'e(dZ)dZ*ddZ+d#ddZ,Gdddej-Z.Gdd d e Z/Gd!d"d"e0Z1dS)$z livereload.server ~~~~~~~~~~~~~~~~~ WSGI app server for livereload. :copyright: (c) 2013 - 2015 by Hsiaoming Yang :license: BSD, see LICENSE for more details. N)PopenPIPE) WSGIContainer)IOLoop)add_reload_hook)web)escape)httputil) LogFormatter)LiveReloadHandlerLiveReloadJSHandler)ForceReloadHandlerStaticFileHandler)get_watcher_class) string_typesPY3))errno)rwin32 livereloadscsfdd}|S)z1Helper Function to Add HTTP headers to the servercs&|g|Ri||dSN) set_header)selfargskwargsfnnamevalue3/usr/lib/python3/dist-packages/livereload/server.pyset_default_headers2sz'set_header..set_default_headersr#)r r!r"r%r#rr$r0srwFcsfstjntj}|rtj|st|tttfs's't fdd}|S)aAExecute a shell command. You can add a shell command:: server.watch( 'style.less', shell('lessc style.less', output='style.css') ) :param cmd: a shell command, string or list :param output: output stdout to the given file :param mode: only works with output, mode ``w`` means write, mode ``a`` means append :param cwd: set working directory before command is executed. :param shell: if true, on Unix the executable argument specifies a replacement shell for the default ``/bin/sh``. c sz ttttd}Wn'ty3}zt||jtjkr'tdd|WYd}~Sd}~ww|\}}|rCt||StrI| }t }| |WddS1s_wYdS)N)stdinstdoutstderrcwdshellzmaybe you haven't installed %sr) rrOSErrorloggererrorrENOENT communicaterdecodeopenwrite)per(r)fcmdr*modeoutputr+r#r$ run_shellSs(        "zshell..run_shell) osdevnullpathdirnameisdirmakedirs isinstancelisttupleshlexsplit)r8r:r9r*r+folderr;r#r7r$r+8s   r+cs$eZdZfddZddZZS)LiveScriptInjectorcstt||dSr)superrH__init__)rrequest __class__r#r$rJjszLiveScriptInjector.__init__cCsNt|vr"|t|jt}d|vr"t|dt|j}t||d<|||fS)NContent-Length)HEAD_ENDreplacescriptintlenstr)r status_codeheaderschunk finishinglengthr#r#r$transform_first_chunkms   z(LiveScriptInjector.transform_first_chunk)__name__ __module__ __qualname__rJrZ __classcell__r#r#rLr$rHis rHc@seZdZdddZddZdS)LiveScriptContainercCs||_||_dSr)wsgi_apprQ)rrarQr#r#r$rJws zLiveScriptContainer.__init__c sigdfdd }|t||}z|d}Wt|dr*|n t|dr5|wws.start_responseclosez$WSGI app did not call start_responserb r rVcss|] \}}|VqdSr)lower).0kvr#r#r$ sz/LiveScriptContainer.__call__..i0z content-type)z Content-Typez'application/octet-stream; charset=UTF-8zcontent-lengthrNserver)Server LiveServerzHTTP/1.1)rWr)rarenvironextendjoinhasattrrk ExceptionrFrRsetrutf8rOrPrQrcrTrSr ResponseStartLine HTTPHeadersrmadd connection write_headersfinish_log) rrKri app_responsebodyrUreasonrV header_set start_line header_objkeyr"r#rfr$__call__{sT            zLiveScriptContainer.__call__N)r`)r[r\r]rJrr#r#r#r$r_vs  r_c@sZeZdZdZdddZddZdddZ  dd d Zd d Z   dddZ ddZ dS)rsaLivereload server interface. Initialize a server and watch file changes:: server = Server(wsgi_app) server.serve() :param app: a wsgi application instance :param watcher: A Watcher instance, you don't have to initialize it by yourself. Under Linux, you will want to install pyinotify and use INotifyWatcher() to avoid wasted CPU usage. NcCs,d|_||_|st}|}||_t|_dSr)rootapprwatcherrSFH)rrr watcher_clsr#r#r$rJs zServer.__init__cCsttj||t_t|_dS)aAdd or override HTTP headers at the at the beginning of the request. Once you have intialized a server, you can add one or more headers before starting the server:: server.setHeader('Access-Control-Allow-Origin', '*') server.setHeader('Access-Control-Allow-Methods', '*') server.serve() :param name: The name of the header field to be defined. :param value: The value of the header field to be defined. N)rrr%r)rr!r"r#r#r$ setHeaders zServer.setHeadercCs:t|tr|}t|}d||_|jj||||ddS)aAdd the given filepath for watcher list. Once you have intialized a server, watch file changes before serve the server:: server.watch('static/*.stylus', 'make static') def alert(): print('foo') server.watch('foo.txt', alert) server.serve() :param filepath: files to be watched, it can be a filepath, a directory, or a glob pattern :param func: the function to be called, it can be a string of shell command, or any callable object without parameters :param delay: Delay sending the reload message. Use 'forever' to not send it. This is useful to compile sass files to css, but reload on changed css files then only. :param ignore: A function return True to ignore a certain pattern of filepath. z shell: {})ignoreN)rBrr+formatr!rwatch)rfilepathfuncdelayrr8r#r#r$rs  z Server.watchTc s|jt_|t_|dur|jrd}dtfdtfdtfg}d|r't|ntd|}Gfdddt }|sU||} t j | ||gd } | j ||d dSt j |||gd } | j ||d t j |d d } | j ||d dS) NTz /livereloadz /forcereloadz/livereload.jszzJ(window.location.port || (window.location.protocol == 'https:' ? 443: 80))cseZdZZdS)z/Server.application..ConfiguredTransformN)r[r\r]rQr# live_scriptr#r$ConfiguredTransformsr)handlersdebug transforms)addressF)rr) rr live_cssrrr rr{get_web_handlersrHr Applicationlisten) rporthostliveportrr live_handlers web_handlersrrrliver#rr$ applications>   zServer.applicationcCs@|jrt|j|}dtjd|ifgSd|j|jpd|jdfgS)Nz.*fallbackz/(.*).)r>default_filename)rr_rFallbackHandlerrrr)rrQrr#r#r$r.s zServer.get_web_handlers|Fr index.htmlc spd|dur ||_|tdf| |_|j||| d|r,tddur@fdd} tj| d z|j j d |ft td d t WdStyktd YdSw) aStart serve the server with the given port. :param port: serve on this port, default is 5500 :param liveport: live reload on this port :param host: serve on this hostname, default is 127.0.0.1 :param root: serve static on this root directory :param debug: set debug mode, which autoreloads the app on code changes via Tornado (and causes polling). Defaults to True when ``self.app`` is set, otherwise False. :param open_url_delay: open webbrowser after the delay seconds :param live_css: whether to use live css or force reload on css. Defaults to True :param default_filename: launch this file from the selected root on startup z 127.0.0.1NzServing on http://%s:%s)rrrz*Use `open_url_delay` instead of `open_url`cs ttdfdS)Nz http://%s:%s)timesleep webbrowserr2r#ropen_url_delayrr#r$opener[s zServer.serve..opener)target__livereload__cSstjddS)NT)all_fds)rinstancerkr#r#r#r$cszServer.serve..zShutting down...)r_setup_loggingr-inforrr. threadingThreadstartr_changesrcr start_tasksrrrKeyboardInterrupt) rrrrrropen_url restart_delayrrrrr#rr$serve9s,    z Server.servecCs>ttjt}|tt|td|dS)Ntornado) r-setLevelloggingINFO StreamHandler setFormatterr addHandler getLogger)rchannelr#r#r$rhs   zServer._setup_logging)NN)NNN)NNT) rNNNNFrNTr) r[r\r]__doc__rJrrrrrrr#r#r#r$rss   5  /rs)Nr&NF)2rr<rrErrr subprocessrr tornado.wsgirtornado.iolooprtornado.autoreloadrrrrr tornado.logr rr r rrrrsixrrsys version_infomajorrplatformasyncioset_event_loop_policyWindowsSelectorEventLoopPolicyrr-rOrr+OutputTransformrHr_objectrsr#r#r#r$sB             1 ;