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

Handle JSON data better.

Browse Source
This commit is contained in:
Kavin 2022-04-07 18:40:34 +01:00
parent edf9ae5b8f
commit cef4b1dcb7
No known key found for this signature in database
GPG Key ID: 49451E4482CC5BCD
2 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/main/java/me/kavin/piped/ServerLauncher.java
View File

@ -283,7 +283,7 @@ public class ServerLauncher extends MultithreadedHttpServerLauncher {
} }
})).map(POST, "/user/playlists/create", AsyncServlet.ofBlocking(executor, request -> { })).map(POST, "/user/playlists/create", AsyncServlet.ofBlocking(executor, request -> {
try { try {
var name = Constants.mapper.readTree(request.loadBody().getResult().asArray()).get("name").asText(); var name = Constants.mapper.readTree(request.loadBody().getResult().asArray()).get("name").textValue();
return getJsonResponse(ResponseHelper.createPlaylist(request.getHeader(AUTHORIZATION), name), "private"); return getJsonResponse(ResponseHelper.createPlaylist(request.getHeader(AUTHORIZATION), name), "private");
} catch (Exception e) { } catch (Exception e) {
return getErrorResponse(e, request.getPath()); return getErrorResponse(e, request.getPath());
@ -297,8 +297,8 @@ public class ServerLauncher extends MultithreadedHttpServerLauncher {
})).map(POST, "/user/playlists/add", AsyncServlet.ofBlocking(executor, request -> { })).map(POST, "/user/playlists/add", AsyncServlet.ofBlocking(executor, request -> {
try { try {
var json = Constants.mapper.readTree(request.loadBody().getResult().asArray()); var json = Constants.mapper.readTree(request.loadBody().getResult().asArray());
var playlistId = json.get("playlistId").asText(); var playlistId = json.get("playlistId").textValue();
var videoId = json.get("videoId").asText(); var videoId = json.get("videoId").textValue();
return getJsonResponse(ResponseHelper.addToPlaylistResponse(request.getHeader(AUTHORIZATION), playlistId, videoId), "private"); return getJsonResponse(ResponseHelper.addToPlaylistResponse(request.getHeader(AUTHORIZATION), playlistId, videoId), "private");
} catch (Exception e) { } catch (Exception e) {
return getErrorResponse(e, request.getPath()); return getErrorResponse(e, request.getPath());
@ -306,8 +306,8 @@ public class ServerLauncher extends MultithreadedHttpServerLauncher {
})).map(POST, "/user/playlists/remove", AsyncServlet.ofBlocking(executor, request -> { })).map(POST, "/user/playlists/remove", AsyncServlet.ofBlocking(executor, request -> {
try { try {
var json = Constants.mapper.readTree(request.loadBody().getResult().asArray()); var json = Constants.mapper.readTree(request.loadBody().getResult().asArray());
var playlistId = json.get("playlistId").asText(); var playlistId = json.get("playlistId").textValue();
var index = json.get("index").asInt(); var index = json.get("index").intValue();
return getJsonResponse(ResponseHelper.removeFromPlaylistResponse(request.getHeader(AUTHORIZATION), playlistId, index), "private"); return getJsonResponse(ResponseHelper.removeFromPlaylistResponse(request.getHeader(AUTHORIZATION), playlistId, index), "private");
} catch (Exception e) { } catch (Exception e) {
return getErrorResponse(e, request.getPath()); return getErrorResponse(e, request.getPath());
@ -315,7 +315,7 @@ public class ServerLauncher extends MultithreadedHttpServerLauncher {
})).map(POST, "/user/playlists/delete", AsyncServlet.ofBlocking(executor, request -> { })).map(POST, "/user/playlists/delete", AsyncServlet.ofBlocking(executor, request -> {
try { try {
var json = Constants.mapper.readTree(request.loadBody().getResult().asArray()); var json = Constants.mapper.readTree(request.loadBody().getResult().asArray());
var playlistId = json.get("playlistId").asText(); var playlistId = json.get("playlistId").textValue();
return getJsonResponse(ResponseHelper.deletePlaylistResponse(request.getHeader(AUTHORIZATION), playlistId), "private"); return getJsonResponse(ResponseHelper.deletePlaylistResponse(request.getHeader(AUTHORIZATION), playlistId), "private");
} catch (Exception e) { } catch (Exception e) {
return getErrorResponse(e, request.getPath()); return getErrorResponse(e, request.getPath());

2
src/main/java/me/kavin/piped/utils/resp/InvalidRequestResponse.java
View File

@ -2,6 +2,6 @@ package me.kavin.piped.utils.resp;
public class InvalidRequestResponse { public class InvalidRequestResponse {
public String message = "Invalid request sent."; public String error = "Invalid request sent.";
} }