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:
    print("PARSE_FAIL"); print(out[-1500:]); sys.exit(0)
if not d.get("ok"):
    print("NOTOK",d.get("error"),d.get("retry_after_seconds")); sys.exit(0)
json.dump(d,open("/tmp/pa_%s.json"%q.replace(" ","_"),"w"))
print("query=",q,"result_count=",d.get("result_count"))
for r in d["results"][:6]:
    print("---")
    print(" auth:",r["author_name"],"|",(r.get("author_headline") or "")[:110])
    print(" url:",r.get("post_url"),"aid:",r.get("activity_id"))
    print(" age:",r.get("age_hours"),"rx:",r["reactions"],"cm:",r["comments"],"rp:",r["reposts"])
    print(" txt:",(r.get("post_text") or "")[:260].replace("\n"," "))