/*

  *   SONEWS News Server

  *   see AUTHORS for the list of contributors

  *

  *   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 3 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, see <http://www.gnu.org/licenses/>.

  */

 package org.sonews.daemon.command;

 import java.io.IOException;

 import java.net.InetSocketAddress;

 import java.util.List;

 import org.sonews.config.Config;

 import org.sonews.daemon.NNTPConnection;

 import org.sonews.storage.StorageBackendException;

 import org.sonews.storage.StorageManager;

 import org.sonews.feed.FeedManager;

 import org.sonews.feed.Subscription;

 import org.sonews.storage.Channel;

 import org.sonews.storage.Group;

 import org.sonews.util.Stats;

 /**

  * The XDAEMON command allows a client to get/set properties of the

  * running server daemon. Only locally connected clients are allowed to

  * use this command.

  * The restriction to localhost connection can be suppressed by overriding

  * the sonews.xdaemon.host bootstrap config property.

  * @author Christian Lins

  * @since sonews/0.5.0

  */

 public class XDaemonCommand implements Command

 {

 	@Override

 	public String[] getSupportedCommandStrings()

 	{

 		return new String[] {"XDAEMON"};

 	}

 	@Override

 	public boolean hasFinished()

 	{

 		return true;

 	}

 	@Override

 	public String impliedCapability()

 	{

 		return null;

 	}

 	@Override

 	public boolean isStateful()

 	{

 		return false;

 	}

 	private void channelAdd(String[] commands, NNTPConnection conn)

 		throws IOException, StorageBackendException

 	{

 		String groupName = commands[2];

 		if (StorageManager.current().isGroupExisting(groupName)) {

 			conn.println("400 group " + groupName + " already existing!");

 		} else {

 			StorageManager.current().addGroup(groupName, Integer.parseInt(commands[3]));

 			conn.println("200 group " + groupName + " created");

 		}

 	}

 	// TODO: Refactor this method to reduce complexity!

 	@Override

 	public void processLine(NNTPConnection conn, String line, byte[] raw)

 		throws IOException, StorageBackendException

 	{

 		InetSocketAddress addr = (InetSocketAddress) conn.getSocketChannel().socket().getRemoteSocketAddress();

 		if (addr.getHostName().equals(

 			Config.inst().get(Config.XDAEMON_HOST, "localhost"))) {

 			String[] commands = line.split(" ", 4);

 			if (commands.length == 3 && commands[1].equalsIgnoreCase("LIST")) {

 				if (commands[2].equalsIgnoreCase("CONFIGKEYS")) {

 					conn.println("100 list of available config keys follows");

 					for (String key : Config.AVAILABLE_KEYS) {

 						conn.println(key);

 					}

 					conn.println(".");

 				} else if (commands[2].equalsIgnoreCase("PEERINGRULES")) {

 					List<Subscription> pull =

 						StorageManager.current().getSubscriptions(FeedManager.TYPE_PULL);

 					List<Subscription> push =

 						StorageManager.current().getSubscriptions(FeedManager.TYPE_PUSH);

 					conn.println("100 list of peering rules follows");

 					for (Subscription sub : pull) {

 						conn.println("PULL " + sub.getHost() + ":" + sub.getPort()

 							+ " " + sub.getGroup());

 					}

 					for (Subscription sub : push) {

 						conn.println("PUSH " + sub.getHost() + ":" + sub.getPort()

 							+ " " + sub.getGroup());

 					}

 					conn.println(".");

 				} else {

 					conn.println("401 unknown sub command");

 				}

 			} else if (commands.length == 3 && commands[1].equalsIgnoreCase("DELETE")) {

 				StorageManager.current().delete(commands[2]);

 				conn.println("200 article " + commands[2] + " deleted");

 			} else if (commands.length == 4 && commands[1].equalsIgnoreCase("GROUPADD")) {

 				channelAdd(commands, conn);

 			} else if (commands.length == 3 && commands[1].equalsIgnoreCase("GROUPDEL")) {

 				Group group = StorageManager.current().getGroup(commands[2]);

 				if (group == null) {

 					conn.println("400 group not found");

 				} else {

 					group.setFlag(Group.DELETED);

 					group.update();

 					conn.println("200 group " + commands[2] + " marked as deleted");

 				}

 			} else if (commands.length == 4 && commands[1].equalsIgnoreCase("SET")) {

 				String key = commands[2];

 				String val = commands[3];

 				Config.inst().set(key, val);

 				conn.println("200 new config value set");

 			} else if (commands.length == 3 && commands[1].equalsIgnoreCase("GET")) {

 				String key = commands[2];

 				String val = Config.inst().get(key, null);

 				if (val != null) {

 					conn.println("100 config value for " + key + " follows");

 					conn.println(val);

 					conn.println(".");

 				} else {

 					conn.println("400 config value not set");

 				}

 			} else if (commands.length >= 3 && commands[1].equalsIgnoreCase("LOG")) {

 				Group group = null;

 				if (commands.length > 3) {

 					group = (Group) Channel.getByName(commands[3]);

 				}

 				if (commands[2].equalsIgnoreCase("CONNECTED_CLIENTS")) {

 					conn.println("100 number of connections follow");

 					conn.println(Integer.toString(Stats.getInstance().connectedClients()));

 					conn.println(".");

 				} else if (commands[2].equalsIgnoreCase("POSTED_NEWS")) {

 					conn.println("100 hourly numbers of posted news yesterday");

 					for (int n = 0; n < 24; n++) {

 						conn.println(n + " " + Stats.getInstance().getYesterdaysEvents(Stats.POSTED_NEWS, n, group));

 					}

 					conn.println(".");

 				} else if (commands[2].equalsIgnoreCase("GATEWAYED_NEWS")) {

 					conn.println("100 hourly numbers of gatewayed news yesterday");

 					for (int n = 0; n < 24; n++) {

 						conn.println(n + " " + Stats.getInstance().getYesterdaysEvents(Stats.GATEWAYED_NEWS, n, group));

 					}

 					conn.println(".");

 				} else if (commands[2].equalsIgnoreCase("TRANSMITTED_NEWS")) {

 					conn.println("100 hourly numbers of news transmitted to peers yesterday");

 					for (int n = 0; n < 24; n++) {

 						conn.println(n + " " + Stats.getInstance().getYesterdaysEvents(Stats.FEEDED_NEWS, n, group));

 					}

 					conn.println(".");

 				} else if (commands[2].equalsIgnoreCase("HOSTED_NEWS")) {

 					conn.println("100 number of overall hosted news");

 					conn.println(Integer.toString(Stats.getInstance().getNumberOfNews()));

 					conn.println(".");

 				} else if (commands[2].equalsIgnoreCase("HOSTED_GROUPS")) {

 					conn.println("100 number of hosted groups");

 					conn.println(Integer.toString(Stats.getInstance().getNumberOfGroups()));

 					conn.println(".");

 				} else if (commands[2].equalsIgnoreCase("POSTED_NEWS_PER_HOUR")) {

 					conn.println("100 posted news per hour");

 					conn.println(Double.toString(Stats.getInstance().postedPerHour(-1)));

 					conn.println(".");

 				} else if (commands[2].equalsIgnoreCase("FEEDED_NEWS_PER_HOUR")) {

 					conn.println("100 feeded news per hour");

 					conn.println(Double.toString(Stats.getInstance().feededPerHour(-1)));

 					conn.println(".");

 				} else if (commands[2].equalsIgnoreCase("GATEWAYED_NEWS_PER_HOUR")) {

 					conn.println("100 gatewayed news per hour");

 					conn.println(Double.toString(Stats.getInstance().gatewayedPerHour(-1)));

 					conn.println(".");

 				} else {

 					conn.println("401 unknown sub command");

 				}

 			} else if (commands.length >= 3 && commands[1].equalsIgnoreCase("PLUGIN")) {

 			} else {

 				conn.println("400 invalid command usage");

 			}

 		} else {

 			conn.println("501 not allowed");

 		}

 	}

 }