diff --git a/app/src/main/java/awais/instagrabber/managers/ThreadManager.java b/app/src/main/java/awais/instagrabber/managers/ThreadManager.java index 7e00e165..34eff7dc 100644 --- a/app/src/main/java/awais/instagrabber/managers/ThreadManager.java +++ b/app/src/main/java/awais/instagrabber/managers/ThreadManager.java @@ -883,74 +883,71 @@ public final class ThreadManager { public LiveData> acceptRequest() { final MutableLiveData> data = new MutableLiveData<>(); - data.postValue(Resource.success(new Object())); - // final Call request = service.approveRequest(threadId); - // request.enqueue(new Callback() { - // @Override - // public void onResponse(@NonNull final Call call, - // @NonNull final Response response) { - // if (!response.isSuccessful()) { - // try { - // final String string = response.errorBody() != null ? response.errorBody().string() : ""; - // final String msg = String.format(Locale.US, - // "onResponse: url: %s, responseCode: %d, errorBody: %s", - // call.request().url().toString(), - // response.code(), - // string); - // Log.e(TAG, msg); - // data.postValue(Resource.error(msg, null)); - // return; - // } catch (IOException e) { - // Log.e(TAG, "onResponse: ", e); - // } - // return; - // } - // data.postValue(Resource.success(new Object())); - // // refreshChats(); - // } - // - // @Override - // public void onFailure(@NonNull final Call call, @NonNull final Throwable t) { - // Log.e(TAG, "onFailure: ", t); - // data.postValue(Resource.error(t.getMessage(), null)); - // } - // }); + final Call request = service.approveRequest(threadId); + request.enqueue(new Callback() { + @Override + public void onResponse(@NonNull final Call call, + @NonNull final Response response) { + if (!response.isSuccessful()) { + try { + final String string = response.errorBody() != null ? response.errorBody().string() : ""; + final String msg = String.format(Locale.US, + "onResponse: url: %s, responseCode: %d, errorBody: %s", + call.request().url().toString(), + response.code(), + string); + Log.e(TAG, msg); + data.postValue(Resource.error(msg, null)); + return; + } catch (IOException e) { + Log.e(TAG, "onResponse: ", e); + } + return; + } + data.postValue(Resource.success(new Object())); + } + + @Override + public void onFailure(@NonNull final Call call, @NonNull final Throwable t) { + Log.e(TAG, "onFailure: ", t); + data.postValue(Resource.error(t.getMessage(), null)); + } + }); return data; } public LiveData> declineRequest() { final MutableLiveData> data = new MutableLiveData<>(); - data.postValue(Resource.success(new Object())); - // final Call request = service.declineRequest(threadId); - // request.enqueue(new Callback() { - // @Override - // public void onResponse(@NonNull final Call call, - // @NonNull final Response response) { - // if (!response.isSuccessful()) { - // try { - // final String string = response.errorBody() != null ? response.errorBody().string() : ""; - // final String msg = String.format(Locale.US, - // "onResponse: url: %s, responseCode: %d, errorBody: %s", - // call.request().url().toString(), - // response.code(), - // string); - // Log.e(TAG, msg); - // data.postValue(Resource.error(msg, null)); - // return; - // } catch (IOException e) { - // Log.e(TAG, "onResponse: ", e); - // } - // return; - // } - // data.postValue(Resource.success(new Object())); - // } - // - // @Override - // public void onFailure(@NonNull final Call call, @NonNull final Throwable t) { - // Log.e(TAG, "onFailure: ", t); - // data.postValue(Resource.error(t.getMessage(), null)); - // } - // }); + final Call request = service.declineRequest(threadId); + request.enqueue(new Callback() { + @Override + public void onResponse(@NonNull final Call call, + @NonNull final Response response) { + if (!response.isSuccessful()) { + try { + final String string = response.errorBody() != null ? response.errorBody().string() : ""; + final String msg = String.format(Locale.US, + "onResponse: url: %s, responseCode: %d, errorBody: %s", + call.request().url().toString(), + response.code(), + string); + Log.e(TAG, msg); + data.postValue(Resource.error(msg, null)); + return; + } catch (IOException e) { + Log.e(TAG, "onResponse: ", e); + } + return; + } + data.postValue(Resource.success(new Object())); + } + + @Override + public void onFailure(@NonNull final Call call, @NonNull final Throwable t) { + Log.e(TAG, "onFailure: ", t); + data.postValue(Resource.error(t.getMessage(), null)); + } + }); return data; }