o rN)j7@sddlmZddlZddlZddlZddlmZddlmZddl m Z m Z m Z ddl mZmZmZGdddejZGd d d ZdS) ) annotationsN) TracebackType)Any)LifespanFailureLifespanUnsupportedUnexpectedMessage)ASGI LifespanModeMessagec@s8eZdZdZeZeZeZeZ eZ dS)LifespanCycleStatea The state of the ASGI `lifespan` connection. * **CONNECTING** - Initial state. The ASGI application instance will be run with the connection scope containing the `lifespan` type. * **STARTUP** - The lifespan startup event has been pushed to the queue to be received by the application. * **SHUTDOWN** - The lifespan shutdown event has been pushed to the queue to be received by the application. * **FAILED** - A lifespan failure has been detected, and the connection will be closed with an error. * **UNSUPPORTED** - An application attempted to send a message before receiving the lifespan startup event. If the lifespan argument is "on", then the connection will be closed with an error. N) __name__ __module__ __qualname____doc__enumauto CONNECTINGSTARTUPSHUTDOWNFAILED UNSUPPORTEDrrz/var/www/html/finance.cargoinsureonline.com/_shared/backend-venv/lib/python3.10/site-packages/mangum/protocols/lifespan.pyr s r c@s`eZdZdZd!dd Zd"d d Zd#ddZd"ddZd$ddZd%ddZ d"ddZ d"ddZ d S)& LifespanCyclea Manages the application cycle for an ASGI `lifespan` connection. * **app** - An asynchronous callable that conforms to version 3.0 of the ASGI specification. This will usually be an ASGI framework application instance. * **lifespan** - A string to configure lifespan support. Choices are `auto`, `on`, and `off`. Default is `auto`. * **state** - An enumerated `LifespanCycleState` type that indicates the state of the ASGI connection. * **exception** - An exception raised while handling the ASGI event. This may or may not be raised depending on the state. * **app_queue** - An asyncio queue (FIFO) containing messages to be received by the application. * **startup_event** - An asyncio event object used to control the application startup flow. * **shutdown_event** - An asyncio event object used to control the application shutdown flow. apprlifespanr returnNonecCsX||_||_tj|_d|_t|_t |_ t |_ t |_ td|_i|_dS)Nzmangum.lifespan)rrr rstate exceptionasyncioget_event_looploopQueue app_queueEvent startup_eventshutdown_eventlogging getLoggerloggerlifespan_state)selfrrrrr__init__9s      zLifespanCycle.__init__cCs$|j||j|dS)z,Runs the event loop for application startup.N)r" create_taskrunrun_until_completestartupr,rrr __enter__EszLifespanCycle.__enter__exc_typetype[BaseException] | None exc_valueBaseException | None tracebackTracebackType | NonecCs|j|dS)z-Runs the event loop for application shutdown.N)r"r0shutdown)r,r4r6r8rrr__exit__JszLifespanCycle.__exit__c s,zz|dddd|jd|j|jIdHWn>ty'|jdYn=ttfy=}z ||_ WYd}~n8d}~wt yV}z|jj d|d WYd}~n,d}~wwW|j |j dSW|j |j dSW|j |j dSW|j |j dS|j |j w) z;Calls the application with the `lifespan` connection scope.rz2.0z3.0) spec_versionversion)typeasgirNz-ASGI 'lifespan' protocol appears unsupported.z!Exception in 'lifespan' protocol.)exc_info)rr+receivesendrr*inforrr BaseExceptionerrorr&setr')r,excrrrr/Ss<      zLifespanCycle.runr cs<|jtjur tj|_n |jtjurtj|_|jIdHS)z=Awaited by the application to receive ASGI `lifespan` events.N)rr rrrr$getr2rrrrAes    zLifespanCycle.receivemessagecs"|d}|jd|j||jtjur%|jdkrtdtj|_td|dvr5tj |_t d|d|jtj urb|d krF|j dS|d kr`tj |_|j |d d }td |dS|jtjur|dkrs|j dS|dkrtj |_|j |d d }td|dSdS)z:Awaited by the application to send ASGI `lifespan` events.r>z*%s: '%s' event received from application.onz?Lifespan connection failed during startup and lifespan is 'on'.z&Lifespan protocol appears unsupported.)lifespan.startup.completelifespan.shutdown.completelifespan.startup.failedlifespan.shutdown.failedz Unexpected 'z' event received.rKrMrIzLifespan startup failure. rLrNzLifespan shutdown failure. N)r*rCrr rrrrrrrrr&rFrHrr')r,rI message_type message_valuerrrrBus<        zLifespanCycle.sendcsp|jd|jddiIdH|jIdH|jtjur%t |j |j s0|jddS|jddS)zDPushes the `lifespan` startup event to the queue and handles errors.z Waiting for application startup.r>zlifespan.startupNzApplication startup complete.zApplication startup failed.) r*rCr$putr&waitrr rrrr2rrrr1s   zLifespanCycle.startupcsN|jd|jddiIdH|jIdH|jtjur%t |j dS)zEPushes the `lifespan` shutdown event to the queue and handles errors.z!Waiting for application shutdown.r>zlifespan.shutdownN) r*rCr$rRr'rSrr rrrr2rrrr:s   zLifespanCycle.shutdownN)rrrr rr)rr)r4r5r6r7r8r9rr)rr )rIr rr) r r rrr-r3r;r/rArBr1r:rrrrr%s     ) r) __future__rr rr(typesrtypingrmangum.exceptionsrrr mangum.typesrr r Enumr rrrrrs