From 5ec843dcc89737bb2ca9e428415d9a052c5a753d Mon Sep 17 00:00:00 2001 From: Max Kellermann Date: Sun, 20 Oct 2013 13:41:04 +0200 Subject: *Commands: move to src/command/ --- src/MessageCommands.cxx | 137 ------------------------------------------------ 1 file changed, 137 deletions(-) delete mode 100644 src/MessageCommands.cxx (limited to 'src/MessageCommands.cxx') 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 -#include - -#include - -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 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; - } -} -- cgit v1.2.3