Next.js+Supabase：Webhook数据入库及关联用户问题求助

1. 发起Replicate请求时携带用户ID #

当用户在应用内触发图像生成请求时，除了生成参数，要把当前Supabase认证用户的user_id作为自定义元数据传给Replicate。Replicate完成生成后，会在Webhook回调数据中返回这个元数据。

示例代码（应用内发起请求）：

// 获取当前已认证用户
const { data: { user } } = await supabase.auth.getUser();

// 调用Replicate API并携带用户ID元数据
const replicateResponse = await fetch('https://api.replicate.com/v1/predictions', {
  method: 'POST',
  headers: {
    'Authorization': `Token ${process.env.REPLICATE_API_TOKEN}`,
    'Content-Type': 'application/json',
  },
  body: JSON.stringify({
    version: "你的模型版本ID",
    input: { prompt: "生成提示词" },
    webhook: `${process.env.NEXT_PUBLIC_APP_URL}/api/webhooks/replicate`,
    webhook_events_filter: ["completed"],
    // 携带用户ID
    metadata: { user_id: user?.id }
  })
});

2. 修改Webhook路由，用服务角色密钥关联用户 #

在Next.js的Webhook处理路由中，使用Supabase服务角色密钥创建客户端（绕过RLS），从Replicate回调数据中提取user_id，和图像数据一起插入数据库。

示例Webhook路由代码：

// app/api/webhooks/replicate/route.ts
import { createClient } from '@supabase/supabase-js';
import { revalidatePath } from 'next/cache';

export async function POST(request: Request) {
  const replicateData = await request.json();
  
  // 从回调元数据中获取用户ID
  const userId = replicateData.metadata?.user_id;
  if (!userId) {
    return new Response('Missing user ID', { status: 400 });
  }

  // 创建服务角色客户端，不受RLS限制
  const supabaseAdmin = createClient(
    process.env.NEXT_PUBLIC_SUPABASE_URL!,
    process.env.SUPABASE_SERVICE_ROLE_KEY!
  );

  // 提取图像Cloudinary ID（根据实际回调结构调整）
  const originalImageId = replicateData.input.original_image_cloudinary_public_id;
  const generatedImageIds = replicateData.output; // 假设output是ID数组

  // 插入数据并关联用户ID
  const { error } = await supabaseAdmin
    .from('generated_images')
    .insert({
      original_image_cloudinary_public_id: originalImageId,
      cloudinary_public_id: generatedImageIds,
      user_id: userId
    });

  if (error) {
    console.error('Supabase插入错误:', error);
    return new Response('Internal Server Error', { status: 500 });
  }

  revalidatePath('/create');
  
  return new Response('Success', { status: 200 });
}

3. 完善数据库表结构 #

给generated_images表添加user_id字段，关联到Supabase的auth.users表：

ALTER TABLE generated_images ADD COLUMN user_id uuid REFERENCES auth.users(id);

4. 调整RLS策略（可选） #

如果需要限制用户只能访问自己的生成图像，更新RLS策略：

-- 用户只能查看自己的图像
CREATE POLICY "User can view own generated images" ON generated_images
FOR SELECT USING (auth.uid() = user_id);

-- 用户只能插入自己的图像（普通客户端请求时生效）
CREATE POLICY "User can insert own generated images" ON generated_images
FOR INSERT WITH CHECK (auth.uid() = user_id);

服务角色客户端不受RLS约束，可正常执行插入操作。

内容的提问来源于stack exchange，提问作者Noah Böhringer