package com.github.theholywaffle.teamspeak3;

/*
 * #%L
 * TeamSpeak 3 Java API
 * %%
 * Copyright (C) 2014 Bert De Geyter
 * %%
 * Permission is hereby granted, free of charge, to any person obtaining a copy
 * of this software and associated documentation files (the "Software"), to deal
 * in the Software without restriction, including without limitation the rights
 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
 * copies of the Software, and to permit persons to whom the Software is
 * furnished to do so, subject to the following conditions:
 * 
 * The above copyright notice and this permission notice shall be included in
 * all copies or substantial portions of the Software.
 * 
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
 * THE SOFTWARE.
 * #L%
 */

import com.github.theholywaffle.teamspeak3.api.*;
import com.github.theholywaffle.teamspeak3.api.event.TS3EventType;
import com.github.theholywaffle.teamspeak3.api.event.TS3Listener;
import com.github.theholywaffle.teamspeak3.api.exception.TS3CommandFailedException;
import com.github.theholywaffle.teamspeak3.api.wrapper.*;
import com.github.theholywaffle.teamspeak3.commands.*;

import java.util.ArrayList;
import java.util.Collection;
import java.util.Collections;
import java.util.List;
import java.util.Locale;
import java.util.Map;
import java.util.concurrent.TimeUnit;
import java.util.regex.Pattern;

/**
 * Asynchronous version of {@link TS3Api} to interact with the {@link TS3Query}.
 * <p>
 * This class is used to easily interact with a {@link TS3Query}. It constructs commands,
 * sends them to the TeamSpeak3 server, processes the response and returns the result.
 * </p><p>
 * All methods in this class are asynchronous (so they won't block) and
 * will return a {@link CommandFuture} of the corresponding return type in {@link TS3Api}.
 * If a command fails, no exception will be thrown directly. It will however be rethrown in
 * {@link CommandFuture#get()} and {@link CommandFuture#get(long, TimeUnit)}.
 * Usually, the thrown exception is a {@link TS3CommandFailedException}, which will get you
 * access to the {@link QueryError} from which more information about the error can be obtained.
 * </p><p>
 * Also note that while these methods are asynchronous, the commands will still be sent through a
 * synchronous command pipeline. That means if an asynchronous method is called immediately
 * followed by a synchronous method, the synchronous method will first have to wait until the
 * asynchronous method completed until it its command is sent.
 * </p><p>
 * You won't be able to execute most commands while you're not logged in due to missing permissions.
 * Make sure to either pass your login credentials to the {@link TS3Config} object when
 * creating the {@code TS3Query} or to call {@link #login(String, String)} to log in.
 * </p><p>
 * After that, most commands also require you to select a {@linkplain VirtualServer virtual server}.
 * To do so, call either {@link #selectVirtualServerByPort(int)} or {@link #selectVirtualServerById(int)}.
 * </p>
 *
 * @see TS3Api The synchronous version of the API
 */
public class TS3ApiAsync {

        /**
         * The TS3 query to which this API sends its commands.
         */
        private final TS3Query query;

        /**
         * Creates a new asynchronous API object for the given {@code TS3Query}.
         * <p>
         * <b>Usually, this constructor should not be called.</b> Use {@link TS3Query#getAsyncApi()} instead.
         * </p>
         *
         * @param query
         *              the TS3Query to call
         */
        public TS3ApiAsync(TS3Query query) {
                this.query = query;
        }

        /**
         * Adds a new ban entry. At least one of the parameters {@code ip}, {@code name} or {@code uid} needs to be not null.
         * Returns the ID of the newly created ban.
         *
         * @param ip
         *              a RegEx pattern to match a client's IP against, can be null
         * @param name
         *              a RegEx pattern to match a client's name against, can be null
         * @param uid
         *              the unique identifier of a client, can be null
         * @param timeInSeconds
         *              the duration of the ban in seconds. 0 equals a permanent ban
         * @param reason
         *              the reason for the ban, can be null
         *
         * @return the ID of the newly created ban entry
         *
         * @querycommands 1
         * @see Pattern RegEx Pattern
         * @see Client#getId()
         * @see Client#getUniqueIdentifier()
         * @see ClientInfo#getIp()
         */
        public CommandFuture<Integer> addBan(String ip, String name, String uid, long timeInSeconds, String reason) {
                if (ip == null && name == null && uid == null) {
                        throw new IllegalArgumentException("Either IP, Name or UID must be set");
                }

                final CBanAdd add = new CBanAdd(ip, name, uid, timeInSeconds, reason);
                return executeAndReturnIntProperty(add, "banid");
        }

        /**
         * Adds a specified permission to a client in a specific channel.
         *
         * @param channelId
         *              the ID of the channel wherein the permission should be granted
         * @param clientDBId
         *              the database ID of the client to add a permission to
         * @param permName
         *              the name of the permission to grant
         * @param permValue
         *              the numeric value of the permission (or for boolean permissions: 1 = true, 0 = false)
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see Channel#getId()
         * @see Client#getDatabaseId()
         * @see Permission
         */
        public CommandFuture<Boolean> addChannelClientPermission(int channelId, int clientDBId, String permName, int permValue) {
                final CChannelClientAddPerm add = new CChannelClientAddPerm(channelId, clientDBId, permName, permValue);
                return executeAndReturnError(add);
        }

        /**
         * Creates a new channel group for clients using a given name and returns its ID.
         * <p>
         * To create channel group templates or ones for server queries,
         * use {@link #addChannelGroup(String, PermissionGroupDatabaseType)}.
         * </p>
         *
         * @param name
         *              the name of the new channel group
         *
         * @return the ID of the newly created channel group
         *
         * @querycommands 1
         * @see ChannelGroup
         */
        public CommandFuture<Integer> addChannelGroup(String name) {
                return addChannelGroup(name, null);
        }

        /**
         * Creates a new channel group using a given name and returns its ID.
         *
         * @param name
         *              the name of the new channel group
         * @param type
         *              the desired type of channel group
         *
         * @return the ID of the newly created channel group
         *
         * @querycommands 1
         * @see ChannelGroup
         */
        public CommandFuture<Integer> addChannelGroup(String name, PermissionGroupDatabaseType type) {
                final CChannelGroupAdd add = new CChannelGroupAdd(name, type);
                return executeAndReturnIntProperty(add, "cgid");
        }

        /**
         * Adds a specified permission to a channel group.
         *
         * @param groupId
         *              the ID of the channel group to grant the permission
         * @param permName
         *              the name of the permission to be granted
         * @param permValue
         *              the numeric value of the permission (or for boolean permissions: 1 = true, 0 = false)
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see ChannelGroup#getId()
         * @see Permission
         */
        public CommandFuture<Boolean> addChannelGroupPermission(int groupId, String permName, int permValue) {
                final CChannelGroupAddPerm add = new CChannelGroupAddPerm(groupId, permName, permValue);
                return executeAndReturnError(add);
        }

        /**
         * Adds a specified permission to a channel.
         *
         * @param channelId
         *              the ID of the channel wherein the permission should be granted
         * @param permName
         *              the name of the permission to grant
         * @param permValue
         *              the numeric value of the permission (or for boolean permissions: 1 = true, 0 = false)
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see Channel#getId()
         * @see Permission
         */
        public CommandFuture<Boolean> addChannelPermission(int channelId, String permName, int permValue) {
                final CChannelAddPerm perm = new CChannelAddPerm(channelId, permName, permValue);
                return executeAndReturnError(perm);
        }

        /**
         * Adds a specified permission to a channel.
         *
         * @param clientDBId
         *              the database ID of the client to grant the permission
         * @param permName
         *              the name of the permission to grant
         * @param value
         *              the numeric value of the permission (or for boolean permissions: 1 = true, 0 = false)
         * @param skipped
         *              if set to {@code true}, the permission will not be overridden by channel group permissions
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see Client#getDatabaseId()
         * @see Permission
         */
        public CommandFuture<Boolean> addClientPermission(int clientDBId, String permName, int value, boolean skipped) {
                final CClientAddPerm add = new CClientAddPerm(clientDBId, permName, value, skipped);
                return executeAndReturnError(add);
        }

        /**
         * Adds a client to the specified server group.
         * <p>
         * Please note that a client cannot be added to default groups or template groups.
         * </p>
         *
         * @param groupId
         *              the ID of the server group to add the client to
         * @param clientDatabaseId
         *              the database ID of the client to add
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see ServerGroup#getId()
         * @see Client#getDatabaseId()
         */
        public CommandFuture<Boolean> addClientToServerGroup(int groupId, int clientDatabaseId) {
                final CServerGroupAddClient add = new CServerGroupAddClient(groupId, clientDatabaseId);
                return executeAndReturnError(add);
        }

        /**
         * Submits a complaint about the specified client.
         * The length of the message is limited to 200 UTF-8 bytes and BB codes in it will be ignored.
         *
         * @param clientDBId
         *              the database ID of the client
         * @param message
         *              the message of the complaint, may not contain BB codes
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see Client#getDatabaseId()
         * @see Complaint#getMessage()
         */
        public CommandFuture<Boolean> addComplaint(int clientDBId, String message) {
                final CComplainAdd add = new CComplainAdd(clientDBId, message);
                return executeAndReturnError(add);
        }

        /**
         * Adds a specified permission to all server groups of the type specified by {@code type} on all virtual servers.
         *
         * @param type
         *              the kind of server group this permission should be added to
         * @param permName
         *              the name of the permission to be granted
         * @param value
         *              the numeric value of the permission (or for boolean permissions: 1 = true, 0 = false)
         * @param negated
         *              if set to true, the lowest permission value will be selected instead of the highest
         * @param skipped
         *              if set to true, this permission will not be overridden by client or channel group permissions
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see ServerGroupType
         * @see Permission
         */
        public CommandFuture<Boolean> addPermissionToAllServerGroups(ServerGroupType type, String permName, int value, boolean negated, boolean skipped) {
                final CServerGroupAutoAddPerm add = new CServerGroupAutoAddPerm(type, permName, value, negated, skipped);
                return executeAndReturnError(add);
        }

        /**
         * Create a new privilege key that allows one client to join a server or channel group.
         * <ul>
         * <li>If {@code type} is set to {@linkplain PrivilegeKeyType#SERVER_GROUP SERVER_GROUP},
         * {@code groupId} is used as a server group ID and {@code channelId} is ignored.</li>
         * <li>If {@code type} is set to {@linkplain PrivilegeKeyType#CHANNEL_GROUP CHANNEL_GROUP},
         * {@code groupId} is used as a channel group ID and {@code channelId} is used as the channel in which the group should be set.</li>
         * </ul>
         *
         * @param type
         *              the type of token that should be created
         * @param groupId
         *              the ID of the server or channel group
         * @param channelId
         *              the ID of the channel, in case the token is channel group token
         * @param description
         *              the description for the token, can be null
         *
         * @return the created token for a client to use
         *
         * @querycommands 1
         * @see PrivilegeKeyType
         * @see #addPrivilegeKeyServerGroup(int, String)
         * @see #addPrivilegeKeyChannelGroup(int, int, String)
         */
        public CommandFuture<String> addPrivilegeKey(PrivilegeKeyType type, int groupId, int channelId, String description) {
                final CPrivilegeKeyAdd add = new CPrivilegeKeyAdd(type, groupId, channelId, description);
                return executeAndReturnStringProperty(add, "token");
        }

        /**
         * Creates a new privilege key for a channel group.
         *
         * @param channelGroupId
         *              the ID of the channel group
         * @param channelId
         *              the ID of the channel in which the channel group should be set
         * @param description
         *              the description for the token, can be null
         *
         * @return the created token for a client to use
         *
         * @querycommands 1
         * @see ChannelGroup#getId()
         * @see Channel#getId()
         * @see #addPrivilegeKey(PrivilegeKeyType, int, int, String)
         * @see #addPrivilegeKeyServerGroup(int, String)
         */
        public CommandFuture<String> addPrivilegeKeyChannelGroup(int channelGroupId, int channelId, String description) {
                return addPrivilegeKey(PrivilegeKeyType.CHANNEL_GROUP, channelGroupId, channelId, description);
        }

        /**
         * Creates a new privilege key for a server group.
         *
         * @param serverGroupId
         *              the ID of the server group
         * @param description
         *              the description for the token, can be null
         *
         * @return the created token for a client to use
         *
         * @querycommands 1
         * @see ServerGroup#getId()
         * @see #addPrivilegeKey(PrivilegeKeyType, int, int, String)
         * @see #addPrivilegeKeyChannelGroup(int, int, String)
         */
        public CommandFuture<String> addPrivilegeKeyServerGroup(int serverGroupId, String description) {
                return addPrivilegeKey(PrivilegeKeyType.SERVER_GROUP, serverGroupId, 0, description);
        }

        /**
         * Creates a new server group for clients using a given name and returns its ID.
         * <p>
         * To create server group templates or ones for server queries,
         * use {@link #addServerGroup(String, PermissionGroupDatabaseType)}.
         * </p>
         *
         * @param name
         *              the name of the new server group
         *
         * @return the ID of the newly created server group
         *
         * @querycommands 1
         * @see ServerGroup
         */
        public CommandFuture<Integer> addServerGroup(String name) {
                return addServerGroup(name, PermissionGroupDatabaseType.REGULAR);
        }

        /**
         * Creates a new server group using a given name and returns its ID.
         *
         * @param name
         *              the name of the new server group
         * @param type
         *              the desired type of server group
         *
         * @return the ID of the newly created server group
         *
         * @querycommands 1
         * @see ServerGroup
         * @see PermissionGroupDatabaseType
         */
        public CommandFuture<Integer> addServerGroup(String name, PermissionGroupDatabaseType type) {
                final CServerGroupAdd add = new CServerGroupAdd(name, type);
                return executeAndReturnIntProperty(add, "sgid");
        }

        /**
         * Adds a specified permission to a server group.
         *
         * @param groupId
         *              the ID of the channel group to which the permission should be added
         * @param permName
         *              the name of the permission to add
         * @param value
         *              the numeric value of the permission (or for boolean permissions: 1 = true, 0 = false)
         * @param negated
         *              if set to true, the lowest permission value will be selected instead of the highest
         * @param skipped
         *              if set to true, this permission will not be overridden by client or channel group permissions
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see ServerGroup#getId()
         * @see Permission
         */
        public CommandFuture<Boolean> addServerGroupPermission(int groupId, String permName, int value, boolean negated, boolean skipped) {
                final CServerGroupAddPerm add = new CServerGroupAddPerm(groupId, permName, value, negated, skipped);
                return executeAndReturnError(add);
        }

