U a64@sddlZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlmZmZmZmZmZmZmZmZddlZddlZddlZddlZddlmZddlm Z ddl!m"Z"ddl#m$Z$d d l%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;mZ>m?Z?m@Z@mAZAmBZBmCZCmDZDmEZEmFZFmBZBmCZCdd lGmHZHmIZIejJd d d d GdddZKejJd d d d GdddZLejJd d d d GdddZMejJd d d d GdddZNejJd d d d GdddZOeeLeMeNfZPddZQddZRddZSddZTd d!ZUd"d#ZVGd$d%d%ZWGd&d'd'e$ZXeedd(d)d*ZYdS)+N) TYPE_CHECKINGTypeUnionMappingIOAnyAnyStrOptional)__jsii_runtime_version__)importlib_resources)memoized_property) BaseProvider)#ObjRefEnumRefOverride KernelRequestKernelResponse LoadRequest LoadResponse CreateRequestCreateResponse DeleteRequestDeleteResponse GetRequest GetResponse InvokeRequestInvokeResponseInvokeScriptRequestInvokeScriptResponse SetRequest SetResponseStaticGetRequestStaticInvokeRequestStaticSetRequest BeginRequest BeginResponse EndRequest EndResponseCallbacksRequestCallbacksResponseCompleteRequestCompleteResponse StatsRequest StatsResponseCallbackr-r.) JSIIErrorJavaScriptErrorT)Z auto_attribsfrozenslotsc@seZdZUeed<dS)_HelloResponsehelloN__name__ __module__ __qualname__str__annotations__r>r>/Users/jalaguru/Documents/Proserv/artifacts/aws_dms_cdk_automation/aws-dms-cdk-automation/venv/lib/python3.8/site-packages/jsii/_kernel/providers/process.pyr6Ds r6c@seZdZUeed<dS) _OkayResponseokN)r9r:r;rr=r>r>r>r?r@Js r@c@seZdZUeed<eed<dS) _ErrorResposeerrorstackNr8r>r>r>r?rBUs rBc@seZdZUeed<dS)_CallbackResponsecallbackN)r9r:r;r1r=r>r>r>r?rE\s rEc@seZdZUeed<dS)_CompleteRequestcompleteN)r9r:r;r-r=r>r>r>r?rGbs rGcsfdd}|S)Ncs|}|d<|S)Napir>)valueZ unstructuredapi_nameasdictr>r? unstructurerlsz#_with_api_key..unstructurerr>)rLrMrNr>rKr? _with_api_keyksrOcCst||s||jdS|S)Nref) isinstancerQ)datatype_r>r>r?_with_referenceus  rUcCs d|jiS)N $jsii.byrefrP)rJr>r>r?_unstructure_ref{srWcCsd|jjd|jiS)N $jsii.enum/) __class__Z __jsii_type__rJ)memberr>r>r?_unstructure_enumsr\cCs|dhks|ddhkr4t|d|ddS|dhkrRtj|dS|dhkr|ddd\}}tt|dd |d S|d hkr|d S|S) NrVz$jsii.interfaces)rQZ interfaces $jsii.daterXrYr@rP)rQr[z $jsii.map)keysrgetdateutilparserZisoparsersplitr)drQr[r>r>r?ohooksrecCsZt|drt|jSt|tjr6|jdk r6d|iSt|tjrJtdtd|dS)N __jsii_ref__r]z8Naive datetimes are not supported, please add a timzone.z,Don't know how to convert object to JSON: %r)hasattrrWrfrRdatetimetzinfo isoformat TypeError)objr>r>r?jdefaults    rmc@sneZdZddZddZedddZeeefddd Z d d Z d d Z ddZ e eeedddZdS) _NodeProcesscCst|_|jtjt|jttd|jj |jt td|jj |jt td|jj |jt td|jj |jt td|jj |jttd|jj |jttd|jj |jttd|jj |jttd |jj |jttd |jj |jttd |jj |jttd |jj |jttd |jj |jttd|jj |jttd|jj |jt|jj |jtt|jttt|_dS)NloadinvokeBinScriptcreatedelr`sgetsetssetinvokesinvokebeginend callbacksrHstats) cattrZ Converter _serializerZregister_unstructure_hookenumEnumr\rrOZunstructure_attrs_asdictr rrrr$r"r&rr%r'r)r+r-r/rrrWZregister_structure_hookrU contextlib ExitStack _ctx_stackselfr>r>r?__init__s                z_NodeProcess.__init__cCs |dSN)stoprr>r>r?__del__sz_NodeProcess.__del__returnc s|jtfddtjjjD}|D]N\}}t t j |j ddt|d}|ttjj|W5QRXq4|tjjjS)Nc s*i|]"\}}|tj|dtjqS)rY)ospathjoinreplacesep).0resnamefilenameZtmpdirr>r? sz._NodeProcess._jsii_runtime..T)exist_okwb)r enter_contexttempfileTemporaryDirectoryjsiiZ _embeddedZEMBEDDED_FILESitemspathlibPathrrdirnamemkdiropenwriter read_binaryZ ENTRYPOINT)r resourcesrrfpr>rr? _jsii_runtimes   "z_NodeProcess._jsii_runtimecCstj|jjtdS)N) object_hook)jsonloads_processstdoutreadlinererr>r>r? _next_messagesz_NodeProcess._next_messagecCstj}dt|d<|d|}tjdd|gtj tj tj |d|_ t j dt |j jfdd |_|jt|j|dS) NzPython/Z JSII_AGENTZ JSII_RUNTIMEnodez--max-old-space-size=4069)stdinrstderrenvzprocess.stderr_sinkT)nametargetargsdaemon)renvironcopyplatformpython_versionr`r subprocessPopenPIPEr threadingThread stderr_sinkr sink_threadstartatexitregisterr handshake)rrZ jsii_runtimer>r>r?rs,    z_NodeProcess.startcCst|j|jjjs0|jjd|jjz|jjddWn t j k rb|j YnX|j r||j jdd|jdS)Ns {"exit":0} )timeout)r unregisterrrrclosedrclosewaitrTimeoutExpired terminateris_aliverrrr>r>r?rs    z_NodeProcess.stopcCs6|j|t}|jdtks2td|jdS)Nz@jsii/runtime@zInvalid JSII Runtime Version: )r} structurerr6r7r AssertionError)rrespr>r>r?r(s z_NodeProcess.handshakerequest response_typercCs|j|}tj|tdd}|jjd|f|jj |j | t }t |trl|j |j|St |tr||jSt|jt|jdS)N)defaultutf8s%b )r}Z unstructurerdumpsrmencoderrrflushrr_ProcessResponserRr@rArErFr2rCr3rD)rrrZreq_dictrSrr>r>r?send3s    z_NodeProcess.sendN)r9r:r;rrr<rrrrrrrrrrrr>r>r>r?rnsD! rnc@s:eZdZeedddZeedddZe e dddZ e e dd d Zeedd d Zeedd dZeedddZeedddZeeeefdddZeedddZe e!dddZ"e#e$dddZ%e&e'dddZ(e)e*dddZ+e,e-ddd Z.e,e/e0eeefd!d"d#Z1d'e2e3e4dd%d&Z5d$S)(ProcessProviderrcCst}||Sr)rnr)rprocessr>r>r?rJszProcessProvider._process)rrcCs|j|tSr)rrrrrr>r>r?roQszProcessProvider.loadcCs|j|tSr)rrr!rr>r>r?rpTszProcessProvider.invokeBinScriptcCs|j|tSr)rrrrr>r>r?rqWszProcessProvider.createcCs|j|tSrrrrrr>r>r?r`ZszProcessProvider.getcCs|j|tSrrrr#rr>r>r?rt]szProcessProvider.setcCs|j|tSrrrr>r>r?rs`szProcessProvider.sgetcCs|j|tSrrrr>r>r?rucszProcessProvider.ssetcCs|j|tSrrrrrr>r>r?rvfszProcessProvider.invokecCs|j|tSrrrr>r>r?rwiszProcessProvider.sinvokecCs|j|tSr)rrrrr>r>r?deletelszProcessProvider.deletecCs|j|tSr)rrr(rr>r>r?rxoszProcessProvider.begincCs|j|tSr)rrr*rr>r>r?ryrszProcessProvider.endcCs|j|tSr)rrr,rr>r>r?rzuszProcessProvider.callbackscCs|j|tSr)rrr.rr>r>r?rHxszProcessProvider.completercCs|jt|d|}|S)N)rH)rrrG)rrrrr>r>r? sync_complete{szProcessProvider.sync_completeNcCs|dkrt}|j|tSr)r/rrr0rr>r>r?r{szProcessProvider.stats)N)6r9r:r;r rnrrrror r!rprrrqrrr`r"r#rtr$rsr&rurrrr1rvr%rwrrrr'r(rxr)r*ryr+r,rzr-r.rHrrrr r/r0r{r>r>r>r?rIs* r)readerrcCst|jdD]}|dkrqzZt|}|ddk rNtjjt |d|ddk rttj jt |dWq t |tjdYq Xq dS)Nrr)file) iterrrrr`sysrbufferrbase64 b64decoderprint)rlineconsoler>r>r?rs r)Zrrrhrr~rros.pathrrrrrrtypingrrrrrrrr attrr|Zdateutil.parserraZjsii._embedded.jsiirZ__meta__r Z_compatr _utilsr basertypesrrrrrrrrrrrrrrrr r!r"r#r$r%r&r'r(r)r*r+r,r-r.r/r0r1errorsr2r3sr6r@rBrErGrrOrUrWr\rermrnrrr>r>r>r?sZ(    %    0>