o .j}@s\ dZddlZddlZddlZddlZddlmZddlmZm Z m Z m Z m Z m Z mZmZmZddlZddlZddlZddlmZeejZedZeeZejddZejd d Zed d d Z edddZ!edddZ"edddZ#dZ$edZ%ddZ&edddZ'ejddgd d!d"Z(ejdd#gd d$d%Z)ejd&d#gd d'd(Z*ejd&dgd d)d*Z+ed+ed,dwd.d/Z,ed0Z-ed1ed2d3d4Z.ed5d6d7Z/ed8d9d:Z0d;Z1ed<Z2ed=d>d?Z3ejd=d#gd d@dAZ4edBedCedDdwdEdFZ5e6dG7dHZ8dIdJZ9edKdLdMZ:ejdNdgd dOdPZ;ejdNd#gd dQdRZZ?edVedWedXdwdYdZZ@ed[ed\ed]dwd^d_ZAed`dadbZBedcdddeZCedfdgdhZDediedjedkdxdldmZEedndodpZFedqdrdsZGedtdudvZHedwedxdydzd{ZIed|ed}dwd~dZJededdwddZKedddZLedddZMejdd#gd ddZNdZOddZPededdxddZQedddZRedddZSejdd#gd ddZTejdd#gd ddZUddZVddZWejdd#gd ddZXejdd#gd ddZYddZZejdd#gd ddZ[ejdd#gd ddZ\edddZ]dZ^dZ_ejdd#gd ddZ`ddZadZbdacddZdejdd#gd ddZeejdd#gd ddÄZfejdd#gd ddƄZgdZhedȡedɡdd˄Zied̡dd΄ZjedϡedСdd҄ZkedӡddՄZledփZmedסedءddڄZnedZoed܃ZpedݡedޡddZqedddZredddZsedddZtejdd#gd ddZuededddZvedddZwedddZxedddZydZzhdZ{hdZ|ddl}Z~edZejdddZdededefddZdedefddZdedefd d Zed Zejdddedefd d ZdedefddZdededefddZdededefddZdedefddZdedefddZededededgZddZeded d!d"Zed#ed$dzd&d'Zd{d)ed*efd+d,Zed-Zed.Zejdded/ed0ed1dwd2d3Zed4d5d6Zejd7d#gd d8d9Zejd:d#gd d;d<Zd=d>Zed-ed?d@ZejdAd#gd dBdCZdadDdEZejdFd#gd dGdHZedIdJdKZejdLd#gd dMdNZdOZdPZdQZdRefdSdTZejdUdVd%igdWdXejdYdVd%igdWdXejdZgdWd d[d\Zejd]dVd%igdWdXejd^dVd%igdWdXejd_gdWd d`daZejdbgdWd ejdcgdWd ejddgdWd dzdedfZedgkr,eZejdhedidjejdkdldmdnejdod(d(dpgdqeZejrejeejejfddrZeedsejejdtejdudvdSdS(|a8 Simple Flask server for the PARA experiment dashboard. Serves static HTML reports + media with directory listing fallback. Usage: python serve.py # localhost:8080 python serve.py --public # + cloudflared tunnel for public URL python serve.py --port 9090 # custom port N)Path) Flasksend_from_directory send_fileredirectabortrequestResponse make_responsejsonify)datetime /data/cameroncCs<|jdd|jdd|jdd|jdd|S) zIAdd Accept-Ranges to all responses so browsers know they can seek videos. Accept-RangesbyteszAccess-Control-Allow-Origin*zAccess-Control-Allow-MethodszGET, POST, OPTIONSzAccess-Control-Allow-HeaderszContent-Type, X-Agents-Password)headers setdefault)responser+/data/cameron/para/.agents/reports/serve.pyadd_range_headers rcCstjdkrdSdS)z=Short-circuit CORS preflight requests with the headers above.OPTIONS)N)rmethodrrrr_cors_preflight)s r/cCstd}|r ttdSdS)N index.htmlzC

No reports yet

Agents haven't generated any reports.

) REPORTS_DIRexistsr)Z index_filerrrindex0 r z /style.csscC ttdS)Nz style.cssrrrrrrstyle8s r$z/lifecCs"td}|drt|dSdS)N/data/cameron/lifezdashboard.html)zLife dashboard not found.)rrr)Zlife_dirrrrlife_dashboardAs  r'z/life/vision/cCsttd|S)Nz/data/cameron/life/visionrrfilenamerrr life_visionIr+Zfabregasz/data/cameron/life/notes.mdcCs0ddlm}m}|jdtkr|ddSdS)Nrrrz X-Notes-Auth)flaskrrrget_NOTES_PASSWORDr-rrr_check_notes_authVs r2z/notescCsttddS)Nr%z notes.htmlr(rrrr notes_page\r,r3z /api/notesGET)methodscCs$ttrtdddifSdS)Nz Content-Typeztext/plain; charset=utf-8)rr6)r2 _NOTES_FILEr read_textrrrr get_notesasr9POSTcCs(tddlm}t|jdddS)NrrTZas_text)okr6)r2r/rr7 write_textget_datar;rrr save_notesis r@z /api/annotatec Cs>ddl}tjdddp i}|dd}|dd}|dip i}|r%|s.td d d d fSt|}|dus:|sFtd d |d dfS|d}i}|rez || }Wn t ydi}Ynw|||<z | |j |dddWnt y}ztd t|d dfWYd}~Sd}~wwtdt|ddfS)aYSave one rollout's annotation to `/_annotations.json`. Body: {"eval_dir": "", "rollout_id": "rollout_NNN", "fields": {"success": "yes|partial|no", "touched_obj": bool, "failure_mode": "..."|null, "notes": "..."}} rNT)Zforcesilenteval_dirrZ rollout_idfieldsFzmissing eval_dir / rollout_id)r=errorzeval_dir not allowed/found: _annotations.json)indentZ sort_keys)r=savedr6)jsonrget_jsonr0r _check_browse_pathis_dirrloadsr8 Exceptionr>dumpsOSErrorstr) rLbodyeval_relZrollrC eval_pathann_pathstateerrrannotate_rolloutqs4    "r[cCsddl}tjdd}|stidfSt|}|dus|s%tidfS|d}|s3tidfSz t|| dfWSt yNtidfYSw)zJReturn the existing `_annotations.json` for a given eval_dir (browse-rel).rNrBrr6rG) rLrargsr0r rNrOrrPr8rQ)rLrVrWrXrrr annotate_gets    r]z /567_projectz/567_project/rcCtd}|r t||SdS)Nz8/data/cameron/567_augmentation_viewpoint_project/websitez Not found.r&rrOrr*Zsite_dirrrrschool_project rbZ meeting_notesz/meeting_notesz/meeting_notes/cCsg}trYttddD]J}|rX|drX|d}|jdddd}|dD]}| drA|d d  }nq0t |d jd }||j||fqd d d|D}d|pgddS)z%List all meeting notes, newest first.Treversenotes.md- _ z# rHN%Y-%m-%d %H:%Mrcss.|]\}}}d|d|d|dVqdS)z
  • z
    • Nr).0Zslugtitlemtimerrr s z&meeting_notes_index..a0 Meeting Notes

    Meeting Notes

      z5
    • No meeting notes yet.
      • 
    ) NOTES_DIRrOsortediterdirrr8namereplacesplit startswithstripr fromtimestampstatst_mtimestrftimeappendjoin)notesfZmdrolinerpitemsrrrmeeting_notes_indexs(   rz/meeting_notes/cCsHt|}|d}|sdS|}td|d|ddddS) z8Render a meeting note as HTML with collapsible sections.rfz Not foundr& {{NOTE_ID}}{{MD_CONTENT}}`\`${\${)rsrr8MEETING_NOTE_HTMLrw)note_idZnote_dirmd_file md_contentrrrmeeting_notes_views $rz./meeting_notes//media/cCstt|d|S)Nmedia)rrs)rr*rrrmeeting_notes_mediaraP Meeting Notes
    z/data/cameron/scratch_filesz/uploadcCdS)NuF Upload

    Upload File

    Drag & drop a file here, or click to select
    rrrrr upload_pageGrcCsdtjvr tddidfStjd}tjddp|j}ddl}|dd |}t |}| t |t | d d}tt ||d S) NfilerDzNo file providedrErvrrz [^\w\-\. ]riz/data/cameron/)pathZ browse_path) rfilesr Zformr0rzr*resub UPLOAD_DIRsaverTrw)rrvrZ safe_namedestrelrrr upload_files  rz /data_viewerz /data_viewer/z/data_viewer/cCtd}|r t||SdS)N data_viewer)zData viewer not built yet.r&rrOrr*Z viewer_dirrrrr rrz(\d+)cCsddt|DS)NcSs$g|]}|r t|n|qSr)isdigitintlower)rntrrr s$z _natural_key..) _NATURAL_RErxsrrr _natural_keysrz/api/data_viewer/datasetscCs:tdd}|stdgiSddl}t||S)Nrz datasets.jsonZdatasetsr)rrr rLrPr8)Zcfg_jsonrrrdata_viewer_datasetss  rz/api/data_viewer/annotationsc sddl}tjddd}t|}|dus|s"tddidfS|d }|rRz t| | WSt yQ}ztdd |id fWYd}~Sd}~wwhd z fd d| D}Wn t yng}Ynwtd|t|dgdS)zhLoad episodes.json (if present) from a frames directory, else return an empty skeleton with frame count.rNrrrrDpath not a directoryrE episodes.jsonzinvalid episodes.json: rJ>.jpg.jpeg.png.webpcs&g|]}|r|jvr|qSr)is_filesuffixrrnpZIMG_EXTSrrrs&z/data_viewer_get_annotations..)version source_path total_framesfpsepisodes)rLrr\r0lstriprNrOr rrPr8rQrurSlen)rrfullZ meta_filerZZframesrrrdata_viewer_get_annotationss4" rcCs:ddl}ddlm}tjddpi}|dpdd}t|}|dus(|s0t d d id fS|d g}t |t sCt d d id fSt |dpJd}g}t |D]d\}} t | tsjt d d|did fSzt | d} t | d} Wntttfyt d d|did fYSw| dks| | krt d d|d| d| id fS|r| |krt d d|d| d|id fS| dpg} t | t st d d|did fSg} t}t | D]\}}t |tst d d|d|did fSzt |d}Wn tttfy/t d d|d|did fYSw|| ks:|| krUt d d|d|d|d| d| id fSt|dpcd |d!|}||vrq|d!|}||| ||t|d"pdd#q| jd$d%d&|t| dpd'|| | t| d"pdt| d(pd| d)qRt|jjd*d+}d,||t|d-pd.||d/}|d0}|d1t}z||j|d2d3||Wnt y}zt d d4|id5fWYd}~Sd}~wwt d6t|t!||d7S)8z[Persist episodes.json into the frames directory. Body: {path, total_frames, fps, episodes}.rN)timezoneT)rArrrrDrrErzepisodes must be a listrzepisode z must be an objectstartendz missing/invalid start/endz invalid range rgz end z >= total_frames keyframesz keyframes must be a listz keyframe framez missing/invalid framez frame z outside ep range idZkf_rilabel)rrrcSs|dS)Nrr)krrr7sz-data_viewer_put_annotations..keyZep_r)rrrrrrZseconds)Ztimespecrrr)rrrrr updated_atrz.episodes.json.tmp.rH)rIzwrite failed: rJr=)statusrcountr)"rLr rrrMr0rrNrOr isinstancelistr enumeratedictKeyError TypeError ValueErrorsetrTaddrsortnowZutcZ isoformatfloatosgetpidr>rRrwrSr)rZ_tzdatarrZepsrZ normalizedieprrZkfs_inZkfs_outZseen_idsjZkfrZkf_idrZpayloadrtmprZrrrdata_viewer_put_annotationss     & &  &*6       "rz/api/data_viewer/listc Cstjddd}ttjdd}ttjdd}tjdd}|r)t|nt}|d ur7td d id fS|r?| sJtd t |ddfSgg}}zD| D]=}|j }| dr_qTz)| rq|dkrp||ddn|dkr|j} ||d| |jdWqTtyYqTwWntytd did fYSw|jddd|jdddt|} t|} ||} | |||} t|| | ||t| | dS)zDList directory contents under BROWSE_ROOT as JSON with natural sort.rrrlimitZ2000offset0onlyNrDZ forbiddenrFznot a directory)rDrr&.rdir)rvtypedirsr)rvrextsizezpermission deniedcS t|dSNrvrrZrrrr| z"data_viewer_list..rcSrrrrrrrr}r)r total_dirs total_filesrrZreturnedentries)rr\r0rrrN BROWSE_ROOTr rrOrTrurvryrrrr|st_sizerSPermissionErrorrr)rrrrrrritemrvrrrZcombinedZpagedrrrdata_viewer_listVsf      rz/runsz/runs/z/runs/cCr)Nruns)zRuns viewer not built yet.r&rrrrr wandb_viewerrrz/glassesz /glasses/z/glasses/cCr)N glasses_app)zGlasses app not built yet.r&r)r*Zapp_dirrrrrs rz/api/runs/listcCs ttSN)r _wandb_runsZ list_runsrrrr api_runs_lists rz/api/runs/cCs*t|}|durtddidfSt|S)NrDz run not foundr&)rZ run_detailr )run_idZdetailrrrapi_runs_details rz(/api/runs//media/cs`t|}|dur td|ddtD}tfdd|Ds)tdt|d|S)Nr&cSsg|]}t|qSr)rresolvernrrrrrsz"api_runs_media..c3s&|]}tt|dVqdS)rN)rTryr resolvedrrrq$z!api_runs_media..rFr)rZfind_runrr Z get_rootsanyr)rr*Zrun_dirrootsrr rapi_runs_medias rz/figmaz/figma/z/figma/cCsRtd}|s dS|rt||St|}ddd|D}d|p%ddS) Nz#/data/cameron/para/paper/figs/figmaz

    No Figma exports yet

    rcss>|]}|rd|jd|jd|jddVqdS)zN
  • z4 (zKB)
    • N)rrvr|rrnrrrrrqs  z figma_exports..a6Figma Exports

    Figma Exports

    Dashboard

      zI
    • No exports yet. Set up figma_config.yaml and run figma_export.py
      • z
    )rrOrrtrur)r*Z figma_dirrrrrr figma_exportss   rz/papercCr)Na! PARA Paper

    PARA Paper

    checking...
    DashboardPDFAgents
    rrrrr paper_viewerrrz/paper/cCr^)Nz/data/cameron/para/paperr_r`)r*Z paper_dirrrr paper_filer!rz/old_para_websitecCstdS)N/old_para_website/)rrrrrold_para_website_redirect$srrz!/old_para_website/index_goal.htmlcCr^)Nz#/data/cameron/para/old_para_websiter_r`rarrrold_para_website(rcrz /para_websitez/para_website/cCr)NZ project_site)zProject website not built yet.r&rrarrr para_website1rcrz/para_website_v1z /para_website_v1/cCr)NZproject_site_v1)zArchived v1 site not found.r&rrarrrpara_website_v1:rcrz/chatcCtSr)MOBILE_CHATTER_HTMLrrrr chat_pageCrrz/api/mobile_chatter/iframe_urlcCs td}|r|SdS)Nz8/data/cameron/para/.agents/mobile_chatter/iframe_url.txtr)rrr8rz)Zurl_filerrrmobile_chatter_iframe_urlHs r z /api/chatc Csddlm}t}|dd}|dtt}|s$tddidfS|d d }z||||d }t||d WStyU}ztdt|id fWYd}~Sd}~ww)Nr)chatmessager session_idrDzNo message providedrEmodelzclaude-sonnet-4-20250514)r$)rr#rJ) r!rrMr0rTuuidZuuid4r rQ)Zdo_chatrZuser_msgr#r$Z response_textrZrrrapi_chatPs    r&cCs tjdp tjd}|tkS)z*Check password from header or query param.zX-Agents-Passwordpw)rrr0r\AGENTS_PASSWORD)r'rrr_check_agents_authgsr)z/agentsz/agents/cCrr) AGENTS_HTML) agent_namerrr agents_pagemsr,z/api/agents/listc Csts tddidfSddl}tjd}|stgSt| }||}Wdn1s0wYg}|di D]$\}}tj|d}|rT| nd }| ||d d |d q?t|S) z.List all agents with their tmux window status.rD unauthorizedr.rNz config.yamlagentsz status.mdunknown descriptionr)rvr0r) r)r yamlrparentropenZ safe_loadr0rr8rzr) r1Z config_pathrZconfigr.rvinfoZ status_filerrrrapi_agents_listss   r5z/api/agents//panec Csts tddidfStjjddtd}t|}|s%td|dd d Stjd d d |ddd|gddd}ddl }| dd |j }| dd |}td|iS)z&Capture tmux pane output for an agent.rDr-r.linesr6rWindow ' ' not foundr)rDoutputtmuxz capture-pane-tz-pz-SrgTcapture_outputtextrNz\x1b\[[0-9;]*[a-zA-Z]z \x1b\].*?\x07r:) r)r rr\r0r_find_tmux_window subprocessrunrrstdout)r+r6targetresultrZcleanrrrapi_agent_panes rFz"/api/agents//interruptcCsts tddidfSt|}|stdd|didfStddd |d gd d l}|d tddd |dgtddiS)z)Send Escape key to interrupt Claude Code.rDr-r.r8r9r&r; send-keysr<ZEscaperN333333?rrZ interrupted)r)r r@rArBtimesleep)r+rD_trrrapi_agent_interrupts rLz/api/agents//sendcCsts tddidfSt}|dd}|stddidfSt|}|s1tdd|d id fStd d d ||dgddl}| dtd d d |dgtddiS)z(Send keystrokes to an agent's tmux pane.rDr-r.r?rNo text providedrEr8r9r&r;rGr<EnterrNrrsent) r)r rrMr0r@rArBrIrJ)r+rr?rDZ_timerrrapi_agent_sends  rPcCs0ddl}d}||jvr|jd|ddl}|S)Nrz)/data/cameron/agents_stuff/agents/glasses)sysrinsert spotify_lib)_sysglrSrrr _spotify_libs  rVcCsDzddl}ddl}|dt|WdSty!YdSw)zRSignal the renderer to refresh now-playing immediately (glasses-initiated change).rNz/tmp/glasses_spotify_force)pathlibrIrr>rTrQrWrKrrr_sp_force_refreshs  rYz/api/glasses/spotify/playpausecC2ts tddidfSt}ttd|iSNrDr-r.code)r)r rVZtoggle_playbackrYr\rrrapi_glasses_spotify_playpause   r^z/api/glasses/spotify/nextcCrZr[)r)r rVZ next_trackrYr]rrrapi_glasses_spotify_nextr_r`c Csddl}z6|dkr|||ddWS|dkr'|||ddWS|dkr8|||ddWSWd StyV}zd t|dd WYd}~Sd}~ww) Nrsearch_spotifyqueryr artist_albumsartist album_tracksalbum_idz tool error: xz unknown tool)rLrRZ search_tracksr0rcrerQrT)rvinplibrrZrrr _sp_find_tools rjz/api/glasses/spotify/findc s&ts tddidfStpidd}|s!tddidfStdd l}dd l}d d d d ddiid gddddd dddiidgddddd dddiidgddg}d}d|dg}z}dd l }| }t dD]n}|j j dd|||d} | jdkr|d | jd|dfd!d"| jDdqmdd#d$| jD} |d%| |j} | r|| dni} | d&rtd'| d&| d(d| ddd)WStd*d+iWSWn/ty } z"|}|rtd*d'i|n td+t| d d,d-WYd } ~ Sd } ~ wwtd*d+iS).uPick the track to play for a spoken request, grounded in Spotify's LIVE catalog via tools (so 'newest album' is current, not guessed). Returns the candidate WITHOUT playing it — the glasses confirm first.rDr-r.r?rrMrErNrazCSearch Spotify for tracks. Returns up to 5 {name,artist,album,uri}.objectrbrstring)rZ propertiesrequired)rvr0Z input_schemarcuList an artist's albums/singles NEWEST-FIRST with release_date. Use this for 'newest/latest album' requests — it reflects Spotify's live catalog.rdrezGList an album's tracks {name,uri} given an album id from artist_albums.rfuPick the single Spotify track to play for the spoken request. ALWAYS ground your answer in the tool results (Spotify's live catalog) — never rely on your own memory of what albums/songs exist or are newest. For 'newest/latest album by X' call artist_albums (newest-first) and use the top album, then album_tracks. For a named song use search_spotify. When you've decided, reply with ONLY JSON: {"uri":"spotify:track:..","name":"..","artist":".."} — or {"found":false} if nothing fits.user)Zrolecontentzclaude-sonnet-4-6i )r$Z max_tokenssystemtoolsmessagestool_useZ assistantcs0g|]}|jdkrd|jt|j|jdqS)rtZ tool_result)rZ tool_use_idro)rrrjrvinputrnbrirrrs z,api_glasses_spotify_find..css |] }|jdkr|jVqdS)r?N)rr?rvrrrrqsz+api_glasses_spotify_find..z\{.*\}uriTrv)foundryrvrdrzFrg)rzrD)r)r rrMr0rzrVrLr anthropicZ AnthropicrangersZcreateZ stop_reasonrrorsearchSrPgrouprQrT)r?r_rerrrqrsr{clientrir ZtxtmdrZrrrxrapi_glasses_spotify_findsZ      , : rz/api/glasses/spotify/play_uricCs`ts tddidfStpidd}|s!tddidfSt|}ttd|iS) NrDr-r.ryrzNo uri providedrEr\) r)r rrMr0rzrVZplay_urirY)ryr\rrrapi_glasses_spotify_play_uri!s  rzA/browse/para/.agents/reports/glasses_app/feed/module_spotify.jsoncCsJzddl}ddl}|dt|Wn tyYnwtddS)zThe client fetching this feed == it's on the Spotify tab. Touch a marker so the renderer only polls Spotify while it's actually being viewed (avoids 24/7 polling -> rate-limit bans). Then serve the renderer-written file.rNz/tmp/glasses_spotify_viewedz3/data/cameron/para/.agents/reports/glasses_app/feedzmodule_spotify.json)rWrIrr>rTrQrrXrrrglasses_spotify_feed-s  rz5/data/cameron/agents_stuff/agents/glasses/chat_log.mdZvoice_interfacez/api/glasses/chat/sendcCs.ts tddidfStpidd}|s!tddidfSttd}|d |d Wd n1s:wYt t }|skttd}|d t d Wd n1s^wYtddidfS|dtd}t ddd||dgdd l }|dt ddd|dgtddiS)zGlasses Chat -> the persistent voice_interface agent. It observes/commands other agents per its own ROLE, then appends its reply to the chat log, which the glasses poll (so the reply shows up whenever it's done).rDr-r.r?rrMrEaz> you: rjNzvoice: (agent 'z' window not found) zvoice agent not foundr&za [glasses chat from Cameron -- when done, append ONE line 'voice: ' to zU; observe agents by reading their panes, only message one if Cameron explicitly asks]r;rGr<rNrrrZ dispatched)r)r rrMr0rzr3GLASSES_CHAT_LOGwriter@ VOICE_AGENTrArBrIrJ)r?rrDwrappedrKrrrapi_glasses_chat_send@s*   rcCs^tjgdddd}|jdD]}|dd}t|dkr,|d|kr,|dSqd S) z Find tmux window target by name.)r;z list-windowsz-az-Fz.#{session_name}:#{window_index} #{window_name}Tr=rjrhrrHrN)rArBrCrzrxr)rvrErpartsrrrr@[s  r@u[E PARA Agents

    AGENTS

    Dashboard Chat Files
    cCs&tdurddlm}|ddddatS)Nr WhisperModelZsmallZcpuZint8)ZdeviceZ compute_type)_whisper_modelZfaster_whisperrrrrr _get_whisperDs rz/api/transcribec Cs ddl}dtjvrtddidfStjd}|jddd }||j|zaz=tj |jd krAtd d d WWt |jSt }|j |jdd\}}ddd|D}td|iWWt |jSty}ztdt|idfWYd}~Wt |jSd}~wwt |jw)zTranscribe audio using Whisper.rNaudiorDz No audio filerE.webmFrdeleterrzrecording too short or empty)r?warningen)languagerhcss|]}|jVqdSr)r?rz)rnsegrrrrq[sz!api_transcribe..r?rJ)tempfilerrr NamedTemporaryFilerrvcloserrgetsizeunlinkrZ transcriberrQrT)rrrr$segmentsrir?rZrrrapi_transcribeLs,    rz/api/ttsc Csddl}t}|dd}|stddidfSt|dkr&|ddd }z4|jd d d }|tj d ddddd|j g|dddd}|j dkrStd|j idfWSt |j ddWStjyltddidfYSty}ztdt|idfWYd}~Sd}~ww)z.Convert text to speech using Piper neural TTS.rNr?rrDrMrEiz... text truncated for speech.z.wavFrZpythonz-mZpiperz--modelz0/data/cameron/.piper_voices/en_US-ryan-high.onnxz --output_fileTrg)rur>r?timeoutrJz audio/wavmimetypeuTTS timed out — text too long)rrrMr0r rrrrArBrv returncodestderrrZTimeoutExpiredrQrT)rrr?rrErZrrrapi_ttscs4    rz/api/chat/clearcCs4ddlm}t}|dd}||tddiS)Nr)clear_conversationr#rrZcleared)r!rrrMr0r )rrr#rrrapi_chat_clears   ra3 PARA Mobile

    PARA Mobile


    PARA Mobile

    DashboardAgents
    /
    z/paper_figuresz/paper_figures/cCDtdd}|s dS|}tddd|dddd S) z!Render paper figures review page. paper_figuresrfrrrrrrrrrr8rrwrrrrrrx $rz$/paper_figures/media/cCttdd|S)Nrrr#r)rrrpaper_figures_mediarrz/para_presentationz/para_presentation/cCr) z2Render lab presentation deck (markdown-as-slides).para_presentationrfrrrrrrrrrrrrrrrz(/para_presentation/media/cCr)Nrrr#r)rrrpara_presentation_mediarrz/data/cameron/tri_diaryz /tri_diariesz /tri_diaries/cCstd}|s dSttdS)Nr)u@TRI diary not built yet — run /data/cameron/tri_diary/build.pyr&) TRI_DIARY_DIRrr)idxrrr tri_diariess rZ svg_editorz!/data/cameron/para/paper/figs/svgz /svg_editorz /svg_editor/cCr")Nz editor.htmlrSVG_EDITOR_DIRrrrrsvg_editor_indexs rz/svg_editor/static/cCttd|S)NZsvgeditr)rrrrsvg_editor_staticr,rz/svg_editor/filescCsBtddtdD}dd|D}dd|D}t||dS)Ncss|]}|jVqdSr)rvrrrrrqsz#svg_editor_files..z*.svgcSsg|] }|ds|qS _edited.svgendswithrrrrrz$svg_editor_files..cSsg|] }|dr|qSrrrrrrrr) originalsedited)rtSVG_SOURCE_DIRglobr )Zall_svgsrrrrrsvg_editor_filessrz/svg_editor/load/cCsBd|vs d|vs |dsdSt|}|sdSt|ddS)N..r.svg)bad namerE)z not foundr&z image/svg+xmlr)rrrr r8)fnamerrrrsvg_editor_loads rz/svg_editor/save/cCsd|vs d|vs |dstddidfS|dd}|dr%t|}nt|d }tjd d }||tt||jd S) NrrrrDrrEZ_editedrTr<)rKr) rr rrr?r>rTr|r)rstemoutrUrrrsvg_editor_saves     rz/paper_as_markdownz/paper_as_markdown/cCr) z8Render the paper outline as a collapsible markdown page.paper_as_markdownrfrrrrrrrrrrrrrrrz(/paper_as_markdown/media/cCr)Nrrr#r)rrrpaper_as_markdown_mediarrz//cCst|}|r t||SdS)Nrr)agentr* agent_dirrrr report_filer!rz //cCsPt|}|s dSt|ddd}|r"td|d|djSd|dS) Nrz*.htmlTrdrrz

    z

    No reports yet.

    )rrOrtrrrv)rrZreportsrrr agent_indexs ra >.mp4z.aviz.movrz.mkv>z.bmprrrz.gifrZ _thumb_cacheT)exist_ok) @`i@iiiiii full_pathrreturncCsF|}|d|jd|}t|dd}t|dS)N|r)r| st_mtime_ns_hashlibZsha1encode hexdigest_THUMB_CACHE_DIR)rrstrhrrr_thumb_cache_path+src Cst||}|r|jdkr|Sz:ddlm}||$}|d}|||f|j |j t |dddddWd |WS1sEwY|WSt y}z*z |r]| Wn tygYnwtjd |d |d |WYd }~d Sd }~ww) zUReturn a Path to a cached JPEG thumbnail (longest-edge = `size`), or None on failure.r)ImageZRGBZJPEGRTF)ZqualityZ progressiveoptimizeNzthumb failed for z @ z: )rrr|rZPILrr3ZconvertZ thumbnailZLANCZOSrrTrQrrSapploggerr)rrtprZimgrZrrr _ensure_thumb2s2      r file_pathc Csj|jtvr dSz!tjdddddddd d t|g d d d d }|j}|dvWSty4YdSw)zFCheck if a video uses a codec browsers can't play (e.g. mpeg4 part 2).FZffprobez-vquietz-select_streamszv:0z -show_entrieszstream=codec_namez-ofzcsv=p=0T)r>r?r)Zh264ZhevcZh265Zvp8Zvp9Zav1) rr VIDEO_EXTSrArBrTrCrzrQ)rr codecrrr_needs_transcodeJs   rz/tmp/para_transcode_cachecCs~ddl}|d|j}||d}t|}|s=tj ddt |ddd d d d d ddddt |dgddd|S)z;Return path to an H.264 transcoded version, cached on disk.rN:rZffmpegz-iz-c:vZlibx264z-presetZ ultrafastz-crfZ23z -movflagsz +faststartz-anz-fZmp4-yTrg)r>r) hashlibr|r}Zmd5rrTRANSCODE_CACHErrArBrT)rrrZ cache_namecachedrrr_get_transcoded`s rc CsXt|rt|}|j}tt|dpd}tj d}|r| dd }| d}|dr7t |dnd}|drCt |dn|d}t||d}||d}t|d} | || |} Wd n1snwYt| d |d } d |d|d || jd<t|| jd<d| jd<| Stt||d} d| jd<t|| jd<| S)zOServe a file with manual Range request support (works through tunnels/proxies).rzapplication/octet-streamZRangezbytes=rrgrrbNrrzbytes rz Content-RangezContent-Lengthrrr)rrr|r mimetypesZ guess_typerTrrr0rwrzrxrminr3seekreadr r r) r file_sizeZ mime_typeZ range_headerZ byte_rangerrrlengthrrresprrr _serve_fileqs2         rrel_pathcCs|j}t|j}d|dddd}|r!d|dnd}d|d}d|d|d|d |d |d |d |d |d|d|dS)zFServe an HTML page with an embedded video player instead of raw bytes.rN/browse/?raw a ��
    ← Back
    Loading  (z%)...
    Download
    )rv _human_sizer|rrrstriprx)rrrvrr2 parent_urlraw_urlrrr_video_player_pages4 $$4rcCs\|j}d|dddd}|rd|dnd}d|d}d|d|d|d S) z1Serve an HTML page with an embedded image viewer.rNrrrr a
    ← Back
    )rvrr rx)rrrvr2r rrrr_image_viewer_pages rnbytescCsPdD]}|dkr|dkr|dd|S|dS|d}q|ddS)N)BZKBZMBZGBrrz.1frhz Bz TBr)rZunitrrrr s *  r cCs~|dr |ddng}dg}t|D]\}}dd|d|dd}|d|d|dqdd |d S) Nrz$/data/cameronrrz z / z)rzrxrrr)rrZcrumbsrpartlinkrrr _breadcrumbs rz /data/libero /home/cameronsmith/mnt/robot-labz/home/cameronsmith/mnt/yukoncCsxdt|jvr dSt|}z|}Wn tyYdSwtD]}t|t|ks5t|t|dr9|Sq dS)zResolve `subpath` under BROWSE_ROOT, rejecting `..` traversal. Symlinks that resolve into any allowlisted root (e.g. /data/cameron/libero -> /data/libero) are accepted.rNr)rrrr rQ_BROWSE_ALLOWED_ROOTSrTry)subpath candidater rootrrrrN s  &rNz /browse_yamz /browse_yam/c CsTtd}z t|WtdSty)}zd|ddfWYd}~Sd}~ww)uLand on the YAM calibration QA folder served through the SSHFS mount. The mount is school-server → dev (Tailscale ProxyJump) → robot-lab. If puget is offline, the mount stalls. Triggers a stat() to surface that quickly. rzP

    YAM mount unavailable

    SSHFS to robot-lab (via puget) returned: z

    On the school server run:
    fusermount -u /home/cameronsmith/mnt/robot-lab && sshfs robot-lab:/home/robot-lab /home/cameronsmith/mnt/robot-lab -o reconnect,ServerAliveInterval=30

    Nz6/browse/yam_remote/cameron/yam_overlay/calibration_qa/)rrrurSr)ZmountrZrrr browse_yam srrz/browse/rcsPt|}|dur td|std|ro|j}tjddurYtjjdt drU|t vrUt vrAt t fdddt |}|durUt|}d |jd <|St|S|tvrbt||S|t vrkt||St|Sg}g}zt|d ddD]~}|j}|d rq~|r|d d |n|} |} t| jd} |r|d| d|d| dq~t| j |j}|tvrd} |d|d| fn|t vrd} |d|d| fnd} |d| d| d|dd| d q~Wnt!y tdYnwd} |rg}t"|D]2\}\}}}|d}|dkr:|d |d!|d|d"q|d#|d$|d|d"qd%d&t"|D}d}|rpd'#d(d)d*d)|$DD}d+|d,}d-t%|d.d#|d/|} |rd |d nd }d0|d1t&d2t'|d3|d4| d5d#|d6 }|S)7NrFr&rawrr7cs t|Sr)absrrrrrK rzbrowse..rzpublic, max-age=86400z Cache-ControlcSs||jfSr)rrvr)rrrrr] srrrkz8
  • 📁z/rmz 🎦videorz 🖼Zimagez 📄z
  • zzrrz
    .css"|] \}}d||fVqdS)vNr)rnrr&rrrrq s zz
    z
    z Browse zz z

    z

    z
      rr)(rNrrrrrrr\r0r IMAGE_EXTS_ALLOWED_THUMB_SIZESrrrrrrrrtrurvryr r|r r{r}r~rOrr rrrrrr BROWSE_STYLEr)rrrrrrZ media_filesrrvrr|dateZiconZ media_htmlZcardsrr!r"r#rZ video_mapZ load_scriptZ entries_jsZdir_nameZhtmlrrrbrowse4 s              r, localtunnelportrc Csddl} z|dkrZtdtjddddt|gtjtjdd }|jD]1}|}d |vs3d | vrTd |vr=| d n|}tddtd|tddq#| nZ|dkrtdtjdddd|gtjtjdd }|jD]8}|}d|vr| D])}d|vr| d r|nd|}tddtd|tddnqqw| Wnt y}z td|WYd}~nd}~wwtd|dq)z@Start a tunnel in background with auto-retry. Prints public URL.rNTr-z Starting localtunnel...Znpxr--port)rCrr?zloca.ltzyour urlhttprrjz<============================================================z PUBLIC URL: cloudflaredz Starting cloudflared tunnel...tunnelz--urlzhttp://localhost:z.trycloudflare.comztrycloudflare.comzhttps://zTunnel error: z&Tunnel disconnected, retrying in 5s...r)rIprintrAPopenrTPIPEZSTDOUTrCrzrrxwaitryrQrJ)r.rrIprocrr&ZwordrZrrr start_tunnel sb     r8z+/data/cameron/panda_data/single_demo_sanityik_cachez /inferencez /inference/z/inference/cCr)NZ inferencer#r)rrrinference_page sr:z/api/inference/episodescCsbtd}|stddidfSddl}t|}t||WdS1s*wYdS)NrrDno episodes.jsonr&r)PANDA_DATA_DIRrr rLr3load)ep_filerrrrrinference_episodes s  $r?z/api/inference/run_ikcCsDt}|dd}t|}|durtdd|didfSt|S)N frame_idxrrDzframe z not foundr&)rrMr0_run_ik_for_framer )rr@rErrrinference_run_ik s  rBz/api/inference/run_ik_episodec Cst}|dd}ddl}ttd}||d}Wdn1s&wY|t|kr9tddidfS||}g}t |d|d d d D] }t |}|rX| |qKtd |iS) NZ episode_idxrrrrDinvalid episoderErrrrHresults) rrMr0rLr3r<r=rr r|rAr) rep_idxrrrrrDrr rrrinference_run_ik_episode s     rFc5 Csddl}ddl}|d}t|d}t|d}|r"|s$dSt|d}t|d}t|d}|r|r|rddl} t| } | | } Wdn1s]wYtt d } | d |d| d <| d |d| d <| d |d| d<| Sz,ddl } ddl m }ddl }|jddtdddlm}ddlm}m}m}Wnty}z dt|iWYd}~Sd}~ww|gdgdgdgdg}|jgdgdgdg|jd}|gd}| j|j}| |}| || j!j"d}|t|#|j}|$|%t||j&}t'|dkr.|dnd}|dd|j(dd<|d |j(d<|j(d!<| )|||j*|+}|gd"}||j(dd<|d |j(d<|j(d!<| )||t,d#D]} |j*|+}!|j-|.d$d$+}"||!}#||"j/}$|0|1|2|$d%d&d'd%}%|%d(kr|3d$n$|%d&|4|%d)||$d*|$d+|$d,|$d-|$d.|$d/g}&|j56|#d0kr|j56|&d1krnj|3d$|j7f|3d$|j7f}'}(| 8|||'|(||9|#d2|&g})|:|'ddddfd2|(ddddfg}*|j5;|*j/|*d3||/d9kd&d:}0|+}1||0d;|/|0d<#|j?|1|0<|,|j(dd<|d |j(d<|j(d!<| )|||||||||||||||d7d8}2|j>|2d9kd&d:}3|+}4||3d;|2|3d<#|j?|4|3<|@t||$|A|1d=|jB|jCd>g|@t||$|A|4d=|jB|jCd>gddl} ||.|D|-Dt=||ddD|,Dd?} t|d@} | E| | Wdn 1shwYdA|d| d <dB|d| d <dB|d| d<| S)Cz4Run IK for a single frame, cache the overlay images.rN06d.npyrz_gt.jpgz_ik.jpgz _meta.jsonr rZrgb_pathz /ik_cache/Zgt_overlay_pathZik_overlay_path)Rotation"/data/cameron/para/panda_streamingPANDA_HANDEYE_4X2_CONFIGrender_from_camera_poseget_link_poses_from_robotposition_exoskeleton_meshesrDgS?gCH?g8$K?gp^ڿg̺=r?g,2ۿggvMiyu?ghݫɿg*i?g lPk޿gtUE}?rrrrr@r33333@r4@X@rrrZdtype?r_handr^{Gz?rpgQrdg +rdgA`"?gQ?r6rrHrư>绽|=rHrrrHrrHrHrrrrrMb@?MbP?rH-C6?皙皙?i8 Zaxis皙?333333?)rihU)r@Z pos_error_mmZ gt_eef_posZ ik_eef_posZgripperZ gt_joints ik_jointswz+panda_data/data_20260420_115853_632_frames/z4panda_data/data_20260420_115853_632_frames/ik_cache/)Fnumpycv2r<r _ik_cache_dirrLr3r=rT relative_tomujocoZscipy.spatial.transformrIrQrrRrchdir ExoConfigs.panda_exo_handeye_4x2rL exo_utilsrNrOrPrQarrayfloat64diagMjModelfrom_xml_stringxmlMjData mj_name2idmjtObj mjOBJ_BODYastypecvtColorimread COLOR_BGR2RGBrqpos mj_forwardxposcopyr|xmatreshapeTarccoscliptracezerossinlinalgnormnv mj_jacBody concatenatevstacksolveeyerruint8ZimwriteZresize COLOR_RGB2BGRIMWRITE_JPEG_QUALITYtolistdump)5r@npr}tsnpy_pathimg_pathZgt_cacher9Z meta_cacherrmetaZ_relrZRotrQrLrNrOrPrZZ T_CAM_WORLDZCAM_K FIXED_ROTr$mj_datahand_idjsrgbgwZgt_posHOME_QriZcur_poscur_rotZpos_errZR_errZangleZrot_errZjacpZjacrerrJdqZik_qZik_posZ pos_err_mmZ gt_renderZgt_maskZ gt_overlayZ ik_renderZik_maskZ ik_overlayrrrrA# s     "     "^$"2( $ $** rAz,/data/cameron/panda_data/fewdemo_bowl_pickup)single_demo_sanityZfewdemo_bowl_pickupz/api/inference/trajectory/loadcM sddl}ddl}ddl}ddl}t}|dd}|dd}|dd}|dd }t|} | s>td d |id fS| d } | sNtd didfSt | } | | d} Wdn1sdwY|t | krwtd did fS| |} ddl }ddl}|jddtdddlm}ddlm}m}m}|gdgdgdgdg|jgdgdgdg|jd|j|j}||}|||j j!d}fdd}t"t#| d | d!d"|}g}t$|D]E\}}g}g}g}t#|D]}}|||} | | d!kr| d!} | | d#d$}!|! s"n\| t%|!&|j}"t |"d%kr:t'|"d%nd&}#|"dd%|j(dd%<|#d'|j(d%<|j(d <|)|||j*|+}$||$}%|,|%rk|%nddg|,|$-|,|#q| |d#d(}&|& rb|.t%|&}'gd)}(t$t/||D]\})\}*}+t0|*dt0|*d"},}-|(|)t |(}.|)dkr|1|'|,|-fd*|.d+|1|'|,|-fd |.d,|2|'d-|+d.|,d/|-d0f|j3d1|.d2n |1|'|,|-fd3|.d,|2|'d4|)|,d5|-d+f|j3d6|.d"|)dkr1t0||)d"dt0||)d"d"}/}0|4|'|/|0f|,|-f|.d2q|2|'d7|d"d8t |d9|d:d;|j3d&dg\}1}2|7|28d?}3nd@}3|r|9gdA}4|gdB}5|5|j(dd%<|)||||d}6t#dCD]}1|j*|+}7|j:|;d+d+}8|6|7}9|4|8j<}:|=|>|?|:d"d2d,d"};|;dDkr|@d+n$|;d2|A|;dE||:dF|:dG|:dH|:dI|:dJ|:dKg}<|jBC|9dLkr|jBC|<dMkrnh|@d+|jDf|@d+|jDf}=}>|E|||=|>||F|=dddd%fdN|>dddd%fg}?|G|9dN|<g}@|jBH|?j<|?dO|Id%|?j<|@}A|j(dd%|>|AdPdQ7<|)||q|rk|dnd&}B|Bd'|j(d%<|j(d <|)|||||||||||||dRdS}C|& r|.t%|&}D|jJ|Cd3kd2dT}E|K|D|jL}F|F|E&t'dU|C|E&t'dV&|jM|F|E<|j*|+}G||G}H|Hrt0|Hdt0|Hd"}I}J|1|F|I|JfdWdXd,|2|FdY|Bd.d:d;|j3d&dXd2|5d=|K|F|jN|j6d>g\}1}K|7|K8d?}Lnd@}Lnd@}L|,||||||3|L|r2|j(dd%-nddZqt||| d | d!||t ||d[S)\zHLoad a GT trajectory: compute 2D keypoints + 3D positions for all steps.rNdatasetrepisodewindowstriderprDzunknown dataset: rErr;r&rrCrJrKrMrQrRrSrTrUrXr[r\r`csddddf|dddf}|ddkrdStd|d|ddtd|d|ddgS) NrerHrrrrjrrrri)r)posp_cam T_cam_worldZcam_Krrproject s (""z trajectory_load..projectrrrrGrHrar^rbr))dr)r2)rr6r)r6rr)rrr)rr6rrrerzNEXT g=z.2frgffffff?rHruzt+ g?zStep rz (frame ))r()rrrrPasciirr]rcr6rfrgrhrirjrkrlrmrnrorHrprqrrrsrtrvrwrxrrrzIK target (grip=)stepr@ keypoints_2d keypoints_3dgrippersZkp_imgZik_imgrz)rrZep_startZep_endrrZn_stepssteps)Or|rLr}base64rrMr0 DATASET_PATHSr rr3r=rrrQrrRrrrrLrrNrOrPrrrrrrrrrrr|rrTrrrrrrrrrziprcircleZputTextZFONT_HERSHEY_SIMPLEXrimencoder b64encodedecoderrrrrrrrrrrrrrrrrrrrrr)Mrrr}rrZ dataset_idrErrZdpathr>rrrrrQrLrNrOrPmj_modelrrrZ frame_indicesrsiZfidxrrrrZ future_idxrrrZeefZpixrrZcolorsZkiZkpgvur'ZcolorZpuZpvribufZ kp_img_b64rrZtgtZcurrZpeZReZangrZjpZjrrrrZgw0renderedZbase_rgbmaskZik_visZep_posZep_pixeuZevZbuf2Z ik_img_b64rrrtrajectory_load s.          "          *$    "^("2(    0   rcs`tdur tr tSddlddlddlddlddlGfddd}|atS)Nrcs<eZdZfddZddZddZfddZd S) z$_get_live_stream..LiveStreamcs<d|_d|_|_d|_j|jdd|_|jdS)NTrDdaemon) latest_frame_b64 latest_jointsZLocklock_runningThread_run_threadrself) threadingrr__init__q s  z-_get_live_stream..LiveStream.__init__cSs|jo|jSr)ris_aliverrrrrry sz-_get_live_stream..LiveStream.is_alivecSs d|_dS)NF)rrrrrstop| s z)_get_live_stream..LiveStream.stopc' sddl}tddfdd}z |d|jddd }||js*|d WdS|d fd d }||dd}||jdjd_ d_ ddl fdd}j |dd}| ddl}ddl} | jddtdddlm} ddlm} m} m} gdgdgdgdg}d}d}jd |dd!||gdd"|d#|ggd$gjd}|j| j}||}| ||j!j"d%}|d&d}j#rj$j%}j &}j }Wdn1swY|dur|dkr|d'd(}'d)q|dkr|d*|d}t(d+D] }|||j)|<q |*||| | ||| | ||| ||||d,d,}+|j,}j-|d-kd.d/}|&}||.t/d0||.t/d1.j||<|j0|&}|dd2dd2f||dd2d2f}|d.dkrt1|d3|d|d.|d4} t1|d5|d6|d.|d7}!d| krd,krnnd|!krd,krnn 2|| |!fd8d9d(3d:+|j4j5d;g\}"}#6|#7d<}$j$ |$_8Wdn 1s wY'd=j#sWdSWdSt9yD}%z|d>|%ddl:}&|&j;d?<WYd}%~%dSd}%~%ww)@Nrz/tmp/livestream_debug.logr{cs.|dtd|dddS)Nrjz [LiveStream] T)flush)rrr3)msg)_lfrr_log sz7_get_live_stream..LiveStream._run.._logz Starting...Z localhosti#)hostr.zFailed to connect to rosbridgezConnected to rosbridgecsp|dg}|dg}tt||fddtddD}j |_WddS1s1wYdS)NrvZpositioncsg|] }d|dqS)Z fr3_jointr)r0)rnrZpos_dictrrr szP_get_live_stream..LiveStream._run..on_joints..rrp)r0rrr|rr)rnamesZ positionsqrrr on_joints s  "z<_get_live_stream..LiveStream._run..on_jointsz /joint_stateszsensor_msgs/msg/JointState)rrer\FcsjrQz:jjddd}|}j|jd}|j}|dur<j|_ d_ Wdn1s7wYWn t yFYnw djsdSdS)Nzhttp://localhost:8877/frame.jpgr)rr\T皙?) rrZurlopenrZ frombufferrZimdecodeZ IMREAD_COLORr _raw_frame _has_camerarQrJ)rZ img_bytesZimg_arrr)r}rrrIurllibrrcamera_fetch_loop s"  zD_get_live_stream..LiveStream._run..camera_fetch_loopTrrJrKrMrQrRrSrTg@z@gŨoS?rVrWrYrZr[r`zMuJoCo loaded, streaming...zWaiting for joint states...rgQ?zGot joints! has_camera=rarrurHrvrwrxrerrjrrrirprrKrrzError: )r)=roslibpyr3ZRosrBZ is_connectedZTopicZ subscriberrrrZurllib.requestrrrrQrrRrrrrLrrNrOrPrrrrrrrrrrrrrrJr|rrrrrrrrrrrrrrrrrQ traceback print_excr)'rrrrrZ joint_subrZ cam_threadrrQrLrNrOrPrZ_crop_x0Z_sZ cam_K_448rrrZ _frame_countjointsrZhas_camrrrrZoverlayZeef_posrrr'rirb64rZr rr}rrrI)rrrrr s                0($$8 4*z)_get_live_stream..LiveStream._runN)__name__ __module__ __qualname__rrrrrr rr LiveStreamp s  r) _live_streamrr|r}rrrI)rrr r_get_live_streami s(rz/api/inference/live/startcCs"t}td|r diSdiS)NrZstartedZfailed)rr r)streamrrr live_start srz/api/inference/live/framecCsxtduststddidfStjtj}tj}Wdn1s$wY|dur5tddidfSt||dS)NrDzstream not startedrz no frame yet)rr )rrr rrr)r r rrr live_frame srz/api/inference/live/stopcCstrtdatddiS)NrZstopped)rrr rrrr live_stop s rz100.104.232.94i#i# target_urlc sddl}tj}ddtjD}z|j||||dkrtnddddd }Wn"|jjyI}ztd |d |d d ddWYd}~Sd}~wwhdfdd|j jD}t|j dd|j |dS)zStream a request to target_url and yield the response. Preserves headers, streams the body so gRPC-Web trailers/chunks pass through.rNcSs"i|] \}}|dvr||qS))rzcontent-lengthrrnrr'rrrr$< s z!_stream_proxy..r4T)rNF)rrrrZallow_redirectsz$Rerun proxy: puget not reachable at r riz text/plainr>zcontent-encodingZ connectionztransfer-encodingz keep-alivecs$g|]\}}|vr||fqSrrrZexcludedrrrK s z!_stream_proxy..i )Z chunk_size)rr) requestsrrrrr? exceptionsZRequestExceptionr rZ iter_contentZ status_code)rrrrZupstreamrZZ resp_headersrrr _stream_proxy7 s0  rz /rerun_pugetr)r4r:r)defaultsr5z /rerun_puget/z/rerun_puget/cC6dtdtd|}tjr|dtj7}t|S)uMProxy the rerun web viewer SPA from puget:9092 → omidlab.net/rerun_puget/*.http://rr?)_RERUN_PUGET_HOST_RERUN_VIEWER_PORTr query_stringrrrrDrrrrerun_viewer_proxyT sr'z /rerun_proxyz /rerun_proxy/z/rerun_proxy/cCr )uProxy the rerun gRPC-Web data stream from puget:9093 → omidlab.net/rerun_proxy/*. The rerun viewer SPA reads the ?url=rerun+/ query param at load time and connects to this endpoint for the data stream. r!rrr"r#_RERUN_STREAM_PORTrr%rrr&rrrrerun_grpc_proxy_ s r*/proxyz/proxy/z/proxy/cCsDdtdtd}|r|d|7}tjr|dtj7}t|S)Nr!rr+rr"r(r&rrrrerun_grpc_proxy_rootr s r,__main__r/i)rdefaultz--public store_truezCreate public URL via tunnel)actionhelpz--tunnelr1)r.choices)rDr\rz$Serving reports at http://localhost:z0.0.0.0F)rr.debug)rr)r)r)r-)__doc__argparserArQrrWrr/rrrrrrr r r rrr%r __file__r2rrrrZ after_requestrZbefore_requestrZrouter r$r'r+r1r7r2r3r9r@r[r]rbrsrrrrrrrr __import__compilerrrrrrZ wandb_runsrrrrrrrrrrrrrrr r&r(r)r,r5rFrLrPrVrYr^r`rjrrrrrrr@r*rrrrrrrrrrrrrrrrrrrrrrrr*rr(rrrmkdirr)rrrboolrrrrrTrrr rr rrNrr,r8r<r~r:r?rBrFrArrrrrrrr#r$r)rr'r*r,ArgumentParserparser add_argument parse_argsr\Zpublicrr.r2Z tunnel_threadrr3rBrrrrs6  ,            #   '  O q     Q =    :             3     ]   m               !     $ A      3       < $