Stripe Webhook中的防御性编程

// ❌ 错误：直接使用，假设是字符串
subscriptionId = object.subscription;

// ✅ 正确：检查类型，安全提取
subscriptionId = typeof object.subscription === 'string'
  ? object.subscription
  : object.subscription?.id;

// 添加null check，避免传递undefined
if (!subscriptionId) {
  console.error("Missing subscription ID in invoice.");
  return c.json({ error: 'Missing subscription ID' }, 400);
}

export const createSupabaseClient = (env, userJWT = null) => {
  // 先检查URL（所有场景都需要）
  if (!env.SUPABASE_URL) {
    throw new Error("Missing SUPABASE_URL environment variable.");
  }

  const options = {
    auth: { autoRefreshToken: false, persistSession: false },
  };

  // 如果提供了userJWT，使用anon key（客户端场景）
  if (userJWT) {
    if (!env.SUPABASE_ANON_KEY) {
      throw new Error("Missing SUPABASE_ANON_KEY for user-context operations.");
    }
    options.global = {
      headers: { Authorization: `Bearer ${userJWT}` },
    };
    return createClient(env.SUPABASE_URL, env.SUPABASE_ANON_KEY, options);
  }

  // 服务端操作，使用service role key
  if (!env.SUPABASE_SERVICE_ROLE_KEY) {
    throw new Error("Missing SUPABASE_SERVICE_ROLE_KEY for server-side operations.");
  }

  return createClient(env.SUPABASE_URL, env.SUPABASE_SERVICE_ROLE_KEY, options);
};

let orderId;
let userId;
let planId;
let subscriptionId;
let customerId;

// ✅ 在switch之前创建supabase实例
const supabase = createSupabaseClient(c.env);

switch (type) {
  case 'checkout.session.completed': {
    // 可以直接使用supabase
    break;
  }

  case 'invoice.payment_succeeded': {
    // 可以直接使用supabase
    break;
  }
}

// Switch后续代码也可以使用supabase
const { data: plan } = await supabase.from('plans')...