Something went wrong. Try again.
Monorepo for Aesthetic.Computer aesthetic.computer
Something went wrong. Try again.
JavaScript
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120#!/usr/bin/env node// Sync all kidlisp records for @fifi to ATProto
import { connect } from "../../system/backend/database.mjs";import { createMediaRecord, MediaTypes } from "../../system/backend/media-atproto.mjs";
const isDryRun = process.argv[2] !== 'live';const BATCH_SIZE = 10; // Process in batches to avoid overwhelming the PDS
async function main() { console.log(`\n🔄 SYNC @FIFI KIDLISP TO ATPROTO`); console.log(` Mode: ${isDryRun ? '🔍 DRY RUN' : '⚡ LIVE'}\n`); const database = await connect(); // Get @fifi user const fifiUser = await database.db.collection('users').findOne({'atproto.handle': 'fifi.at.aesthetic.computer'}); if (!fifiUser) { console.error('❌ @fifi user not found'); await database.disconnect(); process.exit(1); } console.log(`👤 User: ${fifiUser.atproto.handle} (${fifiUser.atproto.did})`); // Find kidlisp missing rkey const kidlispCollection = database.db.collection('kidlisp'); const missing = await kidlispCollection.find({ user: fifiUser._id, $or: [ { 'atproto.rkey': { $exists: false } }, { 'atproto.rkey': null } ] }).toArray(); console.log(`📝 Found ${missing.length} kidlisp records missing ATProto records`); if (missing.length === 0) { console.log('✅ All kidlisp already synced!'); await database.disconnect(); process.exit(0); } if (isDryRun) { console.log(`\n🔍 DRY RUN - Would create ATProto records for ${missing.length} kidlisp`); console.log(` Processing in batches of ${BATCH_SIZE}`); console.log(` Estimated time: ~${Math.ceil(missing.length / BATCH_SIZE)} batches`); console.log(`\nFirst 10 samples:`); missing.slice(0, 10).forEach(k => { console.log(` - ${k.code}: "${k.source?.substring(0, 50)}..."`); }); if (missing.length > 10) { console.log(` ... and ${missing.length - 10} more`); } console.log(`\n💡 Run with 'live' argument to apply changes`); await database.disconnect(); process.exit(0); } // Create ATProto records in batches let created = 0; let failed = 0; const total = missing.length; for (let i = 0; i < missing.length; i += BATCH_SIZE) { const batch = missing.slice(i, i + BATCH_SIZE); const batchNum = Math.floor(i / BATCH_SIZE) + 1; const totalBatches = Math.ceil(missing.length / BATCH_SIZE); console.log(`\n📦 Batch ${batchNum}/${totalBatches} (${i + 1}-${Math.min(i + BATCH_SIZE, total)} of ${total})`); const results = await Promise.all( batch.map(async (kidlisp) => { try { const result = await createMediaRecord( database, MediaTypes.KIDLISP, kidlisp, { userSub: fifiUser._id } ); if (result.error) { return { code: kidlisp.code, success: false, error: result.error }; } else { return { code: kidlisp.code, success: true, rkey: result.rkey }; } } catch (error) { return { code: kidlisp.code, success: false, error: error.message }; } }) ); // Report batch results results.forEach(r => { if (r.success) { console.log(` ✅ ${r.code} → ${r.rkey}`); created++; } else { console.log(` ⚠️ ${r.code}: ${r.error}`); failed++; } }); console.log(` Progress: ${created + failed}/${total} (${created} ✅, ${failed} ❌)`); } console.log(`\n📊 Final Results:`); console.log(` ✅ Created: ${created}`); console.log(` ❌ Failed: ${failed}`); console.log(` 📈 Success rate: ${((created / total) * 100).toFixed(1)}%`); await database.disconnect(); process.exit(0);}
main().catch(err => { console.error('❌ Error:', err); process.exit(1);});