kianiadee/tracksolid_timescale_grafana_prod
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions 1

diag: log raw push body + content-type at INFO level
Some checks failed
Static Analysis / static (push) Waiting to run
Details
Tests / test (push) Waiting to run
Details
Static Analysis / static (pull_request) Has been cancelled
Details
Tests / test (pull_request) Has been cancelled
Details

Browse source 
Temporary diagnostic to see what format Jimi actually sends on /pushalarm.
New container is parsing to empty items (pushes arrive but no DB insert),
so we need to see the real body shape. Remove once format is confirmed.

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
This commit is contained in:
David Kiania 2026-04-21 12:04:55 +03:00
parent ef36ebebea
commit c54794eb4c
1 changed files with 9 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
webhook_receiver_rev.py
View file

@ -112,8 +112,12 @@ async def _parse_request(request: Request) -> tuple[str, list[dict]]:
content_type = request.headers.get("content-type", "") content_type = request.headers.get("content-type", "")
body = await request.body() body = await request.body()
# TEMP DIAGNOSTIC: log every push so we can see what Jimi actually sends.
log.info("push %s: content-type=%r body=%.300s",
request.url.path, content_type,
body.decode("utf-8", errors="replace") if body else "<empty>")
if not body: if not body:
log.debug("push: empty request body")
return "", [] return "", []
# ── Try JSON body first (integration push format) ────────────────────────── # ── Try JSON body first (integration push format) ──────────────────────────
@ -128,11 +132,10 @@ async def _parse_request(request: Request) -> tuple[str, list[dict]]:
items = _parse_data_list(raw_dl) items = _parse_data_list(raw_dl)
else: else:
items = [] items = []
log.debug("push: parsed JSON body — %d items", len(items)) log.info("push: parsed JSON body — %d items", len(items))
return token, items return token, items
except (json.JSONDecodeError, TypeError): except (json.JSONDecodeError, TypeError):
log.warning("push: JSON body parse failed — body: %.200s", log.warning("push: JSON body parse failed")
body.decode("utf-8", errors="replace"))
# ── Fall back to form-encoded ─────────────────────────────────────────────── # ── Fall back to form-encoded ───────────────────────────────────────────────
try: try:
@ -140,11 +143,10 @@ async def _parse_request(request: Request) -> tuple[str, list[dict]]:
token = str(form.get("token", "")) token = str(form.get("token", ""))
raw_dl = str(form.get("data_list", "")) raw_dl = str(form.get("data_list", ""))
items = _parse_data_list(raw_dl) if raw_dl else [] items = _parse_data_list(raw_dl) if raw_dl else []
log.debug("push: parsed form body — %d items", len(items)) log.info("push: parsed form body — %d items", len(items))
return token, items return token, items
except Exception: except Exception:
log.warning("push: form body parse failed — body: %.200s", log.warning("push: form body parse failed", exc_info=True)
body.decode("utf-8", errors="replace"), exc_info=True)
return "", [] return "", []