package server; import java.io.File; import java.io.IOException; import java.math.BigInteger; import java.security.MessageDigest; import java.security.NoSuchAlgorithmException; import java.sql.Connection; import java.sql.ResultSet; import java.sql.SQLException; import java.util.ArrayList; import java.util.Date; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.UUID; import javax.xml.parsers.ParserConfigurationException; import javax.xml.transform.TransformerException; import models.Configuration; import org.apache.commons.io.FileUtils; import org.apache.log4j.Logger; import org.apache.thrift.TException; import org.ini4j.Wini; import sql.SQL; import util.XMLCreator; public class ServerHandler implements Server.Iface { static SQL sql = new SQL(); static Connection con = sql.getConnection(); private static Logger log = Logger.getLogger(ServerHandler.class); @Override public User getFtpUser() throws TException { log.info(new Date() + " - returing FTPUser..."); User user = new User(); user.setUserName(UUID.randomUUID().toString().substring(0, 8)); user.setPassword(getEncodedSha1Sum(UUID.randomUUID().toString() .substring(0, 8))); user.setPath(Configuration.config.getAbsolute_path()); SQL sql = new SQL(); Connection con = sql.getConnection(); sql.writeFTPUser(con, user.getUserName(), user.getPassword()); return user; } public String getEncodedSha1Sum(String key) { try { MessageDigest md = MessageDigest.getInstance("SHA1"); md.update(key.getBytes()); log.info(new Date() + " - successfully returned EncodedSha1Sum"); return new BigInteger(1, md.digest()).toString(16); } catch (NoSuchAlgorithmException e) { // handle error case to taste } return null; } @Override public long DeleteFtpUser(String user) throws TException { int ret = sql.DeleteUser(con, user); return ret; } @Override public String getPathOfImage(String image_id, String version) throws TException { try { ResultSet rs = sql.getPathOfImage(con, image_id, version); rs.next(); log.info(new Date() + " - successfully returned PathOfImage: " + rs.getString("image_path")); return rs.getString("image_path"); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } log.info(new Date() + " - returning PathOfImage: null"); return null; } @Override public boolean writeVLdata(String imagename, String login, String firstname, String lastname, String university, String Mail, String Tel, String Fak, boolean license, boolean internet, long ram, long cpu, String imagePath, boolean isTemplate ,long filesize) throws TException { String pk_institution = sql.setInstitution(con, university); String pk_person = sql.setPerson(con, login, lastname, firstname, Mail, new Date(), pk_institution); sql.setImageData(con, pk_person, license, internet, cpu, ram, imagename, imagePath,isTemplate ,filesize); log.info(new Date() + " - written VLdata"); // TODO Auto-generated method stub return true; } @Override public List getImageList() throws TException { ResultSet res = sql.getImageList(con); List list = new ArrayList(); try { while (res.next()) { list.add(new Image(res.getString("GUID_imageID"), res .getString("imageVersion"), res.getString("image_name"), res .getString("cond_hasLicenseRestriction"), res .getString("name"), res.getString("lecture"), res.getString("image_update_time"), res .getString("user"))); } return list; } catch (SQLException e1) { // TODO Auto-generated catch block e1.printStackTrace(); } log.info(new Date() + " - returning ImageList: " + list.size() + " items."); return null; } @Override public List getAllOS() throws TException { List list = new ArrayList<>(); ResultSet rs = sql.getAllOS(con); try { while (rs.next()) { list.add(rs.getString("name")); } return list; } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } return null; } @Override public Map getPersonData(String Vorname, String Nachname) throws TException { Map map = new HashMap(); ResultSet rs = sql.getPersonData(con, Vorname, Nachname); try { while (rs.next()) { map.put("mail", rs.getString("mail")); map.put("Nachname", rs.getString("Nachname")); map.put("Vorname", rs.getString("Vorname")); map.put("Hochschule", rs.getString("name")); } return map; } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } log.info(new Date() + " - returning PersonData: " + map.size() + " items."); return null; } @Override public boolean writeLecturedata(String name, String shortdesc, String desc, String startDate, String endDate, boolean isActive, String imagename, String login, String firstname, String lastname, String university, String Mail, String Tel, String Fak) throws TException { String pk_image = null; int imageversion = 0; String pk_institution = sql.setInstitution(con, university); String pk_person = sql.setPerson(con, login, lastname, firstname, Mail, new Date(), pk_institution); ResultSet image = sql.getImageIDandVersion(con, imagename); try { while (image.next()) { pk_image = image.getString("GUID_imageID"); imageversion = image.getInt("imageVersion"); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } sql.setLectureData(con, pk_person, pk_image, imageversion, name, desc, shortdesc, startDate, endDate, isActive); XMLCreator xml = new XMLCreator(con, name); try { xml.create(name); log.info(new Date() + " - XML created."); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (ParserConfigurationException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (TransformerException e) { // TODO Auto-generated catch block e.printStackTrace(); } return false; } @Override public boolean startFileCopy(String filename) throws TException { String file=Configuration.config.getAbsolute_path()+"temp/"+filename; File tmpFile = new File(file); log.info(new Date() + " - Trying to move file to '/srv/openslx/nfs/prod/"+tmpFile.getName() +"'"); try { // der übergebene Filename ist falsch - hier muss der generierte // name geholt werden, nicht der ursprüngliche name. wo wird dieser // eingelesen? //FileUtils.moveFile(tmpFile, new File("141.79.128.103:/srv/nfs4slx/" // + tmpFile.getName())); FileUtils.moveFile(tmpFile, new File(Configuration.config.getAbsolute_path()+"prod/"+filename)); int ret=sql.UpdateImagePath(con, filename); log.info(new Date() + " - update "+ret); log.info(new Date() + " - file moved"); } catch (IOException e) { // TODO Auto-generated catch block log.info(new Date() + " - Failed to move file."); e.printStackTrace(); } return true; } @Override public Map getImageData(String imageid, String imageversion) throws TException { ResultSet data = sql.getImageData(con, imageid, imageversion); Map map = new HashMap(); try { while (data.next()) { System.out.println(data .getString("cond_hasInternetRestriction") + data.getString("cond_hasLicenseRestriction") + data.getString("cond_minCPUs") + data.getString("cond_minRAM")); map.put("name", data.getString("image_name")); map.put("internet", data.getString("cond_hasInternetRestriction")); map.put("license", data.getString("cond_hasLicenseRestriction")); map.put("cpu", data.getString("cond_minCPUs")); map.put("ram", data.getString("cond_minRAM")); } return map; } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } log.info(new Date() + " - returning ImageData: " + map.size() + "items."); return null; } @Override public boolean updateImageData(String name, String newName, String image_path, boolean license, boolean internet, long ram, long cpu, String id, String version, boolean isTemplate, long filesize) throws TException { sql.UpdateImageData(con, name, newName,image_path, license, internet, cpu, ram, id, version, isTemplate, filesize); return false; } @Override public Map getLectureData(String lecturename) throws TException { // TODO Auto-generated method stub return null; } @Override public List getLectureList() throws TException { ResultSet res = sql.getLectureList(con); List list = new ArrayList(); try { while (res.next()) { list.add(new Lecture(res.getString("lectureID"), res .getString("name"), res.getString("isActive"), res .getString("startTime"), res.getString("endTime"), res .getString("lastUsed"), res.getString("description"), res.getString("image_name"), res.getString("user"))); } return list; } catch (SQLException e1) { // TODO Auto-generated catch block e1.printStackTrace(); } log.info(new Date() + " - returning LectureList: " + list.size() + " items."); return null; } @Override public boolean updateLecturedata(String name, String newName, String shortdesc, String desc, String startDate, String endDate, boolean isActive, String imagename, String firstname, String lastname, String university, String Mail, String Tel, String Fak, String id) throws TException { String pk_image = ""; int imageversion = 0; ResultSet image = sql.getImageIDandVersion(con, imagename); try { while (image.next()) { pk_image = image.getString("GUID_imageID"); imageversion = image.getInt("imageVersion"); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } sql.updateLectureData(con, pk_image, imageversion, lastname, newName, desc, shortdesc, startDate, endDate, isActive, id); XMLCreator xml = new XMLCreator(con, newName); try { xml.create(newName); } catch (SQLException | ParserConfigurationException | TransformerException e) { // TODO Auto-generated catch block e.printStackTrace(); } //sql.updateLectureData(con, pk_image, imageversion, lastname, newName, // desc, shortdesc, startDate, endDate, isActive, id); return false; } @Override public boolean deleteImageServer(String imageid, String imageversion) throws TException { String stringFile = sql.getFile(con, imageid, imageversion); log.info(new Date() + " - File to Delete: " + stringFile); File tmpFile = new File(Configuration.config.getAbsolute_path()+stringFile); try { // File wird von Server gelöscht FileUtils.forceDelete(tmpFile); return true; } catch (IOException e) { log.info(new Date() + " - Failed to execute deleteImageServer."); e.printStackTrace(); } return false; } @Override public boolean deleteImageData(String id, String version) throws TException { return sql.deleteImage(con, id, version); } @Override public boolean connectedToLecture(String id, String version) throws TException { // TODO Auto-generated method stub return sql.connectedToLecture(con, id, version); } public boolean deleteLecture(String id, String hs, String user) { ResultSet rs = sql.getDeleteXMLData(con, id); try { rs.next(); String date = rs.getString("admin_createTime").replace(" ", "") .replace("-", "").replace(":", ""); String name = rs.getString("name"); String path = Configuration.config.getAbsolute_path()+"temp/" + date.substring(0, date.length() - 2) + "_" + hs + "_" + user + "_" + name + ".xml"; File xmlFile = new File(path); FileUtils.forceDelete(xmlFile); } catch (SQLException e) { log.info(new Date() + " - Failed to execute deleteLecture"); e.printStackTrace(); } catch (IOException e) { log.info(new Date() + " - Failed to execute deleteLecture"); e.printStackTrace(); } return sql.deleteLecture(con, id); } }