aboutsummaryrefslogtreecommitdiff
path: root/examples/auto_follower_webhook.py
diff options
context:
space:
mode:
authorOliver <zen@noreply.codeberg.org>2025-07-16 20:21:20 +0200
committerOliver <zen@noreply.codeberg.org>2025-07-16 20:21:20 +0200
commit3554a73aa50526631961efcca78c6c8eb2a16911 (patch)
treefc4c21a65337ab8ecb4fb00aa551ee21997faf6f /examples/auto_follower_webhook.py
parentd6973cf43adfd67000e76eed26fadea7c265a09c (diff)
parenta2518f5d70b19f9cafd860bd6cde22399c452b60 (diff)
Merge pull request 'master' (#9) from grunfink/snac2:master into master
Reviewed-on: https://codeberg.org/zen/snac2/pulls/9
Diffstat (limited to 'examples/auto_follower_webhook.py')
-rwxr-xr-xexamples/auto_follower_webhook.py55
1 files changed, 55 insertions, 0 deletions
diff --git a/examples/auto_follower_webhook.py b/examples/auto_follower_webhook.py
new file mode 100755
index 0000000..eb632a3
--- /dev/null
+++ b/examples/auto_follower_webhook.py
@@ -0,0 +1,55 @@
+#!/usr/bin/env python3
+
+# This is an example of a snac webhook that automatically follows all new followers.
+
+# To use it, configure the user webhook to be http://localhost:12345, and run this program.
+
+# copyright (C) 2025 grunfink et al. / MIT license
+
+from http.server import BaseHTTPRequestHandler, HTTPServer
+import time
+import json
+import os
+
+host_name = "localhost"
+server_port = 12345
+
+class SnacAutoResponderServer(BaseHTTPRequestHandler):
+
+ def do_POST(self):
+ self.send_response(200)
+ self.end_headers()
+
+ content_type = self.headers["content-type"]
+ content_length = int(self.headers["content-length"])
+ payload = self.rfile.read(content_length).decode("utf-8")
+
+ if content_type == "application/json":
+ try:
+ noti = json.loads(payload)
+
+ type = noti["type"]
+
+ if type == "Follow":
+ actor = noti["actor"]
+ uid = noti["uid"]
+ basedir = noti["basedir"]
+
+ cmd = "snac follow %s %s %s" % (basedir, uid, actor)
+
+ os.system(cmd)
+
+ except:
+ print("Error parsing notification")
+
+if __name__ == "__main__":
+ webServer = HTTPServer((host_name, server_port), SnacAutoResponderServer)
+ print("Webhook started http://%s:%s" % (host_name, server_port))
+
+ try:
+ webServer.serve_forever()
+ except KeyboardInterrupt:
+ pass
+
+ webServer.server_close()
+ print("Webhook stopped.")