package nl.tudelft.simulation.dsol.naming.demo;

import java.io.IOException;
import java.rmi.RemoteException;
import java.util.Collections;
import java.util.Properties;
import java.util.Scanner;

import javax.naming.NamingException;

import nl.tudelft.simulation.naming.context.ContextInterface;
import nl.tudelft.simulation.naming.context.InitialEventContext;

/**
 * DemoServer sets up a context with a few items and subcontexts to which a DemoClient can subscribe.
 * <p>
 * Copyright (c) 2020-2020 Delft University of Technology, Jaffalaan 5, 2628 BX Delft, the Netherlands. All rights reserved. See
 * for project information <a href="https://simulation.tudelft.nl/" target="_blank"> https://simulation.tudelft.nl</a>. The DSOL
 * project is distributed under a three-clause BSD-style license, which can be found at
 * <a href="https://simulation.tudelft.nl/dsol/3.0/license.html" target="_blank">
 * https://simulation.tudelft.nl/dsol/3.0/license.html</a>.
 * </p>
 * @author <a href="https://www.tudelft.nl/averbraeck" target="_blank">Alexander Verbraeck</a>
 */
public class DemoServer
{
    /**
     * @param args empty
     * @throws NamingException on context error
     * @throws IOException on error reading from stdin
     */
    public static void main(final String[] args) throws NamingException, IOException
    {
        Properties properties = new Properties();
        properties.put("java.naming.factory.initial", "nl.tudelft.simulation.naming.context.RemoteContextFactory");
        properties.put("java.naming.provider.url", "http://localhost:1099/remoteContext");
        properties.put("wrapped.naming.factory.initial", "nl.tudelft.simulation.naming.context.JVMContextFactory");
        InitialEventContext remoteContext = InitialEventContext.instantiate(properties);
        remoteContext.bind("key1", "string1");
        remoteContext.bind("key2", "string2");
        remoteContext.bind("key3", "string3");
        ContextInterface level1 = remoteContext.createSubcontext("level1");
        level1.bind("key11", "string11");
        level1.bind("key12", "string12");
        level1.bind("key13", "string13");

        // create a small interactive application
        char c = 'n';
        Scanner s = new Scanner(System.in);
        while (c != 'x')
        {
            System.out.println(
                    "\nCommands: 'x' = exit; 'l' - list; 'a key value' = add key; 'm name' = make ctx; 'd key' = delete key");
            String str = s.nextLine();
            c = str.charAt(0);

            if (c == 'a')
            {
                String[] cmd = str.split(" ");
                if (cmd.length != 3)
                {
                    System.err.println("not a legal command");
                    continue;
                }
                try
                {
                    remoteContext.rebind(cmd[1], cmd[2]);
                    continue;
                }
                catch (NamingException e)
                {
                    System.err.println(e.getMessage());
                    continue;
                }
            }

            if (c == 'x')
            {
                continue;
            }

            if (c == 'd')
            {
                String[] cmd = str.split(" ");
                if (cmd.length != 2)
                {
                    System.err.println("not a legal command");
                    continue;
                }
                try
                {
                    remoteContext.unbind(cmd[1]);
                    continue;
                }
                catch (NamingException e)
                {
                    System.err.println(e.getMessage());
                    continue;
                }
            }

            if (c == 'm')
            {
                String[] cmd = str.split(" ");
                if (cmd.length != 2)
                {
                    System.err.println("not a legal command");
                    continue;
                }
                try
                {
                    remoteContext.createSubcontext(cmd[1]);
                    continue;
                }
                catch (NamingException e)
                {
                    System.err.println(e.getMessage());
                    continue;
                }
            }

            if (c == 'l')
            {
                print(remoteContext, 0);
            }
        }
        s.close();
        System.exit(0);
    }

    /**
     * recursively print the context to stdout.
     * @param ctx the context to print
     * @param indent the indentation on the screen
     */
    public static void print(final ContextInterface ctx, final int indent)
    {
        try
        {
            System.out.println(String.join("", Collections.nCopies(indent, " ")) + "CTX " + ctx.getAtomicName());
            for (String key : ctx.keySet())
            {
                Object obj = ctx.getObject(key);
                if (obj instanceof ContextInterface)
                {
                    print((ContextInterface) obj, indent + 2);
                }
                else
                {
                    System.out.println(String.join("", Collections.nCopies(indent + 2, " ")) + key + "=" + obj);
                }
            }
        }
        catch (NamingException | RemoteException exception)
        {
            System.err.println("ERR " + exception.getMessage());
        }
    }
}