fix update app

supabase/functions/update-app/index.ts

@@ -52,24 +52,40 @@ Deno.serve(async (req) => {
     const timestamp = Math.floor(Date.now() / 3600000) * 3600;
 
     // 上传所有 app 数据到 storage
-    const allAppsJson = JSON.stringify(allApps);
     const directory = `app-category/${timestamp}`;
-    const allAppsFileName = `${directory}/app_all.json`;
     const bucketName = 'cache'; // 替换为存储桶名称
+    // 分页参数
+    const pageSize = 30;
+    const totalCount = allApps.length;
+    const paginatedApps = [];
+    for (let i = 0; i < totalCount; i += pageSize) {
+      paginatedApps.push(allApps.slice(i, i + pageSize));
+    }
 
-    const { error: allAppsUploadError } = await supabase.storage
-      .from(bucketName)
-      .upload(allAppsFileName, new Blob([allAppsJson]), {
-        contentType: 'application/json',
-        upsert: true,
+    // 遍历分页后的数据并上传
+    for (let pageNum = 1; pageNum <= paginatedApps.length; pageNum++) {
+      const pageApps = paginatedApps[pageNum - 1];
+      const pageJson = JSON.stringify({
+        total_count: totalCount,
+        apps: pageApps,
       });
 
-    if (allAppsUploadError) {
-      console.error('Error uploading all apps JSON:', allAppsUploadError);
-      return new Response(
-        JSON.stringify({ error: 'Failed to upload all apps JSON' }),
-        { status: 500 }
-      );
+      const pageFileName = `${directory}/app_all_${pageNum}.json`;
+
+      const { error: pageUploadError } = await supabase.storage
+        .from(bucketName)
+        .upload(pageFileName, new Blob([pageJson]), {
+          contentType: 'application/json',
+          upsert: true,
+        });
+
+      if (pageUploadError) {
+        console.error(`Error uploading page ${pageNum} JSON:`, pageUploadError);
+        return new Response(
+          JSON.stringify({ error: `Failed to upload app_all_${pageNum}.json` }),
+          { status: 500 }
+        );
+      }
     }
 
     // 按 category_id 分组
@@ -82,28 +98,45 @@ Deno.serve(async (req) => {
     });
 
     // 上传每个 category_id 的数据
+    // 上传每个 category_id 的分页数据
     for (const [categoryId, apps] of Object.entries(groupedData)) {
-      const categoryJson = JSON.stringify(apps);
-      const categoryFileName = `${directory}/${categoryId}.json`;
+      const totalCount = apps.length; // 当前分类的总数
+      const pageSize = 30;
+      const paginatedApps = [];
+      for (let i = 0; i < totalCount; i += pageSize) {
+        paginatedApps.push(apps.slice(i, i + pageSize));
+      }
 
-      const { error: categoryUploadError } = await supabase.storage
-        .from(bucketName)
-        .upload(categoryFileName, new Blob([categoryJson]), {
-          contentType: 'application/json',
-          upsert: true,
+      // 遍历分页数据并上传
+      for (let pageNum = 1; pageNum <= paginatedApps.length; pageNum++) {
+        const pageApps = paginatedApps[pageNum - 1];
+        const pageJson = JSON.stringify({
+          total_count: totalCount,
+          apps: pageApps,
         });
 
-      if (categoryUploadError) {
-        console.error(
-          `Error uploading category ${categoryId} JSON:`,
-          categoryUploadError
-        );
-        return new Response(
-          JSON.stringify({
-            error: `Failed to upload category ${categoryId} JSON`,
-          }),
-          { status: 500 }
-        );
+        // 文件名格式：{categoryId}_{pageNum}.json
+        const categoryPageFileName = `${directory}/${categoryId}_${pageNum}.json`;
+
+        const { error: categoryPageUploadError } = await supabase.storage
+          .from(bucketName)
+          .upload(categoryPageFileName, new Blob([pageJson]), {
+            contentType: 'application/json',
+            upsert: true,
+          });
+
+        if (categoryPageUploadError) {
+          console.error(
+            `Error uploading category ${categoryId} page ${pageNum} JSON:`,
+            categoryPageUploadError
+          );
+          return new Response(
+            JSON.stringify({
+              error: `Failed to upload category ${categoryId} page ${pageNum} JSON`,
+            }),
+            { status: 500 }
+          );
+        }
       }
     }
     return new Response(
@@ -111,11 +144,15 @@ Deno.serve(async (req) => {
         message: 'All data uploaded successfully',
         fileName: allAppsFileName,
       }),
-      { status: 200 }
+      {
+        headers: { 'Content-Type': 'application/json' },
+        status: 200
+      }
     );
   } catch (err) {
     console.error('Unexpected error:', err);
     return new Response(JSON.stringify({ error: 'Internal server error' }), {
+      headers: { 'Content-Type': 'application/json' },
       status: 500,
     });
   }