feat: New social notifications, track social media posts from the Fediverse and Bluesky, no login or authentication needed.

New Features:
- Introduced a new /social command for Discord servers to manage Fediverse and Bluesky account tracking.
- Enabled adding, removing, listing, and refreshing social media subscriptions with notifications in designated channels.
- Automated periodic checks for new social media posts with timely notifications.
- Added comprehensive localization strings for social media commands and messages.
- Implemented social media integration supporting Bluesky and Fediverse platforms with real-time post fetching and notifications.
- Added database support for storing social media subscriptions and tracking updates.
- Unified conversation and user identification keys for improved context management and scoping of user data and limits.

Chores:
- Updated dependencies and package version for improved stability and feature support.
- Improved environment variable handling in production Docker setup.

Bug Fixes:
- Enhanced validation and error handling for social media account management and notification delivery.

Dockerfile

···
 ENV NODE_ENV=production
 ENV VITE_BOT_API_URL=${VITE_BOT_API_URL}
 ENV STATUS_API_KEY=${VITE_STATUS_API_KEY}
-ENV VITE_STATUS_API_KEY=${VITE_STATUS_API_KEY}
+ENV VITE_STATUS_API_KEY=${STATUS_API_KEY}
 ENV VITE_FRONTEND_URL=${VITE_FRONTEND_URL}
 
 RUN addgroup -g 1001 -S nodejs && \

locales/en-US.json

···
         "fetch_failed": "Failed to fetch trivia questions: {error}",
         "api_error": "Trivia API error: {code}"
       }
+    },
+    "social": {
+      "name": "social",
+      "description": "Get notifications of posts from Fediverse and Bluesky accounts",
+      "invalidChannel": "❌ Invalid channel selected.",
+      "notInitializedThrow": "Social media features are not properly initialized.",
+      "addSuccess": "✅ Now tracking {platform} account {account}. New posts will be posted in {channel}.",
+      "notInitialized": "❌ Social media features are not initialized.",
+      "refreshSuccess": "🔄 Refresh complete. {count} new post(s) notified.",
+      "refreshFailed": "❌ Refresh failed: {message}",
+      "removeSuccess": "✅ Removed {platform} account {account} from tracking.",
+      "removeNotFound": "❌ Could not find a subscription for {platform} account {account}.",
+      "listNone": "No social media accounts are being tracked in this server.",
+      "listTitle": "📱 Tracked Social Media Accounts",
+      "listDescription": "Here are all the social media accounts being tracked in this server:",
+      "channelUnset": "No channel set",
+      "fieldNoAccounts": "No accounts",
+      "guildOnly": "This command can only be used in a server.",
+      "unknownSubcommand": "Unknown subcommand.",
+      "failedAction": "❌ Failed to {action} subscription: {message}"
     }
   },
   "categories": {

migrations/008_create_social_media_tables.sql

···
+CREATE TYPE social_platform AS ENUM ('bluesky', 'fediverse');
+
+CREATE TABLE IF NOT EXISTS server_social_subscriptions (
+    id SERIAL PRIMARY KEY,
+    guild_id TEXT NOT NULL,
+    platform social_platform NOT NULL,
+    account_handle TEXT NOT NULL,
+    last_post_uri TEXT,
+    last_post_timestamp TIMESTAMPTZ,
+    channel_id TEXT NOT NULL,
+    created_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    updated_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP
+);
+
+CREATE INDEX IF NOT EXISTS idx_server_social_subscriptions_guild ON server_social_subscriptions(guild_id);
+CREATE INDEX IF NOT EXISTS idx_server_social_subscriptions_platform ON server_social_subscriptions(platform);
+
+CREATE UNIQUE INDEX IF NOT EXISTS uniq_server_social_subscriptions_ci
+ON server_social_subscriptions (guild_id, platform, lower(account_handle));
+
+CREATE OR REPLACE FUNCTION update_updated_at_column()
+RETURNS TRIGGER AS $$
+BEGIN
+    NEW.updated_at = NOW();
+    RETURN NEW;
+END;
+$$ LANGUAGE plpgsql;
+
+CREATE TRIGGER update_server_social_subscriptions_updated_at
+BEFORE UPDATE ON server_social_subscriptions
+FOR EACH ROW
+EXECUTE FUNCTION update_updated_at_column();

package.json

···
 {
   "name": "aethel",
-  "version": "2.0.0-beta",
+  "version": "2.0.0-lyra",
   "description": "A privacy-conscious, production-ready Discord user bot",
   "type": "module",
   "main": "dist/index.js",
···
     "check": "pnpm run lint && pnpm run format:check"
   },
   "dependencies": {
+    "@atproto/identity": "^0.4.8",
     "@discordjs/rest": "^2.5.1",
     "axios": "^1.11.0",
     "city-timezones": "^1.3.1",
     "cors": "^2.8.5",
     "discord.js": "^14.21.0",
     "dotenv": "^16.6.1",
-    "eslint-plugin-prettier": "^5.5.3",
+    "eslint-plugin-prettier": "^5.5.4",
     "express": "^4.21.2",
     "express-rate-limit": "^7.5.1",
     "express-validator": "^7.2.1",
···
     "jsonwebtoken": "^9.0.2",
     "moment-timezone": "^0.6.0",
     "node-fetch": "^3.3.2",
-    "openai": "^5.12.0",
+    "openai": "^5.12.2",
     "pg": "^8.16.3",
     "uuid": "^11.1.0",
     "validator": "^13.15.15",
···
     "winston": "^3.17.0"
   },
   "devDependencies": {
-    "@eslint/js": "^9.32.0",
+    "@eslint/js": "^9.33.0",
     "@types/cors": "^2.8.19",
     "@types/express": "^4.17.23",
     "@types/jsonwebtoken": "^9.0.10",
-    "@types/node": "^24.1.0",
+    "@types/node": "^24.2.1",
     "@types/pg": "^8.15.5",
     "@types/uuid": "^10.0.0",
     "@types/validator": "^13.15.2",
     "@types/whois-json": "^2.0.4",
-    "eslint": "^9.32.0",
+    "eslint": "^9.33.0",
     "eslint-config-prettier": "^10.1.8",
     "globals": "^16.3.0",
     "nodemon": "^3.1.10",
···
     "tsc-alias": "^1.8.16",
     "tsconfig-paths": "^4.2.0",
     "tsx": "^4.20.3",
-    "typescript": "^5.8.3",
-    "typescript-eslint": "^8.38.0"
+    "typescript": "^5.9.2",
+    "typescript-eslint": "^8.39.0"
   }
 }

pnpm-lock.yaml

···
 
   .:
     dependencies:
+      '@atproto/identity':
+        specifier: ^0.4.8
+        version: 0.4.8
       '@discordjs/rest':
         specifier: ^2.5.1
         version: 2.5.1
···
         specifier: ^16.6.1
         version: 16.6.1
       eslint-plugin-prettier:
-        specifier: ^5.5.3
-        version: 5.5.3(eslint-config-prettier@10.1.8(eslint@9.32.0))(eslint@9.32.0)(prettier@3.6.2)
+        specifier: ^5.5.4
+        version: 5.5.4(eslint-config-prettier@10.1.8(eslint@9.33.0))(eslint@9.33.0)(prettier@3.6.2)
       express:
         specifier: ^4.21.2
         version: 4.21.2
···
         specifier: ^3.3.2
         version: 3.3.2
       openai:
-        specifier: ^5.12.0
-        version: 5.12.0(ws@8.18.3)
+        specifier: ^5.12.2
+        version: 5.12.2(ws@8.18.3)(zod@3.25.76)
       pg:
         specifier: ^8.16.3
         version: 8.16.3
···
         version: 3.17.0
     devDependencies:
       '@eslint/js':
-        specifier: ^9.32.0
-        version: 9.32.0
+        specifier: ^9.33.0
+        version: 9.33.0
       '@types/cors':
         specifier: ^2.8.19
         version: 2.8.19
···
         specifier: ^9.0.10
         version: 9.0.10
       '@types/node':
-        specifier: ^24.1.0
-        version: 24.1.0
+        specifier: ^24.2.1
+        version: 24.2.1
       '@types/pg':
         specifier: ^8.15.5
         version: 8.15.5
···
         specifier: ^2.0.4
         version: 2.0.4
       eslint:
-        specifier: ^9.32.0
-        version: 9.32.0
+        specifier: ^9.33.0
+        version: 9.33.0
       eslint-config-prettier:
         specifier: ^10.1.8
-        version: 10.1.8(eslint@9.32.0)
+        version: 10.1.8(eslint@9.33.0)
       globals:
         specifier: ^16.3.0
         version: 16.3.0
···
         specifier: ^4.20.3
         version: 4.20.3
       typescript:
-        specifier: ^5.8.3
-        version: 5.8.3
+        specifier: ^5.9.2
+        version: 5.9.2
       typescript-eslint:
-        specifier: ^8.38.0
-        version: 8.38.0(eslint@9.32.0)(typescript@5.8.3)
+        specifier: ^8.39.0
+        version: 8.39.0(eslint@9.33.0)(typescript@5.9.2)
 
 packages:
+
+  '@atproto/common-web@0.4.2':
+    resolution: {integrity: sha512-vrXwGNoFGogodjQvJDxAeP3QbGtawgZute2ed1XdRO0wMixLk3qewtikZm06H259QDJVu6voKC5mubml+WgQUw==}
+
+  '@atproto/crypto@0.4.4':
+    resolution: {integrity: sha512-Yq9+crJ7WQl7sxStVpHgie5Z51R05etaK9DLWYG/7bR5T4bhdcIgF6IfklLShtZwLYdVVj+K15s0BqW9a8PSDA==}
+    engines: {node: '>=18.7.0'}
+
+  '@atproto/identity@0.4.8':
+    resolution: {integrity: sha512-Z0sLnJ87SeNdAifT+rqpgE1Rc3layMMW25gfWNo4u40RGuRODbdfAZlTwBSU2r+Vk45hU+iE+xeQspfednCEnA==}
+    engines: {node: '>=18.7.0'}
 
   '@colors/colors@1.6.0':
     resolution: {integrity: sha512-Ir+AOibqzrIsL6ajt3Rz3LskB7OiMVHqltZmspbW/TJuTVuyOMirVqAkjfY6JISiLHgyNqicAC8AyHHGzNd/dA==}
···
     resolution: {integrity: sha512-ENIdc4iLu0d93HeYirvKmrzshzofPw6VkZRKQGe9Nv46ZnWUzcF1xV01dcvEg/1wXUR61OmmlSfyeyO7EvjLxQ==}
     engines: {node: ^18.18.0 || ^20.9.0 || >=21.1.0}
 
-  '@eslint/config-helpers@0.3.0':
-    resolution: {integrity: sha512-ViuymvFmcJi04qdZeDc2whTHryouGcDlaxPqarTD0ZE10ISpxGUVZGZDx4w01upyIynL3iu6IXH2bS1NhclQMw==}
+  '@eslint/config-helpers@0.3.1':
+    resolution: {integrity: sha512-xR93k9WhrDYpXHORXpxVL5oHj3Era7wo6k/Wd8/IsQNnZUTzkGS29lyn3nAT05v6ltUuTFVCCYDEGfy2Or/sPA==}
     engines: {node: ^18.18.0 || ^20.9.0 || >=21.1.0}
 
-  '@eslint/core@0.15.1':
-    resolution: {integrity: sha512-bkOp+iumZCCbt1K1CmWf0R9pM5yKpDv+ZXtvSyQpudrI9kuFLp+bM2WOPXImuD/ceQuaa8f5pj93Y7zyECIGNA==}
+  '@eslint/core@0.15.2':
+    resolution: {integrity: sha512-78Md3/Rrxh83gCxoUc0EiciuOHsIITzLy53m3d9UyiW8y9Dj2D29FeETqyKA+BRK76tnTp6RXWb3pCay8Oyomg==}
     engines: {node: ^18.18.0 || ^20.9.0 || >=21.1.0}
 
   '@eslint/eslintrc@3.3.1':
     resolution: {integrity: sha512-gtF186CXhIl1p4pJNGZw8Yc6RlshoePRvE0X91oPGb3vZ8pM3qOS9W9NGPat9LziaBV7XrJWGylNQXkGcnM3IQ==}
     engines: {node: ^18.18.0 || ^20.9.0 || >=21.1.0}
 
