commit 8f61091e1b556864f98b4d28f9c3e672ae76bb3a · juli.ee/cleanfollow

+58 -58
src/App.tsx
···

       47
       47
        
           : "https://plc.directory/" + did,

     

       48
       48
        
         );

     

       49
       49
        
       

     

       50
       50
       -
         return await res.json().then((doc) => {

     

       50
       50
       +
         return res.json().then((doc) => {

     

       51
       51
        
           for (const alias of doc.alsoKnownAs) {

     

       52
       52
        
             if (alias.includes("at://")) {

     

       53
       53
        
               return alias.split("//")[1];

     
···

       78
       78
        
           if (result) {

     

       79
       79
        
             agent = new Agent(result.session);

     

       80
       80
        
             setLoginState(true);

     

       81
       81
       -
             setHandle(await resolveDid(agent.did!));

     

       81
       81
       +
             setHandle(await resolveDid(agent.assertDid));

     

       82
       82
        
             sub = result.session.sub;

     

       83
       83
        
           }

     

       84
       84
        
           setNotice("");

     
···

       149
       149
        
             const PAGE_LIMIT = 100;

     

       150
       150
        
             const fetchPage = async (cursor?: string) => {

     

       151
       151
        
               return await agent.com.atproto.repo.listRecords({

     

       152
       152
       -
                 repo: agent.did!,

     

       152
       152
       +
                 repo: agent.assertDid,

     

       153
       153
        
                 collection: "app.bsky.graph.follow",

     

       154
       154
        
                 limit: PAGE_LIMIT,

     

       155
       155
        
                 cursor: cursor,

     
···

       170
       170
        
           setProgress(0);

     

       171
       171
        
           setNotice("");

     

       172
       172
        
       

     

       173
       173
       -
           await fetchFollows().then((follows) => {

     

       174
       174
       -
             setFollowCount(follows.length);

     

       175
       175
       -
             let tmpFollows: FollowRecord[] = [];

     

       176
       176
       -
             follows.forEach(async (record: ComAtprotoRepoListRecords.Record) => {

     

       177
       177
       -
               let status: RepoStatus | undefined = undefined;

     

       178
       178
       -
               const follow = record.value as AppBskyGraphFollow.Record;

     

       179
       179
       -
               let handle = "";

     

       173
       173
       +
           const follows = await fetchFollows();

     

       174
       174
       +
           setFollowCount(follows.length);

     

       175
       175
       +
           let tmpFollows: FollowRecord[] = [];

     

       180
       176
        
       

     

       181
       181
       -
               try {

     

       182
       182
       -
                 const res = await agent.getProfile({

     

       183
       183
       -
                   actor: follow.subject,

     

       184
       184
       -
                 });

     

       177
       177
       +
           follows.forEach(async (record: ComAtprotoRepoListRecords.Record) => {

     

       178
       178
       +
             let status: RepoStatus | undefined = undefined;

     

       179
       179
       +
             const follow = record.value as AppBskyGraphFollow.Record;

     

       180
       180
       +
             let handle = "";

     

       185
       181
        
       

     

       186
       186
       -
                 handle = res.data.handle;

     

       187
       187
       -
                 const viewer = res.data.viewer!;

     

       182
       182
       +
             try {

     

       183
       183
       +
               const res = await agent.getProfile({

     

       184
       184
       +
                 actor: follow.subject,

     

       185
       185
       +
               });

     

       188
       186
        
       

     

       189
       189
       -
                 if (!viewer.followedBy) status = RepoStatus.NONMUTUAL;

     

       187
       187
       +
               handle = res.data.handle;

     

       188
       188
       +
               const viewer = res.data.viewer!;

     

       190
       189
        
       

     

       191
       191
       -
                 if (viewer.blockedBy) {

     

       192
       192
       -
                   status =

     

       193
       193
       -
                     viewer.blocking || viewer.blockingByList ?

     

       194
       194
       -
                       RepoStatus.BLOCKEDBY | RepoStatus.BLOCKING

     

       195
       195
       -
                     : RepoStatus.BLOCKEDBY;

     

       196
       196
       -
                 } else if (res.data.did.includes(agent.did!)) {

     

       197
       197
       -
                   status = RepoStatus.YOURSELF;

     

       198
       198
       -
                 } else if (viewer.blocking || viewer.blockingByList) {

     

       199
       199
       -
                   status = RepoStatus.BLOCKING;

     

       200
       200
       -
                 }

     

       201
       201
       -
               } catch (e: any) {

     

       202
       202
       -
                 handle = await resolveDid(follow.subject);

     

       190
       190
       +
               if (!viewer.followedBy) status = RepoStatus.NONMUTUAL;

     

       203
       191
        
       

     

       192
       192
       +
               if (viewer.blockedBy) {

     

       204
       193
        
                 status =

     

       205
       205
       -
                   e.message.includes("not found") ? RepoStatus.DELETED

     

       206
       206
       -
                   : e.message.includes("deactivated") ? RepoStatus.DEACTIVATED

     

       207
       207
       -
                   : e.message.includes("suspended") ? RepoStatus.SUSPENDED

     

       208
       208
       -
                   : undefined;

     

       194
       194
       +
                   viewer.blocking || viewer.blockingByList ?

     

       195
       195
       +
                     RepoStatus.BLOCKEDBY | RepoStatus.BLOCKING

     

       196
       196
       +
                   : RepoStatus.BLOCKEDBY;

     

       197
       197
       +
               } else if (res.data.did.includes(agent.assertDid)) {

     

       198
       198
       +
                 status = RepoStatus.YOURSELF;

     

       199
       199
       +
               } else if (viewer.blocking || viewer.blockingByList) {

     

       200
       200
       +
                 status = RepoStatus.BLOCKING;

     

       209
       201
        
               }

     

       202
       202
       +
             } catch (e: any) {

     

       203
       203
       +
               handle = await resolveDid(follow.subject);

     

       210
       204
        
       

     

       211
       211
       -
               const status_label =

     

       212
       212
       -
                 status == RepoStatus.DELETED ? "Deleted"

     

       213
       213
       -
                 : status == RepoStatus.DEACTIVATED ? "Deactivated"

     

       214
       214
       -
                 : status == RepoStatus.SUSPENDED ? "Suspended"

     

       215
       215
       -
                 : status == RepoStatus.NONMUTUAL ? "Non Mutual"

     

       216
       216
       -
                 : status == RepoStatus.YOURSELF ? "Literally Yourself"

     

       217
       217
       -
                 : status == RepoStatus.BLOCKING ? "Blocking"

     

       218
       218
       -
                 : status == RepoStatus.BLOCKEDBY ? "Blocked by"

     

       219
       219
       -
                 : RepoStatus.BLOCKEDBY | RepoStatus.BLOCKING ? "Mutual Block"

     

       220
       220
       -
                 : "";

     

       205
       205
       +
               status =

     

       206
       206
       +
                 e.message.includes("not found") ? RepoStatus.DELETED

     

       207
       207
       +
                 : e.message.includes("deactivated") ? RepoStatus.DEACTIVATED

     

       208
       208
       +
                 : e.message.includes("suspended") ? RepoStatus.SUSPENDED

     

       209
       209
       +
                 : undefined;

     

       210
       210
       +
             }

     

       221
       211
        
       

     

       222
       222
       -
               if (status !== undefined) {

     

       223
       223
       -
                 tmpFollows.push({

     

       224
       224
       -
                   did: follow.subject,

     

       225
       225
       -
                   handle: handle,

     

       226
       226
       -
                   uri: record.uri,

     

       227
       227
       -
                   status: status,

     

       228
       228
       -
                   status_label: status_label,

     

       229
       229
       -
                   toDelete: false,

     

       230
       230
       -
                   visible: status == RepoStatus.NONMUTUAL ? false : true,

     

       231
       231
       -
                 });

     

       232
       232
       -
               }

     

       233
       233
       -
               setProgress(progress() + 1);

     

       234
       234
       -
               if (progress() == followCount()) setFollowRecords(tmpFollows);

     

       235
       235
       -
             });

     

       212
       212
       +
             const status_label =

     

       213
       213
       +
               status == RepoStatus.DELETED ? "Deleted"

     

       214
       214
       +
               : status == RepoStatus.DEACTIVATED ? "Deactivated"

     

       215
       215
       +
               : status == RepoStatus.SUSPENDED ? "Suspended"

     

       216
       216
       +
               : status == RepoStatus.NONMUTUAL ? "Non Mutual"

     

       217
       217
       +
               : status == RepoStatus.YOURSELF ? "Literally Yourself"

     

       218
       218
       +
               : status == RepoStatus.BLOCKING ? "Blocking"

     

       219
       219
       +
               : status == RepoStatus.BLOCKEDBY ? "Blocked by"

     

       220
       220
       +
               : RepoStatus.BLOCKEDBY | RepoStatus.BLOCKING ? "Mutual Block"

     

       221
       221
       +
               : "";

     

       222
       222
       +
       

     

       223
       223
       +
             if (status !== undefined) {

     

       224
       224
       +
               tmpFollows.push({

     

       225
       225
       +
                 did: follow.subject,

     

       226
       226
       +
                 handle: handle,

     

       227
       227
       +
                 uri: record.uri,

     

       228
       228
       +
                 status: status,

     

       229
       229
       +
                 status_label: status_label,

     

       230
       230
       +
                 toDelete: false,

     

       231
       231
       +
                 visible: status == RepoStatus.NONMUTUAL ? false : true,

     

       232
       232
       +
               });

     

       233
       233
       +
             }

     

       234
       234
       +
             setProgress(progress() + 1);

     

       235
       235
       +
             if (progress() == followCount()) setFollowRecords(tmpFollows);

     

       236
       236
        
           });

     

       237
       237
        
         };

     

       238
       238
        
       

     
···

       250
       250
        
           const BATCHSIZE = 200;

     

       251
       251
        
           for (let i = 0; i < writes.length; i += BATCHSIZE) {

     

       252
       252
        
             await agent.com.atproto.repo.applyWrites({

     

       253
       253
       -
               repo: agent.did!,

     

       253
       253
       +
               repo: agent.assertDid,

     

       254
       254
        
               writes: writes.slice(i, i + BATCHSIZE),

     

       255
       255
        
             });

     

       256
       256
        
           }