        /**
         * Adds one or more {@link TS3Listener}s to the event manager of the query.
         * These listeners will be notified when the TS3 server fires an event.
         * <p>
         * Note that for the TS3 server to fire events, you must first also register
         * the event types you want to listen to.
         * </p>
         *
         * @param listeners
         *              one or more listeners to register
         *
         * @see #registerAllEvents()
         * @see #registerEvent(TS3EventType, int)
         * @see TS3Listener
         * @see TS3EventType
         */
        public void addTS3Listeners(TS3Listener... listeners) {
                query.getEventManager().addListeners(listeners);
        }

        /**
         * Bans a client with a given client ID for a given time.
         * <p>
         * Please note that this will create two separate ban rules,
         * one for the targeted client's IP address and their unique identifier.
         * </p><p>
         * <i>Exception:</i> If the banned client connects via a loopback address
         * (i.e. {@code 127.0.0.1} or {@code localhost}), no IP ban is created
         * and the returned array will only have 1 entry.
         * </p>
         *
         * @param clientId
         *              the ID of the client
         * @param timeInSeconds
         *              the duration of the ban in seconds. 0 equals a permanent ban
         *
         * @return an array containing the IDs of the first and the second ban entry
         *
         * @querycommands 1
         * @see Client#getId()
         * @see #addBan(String, String, String, long, String)
         */
        public CommandFuture<int[]> banClient(int clientId, long timeInSeconds) {
                return banClient(clientId, timeInSeconds, null);
        }

        /**
         * Bans a client with a given client ID for a given time for the specified reason.
         * <p>
         * Please note that this will create two separate ban rules,
         * one for the targeted client's IP address and their unique identifier.
         * </p><p>
         * <i>Exception:</i> If the banned client connects via a loopback address
         * (i.e. {@code 127.0.0.1} or {@code localhost}), no IP ban is created
         * and the returned array will only have 1 entry.
         * </p>
         *
         * @param clientId
         *              the ID of the client
         * @param timeInSeconds
         *              the duration of the ban in seconds. 0 equals a permanent ban
         * @param reason
         *              the reason for the ban, can be null
         *
         * @return an array containing the IDs of the first and the second ban entry
         *
         * @querycommands 1
         * @see Client#getId()
         * @see #addBan(String, String, String, long, String)
         */
        public CommandFuture<int[]> banClient(int clientId, long timeInSeconds, String reason) {
                final CBanClient client = new CBanClient(clientId, timeInSeconds, reason);
                final CommandFuture<int[]> future = new CommandFuture<>();

                query.doCommandAsync(client, new Callback() {
                        @Override
                        public void handle() {
                                if (hasFailed(client, future)) return;

                                final List<Wrapper> response = client.getResponse();
                                final int[] banIds = new int[response.size()];
                                for (int i = 0; i < banIds.length; ++i) {
                                        banIds[i] = response.get(i).getInt("banid");
                                }
                                future.set(banIds);
                        }
                });
                return future;
        }

        /**
         * Bans a client with a given client ID permanently for the specified reason.
         * <p>
         * Please note that this will create two separate ban rules,
         * one for the targeted client's IP address and their unique identifier.
         * </p><p>
         * <i>Exception:</i> If the banned client connects via a loopback address
         * (i.e. {@code 127.0.0.1} or {@code localhost}), no IP ban is created
         * and the returned array will only have 1 entry.
         * </p>
         *
         * @param clientId
         *              the ID of the client
         * @param reason
         *              the reason for the ban, can be null
         *
         * @return an array containing the IDs of the first and the second ban entry
         *
         * @querycommands 1
         * @see Client#getId()
         * @see #addBan(String, String, String, long, String)
         */
        public CommandFuture<int[]> banClient(int clientId, String reason) {
                return banClient(clientId, 0, reason);
        }

        /**
         * Sends a text message to all clients on all virtual servers.
         * These messages will appear to clients in the tab for server messages.
         *
         * @param message
         *              the message to be sent
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         */
        public CommandFuture<Boolean> broadcast(String message) {
                final CGM broadcast = new CGM(message);
                return executeAndReturnError(broadcast);
        }

        /**
         * Creates a copy of the channel group specified by {@code sourceGroupId},
         * overwriting any other channel group specified by {@code targetGroupId}.
         * <p>
         * The parameter {@code type} can be used to create server query and template groups.
         * </p>
         *
         * @param sourceGroupId
         *              the ID of the channel group to copy
         * @param targetGroupId
         *              the ID of another channel group to overwrite
         * @param type
         *              the desired type of channel group
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see ChannelGroup#getId()
         */
        public CommandFuture<Boolean> copyChannelGroup(int sourceGroupId, int targetGroupId, PermissionGroupDatabaseType type) {
                if (targetGroupId <= 0) {
                        throw new IllegalArgumentException("To create a new channel group, use the method with a String argument");
                }

                final CChannelGroupCopy copy = new CChannelGroupCopy(sourceGroupId, targetGroupId, type);
                return executeAndReturnError(copy);
        }

        /**
         * Creates a copy of the channel group specified by {@code sourceGroupId} with a given name
         * and returns the ID of the newly created channel group.
         *
         * @param sourceGroupId
         *              the ID of the channel group to copy
         * @param targetName
         *              the name for the copy of the channel group
         * @param type
         *              the desired type of channel group
         *
         * @return the ID of the newly created channel group
         *
         * @querycommands 1
         * @see ChannelGroup#getId()
         */
        public CommandFuture<Integer> copyChannelGroup(int sourceGroupId, String targetName, PermissionGroupDatabaseType type) {
                final CChannelGroupCopy copy = new CChannelGroupCopy(sourceGroupId, targetName, type);
                return executeAndReturnIntProperty(copy, "cgid");
        }

        /**
         * Creates a copy of the server group specified by {@code sourceGroupId},
         * overwriting another server group specified by {@code targetGroupId}.
         * <p>
         * The parameter {@code type} can be used to create server query and template groups.
         * </p>
         *
         * @param sourceGroupId
         *              the ID of the server group to copy
         * @param targetGroupId
         *              the ID of another server group to overwrite
         * @param type
         *              the desired type of server group
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see ServerGroup#getId()
         */
        public CommandFuture<Integer> copyServerGroup(int sourceGroupId, int targetGroupId, PermissionGroupDatabaseType type) {
                if (targetGroupId <= 0) {
                        throw new IllegalArgumentException("To create a new server group, use the method with a String argument");
                }

                final CServerGroupCopy copy = new CServerGroupCopy(sourceGroupId, targetGroupId, type);
                return executeAndReturnIntProperty(copy, "sgid");
        }

        /**
         * Creates a copy of the server group specified by {@code sourceGroupId} with a given name
         * and returns the ID of the newly created server group.
         *
         * @param sourceGroupId
         *              the ID of the server group to copy
         * @param targetName
         *              the name for the copy of the server group
         * @param type
         *              the desired type of server group
         *
         * @return the ID of the newly created server group
         *
         * @querycommands 1
         * @see ServerGroup#getId()
         */
        public CommandFuture<Integer> copyServerGroup(int sourceGroupId, String targetName, PermissionGroupDatabaseType type) {
                final CServerGroupCopy copy = new CServerGroupCopy(sourceGroupId, targetName, type);
                return executeAndReturnIntProperty(copy, "sgid");
        }

        /**
         * Creates a new channel with a given name using the given properties and returns its ID.
         *
         * @param name
         *              the name for the new channel
         * @param options
         *              a map of options that should be set for the channel
         *
         * @return the ID of the newly created channel
         *
         * @querycommands 1
         * @see Channel
         */
        public CommandFuture<Integer> createChannel(String name, Map<ChannelProperty, String> options) {
                final CChannelCreate create = new CChannelCreate(name, options);
                return executeAndReturnIntProperty(create, "cid");
        }

        /**
         * Creates a new virtual server with the given name and returns an object containing the ID of the newly
         * created virtual server, the default server admin token and the virtual server's voice port. Usually,
         * the virtual server is also automatically started. This can be turned off on the TS3 server, though.
         * <p>
         * If {@link VirtualServerProperty#VIRTUALSERVER_PORT} is not specified in the virtual server properties,
         * the server will test for the first unused UDP port.
         * </p><p>
         * Please also note that creating virtual servers usually requires the server query admin account
         * and that there is a limit to how many virtual servers can be created, which is dependent on your license.
         * Unlicensed TS3 server instances are limited to 1 virtual server with up to 32 client slots.
         * </p>
         *
         * @param name
         *              the name for the new virtual server
         * @param options
         *              a map of options that should be set for the virtual server
         *
         * @return information about the newly created virtual server
         *
         * @querycommands 1
         * @see VirtualServer
         */
        public CommandFuture<CreatedVirtualServer> createServer(String name, Map<VirtualServerProperty, String> options) {
                final CServerCreate create = new CServerCreate(name, options);
                final CommandFuture<CreatedVirtualServer> future = new CommandFuture<>();

                query.doCommandAsync(create, new Callback() {
                        @Override
                        public void handle() {
                                if (hasFailed(create, future)) return;
                                future.set(new CreatedVirtualServer(create.getFirstResponse().getMap()));
                        }
                });
                return future;
        }

        /**
         * Creates a {@link Snapshot} of the selected virtual server containing all settings,
         * groups and known client identities. The data from a server snapshot can be
         * used to restore a virtual servers configuration.
         *
         * @return a snapshot of the virtual server
         *
         * @querycommands 1
         * @see #deployServerSnapshot(Snapshot)
         */
        public CommandFuture<Snapshot> createServerSnapshot() {
                final CServerSnapshotCreate create = new CServerSnapshotCreate();
                final CommandFuture<Snapshot> future = new CommandFuture<>();

                query.doCommandAsync(create, new Callback() {
                        @Override
                        public void handle() {
                                if (hasFailed(create, future)) return;
                                future.set(new Snapshot(create.getRaw()));
                        }
                });
                return future;
        }

        /**
         * Deletes all active ban rules from the server. Use with caution.
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         */
        public CommandFuture<Boolean> deleteAllBans() {
                final CBanDelAll del = new CBanDelAll();
                return executeAndReturnError(del);
        }

        /**
         * Deletes all complaints about the client with specified database ID from the server.
         *
         * @param clientDBId
         *              the database ID of the client
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see Client#getDatabaseId()
         * @see Complaint
         */
        public CommandFuture<Boolean> deleteAllComplaints(int clientDBId) {
                final CComplainDelAll del = new CComplainDelAll(clientDBId);
                return executeAndReturnError(del);
        }

        /**
         * Deletes the ban rule with the specified ID from the server.
         *
         * @param banId
         *              the ID of the ban to delete
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see Ban#getId()
         */
        public CommandFuture<Boolean> deleteBan(int banId) {
                final CBanDel del = new CBanDel(banId);
                return executeAndReturnError(del);
        }

        /**
         * Deletes an existing channel specified by its ID, kicking all clients out of the channel.
         *
         * @param channelId
         *              the ID of the channel to delete
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see Channel#getId()
         * @see #deleteChannel(int, boolean)
         * @see #kickClientFromChannel(String, int...)
         */
        public CommandFuture<Boolean> deleteChannel(int channelId) {
                return deleteChannel(channelId, true);
        }

        /**
         * Deletes an existing channel with a given ID.
         * If {@code force} is true, the channel will be deleted even if there are clients within,
         * else the command will fail in this situation.
         *
         * @param channelId
         *              the ID of the channel to delete
         * @param force
         *              whether clients should be kicked out of the channel
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see Channel#getId()
         * @see #kickClientFromChannel(String, int...)
         */
        public CommandFuture<Boolean> deleteChannel(int channelId, boolean force) {
                final CChannelDelete del = new CChannelDelete(channelId, force);
                return executeAndReturnError(del);
        }

        /**
         * Removes a specified permission from a client in a specific channel.
         *
         * @param channelId
         *              the ID of the channel wherein the permission should be removed
         * @param clientDBId
         *              the database ID of the client
         * @param permName
         *              the name of the permission to revoke
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see Channel#getId()
         * @see Client#getDatabaseId()
         * @see Permission#getName()
         */
        public CommandFuture<Boolean> deleteChannelClientPermission(int channelId, int clientDBId, String permName) {
                final CChannelClientDelPerm del = new CChannelClientDelPerm(channelId, clientDBId, permName);
                return executeAndReturnError(del);
        }

        /**
         * Removes the channel group with the given ID.
         *
         * @param groupId
         *              the ID of the channel group
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see ChannelGroup#getId()
         */
        public CommandFuture<Boolean> deleteChannelGroup(int groupId) {
                return deleteChannelGroup(groupId, true);
        }

        /**
         * Removes the channel group with the given ID.
         * If {@code force} is true, the channel group will be deleted even if it still contains clients,
         * else the command will fail in this situation.
         *
         * @param groupId
         *              the ID of the channel group
         * @param force
         *              whether the channel group should be deleted even if it still contains clients
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see ChannelGroup#getId()
         */
        public CommandFuture<Boolean> deleteChannelGroup(int groupId, boolean force) {
                final CChannelGroupDel del = new CChannelGroupDel(groupId, force);
                return executeAndReturnError(del);
        }

        /**
         * Removes a permission from the channel group with the given ID.
         *
         * @param groupId
         *              the ID of the channel group
         * @param permName
         *              the name of the permission to revoke
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see ChannelGroup#getId()
         * @see Permission#getName()
         */
        public CommandFuture<Boolean> deleteChannelGroupPermission(int groupId, String permName) {
                final CChannelGroupDelPerm del = new CChannelGroupDelPerm(groupId, permName);
                return executeAndReturnError(del);
        }

        /**
         * Removes a permission from the channel with the given ID.
         *
         * @param channelId
         *              the ID of the channel
         * @param permName
         *              the name of the permission to revoke
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see Channel#getId()
         * @see Permission#getName()
         */
        public CommandFuture<Boolean> deleteChannelPermission(int channelId, String permName) {
                final CChannelDelPerm del = new CChannelDelPerm(channelId, permName);
                return executeAndReturnError(del);
        }

        /**
         * Removes a permission from a client.
         *
         * @param clientDBId
         *              the database ID of the client
         * @param permName
         *              the name of the permission to revoke
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see Client#getDatabaseId()
         * @see Permission#getName()
         */
        public CommandFuture<Boolean> deleteClientPermission(int clientDBId, String permName) {
                final CClientDelPerm del = new CClientDelPerm(clientDBId, permName);
                return executeAndReturnError(del);
        }

