9 Commits
75 changed files with 5401 additions and 6199 deletions

No files matched your search

+14 -1
View File
@@ -1 +1,14 @@
node_modules
# Ignore everything by default
*
# Dockerfile
!Dockerfile
# Source
!src/
# Dependencies
!package*.json
# Typescript compiller config
!tsconfig.json
+19 -13
View File
@@ -1,15 +1,21 @@
{
"env": { "browser": true, "es2021": true },
"extends": ["eslint:recommended", "plugin:@typescript-eslint/recommended"],
"parser": "@typescript-eslint/parser",
"parserOptions": { "ecmaVersion": "latest", "sourceType": "module" },
"plugins": ["@typescript-eslint"],
"rules": {
"indent": ["error", 4],
"linebreak-style": ["error", "windows"],
"quotes": ["error", "double"],
"semi": ["error", "always"],
"brace-style": ["error", "stroustrup"],
"arrow-body-style": ["error", "as-needed"]
}
"root": true,
"parser": "@typescript-eslint/parser",
"parserOptions": {
"warnOnUnsupportedTypeScriptVersion": false,
"sourceType": "module"
},
"env": {
"browser": false,
"node": true,
"es6": true
},
"extends": ["eslint:recommended", "plugin:@typescript-eslint/recommended", "prettier"],
"plugins": ["@typescript-eslint", "import", "simple-import-sort"],
"ignorePatterns": ["**/node_modules/**", "/dist/**", "/tests/**"],
"rules": {
"curly": ["error", "all"],
"simple-import-sort/imports": "error",
"simple-import-sort/exports": "error"
}
}
-63
View File
@@ -1,63 +0,0 @@
###############################################################################
# Set default behavior to automatically normalize line endings.
###############################################################################
* text=auto
###############################################################################
# Set default behavior for command prompt diff.
#
# This is need for earlier builds of msysgit that does not have it on by
# default for csharp files.
# Note: This is only used by command line
###############################################################################
#*.cs diff=csharp
###############################################################################
# Set the merge driver for project and solution files
#
# Merging from the command prompt will add diff markers to the files if there
# are conflicts (Merging from VS is not affected by the settings below, in VS
# the diff markers are never inserted). Diff markers may cause the following
# file extensions to fail to load in VS. An alternative would be to treat
# these files as binary and thus will always conflict and require user
# intervention with every merge. To do so, just uncomment the entries below
###############################################################################
#*.sln merge=binary
#*.csproj merge=binary
#*.vbproj merge=binary
#*.vcxproj merge=binary
#*.vcproj merge=binary
#*.dbproj merge=binary
#*.fsproj merge=binary
#*.lsproj merge=binary
#*.wixproj merge=binary
#*.modelproj merge=binary
#*.sqlproj merge=binary
#*.wwaproj merge=binary
###############################################################################
# behavior for image files
#
# image files are treated as binary by default.
###############################################################################
#*.jpg binary
#*.png binary
#*.gif binary
###############################################################################
# diff behavior for common document formats
#
# Convert binary document formats to text before diffing them. This feature
# is only available from the command line. Turn it on by uncommenting the
# entries below.
###############################################################################
#*.doc diff=astextplain
#*.DOC diff=astextplain
#*.docx diff=astextplain
#*.DOCX diff=astextplain
#*.dot diff=astextplain
#*.DOT diff=astextplain
#*.pdf diff=astextplain
#*.PDF diff=astextplain
#*.rtf diff=astextplain
#*.RTF diff=astextplain
+31 -32
View File
@@ -5,48 +5,47 @@ name: CI/CD
on:
push:
tags:
- '*'
tags:
- "*"
jobs:
build:
runs-on: ubuntu-latest
strategy:
matrix:
node-version: [16.x]
node-version: [18.x]
# See supported Node.js release schedule at https://nodejs.org/en/about/releases/
steps:
- uses: actions/checkout@v3
- name: Use Node.js ${{ matrix.node-version }}
uses: actions/setup-node@v3
with:
node-version: ${{ matrix.node-version }}
cache: 'npm'
- run: npm ci
- run: npm run build --if-present
- name: Check out the repo
uses: actions/checkout@v3
- uses: actions/checkout@v3
- name: Use Node.js ${{ matrix.node-version }}
uses: actions/setup-node@v3
with:
node-version: ${{ matrix.node-version }}
cache: "npm"
- run: npm ci
- run: npm run build --if-present
- name: Log in to Docker Hub
uses: docker/login-action@f054a8b539a109f9f41c372932f1ae047eff08c9
with:
username: ${{ secrets.DOCKER_USERNAME }}
password: ${{ secrets.DOCKER_PASSWORD }}
- name: Check out the repo
uses: actions/checkout@v3
- name: Extract metadata (tags, labels) for Docker
id: meta
uses: docker/metadata-action@98669ae865ea3cffbcbaa878cf57c20bbf1c6c38
with:
images: unknowableshade/quetza-bot
- name: Log in to Docker Hub
uses: docker/login-action@f054a8b539a109f9f41c372932f1ae047eff08c9
with:
username: ${{ secrets.DOCKER_USERNAME }}
password: ${{ secrets.DOCKER_PASSWORD }}
- name: Build and push Docker image
uses: docker/build-push-action@ad44023a93711e3deb337508980b4b5e9bcdc5dc
with:
context: .
push: true
tags: ${{ steps.meta.outputs.tags }}
labels: ${{ steps.meta.outputs.labels }}
- name: Extract metadata (tags, labels) for Docker
id: meta
uses: docker/metadata-action@98669ae865ea3cffbcbaa878cf57c20bbf1c6c38
with:
images: unknowableshade/quetza-bot
- name: Build and push Docker image
uses: docker/build-push-action@ad44023a93711e3deb337508980b4b5e9bcdc5dc
with:
context: .
push: true
tags: ${{ steps.meta.outputs.tags }}
labels: ${{ steps.meta.outputs.labels }}
+58 -368
View File
@@ -1,374 +1,64 @@
## Ignore Visual Studio temporary files, build results, and
## files generated by popular Visual Studio add-ons.
##
## Get latest from https://github.com/github/gitignore/blob/master/VisualStudio.gitignore
# User-specific files
*.rsuser
*.suo
*.user
*.userosscache
*.sln.docstates
# User-specific files (MonoDevelop/Xamarin Studio)
*.userprefs
# Mono auto generated files
mono_crash.*
# Build results
[Dd]ebug/
[Dd]ebugPublic/
[Rr]elease/
[Rr]eleases/
x64/
x86/
[Ww][Ii][Nn]32/
[Aa][Rr][Mm]/
[Aa][Rr][Mm]64/
bld/
[Bb]in/
[Oo]bj/
[Oo]ut/
[Ll]og/
[Ll]ogs/
# Visual Studio 2015/2017 cache/options directory
.vs/
# Uncomment if you have tasks that create the project's static files in wwwroot
#wwwroot/
# Visual Studio 2017 auto generated files
Generated\ Files/
# MSTest test Results
[Tt]est[Rr]esult*/
[Bb]uild[Ll]og.*
# NUnit
*.VisualState.xml
TestResult.xml
nunit-*.xml
# Build Results of an ATL Project
[Dd]ebugPS/
[Rr]eleasePS/
dlldata.c
# Benchmark Results
BenchmarkDotNet.Artifacts/
# .NET Core
project.lock.json
project.fragment.lock.json
artifacts/
# ASP.NET Scaffolding
ScaffoldingReadMe.txt
# StyleCop
StyleCopReport.xml
# Files built by Visual Studio
*_i.c
*_p.c
*_h.h
*.ilk
*.meta
*.obj
*.iobj
*.pch
*.pdb
*.ipdb
*.pgc
*.pgd
*.rsp
*.sbr
*.tlb
*.tli
*.tlh
*.tmp
*.tmp_proj
*_wpftmp.csproj
# Logs
logs
*.log
*.vspscc
*.vssscc
.builds
*.pidb
*.svclog
*.scc
npm-debug.log*
yarn-debug.log*
yarn-error.log*
lerna-debug.log*
.pnpm-debug.log*
# Chutzpah Test files
_Chutzpah*
# Diagnostic reports (https://nodejs.org/api/report.html)
report.[0-9]*.[0-9]*.[0-9]*.[0-9]*.json
# Visual C++ cache files
ipch/
*.aps
*.ncb
*.opendb
*.opensdf
*.sdf
*.cachefile
*.VC.db
*.VC.VC.opendb
# Runtime data
pids
*.pid
*.seed
*.pid.lock
# Visual Studio profiler
*.psess
*.vsp
*.vspx
*.sap
# Visual Studio Trace Files
*.e2e
# TFS 2012 Local Workspace
$tf/
# Guidance Automation Toolkit
*.gpState
# ReSharper is a .NET coding add-in
_ReSharper*/
*.[Rr]e[Ss]harper
*.DotSettings.user
# TeamCity is a build add-in
_TeamCity*
# DotCover is a Code Coverage Tool
*.dotCover
# AxoCover is a Code Coverage Tool
.axoCover/*
!.axoCover/settings.json
# Coverlet is a free, cross platform Code Coverage Tool
coverage*.json
coverage*.xml
coverage*.info
# Visual Studio code coverage results
*.coverage
*.coveragexml
# NCrunch
_NCrunch_*
.*crunch*.local.xml
nCrunchTemp_*
# MightyMoose
*.mm.*
AutoTest.Net/
# Web workbench (sass)
.sass-cache/
# Installshield output folder
[Ee]xpress/
# DocProject is a documentation generator add-in
DocProject/buildhelp/
DocProject/Help/*.HxT
DocProject/Help/*.HxC
DocProject/Help/*.hhc
DocProject/Help/*.hhk
DocProject/Help/*.hhp
DocProject/Help/Html2
DocProject/Help/html
# Click-Once directory
publish/
# Publish Web Output
*.[Pp]ublish.xml
*.azurePubxml
# Note: Comment the next line if you want to checkin your web deploy settings,
# but database connection strings (with potential passwords) will be unencrypted
*.pubxml
*.publishproj
# Microsoft Azure Web App publish settings. Comment the next line if you want to
# checkin your Azure Web App publish settings, but sensitive information contained
# in these scripts will be unencrypted
PublishScripts/
# NuGet Packages
*.nupkg
# NuGet Symbol Packages
*.snupkg
# The packages folder can be ignored because of Package Restore
**/[Pp]ackages/*
# except build/, which is used as an MSBuild target.
!**/[Pp]ackages/build/
# Uncomment if necessary however generally it will be regenerated when needed
#!**/[Pp]ackages/repositories.config
# NuGet v3's project.json files produces more ignorable files
*.nuget.props
*.nuget.targets
# Microsoft Azure Build Output
csx/
*.build.csdef
# Microsoft Azure Emulator
ecf/
rcf/
# Windows Store app package directories and files
AppPackages/
BundleArtifacts/
Package.StoreAssociation.xml
_pkginfo.txt
*.appx
*.appxbundle
*.appxupload
# Visual Studio cache files
# files ending in .cache can be ignored
*.[Cc]ache
# but keep track of directories ending in .cache
!?*.[Cc]ache/
# Others
ClientBin/
~$*
*~
*.dbmdl
*.dbproj.schemaview
*.jfm
*.pfx
*.publishsettings
orleans.codegen.cs
# Including strong name files can present a security risk
# (https://github.com/github/gitignore/pull/2483#issue-259490424)
#*.snk
# Since there are multiple workflows, uncomment next line to ignore bower_components
# (https://github.com/github/gitignore/pull/1529#issuecomment-104372622)
#bower_components/
# RIA/Silverlight projects
Generated_Code/
# Backup & report files from converting an old project file
# to a newer Visual Studio version. Backup files are not needed,
# because we have git ;-)
_UpgradeReport_Files/
Backup*/
UpgradeLog*.XML
UpgradeLog*.htm
ServiceFabricBackup/
*.rptproj.bak
# SQL Server files
*.mdf
*.ldf
*.ndf
# Business Intelligence projects
*.rdl.data
*.bim.layout
*.bim_*.settings
*.rptproj.rsuser
*- [Bb]ackup.rdl
*- [Bb]ackup ([0-9]).rdl
*- [Bb]ackup ([0-9][0-9]).rdl
# Microsoft Fakes
FakesAssemblies/
# GhostDoc plugin setting file
*.GhostDoc.xml
# Node.js Tools for Visual Studio
.ntvs_analysis.dat
node_modules/
# Visual Studio 6 build log
*.plg
# Visual Studio 6 workspace options file
*.opt
# Visual Studio 6 auto-generated workspace file (contains which files were open etc.)
*.vbw
# Visual Studio LightSwitch build output
**/*.HTMLClient/GeneratedArtifacts
**/*.DesktopClient/GeneratedArtifacts
**/*.DesktopClient/ModelManifest.xml
**/*.Server/GeneratedArtifacts
**/*.Server/ModelManifest.xml
_Pvt_Extensions
# Paket dependency manager
.paket/paket.exe
paket-files/
# FAKE - F# Make
.fake/
# CodeRush personal settings
.cr/personal
# Python Tools for Visual Studio (PTVS)
__pycache__/
*.pyc
# Cake - Uncomment if you are using it
# tools/**
# !tools/packages.config
# Tabs Studio
*.tss
# Telerik's JustMock configuration file
*.jmconfig
# BizTalk build output
*.btp.cs
*.btm.cs
*.odx.cs
*.xsd.cs
# OpenCover UI analysis results
OpenCover/
# Azure Stream Analytics local run output
ASALocalRun/
# MSBuild Binary and Structured Log
*.binlog
# NVidia Nsight GPU debugger configuration file
*.nvuser
# MFractors (Xamarin productivity tool) working folder
.mfractor/
# Local History for Visual Studio
.localhistory/
# BeatPulse healthcheck temp database
healthchecksdb
# Backup folder for Package Reference Convert tool in Visual Studio 2017
MigrationBackup/
# Ionide (cross platform F# VS Code tools) working folder
.ionide/
# Fody - auto-generated XML schema
FodyWeavers.xsd
# assetscript restrictions
dist/
*.js
*.js.map
# binaries is not bundled
# Binaries
bin/
# Keep enviromental variables out of version control
*.env
# Compiled binary addons (https://nodejs.org/api/addons.html)
build/Release
# Dependency directories
node_modules/
jspm_packages/
# TypeScript cache
*.tsbuildinfo
dist/
# Optional npm cache directory
.npm
# Optional eslint cache
.eslintcache
# Optional REPL history
.node_repl_history
# Output of 'npm pack'
*.tgz
# Yarn Integrity file
.yarn-integrity
# dotenv environment variable files
.env
.env.development.local
.env.test.local
.env.production.local
.env.local
# VSCode
.vscode-test
.vscode
# yarn v2
.yarn/cache
.yarn/unplugged
.yarn/build-state.yml
.yarn/install-state.gz
.pnp.*
+5
View File
@@ -0,0 +1,5 @@
# Node.js Tools
node_modules
# Typescript compiller artifacts
dist/
+23
View File
@@ -0,0 +1,23 @@
{
"semi": true,
"trailingComma": "none",
"singleQuote": false,
"printWidth": 100,
"arrowParens": "always",
"bracketSpacing": true,
"endOfLine": "crlf",
"overrides": [
{
"files": ["**/*.json, **/*.yml"],
"options": {
"tabWidth": 2
}
},
{
"files": ["**/*.ts"],
"options": {
"tabWidth": 4
}
}
]
}
+8 -11
View File
@@ -1,9 +1,10 @@
FROM node:16
RUN apt -y update
RUN apt install -y ffmpeg
RUN apt install -y python3-pip
FROM node:18-alpine
RUN apk update
RUN apk add --no-cache bash
RUN apk add --no-cache curl
RUN apk add --no-cache ffmpeg
RUN apk add --no-cache python3
WORKDIR /usr/src/app
@@ -11,11 +12,7 @@ RUN mkdir bin
RUN curl -L https://yt-dl.org/downloads/latest/youtube-dl -o /usr/src/app/bin/youtube-dl
RUN chmod a+rx /usr/src/app/bin/youtube-dl
COPY package*.json ./
COPY . .
RUN npm ci
COPY . .
run npm run build
CMD [ "npm", "start" ]
CMD [ "npm", "start" ]
+1
View File
@@ -0,0 +1 @@
worker: npm start
+8 -8
View File
@@ -1,16 +1,16 @@
# Quetza - 2210.1 <soundrewrite>
# Quetza - 2302.1
_Neat typescript discord bot._
## About
- Base player features.
- Play music from YouTube and many other sites.
- Lots of different filters _(nightcore, earrape etc.)_.
- Slash commands.
- Base player features.
- Play music from YouTube and many other sites.
- Lots of different filters _(nightcore, earrape etc.)_.
- Slash commands.
## Links
- **[Dependencies](https://github.com/unknowableshade/quetza-bot/blob/master/package.json)**
- **[Docker](https://hub.docker.com/repository/docker/unknowableshade/quetza-bot)**
- **[Licence](https://github.com/unknowableshade/5a0b-bot/blob/master/LICENSE)**
- **[Dependencies](https://github.com/unknowableshade/quetza-bot/blob/master/package.json)**
- **[Docker](https://hub.docker.com/repository/docker/unknowableshade/quetza-bot)**
- **[Licence](https://github.com/unknowableshade/5a0b-bot/blob/master/LICENSE)**
+3363 -3976
View File
File diff suppressed because it is too large. Load diff
+48 -42
View File
@@ -1,44 +1,50 @@
{
"name": "quetza-bot",
"engines": {
"node": "16.x.x",
"npm": "*"
},
"version": "2205.3.0",
"description": "Discord multifunctional bot",
"author": {
"name": "unknowableshade",
"email": "60275123+unknowableshade@users.noreply.github.com",
"url": "https://unknowableshade.ru"
},
"repository": {
"type": "git",
"url": "git+https://github.com/unknowableshade/quetza-bot.git"
},
"bugs": {
"url": "https://github.com/unknowableshade/quetza-bot/issues"
},
"readme": "https://github.com/unknowableshade/quetza-bot#readme",
"license": "MIT",
"main": "dist/index.js",
"scripts": {
"start": "node dist/index.js",
"build": "tsc --build",
"clean": "tsc --build --clean"
},
"dependencies": {
"@discordjs/opus": "^0.8.0",
"@discordjs/voice": "^0.11.0",
"discord-ytdl-core": "^5.0.4",
"discord.js": "^14.3.0",
"tweetnacl": "^1.0.3",
"ytdl-core": "^4.11.1"
},
"devDependencies": {
"@types/node": "^18.7.13",
"@typescript-eslint/eslint-plugin": "^5.35.1",
"@typescript-eslint/parser": "^5.35.1",
"eslint": "^8.22.0",
"typescript": "^4.8.2"
}
"name": "quetza-bot",
"engines": {
"node": "18.x.x",
"npm": "*"
},
"type": "module",
"version": "2303.1",
"description": "Discord multifunctional bot",
"author": {
"name": "unknowableshade",
"email": "60275123+unknowableshade@users.noreply.github.com",
"url": "https://unknowableshade.ru"
},
"repository": {
"type": "git",
"url": "git+https://github.com/unknowableshade/quetza-bot.git"
},
"bugs": {
"url": "https://github.com/unknowableshade/quetza-bot/issues"
},
"readme": "https://github.com/unknowableshade/quetza-bot#readme",
"license": "MIT",
"main": "dist/index.js",
"scripts": {
"start": "node dist/index.js",
"build": "npx tsc --build",
"clean": "npx tsc --build --clean",
"lint": "npx eslint --fix . && npx prettier --write .",
"postinstall": "npm run build"
},
"dependencies": {
"@discordjs/opus": "^0.8.0",
"@discordjs/voice": "^0.11.0",
"discord-ytdl-core": "^5.0.4",
"discord.js": "^14.3.0",
"tweetnacl": "^1.0.3",
"ytdl-core": "^4.11.1"
},
"devDependencies": {
"@types/node": "^18.7.13",
"@typescript-eslint/eslint-plugin": "^5.35.1",
"@typescript-eslint/parser": "^5.35.1",
"eslint": "^8.22.0",
"eslint-config-prettier": "^8.6.0",
"eslint-plugin-import": "^2.27.5",
"eslint-plugin-simple-import-sort": "^10.0.0",
"typescript": "^4.8.2"
}
}
-24
View File
@@ -1,24 +0,0 @@
import Client from "../lib/Client";
import { CommandInteraction, SlashCommandBuilder } from "discord.js";
import I18n from "../lib/I18n";
export async function run(client: Client, ctx: CommandInteraction) {
if (!ctx.guild || !ctx.channel) return;
const player = client.modules.music.get(ctx.guild.id, ctx.channel);
if (!player) return;
const amount = player.Queue.Tracks.length;
player.clear();
await ctx.reply({ embeds: [I18n.en.cleared(amount)] });
}
const data = new SlashCommandBuilder()
.setName("clear")
.setDescription("Clear the player's queue.");
export { data };
-40
View File
@@ -1,40 +0,0 @@
import Client from "../lib/Client";
import { CommandInteraction, GuildMember, SlashCommandBuilder } from "discord.js";
import I18n from "../lib/I18n";
export async function run(client: Client, ctx: CommandInteraction) {
if (!ctx.guild || !ctx.channel || !ctx.member) return;
await ctx.deferReply();
const player =
client.modules.music.get(ctx.guild.id, ctx.channel) ||
client.modules.music.set(ctx.guild, ctx.channel);
if (!player.Connection) {
const channel = (ctx.member as GuildMember).voice.channel;
if (channel) {
player.connect(channel);
await ctx.editReply({ embeds: [I18n.en.okConnected(channel.name)] });
}
else {
client.modules.music.del(ctx.guild.id);
await ctx.editReply({ embeds: [I18n.en.notConnected()] });
return undefined;
}
}
else {
await ctx.editReply({ embeds: [I18n.en.wasConnected()] });
}
return player;
}
const data = new SlashCommandBuilder()
.setName("connect")
.setDescription("Connect me to a voice channel.");
export { data };
-121
View File
@@ -1,121 +0,0 @@
import { CommandInteraction, SlashCommandBuilder } from "discord.js";
import Client from "../lib/Client";
import I18n from "../lib/I18n";
export async function run(client: Client, ctx: CommandInteraction) {
const filter = ctx.options.get("filter")?.value as string;
if (!ctx.guild || !ctx.channel) return;
const player = client.modules.music.get(ctx.guild.id, ctx.channel);
if (!player) return;
player.setFilter(filter || undefined);
await ctx.reply({ embeds: [I18n.en.filtered(filter || undefined)] });
}
const data = new SlashCommandBuilder()
.setName("filter")
.setDescription("Apply unique filters to the tracks.")
.addStringOption(option => option
.setName("filter")
.setDescription("Filter to apply.")
.setChoices(
{
name: "bassboost_low",
value: "bassboost_low",
},
{
name: "bassboost",
value: "bassboost",
},
{
name: "bassboost_high",
value: "bassboost_high",
},
{
name: "8D",
value: "8D",
},
{
name: "vaporwave",
value: "vaporwave",
},
{
name: "nightcore",
value: "nightcore",
},
{
name: "phaser",
value: "phaser",
},
{
name: "tremolo",
value: "tremolo",
},
{
name: "vibrato",
value: "vibrato",
},
{
name: "reverse",
value: "reverse",
},
{
name: "treble",
value: "treble",
},
{
name: "normalizer",
value: "normalizer",
},
{
name: "surrounding",
value: "surrounding",
},
{
name: "pulsator",
value: "pulsator",
},
{
name: "subboost",
value: "subboost",
},
{
name: "mono",
value: "mono",
},
{
name: "compressor",
value: "compressor",
},
{
name: "expander",
value: "expander",
},
{
name: "softlimiter",
value: "softlimiter",
},
{
name: "chorus",
value: "chorus",
},
{
name: "fadein",
value: "fadein",
},
{
name: "dim",
value: "dim",
},
{
name: "earrape",
value: "earrape",
})
.setRequired(true)
);
export { data };
-20
View File
@@ -1,20 +0,0 @@
import Client from "../lib/Client";
import { CommandInteraction, SlashCommandBuilder } from "discord.js";
import I18n from "../lib/I18n";
export async function run(client: Client, ctx: CommandInteraction) {
if (!ctx.guild || !ctx.channel || !ctx.member) return;
await ctx.deferReply();
const player = client.modules.music.get(ctx.guild.id, ctx.channel);
await ctx.editReply({ embeds: [I18n.en.playerInfo(player)] });
}
const data = new SlashCommandBuilder()
.setName("info")
.setDescription("Information about the playback.");
export { data };
-36
View File
@@ -1,36 +0,0 @@
import { CommandInteraction, SlashCommandBuilder } from "discord.js";
import Client from "../lib/Client";
import I18n from "../lib/I18n";
export async function run(client: Client, ctx: CommandInteraction) {
const pos = ctx.options.get("position")?.value as number;
const query = ctx.options.get("query")?.value as string;
if (!ctx.guild || !query || !pos || !ctx.channel) return;
const player = client.modules.music.get(ctx.guild.id, ctx.channel);
if (!player) return;
await ctx.deferReply();
const track = await player.add(query, ctx.user, pos - 1);
await ctx.editReply({ embeds: [I18n.en.appended(track)] });
}
const data = new SlashCommandBuilder()
.setName("insert")
.setDescription("Insert a new track to specific position in the queue.")
.addStringOption(option => option
.setName("query")
.setDescription("Title or URL of the song.")
.setRequired(true)
)
.addIntegerOption(option => option
.setName("position")
.setDescription("Position to insert.",)
.setRequired(true)
);
export { data };
-28
View File
@@ -1,28 +0,0 @@
import { CommandInteraction, SlashCommandBuilder } from "discord.js";
import Client from "../lib/Client";
import I18n from "../lib/I18n";
export async function run(client: Client, ctx: CommandInteraction) {
const query = ctx.options.get("query")?.value as string;
if (!ctx.guild || !query || !ctx.channel) return;
const player = client.modules.music.get(ctx.guild.id, ctx.channel);
if (!player) return;
const state = !isNaN(+query) && isFinite(+query) && !/e/i.test(query) ? player.jump(parseInt(query) - 1) : player.jump(query);
await ctx.reply({ embeds: [I18n.en.jumped(state)] });
}
const data = new SlashCommandBuilder()
.setName("jump")
.setDescription("Jump to specific track in the queue.")
.addStringOption(option => option
.setName("query")
.setDescription("Position or title to jump to.")
.setRequired(true)
);
export { data };
-32
View File
@@ -1,32 +0,0 @@
import { CommandInteraction, SlashCommandBuilder } from "discord.js";
import Client from "../lib/Client";
import { loopOption } from "../lib/Types";
import I18n from "../lib/I18n";
export async function run(client: Client, ctx: CommandInteraction) {
const query = ctx.options.get("option")?.value as string;
if (!ctx.guild || !query || !ctx.channel) return;
const player = client.modules.music.get(ctx.guild.id, ctx.channel);
if (!player) return;
player.Queue.Loop = query as loopOption;
await ctx.reply({ embeds: [I18n.en.looped(query as loopOption)] });
}
const data = new SlashCommandBuilder()
.setName("loop")
.setDescription("Select player's loop mode.")
.addStringOption(option => option
.setName("option")
.setDescription("Select loop option.")
.setChoices( { name: "loop queue", value: "LOOP" },
{ name: "loop single track", value: "SONG" },
{ name: "Till end", value: "NONE" },
{ name: "Random order", value: "AUTO" })
.setRequired(true));
export { data };
-21
View File
@@ -1,21 +0,0 @@
import { CommandInteraction, SlashCommandBuilder } from "discord.js";
import Client from "../lib/Client";
import I18n from "../lib/I18n";
export async function run(client: Client, ctx: CommandInteraction) {
if (!ctx.guild || !ctx.channel) return;
const player = client.modules.music.get(ctx.guild.id, ctx.channel);
if (!player) return;
player.skip();
await ctx.reply({ embeds: [I18n.en.skipped()] });
}
const data = new SlashCommandBuilder()
.setName("next")
.setDescription("Skip current song.");
export { data };
-21
View File
@@ -1,21 +0,0 @@
import { CommandInteraction, SlashCommandBuilder } from "discord.js";
import Client from "../lib/Client";
import I18n from "../lib/I18n";
export async function run(client: Client, ctx: CommandInteraction) {
if (!ctx.guild || !ctx.channel) return;
const player = client.modules.music.get(ctx.guild.id, ctx.channel);
if (!player) return;
const state = player.pause();
await ctx.reply({ embeds: [I18n.en.paused(state)] });
}
const data = new SlashCommandBuilder()
.setName("pause")
.setDescription("Toggle pause on player.");
export { data };
-22
View File
@@ -1,22 +0,0 @@
import { CommandInteraction, SlashCommandBuilder } from "discord.js";
import Client from "../lib/Client";
import I18n from "../lib/I18n";
export async function run(client: Client, ctx: CommandInteraction) {
const start = Date.now();
if (!client.application) {
await ctx.reply({ embeds: [I18n.en.ping(undefined)] });
return;
}
await client.application.fetch();
await ctx.reply({ embeds: [I18n.en.ping(Date.now() - start)] });
}
const data = new SlashCommandBuilder()
.setName("ping")
.setDescription("Try to ping me.");
export { data };
-32
View File
@@ -1,32 +0,0 @@
import { CommandInteraction, SlashCommandBuilder } from "discord.js";
import Client from "../lib/Client";
import { run as connect } from "./connect";
import I18n from "../lib/I18n";
export async function run(client: Client, ctx: CommandInteraction) {
const query = ctx.options.get("query")?.value as string;
const player = await connect(client, ctx);
if (!player) return;
if (query) {
const track = await player.add(query, ctx.user);
await ctx.editReply({ embeds: [I18n.en.appended(track)] });
}
if (!player.Resource) {
player.play();
}
}
const data = new SlashCommandBuilder()
.setName("play")
.setDescription("Launch player and add songs to the queue.")
.addStringOption(option => option
.setName("query")
.setDescription("Title or URL of the song.")
);
export { data };
-85
View File
@@ -1,85 +0,0 @@
import {
ActionRowBuilder,
ButtonBuilder,
ButtonInteraction,
ButtonStyle,
CommandInteraction,
Message,
MessageActionRowComponentBuilder,
SlashCommandBuilder
} from "discord.js";
import Client from "../lib/Client";
import I18n from "../lib/I18n";
export async function run(client: Client, ctx: CommandInteraction) {
if (!ctx.guild || !ctx.channel) return;
const player = client.modules.music.get(ctx.guild.id, ctx.channel);
if (!player) return;
await ctx.deferReply();
if (player.Queue.empty()) {
await ctx.editReply({ embeds: [I18n.en.queueEmpty()] });
return;
}
let page = 0;
const row = new ActionRowBuilder<MessageActionRowComponentBuilder>().addComponents(
new ButtonBuilder()
.setCustomId("QueueTop")
.setLabel("🔼")
.setStyle(ButtonStyle.Primary),
new ButtonBuilder()
.setCustomId("QueueUp")
.setLabel("🔺")
.setStyle(ButtonStyle.Secondary),
new ButtonBuilder()
.setCustomId("QueueDown")
.setLabel("🔻")
.setStyle(ButtonStyle.Secondary),
new ButtonBuilder()
.setCustomId("QueueEnd")
.setLabel("🔽")
.setStyle(ButtonStyle.Primary)
);
const message = (await ctx.editReply({
embeds: [I18n.en.queueDesigner(player.Queue, 0, player.Resource)],
components: [row],
})) as Message;
const collector = message.createMessageComponentCollector({ time: 30000 });
collector.on("collect", async (btn: ButtonInteraction) => {
switch (btn.customId) {
case "QueueTop": {
page = 0;
break;
}
case "QueueUp": {
page = Math.max(page - 1, 0);
break;
}
case "QueueDown": {
page = Math.min(page + 1, Math.floor(player.Queue.Tracks.length / 11));
break;
}
case "QueueEnd":
page = Math.floor(player.Queue.Tracks.length / 11);
}
await btn.update({
embeds: [I18n.en.queueDesigner(player.Queue, page, player.Resource)],
});
});
}
const data = new SlashCommandBuilder()
.setName("queue")
.setDescription("Print out the queue.");
export { data };
-28
View File
@@ -1,28 +0,0 @@
import { CommandInteraction, SlashCommandBuilder } from "discord.js";
import Client from "../lib/Client";
import I18n from "../lib/I18n";
export async function run(client: Client, ctx: CommandInteraction) {
const query = ctx.options.get("query")?.value as string;
if (!ctx.guild || !query || !ctx.channel) return;
const player = client.modules.music.get(ctx.guild.id, ctx.channel);
if (!player) return;
const track = !isNaN(+query) && isFinite(+query) && !/e/i.test(query) ? player.remove(parseInt(query) - 1) : player.remove(query);
await ctx.reply({ embeds: [I18n.en.removed(track)] });
}
const data = new SlashCommandBuilder()
.setName("remove")
.setDescription("Remove specific track in the queue.")
.addStringOption(option => option
.setName("query")
.setDescription("Position or title to remove.")
.setRequired(true)
);
export { data };
-21
View File
@@ -1,21 +0,0 @@
import { CommandInteraction, SlashCommandBuilder } from "discord.js";
import Client from "../lib/Client";
import I18n from "../lib/I18n";
export async function run(client: Client, ctx: CommandInteraction) {
if (!ctx.guild || !ctx.channel) return;
const player = client.modules.music.get(ctx.guild.id, ctx.channel);
if (!player) return;
player.shuffle();
await ctx.reply({ embeds: [I18n.en.reshuffle()] });
}
const data = new SlashCommandBuilder()
.setName("reshuffle")
.setDescription("Shuffle the queue.");
export { data };
-41
View File
@@ -1,41 +0,0 @@
import { CommandInteraction, SlashCommandBuilder } from "discord.js";
import Client from "../lib/Client";
import I18n from "../lib/I18n";
export async function run(client: Client, ctx: CommandInteraction) {
const hours = ctx.options.get("hrs")?.value as number || 0;
const minutes = ctx.options.get("mins")?.value as number || 0;
const seconds = ctx.options.get("secs")?.value as number || 0;
if (!ctx.guild || !ctx.channel) return;
const player = client.modules.music.get(ctx.guild.id, ctx.channel);
if (!player) return;
const time = hours * 3600 + minutes * 60 + seconds;
player.seek(time * 1000);
await ctx.reply({
embeds: [I18n.en.fastForwarded(time)],
});
}
const data = new SlashCommandBuilder()
.setName("seek")
.setDescription("Fast-forward by the time.")
.addIntegerOption(option => option
.setName("hrs")
.setDescription("Hours to seek.")
)
.addIntegerOption(option => option
.setName("mins")
.setDescription("Minutes to seek.")
)
.addIntegerOption(option => option
.setName("secs")
.setDescription("Seconds to seek.")
);
export { data };
-21
View File
@@ -1,21 +0,0 @@
import { CommandInteraction, SlashCommandBuilder } from "discord.js";
import Client from "../lib/Client";
import I18n from "../lib/I18n";
export async function run(client: Client, ctx: CommandInteraction) {
if (!ctx.guild || !ctx.channel) return;
const player = client.modules.music.get(ctx.guild.id, ctx.channel);
if (!player) return;
player.destroy();
await ctx.reply({ embeds: [I18n.en.destroyed()] });
}
const data = new SlashCommandBuilder()
.setName("stop")
.setDescription("Destroy the player.");
export { data };
-28
View File
@@ -1,28 +0,0 @@
import { CommandInteraction, SlashCommandBuilder } from "discord.js";
import Client from "../lib/Client";
import I18n from "../lib/I18n";
export async function run(client: Client, ctx: CommandInteraction) {
const volume = ctx.options.get("volume")?.value as number || 100;
if (!ctx.guild || !ctx.channel) return;
const player = client.modules.music.get(ctx.guild.id, ctx.channel);
if (!player) return;
player.Volume = volume;
await ctx.reply({ embeds: [I18n.en.volumeSet(player.Volume)] });
}
const data = new SlashCommandBuilder()
.setName("volume")
.setDescription("Change player's volume amount.")
.addIntegerOption(option => option
.setName("volume")
.setDescription("Volume in percents.")
.setRequired(true)
);
export { data };
+6 -4
View File
@@ -1,10 +1,12 @@
import path from "path";
import { fileURLToPath } from "url";
const ROOT = path.dirname(fileURLToPath(import.meta.url));
const config = {
token: process.env.DISCORD_TOKEN,
commands: path.join(__dirname, "/commands/"),
events: path.join(__dirname, "/events/"),
binaries: path.join(__dirname, "/../bin/")
discordToken: process.env.DISCORD_TOKEN,
modulesDir: path.join(ROOT, "/modules/"),
binariesDir: path.join(ROOT, "/../bin/")
};
export default config;
-14
View File
@@ -1,14 +0,0 @@
import { Interaction } from "discord.js";
import Client from "../lib/Client";
export async function run(client: Client, args: Interaction[]): Promise<void> {
const [interaction] = args;
if (interaction.isCommand()) {
const command = client.Commands.get(interaction.commandName);
if (command) command.run(client, interaction);
}
}
export const name = "interactionCreate";
-22
View File
@@ -1,22 +0,0 @@
import Client from "../lib/Client";
import { generateDependencyReport } from "@discordjs/voice";
import { ActivityType } from "discord.js";
export async function run(client: Client): Promise<void> {
if (!client.user || !client.application) {
console.log("No user or application is provided!");
process.exit(1);
}
console.log(`${client.user.username} logged in as ${client.user.tag}!`);
console.log(generateDependencyReport());
client.user.setActivity("over you", { type: ActivityType.Watching });
const restCommands = Array.from(client.Commands.values()).map(
value => value.data
);
client.application.commands.set(restCommands);
}
export const name = "ready";
-24
View File
@@ -1,24 +0,0 @@
import { VoiceState } from "discord.js";
import I18n from "../lib/I18n";
import Client from "../lib/Client";
import { asleep } from "../lib/Misc";
export async function run(client: Client, args: VoiceState[]): Promise<void> {
const [oldState] = args;
const player = client.modules.music.get(oldState.guild.id);
if (!player || !oldState.channel || !client.user)
return;
if (oldState.channel.members.filter(value => value.user !== client.user).size === 0) {
await asleep(30000);
if (oldState.channel.members.filter(value => value.user !== client.user).size === 0) {
await player.Channel.send({ embeds: [I18n.en.fullyAlone()] });
player.destroy();
}
}
}
export const name = "voiceStateUpdate";
+8 -4
View File
@@ -1,6 +1,10 @@
import Client from "./lib/Client";
import config from "./config";
import { GatewayIntentBits } from "discord.js";
const client = new Client();
import config from "./config.js";
import Client from "./lib/client.js";
client.login(config.token);
const client = new Client({
intents: [GatewayIntentBits.Guilds, GatewayIntentBits.GuildVoiceStates]
});
client.login(config.discordToken);
-56
View File
@@ -1,56 +0,0 @@
import {
Client as DiscordClient
} from "discord.js";
import { existsSync, readdirSync } from "fs";
import path from "path";
import Music from "./Music";
import { command, event } from "./Types";
import config from "../config";
export default class Client extends DiscordClient {
private commands = new Map<string, command>();
get Commands(): Map<string, command> {
return this.commands;
}
public readonly modules = {
music: new Music()
};
public constructor() {
super({
intents: [
"Guilds",
"GuildMessages",
"GuildVoiceStates",
],
});
if (existsSync(config.commands)) {
const files = readdirSync(config.commands).filter((file) =>
file.endsWith(".js")
);
for (const file of files) {
import(path.join(config.commands, file)).then((cmd: command) =>
this.commands.set(cmd.data.name, cmd)
);
}
}
if (existsSync(config.events)) {
const files = readdirSync(config.events).filter((file) =>
file.endsWith(".js")
);
for (const file of files) {
import(path.join(config.events, file)).then((evnt: event) => {
this.on(evnt.name, (...args: unknown[]) =>
evnt.run(this, args)
);
});
}
}
}
}
-77
View File
@@ -1,77 +0,0 @@
export default class Filter {
private filters: Record<string, [boolean, string]> = {
bassboost_low: [false, "bass=g=15:f=110:w=0.3"],
bassboost: [false, "bass=g=20:f=110:w=0.3"],
bassboost_high: [false, "bass=g=30:f=110:w=0.3"],
"8D": [false, "apulsator=hz=0.09"],
vaporwave: [false, "aresample=48000,asetrate=48000*0.75"],
nightcore: [false, "aresample=48000,asetrate=48000*1.25"],
phaser: [false, "aphaser=in_gain=0.4"],
tremolo: [false, "tremolo"],
vibrato: [false, "vibrato=f=6.5"],
reverse: [false, "areverse"],
treble: [false, "treble=g=5"],
normalizer: [false, "dynaudnorm=g=101"],
normalizer2: [false, "acompressor"],
surrounding: [false, "surround"],
pulsator: [false, "apulsator=hz=1"],
subboost: [false, "asubboost"],
karaoke: [false, "stereotools=mlev=0.03"],
flanger: [false, "flanger"],
gate: [false, "agate"],
haas: [false, "haas"],
mcompand: [false, "mcompand"],
mono: [false, "pan=mono|c0=.5*c0+.5*c1"],
mstlr: [false, "stereotools=mode=ms>lr"],
mstrr: [false, "stereotools=mode=ms>rr"],
compressor: [
false,
"compand=points=-80/-105|-62/-80|-15.4/-15.4|0/-12|20/-7.6",
],
expander: [
false,
"compand=attacks=0:points=-80/-169|-54/-80|-49.5/-64.6|-41.1/-41.1|-25.8/-15|-10.8/-4.5|0/0|20/8.3",
],
softlimiter: [
false,
"compand=attacks=0:points=-80/-80|-12.4/-12.4|-6/-8|0/-6.8|20/-2.8",
],
chorus: [false, "chorus=0.7:0.9:55:0.4:0.25:2"],
chorus2d: [false, "chorus=0.6:0.9:50|60:0.4|0.32:0.25|0.4:2|1.3"],
chorus3d: [
false,
"chorus=0.5:0.9:50|60|40:0.4|0.32|0.3:0.25|0.4|0.3:2|2.3|1.3",
],
fadein: [false, "afade=t=in:ss=0:d=10"],
dim: [
false,
"afftfilt=\"'real=re * (1-clip((b/nb)*b,0,1))':imag='im * (1-clip((b/nb)*b,0,1))'\"",
],
earrape: [false, "channelsplit,sidechaingate=level_in=64"],
};
public get Filters(): [string, string][] {
return Object.entries(this.filters)
.filter(value => value[1][0]).map(value => [value[0], value[1][1]]);
}
public toggle(filter?: string): void {
if (!filter) {
Object.values(this.filters).forEach((value) => {
value[0] = false;
});
return;
}
if (Object.prototype.hasOwnProperty.call(this.filters, filter))
this.filters[filter][0] = !this.filters[filter][0];
}
public toString(): string {
return this.Filters.map(value => value[1]).join(",");
}
public empty(): boolean {
return this.Filters.length === 0;
}
}
-294
View File
@@ -1,294 +0,0 @@
import Player from "./Player";
import { loopOption, track } from "./Types";
import { loopMoji, secToISO, statusBarGenerator, volumeMoji } from "./Misc";
import Queue from "./Queue";
import { AudioResource } from "@discordjs/voice";
import { EmbedBuilder } from "discord.js";
export default class I18n {
public static en = {
nowPlaying: (track: track) => new EmbedBuilder()
.setColor("LuminousVividPink")
.setAuthor({
iconURL: track.requester.avatarURL() || undefined,
name: track.requester.tag,
})
.setTitle(track.title)
.setURL(track.url)
.setDescription("**playing now.**")
.setThumbnail(track.thumbnail),
cleared: (amount: number) => new EmbedBuilder()
.setColor("Green")
.setTitle(
`**♻️ ${amount} tracks have been cleared from the queue.**`
)
.setTimestamp(new Date()),
okConnected: (channel: string) => new EmbedBuilder()
.setColor("Green")
.setTitle(`**✅ Successfuly connected to:** _${channel}_.`),
notConnected: () => new EmbedBuilder()
.setColor("Red")
.setTitle(
"**🚫 Make yourself connected to a voice channel beforehand.**"
),
wasConnected: () => new EmbedBuilder()
.setColor("Yellow")
.setTitle("**⚠️ Already connected to a voice channel.**"),
filtered: (filter?: string) => new EmbedBuilder()
.setColor("Green")
.setTitle(filter ? `**✅ ${filter} was applied to the player.**` : "**✅ All filters were declined.**"),
appended: (track?: track) => !track
? new EmbedBuilder()
.setColor("Red")
.setTitle("**🚫 Could not add track to the queue.**")
: new EmbedBuilder()
.setColor("Green")
.setTitle(track.title)
.setURL(track.url)
.setThumbnail(track.thumbnail)
.setAuthor({
iconURL: track.requester.avatarURL() || undefined,
name: track.requester.tag,
})
.setDescription("**has been added to the queue.**")
.setTimestamp(new Date()),
jumped: (state: boolean) => state
? new EmbedBuilder()
.setColor("Green")
.setTitle("_**Perfoming jump.**_")
: new EmbedBuilder()
.setColor("Red")
.setTitle("**❗ Bad _jump_ request.**"),
looped: (query: loopOption) => {
switch (query) {
case "AUTO": {
return new EmbedBuilder()
.setColor("LuminousVividPink")
.setTitle(
"**🔀 Shuffle mode** _(does not affect the queue order)_."
);
}
case "LOOP": {
return new EmbedBuilder()
.setColor("Blue")
.setTitle("**🔁 Looping over the queue.**");
}
case "NONE": {
return new EmbedBuilder()
.setColor("Red")
.setTitle("**⤵️ Player will stop on the queue end.**");
}
case "SONG": {
return new EmbedBuilder()
.setColor("Yellow")
.setTitle("**🔂 Looping a single track.**");
}
}
},
skipped: () => new EmbedBuilder()
.setColor("Green")
.setTitle("**⏭️ Skipping.**"),
paused: (state: boolean) => state
? new EmbedBuilder()
.setColor("Green")
.setTitle("_**▶️ Resumed.**_")
: new EmbedBuilder()
.setColor("Yellow")
.setTitle("_**⏸️ Paused.**_"),
removed: (track?: track) => track
? new EmbedBuilder()
.setColor("Green")
.setTitle(track.title)
.setDescription("**was removed from the queue.**")
.setTimestamp(new Date())
.setURL(track.url)
.setThumbnail(track.thumbnail)
: new EmbedBuilder()
.setColor("Red")
.setTitle("**❗ Bad _remove_ request.**"),
fastForwarded: (amount: number) => new EmbedBuilder()
.setColor("Blue")
.setTitle(
`**⏩ Fast-forwarding to ${secToISO(
amount
)}**`
),
destroyed: () => new EmbedBuilder()
.setColor("Red")
.setTitle("**💀 Destroying the player.**"),
volumeSet: (amount: number) => new EmbedBuilder()
.setColor("Green")
.setTitle(`**${volumeMoji(amount)} Volume has been set to ${amount}%**`),
queueEmpty: () => new EmbedBuilder()
.setColor("Yellow")
.setTitle("**❎ Queue is empty.**"),
playerInfo: (player?: Player) => {
if (!player)
return new EmbedBuilder()
.setColor("Red")
.setTitle("**🚫 Player does not exist.**");
if (player.Resource) {
return new EmbedBuilder()
.setColor("LuminousVividPink")
.setTitle(
`${player.Queue.Position + 1}. ${player.Resource.metadata.title}`
)
.setDescription(
statusBarGenerator(
player.Resource.playbackDuration / 1000,
player.Resource.metadata.duration
)
)
.setThumbnail(player.Resource.metadata.thumbnail)
.setURL(player.Resource.metadata.url)
.addFields([
{
name: "Applied Filters",
value:
player.Filter.Filters.map(
(value) => value[0]
).join("\n") + "\ndefault",
inline: true,
},
{
name: "Queue Length",
value: `🔢 ${player.Queue.Tracks.length}`,
inline: true,
},
{
name: "Queue Duration",
value: `💿 ${secToISO(player.Queue.Duration)}`,
inline: true,
},
{
name: "Queue Looping",
value: `${loopMoji(player.Queue.Loop)} ${player.Queue.Loop}`,
inline: true,
},
{
name: "Volume amount",
value: `${volumeMoji(player.Volume)} ${player.Volume}/150`,
inline: true,
},
{
name: "Player lifetime",
value: `🕓 ${secToISO((Date.now() - player.Created.getTime()) / 1000)}`,
inline: true,
},
]);
}
else {
return new EmbedBuilder()
.setColor("Blue")
.setTitle("💿 Insert the disk...")
.setDescription(statusBarGenerator(0, 0))
.setURL(
"https://www.youtube.com/watch?v=dQw4w9WgXcQ&ab_channel=RickAstley"
)
.addFields([
{
name: "Applied Filters",
value:
player.Filter.Filters.map(
(value) => value[0]
).join("\n") + "\ndefault",
inline: true,
},
{
name: "Queue Length",
value: `🔢 ${player.Queue.Tracks.length}`,
inline: true,
},
{
name: "Queue Duration",
value: `💿 ${secToISO(player.Queue.Duration)}`,
inline: true,
},
{
name: "Queue Looping",
value: `${loopMoji(player.Queue.Loop)} ${player.Queue.Loop}`,
inline: true,
},
{
name: "Volume amount",
value: `${volumeMoji(player.Volume)} ${player.Volume}/150`,
inline: true,
},
{
name: "Player lifetime",
value: `🕓 ${secToISO((Date.now() - player.Created.getTime()) / 1000)}`,
inline: true,
},
]);
}
},
queueDesigner: (
queue: Queue,
page: number,
resource: AudioResource<track> | undefined
) => {
page = Math.max(
0,
Math.min(Math.floor(queue.Tracks.length / 11), page)
);
return new EmbedBuilder()
.setColor("LuminousVividPink")
.setTitle(
resource
? `${queue.Position + 1}. ${resource.metadata.title}`
: "💿 Insert the disk..."
)
.setURL(
resource
? resource.metadata.url
: "https://www.youtube.com/watch?v=5mGuCdlCcNM&ab_channel=Ra%C3%BAlBlanco"
)
.setThumbnail(
resource
? resource.metadata.thumbnail
: "https/img.youtube.com/vi/5mGuCdlCcNM/default.jpg"
)
.setDescription(
resource
? statusBarGenerator(
resource.playbackDuration / 1000,
resource.metadata.duration
)
: statusBarGenerator(0, 0)
)
.setFields(
queue.Tracks.slice(page * 10, page * 10 + 10).map(
(value, index) => ({
name: `${
page * 10 + index + 1
}. ${value.title.padEnd(35)}`,
value: `**[${secToISO(value.duration)}]**`,
})
)
);
},
fullyAlone: () => new EmbedBuilder()
.setColor("LuminousVividPink")
.setTitle("🥬 I have decided to leave to conserve my energy.")
.setDescription(
"_**Since there was nobody in the voice channel.**_"
),
reshuffle: () => new EmbedBuilder()
.setColor("Green")
.setTitle("**✅ Successfuly reshuffled queue.**"),
ping: (ping?: number) => {
const title = ping ? `I have pinged ${ping} ms late.` : "There is no application.";
const comment = !ping ? "How am I speaking then?" : ping > 250 ? "I'm kinda slowpoke ngl." :
ping > 200 ? "I can do better than this." :
"Dream's speed!";
return new EmbedBuilder()
.setColor("Random")
.setTitle(`**${title}**`)
.setDescription(`_**${comment}**_`);
}
};
}
-25
View File
@@ -1,25 +0,0 @@
import { Guild, TextBasedChannel } from "discord.js";
import Player from "./Player";
export default class Music {
private players = new Map<string, Player>();
public get(guildId: string, channel?: TextBasedChannel): Player | undefined {
const player = this.players.get(guildId);
if (player) {
if (channel) player.Channel = channel;
return player;
}
}
public set(guild: Guild, channel: TextBasedChannel): Player {
const player = new Player(guild, this, channel);
this.players.set(guild.id, player);
return player;
}
public del(guildId: string): void {
this.players.delete(guildId);
}
}
-335
View File
@@ -1,335 +0,0 @@
import {
VoiceConnection,
AudioPlayer,
createAudioResource,
AudioPlayerStatus,
joinVoiceChannel,
createAudioPlayer,
AudioResource,
DiscordGatewayAdapterCreator,
VoiceConnectionStatus,
entersState,
} from "@discordjs/voice";
import {
Guild,
Message,
TextBasedChannel,
User,
VoiceBasedChannel,
} from "discord.js";
import Music from "./Music";
import Filter from "./Filter";
import Queue from "./Queue";
import { fetchStream } from "./Fetch";
import I18n from "./I18n";
import ytdl from "discord-ytdl-core";
import { track } from "./Types";
import { largestCommonSequence } from "./Misc";
export default class Player {
private music: Music;
private guild: Guild;
private channel: TextBasedChannel;
public get Channel(): TextBasedChannel {
return this.channel;
}
public set Channel(x: TextBasedChannel) {
this.channel = x;
}
private connection: VoiceConnection | undefined;
public get Connection(): VoiceConnection | undefined {
return this.connection;
}
private player: AudioPlayer;
public get Player(): AudioPlayer {
return this.player;
}
private filter = new Filter();
public get Filter(): Filter {
return this.filter;
}
private queue = new Queue();
public get Queue(): Queue {
return this.queue;
}
private resource: AudioResource<track> | undefined;
public get Resource(): AudioResource<track> | undefined {
return this.resource;
}
private message: Message | undefined;
private created: Date = new Date();
public get Created(): Date {
return this.created;
}
private volume = 100;
public get Volume(): number {
return this.volume;
}
public set Volume(x: number) {
this.volume = Math.max(0, Math.min(150, x));
if (this.resource && this.resource.volume) this.resource.volume.setVolumeLogarithmic(this.volume / 100);
}
public constructor(
guild: Guild,
music: Music,
textBasedChannel: TextBasedChannel
) {
this.music = music;
this.guild = guild;
this.channel = textBasedChannel;
this.player = createAudioPlayer();
this.player.on(AudioPlayerStatus.Idle, async () =>
this.resourceEndResolvable()
);
}
private resourceGenerator(track: track, seek?: number) {
const stream = ytdl(track.url, {
opusEncoded: false,
fmt: "mp3",
filter: "audioonly",
highWaterMark: 1 << 25,
seek: seek ? seek / 1000 : undefined,
encoderArgs: !this.filter.empty()
? ["-af", this.filter.toString()]
: undefined,
});
this.resource = createAudioResource(stream, {
inlineVolume: true,
metadata: track,
});
if (seek) this.resource.playbackDuration = seek;
if (this.resource.volume) this.resource.volume.setVolumeLogarithmic(this.volume / 100);
return this.resource;
}
private resourceEndResolvable(): void {
if (this.resource) this.resource.encoder?.destroy();
if (this.queue.next()) {
this.play();
}
else {
this.resource = undefined;
this.player.stop();
}
}
private async messageResolvable(track: track) {
if (this.message) await this.message.delete();
this.message = await this.channel.send({
embeds: [I18n.en.nowPlaying(track)],
});
}
private async search(
query: string,
requester: User
): Promise<track[] | undefined> {
const response = await fetchStream(query, {
dumpSingleJson: true,
noWarnings: true,
noCheckCertificate: true,
flatPlaylist: true,
skipDownload: true,
defaultSearch: "ytsearch",
});
if (!response) return undefined;
const tracks: track[] = [];
if (response.entries) {
for (const entry of response.entries) {
tracks.push({
url: `https://youtube.com/watch?v=${entry.id}`,
title: entry.title,
thumbnail: `https://img.youtube.com/vi/${entry.id}/default.jpg`,
duration: entry.duration,
requester: requester,
});
}
}
else {
tracks.push({
url: `https://youtube.com/watch?v=${response.id}`,
title: response.title,
thumbnail: `https://img.youtube.com/vi/${response.id}/default.jpg`,
duration: response.duration,
requester: requester,
});
}
return tracks;
}
public play(seek?: number): void {
const track = this.queue.current();
if (!this.connection || !track) return;
this.player.play(this.resourceGenerator(track, seek));
this.connection.subscribe(this.player);
this.messageResolvable(track);
}
public connect(channel: VoiceBasedChannel): void {
if (this.connection) this.connection.destroy();
this.connection = joinVoiceChannel({
channelId: channel.id,
guildId: channel.guildId,
adapterCreator: channel.guild
.voiceAdapterCreator as DiscordGatewayAdapterCreator,
});
this.connection.on(
VoiceConnectionStatus.Disconnected,
async () => {
try {
await Promise.race([
entersState(
this.connection as VoiceConnection,
VoiceConnectionStatus.Signalling,
10_000
),
entersState(
this.connection as VoiceConnection,
VoiceConnectionStatus.Connecting,
10_000
),
]);
}
catch (error) {
this.destroy();
}
}
);
}
public async add(
query: string,
requester: User,
index?: number
): Promise<track | undefined> {
const tracks = await this.search(query, requester);
if (!tracks) return;
this.queue.push(tracks, index);
return tracks[0];
}
public jump(query: number | string): boolean {
let position = typeof query === "number" ? query : -1;
let diff = 0;
if (typeof query === "string") {
this.queue.Tracks.forEach((track, index) => {
const tempDiff = largestCommonSequence(track.title, query);
if (diff < tempDiff) {
diff = tempDiff;
position = index;
}
});
}
if (position !== -1 && this.queue.jump(position)) {
this.play();
return true;
}
return false;
}
public remove(query?: number | string): track | undefined {
const oldPosition = this.queue.Position;
let newPosition = typeof query === "number" ? query : this.queue.Position;
let diff = 0;
if (typeof query === "string") {
this.queue.Tracks.forEach((track, index) => {
const tempDiff = largestCommonSequence(track.title, query);
if (diff < tempDiff) {
diff = tempDiff;
newPosition = index;
}
});
}
const track = this.queue.pop(newPosition);
if (track) {
if (oldPosition === newPosition) this.play();
return track;
}
return undefined;
}
public seek(time: number): void {
this.play(time);
}
public clear(): void {
this.queue.clear();
this.resource = undefined;
if (this.player) this.player.stop();
}
public destroy(): void {
if (this.connection) this.connection.destroy();
this.player.stop();
this.music.del(this.guild.id);
}
public pause(): boolean {
if (this.player.state.status === AudioPlayerStatus.Paused) {
this.player.unpause();
return false;
}
else {
this.player.pause();
return true;
}
}
public shuffle(): void {
this.queue.shuffle();
if (this.resource) {
this.player.stop();
this.play();
}
}
public skip(): void {
this.player.stop();
}
public setFilter(filter?: string): void {
this.filter.toggle(filter);
if (this.resource) this.play(this.resource.playbackDuration);
}
}
-115
View File
@@ -1,115 +0,0 @@
import { loopOption, track } from "./Types";
export default class Queue {
private tracks: track[] = [];
public get Tracks(): track[] {
return this.tracks;
}
private position = 0;
public get Position(): number {
return this.position;
}
private loop: loopOption = "NONE";
public get Loop(): loopOption {
return this.loop;
}
public set Loop(x: loopOption) {
this.loop = x;
}
private duration = 0;
public get Duration(): number {
return this.duration;
}
public next(): track | undefined {
if (this.loop === "SONG") return this.current();
if (this.loop === "AUTO") {
this.position = Math.floor(Math.random() * this.tracks.length);
return this.current();
}
if (this.position + 1 < this.tracks.length) {
this.position++;
return this.current();
}
else if (this.loop === "LOOP") {
this.position = 0;
return this.current();
}
else if (this.loop === "NONE") {
this.position = 0;
return undefined;
}
}
public shuffle(): void {
let currentIndex = this.tracks.length;
while (currentIndex != 0) {
const randomIndex = Math.floor(Math.random() * currentIndex);
currentIndex--;
[this.tracks[currentIndex], this.tracks[randomIndex]] = [
this.tracks[randomIndex],
this.tracks[currentIndex],
];
}
this.position = 0;
}
public push(tracks: track[], index?: number): track {
if (!index || index >= this.tracks.length) {
this.tracks = this.tracks.concat(tracks);
}
else {
this.tracks.splice(Math.max(0, index), 0, ...tracks);
if (this.position >= index) this.position += tracks.length;
}
for (const track of tracks) {
this.duration += track.duration;
}
return this.tracks[index || this.tracks.length - 1];
}
public pop(query: number): track | undefined {
if (query >= 0 && query < this.tracks.length) {
const track = this.tracks[query];
this.tracks.splice(query, 1);
this.position = Math.max(0, this.position - 1);
this.duration -= track.duration;
return track;
}
return undefined;
}
public jump(query: number): track | undefined {
if (query >= 0 && query < this.tracks.length) {
const track = this.tracks[query];
this.position = query;
return track;
}
return undefined;
}
public current(): track {
return this.tracks[this.position];
}
public empty(): boolean {
return this.tracks.length === 0;
}
public clear(): void {
this.tracks = [];
this.position = 0;
}
}
+85
View File
@@ -0,0 +1,85 @@
import { Client as DiscordClient, ClientOptions, Collection } from "discord.js";
import { existsSync, lstatSync, readdirSync } from "fs";
import path from "path";
import { pathToFileURL } from "url";
import config from "../config.js";
import { Command, Event, Module, ModuleMetadata } from "./types.js";
const MODULE_ENTRY = "module.js";
const MODULE_COMMANDS = "commands";
const MODULE_EVENTS = "events";
export default class Client extends DiscordClient {
public readonly commands = new Collection<string, Command>();
public readonly modules = new Collection<string, ModuleMetadata>();
public constructor(options: ClientOptions) {
super(options);
for (const module of readdirSync(config.modulesDir)) {
const modulePath = path.join(config.modulesDir, module);
if (!lstatSync(modulePath).isDirectory()) {
continue;
}
import(pathToFileURL(path.join(modulePath, MODULE_ENTRY)).toString()).then(
(data: Module) => this.loadModule(data)
);
}
}
private loadModule(data: Module): void {
const commands: string[] = [];
const events: string[] = [];
function importModule(dir: string, importThen: (data: Command & Event) => void) {
if (existsSync(dir)) {
for (const source of readdirSync(dir)) {
const file = path.join(dir, source);
if (!lstatSync(file).isFile() || !file.endsWith(".js")) {
continue;
}
import(pathToFileURL(file).toString()).then(importThen);
}
}
}
importModule(path.join(data.rootDir, MODULE_COMMANDS), (command: Command) => {
this.commands.set(command.data.name, command)
commands.push(command.data.name);
});
importModule(path.join(data.rootDir, MODULE_EVENTS), (event: Event) => {
this.on(event.name, (...eventee: unknown[]) => event.execute(this, eventee));
events.push(event.name);
});
this.modules.set(data.name, {
...data,
commands,
events
})
}
public generateApplicationStatus(): string {
const modulesStatus = this.modules.map((module) => {
const tag = `✓ ${module.name}@${module.tag} module is loaded.`
const commands = module.commands.map((name) => " - " + name).join("\n");
const events = module.events.map((name) => " - " + name).join("\n");
return [`${tag}\n`, "commands:", `${commands}`, "events:", `${events}`].join("\n");
}).join("\n" + "-".repeat(50) + "\n");
const clientStatus =
this.user && this.application
? `✓ ${this.application.id} successfully logged in as ${this.user.tag}.`
: "✖ Application is not availiable.";
return ["-".repeat(50), modulesStatus, "-".repeat(50), clientStatus].join("\n");
}
}
+27
View File
@@ -0,0 +1,27 @@
import { ApplicationCommandData, CommandInteraction } from "discord.js";
import Client from "./client.js";
export interface Module {
name: string;
description?: string;
author: string;
tag: string;
controller?: unknown;
rootDir: string;
}
export interface ModuleMetadata extends Module {
commands: string[];
events: string[];
}
export interface Command {
data: ApplicationCommandData;
execute: (client: Client, interaction: CommandInteraction) => Promise<void>;
}
export interface Event {
name: string;
execute: (client: Client, eventee: unknown[]) => Promise<void>;
}
+14
View File
@@ -0,0 +1,14 @@
import { CommandInteraction, SlashCommandBuilder } from "discord.js";
import Client from "../../../lib/client.js";
import I18n from "../lib/i18n.js";
async function execute(client: Client, interaction: CommandInteraction): Promise<void> {
await interaction.reply(I18n.replies.modules(client.modules));
}
const data = new SlashCommandBuilder()
.setName("modules")
.setDescription("List of availiable modules.");
export { data, execute };
+21
View File
@@ -0,0 +1,21 @@
import { CommandInteraction, SlashCommandBuilder } from "discord.js";
import Client from "../../../lib/client.js";
import I18n from "../lib/i18n.js";
async function execute(client: Client, interaction: CommandInteraction): Promise<void> {
const start = Date.now();
if (!client.application) {
await interaction.reply(I18n.replies.ping());
return;
}
await client.application.fetch();
await interaction.reply(I18n.replies.ping(Date.now() - start));
}
const data = new SlashCommandBuilder().setName("ping").setDescription("Try to ping me.");
export { data, execute };
@@ -0,0 +1,19 @@
import { Interaction } from "discord.js";
import Client from "../../../lib/client.js";
async function execute(client: Client, eventee: Interaction[]): Promise<void> {
const [interaction] = eventee;
if (interaction.isCommand()) {
const command = client.commands.get(interaction.commandName);
if (command) {
command.execute(client, interaction);
}
}
}
const name = "interactionCreate";
export { execute, name };
+23
View File
@@ -0,0 +1,23 @@
import { generateDependencyReport } from "@discordjs/voice";
import { ActivityType } from "discord.js";
import Client from "../../../lib/client.js";
async function execute(client: Client): Promise<void> {
if (!client.user || !client.application) {
throw new Error("No application or user for it is provided.");
}
console.log(generateDependencyReport());
console.log(client.generateApplicationStatus());
client.user.setActivity("over you", { type: ActivityType.Watching });
const restCommands = Array.from(client.commands.values()).map((value) => value.data);
client.application.commands.set(restCommands);
}
const name = "ready";
export { execute, name };
+41
View File
@@ -0,0 +1,41 @@
import { bold, Collection, EmbedBuilder, InteractionReplyOptions, italic } from "discord.js";
import { ModuleMetadata } from "../../../lib/types.js";
export default class I18n {
public static readonly replies = {
modules: (modules: Collection<string, ModuleMetadata>): InteractionReplyOptions => {
const embed = new EmbedBuilder()
.setColor("Random")
.setTitle("Modules")
.addFields(
modules.map((value) => {
return {
name: value.name + "@" + value.tag,
value: (value.description ?? "") + " | " + value.author,
inline: true
};
})
);
return { embeds: [embed] };
},
ping: (ping?: number): InteractionReplyOptions => {
const title = ping ? `I have pinged ${ping} ms late.` : "There is no application.";
const comment = !ping
? "How am I speaking then?"
: ping > 250
? "I'm kinda slowpoke ngl."
: ping > 200
? "I can do better than this."
: "Dream's speed!";
const embed = new EmbedBuilder()
.setColor("Random")
.setTitle(bold(title))
.setDescription(italic(bold(comment)));
return { embeds: [embed] };
}
};
}
+11
View File
@@ -0,0 +1,11 @@
import path from "path";
import { fileURLToPath } from "url";
const name = "core";
const description = "Quetza core functionality";
const author = "unknowableshade";
const tag = "2302.1";
const rootDir = path.dirname(fileURLToPath(import.meta.url));
export { author, description, name, rootDir, tag };
+27
View File
@@ -0,0 +1,27 @@
import { CommandInteraction, SlashCommandBuilder, TextChannel } from "discord.js";
import Client from "../../../lib/client.js";
import I18n from "../lib/i18n.js";
import { controller } from "../module.js";
async function execute(client: Client, interaction: CommandInteraction): Promise<void> {
if (!interaction.guild || !interaction.channel) {
return;
}
const player = controller.get(interaction.guild.id, interaction.channel as TextChannel);
if (!player) {
return;
}
const amount = player.queue.tracks.length;
player.clear();
await interaction.reply({ embeds: [I18n.embeds.cleared(amount)] });
}
const data = new SlashCommandBuilder().setName("clear").setDescription("Clear the player's queue.");
export { data, execute };
+41
View File
@@ -0,0 +1,41 @@
import { CommandInteraction, GuildMember, SlashCommandBuilder, TextChannel } from "discord.js";
import Client from "../../../lib/client.js";
import I18n from "../lib/i18n.js";
import { controller } from "../module.js";
async function execute(client: Client, interaction: CommandInteraction) {
if (!interaction.guild || !interaction.channel || !interaction.member) {
return;
}
await interaction.deferReply();
const player =
controller.get(interaction.guild.id, interaction.channel as TextChannel) ||
controller.set(interaction.guild, interaction.channel as TextChannel);
if (!player.connection) {
const channel = (interaction.member as GuildMember).voice.channel;
if (channel) {
player.connect(channel);
await interaction.editReply({ embeds: [I18n.embeds.okConnected(channel.name)] });
} else {
controller.delete(interaction.guild.id);
await interaction.editReply({ embeds: [I18n.embeds.notConnected()] });
return undefined;
}
} else {
await interaction.editReply({ embeds: [I18n.embeds.wasConnected()] });
}
return player;
}
const data = new SlashCommandBuilder()
.setName("connect")
.setDescription("Connect me to a voice channel.");
export { data, execute };
+129
View File
@@ -0,0 +1,129 @@
import { CommandInteraction, SlashCommandBuilder, TextChannel } from "discord.js";
import Client from "../../../lib/client.js";
import I18n from "../lib/i18n.js";
import { controller } from "../module.js";
async function execute(client: Client, interaction: CommandInteraction) {
const filter = interaction.options.get("filter")?.value as string;
if (!interaction.guild || !interaction.channel) {
return;
}
const player = controller.get(interaction.guild.id, interaction.channel as TextChannel);
if (!player) {
return;
}
player.setFilter(filter || undefined);
await interaction.reply({ embeds: [I18n.embeds.filtered(filter || undefined)] });
}
const data = new SlashCommandBuilder()
.setName("filter")
.setDescription("Apply unique filters to the tracks.")
.addStringOption((option) =>
option
.setName("filter")
.setDescription("Filter to apply.")
.setChoices(
{
name: "Bassboost low",
value: "bassboost_low"
},
{
name: "Bassboost",
value: "bassboost"
},
{
name: "Bassboost high",
value: "bassboost_high"
},
{
name: "8D",
value: "8D"
},
{
name: "Vaporwave",
value: "vaporwave"
},
{
name: "Nightcore",
value: "nightcore"
},
{
name: "Phaser",
value: "phaser"
},
{
name: "Tremolo",
value: "tremolo"
},
{
name: "Vibrato",
value: "vibrato"
},
{
name: "Reverse",
value: "reverse"
},
{
name: "Treble",
value: "treble"
},
{
name: "Normalizer",
value: "normalizer"
},
{
name: "Surround Sound",
value: "surrounding"
},
{
name: "Pulsator",
value: "pulsator"
},
{
name: "Subboost",
value: "subboost"
},
{
name: "Mono Audio",
value: "mono"
},
{
name: "Compressor",
value: "compressor"
},
{
name: "Expander",
value: "expander"
},
{
name: "Softlimiter",
value: "softlimiter"
},
{
name: "Chorus",
value: "chorus"
},
{
name: "Fadein",
value: "fadein"
},
{
name: "Dimming",
value: "dim"
},
{
name: "Earrape",
value: "earrape"
}
)
.setRequired(true)
);
export { data, execute };
+23
View File
@@ -0,0 +1,23 @@
import { CommandInteraction, SlashCommandBuilder, TextChannel } from "discord.js";
import Client from "../../../lib/client.js";
import I18n from "../lib/i18n.js";
import { controller } from "../module.js";
async function execute(client: Client, interaction: CommandInteraction) {
if (!interaction.guild || !interaction.channel || !interaction.member) {
return;
}
await interaction.deferReply();
const player = controller.get(interaction.guild.id, interaction.channel as TextChannel);
await interaction.editReply({ embeds: [I18n.embeds.playerInfo(player)] });
}
const data = new SlashCommandBuilder()
.setName("info")
.setDescription("Information about the playback.");
export { data, execute };
+38
View File
@@ -0,0 +1,38 @@
import { CommandInteraction, SlashCommandBuilder, TextChannel } from "discord.js";
import Client from "../../../lib/client.js";
import I18n from "../lib/i18n.js";
import { controller } from "../module.js";
async function execute(client: Client, interaction: CommandInteraction) {
const pos = interaction.options.get("position")?.value as number;
const query = interaction.options.get("query")?.value as string;
if (!interaction.guild || !query || !pos || !interaction.channel) {
return;
}
const player = controller.get(interaction.guild.id, interaction.channel as TextChannel);
if (!player) {
return;
}
await interaction.deferReply();
const track = await player.add(query, interaction.user, pos - 1);
await interaction.editReply({ embeds: [I18n.embeds.appended(track)] });
}
const data = new SlashCommandBuilder()
.setName("insert")
.setDescription("Insert a new track to specific position in the queue.")
.addStringOption((option) =>
option.setName("query").setDescription("Title or URL of the song.").setRequired(true)
)
.addIntegerOption((option) =>
option.setName("position").setDescription("Position to insert.").setRequired(true)
);
export { data, execute };
+35
View File
@@ -0,0 +1,35 @@
import { CommandInteraction, SlashCommandBuilder, TextChannel } from "discord.js";
import Client from "../../../lib/client.js";
import I18n from "../lib/i18n.js";
import { controller } from "../module.js";
async function execute(client: Client, interaction: CommandInteraction) {
const query = interaction.options.get("query")?.value as string;
if (!interaction.guild || !query || !interaction.channel) {
return;
}
const player = controller.get(interaction.guild.id, interaction.channel as TextChannel);
if (!player) {
return;
}
const state =
!isNaN(+query) && isFinite(+query) && !/e/i.test(query)
? player.jump(parseInt(query) - 1)
: player.jump(query);
await interaction.reply({ embeds: [I18n.embeds.jumped(state)] });
}
const data = new SlashCommandBuilder()
.setName("jump")
.setDescription("Jump to specific track in the queue.")
.addStringOption((option) =>
option.setName("query").setDescription("Position or title to jump to.").setRequired(true)
);
export { data, execute };
+42
View File
@@ -0,0 +1,42 @@
import { CommandInteraction, SlashCommandBuilder, TextChannel } from "discord.js";
import Client from "../../../lib/client.js";
import I18n from "../lib/i18n.js";
import { LoopOption } from "../lib/types.js";
import { controller } from "../module.js";
async function execute(client: Client, interaction: CommandInteraction) {
const query = interaction.options.get("option")?.value as string;
if (!interaction.guild || !query || !interaction.channel) {
return;
}
const player = controller.get(interaction.guild.id, interaction.channel as TextChannel);
if (!player) {
return;
}
player.queue.loop = query as LoopOption;
await interaction.reply({ embeds: [I18n.embeds.looped(query as LoopOption)] });
}
const data = new SlashCommandBuilder()
.setName("loop")
.setDescription("Select player's loop mode.")
.addStringOption((option) =>
option
.setName("option")
.setDescription("Select loop option.")
.setChoices(
{ name: "loop queue", value: "LOOP" },
{ name: "loop single track", value: "SONG" },
{ name: "Till end", value: "NONE" },
{ name: "Random order", value: "AUTO" }
)
.setRequired(true)
);
export { data, execute };
+25
View File
@@ -0,0 +1,25 @@
import { CommandInteraction, SlashCommandBuilder, TextChannel } from "discord.js";
import Client from "../../../lib/client.js";
import I18n from "../lib/i18n.js";
import { controller } from "../module.js";
async function execute(client: Client, interaction: CommandInteraction) {
if (!interaction.guild || !interaction.channel) {
return;
}
const player = controller.get(interaction.guild.id, interaction.channel as TextChannel);
if (!player) {
return;
}
player.skip();
await interaction.reply({ embeds: [I18n.embeds.skipped()] });
}
const data = new SlashCommandBuilder().setName("next").setDescription("Skip current song.");
export { data, execute };
+25
View File
@@ -0,0 +1,25 @@
import { CommandInteraction, SlashCommandBuilder, TextChannel } from "discord.js";
import Client from "../../../lib/client.js";
import I18n from "../lib/i18n.js";
import { controller } from "../module.js";
async function execute(client: Client, interaction: CommandInteraction) {
if (!interaction.guild || !interaction.channel) {
return;
}
const player = controller.get(interaction.guild.id, interaction.channel as TextChannel);
if (!player) {
return;
}
const state = player.pause();
await interaction.reply({ embeds: [I18n.embeds.paused(state)] });
}
const data = new SlashCommandBuilder().setName("pause").setDescription("Toggle pause on player.");
export { data, execute };
+34
View File
@@ -0,0 +1,34 @@
import { CommandInteraction, SlashCommandBuilder } from "discord.js";
import Client from "../../../lib/client.js";
import I18n from "../lib/i18n.js";
import { execute as connect } from "./connect.js";
async function execute(client: Client, interaction: CommandInteraction) {
const query = interaction.options.get("query")?.value as string;
const player = await connect(client, interaction);
if (!player) {
return;
}
if (query) {
const track = await player.add(query, interaction.user);
await interaction.editReply({ embeds: [I18n.embeds.appended(track)] });
}
if (!player.resource) {
player.play();
}
}
const data = new SlashCommandBuilder()
.setName("play")
.setDescription("Launch player and add songs to the queue.")
.addStringOption((option) =>
option.setName("query").setDescription("Title or URL of the song.")
);
export { data, execute };
+77
View File
@@ -0,0 +1,77 @@
import {
ActionRowBuilder,
ButtonBuilder,
ButtonInteraction,
ButtonStyle,
CommandInteraction,
Message,
MessageActionRowComponentBuilder,
SlashCommandBuilder,
TextChannel
} from "discord.js";
import Client from "../../../lib/client.js";
import I18n from "../lib/i18n.js";
import { controller } from "../module.js";
async function execute(client: Client, interaction: CommandInteraction) {
if (!interaction.guild || !interaction.channel) {
return;
}
const player = controller.get(interaction.guild.id, interaction.channel as TextChannel);
if (!player) {
return;
}
await interaction.deferReply();
if (player.queue.empty()) {
await interaction.editReply({ embeds: [I18n.embeds.queueEmpty()] });
return;
}
let page = 0;
const row = new ActionRowBuilder<MessageActionRowComponentBuilder>().addComponents(
new ButtonBuilder().setCustomId("QueueTop").setLabel("🔼").setStyle(ButtonStyle.Primary),
new ButtonBuilder().setCustomId("QueueUp").setLabel("🔺").setStyle(ButtonStyle.Secondary),
new ButtonBuilder().setCustomId("QueueDown").setLabel("🔻").setStyle(ButtonStyle.Secondary),
new ButtonBuilder().setCustomId("QueueEnd").setLabel("🔽").setStyle(ButtonStyle.Primary)
);
const message = (await interaction.editReply({
embeds: [I18n.embeds.queueDesigner(player.queue, 0, player.resource)],
components: [row]
})) as Message;
const collector = message.createMessageComponentCollector({ time: 30000 });
collector.on("collect", async (btn: ButtonInteraction) => {
switch (btn.customId) {
case "QueueTop": {
page = 0;
break;
}
case "QueueUp": {
page = Math.max(page - 1, 0);
break;
}
case "QueueDown": {
page = Math.min(page + 1, Math.floor(player.queue.tracks.length / 11));
break;
}
case "QueueEnd":
page = Math.floor(player.queue.tracks.length / 11);
}
await btn.update({
embeds: [I18n.embeds.queueDesigner(player.queue, page, player.resource)]
});
});
}
const data = new SlashCommandBuilder().setName("queue").setDescription("Print out the queue.");
export { data, execute };
+35
View File
@@ -0,0 +1,35 @@
import { CommandInteraction, SlashCommandBuilder, TextChannel } from "discord.js";
import Client from "../../../lib/client.js";
import I18n from "../lib/i18n.js";
import { controller } from "../module.js";
async function execute(client: Client, interaction: CommandInteraction) {
const query = interaction.options.get("query")?.value as string;
if (!interaction.guild || !query || !interaction.channel) {
return;
}
const player = controller.get(interaction.guild.id, interaction.channel as TextChannel);
if (!player) {
return;
}
const track =
!isNaN(+query) && isFinite(+query) && !/e/i.test(query)
? player.remove(parseInt(query) - 1)
: player.remove(query);
await interaction.reply({ embeds: [I18n.embeds.removed(track)] });
}
const data = new SlashCommandBuilder()
.setName("remove")
.setDescription("Remove specific track in the queue.")
.addStringOption((option) =>
option.setName("query").setDescription("Position or title to remove.").setRequired(true)
);
export { data, execute };
+25
View File
@@ -0,0 +1,25 @@
import { CommandInteraction, SlashCommandBuilder, TextChannel } from "discord.js";
import Client from "../../../lib/client.js";
import I18n from "../lib/i18n.js";
import { controller } from "../module.js";
async function execute(client: Client, interaction: CommandInteraction) {
if (!interaction.guild || !interaction.channel) {
return;
}
const player = controller.get(interaction.guild.id, interaction.channel as TextChannel);
if (!player) {
return;
}
player.shuffle();
await interaction.reply({ embeds: [I18n.embeds.reshuffle()] });
}
const data = new SlashCommandBuilder().setName("reshuffle").setDescription("Shuffle the queue.");
export { data, execute };
+38
View File
@@ -0,0 +1,38 @@
import { CommandInteraction, SlashCommandBuilder, TextChannel } from "discord.js";
import Client from "../../../lib/client.js";
import I18n from "../lib/i18n.js";
import { controller } from "../module.js";
async function execute(client: Client, interaction: CommandInteraction) {
const hours = (interaction.options.get("hrs")?.value as number) || 0;
const minutes = (interaction.options.get("mins")?.value as number) || 0;
const seconds = (interaction.options.get("secs")?.value as number) || 0;
if (!interaction.guild || !interaction.channel) {
return;
}
const player = controller.get(interaction.guild.id, interaction.channel as TextChannel);
if (!player) {
return;
}
const time = hours * 3600 + minutes * 60 + seconds;
player.seek(time * 1000);
await interaction.reply({
embeds: [I18n.embeds.fastForwarded(time)]
});
}
const data = new SlashCommandBuilder()
.setName("seek")
.setDescription("Fast-forward by the time.")
.addIntegerOption((option) => option.setName("hrs").setDescription("Hours to seek."))
.addIntegerOption((option) => option.setName("mins").setDescription("Minutes to seek."))
.addIntegerOption((option) => option.setName("secs").setDescription("Seconds to seek."));
export { data, execute };
+25
View File
@@ -0,0 +1,25 @@
import { CommandInteraction, SlashCommandBuilder, TextChannel } from "discord.js";
import Client from "../../../lib/client.js";
import I18n from "../lib/i18n.js";
import { controller } from "../module.js";
async function execute(client: Client, interaction: CommandInteraction) {
if (!interaction.guild || !interaction.channel) {
return;
}
const player = controller.get(interaction.guild.id, interaction.channel as TextChannel);
if (!player) {
return;
}
player.destroy();
await interaction.reply({ embeds: [I18n.embeds.destroyed()] });
}
const data = new SlashCommandBuilder().setName("stop").setDescription("Destroy the player.");
export { data, execute };
+32
View File
@@ -0,0 +1,32 @@
import { CommandInteraction, SlashCommandBuilder, TextChannel } from "discord.js";
import Client from "../../../lib/client.js";
import I18n from "../lib/i18n.js";
import { controller } from "../module.js";
async function execute(client: Client, interaction: CommandInteraction) {
const volume = (interaction.options.get("volume")?.value as number) || 100;
if (!interaction.guild || !interaction.channel) {
return;
}
const player = controller.get(interaction.guild.id, interaction.channel as TextChannel);
if (!player) {
return;
}
player.volume = volume;
await interaction.reply({ embeds: [I18n.embeds.volumeSet(player.volume)] });
}
const data = new SlashCommandBuilder()
.setName("volume")
.setDescription("Change player's volume amount.")
.addIntegerOption((option) =>
option.setName("volume").setDescription("Volume in percents.").setRequired(true)
);
export { data, execute };
@@ -0,0 +1,28 @@
import { VoiceState } from "discord.js";
import Client from "../../../lib/client.js";
import I18n from "../lib/i18n.js";
import { asleep } from "../lib/misc.js";
import { controller } from "../module.js";
async function execute(client: Client, eventee: VoiceState[]): Promise<void> {
const [oldState] = eventee;
const player = controller.get(oldState.guild.id);
if (!player || !oldState.channel || !client.user) {
return;
}
if (oldState.channel.members.filter((value) => value.user !== client.user).size === 0) {
await asleep(30000);
if (oldState.channel.members.filter((value) => value.user !== client.user).size === 0) {
await player.channel.send({ embeds: [I18n.embeds.fullyAlone()] });
player.destroy();
}
}
}
const name = "voiceStateUpdate";
export { execute, name };
@@ -1,54 +1,46 @@
import { ytdlArgs, ytdlResponse } from "./Types";
import { execFile } from "child_process";
import { promisify } from "util";
import config from "../config";
import path from "path";
import { promisify } from "util";
import config from "../../../config.js";
import { YtdlArgs, YtdlResponse } from "./types.js";
const execFileAsync = promisify(execFile);
function argumentsResolver(args: ytdlArgs): string[] {
function argumentsResolver(args: YtdlArgs): string[] {
const options = Object.entries(args);
return options.map(([key, value]) => {
if (typeof value === "boolean" && value) {
return `--${key.split(/(?=[A-Z])/).join("-")}`.toLowerCase();
}
else {
return `--${key
.split(/(?=[A-Z])/)
.join("-")}=${value}`.toLowerCase();
} else {
return `--${key.split(/(?=[A-Z])/).join("-")}=${value}`.toLowerCase();
}
});
}
async function ytdlExec(
query: string,
args: ytdlArgs
): Promise<ytdlResponse | undefined> {
async function ytdlExec(query: string, args: YtdlArgs): Promise<YtdlResponse | undefined> {
try {
const executable = await execFileAsync(
path.join(config.binaries, "/youtube-dl"),
path.join(config.binariesDir, "/youtube-dl"),
[query].concat(argumentsResolver(args))
);
return JSON.parse(executable.stdout);
}
catch (error) {
} catch (error) {
console.log(error);
return undefined;
return;
}
}
export async function fetchStream(
query: string,
args: ytdlArgs
): Promise<ytdlResponse | undefined> {
args: YtdlArgs
): Promise<YtdlResponse | undefined> {
let response = await ytdlExec(query, args);
if (response && !response.extractor.includes("youtube")) {
response = await ytdlExec(
`${response.title} - ${response.creator}`,
args
);
response = await ytdlExec(`${response.title} - ${response.creator}`, args);
}
return response;
}
}
+71
View File
@@ -0,0 +1,71 @@
export default class Filter {
public static readonly filters: Record<string, string> = {
bassboost_low: "bass=g=15:f=110:w=0.3",
bassboost: "bass=g=20:f=110:w=0.3",
bassboost_high: "bass=g=30:f=110:w=0.3",
"8D": "apulsator=hz=0.09",
vaporwave: "aresample=48000,asetrate=48000*0.75",
nightcore: "aresample=48000,asetrate=48000*1.25",
phaser: "aphaser=in_gain=0.4",
tremolo: "tremolo",
vibrato: "vibrato=f=6.5",
reverse: "areverse",
treble: "treble=g=5",
normalizer: "dynaudnorm=g=101",
normalizer2: "acompressor",
surrounding: "surround",
pulsator: "apulsator=hz=1",
subboost: "asubboost",
karaoke: "stereotools=mlev=0.03",
flanger: "flanger",
gate: "agate",
haas: "haas",
mcompand: "mcompand",
mono: "pan=mono|c0=.5*c0+.5*c1",
mstlr: "stereotools=mode=ms>lr",
mstrr: "stereotools=mode=ms>rr",
compressor: "compand=points=-80/-105|-62/-80|-15.4/-15.4|0/-12|20/-7.6",
expander:
"compand=attacks=0:points=-80/-169|-54/-80|-49.5/-64.6|-41.1/-41.1|-25.8/-15|-10.8/-4.5|0/0|20/8.3",
softlimiter: "compand=attacks=0:points=-80/-80|-12.4/-12.4|-6/-8|0/-6.8|20/-2.8",
chorus: "chorus=0.7:0.9:55:0.4:0.25:2",
chorus2d: "chorus=0.6:0.9:50|60:0.4|0.32:0.25|0.4:2|1.3",
chorus3d: "chorus=0.5:0.9:50|60|40:0.4|0.32|0.3:0.25|0.4|0.3:2|2.3|1.3",
fadein: "afade=t=in:ss=0:d=10",
dim: "afftfilt=\"'real=re * (1-clip((b/nb)*b,0,1))':imag='im * (1-clip((b/nb)*b,0,1))'\"",
earrape: "channelsplit,sidechaingate=level_in=64"
};
private switches = new Set<string>();
public toggled(): [string, string][] {
return Object.entries(Filter.filters)
.filter((value) => this.switches.has(value[0]))
.map((value) => [value[0], value[1]]);
}
public toggle(query?: string): void {
if (!query) {
this.switches.clear();
return;
}
if (!this.switches.delete(query) && Object.hasOwn(Filter.filters, query)) {
this.switches.add(query);
}
}
public size(): number {
return this.switches.size;
}
public empty(): boolean {
return this.size() === 0;
}
public toString(): string {
return this.toggled()
.map((value) => value[1])
.join(",");
}
}
+259
View File
@@ -0,0 +1,259 @@
import { AudioResource } from "@discordjs/voice";
import { EmbedBuilder } from "discord.js";
import { loopMoji, secToISO, statusBarGenerator, volumeMoji } from "./misc.js";
import Player from "./player.js";
import Queue from "./queue.js";
import { LoopOption, Track } from "./types.js";
export default class I18n {
public static readonly embeds = {
nowPlaying: (track: Track) =>
new EmbedBuilder()
.setColor("LuminousVividPink")
.setAuthor({
iconURL: track.requester.avatarURL() || undefined,
name: track.requester.tag
})
.setTitle(track.title)
.setURL(track.url)
.setDescription("**playing now.**")
.setThumbnail(track.thumbnail),
cleared: (amount: number) =>
new EmbedBuilder()
.setColor("Green")
.setTitle(`**♻️ ${amount} tracks have been cleared from the queue.**`)
.setTimestamp(new Date()),
okConnected: (channel: string) =>
new EmbedBuilder()
.setColor("Green")
.setTitle(`**✅ Successfuly connected to:** _${channel}_.`),
notConnected: () =>
new EmbedBuilder()
.setColor("Red")
.setTitle("**🚫 Make yourself connected to a voice channel beforehand.**"),
wasConnected: () =>
new EmbedBuilder()
.setColor("Yellow")
.setTitle("**⚠️ Already connected to a voice channel.**"),
filtered: (filter?: string) =>
new EmbedBuilder()
.setColor("Green")
.setTitle(
filter
? `**✅ ${filter} was applied to the player.**`
: "**✅ All filters were declined.**"
),
appended: (track?: Track) =>
!track
? new EmbedBuilder()
.setColor("Red")
.setTitle("**🚫 Could not add track to the queue.**")
: new EmbedBuilder()
.setColor("Green")
.setTitle(track.title)
.setURL(track.url)
.setThumbnail(track.thumbnail)
.setAuthor({
iconURL: track.requester.avatarURL() || undefined,
name: track.requester.tag
})
.setDescription("**has been added to the queue.**")
.setTimestamp(new Date()),
jumped: (state: boolean) =>
state
? new EmbedBuilder().setColor("Green").setTitle("_**Perfoming jump.**_")
: new EmbedBuilder().setColor("Red").setTitle("**❗ Bad _jump_ request.**"),
looped: (query: LoopOption) => {
switch (query) {
case "AUTO": {
return new EmbedBuilder()
.setColor("LuminousVividPink")
.setTitle("**🔀 Shuffle mode** _(does not affect the queue order)_.");
}
case "LOOP": {
return new EmbedBuilder()
.setColor("Blue")
.setTitle("**🔁 Looping over the queue.**");
}
case "NONE": {
return new EmbedBuilder()
.setColor("Red")
.setTitle("**⤵️ Player will stop on the queue end.**");
}
case "SONG": {
return new EmbedBuilder()
.setColor("Yellow")
.setTitle("**🔂 Looping a single track.**");
}
}
},
skipped: () => new EmbedBuilder().setColor("Green").setTitle("**⏭️ Skipping.**"),
paused: (state: boolean) =>
state
? new EmbedBuilder().setColor("Green").setTitle("_**▶️ Resumed.**_")
: new EmbedBuilder().setColor("Yellow").setTitle("_**⏸️ Paused.**_"),
removed: (track?: Track) =>
track
? new EmbedBuilder()
.setColor("Green")
.setTitle(track.title)
.setDescription("**was removed from the queue.**")
.setTimestamp(new Date())
.setURL(track.url)
.setThumbnail(track.thumbnail)
: new EmbedBuilder().setColor("Red").setTitle("**❗ Bad _remove_ request.**"),
fastForwarded: (amount: number) =>
new EmbedBuilder()
.setColor("Blue")
.setTitle(`**⏩ Fast-forwarding to ${secToISO(amount)}**`),
destroyed: () =>
new EmbedBuilder().setColor("Red").setTitle("**💀 Destroying the player.**"),
volumeSet: (amount: number) =>
new EmbedBuilder()
.setColor("Green")
.setTitle(`**${volumeMoji(amount)} Volume has been set to ${amount}%**`),
queueEmpty: () => new EmbedBuilder().setColor("Yellow").setTitle("**❎ Queue is empty.**"),
playerInfo: (player?: Player) => {
if (!player) {
return new EmbedBuilder()
.setColor("Red")
.setTitle("**🚫 Player does not exist.**");
}
if (player.resource) {
return new EmbedBuilder()
.setColor("LuminousVividPink")
.setTitle(`${player.queue.position + 1}. ${player.resource.metadata.title}`)
.setDescription(
statusBarGenerator(
player.resource.playbackDuration / 1000,
player.resource.metadata.duration
)
)
.setThumbnail(player.resource.metadata.thumbnail)
.setURL(player.resource.metadata.url)
.addFields([
{
name: "Applied Filters",
value:
player.filter
.toggled()
.map((value) => value[0])
.join("\n") + "\ndefault",
inline: true
},
{
name: "Queue Length",
value: `🔢 ${player.queue.tracks.length}`,
inline: true
},
{
name: "Queue Duration",
value: `💿 ${secToISO(player.queue.duration)}`,
inline: true
},
{
name: "Queue Looping",
value: `${loopMoji(player.queue.loop)} ${player.queue.loop}`,
inline: true
},
{
name: "Volume amount",
value: `${volumeMoji(player.volume)} ${player.volume}/150`,
inline: true
},
{
name: "Player lifetime",
value: `🕓 ${secToISO((Date.now() - player.created.getTime()) / 1000)}`,
inline: true
}
]);
} else {
return new EmbedBuilder()
.setColor("Blue")
.setTitle("💿 Insert the disk...")
.setDescription(statusBarGenerator(0, 0))
.setURL("https://www.youtube.com/watch?v=dQw4w9WgXcQ&ab_channel=RickAstley")
.addFields([
{
name: "Applied Filters",
value:
player.filter
.toggled()
.map((value) => value[0])
.join("\n") + "\ndefault",
inline: true
},
{
name: "Queue Length",
value: `🔢 ${player.queue.tracks.length}`,
inline: true
},
{
name: "Queue Duration",
value: `💿 ${secToISO(player.queue.duration)}`,
inline: true
},
{
name: "Queue Looping",
value: `${loopMoji(player.queue.loop)} ${player.queue.loop}`,
inline: true
},
{
name: "Volume amount",
value: `${volumeMoji(player.volume)} ${player.volume}/150`,
inline: true
},
{
name: "Player lifetime",
value: `🕓 ${secToISO((Date.now() - player.created.getTime()) / 1000)}`,
inline: true
}
]);
}
},
queueDesigner: (queue: Queue, page: number, resource: AudioResource<Track> | undefined) => {
page = Math.max(0, Math.min(Math.floor(queue.tracks.length / 11), page));
return new EmbedBuilder()
.setColor("LuminousVividPink")
.setTitle(
resource
? `${queue.position + 1}. ${resource.metadata.title}`
: "💿 Insert the disk..."
)
.setURL(
resource
? resource.metadata.url
: "https://www.youtube.com/watch?v=5mGuCdlCcNM&ab_channel=Ra%C3%BAlBlanco"
)
.setThumbnail(
resource
? resource.metadata.thumbnail
: "https/img.youtube.com/vi/5mGuCdlCcNM/default.jpg"
)
.setDescription(
resource
? statusBarGenerator(
resource.playbackDuration / 1000,
resource.metadata.duration
)
: statusBarGenerator(0, 0)
)
.setFields(
queue.tracks.slice(page * 10, page * 10 + 10).map((value, index) => ({
name: `${page * 10 + index + 1}. ${value.title.padEnd(35)}`,
value: `**[${secToISO(value.duration)}]**`
}))
);
},
fullyAlone: () =>
new EmbedBuilder()
.setColor("LuminousVividPink")
.setTitle("🥬 I have decided to leave to conserve my energy.")
.setDescription("_**Since there was nobody in the voice channel.**_"),
reshuffle: () =>
new EmbedBuilder().setColor("Green").setTitle("**✅ Successfuly reshuffled queue.**")
};
}
@@ -1,19 +1,17 @@
import { loopOption } from "./Types";
import { LoopOption } from "./types.js";
export function statusBarGenerator(duration: number, length: number): string {
duration = Math.max(0, duration);
length = Math.max(0, length);
if (duration > length) duration = length;
const PLAYBACK_LENGTH = 15;
export function statusBarGenerator(playback: number, duration: number): string {
const filled = Array<string>(
Math.floor((15 * duration) / (length === 0 ? 1 : length))
).fill(":small_blue_diamond:");
const empty = Array<string>(
15 - Math.floor((15 * duration) / (length === 0 ? 1 : length))
).fill(":white_small_square:");
Math.floor((PLAYBACK_LENGTH * playback) / (duration === 0 ? 1 : duration))
).fill("🔹");
return `**[${filled.join("")}${empty.join("")}] ${secToISO(
duration
)}/${secToISO(length)}**`;
const empty = Array<string>(
PLAYBACK_LENGTH - Math.floor((PLAYBACK_LENGTH * playback) / (duration === 0 ? 1 : duration))
).fill("▫️");
return `**[${filled.join("")}${empty.join("")}] ${secToISO(playback)}/${secToISO(duration)}**`;
}
export function secToISO(amount: number): string {
@@ -24,6 +22,7 @@ export function secToISO(amount: number): string {
const hDisplay = h > 0 ? `${h}:` : "";
const mDisplay = `${Math.floor(m / 10)}${Math.floor(m % 10)}:`;
const sDisplay = `${Math.floor(s / 10)}${Math.floor(s % 10)}`;
return hDisplay + mDisplay + sDisplay;
}
@@ -35,29 +34,23 @@ export function volumeMoji(amount: number): string {
return amount > 100 ? "🔊" : amount > 50 ? "🔉" : amount > 0 ? "🔈" : "🔇";
}
export function loopMoji(loop: loopOption): string {
return loop === "AUTO"
? "🔀"
: loop === "LOOP"
? "🔁"
: loop === "NONE"
? "⤵️"
: "🔂";
export function loopMoji(loop: LoopOption): string {
return loop === "AUTO" ? "🔀" : loop === "LOOP" ? "🔁" : loop === "NONE" ? "⤵️" : "🔂";
}
export function largestCommonSequence(s1: string, s2: string) {
s1 = s1.toLowerCase().slice(0, 100);
s2 = s2.toLowerCase().slice(0, 100);
const buffer = Array.from(
Array(s1.length + 1),
() => new Array<number>(s2.length + 1).fill(0)
);
const buffer = Array.from(Array(s1.length + 1), () => new Array<number>(s2.length + 1).fill(0));
for (let i = 1; i <= s1.length; i++) {
for (let j = 1; j <= s2.length; j++) {
if (s1[i - 1] === s2[j - 1])
if (s1[i - 1] === s2[j - 1]) {
buffer[i][j] = buffer[i - 1][j - 1] + 1;
else buffer[i][j] = Math.max(buffer[i - 1][j], buffer[i][j - 1]);
} else {
buffer[i][j] = Math.max(buffer[i - 1][j], buffer[i][j - 1]);
}
}
}
+31
View File
@@ -0,0 +1,31 @@
import { Collection, Guild, TextChannel } from "discord.js";
import Player from "./player.js";
export default class Music {
private players = new Collection<string, Player>();
public get(guildId: string, channel?: TextChannel): Player | undefined {
const player = this.players.get(guildId);
if (player) {
if (channel) {
player.channel = channel;
}
return player;
}
}
public set(guild: Guild, channel: TextChannel): Player {
const player = new Player(guild, this, channel);
this.players.set(guild.id, player);
return player;
}
public delete(guildId: string): void {
this.players.delete(guildId);
}
}
+328
View File
@@ -0,0 +1,328 @@
import {
AudioPlayer,
AudioPlayerStatus,
AudioResource,
createAudioPlayer,
createAudioResource,
DiscordGatewayAdapterCreator,
entersState,
joinVoiceChannel,
VoiceConnection,
VoiceConnectionStatus
} from "@discordjs/voice";
import { Guild, Message, TextChannel, User, VoiceBasedChannel } from "discord.js";
import ytdl from "discord-ytdl-core";
import { fetchStream } from "./fetch.js";
import Filter from "./filter.js";
import I18n from "./i18n.js";
import { largestCommonSequence } from "./misc.js";
import Music from "./music.js";
import Queue from "./queue.js";
import { Track } from "./types.js";
export default class Player {
private music: Music;
private guild: Guild;
private msgChannel: TextChannel;
public get channel(): TextChannel {
return this.msgChannel;
}
public set channel(x: TextChannel) {
this.msgChannel = x;
}
private message: Message | undefined;
public internalConnection: VoiceConnection | undefined;
public get connection(): VoiceConnection | undefined {
return this.internalConnection;
}
private internalPlayer: AudioPlayer;
public get player(): AudioPlayer {
return this.internalPlayer;
}
private playerResource: AudioResource<Track> | undefined;
public get resource(): AudioResource<Track> | undefined {
return this.playerResource;
}
private resourceVolume = 100;
public get volume(): number {
return this.resourceVolume;
}
public set volume(x: number) {
this.resourceVolume = Math.max(0, Math.min(150, x));
if (this.playerResource && this.playerResource.volume) {
this.playerResource.volume.setVolumeLogarithmic(this.resourceVolume / 100);
}
}
public readonly queue = new Queue();
public readonly filter = new Filter();
public readonly created: Date = new Date();
public constructor(guild: Guild, music: Music, textChannel: TextChannel) {
this.music = music;
this.guild = guild;
this.msgChannel = textChannel;
this.internalPlayer = createAudioPlayer();
this.internalPlayer.on(AudioPlayerStatus.Idle, async () => this.resourceEndResolvable());
}
private resourceGenerator(track: Track, seek?: number) {
const stream = ytdl(track.url, {
opusEncoded: false,
fmt: "mp3",
filter: "audioonly",
highWaterMark: 1 << 25,
seek: seek ? seek / 1000 : undefined,
encoderArgs: !this.filter.empty() ? ["-af", this.filter.toString()] : undefined
});
this.playerResource = createAudioResource(stream, {
inlineVolume: true,
metadata: track
});
if (seek) {
this.playerResource.playbackDuration = seek;
}
if (this.playerResource.volume) {
this.playerResource.volume.setVolumeLogarithmic(this.resourceVolume / 100);
}
return this.playerResource;
}
private resourceEndResolvable(): void {
if (this.playerResource) {
this.playerResource.encoder?.destroy();
}
if (this.queue.next()) {
this.play();
} else {
this.playerResource = undefined;
this.internalPlayer.stop();
}
}
private async messageResolvable(track: Track) {
if (this.message) {
await this.message.delete();
}
this.message = await this.msgChannel.send({
embeds: [I18n.embeds.nowPlaying(track)]
});
}
private async search(query: string, requester: User): Promise<Track[] | undefined> {
const response = await fetchStream(query, {
dumpSingleJson: true,
noWarnings: true,
noCheckCertificate: true,
flatPlaylist: true,
skipDownload: true,
defaultSearch: "ytsearch"
});
if (!response) {
return undefined;
}
const tracks: Track[] = [];
if (response.entries) {
for (const entry of response.entries) {
tracks.push({
url: `https://youtube.com/watch?v=${entry.id}`,
title: entry.title,
thumbnail: `https://img.youtube.com/vi/${entry.id}/default.jpg`,
duration: entry.duration,
requester: requester
});
}
} else {
tracks.push({
url: `https://youtube.com/watch?v=${response.id}`,
title: response.title,
thumbnail: `https://img.youtube.com/vi/${response.id}/default.jpg`,
duration: response.duration,
requester: requester
});
}
return tracks;
}
public play(seek?: number): void {
const track = this.queue.current();
if (!this.internalConnection || !track) {
return;
}
this.internalPlayer.play(this.resourceGenerator(track, seek));
this.internalConnection.subscribe(this.internalPlayer);
this.messageResolvable(track);
}
public connect(channel: VoiceBasedChannel): void {
if (this.internalConnection) {
this.internalConnection.destroy();
}
this.internalConnection = joinVoiceChannel({
channelId: channel.id,
guildId: channel.guildId,
adapterCreator: channel.guild.voiceAdapterCreator as DiscordGatewayAdapterCreator
});
this.internalConnection.on(VoiceConnectionStatus.Disconnected, async () => {
try {
await Promise.race([
entersState(
this.internalConnection as VoiceConnection,
VoiceConnectionStatus.Signalling,
10_000
),
entersState(
this.internalConnection as VoiceConnection,
VoiceConnectionStatus.Connecting,
10_000
)
]);
} catch (error) {
this.destroy();
}
});
}
public async add(query: string, requester: User, index?: number): Promise<Track | undefined> {
const tracks = await this.search(query, requester);
if (!tracks) {
return;
}
this.queue.push(tracks, index);
return tracks[0];
}
public jump(query: number | string): boolean {
let position = typeof query === "number" ? query : -1;
let diff = 0;
if (typeof query === "string") {
this.queue.tracks.forEach((track, index) => {
const tempDiff = largestCommonSequence(track.title, query);
if (diff < tempDiff) {
diff = tempDiff;
position = index;
}
});
}
if (position !== -1 && this.queue.jump(position)) {
this.play();
return true;
}
return false;
}
public remove(query?: number | string): Track | undefined {
const oldPosition = this.queue.position;
let newPosition = typeof query === "number" ? query : this.queue.position;
let diff = 0;
if (typeof query === "string") {
this.queue.tracks.forEach((track, index) => {
const tempDiff = largestCommonSequence(track.title, query);
if (diff < tempDiff) {
diff = tempDiff;
newPosition = index;
}
});
}
const track = this.queue.pop(newPosition);
if (track) {
if (oldPosition === newPosition) {
this.play();
}
return track;
}
return undefined;
}
public seek(time: number): void {
this.play(time);
}
public clear(): void {
this.queue.clear();
this.playerResource = undefined;
if (this.internalPlayer) {
this.internalPlayer.stop();
}
}
public destroy(): void {
if (this.internalConnection) {
this.internalConnection.destroy();
}
this.internalPlayer.stop();
this.music.delete(this.guild.id);
}
public pause(): boolean {
if (this.internalPlayer.state.status === AudioPlayerStatus.Paused) {
this.internalPlayer.unpause();
return false;
} else {
this.internalPlayer.pause();
return true;
}
}
public shuffle(): void {
this.queue.shuffle();
if (this.playerResource) {
this.internalPlayer.stop();
this.play();
}
}
public skip(): void {
this.internalPlayer.stop();
}
public setFilter(filter?: string): void {
this.filter.toggle(filter);
if (this.playerResource) {
this.play(this.playerResource.playbackDuration);
}
}
}
+117
View File
@@ -0,0 +1,117 @@
import { LoopOption, Track } from "./types.js";
export default class Queue {
private entries: Track[] = [];
public get tracks(): Track[] {
return this.entries;
}
private currentIndex = 0;
public get position(): number {
return this.currentIndex;
}
private loopStatus: LoopOption = "NONE";
public get loop(): LoopOption {
return this.loopStatus;
}
public set loop(x: LoopOption) {
this.loopStatus = x;
}
private overallDuration = 0;
public get duration(): number {
return this.overallDuration;
}
public next(): Track | undefined {
if (this.loopStatus === "SONG") {
return this.current();
}
if (this.loopStatus === "AUTO") {
this.currentIndex = Math.floor(Math.random() * this.entries.length);
return this.current();
}
if (this.currentIndex + 1 < this.entries.length) {
this.currentIndex++;
return this.current();
} else if (this.loopStatus === "LOOP") {
this.currentIndex = 0;
return this.current();
} else if (this.loopStatus === "NONE") {
this.currentIndex = 0;
return undefined;
}
}
public shuffle(): void {
let currentIndex = this.entries.length;
while (currentIndex != 0) {
const randomIndex = Math.floor(Math.random() * currentIndex);
currentIndex--;
[this.entries[currentIndex], this.entries[randomIndex]] = [
this.entries[randomIndex],
this.entries[currentIndex]
];
}
this.currentIndex = 0;
}
public push(tracks: Track[], index?: number): Track {
if (!index || index >= this.entries.length) {
this.entries = this.entries.concat(tracks);
} else {
this.entries.splice(Math.max(0, index), 0, ...tracks);
if (this.currentIndex >= index) {
this.currentIndex += tracks.length;
}
}
for (const track of tracks) {
this.overallDuration += track.duration;
}
return this.entries[index || this.entries.length - 1];
}
public pop(query: number): Track | undefined {
if (query >= 0 && query < this.entries.length) {
const track = this.entries[query];
this.entries.splice(query, 1);
this.currentIndex = Math.max(0, this.currentIndex - 1);
this.overallDuration -= track.duration;
return track;
}
return undefined;
}
public jump(query: number): Track | undefined {
if (query >= 0 && query < this.entries.length) {
const track = this.entries[query];
this.currentIndex = query;
return track;
}
return undefined;
}
public current(): Track {
return this.entries[this.currentIndex];
}
public empty(): boolean {
return this.entries.length === 0;
}
public clear(): void {
this.entries = [];
this.currentIndex = 0;
}
}
@@ -1,27 +1,16 @@
import { ApplicationCommandData, User, CommandInteraction } from "discord.js";
import Client from "./Client";
import { User } from "discord.js";
export type track = {
export interface Track {
url: string;
title: string;
thumbnail: string;
duration: number;
requester: User;
};
}
export type command = {
data: ApplicationCommandData;
run: (arg0: Client, arg1: CommandInteraction) => Promise<void>;
};
export type LoopOption = "LOOP" | "SONG" | "NONE" | "AUTO";
export type event = {
name: string;
run: (arg0: Client, arg1: unknown[]) => Promise<void>;
};
export type loopOption = "LOOP" | "SONG" | "NONE" | "AUTO";
export type ytdlArgs = {
export interface YtdlArgs {
help?: boolean;
version?: boolean;
update?: boolean;
@@ -172,9 +161,9 @@ export type ytdlArgs = {
ffmpegLocation?: string;
exec?: string;
convertSubs?: string;
};
}
type ytdlFormat = {
interface YtdlFormat {
asr: number;
filesize: number;
format_id: string;
@@ -194,29 +183,29 @@ type ytdlFormat = {
format: string;
protocol: string;
http_headers: unknown;
};
}
type ytdlThumbnail = {
interface YtdlThumbnail {
height: number;
url: string;
width: number;
resolution: string;
id: string;
};
}
type ytdlEntry = {
interface YtdlEntry {
uploader: string;
duration: number;
id: string;
title: string;
url: string;
};
}
export type ytdlResponse = {
export interface YtdlResponse {
id: string;
title: string;
formats: ytdlFormat[];
thumbnails: ytdlThumbnail[];
formats: YtdlFormat[];
thumbnails: YtdlThumbnail[];
description: string;
upload_date: string;
uploader: string;
@@ -268,5 +257,5 @@ export type ytdlResponse = {
http_headers: unknown;
fulltitle: string;
_filename: string;
entries: ytdlEntry[];
};
entries: YtdlEntry[];
}
+15
View File
@@ -0,0 +1,15 @@
import path from "path";
import { fileURLToPath } from "url";
import Music from "./lib/music.js";
const name = "music";
const description = "Music module";
const author = "unknowableshade";
const tag = "2302.1";
const controller = new Music();
const rootDir = path.dirname(fileURLToPath(import.meta.url));
export { author, controller, description, name, rootDir, tag };
+15 -15
View File
@@ -1,19 +1,19 @@
{
"compilerOptions": {
"strict": true,
"compilerOptions": {
"strict": true,
"module": "CommonJS",
"moduleResolution": "node",
"outDir": "dist",
"removeComments": false,
"sourceMap": true,
"esModuleInterop": true,
"module": "ESNext",
"moduleResolution": "node",
"outDir": "dist",
"removeComments": false,
"sourceMap": true,
"esModuleInterop": true,
"target": "ESNext",
"lib": ["ESNext"],
"types": ["node"],
"skipLibCheck": true
},
"include": ["src/**/*"],
"exclude": ["node_modules", "dist"]
"target": "ESNext",
"lib": ["ESNext"],
"types": ["node"],
"skipLibCheck": true
},
"include": ["src/**/*"],
"exclude": ["node_modules", "dist", "src/commands", "src/events"]
}