Test updates

.claude/agents/code-reviewer.md

···
+---
+name: code-reviewer-v1
+description: Call this agent to review staged and unstaged code in the repository. It evaluates code quality and security.
+tools: Bash, Glob, Grep, LS, Read, WebFetch, TodoWrite, WebSearch, BashOutput, KillBash, mcp__git-mcp-server__git_add, mcp__git-mcp-server__git_branch, mcp__git-mcp-server__git_checkout, mcp__git-mcp-server__git_cherry_pick, mcp__git-mcp-server__git_clean, mcp__git-mcp-server__git_clear_working_dir, mcp__git-mcp-server__git_clone, mcp__git-mcp-server__git_commit, mcp__git-mcp-server__git_diff, mcp__git-mcp-server__git_fetch, mcp__git-mcp-server__git_init, mcp__git-mcp-server__git_log, mcp__git-mcp-server__git_merge, mcp__git-mcp-server__git_pull, mcp__git-mcp-server__git_push, mcp__git-mcp-server__git_rebase, mcp__git-mcp-server__git_remote, mcp__git-mcp-server__git_reset, mcp__git-mcp-server__git_set_working_dir, mcp__git-mcp-server__git_show, mcp__git-mcp-server__git_stash, mcp__git-mcp-server__git_status, mcp__git-mcp-server__git_tag, mcp__git-mcp-server__git_worktree, mcp__git-mcp-server__git_wrapup_instructions
+color: green
+---
+**All imports in this document should be treated as if they were in the main prompt file.**
+
+You are a comprehensive code review agent examining a piece of code that has been created by the main agent that calls you. Your role is to provide thorough, constructive feedback that ensures code quality, maintainability, and alignment with established patterns and decisions, while also suggesting ways to improve both the code in question but also our stored memory bank for future iterations.
+
+The agent that calls you may also provide you with a Task Master task definition. Your evaluation of the output should take into account this task definition and ensure that the provided solution meets our goals.
+
+## Review Methodology
+
+### Phase 1: Context Gathering
+1. Check the repository's Git status, both staged and unstaged
+2. Examine the full diff to understand what's changing
+4. Search the codebase for similar patterns or implementations that might be reusable
+
+### Phase 2: Comprehensive Review
+#### Code Quality & Patterns
+- **Compilation**: For all touched packages and apps, make sure the code compiles and all tests pass
+- **DRY Violations**: Search for similar code patterns elsewhere in the codebase
+- **Consistency**: Does this follow established patterns in the project?
+- **Abstraction Level**: Is this the right level of generalization?
+- **Naming**: Are names clear, consistent, and follow project conventions?
+
+#### Engineering Excellence
+- **Error Handling**: How are errors caught, logged, and recovered from?
+- **Edge Cases**: What happens with null/undefined/empty/malformed inputs?
+- **Performance**: Will this scale with realistic data volumes?
+  - Consider cases where an iterative approach is being done when a parallel approach would be better
+    - Example: the original implementation of Fastify health checks had try-catch blocks all in a row; a good suggestion would be to make these into functions called with `Promise.allSettled`
+- **Security**: Are there injection risks, exposed secrets, or auth bypasses?
+- **Testing**: Are critical paths tested? Are tests meaningful?
+  - Our system is entirely built around a dependency injector; we can create (and make DRY and reusable) stub implementations of our services in order to allow for more integrated tests. Recommend this proactively.
+
+#### Integration & Dependencies
+- **Codebase Fit**: Does this integrate well with existing modules?
+- **Dependencies**: Are we adding unnecessary dependencies when existing utilities could work?
+- **Side Effects**: What other parts of the system might this affect?
+
+### Phase 3: Knowledge Management Assessment
+
+Identify knowledge gaps and opportunities:
+
+#### Flag for Documentation
+- **New Techniques**: "This retry mechanism is well-implemented and reusable.
+- **Missing Decisions**: "Choosing WebSockets over SSE here seems like an architectural decision that should be recorded"
+- **Complex Logic**: "This order processing logic should be captured as a detail entry"
+- **Implementation doesn't match product concepts**:
+
+## Review Output Format
+
+Structure your review as:
+
+### Summary
+Brief overview of the changes and overall assessment
+
+### Critical Issues 🔴
+Must-fix problems (security, bugs, broken functionality)
+
+### Important Suggestions 🟡
+Should-fix issues (performance, maintainability, patterns)
+
+### Minor Improvements 🟢
+Nice-to-have enhancements (style, optimization, clarity)
+
+### Knowledge Management
+- **Alignment Check**: How this aligns with existing knowledge
+- **Documentation Opportunities**: What should be added to Basic Memory
+- **Updates Needed**: What existing entries need updating
+
+### Code Reuse Opportunities
+Specific suggestions for using existing code instead of reimplementing
+
+## Review Tone
+
+Be constructive and specific:
+- ✅ "Consider using the cursor pagination technique from `src/api/utils.ts:142` instead"
+- ❌ "This pagination is wrong"
+
+- ✅ "This deviates from our decision to use Zod for validation. If intentional, please update the decision entry"
+- ❌ "You should use Zod"
+
+- ✅ "Great implementation of circuit breaker! This is reusable - worth documenting"
+- ❌ "Good code"
+
+## Special Instructions
+
+1. **Search Extensively**: Use Grep and Glob liberally to find similar code patterns
+2. **Reference Specifically**: Include file paths and line numbers in feedback
+3. **Suggest Alternatives**: Don't just identify problems - propose solutions
+4. **Prioritize Feedback**: Focus on what matters most for safety and maintainability
+5. **Learn from History**: Check Basic Memory for past decisions and patterns
+6. **Think Long-term**: Consider how this code will age and be maintained
+
+Remember: Your goal is not just to find problems, but to help maintain a coherent, well-documented, and maintainable codebase that builds on established knowledge and patterns.

.claude/mcp-descriptions/git-mcp.mdc

