diff --git a/.github/workflows/sync.yml b/.github/workflows/sync.yml
new file mode 100644
index 0000000..8df59f1
--- /dev/null
+++ b/.github/workflows/sync.yml
@@ -0,0 +1,37 @@
+name: Daily sync of EUVD catalog
+
+on:
+  workflow_dispatch:
+  schedule:
+    - cron: '0 0 * * *'
+
+permissions:
+  contents: write
+
+jobs:
+  scheduled:
+    runs-on: ubuntu-latest
+
+    steps:
+      - name: Checkout repository
+        uses: actions/checkout@v4
+
+      - name: Set up Python
+        uses: actions/setup-python@v5
+        with:
+          python-version: '3.10'
+
+      - name: Install required packages
+        run: pip install -r requirements.txt
+
+      - name: Run sync (daily)
+        run: python sync_catalog.py daily
+
+      - name: Commit and push if it changed
+        run: |-
+          git config user.name "AboutCode Automation"
+          git config user.email "automation@aboutcode.org"
+          git add -A
+          timestamp=$(date -u)
+          git commit -m "$(echo -e "Sync EUVD catalog: $timestamp\n\nSigned-off-by: AboutCode Automation <automation@aboutcode.org>")" || exit 0
+          git push
diff --git a/.gitignore b/.gitignore
new file mode 100644
index 0000000..c993167
--- /dev/null
+++ b/.gitignore
@@ -0,0 +1,21 @@
+# Various junk and temp files
+.DS_Store
+*~
+.*.sw[po]
+.build
+.ve
+*.bak
+var
+share
+selenium
+local
+/dist/
+/.*cache/
+/.venv/
+/.python-version
+/.pytest_cache/
+/scancodeio.egg-info/
+*.rdb
+*.aof
+.vscode
+.ipynb_checkpoints
\ No newline at end of file
diff --git a/requirements.txt b/requirements.txt
new file mode 100644
index 0000000..b80ce4b
--- /dev/null
+++ b/requirements.txt
@@ -0,0 +1,2 @@
+requests==2.32.5
+aboutcode.pipeline==0.2.1
diff --git a/sync_catalog.py b/sync_catalog.py
new file mode 100644
index 0000000..4071964
--- /dev/null
+++ b/sync_catalog.py
@@ -0,0 +1,237 @@
+#
+# Copyright (c) nexB Inc. and others. All rights reserved.
+# SPDX-License-Identifier: Apache-2.0
+# See http://www.apache.org/licenses/LICENSE-2.0 for the license text.
+# See https://aboutcode.org for more information about nexB OSS projects.
+#
+
+import argparse
+import json
+import sys
+from datetime import date, datetime, timedelta, timezone
+from pathlib import Path
+from typing import Any, Dict
+
+import requests
+
+from aboutcode.pipeline import BasePipeline, LoopProgress
+
+ROOT_PATH = Path(__file__).parent
+CATALOG_PATH = ROOT_PATH / "catalog"
+PAGE_DIRECTORY = CATALOG_PATH / "pages"
+
+API_URL = "https://euvdservices.enisa.europa.eu/api/search"
+
+HEADERS = {
+    "User-Agent": "Vulnerablecode",
+    "Accept": "application/json",
+}
+
+PAGE_SIZE = 100
+DEFAULT_START_YEAR = 1970
+REQUEST_TIMEOUT = 10
+
+
+class EUVDCatalogMirror(BasePipeline):
+    @classmethod
+    def steps(cls):
+        return (cls.collect_catalog,)
+
+    def collect_catalog(self) -> None:
+        if getattr(self, "mode", "backfill") == "daily":
+            return self.sync_yesterday()
+        self.backfill_from_year(DEFAULT_START_YEAR)
+
+    def backfill_from_year(self, start_year: int) -> None:
+        today = date.today()
+        backfill_start = date(start_year, 1, 1)
+        backfill_end = today
+
+        months: list[tuple[int, int]] = []
+        current = backfill_start
+
+        while current <= backfill_end:
+            months.append((current.year, current.month))
+            if current.month == 12:
+                current = date(current.year + 1, 1, 1)
+                continue
+            current = date(current.year, current.month + 1, 1)
+
+        self.log(f"Starting backfill for {len(months)} months")
+
+        progress = LoopProgress(total_iterations=len(months), logger=self.log)
+
+        for year, month in progress.iter(months):
+            month_start = date(year, month, 1)
+            day_token = month_start.isoformat()
+
+            if year == backfill_end.year and month == backfill_end.month:
+                self._collect_paginated(
+                    start=month_start,
+                    end=backfill_end,
+                    year=year,
+                    month=month,
+                    day_token=day_token,
+                )
+                continue
+
+            if month == 12:
+                next_month = date(year + 1, 1, 1)
+            else:
+                next_month = date(year, month + 1, 1)
+            month_end = next_month - timedelta(days=1)
+
+            self._collect_paginated(
+                start=month_start,
+                end=month_end,
+                year=year,
+                month=month,
+                day_token=day_token,
+            )
+
+        self.log("Backfill completed")
+
+    def sync_yesterday(self) -> None:
+        target_date = date.today() - timedelta(days=1)
+
+        first_page = self.fetch_page(
+            {
+                "fromUpdatedDate": target_date.isoformat(),
+                "toUpdatedDate": target_date.isoformat(),
+                "size": PAGE_SIZE,
+                "page": 0,
+            }
+        )
+
+        total = first_page.get("total", 0)
+        total_pages = (total + PAGE_SIZE - 1) // PAGE_SIZE
+
+        progress = LoopProgress(total_iterations=total_pages, logger=self.log)
+
+        for page in progress.iter(range(total_pages)):
+            if page == 0:
+                data = first_page
+            else:
+                data = self.fetch_page(
+                    {
+                        "fromUpdatedDate": target_date.isoformat(),
+                        "toUpdatedDate": target_date.isoformat(),
+                        "size": PAGE_SIZE,
+                        "page": page,
+                    }
+                )
+
+            self.write_page_file(
+                year=target_date.year,
+                month=target_date.month,
+                day_token=target_date.isoformat(),
+                page_number=page + 1,
+                payload=data,
+            )
+
+    def _collect_paginated(
+        self,
+        start: date,
+        end: date,
+        year: int,
+        month: int,
+        day_token: str,
+    ) -> None:
+        """
+        Fetch all EUVD results for the given date range using paginated requests.The total number of results is read from the API response and used to determine how many pages to fetch. Each page is written as a separate JSON file under the corresponding year/month directory.
+        """
+
+        first_page = self.fetch_page(
+            {
+                "fromUpdatedDate": start.isoformat(),
+                "toUpdatedDate": end.isoformat(),
+                "size": PAGE_SIZE,
+                "page": 0,
+            }
+        )
+
+        total = first_page.get("total", 0)
+        total_pages = (total + PAGE_SIZE - 1) // PAGE_SIZE
+
+        for page in range(total_pages):
+            if page == 0:
+                data = first_page
+            else:
+                data = self.fetch_page(
+                    {
+                        "fromUpdatedDate": start.isoformat(),
+                        "toUpdatedDate": end.isoformat(),
+                        "size": PAGE_SIZE,
+                        "page": page,
+                    }
+                )
+
+            self.write_page_file(
+                year=year,
+                month=month,
+                day_token=day_token,
+                page_number=page + 1,
+                payload=data,
+            )
+
+    def write_page_file(
+        self,
+        year: int,
+        month: int,
+        day_token: str,
+        page_number: int,
+        payload: Dict[str, Any],
+    ) -> None:
+        year_str = f"{year:04d}"
+        month_str = f"{month:02d}"
+        page_str = f"{page_number:04d}"
+
+        dir_path = PAGE_DIRECTORY / year_str / month_str
+        dir_path.mkdir(parents=True, exist_ok=True)
+
+        filename = f"page{day_token}-{page_str}.json"
+        path = dir_path / filename
+
+        if path.exists():
+            return
+
+        with path.open("w", encoding="utf-8") as output:
+            json.dump(payload, output, indent=2)
+
+    def fetch_page(self, params: Dict[str, Any]) -> Dict[str, Any]:
+        response = requests.get(
+            API_URL,
+            params=params,
+            headers=HEADERS,
+            timeout=REQUEST_TIMEOUT,
+        )
+        response.raise_for_status()
+        data: Any = response.json()
+        if not isinstance(data, dict):
+            return {}
+        return data
+
+    def log(self, message: str) -> None:
+        now = datetime.now(timezone.utc).astimezone()
+        stamp = now.strftime("%Y-%m-%d %H:%M:%S.%f")[:-3]
+        print(f"{stamp} {message}")
+
+
+if __name__ == "__main__":
+    parser = argparse.ArgumentParser(description="EUVD Catalog Mirror")
+    parser.add_argument(
+        "mode",
+        nargs="?",
+        default="daily",
+        choices=["backfill", "daily"],
+        help="Sync mode: 'backfill' for full history, 'daily' for yesterday only",
+    )
+    args = parser.parse_args()
+
+    mirror = EUVDCatalogMirror()
+    mirror.mode = args.mode
+
+    status_code, error_message = mirror.execute()
+    if error_message:
+        print(error_message)
+    sys.exit(status_code)