docs(errors): distinguish rejected operations

Bump @types/node from 26.0.0 to 26.0.1

.gitea/ISSUE_TEMPLATE/bug.yaml

@@ -0,0 +1,21 @@
+name: 🐛 Bug
+description: Report a bug or unexpected behavior
+title: '🐛 [BUG]: '
+body:
+    - type: textarea
+      id: information
+      attributes:
+          label: Description
+          description: Provide all information.
+          placeholder: 'What happened? What did you expect to happen?'
+      validations:
+          required: false
+
+    - type: textarea
+      id: criteria
+      attributes:
+          label: Acceptance Criteria
+          description: What are the expectations?
+          placeholder: 'How do you want it implemented? How should it be tested?'
+      validations:
+          required: false

.gitea/ISSUE_TEMPLATE/feature.yaml

@@ -0,0 +1,21 @@
+name: 💡 Enhancement
+description: Suggest a new feature
+title: '💡 [Enhancement]: '
+body:
+    - type: textarea
+      id: information
+      attributes:
+          label: Description
+          description: Provide all information.
+          placeholder: 'What happened? What did you expect to happen?'
+      validations:
+          required: false
+
+    - type: textarea
+      id: criteria
+      attributes:
+          label: Acceptance Criteria
+          description: What are the expectations?
+          placeholder: 'How do you want it implemented? How should it be tested?'
+      validations:
+          required: false

.gitea/ISSUE_TEMPLATE/improvement.yaml

@@ -0,0 +1,21 @@
+name: ⚙️ Improvement
+description: Suggest an improvement to existing functionality
+title: '⚙️ [Improvement]: '
+body:
+    - type: textarea
+      id: information
+      attributes:
+          label: Description
+          description: Provide all information.
+          placeholder: 'What happened? What did you expect to happen?'
+      validations:
+          required: false
+
+    - type: textarea
+      id: criteria
+      attributes:
+          label: Acceptance Criteria
+          description: What are the expectations?
+          placeholder: 'How do you want it implemented? How should it be tested?'
+      validations:
+          required: false

.gitea/workflows/Build-Rollout.yml

@@ -0,0 +1,102 @@
+name: Release and Deploy Build
+
+on:
+    workflow_dispatch:
+
+permissions:
+    contents: write
+
+env:
+    VERSION_MAJOR: '1'
+    VERSION_MINOR: '1'
+    VERSION_PATCH: ${{ gitea.run_number }}
+
+jobs:
+    build:
+        runs-on: ubuntu-latest
+
+        steps:
+            - name: Checkout Repository
+              uses: actions/checkout@v4
+              with:
+                  fetch-depth: 0
+                  fetch-tags: true
+
+            - name: Use Node.js 24.17.0
+              uses: actions/setup-node@v6
+              with:
+                  node-version: '24.17.0'
+                  registry-url: 'https://registry.npmjs.org'
+                  package-manager-cache: false
+
+            - name: Install Dependencies
+              run: npm ci
+
+            - name: Set Release Version
+              id: version
+              run: npm run version:place
+
+            - name: Export Release Version
+              id: release_version
+              run: |
+                  package_version="$(node -p "require('./package.json').version")"
+                  echo "tag=${package_version}" >> "$GITEA_OUTPUT"
+
+            - name: Run Build
+              run: npm run build
+
+            - name: Publish Library
+              run: npm publish --access public
+              env:
+                  NODE_AUTH_TOKEN: ${{ secrets.NPM_TOKEN }}
+
+            - name: Create Gitea release
+              env:
+                  GITEA_TOKEN: ${{ secrets.GITEA_TOKEN }}
+                  GITEA_API_URL: ${{ gitea.api_url }}
+                  GITEA_REPOSITORY: ${{ gitea.repository }}
+                  GITEA_SERVER_URL: ${{ gitea.server_url }}
+                  GITEA_SHA: ${{ gitea.sha }}
+                  RELEASE_TAG: v${{ steps.release_version.outputs.tag }}
+              run: |
+                  git fetch --force --tags
+
+                  releases_url="${GITEA_API_URL}/repos/${GITEA_REPOSITORY}/releases"
+                  previous_tag="$(curl --fail --silent --show-error --header "Authorization: token ${GITEA_TOKEN}" "${releases_url}?limit=50" | jq -r --arg tag "$RELEASE_TAG" '[.[] | select(.draft == false and .tag_name != $tag)][0].tag_name // empty')"
+
+                  if [ -n "$previous_tag" ]; then
+                      if git rev-parse --verify --quiet "${previous_tag}^{commit}" >/dev/null; then
+                          commit_messages="$(git log --reverse --format='- %s' "${previous_tag}..${GITEA_SHA}")"
+                      else
+                          commit_messages="$(git log --reverse --format='- %s' "${GITEA_SHA}")"
+                      fi
+                      full_changelog="${GITEA_SERVER_URL}/${GITEA_REPOSITORY}/compare/${previous_tag}...${RELEASE_TAG}"
+                  else
+                      commit_messages="$(git log --reverse --format='- %s' "${GITEA_SHA}")"
+                      full_changelog=""
+                  fi
+
+                  if [ -z "$commit_messages" ]; then
+                      commit_messages='- No commits since the previous release'
+                  fi
+
+                  {
+                      echo '## Changes'
+                      echo
+                      printf '%s\n' "$commit_messages"
+                      echo
+                      if [ -n "$full_changelog" ]; then
+                          echo "**Full Changelog**: ${full_changelog}"
+                      fi
+                  } > release-notes.md
+
+                  jq -n --arg tag "$RELEASE_TAG" --arg target "$GITEA_SHA" --rawfile body release-notes.md \
+                      '{tag_name: $tag, target_commitish: $target, name: $tag, body: $body, draft: false, prerelease: false}' > release.json
+
+                  release_id="$(curl --silent --header "Authorization: token ${GITEA_TOKEN}" "${releases_url}/tags/${RELEASE_TAG}" | jq -r '.id // empty')"
+
+                  if [ -n "$release_id" ]; then
+                      curl --fail-with-body --request PATCH --header "Authorization: token ${GITEA_TOKEN}" --header 'Content-Type: application/json' --data @release.json "${releases_url}/${release_id}"
+                  else
+                      curl --fail-with-body --request POST --header "Authorization: token ${GITEA_TOKEN}" --header 'Content-Type: application/json' --data @release.json "$releases_url"
+                  fi

.gitea/workflows/Build-Validation.yml

@@ -2,6 +2,9 @@ name: Build Validation
 
 on:
     workflow_dispatch:
+    push:
+        branches:
+            - main
     pull_request:
         types: [opened, synchronize, reopened]
 
@@ -12,13 +15,16 @@ jobs:
             - name: Checkout Repository
               uses: actions/checkout@v4
 
-            - name: use NodeJS v22.16.0
+            - name: Use Node.js 24.17.0
               uses: actions/setup-node@v4
               with:
-                  node-version: '22.16.0'
+                  node-version: '24.17.0'
 
             - name: Install Dependencies
-              run: npm install
+              run: npm ci
 
-            - name: run Rollout Build
+            - name: Run Checks
+              run: npm run check
+
+            - name: Run Build
               run: npm run build

.github/ISSUE_TEMPLATE/bug.yaml

@@ -1,42 +0,0 @@
-name: 🐛 Bug Report
-description: Report a bug or unexpected behavior
-title: '🐛 [BUG]: '
-body:
-    - type: textarea
-      id: information
-      attributes:
-          label: Information
-          description: Provide all information about the issue.
-          placeholder: 'What happened? What did you expect to happen?'
-      validations:
-          required: false
-
-    - type: textarea
-      id: steps
-      attributes:
-          label: Steps to Reproduce
-          description: Step-by-step instructions to reproduce the issue.
-          placeholder: |
-              1. Go to ...
-              2. Click on ...
-              3. Observe ...
-      validations:
-          required: false
-
-    - type: textarea
-      id: logs
-      attributes:
-          label: Logs or Error Messages
-          description: Paste any relevant console output, stack traces, or screenshots.
-          placeholder: 'Console output, stacktrace, or screenshots here'
-      validations:
-          required: false
-
-    - type: input
-      id: occurrence
-      attributes:
-          label: Occurrence Version
-          description: Specify in which version the issue occurred
-          placeholder: 'v0.1.TTMMJJ-hhmm'
-      validations:
-          required: true

.github/ISSUE_TEMPLATE/feature.yaml

@@ -1,29 +0,0 @@
-name: 💡 Enhancement
-description: Suggest a new feature or improvement
-title: '💡 [ENHANCEMENT]: '
-body:
-    - type: textarea
-      id: description
-      attributes:
-          label: Description
-          description: Describe the new feature or improvement!
-          placeholder: 'What problem does it solve or what value does it add?'
-      validations:
-          required: true
-
-    - type: textarea
-      id: proposal
-      attributes:
-          label: Proposed Solution
-          placeholder: 'Describe how the feature should work.'
-      validations:
-          required: false
-
-    - type: input
-      id: implementation
-      attributes:
-          label: Implementation Version
-          description: Specify in which version the enhancement should be released.
-          placeholder: 'v0.1'
-      validations:
-          required: true

.github/ISSUE_TEMPLATE/improvement.yaml

@@ -1,39 +0,0 @@
-name: ⚙️ Improvement
-description: Suggest an improvement to existing functionality, code quality, or performance
-title: '⚙️ [Improvement]: '
-body:
-    - type: textarea
-      id: context
-      attributes:
-          label: Current Situation / Context
-          description: Describe the current behavior or implementation that could be improved.
-          placeholder: 'Currently, the system loads all users at once, which slows down response time.'
-      validations:
-          required: false
-
-    - type: textarea
-      id: proposal
-      attributes:
-          label: Proposed Improvement
-          description: Describe your proposed change or improvement in detail.
-          placeholder: 'Implement pagination for user loading to reduce memory usage and response time.'
-      validations:
-          required: false
-
-    - type: textarea
-      id: benefits
-      attributes:
-          label: Expected Benefits
-          description: Explain how this improvement will help (e.g., better performance, cleaner code, easier maintenance).
-          placeholder: 'Faster load times, improved scalability, and reduced database load.'
-      validations:
-          required: false
-
-    - type: input
-      id: implementation
-      attributes:
-          label: Implementation Version
-          description: Specify in which version the improvement should be released.
-          placeholder: 'v0.1'
-      validations:
-          required: true

.github/dependabot.yml

@@ -1,11 +0,0 @@
-# To get started with Dependabot version updates, you'll need to specify which
-# package ecosystems to update and where the package manifests are located.
-# Please see the documentation for all configuration options:
-# https://docs.github.com/code-security/dependabot/dependabot-version-updates/configuration-options-for-the-dependabot.yml-file
-
-version: 2
-updates:
-    - package-ecosystem: 'npm' # See documentation for possible values
-      directory: '/' # Location of package manifests
-      schedule:
-          interval: 'daily'

.github/workflows/Build-Rollout.yml

@@ -1,39 +0,0 @@
-name: Release and Deploy Build
-
-on:
-    workflow_dispatch:
-
-permissions:
-    id-token: write
-    contents: read
-
-jobs:
-    build:
-        runs-on: ubuntu-latest
-
-        steps:
-            - name: Checkout Repository
-              uses: actions/checkout@v4
-
-            - name: use NodeJS v22.12.0
-              uses: actions/setup-node@v4
-              with:
-                  node-version: '22.12.0'
-                  registry-url: 'https://registry.npmjs.org'
-                  always-auth: true
-
-            - name: Create .npmrc
-              run: echo "//registry.npmjs.org/:_authToken=\${NPM_TOKEN}" > ~/.npmrc
-              env:
-                  NPM_TOKEN: ${{ secrets.NPM_TOKEN }}
-
-            - name: Install Dependencies
-              run: npm install
-
-            - name: run Rollout Build
-              run: npm run build
-
-            - name: Publish Library
-              run: npm publish
-              env:
-                  NODE_AUTH_TOKEN: ${{ secrets.NPM_TOKEN }}

.github/workflows/migrate-to-gitea.yml

@@ -0,0 +1,106 @@
+name: Redirect contributions to Gitea
+
+on:
+    issues:
+        types: [opened, reopened]
+    pull_request_target:
+        types: [opened, reopened]
+
+permissions:
+    issues: write
+    pull-requests: write
+
+concurrency:
+    group: migrate-${{ github.event_name }}-${{ github.event.issue.number || github.event.pull_request.number }}
+
+env:
+    GITEA_API_URL: https://git.lechner-systems.at/api/v1
+    GITEA_REPOSITORY: FrauJulian/Discord-Audio-Stream
+
+jobs:
+    migrate-issue:
+        if: github.event_name == 'issues'
+        runs-on: ubuntu-latest
+        steps:
+            - name: Migrate issue and close
+              env:
+                  GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
+                  GITEA_TOKEN: ${{ secrets.GITEA_TOKEN }}
+              run: |
+                  set -euo pipefail
+
+                  number="$(jq -r '.issue.number' "$GITHUB_EVENT_PATH")"
+                  title="$(jq -r '.issue.title' "$GITHUB_EVENT_PATH")"
+                  body="$(jq -r '.issue.body // ""' "$GITHUB_EVENT_PATH")"
+                  author="$(jq -r '.issue.user.login' "$GITHUB_EVENT_PATH")"
+                  source_url="$(jq -r '.issue.html_url' "$GITHUB_EVENT_PATH")"
+                  github_api="${GITHUB_API_URL}/repos/${GITHUB_REPOSITORY}"
+                  migrated_url="$(
+                      curl --fail --silent --show-error \
+                          --header "Authorization: Bearer ${GITHUB_TOKEN}" \
+                          --header "Accept: application/vnd.github+json" \
+                          "${github_api}/issues/${number}/comments?per_page=100" |
+                          jq -r '[.[] | select(.user.login == "github-actions[bot]" and (.body | startswith("Migrated to Gitea: ")))] | first | .body // "" | sub("^Migrated to Gitea: "; "")'
+                  )"
+
+                  if [ -z "$migrated_url" ]; then
+                      migrated_body="${body}
+
+                  ---
+                  Originally opened by @${author} on GitHub: ${source_url}"
+
+                      jq -n \
+                          --arg title "$title" \
+                          --arg body "$migrated_body" \
+                          '{title: $title, body: $body}' > gitea-request.json
+
+                      curl --fail-with-body \
+                          --request POST \
+                          --header "Authorization: token ${GITEA_TOKEN}" \
+                          --header "Content-Type: application/json" \
+                          --data @gitea-request.json \
+                          "${GITEA_API_URL}/repos/${GITEA_REPOSITORY}/issues" > gitea-response.json
+
+                      migrated_url="$(jq -r '.html_url' gitea-response.json)"
+                      jq -n --arg body "Migrated to Gitea: ${migrated_url}" '{body: $body}' > github-comment.json
+                      curl --fail-with-body \
+                          --request POST \
+                          --header "Authorization: Bearer ${GITHUB_TOKEN}" \
+                          --header "Content-Type: application/json" \
+                          --data @github-comment.json \
+                          "${github_api}/issues/${number}/comments"
+                  fi
+
+                  curl --fail-with-body \
+                      --request PATCH \
+                      --header "Authorization: Bearer ${GITHUB_TOKEN}" \
+                      --header "Content-Type: application/json" \
+                      --data '{"state":"closed","state_reason":"not_planned"}' \
+                      "${github_api}/issues/${number}"
+
+    redirect-pull-request:
+        if: github.event_name == 'pull_request_target'
+        runs-on: ubuntu-latest
+        steps:
+            - name: Redirect pull request and close
+              env:
+                  GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
+              run: |
+                  set -euo pipefail
+
+                  number="$(jq -r '.pull_request.number' "$GITHUB_EVENT_PATH")"
+                  github_api="${GITHUB_API_URL}/repos/${GITHUB_REPOSITORY}"
+
+                  curl --fail-with-body \
+                      --request POST \
+                      --header "Authorization: Bearer ${GITHUB_TOKEN}" \
+                      --header "Content-Type: application/json" \
+                      --data '{"body":"Please open the Pull Request on Gitea"}' \
+                      "${github_api}/issues/${number}/comments"
+
+                  curl --fail-with-body \
+                      --request PATCH \
+                      --header "Authorization: Bearer ${GITHUB_TOKEN}" \
+                      --header "Content-Type: application/json" \
+                      --data '{"state":"closed"}' \
+                      "${github_api}/pulls/${number}"

