import json,pathlib,time,requests,os
P=pathlib.Path(__file__).parent
cats=json.load(open(P/'categories.json'))['categories']
state={'company':'Cloudflare','lens':'customer','as_of':'2026-10-02','purpose':'Private Reese application sample, not investment advice or a model benchmark','evidence':[{'url':'https://blog.cloudflare.com/clef-decision-models/','facts':['Cloudflare released Clef and Clef Flash hosted on Workers AI on October 1 2026.','Open weights Apache 2.0; System One API compatible.','Multimodal decision models with 64k context.','Fine tuning initially FDE-assisted, self-service platform planned.']},{'url':'https://developers.cloudflare.com/workers-ai/models/clef-flash/','facts':['Clef Flash 9B decision model.','Price $0.09 per million input tokens.','Up to 64 typed questions; up to 4 embedded images.']}],'missing':['financial statements','customer retention','current revenue and margins','independent reliability evidence','team biographies','customer-specific requirements','market sizing','competitor adoption'],'restrictions':['Do not guess missing facts.','These company claims are not independent validation.','No personal portfolio, order or user private data.']}
questions={c['id']:{'type':'score','instructions':c['instructions']+' This is a limited public product-doc snapshot. Do not treat product claims as evidence of company finances, traction, team quality or investor suitability. Missing evidence is not a negative company verdict.','criteria':[x['description'] for x in c['levels']]} for c in cats}
questions['next_step']={'type':'choice','instructions':'Choose the best next action for this customer-lens sample based only on stated evidence and gaps. No purchase or deployment is authorized.','criteria':{'TEST':'Evaluate API compatibility and quality on a labeled private customer workload before adopting','ADOPT_NOW':'Commit to production immediately without evaluation','REJECT':'Reject the product without testing'}}
request={'model':os.environ['INFERENCE_MODEL'],'state':state,'questions':questions}
(P/'request.json').write_text(json.dumps(request,indent=2));token=os.environ['RESTRUCTURE_API_KEY']
# Accept a plain credential from the process environment.
try:
 x=json.loads(token)
 if isinstance(x,str):token=x
 elif isinstance(x,dict):token=x.get('result',x.get('value',token))
except:pass
assert isinstance(token,str) and len(token)>10
r=requests.post(os.environ['INFERENCE_ENDPOINT'],headers={'Authorization':'Bearer '+token},json=request,timeout=30)
r.raise_for_status()
# Results stay on the caller's machine. This repository publishes no vendor performance evaluation.
(P/'private-output.json').write_text(json.dumps(r.json(),indent=2))
print('Private decision output saved locally. Do not commit private-output.json.')