From 6a8b9e7ceb5a7d0fb4b6f4dc674704c62090971c Mon Sep 17 00:00:00 2001 From: Karol Wypchlo Date: Mon, 1 Mar 2021 16:47:06 +0100 Subject: [PATCH] airtable blocklist integration --- setup-scripts/blocklist-airtable.py | 41 +++++++++++++++++++++++++++++ 1 file changed, 41 insertions(+) create mode 100755 setup-scripts/blocklist-airtable.py diff --git a/setup-scripts/blocklist-airtable.py b/setup-scripts/blocklist-airtable.py new file mode 100755 index 00000000..cf98ab00 --- /dev/null +++ b/setup-scripts/blocklist-airtable.py @@ -0,0 +1,41 @@ +#!/usr/bin/env python3 + +import os, asyncio, requests, json + +AIRTABLE_TABLE = "app89plJvA9EqTJEc" +AIRTABLE_FIELD = "Link" + +async def block_skylinks_from_airtable(): + headers = { "Authorization": "Bearer " + AIRTABLE_API_KEY } + airtable = requests.get( + "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']] + + apipassword = os.popen('docker exec sia cat /sia-data/apipassword').read().strip() + ipaddress = os.popen('docker inspect -f \'{{range.NetworkSettings.Networks}}{{.IPAddress}}{{end}}\' sia').read().strip() + + headers = { 'user-agent': 'Sia-Agent' } + auth = ('', apipassword) + data = json.dumps({ 'add': skylinks }) + response = requests.post('http://' + ipaddress + ':9980/skynet/blocklist', auth = auth, headers = headers, data = data) + + if response.status_code != 204: + message = "Blocklist responded with code " + str(response.status_code) + ": " + (response.text or "empty response") + print(message) + +async def exit_after(delay): + await asyncio.sleep(delay) + os._exit(0) + +async def on_ready(): + await block_skylinks_from_airtable() + asyncio.create_task(exit_after(3)) + +asyncio.run(on_ready()) + +# --- BASH EQUIVALENT +# skylinks=$(curl "https://api.airtable.com/v0/${AIRTABLE_TABLE}/Table%201?fields%5B%5D=Link" -H "Authorization: Bearer ${AIRTABLE_KEY}" | python3 -c "import sys, json; print('[\"' + '\",\"'.join([entry['fields']['Link'] for entry in json.load(sys.stdin)['records']]) + '\"]')") +# apipassword=$(docker exec sia cat /sia-data/apipassword) +# ipaddress=$(docker inspect -f '{{range.NetworkSettings.Networks}}{{.IPAddress}}{{end}}' sia) +# curl -A "Sia-Agent" --user "":"${apipassword}" --data "{\"add\" : ${skylinks}}" "${ipaddress}:9980/skynet/blocklist"