mirrors/Piped-Backend
1
0
Fork 0
mirror of https://github.com/TeamPiped/Piped-Backend synced 2025-09-05 21:11:05 +02:00
Code Issues Packages Projects Releases Wiki Activity

Fix compile error.

Browse Source
This commit is contained in:
FireMasterK 2021-02-24 15:56:26 +05:30
parent 05ac540b02
commit 9275e01c5a
No known key found for this signature in database
GPG Key ID: 8DFF5DD33E93DB58
1 changed files with 16 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
src/main/java/me/kavin/piped/Main.java
View File

@ -36,7 +36,7 @@ public class Main {
NewPipe.init(new DownloaderImpl(), new Localization("en", "US")); NewPipe.init(new DownloaderImpl(), new Localization("en", "US"));
DisposableServer server = HttpServer.create().port(Constants.PORT).route(routes -> { DisposableServer server = HttpServer.create().port(Constants.PORT).route(routes -> {
routes.get("/webhooks/pubsub", (req, res) -> { routes.get("/webhooks/pubsub", (req, res) -> {
@ -225,14 +225,10 @@ public class Main {
}); });
}).compress(true).bindNow(); }).compress(true).bindNow();
server.onDispose().block(); server.onDispose().block();
}
}).bindNow();
Thread.sleep(Long.MAX_VALUE);
} }
public static NettyOutbound writeResponse(HttpServerResponse res, String resp, int code, String cache, long time) { public static NettyOutbound writeResponse(HttpServerResponse res, String resp, int code, String cache, long time) {
@ -258,15 +254,13 @@ public class Main {
return writeResponse(res, resp, mimeType.toString(), code, cache, time); return writeResponse(res, resp, mimeType.toString(), code, cache, time);
} }
public static NettyOutbound writeResponse(HttpServerResponse res, byte[] resp, String mimeType, int code, String cache, long time) { public static NettyOutbound writeResponse(HttpServerResponse res, byte[] resp, String mimeType, int code,
return res String cache, long time) {
.status(code) return res.status(code).addHeader(CONTENT_TYPE, mimeType).addHeader(ACCESS_CONTROL_ALLOW_ORIGIN, "*")
.addHeader(CONTENT_TYPE, mimeType) .addHeader(CACHE_CONTROL, cache)
.addHeader(ACCESS_CONTROL_ALLOW_ORIGIN, "*") .addHeader("Server-Timing", "app;dur=" + (System.nanoTime() - time) / 1000000.0)
.addHeader(CACHE_CONTROL, cache) .sendByteArray(Flux.just(resp));
.addHeader("Server-Timing", "app;dur=" + (System.nanoTime() - time) / 1000000.0) }
.sendByteArray(Flux.just(resp));
}
public static NettyOutbound writeResponse(HttpServerResponse res, Flux<String> resp, int code, String cache) { public static NettyOutbound writeResponse(HttpServerResponse res, Flux<String> resp, int code, String cache) {
return writeResponse(res, resp, APPLICATION_JSON, code, cache); return writeResponse(res, resp, APPLICATION_JSON, code, cache);
@ -277,12 +271,10 @@ public class Main {
return writeResponse(res, resp, mimeType.toString(), code, cache); return writeResponse(res, resp, mimeType.toString(), code, cache);
} }
public static NettyOutbound writeResponse(HttpServerResponse res, Flux<String> resp, String mimeType, int code, String cache) { public static NettyOutbound writeResponse(HttpServerResponse res, Flux<String> resp, String mimeType, int code,
return res String cache) {
.status(code) return res.status(code).addHeader(CONTENT_TYPE, mimeType).addHeader(ACCESS_CONTROL_ALLOW_ORIGIN, "*")
.addHeader(CONTENT_TYPE, mimeType) .addHeader(CACHE_CONTROL, cache)
.addHeader(ACCESS_CONTROL_ALLOW_ORIGIN, "*") .send(ByteBufFlux.fromString(resp, java.nio.charset.StandardCharsets.UTF_8, ByteBufAllocator.DEFAULT));
.addHeader(CACHE_CONTROL, cache) }
.send(ByteBufFlux.fromString(resp, java.nio.charset.StandardCharsets.UTF_8, ByteBufAllocator.DEFAULT));
}
} }