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

clear nginx cache

This commit is contained in:
Karol Wypchlo 2021-03-01 17:56:30 +01:00
parent 1c9bdd4dc6
commit 0677e7c933
1 changed files with 13 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -22,6 +22,10 @@ async def block_skylinks_from_airtable():
return print(message) or await send_msg(client, message, force_notify=True) return print(message) or await send_msg(client, message, force_notify=True)
skylinks = [entry['fields'][AIRTABLE_FIELD] for entry in airtable.json()['records']] skylinks = [entry['fields'][AIRTABLE_FIELD] for entry in airtable.json()['records']]
if len(skylinks) == 0:
return print("Airtable returned 0 skylinks to block - make sure your table configuration is correct")
else:
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()
@ -34,11 +38,18 @@ async def block_skylinks_from_airtable():
response = requests.post('http://' + ipaddress + ':9980/skynet/blocklist', auth = auth, headers = headers, data = data) response = requests.post('http://' + ipaddress + ':9980/skynet/blocklist', auth = auth, headers = headers, data = data)
if response.status_code == 204: if response.status_code == 204:
return 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")
return await print(message) or send_msg(client, message, force_notify=True) return await print(message) or send_msg(client, message, force_notify=True)
print("Clearing nginx cache related to blocked skylinks")
find_all_cache_files = '/usr/bin/find /data/nginx/cache/ -type f'
grep_pattern = '^KEY: .*(' + '|'.join(skylinks) + ')'
filter_matching_files = '/usr/bin/xargs --no-run-if-empty -n1000 /bin/grep -El ' + grep_pattern
print('docker exec -it nginx bash -c "' + find_all_cache_files + ' | ' + filter_matching_files + '"')
os.popen('docker exec -it nginx bash -c "' + find_all_cache_files + ' | ' + filter_matching_files + '"')
async def exit_after(delay): async def exit_after(delay):
await asyncio.sleep(delay) await asyncio.sleep(delay)
os._exit(0) os._exit(0)