import de.btobastian.javacord.entities.Server; //导入依赖的package包/类
/**
 * Handles the server text channels.
 *
 * @param packet The packet (the "d"-object).
 * @param server The server of the channel.
 */
private void handleServerTextChannel(JSONObject packet, Server server) {
    if (server.getChannelById(packet.getString("id")) != null) {
        return;
    }
    final Channel channel = new ImplChannel(packet, (ImplServer) server, api);
    listenerExecutorService.submit(new Runnable() {
        @Override
        public void run() {
            List<ChannelCreateListener> listeners = api.getListeners(ChannelCreateListener.class);
            synchronized (listeners) {
                for (ChannelCreateListener listener : listeners) {
                    try {
                        listener.onChannelCreate(api, channel);
                    } catch (Throwable t) {
                        logger.warn("Uncaught exception in ChannelCreateListener!", t);
                    }
                }
            }
        }
    });
}
 

import de.btobastian.javacord.entities.Server; //导入依赖的package包/类
/**
 * Handles the server voice channels.
 *
 * @param packet The packet (the "d"-object).
 * @param server The server of the channel.
 */
private void handleServerVoiceChannel(JSONObject packet, Server server) {
    if (server.getVoiceChannelById(packet.getString("id")) != null) {
        return;
    }
    final VoiceChannel channel = new ImplVoiceChannel(packet, (ImplServer) server, api);
    listenerExecutorService.submit(new Runnable() {
        @Override
        public void run() {
            List<VoiceChannelCreateListener> listeners = api.getListeners(VoiceChannelCreateListener.class);
            synchronized (listeners) {
                for (VoiceChannelCreateListener listener : listeners) {
                    try {
                        listener.onVoiceChannelCreate(api, channel);
                    } catch (Throwable t) {
                        logger.warn("Uncaught exception in VoiceChannelCreateListener!", t);
                    }
                }
            }
        }
    });
}
 

import de.btobastian.javacord.entities.Server; //导入依赖的package包/类
/**
 * Handles the server text channels.
 *
 * @param packet The packet (the "d"-object).
 * @param server The server of the channel.
 */
private void handleServerTextChannel(JSONObject packet, Server server) {
    final Channel channel = server.getChannelById(packet.getString("id"));
    if (channel == null) {
        return;
    }
    ((ImplServer) server).removeChannel(channel);
    listenerExecutorService.submit(new Runnable() {
        @Override
        public void run() {
            List<ChannelDeleteListener> listeners = api.getListeners(ChannelDeleteListener.class);
            synchronized (listeners) {
                for (ChannelDeleteListener listener : listeners) {
                    try {
                        listener.onChannelDelete(api, channel);
                    } catch (Throwable t) {
                        logger.warn("Uncaught exception in ChannelDeleteListener!", t);
                    }
                }
            }
        }
    });
}
 

import de.btobastian.javacord.entities.Server; //导入依赖的package包/类
/**
 * Handles the server voice channels.
 *
 * @param packet The packet (the "d"-object).
 * @param server The server of the channel.
 */
private void handleServerVoiceChannel(JSONObject packet, Server server) {
    final VoiceChannel channel = server.getVoiceChannelById(packet.getString("id"));
    if (channel == null) {
        return;
    }
    ((ImplServer) server).removeVoiceChannel(channel);
    listenerExecutorService.submit(new Runnable() {
        @Override
        public void run() {
            List<VoiceChannelDeleteListener> listeners = api.getListeners(VoiceChannelDeleteListener.class);
            synchronized (listeners) {
                for (VoiceChannelDeleteListener listener : listeners) {
                    try {
                        listener.onVoiceChannelDelete(api, channel);
                    } catch (Throwable t) {
                        logger.warn("Uncaught exception in VoiceChannelDeleteListener!", t);
                    }
                }
            }
        }
    });
}
 

