/*

 *   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 org.sonews.config.Config;

import org.sonews.daemon.ChannelLineBuffers;

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

{

  private Main()

  {

  }

  /** Version information of the sonews daemon */

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

  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("-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

    {

      StorageProvider sprov =

        StorageManager.loadProvider("org.sonews.storage.impl.JDBCDatabaseProvider");

      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)

    {

      ex.printStackTrace();

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

  }

}