/*

  *   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;

 import java.sql.Driver;

 import java.sql.DriverManager;

 import java.util.Enumeration;

 import java.util.Date;

 import java.util.logging.Level;

 import org.sonews.config.Config;

 import org.sonews.daemon.ChannelLineBuffers;

 import org.sonews.daemon.CommandSelector;

 import org.sonews.daemon.Connections;

 import org.sonews.daemon.NNTPDaemon;

 import org.sonews.feed.FeedManager;

 import org.sonews.mlgw.MailPoller;

 import org.sonews.storage.StorageBackendException;

 import org.sonews.storage.StorageManager;

 import org.sonews.storage.StorageProvider;

 import org.sonews.util.Log;

 import org.sonews.util.Purger;

 import org.sonews.util.io.Resource;

 /**

  * Startup class of the daemon.

  * @author Christian Lins

  * @since sonews/0.5.0

  */

 public final class Main {

 	/** Version information of the sonews daemon */

 	public static final String VERSION = "sonews/1.1.0~Drupal";

 	/** The server's startup date */

 	public static final Date STARTDATE = new Date();

 	/**

 	 * The main entrypoint.

 	 * @param args

 	 * @throws Exception

 	 */

 	public static void main(String[] args) throws Exception {

 		System.out.println(VERSION);

 		Thread.currentThread().setName("Mainthread");

 		// Command line arguments

 		boolean feed = false;  // Enable feeding?

 		boolean mlgw = false;  // Enable Mailinglist gateway?

 		int port = -1;

 		for (int n = 0; n < args.length; n++) {

 			if (args[n].equals("-c") || args[n].equals("-config")) {

 				Config.inst().set(Config.LEVEL_CLI, Config.CONFIGFILE, args[++n]);

 				System.out.println("Using config file " + args[n]);

 			} else if (args[n].equals("-dumpjdbcdriver")) {

 				System.out.println("Available JDBC drivers:");

 				Enumeration<Driver> drvs = DriverManager.getDrivers();

 				while (drvs.hasMoreElements()) {

 					System.out.println(drvs.nextElement());

 				}

 				return;

 			} else if (args[n].equals("-feed")) {

 				feed = true;

 			} else if (args[n].equals("-h") || args[n].equals("-help")) {

 				printArguments();

 				return;

 			} else if (args[n].equals("-mlgw")) {

 				mlgw = true;

 			} else if (args[n].equals("-p")) {

 				port = Integer.parseInt(args[++n]);

 			} else if (args[n].equals("-plugin-storage")) {

 				System.out.println("Warning: -plugin-storage is not implemented!");

 			} else if (args[n].equals("-plugin-command")) {

 				try {

 					CommandSelector.addCommandHandler(args[++n]);

 				} catch (Exception ex) {

 					StringBuilder strBuf = new StringBuilder();

 					strBuf.append("Could not load command plugin: ");

 					strBuf.append(args[n]);

 					Log.get().warning(strBuf.toString());

 					Log.get().log(Level.INFO, "Main.java", ex);

 				}

 			} else if (args[n].equals("-plugin-storage")) {

 				System.out.println("Warning: -plugin-storage is not implemented!");

 			} else if (args[n].equals("-v") || args[n].equals("-version")) {

 				// Simply return as the version info is already printed above

 				return;

 			}

 		}

 		// Try to load the JDBCDatabase;

 		// Do NOT USE BackendConfig or Log classes before this point because they require

 		// a working JDBCDatabase connection.

 		try {

 			String provName = Config.inst().get(Config.LEVEL_FILE,

 					Config.STORAGE_PROVIDER, "org.sonews.storage.impl.JDBCDatabaseProvider");

 			StorageProvider sprov = StorageManager.loadProvider(provName);

 			StorageManager.enableProvider(sprov);

 			// Make sure some elementary groups are existing

 			if (!StorageManager.current().isGroupExisting("control")) {

 				StorageManager.current().addGroup("control", 0);

 				Log.get().info("Group 'control' created.");

 			}

 		} catch (StorageBackendException ex) {

 			Log.get().log(Level.SEVERE, ex.getLocalizedMessage(), ex);

 			System.err.println("Database initialization failed with " + ex.toString());

 			System.err.println("Make sure you have specified the correct database"

 							+ " settings in sonews.conf!");

 			return;

 		}

 		ChannelLineBuffers.allocateDirect();

 		// Add shutdown hook

 		Runtime.getRuntime().addShutdownHook(new ShutdownHook());

 		// Start the listening daemon

 		if (port <= 0) {

 			port = Config.inst().get(Config.PORT, 119);

 		}

 		final NNTPDaemon daemon = NNTPDaemon.createInstance(port);

 		daemon.start();

 		// Start Connections purger thread...

 		Connections.getInstance().start();

 		// Start mailinglist gateway...

 		if (mlgw) {

 			new MailPoller().start();

 		}

 		// Start feeds

 		if (feed) {

 			FeedManager.startFeeding();

 		}

 		Purger purger = new Purger();

 		purger.start();

 		// Wait for main thread to exit (setDaemon(false))

 		daemon.join();

 	}

 	private static void printArguments() {

 		String usage = Resource.getAsString("helpers/usage", true);

 		System.out.println(usage);

 	}

 	private Main() {

 	}

 }