/*
|
http-cm - File management extensions to jdk.httpserver
|
Copyright (C) 2021 Ulrich Hilger
|
|
This program is free software: you can redistribute it and/or modify
|
it under the terms of the GNU Affero General Public License as
|
published by the Free Software Foundation, either version 3 of the
|
License, or (at your option) any later version.
|
|
This program is distributed in the hope that it will be useful,
|
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
GNU Affero General Public License for more details.
|
|
You should have received a copy of the GNU Affero General Public License
|
along with this program. If not, see <https://www.gnu.org/licenses/>.
|
*/
|
package de.uhilger.httpserver.cm.actor;
|
|
import com.google.gson.Gson;
|
import com.sun.net.httpserver.Headers;
|
import com.sun.net.httpserver.HttpExchange;
|
import de.uhilger.httpserver.base.HttpHelper;
|
import de.uhilger.httpserver.base.HttpResponder;
|
import de.uhilger.httpserver.base.handler.FileHandler;
|
import static de.uhilger.httpserver.base.handler.FileHandler.CONTENT_TYPE;
|
import static de.uhilger.httpserver.base.handler.FileHandler.SC_METHOD_NOT_ALLOWED;
|
import static de.uhilger.httpserver.base.handler.FileHandler.SC_OK;
|
import static de.uhilger.httpserver.base.handler.FileHandler.SC_UNPROCESSABLE_ENTITY;
|
import static de.uhilger.httpserver.cm.FileManager.OP_COPY;
|
import static de.uhilger.httpserver.cm.FileManager.OP_MOVE;
|
import static de.uhilger.httpserver.cm.FileManager.P_COPY;
|
import static de.uhilger.httpserver.cm.FileManager.P_DUPLICATE;
|
import static de.uhilger.httpserver.cm.FileManager.P_MOVE;
|
import static de.uhilger.httpserver.cm.FileManager.P_RENAME;
|
import static de.uhilger.httpserver.cm.FileManager.P_UNZIP;
|
import static de.uhilger.httpserver.cm.FileManager.P_ZIP;
|
import static de.uhilger.httpserver.cm.FileManager.STR_SLASH;
|
import static de.uhilger.httpserver.cm.FileManager.UTF8;
|
import de.uhilger.httpserver.cm.FileTransporter;
|
import java.io.BufferedReader;
|
import java.io.File;
|
import java.io.FileOutputStream;
|
import java.io.IOException;
|
import java.io.InputStream;
|
import java.io.InputStreamReader;
|
import java.io.OutputStream;
|
import java.net.URLDecoder;
|
import java.util.Arrays;
|
|
/**
|
* Klasse mit Methoden zu schreibenden Dateioperationen
|
*
|
* @author Ulrich Hilger, 15. Janauar 2024
|
*/
|
public class Writer {
|
public void put(HttpExchange exchange, HttpHelper helper) throws IOException {
|
String query = exchange.getRequestURI().getQuery();
|
if (query != null) {
|
String[] params = query.split("=");
|
for (String param : params) {
|
//logger.fine("param: " + param);
|
}
|
switch (params[0]) {
|
case P_COPY:
|
copyOrMove(exchange, params[1], helper.getFileName(exchange), OP_COPY);
|
break;
|
case P_MOVE:
|
copyOrMove(exchange, params[1], helper.getFileName(exchange), OP_MOVE);
|
break;
|
case P_DUPLICATE:
|
if(Boolean.parseBoolean(params[1])) {
|
String neuerDateiName = new Mover().duplizieren(
|
exchange.getHttpContext().getAttributes().get(FileHandler.ATTR_FILE_BASE).toString(),
|
helper.getFileName(exchange));
|
//logger.fine("neuer Name: " + neuerDateiName);
|
standardHeaderUndAntwort(exchange, SC_OK, neuerDateiName);
|
}
|
break;
|
case P_RENAME:
|
String neuerDateiName = new Renamer().umbenennen(exchange, helper, params[1]);
|
//logger.fine("neuer Name: " + neuerDateiName);
|
standardHeaderUndAntwort(exchange, SC_OK, neuerDateiName);
|
break;
|
case P_ZIP:
|
String path = exchange.getRequestURI().toString();
|
//logger.fine(path);
|
String antwort = new Zipper().packFolder(helper.getFileName(exchange), path, exchange.getHttpContext().getAttributes().get(FileHandler.ATTR_FILE_BASE).toString());
|
if(antwort.equalsIgnoreCase("ok")) {
|
standardHeaderUndAntwort(exchange, SC_OK, antwort);
|
} else {
|
standardHeaderUndAntwort(exchange, SC_UNPROCESSABLE_ENTITY, antwort);
|
}
|
break;
|
case P_UNZIP:
|
path = exchange.getRequestURI().toString();
|
//logger.fine(path);
|
antwort = new Unzipper().extractZipfile(helper.getFileName(exchange), path, exchange.getHttpContext().getAttributes().get(FileHandler.ATTR_FILE_BASE).toString());
|
if(antwort.equalsIgnoreCase("ok")) {
|
standardHeaderUndAntwort(exchange, SC_OK, antwort);
|
} else {
|
standardHeaderUndAntwort(exchange, SC_UNPROCESSABLE_ENTITY, antwort);
|
}
|
break;
|
}
|
} else {
|
speichern(exchange, helper);
|
}
|
}
|
|
private void copyOrMove(HttpExchange exchange, String quelle, String ziel, int op) throws IOException {
|
//logger.fine("quelle: " + quelle + ", ziel: " + ziel);
|
String[] dateiNamen = dateiliste(exchange);
|
new Mover().copyOrMoveFiles(quelle, ziel, dateiNamen, op, exchange.getHttpContext().getAttributes().get(FileHandler.ATTR_FILE_BASE).toString());
|
standardHeaderUndAntwort(exchange, SC_OK, "Dateien verarbeitet.");
|
}
|
|
public void loeschen(HttpExchange exchange, HttpHelper helper) throws IOException {
|
String[] dateiNamen = dateiliste(exchange);
|
String relPfad = helper.getFileName(exchange);
|
new Eraser().deleteFiles(relPfad, Arrays.asList(dateiNamen), exchange.getHttpContext().getAttributes().get(FileHandler.ATTR_FILE_BASE).toString());
|
standardHeaderUndAntwort(exchange, SC_OK, "Dateien geloescht.");
|
}
|
|
private String[] dateiliste(HttpExchange exchange) throws IOException {
|
String body = new HttpHelper().bodyLesen(exchange);
|
//logger.fine("dateien: " + body);
|
Gson gson = new Gson();
|
return gson.fromJson(body, String[].class);
|
}
|
|
public void standardHeaderUndAntwort(HttpExchange exchange, int status, String antwort) throws IOException {
|
Headers resHeaders = exchange.getResponseHeaders();
|
resHeaders.add(CONTENT_TYPE, HttpHelper.CT_TEXT_HTML);
|
new HttpResponder().antwortSenden(exchange, status, antwort);
|
}
|
|
public void speichern(HttpExchange exchange, HttpHelper helper) throws IOException {
|
String fileName = helper.getFileName(exchange);
|
//logger.info("fileName: " + fileName);
|
|
// file ist die Datei, um die es geht
|
File file = new File(exchange.getHttpContext().getAttributes().get(FileHandler.ATTR_FILE_BASE).toString(), fileName);
|
|
String method = exchange.getRequestMethod();
|
if (fileName.endsWith(STR_SLASH)) {
|
//logger.info("neuer Ordner: " + file.getAbsolutePath());
|
// neuen Ordner erstellen oder ablehnen, wenn der Ordner schon existiert
|
if (method.equalsIgnoreCase(HttpHelper.HTTP_POST)) {
|
if (!file.exists()) {
|
file.mkdir();
|
new Writer().standardHeaderUndAntwort(exchange, SC_OK, file.getAbsolutePath());
|
} else {
|
String antwort = "Ordner existiert bereits.";
|
new Writer().standardHeaderUndAntwort(exchange, SC_UNPROCESSABLE_ENTITY, antwort);
|
}
|
} else {
|
String antwort = "PUT fuer neuen Ordner nicht erlaubt, bitte POST verwenden.";
|
new Writer().standardHeaderUndAntwort(exchange, SC_METHOD_NOT_ALLOWED, antwort);
|
}
|
} else {
|
//logger.info("Datei speichern: " + file.getAbsolutePath());
|
// Datei speichern
|
if (method.equalsIgnoreCase(HttpHelper.HTTP_POST)) {
|
if (file.exists()) {
|
FileTransporter trans = new FileTransporter();
|
file = trans.getNewFileName(file);
|
}
|
} else if (method.equalsIgnoreCase(HttpHelper.HTTP_PUT)) {
|
if (file.exists()) {
|
/*
|
muss delete() sein?
|
pruefen: ueberschreibt der FileWriter den alteen Inhalt oder
|
entsteht eine unerwuenschte Mischung aus altem und neuem
|
Inhalt?
|
*/
|
file.delete();
|
} else {
|
file.getParentFile().mkdirs();
|
}
|
}
|
// Request Body mit dem Dateiinhalt in einen String lesen
|
StringBuilder sb = new StringBuilder();
|
InputStream is = exchange.getRequestBody();
|
BufferedReader in = new BufferedReader(new InputStreamReader(is));
|
String line = in.readLine();
|
while (line != null) {
|
sb.append(line);
|
line = in.readLine();
|
}
|
|
// dekodieren
|
String content = sb.toString();
|
//logger.fine(content);
|
String decoded = URLDecoder.decode(content, UTF8);
|
//logger.fine(decoded);
|
|
// in Datei schreiben
|
byte[] bytes = decoded.getBytes();
|
file.createNewFile();
|
OutputStream os = new FileOutputStream(file);
|
os.write(bytes);
|
os.flush();
|
os.close();
|
is.close();
|
|
// Antwort senden
|
standardHeaderUndAntwort(exchange, SC_OK, file.getAbsolutePath());
|
}
|
}
|
}
|
