Finish script

.gitignore

···
-node_modules/
+node_modules/
+.env

index.ts

···
+import { AtpAgent } from "@atproto/api";
+import type { ProfileView } from "@atproto/api/dist/client/types/app/bsky/actor/defs.js";
+import "dotenv/config";
+
+const getFollows = async (agent: AtpAgent, actor: string) => {
+	let cursor: string | undefined;
+
+	const follows = [];
+
+	while (true) {
+		const response = await agent.getFollows({
+			actor,
+			limit: 100,
+			...(cursor && { cursor })
+		});
+
+		follows.push(...response.data.follows);
+
+		cursor = response.data.cursor;
+
+		if (!cursor) {
+			break;
+		}
+	}
+
+	return follows;
+};
+
+const getNonMutuals = async (agent: AtpAgent, actor: string) => {
+	console.log("Fetching all accounts that you follow...");
+
+	const follows = await getFollows(agent, actor);
+
+	console.log(`Fetched ${follows.length} follows to evaluate`);
+
+	const dids = follows.map((follow) => follow.did);
+	const BATCH_SIZE = 25;
+	const allRelationships = [];
+
+	for (let i = 0; i < dids.length; i += BATCH_SIZE) {
+		const batch = dids.slice(i, i + BATCH_SIZE);
+
+		const response = await agent.api.app.bsky.graph.getRelationships({
+			actor,
+			others: batch
+		});
+
+		const relationships = response.data.relationships.filter(
+			(relationship) => relationship.did !== actor
+		);
+
+		allRelationships.push(...relationships);
+
+		if (i + BATCH_SIZE < dids.length) {
+			console.log(
+				`   -> Checked ${i + BATCH_SIZE} / ${dids.length} targets...`
+			);
+		}
+	}
+
+	const mutuals = new Set(
+		allRelationships
+			.filter((relationship) => relationship.followedBy)
+			.map((relationship) => relationship.did)
+	);
+
+	console.log(`${mutuals.size} mutuals`);
+
+	const nonMutuals = follows.filter((follow) => !mutuals.has(follow.did));
+
+	console.log(`${nonMutuals.length} non-mutuals`);
+
+	return nonMutuals;
+};
+
+const getProfile = async (agent: AtpAgent, actor: string) => {
+	const response = await agent.getProfile({ actor });
+
+	return {
+		followers: response.data.followersCount,
+		follows: response.data.followsCount
+	};
+};
+
+const snap = async (agent: AtpAgent, nms: ProfileView[]) => {
+	const unfollows: ProfileView[] = [];
+
+	nms.forEach((nm) => {
+		const unfollow = Math.random() < 0.5;
+
+		if (unfollow) {
+			unfollows.push(nm);
+		}
+	});
+
+	console.log(`${unfollows.length} / ${nms.length} to snap`);
+
+	const unfollowPromises = unfollows.map((u) =>
+		agent.deleteFollow(u.viewer?.following!)
+	);
+
+	const CONCURRENCY_LIMIT = 5;
+
+	for (let i = 0; i < unfollowPromises.length; i += CONCURRENCY_LIMIT) {
+		await Promise.all(unfollowPromises.slice(i, i + CONCURRENCY_LIMIT));
+
+		console.log(
+			`Snapped ${i + CONCURRENCY_LIMIT} / ${
+				unfollowPromises.length
+			} non-mutuals`
+		);
+
+		await new Promise((resolve) => setTimeout(resolve, 500));
+	}
+
+	console.log("Thanos Snap operation finished.");
+};
+
+const main = async () => {
+	console.log("Begin Thanos Snap 🪙");
+	console.log("Authenticating ATProto account");
+
+	const agent = new AtpAgent({ service: "https://blacksky.app" });
+
+	await agent.login({
+		identifier: process.env.HANDLE!,
+		password: process.env.PASSWORD!
+	});
+
+	console.log(`Logged in as ${agent.session?.handle}`);
+
+	const did = agent.session?.did;
+
+	if (!did) {
+		throw new Error("Failed to get DID");
+	}
+
+	console.log("Fetching profile ...");
+
+	const profile = await getProfile(agent, did);
+
+	console.log(`You have ${profile.followers} followers!`);
+	console.log(`You follow ${profile.follows} accounts!`);
+	console.log(`That's ${profile.follows - profile.followers} non-mutuals`);
+	console.log(`Time to halve 🫰. Compiling non-mutuals...`);
+
+	const nonMutuals = await getNonMutuals(agent, did);
+
+	snap(agent, nonMutuals);
+};
+
+main();

package-lock.json

···
       "version": "1.0.0",
       "license": "ISC",
       "dependencies": {
-        "@atproto/api": "^0.17.7"
+        "@atproto/api": "^0.17.7",
+        "dotenv": "^17.2.3"
       },
       "devDependencies": {
+        "@types/node": "^24.9.2",
         "ts-node": "^10.9.2",
         "typescript": "^5.9.3"
       }