-  '@eslint/js@9.32.0':
-    resolution: {integrity: sha512-BBpRFZK3eX6uMLKz8WxFOBIFFcGFJ/g8XuwjTHCqHROSIsopI+ddn/d5Cfh36+7+e5edVS8dbSHnBNhrLEX0zg==}
+  '@eslint/js@9.33.0':
+    resolution: {integrity: sha512-5K1/mKhWaMfreBGJTwval43JJmkip0RmM+3+IuqupeSKNC/Th2Kc7ucaq5ovTSra/OOKB9c58CGSz3QMVbWt0A==}
     engines: {node: ^18.18.0 || ^20.9.0 || >=21.1.0}
 
   '@eslint/object-schema@2.1.6':
     resolution: {integrity: sha512-RBMg5FRL0I0gs51M/guSAj5/e14VQ4tpZnQNWwuDT66P14I43ItmPfIZRhO9fUVIPOAQXU47atlywZ/czoqFPA==}
     engines: {node: ^18.18.0 || ^20.9.0 || >=21.1.0}
 
-  '@eslint/plugin-kit@0.3.4':
-    resolution: {integrity: sha512-Ul5l+lHEcw3L5+k8POx6r74mxEYKG5kOb6Xpy2gCRW6zweT6TEhAf8vhxGgjhqrd/VO/Dirhsb+1hNpD1ue9hw==}
+  '@eslint/plugin-kit@0.3.5':
+    resolution: {integrity: sha512-Z5kJ+wU3oA7MMIqVR9tyZRtjYPr4OC004Q4Rw7pgOKUOKkJfZ3O24nz3WYfGRpMDNmcOi3TwQOmgm7B7Tpii0w==}
     engines: {node: ^18.18.0 || ^20.9.0 || >=21.1.0}
 
   '@humanfs/core@0.19.1':
···
   '@humanwhocodes/retry@0.4.3':
     resolution: {integrity: sha512-bV0Tgo9K4hfPCek+aMAn81RppFKv2ySDQeMoSZuvTASywNTnVJCArCZE2FWqpvIatKu7VMRLWlR1EazvVhDyhQ==}
     engines: {node: '>=18.18'}
+
+  '@noble/curves@1.9.6':
+    resolution: {integrity: sha512-GIKz/j99FRthB8icyJQA51E8Uk5hXmdyThjgQXRKiv9h0zeRlzSCLIzFw6K1LotZ3XuB7yzlf76qk7uBmTdFqA==}
+    engines: {node: ^14.21.3 || >=16}
+
+  '@noble/hashes@1.8.0':
+    resolution: {integrity: sha512-jCs9ldd7NwzpgXDIf6P3+NrHh9/sD6CQdxHyjQI+h/6rDNo88ypBxxz45UDuZHz9r3tNz7N/VInSVoVdtXEI4A==}
+    engines: {node: ^14.21.3 || >=16}
 
   '@nodelib/fs.scandir@2.1.5':
     resolution: {integrity: sha512-vq24Bq3ym5HEQm2NKCr3yXDwjc7vTsEThRDnkp2DK9p1uqLR+DHurm/NOTo0KG7HYHU7eppKZj3MyqYuMBf62g==}
···
   '@types/ms@2.1.0':
     resolution: {integrity: sha512-GsCCIZDE/p3i96vtEqx+7dBUGXrc7zeSK3wwPHIaRThS+9OhWIXRqzs4d6k1SVU8g91DrNRWxWUGhp5KXQb2VA==}
 
-  '@types/node@24.1.0':
-    resolution: {integrity: sha512-ut5FthK5moxFKH2T1CUOC6ctR67rQRvvHdFLCD2Ql6KXmMuCrjsSsRI9UsLCm9M18BMwClv4pn327UvB7eeO1w==}
+  '@types/node@24.2.1':
+    resolution: {integrity: sha512-DRh5K+ka5eJic8CjH7td8QpYEV6Zo10gfRkjHCO3weqZHWDtAaSTFtl4+VMqOJ4N5jcuhZ9/l+yy8rVgw7BQeQ==}
 
   '@types/pg@8.15.5':
     resolution: {integrity: sha512-LF7lF6zWEKxuT3/OR8wAZGzkg4ENGXFNyiV/JeOt9z5B+0ZVwbql9McqX5c/WStFq1GaGso7H1AzP/qSzmlCKQ==}
···
   '@types/ws@8.18.1':
     resolution: {integrity: sha512-ThVF6DCVhA8kUGy+aazFQ4kXQ7E1Ty7A3ypFOe0IcJV8O/M511G99AW24irKrW56Wt44yG9+ij8FaqoBGkuBXg==}
 
-  '@typescript-eslint/eslint-plugin@8.38.0':
-    resolution: {integrity: sha512-CPoznzpuAnIOl4nhj4tRr4gIPj5AfKgkiJmGQDaq+fQnRJTYlcBjbX3wbciGmpoPf8DREufuPRe1tNMZnGdanA==}
+  '@typescript-eslint/eslint-plugin@8.39.0':
+    resolution: {integrity: sha512-bhEz6OZeUR+O/6yx9Jk6ohX6H9JSFTaiY0v9/PuKT3oGK0rn0jNplLmyFUGV+a9gfYnVNwGDwS/UkLIuXNb2Rw==}
     engines: {node: ^18.18.0 || ^20.9.0 || >=21.1.0}
     peerDependencies:
-      '@typescript-eslint/parser': ^8.38.0
+      '@typescript-eslint/parser': ^8.39.0
       eslint: ^8.57.0 || ^9.0.0
-      typescript: '>=4.8.4 <5.9.0'
+      typescript: '>=4.8.4 <6.0.0'
 
-  '@typescript-eslint/parser@8.38.0':
-    resolution: {integrity: sha512-Zhy8HCvBUEfBECzIl1PKqF4p11+d0aUJS1GeUiuqK9WmOug8YCmC4h4bjyBvMyAMI9sbRczmrYL5lKg/YMbrcQ==}
+  '@typescript-eslint/parser@8.39.0':
+    resolution: {integrity: sha512-g3WpVQHngx0aLXn6kfIYCZxM6rRJlWzEkVpqEFLT3SgEDsp9cpCbxxgwnE504q4H+ruSDh/VGS6nqZIDynP+vg==}
     engines: {node: ^18.18.0 || ^20.9.0 || >=21.1.0}
     peerDependencies:
       eslint: ^8.57.0 || ^9.0.0
-      typescript: '>=4.8.4 <5.9.0'
+      typescript: '>=4.8.4 <6.0.0'
 
-  '@typescript-eslint/project-service@8.38.0':
-    resolution: {integrity: sha512-dbK7Jvqcb8c9QfH01YB6pORpqX1mn5gDZc9n63Ak/+jD67oWXn3Gs0M6vddAN+eDXBCS5EmNWzbSxsn9SzFWWg==}
+  '@typescript-eslint/project-service@8.39.0':
+    resolution: {integrity: sha512-CTzJqaSq30V/Z2Og9jogzZt8lJRR5TKlAdXmWgdu4hgcC9Kww5flQ+xFvMxIBWVNdxJO7OifgdOK4PokMIWPew==}
     engines: {node: ^18.18.0 || ^20.9.0 || >=21.1.0}
     peerDependencies:
-      typescript: '>=4.8.4 <5.9.0'
+      typescript: '>=4.8.4 <6.0.0'
 
-  '@typescript-eslint/scope-manager@8.38.0':
-    resolution: {integrity: sha512-WJw3AVlFFcdT9Ri1xs/lg8LwDqgekWXWhH3iAF+1ZM+QPd7oxQ6jvtW/JPwzAScxitILUIFs0/AnQ/UWHzbATQ==}
+  '@typescript-eslint/scope-manager@8.39.0':
+    resolution: {integrity: sha512-8QOzff9UKxOh6npZQ/4FQu4mjdOCGSdO3p44ww0hk8Vu+IGbg0tB/H1LcTARRDzGCC8pDGbh2rissBuuoPgH8A==}
     engines: {node: ^18.18.0 || ^20.9.0 || >=21.1.0}
 
-  '@typescript-eslint/tsconfig-utils@8.38.0':
-    resolution: {integrity: sha512-Lum9RtSE3EroKk/bYns+sPOodqb2Fv50XOl/gMviMKNvanETUuUcC9ObRbzrJ4VSd2JalPqgSAavwrPiPvnAiQ==}
+  '@typescript-eslint/tsconfig-utils@8.39.0':
+    resolution: {integrity: sha512-Fd3/QjmFV2sKmvv3Mrj8r6N8CryYiCS8Wdb/6/rgOXAWGcFuc+VkQuG28uk/4kVNVZBQuuDHEDUpo/pQ32zsIQ==}
     engines: {node: ^18.18.0 || ^20.9.0 || >=21.1.0}
     peerDependencies:
-      typescript: '>=4.8.4 <5.9.0'
+      typescript: '>=4.8.4 <6.0.0'
 
-  '@typescript-eslint/type-utils@8.38.0':
-    resolution: {integrity: sha512-c7jAvGEZVf0ao2z+nnz8BUaHZD09Agbh+DY7qvBQqLiz8uJzRgVPj5YvOh8I8uEiH8oIUGIfHzMwUcGVco/SJg==}
+  '@typescript-eslint/type-utils@8.39.0':
+    resolution: {integrity: sha512-6B3z0c1DXVT2vYA9+z9axjtc09rqKUPRmijD5m9iv8iQpHBRYRMBcgxSiKTZKm6FwWw1/cI4v6em35OsKCiN5Q==}
     engines: {node: ^18.18.0 || ^20.9.0 || >=21.1.0}
     peerDependencies:
       eslint: ^8.57.0 || ^9.0.0
-      typescript: '>=4.8.4 <5.9.0'
+      typescript: '>=4.8.4 <6.0.0'
 
-  '@typescript-eslint/types@8.38.0':
-    resolution: {integrity: sha512-wzkUfX3plUqij4YwWaJyqhiPE5UCRVlFpKn1oCRn2O1bJ592XxWJj8ROQ3JD5MYXLORW84063z3tZTb/cs4Tyw==}
+  '@typescript-eslint/types@8.39.0':
+    resolution: {integrity: sha512-ArDdaOllnCj3yn/lzKn9s0pBQYmmyme/v1HbGIGB0GB/knFI3fWMHloC+oYTJW46tVbYnGKTMDK4ah1sC2v0Kg==}
     engines: {node: ^18.18.0 || ^20.9.0 || >=21.1.0}
 
-  '@typescript-eslint/typescript-estree@8.38.0':
-    resolution: {integrity: sha512-fooELKcAKzxux6fA6pxOflpNS0jc+nOQEEOipXFNjSlBS6fqrJOVY/whSn70SScHrcJ2LDsxWrneFoWYSVfqhQ==}
+  '@typescript-eslint/typescript-estree@8.39.0':
+    resolution: {integrity: sha512-ndWdiflRMvfIgQRpckQQLiB5qAKQ7w++V4LlCHwp62eym1HLB/kw7D9f2e8ytONls/jt89TEasgvb+VwnRprsw==}
     engines: {node: ^18.18.0 || ^20.9.0 || >=21.1.0}
     peerDependencies:
-      typescript: '>=4.8.4 <5.9.0'
+      typescript: '>=4.8.4 <6.0.0'
 
-  '@typescript-eslint/utils@8.38.0':
-    resolution: {integrity: sha512-hHcMA86Hgt+ijJlrD8fX0j1j8w4C92zue/8LOPAFioIno+W0+L7KqE8QZKCcPGc/92Vs9x36w/4MPTJhqXdyvg==}
+  '@typescript-eslint/utils@8.39.0':
+    resolution: {integrity: sha512-4GVSvNA0Vx1Ktwvf4sFE+exxJ3QGUorQG1/A5mRfRNZtkBT2xrA/BCO2H0eALx/PnvCS6/vmYwRdDA41EoffkQ==}
     engines: {node: ^18.18.0 || ^20.9.0 || >=21.1.0}
     peerDependencies:
       eslint: ^8.57.0 || ^9.0.0
