import net.dv8tion.jda.utils.SimpleLog; //导入依赖的package包/类
public List<String> getResults(String query, int numresults)
{
    List<String> urls = new ArrayList<>();
    search.setQ(query);
    search.setMaxResults((long)numresults);
    
    SearchListResponse searchResponse;
    try {
        searchResponse = search.execute();
    List<SearchResult> searchResultList = searchResponse.getItems();
    searchResultList.stream().forEach((sr) -> {
        urls.add(sr.getId().getVideoId());
    });
    } catch (IOException ex) {
        SimpleLog.getLog("Youtube").fatal("Search failure: "+ex.toString());
        return null;
    }
    return urls;
}
 

import net.dv8tion.jda.utils.SimpleLog; //导入依赖的package包/类
@Autowired
public Launcher(Config config, SocketServer socketServer) {
    Runtime.getRuntime().addShutdownHook(new Thread(() -> {
        log.info("Shutdown hook triggered");
        try {
            socketServer.stop(30);
        } catch (InterruptedException e) {
            log.warn("Interrupted while stopping socket server", e);
        }
    }, "shutdown hook"));

    SimpleLog.LEVEL = SimpleLog.Level.OFF;
    SimpleLog.addListener(new SimpleLogToSLF4JAdapter());
    Launcher.config = config;
    initSentry();
    this.socketServer = socketServer;
}
 

import net.dv8tion.jda.utils.SimpleLog; //导入依赖的package包/类
public YoutubeSearcher(String apiKey)
{
    youtube = new YouTube.Builder(new NetHttpTransport(), new JacksonFactory(), (HttpRequest request) -> {
    }).setApplicationName(SpConst.BOTNAME).build();
    Search.List tmp = null;
    try {
        tmp = youtube.search().list("id,snippet");
    } catch (IOException ex) {
        SimpleLog.getLog("Youtube").fatal("Failed to initialize search: "+ex.toString());
    }
    search = tmp;
    if(search!=null)
    {
        search.setKey(apiKey);
        search.setType("video");
        search.setFields("items(id/kind,id/videoId,snippet/title,snippet/thumbnails/default/url)");
    }
}
 

import net.dv8tion.jda.utils.SimpleLog; //导入依赖的package包/类
@Override
public void onLog(SimpleLog simpleLog, SimpleLog.Level logLevel, Object message) {
    if (message == null) {
        message = "null";
    }

    switch (logLevel) {
        case TRACE:
            if (log.isTraceEnabled()) {
                log.trace(message.toString());
            }
            break;
        case DEBUG:
            if (log.isDebugEnabled()) {
                log.debug(message.toString());
            }
            break;
        case INFO:
            log.info(message.toString());
            break;
        case WARNING:
            log.warn(message.toString());
            break;
        case FATAL:
            log.error(message.toString());
            break;
    }
}
 

import net.dv8tion.jda.utils.SimpleLog; //导入依赖的package包/类
@Override
public void onError(SimpleLog simpleLog, Throwable err) {
    log.error("An exception occurred", err);
}
 

import net.dv8tion.jda.utils.SimpleLog; //导入依赖的package包/类
public static void main(final String[] args) throws Exception {
    try {
        SimpleLog.addFileLogs(null,new File("err" + System.currentTimeMillis() + ".txt"));
    } catch (IOException e) {
        Logger.writeToErr(e, "");
    }
    Dao dao = new Dao();
    List<Platform> platforms;
    String token = PropertiesReader.getInstance().getProp().getProperty("bot.token");
    DiscordController discordController = new DiscordController(dao);
    JDA jda = new JDABuilder()
            .setBotToken(token)
            .addListener(discordController)
            .buildBlocking();
    discordController.setJda(jda);

    Thread messageConsumer = new MessageConsumer(MessageHandler.getQueue(), jda, dao);
    messageConsumer.start();

    Thread messageFinder = new MessageFinder(MessageHandler.getDeleteQueue(), jda);
    messageFinder.start();

    platforms = setPlatforms(dao, jda);

    WebController webController = new WebController(jda, dao);
    webController.serve();

    platforms.forEach(Platform::checkStillOnline);
    int ticks = 0;
    while(true){

        if(!((JDAImpl)jda).getClient().isConnected()){
            while (!((JDAImpl)jda).getClient().isConnected()){
                Thread.sleep(1000);
            }
            discordController.setJda(jda);
            platforms = setPlatforms(dao, jda);
            //webController.setJda(jda);
            continue;
        }

        if(!messageConsumer.isAlive()){
            messageConsumer = new MessageConsumer(MessageHandler.getQueue(), jda, dao);
            messageConsumer.start();
        }

        if(!messageFinder.isAlive()){
            messageFinder = new MessageFinder(MessageHandler.getDeleteQueue(), jda);
            messageFinder.start();
        }

        if(ticks < 10){
            Session session = HibernateUtil.getSession();
            List<Long> guildIDs = session.createCriteria(GuildEntity.class)
                    .setProjection(Projections.property("id")).list();
            List<Guild> connectedGuilds = jda.getGuilds();
            for(Guild connectedGuild : connectedGuilds){
                Long connectedGuildID = Long.parseLong(connectedGuild.getId());
                if(guildIDs.contains(connectedGuildID)){
                    for(Platform platform : platforms){
                        platform.checkStreams(connectedGuildID);
                    }
                }
            }
            ticks++;
        }
        else{
            platforms.forEach(Platform::checkStillOnline);
            ticks = 0;
        }

        Thread.sleep(60000);


    }

}