o iB@sFdZddlZddlZddlZddlZddlZddlZddlZddl Zddl m Z m Z m Z ddl mZdZdZdZdZd Zd Zd Zd Zd ZedZdZdZddZddZddZddZddZddZ ddZ!dd Z"d!d"Z#d#d$Z$d%d&Z%d'd(Z&d)d*Z'd+d,Z(d-d.Z)d/d0Z*d1d2Z+d3d4Z,d5d6Z-e.d7kre-dSdS)8u MRAV Call Watcher — Phase 2C Watches calls.jsonl for completed calls, extracts structured items via Claude, routes each item to the correct tool, sends Telegram confirmation. Runs via system cron every 2 minutes. N)datetimetimezone timedelta)ZoneInfoz0/home/isthekid/.openclaw/voice-calls/calls.jsonlzB/home/isthekid/.openclaw/workspace/scripts/call-watcher-state.jsonz&/home/isthekid/.openclaw/openclaw.jsonz0/home/isthekid/.openclaw/voice-calls/extractionsz./home/isthekid/.openclaw/secrets/anthropic.envz3/home/isthekid/.openclaw/workspace/action/data.jsonz)/home/isthekid/.openclaw/workspace/memoryzsrvdeskops@gmail.comprimaryzAmerica/New_Yorkzclaude-sonnet-4-6uWYou are a structured data extractor. Below is a transcript of a phone call between Adner and his voice assistant MRAV. Extract all actionable items into JSON. Rules: - Every item must have a unique id (format: "item-001", "item-002", etc.) - Classify each item as exactly one type: task, calendar_event, note, decision, follow_up - For calendar_event: extract date and time if mentioned. If only a day name is given (e.g. "Friday"), resolve it to the next occurrence from today's date: {TODAY} - For follow_up: extract a follow-up date if mentioned - If anything is ambiguous or you can't confidently classify it, put it in the "ambiguous" array - Do not invent items that weren't discussed - Ignore greetings, sign-offs, and small talk — only extract actionable content - Respond with ONLY valid JSON, no preamble, no markdown fences JSON format: {{ "call_id": "{CALL_ID}", "timestamp": "{CALL_TIMESTAMP}", "duration_seconds": {DURATION}, "items": [ {{ "id": "item-001", "type": "task", "content": "Call Jerry about the permit renewal", "priority": "normal", "due": null }}, {{ "id": "item-002", "type": "calendar_event", "content": "Meeting with Erika", "date": "2026-03-07", "time": "15:00", "duration_minutes": 30 }} ], "ambiguous": [] }} Transcript: {TRANSCRIPT}cCsrtt }|}Wdn1swYtd|}td|}|s*td|d|r6|dfSdfS)Nz"([0-9]{8,10}:AA[A-Za-z0-9_-]{33,})z"id"\s*:\s*"?(8340647700)"?z-Telegram bot token not found in openclaw.json 8340647700)openOPENCLAW_CONFIGreadresearch ValueErrorgroup)fraw token_match chat_matchr:/home/isthekid/.openclaw/workspace/scripts/call-watcher.pyget_telegram_credentialsKs    rcCstjdd}|r |StjtrOtt2}|D]$}|}|dr<| dddddWdSqWdt d 1sJwYt d ) z/Get Anthropic API key from env or secrets file.ANTHROPIC_API_KEYzANTHROPIC_API_KEY==r"'Nz:ANTHROPIC_API_KEY not found in environment or secrets file) osenvirongetpathexistsANTHROPIC_SECRETSr strip startswithsplitr)keyrlinerrrget_anthropic_keyUs    " r'cCsFtjtrtt }t|WdS1swYdgiS)Nprocessed_call_ids)rrr STATE_FILEr jsonload)rrrr load_statecs   r,cCs@ttd}tj||ddWddS1swYdS)Nwindent)r r)r*dump)staterrrr save_statejs "r3cCsHtdt||d}|d}|d}|dkr|d|dS|dS)Nr<z min z sec)maxint)start_msend_ms total_secminutessecondsrrrformat_durationos  r=cC$tj|dtjdt}|dS)Nr4tzz%B %-d, %Y %-I:%M %p ESTr fromtimestamprutc astimezoneTIMEZONEstrftimets_msdtrrrformat_timestampx rJcCr>)Nr4r?z%b %-d, %-I:%M %prArGrrrformat_timestamp_short}rKrLcCs:|r|sdS|}tdd|D}|t|dkS)uJFilter out noise artifacts — require at least 50% ASCII printable chars.Fcss(|]}t|dkr|rdVqdS)rN)ord isprintable.0crrr s&z*is_recognizable_english..g?)r"sumlen)text ascii_charsrrris_recognizable_englishs rXcCshg}|D]*}|ds q|dd}t|sq|ddkr"dnd}||d|qd |S) z4Format transcript as readable text, filtering noise.isFinalrVrspeakeruserAdnerMRAV:  )rr"rXappendjoin) transcriptlinesentryrVrZrrrformat_transcripts  recCsttdd|dgdd}tjjd|d|dd d d }tjj|d d }t| }Wdn1s8wY|ddd }t dd|}t dd|}| S)z,Call Anthropic API and return response text.ir[)rolecontent)model max_tokensmessagesutf-8z%https://api.anthropic.com/v1/messagesapplication/jsonz 2023-06-01) Content-Typez x-api-keyzanthropic-versionPOSTdataheadersmethodtimeoutNrgrrVz^```(?:json)?\s*rz\s*```$) r*dumpsANTHROPIC_MODELencodeurllibrequestRequesturlopenloadsr r"r sub)api_keypromptpayloadreqrespresultrVrrrcall_anthropics.  rcCszt||ddd}tjjd|d|ddidd }tjj|d d }t|WdS1s6wYdS) NHTML)chat_idrV parse_moderkzhttps://api.telegram.org/botz /sendMessagermrlrnro rt) r*rvrxryrzr{r|r}r ) bot_tokenrrVrrrrrr send_telegrams   $rc Cs|dg}|dg}|d}d|d|d}|s |s d}nyg} t|dD]l\} } | d d } | d d } d }| d kr]| dd }| dd }|sM|r\|rWd|d|nd|}n'| dkrt| dpk| dd }|rsd|}n| dkr| d}|rd|}| | d| d| |q'd| }d }|rdd|D}dd|}nd}td|d}d|d}||||S) z6Format extracted items as a readable Telegram message.items ambiguouscallIdu📞 Call extracted (u — z) zNo actionable items found.rtype?rgrcalendar_eventdatetime @ follow_updueu — due taskz. [z] r_cSs"g|] }d|dt|qS)u • rg)rstr)rQarrr s"z-format_extraction_message..u ⚠️ Ambiguous: z Ambiguous: none/.jsonu Raw JSON → z)r enumerater`raEXTRACTIONS_DIR) extractioncall duration_str time_shortrrcall_idheaderbodyrciitemtrgextrarrr amb_section amb_lines save_pathfooterrrrformat_extraction_messagesH            rcCsdtj|}tjd|ddd}tj||dd|j}Wdn1s%wYt ||dS)zCWrite JSON atomically using temp file + rename to avoid corruption.r-z.tmpF)dirsuffixdeleter.r/N) rrdirnametempfileNamedTemporaryFiler*r1nameshutilmove)robjdir_rtmp_pathrrratomic_write_jsons rc Csztt }t|}Wdn1swY|d}|dkr%dnd}ttd}t d }d|d |}||d d d |d d |dpW|dpWdgdgd|dd} d} |dgD]} | d|kr| dgd| d} nqj| s|dr|dd dgd| tt|dd|d| dfWSty} z dd| fWYd} ~ Sd} ~ ww)z:Add a new card to action/data.json. Returns (ok, message).Nrrwaitingdo_nowz %Y%m%d%H%M%Sr.zmrav--rgz Untitled taskz MRAV CaptureprioritynormalrrmravzCaptured via voice call ())idtitlearearr nextActionstagsstatusFcolumnsrcardsrTuBoard card added → r^rz Board error: )r ACTION_DATAr*r+rrnowrErFrurandomhex capitalize setdefaultinsertr Exception) rcall_timestamp_shortrrp item_type target_coltsrandcard_idcardinsertedcolerrrroute_board_cardsD        rc Cs.z}|dd}|d}|dd}|dd}|sWdS|d |d }t|jtd }|tt|d }|} |} tj d ddt dt d|d| d| dd|ddgdddd} | j dkrpdd| j pk| jfWSdd|d|d |fWSty} z dd| fWYd!} ~ Sd!} ~ ww)"zBCreate a Google Calendar event via gog CLI. Returns (ok, message).rgEventrrz09:00duration_minutesrs)Fz"Calendar skipped: no date providedTz:00)tzinfo)r;gogcalendarcreatez --accountz --summaryz--fromz--toz --descriptionzCaptured via MRAV voice call (rz --no-inputT)capture_outputrVrurFzCalendar error: zCalendar event created: z on rN)rr fromisoformatreplacerErr7 isoformat subprocessrunGOG_CALENDAR_IDGOG_CALENDAR_ACCOUNT returncodestderrr"stdoutr) rrsummaryrtime_ duration_min start_strstart_dtend_dtfrom_rfcto_rfcrrrrrroute_calendar_event)s<       rc Cszittd}tjt|d}|dd }|dd}ttd}d|d |d |d |d }tj td dt |d }| |Wdn1sTwYd d| d|ddfWSty} z dd| fWYd} ~ Sd} ~ ww)zFAppend note or decision to today's memory file. Returns (ok, message).%Y-%m-%dz.mdrnotergrz %-I:%M %pu ## MRAV Capture — z **z (via voice call, z):** r_Texist_okrNzMemory logged (z): r5FzMemory error: )rrrErFrrra MEMORY_DIRrrmakedirsr writelowerr) rrtodaymem_filerrgtime_nowrdrrrrr route_memoryRs    "rcCsN|d}|dvrt||S|dkrt||S|dvr t||Sdd|fS)z2Route a single extracted item to the correct tool.r)rrr)rdecisionFzUnknown type: )rrrr)rrrrrr route_itemhs    rc CstjtsgSi}tt5}|D]*}|}|sqzt|}|dr0|d}|r0|||<Wqtj y;YqwWdn1sFwYt | S)NendedAtr) rrr CALLS_JSONLr r"r*r}rJSONDecodeErrorlistvalues)seenrr&recordcidrrrread_completed_callsus*      rc st}t|dgzt\}}Wnty,}ztd|WYd}~dSd}~wwzt}WntyL}ztd|WYd}~dSd}~wwtjt ddt t  d}t}fdd|D}|D]g}|d } z |d d } |d d } td t| | d } t| | } t| }t| }t|dg}|std| d| Wqjtj|| || |d}td| dt||}t|}tjt | d}t|d}tj||ddWdn1swYg}|dgD] }t ||\}}|!|||ftd|rdndd|q|dgD]}|dt"|}t#||d|d q$g}|D]\}}}|rHd!nd"}|!|d#|q>|r^d$|nd%}t$||| |}|d&|7}t#|||td'| WnPtj%y}ztd(| d|t#||d)| d*WYd}~n-d}~wty}ztd+| d|t#||d)| d,|WYd}~nd}~ww| qjt&|d<t'|dS)-Nr(z+[call-watcher] Telegram credentials error: z$[call-watcher] Anthropic key error: Trrcsg|] }|dvr|qS)rrrP processedrrrszmain..r startedAtrrr4rbz([call-watcher] No usable transcript for z, skipping extraction)TODAYCALL_IDCALL_TIMESTAMPDURATION TRANSCRIPTz[call-watcher] Extracting z...rr-r.r/rz[call-watcher] Route u✓u✗r^rrgu;⚠️ MRAV — ambiguous item needs clarification: z Reply to route it manually.u✅u❌ r_zNo items to route.z Routed: z0[call-watcher] Extracted, routed, and notified: z$[call-watcher] JSON parse error for u+⚠️ Call watcher: extraction failed for z Error: Claude returned non-JSONz [call-watcher] Error processing z Error: )(r,setrrrprintr'rrrrrrErFrr6r7r=rLrJrer"addEXTRACTION_PROMPTformatrr*r}rrar r1rr`rrrr r r3) r2rrr anthropic_keyrcompleted_calls new_callsrrstartedended duration_secrrcall_timestamptranscript_textrraw_jsonrrrrouting_resultsrokmsg_rambrg routed_linesicon routing_blockmsgrrrmains                r0__main__)/__doc__r*rr rrrurllib.requestry urllib.parserrrzoneinforr r)r rr!rrrrrErwrrr'r,r3r=rJrLrXrerrrrrrrrrr0__name__rrrrsZ +   - /) c