.gitignore

@@ -1,4 +1,13 @@
-.idea
-.git
-node_modules
-dist
+.idea/
+.vscode/
+node_modules/
+dist/
+coverage/
+
+.npm/
+.eslintcache
+*.log
+*.tsbuildinfo
+
+.DS_Store
+Thumbs.db

.husky/pre-commit

@@ -1,3 +1,2 @@
 #!/usr/bin/env sh
-npm run format:check || exit 1
-npm run lint || exit 1
+npm run check || exit 1

.npmignore

@@ -1,4 +1,4 @@
-.github
+.gitea
 .git
 
 .idea
@@ -6,6 +6,8 @@
 
 dist
 node_modules
+coverage
+.npm
 
 .husky
 src
@@ -24,6 +26,8 @@ CODEOWNERS
 tsconfig.json
 tsconfig.eslint.json
 tsup.config.ts
-eslint.config.js
+eslint.config.cjs
 eslint.config.typeaware.cjs
 package-lock.json
+jest.config.cjs
+tests

.prettierignore

@@ -1,5 +1,9 @@
-node_modules
-dist
-.git
-.idea
-.vscode
+node_modules/
+dist/
+coverage/
+
+.git/
+.idea/
+.vscode/
+
+package-lock.json

.prettierrc

@@ -9,5 +9,5 @@
     "bracketSpacing": true,
     "bracketSameLine": false,
     "quoteProps": "as-needed",
-    "endOfLine": "crlf"
+    "endOfLine": "auto"
 }

CODEOWNERS

@@ -1 +0,0 @@
-FrauJulian

README.md

@@ -1,129 +1,222 @@
 # Discord Audio Stream
 
