修改跨域

Author: zhuyinjun

src/app/api/azuro-graphql/route.ts

@@ -0,0 +1,107 @@
+import { NextRequest, NextResponse } from 'next/server'
+
+/**
+ * 与 @azuro-org/toolkit 中一致的 chainId -> 子路径映射
+ * 用于服务端转发到正确的 GraphQL 端点，避免浏览器直连时的 CORS
+ */
+const ENDPOINT_NAME_BY_CHAIN_ID: Record<number, string> = {
+  100: 'gnosis',       // gnosis
+  137: 'polygon',      // polygon
+  80002: 'polygon-amoy-dev',  // polygonAmoy
+  88882: 'chiliz',     // chiliz
+  88888: 'chiliz-spicy-dev',  // spicy
+  8453: 'base',        // base
+  84532: 'base-sepolia-dev',  // baseSepolia
+  97: 'bsc-dev',       // bscTestnet
+  56: 'bsc',           // bsc
+}
+
+const DEV_CHAIN_IDS = new Set([80002, 88888, 84532, 97])
+
+function getFeedGraphqlEndpoint(chainId: number): string {
+  const name = ENDPOINT_NAME_BY_CHAIN_ID[chainId]
+  if (!name) throw new Error(`Unsupported chainId for feed: ${chainId}`)
+  return `https://thegraph-1.chainfeedon.com/subgraphs/name/azuro-protocol/azuro-data-feed-${name}`
+}
+
+function getBetsGraphqlEndpoint(chainId: number): string {
+  const name = ENDPOINT_NAME_BY_CHAIN_ID[chainId]
+  if (!name) throw new Error(`Unsupported chainId for bets: ${chainId}`)
+  return `https://thegraph.chainfeedon.com/subgraphs/name/azuro-protocol/azuro-api-${name}-v3`
+}
+
+function getLegacyLiveGraphqlEndpoint(chainId: number): string {
+  if (DEV_CHAIN_IDS.has(chainId)) {
+    return 'https://thegraph.chainfeedon.com/subgraphs/name/azuro-protocol/azuro-api-live-data-feed-dev'
+  }
+  return 'https://thegraph.chainfeedon.com/subgraphs/name/azuro-protocol/azuro-api-live-data-feed'
+}
+
+function getTargetUrl(chainId: number, type: 'feed' | 'bets' | 'legacyLive'): string {
+  switch (type) {
+    case 'feed':
+      return getFeedGraphqlEndpoint(chainId)
+    case 'bets':
+      return getBetsGraphqlEndpoint(chainId)
+    case 'legacyLive':
+      return getLegacyLiveGraphqlEndpoint(chainId)
+    default:
+      throw new Error(`Unknown type: ${type}`)
+  }
+}
+
+export async function POST(request: NextRequest) {
+  try {
+    const { searchParams } = new URL(request.url)
+    const chainIdStr = searchParams.get('chainId')
+    const type = (searchParams.get('type') || 'feed') as 'feed' | 'bets' | 'legacyLive'
+
+    if (!chainIdStr) {
+      return NextResponse.json(
+        { error: 'Missing query param: chainId' },
+        { status: 400 }
+      )
+    }
+
+    const chainId = parseInt(chainIdStr, 10)
+    if (Number.isNaN(chainId) || !ENDPOINT_NAME_BY_CHAIN_ID[chainId]) {
+      return NextResponse.json(
+        { error: `Unsupported or invalid chainId: ${chainIdStr}` },
+        { status: 400 }
+      )
+    }
+
+    const targetUrl = getTargetUrl(chainId, type)
+    const body = await request.json()
+
+    const forwardParams = new URLSearchParams(searchParams)
+    forwardParams.delete('chainId')
+    forwardParams.delete('type')
+    const queryString = forwardParams.toString()
+    const url = queryString ? `${targetUrl}?${queryString}` : targetUrl
+
+    const res = await fetch(url, {
+      method: 'POST',
+      headers: {
+        'Content-Type': 'application/json',
+        Accept: 'application/graphql-response+json',
+      },
+      body: JSON.stringify(body),
+      cache: 'no-store',
+    })
+
+    const data = await res.json()
+
+    if (!res.ok) {
+      return NextResponse.json(data, { status: res.status })
+    }
+
+    return NextResponse.json(data)
+  } catch (err) {
+    console.error('[azuro-graphql] proxy error:', err)
+    return NextResponse.json(
+      { error: err instanceof Error ? err.message : 'Proxy failed' },
+      { status: 500 }
+    )
+  }
+}

src/compositions/Providers/Providers.tsx

@@ -9,10 +9,14 @@ import { SvgProvider, SvgSprite } from 'svg-provider'
 import { AzuroSDKProvider, LiveProvider } from '@azuro-org/sdk'
 import { WagmiProvider } from 'wallet'
 import { DeviceProvider, LocaleProvider, OddsViewProvider } from 'contexts'
+import { patchAzuroChainsForCors } from 'helpers/patchAzuroChainsForCors'
 import type { Locale } from 'i18n/config'
 
 import NewFreeBetsChecker from 'compositions/NewFreeBetsChecker/NewFreeBetsChecker'
 
+// 将 Azuro GraphQL 请求改为走同源代理，避免 CORS
+patchAzuroChainsForCors()
+
 
 type Props = {
   locale: Locale

src/helpers/patchAzuroChainsForCors.ts

@@ -0,0 +1,21 @@
+/**
+ * 在客户端将 Azuro GraphQL 请求改为走同源代理，避免直连 thegraph 时的 CORS。
+ * 必须在 AzuroSDKProvider 使用 chainsData 之前执行（在 Providers 中引入即可）。
+ */
+import { chainsData } from '@azuro-org/toolkit'
+
+const PROXY_PATH = '/api/azuro-graphql'
+
+export function patchAzuroChainsForCors(): void {
+  if (typeof window === 'undefined') return
+
+  Object.keys(chainsData).forEach((key) => {
+    const chainId = Number(key)
+    const chain = chainsData[chainId as keyof typeof chainsData]
+    if (chain?.graphql) {
+      chain.graphql.feed = `${PROXY_PATH}?chainId=${chainId}&type=feed`
+      chain.graphql.bets = `${PROXY_PATH}?chainId=${chainId}&type=bets`
+      chain.graphql.legacyLive = `${PROXY_PATH}?chainId=${chainId}&type=legacyLive`
+    }
+  })
+}