Something went wrong. Try again.
Monorepo for Aesthetic.Computer aesthetic.computer
Something went wrong. Try again.
JavaScript
12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182#!/usr/bin/env node// create-bulk-accounts.mjs// Create ATProto accounts for multiple users in bulk
import { createAccount } from './create-account.mjs';import { connect } from '../../../system/backend/database.mjs';import { shell } from '../../../system/backend/shell.mjs';
async function main() { const batchSize = parseInt(process.argv[2]) || 10; console.log(`🦋 Creating ATProto accounts for ${batchSize} users...\n`); // Connect to database const database = await connect(); const users = database.db.collection('users'); // Find users without ATProto accounts const usersToProcess = await users.find({ 'atproto.did': { $exists: false } }).limit(batchSize).toArray(); console.log(`📊 Found ${usersToProcess.length} users without ATProto accounts\n`); if (usersToProcess.length === 0) { console.log('✅ All users already have ATProto accounts!\n'); await database.disconnect(); return; } let created = 0; let failed = 0; const errors = []; for (let i = 0; i < usersToProcess.length; i++) { const user = usersToProcess[i]; const progress = `[${i + 1}/${usersToProcess.length}]`; try { console.log(`\n${'═'.repeat(80)}`); console.log(`${progress} Processing: ${user._id}`); console.log(`${'═'.repeat(80)}`); await createAccount(user._id); created++; console.log(`\n✅ ${progress} Success!`); // Small delay to avoid overwhelming the PDS if (i < usersToProcess.length - 1) { await new Promise(resolve => setTimeout(resolve, 1000)); } } catch (error) { failed++; errors.push({ sub: user._id, error: error.message }); console.error(`\n❌ ${progress} Failed: ${error.message}`); } } await database.disconnect(); // Summary console.log(`\n${'═'.repeat(80)}`); console.log('📊 BULK CREATION SUMMARY'); console.log(`${'═'.repeat(80)}`); console.log(`✅ Created: ${created}`); console.log(`❌ Failed: ${failed}`); console.log(`📊 Total: ${usersToProcess.length}`); if (errors.length > 0) { console.log(`\n❌ ERRORS:`); errors.forEach(({ sub, error }) => { console.log(` ${sub}: ${error}`); }); } console.log(`\n${'═'.repeat(80)}\n`);}
main().catch(console.error);