harmony/src/test/music.ts

import {
  CommandClient,
  event,
  Intents,
  command,
  CommandContext,
  Extension,
  Collection
} from '../../mod.ts'
import { LL_IP, LL_PASS, LL_PORT, TOKEN } from './config.ts'
import {
  Manager,
  Player
} from 'https://raw.githubusercontent.com/Lavaclient/lavadeno/master/mod.ts'

export const nodes = [
  {
    id: 'main',
    host: LL_IP,
    port: LL_PORT,
    password: LL_PASS
  }
]

class MyClient extends CommandClient {
  manager: Manager

  constructor() {
    super({
      prefix: ['.'],
      caseSensitive: false
    })

    // eslint-disable-next-line @typescript-eslint/no-this-alias
    const client = this

    this.manager = new Manager(nodes, {
      send(id, payload) {
        // Sharding not added yet
        client.gateway?.send(payload)
      }
    })

    this.manager.on('socketError', ({ id }, error) =>
      console.error(`${id} ran into an error`, error)
    )
    this.manager.on('socketReady', (node) =>
      console.log(`${node.id} connected.`)
    )

    this.on('raw', (evt: string, d: any) => {
      if (evt === 'VOICE_SERVER_UPDATE') this.manager.serverUpdate(d)
      else if (evt === 'VOICE_STATE_UPDATE') this.manager.stateUpdate(d)
    })
  }

  @event()
  ready(): void {
    console.log(`Logged in as ${this.user?.tag}!`)
    this.manager.init(this.user?.id as string)
  }
}

const players = new Collection<string, Player>()

class VCExtension extends Extension {
  name = 'VC'
  subPrefix = 'vc'

  @command()
  async join(ctx: CommandContext): Promise<any> {
    if (players.has(ctx.guild?.id as string) === true)
      return ctx.message.reply(`Already playing in this server!`)

    ctx.argString = ctx.argString.slice(4).trim()

    if (ctx.argString === '')
      return ctx.message.reply('You gave nothing to search.')

    const userVS = await ctx.guild?.voiceStates.get(ctx.author.id)
    if (userVS === undefined) {
      ctx.message.reply("You're not in VC.")
      return
    }

    const player = (ctx.client as MyClient).manager.create(
      ctx.guild?.id as string
    )

    await player.connect(userVS.channel?.id as string, { selfDeaf: true })

    ctx.message.reply(`Joined VC channel - ${userVS.channel?.name}!`)

    players.set(ctx.guild?.id as string, player)

    ctx.channel.send(`Loading...`)

    ctx.channel.send(`Searching for ${ctx.argString}...`)

    const { track, info } = await player.manager
      .search(`ytsearch:${ctx.argString}`)
      .then((e) => e.tracks[0])

    await player.play(track)

    ctx.channel.send(`Now playing ${info.title}!`)
  }

  @command()
  async leave(ctx: CommandContext): Promise<any> {
    const userVS = await ctx.guild?.voiceStates.get(
      (ctx.client.user?.id as unknown) as string
    )
    if (userVS === undefined) {
      ctx.message.reply("I'm not in VC.")
      return
    }
    userVS.channel?.leave()
    ctx.message.reply(`Left VC channel - ${userVS.channel?.name}!`)

    if (players.has(ctx.guild?.id as string) !== true)
      return ctx.message.reply('Not playing anything in this server.')

    const player = (players.get(ctx.guild?.id as string) as unknown) as Player
    await player.stop()
    await player.destroy()

    players.delete(ctx.guild?.id as string)
    ctx.message.reply('Stopped player')
  }
}

const client = new MyClient()

client.extensions.load(VCExtension)

client.connect(TOKEN, Intents.None)