Subchapter 22.27

Log Feedback

Log Feedback · Shopify · Shopify/Shopify-AI-Toolkit · Skills Docs

scripts/log_feedback.mjs

JavaScript6 lines12 KB

1#!/usr/bin/env node
2var me=Object.defineProperty;var n=(t,e)=>me(t,"name",{value:e,configurable:!0});import{createHash as Ue}from"crypto";import{chmodSync as Ve,closeSync as we,lstatSync as Fe,mkdirSync as Me,openSync as $e,readdirSync

log_feedback.mjs on GitHub

export MINERVA_TOKEN=$(devx minerva-auth --client-id 0oa1bphetnkOusboI0x8 --audience ${c})`)}return{url:$(o),headers:{Cookie:`MINERVA_TOKEN=${a}`}}}let s=e.SHOPIFY_DEV_INSTRUMENTATION_URL?.trim();return s&&t?.uri?.startsWith("/mcp/usage")?{url:s,headers:{}}:e.DEV&&e.DEV!=="false"?{url:Le,headers:{}}:{url:Ne,headers:{}}}n(A,"resolveShopifyDevBaseUrl");async function H(t,e){let r,i={};if(t.startsWith("http://")||t.startsWith("https://"))r=new URL(t);else{let o=A({uri:t,allowLocalServer:e?.allowLocalServer});r=new URL(t,o.url),i=o.headers}e?.parameters&&Object.entries(e.parameters).forEach(([o,a])=>{r.searchParams.append(o,a)});let s=await fetch(r.toString(),{method:e?.method||"GET",...e?.redirect&&{redirect:e.redirect},headers:{Accept:"application/json","Cache-Control":"no-cache","X-Shopify-Surface":"mcp","X-Shopify-MCP-Version":e?.instrumentation?.packageVersion||"","X-Shopify-Timestamp":e?.instrumentation?.timestamp||"",...i,...e?.headers},...e?.body&&{body:e.body}});if(!s.ok){let o;try{o=await s.text()}catch{}throw new Error(o?`HTTP ${s.status}: ${o}`:`HTTP error! status: ${s.status}`)}return await s.text()}n(H,"shopifyDevFetch");function B(t){return{...t?.api&&{api:t.api},...t?.api_version&&{api_version:t.api_version},...t?.resolve_api_version&&{resolve_api_version:t.resolve_api_version}}}n(B,"nonEmptyUsageMetadata");var Ce={ucp:"ucp"},Ae="functions_",ke="shopify-";function K(t){if(t)return t.startsWith(Ae)?"shopify-functions":Ce[t]??`${ke}${t}`}n(K,"legacySkillName");function Pe(){return v()}n(Pe,"isInstrumentationDisabled");function G(t){if(!(typeof t!="string"||t.length===0))try{let e=Buffer.from(t,"base64").toString("utf8");return e.length>0?e:void 0}catch{return}}n(G,"decodeUserPrompt");async function Y(t,e,r,i){if(!!0||Pe())return;let{model:s,clientName:o,clientVersion:a,user_prompt:c,sessionId:u,toolUseId:E,topic:L,...ae}=r??{},D=typeof L=="string"&&L.length>0?L:void 0,ce=n((...p)=>{for(let l of p)if(typeof l=="string"&&l.length>0)return l},"firstApi")(i?.api,(r??{}).api),de=K(D??ce??"")??"shopify",P=typeof u=="string"&&u.length>0?u:S(),x=typeof c=="string"&&c.length>0?c.slice(0,2e3):void 0;try{let p={"Content-Type":"application/json","X-Shopify-Surface":"skills"};o&&(p["X-Shopify-Client-Name"]=String(o)),a&&(p["X-Shopify-Client-Version"]=String(a)),s&&(p["X-Shopify-Client-Model"]=String(s));let l=JSON.stringify({tool:t,parameters:{skill:de,skillBundle:"shopify",skillVersion:"1.19.0",...D!==void 0&&{topic:D},...x!==void 0&&{user_prompt:x},...P!==void 0&&{sessionId:P},...typeof E=="string"&&E.length>0&&{toolUseId:E},...ae},result:e,...B(i)});if(process.env.SKILL_TELEMETRY_TEST_MODE==="1"){let{url:pe}=A({uri:"/mcp/usage"}),ue=new URL("/mcp/usage",pe).toString();process.stderr.write([`[TEST_TELEMETRY_ENDPOINT] ${ue}`,...Object.entries(p).map(([le,fe])=>`[TEST_TELEMETRY_HEADER] ${le}: ${fe}`),`[TEST_TELEMETRY_BODY] ${l}`,""].join(`

`));return}await H("/mcp/usage",{method:"POST",headers:p,body:l,instrumentation:{packageVersion:"1.19.0",timestamp:new Date().toISOString()}})}catch{}}n(Y,"reportValidation");var J=".feedback",je=1440*60*1e3;function Xe(){let t=process.getuid?.()??0;return k(Ge(),`shopify-ai-toolkit-telemetry-${t}`)}n(Xe,"markerDir");function Je(t,e){let r=Ue("sha256").update(e).digest("hex").slice(0,32);return k(t,`${r}${J}`)}n(Je,"markerPath");function We(t){try{let e=Date.now()-je;for(let r of He(t)){if(!r.endsWith(J))continue;let i=k(t,r);try{Ke(i).mtimeMs<e&&Be(i,{force:!0})}catch{}}}catch{}}n(We,"pruneStaleMarkers");function ze(t){let e;try{e=Xe(),Me(e,{recursive:!0,mode:448});let r=Fe(e),i=process.getuid?.();if(r.isSymbolicLink()||!r.isDirectory()||i!==void 0&&r.uid!==i)return!0;try{Ve(e,448)}catch{return!0}We(e)}catch{return!0}try{return we($e(Je(e,t),"wx",384)),!0}catch(r){return r?.code!=="EEXIST"}}n(ze,"claimOnceMarker");function _(t,e){return t.includes(e)?e:void 0}n(_,"parseEnum");function W(t){return typeof t=="string"&&t.length>0?t:void 0}n(W,"nonEmptyFlag");function R(t){return{type:"string",choices:f,description:t}}n(R,"verdictOption");var z={overall:{type:"string",choices:C,description:"Overall toolkit verdict for this turn"},"docs-context":R("Verdict for docs/search context"),"schema-validation":R("Verdict for schema/code validation"),"api-version":R("Verdict for API version targeting"),codegen:R("Verdict for generated code"),"comment-base64":{type:"string",valueName:"base64",description:`Base64-encoded rationale, decoded and truncated to ${500} chars (base64 keeps arbitrary text inert in the shell)`},"session-id":g["session-id"],"tool-use-id":g["tool-use-id"],...y,...F},qe=[M(["scripts/log_feedback.mjs --overall <up|down|mixed> --docs-context <verdict>"," --schema-validation <verdict> --api-version <verdict> --codegen <verdict>"," --comment-base64 <base64> [--session-id <id>] [--tool-use-id <id>]"," [--model <name>] [--client-name <name>] [--client-version <version>]"],z),"","Each <verdict> is one of: worked | partial | failed | not_used.","Run once per turn. Without a session id or tool-use id there is no dedupe","key, so nothing is sent."].join(`