chore: update issue templates and workflow files for Gitea compatibility

Bump @types/node from 26.0.0 to 26.0.1

.gitattributes

@@ -0,0 +1,9 @@
+*.ts text eol=crlf linguist-language=TypeScript
+*.tsx text eol=crlf linguist-language=TypeScript
+*.mts text eol=crlf linguist-language=TypeScript
+*.cts text eol=crlf linguist-language=TypeScript
+
+*.js text eol=crlf linguist-language=JavaScript
+*.jsx text eol=crlf linguist-language=JavaScript
+*.mjs text eol=crlf linguist-language=JavaScript
+*.cjs text eol=crlf linguist-language=JavaScript

.gitea/ISSUE_TEMPLATE/bug.yaml

@@ -0,0 +1,21 @@
+name: 🐛 Bug
+about: 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/config.yml

@@ -0,0 +1 @@
+blank_issues_enabled: false

.gitea/ISSUE_TEMPLATE/feature.yaml

@@ -0,0 +1,21 @@
+name: 💡 Enhancement
+about: 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
+about: 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/ISSUE_TEMPLATE/request.yaml

@@ -0,0 +1,21 @@
+name: 📝 Service Request
+about: Request a service or support task
+title: '📝 [Service Request]: '
+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/story.yaml

@@ -0,0 +1,21 @@
+name: 👮 Story
+about: Describe a user story
+title: '👮 [Story]: '
+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,92 @@
+name: Release and Deploy Build
+
+on:
+    workflow_dispatch:
+
+env:
+    VERSION_MAJOR: '1'
+    VERSION_MINOR: '1'
+
+jobs:
+    build:
+        runs-on: ubuntu-latest
+
+        steps:
+            - name: Checkout Repository
+              uses: https://gitea.com/actions/checkout@v4
+              with:
+                  fetch-depth: 0
+                  fetch-tags: true
+
+            - name: Use NodeJS v22.22.3
+              uses: https://gitea.com/actions/setup-node@v4
+              with:
+                  node-version: '22.22.3'
+                  registry-url: 'https://registry.npmjs.org'
+
+            - 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_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
+
+                  previous_tag="$(git describe --tags --abbrev=0 "$GITEA_SHA^" 2>/dev/null || true)"
+
+                  if [ -n "$previous_tag" ]; then
+                      commit_messages="$(git log --reverse --format='- %s' "${previous_tag}..${GITEA_SHA}")"
+                      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
+
+                  node -e 'const fs = require("node:fs"); fs.writeFileSync("release.json", JSON.stringify({ tag_name: process.env.RELEASE_TAG, target_commitish: process.env.GITEA_SHA, name: process.env.RELEASE_TAG, body: fs.readFileSync("release-notes.md", "utf8") }))'
+
+                  api_url="${GITEA_SERVER_URL}/api/v1/repos/${GITEA_REPOSITORY}/releases"
+                  auth_header="Authorization: token ${GITEA_TOKEN}"
+
+                  if curl --fail --silent --header "$auth_header" --output current-release.json "${api_url}/tags/${RELEASE_TAG}"; then
+                      release_id="$(node -p 'require("./current-release.json").id')"
+                      curl --fail-with-body --header "$auth_header" --header 'Content-Type: application/json' --request PATCH --data-binary @release.json "${api_url}/${release_id}"
+                  else
+                      curl --fail-with-body --header "$auth_header" --header 'Content-Type: application/json' --request POST --data-binary @release.json "$api_url"
+                  fi

.gitea/workflows/Build-Validation.yml

@@ -0,0 +1,30 @@
+name: Build Validation
+
+on:
+    workflow_dispatch:
+    push:
+        branches:
+            - main
+    pull_request:
+        types: [opened, synchronize, reopened]
+
+jobs:
+    build:
+        runs-on: ubuntu-latest
+        steps:
+            - name: Checkout Repository
+              uses: https://gitea.com/actions/checkout@v4
+
+            - name: use NodeJS v22.22.3
+              uses: https://gitea.com/actions/setup-node@v4
+              with:
+                  node-version: '22.22.3'
+
+            - name: Install Dependencies
+              run: npm ci
+
+            - name: Run Checks
+              run: npm run check
+
+            - name: Run Build
+              run: npm run build

.github/FUNDING.yml

@@ -1,15 +0,0 @@
-# These are supported funding model platforms
-
-github: # Replace with up to 4 GitHub Sponsors-enabled usernames e.g., [user1, user2]
-patreon: # Replace with a single Patreon username
-open_collective: # Replace with a single Open Collective username
-ko_fi: FrauJulian
-tidelift: # Replace with a single Tidelift platform-name/package-name e.g., npm/babel
-community_bridge: # Replace with a single Community Bridge project-name e.g., cloud-foundry
-liberapay: # Replace with a single Liberapay username
-issuehunt: # Replace with a single IssueHunt username
-lfx_crowdfunding: # Replace with a single LFX Crowdfunding project-name e.g., cloud-foundry
-polar: # Replace with a single Polar username
-buy_me_a_coffee: # Replace with a single Buy Me a Coffee username
-thanks_dev: # Replace with a single thanks.dev username
-custom: # Replace with up to 4 custom sponsorship URLs e.g., ['link1', 'link2']

.github/workflows/Build-Rollout.yml

@@ -1,39 +0,0 @@
-name: Build Rollout
-
-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.16.0
-        uses: actions/setup-node@v4
-        with:
-          node-version: '22.16.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 rolloutBuild
-
-      - name: Publish Library
-        run: npm publish
-        env:
-          NODE_AUTH_TOKEN: ${{ secrets.NPM_TOKEN }}

.github/workflows/Build-Validation.yml

