import json,subprocess,sys,os
q=sys.argv[1]
env=dict(os.environ); env["SOCIAL_AUTOPOSTER_LINKEDIN_SEARCH"]="1"
p=subprocess.run(["/opt/homebrew/bin/python3.11","scripts/discover_linkedin_candidates.py","content",q],capture_output=True,text=True,env=env)
out=p.stdout
i=out.find("{")
try: d=json.loads(out[i:])
except Exception as e:
    print(json.dumps({"query":q,"ok":False,"error":"parse","raw":out[-500:]})); sys.exit()
if not d.get("ok"):
    print(json.dumps({"query":q,"ok":False,"error":d.get("error"),"result_count":0})); sys.exit()
res=d.get("results",[])
slim=[{"n":r.get("author_name"),"h":(r.get("author_headline") or "")[:110],"t":(r.get("post_text") or "")[:260],"a":round(r.get("age_hours") or 0,1),"rx":r.get("reactions"),"c":r.get("comments"),"rp":r.get("reposts"),"aid":r.get("activity_id"),"u":r.get("author_profile_url")} for r in res[:8]]
print(json.dumps({"query":q,"ok":True,"result_count":d.get("result_count"),"top":slim},ensure_ascii=False))