···
+---
+description:
+globs:
+alwaysApply: true
+---
+# LLM Agent Guidelines for `@cyanheads/git-mcp-server`
+
+This document provides a concise overview of the available Git tools, designed to be used as a quick-reference guide for an LLM coding assistant.
+
+### Guiding Principles for the LLM Agent
+
+* **Human-in-the-Loop**: Do not commit any changes without explicit permission from a human operator.
+* **Safety First**: Never use potentially destructive commands like `git_reset`, `git_clean`, or `git_push` with the `force` option enabled. These operations can lead to permanent data loss.
+* **Session Context is Key**: Always start your workflow by setting a working directory with `git_set_working_dir`. Subsequent commands can then use `.` as the path, which is more efficient. Use `git_clear_working_dir` when a session is complete.
+* **Conventional Commits**: When using `git_commit`, write clear, concise messages following the Conventional Commits format: `type(scope): subject`. The tool's description provides detailed guidance.
+* **Review Before Committing**: Before committing, always use `git_status` and `git_diff` to review the changes. This ensures you create logical, atomic commits.
+
+---
+
+## Commonly Used Tools
+
+These are the essential tools for day-to-day version control tasks.
+
+### `git_set_working_dir`
+
+* **Description**: Sets the default working directory for the current session. Subsequent Git tool calls can use `.` for the `path`, which will resolve to this directory. **This should be the first tool you use in any workflow.**
+* **When to Use**: At the beginning of any task that involves a Git repository to establish context for all subsequent commands.
+* **Input Parameters**:
+
+| Parameter                | Type    | Description                                                                  |
+| :----------------------- | :------ | :--------------------------------------------------------------------------- |
+| `path`                   | string  | The **absolute path** to set as the default working directory. |
+| `validateGitRepo`        | boolean | Validate that the path is a Git repository. Defaults to `true`. |
+| `initializeIfNotPresent` | boolean | If not a Git repository, initialize it with 'git init'. Defaults to `false`. |
+
+### `git_status`
+
+* **Description**: Retrieves the status of the repository, showing staged, unstaged, and untracked files.
+* **When to Use**: Use this frequently to check the state of the repository before staging changes, after pulling from a remote, or before committing.
+* **Input Parameters**:
+
+| Parameter | Type   | Description                                                                                                                           |
+| :-------- | :----- | :------------------------------------------------------------------------------------------------------------------------------------ |
+| `path`    | string | Path to the Git repository. Defaults to `.` (the session's working directory). |
+
+### `git_add`
+
+* **Description**: Stages changes, adding them to the index before committing.
+* **When to Use**: After making changes to files and before you are ready to commit them.
+* **Input Parameters**:
+
+| Parameter | Type                 | Description                                                                                                                           |
+| :-------- | :------------------- | :------------------------------------------------------------------------------------------------------------------------------------ |
+| `path`    | string               | Path to the Git repository. Defaults to the directory set via `git_set_working_dir`. |
+| `files`   | string \| string\[] | Files or patterns to stage. Defaults to all changes (`.`). |
+
+### `git_commit`
+
+* **Description**: Commits staged changes to the repository with a descriptive message.
+* **When to Use**: After staging a logical group of changes with `git_add` and receiving approval from the operator to commit.
+* **Input Parameters**:
+
+| Parameter    | Type                             | Description                                                                                                                              |
+| :----------- | :------------------------------- | :--------------------------------------------------------------------------------------------------------------------------------------- |
+| `path`       | string                           | Path to the Git repository. |
+| `message`    | string                           | The commit message. |
+| `author`     | object                           | Override the commit author (`{ name: string, email: string }`). |
+| `filesToStage`| string\[]                        | An array of file paths to stage before committing. |
+
+### `git_log`
+
+* **Description**: Shows the commit history. Can be filtered by author, date, or branch.
+* **When to Use**: To review recent changes, find a specific commit, or understand the history of a file or branch.
+* **Input Parameters**:
+
+| Parameter      | Type    | Description                                                          |
+| :------------- | :------ | :------------------------------------------------------------------- |
+| `path`         | string  | Path to the Git repository. |
+| `maxCount`     | number  | Limit the number of commits to output. |
+| `author`       | string  | Filter commits by a specific author. |
+| `since`        | string  | Show commits more recent than a specific date. |
+| `until`        | string  | Show commits older than a specific date. |
+| `branchOrFile` | string  | Show logs for a specific branch, tag, or file path. |
+| `showSignature`| boolean | Show signature verification status for commits. |
+
+### `git_diff`
+
+* **Description**: Shows changes between commits, the working tree, etc.
+* **When to Use**: To review unstaged changes before adding, or to see the difference between two branches or commits.
+* **Input Parameters**:
+
+| Parameter        | Type    | Description                                                                      |
+| :--------------- | :------ | :------------------------------------------------------------------------------- |
+| `path`           | string  | Path to the Git repository. |
+| `commit1`        | string  | First commit, branch, or ref for comparison. |
+| `commit2`        | string  | Second commit, branch, or ref for comparison. |
+| `staged`         | boolean | Show diff of staged changes. |
+| `file`           | string  | Limit the diff to a specific file. |
+| `includeUntracked`| boolean | Include untracked files in the diff output. |
+
+### `git_branch`
+
+* **Description**: Manages branches: list, create, delete, and rename.
+* **When to Use**: To see what branches are available, create a new branch for a feature or bugfix, or clean up old branches. DO NOT do this without human operator confirmation.
+* **Input Parameters**:
+
+| Parameter     | Type    | Description                                                          |
+| :------------ | :------ | :------------------------------------------------------------------- |
+| `path`        | string  | Path to the Git repository. |
+| `mode`        | enum    | The operation: `list`, `create`, `delete`, `rename`, `show-current`. |
+| `branchName`  | string  | Name of the branch for create/delete/rename operations. |
+| `newBranchName`| string  | The new name for the branch when renaming. |
+| `startPoint`  | string  | The starting point for a new branch. |
+| `force`       | boolean | Force the operation (e.g., deleting an unmerged branch). |
+| `all`         | boolean | List all branches (local and remote). |
+| `remote`      | boolean | Act on remote-tracking branches. |
+
+### `git_checkout`
+
+* **Description**: Switches branches or restores working tree files.
+* **When to Use**: To start working on a different branch or to discard changes in a specific file. DO NOT do this without human operator confirmation.
+* **Input Parameters**:
+
+| Parameter    | Type    | Description                                                       |
+| :----------- | :------ | :---------------------------------------------------------------- |
+| `path`       | string  | Path to the Git repository. |
+| `branchOrPath`| string  | The branch, commit, tag, or file path to checkout. |
+| `newBranch`  | string  | Create a new branch before checking out. |
+| `force`      | boolean | Force checkout, discarding local changes. |
+
+### `git_pull`
+
+* **Description**: Fetches from and integrates with a remote repository or a local branch.
+* **When to Use**: To update your current local branch with changes from its remote counterpart. DO NOT do this without human operator confirmation.
+* **Input Parameters**:
+
+| Parameter | Type    | Description                                                        |
+| :-------- | :------ | :----------------------------------------------------------------- |
+| `path`    | string  | Path to the Git repository. |
+| `remote`  | string  | The remote repository to pull from (e.g., 'origin'). |
+| `branch`  | string  | The remote branch to pull. |
+| `rebase`  | boolean | Use 'git pull --rebase' instead of merge. |
+| `ffOnly`  | boolean | Only allow fast-forward merges. |
+
+### `git_push`
+
+* **Description**: Updates remote refs with local changes.
+* **When to Use**: After committing your changes locally, use this to share them on the remote repository. DO NOT do this without human operator confirmation.
+* **Input Parameters**:
+
+| Parameter    | Type    | Description                                                  |
+| :----------- | :------ | :----------------------------------------------------------- |
+| `path`       | string  | Path to the Git repository. |
+| `remote`     | string  | The remote repository to push to. |
+| `branch`     | string  | The local branch to push. |
+| `remoteBranch`| string  | The remote branch to push to. |
+| `force`      | boolean | Force the push (use with caution). |
+| `forceWithLease`| boolean | Force push only if remote ref is as expected. |
+| `setUpstream`| boolean | Set the upstream tracking configuration. |
+| `tags`       | boolean | Push all tags. |
+| `delete`     | boolean | Delete the remote branch. |
+
+---
+
+## Complex Situations
+
+If you encounter a situation where you believe a more advanced or potentially destructive tool is needed (such as `git rebase`, `git reset`, `git cherry-pick`, or `git clean`), **do not proceed automatically**.
+
+Instead, you should:
+
+1.  **Pause execution.**
+2.  **Explain the situation** to the human operator.
+3.  **State which advanced Git operation you think is necessary and why.**
+4.  **Await explicit instruction** from the operator before taking any further action.

.claude/settings.local.json

···
+{
+  "permissions": {
+    "allow": [
+      "mcp__git-mcp-server__git_status",
+      "mcp__git-mcp-server__git_diff",
+      "mcp__git-mcp-server__git_set_working_dir"
+    ],
+    "ask": [
+      "curl"
+    ]
+  },
+  "enableAllProjectMcpServers": true,
+  "enabledMcpjsonServers": [
+    "git-mcp-server"
+  ]
+}

.mcp.json

···
+{
+  "mcpServers": {
+    "git-mcp-server": {
+      "type": "stdio",
+      "command": "npx",
+      "args": ["@cyanheads/git-mcp-server"],
+      "env": {
+        "MCP_LOG_LEVEL": "info",
+        "GIT_SIGN_COMMITS": "false"
+      }
+    }
+  }
+}

CLAUDE.md

···
+# Claude Code Instructions
+
+**All imports in this document should be treated as if they were in the main prompt file.**
+
+## MCP Orientation Instructions
+
+@.claude/mcp-descriptions/github-mcp.mdc
+
+NEVER USE A COMMAND-LINE TOOL WHEN AN MCP TOOL IS AVAILABLE. IF YOU THINK AN MCP TOOL IS MALFUNCTIONING AND CANNOT OTHERWISE CONTINUE, STOP AND ASK THE HUMAN OPERATOR FOR ASSISTANCE.
+
+## Development Commands
+
+### Running the Application
+
+- `bun run start` - Run the main application (production mode)
+- `bun run dev` - Run in development mode with file watching
+- `bun i` - Install dependencies
+
+### Code Quality
+
+- `bun run format` - Format code using Prettier
+- `bun run lint` - Run ESLint to check for issues
+- `bun run lint:fix` - Automatically fix ESLint issues where possible
+
+### Docker Deployment
+
+- `docker build -pull -t skywatch-tools .` - Build Docker image
+- `docker run -d -p 4101:4101 skywatch-autolabeler` - Run container
+
+## Architecture Overview
+
+This is a TypeScript rewrite of a Bash-based Bluesky content moderation system for the skywatch.blue independent labeler. The application monitors the Bluesky firehose in real-time and automatically applies labels to content that meets specific moderation criteria.
+
+### Core Components
+
+- **`main.ts`** - Entry point that sets up Jetstream WebSocket connection to monitor Bluesky firehose events (posts, profiles, handles, starter packs)
+- **`agent.ts`** - Configures the AtpAgent for interacting with Ozone PDS for labeling operations
+- **`constants.ts`** - Contains all moderation check definitions (PROFILE_CHECKS, POST_CHECKS, HANDLE_CHECKS)
+- **`config.ts`** - Environment variable configuration and application settings
+- **Check modules** - Individual modules for different content types:
+  - `checkPosts.ts` - Analyzes post content and URLs
+  - `checkHandles.ts` - Validates user handles
+  - `checkProfiles.ts` - Examines profile descriptions and display names
+  - `checkStarterPack.ts` - Reviews starter pack content
+
+### Moderation Check System
+
+The system uses a `Checks` interface to define moderation rules with the following properties:
+
+- `label` - The label to apply when content matches
+- `check` - RegExp pattern to match against content
+- `whitelist` - Optional RegExp to exempt certain content
+- `ignoredDIDs` - Array of DIDs to skip for this check
+- `reportAcct/commentAcct/toLabel` - Actions to take when content matches
+
+### Environment Configuration
+
+The application requires several environment variables:
+
+- Bluesky credentials (`BSKY_HANDLE`, `BSKY_PASSWORD`)
+- Ozone server configuration (`OZONE_URL`, `OZONE_PDS`)
+- Optional: firehose URL, ports, rate limiting settings
+
+### Data Flow
+
+1. Jetstream receives events from Bluesky firehose
+2. Events are categorized by type (post, profile, handle, starter pack)
+3. Appropriate check functions validate content against defined patterns
+4. Matching content triggers labeling actions via Ozone PDS
+5. Cursor position is periodically saved for resumption after restart
+
+### Development Notes
+
+- Uses Bun as the runtime and package manager
+- Built with modern TypeScript and ESNext modules
+- Implements rate limiting and error handling for API calls
+- Supports both labeling and reporting workflows
+- Includes metrics server on port 4101 for monitoring
+
+See `src/developing_checks.md` for detailed instructions on creating new moderation checks.
+
+## TODO
+
+The code-reviewer has completed a comprehensive review of the codebase and identified several critical issues that need immediate attention:
+
+  Immediate Blocking Issues
+
+  - Missing constants.ts file (only example exists)
+  - Unsafe type assertions in main.ts:152,158
+  - Inadequate error handling for async operations
+
+  High Priority Security & Reliability Concerns
+
+  - Hardcoded DIDs should be moved to environment variables
+  - Missing structured error handling and logging
+  - No environment variable validation at startup
+
+  Medium Priority Code Quality Issues
+
+  - Duplicate profile checking logic needs refactoring
+  - ESLint configuration needs TypeScript updates
+  - Missing comprehensive test suite
+
+  The reviewer noted that while the modular architecture is well-designed, there are critical execution flaws that must be addressed before this
+  can be safely deployed to production.

README.md

···
 
 The following environment variables are used for configuration:
 
-| Variable                 | Description                                                      | Default                                   |
-| ------------------------ | ---------------------------------------------------------------- | ----------------------------------------- |
-| `DID`                    | The DID of your moderation service for atproto-proxy headers.    | `""`                                      |
-| `OZONE_URL`              | The URL of the Ozone service.                                    | `""`                                      |
-| `OZONE_PDS`              | The Public Downstream Service for Ozone.                         | `""`                                      |
-| `BSKY_HANDLE`            | The handle (username) of the bot's Bluesky account.              | `""`                                      |
-| `BSKY_PASSWORD`          | The app password for the bot's Bluesky account.                  | `""`                                      |
-| `HOST`                   | The host on which the server runs.                               | `127.0.0.1`                               |
-| `PORT`                   | The port for the main application (currently unused).            | `4100`                                    |
-| `METRICS_PORT`           | The port for the Prometheus metrics server.                      | `4101`                                    |
+| Variable                 | Description                                                      | Default                                                        |
+| ------------------------ | ---------------------------------------------------------------- | -------------------------------------------------------------- |
+| `DID`                    | The DID of your moderation service for atproto-proxy headers.    | `""`                                                           |
+| `OZONE_URL`              | The URL of the Ozone service.                                    | `""`                                                           |
+| `OZONE_PDS`              | The Public Downstream Service for Ozone.                         | `""`                                                           |
+| `BSKY_HANDLE`            | The handle (username) of the bot's Bluesky account.              | `""`                                                           |
+| `BSKY_PASSWORD`          | The app password for the bot's Bluesky account.                  | `""`                                                           |
+| `HOST`                   | The host on which the server runs.                               | `127.0.0.1`                                                    |
+| `PORT`                   | The port for the main application (currently unused).            | `4100`                                                         |
+| `METRICS_PORT`           | The port for the Prometheus metrics server.                      | `4101`                                                         |
 | `FIREHOSE_URL`           | The WebSocket URL for the Bluesky firehose.                      | `FIREHOSE_URL=wss://jetstream1.us-east.bsky.network/subscribe` |
-| `CURSOR_UPDATE_INTERVAL` | How often to save the firehose cursor to disk (in milliseconds). | `60000`                                   |
-| `LABEL_LIMIT`            | (Optional) API call limit for labeling.                          | `undefined`                               |
-| `LABEL_LIMIT_WAIT`       | (Optional) Wait time when label limit is hit.                    | `undefined`                               |
-| `LOG_LEVEL`              | The logging level.                                               | `info`                                    |
+| `CURSOR_UPDATE_INTERVAL` | How often to save the firehose cursor to disk (in milliseconds). | `60000`                                                        |
+| `LABEL_LIMIT`            | (Optional) API call limit for labeling.                          | `undefined`                                                    |
+| `LABEL_LIMIT_WAIT`       | (Optional) Wait time when label limit is hit.                    | `undefined`                                                    |
+| `LOG_LEVEL`              | The logging level.                                               | `info`                                                         |

eslint.config.mjs

···
+import eslint from "@eslint/js";
+import tseslint from "typescript-eslint";
+import stylistic from "@stylistic/eslint-plugin";
+import prettier from "eslint-config-prettier";
+import importPlugin from "eslint-plugin-import";
+
+export default tseslint.config(
+  eslint.configs.recommended,
+  ...tseslint.configs.strictTypeChecked,
+  ...tseslint.configs.stylisticTypeChecked,
+  prettier,
+  {
+    languageOptions: {
+      parserOptions: {
+        project: "./tsconfig.json",
+        tsconfigRootDir: import.meta.dirname,
+      },
+    },
+  },
+  {
+    plugins: {
+      "@stylistic": stylistic,
+      import: importPlugin,
+    },
+    rules: {
+      // TypeScript specific rules
+      "@typescript-eslint/no-unused-vars": [
+        "error",
+        { argsIgnorePattern: "^_" },
+      ],
+      "@typescript-eslint/no-explicit-any": "error",
+      "@typescript-eslint/no-unsafe-assignment": "error",
+      "@typescript-eslint/no-unsafe-member-access": "error",
+      "@typescript-eslint/no-unsafe-call": "error",
+      "@typescript-eslint/no-unsafe-return": "error",
+      "@typescript-eslint/no-unsafe-argument": "error",
+      "@typescript-eslint/prefer-nullish-coalescing": "error",
+      "@typescript-eslint/prefer-optional-chain": "error",
+      "@typescript-eslint/no-non-null-assertion": "error",
+      "@typescript-eslint/consistent-type-imports": "error",
+      "@typescript-eslint/consistent-type-exports": "error",
+      "@typescript-eslint/no-import-type-side-effects": "error",
+
+      // General code quality
+      "no-console": "warn",
+      "no-debugger": "error",
+      "no-var": "error",
+      "prefer-const": "error",
+      "prefer-template": "error",
+      "object-shorthand": "error",
+      "prefer-destructuring": ["error", { object: true, array: false }],
+
+      // Import rules
+      "import/order": [
+        "error",
+        {
+          groups: [
+            "builtin",
+            "external",
+            "internal",
+            "parent",
+            "sibling",
+            "index",
+          ],
+          "newlines-between": "always",
+          alphabetize: { order: "asc", caseInsensitive: true },
+        },
+      ],
+      "import/no-duplicates": "error",
+      "import/no-unresolved": "off", // TypeScript handles this
+
+      // Security-focused rules
+      "no-eval": "error",
+      "no-implied-eval": "error",
+      "no-new-func": "error",
+      "no-script-url": "error",
+
+      // Error handling
+      "no-empty-pattern": "error",
+      "no-fallthrough": "error",
+      "no-unreachable": "error",
+      "no-unreachable-loop": "error",
+
+      // Style preferences
+      "@stylistic/indent": ["error", 2],
+      "@stylistic/quotes": ["error", "single"],
+      "@stylistic/semi": ["error", "always"],
+      //"@stylistic/comma-dangle": ["error", "es5"],
+      "@stylistic/object-curly-spacing": ["error", "always"],
+      "@stylistic/array-bracket-spacing": ["error", "never"],
+      "@stylistic/space-before-function-paren": [
+        "error",
+        {
+          anonymous: "always",
+          named: "never",
+          asyncArrow: "always",
+        },
+      ],
+    },
+  },
+  {
+    files: ["**/*.js", "**/*.mjs"],
+    ...tseslint.configs.disableTypeChecked,
+  },
+  {
+    ignores: [
+      "node_modules/",
+      "dist/",
+      "build/",
+      "*.config.js",
+      "*.config.mjs",
+      "coverage/",
+    ],
+  },
+);

package.json

···
   },
   "devDependencies": {
     "@eslint/js": "^9.29.0",
+    "@stylistic/eslint-plugin": "^5.2.3",
+    "@typescript-eslint/eslint-plugin": "^6.10.0",
+    "@typescript-eslint/parser": "^6.10.0",
+    "@eslint/compat": "^1.3.2",
+    "@eslint/eslintrc": "^3.3.1",
+    "eslint-config-prettier": "^10.1.8",
+    "eslint-plugin-import": "^2.32.0",
+    "eslint-plugin-prettier": "^5.5.4",
     "@trivago/prettier-plugin-sort-imports": "^4.3.0",
     "@types/better-sqlite3": "^7.6.13",
     "@types/eslint__js": "^8.42.3",
···
     "pino": "^9.6.0",
     "pino-pretty": "^13.0.0",
     "prom-client": "^15.1.3",
+    "stylistic/comma-trailing": "stylistic/comma-trailing",
     "undici": "^7.8.0"
   }
 }