@@ -1,23 +0,0 @@
-name: Build Validation
-
-on:
-  pull_request:
-    types: [opened, synchronize, reopened]
-
-jobs:
-  build:
-    runs-on: ubuntu-latest
-    steps:
-      - name: Checkout Repository
-        uses: actions/checkout@v4
-
-      - name: use NodeJS v22.16.0
-        uses: actions/setup-node@v4
-        with:
-          node-version: '22.16.0'
-
-      - name: Install Dependencies
-        run: npm install
-
-      - name: run Rollout Build
-        run: npm run rolloutBuild

.gitignore

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

.husky/pre-commit

@@ -0,0 +1,2 @@
+#!/usr/bin/env sh
+npm run check || exit 1

.npmignore

@@ -1,10 +1,33 @@
-.idea
-.git
 .github
+.git
+
+.idea
+.vscode
+
+dist
+node_modules
+coverage
+.npm
+
+.husky
+src
+set-version.js
+
+README.md
+SECURITY.md
+CODEOWNERS
+
 .gitignore
 .npmignore
-node_modules
+.prettierignore
-src
+.prettierrc
-README.md
+.gitattributes
+
 tsconfig.json
+tsconfig.eslint.json
 tsup.config.ts
+eslint.config.cjs
+eslint.config.typeaware.cjs
+package-lock.json
+jest.config.cjs
+tests

.prettierignore

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

.prettierrc

@@ -0,0 +1,13 @@
+{
+    "printWidth": 120,
+    "tabWidth": 4,
+    "useTabs": false,
+    "singleQuote": true,
+    "trailingComma": "all",
+    "semi": true,
+    "arrowParens": "always",
+    "bracketSpacing": true,
+    "bracketSameLine": false,
+    "quoteProps": "as-needed",
+    "endOfLine": "auto"
+}

README.md

@@ -1,87 +1,207 @@
 # 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)