-      typescript: '>=4.8.4 <5.9.0'
+      typescript: '>=4.8.4 <6.0.0'
 
-  '@typescript-eslint/visitor-keys@8.38.0':
-    resolution: {integrity: sha512-pWrTcoFNWuwHlA9CvlfSsGWs14JxfN1TH25zM5L7o0pRLhsoZkDnTsXfQRJBEWJoV5DL0jf+Z+sxiud+K0mq1g==}
+  '@typescript-eslint/visitor-keys@8.39.0':
+    resolution: {integrity: sha512-ldgiJ+VAhQCfIjeOgu8Kj5nSxds0ktPOSO9p4+0VDH2R2pLvQraaM5Oen2d7NxzMCm+Sn/vJT+mv2H5u6b/3fA==}
     engines: {node: ^18.18.0 || ^20.9.0 || >=21.1.0}
 
   '@vladfrangu/async_event_emitter@2.4.6':
···
     peerDependencies:
       eslint: '>=7.0.0'
 
-  eslint-plugin-prettier@5.5.3:
-    resolution: {integrity: sha512-NAdMYww51ehKfDyDhv59/eIItUVzU0Io9H2E8nHNGKEeeqlnci+1gCvrHib6EmZdf6GxF+LCV5K7UC65Ezvw7w==}
+  eslint-plugin-prettier@5.5.4:
+    resolution: {integrity: sha512-swNtI95SToIz05YINMA6Ox5R057IMAmWZ26GqPxusAp1TZzj+IdY9tXNWWD3vkF/wEqydCONcwjTFpxybBqZsg==}
     engines: {node: ^14.18.0 || >=16.0.0}
     peerDependencies:
       '@types/eslint': '>=8.0.0'
···
     resolution: {integrity: sha512-Uhdk5sfqcee/9H/rCOJikYz67o0a2Tw2hGRPOG2Y1R2dg7brRe1uG0yaNQDHu+TO/uQPF/5eCapvYSmHUjt7JQ==}
     engines: {node: ^18.18.0 || ^20.9.0 || >=21.1.0}
 
-  eslint@9.32.0:
-    resolution: {integrity: sha512-LSehfdpgMeWcTZkWZVIJl+tkZ2nuSkyyB9C27MZqFWXuph7DvaowgcTvKqxvpLW1JZIk8PN7hFY3Rj9LQ7m7lg==}
+  eslint@9.33.0:
+    resolution: {integrity: sha512-TS9bTNIryDzStCpJN93aC5VRSW3uTx9sClUn4B87pwiCaJh220otoI0X8mJKr+VcPtniMdN8GKjlwgWGUv5ZKA==}
     engines: {node: ^18.18.0 || ^20.9.0 || >=21.1.0}
     hasBin: true
     peerDependencies:
···
   ms@2.1.3:
     resolution: {integrity: sha512-6FlzubTLZG3J2a/NVCAleEhjzq5oxgHyaCU9yYXvcLsvoVaHJq/s5xXI6/XXP6tz7R9xAOtHnSO/tXtF3WRTlA==}
 
+  multiformats@9.9.0:
+    resolution: {integrity: sha512-HoMUjhH9T8DDBNT+6xzkrd9ga/XiBI4xLr58LJACwK6G3HTOPeMz4nB4KJs33L2BelrIJa7P0VuNaVF3hMYfjg==}
+
   mylas@2.1.13:
     resolution: {integrity: sha512-+MrqnJRtxdF+xngFfUUkIMQrUUL0KsxbADUkn23Z/4ibGg192Q+z+CQyiYwvWTsYjJygmMR8+w3ZDa98Zh6ESg==}
     engines: {node: '>=12.0.0'}
···
   one-time@1.0.0:
     resolution: {integrity: sha512-5DXOiRKwuSEcQ/l0kGCF6Q3jcADFv5tSmRaJck/OqkVFcOzutB134KRSfF0xDrL39MNnqxbHBbUUcjZIhTgb2g==}
 
-  openai@5.12.0:
-    resolution: {integrity: sha512-vUdt02xiWgOHiYUmW0Hj1Qu9OKAiVQu5Bd547ktVCiMKC1BkB5L3ImeEnCyq3WpRKR6ZTaPgekzqdozwdPs7Lg==}
+  openai@5.12.2:
+    resolution: {integrity: sha512-xqzHHQch5Tws5PcKR2xsZGX9xtch+JQFz5zb14dGqlshmmDAFBFEWmeIpf7wVqWV+w7Emj7jRgkNJakyKE0tYQ==}
     hasBin: true
     peerDependencies:
       ws: ^8.18.0
···
     resolution: {integrity: sha512-TkRKr9sUTxEH8MdfuCSP7VizJyzRNMjj2J2do2Jr3Kym598JVdEksuzPQCnlFPW4ky9Q+iA+ma9BGm06XQBy8g==}
     engines: {node: '>= 0.6'}
 
-  typescript-eslint@8.38.0:
-    resolution: {integrity: sha512-FsZlrYK6bPDGoLeZRuvx2v6qrM03I0U0SnfCLPs/XCCPCFD80xU9Pg09H/K+XFa68uJuZo7l/Xhs+eDRg2l3hg==}
+  typescript-eslint@8.39.0:
+    resolution: {integrity: sha512-lH8FvtdtzcHJCkMOKnN73LIn6SLTpoojgJqDAxPm1jCR14eWSGPX8ul/gggBdPMk/d5+u9V854vTYQ8T5jF/1Q==}
     engines: {node: ^18.18.0 || ^20.9.0 || >=21.1.0}
     peerDependencies:
       eslint: ^8.57.0 || ^9.0.0
-      typescript: '>=4.8.4 <5.9.0'
+      typescript: '>=4.8.4 <6.0.0'
 
-  typescript@5.8.3:
-    resolution: {integrity: sha512-p1diW6TqL9L07nNxvRMM7hMMw4c5XOo/1ibL4aAIGmSAt9slTE1Xgw5KWuof2uTOvCg9BY7ZRi+GaF+7sfgPeQ==}
+  typescript@5.9.2:
+    resolution: {integrity: sha512-CWBzXQrc/qOkhidw1OzBTQuYRbfyxDXJMVJ1XNwUHGROVmuaeiEm3OslpZ1RV96d7SKKjZKrSJu3+t/xlw3R9A==}
     engines: {node: '>=14.17'}
     hasBin: true
