Update src/main/java/com/mediamanager/service/delegate/handler/disc/CreateDiscHandler.java
Co-authored-by: coderabbitai[bot] <136622811+coderabbitai[bot]@users.noreply.github.com>
This commit is contained in:
parent
07f7405b03
commit
dfa4185e64
|
|
@ -23,7 +23,7 @@ public class CreateDiscHandler implements ActionHandler {
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public TransportProtocol.Response.Builder handle(ByteString requestPayload) throws InvalidProtocolBufferException {
|
public TransportProtocol.Response.Builder handle(ByteString requestPayload) throws InvalidProtocolBufferException {
|
||||||
try{
|
try {
|
||||||
DiscMessages.CreateDiscRequest createRequest =
|
DiscMessages.CreateDiscRequest createRequest =
|
||||||
DiscMessages.CreateDiscRequest.parseFrom(requestPayload);
|
DiscMessages.CreateDiscRequest.parseFrom(requestPayload);
|
||||||
|
|
||||||
|
|
@ -42,13 +42,20 @@ public class CreateDiscHandler implements ActionHandler {
|
||||||
logger.error("Validation error", e);
|
logger.error("Validation error", e);
|
||||||
return TransportProtocol.Response.newBuilder()
|
return TransportProtocol.Response.newBuilder()
|
||||||
.setStatusCode(400)
|
.setStatusCode(400)
|
||||||
.setPayload(ByteString.copyFromUtf8("Validation error: " + e.getMessage()));
|
.setPayload(ByteString.copyFromUtf8("Invalid request"));
|
||||||
|
|
||||||
|
} catch (InvalidProtocolBufferException e) {
|
||||||
|
logger.error("Invalid CreateDiscRequest payload", e);
|
||||||
|
return TransportProtocol.Response.newBuilder()
|
||||||
|
.setStatusCode(400)
|
||||||
|
.setPayload(ByteString.copyFromUtf8("Invalid request payload"));
|
||||||
|
|
||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
logger.error("Error creating disc", e);
|
logger.error("Error creating disc", e);
|
||||||
return TransportProtocol.Response.newBuilder()
|
return TransportProtocol.Response.newBuilder()
|
||||||
.setStatusCode(500)
|
.setStatusCode(500)
|
||||||
.setPayload(ByteString.copyFromUtf8("Error: " + e.getMessage()));
|
.setPayload(ByteString.copyFromUtf8("Internal server error"));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue