]> git.mxchange.org Git - fba.git/commitdiff
Continued:
authorRoland Häder <roland@mxchange.org>
Mon, 29 May 2023 19:05:16 +0000 (21:05 +0200)
committerRoland Häder <roland@mxchange.org>
Mon, 29 May 2023 19:08:45 +0000 (21:08 +0200)
- added .json to all JSON responses
- added response class JSONResponse (I hope it is not overstated this way?
- cleaned up imports a bit (only used once can be referenced directly)

api.py

diff --git a/api.py b/api.py
index 7b18ead8947b0e798ae1c31a4d77672c44cdfa1f..520cad0fc88b2639af158868bf0db7094a83e58f 100644 (file)
--- a/api.py
+++ b/api.py
@@ -14,7 +14,8 @@
 # You should have received a copy of the GNU Affero General Public License
 # along with this program.  If not, see <https://www.gnu.org/licenses/>.
 
-from fastapi import Request, HTTPException, responses, Query
+from fastapi import Request, HTTPException, Query
+from fastapi.responses import JSONResponse
 from fastapi.responses import PlainTextResponse
 from fastapi.templating import Jinja2Templates
 from datetime import datetime
@@ -29,7 +30,7 @@ import fba
 router = fastapi.FastAPI(docs_url=fba.config["base_url"] + "/docs", redoc_url=fba.config["base_url"] + "/redoc")
 templates = Jinja2Templates(directory="templates")
 
-@router.get(fba.config["base_url"] + "/api/info")
+@router.get(fba.config["base_url"] + "/api/info.json", response_class=JSONResponse)
 def info():
     fba.cursor.execute("SELECT (SELECT COUNT(domain) FROM instances), (SELECT COUNT(domain) FROM instances WHERE software IN ('pleroma', 'mastodon', 'misskey', 'gotosocial', 'friendica', 'bookwyrm', 'takahe', 'peertube')), (SELECT COUNT(blocker) FROM blocks), (SELECT COUNT(domain) FROM instances WHERE last_status_code IS NOT NULL)")
     known, indexed, blocks, errorous = fba.cursor.fetchone()
@@ -42,7 +43,7 @@ def info():
         "slogan"            : fba.config["slogan"]
     }
 
-@router.get(fba.config["base_url"] + "/api/top")
+@router.get(fba.config["base_url"] + "/api/top.json", response_class=JSONResponse)
 def top(blocked: int = None, blockers: int = None, reference: int = None, software: int = None):
     if blocked != None:
         if blocked > 500:
