SocketSystem.java

package de.Panakotta00.BedWars;

import java.io.BufferedReader;
import java.io.File;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;

import org.bukkit.configuration.file.YamlConfiguration;

import de.Panakotta00.BedWars.Arena.ArenaTemplate;

public class SocketSystem implements Runnable {
    BedWars main;

    Thread thread;
    boolean loop;
    ServerSocket socket;
    Socket lobby;
    Socket bungee;

    int port;

    public SocketSystem(BedWars main, int port, String bungeehost, int bungeeport) {
        this.main = main;

        this.port = port;

        try {
            socket = new ServerSocket(port, 0, InetAddress.getByName(null));;
            thread = new Thread(this);
            thread.start();
            System.out.println("ServerSocket auf Port " + port + " und IP " + socket.getInetAddress() + " gestartet!");
        } catch (IOException e) {
            e.printStackTrace();
        }
        try {
            bungee = new Socket("localhost", bungeeport);

            PrintStream out = new PrintStream(bungee.getOutputStream());

            out.println("arena");

            out.flush();

            System.out.println("BungeeSocket gestartet!");
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    @Override
    public void run() {
        while (loop) {
            try {
                Socket socket = this.socket.accept();

                BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
                String cmd = in.readLine();

                if (cmd.equals("servercontroller")) {
                    lobby = socket;
                    main.id = Integer.valueOf(in.readLine());

                    for (String s : (String[])((Object) in.readLine())) {
                        main.arenas.put(s.intern(), loadTemplate(s.intern()));
                    }
                }

                main.nextArena();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }

        try {
            this.socket.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    @SuppressWarnings("deprecation")
    public void stop() {
        if (loop) {
            loop = false;
        }

        if (!socket.isClosed()) {
            try {
                socket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }

        if (thread.isAlive()) {
            thread.stop();
        }
    }

    private ArenaTemplate loadTemplate(String name) {
        String path = main.config.cfg.getString("World_Dictonary");
        File dir = new File(path);

        if (dir.isDirectory()) {
            for (final File world : dir.listFiles()) {
                if (world.isDirectory() && world.getName().intern() == name.intern()) {
                    try {
                        YamlConfiguration cfg = YamlConfiguration.loadConfiguration(new File(world.getAbsolutePath() + "\\Arena.enabled.yml"));
                        return new ArenaTemplate(main, world.getAbsolutePath(), world, cfg);
                    } catch (Exception e) {
                        e.printStackTrace();
                        System.out.println("[BedWars] Cant load World \"" + world.getName() + "\" to ArenaTemplate!");
                    }
                }
            }
            return null;
        } else {
            return null;
        }
    }

    public void signUpdate(int id, String[] lines) {
        try {
            PrintStream out = new PrintStream(lobby.getOutputStream());

            out.println("updateSign");
            out.println(id);
            out.println(lines[0].intern());
            out.println(lines[1].intern());
            out.println(lines[2].intern());
            out.println(lines[3].intern());

            out.flush();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}