LumeWeb
/
skynet-webportal
Archived
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

better error handling

This commit is contained in:
Karol Wypchlo 2021-03-01 17:19:13 +01:00
parent 46fd77a2e2
commit 0d8b50e5a2
1 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
setup-scripts/blocklist-airtable.py
View File

@ -15,8 +15,13 @@ async def block_skylinks_from_airtable():
headers = { "Authorization": "Bearer " + AIRTABLE_API_KEY } headers = { "Authorization": "Bearer " + AIRTABLE_API_KEY }
airtable = requests.get( airtable = requests.get(
"https://api.airtable.com/v0/" + AIRTABLE_TABLE + "/Table%201?fields%5B%5D=" + AIRTABLE_FIELD, headers=headers "https://api.airtable.com/v0/" + AIRTABLE_TABLE + "/Table%201?fields%5B%5D=" + AIRTABLE_FIELD, headers=headers
).json() )
skylinks = [entry['fields'][AIRTABLE_FIELD] for entry in airtable['records']]
if airtable.status_code != 200:
message = "Airtable blocklist integration responded with code " + str(response.status_code) + ": " + (response.text or "empty response")
return print(message) and await send_msg(client, message, force_notify=False)
skylinks = [entry['fields'][AIRTABLE_FIELD] for entry in airtable.json()['records']]
print("Airtable returned " + str(len(skylinks)) + " skylinks to block") print("Airtable returned " + str(len(skylinks)) + " skylinks to block")
apipassword = os.popen('docker exec sia cat /sia-data/apipassword').read().strip() apipassword = os.popen('docker exec sia cat /sia-data/apipassword').read().strip()
@ -32,7 +37,7 @@ async def block_skylinks_from_airtable():
print("Skylinks successfully added to siad blocklist") print("Skylinks successfully added to siad blocklist")
else: else:
message = "Siad blocklist endpoint responded with code " + str(response.status_code) + ": " + (response.text or "empty response") message = "Siad blocklist endpoint responded with code " + str(response.status_code) + ": " + (response.text or "empty response")
await send_msg(client, message, force_notify=False) await print(message) and send_msg(client, message, force_notify=False)
async def exit_after(delay): async def exit_after(delay):
await asyncio.sleep(delay) await asyncio.sleep(delay)