hg
/
FONGMITV
mirror of https://github.com/FongMi/TV.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Nano support range

Browse Source
pull/171/head
FongMi 2 years ago
parent 2102bb92af
commit 706695aa31
3 changed files with 77 additions and 17 deletions
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Show Stats Download Patch File Download Diff File
  1. 4
      app/build.gradle
  2. 2
      app/src/main/java/com/fongmi/android/tv/server/Nano.java
  3. 88
      app/src/main/java/com/fongmi/android/tv/server/process/Local.java

4
app/build.gradle
Unescape View File

@ -21,12 +21,12 @@ android {
leanback {
dimension "mode"
versionCode 207
versionName "20231020#2"
versionName "20231023"
}
mobile {
dimension "mode"
versionCode 207
versionName "20231020#2"
versionName "20231023"
}
java {
dimension "api"

2
app/src/main/java/com/fongmi/android/tv/server/Nano.java
Unescape View File

@ -70,7 +70,7 @@ public class Nano extends NanoHTTPD {
return getAssets(url.substring(1));
}
private void parse(NanoHTTPD.IHTTPSession session, Map<String, String> files) {
private void parse(IHTTPSession session, Map<String, String> files) {
String ct = session.getHeaders().get("content-type");
if (ct != null && ct.toLowerCase().contains("multipart/form-data") && !ct.toLowerCase().contains("charset=")) {
Matcher matcher = Pattern.compile("[ |\t]*(boundary[ |\t]*=[ |\t]*['|\"]?[^\"^'^;^,]*['|\"]?)", Pattern.CASE_INSENSITIVE).matcher(ct);

88
app/src/main/java/com/fongmi/android/tv/server/process/Local.java
Unescape View File

@ -32,18 +32,18 @@ public class Local implements Process {
@Override
public NanoHTTPD.Response doResponse(NanoHTTPD.IHTTPSession session, String path, Map<String, String> files) {
if (path.startsWith("/file")) return getFile(path);
if (path.startsWith("/file")) return getFile(session.getHeaders(), path);
if (path.startsWith("/upload")) return upload(session.getParms(), files);
if (path.startsWith("/newFolder")) return newFolder(session.getParms());
if (path.startsWith("/delFolder") || path.startsWith("/delFile")) return delFolder(session.getParms());
return null;
}
private NanoHTTPD.Response getFile(String url) {
private NanoHTTPD.Response getFile(Map<String, String> headers, String path) {
try {
File file = Path.root(url.substring(6));
if (file.isFile()) return Nano.newChunkedResponse(NanoHTTPD.Response.Status.OK, "application/octet-stream", new FileInputStream(file));
if (file.isDirectory()) return Nano.success(listFiles(file));
File file = Path.root(path.substring(6));
if (file.isDirectory()) return getFolder(file);
if (file.isFile()) return getFile(headers, file, NanoHTTPD.getMimeTypeForFile(path));
throw new FileNotFoundException();
} catch (Exception e) {
return Nano.error(e.getMessage());
@ -74,18 +74,13 @@ public class Local implements Process {
return Nano.success();
}
private String getParent(File root) {
return root.equals(Path.root()) ? "." : root.getParent().replace(Path.rootPath(), "");
}
private String listFiles(File root) {
private NanoHTTPD.Response getFolder(File root) {
File[] list = root.listFiles();
String parent = getParent(root);
JsonObject info = new JsonObject();
info.addProperty("parent", parent);
info.addProperty("parent", root.equals(Path.root()) ? "." : root.getParent().replace(Path.rootPath(), ""));
if (list == null || list.length == 0) {
info.add("files", new JsonArray());
return info.toString();
return Nano.success(info.toString());
}
Arrays.sort(list, (o1, o2) -> {
if (o1.isDirectory() && o2.isFile()) return -1;
@ -101,6 +96,71 @@ public class Local implements Process {
obj.addProperty("dir", file.isDirectory() ? 1 : 0);
files.add(obj);
}
return info.toString();
return Nano.success(info.toString());
}
private NanoHTTPD.Response getFile(Map<String, String> header, File file, String mime) throws Exception {
long startFrom = 0;
long endAt = -1;
String range = header.get("range");
if (range != null) {
if (range.startsWith("bytes=")) {
range = range.substring("bytes=".length());
int minus = range.indexOf('-');
try {
if (minus > 0) {
startFrom = Long.parseLong(range.substring(0, minus));
endAt = Long.parseLong(range.substring(minus + 1));
}
} catch (NumberFormatException ignored) {
}
}
}
NanoHTTPD.Response res;
long fileLen = file.length();
String ifRange = header.get("if-range");
String etag = Integer.toHexString((file.getAbsolutePath() + file.lastModified() + "" + file.length()).hashCode());
boolean headerIfRangeMissingOrMatching = (ifRange == null || etag.equals(ifRange));
String ifNoneMatch = header.get("if-none-match");
boolean headerIfNoneMatchPresentAndMatching = ifNoneMatch != null && ("*".equals(ifNoneMatch) || ifNoneMatch.equals(etag));
if (headerIfRangeMissingOrMatching && range != null && startFrom >= 0 && startFrom < fileLen) {
if (headerIfNoneMatchPresentAndMatching) {
res = NanoHTTPD.newFixedLengthResponse(NanoHTTPD.Response.Status.NOT_MODIFIED, mime, "");
res.addHeader("Accept-Ranges", "bytes");
res.addHeader("ETag", etag);
} else {
if (endAt < 0) endAt = fileLen - 1;
long newLen = endAt - startFrom + 1;
if (newLen < 0) newLen = 0;
FileInputStream fis = new FileInputStream(file);
fis.skip(startFrom);
res = NanoHTTPD.newFixedLengthResponse(NanoHTTPD.Response.Status.PARTIAL_CONTENT, mime, fis, newLen);
res.addHeader("Accept-Ranges", "bytes");
res.addHeader("Content-Length", newLen + "");
res.addHeader("Content-Range", "bytes " + startFrom + "-" + endAt + "/" + fileLen);
res.addHeader("ETag", etag);
}
} else {
if (headerIfRangeMissingOrMatching && range != null && startFrom >= fileLen) {
res = NanoHTTPD.newFixedLengthResponse(NanoHTTPD.Response.Status.RANGE_NOT_SATISFIABLE, NanoHTTPD.MIME_PLAINTEXT, "");
res.addHeader("Content-Range", "bytes */" + fileLen);
res.addHeader("Accept-Ranges", "bytes");
res.addHeader("ETag", etag);
} else if (range == null && headerIfNoneMatchPresentAndMatching) {
res = NanoHTTPD.newFixedLengthResponse(NanoHTTPD.Response.Status.NOT_MODIFIED, mime, "");
res.addHeader("Accept-Ranges", "bytes");
res.addHeader("ETag", etag);
} else if (!headerIfRangeMissingOrMatching && headerIfNoneMatchPresentAndMatching) {
res = NanoHTTPD.newFixedLengthResponse(NanoHTTPD.Response.Status.NOT_MODIFIED, mime, "");
res.addHeader("Accept-Ranges", "bytes");
res.addHeader("ETag", etag);
} else {
res = NanoHTTPD.newFixedLengthResponse(NanoHTTPD.Response.Status.OK, mime, new FileInputStream(file), (int) file.length());
res.addHeader("Content-Length", fileLen + "");
res.addHeader("Accept-Ranges", "bytes");
res.addHeader("ETag", etag);
}
}
return res;
}
}

Write Preview
Loading…
Cancel
Save