Method check

scripts/fetch_updates.py:1858–1921

(self, source_id: str, source: dict)

        return any(mc in category for mc in self._MEDICAL_DEVICE_CATEGORIES)

    def check(self, source_id: str, source: dict) -> Optional[dict]:
        prev = self.state.get(source_id, {})
        prev_nids = set(str(n) for n in prev.get("seen_nids", []))

        try:
            resp = self.session.get(self.DATA_URL, timeout=60)
            resp.raise_for_status()
            all_records = resp.json()
        except Exception as e:
            print(f"    ERROR Canada Open Data: {e}")
            return None

        cutoff = (datetime.now() - timedelta(days=90)).strftime("%Y-%m-%d")
        md_records = []
        for r in all_records:
            if not self._is_medical_device(r):
                continue
            updated = r.get("Last updated", "") or ""
            if updated >= cutoff:
                md_records.append(r)

        print(f"    INFO: {len(md_records)} medical device records in last 90 days (from {len(all_records)} total)")

        new_items = []
        all_nids = list(prev_nids)

        for r in md_records:
            nid = str(r.get("NID", ""))
            if not nid or nid in prev_nids:
                continue
            all_nids.append(nid)
            title = r.get("Title", "Untitled")
            url = r.get("URL", "")
            if url and not url.startswith("http"):
                url = "https://recalls-rappels.canada.ca" + url
            new_items.append({
                "title": title,
                "link": url,
                "pub_date": (r.get("Last updated", "") or "")[:10],
                "description": (r.get("Issue", "") or "")[:400],
                "recall_class": r.get("Recall class", ""),
                "category": r.get("Category", ""),
            })

        self.state[source_id] = {
            "url": self.DATA_URL,
            "last_checked": datetime.now().isoformat(),
            "seen_nids": all_nids[-1000:],
        }

        if new_items and (prev_nids or self.seed_mode):
            if self.seed_mode and not prev_nids:
                new_items = new_items[:10]
                print(f"    INFO: Seed mode -- returning top {len(new_items)} medical device entries")
            result = _make_update(
                source_id, source, "canada_recalls",
                f"{len(new_items)} new Canada medical device recall(s)/alert(s)"
            )