Using Python to Aggregate and Score Signals Automatically

[
  {"claim_id":"c1","origin_id":"o1","weight":0.7,"direction":1,"approved":true},
  {"claim_id":"c2","origin_id":"o2","weight":0.3,"direction":-1,"approved":true}
]

import json
from pathlib import Path

rows = json.loads(Path("signals.json").read_text(encoding="utf-8"))
required = {"claim_id", "origin_id", "weight", "direction", "approved"}

origins = {}
for row in rows:
    if set(row) != required:
        raise ValueError(f"unexpected schema for {row.get('claim_id', 'unknown')}")
    if row["approved"] is not True:
        continue
    if row["direction"] not in {-1, 0, 1}:
        raise ValueError("direction must be -1, 0, or 1")
    if not 0 <= row["weight"] <= 1:
        raise ValueError("weight outside 0..1")
    if row["origin_id"] in origins:
        raise ValueError("duplicate origin requires manual dependency rule")
    origins[row["origin_id"]] = row

denominator = sum(row["weight"] for row in origins.values())
score = None if denominator == 0 else sum(
    row["weight"] * row["direction"] for row in origins.values()
) / denominator

print(json.dumps({"approved_origins": len(origins), "paper_score": score}, indent=2))