jpt/scrapple
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

API keys and httpx

Browse Source
This commit is contained in:
James Turk 2025-01-10 17:23:03 -06:00
parent 6780b4d638
commit f4aaa31d00
2 changed files with 27 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
requirements.txt
View File

@ -4,3 +4,4 @@ itsdangerous==2.1.2
Jinja2==3.1.2 Jinja2==3.1.2
MarkupSafe==2.1.1 MarkupSafe==2.1.1
Werkzeug==2.2.2 Werkzeug==2.2.2
httpx==0.28.1

39
scrapple/hearings.py
View File

@ -4,8 +4,30 @@ import pathlib
from . import app from . import app
from flask import request, abort from flask import request, abort
BASE_API_URL = "https://scrapple.fly.io/hearings/house/118/" BASE_API_URL = "https://scrapple.fly.io/hearings/"
BASE_DIR = pathlib.Path("data/congress-hearing-118-house") BASE_DIR = pathlib.Path("data/congress-hearing-118-house")
# not actually secret, but for testing API Keys
API_SECRET = "53cR3T"
def _api_key_check():
key = request.args.get("api_key", None)
if not key:
abort(401, "Must provide api_key parameter.")
pieces = key.split("-", 1)
if len(pieces) != 2 or pieces[1] != API_SECRET:
abort(401, "API Key should be in format '{username}-{secret}'")
def _shortened(hearing):
"""return compact hearing form for list view"""
return {
"chamber": hearing["request"]["chamber"],
"congress": hearing["request"]["congress"],
"jacketNumber": hearing["request"]["jacketNumber"],
"updateDate": hearing["hearing"]["updateDate"],
"url": BASE_API_URL + hearing["request"]["jacketNumber"],
}
def _load_hearings(): def _load_hearings():
@ -20,19 +42,9 @@ ALL_HEARINGS = _load_hearings()
HEARING_IDS = list(ALL_HEARINGS.keys()) # semi-consistent ordering HEARING_IDS = list(ALL_HEARINGS.keys()) # semi-consistent ordering
def shortened(hearing):
"""return compact hearing form for list view"""
return {
"chamber": hearing["request"]["chamber"],
"congress": hearing["request"]["congress"],
"jacketNumber": hearing["request"]["jacketNumber"],
"updateDate": hearing["hearing"]["updateDate"],
"url": BASE_API_URL + hearing["request"]["jacketNumber"],
}
@app.route("/hearings") @app.route("/hearings")
def hearings_list(): def hearings_list():
_api_key_check()
offset = int(request.args.get("offset", 0)) offset = int(request.args.get("offset", 0))
limit = min(int(request.args.get("limit", 50)), 200) limit = min(int(request.args.get("limit", 50)), 200)
format = request.args.get("format", "json") format = request.args.get("format", "json")
@ -49,7 +61,7 @@ def hearings_list():
hearing_ids = HEARING_IDS[offset : offset + limit] hearing_ids = HEARING_IDS[offset : offset + limit]
hearings = [ALL_HEARINGS[h] for h in hearing_ids] hearings = [ALL_HEARINGS[h] for h in hearing_ids]
return { return {
"hearings": [shortened(h) for h in hearings], "hearings": [_shortened(h) for h in hearings],
"pagination": {"count": len(ALL_HEARINGS), "next": next_url}, "pagination": {"count": len(ALL_HEARINGS), "next": next_url},
"chamber": { "chamber": {
"chamber": "house", "chamber": "house",
@ -62,6 +74,7 @@ def hearings_list():
@app.route("/hearings/<jacket_id>") @app.route("/hearings/<jacket_id>")
def hearings_detail(jacket_id): def hearings_detail(jacket_id):
_api_key_check()
if jacket_id not in ALL_HEARINGS: if jacket_id not in ALL_HEARINGS:
abort(404) abort(404)
return ALL_HEARINGS[jacket_id] return ALL_HEARINGS[jacket_id]