···
       "integrity": "sha512-uWN8YqxXxqFMX2RqGOrumsKeti4LlmIMIyV0lgut4jx7KQBcBiW6vkDtIBvHnHIquwNfJhk8v2OtmO8zXWHfPA==",
       "dev": true,
       "license": "MIT",
-      "peer": true,
       "dependencies": {
         "undici-types": "~7.16.0"
       }
···
         "node": ">=0.3.1"
       }
     },
+    "node_modules/dotenv": {
+      "version": "17.2.3",
+      "resolved": "https://registry.npmjs.org/dotenv/-/dotenv-17.2.3.tgz",
+      "integrity": "sha512-JVUnt+DUIzu87TABbhPmNfVdBDt18BLOWjMUFJMSi/Qqg7NTYtabbvSNJGOJ7afbRuv9D/lngizHtP7QyLQ+9w==",
+      "license": "BSD-2-Clause",
+      "engines": {
+        "node": ">=12"
+      },
+      "funding": {
+        "url": "https://dotenvx.com"
+      }
+    },
     "node_modules/graphemer": {
       "version": "1.4.0",
       "resolved": "https://registry.npmjs.org/graphemer/-/graphemer-1.4.0.tgz",
···
       "resolved": "https://registry.npmjs.org/undici-types/-/undici-types-7.16.0.tgz",
       "integrity": "sha512-Zz+aZWSj8LE6zoxD+xrjh4VfkIG8Ya6LvYkZqtUQGJPZjYl53ypCaUwWqo7eI0x66KBGeRo+mlBEkMSeSZ38Nw==",
       "dev": true,
-      "license": "MIT",
-      "peer": true
+      "license": "MIT"
     },
     "node_modules/v8-compile-cache-lib": {
       "version": "3.0.1",

package.json

···
   },
   "license": "ISC",
   "author": "",
-  "type": "commonjs",
+  "type": "module",
   "main": "index.ts",
   "scripts": {
     "test": "echo \"Error: no test specified\" && exit 1"
   },
   "dependencies": {
-    "@atproto/api": "^0.17.7"
+    "@atproto/api": "^0.17.7",
+    "dotenv": "^17.2.3"
   },
   "devDependencies": {
+    "@types/node": "^24.9.2",
     "ts-node": "^10.9.2",
     "typescript": "^5.9.3"
   }

tsconfig.json

···
 {
-  // Visit https://aka.ms/tsconfig to read more about this file
-  "compilerOptions": {
-    // File Layout
-    // "rootDir": "./src",
-    // "outDir": "./dist",
+	// Visit https://aka.ms/tsconfig to read more about this file
+	"compilerOptions": {
+		// File Layout
+		// "rootDir": "./src",
+		// "outDir": "./dist",
 
-    // Environment Settings
-    // See also https://aka.ms/tsconfig/module
-    "module": "nodenext",
-    "target": "esnext",
-    "types": [],
-    // For nodejs:
-    // "lib": ["esnext"],
-    // "types": ["node"],
-    // and npm install -D @types/node
+		// Environment Settings
+		// See also https://aka.ms/tsconfig/module
+		"module": "nodenext",
+		"target": "esnext",
+		"types": ["node"],
+		// For nodejs:
+		// "lib": ["esnext"],
+		// "types": ["node"],
+		// and npm install -D @types/node
 
-    // Other Outputs
-    "sourceMap": true,
-    "declaration": true,
-    "declarationMap": true,
+		// Other Outputs
+		"sourceMap": true,
+		"declaration": true,
+		"declarationMap": true,
 
-    // Stricter Typechecking Options
-    "noUncheckedIndexedAccess": true,
-    "exactOptionalPropertyTypes": true,
+		// Stricter Typechecking Options
+		"noUncheckedIndexedAccess": true,
+		"exactOptionalPropertyTypes": true,
 
-    // Style Options
-    // "noImplicitReturns": true,
-    // "noImplicitOverride": true,
-    // "noUnusedLocals": true,
-    // "noUnusedParameters": true,
-    // "noFallthroughCasesInSwitch": true,
-    // "noPropertyAccessFromIndexSignature": true,
+		// Style Options
+		// "noImplicitReturns": true,
+		// "noImplicitOverride": true,
+		// "noUnusedLocals": true,
+		// "noUnusedParameters": true,
+		// "noFallthroughCasesInSwitch": true,
+		// "noPropertyAccessFromIndexSignature": true,
 
-    // Recommended Options
-    "strict": true,
-    "jsx": "react-jsx",
-    "verbatimModuleSyntax": true,
-    "isolatedModules": true,
-    "noUncheckedSideEffectImports": true,
-    "moduleDetection": "force",
-    "skipLibCheck": true,
-  }
+		// Recommended Options
+		"strict": true,
+		"jsx": "react-jsx",
+		"verbatimModuleSyntax": true,
+		"isolatedModules": true,
+		"noUncheckedSideEffectImports": true,
+		"moduleDetection": "force",
+		"skipLibCheck": true
+	}
 }