B 6d;@sdZddlZddlZddlZddlZddlZddlZddlZddl m Z ddl m Z ddl m Z mZmZmZmZmZddlmZddlmZddlmZdd lmZmZmZdd lmZd d Zd dZ ddZ!ddZ"ddZ#ddZ$ddZ%dBddZ&dCddZ'ddZ(d d!Z)d"d#Z*ej+d$kr.e)Z,ne*Z,d%d&Z-d'd(Z.d)d*Z/d+d,Z0d-d.Z1d/d0Z2d1d2Z3e dDd4d5Z4dEd6d7Z5dFd8d9Z6d:d;Z7dGdd?Z9d@dAZ:dS)HzNotebook related utilitiesN)contextmanager)urljoin) SplitResultquoteunquoteurlparseurlsplit urlunsplit) pathname2url)_NamespacePath)Version)AsyncHTTPClient HTTPClient HTTPRequest)ResolvercGsf|dd}|dd}dd|D}ddd|D}|rJd|}|rV|d}|dkrbd}|S) zJoin components of url into a relative url Use to prevent double slash when joining subpath. This will leave the initial and final / in place r/cSsg|]}|dqS)r)strip).0sra/work/yifan.wang/ringdown/master-ringdown-env/lib/python3.7/site-packages/jupyter_server/utils.py sz!url_path_join..css|]}|r|VqdS)Nr)rrrrr sz url_path_join..z//) startswithendswithjoin)piecesinitialfinalstrippedresultrrr url_path_joinsr"cCst|jdS)z)Determine whether a given URL is absoluter)rpathr)urlrrrurl_is_absolute)sr%cCs6dd|tjD}|ddkr*d|d<t|}|S)z"Convert a local file path to a URLcSsg|] }t|qSr)r)rprrrr0szpath2url..rr)splitossepr")r#rr$rrrpath2url.s  r+cCs$dd|dD}tjj|}|S)z"Convert a URL to a local file pathcSsg|] }t|qSr)r)rr&rrrr:szurl2path..r)r(r)r#r)r$rr#rrrurl2path8s r,cCs|d}ddd|DS)zVEscape special characters in a URL path Turns '/foo bar/' into '/foo%20bar/' rcSsg|] }t|qSr)r)rr&rrrrEszurl_escape..)r(r)r#partsrrr url_escape?s r.cCsddd|dDS)zXUnescape special characters in a URL path Turns '/foo%20bar/' into '/foo bar/' rcSsg|] }t|qSr)r)rr&rrrrMsz url_unescape..)rr()r#rrr url_unescapeHsr/cCs,t|}t|}||ko*||kS)af Fill in for os.path.samefile when it is unavailable (Windows+py2). Do a case-insensitive string comparison in this case plus comparing the full stat result (including times) because Windows + py2 doesn't support the stat fields needed for identifying if it's the same file (st_ino, st_dev). Only to be used if os.path.samefile is not available. Parameters ---------- path : String representing a path to a file other_path : String representing a path to another file Returns ------- same: Boolean that is True if both path and other path are the same )r)statlower)r# other_pathZ path_statZother_path_statrrrsamefile_simplePs  r3r'cCs<|dd}dd|D}tjj|f|}tj|S)zConvert an API path to a filesystem path If given, root will be prepended to the path. root must be a filesystem path already. rcSsg|]}|dkr|qS)r'r)rr&rrrrpszto_os_path..)rr(r)r#rnormpath)r#rootr-rrr to_os_pathisr6cCsN||r|t|d}|tjjtjj}dd|D}d|}|S)zConvert a filesystem path to an API path If given, root will be removed from the path. root must be a filesystem path already. NcSsg|]}|dkr|qS)r'r)rr&rrrr~szto_api_path..r)rlenrr)r#r*r(r)Zos_pathr5r-r#rrr to_api_pathus   r8cCs*yt|t|kStk r$dSXdS)zcheck version string v >= check If dev/prerelease tags result in TypeError for string-number comparison, it is assumed that the dependency is satisfied. Users on dev branches are responsible for keeping their own packages up to date. TN)r TypeError)vcheckrrr check_versionsr<cCsddl}t|jjdd|S)Nr)ctypesboolwindllkernel32Z OpenProcess)pidr>rrr_check_pid_win32srCc Cs^yt|dWnDtk rT}z&|jtjkr2dS|jtjkrBdSWdd}~XYnXdSdS)z'Copy of IPython.utils.process.check_pidrFTN)r)killOSErrorerrnoZESRCHEPERM)rBerrrrr_check_pid_posixs  rIwin32c sVt|rRy|IdH}Wn4tk rL}zt|dkr:|SWdd}~XYnX|S|S)zmConvert a non-awaitable object to a coroutine if needed, and await it if it was not already awaited. Nz&cannot reuse already awaited coroutine)inspect isawaitable RuntimeErrorstr)objr!errr ensure_asyncs  rQcs tsSfdd}|S)aIf async, runs maybe_async and blocks until it has executed, possibly creating an event loop. If not async, just returns maybe_async as it is the result of something that has already executed. Parameters ---------- maybe_async : async or non-async object The object to be executed, if it is async. Returns ------- result Whatever the async object returns, or the object itself. c sd}y t}Wntk r(d}YnX|r6d}|rLt}t|y|}Wn>tk r}z t|dkrt}n|Wdd}~XYnX|S)NFTz"This event loop is already running) asyncioget_event_looprM is_closednew_event_loopset_event_looprun_until_completerN ensure_future)Zcreate_new_event_looploopr!rP) maybe_asyncrrwrappeds"     zrun_sync..wrapped)rKrL)rZr[r)rZrrun_syncs  r\cst|s|S|IdHS)aRuns a function synchronously whether it is an async function or not. If async, runs maybe_async and blocks until it has executed. If not async, just returns maybe_async as it is the result of something that has already executed. Parameters ---------- maybe_async : async or non-async object The object to be executed, if it is async. Returns ------- result Whatever the async object returns, or the object itself. N)rKrL)rZrrrrun_sync_in_loops r]cCs |ddS)zREncodes a UNIX socket path string from a socket path for the `http+unix` URI form.rz%2F)replace) socket_pathrrrurlencode_unix_socket_pathsr`cCs |ddS)zWDecodes a UNIX sock path string from an encoded sock path for the `http+unix` URI form.z%2Fr)r^)r_rrrurldecode_unix_socket_path sracCs dt|S)zJEncodes a UNIX socket URL from a socket path for the `http+unix` URI form.zhttp+unix://%s)r`)r_rrrurlencode_unix_socketsrbcCs\tj|sdSz.UnixSocketResolvera>A resolver that routes HTTP requests to unix sockets in tornado HTTP clients. Due to constraints in Tornados' API, the scheme of the must be `http` (not `http+unix`). Applications should replace the scheme in URLS before making a request to the HTTP client. cSs ||_dS)N)resolver)selfrrrrr initializeDszB_request_for_tornado_client..UnixSocketResolver.initializecSs|jdS)N)rrrh)rsrrrrhGsz=_request_for_tornado_client..UnixSocketResolver.closecstjt|fgS)N)rdrera)rshostportargskwargsrrrresolveJsz?_request_for_tornado_client..UnixSocketResolver.resolveN)__name__ __module__ __qualname____doc__rtrhryrrrrUnixSocketResolver<sr~)rrNzUnknown URL scheme.)methodbodyheaders) rrnrror#rprqrr configure Exceptionr r) urlstringrrrr-r~rrr$requestrrr_request_for_tornado_client%s"     rc Cs.t||||d}tt|}WdQRX|S)zo Send a HTTP, HTTPS, or HTTP+UNIX request to a Tornado Web Server. Returns a tornado HTTPResponse. )rrrN)rrr fetch)rrrrrresponserrrrXs rc s4t||||d}t||IdH}WdQRX|S)z} Send an asynchronous HTTP, HTTPS, or HTTP+UNIX request to a Tornado Web Server. Returns a tornado HTTPResponse. )rrrN)rr r)rrrrZio_looprrrrr async_fetchds rcCs:ytj|}Wntk r$dSX|s.dSt|jtS)zIs the provided namespace a Python Namespace Package (PEP420). https://www.python.org/dev/peps/pep-0420/#specification Returns `None` if module is not importable. N) importlibutil find_spec ValueError isinstancesubmodule_search_locationsr ) namespacespecrrris_namespace_packageps rcCs|dd}tj|r,tj|r,|S|dkr:d}nt|trJ|f}xF|D]>}|dkrdt}ttj ||}tj|rPtj |SqPWt d|d|dS)aFind a file by looking through a sequence of paths. This iterates through a sequence of paths looking for a file and returns the full, absolute path of the first occurence of the file. If no set of path dirs is given, the filename is tested as is, after running through :func:`expandvars` and :func:`expanduser`. Thus a simple call:: filefind('myfile.txt') will find the file in the current working dir, but:: filefind('~/myfile.txt') Will find the file in the users home directory. This function does not automatically try any paths, such as the cwd or the user's home directory. Parameters ---------- filename : str The filename to look for. path_dirs : str, None or sequence of str The sequence of paths to look for the file in. If None, the filename need to be absolute or be in the cwd. If a string, the string is put into a sequence and the searched. If a sequence, walk through each element and join with ``filename``, calling :func:`expandvars` and :func:`expanduser` before testing for existence. Returns ------- Raises :exc:`IOError` or returns absolute path to file. "'N)r'.zFile z, does not exist in any of the search paths: ) rr)r#isabsisfilerrNgetcwd expand_pathrabspathrE)filenameZ path_dirsr#Ztestnamerrrfilefinds   rcCsDtjdkr|dd}tjtj|}tjdkr@|dd}|S)zExpand $VARS and ~names in a string, like a shell :Examples: In [2]: os.environ['FOO']='test' In [3]: expand_path('variable FOO is $FOO') Out[3]: 'variable FOO is test' ntz$\Z IPYTHON_TEMP)r)namer^r# expandvars expanduser)rrrrrs    rcCsr|dd}t|dkrb|\}}t||gd}yt||}Wn tk r\td|YnX|St|dSdS)aImport and return ``bar`` given the string ``foo.bar``. Calling ``bar = import_item("foo.bar")`` is the functional equivalent of executing the code ``from foo import bar``. Parameters ---------- name : string The fully qualified name of the module/package being imported. Returns ------- mod : module object The module that was imported. rr=)fromlistzNo module named %srN)rsplitr7 __import__getattrAttributeError ImportError)rr-packagerOmoduleZpakrrr import_items  r)r')r')rkNN)rkNN)rkNNN)N);r}rRrFimportlib.utilrrKr)rdsys contextlibr urllib.parserrrrrrr urllib.requestr _frozen_importlib_externalr Zpackaging.versionr Ztornado.httpclientr rrZtornado.netutilrr"r%r+r,r.r/r3r6r8r<rCrIplatformZ check_pidrQr\r]r`rarbrjrrrrrrrrrrrsZ           . 2  /