reorg and format

.gitignore

···
 
 # Finder (MacOS) folder config
 .DS_Store
+*.json

bun.lock

···
   "workspaces": {
     "": {
       "name": "unfollower",
+      "dependencies": {
+        "@atproto/api": "^0.18.3",
+      },
       "devDependencies": {
         "@types/bun": "latest",
       },
···
     },
   },
   "packages": {
+    "@atproto/api": ["@atproto/api@0.18.3", "", { "dependencies": { "@atproto/common-web": "^0.4.5", "@atproto/lexicon": "^0.5.2", "@atproto/syntax": "^0.4.1", "@atproto/xrpc": "^0.7.6", "await-lock": "^2.2.2", "multiformats": "^9.9.0", "tlds": "^1.234.0", "zod": "^3.23.8" } }, "sha512-CBqyZfkcKYsr348KP4CKb9plMlZ5A96HwA/DnYscPBl6fvMZkAezAjniZX+xUILASHQJg5c+NaNw9xP8ZuyyDQ=="],
+
+    "@atproto/common-web": ["@atproto/common-web@0.4.5", "", { "dependencies": { "@atproto/lex-data": "0.0.1", "@atproto/lex-json": "0.0.1", "zod": "^3.23.8" } }, "sha512-Tx0xUafLm3vRvOQpbBl5eb9V8xlC7TaRXs6dAulHRkDG3Kb+P9qn3pkDteq+aeMshbVXbVa1rm3Ok4vFyuoyYA=="],
+
+    "@atproto/lex-data": ["@atproto/lex-data@0.0.1", "", { "dependencies": { "@atproto/syntax": "0.4.1", "multiformats": "^9.9.0", "tslib": "^2.8.1", "uint8arrays": "3.0.0", "unicode-segmenter": "^0.14.0" } }, "sha512-DrS/8cQcQs3s5t9ELAFNtyDZ8/PdiCx47ALtFEP2GnX2uCBHZRkqWG7xmu6ehjc787nsFzZBvlnz3T/gov5fGA=="],
+
+    "@atproto/lex-json": ["@atproto/lex-json@0.0.1", "", { "dependencies": { "@atproto/lex-data": "0.0.1", "tslib": "^2.8.1" } }, "sha512-ivcF7+pDRuD/P97IEKQ/9TruunXj0w58Khvwk3M6psaI5eZT6LRsRZ4cWcKaXiFX4SHnjy+x43g0f7pPtIsERg=="],
+
+    "@atproto/lexicon": ["@atproto/lexicon@0.5.2", "", { "dependencies": { "@atproto/common-web": "^0.4.4", "@atproto/syntax": "^0.4.1", "iso-datestring-validator": "^2.2.2", "multiformats": "^9.9.0", "zod": "^3.23.8" } }, "sha512-lRmJgMA8f5j7VB5Iu5cp188ald5FuI4FlmZ7nn6EBrk1dgOstWVrI5Ft6K3z2vjyLZRG6nzknlsw+tDP63p7bQ=="],
+
+    "@atproto/syntax": ["@atproto/syntax@0.4.1", "", {}, "sha512-CJdImtLAiFO+0z3BWTtxwk6aY5w4t8orHTMVJgkf++QRJWTxPbIFko/0hrkADB7n2EruDxDSeAgfUGehpH6ngw=="],
+
+    "@atproto/xrpc": ["@atproto/xrpc@0.7.6", "", { "dependencies": { "@atproto/lexicon": "^0.5.2", "zod": "^3.23.8" } }, "sha512-RvCf4j0JnKYWuz3QzsYCntJi3VuiAAybQsMIUw2wLWcHhchO9F7UaBZINLL2z0qc/cYWPv5NSwcVydMseoCZLA=="],
+
     "@types/bun": ["@types/bun@1.3.3", "", { "dependencies": { "bun-types": "1.3.3" } }, "sha512-ogrKbJ2X5N0kWLLFKeytG0eHDleBYtngtlbu9cyBKFtNL3cnpDZkNdQj8flVf6WTZUX5ulI9AY1oa7ljhSrp+g=="],
 
     "@types/node": ["@types/node@24.10.1", "", { "dependencies": { "undici-types": "~7.16.0" } }, "sha512-GNWcUTRBgIRJD5zj+Tq0fKOJ5XZajIiBroOF0yvj2bSU1WvNdYS/dn9UxwsujGW4JX06dnHyjV2y9rRaybH0iQ=="],
 
+    "await-lock": ["await-lock@2.2.2", "", {}, "sha512-aDczADvlvTGajTDjcjpJMqRkOF6Qdz3YbPZm/PyW6tKPkx2hlYBzxMhEywM/tU72HrVZjgl5VCdRuMlA7pZ8Gw=="],
+
     "bun-types": ["bun-types@1.3.3", "", { "dependencies": { "@types/node": "*" } }, "sha512-z3Xwlg7j2l9JY27x5Qn3Wlyos8YAp0kKRlrePAOjgjMGS5IG6E7Jnlx736vH9UVI4wUICwwhC9anYL++XeOgTQ=="],
 
+    "iso-datestring-validator": ["iso-datestring-validator@2.2.2", "", {}, "sha512-yLEMkBbLZTlVQqOnQ4FiMujR6T4DEcCb1xizmvXS+OxuhwcbtynoosRzdMA69zZCShCNAbi+gJ71FxZBBXx1SA=="],
+
+    "multiformats": ["multiformats@9.9.0", "", {}, "sha512-HoMUjhH9T8DDBNT+6xzkrd9ga/XiBI4xLr58LJACwK6G3HTOPeMz4nB4KJs33L2BelrIJa7P0VuNaVF3hMYfjg=="],
+
+    "tlds": ["tlds@1.261.0", "", { "bin": { "tlds": "bin.js" } }, "sha512-QXqwfEl9ddlGBaRFXIvNKK6OhipSiLXuRuLJX5DErz0o0Q0rYxulWLdFryTkV5PkdZct5iMInwYEGe/eR++1AA=="],
+
+    "tslib": ["tslib@2.8.1", "", {}, "sha512-oJFu94HQb+KVduSUQL7wnpmqnfmLsOA/nAh6b6EH0wCEoK0/mPeXU6c3wKDV83MkOuHPRHtSXKKU99IBazS/2w=="],
+
     "typescript": ["typescript@5.9.3", "", { "bin": { "tsc": "bin/tsc", "tsserver": "bin/tsserver" } }, "sha512-jl1vZzPDinLr9eUt3J/t7V6FgNEw9QjvBPdysz9KfQDD41fQrC2Y4vKQdiaUpFT4bXlb1RHhLpp8wtm6M5TgSw=="],
+
+    "uint8arrays": ["uint8arrays@3.0.0", "", { "dependencies": { "multiformats": "^9.4.2" } }, "sha512-HRCx0q6O9Bfbp+HHSfQQKD7wU70+lydKVt4EghkdOvlK/NlrF90z+eXV34mUd48rNvVJXwkrMSPpCATkct8fJA=="],
 
     "undici-types": ["undici-types@7.16.0", "", {}, "sha512-Zz+aZWSj8LE6zoxD+xrjh4VfkIG8Ya6LvYkZqtUQGJPZjYl53ypCaUwWqo7eI0x66KBGeRo+mlBEkMSeSZ38Nw=="],
+
+    "unicode-segmenter": ["unicode-segmenter@0.14.0", "", {}, "sha512-AH4lhPCJANUnSLEKnM4byboctePJzltF4xj8b+NbNiYeAkAXGh7px2K/4NANFp7dnr6+zB3e6HLu8Jj8SKyvYg=="],
+
+    "zod": ["zod@3.25.76", "", {}, "sha512-gzUt/qt81nXsFGKIFcC3YnfEAx5NkunCfnDlvuBSSFS02bcXu4Lmea0AFIUwbLWxWPx3d9p8S5QoaujKcNQxcQ=="],
   }
 }