+![latest release](https://img.shields.io/badge/dynamic/json?label=release&query=$.name&url=https%3A%2F%2Fapi.github.com%2Frepos%2FFrauJulian%2Fdiscord-audio-stream%2Freleases%2Flatest&color=blue)
 ![GitHub Repo stars](https://img.shields.io/github/stars/FrauJulian/discord-audio-stream?style=social)
 
-**This module is designed to work with [discord.js/voice](https://www.npmjs.com/package/@discordjs/voice) v0.18. This
+`discord-audio-stream` is a small TypeScript library for managed Discord voice playback through
-package doesn't support older
+`@discordjs/voice` and ffmpeg.
-versions!**
 
-## 👋 Support
+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.
 
-Please create an [issue](https://github.com/FrauJulian/DiscordAudioStreamNPM/issues) on github or write [
+## Support
-`fraujulian`](https://discord.com/users/860206216893693973) on discord!
 
-## 📝 Usage
+Create an [issue](https://git.lechner-systems.at/fraujulian/Discord-Audio-Stream/issues) on GitHub or contact
+[`fraujulian`](https://discord.com/users/860206216893693973) on Discord.
 
-### Install package
+## Installation
+
+Node.js `22.22.3` or newer is required.
 
 ```bash
-npm install discord-audio-stream opusscript @discordjs/voice ffmpeg-static sodium-native
+npm install discord-audio-stream @discordjs/voice prism-media @snazzah/davey opusscript
 ```
 
-### Create Instance
+`ffmpeg` must be available either on the host PATH or through the optional `ffmpeg-static` package:
 
-```js
+```bash
-let audioManager = new AudioManager();
+npm install ffmpeg-static
 ```
 
-or (with parameters)
+Use `ffmpeg.mode: 'native'` for PATH-based ffmpeg and `ffmpeg.mode: 'static'` for `ffmpeg-static`.
 
-```js
+`libsodium-wrappers` is optional. Install it only when your runtime does not support `aes-256-gcm`:
-let audioManager = new AudioManager({
+
-        VoiceChannelId: 0, //voice channel id where to play music
+```bash
-        GuildId: 0, //guild id
+node -e "console.log(require('node:crypto').getCiphers().includes('aes-256-gcm'))"
-        VoiceAdapter: 0 //guild VoiceAdapter
+npm install libsodium-wrappers
+```
+
+## Basic Usage
+
+```ts
+import { AudioManager } from 'discord-audio-stream';
+
+const manager = new AudioManager({
+    connection: {
+        guildId: guild.id,
+        channelId: voiceChannel.id,
+        adapterCreator: guild.voiceAdapterCreator,
     },
-    {
+    source: {
-        ResourceType: "", //resource type like link or file
+        type: 'url',
-        Resource: "" //auto play link or file name
+        url: 'https://example.com/live-stream.mp3',
-    });
+    },
+    ffmpeg: {
+        mode: 'native',
+    },
+});
+
+await manager.start();
 ```
 
-### Properties of the AudioManager
+For a file source:
 
-#### Properties
+```ts
+manager.setSource({
+    type: 'file',
+    path: 'audio/intro.mp3',
+});
 
-| Callable with     | Type                         | Description                                     |
+await manager.start();
-|-------------------|------------------------------|-------------------------------------------------|
+```
-| `VoiceConnection` | **VoiceConnection**          | VoiceConnection instance from discord.js/voice. |
-| `AudioPlayer`     | **AudioPlayer**              | AudioPlayer instance from discord.js/voice.     |
-| `AudioResource`   | **AudioResource**            | AudioResource instance from discord.js/voice.   |
-| `ConnectionData`  | **VoiceConnectionDataModel** | Global variable for connection data.            |
-| `AudioData`       | **AudioDataModel**           | Global variable for audio data.                 |
 
-#### Methods
+Relative file paths are resolved from `process.cwd()`. URL sources are validated before playback starts.
 
-| Callable with                  | Parameters                                                                                             | Return type | Description                                                        |
+For large bots, queue many simultaneous starts so the host does not spawn too many ffmpeg processes in the same tick.
-|--------------------------------|--------------------------------------------------------------------------------------------------------|-------------|--------------------------------------------------------------------|
-| `OverrideOptions`              | `connectionData` (type of **VoiceConnectionDataModel**), `audioData` (type of **VoiceAudioDataModel**) | void        | Method to override global variables, connectionData and audioData. |
-| `CreateConnection`             | `isRenew` (type of boolean, default value is false)                                                    | void        | Method to join the voice connection.                               |
-| `PlayAudioOnConnection`        |                                                                                                        | void        | Method to play audio on the existing voice connection.             |
-| `PauseAudio`                   |                                                                                                        | void        | Method to pause the audio.                                         |
-| `ResumeAudio`                  |                                                                                                        | void        | Method to resume the audio.                                        |
-| `StopAudioOnConnection`        |                                                                                                        | void        | Method to stop the audio without destroying voice connection.      |
-| `CreateConnectionAndPlayAudio` |                                                                                                        | void        | Method to join the voice connection and play audio.                |
-| `DestroyConnection`            |                                                                                                        | void        | Method to destroy the voice connection.                            |
-| `SetVolume`                    | `volume` (type of number, 0 - 100 percent)                                                             | void        | Method to set the audio volume.                                    | Method to set the volume of the audio.                             |
-| `SetMaxListeners`              | `maxListeners` (type of number)                                                                        | void        | Method to set the max listeners of the audio stream.               |
 
-##### Types History
+## Lifecycle
 
-- [**VoiceConnection** by discord.js/voice](https://github.com/discordjs/discord.js/blob/main/packages/voice/src/VoiceConnection.ts#L166)
+```ts
-- [**AudioPlayer** by discord.js/voice](https://github.com/discordjs/discord.js/blob/main/packages/voice/src/audio/AudioPlayer.ts#L155)
+manager.setConnection(connectionOptions);
-- [**AudioResource** by discord.js/voice](https://github.com/discordjs/discord.js/blob/main/packages/voice/src/audio/AudioResource.ts#L44)
+manager.setSource(source);
-- [**VoiceConnectionDataModel**](https://github.com/FrauJulian/Discord-Audio-Stream/blob/main/src/Models/VoiceConnectionDataModel.d.ts#L3) (custom type)
-- [**VoiceAudioDataModel**](https://github.com/FrauJulian/Discord-Audio-Stream/blob/main/src/Models/VoiceAudioDataModel.d.ts#L1) (custom type)
 
-## 📋 Credits:
+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
+```
 
-~ [**FrauJulian**](https://fraujulian.xyz/).
+`connect()` joins the configured voice channel. `play(source?)` starts playback on an existing connection. Use `start()`
+when you want both.
 
-## 🤝 Enjoy the package?
+## API
 
-Give it a star ⭐ on [github](https://github.com/FrauJulian/discord-audio-stream)!
+```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;
+    volume?: {
+        enabled?: boolean;
+        initialPercent?: number;
+    };
+};
+```
 
-### Greetings from Austria! ⛰️
+### Defaults
+
+| Option             | Default     |
+| ------------------ | ----------- |
+| `ffmpeg.mode`      | `'native'`  |
+| `connectTimeoutMs` | `20_000`    |
+| `renewIntervalMs`  | `5_400_000` |
+| `volume.enabled`   | `false`     |
+
+### Methods
+
+| Method                   | Description                                                                        |
+| ------------------------ | ---------------------------------------------------------------------------------- |
+| `setConnection(options)` | Replaces the voice connection target.                                              |
+| `setSource(source)`      | Replaces the audio source.                                                         |
+| `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. |
+
+### 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`.
+
+By default, the manager schedules a renewal after `5_400_000 ms` so long-running streams can reconnect periodically.
+Set `renewIntervalMs: false` to disable it. `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`.
+
+## Development
+
+```bash
+npm ci
+npm run check
+npm run build
+```
+
+## Contributors
+
+~ [**FrauJulian - Julian Lechner**](https://fraujulian.xyz/) - CODEOWNER
+
+## Enjoy the package?
+
+Give it a star on [Gitea](https://git.lechner-systems.at/fraujulian/Discord-Audio-Stream)!

SECURITY.md

@@ -0,0 +1,55 @@
+# Security Policy
+
+## Supported Versions
+
+Security fixes are provided for the latest published release line.
+
+| Version                                   | Supported |
+| ----------------------------------------- | --------- |
+| 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
+
+Do not open a public GitHub issue for security vulnerabilities.
+
+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

@@ -0,0 +1,91 @@
+/** @type {import('eslint').Linter.FlatConfig[]} */
+const config = [
+    {
+        ignores: ['dist/', 'node_modules/'],
+    },
+
+    {
+        files: ['**/*.{ts,tsx,js,cjs,mjs}'],
+
+        languageOptions: {
+            ecmaVersion: 'latest',
+            sourceType: 'module',
+            parser: require('@typescript-eslint/parser'),
+            parserOptions: {
+                ecmaFeatures: {},
+            },
+        },
+
+        plugins: {
+            '@typescript-eslint': require('@typescript-eslint/eslint-plugin'),
+            import: require('eslint-plugin-import'),
+            promise: require('eslint-plugin-promise'),
+            'unused-imports': require('eslint-plugin-unused-imports'),
+            n: require('eslint-plugin-n'),
+        },
+
+        rules: {
+            /* Base */
+            'no-debugger': 'warn',
+
+            /* TypeScript */
+            '@typescript-eslint/consistent-type-imports': ['warn', { prefer: 'type-imports' }],
+            '@typescript-eslint/no-unused-vars': 'off',
+            'unused-imports/no-unused-imports': 'warn',
+            'unused-imports/no-unused-vars': [
+                'warn',
+                { vars: 'all', varsIgnorePattern: '^_', args: 'after-used', argsIgnorePattern: '^_' },
+            ],
+            '@typescript-eslint/no-explicit-any': 'error',
+
+            /* Imports */
+            'import/first': 'error',
+            'import/no-duplicates': 'error',
+            'import/newline-after-import': 'warn',
+            'import/no-extraneous-dependencies': [
+                'error',
+                {
+                    devDependencies: [
+                        '**/*.config*.{js,cjs,mjs,ts}',
+                        '**/scripts/**',
+                        '**/*.test.{ts,js}',
+                        '**/Testing.{ts,js}',
+                        '**/.eslintrc.{js,cjs}',
+                    ],
+                },
+            ],
+
+            /* Node */
+            'n/no-missing-import': 'off',
+            'n/no-unsupported-features/es-syntax': 'off',
+
+            /* Promis */
+            'promise/catch-or-return': 'warn',
+            'promise/always-return': 'off',
+
+            /* „Fire-and-forget“-Promises `void` */
+            'no-void': ['warn', { allowAsStatement: true }],
+        },
+
+        settings: {
+            'import/resolver': {
+                typescript: {
+                    alwaysTryTypes: true,
+                },
+                node: true,
+            },
+        },
+    },
+
+    {
+        files: ['**/*.{js,cjs}'],
+        languageOptions: {
+            sourceType: 'script',
+        },
+        rules: {
+            'n/global-require': 'off',
+        },
+    },
+];
+
+module.exports = config;

eslint.config.typeaware.cjs

@@ -0,0 +1,25 @@
+/** @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.6.12",
+    "version": "x.x.x",
-    "license": "LGPL-2.1-only",
+    "license": "LGPL-3.0-only",
-    "description": "NodeJS library to make stream any audio on discord easier.",
+    "description": "A small Discord voice audio streaming library with managed ffmpeg playback.",
     "exports": {
         ".": {
             "require": {
@@ -25,52 +26,90 @@
         "lib": "src"
     },
     "scripts": {
-        "updateDependencies": "npx npm-check-updates --upgrade && npm install && echo SUCCEED UPDATE",
+        "version:place": "node set-version.js set-ci-version",
-        "cleanSolution": "del-cli dist && echo SUCCEED CLEAN",
+        "version:check": "node set-version.js check-placeholder",
-        "updateVersion": "npm version patch --no-git-tag-version && echo SUCCEED UPDATE VERSION",
+        "version:fix": "node set-version.js fix-placeholder",
-        "buildPackage": "tsup && echo SUCCEED BUILD && npm run updateVersion",
+        "lint": "eslint . --ext .ts,.tsx,.js,.cjs,.mjs",
-        "rolloutBuild": "npm run updateDependencies && npm run cleanSolution && tsup"
+        "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 .",
+        "typecheck": "tsc --noEmit",
+        "test": "jest --runInBand",
+        "check": "npm run version:check && npm run format:check && npm run lint && npm run lint:types && npm run typecheck && npm run test",
+        "fix": "npm run version:fix && npm run format && npm run lint:fix",
+        "build": "node -e \"require('node:fs').rmSync('dist', { recursive: true, force: true })\" && tsup && tsc -p tsconfig.build.json && node scripts/copy-dts.cjs",
+        "prepare": "husky"
     },
-    "repository": "https://github.com/FrauJulian/Discord-Audio-Stream",
+    "repository": {
-    "bugs": "https://github.com/FrauJulian/Discord-Audio-Stream/issues",
+        "type": "git",
+        "url": "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.js",
         "discord",
+        "discord.js",
         "audio",
         "voice",
-        "stream"
+        "streaming",
+        "discordjs/voice",
+        "music",
+        "24/7"
     ],
     "contributors": [
-        {
+        "Julian Lechner - FrauJulian <fraujulian@lechner.top>"
-            "name": "Lechner Julian",
-            "nickname": "FrauJulian",
-            "email": "office@lechner-systems.at",
-            "website": "https://lechner-systems.at/"
-        }
     ],
-    "dependencies": {
+    "lint-staged": {
-        "@noble/ciphers": "^1.3.0",
+        "*.{ts,tsx,js,cjs,mjs}": [
-        "@stablelib/xchacha20poly1305": "^2.0.1",
+            "eslint --fix",
-        "sodium-native": "^5.0.6"
+            "prettier --write"
+        ],
+        "*.{json,md,yml,yaml}": [
+            "prettier --write"
+        ]
     },
     "devDependencies": {
+        "@jest/globals": "^30.4.1",
         "@types/ejs": "^3.1.5",
-        "@types/node": "^24.1.0",
+        "@types/node": "^26.0.0",
-        "del-cli": "^6.0.0",
+        "@typescript-eslint/eslint-plugin": "^8.61.1",
-        "npm-check-updates": "^18.0.2",
+        "@typescript-eslint/parser": "^8.61.1",
-        "tsup": "^8.5.0",
+        "eslint": "^9.39.4",
-        "typescript": "^5.8.3"
+        "eslint-config-prettier": "^10.1.8",
+        "eslint-import-resolver-typescript": "^4.4.5",
+        "eslint-plugin-import": "^2.32.0",
+        "eslint-plugin-n": "^18.1.0",
+        "eslint-plugin-promise": "^7.3.0",
+        "eslint-plugin-unused-imports": "^4.4.1",
+        "husky": "^9.1.7",
+        "jest": "^30.4.2",
+        "prettier": "^3.8.4",
+        "ts-jest": "^29.4.11",
+        "tsup": "^8.5.1",
+        "typescript": "^6.0.3"
     },
     "peerDependencies": {
-        "@discordjs/voice": "^0.18.0",
+        "@discordjs/voice": "^0.19.2",
-        "libsodium-wrappers": "^0.7.15",
+        "@snazzah/davey": "^0.1.12",
-        "opusscript": "^0.1.1",
+        "ffmpeg-static": "^5.3.0",
-        "ffmpeg-static": "^5.2.0"
+        "libsodium-wrappers": "^0.8.4",
+        "opusscript": "^0.0.8",
+        "prism-media": "^1.3.5"
+    },
+    "peerDependenciesMeta": {
+        "ffmpeg-static": {
+            "optional": true
+        },
+        "libsodium-wrappers": {
+            "optional": true
+        }
+    },
+    "overrides": {
+        "esbuild": "^0.28.1"
     },
     "engines": {
-        "node": ">=18"
+        "node": ">=22.22.3"
     },
     "private": false,
     "publishConfig": {

scripts/copy-dts.cjs

@@ -0,0 +1,11 @@
+const { copyFileSync, existsSync } = require('node:fs');
+const { join } = require('node:path');
+
+const declarationFile = join(__dirname, '..', 'dist', 'index.d.ts');
+const esmDeclarationFile = join(__dirname, '..', 'dist', 'index.d.mts');
+
+if (!existsSync(declarationFile)) {
+    throw new Error(`Missing declaration file: ${declarationFile}`);
+}
+
+copyFileSync(declarationFile, esmDeclarationFile);

set-version.js

@@ -0,0 +1,103 @@
+const fs = require('fs');
+
+const lockFilePath = 'package-lock.json';
+const packageFilePath = 'package.json';
+const placeholderVersion = 'x.x.x';
+const command = process.argv[2];
+
+function readJson(path) {
+    return JSON.parse(fs.readFileSync(path, 'utf8').toString());
+}
+
+function writeJson(path, value, spaces) {
+    fs.writeFileSync(path, `${JSON.stringify(value, null, spaces)}\n`);
+}
+
+function getLockFile() {
+    if (!fs.existsSync(lockFilePath)) {
+        return null;
+    }
+
+    return readJson(lockFilePath);
+}
+
+function writeVersions(version) {
+    const pkg = readJson(packageFilePath);
+    pkg.version = version;
+    writeJson(packageFilePath, pkg, 2);
+
+    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 ?? process.env.GITHUB_RUN_NUMBER;
+    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

@@ -0,0 +1,296 @@
+import type { AudioPlayer, AudioResource, VoiceConnection } from '@discordjs/voice';
+import {
+    createAudioPlayer,
+    createAudioResource,
+    entersState,
+    joinVoiceChannel,
+    NoSubscriberBehavior,
+    StreamType,
+    VoiceConnectionStatus,
+} from '@discordjs/voice';
+import { isAbsolute, resolve } from 'node:path';
+
+import { AudioManagerConfigError, AudioManagerStateError } from './errors';
+import { startFfmpeg, type FfmpegProcessHandle } from './ffmpeg';
+import type {
+    AudioManagerOptions,
+    AudioSource,
+    PlaybackState,
+    ResolvedAudioSource,
+    VoiceConnectionOptions,
+} from './types';
+
+const DEFAULT_CONNECT_TIMEOUT_MS = 20_000;
+const DEFAULT_RENEW_INTERVAL_MS = 5_400_000;
+
+export default class AudioManager {
+    private readonly audioPlayer: AudioPlayer;
+
+    private connection: VoiceConnection | undefined;
+    private resource: AudioResource | undefined;
+    private ffmpeg: FfmpegProcessHandle | 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 = {}) {
+        this.options = {
+            ...options,
+            connectTimeoutMs: options.connectTimeoutMs ?? DEFAULT_CONNECT_TIMEOUT_MS,
+        };
+        this.connectionOptions = options.connection;
+        this.audioSource = options.source;
+        this.audioPlayer = createAudioPlayer({
+            behaviors: {
+                noSubscriber: NoSubscriberBehavior.Play,
+            },
+        });
+    }
+
+    public get state(): PlaybackState {
+        return this.playbackState;
+    }
+
+    public get isPlaying(): boolean {
+        return this.playbackState === 'playing';
+    }
+
+    public get isConnected(): boolean {
+        return Boolean(this.connection);
+    }
+
+    public setConnection(options: VoiceConnectionOptions): void {
+        this.assertNotDisposed();
+        this.connectionOptions = options;
+    }
+
+    public setSource(source: AudioSource): void {
+        this.assertNotDisposed();
+        this.audioSource = source;
+    }
+
+    public async connect(): Promise<void> {
+        this.assertNotDisposed();
+
+        if (!this.connectionOptions) {
+            throw new AudioManagerConfigError('Voice connection options are required before connecting.');
+        }
+
+        this.clearRenewTimer();
+        this.playbackState = 'connecting';
+        this.connection?.destroy();
+        const connection = joinVoiceChannel({
+            guildId: this.connectionOptions.guildId,
+            channelId: this.connectionOptions.channelId,
+            adapterCreator: this.connectionOptions.adapterCreator,
+        });
+        this.connection = connection;
+        connection.subscribe(this.audioPlayer);
+
+        try {
+            await entersState(connection, VoiceConnectionStatus.Ready, this.options.connectTimeoutMs);
+        } catch (error) {
+            connection.destroy();
+            if (this.connection === connection) {
+                this.connection = undefined;
+            }
+            this.playbackState = 'stopped';
+            throw error;
+        }
+        if (this.connection !== connection) {
+            throw new AudioManagerStateError('Voice connection was stopped before it became ready.');
+        }
+        this.playbackState = 'ready';
+        this.scheduleRenewal();
+    }
+
+    public async play(source?: AudioSource): Promise<void> {
+        this.assertNotDisposed();
+
+        if (source) {
+            this.setSource(source);
+        }
+
+        if (!this.connection) {
+            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) {
+                this.stopCurrentPlayback();
+            }
+            throw error;
+        }
+
+        if (this.options.volume?.enabled === true && this.options.volume.initialPercent !== undefined) {
+            this.setVolume(this.options.volume.initialPercent);
+        }
+
+        try {
+            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.clearRenewTimer();
+        this.stopCurrentPlayback();
+        this.audioPlayer.stop(true);
+        this.connection?.disconnect();
+        this.connection?.destroy();
+        this.connection = undefined;
+        this.playbackState = 'stopped';
+    }
+
+    public setVolume(volumeInPercent: number): void {
+        this.assertNotDisposed();
+
+        if (this.options.volume?.enabled !== true) {
+            throw new AudioManagerStateError('Volume control requires volume.enabled to be true.');
+        }
+
+        if (!Number.isFinite(volumeInPercent) || volumeInPercent < 0 || volumeInPercent > 100) {
+            throw new AudioManagerConfigError('Volume must be between 0 and 100 percent.');
+        }
+
+        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.clearRenewTimer();
+        this.stopCurrentPlayback();
+        this.audioPlayer.stop(true);
+        this.connection?.destroy();
+        this.connection = undefined;
+        this.connectionOptions = undefined;
+        this.audioSource = undefined;
+        this.playbackState = 'disposed';
+    }
+
+    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: ${String(error)}`);
+            }
+        }
+
+        return {
+            input: isAbsolute(this.audioSource.path)
+                ? this.audioSource.path
+                : resolve(process.cwd(), this.audioSource.path),
+            source: this.audioSource,
+        };
+    }
+
+    private scheduleRenewal(): void {
+        const renewIntervalMs = this.options.renewIntervalMs ?? DEFAULT_RENEW_INTERVAL_MS;
+
+        if (renewIntervalMs === false) {
+            return;
+        }
+
+        this.renewTimer = setTimeout(() => {
+            void this.start().catch(() => {
+                this.clearRenewTimer();
+                this.stopCurrentPlayback();
+                this.audioPlayer.stop(true);
+                this.connection?.disconnect();
+                this.connection?.destroy();
+                this.connection = undefined;
+                this.playbackState = 'stopped';
+            });
+        }, renewIntervalMs);
+
+        if (typeof this.renewTimer.unref === 'function') {
+            this.renewTimer.unref();
+        }
+    }
+
+    private clearRenewTimer(): void {
+        if (this.renewTimer) {
+            clearTimeout(this.renewTimer);
+            this.renewTimer = 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/audioManager.ts

@@ -1,137 +0,0 @@
-import {
-    AudioPlayer,
-    AudioResource,
-    createAudioPlayer,
-    createAudioResource,
-    joinVoiceChannel,
-    VoiceConnection
-} from "@discordjs/voice";
-import {join} from "node:path";
-import {VoiceConnectionDataModel} from "./types/VoiceConnectionDataModel";
-import {VoiceAudioDataModel} from "./types/VoiceAudioDataModel";
-
-export default class AudioManager {
-    public VoiceConnection: VoiceConnection | null = null;
-    public AudioPlayer: AudioPlayer | null = null;
-    public AudioResource: AudioResource | null = null;
-
-    protected IsActive: boolean = false;
-    protected IsAudioPlaying: boolean = false;
-
-    protected ConnectionData: VoiceConnectionDataModel | null;
-    protected AudioData: VoiceAudioDataModel | null;
-
-    constructor(connectionData: VoiceConnectionDataModel | null = null, audioData: VoiceAudioDataModel | null = null) {
-        this.ConnectionData = connectionData;
-        this.AudioData = audioData;
-    }
-
-    public OverrideOptions(connectionData: VoiceConnectionDataModel | null = null, audioData: VoiceAudioDataModel | null = null): void {
-        this.ConnectionData = connectionData;
-        this.AudioData = audioData;
-    }
-
-    public CreateConnection(isRenew: boolean = false): void {
-        this.CheckIfNull(this.ConnectionData);
-
-        if (!isRenew) {
-            if (this.IsActive) {
-                this.DestroyConnection(false);
-            } else {
-                this.IsActive = true;
-            }
-        }
-
-        this.VoiceConnection = joinVoiceChannel({
-            channelId: this.ConnectionData!.VoiceChannelId.toString(),
-            guildId: this.ConnectionData!.GuildId.toString(),
-            adapterCreator: this.ConnectionData!.VoiceAdapter
-        });
-
-        setTimeout((): void => {
-            this.RenewConnectionAndAudio();
-        }, 5400000);
-    }
-
-    public PlayAudioOnConnection(): void {
-        this.CheckIfNull(this.AudioData);
-
-        if (this.AudioData!.ResourceType === "File") {
-            this.AudioResource = createAudioResource(join(__dirname, this.AudioData!.Resource), {inlineVolume: true});
-        } else if (this.AudioData!.ResourceType === "Link") {
-            this.AudioResource = createAudioResource(this.AudioData!.Resource, {inlineVolume: true});
-        } else {
-            throw new Error("Invalid resource type.");
-        }
-
-        this.AudioPlayer = createAudioPlayer();
-        this.AudioPlayer.play(this.AudioResource);
-
-        this.VoiceConnection!.subscribe(this.AudioPlayer!);
-        this.IsAudioPlaying = true;
-    }
-
-    public StopAudioOnConnection(): void {
-        if (this.IsAudioPlaying) {
-            this.DestroyConnection(false)
-            this.CreateConnection();
-        } else {
-            throw new Error("Audio is not playing.");
-        }
-
-    }
-
-    public PauseAudio(): void {
-        this.CheckIfNull(this.AudioPlayer);
-        this.AudioPlayer!.pause();
-    }
-
-    public ResumeAudio(): void {
-        this.CheckIfNull(this.AudioPlayer);
-        this.AudioPlayer!.unpause();
-    }
-
-    public CreateConnectionAndPlayAudio(): void {
-        this.CreateConnection();
-        this.PlayAudioOnConnection();
-    }
-
-    public DestroyConnection(resetValidationParameters: boolean = true): void {
-        this.CheckIfNull(this.VoiceConnection);
-        this.VoiceConnection!.destroy();
-
-        if (resetValidationParameters) {
-            this.IsActive = false;
-            this.IsAudioPlaying = false;
-        }
-    }
-
-    public SetMaxListeners(maxListeners: number): void {
-        this.CheckIfNull(this.VoiceConnection);
-        this.VoiceConnection!.setMaxListeners(maxListeners);
-    }
-
-    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);
-    }
-
-    private RenewConnectionAndAudio(): void {
-        this.DestroyConnection(false);
-        if (this.IsActive) {
-            this.CreateConnection(true);
-
-            if (this.IsAudioPlaying) {
-                this.PlayAudioOnConnection();
-            }
-        }
-    }
-
-    private CheckIfNull<T>(value: T | null): boolean {
-        if (value === null) {
-            throw new Error(`${value} cannot be null in this case.`);
-        }
-
-        return true;
-    }
-}

src/errors.ts

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

src/ffmpeg.ts

@@ -0,0 +1,132 @@
+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 = {
+    process: ChildProcessByStdio<null, Readable, Readable>;
+    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: ${String(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 ready = waitForFfmpegOutput(childProcess);
+
+    childProcess.stderr.resume();
+
+    return {
+        process: childProcess,
+        ready,
+        stop: (): void => {
+            stopProcess(childProcess);
+        },
+    };
+}
+
+function waitForFfmpegOutput(childProcess: ChildProcessByStdio<null, Readable, Readable>): Promise<void> {
+    let stderrTail = '';
+
+    const appendStderr = (chunk: Buffer | string): void => {
+        stderrTail = (stderrTail + String(chunk)).slice(-STDERR_TAIL_BYTES);
+    };
+
+    childProcess.stderr.on('data', appendStderr);
+
+    return new Promise((resolve, reject) => {
+        const cleanup = (): void => {
+            childProcess.off('error', onError);
+            childProcess.off('exit', onExit);
+            childProcess.stdout.off('readable', onReadable);
+        };
+
+        const fail = (message: string, cause?: unknown): void => {
+            cleanup();
+            reject(new FfmpegProcessError(addStderrTail(message, stderrTail), cause));
+        };
+
+        const onError = (error: Error): void => {
+            fail(`Unable to start ffmpeg. Cause: ${error.message}`, error);
+        };
+
+        const onExit = (code: number | null, signal: NodeJS.Signals | null): void => {
+            fail(`ffmpeg exited before producing audio. Exit code: ${code ?? 'none'}, signal: ${signal ?? 'none'}.`);
+        };
+
+        const onReadable = (): void => {
+            cleanup();
+            resolve();
+        };
+
+        childProcess.once('error', onError);
+        childProcess.once('exit', onExit);
+        childProcess.stdout.once('readable', onReadable);
+    });
+}
+
+function addStderrTail(message: string, stderrTail: string): string {
+    const trimmedTail = stderrTail.trim();
+
+    return trimmedTail ? `${message} stderr: ${trimmedTail}` : message;
+}
+
+function stopProcess(childProcess: ChildProcessByStdio<null, Readable, Readable>): void {
+    childProcess.stdout.destroy();
+    childProcess.stderr.destroy();
+    childProcess.removeAllListeners();
+
+    if (childProcess.killed || childProcess.exitCode !== null || childProcess.signalCode !== null) {
+        return;
+    }
+
+    childProcess.kill('SIGTERM');
+
+    const forceKillTimeout = setTimeout(() => {
+        if (!childProcess.killed && childProcess.exitCode === null && childProcess.signalCode === null) {
+            childProcess.kill('SIGKILL');
+        }
+    }, FORCE_KILL_TIMEOUT_MS);
+
+    forceKillTimeout.unref();
+}

src/index.ts

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

src/types.ts

@@ -0,0 +1,178 @@
+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.
+     *
+     * 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.
+     *
+     * Set to `false` to disable renewal.
+     *
+     * @defaultValue `5_400_000`
+     */
+    renewIntervalMs?: number | false;
+
+    /**
+     * Maximum milliseconds to wait for the Discord voice connection to become ready.
+     *
+     * @defaultValue `20_000`
+     */
+    connectTimeoutMs?: number;
+
+    /**
+     * 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;
+};

src/types/VoiceAudioDataModel.d.ts

@@ -1,12 +0,0 @@
-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;
-}

src/types/VoiceConnectionDataModel.d.ts

@@ -1,19 +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;
-}

tests/audio-manager.test.ts

@@ -0,0 +1,633 @@
+import { jest, describe, beforeEach, afterEach, it, expect } from '@jest/globals';
+import { createAudioResource, entersState, joinVoiceChannel } 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';
+
+const mockAudioPlayer = {
+    play: jest.fn(),
+    pause: jest.fn(),
+    unpause: jest.fn(),
+    stop: jest.fn(),
+};
+const mockConnection = {
+    subscribe: jest.fn(),
+    disconnect: jest.fn(),
+    destroy: jest.fn(),
+};
+const 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', () => ({
+    NoSubscriberBehavior: {
+        Play: 'play',
+    },
+    StreamType: {
+        Raw: 'raw',
+    },
+    VoiceConnectionStatus: {
+        Ready: 'ready',
+    },
+    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 deferred<T>(): { promise: Promise<T>; resolve: (value: T) => void } {
+    let resolve!: (value: T) => void;
+    const promise = new Promise<T>((promiseResolve) => {
+        resolve = promiseResolve;
+    });
+
+    return { promise, resolve };
+}
+
+function createMockFfmpegHandle(): FfmpegProcessHandle {
+    return {
+        process: {
+            stdout: new PassThrough(),
+        } as unknown as FfmpegProcessHandle['process'],
+        ready: Promise.resolve(),
+        stop: jest.fn(),
+    };
+}
+
+describe('AudioManager', () => {
+    beforeEach(() => {
+        jest.clearAllMocks();
+    });
+
+    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('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('does not become ready when stopped during connection startup', async () => {
+        jest.useFakeTimers();
+        const ready = deferred<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 concurrent connects resolve out of order', async () => {
+        const firstReady = deferred<VoiceConnection>();
+        const secondReady = deferred<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.resolve(mockVoiceConnection);
+        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 = deferred<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.resolve(mockVoiceConnection);
+
+        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('does not report playback when stopped before ffmpeg is ready', async () => {
+        const ready = deferred<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 = deferred<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 = deferred<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 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('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,227 @@
+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;
+        resume: jest.Mock;
+    };
+    once: jest.Mock;
+    off: jest.Mock;
+    removeAllListeners: 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(),
+            resume: jest.fn(),
+        },
+        once: jest.fn(),
+        off: jest.fn(),
+        removeAllListeners: 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 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.once).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 = getProcessHandler(childProcess, 'error');
+
+        errorHandler(new Error('spawn ENOENT'));
+
+        await expect(handle.ready).rejects.toThrow(FfmpegProcessError);
+        await expect(handle.ready).rejects.toThrow('spawn ENOENT');
+    });
+
+    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');
+
+        readableHandler();
+        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', () => {
+        jest.useFakeTimers();
+        const childProcess = createMockChildProcess();
+        mockSpawnReturn(childProcess);
+
+        const handle = startFfmpeg('tests/audio.mp3');
+        handle.stop();
+
+        expect(childProcess.stdout.destroy).toHaveBeenCalledTimes(1);
+        expect(childProcess.stderr.destroy).toHaveBeenCalledTimes(1);
+        expect(childProcess.removeAllListeners).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', () => {
+        const childProcess = createMockChildProcess();
+        childProcess.exitCode = 0;
+        mockSpawnReturn(childProcess);
+
+        const handle = startFfmpeg('tests/audio.mp3');
+        handle.stop();
+
+        expect(childProcess.kill).not.toHaveBeenCalled();
+    });
+});

tsconfig.build.json

@@ -0,0 +1,10 @@
+{
+    "extends": "./tsconfig.json",
+    "compilerOptions": {
+        "declaration": true,
+        "declarationMap": false,
+        "emitDeclarationOnly": true,
+        "rootDir": "./src"
+    },
+    "include": ["src/**/*.ts"]
+}

tsconfig.eslint.json

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

tsconfig.json

@@ -1,28 +1,33 @@
 {
-  "compilerOptions": {
+    "compilerOptions": {
-    "strict": true,
+        "target": "ES2022",
-    "allowJs": false,
+        "lib": ["ES2022"],
-    "noImplicitAny": true,
+        "module": "Node16",
-    "esModuleInterop": true,
+        "moduleResolution": "node16",
-    "strictNullChecks": true,
+        "resolveJsonModule": true,
-    "target": "ES2022",
+        "types": [],
-    "moduleResolution": "Node",
+        "rootDir": "./",
-    "module": "CommonJS",
+        "outDir": "./dist",
-    "declaration": true,
+        "esModuleInterop": true,
-    "isolatedModules": true,
+        "allowSyntheticDefaultImports": true,
-    "noEmit": true,
+        "forceConsistentCasingInFileNames": true,
-    "outDir": "dist",
+        "strict": true,
-    "types": [
+        "noImplicitAny": true,
-      "node"
+        "strictNullChecks": true,
-    ],
+        "strictFunctionTypes": true,
-    "typeRoots": [
+        "strictBindCallApply": true,
-      "node_modules/@types"
+        "strictPropertyInitialization": true,
-    ]
+        "alwaysStrict": true,
-  },
+        "noUnusedLocals": true,
-  "include": [
+        "noUnusedParameters": true,
-    "src"
+        "noImplicitReturns": true,
-  ],
+        "noUncheckedIndexedAccess": true,
-  "exclude": [
+        "exactOptionalPropertyTypes": true,
-    "node_modules"
+        "noFallthroughCasesInSwitch": true,
-  ]
+        "useUnknownInCatchVariables": true,
+        "skipLibCheck": true,
+        "noEmitOnError": true
+    },
+    "include": ["src"],
+    "exclude": ["node_modules", "dist"]
 }

tsconfig.test.json

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

tsup.config.ts

@@ -1,9 +1,9 @@
-import {defineConfig} from "tsup";
+import { defineConfig } from 'tsup';
 
 export default defineConfig({
-    format: ["cjs", "esm"],
+    format: ['cjs', 'esm'],
-    entry: ["./src/index.ts"],
+    entry: ['./src/index.ts'],
-    dts: true,
+    dts: false,
     shims: true,
     skipNodeModulesBundle: true,
     clean: true,