+Pkj UddlZddlZddlZddlZddlZddlZddlmZmZm Z m Z m Z m Z m Z mZmZddlmZddlmZddlmZddlmZddlmZmZmZddlmZmZmZm Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6eeeg Z7eZ8iZ9d Z:iZ;ed <iZ?ed <iZ@ed <dZAiZBed<dZCdeDde fdZEdede=fdZFddZGde=de2ddfdZHdeZ\e7jd?de)fd@Z]e7jdAdefdBZ^e7jdCdDZ_e7jdEdefdFZ`e7jdGdHZae7jdIde fdJZbe7jdKde!fdLZce7jdMdNZde7jdMde"fdOZee7jdPde#fdQZfe7jdRdSZge7jdRdTZhe7jdUde&fdVZie7jdWde'fdXZje7jdYdZZke7jd[d\Zle7jd]d^Zme7jd_d`Zndae=fdbZoe7jdce de ddfdee dfepdzdge fdhZqe7jdidjZre7jdkde$fdlZse7jdmdnZte7jdodpZue7jdqdrZve7jdsdtZwe7jdude%fdvZxe7jdwdxZye7jdydd#e=dzfdzZze7jd{dd#e=dzd$eNfd|Z{e7jd} dd#e=dzd~e=d$eNfdZ|e7jd dd#e=dzd~e=dae=d$eNfdZ}e7jdejeefde2dee defdZe7jdeefde3defdZe7jdeefde4defdZe7jddeefde=dedefdZe7jdde*fdZe7jddZe7jdde+fdZe7jdde,fdZe7jdde+fdZe7jdde-fdZe7jddZe7jdde.fdZe7jdde/fdZe7jdde+fdZe7jdde1fdZe7jdde0fdZe7jddZe7jdde=fdZe7jdde+fdZe8jddde=dede=fdZe8jddde=dede=fdZe8jdddepde=dee fdZe8jd dde=dede=deNfdZy)N) APIRouterDepends HTTPException UploadFileFileFormBackgroundTasksRequeststatus)browser_manager)run_task) session_store)HudlForbiddenError) AuthContext require_authresolve_auth_from_token)ExchangeSearchSchemaExchangeTypeSchema LoginSchemaVideoSelectSchemaPlaylistSelectSchema StatsSchema NotesSchemaDeleteFileSchemaVideoDetailsSchema CancelSchema BackSchemaActiveExchangeDetailsSchemaActiveExchangeActionSchemaVideoStreamSchemaLibraryActionBaseSchemaLibraryUpdateTypeSchemaLibraryUpdateEventSchemaLibraryRenameSchemaLibraryEmailDownloadSchemaLibraryDownloadToMediaSchemaLibraryDownloadByRefSchemaManageLibraryDownloadSchemaManageLibrarySelectSchemaManageLibraryClipMetaSchemaSwitchHudlTeamSchemaOpenExchangeSchema) dependenciesMANAGE_LIBRARY_CACHEMANAGE_LIBRARY_SEASON_CACHEMANAGE_LIBRARY_FOLDER_CACHEiMANAGE_LIBRARY_DOWNLOAD_JOBSiQexcreturnct|tr|St|trtd|jStdt |S)uEMap automation errors to HTTP — preserve Hudl 403 permission pages.i status_codedetail) isinstancerras_dictstrr3s =/var/www/html/sergio/sergio-backend/app/routes/hudl_routes.py_hudl_http_errorr?As@#}% #)*S[[]CC SS ::authc|jd|jjS|jd|jjStdd)Nzuser:zaccount:zAuthentication required)useridaccountr)rAs r>_download_job_ownerrGJsO yytyy||n%% ||$,,//*++ 6 77r@ctjtz }tjDcgc]\}}|d|kr|}}}|D]}tj |dycc}}w)N created_at)timeMANAGE_LIBRARY_DOWNLOAD_JOB_TTLr2itemspop)cutoffjob_idjob expired_idss r>_prune_download_jobsrRRsp YY[: :F8==??KFC | v % ? $((6 sA(rObodyc bKtj|}|sy|jdd td|j|j |j Dcgc]}|jc}|j|jd{}|jd|jdd|tj ycc}w7A#t$rN}td |d ||jd t|xsd tjYd}~yd}~wwxYww)N processingz2Selecting items and starting the download on Hudl.r messagedownload_manage_library_items)team_id season_labelrLdownload_formatinclude_breakdown completedrWz _run_manage_library_download_jobri]s & * *6 2C JJl,`Ja  +LL15<4??$< KK"44    JJN  =  "   :6(#cUKL HG G    sM,D/*CC0!CC;C D/C D,AD'"D/'D,,D/cachekeyc|j|}|syddl}|j|dz tkDr|j|dy|dS)Nr timestampdata)rarJMANAGE_LIBRARY_CACHE_TTLrM)rjrkentryrJs r> _cache_getrq~sN IIcNE tyy{U;''*BB #t =r@rnc:ddl}|j|d||<y)Nr)rmrn)rJ)rjrkrnrJs r> _cache_setrss(tyy{D9E#Jr@cKddlm}m}m}d}t j |4d{t j |d t j|d{}||d{rL||d{s< t j |dt jdddd{y||d{rtd||d{t j |dt jdddd{y77777s7d7K#t j |dt jwxYw7B#1d{7swYyxYww) uStart the Manage Library lane. Login only if Hudl shows the identity form. Blank lane tabs share cookies with the rest of the browser context, so we do NOT treat about:blank as logged-out — that forced a full re-login on every download after a lane tab was created. r)is_hudl_logged_in is_login_pagerunmanage_libraryNT)laneFu1Manage Library: session expired — logging in...) app.automation.tasks.loginrurvrwr lane_lock set_lane_busystartrecord_activityrg)rurv login_runrypages r>_ensure_hudl_browser_readyrs,^] D((..%%dD1 .(..D99D&t,,,=;N5N5N  ) )$ 6  + + -/..#4(((IJo%%  ) )$ 6  + + -/..:,5N /)%  ) )$ 6  + + -/...s&E8D$E8E#D2D&D2-D(.D2=D*>D2*E#- E88D,9E8> D2 D. D2$D0%D2)*E# E8E!E8&D2(D2*D2,E8.D20D22,EE#!E8#E5)E, *E51E8z/statusc Ktj}tj}tj}tj |j dd|r|js |jnd|j d|tjdtjdtjdddSw) N logged_inFlast_urldefaultexchangerx)rrrx)browser_runningr current_urlrstorage_warning lanes_busy) rreadr rget_storage_warning_cached is_runningra is_closedurl is_lane_busy)staterrs r> hudl_statusrs    E   D#>>@O*55YY{E2#'0@txxdIIj)*&33I>'44Z@-::;KL  sC C z/storagerYrefreshcKt|xsdjxsd}|r|jsd}|stj|}|rd|dS ddlm}ddlm}tjd{}tjs||d{|||d{}tj||d|dS7V747$#t$r}d t|d d id cYd}~Sd}~wwxYww) uNReturn Hudl storage usage for the sidebar — team-scoped when team_id is set.NrYok)r rrrw)fetch_hudl_storage_usageerror availableF)r rWr)r<stripisdigitrrrzrwapp.automation.tasks.libraryrr r}is_marked_logged_inset_storage_warningrf)rYrtidrrrrr3s r>get_hudl_storagers gm  " " $ ,C 3;;= 'BB3O "G G ?I$**,,002D/ ! ! 8s KK))/3G?CC - !K  3x +U3   slAC?#C;C<#CC C1C2CC?CCC C<!C71C<2C?7C<<C?z/browser/startcK tjd{}d|jdS7#t$r}t ||d}~wwxYww)Nr)r r)r r}rrfr?)rr3s r> start_browserrsL-$**,,txx00- -s#,-s0A1/1A1 A  AA  Az/browser/clear-sessioncKd}d}td|dzD]W} tjd{tjd{}ddlm}||d{dddcStd d |d|7P767"#t $rn}|}td |d | tjd{7n#t $rYnwxYw||krddl }|jd d{7Yd}~d}~wwxYww)zdClear the persistent browser session data completely and force a fresh login with automatic retries.Nrrrz2Browser session cleared and fresh login completed.rVzClear session attempt z failed: r9zFailed to reset session after z attempts. Error: ) ranger clear_sessionr}rzrwrfrgcloseasynciosleepr) max_retrieslast_excattemptrrr3rs r>clear_browser_sessionrs KHK!O, '!//1 1 1(..00D CD/ ! !"/cd d -$ =k]J\]e\fg hh! 20 ! 'H *7)9SEB C %++---  $mmA&&& 'sDBBB BB#B$B,DBBB C?C:%C<B?=CC: C C:C C:/C20C:5D:C??Dz/logoutcK tjd{tj}d|d<tj|dddS77#t $r}t ||d}~wwxYww)z hudl_logoutrsr-##%%%""$"kE"+QRR & -s#,-s8A2AA6AA2A A/ A**A//A2z /account-namecKtj}|sE ddlm}m}t j d{}||d{||d{}d|dS7)77 #t$rd}YwxYww)zKReturns the cached Hudl account holder's name or fetches it if not present.r)fetch_hudl_account_namerwNrr)r name)rget_account_holder_namerzrrwr r}rf)rrrrs r>get_hudl_account_namer sy  0 0 2D   \(..00DD/ ! !066DD )) 1 !6 D s\A:A)A#A) A% A)A'A)A:#A)%A)'A)) A74A:6A77A:z/logincKddlm} td|jd{S7#t|f$r}t dt ||d}~wt$r}t||d}~wwxYww)zMHudl website login (JWT already checked). App login = POST /api/v1/auth/loginr)LoginVerificationErrorlogin)forceN) rzrr r ValueErrorrr<rfr?)rSrr3s r>hudl_site_loginrsfB-gTZZ8888 . /4CS*3 -s#,-s<A,+)+A,+ A)A  A) A$$A))A,z/organizationscpK tdd{S7#t$r}t||d}~wwxYww)zPList every school/team from the Hudl team switcher (full Organizations sidebar).list_hudl_organizationsNr rfr?r=s r>list_hudl_organizations_apir)s9-78888 -s#,-(66 3 .36z /team/switchcK tjtd|j|j|j d{}t |jdxsdj}|jr|jdd|S7T#t$r}tdt ||d}~wt$r}t||d}~wwxYww) uClick a Hudl team by id/name and return its team_id. Intentionally does NOT open Exchange here — that was blocking the switch modal for 30–90s. The Exchange page warms itself after navigation. switch_hudl_team_by_name) team_nameorg_namerYNrYr has_exchangeTr)rclear_storage_warningr rrrYr<rarr setdefaultrrrfr?)rSr^rYr3s r>switch_hudl_teamr2s-++- &nn]]LL   fjj+1r288: ??    nd 3   4CS*3 -s#,-sHCABB ABCB C(B>> C CCCz/exchange/opencK |r |jnd}td|d{S7#t$r}t||d}~wwxYww)N open_exchanger)rYr rfr?)rSrYr3s r>rrMsG-"&$,,Dow???? -s#,-s0A +)+A+ A AAAz/exchange/datactK td|d{S7#t$r}t||d}~wwxYww)Nget_exchange_datarrrYr3s r>rrVs;-17CCCC -s#,-(88 5 058z/exchange/active full_scrollcvK td||d{S7#t$r}t||d}~wwxYww)zEGET: Fetch list of active exchanges directly from page list elements.get_active_exchanges)rrYNr)rrYr3s r>get_active_exchanges_apir^sI- "#    -s#,-s(99 6 169z/exchange/active/detailscK td|j|j|j|j|j d{}|S7#t $r}t||d}~wwxYww)zYPOST: Fetch specific active exchange's dynamic ex-details by team name (live Playwright).get_active_exchange_details) exchange_nameexchange_index exchange_idhrefrYN)r rindexrrrYrfr?rSresr3s r>get_active_exchange_details_apirksl - )))::((LL      -s#,-s;A0AA A AA0A A- A((A--A0z!/exchange/incoming-videos/processcpK tdd{S7#t$r}t||d}~wwxYww)zHPOST: Auto-add all 'They sent you video' exchanges to the video library. process_incoming_video_exchangesNrr=s r>$process_incoming_video_exchanges_apir|s9-@AAAA -s#,-rz/exchange/active/actioncK td|j|j|j|j|j d{}|r|j ddk(r}tDcgc]R}|jr|d|jk(s0|j r|d|j k(s|d|jk(r|Tc}D]}tj|d|S7cc}w#t$r}t||d}~wwxYww) zMPOST: Click a header action button (delete/cancel/etc) on an active exchange.click_active_exchange_button) action_typerrrrNr rrrr) r rrrrrra DETAILS_CACHErMrfr?)rSrkr3s r>active_exchange_action_apirs- *(())::((    3778$,((a$$11A1A)AII!A$$))"3Q4499$= !!!T*  #  -s#,-sNDAC+ C$ "C+-AC&C+#D$C+&C++ D4 DDDz/exchange/searchcK td|jd{S7#t$r}t||d}~wwxYww)u 3rd API (POST): search box me keyword → loader wait → header text. File: app/automation/tasks/search.py → run_search() run_search)queryN)r rrfr?rSr3s r>exchange_searchrs> -l$**==== -s#,-+A%#%A% ? :?Az/exchange/search/teamscpK tdd{S7#t$r}t||d}~wwxYww)u 3rd API (GET): search results ki team list (2nd API jaisa format). File: app/automation/tasks/search.py → get_search_teams() Call POST /exchange/search first. get_search_teamsNrr=s r>exchange_search_teamsrs9-01111 -s#,-rz/exchange/typescK td|j|j|j|jd{S7#t $r}t ||d}~wwxYww)un 4th API: team id click → exchange type → Next. Code: app/automation/tasks/exchange_types.py Example body: { "team_id": "", "owner_team_id": "", "team_source": "suggested", "exchange_type": "two-way" } select_exchange_type)rY team_source exchange_type owner_team_idN)r rYrrrrfr?rs r>exchange_typesrse - "LL((,,,,      -s#,-9A#;AAAA#A A  AA  A#z/exchange/videoscpK tdd{S7#t$r}t||d}~wwxYww)uP 5th API (GET): get video list from events-container. Reads all
  • from //section[@id="events-container"]/div/ul. Skips li[@class="bad-status"] items (video still processing). Call after POST /exchange/types (when the video selection page is open). File: app/automation/tasks/videos.py → get_video_list() get_video_listNrr=s r>rrs9-.//// -s#,-rz/exchange/videos/selectcK td|jd{S7#t$r}t||d}~wwxYww)z 6th API (POST): Select videos/games from the list. Football multi-step may return wizard_step=playlists (incl. empty No Playlists). select_videos) video_indicesN)r rrfr?rs r>rrs@ -oT=O=OPPPP -s#,-rz/exchange/playlists/selectcK td|jd{S7#t$r}t||d}~wwxYww)zCSelect playlists on Choose Playlist(s) and click Next when enabled.select_playlists)playlist_indicesN)r rrfr?rs r>rrsK- 1F1F     -s#,-rz/exchange/statscpK tdd{S7#t$r}t||d}~wwxYww)zR 7th API (GET): Get available options on the stats page before selecting. get_stats_optionsNrr=s r>rrs9 -12222 -s#,-rcK td|jd{S7#t$r}t||d}~wwxYww)zm 7th API (POST): Optionally include stats and click next. Example body: {"include_stats": false} select_stats) include_statsN)r rrfr?rs r>rrs@ -nDr r s> -k4<<@@@@ -s#,-rz/exchange/confirmcpK tdd{S7#t$r}t||d}~wwxYww)z 9th API (GET): Read the confirmation screen details before submitting. Returns exchange_name, school_name, school_image, video_names, stats, message. get_confirm_detailsNrr=s r>r r 9 -34444 -s#,-rcpK tdd{S7#t$r}t||d}~wwxYww)zP 9th API (POST): Click the Send Exchange button to finalize everything. submit_exchangeNrr=s r>rr+s9 -/0000 -s#,-rz/exchange/cancelcK td|jd{S7#t$r}t||d}~wwxYww)zA POST API: Cancel exchange wizard at current step index. cancel_exchange) step_indexN)r rrfr?rs r>rr6s? -/DOOLLLL -s#,-rz/exchange/backcK td|jd{S7#t$r}t||d}~wwxYww)zC POST API: Click the physical back button at active index. go_back_exchange) back_indexN)r rrfr?rs r>rrAs? -0T__MMMM -s#,-rz /upload/opencpK tdd{S7#t$r}t||d}~wwxYww)z910th API (POST): Click the global upload navigation link. open_uploadNrr=s r>rrLs8-m,,,, -s#,-rz /upload/teamcpK tdd{S7#t$r}t||d}~wwxYww)zC11th API (GET): Read the currently selected team from the combobox.get_upload_teamNrr=s r>rrUs9-/0000 -s#,-rz/upload/team/dropdowncpK tdd{S7#t$r}t||d}~wwxYww)zB11th API (POST): Click the dropdown arrow to reveal the team list.open_team_dropdownNrr=s r>rr^9-23333 -s#,-rz/upload/teams-listcpK tdd{S7#t$r}t||d}~wwxYww)zJ12th API (GET): Read the list of available teams after dropdown is opened.get_upload_teams_listNrr=s r>rrg9-56666 -s#,-rpathcntjj|rtj|yy)z6Background task to delete temporary file after upload.N)osrexistsremove)rs r>delete_temp_filer$ps" ww~~d $r@z/upload/select-files.background_tasks team_indexfilecK tjjtjt t j}tj|dtjj||j}t|d5}tj|j|dddtd||d{S#1swYxYw7#t$r}t!||d}~wwxYww)z 12th API (POST): Optionally select a team from the list by index, and upload a file. The server will pass this file to Playwright automatically. T)exist_okwbN select_files)r& file_path)r!rjointempfile gettempdirr<uuiduuid4makedirsfilenameopenshutil copyfileobjr'r rfr?)r%r&r' unique_dirtmp_pathbufferr3s r>select_files_apir:vs-WW\\("5"5"7TZZ\9JK  J.77<< DMM: (D !V   tyy& 1"nxXXX" !Y -s#,-sMDBC+!C?C+C)C+DC&"C++ D4 DDDz /upload/filescpK tdd{S7#t$r}t||d}~wwxYww)z013th API (GET): Read the list of uploaded files.get_uploaded_filesNrr=s r>r<r<rrz/upload/files/deletecK td|jd{S7#t$r}t||d}~wwxYww)z613th API (POST): Delete an uploaded file by its index.delete_uploaded_file) file_indexN)r r?rfr?rs r>r>r>s?-4QQQQ -s#,-rz/upload/triggercpK tdd{S7#t$r}t||d}~wwxYww)z114th API (POST): Click the trigger upload button.trigger_uploadNrr=s r>rArAs9-.//// -s#,-rz/upload/progresscpK tdd{S7#t$r}t||d}~wwxYww)zA14.5 API (GET): Fetch live upload progress (total and completed).get_upload_progressNrr=s r>rCrC9-34444 -s#,-rz/upload/schedule-event/opencpK tdd{S7#t$r}t||d}~wwxYww)zF15th API (POST): Click the Select-placeholder to open schedule events.open_schedule_eventNrr=s r>rFrFrDrz/upload/schedule-eventscpK tdd{S7#t$r}t||d}~wwxYww)z 15th API (GET): Fetch all parsed events from the Select-menu-outer dropdown. MUST be called after POST /upload/schedule-event/open so the menu is visible. get_schedule_eventsNrr=s r>rHrHr rz/upload/detailscK td|j|j|j|jd{S7#t $r}t ||d}~wwxYww)zZ 16th API (POST): Fill out the details (video type, schedule event, title, save). fill_video_details)schedule_event_index video_typetitle check_eventN)r rKrLrMrNrfr?rs r>rJrJsc - !%!:!:**((      -s#,-rz/upload/cancelcpK tdd{S7#t$r}t||d}~wwxYww)zb 17th API (POST): Cancel the current upload by clicking the cancel button and confirming. cancel_uploadNrr=s r>rPrPs8 -o.... -s#,-rz/library/videosctK td|d{S7#t$r}t||d}~wwxYww)z/Fetch parsed video items from the Hudl library.get_library_videosrNrrs r>rRrRs;-2GDDDD -s#,-rz/manage-librarycK td{td|d{}|S77#t$r}t||d}~wwxYww)zAFetch Manage Library seasons from Hudl via Playwright (no cache).Nget_manage_libraryr)rr rfr?)rYrr^r3s r>rTrTsQ-(*** 4gFF  +F -s#,-s<A 1-1/1A11 A  AA  Az/manage-library/seasonrcc$K|js tdd td{td||d{}|S77#t$r6}ddl}t d|d||jt||d}~wwxYww) z:Expand a season on Hudl Library via Playwright (no cache).rseason query param is requiredNexpand_manage_library_season)rYrZrzmanage-library/season 500 for z: ) rrrr rf tracebackrg print_excr?)rYrcrr^r3rXs r>rWrWs <<>C!ABB -(*** *    + - .vj3%@As#, -sJB AA AA A B A A B 1BB  Bz/manage-library/folderc fK|js tddddl}|jd|j}|jd}|j dDcgc]P}|jr>|j d|j d|jjR}}|Dcgc]}|s| }}|s tdd  td{td ||| d{} | Scc}wcc}w7'7#t$r} t| | d} ~ wwxYww) zFExpand a folder path on Hudl Manage Library via Playwright (no cache).rrVrNz?(?:Jan|Feb|Mar|Apr|May|Jun|Jul|Aug|Sep|Oct|Nov|Dec)\s+\d{1,2}\bz\s*\(\d+\)\s*$,rzr\r\s9 <<>C!ABB;;J L;;01LC A 779 \--b!4::<=CCE  */kQ1kK/ C!_`` -(*** *#     ! 0 +  -s#,-smA!D1#AD8D1>D D  D1 D(D)D?DD D1DD D. D))D..D1z/manage-library/download)r7c K|js tddttt j }|t |ddt|j|jDcgc]}|jc}tjddd t|<|jt||t|jDcic] \}}|dk7r||c}}Scc}wcc}}ww)zMQueue a background job that selects clips and triggers Hudl's email download.rzitems is requiredqueuedzGDownload queued. Sergio will complete the Hudl steps in the background.N) rOownerr rW item_countrLrIr_r^ri) rLrrRr<r0r1rGlenlabelrJr2add_taskri)rSr%rArOrhrkvalues r>rXrX8s ::C!455  F$T*\$**o)-4$**4iik , (>M7v>DDF FJC '> U F  5  sA/C71C,AC7C1(C7z/manage-library/selectcKt|tfdtjD}|rdd|j|j dS t d{td|j|j|j|j|j d{S7O7#t$r<}td|d t||j|j dcYd}~Sd}~wwxYww) aaMirror a frontend clip selection onto the open Hudl Manage Library page. Best-effort: the download flow re-selects clips itself, so a failure here must never surface as a 500 or block the UI. It also skips while a download is in progress, since running a select on the same page would fight the download's own selection/navigation. c3pK|]-}|jdk(xr|jddv/ywrir rhrUNra.0rPris r> z-select_manage_library_clip..d>8C E!Scggh&7;S&SS836skippeddownload_in_progress)r reasonrlselectedN!set_manage_library_clip_selection)rYrZrrlr|z1Manage Library select mirror failed (non-fatal): r)rGanyr2valuesrlr|rr rYrcrrfrgr<rSrAdownload_activer3ris @r>select_manage_library_cliprWs  %E/668O,ZZ    (*** /LL**]]     +    A#GH#hZZ    s[AC< B4 B0!A B4+B2,B4/C<0B42B44 C9=1C4.C9/C<4C99C<z/manage-library/clip-metacKt|tfdtjD}|rdd|jd|jidS t d{t d|j|j|j|jd{S7D7#t$r>}td |d t||jd|jidcYd}~Sd}~wwxYww) uQRead Hudl hover tooltip fields (Created by, Shared with, Date, …) for one clip.c3pK|]-}|jdk(xr|jddv/ywrqrsrts r>rvz/get_manage_library_clip_meta..rwrxryrzr)r r{rlmetaNget_manage_library_clip_meta)rYrZr]rlz-Manage Library clip meta failed (non-fatal): r) rGr~r2rrlrr rYrcrrfrgr<rs @r>rrs  %E/668O,ZZTZZ(    (*** *LL **     +    =cUCD#hZZTZZ(    sZAC5 B+"B'#?B+"B)#B+&C5'B+)B++ C243C-'C2(C5-C22C5z!/manage-library/download/{job_id}waitcLKddl}tt|}tj |}|r|d|k7r t dd|r|dkDrt jt|dz}|j ddvrpt j|k\rnX|jd d{tj |}|r|d|k7r t dd|j ddvrp|jDcic]\}}|dk7s ||c}}S7mcc}}ww) a^Return the current state of a queued Manage Library download. Supports long-polling: pass ?wait= and the request will block until the job reaches a terminal state (completed/failed) or the wait window elapses. This lets the frontend keep one slow request open instead of hammering this endpoint every couple of seconds. rNrizDownload job not foundg9@r rrg?) rrRrGr2rarrJ monotonicminrrL) rOrrArrirPdeadlinerkrns r>get_manage_library_download_jobrs  %E & * *6 2C #g,%'C!9:: q>>#c$o5ggh#;;~~8+--$ $ $.226:C#g,%/#C)ABB ggh#;;*- G:3wCJ GG % Hs1B,D$.D/AD$2D$ DDD$D$z/library/video-streamcK td|jd{S7#t$r}t||d}~wwxYww)z;Fetch the intercepted HLS stream URL for a given watch URL.get_video_stream_url) watch_urlN)r rrfr?rs r>rrs?-4OOOO -s#,-rz/library/close-videocpK tdd{S7#t$r}t||d}~wwxYww)z>Trigger clicking the close/back button on Hudl's watch screen.close_video_playerNrr=s r>rrrrz/library/video/details/opencK td|jd{S7#t$r}t||d}~wwxYww)z:Open details panel for a video and return its information.open_library_details video_indexNr rrfr?rs r>open_video_detailsrA-4$BRBRSSSS -s#,-rz/library/video/details/typecK td|j|jd{S7#t$r}t ||d}~wwxYww)zHUpdate video type (Game, Scout, Practice) inside the open details panel.update_library_type)rrLN)r rrLrfr?rs r>update_video_typersJ-3AQAQ^b^m^mnnnn -s#,-0A %0.0A 0 A  AA  A z$/library/video/details/event/optionscK td|jd{S7#t$r}t||d}~wwxYww)z1Retrieve event dropdown options in details panel.get_library_event_optionsrNrrs r>get_video_event_optionsrsA-9tGWGWXXXX -s#,-rz/library/video/details/eventcK td|j|jd{S7#t$r}t ||d}~wwxYww)z6Select a specific event in the details panel dropdown.update_library_event)r event_nameN)r rrrfr?rs r>update_video_eventrsJ-4$BRBR_c_n_noooo -s#,-rz/library/video/details/closecpK tdd{S7#t$r}t||d}~wwxYww)zClose details panel.close_library_detailsNrr=s r>close_video_detailsrrrz/library/video/renamecK td|j|j|jd{S7#t$r}t ||d}~wwxYww)z3Rename video tile (either save new_name or cancel).rename_library_video)rnew_namecancelN)r rrrrfr?rs r> rename_videor sS-4$BRBR]a]j]jsws~s~ -s#,-1A0;9;A; A AAAz/library/video/email-downloadcK td|j|j|jd{S7#t$r}t ||d}~wwxYww)z>Trigger Email Download Link popup with stats option or cancel.email_download_link)roptionrN)r rrrrfr?rs r>email_downloadrsS-3AQAQZ^ZeZenrnynyzzzz -s#,-rz/library/video/downloadc K td|jd{}|jddk(rYd|vrUdd|jd|jd |jd|jd |jd d Std |jdd7#t$r}t ||d}~wwxYww)zdDownload video from Hudl and save under media/{id}/ (server). Local browser download kept commented.download_library_videorNr r local_pathVideo saved to media folder.media_idrr3 file_sizer rWrrrr3rr9rWDownload failed)r rrarrfr?rs r>download_videors-54CSCSTT 778  $)<9GGJ/!ggl3GGJ/ WW[1 " SWWY8I%JK K)U* -s#,-s9C B.B,A0B.C B.. C7 CCC z/library/video/download-by-refc Kddlm}ddlm}ddlm}ddlm}ddlm m }m }m m }m}m} |j xsdj#xsd} d} | rdd lm} m} | | xs| | } d t*d t,dzd t.ffd }| r7|5}||| }|r||r||d| cdddSddd t1d|j2| d{}|j9ddk7sd|vrIt;dt-|j9ddj=vrdnd|j9dd|d}||j?s t;dd|j9dxs| xsdj#xsd}|j9dxsdj#}|s|r d||d}|sd |j2}|r||n||} |5}|r|||}|r |j@}| |||j9d!xs|j9d"xsd#||j9d"xsd$|j9d%||j9d&'}||d(|cdddS#1swYxYw7#t4$r}t7||d}~wwxYw#1swYyxYw#t4$r:} ||jCd)n#t4$rYnwxYwt7||d}~wwxYww)*u Download a Hudl library video by `video_index` or `v` and save it under media/{id}/ on the server only. Returns JSON locations — never a browser file download. rPathquote SessionLocal MediaVideo) BACKEND_ROOTfind_media_by_hudl_vmedia_file_existsserialize_mediasource_key_from_hudl_vsource_key_from_watch_urlstore_downloaded_videorN)_canonical_hudl_v_extract_hudl_v already_savedv_valuer4c|}|jdxsd}|rt|z nd}d|rdnd|||j|jd|jd|jd||||jdrtd z |dz nd|jd |jd |jd d S)Nr,rr$Video already saved in media folder.rrMrrEmedia access_urloriginal_filenamer)r rWrvrrMrrrr,rmedia_folder_pathrr3r)rar<r)rowrrrrelabs_pathrrs r>_media_payloadz-download_video_by_ref.._media_payloadZs$ii $*.13|c)*t!73*??YYw';/ $"NSiiX\o\G%;eDk%I!Jcg))L1 "56;/'  r@T)rrdownload_library_video_by_ref)rrr rrz not foundrWrr9rDownloaded file missing on diskrrz*https://app.hudl.com/watch/team/analyze?v=z=+/)safezhudl://library/index/rMr3Video video.mp4rr) temp_pathrMrrr source_keyrF missing_ok)"pathlibr urllib.parserapp.core.databaserapp.models.media_modelrapp.services.media_servicerrrrrrrrrrrrboolr<dictr rrfr?rarloweris_filerunlink)rSrrrrrrrrrv_rawv_canonrrrdbexistingrr3rrrrrrrs @@r>download_video_by_refr=s ".1VV\r " *dEG S!%(D,=e,D d S4Z D 6 ^r+B8H-h7%hdGT^^ - +((   wwxD L$;#cggi&<"="C"C"EEC3 GGI0 1  L!I  ? " " $C!BCCwws|,w,"335=G%+224I @wUZA[@\] +D,<,<+=> 4;'0AZ[dAeJ- ^r/G<!)!4!4J(#ggg&H#''**=H#"%''*"5"DGGM2%, C"#UGL!^G^  -s#,-0^" -  O " "d " 3   s#, -sBL J 2L J J!J%D L 0K7B J9 K L  JL J J6% J11J66L 9K>KL K LK('L( K41L3K44LLL z /library/video/download-to-mediac Kddlm}ddlm}ddlm}ddlm}m}m }m }|jxsdj}|s tdddd lm} |5} ||} | j|j!|j"| k(j%} | r|| rd d d d || cdddS ddlm} | |}|r*| | |}|r||rd d d d ||cdddSddd t-d|j.d{}|j3dd k7sd|vrtd|j3dd|d}||j5s tdd |5} || ||j6||j3dxsd|j.}||}dddd ddd S#t*$rYwxYw#1swYxYw7#t*$r}t1||d}~wwxYw#1swYKxYw#t*$r:} ||j9d n#t*$rYnwxYwt1||d}~wwxYww)z Download a Hudl library video via Playwright, save under media/{id}/, and store id + path in the database for later direct access. rrrr)rrrrrrzwatch_url is required)rrTr)r rrWNrrrr rr9rWrrr3r)rrMrrrrFr)rrrrrrrrrrrrrrrrfilterrfirstrrrfr rr?rarrMr)rSrrrrrrrrrrrkrrrby_vrr3rrpayloads r>download_video_to_mediars~ .1%2,,.I C!899? 2' 288J'..z/D/D/KLRRT )(3!%A"(+    D *A+B2-d3"&)-#I*$/ % 6-54CSCSTT wwxD L$;C4E!FGGL!I  ? " " $C!BCC- ^r(#jj#"%''*"5"D ,, C&c*G$1    C   1 8U -s#,-^ -  O " "d " 3   s#, -sAIAG"5 I0G0IG0G.G0"AI>H>H H I GG"GG""G+'I.G00 H 9 HH  I HH I#H<;I< IIIIIIz/mediac DKddlm}ddlm}ddlm}|5}|j |j|jjj}dt||Dcgc] }|| c}dcdddScc}w#1swYyxYww)z-List all videos saved under the media folder.rrr)rr)r countvideosN) rrrrrrrorder_byrIdescallrk)rrrrrowsrs r>list_media_videosr s/1: 2 HHZ Xj++002 3 SU Y3784aq)48 9 s/B AB2B B B BBB z /media/lookuprcfKddlm}ddlm}ddlm}ddlm}m}m }m }|||xsdj}|5} |xsd|fD]j} | s|| } | j|j|j| k(j} | sL|| sUdd|| d ccd d d S dd lm} | |xs | |xsd}|r(|| |} | r|| rdd|| d cd d d Sdd d d cd d d S#t$$rd }YFwxYw#1swYy xYww) z?Find a saved media video by Hudl watch_url or by `v` inside it.r)unquoterr)rrrrrrT)r foundvideoNrF)rrrrrrrrrrrrrrrrrrrf)rrrrrrrrrawr candidaterkrrrs r>lookup_media_by_watch_urlrs>%.1 ')/r* + 1 1 3C 2#/r3/I+I6C((:&--j.C.Cs.JKQQSC(-"!,S1 /  D$H R(HA &r1-C(-"!,S11 <>= & A ' sgAD1AD%D%& D%3 D1=D%?D D%; D1D% D1 D"D%!D""D%%D.*D1z/library/video/deletecK td|jd{S7#t$r}t||d}~wwxYww)z&Delete a video item from Hudl Library.delete_library_videorNrrs r> delete_videor Orrz/library/stream-proxyrrequesttokenc ()*+Kddl}ddl}ddl+ddl+ddl}ddlm}m}m}m } |**sD|rB|jjd} | r%| jdr| jdd**s *s||jd  dd lm} | 5} t#*| dddt&j(j+d{}d j-|Dcgc]}|d d|dc}}+j.j|))j1dd)j1d| |j3})+fd}|j5d|d{\}}}|jddk(xs|jd}|r |j7|}|jdd}d|j9vs$|jddj;drx |j=d}+j>jA|}tBjDjG|jD}|j;ds|dz }|jHd|jJ|(|jM}g}|D]}|jO}|s|jQ|'|jdr1d |vr(*+fd!}|jRd"||}|jQ|i+j>jU(|} d#+j>jW| d$*}!|jQ|!d%j-|jYd}d&}d(d)i}#|j]D]\}$}%|$j9}&|&d*vs|%|#|$<!|||||#+S#1swY xYw#|$rt$$r} ||jd |  d} ~ wwxYw7cc}w7#t$$rYSwxYw#t$$r}"t[d'|"Yd}"~"d}"~"wwxYw#t$$r}'|d,d-|'d}'~'wwxYww).zV Proxy HLS stream requests and inject Hudl session cookies for authorization. rN)Responserr r AuthorizationBearer  rAuthentication token requiredr6rAuthentication failed: ; r=rn User-AgenteMozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36Cookiec jj5}|jt|j|j fcdddS#1swYyxYw#j j$r:}|jt|j|j fcYd}~Sd}~wt$r&}dit|jfcYd}~Sd}~wwxYw)Nr9 r urlopenr rheadersrr HTTPErrorcoderfr<encoderesponseheerequrllibs r> fetch_remotez'hudl_stream_proxy..fetch_remotes 0^^++C0H#??D1A1A,BHMMOS100<<)) <wwRZZ 0"'');; 0BA // 0sLA$0A A$A!A$!A$$C$=/B2,C$2 C$>CC$C$zContent-Encodinggzips Content-Typeapplication/octet-streammpegurl?z.m3u8zutf-8/z://#URI="c|jd}jj|}djj|d}d|dS)Nr&/api/v1/hudl/library/stream-proxy?url=&token=r/")groupparseurljoinr)matchtag_uriabs_uri proxied_uribase_url token_valr&s r> replace_uriz&hudl_stream_proxy..replace_urisi*/++a.*0,,*>*>x*Q0VW]WcWcWiWijqWrVssz|E{F/G ).{m1'= =r@z URI="([^"]+)"r1r2 zapplication/vnd.apple.mpegurlzError rewriting manifest: Access-Control-Allow-Origin*)zcontent-encodingzcontent-lengthztransfer-encodingserver connectioncontentr7 media_typerr9zStreaming proxy failed: )/rr(urllib.requestrr^fastapirrr r rra startswithraHTTP_401_UNAUTHORIZEDrrrrfr contextcookiesr-r  add_headerget_running_looprun_in_executor decompressrendswithdecoder5urlparser!rdirnameschemenetloc splitlinesrappendrbr6rr rgrL),rr r rr(r^rrr r auth_headerrrauth_errrKc cookie_strloopr'r7rrS is_gzipped content_type manifest_text parsed_url base_pathlines new_linesline line_stripr= abs_targetproxied_target rewrite_errresponse_headersrrk_lowr3r;r%r<r&s, @@@@r>hudl_stream_proxyrkXsL  @@I oo))/: ;11)<#))#.q1I  (D(DMlmms2 ^r #Ir 2$++3355GIAqyk1W:,7IJJ ..  %CNN<"IJNN8Z(KC'') 0,0+?+?l+S%S" Wd[[!34>^$//R]B^  t,{{>3MN   **, , #q0A0J0J70S$ B $ G 4 $\\2237 GGOOJOO<  ))#.$I(//0J4E4E3FykR&002 !D!%J%!((.#..s3"d?> $*266*:K#ND!((.&,\\%9%9(J%O +QRXR^R^RdRdeoRpQqqxzCyD*E!((8%"(yy+227;> *3 MMODAqGGIEoo&' #$ +,`pqqq^  s(D(DOfgofpMqrrs6I$&T  T B2;-@AA B CC#;C5!ABBCsBQ N9 N,#N9+!Q O& Q O)4AQ;+P%&O.'1P%O1*AP%3E7P*.P%P%+Q,N61N99O#OO##Q)Q.P%1 O>:P%=O>>P% P" PP%P""P%% P?. P::P??Qz/library/thumb-proxyc Kddl}ddlddlddlm}m}m}|}|sD|rB|jjd}|r%|jdr|jdd}|s||jd  dd l m } | 5} t|| ddd|xsd j!} | jd s |ddt#j$d| t"j&r |ddt(j*j-d{} dj/| Dcgc]}|dd|dc}}j0j3| j5ddj5d|j5dd |j7}fd}|j9d|d{\}}}|jdd}|dk\s|s |dd|d ||d!|jd"dj!xsdd#d$d%&S#1swYxYw#|$rt$r} ||jd |  d} ~ wwxYw7Hcc}w7#|$rt$r}|d'd(|d}~wwxYww))z Proxy Hudl library thumbnail images with the Playwright session cookies so the frontend can show original film stills (not profile avatars). rN)rrr rrrrrr6rrrhttprzInvalid thumbnail urlz avatar|profile|headshot|/users?/zNot a video thumbnailrrrrnrrrRefererzhttps://www.hudl.com/c jjd5}|jt|j|j fcdddS#1swYyxYw#j j$r:}|jt|j|j fcYd}~Sd}~wt$r&}dit|jfcYd}~Sd}~wwxYw)N)timeoutr9rr!s r>r'z&hudl_thumb_proxy..fetch_remotes 0^^++C+<#??D1A1A,BHMMOS=<<<<)) <wwRZZ 0"'');; 0BA // 0sLA&0A A&A#A&#A&&C&?/B4.C&4 C&C!C&!C&r)z image/jpegizThumbnail fetch failed ();zprivate, max-age=3600r@)z Cache-Controlr?rCr9zThumbnail proxy failed: )rrFrrGrrr rrarHrarIrrrrfrr^searchIr rJrKr-r r rLrMrN)rr r rrrr r<rXrrrYrrKrZr[r\r'r7rrSr^r3r%r&s @@r>hudl_thumb_proxyrws 77I oo))/: ;11)<#))#.q1I (D(DMlmm  2 ^r #Ir 2 9"   C >>& !C!899 yy4c244@C!899#++3355GIAqyk1W:,7IJJ ..  %CNNoNN8Z(NN956C'') 0,0+?+?l+S%S" Wd{{><@ # T'? }A%NO O#))#.q1779I\!8/2   W^   44,XJ7   6I*&T  CC#;C5!ABBCsA5J : H4 H'H4A=J I!J -I$AJ +I+I)A I+&J 'H1,H44IIIJ $J )I++J 9 JJ  J z/library/video/download-directrc ZK|}|s tdd ddlm}|5}t||ddd t d| d{}|j d d k(rYd |vrUd d |j d|j d|j d |j d|j ddStd|j dd#1swYxYw#t$rt$r}tdd|d}~wwxYw7#t$r}t||d}~wwxYww)z Download video from Hudl and save under media/{id}/ on the server. Local browser FileResponse download is kept commented below. rCrr6rrNrrrr rrrrrr3rrr9rWr)rrrrrfr rar?) rr r%r<rrrYrr3s r>download_video_directry#s2I 4STTZ2 ^r #Ir 2&-5;OO 778  $)<9GGJ/!ggl3GGJ/ WW[1 @ SWWY8I%JK KW^  Z6MhZ4XYYZPH -s#,-stD+ C" CC"DD  A0D9D+:DCC""D 4DD  D+ D D( D##D((D+z/media/{media_id}rdownloadcKddlm}ddlm}ddlm}ddlm}ddlm }m } |} | sD|rB|jjd} | r%| jdr| jd d } | s td d  |5} t!| | | j#|j%|j&|k(j)} | s tdd| | s tdd|| j*}| j,xs |j.}t1|}|}dddddi}|r/j5dd}d|d|||d<||d|Sdj5t7ddd|d<|d|S#1swYkxYw#t$rt2$r}td d| d}~wwxYww) z Direct access to a video saved under media/{id}/. - Default: inline playback for