o }||k}|std|fd$||ft |t |d%}d&d'|i}t t|d}}}|d?}d;}||k}|std|fd$||ft |t |d%}d&d'|i}t t|d}}}| tv}|sLtd|fd| tfdt vs"t | r't | nddt vs5t tr:t tndd } d!d"| i}t t|d}t| d }d>}||k}|std|fd$||ft |t |d%}d&d'|i}t t|d}}}|jd7| d@d3d}|j}tj}||k}|std|fdA||fdBt vst |rt |ndBt |d t vst trt tnd t |d }d d|i}t t|d}}}dC}|dD}||v}|std|fd,||ft |t |d%}d&d'|i}t t|d}}}WddS1s0wYdS)ENzdemo-.com/api/v1/tenant/registerzLive Chat Demo Storedomainnamejson==)zY%(py2)s {%(py2)s = %(py0)s.status_code } == %(py6)s {%(py6)s = %(py4)s.HTTP_201_CREATED }reg_resprpy0py2py4py6assert %(py8)spy8siteIdOriginhttp:///api/v1/session/init usr_demo_888z Alice Visitorzalice@example.com)idr email)ruserr headers init_resp sessionId /ws/session/inz%(py0)s in %(py2)s session_idrrrassert %(py4)srRINGINGz%(py1)s == %(py4)spy1rassert %(py6)srrr rcountryz%(py1)s in %(py4)s/api/v1/handoff/acceptzT%(py2)s {%(py2)s = %(py0)s.status_code } == %(py6)s {%(py6)s = %(py4)s.HTTP_200_OK } accept_respIN_CHATz/api/v1/messagez"Hello Agent! Need help with order.r!messagemsg_respzdelivered to agentreply/api/v1/handoff/messagezHi Alice! I am here to help.agent_reply_resp/api/v1/handoff/endvisitorr!endedByend_respENDEDr=Attempt reply after chat endedz]%(py2)s {%(py2)s = %(py0)s.status_code } == %(py6)s {%(py6)s = %(py4)s.HTTP_400_BAD_REQUEST }rejected_reply ended sessiondetail)uuiduuid4hexpost status_coderHTTP_201_CREATED @pytest_ar_call_reprcompare @py_builtinslocals_should_repr_global_name _safereprAssertionError_format_explanationr websocket_connectr HTTP_200_OKHTTP_400_BAD_REQUEST)clientrr @py_assert1 @py_assert5 @py_assert3 @py_format7 @py_format9site_idrr r&ws @py_format3 @py_format5 @py_assert0 @py_assert2r2r6r9r>rBrb5/web/html/dev/chatbot/backend/tests/test_demo_flow.py&test_active_sessions_snapshot_and_flowsl   pttlpp p pppp r$rdcsdtjddd}|jd|ddd}|d}d |d d }|jd d|i|d }|d|d*}tv}|std|fdtfdt vsZt r_t nddt vskt trpt tndd}dd|i} t t| d}td} d} | | u} | std| fd| | ft | t | d} dd| i} t t| d} } } td} d } | | k} | std| fd| | ft | t | d} dd| i} t t| d} } } td } d!} | | k} | s$td| fd| | ft | t | d} dd| i} t t| d} } } |d"}|j}tj}||k} | std| fd#||fd$t vsSt |rXt |nd$t |d t vsjt trot tnd t |d%} d&d'| i}t t|d}} }fd(d)|D}t|} d*}| |k}|std|fd+| |fd,t vst trt tnd,d-t vst |rt |nd-t | t |d.} d&d'| i}t t|d} }}|d/d} d } | | k} | s$td| fd| | ft | t | d} dd| i} t t| d} } } d0} |d/} | | v} | sZtd| fd1| | ft | t | d} dd| i} t t| d} } } WddS1slwYdS)2Nzanon-rrrz Anon Storerr rrz 203.0.113.195)rzX-Forwarded-Forrrr!r"r#r%r&rr'r(rr)is)z%(py1)s is %(py4)sr+r-r ipAddressr r*rr)z/api/v1/admin/active-sessionsr1 res_adminrrrcsg|] }|dkr|qS)r!rb).0sr&rbrc bsz1test_anonymous_active_session..)z0%(py3)s {%(py3)s = %(py0)s(%(py1)s) } == %(py6)slenmatching)rr,py3rrr.r/)rErFrGrHr rSrrKrLrMrNrOrPrQrRgetrIrrTrm)rVrrr\rr r]rWr^r_r`rYrarZrgrXr[rn @py_assert4rbrjrctest_anonymous_active_sessionMs*  nnp pn$rrcCsdtjddd}|jd|ddd}|d}d d |i}|jd d|i|d }|d }|d|}|jdd |id}|j} tj} | | k} | st d| fd| | fdt vsht |rmt |ndt | dt vs}t trt tndt | d} dd| i} tt | d} } } t|d}d} || k}|st d|fd|| ft |t | d}dd|i} tt | d}}} |}|d}d} || k}|s t d|fd|| ft |t | d}dd|i} tt | d}}} |d}d} || k}|s?t d|fd|| ft |t | d}dd|i} tt | d}}} |jd|dd d}|j} tj} | | k} | st d| fd| | fd!t vsst |rxt |nd!t | dt vst trt tndt | d} dd| i} tt | d} } } |d}d"} || k}|st d|fd|| ft |t | d}dd|i} tt | d}}} |d#}d} || k}|st d|fd|| ft |t | d}dd|i} tt | d}}} |tv} | sct d$| fd%|tfd&t vs9t |r>t |nd&d't vsLt trQt tnd'd(}d)d*|i}tt |d} t|d}d"} || k}|st d|fd|| ft |t | d}dd|i} tt | d}}} |}|d}d} || k}|st d|fd|| ft |t | d}dd|i} tt | d}}} |d}d"} || k}|st d|fd|| ft |t | d}dd|i} tt | d}}} |d#}d} || k}|s=t d|fd|| ft |t | d}dd|i} tt | d}}} |jd+|d,d-d}|j} tj} | | k} | st d| fd.| | fd/t vsqt |rvt |nd/t | dt vst trt tndt | d} dd| i} tt | d} } } d0}|d1} || v}|st d$|fd2|| ft |t | d}dd|i} tt | d}}} WddS1swYdS)3Nz agentend-rrrzAgent End Test Storerr rrrrrr!r"r0r r1r2rrrrr3r*r+r-rtypestatus_changedr:agentr<r>r?r=r#r%r&rr'r(rr8r@r4rArBrCrDr/)rErFrGrHr rSrIrrTrKrLrMrNrOrPrQrRr receive_jsonrU)rVrrr\rr r&r]r2rWrXrYrZr[r`rar_accepted_eventr>r^ ended_eventrBrbrbrctest_agent_ends_chat_flowgsB  nllppplll r$ry)builtinsrM_pytest.assertion.rewrite assertionrewriterKrEfastapirapp.services.presencerrdrrryrbrbrbrcs "  H