+
+  uint8arrays@3.0.0:
+    resolution: {integrity: sha512-HRCx0q6O9Bfbp+HHSfQQKD7wU70+lydKVt4EghkdOvlK/NlrF90z+eXV34mUd48rNvVJXwkrMSPpCATkct8fJA==}
 
   undefsafe@2.0.5:
     resolution: {integrity: sha512-WxONCrssBM8TSPRqN5EmsjVrsv4A8X12J4ArBiiayv3DyyG3ZlIg6yysuuSYdZsVz3TKcTg2fd//Ujd4CHV1iA==}
···
   underscore@1.13.7:
     resolution: {integrity: sha512-GMXzWtsc57XAtguZgaQViUOzs0KTkk8ojr3/xAxXLITqf/3EMwxC0inyETfDFjH/Krbhuep0HNbbjI9i/q3F3g==}
 
-  undici-types@7.8.0:
-    resolution: {integrity: sha512-9UJ2xGDvQ43tYyVMpuHlsgApydB8ZKfVYTsLDhXkFL/6gfkp+U8xTGdh8pMJv1SpZna0zxG1DwsKZsreLbXBxw==}
+  undici-types@7.10.0:
+    resolution: {integrity: sha512-t5Fy/nfn+14LuOc2KNYg75vZqClpAiqscVvMygNnlsHBFpSXdJaYtXMcdNLpl/Qvc3P2cB3s6lOV51nqsFq4ag==}
 
   undici@6.21.3:
     resolution: {integrity: sha512-gBLkYIlEnSp8pFbT64yFgGE6UIB9tAkhukC23PmMDCe5Nd+cRqKxSjw5y54MK2AZMgZfJWMaNE4nYUHgi1XEOw==}
···
     resolution: {integrity: sha512-rVksvsnNCdJ/ohGc6xgPwyN8eheCxsiLM8mxuE/t/mOVqJewPuO1miLpTHQiRgTKCLexL4MeAFVagts7HmNZ2Q==}
     engines: {node: '>=10'}
 
+  zod@3.25.76:
+    resolution: {integrity: sha512-gzUt/qt81nXsFGKIFcC3YnfEAx5NkunCfnDlvuBSSFS02bcXu4Lmea0AFIUwbLWxWPx3d9p8S5QoaujKcNQxcQ==}
+
 snapshots:
 
+  '@atproto/common-web@0.4.2':
+    dependencies:
+      graphemer: 1.4.0
+      multiformats: 9.9.0
+      uint8arrays: 3.0.0
+      zod: 3.25.76
+
+  '@atproto/crypto@0.4.4':
+    dependencies:
+      '@noble/curves': 1.9.6
+      '@noble/hashes': 1.8.0
+      uint8arrays: 3.0.0
+
+  '@atproto/identity@0.4.8':
+    dependencies:
+      '@atproto/common-web': 0.4.2
+      '@atproto/crypto': 0.4.4
+
   '@colors/colors@1.6.0': {}
 
   '@dabh/diagnostics@2.0.3':
···
   '@esbuild/win32-x64@0.25.8':
     optional: true
 
-  '@eslint-community/eslint-utils@4.7.0(eslint@9.32.0)':
+  '@eslint-community/eslint-utils@4.7.0(eslint@9.33.0)':
     dependencies:
-      eslint: 9.32.0
+      eslint: 9.33.0
       eslint-visitor-keys: 3.4.3
 
   '@eslint-community/regexpp@4.12.1': {}
···
     transitivePeerDependencies:
       - supports-color
 
-  '@eslint/config-helpers@0.3.0': {}
+  '@eslint/config-helpers@0.3.1': {}
 
-  '@eslint/core@0.15.1':
+  '@eslint/core@0.15.2':
     dependencies:
       '@types/json-schema': 7.0.15
 
···
     transitivePeerDependencies:
       - supports-color
 
-  '@eslint/js@9.32.0': {}
+  '@eslint/js@9.33.0': {}
 
   '@eslint/object-schema@2.1.6': {}
 
-  '@eslint/plugin-kit@0.3.4':
+  '@eslint/plugin-kit@0.3.5':
     dependencies:
-      '@eslint/core': 0.15.1
+      '@eslint/core': 0.15.2
       levn: 0.4.1
 
   '@humanfs/core@0.19.1': {}
···
 
   '@humanwhocodes/retry@0.4.3': {}
 
+  '@noble/curves@1.9.6':
+    dependencies:
+      '@noble/hashes': 1.8.0
+
+  '@noble/hashes@1.8.0': {}
+
   '@nodelib/fs.scandir@2.1.5':
     dependencies:
       '@nodelib/fs.stat': 2.0.5
···
   '@types/body-parser@1.19.6':
     dependencies:
       '@types/connect': 3.4.38
-      '@types/node': 24.1.0
+      '@types/node': 24.2.1
 
   '@types/connect@3.4.38':
     dependencies:
-      '@types/node': 24.1.0
+      '@types/node': 24.2.1
 
   '@types/cors@2.8.19':
     dependencies:
-      '@types/node': 24.1.0
+      '@types/node': 24.2.1
 
   '@types/estree@1.0.8': {}
 
   '@types/express-serve-static-core@4.19.6':
     dependencies:
-      '@types/node': 24.1.0
+      '@types/node': 24.2.1
       '@types/qs': 6.14.0
       '@types/range-parser': 1.2.7
       '@types/send': 0.17.5
···
   '@types/jsonwebtoken@9.0.10':
     dependencies:
       '@types/ms': 2.1.0
-      '@types/node': 24.1.0
+      '@types/node': 24.2.1
 
   '@types/mime@1.3.5': {}
 
   '@types/ms@2.1.0': {}
 
-  '@types/node@24.1.0':
+  '@types/node@24.2.1':
     dependencies:
-      undici-types: 7.8.0
+      undici-types: 7.10.0
 
   '@types/pg@8.15.5':
     dependencies:
-      '@types/node': 24.1.0
+      '@types/node': 24.2.1
       pg-protocol: 1.10.3
       pg-types: 2.2.0
 
···
   '@types/send@0.17.5':
     dependencies:
       '@types/mime': 1.3.5
-      '@types/node': 24.1.0
+      '@types/node': 24.2.1
 
   '@types/serve-static@1.15.8':
     dependencies:
       '@types/http-errors': 2.0.5
-      '@types/node': 24.1.0
+      '@types/node': 24.2.1
       '@types/send': 0.17.5
 
   '@types/triple-beam@1.3.5': {}
···
 
   '@types/ws@8.18.1':
     dependencies:
-      '@types/node': 24.1.0
+      '@types/node': 24.2.1
 
-  '@typescript-eslint/eslint-plugin@8.38.0(@typescript-eslint/parser@8.38.0(eslint@9.32.0)(typescript@5.8.3))(eslint@9.32.0)(typescript@5.8.3)':
+  '@typescript-eslint/eslint-plugin@8.39.0(@typescript-eslint/parser@8.39.0(eslint@9.33.0)(typescript@5.9.2))(eslint@9.33.0)(typescript@5.9.2)':
     dependencies:
       '@eslint-community/regexpp': 4.12.1
-      '@typescript-eslint/parser': 8.38.0(eslint@9.32.0)(typescript@5.8.3)
-      '@typescript-eslint/scope-manager': 8.38.0
-      '@typescript-eslint/type-utils': 8.38.0(eslint@9.32.0)(typescript@5.8.3)
-      '@typescript-eslint/utils': 8.38.0(eslint@9.32.0)(typescript@5.8.3)
-      '@typescript-eslint/visitor-keys': 8.38.0
-      eslint: 9.32.0
+      '@typescript-eslint/parser': 8.39.0(eslint@9.33.0)(typescript@5.9.2)
+      '@typescript-eslint/scope-manager': 8.39.0
+      '@typescript-eslint/type-utils': 8.39.0(eslint@9.33.0)(typescript@5.9.2)
+      '@typescript-eslint/utils': 8.39.0(eslint@9.33.0)(typescript@5.9.2)
+      '@typescript-eslint/visitor-keys': 8.39.0
+      eslint: 9.33.0
       graphemer: 1.4.0
       ignore: 7.0.5
       natural-compare: 1.4.0
-      ts-api-utils: 2.1.0(typescript@5.8.3)
-      typescript: 5.8.3
+      ts-api-utils: 2.1.0(typescript@5.9.2)
+      typescript: 5.9.2
     transitivePeerDependencies:
       - supports-color
 
-  '@typescript-eslint/parser@8.38.0(eslint@9.32.0)(typescript@5.8.3)':
+  '@typescript-eslint/parser@8.39.0(eslint@9.33.0)(typescript@5.9.2)':
     dependencies:
-      '@typescript-eslint/scope-manager': 8.38.0
-      '@typescript-eslint/types': 8.38.0
-      '@typescript-eslint/typescript-estree': 8.38.0(typescript@5.8.3)
-      '@typescript-eslint/visitor-keys': 8.38.0
+      '@typescript-eslint/scope-manager': 8.39.0
+      '@typescript-eslint/types': 8.39.0
+      '@typescript-eslint/typescript-estree': 8.39.0(typescript@5.9.2)
+      '@typescript-eslint/visitor-keys': 8.39.0
       debug: 4.4.1(supports-color@5.5.0)
-      eslint: 9.32.0
-      typescript: 5.8.3
+      eslint: 9.33.0
+      typescript: 5.9.2
     transitivePeerDependencies:
       - supports-color
 
-  '@typescript-eslint/project-service@8.38.0(typescript@5.8.3)':
+  '@typescript-eslint/project-service@8.39.0(typescript@5.9.2)':
     dependencies:
-      '@typescript-eslint/tsconfig-utils': 8.38.0(typescript@5.8.3)
-      '@typescript-eslint/types': 8.38.0
+      '@typescript-eslint/tsconfig-utils': 8.39.0(typescript@5.9.2)
+      '@typescript-eslint/types': 8.39.0
       debug: 4.4.1(supports-color@5.5.0)
-      typescript: 5.8.3
+      typescript: 5.9.2
     transitivePeerDependencies:
       - supports-color
 
-  '@typescript-eslint/scope-manager@8.38.0':
+  '@typescript-eslint/scope-manager@8.39.0':
     dependencies:
-      '@typescript-eslint/types': 8.38.0
-      '@typescript-eslint/visitor-keys': 8.38.0
+      '@typescript-eslint/types': 8.39.0
+      '@typescript-eslint/visitor-keys': 8.39.0
 
-  '@typescript-eslint/tsconfig-utils@8.38.0(typescript@5.8.3)':
+  '@typescript-eslint/tsconfig-utils@8.39.0(typescript@5.9.2)':
     dependencies:
-      typescript: 5.8.3
+      typescript: 5.9.2
 
-  '@typescript-eslint/type-utils@8.38.0(eslint@9.32.0)(typescript@5.8.3)':
+  '@typescript-eslint/type-utils@8.39.0(eslint@9.33.0)(typescript@5.9.2)':
     dependencies:
-      '@typescript-eslint/types': 8.38.0
-      '@typescript-eslint/typescript-estree': 8.38.0(typescript@5.8.3)
-      '@typescript-eslint/utils': 8.38.0(eslint@9.32.0)(typescript@5.8.3)
+      '@typescript-eslint/types': 8.39.0
+      '@typescript-eslint/typescript-estree': 8.39.0(typescript@5.9.2)
+      '@typescript-eslint/utils': 8.39.0(eslint@9.33.0)(typescript@5.9.2)
       debug: 4.4.1(supports-color@5.5.0)
-      eslint: 9.32.0
-      ts-api-utils: 2.1.0(typescript@5.8.3)
-      typescript: 5.8.3
+      eslint: 9.33.0
+      ts-api-utils: 2.1.0(typescript@5.9.2)
+      typescript: 5.9.2
     transitivePeerDependencies:
       - supports-color
 
-  '@typescript-eslint/types@8.38.0': {}
+  '@typescript-eslint/types@8.39.0': {}
 
-  '@typescript-eslint/typescript-estree@8.38.0(typescript@5.8.3)':
+  '@typescript-eslint/typescript-estree@8.39.0(typescript@5.9.2)':
     dependencies:
-      '@typescript-eslint/project-service': 8.38.0(typescript@5.8.3)
-      '@typescript-eslint/tsconfig-utils': 8.38.0(typescript@5.8.3)
-      '@typescript-eslint/types': 8.38.0
-      '@typescript-eslint/visitor-keys': 8.38.0
+      '@typescript-eslint/project-service': 8.39.0(typescript@5.9.2)
+      '@typescript-eslint/tsconfig-utils': 8.39.0(typescript@5.9.2)
+      '@typescript-eslint/types': 8.39.0
+      '@typescript-eslint/visitor-keys': 8.39.0
       debug: 4.4.1(supports-color@5.5.0)
       fast-glob: 3.3.3
       is-glob: 4.0.3
       minimatch: 9.0.5
       semver: 7.7.2
-      ts-api-utils: 2.1.0(typescript@5.8.3)
-      typescript: 5.8.3
+      ts-api-utils: 2.1.0(typescript@5.9.2)
+      typescript: 5.9.2
     transitivePeerDependencies:
       - supports-color
 
-  '@typescript-eslint/utils@8.38.0(eslint@9.32.0)(typescript@5.8.3)':
+  '@typescript-eslint/utils@8.39.0(eslint@9.33.0)(typescript@5.9.2)':
     dependencies:
-      '@eslint-community/eslint-utils': 4.7.0(eslint@9.32.0)
-      '@typescript-eslint/scope-manager': 8.38.0
-      '@typescript-eslint/types': 8.38.0
-      '@typescript-eslint/typescript-estree': 8.38.0(typescript@5.8.3)
-      eslint: 9.32.0
-      typescript: 5.8.3
+      '@eslint-community/eslint-utils': 4.7.0(eslint@9.33.0)
+      '@typescript-eslint/scope-manager': 8.39.0
+      '@typescript-eslint/types': 8.39.0
+      '@typescript-eslint/typescript-estree': 8.39.0(typescript@5.9.2)
+      eslint: 9.33.0
+      typescript: 5.9.2
     transitivePeerDependencies:
       - supports-color
 
-  '@typescript-eslint/visitor-keys@8.38.0':
+  '@typescript-eslint/visitor-keys@8.39.0':
     dependencies:
-      '@typescript-eslint/types': 8.38.0
+      '@typescript-eslint/types': 8.39.0
       eslint-visitor-keys: 4.2.1
 
   '@vladfrangu/async_event_emitter@2.4.6': {}
···
 
   escape-string-regexp@4.0.0: {}
 
-  eslint-config-prettier@10.1.8(eslint@9.32.0):
+  eslint-config-prettier@10.1.8(eslint@9.33.0):
     dependencies:
-      eslint: 9.32.0
+      eslint: 9.33.0
 
-  eslint-plugin-prettier@5.5.3(eslint-config-prettier@10.1.8(eslint@9.32.0))(eslint@9.32.0)(prettier@3.6.2):
+  eslint-plugin-prettier@5.5.4(eslint-config-prettier@10.1.8(eslint@9.33.0))(eslint@9.33.0)(prettier@3.6.2):
     dependencies:
-      eslint: 9.32.0
+      eslint: 9.33.0
       prettier: 3.6.2
       prettier-linter-helpers: 1.0.0
       synckit: 0.11.11
     optionalDependencies:
-      eslint-config-prettier: 10.1.8(eslint@9.32.0)
+      eslint-config-prettier: 10.1.8(eslint@9.33.0)
 
   eslint-scope@8.4.0:
     dependencies:
···
 
   eslint-visitor-keys@4.2.1: {}
 
-  eslint@9.32.0:
+  eslint@9.33.0:
     dependencies:
-      '@eslint-community/eslint-utils': 4.7.0(eslint@9.32.0)
+      '@eslint-community/eslint-utils': 4.7.0(eslint@9.33.0)
       '@eslint-community/regexpp': 4.12.1
       '@eslint/config-array': 0.21.0
-      '@eslint/config-helpers': 0.3.0
-      '@eslint/core': 0.15.1
+      '@eslint/config-helpers': 0.3.1
+      '@eslint/core': 0.15.2
       '@eslint/eslintrc': 3.3.1
-      '@eslint/js': 9.32.0
-      '@eslint/plugin-kit': 0.3.4
+      '@eslint/js': 9.33.0
+      '@eslint/plugin-kit': 0.3.5
       '@humanfs/node': 0.16.6
       '@humanwhocodes/module-importer': 1.0.1
       '@humanwhocodes/retry': 0.4.3
···
 
   ms@2.1.3: {}
 
+  multiformats@9.9.0: {}
+
   mylas@2.1.13: {}
 
   natural-compare@1.4.0: {}
···
     dependencies:
       fn.name: 1.1.0
 
-  openai@5.12.0(ws@8.18.3):
+  openai@5.12.2(ws@8.18.3)(zod@3.25.76):
     optionalDependencies:
       ws: 8.18.3
+      zod: 3.25.76
 
   optionator@0.9.4:
     dependencies:
···
 
   triple-beam@1.4.1: {}
 
-  ts-api-utils@2.1.0(typescript@5.8.3):
+  ts-api-utils@2.1.0(typescript@5.9.2):
     dependencies:
-      typescript: 5.8.3
+      typescript: 5.9.2
 
   ts-mixer@6.0.4: {}
 
···
       media-typer: 0.3.0
       mime-types: 2.1.35
 
-  typescript-eslint@8.38.0(eslint@9.32.0)(typescript@5.8.3):
+  typescript-eslint@8.39.0(eslint@9.33.0)(typescript@5.9.2):
     dependencies:
-      '@typescript-eslint/eslint-plugin': 8.38.0(@typescript-eslint/parser@8.38.0(eslint@9.32.0)(typescript@5.8.3))(eslint@9.32.0)(typescript@5.8.3)
-      '@typescript-eslint/parser': 8.38.0(eslint@9.32.0)(typescript@5.8.3)
-      '@typescript-eslint/typescript-estree': 8.38.0(typescript@5.8.3)
-      '@typescript-eslint/utils': 8.38.0(eslint@9.32.0)(typescript@5.8.3)
-      eslint: 9.32.0
-      typescript: 5.8.3
+      '@typescript-eslint/eslint-plugin': 8.39.0(@typescript-eslint/parser@8.39.0(eslint@9.33.0)(typescript@5.9.2))(eslint@9.33.0)(typescript@5.9.2)
+      '@typescript-eslint/parser': 8.39.0(eslint@9.33.0)(typescript@5.9.2)
+      '@typescript-eslint/typescript-estree': 8.39.0(typescript@5.9.2)
+      '@typescript-eslint/utils': 8.39.0(eslint@9.33.0)(typescript@5.9.2)
+      eslint: 9.33.0
+      typescript: 5.9.2
     transitivePeerDependencies:
       - supports-color
 
-  typescript@5.8.3: {}
+  typescript@5.9.2: {}
+
+  uint8arrays@3.0.0:
+    dependencies:
+      multiformats: 9.9.0
 
   undefsafe@2.0.5: {}
 
   underscore@1.13.7: {}
 
-  undici-types@7.8.0: {}
+  undici-types@7.10.0: {}
 
   undici@6.21.3: {}
 
···
       yargs-parser: 18.1.3
 
   yocto-queue@0.1.0: {}
+
+  zod@3.25.76: {}

src/commands/utilities/ai.ts

···
       `prompt: "${prompt.substring(0, 50)}${prompt.length > 50 ? '...' : ''}"`,
     );
 