constants.ts

···
+export const MONTHS_IN_DAYS = Number(Bun.env.DAYS_SINCE_LAST_POST);
+export const USER_AGENT =
+	"swab/https://tangled.org/dane.is.extraordinarily.cool/swab";
+export const IDENTIFIER = Bun.env.IDENTIFIER as string;
+export const PDS_URL = Bun.env.PDS_URL as string;
+export const BSKY_USERNAME = Bun.env.BSKY_USERNAME as string;
+export const BSKY_APP_PASSWORD = Bun.env.BSKY_APP_PASSWORD as string;

index.ts

···
-interface Follow {
-        did: string;
-    handle: string;
-    displayName: string;
-    avatar: string;
-    associated: {
-        activitySubsription:{
-            allowSubscriptions: string;
-        }
-    }
-        labels: unknown[]
-        createdAt: string;
-        description: string;
-        indexedAt: string;
-}
+import { IDENTIFIER, MONTHS_IN_DAYS } from "./constants";
+import {
+	getDateDifferenceInDays,
+	getFollowRecords,
+	getRecentPost,
+	resolveIdentity,
+} from "./utils";
 
-interface MiniDoc {
-    did: string;
-    handle: string;
-    pds: string;
-    signing_key: string;
-}
+let cursor: string | undefined;
 
