From: pwm <pwm@crlf.ninja>
Date: Sun, 26 Feb 2023 21:23:35 +0000 (-0600)
Subject: Add api endpoint to test if there are blocks between two domains. Added an index... 
X-Git-Url: https://git.mxchange.org/?a=commitdiff_plain;h=e4caf63d48037c1d5597155e68d82993c56bb9f1;p=fba.git

Add api endpoint to test if there are blocks between two domains. Added an index to cover the query.
---

diff --git a/api.py b/api.py
index f2742ed..43086fd 100644
--- a/api.py
+++ b/api.py
@@ -1,5 +1,5 @@
 import uvicorn
-from fastapi import FastAPI, Request, HTTPException, responses
+from fastapi import FastAPI, Request, HTTPException, responses, Query
 import sqlite3
 from hashlib import sha256
 from fastapi.templating import Jinja2Templates
@@ -129,5 +129,29 @@ def index(request: Request, domain: str = None, reason: str = None, reverse: str
 
     return templates.TemplateResponse("index.html", {"request": request, "domain": domain, "blocks": blocks, "reason": reason, "reverse": reverse, "info": info})
 
+@app.get(base_url+"/api/mutual")
+def mutual(domains: list[str] = Query()):
+    """Return 200 if federation is open between the two, 4xx otherwise"""
+    conn = sqlite3.connect('blocks.db')
+    c = conn.cursor()
+    c.execute(
+        "SELECT block_level FROM blocks " \
+        "WHERE ((blocker = :a OR blocker = :b) AND (blocked = :b OR blocked = :a)) " \
+        "AND block_level = 'reject' " \
+        "LIMIT 1",
+        {
+            "a": domains[0],
+            "b": domains[1],
+        },
+    )
+    res = c.fetchone()
+    c.close()
+    if res is not None:
+        # Blocks found
+        return responses.JSONResponse(status_code=418, content={})
+    # No known blocks
+    return responses.JSONResponse(status_code=200, content={})
+
 if __name__ == "__main__":
     uvicorn.run("api:app", host="127.0.0.1", port=port, log_level="info")
+
diff --git a/blocks_empty.db b/blocks_empty.db
index 6ebc131..f823480 100644
Binary files a/blocks_empty.db and b/blocks_empty.db differ