| 7719 | `,"utf8")}catch(V6){N(`Hooks: Prompt request handling failed: ${V6}`),B.stdin.destroy()}});continue}}catch{}}}if(!t){let l=ce(U).trim();if(!l.includes("}"))return;t=!0,N(`Hooks: Checking first line for async: ${l}`);try{let A6=r8(l);if(N(`Hooks: Parsed initial response: ${g6(A6)}`),rb(A6)&&!H){let J6=`async_hook_${B.pid}`;if(N(`Hooks: Detected async hook, backgrounding process ${J6}`),GgK({processId:J6,hookId:$,shellCommand:C,asyncResponse:A6,hookEvent:K,hookName:_,command:q.command,pluginId:w}))g=!0,q6?.({stdout:U,stderr:c,output:K6,status:0})}else if(rb(A6)&&H)N("Hooks: Detected async hook but forceSyncExecution is true, waiting for completion");else N("Hooks: Initial response is not async, continuing normal processing")}catch(A6){N(`Hooks: Failed to parse initial response as JSON: ${A6}`)}}}),B.stderr.on("data",(n)=>{c+=n,K6+=n});let j6=KB8({hookId:$,hookName:_,hookEvent:K,getOutput:async()=>({stdout:U,stderr:c,output:K6})}),G6=new Promise((n)=>{B.stdout.on("end",()=>n())}),w6=new Promise((n)=>{B.stderr.on("end",()=>n())}),o=F?Promise.resolve():new Promise((n,l)=>{if(B.stdin.on("error",(A6)=>{if(!J)l(A6);else N(`Hooks: stdin error during prompt flow (likely process exited): ${A6}`)}),B.stdin.write(z+` |
| 7722 | `);n({stdout:J6,stderr:c,output:K6,status:l,aborted:Y.aborted})})})});try{if(M)c8("info","hook_spawn_started",{hook_event_name:K,index:A});await Promise.race([o,s]);let n=await Promise.race([e,a,s]);return await $6,P=n.status,W=n.aborted??!1,n}catch(n){let l=s1(n);if(P=1,l==="EPIPE"){N("EPIPE error while writing to hook stdin (hook command likely closed early)");let A6="Hook command closed stdin before hook input was fully written (EPIPE)";return{stdout:"",stderr:A6,output:A6,status:1}}else if(l==="ABORT_ERR")return W=!0,{stdout:"",stderr:"Hook cancelled",output:"Hook cancelled",status:1,aborted:!0};else{let J6=`Error occurred while executing hook command: ${d6(n)}`;return{stdout:"",stderr:J6,output:J6,status:1}}}finally{if(M)c8("info","hook_spawn_completed",{hook_event_name:K,index:A,duration_ms:Date.now()-X,exit_code:P,aborted:W});if(j6(),!g)C.cleanup()}}function lhY(q,K){if(!K||K==="*")return!0;if(/^[a-zA-Z0-9_|]+$/.test(K)){if(K.includes("|"))return K.split("|").map((z)=>Zf(z.trim())).includes(q);return q===Zf(K)}try{let _=new RegExp(K);if(_.test(q))return!0;for(let z of $S7(q))if(_.test(z))return!0;return!1}catch{return N(`Invalid regex pattern in hook matcher: ${K}`),!1}}async function nhY(q,K){if(q.hook_event_name!=="PreToolUse"&&q.hook_event_name!=="PostToolUse"&&q.hook_event_name!=="PostToolUseFailure"&&q.hook_event_name!=="PermissionRequest")return;let _=Zf(q.tool_name),z=K&&L5(K,q.tool_name),Y=z?.inputSchema.safeParse(q.tool_input),$=Y?.success&&z?.preparePermissionMatcher?await z.preparePermissionMatcher(Y.data):void 0;return(A)=>{let O=G2(A);if(Zf(O.toolName)!==_)return!1;if(!O.ruleContent)return!0;return $?$(O.ruleContent):!1}}function NgK(q){return q.hook.type==="callback"&&q.hook.internal===!0}function RQ8(q,K){return`${q.pluginRoot??q.skillRoot??""}\x00${K}`}function ygK(q){let K=q.filter((z)=>z.pluginId);if(K.length===0)return;let _={};for(let z of K){let Y=z.pluginId.lastIndexOf("@"),A=Y>0&&_I.has(z.pluginId.slice(Y+1))?z.pluginId:"third-party";_[A]=(_[A]||0)+1}return _}function EgK(q){let K={};for(let _ of q)K[_.hook.type]=(K[_.hook.type]||0)+1;return K}function ihY(q,K,_){let z=[...bQ()?.[_]??[]],Y=fb(),$=sR()?.[_];if($)for(let A of $){if(Y&&"pluginRoot"in A)continue;z.push(A)}if(!Y&&q!==void 0){let A=HL8(q,K,_).get(_);if(A)for(let w of A)z.push(w);let O=Gb4(q,K,_).get(_);if(O)for(let w of O)z.push(w)}return z}function iS6(q,K,_){let z=bQ()?.[q];if(z&&z.length>0)return!0;let Y=sR()?.[q];if(Y&&Y.length>0)return!0;if(K?.sessionHooks.get(_)?.hooks[q])return!0;return!1}async function O_7(q,K,_,z,Y){try{let $=ihY(q,K,_),A=void 0;switch(z.hook_event_name){case"PreToolUse":case"PostToolUse":case"PostToolUseFailure":case"PermissionRequest":case"PermissionDenied":A=z.tool_name;break;case"SessionStart":A=z.source;break;case"Setup":A=z.trigger;break;case"PreCompact":case"PostCompact":A=z.trigger;break;case"Notification":A=z.notification_type;break;case"SessionEnd":A=z.reason;break;case"StopFailure":A=z.error;break;case"SubagentStart":A=z.agent_type;break;case"SubagentStop":A=z.agent_type;break;case"TeammateIdle":case"TaskCreated":case"TaskCompleted":break;case"Elicitation":A=z.mcp_server_name;break;case"ElicitationResult":A=z.mcp_server_name;break;case"ConfigChange":A=z.source;break;case"InstructionsLoaded":A=z.load_reason;break;case"FileChanged":A=dhY(z.file_path);break;default:break}N(`Getting matching hook commands for ${_} with query: ${A}`,{level:"verbose"}),N(`Found ${$.length} hook matchers in settings`,{level:"verbose"});let w=(A?$.filter((v)=>!v.matcher||lhY(A,v.matcher)):$).flatMap((v)=>{let V="pluginRoot"in v?v.pluginRoot:void 0,E="pluginId"in v?v.pluginId:void 0,S="skillRoot"in v?v.skillRoot:void 0,R=V?"pluginName"in v?`plugin:${v.pluginName}`:"plugin":S?"skillName"in v?`skill:${v.skillName}`:"skill":"settings";return v.hooks.map((x)=>({hook:x,pluginRoot:V,pluginId:E,skillRoot:S,hookSource:R}))});if(w.every((v)=>v.hook.type==="callback"||v.hook.type==="function"))return w;let j=(v)=>v.if??"",H=Array.from(new Map(w.filter((v)=>v.hook.type==="command").map((v)=>[RQ8(v,`${v.hook.shell??zD6}\x00${v.hook.command}\x00${j(v.hook)}`),v])).values()),J=Array.from(new Map(w.filter((v)=>v.hook.type==="prompt").map((v)=>[RQ8(v,`${v.hook.prompt}\x00${j(v.hook)}`),v])).values()),M=Array.from(new Map(w.filter((v)=>v.hook.type==="agent").map((v)=>[RQ8(v,`${v.hook.prompt}\x00${j(v.hook)}`),v])).values()),X=Array.from(new Map(w.filter((v)=>v.hook.type==="http").map((v)=>[RQ8(v,`${v.hook.url}\x00${j(v.hook)}`),v])).values()),P=w.filter((v)=>v.hook.type==="callback"),W=w.filter((v)=>v.hook.type==="function"),D=[...H,...J,...M,...X,...P,...W],G=D.some((v)=>(v.hook.type==="command"||v.hook.type==="prompt"||v.hook.type==="agent"||v.hook.type==="http")&&v.hook.if)?await nhY(z,Y):void 0,Z=D.filter((v)=>{if(v.hook.type!=="command"&&v.hook.type!=="prompt"&&v.hook.type!=="agent"&&v.hook.type!=="http")return!0;let V=v.hook.if;if(!V)return!0;if(!G)return N(`Hook if condition "${V}" cannot be evaluated for non-tool event ${z.hook_event_name}`),!1;if(G(V))return!0;return N(`Skipping hook due to if condition "${V}" not matching`),!1}),T=_==="SessionStart"||_==="Setup"?Z.filter((v)=>{if(v.hook.type==="http")return N(`Skipping HTTP hook ${v.hook.url} — HTTP hooks are not supported for ${_}`),!1;return!0}):Z;return N(`Matched ${T.length} unique hooks for query "${A||"no match query"}" (${w.length} before deduplication)`,{level:"verbose"}),T}catch{return[]}}function z87(q,K){return`${q} hook error: ${K.blockingError}`}function G87(q){return`Stop hook feedback: |