        /**
         * Deletes the complaint about the client with database ID {@code targetClientDBId} submitted by
         * the client with database ID {@code fromClientDBId} from the server.
         *
         * @param targetClientDBId
         *              the database ID of the client the complaint is about
         * @param fromClientDBId
         *              the database ID of the client who added the complaint
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see Complaint
         * @see Client#getDatabaseId()
         */
        public CommandFuture<Boolean> deleteComplaint(int targetClientDBId, int fromClientDBId) {
                final CComplainDel del = new CComplainDel(targetClientDBId, fromClientDBId);
                return executeAndReturnError(del);
        }

        /**
         * Removes all stored database information about the specified client.
         * Please note that this data is also automatically removed after a configured time (usually 90 days).
         * <p>
         * See {@link DatabaseClientInfo} for a list of stored information about a client.
         * </p>
         *
         * @param clientDBId
         *              the database ID of the client
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see Client#getDatabaseId()
         * @see #getDatabaseClientInfo(int)
         * @see DatabaseClientInfo
         */
        public CommandFuture<Boolean> deleteDatabaseClientProperties(int clientDBId) {
                final CClientDBDelete del = new CClientDBDelete(clientDBId);
                return executeAndReturnError(del);
        }

        /**
         * Deletes the offline message with the specified ID.
         *
         * @param messageId
         *              the ID of the offline message to delete
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see Message#getId()
         */
        public CommandFuture<Boolean> deleteOfflineMessage(int messageId) {
                final CMessageDel del = new CMessageDel(messageId);
                return executeAndReturnError(del);
        }

        /**
         * Removes a specified permission from all server groups of the type specified by {@code type} on all virtual servers.
         *
         * @param type
         *              the kind of server group this permission should be removed from
         * @param permName
         *              the name of the permission to remove
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see ServerGroupType
         * @see Permission#getName()
         */
        public CommandFuture<Boolean> deletePermissionFromAllServerGroups(ServerGroupType type, String permName) {
                final CServerGroupAutoDelPerm del = new CServerGroupAutoDelPerm(type, permName);
                return executeAndReturnError(del);
        }

        /**
         * Deletes the privilege key with the given token.
         *
         * @param token
         *              the token of the privilege key
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see PrivilegeKey
         */
        public CommandFuture<Boolean> deletePrivilegeKey(String token) {
                final CPrivilegeKeyDelete del = new CPrivilegeKeyDelete(token);
                return executeAndReturnError(del);
        }

        /**
         * Deletes the virtual server with the specified ID.
         * <p>
         * Only stopped virtual servers can be deleted.
         * </p>
         *
         * @param serverId
         *              the ID of the virtual server
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see VirtualServer#getId()
         * @see #stopServer(int)
         */
        public CommandFuture<Boolean> deleteServer(int serverId) {
                final CServerDelete delete = new CServerDelete(serverId);
                return executeAndReturnError(delete);
        }

        /**
         * Deletes the server group with the specified ID, even if the server group still contains clients.
         *
         * @param groupId
         *              the ID of the server group
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see ServerGroup#getId()
         */
        public CommandFuture<Boolean> deleteServerGroup(int groupId) {
                return deleteServerGroup(groupId, true);
        }

        /**
         * Deletes a server group with the specified ID.
         * <p>
         * If {@code force} is true, the server group will be deleted even if it contains clients,
         * else the command will fail in this situation.
         * </p>
         *
         * @param groupId
         *              the ID of the server group
         * @param force
         *              whether the server group should be deleted if it still contains clients
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see ServerGroup#getId()
         */
        public CommandFuture<Boolean> deleteServerGroup(int groupId, boolean force) {
                final CServerGroupDel del = new CServerGroupDel(groupId, force);
                return executeAndReturnError(del);
        }

        /**
         * Removes a permission from the server group with the given ID.
         *
         * @param groupId
         *              the ID of the server group
         * @param permName
         *              the name of the permission to revoke
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see ServerGroup#getId()
         * @see Permission#getName()
         */
        public CommandFuture<Boolean> deleteServerGroupPermission(int groupId, String permName) {
                final CServerGroupDelPerm del = new CServerGroupDelPerm(groupId, permName);
                return executeAndReturnError(del);
        }

        /**
         * Restores the selected virtual servers configuration using the data from a
         * previously created server snapshot.
         *
         * @param snapshot
         *              the snapshot to restore
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see #createServerSnapshot()
         */
        public CommandFuture<Boolean> deployServerSnapshot(Snapshot snapshot) {
                return deployServerSnapshot(snapshot.get());
        }

        /**
         * Restores the configuration of the selected virtual server using the data from a
         * previously created server snapshot.
         *
         * @param snapshot
         *              the snapshot to restore
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see #createServerSnapshot()
         */
        public CommandFuture<Boolean> deployServerSnapshot(String snapshot) {
                final CServerSnapshotDeploy deploy = new CServerSnapshotDeploy(snapshot);
                return executeAndReturnError(deploy);
        }

        /**
         * Changes a channel's configuration using the given properties.
         *
         * @param channelId
         *              the ID of the channel to edit
         * @param options
         *              the map of properties to modify
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see Channel#getId()
         */
        public CommandFuture<Boolean> editChannel(int channelId, Map<ChannelProperty, String> options) {
                final CChannelEdit edit = new CChannelEdit(channelId, options);
                return executeAndReturnError(edit);
        }

        /**
         * Changes a client's configuration using given properties.
         * <p>
         * Only {@link ClientProperty#CLIENT_DESCRIPTION} can be changed for other clients.
         * To update the current client's properties, use {@link #updateClient(Map)}.
         * </p>
         *
         * @param clientId
         *              the ID of the client to edit
         * @param options
         *              the map of properties to modify
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see Client#getId()
         * @see #updateClient(Map)
         */
        public CommandFuture<Boolean> editClient(int clientId, Map<ClientProperty, String> options) {
                final CClientEdit edit = new CClientEdit(clientId, options);
                return executeAndReturnError(edit);
        }

        /**
         * Changes a client's database settings using given properties.
         *
         * @param clientDBId
         *              the database ID of the client to edit
         * @param options
         *              the map of properties to modify
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see DatabaseClientInfo
         * @see Client#getDatabaseId()
         */
        public CommandFuture<Boolean> editDatabaseClient(int clientDBId, Map<ClientProperty, String> options) {
                final CClientDBEdit edit = new CClientDBEdit(clientDBId, options);
                return executeAndReturnError(edit);
        }

        /**
         * Changes the server instance configuration using given properties.
         * If the given property is not changeable, {@code IllegalArgumentException} will be thrown.
         *
         * @param property
         *              the property to edit, must be changeable
         * @param value
         *              the new value for the edit
         *
         * @return whether the command succeeded or not
         *
         * @throws IllegalArgumentException
         *              if {@code property} is not changeable
         * @querycommands 1
         * @see ServerInstanceProperty#isChangeable()
         */
        public CommandFuture<Boolean> editInstance(ServerInstanceProperty property, String value) {
                if (!property.isChangeable()) {
                        throw new IllegalArgumentException("Property is not changeable");
                }

                final CInstanceEdit edit = new CInstanceEdit(property, value);
                return executeAndReturnError(edit);
        }

        /**
         * Changes the configuration of the selected virtual server using given properties.
         *
         * @param options
         *              the map of properties to edit
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see VirtualServerProperty
         */
        public CommandFuture<Boolean> editServer(Map<VirtualServerProperty, String> options) {
                final CServerEdit edit = new CServerEdit(options);
                return executeAndReturnError(edit);
        }

        /**
         * Gets a list of all bans on the selected virtual server.
         *
         * @return a list of all bans on the virtual server
         *
         * @querycommands 1
         * @see Ban
         */
        public CommandFuture<List<Ban>> getBans() {
                final CBanList list = new CBanList();
                final CommandFuture<List<Ban>> future = new CommandFuture<>();

                query.doCommandAsync(list, new Callback() {
                        @Override
                        public void handle() {
                                if (hasFailed(list, future)) return;

                                final List<Wrapper> responses = list.getResponse();
                                final List<Ban> bans = new ArrayList<>(responses.size());

                                for (final Wrapper response : responses) {
                                        bans.add(new Ban(response.getMap()));
                                }
                                future.set(bans);
                        }
                });
                return future;
        }

        /**
         * Gets a list of IP addresses used by the server instance.
         *
         * @return the list of bound IP addresses
         *
         * @querycommands 1
         * @see Binding
         */
        public CommandFuture<List<Binding>> getBindings() {
                final CBindingList list = new CBindingList();
                final CommandFuture<List<Binding>> future = new CommandFuture<>();

                query.doCommandAsync(list, new Callback() {
                        @Override
                        public void handle() {
                                if (hasFailed(list, future)) return;

                                final List<Wrapper> responses = list.getResponse();
                                final List<Binding> bindings = new ArrayList<>(responses.size());

                                for (final Wrapper response : responses) {
                                        bindings.add(new Binding(response.getMap()));
                                }
                                future.set(bindings);
                        }
                });
                return future;
        }

        /**
         * Finds and returns the channel matching the given name exactly.
         *
         * @param name
         *              the name of the channel
         * @param ignoreCase
         *              whether the case of the name should be ignored
         *
         * @return the found channel or {@code null} if no channel was found
         *
         * @querycommands 1
         * @see Channel
         * @see #getChannelsByName(String)
         */
        public CommandFuture<Channel> getChannelByNameExact(String name, final boolean ignoreCase) {
                final CommandFuture<Channel> future = new CommandFuture<>();
                final String caseName = ignoreCase ? name.toLowerCase(Locale.ROOT) : name;

                getChannels().onSuccess(new CommandFuture.SuccessListener<List<Channel>>() {
                        @Override
                        public void handleSuccess(final List<Channel> allChannels) {
                                for (final Channel c : allChannels) {
                                        final String channelName = ignoreCase ? c.getName().toLowerCase(Locale.ROOT) : c.getName();
                                        if (caseName.equals(channelName)) {
                                                future.set(c);
                                                return;
                                        }
                                }
                                future.set(null); // Not found
                        }
                }).forwardFailure(future);
                return future;
        }

        /**
         * Gets a list of channels whose names contain the given search string.
         *
         * @param name
         *              the name to search
         *
         * @return a list of all channels with names matching the search pattern
         *
         * @querycommands 2
         * @see Channel
         * @see #getChannelByNameExact(String, boolean)
         */
        public CommandFuture<List<Channel>> getChannelsByName(String name) {
                final CChannelFind find = new CChannelFind(name);
                final CommandFuture<List<Channel>> future = new CommandFuture<>();

                getChannels().onSuccess(new CommandFuture.SuccessListener<List<Channel>>() {
                        @Override
                        public void handleSuccess(final List<Channel> allChannels) {
                                query.doCommandAsync(find, new Callback() {
                                        @Override
                                        public void handle() {
                                                if (hasFailed(find, future)) return;

                                                final List<Wrapper> responses = find.getResponse();
                                                final List<Channel> channels = new ArrayList<>(responses.size());

                                                for (final Wrapper response : responses) {
                                                        final int channelId = response.getInt("cid");
                                                        for (final Channel c : allChannels) {
                                                                if (c.getId() == channelId) {
                                                                        channels.add(c);
                                                                        break;
                                                                }
                                                        }
                                                }
                                                future.set(channels);
                                        }
                                });
                        }
                }).forwardFailure(future);
                return future;
        }

        /**
         * Displays a list of permissions defined for a client in a specific channel.
         *
         * @param channelId
         *              the ID of the channel
         * @param clientDBId
         *              the database ID of the client
         *
         * @return a list of permissions for the user in the specified channel
         *
         * @querycommands 1
         * @see Channel#getId()
         * @see Client#getDatabaseId()
         * @see Permission
         */
        public CommandFuture<List<Permission>> getChannelClientPermissions(int channelId, int clientDBId) {
                final CChannelClientPermList list = new CChannelClientPermList(channelId, clientDBId);
                final CommandFuture<List<Permission>> future = new CommandFuture<>();

                query.doCommandAsync(list, new Callback() {
                        @Override
                        public void handle() {
                                if (hasFailed(list, future)) return;

                                final List<Wrapper> responses = list.getResponse();
                                final List<Permission> permissions = new ArrayList<>(responses.size());

                                for (final Wrapper response : responses) {
                                        permissions.add(new Permission(response.getMap()));
                                }
                                future.set(permissions);
                        }
                });
                return future;
        }

        /**
         * Gets all client / channel ID combinations currently assigned to channel groups.
         * All three parameters are optional and can be turned off by setting it to {@code -1}.
         *
         * @param channelId
         *              restricts the search to the channel with a specified ID. Set to {@code -1} to ignore.
         * @param clientDBId
         *              restricts the search to the client with a specified database ID. Set to {@code -1} to ignore.
         * @param groupId
         *              restricts the search to the channel group with the specified ID. Set to {@code -1} to ignore.
         *
         * @return a list of combinations of channel ID, client database ID and channel group ID
         *
         * @querycommands 1
         * @see Channel#getId()
         * @see Client#getDatabaseId()
         * @see ChannelGroup#getId()
         * @see ChannelGroupClient
         */
        public CommandFuture<List<ChannelGroupClient>> getChannelGroupClients(int channelId, int clientDBId, int groupId) {
                final CChannelGroupClientList list = new CChannelGroupClientList(channelId, clientDBId, groupId);
                final CommandFuture<List<ChannelGroupClient>> future = new CommandFuture<>();

                query.doCommandAsync(list, new Callback() {
                        @Override
                        public void handle() {
                                if (hasFailed(list, future)) return;

                                final List<Wrapper> responses = list.getResponse();
                                final List<ChannelGroupClient> clients = new ArrayList<>(responses.size());

                                for (final Wrapper response : responses) {
                                        clients.add(new ChannelGroupClient(response.getMap()));
                                }
                                future.set(clients);
                        }
                });
                return future;
        }

        /**
         * Gets all client / channel ID combinations currently assigned to the specified channel group.
         *
         * @param groupId
         *              the ID of the channel group whose client / channel assignments should be returned.
         *
         * @return a list of combinations of channel ID, client database ID and channel group ID
         *
         * @querycommands 1
         * @see ChannelGroup#getId()
         * @see ChannelGroupClient
         * @see #getChannelGroupClients(int, int, int)
         */
        public CommandFuture<List<ChannelGroupClient>> getChannelGroupClientsByChannelGroupId(int groupId) {
                return getChannelGroupClients(-1, -1, groupId);
        }

        /**
         * Gets all channel group assignments in the specified channel.
         *
         * @param channelId
         *              the ID of the channel whose channel group assignments should be returned.
         *
         * @return a list of combinations of channel ID, client database ID and channel group ID
         *
         * @querycommands 1
         * @see Channel#getId()
         * @see ChannelGroupClient
         * @see #getChannelGroupClients(int, int, int)
         */
        public CommandFuture<List<ChannelGroupClient>> getChannelGroupClientsByChannelId(int channelId) {
                return getChannelGroupClients(channelId, -1, -1);
        }

