diff --git a/.env.example b/.env.example
index 3d588df..0e0e752 100644
--- a/.env.example
+++ b/.env.example
@@ -1,6 +1,5 @@
-# You should copy this file to .env.mainnet or .env.testnet and fill in the values.
-# then run the proper script `pnpm run dev` (testnet) o `pnpm run dev:mainnet` (mainnet)
+# Copy this file to .env.mainnet or .env.testnet and fill in the values.
+# Then run: pnpm run dev (testnet) or pnpm run dev:mainnet (mainnet)
 
-NUXT_HUB_PROJECT_KEY=
 NUXT_PUBLIC_NIMIQ_NETWORK=test-albatross
 ALBATROSS_RPC_NODE_URL=
diff --git a/.github/workflows/ci.yml b/.github/workflows/ci.yml
index 0cdeaf5..68d8d94 100644
--- a/.github/workflows/ci.yml
+++ b/.github/workflows/ci.yml
@@ -37,7 +37,7 @@ jobs:
           NUXT_PUBLIC_NIMIQ_NETWORK: ${{ vars.NUXT_PUBLIC_NIMIQ_NETWORK }}
 
       - name: Validate JSON files
-        run: pnpm run validate:json-files github
+        run: pnpm run validate:json-files
 
       - name: Test
         run: pnpm run test