-    const { apiKey, model, apiUrl } = await getUserCredentials(interaction.user.id);
+    const invokerId = getInvokerId(interaction);
+    const { apiKey, model, apiUrl } = await getUserCredentials(invokerId);
     const config = getApiConfiguration(apiKey ?? null, model ?? null, apiUrl ?? null);
 
     if (config.usingDefaultKey) {
       const exemptUserId = process.env.AI_EXEMPT_USER_ID;
-      if (interaction.user.id !== exemptUserId) {
-        const allowed = await incrementAndCheckDailyLimit(interaction.user.id, 10);
+      if (invokerId !== exemptUserId) {
+        const allowed = await incrementAndCheckDailyLimit(invokerId, 10);
         if (!allowed) {
           await interaction.editReply(
             '❌ ' +
···
       return;
     }
 
-    const existingConversation = userConversations.get(interaction.user.id) || [];
+    const existingConversation = userConversations.get(invokerId) || [];
     const conversationArray = Array.isArray(existingConversation) ? existingConversation : [];
     const systemPrompt = buildSystemPrompt(
       !!config.usingDefaultKey,
···
     if (updatedConversation.length > 10) {
       updatedConversation.splice(0, updatedConversation.length - 10);
     }
-    userConversations.set(interaction.user.id, updatedConversation);
+    userConversations.set(invokerId, updatedConversation);
 
     await sendAIResponse(interaction, aiResponse, client);
   } catch (error) {
···
       interaction,
       client,
       error: error as Error,
-      userId: interaction.user.id,
+      userId: getInvokerId(interaction),
       username: interaction.user.tag,
     });
   } finally {
-    pendingRequests.delete(interaction.user.id);
+    pendingRequests.delete(getInvokerId(interaction));
   }
 }
 
···
     ),
 
   async execute(client: BotClient, interaction: ChatInputCommandInteraction) {
-    const userId = interaction.user.id;
+    const userId = getInvokerId(interaction);
 
     if (pendingRequests.has(userId)) {
       const pending = pendingRequests.get(userId);
···
       if (interaction.customId === 'apiCredentials') {
         await interaction.deferReply({ flags: MessageFlags.Ephemeral });
 
-        const userId = interaction.user.id;
+        const userId = getInvokerId(interaction);
         const pendingRequest = pendingRequests.get(userId);
 
         if (!pendingRequest) {
···
         content: await client.getLocaleText('failedrequest', interaction.locale),
       });
     } finally {
-      pendingRequests.delete(interaction.user.id);
+      pendingRequests.delete(getInvokerId(interaction));
     }
   },
 } as unknown as SlashCommandProps;
+
+function getInvokerId(interaction: ChatInputCommandInteraction | ModalSubmitInteraction) {
+  if (interaction.inGuild()) {
+    return `${interaction.guildId}-${interaction.user.id}`;
+  }
+  return interaction.user.id;
+}

src/commands/utilities/social.ts

···
+import {
+  SlashCommandBuilder,
+  PermissionFlagsBits,
+  EmbedBuilder,
+  ChatInputCommandInteraction,
+  MessageFlags,
+} from 'discord.js';
+import { SlashCommandProps } from '@/types/command';
+import BotClient from '@/services/Client';
+import logger from '@/utils/logger';
+import { SocialMediaSubscription } from '@/types/social';
+
+interface SocialCommand extends SlashCommandProps {
+  handleAdd: (client: BotClient, interaction: ChatInputCommandInteraction) => Promise<void>;
+  handleRemove: (client: BotClient, interaction: ChatInputCommandInteraction) => Promise<void>;
+  handleList: (client: BotClient, interaction: ChatInputCommandInteraction) => Promise<void>;
+  handleRefresh: (client: BotClient, interaction: ChatInputCommandInteraction) => Promise<void>;
+}
+
+const platforms = [
+  { name: 'Bluesky', value: 'bluesky' },
+  { name: 'Fediverse (Mastodon, Pleroma, etc.)', value: 'fediverse' },
+] as const;
+
+type SocialPlatform = (typeof platforms)[number]['value'];
+
+const platformNames: Record<string, string> = {
+  bluesky: 'Bluesky',
+  fediverse: 'Fediverse',
+};
+
+const platformEmojis: Record<string, string> = {
+  bluesky: '🔵',
+  fediverse: '🐘',
+};
+
+const command: SocialCommand = {
+  data: new SlashCommandBuilder()
+    .setName('social')
+    .setDescription('Get notifications of posts from Fediverse and Bluesky accounts')
+    .setDefaultMemberPermissions(PermissionFlagsBits.ManageGuild)
+    .setDMPermission(false)
+    .addSubcommand((subcommand) =>
+      subcommand
+        .setName('add')
+        .setDescription('Add a social media account to track')
+        .addStringOption((option) =>
+          option
+            .setName('platform')
+            .setDescription('Social media platform')
+            .setRequired(true)
+            .addChoices(...platforms),
+        )
+        .addStringOption((option) =>
+          option
+            .setName('account')
+            .setDescription(
+              'Account handle (e.g., [e-mail] for Fediverse, or user.bsky.social for Bluesky)',
+            )
+            .setRequired(true),
+        )
+        .addChannelOption((option) =>
+          option
+            .setName('channel')
+            .setDescription('Channel to post notifications (defaults to current channel)')
+            .setRequired(false),
+        ),
+    )
+    .addSubcommand((subcommand) =>
+      subcommand
+        .setName('remove')
+        .setDescription('Remove a social media account from tracking')
+        .addStringOption((option) =>
+          option
+            .setName('platform')
+            .setDescription('Social media platform')
+            .setRequired(true)
+            .addChoices(...platforms),
+        )
+        .addStringOption((option) =>
+          option
+            .setName('account')
+            .setDescription('Account handle to remove from tracking')
+            .setRequired(true),
+        ),
+    )
+    .addSubcommand((subcommand) =>
+      subcommand
+        .setName('list')
+        .setDescription('List all tracked social media accounts for this server'),
+    )
+    .addSubcommand((subcommand) =>
+      subcommand
+        .setName('refresh')
+        .setDescription('Check for new posts and send notifications immediately'),
+    ) as unknown as SlashCommandBuilder,
+
+  handleAdd: async (client: BotClient, interaction: ChatInputCommandInteraction) => {
+    await interaction.deferReply({ flags: MessageFlags.Ephemeral });
+
+    const platform = interaction.options.getString('platform', true) as SocialPlatform;
+    const account = interaction.options.getString('account', true);
+    const channel = interaction.options.getChannel('channel') || interaction.channel;
+
+    if (!channel || !('isTextBased' in channel) || !channel.isTextBased()) {
+      const msg = await client.getLocaleText(
+        'commands.social.invalidChannel',
+        interaction.locale || 'en-US',
+      );
+      await interaction.editReply(msg);
+      return;
+    }
+
+    if (!client.socialMediaManager) {
+      throw new Error(
+        await client.getLocaleText(
+          'commands.social.notInitializedThrow',
+          interaction.locale || 'en-US',
+        ),
+      );
+    }
+
+    await client.socialMediaManager
+      .getService()
+      .addSubscription(interaction.guildId!, platform, account, channel.id);
+
+    const success = await client.getLocaleText(
+      'commands.social.addSuccess',
+      interaction.locale || 'en-US',
+      {
+        platform,
+        account,
+        channel: String(channel),
+      },
+    );
+    await interaction.editReply(success);
+
+    logger.info(
+      `Added social media subscription for ${platform} account ${account} in guild ${interaction.guildId}`,
+    );
+  },
+
+  handleRefresh: async (client: BotClient, interaction: ChatInputCommandInteraction) => {
+    await interaction.deferReply({ flags: MessageFlags.Ephemeral });
+    if (!client.socialMediaManager) {
+      const msg = await client.getLocaleText(
+        'commands.social.notInitialized',
+        interaction.locale || 'en-US',
+      );
+      await interaction.editReply(msg);
+      return;
+    }
+    try {
+      const count = await client.socialMediaManager.refreshOnce();
+      const msg = await client.getLocaleText(
+        'commands.social.refreshSuccess',
+        interaction.locale || 'en-US',
+        { count: String(count) },
+      );
+      await interaction.editReply(msg);
+    } catch (err) {
+      const msg = err instanceof Error ? err.message : 'Unknown error';
+      const loc = await client.getLocaleText(
+        'commands.social.refreshFailed',
+        interaction.locale || 'en-US',
+        { message: msg },
+      );
+      await interaction.editReply(loc);
+    }
+  },
+
+  handleRemove: async (client: BotClient, interaction: ChatInputCommandInteraction) => {
+    await interaction.deferReply({ flags: MessageFlags.Ephemeral });
+
+    const platform = interaction.options.getString('platform', true) as SocialPlatform;
+    const account = interaction.options.getString('account', true);
+
+    if (!client.socialMediaManager) {
+      throw new Error('Social media features are not properly initialized.');
+    }
+
+    const removed = await client.socialMediaManager
+      .getService()
+      .removeSubscription(interaction.guildId!, platform, account);
+
+    if (removed) {
+      const msg = await client.getLocaleText(
+        'commands.social.removeSuccess',
+        interaction.locale || 'en-US',
+        { platform, account },
+      );
+      await interaction.editReply(msg);
+      logger.info(
+        `Removed social media subscription for ${platform} account ${account} in guild ${interaction.guildId}`,
+      );
+    } else {
+      const msg = await client.getLocaleText(
+        'commands.social.removeNotFound',
+        interaction.locale || 'en-US',
+        { platform, account },
+      );
+      await interaction.editReply(msg);
+    }
+  },
+
+  handleList: async (client: BotClient, interaction: ChatInputCommandInteraction) => {
+    await interaction.deferReply({ flags: MessageFlags.Ephemeral });
+
+    if (!client.socialMediaManager) {
+      throw new Error('Social media features are not properly initialized.');
+    }
+
+    const subscriptions = await client.socialMediaManager
+      .getService()
+      .listSubscriptions(interaction.guildId!);
+
+    if (subscriptions.length === 0) {
+      const msg = await client.getLocaleText(
+        'commands.social.listNone',
+        interaction.locale || 'en-US',
+      );
+      await interaction.editReply(msg);
+      return;
+    }
+
+    const embed = new EmbedBuilder()
+      .setTitle(
+        await client.getLocaleText('commands.social.listTitle', interaction.locale || 'en-US'),
+      )
+      .setColor(0x3498db)
+      .setDescription(
+        await client.getLocaleText(
+          'commands.social.listDescription',
+          interaction.locale || 'en-US',
+        ),
+      );
+
+    const groupedByPlatform = subscriptions.reduce(
+      (acc, sub) => {
+        if (!acc[sub.platform]) {
+          acc[sub.platform] = [];
+        }
+        acc[sub.platform].push(sub);
+        return acc;
+      },
+      {} as Record<string, SocialMediaSubscription[]>,
+    );
+
+    for (const [platform, subs] of Object.entries(groupedByPlatform)) {
+      const platformName =
+        platformNames[platform] || platform.charAt(0).toUpperCase() + platform.slice(1);
+      const emoji = platformEmojis[platform] || '📱';
+
+      const channelUnset = await client.getLocaleText(
+        'commands.social.channelUnset',
+        interaction.locale || 'en-US',
+      );
+
+      const value = subs
+        .map((sub) => {
+          const channelMention = sub.channelId ? `<#${sub.channelId}>` : channelUnset;
+          return `• ${sub.accountHandle} → ${channelMention}`;
+        })
+        .join('\n');
+
+      embed.addFields({
+        name: `${emoji} ${platformName} (${subs.length})`,
+        value:
+          value ||
+          (await client.getLocaleText(
+            'commands.social.fieldNoAccounts',
+            interaction.locale || 'en-US',
+          )),
+        inline: false,
+      });
+    }
+
+    await interaction.editReply({ embeds: [embed] });
+    logger.info(
+      `Listed ${subscriptions.length} social media subscriptions for guild ${interaction.guildId}`,
+    );
+  },
+
+  async execute(client: BotClient, interaction: ChatInputCommandInteraction) {
+    if (!interaction.guildId) {
+      await interaction.reply({
+        content: await client.getLocaleText(
+          'commands.social.guildOnly',
+          interaction.locale || 'en-US',
+        ),
+        flags: MessageFlags.Ephemeral,
+      });
+      return;
+    }
+
+    const subcommand = interaction.options.getSubcommand();
+
+    try {
+      switch (subcommand) {
+        case 'add':
+          await command.handleAdd(client, interaction);
+          break;
+        case 'remove':
+          await command.handleRemove(client, interaction);
+          break;
+        case 'list':
+          await command.handleList(client, interaction);
+          break;
+        case 'refresh':
+          await command.handleRefresh(client, interaction);
+          break;
+        default:
+          await interaction.reply({
+            content: await client.getLocaleText(
+              'commands.social.unknownSubcommand',
+              interaction.locale || 'en-US',
+            ),
+            flags: MessageFlags.Ephemeral,
+          });
+      }
+    } catch (error: unknown) {
+      const errorMessage = error instanceof Error ? error.message : 'An unknown error occurred';
+      logger.error(`Error in social ${subcommand} command:`, error);
+
+      if (interaction.deferred || interaction.replied) {
+        const msg = await client.getLocaleText(
+          'commands.social.failedAction',
+          interaction.locale || 'en-US',
+          { action: subcommand, message: errorMessage },
+        );
+        await interaction.editReply(msg);
+      } else {
+        await interaction.reply({
+          content: await client.getLocaleText(
+            'commands.social.failedAction',
+            interaction.locale || 'en-US',
+            { action: subcommand, message: errorMessage },
+          ),
+          flags: MessageFlags.Ephemeral,
+        });
+      }
+    }
+  },
+};
+
+export default command;

