1.1 --- a/org/sonews/daemon/command/XDaemonCommand.java Sun Aug 29 17:04:25 2010 +0200
1.2 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000
1.3 @@ -1,270 +0,0 @@
1.4 -/*
1.5 - * SONEWS News Server
1.6 - * see AUTHORS for the list of contributors
1.7 - *
1.8 - * This program is free software: you can redistribute it and/or modify
1.9 - * it under the terms of the GNU General Public License as published by
1.10 - * the Free Software Foundation, either version 3 of the License, or
1.11 - * (at your option) any later version.
1.12 - *
1.13 - * This program is distributed in the hope that it will be useful,
1.14 - * but WITHOUT ANY WARRANTY; without even the implied warranty of
1.15 - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
1.16 - * GNU General Public License for more details.
1.17 - *
1.18 - * You should have received a copy of the GNU General Public License
1.19 - * along with this program. If not, see <http://www.gnu.org/licenses/>.
1.20 - */
1.21 -
1.22 -package org.sonews.daemon.command;
1.23 -
1.24 -import java.io.IOException;
1.25 -import java.net.InetSocketAddress;
1.26 -import java.util.List;
1.27 -import org.sonews.config.Config;
1.28 -import org.sonews.daemon.NNTPConnection;
1.29 -import org.sonews.storage.StorageBackendException;
1.30 -import org.sonews.storage.StorageManager;
1.31 -import org.sonews.feed.FeedManager;
1.32 -import org.sonews.feed.Subscription;
1.33 -import org.sonews.storage.Channel;
1.34 -import org.sonews.storage.Group;
1.35 -import org.sonews.util.Stats;
1.36 -
1.37 -/**
1.38 - * The XDAEMON command allows a client to get/set properties of the
1.39 - * running server daemon. Only locally connected clients are allowed to
1.40 - * use this command.
1.41 - * The restriction to localhost connection can be suppressed by overriding
1.42 - * the sonews.xdaemon.host bootstrap config property.
1.43 - * @author Christian Lins
1.44 - * @since sonews/0.5.0
1.45 - */
1.46 -public class XDaemonCommand implements Command
1.47 -{
1.48 -
1.49 - @Override
1.50 - public String[] getSupportedCommandStrings()
1.51 - {
1.52 - return new String[]{"XDAEMON"};
1.53 - }
1.54 -
1.55 - @Override
1.56 - public boolean hasFinished()
1.57 - {
1.58 - return true;
1.59 - }
1.60 -
1.61 - @Override
1.62 - public String impliedCapability()
1.63 - {
1.64 - return null;
1.65 - }
1.66 -
1.67 - @Override
1.68 - public boolean isStateful()
1.69 - {
1.70 - return false;
1.71 - }
1.72 -
1.73 - private void channelAdd(String[] commands, NNTPConnection conn)
1.74 - throws IOException, StorageBackendException
1.75 - {
1.76 - String groupName = commands[2];
1.77 - if(StorageManager.current().isGroupExisting(groupName))
1.78 - {
1.79 - conn.println("400 group " + groupName + " already existing!");
1.80 - }
1.81 - else
1.82 - {
1.83 - StorageManager.current().addGroup(groupName, Integer.parseInt(commands[3]));
1.84 - conn.println("200 group " + groupName + " created");
1.85 - }
1.86 - }
1.87 -
1.88 - // TODO: Refactor this method to reduce complexity!
1.89 - @Override
1.90 - public void processLine(NNTPConnection conn, String line, byte[] raw)
1.91 - throws IOException, StorageBackendException
1.92 - {
1.93 - InetSocketAddress addr = (InetSocketAddress)conn.getSocketChannel().socket()
1.94 - .getRemoteSocketAddress();
1.95 - if(addr.getHostName().equals(
1.96 - Config.inst().get(Config.XDAEMON_HOST, "localhost")))
1.97 - {
1.98 - String[] commands = line.split(" ", 4);
1.99 - if(commands.length == 3 && commands[1].equalsIgnoreCase("LIST"))
1.100 - {
1.101 - if(commands[2].equalsIgnoreCase("CONFIGKEYS"))
1.102 - {
1.103 - conn.println("100 list of available config keys follows");
1.104 - for(String key : Config.AVAILABLE_KEYS)
1.105 - {
1.106 - conn.println(key);
1.107 - }
1.108 - conn.println(".");
1.109 - }
1.110 - else if(commands[2].equalsIgnoreCase("PEERINGRULES"))
1.111 - {
1.112 - List<Subscription> pull =
1.113 - StorageManager.current().getSubscriptions(FeedManager.TYPE_PULL);
1.114 - List<Subscription> push =
1.115 - StorageManager.current().getSubscriptions(FeedManager.TYPE_PUSH);
1.116 - conn.println("100 list of peering rules follows");
1.117 - for(Subscription sub : pull)
1.118 - {
1.119 - conn.println("PULL " + sub.getHost() + ":" + sub.getPort()
1.120 - + " " + sub.getGroup());
1.121 - }
1.122 - for(Subscription sub : push)
1.123 - {
1.124 - conn.println("PUSH " + sub.getHost() + ":" + sub.getPort()
1.125 - + " " + sub.getGroup());
1.126 - }
1.127 - conn.println(".");
1.128 - }
1.129 - else
1.130 - {
1.131 - conn.println("401 unknown sub command");
1.132 - }
1.133 - }
1.134 - else if(commands.length == 3 && commands[1].equalsIgnoreCase("DELETE"))
1.135 - {
1.136 - StorageManager.current().delete(commands[2]);
1.137 - conn.println("200 article " + commands[2] + " deleted");
1.138 - }
1.139 - else if(commands.length == 4 && commands[1].equalsIgnoreCase("GROUPADD"))
1.140 - {
1.141 - channelAdd(commands, conn);
1.142 - }
1.143 - else if(commands.length == 3 && commands[1].equalsIgnoreCase("GROUPDEL"))
1.144 - {
1.145 - Group group = StorageManager.current().getGroup(commands[2]);
1.146 - if(group == null)
1.147 - {
1.148 - conn.println("400 group not found");
1.149 - }
1.150 - else
1.151 - {
1.152 - group.setFlag(Group.DELETED);
1.153 - group.update();
1.154 - conn.println("200 group " + commands[2] + " marked as deleted");
1.155 - }
1.156 - }
1.157 - else if(commands.length == 4 && commands[1].equalsIgnoreCase("SET"))
1.158 - {
1.159 - String key = commands[2];
1.160 - String val = commands[3];
1.161 - Config.inst().set(key, val);
1.162 - conn.println("200 new config value set");
1.163 - }
1.164 - else if(commands.length == 3 && commands[1].equalsIgnoreCase("GET"))
1.165 - {
1.166 - String key = commands[2];
1.167 - String val = Config.inst().get(key, null);
1.168 - if(val != null)
1.169 - {
1.170 - conn.println("100 config value for " + key + " follows");
1.171 - conn.println(val);
1.172 - conn.println(".");
1.173 - }
1.174 - else
1.175 - {
1.176 - conn.println("400 config value not set");
1.177 - }
1.178 - }
1.179 - else if(commands.length >= 3 && commands[1].equalsIgnoreCase("LOG"))
1.180 - {
1.181 - Group group = null;
1.182 - if(commands.length > 3)
1.183 - {
1.184 - group = (Group)Channel.getByName(commands[3]);
1.185 - }
1.186 -
1.187 - if(commands[2].equalsIgnoreCase("CONNECTED_CLIENTS"))
1.188 - {
1.189 - conn.println("100 number of connections follow");
1.190 - conn.println(Integer.toString(Stats.getInstance().connectedClients()));
1.191 - conn.println(".");
1.192 - }
1.193 - else if(commands[2].equalsIgnoreCase("POSTED_NEWS"))
1.194 - {
1.195 - conn.println("100 hourly numbers of posted news yesterday");
1.196 - for(int n = 0; n < 24; n++)
1.197 - {
1.198 - conn.println(n + " " + Stats.getInstance()
1.199 - .getYesterdaysEvents(Stats.POSTED_NEWS, n, group));
1.200 - }
1.201 - conn.println(".");
1.202 - }
1.203 - else if(commands[2].equalsIgnoreCase("GATEWAYED_NEWS"))
1.204 - {
1.205 - conn.println("100 hourly numbers of gatewayed news yesterday");
1.206 - for(int n = 0; n < 24; n++)
1.207 - {
1.208 - conn.println(n + " " + Stats.getInstance()
1.209 - .getYesterdaysEvents(Stats.GATEWAYED_NEWS, n, group));
1.210 - }
1.211 - conn.println(".");
1.212 - }
1.213 - else if(commands[2].equalsIgnoreCase("TRANSMITTED_NEWS"))
1.214 - {
1.215 - conn.println("100 hourly numbers of news transmitted to peers yesterday");
1.216 - for(int n = 0; n < 24; n++)
1.217 - {
1.218 - conn.println(n + " " + Stats.getInstance()
1.219 - .getYesterdaysEvents(Stats.FEEDED_NEWS, n, group));
1.220 - }
1.221 - conn.println(".");
1.222 - }
1.223 - else if(commands[2].equalsIgnoreCase("HOSTED_NEWS"))
1.224 - {
1.225 - conn.println("100 number of overall hosted news");
1.226 - conn.println(Integer.toString(Stats.getInstance().getNumberOfNews()));
1.227 - conn.println(".");
1.228 - }
1.229 - else if(commands[2].equalsIgnoreCase("HOSTED_GROUPS"))
1.230 - {
1.231 - conn.println("100 number of hosted groups");
1.232 - conn.println(Integer.toString(Stats.getInstance().getNumberOfGroups()));
1.233 - conn.println(".");
1.234 - }
1.235 - else if(commands[2].equalsIgnoreCase("POSTED_NEWS_PER_HOUR"))
1.236 - {
1.237 - conn.println("100 posted news per hour");
1.238 - conn.println(Double.toString(Stats.getInstance().postedPerHour(-1)));
1.239 - conn.println(".");
1.240 - }
1.241 - else if(commands[2].equalsIgnoreCase("FEEDED_NEWS_PER_HOUR"))
1.242 - {
1.243 - conn.println("100 feeded news per hour");
1.244 - conn.println(Double.toString(Stats.getInstance().feededPerHour(-1)));
1.245 - conn.println(".");
1.246 - }
1.247 - else if(commands[2].equalsIgnoreCase("GATEWAYED_NEWS_PER_HOUR"))
1.248 - {
1.249 - conn.println("100 gatewayed news per hour");
1.250 - conn.println(Double.toString(Stats.getInstance().gatewayedPerHour(-1)));
1.251 - conn.println(".");
1.252 - }
1.253 - else
1.254 - {
1.255 - conn.println("401 unknown sub command");
1.256 - }
1.257 - }
1.258 - else if(commands.length >= 3 && commands[1].equalsIgnoreCase("PLUGIN"))
1.259 - {
1.260 -
1.261 - }
1.262 - else
1.263 - {
1.264 - conn.println("400 invalid command usage");
1.265 - }
1.266 - }
1.267 - else
1.268 - {
1.269 - conn.println("501 not allowed");
1.270 - }
1.271 - }
1.272 -
1.273 -}