diff --git a/.github/workflows/nuxt-hub.yml b/.github/workflows/nuxt-hub.yml
deleted file mode 100644
index a9339f3..0000000
--- a/.github/workflows/nuxt-hub.yml
+++ /dev/null
@@ -1,86 +0,0 @@
-name: Deploy to NuxtHub
-on:
-  push:
-    branches:
-      - '*'
-
-jobs:
-  deploy-testnet:
-    name: Deploy to NuxtHub Testnet
-    runs-on: ubuntu-latest
-    environment:
-      name: ${{ github.ref == 'refs/heads/main' && 'production-testnet' || 'preview-testnet' }}
-      url: ${{ steps.deploy-testnet.outputs.deployment-url }}
-    permissions:
-      contents: read
-      id-token: write
-
-    steps:
-      - uses: actions/checkout@v4
-
-      - name: Install pnpm
-        uses: pnpm/action-setup@v4
-
-      - name: Install Node.js
-        uses: actions/setup-node@v4
-        with:
-          node-version: 22
-          cache: pnpm
-
-      - name: Install dependencies
-        run: pnpm install
-        env:
-          ALBATROSS_RPC_NODE_URL: ${{ secrets.ALBATROSS_RPC_NODE_URL }}
-          NUXT_PUBLIC_NIMIQ_NETWORK: ${{ vars.NUXT_PUBLIC_NIMIQ_NETWORK }}
-
-      - name: Build application
-        run: pnpm run build
-        env:
-          ALBATROSS_RPC_NODE_URL: ${{ secrets.ALBATROSS_RPC_NODE_URL }}
-          NUXT_PUBLIC_NIMIQ_NETWORK: ${{ vars.NUXT_PUBLIC_NIMIQ_NETWORK }}
-
-      - name: Deploy to NuxtHub ${{ vars.NUXT_HUB_ENV }} Testnet
-        uses: nuxt-hub/action@v1
-        id: deploy-testnet
-        with:
-          project-key: ${{ vars.NUXT_HUB_PROJECT_KEY }}
-
-  deploy-mainnet:
-    name: Deploy to NuxtHub Mainnet
-    runs-on: ubuntu-latest
-    environment:
-      name: ${{ github.ref == 'refs/heads/main' && 'production-mainnet' || 'preview-mainnet' }}
-      url: ${{ steps.deploy-mainnet.outputs.deployment-url }}
-    permissions:
-      contents: read
-      id-token: write
-
-    steps:
-      - uses: actions/checkout@v4
-
-      - name: Install pnpm
-        uses: pnpm/action-setup@v4
-
-      - name: Install Node.js
-        uses: actions/setup-node@v4
-        with:
-          node-version: 22
-          cache: pnpm
-
-      - name: Install dependencies
-        run: pnpm install
-        env:
-          ALBATROSS_RPC_NODE_URL: ${{ secrets.ALBATROSS_RPC_NODE_URL }}
-          NUXT_PUBLIC_NIMIQ_NETWORK: ${{ vars.NUXT_PUBLIC_NIMIQ_NETWORK }}
-
-      - name: Build application
-        run: pnpm run build
-        env:
-          ALBATROSS_RPC_NODE_URL: ${{ secrets.ALBATROSS_RPC_NODE_URL }}
-          NUXT_PUBLIC_NIMIQ_NETWORK: ${{ vars.NUXT_PUBLIC_NIMIQ_NETWORK }}
-
-      - name: Deploy to NuxtHub ${{ vars.NUXT_HUB_ENV }} Mainnet
-        uses: nuxt-hub/action@v1
-        id: deploy-mainnet
-        with:
-          project-key: ${{ vars.NUXT_HUB_PROJECT_KEY }}
diff --git a/.github/workflows/sync.yaml b/.github/workflows/sync.yaml
deleted file mode 100644
index 8156915..0000000
--- a/.github/workflows/sync.yaml
+++ /dev/null
@@ -1,99 +0,0 @@
-name: Sync
-
-on:
-  schedule:
-    - cron: '0 * * * *' # Runs hourly
-  workflow_dispatch: # Allows manual triggering of the workflow
-
-jobs:
-  sync:
-    runs-on: ubuntu-latest
-    continue-on-error: true
-    strategy:
-      matrix:
-        endpoint:
-          - https://validators-api-mainnet.pages.dev
-          - https://validators-api-testnet.pages.dev
-          - https://dev.validators-api-mainnet.pages.dev
-          - https://dev.validators-api-testnet.pages.dev
-    steps:
-      # - name: Stream sync API
-      #   run: |
-      #     # --no-buffer (or -N) tells curl to flush each chunk as soon as it arrives,
-      #     # so can see Nitro stream lines in real time.
-      #     curl -fsS --no-buffer "${{ matrix.endpoint }}/api/v1/sync/sse" || {
-      #       echo "Sync request failed for ${{ matrix.endpoint }}"
-      #       exit 1
-      #     }
-      - name: Sync missing epochs
-        env:
-          ENDPOINT: ${{ matrix.endpoint }}
-        run: |
-          set -eo pipefail
-          echo "🔄 Starting missing-epoch sync at $ENDPOINT"
-
-          while true; do
-            # call and capture both body and HTTP status in one go
-            resp=$(curl -sS -w "HTTPSTATUS:%{http_code}" \
-              "$ENDPOINT/api/v1/sync/missing-epoch")
-
-            body=${resp%HTTPSTATUS:*}
-            status=${resp##*HTTPSTATUS:}
-
-            echo "HTTP status: $status"
-            echo "$body"
-
-            # any non-200 is a hard failure
-            if [[ "$status" -ne 200 ]]; then
-              echo "❌ HTTP $status returned"
-              exit 1
-            fi
-
-            # JSON error field?
-            if echo "$body" | jq -e 'has("error")' >/dev/null; then
-              echo "❌ Server error:" $(echo "$body" | jq -r '.error')
-              exit 1
-            fi
-
-            # parse out sync flags
-            isSynced=$(echo "$body" | jq -r '.isSynced // false')
-            syncedEpoch=$(echo "$body" | jq -r '.syncedEpoch // "N/A"')
-            totalMissing=$(echo "$body" | jq -r '.totalMissing // "N/A"')
-
-            if [[ "$isSynced" == "true" ]]; then
-              echo "✅ All epochs synced (last synced epoch: $syncedEpoch)"
-              break
-            fi
-
-            next=$(echo "$body" | jq -r '.next // "N/A"')
-            echo "✅ Synced up to epoch $syncedEpoch → next: $next ($totalMissing remaining)"
-            sleep 1
-          done
-
-      - name: Sync snapshot
-        env:
-          ENDPOINT: ${{ matrix.endpoint }}
-        run: |
-          set -eo pipefail
-          echo "🔄 Syncing snapshot at $ENDPOINT"
-
-          resp=$(curl -sS -w "HTTPSTATUS:%{http_code}" \
-            "$ENDPOINT/api/v1/sync/snapshot")
-
-          body=${resp%HTTPSTATUS:*}
-          status=${resp##*HTTPSTATUS:}
-
-          echo "HTTP status: $status"
-          echo "$body"
-
-          if [[ "$status" -ne 200 ]]; then
-            echo "❌ HTTP $status returned"
-            exit 1
-          fi
-
-          if echo "$body" | jq -e 'has("error")' >/dev/null; then
-            echo "❌ Server error:" $(echo "$body" | jq -r '.error')
-            exit 1
-          fi
-
-          echo "✅ Snapshot sync completed successfully"
diff --git a/README.md b/README.md
index 3f62fa2..ad03225 100644
--- a/README.md
+++ b/README.md
@@ -13,7 +13,7 @@
 </p>
 
 <p align="center">
-<a href="https://github.com/nimiq/validators-api/actions/workflows/sync.yml" target="_blank"><img src="https://github.com/nimiq/validators-api/actions/workflows/sync.yml/badge.svg" /></a>
+<a href="https://github.com/nimiq/validators-api/actions/workflows/ci.yml" target="_blank"><img src="https://github.com/nimiq/validators-api/actions/workflows/ci.yml/badge.svg" /></a>
 </p>
 
 <h2 align="center">Dashboards</h2>
@@ -203,17 +203,25 @@ The system automatically detects the environment and only sends notifications in
 
 ## Deployment
 
-The deployment is handled by the [`NuxtHub Action`](./.github/workflows/nuxt-hub.yml).
+Deployed via Wrangler CLI with `wrangler.json` config:
 
-There are 4 different environments:
+```bash
+pnpm build && npx wrangler --cwd .output deploy [-e env]
+```
+
+Where `env`: `preview`, `testnet`, or `testnet-preview` (omit for mainnet production).
+
+**Required secrets:** `ALBATROSS_RPC_NODE_URL`, `NUXT_SLACK_WEBHOOK_URL`
+
+**Environments** (configured in `wrangler.json`):
 
-| Nuxt Hub Env | GitHub Env           | Dashboard URL                                                                  | Trigger                       |
-| ------------ | -------------------- | ------------------------------------------------------------------------------ | ----------------------------- |
-| `production` | `production-mainnet` | [Validators API Mainnet](https://validators-api-mainnet.pages.dev)             | Push to `main` branch         |
-| `production` | `production-testnet` | [Validators API Testnet](https://validators-api-testnet.pages.dev)             | Push to `main` branch         |
-| `preview`    | `preview-mainnet`    | [Validators API Mainnet Preview](https://dev.validators-api-mainnet.pages.dev) | Push any commit to any branch |
-| `preview`    | `preview-testnet`    | [Validators API Testnet Preview](https://dev.validators-api-testnet.pages.dev) | Push any commit to any branch |
+| Environment       | Dashboard URL                                                                  | Trigger            |
+| ----------------- | ------------------------------------------------------------------------------ | ------------------ |
+| `production`      | [Validators API Mainnet](https://validators-api-mainnet.pages.dev)             | Push to `main`     |
+| `preview`         | [Validators API Mainnet Preview](https://dev.validators-api-mainnet.pages.dev) | Push to any branch |
+| `testnet`         | [Validators API Testnet](https://validators-api-testnet.pages.dev)             | Push to `main`     |
+| `testnet-preview` | [Validators API Testnet Preview](https://dev.validators-api-testnet.pages.dev) | Push to any branch |
 
-Each Nuxt Hub environment has its own database, so effectively we have 4 different databases and there are 4 tasks in the [`sync.yml`](./.github/workflows/sync.yml) workflow that are responsible for syncing the data from the Nimiq network to the database.
+Each environment has its own D1 database, KV cache, and R2 blob. Sync runs hourly via Cloudflare cron triggers (see `server/tasks/sync/`).
 
 **Write operations to `main` are restricted**, only via PR.
diff --git a/app/app.vue b/app/app.vue
index 9e2c1db..50b7a7d 100644
--- a/app/app.vue
+++ b/app/app.vue
@@ -1,32 +1,6 @@
 <script setup lang="ts">
 const { data: status, status: statusRequest, refresh: refreshStatus, error } = await useFetch('/api/v1/status', { server: true, lazy: false })
 
-const debouncedRefresh = useDebounceFn(() => {
-  refreshStatus()
-  refreshNuxtData(['/api/v1/validators', '/api/v1/supply', '/api/v1/status'])
-}, 300)
-
-const { status: statusSync, data: dataSync, error: syncError, close: closeSync, open: syncData } = useEventSource('/api/v1/sync/sse', [], { immediate: false })
-
-// Check for sync success message and refresh document
-watch(() => dataSync.value, (newData) => {
-  if (newData) {
-    try {
-      const parsedData = JSON.parse(newData)
-      if (parsedData.kind === 'success' && parsedData.message === 'Sync process completed') {
-        debouncedRefresh()
-        closeSync()
-      }
-    }
-    catch (e) {
-      console.error('Failed to parse sync data:', e)
-    }
-  }
-}, { immediate: true })
-
-// Also maintain the original watch for general updates
-watch(() => [dataSync, syncError], debouncedRefresh)
-
 const colorMode = useColorMode()
 const toggleDark = () => colorMode.value = colorMode.value === 'light' ? 'dark' : 'light'
 
@@ -110,7 +84,7 @@ const currentEnvItem = { branch: gitBranch, network: nimiqNetwork, link: environ
       <button i-nimiq:moon @click="() => toggleDark()" />
     </header>
     <main flex-1>
-      <div v-if="(!isSynced || error || syncError) && $route.path === '/'" bg="red/8" outline="1.5 ~ red-600" rounded-12 f-p-md text="14 red-1100" nq-prose-compact children:max-w-none f-mb-lg>
+      <div v-if="(!isSynced || error) && $route.path === '/'" bg="red/8" outline="1.5 ~ red-600" rounded-12 f-p-md text="14 red-1100" nq-prose-compact children:max-w-none f-mb-lg>
         <h1 flex="~ items-center gap-12" text-red-1100 f-text-lg>
           <div i-nimiq:alert op-70 text-0.9em m-0 />
           <template v-if="!isActivitySync">
@@ -124,7 +98,7 @@ const currentEnvItem = { branch: gitBranch, network: nimiqNetwork, link: environ
           The database is not fully synchronized with the blockchain. The API may not return the most recent data.
         </p>
 
-        <pre v-if="syncError || error" bg="red/6" text="f-2xs red-1100" outline="red/30" w-inherit>{{ JSON.stringify(syncError || error, null, 2) }}</pre>
+        <pre v-if="error" bg="red/6" text="f-2xs red-1100" outline="red/30" w-inherit>{{ JSON.stringify(error, null, 2) }}</pre>
 
         <template v-if="status">
           <h2 f-mt-md text-red-1100 f-text-md flex="~ items-center gap-12">
@@ -149,29 +123,9 @@ const currentEnvItem = { branch: gitBranch, network: nimiqNetwork, link: environ
 
         <hr f-my-sm border-red-600>
 
-        <div flex="~ items-baseline gap-8" mx-0 f-mt-md>
-          <button
-            mx-0 nq-pill nq-pill-red outline="~ 1.5 offset--1.5 red-1100/40"
-            :disabled="statusSync === 'OPEN'"
-            @click="() => syncData()"
-          >
-            <div :class="statusSync === 'OPEN' ? 'i-nimiq:spinner' : 'i-nimiq:restore'" mr-6 />
-            <span>
-              {{ statusSync === 'OPEN' ? 'Syncing...' : 'Sync now' }}
-            </span>
-          </button>
-
-          <button v-if="statusSync === 'OPEN'" mx-0 nq-pill-tertiary @click="() => closeSync()">
-            <div i-nimiq:cross mr-6 scale-70 />
-            Cancel
-          </button>
-
-          <div flex-1 flex="~ items-center justify-end">
-            <code w-max mr-0>SSE: {{ statusSync }}</code>
-          </div>
-        </div>
-
-        <pre v-if="dataSync" bg="red/6" lh-none text="f-2xs red-1100" outline="red/30" w-inherit max-h-80vh of-auto>{{ dataSync }}</pre>
+        <p f-mt-md text="f-sm red-1100/80">
+          <strong>Note:</strong> Data synchronization is handled automatically by scheduled tasks that run hourly. Please wait for the next sync cycle or contact an administrator if the issue persists.
+        </p>
       </div>
 
       <NuxtPage />
diff --git a/nuxt.config.ts b/nuxt.config.ts
index 096f9af..bbf2106 100644
--- a/nuxt.config.ts
+++ b/nuxt.config.ts
@@ -139,8 +139,14 @@ export default defineNuxtConfig({
   },
 
   nitro: {
+    preset: 'cloudflare_module',
     experimental: {
       openAPI: true,
+      tasks: true,
+    },
+    scheduledTasks: {
+      // Hourly sync: fetch missing epochs and update validator snapshots
+      '0 * * * *': ['sync:epochs', 'sync:snapshot'],
     },
     openAPI: {
       meta: { title: name, description, version },
diff --git a/package.json b/package.json
index 0a52d09..009ad03 100644
--- a/package.json
+++ b/package.json
@@ -15,7 +15,7 @@
     "dev:packages": "nr -C packages -r dev",
     "build": "nr -r build && nuxt build",
     "generate": "nuxt generate",
-    "preview": "npx nuxthub preview",
+    "preview": "npx wrangler --cwd .output dev",
     "postinstall": "nuxt prepare",
     "prepublishOnly": "nr build",
     "typecheck": "nuxt typecheck && nr -r typecheck",
diff --git a/public/assets/fonts/firacode-030c1602.woff2 b/public/assets/fonts/firacode-030c1602.woff2
new file mode 100644
index 0000000..f4cf47d
Binary files /dev/null and b/public/assets/fonts/firacode-030c1602.woff2 differ
diff --git a/public/assets/fonts/firacode-300fab9e.woff2 b/public/assets/fonts/firacode-300fab9e.woff2
new file mode 100644
index 0000000..f823ac0
Binary files /dev/null and b/public/assets/fonts/firacode-300fab9e.woff2 differ
diff --git a/public/assets/fonts/firacode-50d475f6.woff2 b/public/assets/fonts/firacode-50d475f6.woff2
new file mode 100644
index 0000000..67538ae
Binary files /dev/null and b/public/assets/fonts/firacode-50d475f6.woff2 differ
diff --git a/public/assets/fonts/firacode-6175507f.woff2 b/public/assets/fonts/firacode-6175507f.woff2
new file mode 100644
index 0000000..c56ad0f
Binary files /dev/null and b/public/assets/fonts/firacode-6175507f.woff2 differ
diff --git a/public/assets/fonts/firacode-7d2b4d2e.woff2 b/public/assets/fonts/firacode-7d2b4d2e.woff2
new file mode 100644
index 0000000..e9666c3
Binary files /dev/null and b/public/assets/fonts/firacode-7d2b4d2e.woff2 differ
diff --git a/public/assets/fonts/firacode-b029b37d.woff2 b/public/assets/fonts/firacode-b029b37d.woff2
new file mode 100644
index 0000000..9589c8a
Binary files /dev/null and b/public/assets/fonts/firacode-b029b37d.woff2 differ
diff --git a/public/assets/fonts/firacode-f5905b7f.woff2 b/public/assets/fonts/firacode-f5905b7f.woff2
new file mode 100644
index 0000000..9142b4d
Binary files /dev/null and b/public/assets/fonts/firacode-f5905b7f.woff2 differ
diff --git a/public/assets/fonts/mulish-294ced17.woff2 b/public/assets/fonts/mulish-294ced17.woff2
new file mode 100644
index 0000000..2213514
Binary files /dev/null and b/public/assets/fonts/mulish-294ced17.woff2 differ
diff --git a/public/assets/fonts/mulish-4eb440e1.woff2 b/public/assets/fonts/mulish-4eb440e1.woff2
new file mode 100644
index 0000000..18a1e68
Binary files /dev/null and b/public/assets/fonts/mulish-4eb440e1.woff2 differ
diff --git a/public/assets/fonts/mulish-78a2d471.woff2 b/public/assets/fonts/mulish-78a2d471.woff2
new file mode 100644
index 0000000..2dc023f
Binary files /dev/null and b/public/assets/fonts/mulish-78a2d471.woff2 differ
diff --git a/public/assets/fonts/mulish-c1a61bc6.woff2 b/public/assets/fonts/mulish-c1a61bc6.woff2
new file mode 100644
index 0000000..d66e265
Binary files /dev/null and b/public/assets/fonts/mulish-c1a61bc6.woff2 differ
diff --git a/public/assets/fonts/mulish-e64de9e7.woff2 b/public/assets/fonts/mulish-e64de9e7.woff2
new file mode 100644
index 0000000..b3b6c58
Binary files /dev/null and b/public/assets/fonts/mulish-e64de9e7.woff2 differ
diff --git a/server/api/[version]/rpc-proxy.post.ts b/server/api/[version]/rpc-proxy.post.ts
deleted file mode 100644
index aecec1a..0000000
--- a/server/api/[version]/rpc-proxy.post.ts
+++ /dev/null
@@ -1,33 +0,0 @@
-/**
- * RPC proxy for sending requests to a specified URL.
- * This is useful for sending requests to a Nimiq RPC node from the new
- * Developer Center without the need for CORS.
- */
-
-export default defineEventHandler(async (event) => {
-  const body = await readBody(event)
-
-  if (!body.payload)
-    throw createError({ statusCode: 400, message: 'Missing payload in request body' })
-  if (!body.url)
-    throw createError({ statusCode: 400, message: 'Missing url in request body' })
-
-  try {
-    const response = await fetch(body.url, {
-      method: 'POST',
-      headers: { 'Content-Type': 'application/json' },
-      body: JSON.stringify(body.payload),
-    })
-
-    const data = await response.json()
-    return data
-  }
-  catch (error) {
-    console.error('RPC proxy error:', error)
-    throw createError({
-      statusCode: 502,
-      message: 'Failed to connect to RPC node',
-      cause: error,
-    })
-  }
-})
diff --git a/server/api/[version]/sync/missing-epoch.get.ts b/server/api/[version]/sync/missing-epoch.get.ts
deleted file mode 100644
index 11ca096..0000000
--- a/server/api/[version]/sync/missing-epoch.get.ts
+++ /dev/null
@@ -1,55 +0,0 @@
-import { initRpcClient } from 'nimiq-rpc-client-ts/client'
-import { fetchActivity } from '~~/packages/nimiq-validator-trustscore/src/fetcher'
-import { getRange } from '~~/packages/nimiq-validator-trustscore/src/range'
-import { storeActivities } from '~~/server/utils/activities'
-import { sendNewEpochNotification, sendSyncFailureNotification } from '~~/server/utils/slack'
-
-export default defineEventHandler(async () => {
-  try {
-    initRpcClient({ url: useRuntimeConfig().albatrossRpcNodeUrl })
-
-    const [rangeOk, rangeError, range] = await getRange({ network: useRuntimeConfig().public.nimiqNetwork })
-    if (!rangeOk) {
-      const error = createError(rangeError || 'Unable to fetch range')
-      await sendSyncFailureNotification('missing-epoch', error)
-      throw error
-    }
-
-    const missingEpochs = await findMissingEpochs(range)
-    if (!missingEpochs) {
-      const error = createError('Unable to fetch missing epochs')
-      await sendSyncFailureNotification('missing-epoch', error)
-      throw error
-    }
-
-    if (missingEpochs.length === 0)
-      return { isSynced: true, next: null, syncedEpoch: null, totalMissing: 0 }
-
-    const missingEpoch = missingEpochs.at(0)!
-    const [activityOk, activityError, epochActivity] = await fetchActivity(missingEpoch)
-    if (!activityOk || !epochActivity) {
-      const error = createError(activityError || 'Unable to fetch activity')
-      await sendSyncFailureNotification('missing-epoch', error)
-      throw error
-    }
-
-    await storeActivities({ [`${missingEpoch}`]: epochActivity })
-
-    // Send notification for new epoch (only for mainnet, no tagging)
-    await sendNewEpochNotification(missingEpoch, missingEpochs.length)
-
-    // Subtract 1 from totalMissing as we've just synced one epoch
-    const totalMissing = missingEpochs.length - 1
-
-    return totalMissing === 0
-      ? { isSynced: true, next: null, syncedEpoch: missingEpoch, totalMissing }
-      : { isSynced: false, next: missingEpochs[1], syncedEpoch: missingEpoch, totalMissing }
-  }
-  catch (error) {
-    // Send failure notification if it hasn't been sent already
-    if (!(error as any)?.statusMessage?.includes('SLACK_NOTIFIED')) {
-      await sendSyncFailureNotification('missing-epoch', error)
-    }
-    throw error
-  }
-})
diff --git a/server/api/[version]/sync/snapshot.get.ts b/server/api/[version]/sync/snapshot.get.ts
deleted file mode 100644
index 1656418..0000000
--- a/server/api/[version]/sync/snapshot.get.ts
+++ /dev/null
@@ -1,41 +0,0 @@
-import { initRpcClient } from 'nimiq-rpc-client-ts/client'
-import { isDevelopment } from 'std-env'
-import { sendSyncFailureNotification } from '~~/server/utils/slack'
-
-export default defineEventHandler(async () => {
-  try {
-    initRpcClient({ url: useRuntimeConfig().albatrossRpcNodeUrl })
-
-    const source = isDevelopment ? 'filesystem' : 'github'
-    const { nimiqNetwork, gitBranch } = useRuntimeConfig().public
-    const [importSuccess, errorImport, importData] = await importValidators(source, { nimiqNetwork, gitBranch })
-    if (!importSuccess || !importData) {
-      const error = createError(errorImport || 'Unable to import from GitHub')
-      await sendSyncFailureNotification('snapshot', error)
-      throw error
-    }
-
-    const [fetchActiveEpochSuccess, fetchActiveEpochError, fetchActiveEpochData] = await fetchActiveEpoch()
-    if (!fetchActiveEpochSuccess || !fetchActiveEpochData) {
-      const error = createError(fetchActiveEpochError || 'Unable to fetch active epoch')
-      await sendSyncFailureNotification('snapshot', error)
-      throw error
-    }
-
-    const [scoresSuccess, errorScores, scores] = await upsertScoresSnapshotEpoch()
-    if (!scoresSuccess || !scores) {
-      const error = createError(errorScores || 'Unable to fetch scores')
-      await sendSyncFailureNotification('snapshot', error)
-      throw error
-    }
-
-    return { success: true, data: { ...fetchActiveEpochData, scores } }
-  }
-  catch (error) {
-    // Send failure notification if it hasn't been sent already
-    if (!(error as any)?.statusMessage?.includes('SLACK_NOTIFIED')) {
-      await sendSyncFailureNotification('snapshot', error)
-    }
-    throw error
-  }
-})
diff --git a/server/api/[version]/sync/sse.get.ts b/server/api/[version]/sync/sse.get.ts
deleted file mode 100644
index 631af7d..0000000
--- a/server/api/[version]/sync/sse.get.ts
+++ /dev/null
@@ -1,82 +0,0 @@
-import type { SyncStream } from '~~/server/utils/types'
-import { createConsola } from 'consola'
-import { initRpcClient } from 'nimiq-rpc-client-ts/client'
-import { isDevelopment } from 'std-env'
-
-const consola = createConsola({ defaults: { tag: 'sync' } })
-
-export default defineEventHandler(async (event) => {
-  const eventStream = createEventStream(event)
-  const controller = new AbortController()
-
-  // Handle client disconnection by aborting the controller
-  eventStream.onClosed(async () => {
-    consola.info('Client disconnected, aborting sync process')
-    controller.abort()
-    await eventStream.close()
-  })
-
-  function report(json: SyncStream) {
-    const method = json.kind === 'error' ? 'error' : json.kind === 'success' ? 'success' : 'log'
-
-    if (json.message && typeof json.message === 'string')
-      json.message = json.message.replace(/\\+"/g, '"')
-    if (json.payload && typeof json.payload === 'string')
-      json.payload = json.payload.replace(/\\+"/g, '"')
-
-    consola[method](json.message)
-    eventStream.push(JSON.stringify(json))
-
-    if (json.kind === 'error') {
-      eventStream.close()
-      throw createError(json.message)
-    }
-    if (controller.signal.aborted && json.message !== 'Sync process aborted') {
-      consola.warn('Sync process aborted')
-      report({ kind: 'log', message: 'Sync process aborted' })
-    }
-  }
-
-  if (!useRuntimeConfig().albatrossRpcNodeUrl)
-    throw createError('No Albatross RPC Node URL')
-  initRpcClient({ url: useRuntimeConfig().albatrossRpcNodeUrl })
-  report({ kind: 'log', message: 'Starting syncing...' })
-
-  // We need to return the event stream to the client first
-  setTimeout(async () => {
-    try {
-      const source = isDevelopment ? 'filesystem' : 'github'
-      const { nimiqNetwork, gitBranch } = useRuntimeConfig().public
-      const [importSuccess, errorImport, importData] = await importValidators(source, { nimiqNetwork, gitBranch })
-      if (!importSuccess || !importData)
-        return report({ kind: 'error', message: errorImport || 'Unable to import from GitHub' })
-      report({ kind: 'success', payload: importData, message: `Fetched ${importData.length} validators` })
-
-      // Pass the controller to fetchMissingEpochs for proper abort handling
-      const [fetchEpochsSuccess, fetchEpochsError, fetchEpochsData] = await fetchMissingEpochs({ report, controller })
-      if (!fetchEpochsSuccess || !fetchEpochsData)
-        return report({ kind: 'error', message: fetchEpochsError || 'Unable to fetch missing epochs' })
-      report({ kind: 'success', payload: fetchEpochsData, message: `Fetched ${fetchEpochsData.length} missing epochs` })
-
-      const [fetchActiveEpochSuccess, fetchActiveEpochError, fetchActiveEpochData] = await fetchActiveEpoch()
-      if (!fetchActiveEpochSuccess || !fetchActiveEpochData)
-        return report({ kind: 'error', message: fetchActiveEpochError || 'Unable to fetch active epoch' })
-      report({ kind: 'log', message: `Fetched active epoch: ${fetchActiveEpochData.epochNumber}`, payload: fetchActiveEpochData })
-
-      const [scoresSuccess, errorScores, scores] = await upsertScoresSnapshotEpoch()
-      if (!scoresSuccess || !scores)
-        return report({ kind: 'error', message: errorScores || 'Unable to fetch scores' })
-      report({ kind: 'success', payload: scores, message: `Fetched scores` })
-
-      const supplyData = await $fetch('/api/v1/supply')
-      report({ kind: 'success', payload: supplyData, message: 'Fetched distribution data' })
-
-      report({ kind: 'success', message: 'Sync process completed' })
-    }
-    catch (e) {
-      report({ kind: 'error', message: JSON.stringify(e) })
-    }
-  })
-
-  return eventStream.send()
-})
diff --git a/server/tasks/sync/epochs.ts b/server/tasks/sync/epochs.ts
new file mode 100644
index 0000000..ccfc982
--- /dev/null
+++ b/server/tasks/sync/epochs.ts
@@ -0,0 +1,59 @@
+import { initRpcClient } from 'nimiq-rpc-client-ts/client'
+import { fetchActivity } from '~~/packages/nimiq-validator-trustscore/src/fetcher'
+import { getRange } from '~~/packages/nimiq-validator-trustscore/src/range'
+import { storeActivities } from '~~/server/utils/activities'
+import { sendNewEpochNotification, sendSyncFailureNotification } from '~~/server/utils/slack'
+
+// In production, limit epochs per run to avoid Cloudflare Workers 30s CPU timeout.
+// In local dev, no limit so we can sync everything at once.
+const MAX_EPOCHS_PER_RUN = import.meta.dev ? Infinity : 50
+
+export default defineTask({
+  meta: {
+    name: 'sync:epochs',
+    description: 'Sync all missing blockchain epochs to D1 database',
+  },
+  async run() {
+    const config = useRuntimeConfig()
+
+    try {
+      initRpcClient({ url: config.albatrossRpcNodeUrl })
+
+      const [rangeOk, rangeError, range] = await getRange({ network: config.public.nimiqNetwork })
+      if (!rangeOk || !range) {
+        const error = new Error(rangeError || 'Unable to fetch range')
+        await sendSyncFailureNotification('missing-epoch', error)
+        return { result: { success: false, error: rangeError } }
+      }
+
+      let totalSynced = 0
+      const epochsSynced: number[] = []
+
+      while (totalSynced < MAX_EPOCHS_PER_RUN) {
+        const missingEpochs = await findMissingEpochs(range)
+        if (!missingEpochs || missingEpochs.length === 0)
+          break
+
+        const missingEpoch = missingEpochs.at(0)!
+        const [activityOk, activityError, epochActivity] = await fetchActivity(missingEpoch)
+        if (!activityOk || !epochActivity) {
+          const error = new Error(activityError || 'Unable to fetch activity')
+          await sendSyncFailureNotification('missing-epoch', error)
+          return { result: { success: false, error: activityError, totalSynced, epochsSynced } }
+        }
+
+        await storeActivities({ [`${missingEpoch}`]: epochActivity })
+        await sendNewEpochNotification(missingEpoch, missingEpochs.length)
+
+        epochsSynced.push(missingEpoch)
+        totalSynced++
+      }
+
+      return { result: { success: true, totalSynced, epochsSynced } }
+    }
+    catch (error) {
+      await sendSyncFailureNotification('missing-epoch', error)
+      return { result: { success: false, error: String(error) } }
+    }
+  },
+})
diff --git a/server/tasks/sync/snapshot.ts b/server/tasks/sync/snapshot.ts
new file mode 100644
index 0000000..f30fd50
--- /dev/null
+++ b/server/tasks/sync/snapshot.ts
@@ -0,0 +1,47 @@
+import { initRpcClient } from 'nimiq-rpc-client-ts/client'
+import { sendSyncFailureNotification } from '~~/server/utils/slack'
+
+export default defineTask({
+  meta: {
+    name: 'sync:snapshot',
+    description: 'Sync validator snapshot and calculate scores',
+  },
+  async run() {
+    const config = useRuntimeConfig()
+
+    try {
+      initRpcClient({ url: config.albatrossRpcNodeUrl })
+
+      // Use import.meta.dev for consistent behavior with Cloudflare Workers runtime
+      const source = import.meta.dev ? 'filesystem' : 'github'
+      const { nimiqNetwork, gitBranch } = config.public
+
+      const [importSuccess, errorImport, importData] = await importValidators(source, { nimiqNetwork, gitBranch })
+      if (!importSuccess || !importData) {
+        const error = new Error(errorImport || 'Unable to import from GitHub')
+        await sendSyncFailureNotification('snapshot', error)
+        return { result: { success: false, error: errorImport } }
+      }
+
+      const [fetchActiveEpochSuccess, fetchActiveEpochError, fetchActiveEpochData] = await fetchActiveEpoch()
+      if (!fetchActiveEpochSuccess || !fetchActiveEpochData) {
+        const error = new Error(fetchActiveEpochError || 'Unable to fetch active epoch')
+        await sendSyncFailureNotification('snapshot', error)
+        return { result: { success: false, error: fetchActiveEpochError } }
+      }
+
+      const [scoresSuccess, errorScores, scores] = await upsertScoresSnapshotEpoch()
+      if (!scoresSuccess || !scores) {
+        const error = new Error(errorScores || 'Unable to fetch scores')
+        await sendSyncFailureNotification('snapshot', error)
+        return { result: { success: false, error: errorScores } }
+      }
+
+      return { result: { success: true, epochNumber: fetchActiveEpochData.epochNumber } }
+    }
+    catch (error) {
+      await sendSyncFailureNotification('snapshot', error)
+      return { result: { success: false, error: String(error) } }
+    }
+  },
+})
diff --git a/wrangler.json b/wrangler.json
new file mode 100644
index 0000000..d35a20a
--- /dev/null
+++ b/wrangler.json
@@ -0,0 +1,37 @@
+{
+  "$schema": "node_modules/wrangler/config-schema.json",
+  "name": "validators-api-mainnet",
+  "account_id": "cf9baad7d68d7ee717f3339731e81dfb",
+  "compatibility_date": "2025-01-01",
+  "triggers": { "crons": ["0 * * * *"] },
+  "vars": { "NUXT_PUBLIC_NIMIQ_NETWORK": "main-albatross" },
+  "d1_databases": [{ "binding": "DB", "database_id": "cc9f1d25-676b-4cb3-8af6-887e85a08baa", "database_name": "validators-api-mainnet" }],
+  "kv_namespaces": [{ "binding": "CACHE", "id": "4be4d10e6d3444eca6e7c02cdbcd275f" }],
+  "r2_buckets": [{ "binding": "BLOB", "bucket_name": "validators-api-mainnet" }],
+  "env": {
+    "preview": {
+      "name": "validators-api-mainnet-preview",
+      "triggers": { "crons": ["0 * * * *"] },
+      "vars": { "NUXT_PUBLIC_NIMIQ_NETWORK": "main-albatross" },
+      "d1_databases": [{ "binding": "DB", "database_id": "dd9fa8b7-f5a1-48ab-b0af-d93d1092b89a", "database_name": "validators-api-mainnet-preview" }],
+      "kv_namespaces": [{ "binding": "CACHE", "id": "e3497d0c795d46f59473e187d4d70920" }],
+      "r2_buckets": [{ "binding": "BLOB", "bucket_name": "validators-api-mainnet-preview" }]
+    },
+    "testnet": {
+      "name": "validators-api-testnet",
+      "triggers": { "crons": ["0 * * * *"] },
+      "vars": { "NUXT_PUBLIC_NIMIQ_NETWORK": "test-albatross" },
+      "d1_databases": [{ "binding": "DB", "database_id": "de14e353-5028-4e52-a383-a9cc200d960d", "database_name": "validators-api-testnet" }],
+      "kv_namespaces": [{ "binding": "CACHE", "id": "90c1598af92a4e72a767e6601090f014" }],
+      "r2_buckets": [{ "binding": "BLOB", "bucket_name": "validators-api-testnet" }]
+    },
+    "testnet-preview": {
+      "name": "validators-api-testnet-preview",
+      "triggers": { "crons": ["0 * * * *"] },
+      "vars": { "NUXT_PUBLIC_NIMIQ_NETWORK": "test-albatross" },
+      "d1_databases": [{ "binding": "DB", "database_id": "da6931b2-6d06-4598-911b-fba1fa19efd2", "database_name": "validators-api-testnet-preview" }],
+      "kv_namespaces": [{ "binding": "CACHE", "id": "9ef2ab4420a04df8b5d82825f79620e1" }],
+      "r2_buckets": [{ "binding": "BLOB", "bucket_name": "validators-api-testnet-preview" }]
+    }
+  }
+}