!7

//set flag DifferentJDA.

//lib 1400185 // discord with opus/JNA (hopefully not a problem)

import net.dv8tion.jda.core.managers.AudioManager; // Note: moved from core to api in JDA 4.0

import net.dv8tion.jda.core.audio.*;

import java.nio.ByteBuffer;

import com.sedmelluq.discord.lavaplayer.player.*;

import com.sedmelluq.discord.lavaplayer.player.event.*;

import com.sedmelluq.discord.lavaplayer.demo.jda.TrackScheduler;

import com.sedmelluq.discord.lavaplayer.track.*;

import com.sedmelluq.discord.lavaplayer.track.playback.*;

import com.sedmelluq.discord.lavaplayer.source.*;

import com.sedmelluq.discord.lavaplayer.tools.*;

//lib 1400286 // lavaplayer 1.3.22

lib 1400288 // lavaplayer fat

lib 1400289 // httpclient

lib 1400290 // httpcore

lib 1400291 // commons-io

lib 1400298 // lavaplayer libconnector.so

lib 1400295 lib 1400296 // logback

lib 1002510 // jsoup

lib 1400299 // apache-commons-logging

static AudioPlayerManager playerManager;

svoid cleanMeUp { dispose playerManager; }

cmodule DiscordAudioSpike > DynTalkBot2 {

  S myName = "Discord Audio Spike";

  start {

    setLoggingLevel(ch.qos.logback.classic.Level.DEBUG);

    if (isLinux()) {

      //loadNativeLibraryInX30(loadLibrary(#1400293));

      loadNativeLibrarySnippet/*InX30*/(#1400293); // libopus

      //loadNativeLibrarySnippet/*InX30*/(#1400294); // libconnector

    }

    makeByServer = () -> new ByServer;

    useAGIBlueForDropPunctuation = false;

    preprocessAtSelfToMyName = false;

    if (playerManager == null) {

      playerManager = new DefaultAudioPlayerManager;

      AudioSourceManagers.registerLocalSource(playerManager);

      AudioSourceManagers.registerRemoteSources(playerManager);

    }

  }

  class ByServer extends DynTalkBot2.ByServer {

    synchronized S processSimplifiedLine(S s, O... _) {

      try answer super.processSimplifiedLine(s, _); // adding authorized users etc.

      new Matches m;

      if null (s = dropMyPrefixOrNull(s)) null;

      optPar Message msg;

      Guild guild = msg == null ? null : msg.getGuild();

      if "voice channels"

        ret str(guild.getVoiceChannels());

      if "join voice channel"

        ret joinVoiceChannel(first(guild.getVoiceChannels());

      if (eqic(s, "help"))

        ret ltrim([[

I'm a Discord Audio Test

[Bot made by https://BotCompany.de]

  ]]).replace("@me", atSelf());

      null;

    }

    S joinVoiceChannel(VoiceChannel vc) {

      if (vc == null) ret "No channel";

      Guild guild = vc.getGuild();

      AudioManager am = guild.getAudioManager();

      AudioPlayer player = playerManager.createPlayer();

      TrackScheduler trackScheduler = new(player);

      player.addListener(trackScheduler);

      player.addListener(e -> {

        temp enter();

        print("Audio event: " + e);

        if (e cast TrackExceptionEvent)

          printStackTrace(e.exception);

      });

      am.setSendingHandler(new AudioPlayerSendHandler(player));

      am.openAudioConnection(vc);

      /*S trackID = f2s(

        //loadLibrary(#1400292) // opus

        mp3ToWAVUnlessExists(loadLibrary(#1001093), javaxCachesDir("1001093.wav")) // mp3 -> wav

      );*/

      S trackID = "http://s3.free-shoutcast.com:18162/;?type=http&nocache=" + randomInt();

      playerManager.loadItem(print("Loading: ", trackID), new AudioLoadResultHandler {

        public void trackLoaded(AudioTrack track) enter {

          //print("Scheduling track " + track);

          //trackScheduler.queue(track);

          //player.playTrack(track);

          print(player.startTrack(track, false));

          print("Started track " + track);

          print("isPaused: " + player.isPaused());

          print("Active track: " + player.getPlayingTrack());

        }

        public void playlistLoaded(AudioPlaylist playlist) enter {

          for (AudioTrack track : playlist.getTracks())

            trackScheduler.queue(track);

        }

        public void noMatches() enter { print("noMatches"); }

        public void loadFailed(FriendlyException e) enter {

          print("loadFailed: " + e);

          printStackTrace(e);

        }

      });

      ret "Audio connection to " + vc.getName() + " opened";

    }

  }

}

sclass AudioPlayerSendHandler implements AudioSendHandler {

  AudioPlayer audioPlayer;

  AudioFrame lastFrame;

  NotTooOften nto = notTooOften_everySecond();

  *(AudioPlayer *audioPlayer) {}

  public bool canProvide() {

    lastFrame = audioPlayer.provide();

    if (nto.yo()) print("canProvide: " + (lastFrame != null));

    ret lastFrame != null;

  }

  public byte[] provide20MsAudio() {

    return lastFrame.getData();

  }

  public bool isOpus() { true; }

}

svoid setLoggingLevel(ch.qos.logback.classic.Level level) {

  ch.qos.logback.classic.Logger root = (ch.qos.logback.classic.Logger) org.slf4j.LoggerFactory.getLogger(ch.qos.logback.classic.Logger.ROOT_LOGGER_NAME);

  root.setLevel(level);

}