commit 3ac1b3673dadf1688037812df1d3f8af4bde8fbe · nekomimi.pet/wisp.place-monorepo

+55 -1
src/routes/site.ts
···

       4
       4
        
       import { Agent } from '@atproto/api'

     

       5
       5
        
       import { deleteSite } from '../lib/db'

     

       6
       6
        
       import { logger } from '../lib/logger'

     

       7
       7
       +
       import { extractSubfsUris } from '../lib/wisp-utils'

     

       7
       8
        
       

     

       8
       9
        
       export const siteRoutes = (client: NodeOAuthClient, cookieSecret: string) =>

     

       9
       10
        
       	new Elysia({

     
···

       31
       32
        
       				// Create agent with OAuth session

     

       32
       33
        
       				const agent = new Agent((url, init) => auth.session.fetchHandler(url, init))

     

       33
       34
        
       

     

       34
       34
       -
       				// Delete the record from AT Protocol

     

       35
       35
       +
       				// First, fetch the site record to find any subfs references

     

       36
       36
       +
       				let subfsUris: Array<{ uri: string; path: string }> = [];

     

       37
       37
       +
       				try {

     

       38
       38
       +
       					const existingRecord = await agent.com.atproto.repo.getRecord({

     

       39
       39
       +
       						repo: auth.did,

     

       40
       40
       +
       						collection: 'place.wisp.fs',

     

       41
       41
       +
       						rkey: rkey

     

       42
       42
       +
       					});

     

       43
       43
       +
       

     

       44
       44
       +
       					if (existingRecord.data.value && typeof existingRecord.data.value === 'object' && 'root' in existingRecord.data.value) {

     

       45
       45
       +
       						const manifest = existingRecord.data.value as any;

     

       46
       46
       +
       						subfsUris = extractSubfsUris(manifest.root);

     

       47
       47
       +
       

     

       48
       48
       +
       						if (subfsUris.length > 0) {

     

       49
       49
       +
       							console.log(`Found ${subfsUris.length} subfs records to delete`);

     

       50
       50
       +
       							logger.info(`[Site] Found ${subfsUris.length} subfs records associated with ${rkey}`);

     

       51
       51
       +
       						}

     

       52
       52
       +
       					}

     

       53
       53
       +
       				} catch (err) {

     

       54
       54
       +
       					// Record might not exist, continue with deletion

     

       55
       55
       +
       					console.log('Could not fetch site record for subfs cleanup, continuing...');

     

       56
       56
       +
       				}

     

       57
       57
       +
       

     

       58
       58
       +
       				// Delete the main record from AT Protocol

     

       35
       59
        
       				try {

     

       36
       60
        
       					await agent.com.atproto.repo.deleteRecord({

     

       37
       61
        
       						repo: auth.did,

     
···

       42
       66
        
       				} catch (err) {

     

       43
       67
        
       					logger.error(`[Site] Failed to delete site ${rkey} from PDS`, err)

     

       44
       68
        
       					throw new Error('Failed to delete site from AT Protocol')

     

       69
       69
       +
       				}

     

       70
       70
       +
       

     

       71
       71
       +
       				// Delete associated subfs records

     

       72
       72
       +
       				if (subfsUris.length > 0) {

     

       73
       73
       +
       					console.log(`Deleting ${subfsUris.length} associated subfs records...`);

     

       74
       74
       +
       

     

       75
       75
       +
       					await Promise.all(

     

       76
       76
       +
       						subfsUris.map(async ({ uri }) => {

     

       77
       77
       +
       							try {

     

       78
       78
       +
       								// Parse URI: at://did/collection/rkey

     

       79
       79
       +
       								const parts = uri.replace('at://', '').split('/');

     

       80
       80
       +
       								const subRkey = parts[2];

     

       81
       81
       +
       

     

       82
       82
       +
       								await agent.com.atproto.repo.deleteRecord({

     

       83
       83
       +
       									repo: auth.did,

     

       84
       84
       +
       									collection: 'place.wisp.subfs',

     

       85
       85
       +
       									rkey: subRkey

     

       86
       86
       +
       								});

     

       87
       87
       +
       

     

       88
       88
       +
       								console.log(`  🗑️  Deleted subfs: ${uri}`);

     

       89
       89
       +
       								logger.info(`[Site] Deleted subfs record: ${uri}`);

     

       90
       90
       +
       							} catch (err: any) {

     

       91
       91
       +
       								// Log but don't fail if subfs deletion fails

     

       92
       92
       +
       								console.warn(`Failed to delete subfs ${uri}:`, err?.message);

     

       93
       93
       +
       								logger.warn(`[Site] Failed to delete subfs ${uri}`, err);

     

       94
       94
       +
       							}

     

       95
       95
       +
       						})

     

       96
       96
       +
       					);

     

       97
       97
       +
       

     

       98
       98
       +
       					logger.info(`[Site] Deleted ${subfsUris.length} subfs records for ${rkey}`);

     

       45
       99
        
       				}

     

       46
       100
        
       

     

       47
       101
        
       				// Delete from database