Function syncDevEnvironment

apps/web/scripts/sync-dev-environment.ts:10–156

()

const sql = neon(process.env.DATABASE_URL!);

async function syncDevEnvironment() {
  console.log("🔄 Starting dev environment sync...\n");

  try {
    // Step 1: Sync users from Clerk
    console.log("📥 Step 1: Fetching users from Clerk (dev)...");
    const client = await clerkClient();
    const clerkUsers = await client.users.getUserList({ limit: 500 });
    console.log(`Found ${clerkUsers.data.length} users in Clerk\n`);

    let created = 0;
    let updated = 0;
    let skipped = 0;

    for (const clerkUser of clerkUsers.data) {
      try {
        const userId = clerkUser.id;
        const email = clerkUser.emailAddresses.find(
          (e) => e.id === clerkUser.primaryEmailAddressId,
        );
        const name =
          clerkUser.fullName ||
          clerkUser.firstName ||
          clerkUser.lastName ||
          null;

        // Check if user exists
        const existingUser = await sql`
          SELECT id FROM "user" WHERE id = ${userId}
        `;

        // Check if email exists
        const existingEmail = email?.emailAddress
          ? await sql`SELECT id FROM "user" WHERE email = ${email.emailAddress}`
          : [];

        if (existingUser.length > 0) {
          // Update
          await sql`
            UPDATE "user"
            SET
              name = ${name},
              email = ${email?.emailAddress || null},
              email_verified = ${email?.verification?.status === "verified"},
              image = ${clerkUser.imageUrl || null},
              updated_at = NOW()
            WHERE id = ${userId}
          `;
          updated++;
          console.log(`✓ Updated: ${email?.emailAddress || userId}`);
        } else if (existingEmail.length > 0) {
          // Skip if email exists with different ID
          skipped++;
          console.log(
            `⚠ Skipped: ${email?.emailAddress} (email already exists)`,
          );
        } else {
          // Create