-interface Post {
-    uri: string;
-    cid: string;
-    value: {
-        text: string;
-        $type: "app.bsky.feed.post"
-        langs: string[]
-        reply: {
-            root: {
-                cid: string;
-                uri: string;
-            },
-            parent: {
-                cid: string;
-                uri: string;
-            }
-        }
-        createdAt: string;
-    }
-}
+const unfollows = [];
 
-const headers = {
-    'User-Agent': 'swab/https://tangled.org/dane.is.extraordinarily.cool/swab'
-}
-
-const MONTHS_IN_DAYS = 183 // 6 months, seems reasonable
-
-
-// https://stackoverflow.com/questions/3224834/get-difference-between-2-dates-in-javascript
-function getDateDifferenceInDays(start: Date, end: Date) {
-    const MS_PER_DAY = 1000 * 60 * 60 * 24;
-    const startUTCDate = Date.UTC(start.getFullYear(), start.getMonth(), start.getDate());
-    const endUTCDate = Date.UTC(end.getFullYear(), end.getMonth(), end.getDate());
-    return Math.floor((endUTCDate - startUTCDate) / MS_PER_DAY);
-}
-
-async function resolveIdentity(indentifier: string): Promise<MiniDoc> {
-    try {
-     const response = await fetch(`https://slingshot.microcosm.blue/xrpc/com.bad-example.identity.resolveMiniDoc?identifier=${indentifier}`, {headers})
-     if (!response.ok) {
-        // throw new Error(`Failed to fetch minidoc for ${indentifier}. Status - ${response.status}`)
-        console.error(`Failed to fetch minidoc for ${indentifier}. Status - ${response.status}`)
-     }
-     const data = await response.json() as MiniDoc
-     return data
-    } catch (error) {
-        if (error instanceof Error) {
-            console.error(error.message)
-        }
-        throw error;
-    }
-}
-
-async function getRecentPost(doc: MiniDoc) {
-    try {
-        const response = await fetch(`${doc.pds}/xrpc/com.atproto.repo.listRecords?repo=${doc.did}&collection=app.bsky.feed.post&limit=1`, {headers})
-        if (!response.ok) {
-            // throw new Error(`There was an error fetching posts for ${doc.handle}. Status - ${response.status}`)
-            console.error(`There was an error fetching posts for ${doc.handle}. Status - ${response.status}`)
-        }
-        const data = await response.json() as {records: Post[]}
-        return data;
-    } catch (error) {
-        if (error instanceof Error) {
-            console.error(error.message)
-        }
-
-        throw error;
-    }
-}
-
-async function getFollowsByUser(did: string, cursor?: string) {
-    try {
-        const response = await fetch(`https://public.api.bsky.app/xrpc/app.bsky.graph.getFollows?actor=${did}&cursor=${cursor}&limit=100`)
-        if (!response.ok) {
-            // throw new Error(`There was a problem getting follows for ${did}. Status - ${response.status}`)
-            console.error(`There was a problem getting follows for ${did}. Status - ${response.status}`)
-        }
-
-       const data = await response.json() as {
-        cursor: string
-        follows: Follow[]
-       }
-
-       return {
-        cursor: data?.cursor,
-        follows: data?.follows
-       }
-    } catch (error) {
-         if (error instanceof Error) {
-            console.error(error.message)
-        }
-        throw error;
-    }
-}
-
-let cursor: string | undefined;
-
-const unfollowMap = new Map<string, number>();
+const doc = await resolveIdentity(IDENTIFIER);
 
 do {
-    const {follows, cursor: followsCursor} = await getFollowsByUser("did:plc:qttsv4e7pu2jl3ilanfgc3zn", cursor)
-    for (const [index, follower] of follows.entries()) {
-        const doc = await resolveIdentity(follower.did)
-        const post = await getRecentPost(doc)
+	const { follows, cursor: followCursor } = await getFollowRecords(doc, cursor);
 
-
-        // it's possible that someone has never made a post i guess, we should add them to the list
-        if (!post?.records?.[0]) {
-            // neg 1 can represent never made post
-            unfollowMap.set(follower.handle, -1)
-        }
-        if (post?.records[0] && post?.records[0]?.value) {
-            const recentPostCreationDate = post?.records?.[0].value?.createdAt
-            // invalid date for some reason idk
-            const daysSinceLastPost = getDateDifferenceInDays(new Date(recentPostCreationDate), new Date())
-            if (daysSinceLastPost >= MONTHS_IN_DAYS) {
-                unfollowMap.set(follower.handle, daysSinceLastPost)
-            }
+	for (const [index, record] of follows.entries()) {
+		const doc = await resolveIdentity(record?.value?.subject);
+		const post = await getRecentPost(doc);
 
-            console.clear();
-            console.info(`Auditing user [${index + 1} / ${follows.length}]`)
-        }
+		// it's possible that someone has never made a post i guess, we should add them to the list
+		if (!post?.records) {
+			// neg 1 can represent never made post
+			unfollows.push({ did: record?.value?.subject, lastPost: -1, uri: "" });
+			continue;
+		}
+		if (post?.records?.[0]?.value) {
+			const recentPostCreationDate = post?.records?.[0].value?.createdAt;
+			const daysSinceLastPost = getDateDifferenceInDays(
+				new Date(recentPostCreationDate),
+				new Date(),
+			);
+			if (daysSinceLastPost >= MONTHS_IN_DAYS) {
+				unfollows.push({
+					did: record?.value?.subject,
+					lastPost: daysSinceLastPost,
+					uri: record?.uri,
+				});
+			}
+		}
 
-        // await new Promise((resolve) => setTimeout(resolve, 1000))
-}
-cursor = followsCursor
-} while (cursor)
+		console.clear();
+		console.info(`Auditing user [${index + 1} / ${follows.length}]`);
+	}
 
