i_* SSKJr SSKrSSKrSSKJr SSKJr SSKJrJ r J r J r J r SSK JrJrJrJrJrJr SSKJrJr SSKJr SS KJr SS KJr SS KJr SS KJ r J!r! SS K"J#r$ SSK%J&r&J'r( SSK)J*r* \"SS/S9r+\\\"\54r,\"SS9r-Sq.S/S.S/SQS.S/SQS.S/SQS.S/SQS.S/S QS.S!/S"QS.S#/S$QS.S%/S&QS.S'. r/"S(S)\5r0"S*S+\5r1\+ReS,5SIS-j5r3\+ReS.5SJS/j5r4\+RkS05S15r6\+RkS25\"S3S4S5S69\"S7S8S99\"S7S:S99\"S7S;S994SKS<jj5r7"S=S>\5r8"S?S@\5r9SLSMSAjjr:\+ReSB\"\:5/SC9SNSDj5r;\+ReSE5SOSFj5r<\+ReSG\"\:5/SC9SPSHj5r=g)Q) annotationsN)deque)datetime) AnnotatedAnyDictListOptional) APIRouterDependsHeader HTTPExceptionQuerystatus) BaseModelField)select) AsyncSession)settings) get_session)Poll PollStatus)ws) hihaho_clientvoting)parse_branchesz/hihahohihaho)prefixtags)maxlenz3The hihaho interactive layer / API has been loaded.) descriptionfieldsz!The viewer has started the video.)actorpercentageToSucceed session_idvideo_id video_uuidz,The viewer has reached the end of the video.) r$historyscoremaxScore scaledResultr%passedr&r'r(z#The viewer has answered a question.) r$correcttype answerText startTimeendTimepointsr)r&r'r(z.The viewer has submitted an optional variable.)namevaluer&r'r(z)The viewer has clicked on an interaction.)interaction_namer5actionr&r(z&The viewer has clicked on a menu item.)titler7r&r'r(z)The viewer has clicked on a chapter item.)r8 start_timer&r(zDPlayback heartbeat called roughly every 100ms while the video plays.) currentTimevolumeduration) inithihaho_started hihaho_ended hihaho_answer"hihaho_optional_variable_submittedhihaho_interaction_clickedhihaho_menu_item_clickedhihaho_chapter_item_clickedonTimec<\rSrSr%SrS\S'S\S'SrS\S'S rg) BranchNotifyBodyYstrfilm_session_id branch_keyNOptional[Dict[str, Any]]metadata)__name__ __module__ __qualname____firstlineno__rK__annotations__rN__static_attributes__rOHC:\Users\jasmi\Projects\line-hihaho-voting\backend\app\routers\hihaho.pyrGrGYsOSO)-H&-rVrGc\rSrSr%SrS\S'SrS\S'SrS\S'SrS\S'Sr S\S'Sr S\S 'S r S \S 'Sr S\S 'Sr S\S'SrS\S'Srg)DebugEventBody_rIrJroom_idpoll_idfilm_urlevent_idorigin event_typeFboolsource_is_iframereceived_at_clientNrrawrMrNrO)rPrQrRrSr[rTr\r]r^r_r`rbrcrdrNrUrOrVrWrYrY_shGSGSHcHcFCJ"d"  CO)-H&-rVrYz/branchc# [R"UR=(d SURURS9IShvN $N7f)zJProxy to hihaho when API is configured; otherwise returns skipped payload.zdefault-session)rKrLrNN)rnotify_branch_resultrKrLrN)bodys rW notify_branchrhlsA33,,A0A??  sAA AA z /events/debugc# [S- qUR5n[US'[R"5R 5S-US'[ R U5 SS[[ 5URS.$7f)N server_seqZreceived_at_serverT)okstoredcountlatest_event_id) _DEBUG_SEQ model_dumprutcnow isoformat _DEBUG_EVENTSappendlenr^)rgpayloads rWingest_debug_eventrzvss!OJooG&GL$,OO$5$?$?$AC$GG !!]#==  sA?Bz /events/specc# S[S.$7f)NT)rnitems)HIHAHO_EVENT_SPECSrOrVrWhihaho_event_specsr~s# s z/events/debug/latestrjd)gelerIzfilter by room id)r"zfilter by poll idzsubstring matchc # [[5nU(a2UVs/sH&n[URSS55U:XdM$UPM( nnU(a2UVs/sH&n[URSS55U:XdM$UPM( nnU(aOUR 5nUVs/sH3oV[URSS55R 5;dM1UPM5 nnX@*SnS[ U5US.$s snfs snfs snf7f)Nr[rIr\r`T)rnrpr|)listrvrJgetlowerrx)limitr[r\r`rowsrneedles rWlatest_debug_eventsrs  DH4a3quuY';#<#G4HH4a3quuY';#<#G4H!!#R4aS|R1H-I-O-O-Q#Q4R =DT IHSs:C="C.C. C="C3<C3C=/C8C8%C=c:\rSrSr%SrS\S'\"SS9rS\S'S rg ) BranchOptionNamesrIrJr8) min_length List[str] option_namesrON) rPrQrRrSr8rTrrrUrOrVrWrrsE3O#q1L)1rVrcP\rSrSr%S\S'\"\S9rS\S'\"SSS 9rS \S 'S r g )InteractionSetupBodyzDict[str, Any] interactions)default_factoryzList[BranchOptionNames]branchesc SS/$)Nu選項Au選項BrOrOrVrWInteractionSetupBody.s I 6rVzKFallback option names when branches list is shorter than detected branches.)rr"rdefault_option_namesrON) rPrQrRrSrTrrrrrUrOrVrWrrs0  (-d(CH%C&+6a')rVrc# [R(dgU[R:wa[[RSS9eg7f)Nzinvalid host key) status_codedetail)r host_api_keyrrHTTP_403_FORBIDDEN) x_host_keys rW_require_host_keyrs:  X***(A(AJ\]]+sAAz/rooms/{room_id}/reset) dependenciesc# SSKJn SSKJn UR [ [ 5R[ RU:H55IShvN R5nU(aUVs/sHoURPM nnUR U"U5RURRU555IShvN UHnURU5IShvN M UR5IShvN [R"U5IShvN S[!U5S.$Ns snfNqNUN;N7f)zADelete all polls/votes for a room and broadcast a clean snapshot.rdeleteVoteNT)rn deleted_polls) sqlalchemyrapp.models.entitiesrexecrrwherer[allidr\in_commit ws_routerbroadcast_room_snapshotrx)r[session sa_deleterexistingppoll_idss rW reset_roomrs /(llt 4<<723 su "*+(QDD(+ll9T?001A1A(1KLMMMA..# # #nn  + +G 444X 77,M #4sgAED1E.D3AED8E$D:%ED<ED>E3E:E<E>Ez/interactions/parsec# URRS/5n[U[5(d [ SS5e[ U5nS[ U5US.$7f)zHParse interaction JSON and return detected branch schedules (read-only).r*interactions.interactions must be an arrayT)rn branch_countr)rr isinstancerrrrx)rgraw_interactionsrs rWparse_interaction_jsonrsX((,,^R@ & - -C!MNN./HH 8 LLsAAz(/rooms/{room_id}/setup-from-interactionsc# SSKJn SSKJn SSKJnJn URRS/5n[U[5(d [SS5e[U5nU(d [SS5eU"X U5IS hvN UR[[5R![R"U:H55IS hvN R%5n U (aU V s/sHoR&PM n n URU"U5R!UR(R+U 555IS hvN U Hn URU 5IS hvN M UR-5IS hvN /n [/U5GHupU [1UR25:aUR2U OS nU(a1[1UR45[1US 5:a UR4O UR6nU(aUR8(a UR8OS U S -3n0n[/US 5H*unnU[1U5:a OUUnS SUSS.S.UU'M, [[;[<R>"55UU[@RB"US [1US 5SS9[DRFS9nU"US/SUS3/S SS0S.U[IUS5USUSUSUS S. 5 URKU5 U RMU5 GM URO5IS hvN U Hn URQU 5IS hvN M [RRT"U5IS hvN SSK+J,n SU[1U5UU V s/sH n U"U 5PM sn S .$GN#GNs sn fGNrGNWGN>NNiNIs sn f7f)!zParse interaction JSON, create a room and one draft poll per branch. Each poll is pre-configured with the correct trigger time, voting duration, pause action, and winner jump actions derived from the JSON hotspots. rrr) ensure_roomset_poll_configrrrz6No branch decision points detected in interaction JSONNoptionsu 劇情選擇 rj postmessagejumpposition)commandr)r/ryF) ensure_ascii)rr[r8 options_jsonrrEz currentTime>=r9rpauseduration_secondsend_timedefault_jump_time) trigger_names trigger_keys pause_actionwinner_actionsrbranch_start_timebranch_end_timebranch_default_jumpbranch_options)poll_outT)rnr[rrpolls)-rrrrapp.services.votingrrrrrrrrrrrrr[rrr\rflush enumeraterxrrrr8rJuuiduuid4jsondumpsrdraftintaddrwrrefreshrrapp.routers.pollsr)r[rgrrrrrrrrrr created_pollsidxbranch branch_cfgrr8rjopt_infor4pollrs rWsetup_from_interactionsrs/(@((,,^R@ & - -C!MNN./H C!YZZ g 000llt 4<<723 su "*+(QDD(+ll9T?001A1A(1KLMMMA..# # #mmoM * +.T]]1C+CT]]3' c*"9"9:c&BS>TT  # #** j..    q *  *,$VI%67KAxC %%?D%% ( 4$N4 84::< 5s6)#456U##  &Z,VL-A,BCD%%w/- #F+=$> ?!' !5%j1#)*=#>$Y/    DT"e+h ..  ooa     + +G 444*H '45}!(1+}5  S1,M #n 46sAN!?AON$O"N'6AO:N,;ON/O4N25F:O/N50O N7!O/N90O N; O$O'O/O2O5O7O9O;O)rgrG)rgrY)rrr[rJr\rJr`rJ)N)rz4Annotated[Optional[str], Header(alias='X-Host-Key')])r[rJr SessionDep)rgr)r[rJrgrrr)> __future__rrr collectionsrrtypingrrrr r fastapir r r rrrpydanticrrsqlmodelrsqlmodel.ext.asyncio.sessionr app.configrapp.dbrrrr app.routersrr app.servicesrr voting_svc!app.services.interaction_schedulerrouterrrvrrr}rGrYpostrhrzrr~rrrrrrrrOrVrWrs" 77LL%50'<< )8* 5 |W[%99 : S!  M  ;Z F   =  "HK+ CU# @M! CE$ ^7q<~.y. .Y .Y_  N "#raC()<=)<=B,=>    $42 2 9HL^D^+,- 8 8$ "#M$M.+,- e e ee erV