        /**
         * Gets all channel group assignments for the specified client.
         *
         * @param clientDBId
         *              the database ID of the client whose channel group
         *
         * @return a list of combinations of channel ID, client database ID and channel group ID
         *
         * @querycommands 1
         * @see Client#getDatabaseId()
         * @see ChannelGroupClient
         * @see #getChannelGroupClients(int, int, int)
         */
        public CommandFuture<List<ChannelGroupClient>> getChannelGroupClientsByClientDBId(int clientDBId) {
                return getChannelGroupClients(-1, clientDBId, -1);
        }

        /**
         * Gets a list of all permissions assigned to the specified channel group.
         *
         * @param groupId
         *              the ID of the channel group.
         *
         * @return a list of permissions assigned to the channel group
         *
         * @querycommands 1
         * @see ChannelGroup#getId()
         * @see Permission
         */
        public CommandFuture<List<Permission>> getChannelGroupPermissions(int groupId) {
                final CChannelGroupPermList list = new CChannelGroupPermList(groupId);
                final CommandFuture<List<Permission>> future = new CommandFuture<>();

                query.doCommandAsync(list, new Callback() {
                        @Override
                        public void handle() {
                                if (hasFailed(list, future)) return;

                                final List<Wrapper> responses = list.getResponse();
                                final List<Permission> permissions = new ArrayList<>(responses.size());

                                for (final Wrapper response : responses) {
                                        permissions.add(new Permission(response.getMap()));
                                }
                                future.set(permissions);
                        }
                });
                return future;
        }

        /**
         * Gets a list of all channel groups on the selected virtual server.
         *
         * @return a list of all channel groups on the virtual server
         *
         * @querycommands 1
         * @see ChannelGroup
         */
        public CommandFuture<List<ChannelGroup>> getChannelGroups() {
                final CChannelGroupList list = new CChannelGroupList();
                final CommandFuture<List<ChannelGroup>> future = new CommandFuture<>();

                query.doCommandAsync(list, new Callback() {
                        @Override
                        public void handle() {
                                if (hasFailed(list, future)) return;

                                final List<Wrapper> responses = list.getResponse();
                                final List<ChannelGroup> groups = new ArrayList<>(responses.size());

                                for (final Wrapper response : responses) {
                                        groups.add(new ChannelGroup(response.getMap()));
                                }
                                future.set(groups);
                        }
                });
                return future;
        }

        /**
         * Gets detailed configuration information about the channel specified channel.
         *
         * @param channelId
         *              the ID of the channel
         *
         * @return information about the channel
         *
         * @querycommands 1
         * @see Channel#getId()
         * @see ChannelInfo
         */
        public CommandFuture<ChannelInfo> getChannelInfo(final int channelId) {
                final CChannelInfo info = new CChannelInfo(channelId);
                final CommandFuture<ChannelInfo> future = new CommandFuture<>();

                query.doCommandAsync(info, new Callback() {
                        @Override
                        public void handle() {
                                if (hasFailed(info, future)) return;
                                future.set(new ChannelInfo(channelId, info.getFirstResponse().getMap()));
                        }
                });
                return future;
        }

        /**
         * Gets a list of all permissions assigned to the specified channel.
         *
         * @param channelId
         *              the ID of the channel
         *
         * @return a list of all permissions assigned to the channel
         *
         * @querycommands 1
         * @see Channel#getId()
         * @see Permission
         */
        public CommandFuture<List<Permission>> getChannelPermissions(int channelId) {
                final CChannelPermList list = new CChannelPermList(channelId);
                final CommandFuture<List<Permission>> future = new CommandFuture<>();

                query.doCommandAsync(list, new Callback() {
                        @Override
                        public void handle() {
                                if (hasFailed(list, future)) return;

                                final List<Wrapper> responses = list.getResponse();
                                final List<Permission> permissions = new ArrayList<>(responses.size());

                                for (final Wrapper response : responses) {
                                        permissions.add(new Permission(response.getMap()));
                                }
                                future.set(permissions);
                        }
                });
                return future;
        }

        /**
         * Gets a list of all channels on the selected virtual server.
         *
         * @return a list of all channels on the virtual server
         *
         * @querycommands 1
         * @see Channel
         */
        public CommandFuture<List<Channel>> getChannels() {
                final CChannelList list = new CChannelList();
                final CommandFuture<List<Channel>> future = new CommandFuture<>();

                query.doCommandAsync(list, new Callback() {
                        @Override
                        public void handle() {
                                if (hasFailed(list, future)) return;

                                final List<Wrapper> responses = list.getResponse();
                                final List<Channel> channels = new ArrayList<>(responses.size());

                                for (final Wrapper response : responses) {
                                        channels.add(new Channel(response.getMap()));
                                }
                                future.set(channels);
                        }
                });
                return future;
        }

        /**
         * Finds and returns the client whose nickname matches the given name exactly.
         *
         * @param name
         *              the name of the client
         * @param ignoreCase
         *              whether the case of the name should be ignored
         *
         * @return the found client or {@code null} if no client was found
         *
         * @querycommands 1
         * @see Client
         * @see #getClientsByName(String)
         */
        public CommandFuture<Client> getClientByNameExact(String name, final boolean ignoreCase) {
                final CommandFuture<Client> future = new CommandFuture<>();
                final String caseName = ignoreCase ? name.toLowerCase(Locale.ROOT) : name;

                getClients().onSuccess(new CommandFuture.SuccessListener<List<Client>>() {
                        @Override
                        public void handleSuccess(final List<Client> allClients) {
                                for (final Client c : allClients) {
                                        final String clientName = ignoreCase ? c.getNickname().toLowerCase(Locale.ROOT) : c.getNickname();
                                        if (caseName.equals(clientName)) {
                                                future.set(c);
                                                return;
                                        }
                                }
                                future.set(null); // Not found
                        }
                }).forwardFailure(future);
                return future;
        }

        /**
         * Gets a list of clients whose nicknames contain the given search string.
         *
         * @param name
         *              the name to search
         *
         * @return a list of all clients with nicknames matching the search pattern
         *
         * @querycommands 2
         * @see Client
         * @see #getClientByNameExact(String, boolean)
         */
        public CommandFuture<List<Client>> getClientsByName(String name) {
                final CClientFind find = new CClientFind(name);
                final CommandFuture<List<Client>> future = new CommandFuture<>();

                getClients().onSuccess(new CommandFuture.SuccessListener<List<Client>>() {
                        @Override
                        public void handleSuccess(final List<Client> allClients) {
                                query.doCommandAsync(find, new Callback() {
                                        @Override
                                        public void handle() {
                                                if (hasFailed(find, future)) return;

                                                final List<Wrapper> responses = find.getResponse();
                                                final List<Client> clients = new ArrayList<>(responses.size());

                                                for (final Wrapper response : responses) {
                                                        for (final Client c : allClients) {
                                                                if (c.getId() == response.getInt("clid")) {
                                                                        clients.add(c);
                                                                        break;
                                                                }
                                                        }
                                                }
                                                future.set(clients);
                                        }
                                });
                        }
                }).forwardFailure(future);
                return future;
        }

        /**
         * Gets information about the client with the specified unique identifier.
         *
         * @param clientUId
         *              the unique identifier of the client
         *
         * @return the client or {@code null} if no client was found
         *
         * @querycommands 2
         * @see Client#getUniqueIdentifier()
         * @see ClientInfo
         */
        public CommandFuture<ClientInfo> getClientByUId(String clientUId) {
                final CClientGetIds get = new CClientGetIds(clientUId);
                final CommandFuture<ClientInfo> future = new CommandFuture<>();

                query.doCommandAsync(get, new Callback() {
                        @Override
                        public void handle() {
                                if (hasFailed(get, future)) return;

                                getClientInfo(get.getFirstResponse().getInt("clid")).forwardResult(future);
                        }
                });
                return future;
        }

        /**
         * Gets information about the client with the specified client ID.
         *
         * @param clientId
         *              the client ID of the client
         *
         * @return the client or {@code null} if no client was found
         *
         * @querycommands 1
         * @see Client#getId()
         * @see ClientInfo
         */
        public CommandFuture<ClientInfo> getClientInfo(final int clientId) {
                final CClientInfo info = new CClientInfo(clientId);
                final CommandFuture<ClientInfo> future = new CommandFuture<>();

                query.doCommandAsync(info, new Callback() {
                        @Override
                        public void handle() {
                                if (hasFailed(info, future)) return;
                                future.set(new ClientInfo(clientId, info.getFirstResponse().getMap()));
                        }
                });
                return future;
        }

        /**
         * Gets a list of all permissions assigned to the specified client.
         *
         * @param clientDBId
         *              the database ID of the client
         *
         * @return a list of all permissions assigned to the client
         *
         * @querycommands 1
         * @see Client#getDatabaseId()
         * @see Permission
         */
        public CommandFuture<List<Permission>> getClientPermissions(int clientDBId) {
                final CClientPermList list = new CClientPermList(clientDBId);
                final CommandFuture<List<Permission>> future = new CommandFuture<>();

                query.doCommandAsync(list, new Callback() {
                        @Override
                        public void handle() {
                                if (hasFailed(list, future)) return;

                                final List<Wrapper> responses = list.getResponse();
                                final List<Permission> permissions = new ArrayList<>(responses.size());

                                for (final Wrapper response : responses) {
                                        permissions.add(new Permission(response.getMap()));
                                }
                                future.set(permissions);
                        }
                });
                return future;
        }

        /**
         * Gets a list of all clients on the selected virtual server.
         *
         * @return a list of all clients on the virtual server
         *
         * @querycommands 1
         * @see Client
         */
        public CommandFuture<List<Client>> getClients() {
                final CClientList list = new CClientList();
                final CommandFuture<List<Client>> future = new CommandFuture<>();

                query.doCommandAsync(list, new Callback() {
                        @Override
                        public void handle() {
                                if (hasFailed(list, future)) return;

                                final List<Wrapper> responses = list.getResponse();
                                final List<Client> clients = new ArrayList<>(responses.size());

                                for (final Wrapper response : responses) {
                                        clients.add(new Client(response.getMap()));
                                }
                                future.set(clients);
                        }
                });
                return future;
        }

        /**
         * Gets a list of all complaints on the selected virtual server.
         *
         * @return a list of all complaints on the virtual server
         *
         * @querycommands 1
         * @see Complaint
         * @see #getComplaints(int)
         */
        public CommandFuture<List<Complaint>> getComplaints() {
                return getComplaints(-1);
        }

        /**
         * Gets a list of all complaints about the specified client.
         *
         * @param clientDBId
         *              the database ID of the client
         *
         * @return a list of all complaints about the specified client
         *
         * @querycommands 1
         * @see Client#getDatabaseId()
         * @see Complaint
         */
        public CommandFuture<List<Complaint>> getComplaints(int clientDBId) {
                final CComplainList list = new CComplainList(clientDBId);
                final CommandFuture<List<Complaint>> future = new CommandFuture<>();

                query.doCommandAsync(list, new Callback() {
                        @Override
                        public void handle() {
                                if (hasFailed(list, future)) return;

                                final List<Wrapper> responses = list.getResponse();
                                final List<Complaint> complaints = new ArrayList<>(responses.size());

                                for (final Wrapper response : responses) {
                                        complaints.add(new Complaint(response.getMap()));
                                }
                                future.set(complaints);
                        }
                });
                return future;
        }

        /**
         * Gets detailed connection information about the selected virtual server.
         *
         * @return connection information about the selected virtual server
         *
         * @querycommands 1
         * @see ConnectionInfo
         * @see #getServerInfo()
         */
        public CommandFuture<ConnectionInfo> getConnectionInfo() {
                final CServerRequestConnectionInfo info = new CServerRequestConnectionInfo();
                final CommandFuture<ConnectionInfo> future = new CommandFuture<>();

                query.doCommandAsync(info, new Callback() {
                        @Override
                        public void handle() {
                                if (hasFailed(info, future)) return;
                                future.set(new ConnectionInfo(info.getFirstResponse().getMap()));
                        }
                });
                return future;
        }

        /**
         * Gets all clients in the database whose last nickname matches the specified name <b>exactly</b>.
         *
         * @param name
         *              the nickname for the clients to match
         *
         * @return a list of all clients with a matching nickname
         *
         * @querycommands 1 + n,
         * where n is the amount of database clients with a matching nickname
         * @see Client#getNickname()
         */
        public CommandFuture<List<DatabaseClientInfo>> getDatabaseClientsByName(String name) {
                final CClientDBFind find = new CClientDBFind(name, false);
                final CommandFuture<List<DatabaseClientInfo>> future = new CommandFuture<>();

                query.doCommandAsync(find, new Callback() {
                        @Override
                        public void handle() {
                                if (hasFailed(find, future)) return;

                                final List<Wrapper> responses = find.getResponse();
                                final Collection<CommandFuture<DatabaseClientInfo>> infoFutures = new ArrayList<>(responses.size());
                                for (Wrapper response : responses) {
                                        final int databaseId = response.getInt("cldbid");
                                        infoFutures.add(getDatabaseClientInfo(databaseId));
                                }

                                CommandFuture.ofAll(infoFutures).forwardResult(future);
                        }
                });
                return future;
        }

        /**
         * Gets information about the client with the specified unique identifier in the server database.
         *
         * @param clientUId
         *              the unique identifier of the client
         *
         * @return the database client or {@code null} if no client was found
         *
         * @querycommands 2
         * @see Client#getUniqueIdentifier()
         * @see DatabaseClientInfo
         */
        public CommandFuture<DatabaseClientInfo> getDatabaseClientByUId(String clientUId) {
                final CClientGetDBIdFromUId get = new CClientGetDBIdFromUId(clientUId);
                final CommandFuture<DatabaseClientInfo> future = new CommandFuture<>();

                query.doCommandAsync(get, new Callback() {
                        @Override
                        public void handle() {
                                if (hasFailed(get, future)) return;

                                getDatabaseClientInfo(get.getFirstResponse().getInt("cldbid")).forwardResult(future);
                        }
                });
                return future;
        }