+	cursor = followCursor;
+} while (cursor);
 
-console.log(unfollowMap)
+await Bun.write("follows.json", JSON.stringify(unfollows));
+console.info(`wrote ${unfollows.length} accounts to follows.json`);

package.json

···
   },
   "peerDependencies": {
     "typescript": "^5"
+  },
+  "dependencies": {
+    "@atproto/api": "^0.18.3"
   }
 }

types.ts

···
+export interface FollowRecord {
+	uri: string;
+	cid: string;
+	value: {
+		$type: "app.bsky.graph.follow";
+		subject: string;
+		createdAt: string;
+	};
+}
+
+export interface MiniDoc {
+	did: string;
+	handle: string;
+	pds: string;
+	signing_key: string;
+}
+
+export interface Post {
+	uri: string;
+	cid: string;
+	value: {
+		text: string;
+		$type: "app.bsky.feed.post";
+		langs: string[];
+		reply: {
+			root: {
+				cid: string;
+				uri: string;
+			};
+			parent: {
+				cid: string;
+				uri: string;
+			};
+		};
+		createdAt: string;
+	};
+}

unfollow.ts

···
+import { AtpAgent } from "@atproto/api";
+import { BSKY_APP_PASSWORD, BSKY_USERNAME, PDS_URL } from "./constants";
+
+const agent = new AtpAgent({
+	service: PDS_URL,
+});
+
+await agent.login({
+	identifier: BSKY_USERNAME,
+	password: BSKY_APP_PASSWORD,
+});
+
+const file = Bun.file("follows.json");
+
+const unfollows = (await file.json()) as {
+	did: string;
+	lastPost: number;
+	uri: string;
+}[];
+
+for (const [index, unfollow] of unfollows.entries()) {
+	if (unfollow.lastPost === -1 || unfollow.uri === "") {
+		// will figure something out later for this
+		continue;
+	}
+
+	console.clear();
+	console.info(
+		`unfollowing ${unfollow.did} [${index + 1} / ${unfollows.length}]`,
+	);
+	await agent.deleteFollow(unfollow.uri);
+}