src/agent.ts

···
+import { AtpAgent } from "@atproto/api";
+
 import { setGlobalDispatcher, Agent as Agent } from "undici";
+
 setGlobalDispatcher(new Agent({ connect: { timeout: 20_000 } }));
 import { BSKY_HANDLE, BSKY_PASSWORD, OZONE_PDS } from "./config.js";
-import { AtpAgent } from "@atproto/api";
 
 export const agent = new AtpAgent({
   service: `https://${OZONE_PDS}`,

src/checkHandles.ts

···
-import { HANDLE_CHECKS } from "./constants.js";
-import logger from "./logger.js";
+import { HANDLE_CHECKS } from './constants.js';
+import logger from './logger.js';
 import {
   createAccountReport,
   createAccountComment,
   createAccountLabel,
-} from "./moderation.js";
+} from './moderation.js';
 
 export const checkHandle = async (
   did: string,

src/checkPosts.ts

···
-import { LINK_SHORTENER, POST_CHECKS, langs } from "./constants.js";
-import { Post } from "./types.js";
-import logger from "./logger.js";
+import { LINK_SHORTENER, POST_CHECKS, langs } from './constants.js';
+import logger from './logger.js';
 import {
   createPostLabel,
   createAccountReport,
   createAccountComment,
   createPostReport,
-} from "./moderation.js";
-import { getFinalUrl, getLanguage } from "./utils.js";
+} from './moderation.js';
+import type { Post } from './types.js';
+import { getFinalUrl, getLanguage } from './utils.js';
 
 export const checkPosts = async (post: Post[]) => {
   // Get a list of labels
···
       // Check if post is whitelisted
       if (checkPost?.whitelist) {
         if (checkPost?.whitelist.test(post[0].text)) {
-          logger.info(`[CHECKPOSTS]: Whitelisted phrase found"`);
+          logger.info('[CHECKPOSTS]: Whitelisted phrase found"');
           return;
         }
       }

src/checkProfiles.ts

···
-import { login } from "./agent.js";
-import { langs, PROFILE_CHECKS } from "./constants.js";
-import logger from "./logger.js";
+import { login } from './agent.js';
+import { langs, PROFILE_CHECKS } from './constants.js';
+import logger from './logger.js';
 import {
   createAccountReport,
   createAccountLabel,
   createAccountComment,
-} from "./moderation.js";
-import { getLanguage } from "./utils.js";
+} from './moderation.js';
+import { getLanguage } from './utils.js';
 
 export const checkDescription = async (
   did: string,
···
           // Check if description is whitelisted
           if (checkProfiles!.whitelist) {
             if (checkProfiles!.whitelist.test(description)) {
-              logger.info(`[CHECKDESCRIPTION]: Whitelisted phrase found.`);
+              logger.info('[CHECKDESCRIPTION]: Whitelisted phrase found.');
               return;
             }
           }
···
           // Check if displayName is whitelisted
           if (checkProfiles!.whitelist) {
             if (checkProfiles!.whitelist.test(displayName)) {
-              logger.info(`[CHECKDISPLAYNAME]: Whitelisted phrase found.`);
+              logger.info('[CHECKDISPLAYNAME]: Whitelisted phrase found.');
               return;
             }
           }

src/checkStarterPack.ts

···
-import { PROFILE_CHECKS, STARTERPACK_CHECKS } from "./constants.js";
-import logger from "./logger.js";
+import { PROFILE_CHECKS, STARTERPACK_CHECKS } from './constants.js';
+import logger from './logger.js';
 import {
   createAccountLabel,
   createAccountReport,
   createPostLabel,
-} from "./moderation.js";
+} from './moderation.js';
 
 export const checkStarterPack = async (
   did: string,
···
     // Check if DID is whitelisted
     if (checkProfiles?.ignoredDIDs) {
       if (checkProfiles.ignoredDIDs.includes(did)) {
-        return logger.info(`Whitelisted DID: ${did}`);
+        logger.info(`Whitelisted DID: ${did}`); return;
       }
     }
 

src/config.ts

···
-import "dotenv/config";
+import 'dotenv/config';
 
-export const MOD_DID = process.env.DID ?? "";
-export const OZONE_URL = process.env.OZONE_URL ?? "";
-export const OZONE_PDS = process.env.OZONE_PDS ?? "";
-export const BSKY_HANDLE = process.env.BSKY_HANDLE ?? "";
-export const BSKY_PASSWORD = process.env.BSKY_PASSWORD ?? "";
-export const HOST = process.env.HOST ?? "127.0.0.1";
+export const MOD_DID = process.env.DID ?? '';
+export const OZONE_URL = process.env.OZONE_URL ?? '';
+export const OZONE_PDS = process.env.OZONE_PDS ?? '';
+export const BSKY_HANDLE = process.env.BSKY_HANDLE ?? '';
+export const BSKY_PASSWORD = process.env.BSKY_PASSWORD ?? '';
+export const HOST = process.env.HOST ?? '127.0.0.1';
 export const PORT = process.env.PORT ? Number(process.env.PORT) : 4100;
 export const METRICS_PORT = process.env.METRICS_PORT
   ? Number(process.env.METRICS_PORT)
   : 4101; // Left this intact from the code I adapted this from
 export const FIREHOSE_URL =
-  process.env.FIREHOSE_URL ?? "wss://jetstream1.us-east.bsky.network/subscribe";
+  process.env.FIREHOSE_URL ?? 'wss://jetstream1.us-east.bsky.network/subscribe';
 export const WANTED_COLLECTION = [
-  "app.bsky.feed.post",
-  "app.bsky.actor.defs",
-  "app.bsky.actor.profile",
+  'app.bsky.feed.post',
+  'app.bsky.actor.defs',
+  'app.bsky.actor.profile',
 ];
 export const CURSOR_UPDATE_INTERVAL = process.env.CURSOR_UPDATE_INTERVAL
   ? Number(process.env.CURSOR_UPDATE_INTERVAL)
   : 60000;
-export const LABEL_LIMIT = process.env.LABEL_LIMIT;
-export const LABEL_LIMIT_WAIT = process.env.LABEL_LIMIT_WAIT;
+export const { LABEL_LIMIT } = process.env;
+export const { LABEL_LIMIT_WAIT } = process.env;

src/developing_checks.md

···
 # How to build checks for skywatch-automod
 
 ## Introduction
+
 Constants.ts defines three types of types of checks: `HANDLE_CHECKS`, `POST_CHECKS`, and `PROFILE_CHECKS`.
 
 For each check, users need to define a set of regular expressions that will be used to match against the content of the post, handle, or profile. A maximal example of a check is as follows:
···
     toLabel: true, // Should the handle in question be labeled if check evaluates to true.
     check: new RegExp("example", "i"), // Regular expression to match against the content
     whitelist: new RegExp("example.com", "i"), // Optional, regular expression to whitelist content
-    ignoredDIDs: ["did:plc:example"] // Optional, array of DIDs to ignore if they match the check. Useful for folks who reclaim words or accounts which may be false positives.
-  }
+    ignoredDIDs: ["did:plc:example"], // Optional, array of DIDs to ignore if they match the check. Useful for folks who reclaim words or accounts which may be false positives.
+  },
 ];
 ```
 

src/limits.ts

···
-import { pRateLimit } from "p-ratelimit"; // TypeScript
+import { pRateLimit } from 'p-ratelimit'; // TypeScript
 
 // create a rate limiter that allows up to 30 API calls per second,
 // with max concurrency of 10

src/lists.ts

···
-import { List } from "./types.js";
+import type { List } from './types.js';
 
 export const LISTS: List[] = [
   {
-    label: "blue-heart-emoji",
-    rkey: "3lfbtgosyyi22",
+    label: 'blue-heart-emoji',
+    rkey: '3lfbtgosyyi22',
   },
   {
-    label: "troll",
-    rkey: "3lbckxhgu3r2v",
+    label: 'troll',
+    rkey: '3lbckxhgu3r2v',
   },
   {
-    label: "maga-trump",
-    rkey: "3l53cjwlt4o2s",
+    label: 'maga-trump',
+    rkey: '3l53cjwlt4o2s',
   },
   {
-    label: "elon-musk",
-    rkey: "3l72tte74wa2m",
+    label: 'elon-musk',
+    rkey: '3l72tte74wa2m',
   },
   {
-    label: "rmve-imve",
-    rkey: "3l6tfurf7li27",
+    label: 'rmve-imve',
+    rkey: '3l6tfurf7li27',
   },
   {
-    label: "nazi-symbolism",
-    rkey: "3l6vdudxgeb2z",
+    label: 'nazi-symbolism',
+    rkey: '3l6vdudxgeb2z',
   },
   {
-    label: "hammer-sickle",
-    rkey: "3l4ue6w2aur2v",
+    label: 'hammer-sickle',
+    rkey: '3l4ue6w2aur2v',
   },
   {
-    label: "inverted-red-triangle",
-    rkey: "3l4ueabtpec2a",
+    label: 'inverted-red-triangle',
+    rkey: '3l4ueabtpec2a',
   },
   {
-    label: "automated-reply-guy",
-    rkey: "3lch7qbvzpx23",
+    label: 'automated-reply-guy',
+    rkey: '3lch7qbvzpx23',
   },
   {
-    label: "terf-gc",
-    rkey: "3lcqjqjdejs2x",
+    label: 'terf-gc',
+    rkey: '3lcqjqjdejs2x',
   },
 ];

src/logger.ts

···
-import { pino } from "pino";
+import { pino } from 'pino';
 
 const logger = pino({
-  level: process.env.LOG_LEVEL ?? "info",
+  level: process.env.LOG_LEVEL ?? 'info',
   transport:
-    process.env.NODE_ENV !== "production"
+    process.env.NODE_ENV !== 'production'
       ? {
-          target: "pino-pretty",
-          options: {
-            colorize: true,
-            translateTime: "SYS:standard",
-            ignore: "pid,hostname",
-          },
-        }
+        target: 'pino-pretty',
+        options: {
+          colorize: true,
+          translateTime: 'SYS:standard',
+          ignore: 'pid,hostname',
+        },
+      }
       : undefined,
   timestamp: pino.stdTimeFunctions.isoTime,
 });

src/main.ts

···
-import {
+import fs from 'node:fs';
+
+import type {
   CommitCreateEvent,
-  CommitUpdate,
   CommitUpdateEvent,
-  IdentityEvent,
+  IdentityEvent } from '@skyware/jetstream';
+import {
+  CommitUpdate,
   Jetstream,
-} from "@skyware/jetstream";
-import fs from "node:fs";
+} from '@skyware/jetstream';
+
 
+import { checkHandle } from './checkHandles.js';
+import { checkPosts } from './checkPosts.js';
+import { checkDescription, checkDisplayName } from './checkProfiles.js';
+import { checkStarterPack, checkNewStarterPack } from './checkStarterPack.js';
 import {
   CURSOR_UPDATE_INTERVAL,
   FIREHOSE_URL,
   METRICS_PORT,
   WANTED_COLLECTION,
-} from "./config.js";
-import logger from "./logger.js";
-import { startMetricsServer } from "./metrics.js";
-import { Post, LinkFeature, Handle } from "./types.js";
-import { checkPosts } from "./checkPosts.js";
-import { checkHandle } from "./checkHandles.js";
-import { checkStarterPack, checkNewStarterPack } from "./checkStarterPack.js";
-import { checkDescription, checkDisplayName } from "./checkProfiles.js";
+} from './config.js';
+import logger from './logger.js';
+import { startMetricsServer } from './metrics.js';
+import type { Post, LinkFeature } from './types.js';
+import { Handle } from './types.js';
 
 let cursor = 0;
 let cursorUpdateInterval: NodeJS.Timeout;
···
 }
 
 try {
-  logger.info("Trying to read cursor from cursor.txt...");
-  cursor = Number(fs.readFileSync("cursor.txt", "utf8"));
+  logger.info('Trying to read cursor from cursor.txt...');
+  cursor = Number(fs.readFileSync('cursor.txt', 'utf8'));
   logger.info(`Cursor found: ${cursor} (${epochUsToDateTime(cursor)})`);
 } catch (error) {
-  if (error instanceof Error && "code" in error && error.code === "ENOENT") {
+  if (error instanceof Error && 'code' in error && error.code === 'ENOENT') {
     cursor = Math.floor(Date.now() * 1000);
     logger.info(
       `Cursor not found in cursor.txt, setting cursor to: ${cursor} (${epochUsToDateTime(cursor)})`,
     );
-    fs.writeFileSync("cursor.txt", cursor.toString(), "utf8");
+    fs.writeFileSync('cursor.txt', cursor.toString(), 'utf8');
   } else {
     logger.error(error);
     process.exit(1);
···
 const jetstream = new Jetstream({
   wantedCollections: WANTED_COLLECTION,
   endpoint: FIREHOSE_URL,
-  cursor: cursor,
+  cursor,
 });
 
-jetstream.on("open", () => {
+jetstream.on('open', () => {
   if (jetstream.cursor) {
     logger.info(
       `Connected to Jetstream at ${FIREHOSE_URL} with cursor ${jetstream.cursor} (${epochUsToDateTime(jetstream.cursor)})`,
···
       logger.info(
         `Cursor updated to: ${jetstream.cursor} (${epochUsToDateTime(jetstream.cursor)})`,
       );
-      fs.writeFile("cursor.txt", jetstream.cursor.toString(), (err) => {
+      fs.writeFile('cursor.txt', jetstream.cursor.toString(), (err) => {
         if (err) logger.error(err);
       });
     }
   }, CURSOR_UPDATE_INTERVAL);
 });
 
-jetstream.on("close", () => {
+jetstream.on('close', () => {
   clearInterval(cursorUpdateInterval);
-  logger.info("Jetstream connection closed.");
+  logger.info('Jetstream connection closed.');
 });
 
-jetstream.on("error", (error) => {
+jetstream.on('error', (error) => {
   logger.error(`Jetstream error: ${error.message}`);
 });
 
 // Check for post updates
 
 jetstream.onCreate(
-  "app.bsky.feed.post",
-  (event: CommitCreateEvent<"app.bsky.feed.post">) => {
+  'app.bsky.feed.post',
+  (event: CommitCreateEvent<'app.bsky.feed.post'>) => {
     const atURI = `at://${event.did}/app.bsky.feed.post/${event.commit.rkey}`;