        /**
         * Gets information about the client with the specified database ID in the server database.
         *
         * @param clientDBId
         *              the database ID of the client
         *
         * @return the database client or {@code null} if no client was found
         *
         * @querycommands 1
         * @see Client#getDatabaseId()
         * @see DatabaseClientInfo
         */
        public CommandFuture<DatabaseClientInfo> getDatabaseClientInfo(int clientDBId) {
                final CClientDBInfo info = new CClientDBInfo(clientDBId);
                final CommandFuture<DatabaseClientInfo> future = new CommandFuture<>();

                query.doCommandAsync(info, new Callback() {
                        @Override
                        public void handle() {
                                if (hasFailed(info, future)) return;
                                future.set(new DatabaseClientInfo(info.getFirstResponse().getMap()));
                        }
                });
                return future;
        }

        /**
         * Gets information about all clients in the server database.
         * <p>
         * As this method uses internal commands which can only return 200 clients at once,
         * this method can take quite some time to execute.
         * </p><p>
         * Also keep in mind that the client database can easily accumulate several thousand entries.
         * </p>
         *
         * @return a {@link List} of all database clients
         *
         * @querycommands 1 + n,
         * where n = Math.ceil([amount of database clients] / 200)
         * @see DatabaseClient
         */
        public CommandFuture<List<DatabaseClient>> getDatabaseClients() {
                final CClientDBList countList = new CClientDBList(0, 1, true);
                final CommandFuture<List<DatabaseClient>> future = new CommandFuture<>();

                query.doCommandAsync(countList, new Callback() {
                        @Override
                        public void handle() {
                                if (hasFailed(countList, future)) return;

                                final int count = countList.getFirstResponse().getInt("count");
                                final int futuresCount = ((count - 1) / 200) + 1;
                                final Collection<CommandFuture<List<DatabaseClient>>> futures = new ArrayList<>(futuresCount);
                                for (int i = 0; i < count; i += 200) {
                                        futures.add(getDatabaseClients(i, 200));
                                }

                                CommandFuture.ofAll(futures).onSuccess(new CommandFuture.SuccessListener<List<List<DatabaseClient>>>() {
                                        @Override
                                        public void handleSuccess(List<List<DatabaseClient>> result) {
                                                int total = 0;
                                                for (List<DatabaseClient> list : result) {
                                                        total += list.size();
                                                }

                                                final List<DatabaseClient> combination = new ArrayList<>(total);
                                                for (List<DatabaseClient> list : result) {
                                                        combination.addAll(list);
                                                }
                                                future.set(combination);
                                        }
                                }).forwardFailure(future);
                        }
                });
                return future;
        }

        /**
         * Gets information about a set number of clients in the server database, starting at {@code offset}.
         *
         * @param offset
         *              the index of the first database client to be returned.
         *              Note that this is <b>not</b> a database ID, but an arbitrary, 0-based index.
         * @param count
         *              the number of database clients that should be returned.
         *              Any integer greater than 200 might cause problems with the connection
         *
         * @return a {@link List} of database clients
         *
         * @querycommands 1
         * @see DatabaseClient
         */
        public CommandFuture<List<DatabaseClient>> getDatabaseClients(final int offset, final int count) {
                final CClientDBList list = new CClientDBList(offset, count, false);
                final CommandFuture<List<DatabaseClient>> future = new CommandFuture<>();

                query.doCommandAsync(list, new Callback() {
                        @Override
                        public void handle() {
                                if (hasFailed(list, future)) return;

                                final List<DatabaseClient> clients = new ArrayList<>(count);
                                for (final Wrapper response : list.getResponse()) {
                                        clients.add(new DatabaseClient(response.getMap()));
                                }
                                future.set(clients);
                        }
                });
                return future;
        }

        /**
         * Displays detailed configuration information about the server instance including
         * uptime, number of virtual servers online, traffic information, etc.
         *
         * @return information about the host
         *
         * @querycommands 1
         */
        public CommandFuture<HostInfo> getHostInfo() {
                final CHostInfo info = new CHostInfo();
                final CommandFuture<HostInfo> future = new CommandFuture<>();

                query.doCommandAsync(info, new Callback() {
                        @Override
                        public void handle() {
                                if (hasFailed(info, future)) return;
                                future.set(new HostInfo(info.getFirstResponse().getMap()));
                        }
                });
                return future;
        }

        /**
         * Displays the server instance configuration including database revision number,
         * the file transfer port, default group IDs, etc.
         *
         * @return information about the TeamSpeak server instance.
         *
         * @querycommands 1
         */
        public CommandFuture<InstanceInfo> getInstanceInfo() {
                final CInstanceInfo info = new CInstanceInfo();
                final CommandFuture<InstanceInfo> future = new CommandFuture<>();

                query.doCommandAsync(info, new Callback() {
                        @Override
                        public void handle() {
                                if (hasFailed(info, future)) return;
                                future.set(new InstanceInfo(info.getFirstResponse().getMap()));
                        }
                });
                return future;
        }

        /**
         * Reads the message body of a message. This will not set the read flag, though.
         *
         * @param messageId
         *              the ID of the message to be read
         *
         * @return the body of the message with the specified ID or {@code null} if there was no message with that ID
         *
         * @querycommands 1
         * @see Message#getId()
         * @see #setMessageRead(int)
         */
        public CommandFuture<String> getOfflineMessage(int messageId) {
                final CMessageGet get = new CMessageGet(messageId);
                return executeAndReturnStringProperty(get, "message");
        }

        /**
         * Reads the message body of a message. This will not set the read flag, though.
         *
         * @param message
         *              the message to be read
         *
         * @return the body of the message with the specified ID or {@code null} if there was no message with that ID
         *
         * @querycommands 1
         * @see Message#getId()
         * @see #setMessageRead(Message)
         */
        public CommandFuture<String> getOfflineMessage(Message message) {
                return getOfflineMessage(message.getId());
        }

        /**
         * Gets a list of all offline messages for the server query.
         * The returned messages lack their message body, though.
         * To read the actual message, use {@link #getOfflineMessage(int)} or {@link #getOfflineMessage(Message)}.
         *
         * @return a list of all offline messages this server query has received
         *
         * @querycommands 1
         */
        public CommandFuture<List<Message>> getOfflineMessages() {
                final CMessageList list = new CMessageList();
                final CommandFuture<List<Message>> future = new CommandFuture<>();

                query.doCommandAsync(list, new Callback() {
                        @Override
                        public void handle() {
                                if (hasFailed(list, future)) return;

                                final List<Wrapper> responses = list.getResponse();
                                final List<Message> msg = new ArrayList<>(responses.size());

                                for (final Wrapper response : responses) {
                                        msg.add(new Message(response.getMap()));
                                }
                                future.set(msg);
                        }
                });
                return future;
        }

        /**
         * Displays detailed information about all assignments of the permission specified
         * with {@code permName}. The output includes the type and the ID of the client,
         * channel or group associated with the permission.
         *
         * @param permName
         *              the name of the permission
         *
         * @return a list of permission assignments
         *
         * @querycommands 1
         * @see #getPermissionOverview(int, int)
         */
        public CommandFuture<List<PermissionAssignment>> getPermissionAssignments(String permName) {
                final CPermFind find = new CPermFind(permName);
                final CommandFuture<List<PermissionAssignment>> future = new CommandFuture<>();

                query.doCommandAsync(find, new Callback() {
                        @Override
                        public void handle() {
                                if (hasFailed(find, future)) return;

                                final List<Wrapper> responses = find.getResponse();
                                final List<PermissionAssignment> assignments = new ArrayList<>(responses.size());

                                for (final Wrapper response : responses) {
                                        assignments.add(new PermissionAssignment(response.getMap()));
                                }
                                future.set(assignments);
                        }
                });
                return future;
        }

        /**
         * Gets the ID of the permission specified by {@code permName}.
         * <p>
         * Note that the use of numeric permission IDs is deprecated
         * and that this API only uses the string variant of the IDs.
         * </p>
         *
         * @param permName
         *              the name of the permission
         *
         * @return the numeric ID of the specified permission
         *
         * @querycommands 1
         */
        public CommandFuture<Integer> getPermissionIdByName(String permName) {
                final CPermIdGetByName get = new CPermIdGetByName(permName);
                return executeAndReturnIntProperty(get, "permid");
        }

        /**
         * Gets a list of all assigned permissions for a client in a specified channel.
         * If you do not care about channel permissions, set {@code channelId} to {@code -1}.
         *
         * @param channelId
         *              the ID of the channel
         * @param clientDBId
         *              the database ID of the client to create the overview for
         *
         * @return a list of all permission assignments for the client in the specified channel
         *
         * @querycommands 1
         * @see Channel#getId()
         * @see Client#getDatabaseId()
         */
        public CommandFuture<List<PermissionAssignment>> getPermissionOverview(int channelId, int clientDBId) {
                final CPermOverview overview = new CPermOverview(channelId, clientDBId);
                final CommandFuture<List<PermissionAssignment>> future = new CommandFuture<>();

                query.doCommandAsync(overview, new Callback() {
                        @Override
                        public void handle() {
                                if (hasFailed(overview, future)) return;

                                final List<Wrapper> responses = overview.getResponse();
                                final List<PermissionAssignment> permissions = new ArrayList<>(responses.size());

                                for (final Wrapper response : responses) {
                                        permissions.add(new PermissionAssignment(response.getMap()));
                                }
                                future.set(permissions);
                        }
                });
                return future;
        }

        /**
         * Displays a list of all permissions, including ID, name and description.
         *
         * @return a list of all permissions
         *
         * @querycommands 1
         */
        public CommandFuture<List<PermissionInfo>> getPermissions() {
                final CPermissionList list = new CPermissionList();
                final CommandFuture<List<PermissionInfo>> future = new CommandFuture<>();

                query.doCommandAsync(list, new Callback() {
                        @Override
                        public void handle() {
                                if (hasFailed(list, future)) return;

                                final List<Wrapper> responses = list.getResponse();
                                final List<PermissionInfo> permissions = new ArrayList<>(responses.size());

                                for (final Wrapper response : responses) {
                                        permissions.add(new PermissionInfo(response.getMap()));
                                }
                                future.set(permissions);
                        }
                });
                return future;
        }

        /**
         * Displays the current value of the specified permission for this server query instance.
         *
         * @param permName
         *              the name of the permission
         *
         * @return the permission value, usually ranging from 0 to 100
         *
         * @querycommands 1
         */
        public CommandFuture<Integer> getPermissionValue(String permName) {
                final CPermGet get = new CPermGet(permName);
                return executeAndReturnIntProperty(get, "permvalue");
        }

        /**
         * Gets a list of all available tokens to join channel or server groups,
         * including their type and group IDs.
         *
         * @return a list of all generated, but still unclaimed privilege keys
         *
         * @querycommands 1
         * @see #addPrivilegeKey(PrivilegeKeyType, int, int, String)
         * @see #usePrivilegeKey(String)
         */
        public CommandFuture<List<PrivilegeKey>> getPrivilegeKeys() {
                final CPrivilegeKeyList list = new CPrivilegeKeyList();
                final CommandFuture<List<PrivilegeKey>> future = new CommandFuture<>();

                query.doCommandAsync(list, new Callback() {
                        @Override
                        public void handle() {
                                if (hasFailed(list, future)) return;

                                final List<Wrapper> responses = list.getResponse();
                                final List<PrivilegeKey> keys = new ArrayList<>(responses.size());

                                for (final Wrapper response : responses) {
                                        keys.add(new PrivilegeKey(response.getMap()));
                                }
                                future.set(keys);
                        }
                });
                return future;
        }

        /**
         * Gets a list of all clients in the specified server group.
         *
         * @param serverGroupId
         *              the ID of the server group for which the clients should be looked up
         *
         * @return a list of all clients in the server group
         *
         * @querycommands 1
         */
        public CommandFuture<List<ServerGroupClient>> getServerGroupClients(int serverGroupId) {
                final CServerGroupClientList list = new CServerGroupClientList(serverGroupId);
                final CommandFuture<List<ServerGroupClient>> future = new CommandFuture<>();

                query.doCommandAsync(list, new Callback() {
                        @Override
                        public void handle() {
                                if (hasFailed(list, future)) return;

                                final List<Wrapper> responses = list.getResponse();
                                final List<ServerGroupClient> clients = new ArrayList<>(responses.size());

                                for (final Wrapper response : responses) {
                                        clients.add(new ServerGroupClient(response.getMap()));
                                }
                                future.set(clients);
                        }
                });
                return future;
        }

        /**
         * Gets a list of all clients in the specified server group.
         *
         * @param serverGroup
         *              the server group for which the clients should be looked up
         *
         * @return a list of all clients in the server group
         *
         * @querycommands 1
         */
        public CommandFuture<List<ServerGroupClient>> getServerGroupClients(ServerGroup serverGroup) {
                return getServerGroupClients(serverGroup.getId());
        }

        /**
         * Gets a list of all permissions assigned to the specified server group.
         *
         * @param serverGroupId
         *              the ID of the server group for which the permissions should be looked up
         *
         * @return a list of all permissions assigned to the server group
         *
         * @querycommands 1
         * @see ServerGroup#getId()
         * @see #getServerGroupPermissions(ServerGroup)
         */
        public CommandFuture<List<Permission>> getServerGroupPermissions(int serverGroupId) {
                final CServerGroupPermList list = new CServerGroupPermList(serverGroupId);
                final CommandFuture<List<Permission>> future = new CommandFuture<>();

                query.doCommandAsync(list, new Callback() {
                        @Override
                        public void handle() {
                                if (hasFailed(list, future)) return;

                                final List<Wrapper> responses = list.getResponse();
                                final List<Permission> permissions = new ArrayList<>(responses.size());

                                for (final Wrapper response : responses) {
                                        permissions.add(new Permission(response.getMap()));
                                }
                                future.set(permissions);
                        }
                });
                return future;
        }

        /**
         * Gets a list of all permissions assigned to the specified server group.
         *
         * @param serverGroup
         *              the server group for which the permissions should be looked up
         *
         * @return a list of all permissions assigned to the server group
         *
         * @querycommands 1
         */
        public CommandFuture<List<Permission>> getServerGroupPermissions(ServerGroup serverGroup) {
                return getServerGroupPermissions(serverGroup.getId());
        }

        /**
         * Gets a list of all server groups on the virtual server.
         * <p>
         * Depending on your permissions, the output may also contain
         * global server query groups and template groups.
         * </p>
         *
         * @return a list of all server groups
         *
         * @querycommands 1
         */
        public CommandFuture<List<ServerGroup>> getServerGroups() {
                final CServerGroupList list = new CServerGroupList();
                final CommandFuture<List<ServerGroup>> future = new CommandFuture<>();

                query.doCommandAsync(list, new Callback() {
                        @Override
                        public void handle() {
                                if (hasFailed(list, future)) return;

                                final List<Wrapper> responses = list.getResponse();
                                final List<ServerGroup> groups = new ArrayList<>(responses.size());

                                for (final Wrapper response : responses) {
                                        groups.add(new ServerGroup(response.getMap()));
                                }
                                future.set(groups);
                        }
                });
                return future;
        }

