Method check

scripts/fetch_updates.py:1381–1459

(self, source_id: str, source: dict)

        self.state = state

    def check(self, source_id: str, source: dict) -> Optional[dict]:
        prev = self.state.get(source_id, {})
        seen_ids = set(prev.get("seen_res_numbers", []))

        lookback = (datetime.now() - timedelta(days=30)).strftime("%Y%m%d")
        today = datetime.now().strftime("%Y%m%d")

        search_q = f'event_date_initiated:[{lookback} TO {today}]'
        url = (
            f"{self.RECALL_URL}"
            f"?search={requests.utils.quote(search_q)}"
            f"&sort=event_date_initiated:desc&limit=30"
        )
        if self.api_key:
            url += f"&api_key={self.api_key}"

        try:
            resp = requests.get(url, timeout=20)
            if resp.status_code == 404:
                self.state[source_id] = {
                    "url": source["url"],
                    "last_checked": datetime.now().isoformat(),
                    "seen_res_numbers": list(seen_ids),
                }
                return None
            resp.raise_for_status()
            results = resp.json().get("results", [])
        except Exception as e:
            print(f"    ERROR OpenFDA Recall: {e}")
            return None

        new_items = []
        all_ids = list(seen_ids)

        for r in results:
            res_num = r.get("product_res_number") or r.get("res_event_number", "")
            if not res_num or res_num in seen_ids:
                continue
            all_ids.append(res_num)

            firm = r.get("recalling_firm", "Unknown")
            product = (r.get("product_description") or "")[:120]
            reason = r.get("reason_for_recall", "")
            cfres_id = r.get("cfres_id", "")
            init_date = r.get("event_date_initiated", "")

            title = f"Device Recall: {firm} - {product}"
            description = f"Recall {res_num}: {reason[:250]}"
            link = (
                f"https://www.accessdata.fda.gov/scripts/cdrh/cfdocs/cfRes/res.cfm"
                f"?id={cfres_id}"
            ) if cfres_id else source["url"]

            new_items.append({
                "title": title,
                "link": link,
                "pub_date": self._format_date(init_date),
                "description": description,