import de.btobastian.javacord.entities.Server; //导入依赖的package包/类
@Override
public void handle(JSONObject packet) {
    final Server server = api.getServerById(packet.getString("id"));
    if (server == null) {
        return;
    }
    api.getServerMap().remove(server.getId());
    listenerExecutorService.submit(new Runnable() {
        @Override
        public void run() {
            List<ServerLeaveListener> listeners = api.getListeners(ServerLeaveListener.class);
            synchronized (listeners) {
                for (ServerLeaveListener listener : listeners) {
                    try {
                        listener.onServerLeave(api, server);
                    } catch (Throwable t) {
                        logger.warn("Uncaught exception in ServerLeaveListener!", t);
                    }
                }
            }
        }
    });
}
 

import de.btobastian.javacord.entities.Server; //导入依赖的package包/类
@Override
public void handle(JSONObject packet) {
    String guildId = packet.getString("guild_id");
    JSONObject roleJson = packet.getJSONObject("role");

    Server server = api.getServerById(guildId);
    final Role role = new ImplRole(roleJson, (ImplServer) server, api);

    listenerExecutorService.submit(new Runnable() {
        @Override
        public void run() {
            List<RoleCreateListener> listeners = api.getListeners(RoleCreateListener.class);
            synchronized (listeners) {
                for (RoleCreateListener listener : listeners) {
                    try {
                        listener.onRoleCreate(api, role);
                    } catch (Throwable t) {
                        logger.warn("Uncaught exception in RoleCreateListener!", t);
                    }
                }
            }
        }
    });
}
 

import de.btobastian.javacord.entities.Server; //导入依赖的package包/类
@Override
public void handle(JSONObject packet) {
    final Server server = api.getServerById(packet.getString("guild_id"));
    final User user = api.getOrCreateUser(packet.getJSONObject("user"));
    if (server != null) {
        ((ImplServer) server).addMember(user);
        ((ImplServer) server).incrementMemberCount();
        listenerExecutorService.submit(new Runnable() {
            @Override
            public void run() {
                List<ServerMemberAddListener> listeners = api.getListeners(ServerMemberAddListener.class);
                synchronized (listeners) {
                    for (ServerMemberAddListener listener : listeners) {
                        try {
                            listener.onServerMemberAdd(api, user, server);
                        } catch (Throwable t) {
                            logger.warn("Uncaught exception in ServerMemberAddListener!", t);
                        }
                    }
                }
            }
        });
    }
}
 

import de.btobastian.javacord.entities.Server; //导入依赖的package包/类
@Override
public void handle(JSONObject packet) {
    final Server server = api.getServerById(packet.getString("guild_id"));
    final User user = api.getOrCreateUser(packet.getJSONObject("user"));
    if (server != null) {
        listenerExecutorService.submit(new Runnable() {
            @Override
            public void run() {
                List<ServerMemberBanListener> listeners = api.getListeners(ServerMemberBanListener.class);
                synchronized (listeners) {
                    for (ServerMemberBanListener listener : listeners) {
                        try {
                            listener.onServerMemberBan(api, user, server);
                        } catch (Throwable t) {
                            logger.warn("Uncaught exception in ServerMemberBanListener!", t);
                        }
                    }
                }
            }
        });
    }
}
 

import de.btobastian.javacord.entities.Server; //导入依赖的package包/类
@Override
public void handle(JSONObject packet) {
    final Server server = api.getServerById(packet.getString("guild_id"));
    final User user = api.getOrCreateUser(packet.getJSONObject("user"));
    if (server != null) {
        ((ImplServer) server).removeMember(user);
        ((ImplServer) server).decrementMemberCount();
        listenerExecutorService.submit(new Runnable() {
            @Override
            public void run() {
                List<ServerMemberRemoveListener> listeners = api.getListeners(ServerMemberRemoveListener.class);
                synchronized (listeners) {
                    for (ServerMemberRemoveListener listener : listeners) {
                        try {
                            listener.onServerMemberRemove(api, user, server);
                        } catch (Throwable t) {
                            logger.warn("Uncaught exception in ServerMemberRemoveListener!", t);
                        }
                    }
                }
            }
        });
    }
}
 