        /**
         * Gets a list of all server groups set for a client.
         *
         * @param clientDatabaseId
         *              the database ID of the client for which the server groups should be looked up
         *
         * @return a list of all server groups set for the client
         *
         * @querycommands 2
         * @see Client#getDatabaseId()
         * @see #getServerGroupsByClient(Client)
         */
        public CommandFuture<List<ServerGroup>> getServerGroupsByClientId(int clientDatabaseId) {
                final CServerGroupsByClientId client = new CServerGroupsByClientId(clientDatabaseId);
                final CommandFuture<List<ServerGroup>> future = new CommandFuture<>();

                getServerGroups().onSuccess(new CommandFuture.SuccessListener<List<ServerGroup>>() {
                        @Override
                        public void handleSuccess(final List<ServerGroup> allServerGroups) {
                                query.doCommandAsync(client, new Callback() {
                                        @Override
                                        public void handle() {
                                                if (hasFailed(client, future)) return;

                                                final List<Wrapper> responses = client.getResponse();
                                                final List<ServerGroup> list = new ArrayList<>(responses.size());

                                                for (final Wrapper response : responses) {
                                                        for (final ServerGroup s : allServerGroups) {
                                                                if (s.getId() == response.getInt("sgid")) {
                                                                        list.add(s);
                                                                }
                                                        }
                                                }
                                                future.set(list);
                                        }
                                });
                        }
                }).forwardFailure(future);
                return future;
        }

        /**
         * Gets a list of all server groups set for a client.
         *
         * @param client
         *              the client for which the server groups should be looked up
         *
         * @return a list of all server group set for the client
         *
         * @querycommands 2
         * @see #getServerGroupsByClientId(int)
         */
        public CommandFuture<List<ServerGroup>> getServerGroupsByClient(Client client) {
                return getServerGroupsByClientId(client.getDatabaseId());
        }

        /**
         * Gets the ID of a virtual server by its port.
         *
         * @param port
         *              the port of a virtual server
         *
         * @return the ID of the virtual server
         *
         * @querycommands 1
         * @see VirtualServer#getPort()
         * @see VirtualServer#getId()
         */
        public CommandFuture<Integer> getServerIdByPort(int port) {
                final CServerIdGetByPort s = new CServerIdGetByPort(port);
                return executeAndReturnIntProperty(s, "server_id");
        }

        /**
         * Gets detailed information about the virtual server the server query is currently in.
         *
         * @return information about the current virtual server
         *
         * @querycommands 1
         */
        public CommandFuture<VirtualServerInfo> getServerInfo() {
                final CServerInfo info = new CServerInfo();
                final CommandFuture<VirtualServerInfo> future = new CommandFuture<>();

                query.doCommandAsync(info, new Callback() {
                        @Override
                        public void handle() {
                                if (hasFailed(info, future)) return;
                                future.set(new VirtualServerInfo(info.getFirstResponse().getMap()));
                        }
                });
                return future;
        }

        /**
         * Gets the version, build number and platform of the TeamSpeak3 server.
         *
         * @return the version information of the server
         *
         * @querycommands 1
         */
        public CommandFuture<Version> getVersion() {
                final CVersion version = new CVersion();
                final CommandFuture<Version> future = new CommandFuture<>();

                query.doCommandAsync(version, new Callback() {
                        @Override
                        public void handle() {
                                if (hasFailed(version, future)) return;
                                future.set(new Version(version.getFirstResponse().getMap()));
                        }
                });
                return future;
        }

        /**
         * Gets a list of all virtual servers including their ID, status, number of clients online, etc.
         *
         * @return a list of all virtual servers
         *
         * @querycommands 1
         */
        public CommandFuture<List<VirtualServer>> getVirtualServers() {
                final CServerList serverList = new CServerList();
                final CommandFuture<List<VirtualServer>> future = new CommandFuture<>();

                query.doCommandAsync(serverList, new Callback() {
                        @Override
                        public void handle() {
                                if (hasFailed(serverList, future)) return;

                                final List<Wrapper> responses = serverList.getResponse();
                                final List<VirtualServer> servers = new ArrayList<>(responses.size());

                                for (final Wrapper response : responses) {
                                        servers.add((new VirtualServer(response.getMap())));
                                }
                                future.set(servers);
                        }
                });
                return future;
        }

        /**
         * Kicks one or more clients from their current channels.
         * This will move the kicked clients into the default channel and
         * won't do anything if the clients are already in the default channel.
         *
         * @param clientIds
         *              the IDs of the clients to kick
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see #kickClientFromChannel(Client...)
         * @see #kickClientFromChannel(String, int...)
         */
        public CommandFuture<Boolean> kickClientFromChannel(int... clientIds) {
                return kickClients(ReasonIdentifier.REASON_KICK_CHANNEL, null, clientIds);
        }

        /**
         * Kicks one or more clients from their current channels.
         * This will move the kicked clients into the default channel and
         * won't do anything if the clients are already in the default channel.
         *
         * @param clients
         *              the clients to kick
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see #kickClientFromChannel(int...)
         * @see #kickClientFromChannel(String, Client...)
         */
        public CommandFuture<Boolean> kickClientFromChannel(Client... clients) {
                return kickClients(ReasonIdentifier.REASON_KICK_CHANNEL, null, clients);
        }

        /**
         * Kicks one or more clients from their current channels for the specified reason.
         * This will move the kicked clients into the default channel and
         * won't do anything if the clients are already in the default channel.
         *
         * @param message
         *              the reason message to display to the clients
         * @param clientIds
         *              the IDs of the clients to kick
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see Client#getId()
         * @see #kickClientFromChannel(int...)
         * @see #kickClientFromChannel(String, Client...)
         */
        public CommandFuture<Boolean> kickClientFromChannel(String message, int... clientIds) {
                return kickClients(ReasonIdentifier.REASON_KICK_CHANNEL, message, clientIds);
        }

        /**
         * Kicks one or more clients from their current channels for the specified reason.
         * This will move the kicked clients into the default channel and
         * won't do anything if the clients are already in the default channel.
         *
         * @param message
         *              the reason message to display to the clients
         * @param clients
         *              the clients to kick
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see #kickClientFromChannel(Client...)
         * @see #kickClientFromChannel(String, int...)
         */
        public CommandFuture<Boolean> kickClientFromChannel(String message, Client... clients) {
                return kickClients(ReasonIdentifier.REASON_KICK_CHANNEL, message, clients);
        }

        /**
         * Kicks one or more clients from the server.
         *
         * @param clientIds
         *              the IDs of the clients to kick
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see Client#getId()
         * @see #kickClientFromServer(Client...)
         * @see #kickClientFromServer(String, int...)
         */
        public CommandFuture<Boolean> kickClientFromServer(int... clientIds) {
                return kickClients(ReasonIdentifier.REASON_KICK_SERVER, null, clientIds);
        }

        /**
         * Kicks one or more clients from the server.
         *
         * @param clients
         *              the clients to kick
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see #kickClientFromServer(int...)
         * @see #kickClientFromServer(String, Client...)
         */
        public CommandFuture<Boolean> kickClientFromServer(Client... clients) {
                return kickClients(ReasonIdentifier.REASON_KICK_SERVER, null, clients);
        }

        /**
         * Kicks one or more clients from the server for the specified reason.
         *
         * @param message
         *              the reason message to display to the clients
         * @param clientIds
         *              the IDs of the clients to kick
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see Client#getId()
         * @see #kickClientFromServer(int...)
         * @see #kickClientFromServer(String, Client...)
         */
        public CommandFuture<Boolean> kickClientFromServer(String message, int... clientIds) {
                return kickClients(ReasonIdentifier.REASON_KICK_SERVER, message, clientIds);
        }

        /**
         * Kicks one or more clients from the server for the specified reason.
         *
         * @param message
         *              the reason message to display to the clients
         * @param clients
         *              the clients to kick
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see #kickClientFromServer(Client...)
         * @see #kickClientFromServer(String, int...)
         */
        public CommandFuture<Boolean> kickClientFromServer(String message, Client... clients) {
                return kickClients(ReasonIdentifier.REASON_KICK_SERVER, message, clients);
        }

        /**
         * Kicks a list of clients from either the channel or the server for a given reason.
         *
         * @param reason
         *              where to kick the clients from
         * @param message
         *              the reason message to display to the clients
         * @param clients
         *              the clients to kick
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         */
        private CommandFuture<Boolean> kickClients(ReasonIdentifier reason, String message, Client... clients) {
                int[] clientIds = new int[clients.length];
                for (int i = 0; i < clients.length; ++i) {
                        clientIds[i] = clients[i].getId();
                }
                return kickClients(reason, message, clientIds);
        }

        /**
         * Kicks a list of clients from either the channel or the server for a given reason.
         *
         * @param reason
         *              where to kick the clients from
         * @param message
         *              the reason message to display to the clients
         * @param clientIds
         *              the IDs of the clients to kick
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see Client#getId()
         */
        private CommandFuture<Boolean> kickClients(ReasonIdentifier reason, String message, int... clientIds) {
                final CClientKick kick = new CClientKick(reason, message, clientIds);
                return executeAndReturnError(kick);
        }

        /**
         * Logs the server query in using the specified username and password.
         * <p>
         * Note that you can also set the login in the {@link TS3Config},
         * so that you will be logged in right after the connection is established.
         * </p>
         *
         * @param username
         *              the username of the server query
         * @param password
         *              the password to use
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see #logout()
         */
        public CommandFuture<Boolean> login(String username, String password) {
                final CLogin login = new CLogin(username, password);
                return executeAndReturnError(login);
        }

        /**
         * Logs the server query out and deselects the current virtual server.
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see #login(String, String)
         */
        public CommandFuture<Boolean> logout() {
                final CLogout logout = new CLogout();
                return executeAndReturnError(logout);
        }

        /**
         * Moves a channel to a new parent channel specified by its ID.
         * To move a channel to root level, set {@code channelTargetId} to {@code 0}.
         * <p>
         * This will move the channel right below the specified parent channel, above all other child channels.
         * This command will fail if the channel already has the specified target channel as the parent channel.
         * </p>
         *
         * @param channelId
         *              the channel to move
         * @param channelTargetId
         *              the new parent channel for the specified channel
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see Channel#getId()
         * @see #moveChannel(int, int, int)
         */
        public CommandFuture<Boolean> moveChannel(int channelId, int channelTargetId) {
                return moveChannel(channelId, channelTargetId, 0);
        }

        /**
         * Moves a channel to a new parent channel specified by its ID.
         * To move a channel to root level, set {@code channelTargetId} to {@code 0}.
         * <p>
         * The channel will be ordered below the channel with the ID specified by {@code order}.
         * To move the channel right below the parent channel, set {@code order} to {@code 0}.
         * Also note that a channel cannot be re-ordered without also changing its parent channel.
         * </p>
         *
         * @param channelId
         *              the channel to move
         * @param channelTargetId
         *              the new parent channel for the specified channel
         * @param order
         *              the channel to sort the specified channel below
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see Channel#getId()
         * @see #moveChannel(int, int)
         */
        public CommandFuture<Boolean> moveChannel(int channelId, int channelTargetId, int order) {
                final CChannelMove move = new CChannelMove(channelId, channelTargetId, order);
                return executeAndReturnError(move);
        }

        /**
         * Moves the server query into a channel.
         *
         * @param channelId
         *              the ID of the channel to move the server query into
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see Channel#getId()
         */
        public CommandFuture<Boolean> moveQuery(int channelId) {
                return moveClient(0, channelId, null);
        }

        /**
         * Moves the server query into a channel.
         *
         * @param channel
         *              the channel to move the server query into, cannot be {@code null}
         *
         * @return whether the command succeeded or not
         *
         * @throws IllegalArgumentException
         *              if {@code channel} is {@code null}
         * @querycommands 1
         */
        public CommandFuture<Boolean> moveQuery(ChannelBase channel) {
                if (channel == null) throw new IllegalArgumentException("channel was null");

                return moveClient(0, channel.getId(), null);
        }

        /**
         * Moves the server query into a channel using the specified password.
         *
         * @param channelId
         *              the ID of the channel to move the client into
         * @param channelPassword
         *              the password of the channel, can be {@code null}
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see Channel#getId()
         */
        public CommandFuture<Boolean> moveQuery(int channelId, String channelPassword) {
                return moveClient(0, channelId, channelPassword);
        }

        /**
         * Moves the server query into a channel using the specified password.
         *
         * @param channel
         *              the channel to move the client into, cannot be {@code null}
         * @param channelPassword
         *              the password of the channel, can be {@code null}
         *
         * @return whether the command succeeded or not
         *
         * @throws IllegalArgumentException
         *              if {@code channel} is {@code null}
         * @querycommands 1
         */
        public CommandFuture<Boolean> moveQuery(ChannelBase channel, String channelPassword) {
                if (channel == null) throw new IllegalArgumentException("channel was null");

                return moveClient(0, channel.getId(), channelPassword);
        }

        /**
         * Moves a client into a channel.
         * <p>
         * Consider using {@link #moveClients(int[], int)}
         * for moving multiple clients.
         * </p>
         *
         * @param clientId
         *              the ID of the client to move
         * @param channelId
         *              the ID of the channel to move the client into
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see Client#getId()
         * @see Channel#getId()
         */
        public CommandFuture<Boolean> moveClient(int clientId, int channelId) {
                return moveClient(clientId, channelId, null);
        }

        /**
         * Moves multiple clients into a channel.
         * Immediately returns {@code true} for an empty client ID array.
         * <p>
         * Use this method instead of {@link #moveClient(int, int)} for moving
         * several clients as this will only send 1 command to the server and thus complete faster.
         * </p>
         *
         * @param clientIds
         *              the IDs of the clients to move, cannot be {@code null}
         * @param channelId
         *              the ID of the channel to move the clients into
         *
         * @return whether the command succeeded or not
         *
         * @throws IllegalArgumentException
         *              if {@code clientIds} is {@code null}
         * @querycommands 1
         * @see Client#getId()
         * @see Channel#getId()
         */
        public CommandFuture<Boolean> moveClients(int[] clientIds, int channelId) {
                return moveClients(clientIds, channelId, null);
        }

        /**
         * Moves a client into a channel.
         * <p>
         * Consider using {@link #moveClients(Client[], ChannelBase)}
         * for moving multiple clients.
         * </p>
         *
         * @param client
         *              the client to move, cannot be {@code null}
         * @param channel
         *              the channel to move the client into, cannot be {@code null}
         *
         * @return whether the command succeeded or not
         *
         * @throws IllegalArgumentException
         *              if {@code client} or {@code channel} is {@code null}
         * @querycommands 1
         */
        public CommandFuture<Boolean> moveClient(Client client, ChannelBase channel) {
                return moveClient(client, channel, null);
        }

