neoris/openvidu-livekit-tutorials
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

openvidu-android: Handle RPC error messages from server

Browse Source
This commit is contained in:
Juan Navarro 2022-06-03 16:06:41 +02:00
parent 85f6a99129
commit 8645811b06
2 changed files with 40 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
openvidu-android/app/src/main/java/io/openvidu/openvidu_android/constants/JsonConstants.java
View File

@ -44,6 +44,7 @@ public final class JsonConstants {
public static final String METHOD = "method";
public static final String ID = "id";
public static final String RESULT = "result";
public static final String ERROR = "error";
public static final String MEDIA_SERVER = "mediaServer";
public static final String SESSION_ID = "sessionId";

59
openvidu-android/app/src/main/java/io/openvidu/openvidu_android/websocket/CustomWebSocket.java
View File

@ -101,6 +101,8 @@ public class CustomWebSocket extends AsyncTask<SessionActivity, Void, Void> impl
JSONObject json = new JSONObject(text);
if (json.has(JsonConstants.RESULT)) {
handleServerResponse(json);
} else if (json.has(JsonConstants.ERROR)) {
handleServerError(json);
} else {
handleServerEvent(json);
}
@ -193,6 +195,15 @@ public class CustomWebSocket extends AsyncTask<SessionActivity, Void, Void> impl
}
}
private void handleServerError(JSONObject json) throws JSONException {
final JSONObject error = new JSONObject(json.getString(JsonConstants.ERROR));
final int errorCode = error.getInt("code");
final String errorMessage = error.getString("message");
Log.e(TAG, "Server error code " + errorCode + ": " + errorMessage);
}
public void joinRoom() {
Map<String, String> joinRoomParams = new HashMap<>();
joinRoomParams.put(JsonConstants.METADATA, "{\"clientData\": \"" + this.session.getLocalParticipant().getParticipantName() + "\"}");
@ -252,27 +263,35 @@ public class CustomWebSocket extends AsyncTask<SessionActivity, Void, Void> impl
}
private void handleServerEvent(JSONObject json) throws JSONException {
if (!json.has(JsonConstants.METHOD)) {
Log.e(TAG, "Server event lacks a field '" + JsonConstants.METHOD + "'; JSON: "
+ json.toString());
return;
}
final String method = json.getString(JsonConstants.METHOD);
if (!json.has(JsonConstants.PARAMS)) {
Log.e(TAG, "No params " + json.toString());
} else {
final JSONObject params = new JSONObject(json.getString(JsonConstants.PARAMS));
String method = json.getString(JsonConstants.METHOD);
switch (method) {
case JsonConstants.ICE_CANDIDATE:
iceCandidateEvent(params);
break;
case JsonConstants.PARTICIPANT_JOINED:
participantJoinedEvent(params);
break;
case JsonConstants.PARTICIPANT_PUBLISHED:
participantPublishedEvent(params);
break;
case JsonConstants.PARTICIPANT_LEFT:
participantLeftEvent(params);
break;
default:
throw new JSONException("Unknown method: " + method);
}
Log.e(TAG, "Server event '" + method + "' lacks a field '" + JsonConstants.PARAMS
+ "'; JSON: " + json.toString());
return;
}
final JSONObject params = new JSONObject(json.getString(JsonConstants.PARAMS));
switch (method) {
case JsonConstants.ICE_CANDIDATE:
iceCandidateEvent(params);
break;
case JsonConstants.PARTICIPANT_JOINED:
participantJoinedEvent(params);
break;
case JsonConstants.PARTICIPANT_PUBLISHED:
participantPublishedEvent(params);
break;
case JsonConstants.PARTICIPANT_LEFT:
participantLeftEvent(params);
break;
default:
throw new JSONException("Unknown method: '" + method + "'");
}
}