Arakne / Araknemu

 * This file is part of Araknemu.

 *

 * Araknemu is free software: you can redistribute it and/or modify

 * it under the terms of the GNU Lesser General Public License as published by

 * the Free Software Foundation, either version 3 of the License, or

 * (at your option) any later version.

 *

 * Araknemu 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 Lesser General Public License for more details.

 *

 * You should have received a copy of the GNU Lesser General Public License

 * along with Araknemu.  If not, see <https://www.gnu.org/licenses/>.

 *

 * Copyright (c) 2017-2020 Vincent Quatrevieux

 */

package fr.quatrevieux.araknemu;

import fr.quatrevieux.araknemu.core.BootException;

import fr.quatrevieux.araknemu.core.Service;

import fr.quatrevieux.araknemu.core.config.Configuration;

import fr.quatrevieux.araknemu.core.config.ConfigurationLoader;

import fr.quatrevieux.araknemu.core.dbal.DatabaseConfiguration;

import fr.quatrevieux.araknemu.core.dbal.DatabaseHandler;

import fr.quatrevieux.araknemu.core.dbal.DefaultDatabaseHandler;

import fr.quatrevieux.araknemu.core.di.Container;

import fr.quatrevieux.araknemu.core.di.ItemPoolContainer;

import fr.quatrevieux.araknemu.data.living.repository.implementation.sql.SqlLivingRepositoriesModule;

import fr.quatrevieux.araknemu.data.world.repository.implementation.sql.SqlWorldRepositoriesModule;

import fr.quatrevieux.araknemu.game.GameModule;

import fr.quatrevieux.araknemu.game.GameService;

import fr.quatrevieux.araknemu.game.admin.AdminModule;

import fr.quatrevieux.araknemu.game.connector.LocalModule;

import fr.quatrevieux.araknemu.realm.RealmModule;

import fr.quatrevieux.araknemu.realm.RealmService;

import org.apache.logging.log4j.LogManager;

import org.apache.logging.log4j.Logger;

import org.checkerframework.checker.nullness.qual.EnsuresNonNull;

import org.checkerframework.checker.nullness.qual.MonotonicNonNull;

import org.checkerframework.checker.nullness.qual.Nullable;

import java.sql.SQLException;

import java.time.Instant;

import java.util.ArrayList;

import java.util.List;

/**

 * Startup class

 */

public class Araknemu {

    /**

     * Get the current version of the server (retrieved from pom.xml)

     */

    public static final @Nullable String VERSION = Araknemu.class.getPackage() != null ? Araknemu.class.getPackage().getImplementationVersion() : null;

    public static final String NAME = "Araknemu";

    public static final String YEAR = "2017-2021";

    public static final String AUTHOR = "Vincent Quatrevieux";

    private final Logger logger = LogManager.getLogger(getClass());

    private final Configuration configuration;

    private final DatabaseHandler database;

    private final List<Service> services = new ArrayList<>();

    private boolean started = false;

    private @MonotonicNonNull Instant startDate;

    public Araknemu(Configuration configuration, DatabaseHandler database) {

        this.configuration = configuration;

        this.database = database;

    }

    /**

     * Boot all services

     */

    @EnsuresNonNull("startDate")

    public void boot() throws BootException {

        System.out.println(NAME + " Copyright (c) " + YEAR + " " + AUTHOR);

        System.out.println("This program comes with ABSOLUTELY NO WARRANTY.");

        System.out.println("This is free software, and you are welcome to redistribute it under certain conditions.");

        logger.info("Starting {} v{}", NAME, VERSION != null ? VERSION : "DEV");

        logger.info("Booting services");

        for (Service service : services) {

            service.boot();

        }

        logger.info("Running garbage collector");

        started = true;

        startDate = Instant.now();

        logger.info("Araknemu started");

    }

    /**

     * Stop all services

     */

    public void shutdown() {

        if (!started) {

            return;

        }

        logger.info("Shutdown requested...");

        started = false;

        for (Service service : services) {

            service.shutdown();

        }

        services.clear();

        database.stop();

        logger.info("Araknemu successfully stopped");

    }

    /**

     * Add a new service

     */

    public void add(Service service) {

        services.add(service);

    }

    /**

     * Get the application configuration

     */

    public Configuration configuration() {

        return configuration;

    }

    /**

     * Get the database handler

     */

    public DatabaseHandler database() {

        return database;

    }

    /**

     * Check if the server is started

     */

    public boolean started() {

        return started;

    }

    /**

     * Get the server start date

     */

    public Instant startDate() {

        if (startDate == null) {

            throw new IllegalStateException("Server not started");

        }

        return startDate;

    }

    /**

     * Application entry point

     */

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

        final ConfigurationLoader configurationLoader = new ConfigurationLoader();

        if (args.length > 0) {

            configurationLoader.configFileName(args[0]);

        }

        final Configuration configuration = configurationLoader.load();

        final Araknemu app = new Araknemu(

            configuration,

            new DefaultDatabaseHandler(

                configuration.module(DatabaseConfiguration.MODULE),

                LogManager.getLogger(DatabaseHandler.class)

            )

        );

        final Container realmContainer = makeRealmContainer(app);

        final Container gameContainer  = makeGameContainer(app, realmContainer);

        app.add(realmContainer.get(RealmService.class));

        app.add(gameContainer.get(GameService.class));

        app.boot();

        Runtime.getRuntime().addShutdownHook(new Thread(app::shutdown));

    }

    private static Container makeRealmContainer(Araknemu app) throws SQLException {

        final Container container = new ItemPoolContainer();

        container.register(new SqlLivingRepositoriesModule(

            app.database().get("realm")

        ));

        container.register(new RealmModule(app));

        return container;

    }

}