import de.btobastian.javacord.entities.Server; //导入依赖的package包/类
@Override
public void handle(JSONObject packet) {
    final Server server = api.getServerById(packet.getString("guild_id"));
    final User user = api.getOrCreateUser(packet.getJSONObject("user"));
    if (server != null) {
        ((ImplServer) server).removeMember(user);
        listenerExecutorService.submit(new Runnable() {
            @Override
            public void run() {
                List<ServerMemberUnbanListener> listeners = api.getListeners(ServerMemberUnbanListener.class);
                synchronized (listeners) {
                    for (ServerMemberUnbanListener listener : listeners) {
                        try {
                            listener.onServerMemberUnban(api, user.getId(), server);
                        } catch (Throwable t) {
                            logger.warn("Uncaught exception in ServerMemberUnbanListener!", t);
                        }
                    }
                }
            }
        });
    }
}
 

import de.btobastian.javacord.entities.Server; //导入依赖的package包/类
public void registerChannels() {
    Server server = getServer();
    Collection<ChatChannel> channels = module.getChatModule().getChatChannels();
    for (ChatChannel channel : channels) {
        String name = channel.getChannelName();
        // TODO: Find a way to work around the JDK8 limitation with JavaCord 3.0 not being able to support categories.
        if (name.toLowerCase().contains("faction")) {
            continue;
        }
        // Only register public channels.
        if (!channel.isPublicChannel()) {
            continue;
        }
        String ascii = toAsciiString("channel_" + name);
        Channel dChannel = getChannel(ascii);
        if (dChannel == null) {
            dChannel = createChannelIfNotExists(ascii);
        }
        listPublicChannels.add(dChannel);
    }
}
 

import de.btobastian.javacord.entities.Server; //导入依赖的package包/类
/**
 *
 * @param user User to check
 * @param server Server to check against
 * @param roleName Role name
 * @param caseSensitive Case Sensitive
 * @return True or False
 */
public boolean hasRole(User user, Server server, String roleName, boolean caseSensitive){
	if (!caseSensitive) {
		for (Role r : user.getRoles(server)) {
			if (r.getName().equalsIgnoreCase(roleName)) {
				return true;
			}
		}
		return false;
	}else{
		return hasRole(user, server, roleName);
	}
}
 

import de.btobastian.javacord.entities.Server; //导入依赖的package包/类
@Override
public void handle(JSONObject packet) {
    Channel channelTemp = null;
    String channelId = packet.getString("channel_id");
    Iterator<Server> serverIterator = api.getServers().iterator();
    while (serverIterator.hasNext()) {
        channelTemp = serverIterator.next().getChannelById(channelId);
        if (channelTemp != null) {
            break;
        }
    }
    final Channel channel = channelTemp;

    String userId = packet.getString("user_id");
    final User user;
    try {
        user = api.getUserById(userId).get();
    } catch (InterruptedException | ExecutionException e) {
        return;
    }
    listenerExecutorService.submit(new Runnable() {
        @Override
        public void run() {
            List<TypingStartListener> listeners = api.getListeners(TypingStartListener.class);
            synchronized (listeners) {
                for (TypingStartListener listener : listeners) {
                    try {
                        listener.onTypingStart(api, user, channel);
                    } catch (Throwable t) {
                        logger.warn("Uncaught exception in TypingStartListener!", t);
                    }
                }
            }
        }
    });
}
 

import de.btobastian.javacord.entities.Server; //导入依赖的package包/类
@Override
public void handle(JSONObject packet) {
    String guildId = packet.getString("guild_id");
    String roleId = packet.getString("role_id");

    Server server = api.getServerById(guildId);
    final Role role = server.getRoleById(roleId);

    if (role == null) {
        return;
    }

    ((ImplServer) server).removeRole(role);

    listenerExecutorService.submit(new Runnable() {
        @Override
        public void run() {
            List<RoleDeleteListener> listeners = api.getListeners(RoleDeleteListener.class);
            synchronized (listeners) {
                for (RoleDeleteListener listener : listeners) {
                    try {
                        listener.onRoleDelete(api, role);
                    } catch (Throwable t) {
                        logger.warn("Uncaught exception in RoleDeleteListener!", t);
                    }
                }
            }
        }
    });
}
 