-    const hasFacets = event.commit.record.hasOwnProperty("facets");
-    const hasText = event.commit.record.hasOwnProperty("text");
+    const hasFacets = event.commit.record.hasOwnProperty('facets');
+    const hasText = event.commit.record.hasOwnProperty('text');
 
     const tasks: Promise<void>[] = [];
 
···
     if (hasFacets) {
       const hasLinkType = event.commit.record.facets!.some((facet) =>
         facet.features.some(
-          (feature) => feature.$type === "app.bsky.richtext.facet#link",
+          (feature) => feature.$type === 'app.bsky.richtext.facet#link',
         ),
       );
 
       if (hasLinkType) {
         const urls = event.commit.record
           .facets!.flatMap((facet) =>
-            facet.features.filter(
-              (feature) => feature.$type === "app.bsky.richtext.facet#link",
-            ),
-          )
+          facet.features.filter(
+            (feature) => feature.$type === 'app.bsky.richtext.facet#link',
+          ),
+        )
           .map((feature: LinkFeature) => feature.uri);
 
         urls.forEach((url) => {
···
               did: event.did,
               time: event.time_us,
               rkey: event.commit.rkey,
-              atURI: atURI,
+              atURI,
               text: url,
               cid: event.commit.cid,
             },
···
           did: event.did,
           time: event.time_us,
           rkey: event.commit.rkey,
-          atURI: atURI,
+          atURI,
           text: event.commit.record.text,
           cid: event.commit.cid,
         },
···
 
 // Check for profile updates
 jetstream.onUpdate(
-  "app.bsky.actor.profile",
-  async (event: CommitUpdateEvent<"app.bsky.actor.profile">) => {
+  'app.bsky.actor.profile',
+  async (event: CommitUpdateEvent<'app.bsky.actor.profile'>) => {
     try {
       if (event.commit.record.displayName || event.commit.record.description) {
         checkDescription(
           event.did,
           event.time_us,
-          event.commit.record.displayName as string,
-          event.commit.record.description as string,
+          event.commit.record.displayName!,
+          event.commit.record.description!,
         );
         checkDisplayName(
           event.did,
           event.time_us,
-          event.commit.record.displayName as string,
-          event.commit.record.description as string,
+          event.commit.record.displayName!,
+          event.commit.record.description!,
         );
       }
 
···
 // Check for profile updates
 
 jetstream.onCreate(
-  "app.bsky.actor.profile",
-  async (event: CommitCreateEvent<"app.bsky.actor.profile">) => {
+  'app.bsky.actor.profile',
+  async (event: CommitCreateEvent<'app.bsky.actor.profile'>) => {
     try {
       if (event.commit.record.displayName || event.commit.record.description) {
         checkDescription(
           event.did,
           event.time_us,
-          event.commit.record.displayName as string,
-          event.commit.record.description as string,
+          event.commit.record.displayName!,
+          event.commit.record.description!,
         );
         checkDisplayName(
           event.did,
           event.time_us,
-          event.commit.record.displayName as string,
-          event.commit.record.description as string,
+          event.commit.record.displayName!,
+          event.commit.record.description!,
         );
 
         if (event.commit.record.joinedViaStarterPack) {
···
 );
 
 jetstream.onCreate(
-  "app.bsky.graph.starterpack",
-  async (event: CommitCreateEvent<"app.bsky.graph.starterpack">) => {
+  'app.bsky.graph.starterpack',
+  async (event: CommitCreateEvent<'app.bsky.graph.starterpack'>) => {
     try {
       const atURI = `at://${event.did}/app.bsky.feed.post/${event.commit.rkey}`;
 
···
 );
 
 jetstream.onUpdate(
-  "app.bsky.graph.starterpack",
-  async (event: CommitUpdateEvent<"app.bsky.graph.starterpack">) => {
+  'app.bsky.graph.starterpack',
+  async (event: CommitUpdateEvent<'app.bsky.graph.starterpack'>) => {
     try {
       const atURI = `at://${event.did}/app.bsky.feed.post/${event.commit.rkey}`;
 
···
 );
 
 // Check for handle updates
-jetstream.on("identity", async (event: IdentityEvent) => {
+jetstream.on('identity', async (event: IdentityEvent) => {
   if (event.identity.handle) {
     checkHandle(event.identity.did, event.identity.handle, event.time_us);
   }
···
 
 function shutdown() {
   try {
-    logger.info("Shutting down gracefully...");
-    fs.writeFileSync("cursor.txt", jetstream.cursor!.toString(), "utf8");
+    logger.info('Shutting down gracefully...');
+    fs.writeFileSync('cursor.txt', jetstream.cursor!.toString(), 'utf8');
     jetstream.close();
     metricsServer.close();
   } catch (error) {
···
   }
 }
 
-process.on("SIGINT", shutdown);
-process.on("SIGTERM", shutdown);
+process.on('SIGINT', shutdown);
+process.on('SIGTERM', shutdown);

src/metrics.ts

···
-import express from "express";
-import { Registry, collectDefaultMetrics } from "prom-client";
+import express from 'express';
+import { Registry, collectDefaultMetrics } from 'prom-client';
 
-import logger from "./logger.js";
+import logger from './logger.js';
 
 const register = new Registry();
 collectDefaultMetrics({ register });
 
 const app = express();
 
-app.get("/metrics", (req, res) => {
+app.get('/metrics', (req, res) => {
   register
     .metrics()
     .then((metrics) => {
-      res.set("Content-Type", register.contentType);
+      res.set('Content-Type', register.contentType);
       res.send(metrics);
     })
     .catch((ex: unknown) => {
···
     });
 });
 
-export const startMetricsServer = (port: number, host = "127.0.0.1") => {
+export const startMetricsServer = (port: number, host = '127.0.0.1') => {
   return app.listen(port, host, () => {
     logger.info(`Metrics server is listening on ${host}:${port}`);
   });

src/moderation.ts

···
-import { agent, isLoggedIn } from "./agent.js";
-import { MOD_DID } from "./config.js";
-import { limit } from "./limits.js";
-import logger from "./logger.js";
-import { LISTS } from "./lists.js";
+import { agent, isLoggedIn } from './agent.js';
+import { MOD_DID } from './config.js';
+import { limit } from './limits.js';
+import { LISTS } from './lists.js';
+import logger from './logger.js';
 
 export const createPostLabel = async (
   uri: string,
···
       return agent.tools.ozone.moderation.emitEvent(
         {
           event: {
-            $type: "tools.ozone.moderation.defs#modEventLabel",
-            comment: comment,
+            $type: 'tools.ozone.moderation.defs#modEventLabel',
+            comment,
             createLabelVals: [label],
             negateLabelVals: [],
           },
           // specify the labeled post by strongRef
           subject: {
-            $type: "com.atproto.repo.strongRef",
-            uri: uri,
-            cid: cid,
+            $type: 'com.atproto.repo.strongRef',
+            uri,
+            cid,
           },
           // put in the rest of the metadata
           createdBy: `${agent.did}`,
           createdAt: new Date().toISOString(),
         },
         {
-          encoding: "application/json",
+          encoding: 'application/json',
           headers: {
-            "atproto-proxy": `${MOD_DID!}#atproto_labeler`,
-            "atproto-accept-labelers":
-              "did:plc:ar7c4by46qjdydhdevvrndac;redact",
+            'atproto-proxy': `${MOD_DID}#atproto_labeler`,
+            'atproto-accept-labelers':
+              'did:plc:ar7c4by46qjdydhdevvrndac;redact',
           },
         },
       );
···
       await agent.tools.ozone.moderation.emitEvent(
         {
           event: {
-            $type: "tools.ozone.moderation.defs#modEventLabel",
-            comment: comment,
+            $type: 'tools.ozone.moderation.defs#modEventLabel',
+            comment,
             createLabelVals: [label],
             negateLabelVals: [],
           },
           // specify the labeled post by strongRef
           subject: {
-            $type: "com.atproto.admin.defs#repoRef",
-            did: did,
+            $type: 'com.atproto.admin.defs#repoRef',
+            did,
           },
           // put in the rest of the metadata
           createdBy: `${agent.did}`,
           createdAt: new Date().toISOString(),
         },
         {
-          encoding: "application/json",
+          encoding: 'application/json',
           headers: {
-            "atproto-proxy": `${MOD_DID!}#atproto_labeler`,
-            "atproto-accept-labelers":
-              "did:plc:ar7c4by46qjdydhdevvrndac;redact",
+            'atproto-proxy': `${MOD_DID}#atproto_labeler`,
+            'atproto-accept-labelers':
+              'did:plc:ar7c4by46qjdydhdevvrndac;redact',
           },
         },
       );
···
       return agent.tools.ozone.moderation.emitEvent(
         {
           event: {
-            $type: "tools.ozone.moderation.defs#modEventReport",
-            comment: comment,
-            reportType: "com.atproto.moderation.defs#reasonOther",
+            $type: 'tools.ozone.moderation.defs#modEventReport',
+            comment,
+            reportType: 'com.atproto.moderation.defs#reasonOther',
           },
           // specify the labeled post by strongRef
           subject: {
-            $type: "com.atproto.repo.strongRef",
-            uri: uri,
-            cid: cid,
+            $type: 'com.atproto.repo.strongRef',
+            uri,
+            cid,
           },
           // put in the rest of the metadata
           createdBy: `${agent.did}`,
           createdAt: new Date().toISOString(),
         },
         {
-          encoding: "application/json",
+          encoding: 'application/json',
           headers: {
-            "atproto-proxy": `${MOD_DID!}#atproto_labeler`,
-            "atproto-accept-labelers":
-              "did:plc:ar7c4by46qjdydhdevvrndac;redact",
+            'atproto-proxy': `${MOD_DID}#atproto_labeler`,
+            'atproto-accept-labelers':
+              'did:plc:ar7c4by46qjdydhdevvrndac;redact',
           },
         },
       );
···
       await agent.tools.ozone.moderation.emitEvent(
         {
           event: {
-            $type: "tools.ozone.moderation.defs#modEventComment",
-            comment: comment,
+            $type: 'tools.ozone.moderation.defs#modEventComment',
+            comment,
           },
           // specify the labeled post by strongRef
           subject: {
-            $type: "com.atproto.admin.defs#repoRef",
-            did: did,
+            $type: 'com.atproto.admin.defs#repoRef',
+            did,
           },
           // put in the rest of the metadata
           createdBy: `${agent.did}`,
           createdAt: new Date().toISOString(),
         },
         {
-          encoding: "application/json",
+          encoding: 'application/json',
           headers: {
-            "atproto-proxy": `${MOD_DID!}#atproto_labeler`,
-            "atproto-accept-labelers":
-              "did:plc:ar7c4by46qjdydhdevvrndac;redact",
+            'atproto-proxy': `${MOD_DID}#atproto_labeler`,
+            'atproto-accept-labelers':
+              'did:plc:ar7c4by46qjdydhdevvrndac;redact',
           },
         },
       );
···
       await agent.tools.ozone.moderation.emitEvent(
         {
           event: {
-            $type: "tools.ozone.moderation.defs#modEventReport",
-            comment: comment,
-            reportType: "com.atproto.moderation.defs#reasonOther",
+            $type: 'tools.ozone.moderation.defs#modEventReport',
+            comment,
+            reportType: 'com.atproto.moderation.defs#reasonOther',
           },
           // specify the labeled post by strongRef
           subject: {
-            $type: "com.atproto.admin.defs#repoRef",
-            did: did,
+            $type: 'com.atproto.admin.defs#repoRef',
+            did,
           },
           // put in the rest of the metadata
           createdBy: `${agent.did}`,
           createdAt: new Date().toISOString(),
         },
         {
-          encoding: "application/json",
+          encoding: 'application/json',
           headers: {
-            "atproto-proxy": `${MOD_DID!}#atproto_labeler`,
-            "atproto-accept-labelers":
-              "did:plc:ar7c4by46qjdydhdevvrndac;redact",
+            'atproto-proxy': `${MOD_DID}#atproto_labeler`,
+            'atproto-accept-labelers':
+              'did:plc:ar7c4by46qjdydhdevvrndac;redact',
           },
         },
       );
···
   }
   logger.info(`New label added to list: ${newList.label}`);
 
-  const listUri = `at://${MOD_DID!}/app.bsky.graph.list/${newList.rkey}`;
+  const listUri = `at://${MOD_DID}/app.bsky.graph.list/${newList.rkey}`;
 
   await limit(async () => {
     try {
       await agent.com.atproto.repo.createRecord({
-        collection: "app.bsky.graph.listitem",
-        repo: `${MOD_DID!}`,
+        collection: 'app.bsky.graph.listitem',
+        repo: MOD_DID,
         record: {
           subject: did,
           list: listUri,

src/monitor.ts

···
-import { describe } from "node:test";
-import { PROFILE_CHECKS } from "./constants.js";
-import logger from "./logger.js";
-import { createAccountReport, createAccountLabel } from "./moderation.js";
+import { describe } from 'node:test';
+
+import { PROFILE_CHECKS } from './constants.js';
+import logger from './logger.js';
+import { createAccountReport, createAccountLabel } from './moderation.js';
 
 export const monitorDescription = async (
   did: string,
···
     // Check if DID is whitelisted
     if (checkProfiles?.ignoredDIDs) {
       if (checkProfiles.ignoredDIDs.includes(did)) {
-        return logger.info(`Whitelisted DID: ${did}`);
+        logger.info(`Whitelisted DID: ${did}`); return;
       }
     }
 
···
         if (checkProfiles!.check.test(description)) {
           if (checkProfiles!.whitelist) {
             if (checkProfiles!.whitelist.test(description)) {
-              logger.info(`Whitelisted phrase found.`);
+              logger.info('Whitelisted phrase found.');
               return;
             }
           } else {
···
     // Check if DID is whitelisted
     if (checkProfiles?.ignoredDIDs) {
       if (checkProfiles.ignoredDIDs.includes(did)) {
-        return logger.info(`Whitelisted DID: ${did}`);
+        logger.info(`Whitelisted DID: ${did}`); return;
       }
     }
 
···
         if (checkProfiles!.check.test(displayName)) {
           if (checkProfiles!.whitelist) {
             if (checkProfiles!.whitelist.test(displayName)) {
-              logger.info(`Whitelisted phrase found.`);
+              logger.info('Whitelisted phrase found.');
               return;
             }
           } else {

src/types.ts

···
 
 // Define the type for the link feature
 export interface LinkFeature {
-  $type: "app.bsky.richtext.facet#link";
+  $type: 'app.bsky.richtext.facet#link';
   uri: string;
 }
 

src/utils.ts

···
-import logger from "./logger.js";
+import logger from './logger.js';
 
 /*  Normalize the Unicode characters: this doesn't consistently work yet, there is something about certain bluesky strings that causes it to fail. */
 export function normalizeUnicode(text: string): string {
   // First decompose the characters (NFD)
-  const decomposed = text.normalize("NFD");
+  const decomposed = text.normalize('NFD');
 
   // Remove diacritics and combining marks
-  const withoutDiacritics = decomposed.replace(/[\u0300-\u036f]/g, "");
+  const withoutDiacritics = decomposed.replace(/[\u0300-\u036f]/g, '');
 
   // Remove mathematical alphanumeric symbols
   const withoutMath = withoutDiacritics.replace(
···
   );
 
   // Final NFKC normalization to handle any remaining special characters
-  return withoutMath.normalize("NFKC");
+  return withoutMath.normalize('NFKC');
 }
 
 export async function getFinalUrl(url: string): Promise<string> {
   const controller = new AbortController();
-  const timeoutId = setTimeout(() => controller.abort(), 10000); // 10-second timeout
+  const timeoutId = setTimeout(() => { controller.abort(); }, 10000); // 10-second timeout
 
   try {
     const response = await fetch(url, {
-      method: "HEAD",
-      redirect: "follow", // This will follow redirects automatically
+      method: 'HEAD',
+      redirect: 'follow', // This will follow redirects automatically
       signal: controller.signal, // Pass the abort signal to fetch
     });
     clearTimeout(timeoutId); // Clear the timeout if fetch completes
···
   } catch (error) {
     clearTimeout(timeoutId); // Clear the timeout if fetch fails
     // Log the error with more specific information if it's a timeout
-    if (error instanceof Error && error.name === "AbortError") {
+    if (error instanceof Error && error.name === 'AbortError') {
       logger.warn(`Timeout fetching URL: ${url}`, error);
     } else {
       logger.warn(`Error fetching URL: ${url}`, error);
···
 }
 
 export async function getLanguage(profile: string): Promise<string> {
-  if (typeof profile !== "string" || profile === null) {
+  if (typeof profile !== 'string' || profile === null) {
     logger.warn(
-      "[GETLANGUAGE] getLanguage called with invalid profile data, defaulting to 'eng'.",
+      '[GETLANGUAGE] getLanguage called with invalid profile data, defaulting to \'eng\'.',
       profile,
     );
-    return "eng"; // Default or throw an error
+    return 'eng'; // Default or throw an error
   }
 
   const profileText = profile.trim();
 
   if (profileText.length === 0) {
-    return "eng";
+    return 'eng';
   }
 
-  const lande = (await import("lande")).default;
-  let langsProbabilityMap = lande(profileText);
+  const lande = (await import('lande')).default;
+  const langsProbabilityMap = lande(profileText);
 
   // Sort by probability in descending order
   langsProbabilityMap.sort(