utils.ts

···
+import { USER_AGENT } from "./constants";
+import type { FollowRecord, MiniDoc, Post } from "./types";
+
+// https://stackoverflow.com/questions/3224834/get-difference-between-2-dates-in-javascript
+export function getDateDifferenceInDays(start: Date, end: Date) {
+	const MS_PER_DAY = 1000 * 60 * 60 * 24;
+	const startUTCDate = Date.UTC(
+		start.getFullYear(),
+		start.getMonth(),
+		start.getDate(),
+	);
+	const endUTCDate = Date.UTC(end.getFullYear(), end.getMonth(), end.getDate());
+	return Math.floor((endUTCDate - startUTCDate) / MS_PER_DAY);
+}
+
+export async function resolveIdentity(indentifier: string): Promise<MiniDoc> {
+	try {
+		const response = await fetch(
+			`https://slingshot.microcosm.blue/xrpc/com.bad-example.identity.resolveMiniDoc?identifier=${indentifier}`,
+			{
+				headers: {
+					"User-Agent": USER_AGENT,
+				},
+			},
+		);
+		if (!response.ok) {
+			// throw new Error(`Failed to fetch minidoc for ${indentifier}. Status - ${response.status}`)
+			console.error(
+				`Failed to fetch minidoc for ${indentifier}. Status - ${response.status}`,
+			);
+		}
+		const data = (await response.json()) as MiniDoc;
+		return data;
+	} catch (error) {
+		if (error instanceof Error) {
+			console.error(error.message);
+		}
+		throw error;
+	}
+}
+
+export async function getRecentPost(doc: MiniDoc) {
+	try {
+		console.info(
+			`${doc.pds}/xrpc/com.atproto.repo.listRecords?repo=${doc.did}&collection=app.bsky.feed.post&limit=1`,
+		);
+		if (typeof doc.pds === "undefined") {
+			console.info("could not get pds info, skipping");
+			return;
+		}
+
+		const response = await fetch(
+			`${doc.pds}/xrpc/com.atproto.repo.listRecords?repo=${doc.did}&collection=app.bsky.feed.post&limit=1`,
+			{
+				headers: {
+					"User-Agent": USER_AGENT,
+				},
+			},
+		);
+		if (!response.ok) {
+			console.error(
+				`There was an error fetching posts for ${doc.handle}. Status - ${response.status}`,
+			);
+		}
+		const data = (await response.json()) as { records: Post[] };
+		return data;
+	} catch (error) {
+		if (error instanceof Error) {
+			console.error(error.message);
+		}
+
+		throw error;
+	}
+}
+
+export async function getFollowRecords(doc: MiniDoc, cursor?: string) {
+	try {
+		const response = await fetch(
+			`${doc.pds}/xrpc/com.atproto.repo.listRecords?repo=${doc.did}&collection=app.bsky.graph.follow&limit=100&cursor=${cursor}`,
+			{
+				headers: {
+					"User-Agent": USER_AGENT,
+				},
+			},
+		);
+		if (!response.ok) {
+			console.error("There was an error fetching follow records");
+		}
+
+		const data = (await response.json()) as {
+			cursor: string;
+			records: FollowRecord[];
+		};
+
+		return {
+			cursor: data?.cursor,
+			follows: data?.records,
+		};
+	} catch (error) {
+		if (error instanceof Error) {
+			console.error(error.message);
+		}
+
+		throw error;
+	}
+}