+4

src/label.ts

reviewed

··· 43 43 return set; 44 44 }, new Set<string>()); 45 45 46 46 + console.log("labels: ", Array.from(labels)); 47 47 + 48 48 + console.log("got an rkey: ", rkey); 49 49 + 46 50 if (rkey.includes(DELETE)) { 47 51 await handleDeleteLabels(did, labels); 48 52 } else if (labels.size === 0) {

+4 -3

src/main.ts

reviewed

··· 33 33 34 34 ws.on('open', () => { 35 35 intervalID = setInterval(() => { 36 36 - console.log(`${new Date().toISOString()}: ${cursor}`); 36 36 + console.log(`Cursor at ${new Date().toISOString()}: ${cursor}`); 37 37 fs.writeFile('cursor.txt', cursor.toString(), (err) => { 38 38 if (err) console.log(err); 39 39 }); 40 40 - }, 60000); 40 40 + }, 5000); 41 41 }); 42 42 43 43 ws.on('close', () => { ··· 52 52 // eslint-disable-next-line @typescript-eslint/no-unnecessary-condition 53 53 if (event.commit?.record?.$type === 'app.bsky.feed.like') { 54 54 // eslint-disable-next-line @typescript-eslint/no-unnecessary-condition 55 55 - if (event.commit?.record?.subject?.uri?.includes(`at://${DID}/app.bsky.labeler.service/self`)) { 55 55 + //if (event.commit?.record?.subject?.uri?.includes(`at://${DID}/app.bsky.labeler.service/self`)) { 56 56 + if (event.commit?.record?.subject?.uri?.includes(DID)) { 56 57 label(event.did, event.commit.record.subject.uri.split('/').pop()!).catch((error: unknown) => { 57 58 console.error(`Unexpected error labeling ${event.did}:`); 58 59 console.error(error);