start_job.py

import requests, time

base = "http://localhost:8081"
payload = "eJzdVtty2zYQ/Rc8SyxxI0C9xXYcN03Tie3EuUzGA5IQxYgkHJCq7Xj0712KF0mUGEcz7rTjN2KBXSzOOTzAA8pNpAs0+fKAkghNUDhTSX7Nw3AaMDRC5f2NbqMwvDFFUiYmR5MHdIcmYyqJgwn2fC5dQj1KR+gewkw6kvoeJa7LfCKkx5YjFKlSVXmpCnQKNY+bmkmm4moP57fVLk7xdwzRXGW6WwTZRXmfQuABPqfGZidNsbqxCVJFocuzRQCZq89qrilx8tdlG/29OiGFUXGfBSZtJqGkiiKrC4AB8bPoXL0vZpevzLtTVZrX4ir2L+axOHpz/G36Wn3gH/zvn96a7+fix/QjP6pKZ2aRw46IwCDSqQII8kWajlBo8lKFZT2EbW6TqJyhCWFshGY6iWcwxRiGfnSqw1JDe1OVFhrKWBXHSR53gRb5F0Fh0kWpD2dgOWooho6g0HVIsWB8zXEd3kMypw7lgvgSCy6xxP5qC8y547lMCsyp8DEVYg/HTc1h/poFE3R3aVVeTLWtAF0Ft5dc1k1uLivMwob6Zyro+H46freUs0U3nKxUNq6113Y0XxQqU9erbmbbjdUS2ejs9A0/f/G+vJt9/BSZP1+d5285s/HVH5+Jopm5e3kx//ZZ5af2LA6uTi/eoeVyQ1Kuu5YUYd4eSQ0p6BB6t1XZKao2DY9jJvWjpuF7nkOkdJnrMeF7hNSKla7DuZQ+9RlziXDpf2gZfZqeyiFqyp/IIgb4PATen9KJOZaRepROMBcHugWFuJDBXMnqDbF0KCOYC18IQnywpn+b0CQvta2g3SW0nTox5Sa32K1+m+HLYPPn509n7gPMHYbkAHetuUeYKvq4uXtEOAKE4bqSyFYs2HMY8VwMUdjXY/h/YO19ctf0DdPVJ3bXnvddGDu+fOj//qu+XNrFsBgOIKanhK8jpKN46E037t/+LdQ7L78GrJ3nQks3fFgzrzJjq3W+mqkCV83JobVM2bm2L/OoWt4q0Vpz21+Ml51SiyS7SXWgfyQrJbRyaz8vZub2KG7Bq0NtQ4EK57EFAUTHJjW262wlzBBu4qBaV2XufwuNe8bXQbPzYmqx6Sc8J2g2zzbu20pPNeu7oq+aLuE5QbN1uHHv9bOjms6Kt1WzTngO0Hxd/gOReYZ/"

#print("Creating scenario..")
#xx = requests.post(base+"/saveUrl", json={"url": payload})
#print("Response: ")
#print(xx.text)
#s = xx.json()
scenario_id = "LSm-41cJY"#"+DN*1Cug4"#s.get('shortUrl', 'not found')
#print("Scenario id saved as:", scenario_id)

print("Starting job: ")
#js = requests.post(base+"/job/start", json={"id": scenario_id})
#print("start job response:", js.json())
print("sleeping for 10 seconds.. ")
time.sleep(10)
print("Quering logs for ", scenario_id)
logs = requests.post(base+"/scenario/worker/logs", json={"id": scenario_id})
print("Logs returned: ", logs.text)
print("sleeping for 10 seconds.. ")
time.sleep(13)

print("quering /scenario/get_filter_log")
## Query custom log:
 #curl -X POST -H "Content-Type: application/json" -d '{"id": "LSm-41cJY", "log_type": "query"}' http://localhost:8081/scenario/get_filter_logs
query = requests.post(base+"/scenario/get_filter_logs", json={"id": scenario_id, "log_type": "query"})
print("[query]Logs returned: ", query.text)


#{"success":true,"result":["Starting worker","Decoding payload..","Parsed scenario data","Making http request: Url: https://example.com Method: post","Building http request","Building ChainNode request","Drafting xTransfer tx from polkadot to assetHub"]}


## Query for the transaction que 
txmempool = requests.post(base+"/scenario/tx", json={"id": scenario_id})

print("Getting transaction queue: ", txmempool.text)