        /**
         * Moves multiple clients into a channel.
         * Immediately returns {@code true} for an empty client array.
         * <p>
         * Use this method instead of {@link #moveClient(Client, ChannelBase)} for moving
         * several clients as this will only send 1 command to the server and thus complete faster.
         * </p>
         *
         * @param clients
         *              the clients to move, cannot be {@code null}
         * @param channel
         *              the channel to move the clients into, cannot be {@code null}
         *
         * @return whether the command succeeded or not
         *
         * @throws IllegalArgumentException
         *              if {@code clients} or {@code channel} is {@code null}
         * @querycommands 1
         */
        public CommandFuture<Boolean> moveClients(Client[] clients, ChannelBase channel) {
                return moveClients(clients, channel, null);
        }

        /**
         * Moves a client into a channel using the specified password.
         *
         * @param clientId
         *              the ID of the client to move
         * @param channelId
         *              the ID of the channel to move the client into
         * @param channelPassword
         *              the password of the channel, can be {@code null}
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see Client#getId()
         * @see Channel#getId()
         */
        public CommandFuture<Boolean> moveClient(int clientId, int channelId, String channelPassword) {
                final CClientMove move = new CClientMove(clientId, channelId, channelPassword);
                return executeAndReturnError(move);
        }

        /**
         * Moves multiple clients into a channel using the specified password.
         * Immediately returns {@code true} for an empty client ID array.
         * <p>
         * Use this method instead of {@link #moveClient(int, int, String)} for moving
         * several clients as this will only send 1 command to the server and thus complete faster.
         * </p>
         *
         * @param clientIds
         *              the IDs of the clients to move, cannot be {@code null}
         * @param channelId
         *              the ID of the channel to move the clients into
         * @param channelPassword
         *              the password of the channel, can be {@code null}
         *
         * @return whether the command succeeded or not
         *
         * @throws IllegalArgumentException
         *              if {@code clientIds} is {@code null}
         * @querycommands 1
         * @see Client#getId()
         * @see Channel#getId()
         */
        public CommandFuture<Boolean> moveClients(int[] clientIds, int channelId, String channelPassword) {
                if (clientIds == null) throw new IllegalArgumentException("clientIds was null");
                if (clientIds.length == 0) return CommandFuture.immediate(true);

                final CClientMove move = new CClientMove(clientIds, channelId, channelPassword);
                return executeAndReturnError(move);
        }

        /**
         * Moves a client into a channel using the specified password.
         * <p>
         * Consider using {@link #moveClients(Client[], ChannelBase, String)}
         * for moving multiple clients.
         * </p>
         *
         * @param client
         *              the client to move, cannot be {@code null}
         * @param channel
         *              the channel to move the client into, cannot be {@code null}
         * @param channelPassword
         *              the password of the channel, can be {@code null}
         *
         * @return whether the command succeeded or not
         *
         * @throws IllegalArgumentException
         *              if {@code client} or {@code channel} is {@code null}
         * @querycommands 1
         */
        public CommandFuture<Boolean> moveClient(Client client, ChannelBase channel, String channelPassword) {
                if (client == null) throw new IllegalArgumentException("client was null");
                if (channel == null) throw new IllegalArgumentException("channel was null");

                return moveClient(client.getId(), channel.getId(), channelPassword);
        }

        /**
         * Moves multiple clients into a channel using the specified password.
         * Immediately returns {@code true} for an empty client array.
         * <p>
         * Use this method instead of {@link #moveClient(Client, ChannelBase, String)} for moving
         * several clients as this will only send 1 command to the server and thus complete faster.
         * </p>
         *
         * @param clients
         *              the clients to move, cannot be {@code null}
         * @param channel
         *              the channel to move the clients into, cannot be {@code null}
         * @param channelPassword
         *              the password of the channel, can be {@code null}
         *
         * @return whether the command succeeded or not
         *
         * @throws IllegalArgumentException
         *              if {@code clients} or {@code channel} is {@code null}
         * @querycommands 1
         */
        public CommandFuture<Boolean> moveClients(Client[] clients, ChannelBase channel, String channelPassword) {
                if (clients == null) throw new IllegalArgumentException("clients was null");
                if (channel == null) throw new IllegalArgumentException("channel was null");

                int[] clientIds = new int[clients.length];
                for (int i = 0; i < clients.length; i++) {
                        Client client = clients[i];
                        clientIds[i] = client.getId();
                }
                return moveClients(clientIds, channel.getId(), channelPassword);
        }

        /**
         * Pokes the client with the specified client ID.
         * This opens up a small popup window for the client containing your message and plays a sound.
         * The displayed message will be formatted like this: <br>
         * {@code hh:mm:ss - "Your Nickname" poked you: <your message in green color>}
         * <p>
         * The displayed message length is limited to 100 UTF-8 bytes.
         * If a client has already received a poke message, all subsequent pokes will simply add a line
         * to the already opened popup window and will still play a sound.
         * </p>
         *
         * @param clientId
         *              the ID of the client to poke
         * @param message
         *              the message to send, may contain BB codes
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see Client#getId()
         */
        public CommandFuture<Boolean> pokeClient(int clientId, String message) {
                final CClientPoke poke = new CClientPoke(clientId, message);
                return executeAndReturnError(poke);
        }

        /**
         * Terminates the connection with the TeamSpeak3 server.
         * This command should never be executed manually.
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @deprecated This command leaves the query in an undefined state,
         * where the connection is closed without the socket being closed and no more command can be executed.
         * To terminate a connection, use {@link TS3Query#exit()}.
         */
        @Deprecated
        public CommandFuture<Boolean> quit() {
                final CQuit quit = new CQuit();
                return executeAndReturnError(quit);
        }

        /**
         * Registers the server query to receive notifications about all server events.
         * <p>
         * This means that the following actions will trigger event notifications:
         * </p>
         * <ul>
         * <li>A client joins the server or disconnects from it</li>
         * <li>A client switches channels</li>
         * <li>A client sends a server message</li>
         * <li>A client sends a channel message <b>in the channel the query is in</b></li>
         * <li>A client sends <b>the server query</b> a private message or a response to a private message</li>
         * </ul>
         * <p>
         * The limitations to when the query receives notifications about chat events cannot be circumvented.
         * </p>
         * To be able to process these events in your application, register an event listener.
         *
         * @return whether all commands succeeded or not
         *
         * @querycommands 6
         * @see #addTS3Listeners(TS3Listener...)
         */
        public CommandFuture<Boolean> registerAllEvents() {
                final CommandFuture<Boolean> future = new CommandFuture<>();
                final Collection<CommandFuture<Boolean>> eventFutures = new ArrayList<>(5);

                eventFutures.add(registerEvent(TS3EventType.SERVER));
                eventFutures.add(registerEvent(TS3EventType.TEXT_SERVER));
                eventFutures.add(registerEvent(TS3EventType.CHANNEL, 0));
                eventFutures.add(registerEvent(TS3EventType.TEXT_CHANNEL, 0));
                eventFutures.add(registerEvent(TS3EventType.TEXT_PRIVATE));
                eventFutures.add(registerEvent(TS3EventType.PRIVILEGE_KEY_USED));

                CommandFuture.ofAll(eventFutures).onSuccess(new CommandFuture.SuccessListener<List<Boolean>>() {
                        @Override
                        public void handleSuccess(List<Boolean> result) {
                                future.set(true);
                        }
                }).forwardFailure(future);
                return future;
        }

        /**
         * Registers the server query to receive notifications about a given event type.
         * <p>
         * If used with {@link TS3EventType#TEXT_CHANNEL}, this will listen to chat events in the current channel.
         * If used with {@link TS3EventType#CHANNEL}, this will listen to <b>all</b> channel events.
         * To specify a different channel for channel events, use {@link #registerEvent(TS3EventType, int)}.
         * </p>
         *
         * @param eventType
         *              the event type to be notified about
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see #addTS3Listeners(TS3Listener...)
         * @see #registerEvent(TS3EventType, int)
         * @see #registerAllEvents()
         */
        public CommandFuture<Boolean> registerEvent(TS3EventType eventType) {
                if (eventType == TS3EventType.CHANNEL || eventType == TS3EventType.TEXT_CHANNEL) {
                        return registerEvent(eventType, 0);
                }
                return registerEvent(eventType, -1);
        }

        /**
         * Registers the server query to receive notifications about a given event type.
         *
         * @param eventType
         *              the event type to be notified about
         * @param channelId
         *              the ID of the channel to listen to, will be ignored if set to {@code -1}.
         *              Can be set to {@code 0} for {@link TS3EventType#CHANNEL} to receive notifications about all channel switches.
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see Channel#getId()
         * @see #addTS3Listeners(TS3Listener...)
         * @see #registerAllEvents()
         */
        public CommandFuture<Boolean> registerEvent(TS3EventType eventType, int channelId) {
                final CServerNotifyRegister register = new CServerNotifyRegister(eventType, channelId);
                return executeAndReturnError(register);
        }

        /**
         * Registers the server query to receive notifications about multiple given event types.
         * <p>
         * If used with {@link TS3EventType#TEXT_CHANNEL}, this will listen to chat events in the current channel.
         * If used with {@link TS3EventType#CHANNEL}, this will listen to <b>all</b> channel events.
         * To specify a different channel for channel events, use {@link #registerEvent(TS3EventType, int)}.
         * </p>
         *
         * @param eventTypes
         *              the event types to be notified about
         *
         * @return whether the command succeeded or not
         *
         * @querycommands n, one command per TS3EventType
         * @see #addTS3Listeners(TS3Listener...)
         * @see #registerEvent(TS3EventType, int)
         * @see #registerAllEvents()
         */
        public CommandFuture<Boolean> registerEvents(TS3EventType... eventTypes) {
                if (eventTypes.length == 0) return CommandFuture.immediate(true);

                final Collection<CommandFuture<Boolean>> registerFutures = new ArrayList<>(eventTypes.length);
                for (final TS3EventType type : eventTypes) {
                        registerFutures.add(registerEvent(type));
                }

                final CommandFuture<Boolean> future = new CommandFuture<>();
                CommandFuture.ofAll(registerFutures).onSuccess(new CommandFuture.SuccessListener<List<Boolean>>() {
                        @Override
                        public void handleSuccess(List<Boolean> result) {
                                future.set(true);
                        }
                }).forwardFailure(future);
                return future;
        }

        /**
         * Removes the client specified by its database ID from the specified server group.
         *
         * @param serverGroupId
         *              the ID of the server group
         * @param clientDatabaseId
         *              the database ID of the client
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see ServerGroup#getId()
         * @see Client#getDatabaseId()
         * @see #removeClientFromServerGroup(ServerGroup, Client)
         */
        public CommandFuture<Boolean> removeClientFromServerGroup(int serverGroupId, int clientDatabaseId) {
                final CServerGroupDelClient del = new CServerGroupDelClient(serverGroupId, clientDatabaseId);
                return executeAndReturnError(del);
        }

        /**
         * Removes the specified client from the specified server group.
         *
         * @param serverGroup
         *              the server group to remove the client from
         * @param client
         *              the client to remove from the server group
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see #removeClientFromServerGroup(int, int)
         */
        public CommandFuture<Boolean> removeClientFromServerGroup(ServerGroup serverGroup, Client client) {
                return removeClientFromServerGroup(serverGroup.getId(), client.getDatabaseId());
        }

        /**
         * Removes one or more {@link TS3Listener}s to the event manager of the query.
         * <p>
         * If a listener was not actually registered, it will be ignored and no exception will be thrown.
         * </p>
         *
         * @param listeners
         *              one or more listeners to remove
         *
         * @see #addTS3Listeners(TS3Listener...)
         * @see TS3Listener
         * @see TS3EventType
         */
        public void removeTS3Listeners(TS3Listener... listeners) {
                query.getEventManager().removeListeners(listeners);
        }

        /**
         * Renames the channel group with the specified ID.
         *
         * @param channelGroupId
         *              the ID of the channel group to rename
         * @param name
         *              the new name for the channel group
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see ChannelGroup#getId()
         * @see #renameChannelGroup(ChannelGroup, String)
         */
        public CommandFuture<Boolean> renameChannelGroup(int channelGroupId, String name) {
                final CChannelGroupRename rename = new CChannelGroupRename(channelGroupId, name);
                return executeAndReturnError(rename);
        }

        /**
         * Renames the specified channel group.
         *
         * @param channelGroup
         *              the channel group to rename
         * @param name
         *              the new name for the channel group
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see #renameChannelGroup(int, String)
         */
        public CommandFuture<Boolean> renameChannelGroup(ChannelGroup channelGroup, String name) {
                return renameChannelGroup(channelGroup.getId(), name);
        }

        /**
         * Renames the server group with the specified ID.
         *
         * @param serverGroupId
         *              the ID of the server group to rename
         * @param name
         *              the new name for the server group
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see ServerGroup#getId()
         * @see #renameServerGroup(ServerGroup, String)
         */
        public CommandFuture<Boolean> renameServerGroup(int serverGroupId, String name) {
                final CServerGroupRename rename = new CServerGroupRename(serverGroupId, name);
                return executeAndReturnError(rename);
        }

        /**
         * Renames the specified server group.
         *
         * @param serverGroup
         *              the server group to rename
         * @param name
         *              the new name for the server group
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see #renameServerGroup(int, String)
         */
        public CommandFuture<Boolean> renameServerGroup(ServerGroup serverGroup, String name) {
                return renameChannelGroup(serverGroup.getId(), name);
        }

        /**
         * Resets all permissions and deletes all server / channel groups. Use carefully.
         *
         * @return a token for a new administrator account
         *
         * @querycommands 1
         */
        public CommandFuture<String> resetPermissions() {
                final CPermReset reset = new CPermReset();
                return executeAndReturnStringProperty(reset, "token");
        }

        /**
         * Moves the server query into the virtual server with the specified ID.
         *
         * @param id
         *              the ID of the virtual server
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see VirtualServer#getId()
         * @see #selectVirtualServerByPort(int)
         * @see #selectVirtualServer(VirtualServer)
         */
        public CommandFuture<Boolean> selectVirtualServerById(int id) {
                final CUse use = new CUse(id, -1);
                return executeAndReturnError(use);
        }

