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

purging script

This commit is contained in:
Karol Wypchlo 2021-03-01 18:39:43 +01:00
parent ea8ccba3fa
commit 5473468dc8
1 changed files with 10 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -41,12 +41,18 @@ 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")
return await print(message) or send_msg(client, message, force_notify=True) return print(message) or await send_msg(client, message, force_notify=True)
print("Purging nginx cache containing blocked skylinks") print("Purging nginx cache containing blocked skylinks")
purge_command = '/usr/bin/find /data/nginx/cache/ -type f | /usr/bin/xargs --no-run-if-empty -n1000 /bin/grep -El \'^KEY: .*(' + '|'.join(skylinks) + ')\'' cached_files_command = '/usr/bin/find /data/nginx/cache/ -type f | /usr/bin/xargs --no-run-if-empty -n1000 /bin/grep -El \'^KEY: .*(' + '|'.join(skylinks) + ')\''
cached_files = os.popen('docker exec -it nginx bash -c "' + purge_command + '"').read().strip() cached_files_count = int(os.popen('docker exec -it nginx bash -c "' + cached_files_command + ' | wc -l"').read().strip())
print(cached_files)
if cached_files_count == 0:
return print("No nginx cached files matching blocked skylinks were found")
os.popen('docker exec -it nginx bash -c "' + cached_files_command + ' | xargs rm"')
message = "Purged " + str(cached_files_count) + " blocklisted files from nginx cache")
return print(message) or await send_msg(client, message)
async def exit_after(delay): async def exit_after(delay):
await asyncio.sleep(delay) await asyncio.sleep(delay)