diff options
author | Max Kellermann <max@duempel.org> | 2013-10-20 13:41:04 +0200 |
---|---|---|
committer | Max Kellermann <max@duempel.org> | 2013-10-20 13:41:04 +0200 |
commit | 5ec843dcc89737bb2ca9e428415d9a052c5a753d (patch) | |
tree | 17fea4f30c52810ece404200698f1975610f2c3b /src/MessageCommands.cxx | |
parent | a78b2d84ed7c2a82c69c56125036e70b009a87b0 (diff) | |
download | mpd-5ec843dcc89737bb2ca9e428415d9a052c5a753d.tar.gz mpd-5ec843dcc89737bb2ca9e428415d9a052c5a753d.tar.xz mpd-5ec843dcc89737bb2ca9e428415d9a052c5a753d.zip |
*Commands: move to src/command/
Diffstat (limited to 'src/MessageCommands.cxx')
-rw-r--r-- | src/MessageCommands.cxx | 137 |
1 files changed, 0 insertions, 137 deletions
diff --git a/src/MessageCommands.cxx b/src/MessageCommands.cxx deleted file mode 100644 index 7d9893e70..000000000 --- a/src/MessageCommands.cxx +++ /dev/null @@ -1,137 +0,0 @@ -/* - * Copyright (C) 2003-2013 The Music Player Daemon Project - * http://www.musicpd.org - * - * This program is free software; you can redistribute it and/or modify - * it under the terms of the GNU General Public License as published by - * the Free Software Foundation; either version 2 of the License, or - * (at your option) any later version. - * - * This program is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU General Public License for more details. - * - * You should have received a copy of the GNU General Public License along - * with this program; if not, write to the Free Software Foundation, Inc., - * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. - */ - -#include "config.h" -#include "MessageCommands.hxx" -#include "Client.hxx" -#include "ClientList.hxx" -#include "Instance.hxx" -#include "Main.hxx" -#include "protocol/Result.hxx" -#include "protocol/ArgParser.hxx" - -#include <set> -#include <string> - -#include <assert.h> - -CommandResult -handle_subscribe(Client &client, gcc_unused int argc, char *argv[]) -{ - assert(argc == 2); - - switch (client.Subscribe(argv[1])) { - case Client::SubscribeResult::OK: - return CommandResult::OK; - - case Client::SubscribeResult::INVALID: - command_error(client, ACK_ERROR_ARG, - "invalid channel name"); - return CommandResult::ERROR; - - case Client::SubscribeResult::ALREADY: - command_error(client, ACK_ERROR_EXIST, - "already subscribed to this channel"); - return CommandResult::ERROR; - - case Client::SubscribeResult::FULL: - command_error(client, ACK_ERROR_EXIST, - "subscription list is full"); - return CommandResult::ERROR; - } - - /* unreachable */ - assert(false); - gcc_unreachable(); -} - -CommandResult -handle_unsubscribe(Client &client, gcc_unused int argc, char *argv[]) -{ - assert(argc == 2); - - if (client.Unsubscribe(argv[1])) - return CommandResult::OK; - else { - command_error(client, ACK_ERROR_NO_EXIST, - "not subscribed to this channel"); - return CommandResult::ERROR; - } -} - -CommandResult -handle_channels(Client &client, - gcc_unused int argc, gcc_unused char *argv[]) -{ - assert(argc == 1); - - std::set<std::string> channels; - for (const auto &c : *instance->client_list) - channels.insert(c->subscriptions.begin(), - c->subscriptions.end()); - - for (const auto &channel : channels) - client_printf(client, "channel: %s\n", channel.c_str()); - - return CommandResult::OK; -} - -CommandResult -handle_read_messages(Client &client, - gcc_unused int argc, gcc_unused char *argv[]) -{ - assert(argc == 1); - - while (!client.messages.empty()) { - const ClientMessage &msg = client.messages.front(); - - client_printf(client, "channel: %s\nmessage: %s\n", - msg.GetChannel(), msg.GetMessage()); - client.messages.pop_front(); - } - - return CommandResult::OK; -} - -CommandResult -handle_send_message(Client &client, - gcc_unused int argc, gcc_unused char *argv[]) -{ - assert(argc == 3); - - if (!client_message_valid_channel_name(argv[1])) { - command_error(client, ACK_ERROR_ARG, - "invalid channel name"); - return CommandResult::ERROR; - } - - bool sent = false; - const ClientMessage msg(argv[1], argv[2]); - for (const auto &c : *instance->client_list) - if (c->PushMessage(msg)) - sent = true; - - if (sent) - return CommandResult::OK; - else { - command_error(client, ACK_ERROR_NO_EXIST, - "nobody is subscribed to this channel"); - return CommandResult::ERROR; - } -} |