initial import

git-svn-id: http://manut.eu/svn/yalp/trunk@1 f059d3a0-6783-47b7-97ff-1fe0bbf25129

1 files changed, 283 insertions, 0 deletions

diff --git a/src/YalpServer/InitServer.java b/src/YalpServer/InitServer.java
new file mode 100755
index 0000000..ac9d507
--- /dev/null
+++ b/src/YalpServer/InitServer.java
@@ -0,0 +1,283 @@
+/*
+ * Copyright (c) 2006 Manuel Traut and Volker Dahnke
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Common Public License v1.0
+ * which accompanies this distribution, and is available at
+ * http://www.eclipse.org/legal/cpl-v10.html
+ *
+ * Contributors: Manuel Traut and Volker Dahnke
+ *
+ */
+
+package YalpServer;
+
+import java.net.Inet4Address;
+import java.net.MalformedURLException;
+import java.net.UnknownHostException;
+
+import java.beans.XMLDecoder;
+import java.beans.XMLEncoder;
+
+import java.io.FileInputStream;
+import java.io.FileNotFoundException;
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.io.File;
+
+import java.util.ArrayList;
+import java.util.Properties;
+
+import java.security.*;
+
+import java.sql.SQLException;
+
+import org.omg.CosNaming.*;
+import org.omg.CosNaming.NamingContextPackage.*;
+import org.omg.CORBA.*;
+import org.omg.PortableServer.*;
+import org.omg.PortableServer.POA;
+
+import YalpInterfaces.*;
+
+/*
+ * Class InitServer
+ *
+ * <em>Establishes DBConnection and creates VlcStreamer waits for
+ *     further Instructions via Interfaces</em>
+ *
+ * @author Volker Dahnke / Manuel Traut
+ *
+ * @version 0.1 20-11-2005<br>
+ *
+ * @see Server
+ *
+ */
+
+public class InitServer {
+
+	private ServerSettings settings = new ServerSettings();
+	private ServerControlImpl srvCon;
+	private ServerControlInterface srv;
+	private ORB orb;
+	private String[] orbArgs;
+	private POA poa;
+	private String serverIP;
+	private ArrayList<FileBrowser> browseList;
+
+	/*
+	 *  Constructor: starts Server initialization
+	 */
+	public InitServer(String[] _orbArgs) {
+
+		loadConfig("ServerSettings.xml");
+		writeConfig("ServerSettings.xml");
+
+		this.browseList = new ArrayList<FileBrowser>();
+
+		this.orbArgs = _orbArgs; // t.b.d. read orbargs from config xml
+
+		try {
+			this.serverIP = Inet4Address.getLocalHost().getHostAddress();
+		} catch(UnknownHostException e) {
+			/* t.b.d. error handling */
+			System.out.println("couldn't resolve hostname");
+		}
+
+		/* bind ServerControl to ORB and NamingService */
+		this.orb = ORB.init(orbArgs, null);
+
+		try {
+			this.poa = POAHelper.narrow(orb.resolve_initial_references("RootPOA"));
+		} catch(org.omg.CORBA.ORBPackage.InvalidName e) {
+			/* t.b.d. error handling */
+			System.out.println("couldn't get name ref of root poa");
+		}
+
+		try {
+			poa.the_POAManager().activate();
+		} catch(org.omg.PortableServer.POAManagerPackage.AdapterInactive e) {
+			/* t.b.d. error handling */
+			System.out.println("poa inactive");
+		}
+
+		this.srvCon = new ServerControlImpl();
+		this.srvCon.setORB(this.orb);
+
+		try {
+			org.omg.CORBA.Object ref = poa.servant_to_reference(this.srvCon);
+			this.srv = ServerControlInterfaceHelper.narrow(ref);
+
+			org.omg.CORBA.Object objRef =
+				orb.resolve_initial_references("NameService");
+
+			NamingContextExt ncRef = NamingContextExtHelper.narrow(objRef);
+			String name = "YALP_Server";
+			NameComponent path[] = ncRef.to_name(name);
+			ncRef.rebind(path, this.srv);
+
+			System.out.println("YALP Server ready");
+			this.orb.run();
+
+		} catch( org.omg.CosNaming.NamingContextPackage.InvalidName e) {
+			/* t.b.d. error handling */
+			System.out.println("couldn't narrow ref to path");
+		} catch( org.omg.CosNaming.NamingContextPackage.NotFound e) {
+			/* t.b.d. error handling */
+			System.out.println("naming context not found, couldn't bind server ctl");
+		} catch(org.omg.PortableServer.POAPackage.ServantNotActive e) {
+			/* t.b.d. error handling */
+			System.out.println("couldn't get name ref of root poa");
+		} catch (org.omg.CORBA.ORBPackage.InvalidName e) {
+			/* t.b.d. error handling */
+			System.out.println("couldn't get NameService");
+		} catch (org.omg.PortableServer.POAPackage.WrongPolicy e) {
+			/* t.b.d. error handling */
+			System.out.println("policies not set correctly");
+		} catch (org.omg.CosNaming.NamingContextPackage.CannotProceed e) {
+			/* t.b.d. error handling */
+			System.out.println("rebind failed, cannot proceed");
+		}
+	}
+
+/*
+ * write Configuration to XML File
+ *
+ * @param fileName
+ * 		 where to write the configuration file
+ * @return boolean
+ * 		 false - if failed
+ */
+
+	public boolean writeConfig(String fileName) {
+		try{
+			FileOutputStream configFile = new FileOutputStream(fileName);
+			XMLEncoder configWriter = new XMLEncoder(configFile);
+			configWriter.writeObject(settings.imageDir);
+			configWriter.writeObject(settings.videoDir);
+			configWriter.writeObject(settings.soundDir);
+			configWriter.close();
+		} catch (FileNotFoundException fnfe){
+			return false;
+		}
+		return true;
+	}
+
+/*
+ * tries to load ServerSettings from XML File
+ * @param fileName
+ * 		 Configuration file
+ * @return boolean
+ * 		 false - if loading failed
+ */
+
+	public boolean loadConfig(String fileName) {
+		try{
+			FileInputStream configFile = new FileInputStream(fileName);
+			XMLDecoder configLoader = new XMLDecoder(configFile);
+			settings.imageDir = (String)configLoader.readObject();
+			settings.videoDir = (String)configLoader.readObject();
+			settings.soundDir = (String)configLoader.readObject();
+			configLoader.close();
+		} catch(FileNotFoundException fnfe) {
+			System.out.println("Configuration not found, loading defaults...");
+			return false;
+		} catch(ClassCastException cce) {
+			System.out.println("Errors in Configuration, loading defaults...");
+			return false;
+		}
+		return true;
+	}
+
+/*
+ * returns actual configuration of the server
+ * @return ServerSettings
+ * 		 actual configuration
+ */
+
+	public ServerSettings getConfig() {
+		return this.settings;
+	}
+
+/*
+ * sets and saves a new ServerConfiguration
+ *
+ * @param set
+ * 		 new ServerSettings
+ * @return boolean
+ * 		 true if succesfully saved
+ */
+
+	public boolean setConfig(ServerSettings set){
+		this.settings = set;
+		return this.writeConfig("ServerConfiguration.xml");
+	}
+
+/*
+ * t.b.d. session management
+ *
+ * Client logon (give him,his fileBrowser)
+ *
+ * @param ipAdress
+ * 	of the Client
+ * @param userName
+ * 	using the Client
+ *
+
+	public void newClient(String ipAdress,String userName) {
+		this.browseList.add( new FileBrowser( this.settings.startDir,
+																					ipAdress,
+																					userName ) );
+	}
+ */
+
+/*
+ * Client logoff (free memory of his fileBrowser
+ *
+ * @param ipAdress
+ * 	of the Client
+ * @param userName
+ * 	using the Client
+ */
+
+	public void remClient(String ipAdress, String userName) {
+		for( FileBrowser aBrowser : this.browseList ) {
+			if( aBrowser.getOwner().equals(ipAdress) &&
+					aBrowser.getUserName().equals(userName) ) {
+				this.browseList.remove(aBrowser);
+				break;
+			}
+		}
+	}
+
+/*
+ * change Directory in fileBrowser
+ *
+ * @param ip
+ * 	of the Client
+ * @param dir
+ * 	to which should be changed
+ * @return ArrayList<YalpFile>
+ * 	 content of the directory changed to
+ */
+
+	public ArrayList<YalpFile> changeDir(String ip, String dir) {
+		FileBrowser aBrowser = null;
+		for(FileBrowser oneMoreBrowser : this.browseList) {
+			if( oneMoreBrowser.getOwner().equals(ip) ) {
+				oneMoreBrowser.changeDir(dir);
+				aBrowser = oneMoreBrowser;
+				break;
+			}
+		}
+		return aBrowser.getFiles();
+	}
+
+/*
+ * Server Shutdown
+ */
+
+	public void serverShutdown() {
+		System.out.println("Server shutdown - Server is going down");
+		System.exit(0);
+	}
+}