-[![npm](https://img.shields.io/npm/dw/discord-audio-stream)](http://npmjs.org/package/discord-audio-stream)
-![GitHub package.json version](https://img.shields.io/github/package-json/v/FrauJulian/discord-audio-stream)
-![GitHub Repo stars](https://img.shields.io/github/stars/FrauJulian/discord-audio-stream?style=social)
+[![npm](https://img.shields.io/npm/dw/discord-audio-stream)](https://www.npmjs.com/package/discord-audio-stream)
+![latest release](https://img.shields.io/gitea/v/release/FrauJulian/Discord-Audio-Stream?gitea_url=https%3A%2F%2Fgit.lechner-systems.at&color=blue)
+![Github Repo stars](https://img.shields.io/github/stars/FrauJulian/Discord-Audio-Stream?github_url=https%3A%2F%2Fgithub.com&style=social)
 
-**This module is designed to work with [discord.js/voice](https://www.npmjs.com/package/@discordjs/voice) v0.19. This
-package doesn't support older
-versions!**
+`discord-audio-stream` is a small TypeScript library for managed Discord voice playback through
+`@discordjs/voice` and ffmpeg.
 
-> **Designed for 24/7 audio playing on discord.**  
-> Discord has many unwanted rate limits, especially in the audio area. This package does all the work and ensures that
-> your music never stops playing due to ffmpeg or Discord, with as little effort as possible.
+It manages the Discord voice connection, ffmpeg process, raw PCM audio resource, optional renewal, and cleanup. Keep one
+`AudioManager` per guild, usually in a `Map<string, AudioManager>`, and call `dispose()` when that manager will not be
+reused.
 
-> **Recommended best Practise:**  
-> Create a global Map<GuildId, AudioManager> (Map<KEY, OBJ>) list. When the feature is used on a guild, add a new
-> instance of AudioManager to the Map. When starting the connection or audio, overwrite the respective configuration with
-> the override methods provided. To finally start, use the respective method. For each call and each change, retrieve the
-> AudioManager object from the list and perform your actions. When the feature get stopped, first execute StopConnection
-> and then Dispose to save as much power as possible. Garbage collection does the rest.  
-> **For large systems:** For large systems, it is recommended to queue each start with the
-> packet [p-queue](https://www.npmjs.com/package/p-queue), to give ffmpeg enough time..
+## Support
 
-## 👋 Support
+Create an [issue](https://git.lechner-systems.at/FrauJulian/Discord-Audio-Stream/issues) on Gitea or contact
+[`fraujulian`](https://discord.com/users/860206216893693973) on Discord.
 
-Please create an [issue](https://github.com/FrauJulian/DiscordAudioStreamNPM/issues) on github or write [
-`fraujulian`](https://discord.com/users/860206216893693973) on discord!
+## Installation
 
-## 📝 Usage
-
-### Installation
-
-**Node.js 22.12.0 or newer is required.**
+Node.js `>=24.17.0` and `<25` is required.
 
 ```bash
-npm install discord-audio-stream
-yarn add discord-audio-stream
-pnpm add discord-audio-stream
-bun add discord-audio-stream
+npm install discord-audio-stream @discordjs/voice @discordjs/opus
 ```
 
-#### Required Dependencies
+Use `opusscript@^0.0.8` only as a slower JavaScript fallback when `@discordjs/opus` cannot be installed.
 
-- > You only need to install `libsodium-wrappers` if your system does not support `aes-256-gcm` (verify by running
-  > `require('node:crypto').getCiphers().includes('aes-256-gcm')`).
-- `@snazzah/davey`
-- `opusscript`
-- `prism-media`
-- **FFmpeg** (one of those)
-    - [`FFmpeg`](https://ffmpeg.org/) (installed and added to environment)
-    - `ffmpeg-static`
+`ffmpeg` must be available either on the host PATH or through the optional `ffmpeg-static` package:
 
-### AudioManager Instance
-
-#### Options
-
-**Declaration:**
-
-```
-AudioManager(ffmpegMode: string, renewInMs, number, connectionData: VoiceConnectionDataModel, audioData: VoiceAudioDataModel): IDisposable, IAudioManager
+```bash
+npm install ffmpeg-static
 ```
 
-- `ffmpegMode`: 'Native' or 'Standalone'
-    - Native: [`FFmpeg`](https://ffmpeg.org/) installed on your system
-    - Standalone: FFmpeg-static as NodeJs library
-- `renewInMs`: renewal time > default is 1,5h (5400000ms)
-- `connectionData`: Options for voice connection. (type of **VoiceConnectionDataModel**)
-- `audioData`: Options for audio player. (type of **VoiceAudioDataModel**)
+Use `ffmpeg.mode: 'native'` for PATH-based ffmpeg and `ffmpeg.mode: 'static'` for `ffmpeg-static`.
 
-#### Example
+## Basic Usage
 
-```js
-let audioManager = new AudioManager(
-    'Native',
-    5400000,
-    {
-        VoiceChannelId: 0, //voice channel id where to play music
-        GuildId: 0, //guild id
-        VoiceAdapter: 0, //guild VoiceAdapter
+```ts
+import { AudioManager } from 'discord-audio-stream';
+
+const manager = new AudioManager({
+    connection: {
+        guildId: guild.id,
+        channelId: voiceChannel.id,
+        adapterCreator: guild.voiceAdapterCreator,
     },
-    {
-        ResourceType: '', //resource type like link or file
-        Resource: '', //auto play link or file name
+    source: {
+        type: 'url',
+        url: 'https://example.com/live-stream.mp3',
     },
-);
+    ffmpeg: {
+        mode: 'native',
+    },
+});
+
+await manager.start();
 ```
 
-### Fields and Methods of AudioManager
+For a file source:
 
-#### Fields
+```ts
+manager.setSource({
+    type: 'file',
+    path: 'audio/intro.mp3',
+});
 
-| Name      | Type     | Security  | Description                           |
-| --------- | -------- | --------- | ------------------------------------- |
-| `Active`  | **bool** | protected | To check if the connection is active. |
-| `Playing` | **bool** | protected | To check if it is playing audio.      |
+await manager.start();
+```
 
-#### Methods
+Relative file paths are resolved from `process.cwd()`. URL sources are validated before playback starts.
 
-| Name                          | Parameters                                              | Return type   | Description                              |
-| ----------------------------- | ------------------------------------------------------- | ------------- | ---------------------------------------- |
-| `OverrideVoiceConnectionData` | `connectionData` (type of **VoiceConnectionDataModel**) | void          | To override intern connectionData field. |
-| `OverrideVoiceAudioDataModel` | `audioData` (type of **VoiceAudioDataModel**)           | void          | To override intern audioData field.      |
-| `CreateAndPlay`               |                                                         | Promise<void> | Join channel and start playing audio.    |
-| `CreateConnection`            |                                                         | void          | Let it connect to voice channel.         |
-| `PlayAudio`                   |                                                         | Promise<void> | To start playing audio.                  |
-| `PauseAudio`                  |                                                         | void          | Pause the audio, if it is playing        |
-| `ResumeAudio`                 |                                                         | void          | Resume the audio, if it is paused.       |
-| `SetVolume`                   | `volume` (type of number, 0 - 100 percent)              | void          | To set the audio volume.                 |
-| `StopConnection`              |                                                         | Promise<void> | Method to disconnect the voice channel.  |
-| `Dispose`                     |                                                         | void          | Dispose all data in object.              |
+For large bots, queue many simultaneous starts so the host does not spawn too many ffmpeg processes in the same tick.
 
-## 📝 Types
+## Lifecycle
 
-- [**VoiceConnection** by discord.js/voice](https://github.com/discordjs/discord.js/blob/main/packages/voice/src/VoiceConnection.ts#L166)
-- [**AudioPlayer** by discord.js/voice](https://github.com/discordjs/discord.js/blob/main/packages/voice/src/audio/AudioPlayer.ts#L155)
-- [**AudioResource** by discord.js/voice](https://github.com/discordjs/discord.js/blob/main/packages/voice/src/audio/AudioResource.ts#L44)
-- [**DiscordGatewayAdapterCreator** by discord.js/voice](https://github.com/discordjs/discord.js/blob/main/packages/voice/src/util/adapter.ts#L50)
-- [**VoiceConnectionDataModel** by discord-audio-stream](https://github.com/FrauJulian/Discord-Audio-Stream/blob/master/src/types.d.ts#L3)
-- [**VoiceAudioDataModel** by discord-audio-stream](https://github.com/FrauJulian/Discord-Audio-Stream/blob/master/src/types.d.ts#L21)
-- [**IDisposable** by discord-audio-stream](https://github.com/FrauJulian/Discord-Audio-Stream/blob/master/src/types.d.ts#L38)
-- [**IAudioManager** by discord-audio-stream](https://github.com/FrauJulian/Discord-Audio-Stream/blob/master/src/types.d.ts#L45)
+```ts
+manager.setConnection(connectionOptions);
+manager.setSource(source);
 
-## 📋 Contributors:
+await manager.start(); // connect() + play()
+manager.pause();
+manager.resume();
+await manager.stop(); // stops playback and destroys the voice connection
+manager.dispose(); // final cleanup; the manager cannot be reused
+```
+
+`connect()` joins the configured voice channel. `play(source?)` starts playback on an existing connection. Use `start()`
+when you want both.
+
+For scoped playback, `AudioManager` supports explicit resource management:
+
+```ts
+{
+    using manager = new AudioManager(options);
+    await manager.start();
+} // disposed automatically
+```
+
+## API
+
+```ts
+type AudioManagerOptions = {
+    ffmpeg?: {
+        mode?: 'native' | 'static';
+        executablePath?: string;
+        inputArgs?: readonly string[];
+        outputArgs?: readonly string[];
+    };
+    connection?: {
+        guildId: string;
+        channelId: string;
+        adapterCreator: DiscordGatewayAdapterCreator;
+    };
+    source?: { type: 'url'; url: string } | { type: 'file'; path: string };
+    renewIntervalMs?: number | false;
+    connectTimeoutMs?: number;
+    onError?: (error: Error) => void;
+    volume?: {
+        enabled?: boolean;
+        initialPercent?: number;
+    };
+};
+```
+
+`connectTimeoutMs` and numeric `renewIntervalMs` values must be whole milliseconds from `1` through `2_147_483_647`.
+`volume.initialPercent` must be a finite number from `0` through `100` and requires `volume.enabled: true`.
+
+### Defaults
+
+| Option             | Default    |
+| ------------------ | ---------- |
+| `ffmpeg.mode`      | `'native'` |
+| `connectTimeoutMs` | `20_000`   |
+| `renewIntervalMs`  | `false`    |
+| `volume.enabled`   | `false`    |
+
+### Methods
+
+| Method                   | Description                                                                        |
+| ------------------------ | ---------------------------------------------------------------------------------- |
+| `setConnection(options)` | Sets the target for the next `connect()` or `start()` call.                        |
+| `setSource(source)`      | Sets the source for the next `play()` or `start()` call.                           |
+| `connect()`              | Joins the configured Discord voice channel.                                        |
+| `play(source?)`          | Starts playback on an existing connection.                                         |
+| `start()`                | Connects and starts playback.                                                      |
+| `pause()`                | Pauses active playback.                                                            |
+| `resume()`               | Resumes paused playback.                                                           |
+| `stop()`                 | Stops playback, clears renewal, and destroys the voice connection.                 |
+| `setVolume(percent)`     | Sets volume from `0` to `100`; requires `volume.enabled: true`.                    |
+| `dispose()`              | Idempotently releases timers, ffmpeg, streams, player state, and voice connection. |
+| `[Symbol.dispose]()`     | Enables automatic cleanup with TypeScript's `using` declaration.                   |
+
+### State
+
+```ts
+manager.state; // 'idle' | 'connecting' | 'ready' | 'playing' | 'paused' | 'stopped' | 'disposed'
+manager.isPlaying;
+manager.isConnected;
+```
+
+## Audio Options
+
+Inline volume has runtime cost in `@discordjs/voice`, so it is disabled by default.
+
+```ts
+const manager = new AudioManager({
+    connection,
+    source,
+    volume: {
+        enabled: true,
+        initialPercent: 50,
+    },
+});
+
+await manager.start();
+manager.setVolume(25);
+```
+
+Calling `setVolume()` without `volume.enabled: true` throws `AudioManagerStateError`.
+
+Default ffmpeg output is raw Discord-compatible PCM: `s16le`, `48000 Hz`, `2 channels`.
+
+You can override ffmpeg arguments through `ffmpeg.inputArgs` and `ffmpeg.outputArgs`. When you override them, you are
+responsible for keeping the output compatible with `StreamType.Raw`.
+
+Connection renewal is disabled by default because `@discordjs/voice` handles recoverable disconnects. Set
+`renewIntervalMs` only when an application has a measured need for periodic restarts. `stop()` and `dispose()` always
+clear the renewal timer.
+
+## Errors
+
+The package exports these error classes:
+
+- `AudioManagerError`
+- `AudioManagerConfigError`
+- `AudioManagerStateError`
+- `FfmpegProcessError`
+
+Configuration problems, such as a missing source or invalid URL, throw `AudioManagerConfigError`. Invalid lifecycle
+operations, such as calling `pause()` while nothing is playing, throw `AudioManagerStateError`.
+
+Use `onError` to observe asynchronous audio player and voice connection errors. The manager cleans up failed playback
+and unrecoverable connections before invoking the callback.
+
+`onError` does not handle rejected `connect()`, `play()`, or `start()` calls. Await and catch those calls explicitly.
+
+## Development
+
+```bash
+npm ci
+npm run check
+npm run build
+```
+
+## Contributors
 
 ~ [**FrauJulian - Julian Lechner**](https://fraujulian.xyz/) - CODEOWNER
 
-## 🤝 Enjoy the package?
+## Enjoy the package?
 
-Give it a star ⭐ on [github](https://github.com/FrauJulian/discord-audio-stream)!
+Give it a star on [Gitea](https://git.lechner-systems.at/FrauJulian/Discord-Audio-Stream)!

SECURITY.md

@@ -2,17 +2,54 @@
 
 ## Supported Versions
 
-Use this section to tell people about which versions of your project are
-currently being supported with security updates.
+Security fixes are provided for the latest published release line.
 
 | Version                                   | Supported |
-| ------- | ------------------ |
-| 0.1.x   | :white_check_mark: |
+| ----------------------------------------- | --------- |
+| Latest release                            | Yes       |
+| Older releases                            | No        |
+| Unreleased local forks or modified builds | No        |
+
+If a vulnerability is fixed, the fix will generally be released only for the current supported version unless a backport is clearly necessary.
 
 ## Reporting a Vulnerability
 
-Use this section to tell people how to report a vulnerability.
+Do not open a public Gitea issue for security vulnerabilities.
 
-Tell them where to go, how often they can expect to get an update on a
-reported vulnerability, what to expect if the vulnerability is accepted or
-declined, etc.
+Report vulnerabilities privately by email to `fraujulian@lechner.top`.
+
+Please include:
+
+- A clear description of the issue and the expected security impact.
+- Affected package version or commit, Node.js version, and runtime environment.
+- Reproduction steps, proof of concept, or a minimal example.
+- Any relevant logs, stack traces, or dependency details.
+- Whether you believe the issue is already publicly known.
+
+## What To Expect
+
+- Initial acknowledgement is targeted within 7 days.
+- After triage, you may be asked for more detail or validation.
+- If the report is accepted, a fix will be prepared and released as soon as reasonably possible.
+- Coordinated disclosure is preferred. Please wait for a fix or explicit approval before publishing details.
+- If the report is out of scope or not reproducible, you will be told why.
+
+## Scope
+
+This policy covers vulnerabilities in the published `discord-audio-stream` package itself.
+
+Examples that may be in scope:
+
+- Input handling issues that could cause unsafe process execution behavior.
+- Vulnerabilities caused by package logic, lifecycle management, or exposed API behavior.
+- Security-relevant documentation mistakes that would realistically lead users into unsafe deployment.
+
+Examples that are usually out of scope:
+
+- Vulnerabilities in third-party dependencies that are not introduced by this package.
+- Misconfiguration in a consuming bot, Discord server, host OS, or infrastructure.
+- Denial of service caused solely by unsupported environments or intentionally extreme workloads.
+
+## Disclosure
+
+When a report is confirmed, the goal is to publish a fix and then disclose the issue responsibly through the repository release notes, commit history, or an advisory, depending on severity and impact.

eslint.config.cjs

@@ -1,7 +1,9 @@
 /** @type {import('eslint').Linter.FlatConfig[]} */
+const prettierConfig = require('eslint-config-prettier/flat');
+
 const config = [
     {
-        ignores: ['dist/', 'node_modules/'],
+        ignores: ['coverage/', 'dist/', 'node_modules/'],
     },
 
     {
@@ -36,7 +38,7 @@ const config = [
                 'warn',
                 { vars: 'all', varsIgnorePattern: '^_', args: 'after-used', argsIgnorePattern: '^_' },
             ],
-            '@typescript-eslint/no-explicit-any': 'off',
+            '@typescript-eslint/no-explicit-any': 'error',
 
             /* Imports */
             'import/first': 'error',
@@ -46,7 +48,7 @@ const config = [
                 'error',
                 {
                     devDependencies: [
-                        '**/*.config.{js,cjs,mjs,ts}',
+                        '**/*.config*.{js,cjs,mjs,ts}',
                         '**/scripts/**',
                         '**/*.test.{ts,js}',
                         '**/Testing.{ts,js}',
@@ -77,6 +79,23 @@ const config = [
         },
     },
 
+    {
+        files: ['**/*.{ts,tsx}'],
+        languageOptions: {
+            parserOptions: {
+                project: ['./tsconfig.eslint.json'],
+                tsconfigRootDir: __dirname,
+            },
+        },
+        rules: {
+            '@typescript-eslint/no-floating-promises': 'error',
+            '@typescript-eslint/no-misused-promises': ['error', { checksVoidReturn: false }],
+            '@typescript-eslint/no-unsafe-assignment': 'error',
+            '@typescript-eslint/no-unsafe-member-access': 'error',
+            '@typescript-eslint/no-unsafe-argument': 'error',
+        },
+    },
+
     {
         files: ['**/*.{js,cjs}'],
         languageOptions: {
@@ -88,4 +107,4 @@ const config = [
     },
 ];
 
-module.exports = config;
+module.exports = [...config, prettierConfig];

eslint.config.typeaware.cjs

@@ -1,25 +0,0 @@
-/** @type {import('eslint').Linter.FlatConfig[]} */
-const base = require('./eslint.config.cjs');
-
-const typeAwareLayer = {
-    files: ['**/*.{ts,tsx}'],
-    languageOptions: {
-        parser: require('@typescript-eslint/parser'),
-        parserOptions: {
-            project: ['./tsconfig.eslint.json'],
-            tsconfigRootDir: __dirname,
-        },
-    },
-    plugins: {
-        '@typescript-eslint': require('@typescript-eslint/eslint-plugin'),
-    },
-    rules: {
-        '@typescript-eslint/no-floating-promises': 'warn',
-        '@typescript-eslint/no-misused-promises': ['warn', { checksVoidReturn: false }],
-        '@typescript-eslint/no-unsafe-assignment': 'warn',
-        '@typescript-eslint/no-unsafe-member-access': 'warn',
-        '@typescript-eslint/no-unsafe-argument': 'warn',
-    },
-};
-
-module.exports = [...base, typeAwareLayer];

jest.config.cjs

@@ -0,0 +1,15 @@
+/** @type {import('jest').Config} */
+module.exports = {
+    clearMocks: true,
+    moduleFileExtensions: ['ts', 'js', 'json'],
+    testEnvironment: 'node',
+    testMatch: ['<rootDir>/tests/**/*.test.ts'],
+    transform: {
+        '^.+\\.ts$': [
+            'ts-jest',
+            {
+                tsconfig: '<rootDir>/tsconfig.test.json',
+            },
+        ],
+    },
+};

package.json

@@ -1,8 +1,9 @@
 {
+    "$schema": "https://json.schemastore.org/package.json",
     "name": "discord-audio-stream",
-    "version": "0.7.DDDhhmm",
-    "license": "LGPL-2.1-only",
-    "description": "Discord library to make stream any audio easier.",
+    "version": "x.x.x",
+    "license": "LGPL-3.0-only",
+    "description": "A small Discord voice audio streaming library with managed ffmpeg playback.",
     "exports": {
         ".": {
             "require": {
@@ -21,33 +22,40 @@
     "files": [
         "dist"
     ],
-    "directories": {
-        "lib": "src"
-    },
+    "sideEffects": false,
     "scripts": {
-        "update:dependencies": "npx npm-check-updates --upgrade",
-        "update:version": "node set-version.js",
+        "version:place": "node set-version.js set-ci-version",
+        "version:check": "node set-version.js check-placeholder",
+        "version:fix": "node set-version.js fix-placeholder",
         "lint": "eslint . --ext .ts,.tsx,.js,.cjs,.mjs",
         "lint:fix": "eslint . --ext .ts,.tsx,.js,.cjs,.mjs --fix",
-        "lint:types": "eslint . --config eslint.config.typeaware.cjs --ext .ts,.tsx",
         "format": "prettier --write .",
         "format:check": "prettier --check .",
-        "build": "del-cli dist && npm run update:version && tsup",
+        "typecheck": "tsc --noEmit --declaration --isolatedDeclarations",
+        "test": "jest --runInBand",
+        "check": "npm run version:check && npm run format:check && npm run lint && npm run typecheck && npm run test",
+        "fix": "npm run version:fix && npm run format && npm run lint:fix",
+        "build": "tsup",
         "prepare": "husky"
     },
-    "repository": "https://github.com/FrauJulian/Discord-Audio-Stream",
-    "bugs": "https://github.com/FrauJulian/Discord-Audio-Stream/issues",
+    "repository": {
+        "type": "git",
+        "url": "git+https://git.lechner-systems.at/FrauJulian/Discord-Audio-Stream.git"
+    },
+    "bugs": "https://git.lechner-systems.at/FrauJulian/Discord-Audio-Stream/issues",
     "funding": "https://ko-fi.com/FrauJulian",
     "keywords": [
-        "discordjs",
+        "discord",
+        "discord.js",
+        "audio",
+        "voice",
+        "streaming",
         "discordjs/voice",
         "music",
-        "voice",
-        "audio",
         "24/7"
     ],
     "contributors": [
-        "FrauJulian - Lechner Julian <fraujulian@lechner.top>"
+        "Julian Lechner - FrauJulian <fraujulian@lechner.top>"
     ],
     "lint-staged": {
         "*.{ts,tsx,js,cjs,mjs}": [
@@ -58,37 +66,53 @@
             "prettier --write"
         ]
     },
-    "dependencies": {
-        "@typescript-eslint/eslint-plugin": "^8.50.0",
-        "@typescript-eslint/parser": "^8.50.0"
-    },
     "devDependencies": {
+        "@discordjs/opus": "^0.10.0",
+        "@jest/globals": "^30.4.1",
         "@types/ejs": "^3.1.5",
-        "@types/node": "^25.0.2",
-        "del-cli": "^7.0.0",
-        "eslint": "^9.39.2",
+        "@types/node": "^24.0.0",
+        "@typescript-eslint/eslint-plugin": "^8.67.0",
+        "@typescript-eslint/parser": "^8.67.0",
+        "eslint": "^9.39.5",
         "eslint-config-prettier": "^10.1.8",
-        "eslint-import-resolver-typescript": "^4.4.4",
+        "eslint-import-resolver-typescript": "^4.4.5",
         "eslint-plugin-import": "^2.32.0",
-        "eslint-plugin-n": "^17.23.1",
-        "eslint-plugin-promise": "^7.2.1",
-        "eslint-plugin-unused-imports": "^4.3.0",
+        "eslint-plugin-n": "^18.3.0",
+        "eslint-plugin-promise": "^7.3.0",
+        "eslint-plugin-unused-imports": "^4.4.1",
         "husky": "^9.1.7",
-        "npm-check-updates": "^19.2.0",
-        "prettier": "^3.7.4",
-        "ts-jest": "^29.4.6",
+        "jest": "^30.4.2",
+        "prettier": "^3.9.6",
+        "ts-jest": "^29.4.12",
         "tsup": "^8.5.1",
-        "typescript": "^5.9.3"
+        "@typescript/native": "npm:typescript@^7.0.2",
+        "typescript": "npm:@typescript/typescript6@^6.0.2"
     },
     "peerDependencies": {
-        "@discordjs/voice": "^0.19.0",
-        "@snazzah/davey": "^0.1.8",
-        "libsodium-wrappers": "^0.7.15",
-        "opusscript": "^0.0.8",
-        "prism-media": "^1.3.5"
+        "@discordjs/opus": "^0.10.0",
+        "@discordjs/voice": "^0.19.2",
+        "ffmpeg-static": "^5.3.0",
+        "opusscript": "^0.0.8"
+    },
+    "peerDependenciesMeta": {
+        "@discordjs/opus": {
+            "optional": true
+        },
+        "ffmpeg-static": {
+            "optional": true
+        },
+        "opusscript": {
+            "optional": true
+        }
+    },
+    "overrides": {
+        "@discordjs/node-pre-gyp": {
+            "tar": "^7.5.22"
+        },
+        "esbuild": "^0.28.2"
     },
     "engines": {
-        "node": ">=22.12.0"
+        "node": ">=24.17.0 <25"
     },
     "private": false,
     "publishConfig": {

set-version.js

@@ -1,21 +1,103 @@
 const fs = require('fs');
 
-const pkg = JSON.parse(fs.readFileSync('package.json', 'utf8').toString());
+const lockFilePath = 'package-lock.json';
+const packageFilePath = 'package.json';
+const placeholderVersion = 'x.x.x';
+const command = process.argv[2];
 
-const [major, minor] = pkg.version.split('.');
-const prefix = `${major}.${minor}.`;
+function readJson(path) {
+    return JSON.parse(fs.readFileSync(path, 'utf8').toString());
+}
 
-const now = new Date();
-const start = new Date(now.getFullYear(), 0, 0);
-const diff = now - start;
-const dayOfYear = Math.floor(diff / (1000 * 60 * 60 * 24));
+function writeJson(path, value, spaces) {
+    fs.writeFileSync(path, `${JSON.stringify(value, null, spaces)}\n`);
+}
 
-const hh = String(now.getHours()).padStart(2, '0');
-const mm = String(now.getMinutes()).padStart(2, '0');
+function getLockFile() {
+    if (!fs.existsSync(lockFilePath)) {
+        return null;
+    }
 
-const newVersion = `${prefix}${String(dayOfYear).padStart(3, '0')}${hh}${mm}`;
+    return readJson(lockFilePath);
+}
 
-pkg.version = newVersion;
-fs.writeFileSync('package.json', JSON.stringify(pkg, null, 2));
+function writeVersions(version) {
+    const pkg = readJson(packageFilePath);
+    pkg.version = version;
+    writeJson(packageFilePath, pkg, 2);
 
-console.log('Version set to: ', newVersion);
+    const lock = getLockFile();
+
+    if (lock) {
+        lock.version = version;
+
+        if (lock.packages?.['']) {
+            lock.packages[''].version = version;
+        }
+
+        writeJson(lockFilePath, lock, 4);
+    }
+}
+
+function checkPlaceholder() {
+    const pkg = readJson(packageFilePath);
+    const lock = getLockFile();
+    const errors = [];
+
+    if (pkg.version !== placeholderVersion) {
+        errors.push(`package.json version must be "${placeholderVersion}", got "${pkg.version}"`);
+    }
+
+    if (lock && lock.version !== placeholderVersion) {
+        errors.push(`package-lock.json version must be "${placeholderVersion}", got "${lock.version}"`);
+    }
+
+    if (lock?.packages?.[''] && lock.packages[''].version !== placeholderVersion) {
+        errors.push(
+            `package-lock.json packages[""] version must be "${placeholderVersion}", got "${lock.packages[''].version}"`,
+        );
+    }
+
+    if (errors.length > 0) {
+        for (const error of errors) {
+            console.error(error);
+        }
+        process.exit(1);
+    }
+
+    console.log(`Version placeholder validated: ${placeholderVersion}`);
+}
+
+function fixPlaceholder() {
+    writeVersions(placeholderVersion);
+    console.log(`Version placeholder set to: ${placeholderVersion}`);
+}
+
+function getCiVersion() {
+    const major = process.env.VERSION_MAJOR;
+    const minor = process.env.VERSION_MINOR;
+    const patch = process.env.VERSION_PATCH;
+    const segments = { major, minor, patch };
+
+    for (const [name, value] of Object.entries(segments)) {
+        if (!/^\d+$/.test(value ?? '')) {
+            console.error(`Missing or invalid ${name} version segment: "${value ?? ''}"`);
+            process.exit(1);
+        }
+    }
+
+    return `${major}.${minor}.${patch}`;
+}
+
+if (command === 'check-placeholder') {
+    checkPlaceholder();
+} else if (command === 'fix-placeholder') {
+    fixPlaceholder();
+} else if (command === 'set-ci-version') {
+    const ciVersion = getCiVersion();
+    writeVersions(ciVersion);
+    console.log(`CI version set to: ${ciVersion}`);
+} else {
+    console.error('Invalid command. Use one of: check-placeholder, fix-placeholder, set-ci-version');
+    process.exit(1);
+}

src/audio-manager.ts

@@ -4,194 +4,422 @@ import {
     createAudioResource,
     entersState,
     joinVoiceChannel,
+    AudioPlayerStatus,
     NoSubscriberBehavior,
     StreamType,
     VoiceConnectionStatus,
 } from '@discordjs/voice';
-import { join } from 'node:path';
-import type { IAudioManager, IDisposable, VoiceAudioDataModel, VoiceConnectionDataModel } from './types';
-import { spawn } from 'node:child_process';
-import type { Readable } from 'node:stream';
+import { isAbsolute, resolve } from 'node:path';
 
-export default class AudioManager implements IAudioManager, IDisposable {
-    private voiceConnection?: VoiceConnection | null;
-    private audioPlayer?: AudioPlayer | null;
-    private audioResource?: AudioResource | null;
+import { AudioManagerConfigError, AudioManagerStateError } from './errors';
+import { startFfmpeg, type FfmpegProcessHandle } from './ffmpeg';
+import type {
+    AudioManagerOptions,
+    AudioSource,
+    PlaybackState,
+    ResolvedAudioSource,
+    VoiceConnectionOptions,
+} from './types';
 
-    protected Active?: boolean | null;
-    protected Playing?: boolean | null;
+const DEFAULT_CONNECT_TIMEOUT_MS = 20_000;
+const DISCONNECT_RECOVERY_TIMEOUT_MS = 5_000;
+const MAX_TIMER_DELAY_MS = 2_147_483_647;
 
-    private timeout?: NodeJS.Timeout | null;
-    private ffmpegProcess?: ReturnType<typeof spawn> | null;
-    private pcmStream?: Readable | null;
-
-    constructor(
-        private readonly ffmpegMode: 'Native' | 'Standalone',
-        private renewMs: number | null = null,
-        private connectionData: VoiceConnectionDataModel | null = null,
-        private audioData: VoiceAudioDataModel | null = null,
-    ) {
-        this.renewMs = renewMs ? renewMs : 5400000;
-    }
-
-    public OverrideVoiceConnectionData(connectionData: VoiceConnectionDataModel): void {
-        this.connectionData = connectionData;
-    }
-
-    public OverrideVoiceAudioDataModel(audioData: VoiceAudioDataModel): void {
-        this.audioData = audioData;
-    }
-
-    public CreateConnection(): void {
-        this.voiceConnection = joinVoiceChannel({
-            channelId: this.connectionData!.VoiceChannelId,
-            guildId: this.connectionData!.GuildId,
-            adapterCreator: this.connectionData!.VoiceAdapter,
-        });
-
-        this.timeout = setTimeout(async (): Promise<void> => {
-            await this.StopConnection();
-            await this.CreateAndPlay();
-        }, this.renewMs!);
-    }
-
-    public async PlayAudio(): Promise<void> {
-        if (!this.audioData || !this.voiceConnection) return;
-
-        await entersState(this.voiceConnection!, VoiceConnectionStatus.Ready, 20_000);
-
-        if (this.ffmpegProcess) {
-            this.ffmpegProcess.kill('SIGKILL');
-            this.ffmpegProcess = null;
-        }
-
-        let source: string;
-
-        if (this.audioData!.ResourceType === 'File') {
-            source = join(__dirname, this.audioData!.Resource);
-        } else if (this.audioData!.ResourceType === 'Link') {
-            source = this.audioData!.Resource;
-        } else {
-            throw new TypeError('Invalid resource type.');
-        }
-
-        this.ffmpegProcess = spawn(
-            this.ffmpegMode === 'Native' ? 'ffmpeg' : require('ffmpeg-static'),
-            [
-                '-loglevel',
-                'error',
-                '-i',
-                source,
-                '-analyzeduration',
-                '0',
-                '-f',
-                's16le',
-                '-ar',
-                '48000',
-                '-ac',
-                '2',
-                'pipe:1',
-            ],
-            {
-                stdio: ['ignore', 'pipe', 'pipe'],
-            },
+function assertValidTimerDelay(value: number, optionName: string): void {
+    if (!Number.isSafeInteger(value) || value <= 0 || value > MAX_TIMER_DELAY_MS) {
+        throw new AudioManagerConfigError(
+            `${optionName} must be an integer between 1 and ${MAX_TIMER_DELAY_MS} milliseconds.`,
         );
+    }
+}
 
-        this.pcmStream = this.ffmpegProcess!.stdout as Readable;
+function assertValidVolumePercent(value: number): void {
+    if (!Number.isFinite(value) || value < 0 || value > 100) {
+        throw new AudioManagerConfigError('Volume must be between 0 and 100 percent.');
+    }
+}
 
-        this.audioResource = createAudioResource(this.pcmStream, {
-            inputType: StreamType.Raw,
-            inlineVolume: true,
-        });
+export default class AudioManager implements Disposable {
+    private readonly audioPlayer: AudioPlayer;
 
+    private connection: VoiceConnection | undefined;
+    private resource: AudioResource | undefined;
+    private ffmpeg: FfmpegProcessHandle | undefined;
+    private connectAttempt: AbortController | undefined;
+    private renewTimer: NodeJS.Timeout | undefined;
+    private playbackState: PlaybackState = 'idle';
+    private connectionOptions: VoiceConnectionOptions | undefined;
+    private audioSource: AudioSource | undefined;
+    private readonly options: Required<Pick<AudioManagerOptions, 'connectTimeoutMs'>> &
+        Omit<AudioManagerOptions, 'connectTimeoutMs'>;
+
+    public constructor(options: AudioManagerOptions = {}) {
+        const connectTimeoutMs = options.connectTimeoutMs ?? DEFAULT_CONNECT_TIMEOUT_MS;
+        assertValidTimerDelay(connectTimeoutMs, 'connectTimeoutMs');
+
+        if (typeof options.renewIntervalMs === 'number') {
+            assertValidTimerDelay(options.renewIntervalMs, 'renewIntervalMs');
+        }
+
+        if (options.volume?.initialPercent !== undefined) {
+            if (options.volume.enabled !== true) {
+                throw new AudioManagerConfigError('volume.initialPercent requires volume.enabled to be true.');
+            }
+            assertValidVolumePercent(options.volume.initialPercent);
+        }
+
+        this.options = {
+            ...options,
+            connectTimeoutMs,
+        };
+        this.connectionOptions = options.connection;
+        this.audioSource = options.source;
         this.audioPlayer = createAudioPlayer({
             behaviors: {
                 noSubscriber: NoSubscriberBehavior.Play,
             },
         });
-
-        this.voiceConnection!.subscribe(this.audioPlayer);
-
-        this.audioPlayer.play(this.audioResource);
-        this.Playing = true;
+        this.audioPlayer.on('error', (error) => {
+            this.finishPlayback(error.resource);
+            this.reportError(error);
+        });
+        this.audioPlayer.on(AudioPlayerStatus.Idle, (oldState) => {
+            if ('resource' in oldState) {
+                this.finishPlayback(oldState.resource);
+            }
+        });
     }
 
-    public PauseAudio(): void {
-        if (this.Playing) {
-            this.audioPlayer!.pause();
-            this.Playing = false;
-        } else {
-            throw new ReferenceError('Audio is not playing.');
-        }
+    public get state(): PlaybackState {
+        return this.playbackState;
     }
 
-    public ResumeAudio(): void {
-        if (!this.Playing) {
-            this.audioPlayer!.unpause();
-            this.Playing = true;
-        } else {
-            throw new ReferenceError('Audio is playing.');
-        }
+    public get isPlaying(): boolean {
+        return this.playbackState === 'playing';
     }
 
-    public async CreateAndPlay(): Promise<void> {
-        this.CreateConnection();
-        await this.PlayAudio();
+    public get isConnected(): boolean {
+        return this.connection?.state.status === VoiceConnectionStatus.Ready;
     }
 
-    public async StopConnection(): Promise<void> {
-        this.voiceConnection?.disconnect();
-        this.voiceConnection?.destroy();
-        this.voiceConnection = null;
-
-        this.Active = false;
-        this.Playing = false;
+    public setConnection(options: VoiceConnectionOptions): void {
+        this.assertNotDisposed();
+        this.connectionOptions = options;
     }
 
-    public SetVolume(volumeInPercent: number): void {
-        if (volumeInPercent < 0 || volumeInPercent > 100) throw new Error('Volume must be between 0 and 100.');
-        this.audioResource!.volume!.setVolume(volumeInPercent / 100);
+    public setSource(source: AudioSource): void {
+        this.assertNotDisposed();
+        this.audioSource = source;
     }
 
-    public Dispose(): void {
+    public async connect(): Promise<void> {
+        this.assertNotDisposed();
+
+        if (!this.connectionOptions) {
+            throw new AudioManagerConfigError('Voice connection options are required before connecting.');
+        }
+
+        this.cancelConnectAttempt();
+        const attempt = new AbortController();
+        this.connectAttempt = attempt;
+        this.clearRenewTimer();
+        this.playbackState = 'connecting';
+
+        const previousConnection = this.connection;
+        this.connection = undefined;
+        let connection: VoiceConnection | undefined;
+
         try {
-            if (this.timeout) {
-                clearTimeout(this.timeout);
+            previousConnection?.destroy();
+            connection = joinVoiceChannel({
+                guildId: this.connectionOptions.guildId,
+                channelId: this.connectionOptions.channelId,
+                adapterCreator: this.connectionOptions.adapterCreator,
+            });
+            this.connection = connection;
+            this.observeConnection(connection);
+            connection.subscribe(this.audioPlayer);
+
+            await entersState(
+                connection,
+                VoiceConnectionStatus.Ready,
+                AbortSignal.any([attempt.signal, AbortSignal.timeout(this.options.connectTimeoutMs)]),
+            );
+        } catch (error) {
+            if (this.connectAttempt !== attempt) {
+                throw new AudioManagerStateError('Voice connection was stopped before it became ready.', {
+                    cause: error,
+                });
             }
 
-            if (this.audioPlayer) {
+            this.connectAttempt = undefined;
+            if (connection && connection.state.status !== VoiceConnectionStatus.Destroyed) {
+                connection.destroy();
+            }
+            if (this.connection === connection) {
+                this.connection = undefined;
+            }
+            this.playbackState = 'stopped';
+            throw error;
+        }
+
+        if (this.connectAttempt !== attempt || this.connection !== connection) {
+            throw new AudioManagerStateError('Voice connection was stopped before it became ready.');
+        }
+
+        this.connectAttempt = undefined;
+        this.playbackState = 'ready';
+        this.scheduleRenewal();
+    }
+
+    public async play(source?: AudioSource): Promise<void> {
+        this.assertNotDisposed();
+
+        if (source) {
+            this.setSource(source);
+        }
+
+        if (!this.isConnected) {
+            throw new AudioManagerStateError('A voice connection is required before audio can be played.');
+        }
+
+        const resolvedSource = this.resolveSource();
+        this.stopCurrentPlayback();
+        this.ffmpeg = startFfmpeg(resolvedSource.input, this.options.ffmpeg);
+        const ffmpeg = this.ffmpeg;
+        try {
+            await ffmpeg.ready;
+            if (this.ffmpeg !== ffmpeg) {
+                throw new AudioManagerStateError('Playback was stopped before ffmpeg became ready.');
+            }
+            this.resource = createAudioResource(ffmpeg.process.stdout, {
+                inputType: StreamType.Raw,
+                inlineVolume: this.options.volume?.enabled === true,
+            });
+        } catch (error) {
+            if (this.ffmpeg !== ffmpeg) {
+                throw error instanceof AudioManagerStateError
+                    ? error
+                    : new AudioManagerStateError('Playback was stopped before ffmpeg became ready.', {
+                          cause: error,
+                      });
+            }
+
+            this.stopCurrentPlayback();
+            throw error;
+        }
+
+        try {
+            if (this.options.volume?.enabled === true && this.options.volume.initialPercent !== undefined) {
+                this.setVolume(this.options.volume.initialPercent);
+            }
+            this.audioPlayer.play(this.resource);
+            this.playbackState = 'playing';
+        } catch (error) {
+            this.stopCurrentPlayback();
+            this.playbackState = 'ready';
+            throw error;
+        }
+    }
+
+    public async start(): Promise<void> {
+        await this.connect();
+        await this.play();
+    }
+
+    public pause(): void {
+        this.assertNotDisposed();
+
+        if (this.playbackState !== 'playing') {
+            throw new AudioManagerStateError('Audio can only be paused while it is playing.');
+        }
+
+        this.audioPlayer.pause();
+        this.playbackState = 'paused';
+    }
+
+    public resume(): void {
+        this.assertNotDisposed();
+
+        if (this.playbackState !== 'paused') {
+            throw new AudioManagerStateError('Audio can only be resumed while it is paused.');
+        }
+
+        this.audioPlayer.unpause();
+        this.playbackState = 'playing';
+    }
+
+    public async stop(): Promise<void> {
+        if (this.playbackState === 'disposed') {
+            return;
+        }
+
+        this.cancelConnectAttempt();
+        this.clearRenewTimer();
+        this.stopCurrentPlayback();
         this.audioPlayer.stop(true);
+        this.connection?.disconnect();
+        this.connection?.destroy();
+        this.connection = undefined;
+        this.playbackState = 'stopped';
     }
 
-            if (this.audioPlayer) {
-                this.audioPlayer!.stop();
+    public setVolume(volumeInPercent: number): void {
+        this.assertNotDisposed();
 
-                if (this.audioResource && this.audioResource.playStream) {
-                    this.audioResource!.playStream.destroy();
+        if (this.options.volume?.enabled !== true) {
+            throw new AudioManagerStateError('Volume control requires volume.enabled to be true.');
+        }
+
+        assertValidVolumePercent(volumeInPercent);
+
+        if (!this.resource?.volume) {
+            throw new AudioManagerStateError('No audio resource with volume control is currently active.');
+        }
+
+        this.resource.volume.setVolume(volumeInPercent / 100);
+    }
+
+    public dispose(): void {
+        if (this.playbackState === 'disposed') {
+            return;
+        }
+
+        this.cancelConnectAttempt();
+        this.clearRenewTimer();
+        this.stopCurrentPlayback();
+        this.audioPlayer.stop(true);
+        this.connection?.destroy();
+        this.connection = undefined;
+        this.connectionOptions = undefined;
+        this.audioSource = undefined;
+        this.playbackState = 'disposed';
+    }
+
+    public [Symbol.dispose](): void {
+        this.dispose();
+    }
+
+    private resolveSource(): ResolvedAudioSource {
+        if (!this.audioSource) {
+            throw new AudioManagerConfigError('Audio source is required before playback can start.');
+        }
+
+        if (this.audioSource.type === 'url') {
+            try {
+                return {
+                    input: new URL(this.audioSource.url).toString(),
+                    source: this.audioSource,
+                };
+            } catch (error) {
+                throw new AudioManagerConfigError('Invalid audio source URL.', { cause: error });
             }
         }
 
-            if (this.voiceConnection) {
-                this.voiceConnection!.destroy();
+        return {
+            input: isAbsolute(this.audioSource.path)
+                ? this.audioSource.path
+                : resolve(process.cwd(), this.audioSource.path),
+            source: this.audioSource,
+        };
     }
 
-            if (this.ffmpegProcess) {
-                this.ffmpegProcess.kill('SIGKILL');
-                this.ffmpegProcess = null;
+    private scheduleRenewal(): void {
+        const renewIntervalMs = this.options.renewIntervalMs;
+
+        if (renewIntervalMs === undefined || renewIntervalMs === false) {
+            return;
         }
 
-            this.pcmStream?.destroy();
-            this.pcmStream = null;
+        this.renewTimer = setTimeout(() => {
+            void this.start().catch((error: unknown) => {
+                if (this.playbackState === 'disposed') {
+                    return;
+                }
 
-            this.audioPlayer = null;
-            this.audioResource = null;
-            this.voiceConnection = null;
-            this.timeout = null;
-            this.Active = null;
-            this.Playing = null;
-            this.connectionData = null;
-            this.audioData = null;
-            this.renewMs = null;
-        } catch {}
+                this.clearRenewTimer();
+                this.stopCurrentPlayback();
+                this.audioPlayer.stop(true);
+                this.connection?.disconnect();
+                this.connection?.destroy();
+                this.connection = undefined;
+                this.playbackState = 'stopped';
+                this.reportError(error);
+            });
+        }, renewIntervalMs);
+
+        if (typeof this.renewTimer.unref === 'function') {
+            this.renewTimer.unref();
+        }
+    }
+
+    private observeConnection(connection: VoiceConnection): void {
+        connection.on('error', (error) => {
+            this.reportError(error);
+        });
+        connection.on(VoiceConnectionStatus.Disconnected, () => this.handleDisconnectedConnection(connection));
+    }
+
+    private async handleDisconnectedConnection(connection: VoiceConnection): Promise<void> {
+        try {
+            await Promise.race([
+                entersState(connection, VoiceConnectionStatus.Signalling, DISCONNECT_RECOVERY_TIMEOUT_MS),
+                entersState(connection, VoiceConnectionStatus.Connecting, DISCONNECT_RECOVERY_TIMEOUT_MS),
+            ]);
+        } catch (error) {
+            if (this.connection !== connection) {
+                return;
+            }
+
+            this.clearRenewTimer();
+            this.stopCurrentPlayback();
+            this.audioPlayer.stop(true);
+            this.connection = undefined;
+            if (connection.state.status !== VoiceConnectionStatus.Destroyed) {
+                connection.destroy();
+            }
+            this.playbackState = 'stopped';
+            this.reportError(error);
+        }
+    }
+
+    private finishPlayback(resource: AudioResource): void {
+        if (this.resource !== resource) {
+            return;
+        }
+
+        this.stopCurrentPlayback();
+        if (this.playbackState !== 'disposed') {
+            this.playbackState = this.isConnected ? 'ready' : 'stopped';
+        }
+    }
+
+    private reportError(error: unknown): void {
+        this.options.onError?.(error instanceof Error ? error : new Error(String(error)));
+    }
+
+    private clearRenewTimer(): void {
+        if (this.renewTimer) {
+            clearTimeout(this.renewTimer);
+            this.renewTimer = undefined;
+        }
+    }
+
+    private cancelConnectAttempt(): void {
+        this.connectAttempt?.abort();
+        this.connectAttempt = undefined;
+    }
+
+    private stopCurrentPlayback(): void {
+        this.resource?.playStream.destroy();
+        this.resource = undefined;
+        this.ffmpeg?.stop();
+        this.ffmpeg = undefined;
+    }
+
+    private assertNotDisposed(): void {
+        if (this.playbackState === 'disposed') {
+            throw new AudioManagerStateError('AudioManager has been disposed.');
+        }
     }
 }

src/errors.ts

@@ -0,0 +1,16 @@
+export class AudioManagerError extends Error {
+    public constructor(message: string, options?: ErrorOptions) {
+        super(message, options);
+        this.name = new.target.name;
+    }
+}
+
+export class AudioManagerConfigError extends AudioManagerError {}
+
+export class AudioManagerStateError extends AudioManagerError {}
+
+export class FfmpegProcessError extends AudioManagerError {
+    public constructor(message: string, cause?: unknown) {
+        super(message, cause === undefined ? undefined : { cause });
+    }
+}

src/ffmpeg.ts

@@ -0,0 +1,169 @@
+import { spawn } from 'node:child_process';
+import type { ChildProcessByStdio } from 'node:child_process';
+import { createRequire } from 'node:module';
+import type { Readable } from 'node:stream';
+
+import { AudioManagerConfigError, FfmpegProcessError } from './errors';
+import type { FfmpegOptions } from './types';
+
+const requireFromCurrentModule = createRequire(__filename);
+
+const DEFAULT_INPUT_ARGS = ['-hide_banner', '-loglevel', 'error', '-nostdin'] as const;
+const DEFAULT_OUTPUT_ARGS = ['-vn', '-f', 's16le', '-ar', '48000', '-ac', '2', 'pipe:1'] as const;
+const FORCE_KILL_TIMEOUT_MS = 2_000;
+const STDERR_TAIL_BYTES = 4_096;
+
+export type FfmpegProcessHandle = {
+    readonly process: ChildProcessByStdio<null, Readable, Readable>;
+    readonly ready: Promise<void>;
+    stop(): void;
+};
+
+export function resolveFfmpegExecutable(options: FfmpegOptions = {}): string {
+    if (options.executablePath?.trim()) {
+        return options.executablePath;
+    }
+
+    if ((options.mode ?? 'native') === 'native') {
+        return 'ffmpeg';
+    }
+
+    try {
+        const executable = requireFromCurrentModule('ffmpeg-static') as unknown;
+
+        if (typeof executable === 'string' && executable.length > 0) {
+            return executable;
+        }
+    } catch (error) {
+        throw new AudioManagerConfigError(
+            'Unable to resolve ffmpeg-static. Install it or pass ffmpeg.executablePath.',
+            { cause: error },
+        );
+    }
+
+    throw new AudioManagerConfigError('ffmpeg-static did not expose an executable path.');
+}
+
+export function startFfmpeg(input: string, options: FfmpegOptions = {}): FfmpegProcessHandle {
+    const executable = resolveFfmpegExecutable(options);
+    const args = [
+        ...(options.inputArgs ?? DEFAULT_INPUT_ARGS),
+        '-i',
+        input,
+        ...(options.outputArgs ?? DEFAULT_OUTPUT_ARGS),
+    ];
+    const childProcess = spawn(executable, args, { stdio: ['ignore', 'pipe', 'pipe'] });
+    const abortController = new AbortController();
+    const ready = waitForFfmpegOutput(childProcess, abortController.signal);
+
+    childProcess.stderr.resume();
+
+    return {
+        process: childProcess,
+        ready,
+        stop: (): void => {
+            stopProcess(childProcess, abortController);
+        },
+    };
+}
+
+function waitForFfmpegOutput(
+    childProcess: ChildProcessByStdio<null, Readable, Readable>,
+    signal: AbortSignal,
+): Promise<void> {
+    const { promise, resolve, reject } = Promise.withResolvers<void>();
+    let stderrTail = '';
+    let settled = false;
+
+    const appendStderr = (chunk: Buffer | string): void => {
+        stderrTail = (stderrTail + String(chunk)).slice(-STDERR_TAIL_BYTES);
+    };
+
+    const cleanup = (): void => {
+        childProcess.off('exit', onExit);
+        childProcess.stdout.off('readable', onReadable);
+        childProcess.stderr.off('data', appendStderr);
+        signal.removeEventListener('abort', onAbort);
+    };
+
+    const settle = (complete: () => void): void => {
+        if (settled) {
+            return;
+        }
+
+        settled = true;
+        cleanup();
+        complete();
+    };
+
+    const fail = (message: string, cause?: unknown): void => {
+        settle(() => reject(new FfmpegProcessError(addStderrTail(message, stderrTail), cause)));
+    };
+
+    const onError = (error: Error): void => {
+        if (!settled) {
+            fail(`Unable to start ffmpeg. Cause: ${error.message}`, error);
+        }
+    };
+
+    const onExit = (code: number | null, exitSignal: NodeJS.Signals | null): void => {
+        fail(`ffmpeg exited before producing audio. Exit code: ${code ?? 'none'}, signal: ${exitSignal ?? 'none'}.`);
+    };
+
+    const onReadable = (): void => {
+        settle(() => resolve());
+    };
+
+    const onAbort = (): void => {
+        const reason: unknown = signal.reason;
+        settle(() =>
+            reject(
+                reason instanceof Error
+                    ? reason
+                    : new FfmpegProcessError('ffmpeg was stopped before producing audio.', reason),
+            ),
+        );
+    };
+
+    childProcess.stderr.on('data', appendStderr);
+    childProcess.on('error', onError);
+    childProcess.once('exit', onExit);
+    childProcess.stdout.once('readable', onReadable);
+    signal.addEventListener('abort', onAbort, { once: true });
+
+    return promise;
+}
+
+function addStderrTail(message: string, stderrTail: string): string {
+    const trimmedTail = stderrTail.trim();
+
+    return trimmedTail ? `${message} stderr: ${trimmedTail}` : message;
+}
+
+function stopProcess(
+    childProcess: ChildProcessByStdio<null, Readable, Readable>,
+    abortController: AbortController,
+): void {
+    if (abortController.signal.aborted) {
+        return;
+    }
+
+    abortController.abort(new FfmpegProcessError('ffmpeg was stopped before producing audio.'));
+    childProcess.stdout.destroy();
+    childProcess.stderr.destroy();
+
+    if (childProcess.exitCode !== null || childProcess.signalCode !== null) {
+        return;
+    }
+
+    childProcess.kill('SIGTERM');
+
+    const forceKillTimeout = setTimeout(() => {
+        if (childProcess.exitCode === null && childProcess.signalCode === null) {
+            childProcess.kill('SIGKILL');
+        }
+    }, FORCE_KILL_TIMEOUT_MS);
+
+    childProcess.once('close', () => clearTimeout(forceKillTimeout));
+    forceKillTimeout.unref();
+}

src/index.ts

@@ -1,2 +1,11 @@
 export { default as AudioManager } from './audio-manager';
-export type { VoiceAudioDataModel, VoiceConnectionDataModel } from './types';
+export { AudioManagerConfigError, AudioManagerError, AudioManagerStateError, FfmpegProcessError } from './errors';
+export type {
+    AudioManagerOptions,
+    AudioSource,
+    FfmpegMode,
+    FfmpegOptions,
+    PlaybackState,
+    VoiceConnectionOptions,
+    VolumeOptions,
+} from './types';

src/types.d.ts

@@ -1,55 +0,0 @@
-import type { DiscordGatewayAdapterCreator } from '@discordjs/voice';
-
-export type VoiceConnectionDataModel = {
-    /**
-     * The ID of the voice channel to connect to.
-     */
-    VoiceChannelId: string;
-
-    /**
-     * The Id of the guild (server) to connect to.
-     */
-    GuildId: string;
-
-    /**
-     * The adapter creator for the voice connection.
-     * Can be archived by the guild instance via the voiceAdapterCreator property.
-     */
-    VoiceAdapter: DiscordGatewayAdapterCreator;
-};
-
-export type VoiceAudioDataModel = {
-    /**
-     * The unique identifier for the audio resource.
-     */
-    ResourceType: 'Link' | 'File';
-
-    /**
-     * The URL or file path of the audio resource.
-     * any is to be assumed to require(filepath)
-     */
-    Resource: string | any;
-};
-
-/**
- * An interface which is implemented in audio manager
- * for a proper Dispose functionality.
- */
-export type IDisposable = {
-    Dispose(): void;
-};
-
-/**
- * An interface to handle instances later on.
- */
-export type IAudioManager = {
-    OverrideVoiceConnectionData(connectionData: VoiceConnectionDataModel): void;
-    OverrideVoiceAudioDataModel(audioData: VoiceAudioDataModel): void;
-    CreateAndPlay(): Promise<void>;
-    CreateConnection(): void;
-    PlayAudio(): Promise<void>;
-    PauseAudio(): void;
-    ResumeAudio(): void;
-    StopConnection(): Promise<void>;
-    SetVolume(volumeInPercent: number): void;
-};

src/types.ts

@@ -0,0 +1,185 @@
+import type { DiscordGatewayAdapterCreator } from '@discordjs/voice';
+
+/**
+ * Strategy used to resolve the ffmpeg executable.
+ *
+ * - `native` uses the `ffmpeg` binary available on the host PATH.
+ * - `static` resolves the optional `ffmpeg-static` package.
+ */
+export type FfmpegMode = 'native' | 'static';
+
+/**
+ * Audio input consumed by ffmpeg.
+ *
+ * URL sources are validated through the built-in `URL` constructor before playback starts.
+ * File sources may be absolute or relative; relative paths are resolved from `process.cwd()`.
+ */
+export type AudioSource =
+    | {
+          /**
+           * Marks this source as a remote URL.
+           */
+          type: 'url';
+
+          /**
+           * Fully qualified audio URL passed to ffmpeg.
+           */
+          url: string;
+      }
+    | {
+          /**
+           * Marks this source as a local file path.
+           */
+          type: 'file';
+
+          /**
+           * Absolute file path or path relative to `process.cwd()`.
+           */
+          path: string;
+      };
+
+/**
+ * Discord voice channel connection settings.
+ */
+export type VoiceConnectionOptions = {
+    /**
+     * Discord guild/server ID.
+     */
+    guildId: string;
+
+    /**
+     * Discord voice channel ID where audio should be played.
+     */
+    channelId: string;
+
+    /**
+     * Discord voice adapter creator, usually `guild.voiceAdapterCreator` from discord.js.
+     */
+    adapterCreator: DiscordGatewayAdapterCreator;
+};
+
+/**
+ * Public playback lifecycle state exposed by `AudioManager.state`.
+ */
+export type PlaybackState = 'idle' | 'connecting' | 'ready' | 'playing' | 'paused' | 'stopped' | 'disposed';
+
+/**
+ * ffmpeg executable and argument configuration.
+ */
+export type FfmpegOptions = {
+    /**
+     * ffmpeg resolution mode.
+     *
+     * @defaultValue `'native'`
+     */
+    mode?: FfmpegMode;
+
+    /**
+     * Explicit ffmpeg executable path.
+     *
+     * When provided, this value takes precedence over `mode`.
+     */
+    executablePath?: string;
+
+    /**
+     * Arguments placed before `-i <source>`.
+     *
+     * Override only when you need full control over ffmpeg input behavior.
+     */
+    inputArgs?: readonly string[];
+
+    /**
+     * Arguments placed after `-i <source>`.
+     *
+     * If overridden, the output must remain compatible with `StreamType.Raw`.
+     */
+    outputArgs?: readonly string[];
+};
+
+/**
+ * Optional inline volume control settings.
+ */
+export type VolumeOptions = {
+    /**
+     * Enables Discord voice inline volume support.
+     *
+     * Disabled by default because inline volume has runtime overhead.
+     *
+     * @defaultValue `false`
+     */
+    enabled?: boolean;
+
+    /**
+     * Initial volume percentage applied when playback starts.
+     *
+     * Must be a finite number from `0` through `100` and requires `enabled: true`.
+     */
+    initialPercent?: number;
+};
+
+/**
+ * Constructor options for `AudioManager`.
+ */
+export type AudioManagerOptions = {
+    /**
+     * ffmpeg executable and argument configuration.
+     */
+    ffmpeg?: FfmpegOptions;
+
+    /**
+     * Initial Discord voice connection settings.
+     *
+     * May also be supplied later through `setConnection()`.
+     */
+    connection?: VoiceConnectionOptions;
+
+    /**
+     * Initial audio source.
+     *
+     * May also be supplied later through `setSource()` or `play(source)`.
+     */
+    source?: AudioSource;
+
+    /**
+     * Milliseconds after which the manager reconnects and restarts playback.
+     *
+     * Renewal is disabled unless an interval is provided.
+     * Numeric values must be integers from `1` through `2_147_483_647`.
+     *
+     * @defaultValue `false`
+     */
+    renewIntervalMs?: number | false;
+
+    /**
+     * Maximum milliseconds to wait for the Discord voice connection to become ready.
+     * Must be an integer from `1` through `2_147_483_647`.
+     *
+     * @defaultValue `20_000`
+     */
+    connectTimeoutMs?: number;
+
+    /**
+     * Receives asynchronous audio player and voice connection errors.
+     */
+    onError?: (error: Error) => void;
+
+    /**
+     * Optional inline volume configuration.
+     */
+    volume?: VolumeOptions;
+};
+
+/**
+ * Internal normalized audio source passed to ffmpeg.
+ */
+export type ResolvedAudioSource = {
+    /**
+     * Validated URL or absolute file path passed as ffmpeg input.
+     */
+    input: string;
+
+    /**
+     * Original source configuration.
+     */
+    source: AudioSource;
+};

tests/audio-manager.test.ts

@@ -0,0 +1,826 @@
+import { jest, describe, beforeEach, afterEach, it, expect } from '@jest/globals';
+import {
+    AudioPlayerStatus,
+    createAudioPlayer,
+    createAudioResource,
+    entersState,
+    joinVoiceChannel,
+    VoiceConnectionStatus,
+} from '@discordjs/voice';
+import { resolve } from 'node:path';
+import { PassThrough } from 'node:stream';
+
+import AudioManager from '../src/audio-manager';
+import { AudioManagerConfigError, AudioManagerStateError, FfmpegProcessError } from '../src';
+import { startFfmpeg } from '../src/ffmpeg';
+import type { FfmpegProcessHandle } from '../src/ffmpeg';
+import type { AudioSource, VoiceConnectionOptions } from '../src';
+import type { VoiceConnection } from '@discordjs/voice';
+
+type MockListener = (...args: unknown[]) => unknown;
+
+const audioPlayerListeners = new Map<string, MockListener>();
+const connectionListeners = new Map<string, MockListener>();
+const secondConnectionListeners = new Map<string, MockListener>();
+const mockAudioPlayer = {
+    on: jest.fn((event: string, listener: MockListener) => {
+        audioPlayerListeners.set(event, listener);
+        return mockAudioPlayer;
+    }),
+    play: jest.fn(),
+    pause: jest.fn(),
+    unpause: jest.fn(),
+    stop: jest.fn(),
+};
+const mockConnection = {
+    state: { status: 'ready' },
+    on: jest.fn((event: string, listener: MockListener) => {
+        connectionListeners.set(event, listener);
+        return mockConnection;
+    }),
+    subscribe: jest.fn(),
+    disconnect: jest.fn(),
+    destroy: jest.fn(),
+};
+const mockSecondConnection = {
+    state: { status: 'ready' },
+    on: jest.fn((event: string, listener: MockListener) => {
+        secondConnectionListeners.set(event, listener);
+        return mockSecondConnection;
+    }),
+    subscribe: jest.fn(),
+    disconnect: jest.fn(),
+    destroy: jest.fn(),
+};
+const mockVoiceConnection = mockConnection as unknown as VoiceConnection;
+const mockSecondVoiceConnection = mockSecondConnection as unknown as VoiceConnection;
+const mockAudioResource = {
+    playStream: {
+        destroy: jest.fn(),
+    },
+    volume: {
+        setVolume: jest.fn(),
+    },
+};
+const mockFfmpegHandle: FfmpegProcessHandle = {
+    process: {
+        stdout: new PassThrough(),
+    } as unknown as FfmpegProcessHandle['process'],
+    ready: Promise.resolve(),
+    stop: jest.fn(),
+};
+
+jest.mock('@discordjs/voice', () => ({
+    AudioPlayerStatus: {
+        Idle: 'idle',
+    },
+    NoSubscriberBehavior: {
+        Play: 'play',
+    },
+    StreamType: {
+        Raw: 'raw',
+    },
+    VoiceConnectionStatus: {
+        Connecting: 'connecting',
+        Destroyed: 'destroyed',
+        Disconnected: 'disconnected',
+        Ready: 'ready',
+        Signalling: 'signalling',
+    },
+    createAudioPlayer: jest.fn(() => mockAudioPlayer),
+    createAudioResource: jest.fn(() => mockAudioResource),
+    entersState: jest.fn(() => Promise.resolve(mockVoiceConnection)),
+    joinVoiceChannel: jest.fn(() => mockVoiceConnection),
+}));
+
+jest.mock('../src/ffmpeg', () => ({
+    startFfmpeg: jest.fn(() => mockFfmpegHandle),
+}));
+
+const connectionOptions: VoiceConnectionOptions = {
+    guildId: 'guild-id',
+    channelId: 'channel-id',
+    adapterCreator: jest.fn() as unknown as VoiceConnectionOptions['adapterCreator'],
+};
+
+const liveStreamSource: AudioSource = {
+    type: 'url',
+    url: 'https://synradiode.stream.laut.fm/synradiode',
+};
+
+const fileSourcePath = 'tests/audio.mp3';
+const resolvedFileSourcePath = resolve(process.cwd(), fileSourcePath);
+type MockedEntersStateReturn = ReturnType<typeof entersState>;
+
+function createMockFfmpegHandle(): FfmpegProcessHandle {
+    return {
+        process: {
+            stdout: new PassThrough(),
+        } as unknown as FfmpegProcessHandle['process'],
+        ready: Promise.resolve(),
+        stop: jest.fn(),
+    };
+}
+
+function listenerFor(listeners: Map<string, MockListener>, event: string): MockListener {
+    const listener = listeners.get(event);
+
+    if (!listener) {
+        throw new Error(`No listener registered for ${event}.`);
+    }
+
+    return listener;
+}
+
+describe('AudioManager', () => {
+    beforeEach(() => {
+        jest.clearAllMocks();
+        audioPlayerListeners.clear();
+        connectionListeners.clear();
+        secondConnectionListeners.clear();
+        mockConnection.state.status = VoiceConnectionStatus.Ready;
+        mockSecondConnection.state.status = VoiceConnectionStatus.Ready;
+    });
+
+    afterEach(() => {
+        jest.useRealTimers();
+    });
+
+    it('requires connection options before connecting', async () => {
+        const manager = new AudioManager({ renewIntervalMs: false });
+
+        await expect(manager.connect()).rejects.toThrow(AudioManagerConfigError);
+    });
+
+    it('connects and starts playback with resolved URL source', async () => {
+        const manager = new AudioManager({
+            connection: connectionOptions,
+            source: liveStreamSource,
+            renewIntervalMs: false,
+        });
+
+        await manager.start();
+
+        expect(manager.state).toBe('playing');
+        expect(manager.isConnected).toBe(true);
+        expect(manager.isPlaying).toBe(true);
+        expect(mockConnection.subscribe).toHaveBeenCalledWith(mockAudioPlayer);
+        expect(startFfmpeg).toHaveBeenCalledWith('https://synradiode.stream.laut.fm/synradiode', undefined);
+        expect(mockAudioPlayer.play).toHaveBeenCalledWith(mockAudioResource);
+    });
+
+    it('does not schedule connection renewal by default', async () => {
+        jest.useFakeTimers();
+        const manager = new AudioManager({ connection: connectionOptions });
+
+        await manager.connect();
+
+        expect(jest.getTimerCount()).toBe(0);
+        manager.dispose();
+    });
+
+    it('reports voice connection errors without interrupting playback', async () => {
+        const connectionError = new Error('voice connection failed');
+        const onError = jest.fn();
+        const manager = new AudioManager({
+            connection: connectionOptions,
+            source: liveStreamSource,
+            renewIntervalMs: false,
+            onError,
+        });
+        await manager.start();
+
+        listenerFor(connectionListeners, 'error')(connectionError);
+
+        expect(onError).toHaveBeenCalledWith(connectionError);
+        expect(manager.state).toBe('playing');
+    });
+
+    it('keeps playback while a disconnected voice connection recovers', async () => {
+        const manager = new AudioManager({
+            connection: connectionOptions,
+            source: liveStreamSource,
+            renewIntervalMs: false,
+        });
+        await manager.start();
+
+        await listenerFor(connectionListeners, VoiceConnectionStatus.Disconnected)();
+
+        expect(entersState).toHaveBeenCalledWith(mockVoiceConnection, VoiceConnectionStatus.Signalling, 5_000);
+        expect(entersState).toHaveBeenCalledWith(mockVoiceConnection, VoiceConnectionStatus.Connecting, 5_000);
+        expect(mockConnection.destroy).not.toHaveBeenCalled();
+        expect(manager.state).toBe('playing');
+    });
+
+    it('stops playback after an unrecoverable voice disconnect', async () => {
+        const disconnectError = new Error('voice connection did not recover');
+        const onError = jest.fn();
+        const manager = new AudioManager({
+            connection: connectionOptions,
+            source: liveStreamSource,
+            renewIntervalMs: false,
+            onError,
+        });
+        await manager.start();
+        jest.mocked(entersState).mockRejectedValueOnce(disconnectError).mockRejectedValueOnce(disconnectError);
+        mockConnection.state.status = VoiceConnectionStatus.Disconnected;
+
+        await listenerFor(connectionListeners, VoiceConnectionStatus.Disconnected)();
+
+        expect(mockFfmpegHandle.stop).toHaveBeenCalledTimes(1);
+        expect(mockAudioPlayer.stop).toHaveBeenCalledWith(true);
+        expect(mockConnection.destroy).toHaveBeenCalledTimes(1);
+        expect(onError).toHaveBeenCalledWith(disconnectError);
+        expect(manager.state).toBe('stopped');
+        expect(manager.isConnected).toBe(false);
+    });
+
+    it('cleans up when connection startup fails', async () => {
+        jest.useFakeTimers();
+
+        const manager = new AudioManager({
+            connection: connectionOptions,
+            renewIntervalMs: 10_000,
+        });
+        jest.mocked(entersState).mockRejectedValueOnce(new Error('voice connection timeout'));
+
+        await expect(manager.connect()).rejects.toThrow('voice connection timeout');
+
+        expect(manager.state).toBe('stopped');
+        expect(manager.isConnected).toBe(false);
+        expect(mockConnection.subscribe).toHaveBeenCalledWith(mockAudioPlayer);
+        expect(mockConnection.destroy).toHaveBeenCalledTimes(1);
+        expect(jest.getTimerCount()).toBe(0);
+    });
+
+    it('restores the stopped state when voice setup throws synchronously', async () => {
+        const connectionError = new Error('voice setup failed');
+        jest.mocked(joinVoiceChannel).mockImplementationOnce(() => {
+            throw connectionError;
+        });
+        const manager = new AudioManager({ connection: connectionOptions, renewIntervalMs: false });
+
+        await expect(manager.connect()).rejects.toBe(connectionError);
+
+        expect(manager.state).toBe('stopped');
+        expect(manager.isConnected).toBe(false);
+    });
+
+    it('does not become ready when stopped during connection startup', async () => {
+        jest.useFakeTimers();
+        const ready = Promise.withResolvers<VoiceConnection>();
+        jest.mocked(entersState).mockReturnValueOnce(ready.promise as unknown as MockedEntersStateReturn);
+        const manager = new AudioManager({
+            connection: connectionOptions,
+            renewIntervalMs: 10_000,
+        });
+
+        const connectPromise = manager.connect();
+        await manager.stop();
+        ready.resolve(mockVoiceConnection);
+
+        await expect(connectPromise).rejects.toThrow(AudioManagerStateError);
+
+        expect(manager.state).toBe('stopped');
+        expect(manager.isConnected).toBe(false);
+        expect(jest.getTimerCount()).toBe(0);
+    });
+
+    it('keeps the latest connection when a stale connection attempt rejects', async () => {
+        const firstReady = Promise.withResolvers<VoiceConnection>();
+        const secondReady = Promise.withResolvers<VoiceConnection>();
+        jest.mocked(joinVoiceChannel)
+            .mockReturnValueOnce(mockVoiceConnection)
+            .mockReturnValueOnce(mockSecondVoiceConnection);
+        jest.mocked(entersState)
+            .mockReturnValueOnce(firstReady.promise as unknown as MockedEntersStateReturn)
+            .mockReturnValueOnce(secondReady.promise as unknown as MockedEntersStateReturn);
+        const manager = new AudioManager({
+            connection: connectionOptions,
+            renewIntervalMs: false,
+        });
+
+        const firstConnect = manager.connect();
+        const secondConnect = manager.connect();
+        firstReady.reject(new Error('stale connection failed'));
+        secondReady.resolve(mockSecondVoiceConnection);
+
+        await expect(firstConnect).rejects.toThrow(AudioManagerStateError);
+        await expect(secondConnect).resolves.toBeUndefined();
+
+        expect(manager.state).toBe('ready');
+        expect(manager.isConnected).toBe(true);
+        expect(mockConnection.destroy).toHaveBeenCalledTimes(1);
+        expect(mockSecondConnection.destroy).not.toHaveBeenCalled();
+    });
+
+    it('does not become ready when disposed during connection startup', async () => {
+        const ready = Promise.withResolvers<VoiceConnection>();
+        jest.mocked(entersState).mockReturnValueOnce(ready.promise as unknown as MockedEntersStateReturn);
+        const manager = new AudioManager({
+            connection: connectionOptions,
+            renewIntervalMs: false,
+        });
+
+        const connectPromise = manager.connect();
+        manager.dispose();
+        ready.reject(new Error('disposed connection failed'));
+
+        await expect(connectPromise).rejects.toThrow(AudioManagerStateError);
+
+        expect(manager.state).toBe('disposed');
+        expect(manager.isConnected).toBe(false);
+        expect(mockConnection.destroy).toHaveBeenCalledTimes(1);
+    });
+
+    it('starts playback with the committed mp3 test file', async () => {
+        const manager = new AudioManager({
+            connection: connectionOptions,
+            source: {
+                type: 'file',
+                path: fileSourcePath,
+            },
+            renewIntervalMs: false,
+        });
+
+        await manager.start();
+
+        expect(startFfmpeg).toHaveBeenCalledWith(resolvedFileSourcePath, undefined);
+        expect(mockAudioPlayer.play).toHaveBeenCalledWith(mockAudioResource);
+    });
+
+    it('accepts the live stream URL as a valid source', async () => {
+        const manager = new AudioManager({
+            connection: connectionOptions,
+            source: liveStreamSource,
+            renewIntervalMs: false,
+        });
+
+        await manager.connect();
+        await manager.play();
+
+        expect(startFfmpeg).toHaveBeenCalledWith('https://synradiode.stream.laut.fm/synradiode', undefined);
+    });
+
+    it('plays a source passed directly to play()', async () => {
+        const manager = new AudioManager({
+            connection: connectionOptions,
+            renewIntervalMs: false,
+        });
+
+        await manager.connect();
+        await manager.play({
+            type: 'file',
+            path: fileSourcePath,
+        });
+
+        expect(startFfmpeg).toHaveBeenCalledWith(resolvedFileSourcePath, undefined);
+        expect(manager.state).toBe('playing');
+    });
+
+    it('does not report playback when ffmpeg startup fails', async () => {
+        const startupError = new FfmpegProcessError('Unable to start ffmpeg.');
+        jest.mocked(startFfmpeg).mockReturnValueOnce({
+            ...mockFfmpegHandle,
+            ready: Promise.reject(startupError),
+        });
+        const manager = new AudioManager({
+            connection: connectionOptions,
+            source: liveStreamSource,
+            renewIntervalMs: false,
+        });
+
+        await manager.connect();
+        await expect(manager.play()).rejects.toBe(startupError);
+
+        expect(manager.state).toBe('ready');
+        expect(mockAudioPlayer.play).not.toHaveBeenCalled();
+        expect(mockFfmpegHandle.stop).toHaveBeenCalledTimes(1);
+    });
+
+    it('cleans up when audio resource creation fails', async () => {
+        const resourceError = new Error('resource failed');
+        jest.mocked(createAudioResource).mockImplementationOnce(() => {
+            throw resourceError;
+        });
+        const manager = new AudioManager({
+            connection: connectionOptions,
+            source: liveStreamSource,
+            renewIntervalMs: false,
+        });
+
+        await manager.connect();
+        await expect(manager.play()).rejects.toBe(resourceError);
+
+        expect(manager.state).toBe('ready');
+        expect(mockFfmpegHandle.stop).toHaveBeenCalledTimes(1);
+        expect(mockAudioPlayer.play).not.toHaveBeenCalled();
+    });
+
+    it('cleans up when the audio player rejects playback', async () => {
+        const playerError = new Error('player failed');
+        mockAudioPlayer.play.mockImplementationOnce(() => {
+            throw playerError;
+        });
+        const manager = new AudioManager({
+            connection: connectionOptions,
+            source: liveStreamSource,
+            renewIntervalMs: false,
+        });
+
+        await manager.connect();
+        await expect(manager.play()).rejects.toBe(playerError);
+
+        expect(manager.state).toBe('ready');
+        expect(mockFfmpegHandle.stop).toHaveBeenCalledTimes(1);
+        expect(mockAudioResource.playStream.destroy).toHaveBeenCalledTimes(1);
+    });
+
+    it('cleans up and reports asynchronous audio player errors', async () => {
+        const playerError = Object.assign(new Error('audio stream failed'), { resource: mockAudioResource });
+        const onError = jest.fn();
+        const manager = new AudioManager({
+            connection: connectionOptions,
+            source: liveStreamSource,
+            renewIntervalMs: false,
+            onError,
+        });
+        await manager.start();
+
+        listenerFor(audioPlayerListeners, 'error')(playerError);
+
+        expect(mockFfmpegHandle.stop).toHaveBeenCalledTimes(1);
+        expect(mockAudioResource.playStream.destroy).toHaveBeenCalledTimes(1);
+        expect(onError).toHaveBeenCalledWith(playerError);
+        expect(manager.state).toBe('ready');
+        expect(manager.isPlaying).toBe(false);
+    });
+
+    it('returns to ready when the current audio resource becomes idle', async () => {
+        const manager = new AudioManager({
+            connection: connectionOptions,
+            source: liveStreamSource,
+            renewIntervalMs: false,
+        });
+        await manager.start();
+
+        listenerFor(audioPlayerListeners, AudioPlayerStatus.Idle)({ resource: mockAudioResource });
+
+        expect(mockFfmpegHandle.stop).toHaveBeenCalledTimes(1);
+        expect(mockAudioResource.playStream.destroy).toHaveBeenCalledTimes(1);
+        expect(manager.state).toBe('ready');
+        expect(manager.isPlaying).toBe(false);
+    });
+
+    it('does not report playback when stopped before ffmpeg is ready', async () => {
+        const ready = Promise.withResolvers<void>();
+        jest.mocked(startFfmpeg).mockReturnValueOnce({
+            ...mockFfmpegHandle,
+            ready: ready.promise,
+        });
+        const manager = new AudioManager({
+            connection: connectionOptions,
+            source: liveStreamSource,
+            renewIntervalMs: false,
+        });
+
+        await manager.connect();
+        const playPromise = manager.play();
+        await manager.stop();
+        ready.resolve();
+
+        await expect(playPromise).rejects.toThrow(AudioManagerStateError);
+
+        expect(manager.state).toBe('stopped');
+        expect(mockAudioPlayer.play).not.toHaveBeenCalled();
+    });
+
+    it('does not report playback when disposed before ffmpeg is ready', async () => {
+        const ready = Promise.withResolvers<void>();
+        jest.mocked(startFfmpeg).mockReturnValueOnce({
+            ...mockFfmpegHandle,
+            ready: ready.promise,
+        });
+        const manager = new AudioManager({
+            connection: connectionOptions,
+            source: liveStreamSource,
+            renewIntervalMs: false,
+        });
+
+        await manager.connect();
+        const playPromise = manager.play();
+        manager.dispose();
+        ready.resolve();
+
+        await expect(playPromise).rejects.toThrow(AudioManagerStateError);
+
+        expect(manager.state).toBe('disposed');
+        expect(mockAudioPlayer.play).not.toHaveBeenCalled();
+    });
+
+    it('keeps only the latest concurrent playback', async () => {
+        const firstReady = Promise.withResolvers<void>();
+        const firstHandle = {
+            ...createMockFfmpegHandle(),
+            ready: firstReady.promise,
+        };
+        const secondHandle = createMockFfmpegHandle();
+        jest.mocked(startFfmpeg).mockReturnValueOnce(firstHandle).mockReturnValueOnce(secondHandle);
+        const manager = new AudioManager({
+            connection: connectionOptions,
+            source: liveStreamSource,
+            renewIntervalMs: false,
+        });
+
+        await manager.connect();
+        const firstPlay = manager.play();
+        const secondPlay = manager.play({ type: 'file', path: fileSourcePath });
+        firstReady.resolve();
+
+        await expect(firstPlay).rejects.toThrow(AudioManagerStateError);
+        await expect(secondPlay).resolves.toBeUndefined();
+
+        expect(manager.state).toBe('playing');
+        expect(mockAudioPlayer.play).toHaveBeenCalledTimes(1);
+        expect(firstHandle.stop).toHaveBeenCalledTimes(1);
+        expect(secondHandle.stop).not.toHaveBeenCalled();
+    });
+
+    it('replaces active playback when a new source is played', async () => {
+        const manager = new AudioManager({
+            connection: connectionOptions,
+            source: liveStreamSource,
+            renewIntervalMs: false,
+        });
+
+        await manager.start();
+        await manager.play({
+            type: 'file',
+            path: fileSourcePath,
+        });
+
+        expect(mockFfmpegHandle.stop).toHaveBeenCalledTimes(1);
+        expect(mockAudioResource.playStream.destroy).toHaveBeenCalledTimes(1);
+        expect(startFfmpeg).toHaveBeenLastCalledWith(resolvedFileSourcePath, undefined);
+    });
+
+    it('requires an active connection before play()', async () => {
+        const manager = new AudioManager({
+            source: liveStreamSource,
+            renewIntervalMs: false,
+        });
+
+        await expect(manager.play()).rejects.toThrow(AudioManagerStateError);
+    });
+
+    it('requires a source before play()', async () => {
+        const manager = new AudioManager({
+            connection: connectionOptions,
+            renewIntervalMs: false,
+        });
+
+        await manager.connect();
+
+        await expect(manager.play()).rejects.toThrow(AudioManagerConfigError);
+    });
+
+    it('rejects invalid URL sources', async () => {
+        const manager = new AudioManager({
+            connection: connectionOptions,
+            source: {
+                type: 'url',
+                url: 'not a url',
+            },
+            renewIntervalMs: false,
+        });
+
+        await manager.connect();
+
+        await expect(manager.play()).rejects.toThrow(AudioManagerConfigError);
+    });
+
+    it('applies initial volume only when volume support is enabled', async () => {
+        const manager = new AudioManager({
+            connection: connectionOptions,
+            source: liveStreamSource,
+            renewIntervalMs: false,
+            volume: {
+                enabled: true,
+                initialPercent: 35,
+            },
+        });
+
+        await manager.start();
+
+        expect(mockAudioResource.volume.setVolume).toHaveBeenCalledWith(0.35);
+    });
+
+    it('rejects invalid initial volume before allocating audio resources', () => {
+        expect(
+            () =>
+                new AudioManager({
+                    volume: {
+                        enabled: true,
+                        initialPercent: 101,
+                    },
+                }),
+        ).toThrow(AudioManagerConfigError);
+        expect(
+            () =>
+                new AudioManager({
+                    volume: {
+                        enabled: false,
+                        initialPercent: 50,
+                    },
+                }),
+        ).toThrow(AudioManagerConfigError);
+
+        expect(createAudioPlayer).not.toHaveBeenCalled();
+        expect(createAudioResource).not.toHaveBeenCalled();
+        expect(startFfmpeg).not.toHaveBeenCalled();
+    });
+
+    it('rejects timer delays that Node.js cannot schedule safely', () => {
+        expect(() => new AudioManager({ connectTimeoutMs: 0 })).toThrow(AudioManagerConfigError);
+        expect(() => new AudioManager({ renewIntervalMs: 2_147_483_648 })).toThrow(AudioManagerConfigError);
+    });
+
+    it('rejects volume changes when inline volume is disabled', () => {
+        const manager = new AudioManager({ renewIntervalMs: false });
+
+        expect(() => manager.setVolume(50)).toThrow(AudioManagerStateError);
+    });
+
+    it('rejects invalid volume percentages', async () => {
+        const manager = new AudioManager({
+            connection: connectionOptions,
+            source: liveStreamSource,
+            renewIntervalMs: false,
+            volume: {
+                enabled: true,
+            },
+        });
+
+        await manager.start();
+
+        expect(() => manager.setVolume(-1)).toThrow(AudioManagerConfigError);
+        expect(() => manager.setVolume(101)).toThrow(AudioManagerConfigError);
+        expect(() => manager.setVolume(Number.NaN)).toThrow(AudioManagerConfigError);
+        expect(() => manager.setVolume(Number.POSITIVE_INFINITY)).toThrow(AudioManagerConfigError);
+        expect(() => manager.setVolume(Number.NEGATIVE_INFINITY)).toThrow(AudioManagerConfigError);
+        expect(() => manager.setVolume(0)).not.toThrow();
+        expect(() => manager.setVolume(42)).not.toThrow();
+        expect(() => manager.setVolume(100)).not.toThrow();
+    });
+
+    it('rejects volume changes before any resource exists', () => {
+        const manager = new AudioManager({
+            renewIntervalMs: false,
+            volume: {
+                enabled: true,
+            },
+        });
+
+        expect(() => manager.setVolume(50)).toThrow(AudioManagerStateError);
+    });
+
+    it('pauses and resumes only from valid playback states', async () => {
+        const manager = new AudioManager({
+            connection: connectionOptions,
+            source: liveStreamSource,
+            renewIntervalMs: false,
+        });
+
+        expect(() => manager.pause()).toThrow(AudioManagerStateError);
+
+        await manager.start();
+        manager.pause();
+        manager.resume();
+
+        expect(mockAudioPlayer.pause).toHaveBeenCalledTimes(1);
+        expect(mockAudioPlayer.unpause).toHaveBeenCalledTimes(1);
+        expect(manager.state).toBe('playing');
+    });
+
+    it('stops playback and voice resources idempotently', async () => {
+        const manager = new AudioManager({
+            connection: connectionOptions,
+            source: liveStreamSource,
+            renewIntervalMs: false,
+        });
+
+        await manager.start();
+        await manager.stop();
+        await manager.stop();
+
+        expect(mockFfmpegHandle.stop).toHaveBeenCalledTimes(1);
+        expect(mockAudioResource.playStream.destroy).toHaveBeenCalledTimes(1);
+        expect(mockConnection.destroy).toHaveBeenCalled();
+        expect(manager.state).toBe('stopped');
+    });
+
+    it('rejects pause and resume after stop', async () => {
+        const manager = new AudioManager({
+            connection: connectionOptions,
+            source: liveStreamSource,
+            renewIntervalMs: false,
+        });
+
+        await manager.start();
+        await manager.stop();
+
+        expect(() => manager.pause()).toThrow(AudioManagerStateError);
+        expect(() => manager.resume()).toThrow(AudioManagerStateError);
+    });
+
+    it('restarts playback when the renewal timer fires', async () => {
+        jest.useFakeTimers();
+
+        const manager = new AudioManager({
+            connection: connectionOptions,
+            source: liveStreamSource,
+            renewIntervalMs: 10_000,
+        });
+        const startSpy = jest.spyOn(manager, 'start').mockResolvedValue(undefined);
+
+        await manager.connect();
+        jest.advanceTimersByTime(10_000);
+        await Promise.resolve();
+
+        expect(startSpy).toHaveBeenCalledTimes(1);
+    });
+
+    it('cleans up when renewal restart fails', async () => {
+        jest.useFakeTimers();
+
+        const manager = new AudioManager({
+            connection: connectionOptions,
+            source: liveStreamSource,
+            renewIntervalMs: 10_000,
+        });
+        const startSpy = jest.spyOn(manager, 'start').mockRejectedValue(new Error('renewal failed'));
+
+        await manager.connect();
+        jest.advanceTimersByTime(10_000);
+        await Promise.resolve();
+
+        expect(startSpy).toHaveBeenCalledTimes(1);
+        expect(mockAudioPlayer.stop).toHaveBeenCalledWith(true);
+        expect(mockConnection.destroy).toHaveBeenCalled();
+        expect(manager.state).toBe('stopped');
+        expect(jest.getTimerCount()).toBe(0);
+    });
+
+    it('clears existing renewal timer before reconnecting', async () => {
+        jest.useFakeTimers();
+
+        const manager = new AudioManager({
+            connection: connectionOptions,
+            source: liveStreamSource,
+            renewIntervalMs: 10_000,
+        });
+
+        await manager.connect();
+        await manager.connect();
+
+        expect(jest.getTimerCount()).toBe(1);
+        manager.dispose();
+        expect(jest.getTimerCount()).toBe(0);
+    });
+
+    it('blocks source and connection changes after disposal', async () => {
+        const manager = new AudioManager({
+            connection: connectionOptions,
+            source: liveStreamSource,
+            renewIntervalMs: false,
+        });
+
+        manager.dispose();
+
+        expect(() => manager.setSource(liveStreamSource)).toThrow(AudioManagerStateError);
+        expect(() => manager.setConnection(connectionOptions)).toThrow(AudioManagerStateError);
+    });
+
+    it('supports explicit resource management', () => {
+        const manager = (() => {
+            using disposableManager = new AudioManager({ renewIntervalMs: false });
+            return disposableManager;
+        })();
+
+        expect(manager.state).toBe('disposed');
+    });
+
+    it('prevents use after disposal', async () => {
+        const manager = new AudioManager({
+            connection: connectionOptions,
+            source: liveStreamSource,
+            renewIntervalMs: false,
+        });
+
+        await manager.start();
+        manager.dispose();
+
+        expect(() => manager.pause()).toThrow(AudioManagerStateError);
+        expect(manager.state).toBe('disposed');
+    });
+});

tests/ffmpeg.test.ts

@@ -0,0 +1,246 @@
+import { jest, describe, beforeEach, afterEach, it, expect } from '@jest/globals';
+import { spawn } from 'node:child_process';
+import type { ChildProcess } from 'node:child_process';
+
+import { FfmpegProcessError } from '../src';
+import { resolveFfmpegExecutable, startFfmpeg } from '../src/ffmpeg';
+
+jest.mock('node:child_process', () => ({
+    spawn: jest.fn(),
+}));
+
+const mockSpawn = jest.mocked(spawn);
+
+type MockChildProcess = {
+    stdout: {
+        destroy: jest.Mock;
+        once: jest.Mock;
+        off: jest.Mock;
+    };
+    stderr: {
+        destroy: jest.Mock;
+        on: jest.Mock;
+        off: jest.Mock;
+        resume: jest.Mock;
+    };
+    on: jest.Mock;
+    once: jest.Mock;
+    off: jest.Mock;
+    kill: jest.Mock;
+    killed: boolean;
+    exitCode: number | null;
+    signalCode: NodeJS.Signals | null;
+};
+
+function createMockChildProcess(): MockChildProcess {
+    return {
+        stdout: {
+            destroy: jest.fn(),
+            once: jest.fn(),
+            off: jest.fn(),
+        },
+        stderr: {
+            destroy: jest.fn(),
+            on: jest.fn(),
+            off: jest.fn(),
+            resume: jest.fn(),
+        },
+        on: jest.fn(),
+        once: jest.fn(),
+        off: jest.fn(),
+        kill: jest.fn(),
+        killed: false,
+        exitCode: null,
+        signalCode: null,
+    };
+}
+
+function mockSpawnReturn(childProcess: MockChildProcess): void {
+    mockSpawn.mockReturnValue(childProcess as unknown as ChildProcess);
+}
+
+function getProcessHandler(childProcess: MockChildProcess, eventName: string): (...args: unknown[]) => void {
+    return childProcess.once.mock.calls.find(([event]) => event === eventName)?.[1] as (...args: unknown[]) => void;
+}
+
+function getPersistentProcessHandler(childProcess: MockChildProcess, eventName: string): (...args: unknown[]) => void {
+    return childProcess.on.mock.calls.find(([event]) => event === eventName)?.[1] as (...args: unknown[]) => void;
+}
+
+function getStdoutHandler(childProcess: MockChildProcess, eventName: string): (...args: unknown[]) => void {
+    return childProcess.stdout.once.mock.calls.find(([event]) => event === eventName)?.[1] as (
+        ...args: unknown[]
+    ) => void;
+}
+
+function getStderrHandler(childProcess: MockChildProcess, eventName: string): (...args: unknown[]) => void {
+    return childProcess.stderr.on.mock.calls.find(([event]) => event === eventName)?.[1] as (
+        ...args: unknown[]
+    ) => void;
+}
+
+describe('ffmpeg helpers', () => {
+    beforeEach(() => {
+        jest.clearAllMocks();
+    });
+
+    afterEach(() => {
+        jest.useRealTimers();
+    });
+
+    it('prefers an explicit executable path', () => {
+        expect(resolveFfmpegExecutable({ executablePath: '/custom/ffmpeg' })).toBe('/custom/ffmpeg');
+    });
+
+    it('uses the native ffmpeg binary by default', () => {
+        expect(resolveFfmpegExecutable()).toBe('ffmpeg');
+        expect(resolveFfmpegExecutable({ mode: 'native' })).toBe('ffmpeg');
+    });
+
+    it('spawns ffmpeg with the default argument set', () => {
+        const childProcess = createMockChildProcess();
+        mockSpawnReturn(childProcess);
+
+        startFfmpeg('https://synradiode.stream.laut.fm/synradiode');
+
+        expect(mockSpawn).toHaveBeenCalledWith(
+            'ffmpeg',
+            [
+                '-hide_banner',
+                '-loglevel',
+                'error',
+                '-nostdin',
+                '-i',
+                'https://synradiode.stream.laut.fm/synradiode',
+                '-vn',
+                '-f',
+                's16le',
+                '-ar',
+                '48000',
+                '-ac',
+                '2',
+                'pipe:1',
+            ],
+            { stdio: ['ignore', 'pipe', 'pipe'] },
+        );
+        expect(childProcess.on).toHaveBeenCalledWith('error', expect.any(Function));
+        expect(childProcess.once).toHaveBeenCalledWith('exit', expect.any(Function));
+        expect(childProcess.stdout.once).toHaveBeenCalledWith('readable', expect.any(Function));
+        expect(childProcess.stderr.on).toHaveBeenCalledWith('data', expect.any(Function));
+        expect(childProcess.stderr.resume).toHaveBeenCalledTimes(1);
+    });
+
+    it('rejects readiness when ffmpeg startup emits an error', async () => {
+        const childProcess = createMockChildProcess();
+        mockSpawnReturn(childProcess);
+
+        const handle = startFfmpeg('tests/audio.mp3');
+        const errorHandler = getPersistentProcessHandler(childProcess, 'error');
+        const spawnError = new Error('spawn ENOENT');
+
+        errorHandler(spawnError);
+
+        await expect(handle.ready).rejects.toMatchObject({
+            cause: spawnError,
+            message: expect.stringContaining('spawn ENOENT'),
+            name: FfmpegProcessError.name,
+        });
+    });
+
+    it('includes stderr when ffmpeg exits before producing audio', async () => {
+        const childProcess = createMockChildProcess();
+        mockSpawnReturn(childProcess);
+
+        const handle = startFfmpeg('tests/audio.mp3');
+        const stderrHandler = getStderrHandler(childProcess, 'data');
+        const exitHandler = getProcessHandler(childProcess, 'exit');
+
+        stderrHandler('invalid input');
+        exitHandler(1, null);
+
+        await expect(handle.ready).rejects.toThrow('invalid input');
+    });
+
+    it('keeps the useful tail of long ffmpeg stderr output', async () => {
+        const childProcess = createMockChildProcess();
+        mockSpawnReturn(childProcess);
+
+        const handle = startFfmpeg('tests/audio.mp3');
+        const stderrHandler = getStderrHandler(childProcess, 'data');
+        const exitHandler = getProcessHandler(childProcess, 'exit');
+
+        stderrHandler(`${'x'.repeat(5_000)}final diagnostic`);
+        exitHandler(1, null);
+
+        await expect(handle.ready).rejects.toThrow('final diagnostic');
+    });
+
+    it('keeps readiness resolved when ffmpeg exits after producing audio', async () => {
+        const childProcess = createMockChildProcess();
+        mockSpawnReturn(childProcess);
+
+        const handle = startFfmpeg('tests/audio.mp3');
+        const readableHandler = getStdoutHandler(childProcess, 'readable');
+        const exitHandler = getProcessHandler(childProcess, 'exit');
+        const errorHandler = getPersistentProcessHandler(childProcess, 'error');
+
+        readableHandler();
+        errorHandler(new Error('late process error'));
+        exitHandler(1, null);
+
+        await expect(handle.ready).resolves.toBeUndefined();
+    });
+
+    it('uses custom executable and argument overrides when provided', () => {
+        const childProcess = createMockChildProcess();
+        mockSpawnReturn(childProcess);
+
+        startFfmpeg('tests/audio.mp3', {
+            executablePath: '/custom/ffmpeg',
+            inputArgs: ['-re'],
+            outputArgs: ['-f', 'wav', 'pipe:1'],
+        });
+
+        expect(mockSpawn).toHaveBeenCalledWith(
+            '/custom/ffmpeg',
+            ['-re', '-i', 'tests/audio.mp3', '-f', 'wav', 'pipe:1'],
+            { stdio: ['ignore', 'pipe', 'pipe'] },
+        );
+    });
+
+    it('stops a running child process and schedules a force kill fallback', async () => {
+        jest.useFakeTimers();
+        const childProcess = createMockChildProcess();
+        childProcess.kill.mockImplementation(() => {
+            childProcess.killed = true;
+            return true;
+        });
+        mockSpawnReturn(childProcess);
+
+        const handle = startFfmpeg('tests/audio.mp3');
+        const readyExpectation = expect(handle.ready).rejects.toThrow('stopped before producing audio');
+        handle.stop();
+
+        await readyExpectation;
+        expect(childProcess.stdout.destroy).toHaveBeenCalledTimes(1);
+        expect(childProcess.stderr.destroy).toHaveBeenCalledTimes(1);
+        expect(childProcess.kill).toHaveBeenCalledWith('SIGTERM');
+
+        jest.advanceTimersByTime(2_000);
+
+        expect(childProcess.kill).toHaveBeenNthCalledWith(2, 'SIGKILL');
+    });
+
+    it('does not signal a process that already exited', async () => {
+        const childProcess = createMockChildProcess();
+        childProcess.exitCode = 0;
+        mockSpawnReturn(childProcess);
+
+        const handle = startFfmpeg('tests/audio.mp3');
+        const readyExpectation = expect(handle.ready).rejects.toThrow('stopped before producing audio');
+        handle.stop();
+
+        await readyExpectation;
+        expect(childProcess.kill).not.toHaveBeenCalled();
+    });
+});

tsconfig.eslint.json

@@ -1,4 +1,7 @@
 {
     "extends": "./tsconfig.json",
-    "include": ["src/**/*.ts"]
+    "compilerOptions": {
+        "skipLibCheck": true
+    },
+    "include": ["src/**/*.ts", "tests/**/*.ts", "tsup.config.ts"]
 }

tsconfig.json

@@ -1,35 +1,22 @@
 {
     "compilerOptions": {
-        "target": "ES2022",
-        "lib": ["ES2022"],
-        "module": "commonjs",
-        "moduleResolution": "node",
-        "resolveJsonModule": true,
+        "target": "ES2024",
+        "lib": ["ES2024"],
+        "module": "Node20",
         "types": [],
         "rootDir": "./",
         "outDir": "./dist",
-        "baseUrl": "./",
-        "paths": {
-            "@/*": ["src/*"]
-        },
         "esModuleInterop": true,
-        "allowSyntheticDefaultImports": true,
         "forceConsistentCasingInFileNames": true,
         "strict": true,
-        "noImplicitAny": true,
-        "strictNullChecks": true,
-        "strictFunctionTypes": true,
-        "strictBindCallApply": true,
-        "strictPropertyInitialization": true,
-        "alwaysStrict": true,
+        "isolatedModules": true,
+        "erasableSyntaxOnly": true,
         "noUnusedLocals": true,
         "noUnusedParameters": true,
         "noImplicitReturns": true,
         "noUncheckedIndexedAccess": true,
         "exactOptionalPropertyTypes": true,
         "noFallthroughCasesInSwitch": true,
-        "useUnknownInCatchVariables": true,
-        "skipLibCheck": true,
         "noEmitOnError": true
     },
     "include": ["src"],

tsconfig.test.json

@@ -0,0 +1,8 @@
+{
+    "extends": "./tsconfig.json",
+    "compilerOptions": {
+        "outDir": "./dist-test",
+        "skipLibCheck": true
+    },
+    "include": ["src/**/*.ts", "tests/**/*.ts", "tsup.config.ts"]
+}

tsup.config.ts

@@ -3,7 +3,12 @@ import { defineConfig } from 'tsup';
 export default defineConfig({
     format: ['cjs', 'esm'],
     entry: ['./src/index.ts'],
-    dts: true,
+    dts: {
+        compilerOptions: {
+            // tsup's declaration bundler still sets the removed baseUrl option internally.
+            ignoreDeprecations: '6.0',
+        },
+    },
     shims: true,
     skipNodeModulesBundle: true,
     clean: true,