src/events/messageCreate.ts

···
 import type { ConversationMessage, AIResponse } from '@/commands/utilities/ai';
 import { createMemoryManager } from '@/utils/memoryManager';
 
-const dmConversations = createMemoryManager<string, ConversationMessage[]>({
-  maxSize: 500,
+const conversations = createMemoryManager<string, ConversationMessage[]>({
+  maxSize: 2000,
   maxAge: 2 * 60 * 60 * 1000,
   cleanupInterval: 10 * 60 * 1000,
 });
 
-const serverConversations = createMemoryManager<string, ConversationMessage[]>({
-  maxSize: 1000,
-  maxAge: 1 * 60 * 60 * 1000,
-  cleanupInterval: 10 * 60 * 1000,
-});
+function getConversationKey(message: Message): string {
+  if (message.channel.type === ChannelType.DM) {
+    return `dm:${message.author.id}`;
+  } else if (message.guildId) {
+    return `guild:${message.guildId}:${message.author.id}`;
+  }
+  return `channel:${message.channelId}`;
+}
 
 export default class MessageCreateEvent {
   constructor(private client: BotClient) {
···
     try {
       logger.debug(`${isDM ? 'DM' : 'Message'} received (${message.content.length} characters)`);
 
-      const conversationKey = isDM ? message.author.id : message.channel.id;
-      const conversationManager = isDM ? dmConversations : serverConversations;
-      const conversation = conversationManager.get(conversationKey) || [];
+      const conversationKey = getConversationKey(message);
+      const conversation = conversations.get(conversationKey) || [];
 
       const hasImageAttachments = message.attachments.some(
         (att) =>
···
 
       logger.debug(`hasImageAttachments: ${hasImageAttachments}, hasImageUrls: ${hasImageUrls}`);
       const hasImages = hasImageAttachments;
-
-      const { model: userCustomModel } = await getUserCredentials(message.author.id);
+      const { model: userCustomModel } = await getUserCredentials(conversationKey);
 
       const selectedModel = hasImages
         ? 'google/gemma-3-4b-it'
···
         systemPrompt,
       );
 
-      const { apiKey: userApiKey, apiUrl: userApiUrl } = await getUserCredentials(
-        message.author.id,
-      );
+      const { apiKey: userApiKey, apiUrl: userApiUrl } = await getUserCredentials(conversationKey);
       const config = getApiConfiguration(userApiKey ?? null, selectedModel, userApiUrl ?? null);
 
       if (config.usingDefaultKey) {
         const exemptUserId = process.env.AI_EXEMPT_USER_ID;
-        if (message.author.id !== exemptUserId) {
-          const allowed = await incrementAndCheckDailyLimit(message.author.id, 10);
+        const actorId = message.author.id;
+
+        if (actorId !== exemptUserId) {
+          const allowed = await incrementAndCheckDailyLimit(actorId, 10);
           if (!allowed) {
             await message.reply(
               "❌ You've reached your daily limit of AI requests. Please try again tomorrow or set up your own API key using the `/ai` command.",
···
         role: 'assistant',
         content: aiResponse.content,
       });
-      conversationManager.set(conversationKey, updatedConversation);
+      conversations.set(conversationKey, updatedConversation);
 
       logger.info(`${isDM ? 'DM' : 'Server'} response sent successfully`);
     } catch (error) {

src/services/Client.ts

···
 import initialzeCommands from '@/handlers/initialzeCommands';
 import { SlashCommandProps } from '@/types/command';
 import { Client, Collection, GatewayIntentBits, Partials } from 'discord.js';
+import { Pool } from 'pg';
+import { initializeSocialMediaManager, SocialMediaManager } from './social/SocialMediaManager';
 import { promises, readdirSync } from 'fs';
 import path from 'path';
 import { fileURLToPath } from 'url';
···
   public commands = new Collection<string, SlashCommandProps>();
   // eslint-disable-next-line @typescript-eslint/no-explicit-any
   public t = new Collection<string, any>();
+  public socialMediaManager?: SocialMediaManager;
 
   constructor() {
     super({
···
     await this.setupLocalization();
     await initialzeCommands(this);
     await this.setupEvents();
+    await this.setupDatabase();
     this.login(config.TOKEN);
   }
 
···
       throw new Error('Failed to initialize localization');
     }
   }
+  private async setupDatabase() {
+    try {
+      const sslMode = (process.env.PGSSLMODE || process.env.DATABASE_SSL || '').toLowerCase();
+      let ssl: false | { rejectUnauthorized?: boolean; ca?: string } = false;
+      const rootCertPath = process.env.PGSSLROOTCERT || process.env.DATABASE_SSL_CA;
+
+      if (sslMode === 'require') {
+        ssl = { rejectUnauthorized: true };
+      }
+
+      if (rootCertPath) {
+        try {
+          const ca = await promises.readFile(rootCertPath, 'utf8');
+          ssl = { ca, rejectUnauthorized: true };
+        } catch (e) {
+          console.warn('Failed to read CA certificate: unable to access the specified path.', e);
+        }
+      }
+
+      const pool = new Pool({
+        connectionString: process.env.DATABASE_URL,
+        ssl,
+      });
+
+      pool.on('error', (err) => {
+        console.error('Unexpected error on idle PostgreSQL client:', err);
+      });
+
+      const shutdown = async (signal?: NodeJS.Signals) => {
+        try {
+          console.log(`Received ${signal ?? 'shutdown'}: closing services and database pool...`);
+          await this.socialMediaManager?.cleanup();
+          await pool.end();
+          console.log('Database pool closed. Exiting.');
+        } catch (e) {
+          console.error('Error during graceful shutdown:', e);
+        } finally {
+          process.exit(0);
+        }
+      };
+
+      process.on('SIGINT', () => shutdown('SIGINT'));
+      process.on('SIGTERM', () => shutdown('SIGTERM'));
+
+      this.socialMediaManager = initializeSocialMediaManager(this, pool);
+      await this.socialMediaManager.initialize();
+    } catch (error) {
+      console.error('Failed to initialize database and services:', error);
+      throw error;
+    }
+  }
+
   public async getLocaleText(key: string, locale: string, replaces = {}): Promise<string> {
     const fallbackLocale = 'en-US';
 

src/services/social/SocialMediaManager.ts

···
+import { Client, EmbedBuilder } from 'discord.js';
+import { Pool } from 'pg';
+import { SocialMediaService } from './SocialMediaService';
+import { BlueskyFetcher, FediverseFetcher } from './fetchers/UnifiedFetcher';
+import { SocialMediaFetcher } from '../../types/social';
+import { SocialMediaPost, SocialMediaSubscription } from '../../types/social';
+import logger from '../../utils/logger';
+
+export class SocialMediaManager {
+  private socialService: SocialMediaService;
+  private notificationService: NotificationService;
+  private poller: SocialMediaPoller;
+  private isInitialized = false;
+
+  constructor(
+    private client: Client,
+    private pool: Pool,
+  ) {
+    const fetchers: SocialMediaFetcher[] = [new BlueskyFetcher(), new FediverseFetcher()];
+
+    this.socialService = new SocialMediaService(pool, fetchers);
+    this.notificationService = new NotificationService(client);
+    this.poller = new SocialMediaPoller(client, this.socialService, this.notificationService);
+  }
+
+  public async initialize(): Promise<void> {
+    if (this.isInitialized) return;
+
+    this.poller.start();
+    this.isInitialized = true;
+  }
+
+  public getService(): SocialMediaService {
+    return this.socialService;
+  }
+
+  public async refreshOnce(): Promise<number> {
+    const updates = await this.socialService.checkForUpdates();
+    let count = 0;
+    for (const { post, subscription } of updates) {
+      try {
+        await this.notificationService.sendNotification(post, subscription);
+        count++;
+      } catch (error) {
+        console.error('Error sending notification during manual refresh:', error);
+      }
+    }
+    return count;
+  }
+
+  public async cleanup(): Promise<void> {
+    if (this.poller) {
+      this.poller.stop();
+    }
+    this.isInitialized = false;
+  }
+}
+
+class NotificationService {
+  constructor(private client: Client) {}
+
+  async sendNotification(
+    post: SocialMediaPost,
+    subscription: SocialMediaSubscription,
+  ): Promise<void> {
+    try {
+      const channel = await this.client.channels.fetch(subscription.channelId);
+      if (!this.isTextBasedAndSendable(channel)) {
+        console.error(
+          `Channel ${subscription.channelId} not found or not text-capable. Skipping notification.`,
+        );
+        return;
+      }
+
+      const embed = this.createEmbed(post);
+      await channel.send({ embeds: [embed] });
+    } catch (error) {
+      console.error('Error sending notification:', error);
+    }
+  }
+
+  private createEmbed(post: SocialMediaPost): EmbedBuilder {
+    const authorIcon = post.authorAvatarUrl ?? this.getPlatformIcon(post.platform);
+    const authorName =
+      post.authorDisplayName && post.authorDisplayName.trim().length > 0
+        ? `${post.authorDisplayName} (${post.author})`
+        : post.author;
+    const cleanText = this.stripHtml(post.text ?? '');
+    const embed = new EmbedBuilder()
+      .setColor(this.getPlatformColor(post.platform))
+      .setAuthor({ name: authorName, iconURL: authorIcon })
+      .setDescription(this.truncateText(cleanText, 1000))
+      .setTimestamp(post.timestamp)
+      .setFooter({
+        text: `New post on ${this.formatPlatformName(post.platform)}`,
+        iconURL: this.getPlatformIcon(post.platform),
+      });
+
+    if (post.mediaUrls && post.mediaUrls.length > 0) embed.setImage(post.mediaUrls[0]);
+    embed.addFields([
+      { name: 'View Post', value: `[Open in Browser](${this.getPostUrl(post)})`, inline: true },
+    ]);
+    return embed;
+  }
+
+  private getPlatformColor(platform: string): number {
+    switch (platform) {
+      case 'bluesky':
+        return 0x1185fe;
+      case 'fediverse':
+        return 0x6364ff;
+      default:
+        return 0x7289da;
+    }
+  }
+
+  private getPlatformIcon(platform: string): string | undefined {
+    switch (platform) {
+      case 'bluesky':
+        return 'https://upload.wikimedia.org/wikipedia/commons/thumb/7/7a/Bluesky_Logo.svg/24px-Bluesky_Logo.svg.png';
+      case 'fediverse':
+        return 'https://upload.wikimedia.org/wikipedia/commons/thumb/9/93/Fediverse_logo_proposal.svg/64px-Fediverse_logo_proposal.svg.png';
+      default:
+        return undefined;
+    }
+  }
+
+  private formatPlatformName(platform: string): string {
+    return platform.charAt(0).toUpperCase() + platform.slice(1);
+  }
+
+  private getPostUrl(post: SocialMediaPost): string {
+    switch (post.platform) {
+      case 'bluesky': {
+        const handle = post.author.split('@')[0];
+        const postId = post.uri.split('/').pop();
+        return `https://bsky.app/profile/${handle}/post/${postId}`;
+      }
+      case 'fediverse':
+        return post.uri;
+      default:
+        return post.uri;
+    }
+  }
+
+  private truncateText(text: string, maxLength: number): string {
+    if (text.length <= maxLength) return text;
+    return text.substring(0, maxLength - 3) + '...';
+  }
+
+  private stripHtml(text: string): string {
+    return text
+      .replace(/<[^>]*>/g, ' ')
+      .replace(/\s+/g, ' ')
+      .trim();
+  }
+
+  private isTextBasedAndSendable(
+    channel: unknown,
+  ): channel is { send: (options: unknown) => Promise<unknown> } & { isTextBased(): boolean } {
+    const maybe = channel as { send?: unknown; isTextBased?: unknown };
+    return (
+      typeof maybe.send === 'function' &&
+      typeof maybe.isTextBased === 'function' &&
+      maybe.isTextBased()
+    );
+  }
+}
+
+class SocialMediaPoller {
+  private isRunning = false;
+  private inProgress = false;
+  private pollInterval: NodeJS.Timeout | null = null;
+  private readonly POLL_INTERVAL_MS = 60 * 1000;
+
+  constructor(
+    private readonly client: Client,
+    private readonly socialService: SocialMediaService,
+    private readonly notificationService: NotificationService,
+  ) {}
+
+  public start(): void {
+    if (this.isRunning) {
+      logger.warn('Social media poller is already running');
+      return;
+    }
+
+    this.isRunning = true;
+    logger.info('Starting social media poller...');
+
+    this.safeCheckForUpdates();
+
+    this.pollInterval = setInterval(() => {
+      this.safeCheckForUpdates();
+    }, this.POLL_INTERVAL_MS);
+  }
+
+  public stop(): void {
+    if (!this.isRunning) return;
+    logger.info('Stopping social media poller...');
+    if (this.pollInterval) {
+      clearInterval(this.pollInterval);
+      this.pollInterval = null;
+    }
+    this.isRunning = false;
+  }
+
+  public isActive(): boolean {
+    return this.isRunning;
+  }
+
+  private async checkForUpdates(): Promise<void> {
+    if (!this.isRunning) return;
+    logger.debug('Checking for social media updates...');
+    try {
+      const newPosts = await this.socialService.checkForUpdates();
+      if (newPosts.length > 0) {
+        for (const { post, subscription } of newPosts) {
+          try {
+            await this.notificationService.sendNotification(post, subscription);
+          } catch (error) {
+            console.error(`Error sending notification for ${post.platform} post:`, error);
+          }
+        }
+      }
+    } catch (error) {
+      console.error('Error checking for social media updates:', error);
+    }
+  }
+
+  private async safeCheckForUpdates(): Promise<void> {
+    if (!this.isRunning || this.inProgress) {
+      return;
+    }
+    this.inProgress = true;
+    try {
+      await this.checkForUpdates();
+    } catch (error) {
+      logger.error('Error during guarded social media check:', error);
+    } finally {
+      this.inProgress = false;
+    }
+  }
+}
+
+export let socialMediaManager: SocialMediaManager;
+
+export function initializeSocialMediaManager(client: Client, pool: Pool): SocialMediaManager {
+  if (!socialMediaManager) {
+    socialMediaManager = new SocialMediaManager(client, pool);
+  }
+  return socialMediaManager;
+}

src/services/social/SocialMediaService.ts

···
+import { Pool } from 'pg';
+import {
+  SocialMediaSubscription,
+  SocialMediaPost,
+  SocialPlatform,
+  SocialMediaFetcher,
+} from '../../types/social';
+
+export class SocialMediaService {
+  private pool: Pool;
+  private fetchers: Map<SocialPlatform, SocialMediaFetcher>;
+  private isPolling = false;
+  private pollInterval: number = 5 * 60 * 1000;
+
+  constructor(pool: Pool, fetchers: SocialMediaFetcher[]) {
+    this.pool = pool;
+    this.fetchers = new Map(fetchers.map((f) => [f.platform, f]));
+  }
+
+  async addSubscription(
+    guildId: string,
+    platform: SocialPlatform,
+    accountHandle: string,
+    channelId: string,
+  ): Promise<SocialMediaSubscription> {
+    const fetcher = this.fetchers.get(platform);
+    if (!fetcher) {
+      throw new Error(`Unsupported platform: ${platform}`);
+    }
+
+    if (!fetcher.isValidAccount(accountHandle)) {
+      throw new Error(`Invalid account handle format for ${platform}`);
+    }
+
+    const normalized = this.normalizeAccountHandle(platform, accountHandle);
+
+    const result = await this.pool.query(
+      `INSERT INTO server_social_subscriptions 
+             (guild_id, platform, account_handle, channel_id)
+             VALUES ($1, $2::social_platform, $3, $4)
+             ON CONFLICT (guild_id, platform, lower(account_handle)) 
+             DO UPDATE SET channel_id = $4
+             RETURNING *`,
+      [guildId, platform, normalized, channelId],
+    );
+
+    return this.mapDbToSubscription(result.rows[0]);
+  }
+
+  async removeSubscription(
+    guildId: string,
+    platform: SocialPlatform,
+    accountHandle: string,
+  ): Promise<boolean> {
+    const normalizedHandle = this.normalizeAccountHandle(platform, accountHandle);
+    const result = await this.pool.query(
+      `DELETE FROM server_social_subscriptions 
+             WHERE guild_id = $1 AND platform = $2::social_platform AND account_handle = $3`,
+      [guildId, platform, normalizedHandle],
+    );
+
+    return (result.rowCount || 0) > 0;
+  }
+
+  async listSubscriptions(guildId: string): Promise<SocialMediaSubscription[]> {
+    const result = await this.pool.query(
+      `SELECT * FROM server_social_subscriptions WHERE guild_id = $1`,
+      [guildId],
+    );
+
+    return result.rows.map(this.mapDbToSubscription);
+  }
+
+  async checkForUpdates(): Promise<
+    { post: SocialMediaPost; subscription: SocialMediaSubscription }[]
+  > {
+    const subscriptions = await this.getAllActiveSubscriptions();
+    const newPosts: { post: SocialMediaPost; subscription: SocialMediaSubscription }[] = [];
+
+    for (const sub of subscriptions) {
+      try {
+        const fetcher = this.fetchers.get(sub.platform as SocialPlatform);
+        if (!fetcher) continue;
+
+        const latestPost = await fetcher.fetchLatestPost(sub.accountHandle);
+        if (latestPost) {
+          if (!sub.lastPostTimestamp) {
+            await this.updateLastPost(sub.id, latestPost.uri, latestPost.timestamp);
+            continue;
+          }
+
+          if (this.isNewerPost(latestPost, sub)) {
+            await this.updateLastPost(sub.id, latestPost.uri, latestPost.timestamp);
+            newPosts.push({
+              post: latestPost,
+              subscription: sub,
+            });
+          }
+        }
+      } catch (error) {
+        console.error(
+          `Error checking updates for ${sub.platform} account ${sub.accountHandle}:`,
+          error,
+        );
+      }
+    }
+
+    return newPosts;
+  }
+
+  startPolling(): void {
+    if (this.isPolling) return;
+
+    this.isPolling = true;
+    const poll = async () => {
+      if (!this.isPolling) return;
+
+      try {
+        await this.checkForUpdates();
+      } catch (error) {
+        console.error('Error during social media polling:', error);
+      } finally {
+        if (this.isPolling) {
+          setTimeout(poll, this.pollInterval);
+        }
+      }
+    };
+
+    poll();
+  }
+
+  stopPolling(): void {
+    this.isPolling = false;
+  }
+
+  private async getAllActiveSubscriptions(): Promise<SocialMediaSubscription[]> {
+    const result = await this.pool.query(`SELECT * FROM server_social_subscriptions`);
+    return result.rows.map(this.mapDbToSubscription);
+  }
+
+  private async updateLastPost(
+    subscriptionId: number,
+    postUri: string,
+    postTimestamp: Date,
+  ): Promise<void> {
+    await this.pool.query(
+      `UPDATE server_social_subscriptions 
+             SET last_post_uri = $1, last_post_timestamp = $2
+             WHERE id = $3`,
+      [postUri, postTimestamp, subscriptionId],
+    );
+  }
+
+  private isNewerPost(post: SocialMediaPost, subscription: SocialMediaSubscription): boolean {
+    if (!subscription.lastPostTimestamp) return true;
+    if (post.timestamp > subscription.lastPostTimestamp) return true;
+    if (post.timestamp < subscription.lastPostTimestamp) return false;
+    if (!subscription.lastPostUri) return true;
+    return post.uri !== subscription.lastPostUri;
+  }
+
+  private mapDbToSubscription(row: {
+    id: number;
+    guild_id: string;
+    platform: SocialPlatform;
+    account_handle: string;
+    last_post_uri: string | null;
+    last_post_timestamp: string | Date | null;
+    channel_id: string;
+    created_at: Date;
+    updated_at: Date;
+  }): SocialMediaSubscription {
+    const lastPostTimestamp = row.last_post_timestamp ? new Date(row.last_post_timestamp) : null;
+
+    return {
+      id: row.id,
+      guildId: row.guild_id,
+      platform: row.platform as SocialPlatform,
+      accountHandle: row.account_handle,
+      lastPostUri: row.last_post_uri ?? undefined,
+      lastPostTimestamp: lastPostTimestamp ?? undefined,
+      channelId: row.channel_id,
+      createdAt: row.created_at,
+      updatedAt: row.updated_at,
+    };
+  }
+
+  private normalizeAccountHandle(platform: SocialPlatform, handle: string): string {
+    let h = handle.trim();
+    if (platform === 'bluesky') {
+      h = h.startsWith('@') ? h.slice(1) : h;
+      h = h.toLowerCase();
+      if (!h.includes('.')) {
+        h = `${h}.bsky.social`;
+      }
+      return h;
+    }
+    h = h.startsWith('@') ? h.slice(1) : h;
+    return h.toLowerCase();
+  }
+}

src/services/social/fetchers/UnifiedFetcher.ts

···
+import { SocialMediaFetcher, SocialMediaPost, SocialPlatform } from '../../../types/social';
+import { HandleResolver } from '@atproto/identity';
+
+interface BlueskyPost {
+  uri: string;
+  cid: string;
+  author: {
+    did: string;
+    handle: string;
+    displayName?: string;
+  };
+  record: {
+    text: string;
+    createdAt: string;
+  };
+  embed?: {
+    $type: string;
+    images?: Array<{
+      thumb: string;
+      fullsize: string;
+      alt: string;
+    }>;
+  };
+}
+
+interface BlueskyFeedItem {
+  post?: BlueskyPost;
+}
+
+const DEFAULT_FETCH_TIMEOUT_MS = 10_000;
+async function fetchWithTimeout(
+  input: string,
+  init?: RequestInit,
+  timeoutMs: number = DEFAULT_FETCH_TIMEOUT_MS,
+): Promise<Response> {
+  const controller = new AbortController();
+  const timer = setTimeout(() => controller.abort(), timeoutMs);
+  try {
+    return await fetch(input, { ...(init || {}), signal: controller.signal });
+  } finally {
+    clearTimeout(timer);
+  }
+}
+
+export class BlueskyFetcher implements SocialMediaFetcher {
+  platform: SocialPlatform = 'bluesky';
+  private readonly baseUrl = 'https://public.api.bsky.app';
+  private readonly handleResolver = new HandleResolver();
+
+  async fetchLatestPost(account: string): Promise<SocialMediaPost | null> {
+    const actor = await this.resolveActor(account);
+    const url = `${this.baseUrl}/xrpc/app.bsky.feed.getAuthorFeed?actor=${encodeURIComponent(actor)}&limit=1`;
+
+    try {
+      const response = await fetchWithTimeout(url);
+      if (!response.ok) {
+        throw new Error(`HTTP error! status: ${response.status}`);
+      }
+
+      const data = await response.json();
+      const items = (data?.feed as BlueskyFeedItem[]) || [];
+      if (!Array.isArray(items) || items.length === 0) return null;
+
+      const post = items[0]?.post;
+      if (!post || !post.record) return null;
+
+      const actorId = post.author?.did || actor;
+      const profile = await this.fetchBlueskyProfile(actorId);
+      const avatarUrl = profile?.avatar ?? null;
+      const displayName = profile?.displayName ?? post.author?.displayName;
+
+      return this.mapToSocialMediaPost(post, avatarUrl || undefined, displayName);
+    } catch (error: unknown) {
+      const errorMessage = error instanceof Error ? error.message : 'Unknown error';
+      console.error('Error fetching Bluesky post:', error);
+      throw new Error(`Failed to fetch post from Bluesky: ${errorMessage}`);
+    }
+  }
+
+  isValidAccount(account: string | null | undefined): boolean {
+    if (!account) return false;
+
+    if (account.startsWith('did:')) {
+      return /^did:[a-z0-9]+:[a-zA-Z0-9._:%-]*[a-zA-Z0-9._-]$/.test(account);
+    }
+
+    const parts = account.split('@').filter(Boolean);
+    if (parts.length < 2) return false;
+
+    const handle = parts[0];
+    const domain = parts.slice(1).join('@');
+
+    const isValidHandle = /^[a-zA-Z0-9-]+$/.test(handle);
+    const isValidDomain = /^[a-zA-Z0-9.-]+$/.test(domain);
+
+    return isValidHandle && isValidDomain;
+  }
+
+  private normalizeHandle(handle: string): string {
+    if (handle.startsWith('did:')) {
+      return handle;
+    }
+
+    handle = handle.startsWith('@') ? handle.slice(1) : handle;
+    if (!handle.includes('.')) {
+      return `${handle}.bsky.social`.toLowerCase();
+    }
+    return handle.toLowerCase();
+  }
+
+  private async resolveActor(account: string): Promise<string> {
+    const normalized = this.normalizeHandle(account);
+    try {
+      const did = await this.handleResolver.resolve(normalized);
+      if (typeof did === 'string' && did.startsWith('did:')) {
+        return did;
+      }
+    } catch (_error) {
+      void 0;
+    }
+    return normalized;
+  }
+
+  private mapToSocialMediaPost(
+    post: BlueskyPost,
+    authorAvatarUrl?: string,
+    authorDisplayName?: string,
+  ): SocialMediaPost {
+    const mediaUrls: string[] = [];
+
+    if (post.embed?.$type === 'app.bsky.embed.images#view' && post.embed.images) {
+      mediaUrls.push(...post.embed.images.map((img) => img.fullsize));
+    }
+
+    const text = post.record?.text ?? '';
+    const createdAt = post.record?.createdAt ?? new Date().toISOString();
+    const author = post.author?.handle ?? 'unknown';
+
+    return {
+      uri: post.uri,
+      text,
+      author,
+      timestamp: new Date(createdAt),
+      platform: 'bluesky',
+      mediaUrls: mediaUrls.length > 0 ? mediaUrls : undefined,
+      authorAvatarUrl,
+      authorDisplayName,
+    };
+  }
+
+  private async fetchBlueskyProfile(
+    actor: string,
+  ): Promise<{ avatar?: string; displayName?: string } | null> {
+    try {
+      const url = `${this.baseUrl}/xrpc/app.bsky.actor.getProfile?actor=${encodeURIComponent(actor)}`;
+      const res = await fetchWithTimeout(url);
+      if (!res.ok) return null;
+      const data = await res.json();
+      const avatar = typeof data?.avatar === 'string' ? data.avatar : undefined;
+      const displayName = typeof data?.displayName === 'string' ? data.displayName : undefined;
+      return { avatar, displayName };
+    } catch {
+      return null;
+    }
+  }
+}
+
+interface FediverseAccount {
+  username: string;
+  acct: string;
+  display_name: string;
+  avatar: string;
+}
+
+interface FediverseAttachment {
+  id: string;
+  type: 'image' | 'video' | 'gifv' | 'audio' | 'unknown';
+  url: string;
+  preview_url: string;
+  description?: string;
+}
+
+interface FediversePost {
+  id: string;
+  uri: string;
+  url: string;
+  in_reply_to_id: string | null;
+  in_reply_to_account_id: string | null;
+  account: FediverseAccount;
+  content: string;
+  created_at: string;
+  reblogs_count: number;
+  favourites_count: number;
+  reblogged: boolean;
+  favourited: boolean;
+  sensitive: boolean;
+  spoiler_text: string;
+  visibility: 'public' | 'unlisted' | 'private' | 'direct';
+  media_attachments: FediverseAttachment[];
+  mentions: Array<{
+    id: string;
+    username: string;
+    url: string;
+    acct: string;
+  }>;
+  tags: Array<{ name: string; url: string }>;
+  application?: {
+    name: string;
+    website?: string;
+  };
+  language: string | null;
+  reblog: FediversePost | null;
+}
+
+export class FediverseFetcher implements SocialMediaFetcher {
+  platform: SocialPlatform = 'fediverse';
+
+  private validateFediverseAccount(username: string, domain: string | null): void {
+    if (!domain) {
+      throw new Error('Fediverse account must include a domain (e.g., [e-mail])');
+    }
+
+    if (/^https?:\/\//i.test(username) || /^https?:\/\//i.test(domain)) {
+      throw new Error('URL schemes (http/https) are not allowed in Fediverse accounts');
+    }
+
+    if (/[?#]/.test(username) || /[?#]/.test(domain)) {
+      throw new Error('URL paths and query parameters are not allowed in Fediverse accounts');
+    }
+
+    const domainStr = domain as string;
+    if (!/^([a-z0-9]([a-z0-9-]{0,61}[a-z0-9])?\.)+[a-z]{2,}$/i.test(domainStr)) {
+      throw new Error('Invalid domain format in Fediverse account');
+    }
+
+    if (!/^[a-z0-9_.-]+$/i.test(username)) {
+      throw new Error('Invalid username format in Fediverse account');
+    }
+  }
+
+  async fetchLatestPost(account: string): Promise<SocialMediaPost | null> {
+    const [username, domain] = this.parseAccount(account);
+    this.validateFediverseAccount(username, domain);
+
+    const domainStr = domain as string;
+    const apiUrl = `https://${domainStr}/api/v1/accounts/lookup?acct=${username}@${domainStr}`;
+
+    try {
+      const accountResponse = await fetchWithTimeout(apiUrl);
+      if (!accountResponse.ok) {
+        throw new Error(`Failed to fetch account: ${accountResponse.statusText}`);
+      }
+
+      const accountData = await accountResponse.json();
+
+      if (!accountData?.id) {
+        throw new Error('Invalid account data: missing account ID in response');
+      }
+
+      const accountId = accountData.id;
+      const statusesUrl = `https://${domainStr}/api/v1/accounts/${accountId}/statuses?limit=1&exclude_replies=true&exclude_reblogs=true`;
+      const statusResponse = await fetchWithTimeout(statusesUrl);
+
+      if (!statusResponse.ok) {
+        throw new Error(`Failed to fetch statuses: ${statusResponse.statusText}`);
+      }
+
+      const statuses = (await statusResponse.json()) as FediversePost[];
+      if (!statuses || statuses.length === 0) {
+        return null;
+      }
+
+      const post = this.mapToSocialMediaPost(statuses[0], domainStr);
+      return post;
+    } catch (error: unknown) {
+      const errorMessage = error instanceof Error ? error.message : 'Unknown error';
+      console.error('Error fetching Fediverse post:', error);
+      throw new Error(`Failed to fetch post from Fediverse: ${errorMessage}`);
+    }
+  }
+
+  isValidAccount(account: string): boolean {
+    if (!account) return false;
+    const parts = account.split('@').filter(Boolean);
+    return parts.length >= 2 && parts.every((part) => part.length > 0);
+  }
+
+  private parseAccount(account: string): [string, string | null] {
+    const cleanAccount = account.startsWith('@') ? account.slice(1) : account;
+    const firstAt = cleanAccount.indexOf('@');
+
+    if (firstAt === -1) {
+      return [cleanAccount, null];
+    }
+
+    const username = cleanAccount.substring(0, firstAt);
+    const domain = cleanAccount.substring(firstAt + 1);
+    return [username, domain];
+  }
+
+  private mapToSocialMediaPost(post: FediversePost, domain: string): SocialMediaPost {
+    if (post.reblog) {
+      return this.mapToSocialMediaPost(post.reblog, domain);
+    }
+
+    const mediaUrls = post.media_attachments
+      .filter((media) => media.type === 'image' || media.type === 'gifv')
+      .map((media) => media.url);
+
+    const acct = post.account.acct;
+    const authorAcct = acct.includes('@') ? acct : `${acct}@${domain}`;
+
+    return {
+      uri: post.uri,
+      text: post.content,
+      author: authorAcct,
+      timestamp: new Date(post.created_at),
+      platform: 'fediverse',
+      mediaUrls: mediaUrls.length > 0 ? mediaUrls : undefined,
+      authorAvatarUrl: post.account.avatar,
+      authorDisplayName: post.account.display_name,
+    };
+  }
+}

src/types/social.ts

···
+export type SocialPlatform = 'bluesky' | 'fediverse';
+
+export interface SocialMediaSubscription {
+  id: number;
+  guildId: string;
+  platform: SocialPlatform;
+  accountHandle: string;
+  lastPostUri?: string;
+  lastPostTimestamp?: Date;
+  channelId: string;
+  createdAt: Date;
+  updatedAt: Date;
+}
+
+export interface SocialMediaPost {
+  uri: string;
+  text: string;
+  author: string;
+  timestamp: Date;
+  platform: SocialPlatform;
+  mediaUrls?: string[];
+  authorAvatarUrl?: string;
+  authorDisplayName?: string;
+}
+
+export interface SocialMediaFetcher {
+  platform: SocialPlatform;
+  fetchLatestPost(account: string): Promise<SocialMediaPost | null>;
+  isValidAccount(account: string): boolean;
+}