@@ -75,7 +76,7 @@ def top(blocked: int = None, blockers: int = None, reference: int = None, softwa
 
     return scoreboard
 
-@router.get(fba.config["base_url"] + "/api")
+@router.get(fba.config["base_url"] + "/api/index.json", response_class=JSONResponse)
 def blocked(domain: str = None, reason: str = None, reverse: str = None):
     if domain == None and reason == None and reverse == None:
         raise HTTPException(status_code=400, detail="No filter specified")
@@ -113,18 +114,42 @@ def blocked(domain: str = None, reason: str = None, reverse: str = None):
 
     return result
 
+@router.get(fba.config["base_url"] + "/api/mutual.json", response_class=JSONResponse)
+def mutual(domains: list[str] = Query()):
+    """Return 200 if federation is open between the two, 4xx otherwise"""
+    fba.cursor.execute(
+        "SELECT block_level FROM blocks " \
+        "WHERE ((blocker = :a OR blocker = :b) AND (blocked = :b OR blocked = :a OR blocked = :aw OR blocked = :bw)) " \
+        "AND block_level = 'reject' " \
+        "LIMIT 1",
+        {
+            "a" : domains[0],
+            "b" : domains[1],
+            "aw": "*." + domains[0],
+            "bw": "*." + domains[1],
+        },
+    )
+    res = fba.cursor.fetchone()
+
+    if res is not None:
+        # Blocks found
+        return JSONResponse(status_code=418, content={})
+
+    # No known blocks
+    return JSONResponse(status_code=200, content={})
+
 @router.get(fba.config["base_url"] + "/scoreboard")
 def index(request: Request, blockers: int = None, blocked: int = None, reference: int = None, software: int = None):
     scores = None
 
     if blockers != None and blockers > 0:
-        res = requests.get(f"http://{fba.config['host']}:{fba.config['port']}{fba.config['base_url']}/api/top?blockers={blockers}")
+        res = requests.get(f"http://{fba.config['host']}:{fba.config['port']}{fba.config['base_url']}/api/top.json?blockers={blockers}")
     elif blocked != None and blocked > 0:
-        res = requests.get(f"http://{fba.config['host']}:{fba.config['port']}{fba.config['base_url']}/api/top?blocked={blocked}")
+        res = requests.get(f"http://{fba.config['host']}:{fba.config['port']}{fba.config['base_url']}/api/top.json?blocked={blocked}")
     elif reference != None and reference > 0:
-        res = requests.get(f"http://{fba.config['host']}:{fba.config['port']}{fba.config['base_url']}/api/top?reference={reference}")
+        res = requests.get(f"http://{fba.config['host']}:{fba.config['port']}{fba.config['base_url']}/api/top.json?reference={reference}")
     elif software != None and software > 0:
-        res = requests.get(f"http://{fba.config['host']}:{fba.config['port']}{fba.config['base_url']}/api/top?software={software}")
+        res = requests.get(f"http://{fba.config['host']}:{fba.config['port']}{fba.config['base_url']}/api/top.json?software={software}")
     else:
         raise HTTPException(status_code=400, detail="No filter specified")
 
@@ -148,24 +173,24 @@ def index(request: Request, blockers: int = None, blocked: int = None, reference
 @router.get(fba.config["base_url"] + "/")
 def index(request: Request, domain: str = None, reason: str = None, reverse: str = None):
     if domain == "" or reason == "" or reverse == "":
-        return responses.RedirectResponse("/")
+        return fastapi.responses.RedirectResponse("/")
 
     info = None
     blocks = None
 
     if domain == None and reason == None and reverse == None:
-        info = requests.get(f"http://{fba.config['host']}:{fba.config['port']}{fba.config['base_url']}/api/info")
+        info = requests.get(f"http://{fba.config['host']}:{fba.config['port']}{fba.config['base_url']}/api/info.json")
 
         if not info.ok:
             raise HTTPException(status_code=info.status_code, detail=info.text)
 
         info = info.json()
     elif domain != None:
-        blocks = requests.get(f"http://{fba.config['host']}:{fba.config['port']}{fba.config['base_url']}/api?domain={domain}")
+        blocks = requests.get(f"http://{fba.config['host']}:{fba.config['port']}{fba.config['base_url']}/api/index.json?domain={domain}")
     elif reason != None:
-        blocks = requests.get(f"http://{fba.config['host']}:{fba.config['port']}{fba.config['base_url']}/api?reason={reason}")
+        blocks = requests.get(f"http://{fba.config['host']}:{fba.config['port']}{fba.config['base_url']}/api/index.json?reason={reason}")
     elif reverse != None:
-        blocks = requests.get(f"http://{fba.config['host']}:{fba.config['port']}{fba.config['base_url']}/api?reverse={reverse}")
+        blocks = requests.get(f"http://{fba.config['host']}:{fba.config['port']}{fba.config['base_url']}/api/index.json?reverse={reverse}")
 
     if blocks != None:
         if not blocks.ok:
@@ -185,30 +210,6 @@ def index(request: Request, domain: str = None, reason: str = None, reverse: str
         "info"   : info
     })
 
-@router.get(fba.config["base_url"] + "/api/mutual")
-def mutual(domains: list[str] = Query()):
-    """Return 200 if federation is open between the two, 4xx otherwise"""
-    fba.cursor.execute(
-        "SELECT block_level FROM blocks " \
-        "WHERE ((blocker = :a OR blocker = :b) AND (blocked = :b OR blocked = :a OR blocked = :aw OR blocked = :bw)) " \
-        "AND block_level = 'reject' " \
-        "LIMIT 1",
-        {
-            "a" : domains[0],
-            "b" : domains[1],
-            "aw": "*." + domains[0],
-            "bw": "*." + domains[1],
-        },
-    )
-    res = fba.cursor.fetchone()
-
-    if res is not None:
-        # Blocks found
-        return responses.JSONResponse(status_code=418, content={})
-
-    # No known blocks
-    return responses.JSONResponse(status_code=200, content={})
-
 @router.get(fba.config["base_url"] + "/rss")
 def rss(request: Request, domain: str = None):
     if domain != None:
@@ -253,8 +254,6 @@ def robots(request: Request):
     return templates.TemplateResponse("robots.txt", {
         "request" : request,
         "base_url": fba.config["base_url"]
-    }, headers={
-        "Content-Type": "text/plain"
     })
 
 if __name__ == "__main__":