import sys, os, json, urllib.request
from dotenv import load_dotenv; load_dotenv(".env")
import mysql.connector
cid = sys.argv[1]
c = mysql.connector.connect(host=os.getenv("MYSQL_HOST","localhost"), port=int(os.getenv("MYSQL_PORT","3306")), user=os.environ["MYSQL_USERNAME"], password=os.environ["MYSQL_PASSWORD"], database=os.getenv("MYSQL_DATABASE"))
cur = c.cursor(); cur.execute("SELECT rx_response FROM connectivity_requests WHERE consultation_id=%s", (cid,))
body = cur.fetchone()[0]
body = body if isinstance(body, (bytes, str)) else json.dumps(body)
body = body.encode() if isinstance(body, str) else body
print("shipmentCode:", json.loads(body).get("shipmentCode"), "status:", json.loads(body).get("status"))
req = urllib.request.Request("http://127.0.0.1:8012/webhook/1rx", data=body, headers={"Content-Type": "application/json"})
try:
    r = urllib.request.urlopen(req, timeout=90); print("HTTP", r.status, r.read()[:300])
except urllib.error.HTTPError as e:
    print("HTTP", e.code, e.read()[:300])