package electrosphere.engine.loadingthreads; import java.io.IOException; import java.io.PipedInputStream; import java.io.PipedOutputStream; import java.util.List; import java.util.Random; import org.joml.Vector3d; import org.joml.Vector3f; import org.joml.Vector3i; import electrosphere.auth.AuthenticationManager; import electrosphere.engine.Globals; import electrosphere.engine.threads.LabeledThread.ThreadLabel; import electrosphere.entity.types.creature.CreatureTemplate; import electrosphere.entity.types.creature.CreatureToolbarData.ToolbarItem; import electrosphere.game.data.creature.type.CreatureData; import electrosphere.game.data.creature.type.visualattribute.VisualAttribute; import electrosphere.logger.LoggerInterface; import electrosphere.net.NetUtils; import electrosphere.net.client.ClientNetworking; import electrosphere.net.parser.net.message.CharacterMessage; import electrosphere.net.server.Server; import electrosphere.net.server.ServerConnectionHandler; import electrosphere.net.server.player.Player; import electrosphere.server.datacell.Realm; import electrosphere.server.simulation.MicroSimulation; /** * Utilities for all loading thread types */ public class LoadingUtils { /** * The size of the buffer */ static final int STREAM_BUFFER_SIZE = 16 * 1024 * 1024; /** * The name of the editor race */ public static final String EDITOR_RACE_NAME = "editor"; static void initServerThread(){ //start server networking if(Globals.RUN_SERVER){ Globals.server = new Server(NetUtils.getPort()); Thread serverThread = new Thread(Globals.server); Globals.threadManager.start(ThreadLabel.NETWORKING_SERVER, serverThread); } } /** * Initializes the authentication manager * @param mock true if it should make a mock authentication manager, false for a real auth manager */ static void initAuthenticationManager(boolean mock){ if(Globals.RUN_SERVER){ Globals.authenticationManager = AuthenticationManager.create(mock); } } static void initClientThread(){ //start client networking if(Globals.RUN_CLIENT){ Globals.clientConnection = new ClientNetworking(NetUtils.getAddress(),NetUtils.getPort()); Globals.threadManager.start(ThreadLabel.NETWORKING_CLIENT, new Thread(Globals.clientConnection)); } } /** * Initializes a local connection * @param runServerThread true if should run the server in a separate thread, false otherwise * @return The server connection */ static ServerConnectionHandler initLocalConnection(boolean runServerThread){ ServerConnectionHandler rVal = null; try { if(runServerThread){ LoadingUtils.initServerThread(); } else { Globals.server = new Server(NetUtils.getPort()); } //client -> server pipe PipedInputStream clientInput = new PipedInputStream(STREAM_BUFFER_SIZE); PipedOutputStream serverOutput = new PipedOutputStream(clientInput); //server -> client pipe PipedInputStream serverInput = new PipedInputStream(STREAM_BUFFER_SIZE); PipedOutputStream clientOutput; clientOutput = new PipedOutputStream(serverInput); //start server communication thread rVal = Globals.server.addLocalPlayer(serverInput, serverOutput); //start client communication thread Globals.clientConnection = new ClientNetworking(clientInput,clientOutput); Globals.threadManager.start(ThreadLabel.NETWORKING_CLIENT, new Thread(Globals.clientConnection)); } catch (IOException e) { LoggerInterface.loggerNetworking.ERROR(e); } return rVal; } /** * Loads graphics assets necessary for the client of the game engine. This should be stuff that is used essentially universally (ie textures for debugging). */ static void initGameGraphicalEntities(){ Globals.assetManager.addTexturePathtoQueue("Textures/transparent_red.png"); Globals.assetManager.addTexturePathtoQueue("Textures/transparent_blue.png"); Globals.assetManager.addTexturePathtoQueue("Textures/transparent_grey.png"); float skyR = 100; float skyG = 150; float skyB = 200; float groundR = 50; float groundG = 100; float groundB = 150; Globals.skyboxColors.add(new Vector3f(skyR,skyG,skyB)); Globals.skyboxColors.add(new Vector3f(skyR,skyG,skyB)); Globals.skyboxColors.add(new Vector3f(groundR,groundG,groundB)); Globals.skyboxColors.add(new Vector3f(groundR,groundG,groundB)); Globals.skyboxColors.add(new Vector3f(skyR,skyG,skyB)); Globals.skyboxColors.add(new Vector3f(skyR,skyG,skyB)); Globals.skyboxColors.add(new Vector3f(groundR,groundG,groundB)); Globals.skyboxColors.add(new Vector3f(groundR,groundG,groundB)); } /** * Spawns the character, and sets server side connection player object values to the appropriate chunk */ static void spawnLocalPlayerTestEntity(ServerConnectionHandler serverPlayerConnection, boolean isEditor){ // //Create entity // //send default template back String race = EDITOR_RACE_NAME; if(!isEditor){ List races = Globals.gameConfigCurrent.getCreatureTypeLoader().getPlayableRaces(); race = races.get(new Random().nextInt(races.size())); } CreatureData type = Globals.gameConfigCurrent.getCreatureTypeLoader().getType(race); CreatureTemplate template = CreatureTemplate.create(race); for(VisualAttribute attribute : type.getVisualAttributes()){ if(attribute.getType().equals(VisualAttribute.TYPE_BONE)){ float min = attribute.getMinValue(); float max = attribute.getMaxValue(); float defaultValue = min + (max - min)/2.0f; //add attribute to creature template template.putAttributeValue(attribute.getAttributeId(), defaultValue); } else if(attribute.getType().equals(VisualAttribute.TYPE_REMESH)){ template.putAttributeValue(attribute.getAttributeId(), attribute.getVariants().get(0).getId()); } } template.getCreatureToolbarData().setSlotItem("0", new ToolbarItem(71, "terrainTool")); template.getCreatureToolbarData().setSlotItem("1", new ToolbarItem(72, "spawningPalette")); template.getCreatureToolbarData().setSlotItem("2", new ToolbarItem(73, "entityinspector")); //set player character template serverPlayerConnection.setCreatureTemplate(template); Globals.clientConnection.queueOutgoingMessage(CharacterMessage.constructRequestSpawnCharacterMessage()); //set player world-space coordinates Player playerObject = Globals.playerManager.getFirstPlayer(); Realm realm = Globals.realmManager.getRealms().iterator().next(); Vector3d spawnPoint = realm.getSpawnPoint(); playerObject.setWorldPos(new Vector3i( realm.getServerWorldData().convertRealToChunkSpace(spawnPoint.x), realm.getServerWorldData().convertRealToChunkSpace(spawnPoint.y), realm.getServerWorldData().convertRealToChunkSpace(spawnPoint.z) )); } static void initMacroSimulation(){ // Globals.macroData = MacroData.generateWorld(0); // Globals.macroData.describeWorld(); // Globals.macroSimulation = new MacroSimulation(); // Globals.macroSimulation.simulate(); // Town startTown = Globals.macroData.getTowns().get(0); // Vector2i firstPos = startTown.getPositions().get(0); // double startX = firstPos.x * Globals.serverTerrainManager.getChunkWidth(); // double startZ = firstPos.y * Globals.serverTerrainManager.getChunkWidth(); // Globals.spawnPoint.set((float)startX,(float)Globals.commonWorldData.getElevationAtPoint(new Vector3d(startX,0,startZ)),(float)startZ); // Globals.macroSimulation.setReady(true); } static void initMicroSimulation(){ if(Globals.microSimulation == null){ Globals.microSimulation = new MicroSimulation(); } } static void setSimulationsToReady(){ Globals.microSimulation.setReady(true); if(Globals.macroSimulation != null){ Globals.macroSimulation.setReady(true); } } }