        /**
         * Moves the server query into the virtual server with the specified voice port.
         *
         * @param port
         *              the voice port of the virtual server
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see VirtualServer#getPort()
         * @see #selectVirtualServerById(int)
         * @see #selectVirtualServer(VirtualServer)
         */
        public CommandFuture<Boolean> selectVirtualServerByPort(int port) {
                final CUse use = new CUse(-1, port);
                return executeAndReturnError(use);
        }

        /**
         * Moves the server query into the specified virtual server.
         *
         * @param server
         *              the virtual server to move into
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see #selectVirtualServerById(int)
         * @see #selectVirtualServerByPort(int)
         */
        public CommandFuture<Boolean> selectVirtualServer(VirtualServer server) {
                return selectVirtualServerById(server.getId());
        }

        /**
         * Sends an offline message to the client with the given unique identifier.
         * <p>
         * The message subject's length is limited to 200 UTF-8 bytes and BB codes in it will be ignored.
         * The message body's length is limited to 4096 UTF-8 bytes and accepts BB codes
         * </p>
         *
         * @param clientUId
         *              the unique identifier of the client to send the message to
         * @param subject
         *              the subject for the message, may not contain BB codes
         * @param message
         *              the actual message body, may contain BB codes
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see Client#getUniqueIdentifier()
         * @see Message
         */
        public CommandFuture<Boolean> sendOfflineMessage(String clientUId, String subject, String message) {
                final CMessageAdd add = new CMessageAdd(clientUId, subject, message);
                return executeAndReturnError(add);
        }

        /**
         * Sends a text message either to the whole virtual server, a channel or specific client.
         * Your message may contain BB codes, but its length is limited to 1024 UTF-8 bytes.
         * <p>
         * To send a message to all virtual servers, use {@link #broadcast(String)}.
         * To send an offline message, use {@link #sendOfflineMessage(String, String, String)}.
         * </p>
         *
         * @param targetMode
         *              where the message should be sent to
         * @param targetId
         *              the client ID of the recipient of this message. This value is ignored unless {@code targetMode} is {@code CLIENT}
         * @param message
         *              the text message to send
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see Client#getId()
         */
        public CommandFuture<Boolean> sendTextMessage(TextMessageTargetMode targetMode, int targetId, String message) {
                final CSendTextMessage msg = new CSendTextMessage(targetMode.getIndex(), targetId, message);
                return executeAndReturnError(msg);
        }

        /**
         * Sends a text message to the channel with the specified ID.
         * Your message may contain BB codes, but its length is limited to 1024 UTF-8 bytes.
         * <p>
         * This will move the client into the channel with the specified channel ID,
         * <b>but will not move it back to the original channel!</b>
         * </p>
         *
         * @param channelId
         *              the ID of the channel to which the message should be sent to
         * @param message
         *              the text message to send
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see #sendChannelMessage(String)
         * @see Channel#getId()
         */
        public CommandFuture<Boolean> sendChannelMessage(int channelId, final String message) {
                final CommandFuture<Boolean> future = new CommandFuture<>();

                moveQuery(channelId).onSuccess(new CommandFuture.SuccessListener<Boolean>() {
                        @Override
                        public void handleSuccess(Boolean result) {
                                sendTextMessage(TextMessageTargetMode.CHANNEL, 0, message).forwardResult(future);
                        }
                }).forwardFailure(future);

                return future;
        }

        /**
         * Sends a text message to the channel the server query is currently in.
         * Your message may contain BB codes, but its length is limited to 1024 UTF-8 bytes.
         *
         * @param message
         *              the text message to send
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         */
        public CommandFuture<Boolean> sendChannelMessage(String message) {
                return sendTextMessage(TextMessageTargetMode.CHANNEL, 0, message);
        }

        /**
         * Sends a text message to the virtual server with the specified ID.
         * Your message may contain BB codes, but its length is limited to 1024 UTF-8 bytes.
         * <p>
         * This will move the client to the virtual server with the specified server ID,
         * <b>but will not move it back to the original virtual server!</b>
         * </p>
         *
         * @param serverId
         *              the ID of the virtual server to which the message should be sent to
         * @param message
         *              the text message to send
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see #sendServerMessage(String)
         * @see VirtualServer#getId()
         */
        public CommandFuture<Boolean> sendServerMessage(int serverId, final String message) {
                final CommandFuture<Boolean> future = new CommandFuture<>();

                selectVirtualServerById(serverId).onSuccess(new CommandFuture.SuccessListener<Boolean>() {
                        @Override
                        public void handleSuccess(Boolean result) {
                                sendTextMessage(TextMessageTargetMode.SERVER, 0, message).forwardResult(future);
                        }
                }).forwardFailure(future);

                return future;
        }

        /**
         * Sends a text message to the virtual server the server query is currently in.
         * Your message may contain BB codes, but its length is limited to 1024 UTF-8 bytes.
         *
         * @param message
         *              the text message to send
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         */
        public CommandFuture<Boolean> sendServerMessage(String message) {
                return sendTextMessage(TextMessageTargetMode.SERVER, 0, message);
        }

        /**
         * Sends a private message to the client with the specified client ID.
         * Your message may contain BB codes, but its length is limited to 1024 UTF-8 bytes.
         *
         * @param clientId
         *              the ID of the client to send the message to
         * @param message
         *              the text message to send
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see Client#getId()
         */
        public CommandFuture<Boolean> sendPrivateMessage(int clientId, String message) {
                return sendTextMessage(TextMessageTargetMode.CLIENT, clientId, message);
        }

        /**
         * Sets a channel group for a client in a specific channel.
         *
         * @param groupId
         *              the ID of the group the client should join
         * @param channelId
         *              the ID of the channel where the channel group should be assigned
         * @param clientDBId
         *              the database ID of the client for which the channel group should be set
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see ChannelGroup#getId()
         * @see Channel#getId()
         * @see Client#getDatabaseId()
         */
        public CommandFuture<Boolean> setClientChannelGroup(int groupId, int channelId, int clientDBId) {
                final CSetClientChannelGroup group = new CSetClientChannelGroup(groupId, channelId, clientDBId);
                return executeAndReturnError(group);
        }

        /**
         * Sets the read flag to true for a given message. This will not delete the message.
         *
         * @param messageId
         *              the ID of the message for which the read flag should be set
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see #setMessageReadFlag(int, boolean)
         */
        public CommandFuture<Boolean> setMessageRead(int messageId) {
                return setMessageReadFlag(messageId, true);
        }

        /**
         * Sets the read flag to true for a given message. This will not delete the message.
         *
         * @param message
         *              the message for which the read flag should be set
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see #setMessageRead(int)
         * @see #setMessageReadFlag(Message, boolean)
         * @see #deleteOfflineMessage(int)
         */
        public CommandFuture<Boolean> setMessageRead(Message message) {
                return setMessageReadFlag(message.getId(), true);
        }

        /**
         * Sets the read flag for a given message. This will not delete the message.
         *
         * @param messageId
         *              the ID of the message for which the read flag should be set
         * @param read
         *              the boolean value to which the read flag should be set
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see #setMessageRead(int)
         * @see #setMessageReadFlag(Message, boolean)
         * @see #deleteOfflineMessage(int)
         */
        public CommandFuture<Boolean> setMessageReadFlag(int messageId, boolean read) {
                final CMessageUpdateFlag flag = new CMessageUpdateFlag(messageId, read);
                return executeAndReturnError(flag);
        }

        /**
         * Sets the read flag for a given message. This will not delete the message.
         *
         * @param message
         *              the message for which the read flag should be set
         * @param read
         *              the boolean value to which the read flag should be set
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see #setMessageRead(Message)
         * @see #setMessageReadFlag(int, boolean)
         * @see #deleteOfflineMessage(int)
         */
        public CommandFuture<Boolean> setMessageReadFlag(Message message, boolean read) {
                return setMessageReadFlag(message.getId(), read);
        }

        /**
         * Sets the nickname of the server query client.
         * The nickname must be between 3 and 30 UTF-8 bytes long and BB codes will be ignored.
         *
         * @param nickname
         *              the new nickname, may not contain any BB codes and may not be {@code null}
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see #updateClient(Map)
         */
        public CommandFuture<Boolean> setNickname(String nickname) {
                final Map<ClientProperty, String> options = Collections.singletonMap(ClientProperty.CLIENT_NICKNAME, nickname);
                return updateClient(options);
        }

        /**
         * Starts the virtual server with the specified ID.
         *
         * @param serverId
         *              the ID of the virtual server
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         */
        public CommandFuture<Boolean> startServer(int serverId) {
                final CServerStart start = new CServerStart(serverId);
                return executeAndReturnError(start);
        }

        /**
         * Starts the specified virtual server.
         *
         * @param virtualServer
         *              the virtual server to start
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         */
        public CommandFuture<Boolean> startServer(VirtualServer virtualServer) {
                return startServer(virtualServer.getId());
        }

        /**
         * Stops the virtual server with the specified ID.
         *
         * @param serverId
         *              the ID of the virtual server
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         */
        public CommandFuture<Boolean> stopServer(int serverId) {
                final CServerStop stop = new CServerStop(serverId);
                return executeAndReturnError(stop);
        }

        /**
         * Stops the specified virtual server.
         *
         * @param virtualServer
         *              the virtual server to stop
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         */
        public CommandFuture<Boolean> stopServer(VirtualServer virtualServer) {
                return stopServer(virtualServer.getId());
        }

        /**
         * Stops the entire TeamSpeak 3 Server instance by shutting down the process.
         * <p>
         * To have permission to use this command, you need to use the server query admin login.
         * </p>
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         */
        public CommandFuture<Boolean> stopServerProcess() {
                final CServerProcessStop stop = new CServerProcessStop();
                return executeAndReturnError(stop);
        }

        /**
         * Unregisters the server query from receiving any event notifications.
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         */
        public CommandFuture<Boolean> unregisterAllEvents() {
                final CServerNotifyUnregister unr = new CServerNotifyUnregister();
                return executeAndReturnError(unr);
        }

        /**
         * Updates several client properties for this server query instance.
         *
         * @param options
         *              the map of properties to update
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see #editClient(int, Map)
         */
        public CommandFuture<Boolean> updateClient(Map<ClientProperty, String> options) {
                final CClientUpdate update = new CClientUpdate(options);
                return executeAndReturnError(update);
        }

        /**
         * Generates new login credentials for the currently connected server query instance, using the given name.
         * <p>
         * <b>This will remove the current login credentials!</b> You won't be logged out, but after disconnecting,
         * the old credentials will no longer work. Make sure to not lock yourselves out!
         * </p>
         *
         * @param loginName
         *              the name for the server query login
         *
         * @return the generated password for the server query login
         *
         * @querycommands 1
         */
        public CommandFuture<String> updateServerQueryLogin(String loginName) {
                final CClientSetServerQueryLogin login = new CClientSetServerQueryLogin(loginName);
                return executeAndReturnStringProperty(login, "client_login_password");
        }

        /**
         * Uses an existing privilege key to join a server or channel group.
         *
         * @param token
         *              the privilege key to use
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see PrivilegeKey
         * @see #addPrivilegeKey(PrivilegeKeyType, int, int, String)
         * @see #usePrivilegeKey(PrivilegeKey)
         */
        public CommandFuture<Boolean> usePrivilegeKey(String token) {
                final CPrivilegeKeyUse use = new CPrivilegeKeyUse(token);
                return executeAndReturnError(use);
        }

        /**
         * Uses an existing privilege key to join a server or channel group.
         *
         * @param privilegeKey
         *              the privilege key to use
         *
         * @return whether the command succeeded or not
         *
         * @querycommands 1
         * @see PrivilegeKey
         * @see #addPrivilegeKey(PrivilegeKeyType, int, int, String)
         * @see #usePrivilegeKey(String)
         */
        public CommandFuture<Boolean> usePrivilegeKey(PrivilegeKey privilegeKey) {
                return usePrivilegeKey(privilegeKey.getToken());
        }

        /**
         * Gets information about the current server query instance.
         *
         * @return information about the server query instance
         *
         * @querycommands 1
         * @see #getClientInfo(int)
         */
        public CommandFuture<ServerQueryInfo> whoAmI() {
                final CWhoAmI whoAmI = new CWhoAmI();
                final CommandFuture<ServerQueryInfo> future = new CommandFuture<>();

                query.doCommandAsync(whoAmI, new Callback() {
                        @Override
                        public void handle() {
                                if (hasFailed(whoAmI, future)) return;
                                future.set(new ServerQueryInfo(whoAmI.getFirstResponse().getMap()));
                        }
                });
                return future;
        }

        /**
         * Executes a command, checking for failure and returning true if the command succeeded.
         *
         * @param command
         *              the command to execute
         *
         * @return whether the command succeeded or not
         */
        private CommandFuture<Boolean> executeAndReturnError(final Command command) {
                final CommandFuture<Boolean> future = new CommandFuture<>();

                query.doCommandAsync(command, new Callback() {
                        @Override
                        public void handle() {
                                if (hasFailed(command, future)) return;
                                future.set(true);
                        }
                });
                return future;
        }

        /**
         * Executes a command, checking for failure and returning a single
         * {@code String} property from the first response map.
         *
         * @param command
         *              the command to execute
         * @param property
         *              the name of the property to return
         *
         * @return the value of the specified {@code String} property
         */
        private CommandFuture<String> executeAndReturnStringProperty(final Command command, final String property) {
                final CommandFuture<String> future = new CommandFuture<>();

                query.doCommandAsync(command, new Callback() {
                        @Override
                        public void handle() {
                                if (hasFailed(command, future)) return;
                                future.set(command.getFirstResponse().get(property));
                        }
                });
                return future;
        }

        /**
         * Executes a command, checking for failure and returning a single
         * {@code Integer} property from the first response map.
         *
         * @param command
         *              the command to execute
         * @param property
         *              the name of the property to return
         *
         * @return the value of the specified {@code Integer} property
         */
        private CommandFuture<Integer> executeAndReturnIntProperty(final Command command, final String property) {
                final CommandFuture<Integer> future = new CommandFuture<>();

                query.doCommandAsync(command, new Callback() {
                        @Override
                        public void handle() {
                                if (hasFailed(command, future)) return;
                                future.set(command.getFirstResponse().getInt(property));
                        }
                });
                return future;
        }

        /**
         * If a command has failed (i.e. the error ID is not 0),
         * the future will be marked as failed and true will be returned.
         *
         * @param command
         *              the command to be checked for failure
         * @param future
         *              the future to be notified in case of a failure
         *
         * @return true if the command has failed
         *
         * @see Command
         */
        private boolean hasFailed(Command command, CommandFuture<?> future) {
                final QueryError error = command.getError();
                if (error.isSuccessful()) return false;

                future.fail(error);
                return true;
        }
}