import de.btobastian.javacord.entities.Server; //导入依赖的package包/类
@Override
public void handle(JSONObject packet) {
    if (packet.has("unavailable") && packet.getBoolean("unavailable")) {
        return;
    }
    String id = packet.getString("id");
    if (api.getUnavailableServers().contains(id)) {
        api.getUnavailableServers().remove(id);
        new ImplServer(packet, api);
        return;
    }
    if (api.getServerById(id) != null) {
        // TODO update information
        return;
    }
    final Server server = new ImplServer(packet, api);
    listenerExecutorService.submit(new Runnable() {
        @Override
        public void run() {
            List<ServerJoinListener> listeners = api.getListeners(ServerJoinListener.class);
            synchronized (listeners) {
                for (ServerJoinListener listener : listeners) {
                    try {
                        listener.onServerJoin(api, server);
                    } catch (Throwable t) {
                        logger.warn("Uncaught exception in ServerJoinListener!", t);
                    }
                }
            }
        }
    });
    api.getThreadPool().getExecutorService().submit(new Runnable() {
        @Override
        public void run() {
            // can cause a deadlock if someone blocks a listener
            // with the #createServer or #acceptInvite method + #get
            api.getInternalServerJoinListener().onServerJoin(api, server);
        }
    });
}
 

import de.btobastian.javacord.entities.Server; //导入依赖的package包/类
@Override
public void handle(JSONObject packet) {
    final Server server = api.getServerById(packet.getString("guild_id"));
    if (server != null) {
        ((ImplServer) server).addMembers(packet.getJSONArray("members"));
    }
}
 

import de.btobastian.javacord.entities.Server; //导入依赖的package包/类
/**
 * Tries to find the message receiver based on its channel id.
 *
 * @param channelId The channel id of the receiver.
 * @return The receiver with the given id.
 */
private MessageReceiver findReceiver(String channelId) {
    for (Server server : api.getServers()) {
        if (server.getChannelById(channelId) != null) {
            return server.getChannelById(channelId);
        }
    }
    for (User user : api.getUsers()) {
        if (channelId.equals(((ImplUser) user).getUserChannelId())) {
            return user;
        }
    }
    return null;
}
 

import de.btobastian.javacord.entities.Server; //导入依赖的package包/类
@Override
public Collection<Role> getRoles(Server server) {
    Collection<Role> userRoles = new ArrayList<>();
    Iterator<Role> rolesIterator = server.getRoles().iterator();
    while (rolesIterator.hasNext()) {
        Role role = rolesIterator.next();
        if (role.getUsers().contains(this)) {
            userRoles.add(role);
        }
    }
    return userRoles;
}
 

import de.btobastian.javacord.entities.Server; //导入依赖的package包/类
public void discoverChannels() {
    String channelConsole = module.getConsoleChannelName();
    for (Server server : api.getServers()) {
        for (Channel channel : server.getChannels()) {
            if (channel.getName().equalsIgnoreCase(channelConsole)) {
                this.channelConsole = channel;
                return;
            }
        }
    }
}
 

import de.btobastian.javacord.entities.Server; //导入依赖的package包/类
/**
 * @param name   The name to search the server for valid a User
 * @param server The server to search through Users
 * @return The User, if any, that matches the name supplied
 */
static Optional<User> getUserByName(String name, Server server) {
    for (User user : server.getMembers()) {
        if (user.getName().equalsIgnoreCase(name) || (user.getNickname(server) != null && user.getNickname(server).equalsIgnoreCase(name))) {
            return Optional.of(user);
        }
    }
    return Optional.empty();
}