Added initial version

Management-Server/src/main/java/ms/classloader/WorkerThread.java

@@ -0,0 +1,136 @@
+package ms.classloader;
+
+import java.io.BufferedInputStream;
+import java.io.BufferedOutputStream;
+import java.io.IOException;
+import java.io.ObjectInputStream;
+import java.io.ObjectOutputStream;
+import java.net.Socket;
+import java.util.Map;
+
+import ms.ServerConstants;
+import ms.system.OperatingSystem;
+
+/**
+ * Worker thread for launcher connections
+ * @author Clayton Williams (Hope)
+ *
+ */
+public class WorkerThread extends Thread {
+
+	/**
+	 * Our launcher connection
+	 */
+	private Socket launcher = null;
+    
+    /**
+     * Input stream from launcher
+     */
+    private ObjectInputStream is = null;
+    
+    /**
+     * Output stream to launcher
+     */
+    private ObjectOutputStream os = null;
+
+    /**
+     * The user's operating system type
+     */
+    private OperatingSystem operatingSystem = OperatingSystem.WINDOWS;
+
+    /**
+     * Creates a new worker thread to handle the launcher requests
+     * @param socket
+     * @param classesCache
+     * @throws IOException
+     */
+    public WorkerThread(Socket launcher)  throws IOException {
+        super();
+        this.launcher = launcher;
+        try {
+            os = new ObjectOutputStream(new BufferedOutputStream(this.launcher.getOutputStream()));
+            os.flush();
+            is = new ObjectInputStream(new BufferedInputStream(launcher.getInputStream()));
+        } catch (IOException ioe) {
+            this.launcher.close();
+        }
+    }
+
+   /**
+    * Input Stream handler
+    */
+    @SuppressWarnings("unused") //saving resource type for later
+	public void run() {
+        byte opcode = -1;
+        try {
+            while (true) {
+                opcode = is.readByte();
+                switch(opcode) {
+	                case 1: //requests revision
+	                	operatingSystem = is.readUTF().contains("UNIX") ? OperatingSystem.UNIX : OperatingSystem.WINDOWS;
+	                	os.reset();	                	
+	                	os.writeInt(ClassLoadServer.resourceCache.size());//#customresources
+	                	for (Map.Entry<String, byte[]> hm : ClassLoadServer.resourceCache.entrySet()) {
+	                		os.writeUTF(ServerConstants.fixPath(operatingSystem, (String) hm.getKey()));
+	                		os.writeInt(hm.getValue().length);
+	                	}
+	                	os.writeByte(1); //number of custom resources
+	                	//followed by 2 strings
+	                	//System.err.println(operatingSystem.name());
+	                	os.writeUTF(ServerConstants.fixPath(operatingSystem, "ms/launcher/arios-gamepack-530.jar"));
+	                	os.writeUTF("BINARY");
+	                	os.flush();
+	                	break;
+                	case 2: //resource request              		
+                		String resourceName = ServerConstants.fixPath(null, is.readUTF());
+                		String resourceType = is.readUTF();             		
+                		if (ClassLoadServer.resourceCache.containsKey(resourceName)) {
+                			sendResource(ClassLoadServer.resourceCache.get(resourceName));
+                			//System.out.println("Sent Resource: " + resourceName);
+                		} else {
+                			sendOpcode(-1);
+                			//System.out.println("Could not send resource '" + resourceName + "'");
+                		}	                	
+                		break;
+                	default:
+                		System.out.println("Unhandled opcode=" + opcode);
+                		break;
+                }  
+            }
+        } catch(Exception e) {
+        	//System.out.println("Client force disconnect.");
+		} finally {
+            try {
+                is.close();
+                os.close();
+                launcher.close();
+            } catch (Exception e) {}
+        }
+    }
+
+	/**
+	 * send a byte array packet to the client
+	 * @exception   IOException file read error.
+	 */
+    protected void sendResource(byte [] bytes) throws IOException {
+       os.reset();
+       os.writeByte(2);
+       os.writeInt(bytes.length);
+       for (int i = 0; i < bytes.length; i++) {
+    	   os.writeByte(bytes[i]);
+       }
+       os.flush();
+    }
+    
+    /**
+     * Send no data opcodes
+     * @param opcode
+     * @throws IOException
+     */
+    protected void sendOpcode(int opcode) throws IOException {
+    	os.reset();
+    	os.writeByte(opcode);
+    	os.flush();
+    }
+
+}