api is now compatible with ioredis

new api using edge runtime need to explictly enable via edge config (`edge_runtime: true`)

package.json

@@ -27,13 +27,15 @@
     "csstype": "^3.1.1",
     "dayjs": "^1.11.7",
     "emoji-regex": "^10.2.1",
+    "encoding": "^0.1.13",
     "i18next": "^22.4.9",
     "ioredis": "^5.3.0",
     "jszip": "^3.10.1",
     "mpegts.js": "^1.7.2",
     "next": "^13.1.6",
     "next-i18next": "^13.0.3",
     "nextjs-progressbar": "^0.0.16",
+    "node-fetch": "^3.3.0",
     "path-browserify": "^1.0.1",
     "plyr-react": "^5.1.2",
     "preview-office-docs": "^1.0.2",

src/middleware.ts

@@ -0,0 +1,31 @@
+import { NextResponse } from 'next/server'
+import type { NextRequest } from 'next/server'
+import { get } from '@vercel/edge-config'
+
+const pattern = /^\/api\/\w+(?=\/|$)/
+
+export async function middleware(request: NextRequest) {
+  const original = request.nextUrl
+
+  let { pathname } = original
+  if (pathname === '/api/') {
+    pathname = '/api/index/'
+  }
+
+  const edgeRuntimeEnabled =  process.env.EDGE_CONFIG && (await get<boolean>('edge_runtime'))
+  if (!edgeRuntimeEnabled) {
+    pathname = pathname.replace(pattern, m => `${m}-v1`)
+  } else {
+    pathname = pathname.replace(pattern, m => `${m}-v2`)
+  }
+  const rewritten = new URL(pathname, original)
+  original.searchParams.forEach((value, key) => {
+    rewritten.searchParams.append(key, value)
+  })
+  return NextResponse.rewrite(rewritten)
+}
+
+// See "Matching Paths" below to learn more
+export const config = {
+  matcher: '/api/:path*',
+}

src/pages/api/index-v1.ts

@@ -0,0 +1,10 @@
+import { NodeRequestToWeb } from '@/utils/api/common'
+import handle from '@/utils/api/index'
+import { kv } from '@/utils/kv/ioredis'
+import { NextApiRequest, NextApiResponse } from 'next'
+import '@/utils/api/fetch-polyfill'
+
+export default async function handler(req: NextApiRequest, res: NextApiResponse) {
+  const response = await handle(kv, NodeRequestToWeb(req))
+  response.toNode(res)
+}

src/pages/api/index-v2.ts

@@ -0,0 +1,11 @@
+import handle from '@/utils/api/index'
+import { kv } from '@/utils/kv/edge'
+import { NextRequest } from 'next/server'
+
+export const config = {
+  runtime: 'edge',
+}
+
+export default async function handler(req: NextRequest) {
+  return (await handle(kv, req)).toWeb()
+}

src/pages/api/item-v1.ts

@@ -0,0 +1,10 @@
+import { NodeRequestToWeb } from '@/utils/api/common'
+import handle from '@/utils/api/item'
+import { kv } from '@/utils/kv/ioredis'
+import { NextApiRequest, NextApiResponse } from 'next'
+import '@/utils/api/fetch-polyfill'
+
+export default async function handler(req: NextApiRequest, res: NextApiResponse) {
+  const response = await handle(kv, NodeRequestToWeb(req))
+  response.toNode(res)
+}

src/pages/api/item-v2.ts

@@ -0,0 +1,11 @@
+import handle from '@/utils/api/item'
+import { kv } from '@/utils/kv/edge'
+import { NextRequest } from 'next/server'
+
+export const config = {
+  runtime: 'edge',
+}
+
+export default async function handler(req: NextRequest) {
+  return (await handle(kv, req)).toWeb()
+}

src/pages/api/name-v1/[name].ts

@@ -0,0 +1,7 @@
+import { NextApiRequest, NextApiResponse } from 'next'
+import '@/utils/api/fetch-polyfill'
+import handle from '../raw-v1'
+
+export default async function handler(req: NextApiRequest, res: NextApiResponse) {
+  return handle(req, res)
+}

src/pages/api/name/[name].ts → src/pages/api/name-v2/[name].ts

@@ -1,5 +1,5 @@
 import { NextRequest } from 'next/server'
-import rawFileHandler from '../raw'
+import rawFileHandler from '../raw-v2'
 
 export const config = {
   runtime: 'edge',

src/pages/api/raw-v1.ts

@@ -0,0 +1,10 @@
+import { NodeRequestToWeb } from '@/utils/api/common'
+import handle from '@/utils/api/raw'
+import { kv } from '@/utils/kv/ioredis'
+import { NextApiRequest, NextApiResponse } from 'next'
+import '@/utils/api/fetch-polyfill'
+
+export default async function handler(req: NextApiRequest, res: NextApiResponse) {
+  const response = await handle(kv, NodeRequestToWeb(req))
+  response.toNode(res)
+}

src/pages/api/raw-v2.ts

@@ -0,0 +1,11 @@
+import handle from '@/utils/api/raw'
+import { kv } from '@/utils/kv/edge'
+import { NextRequest } from 'next/server'
+
+export const config = {
+  runtime: 'edge',
+}
+
+export default async function handler(req: NextRequest) {
+  return (await handle(kv, req)).toWeb()
+}

src/pages/api/search-v1.ts

@@ -0,0 +1,10 @@
+import { NodeRequestToWeb } from '@/utils/api/common'
+import handle from '@/utils/api/search'
+import { kv } from '@/utils/kv/ioredis'
+import { NextApiRequest, NextApiResponse } from 'next'
+import '@/utils/api/fetch-polyfill'
+
+export default async function handler(req: NextApiRequest, res: NextApiResponse) {
+  const response = await handle(kv, NodeRequestToWeb(req))
+  response.toNode(res)
+}

src/pages/api/search-v2.ts

@@ -0,0 +1,11 @@
+import handle from '@/utils/api/search'
+import { kv } from '@/utils/kv/edge'
+import { NextRequest } from 'next/server'
+
+export const config = {
+  runtime: 'edge',
+}
+
+export default async function handler(req: NextRequest) {
+  return (await handle(kv, req)).toWeb()
+}

src/pages/api/thumbnail-v1.ts

@@ -0,0 +1,10 @@
+import { NodeRequestToWeb } from '@/utils/api/common'
+import handle from '@/utils/api/thumbnail'
+import { kv } from '@/utils/kv/ioredis'
+import { NextApiRequest, NextApiResponse } from 'next'
+import '@/utils/api/fetch-polyfill'
+
+export default async function handler(req: NextApiRequest, res: NextApiResponse) {
+  const response = await handle(kv, NodeRequestToWeb(req))
+  response.toNode(res)
+}