Skip to content

Commit

Permalink
Fix join room request. Add getRoomById request. Resolve #20
Browse files Browse the repository at this point in the history
  • Loading branch information
Andriy Matkivskiy authored and Andriy Matkivskiy committed Oct 1, 2016
1 parent b579fca commit aea8b1c
Show file tree
Hide file tree
Showing 8 changed files with 41 additions and 37 deletions.
4 changes: 3 additions & 1 deletion Changelog.md
Expand Up @@ -13,4 +13,6 @@

**Rx,Async,Sync:**
- Add `delete` room API
- Remove channels API
- Remove channels API
- Fix `joinRoom` API
- Add `getRoomById` API
Expand Up @@ -53,16 +53,20 @@ void searchUsers(
void searchUsers(@Query("q") String searchTerm, Callback<SearchUsersResponse> callback);

// Rooms Api
@GET("/rooms/{roomId}")
void getRoomById(@Path("roomId") String roomId, Callback<RoomResponse> callback);

@POST("/user/{userId}/rooms")
@FormUrlEncoded
void joinRoom(@Path("userId") String userId, @Field("id") String roomId,
Callback<RoomResponse> callback);

@GET("/rooms/{roomId}/users")
void getRoomUsers(@Path("roomId") String roomId, Callback<List<UserResponse>> callback);

@GET("/user/{userId}/rooms")
void getUserRooms(@Path("userId") String userId, Callback<List<RoomResponse>> callback);

@POST("/rooms")
@FormUrlEncoded
void joinRoom(@Field("uri") String roomUri, Callback<RoomResponse> callback);

@PUT("/rooms/{roomId}")
void updateRoom(@Path("roomId") String roomId, @Body UpdateRoomRequestParam param,
Callback<RoomResponse> callback);
Expand Down
Expand Up @@ -91,8 +91,8 @@ public void getCurrentUserRooms(Callback<List<RoomResponse>> callback) {
api.getCurrentUserRooms(callback);
}

public void joinRoom(String roomUri, Callback<RoomResponse> callback) {
api.joinRoom(roomUri, callback);
public void joinRoom(String userId, String roomId, Callback<RoomResponse> callback) {
api.joinRoom(userId, roomId, callback);
}

public void updateRoom(String roomId, UpdateRoomRequestParam params,
Expand Down
Expand Up @@ -46,6 +46,9 @@ public interface RxGitterApi {
Observable<SearchUsersResponse> searchUsers(@Query("q") String searchTerm);

// Rooms API
@GET("/rooms/{roomId}")
Observable<RoomResponse> getRoomById(@Path("roomId") String roomId);

@GET("/user/{userId}/rooms")
Observable<List<RoomResponse>> getUserRooms(@Path("userId") String userId);

Expand All @@ -55,9 +58,9 @@ public interface RxGitterApi {
@GET("/rooms/{roomId}/users")
Observable<List<UserResponse>> getRoomUsers(@Path("roomId") String roomId);

@POST("/rooms")
@POST("/user/{userId}/rooms")
@FormUrlEncoded
Observable<RoomResponse> joinRoom(@Field("uri") String roomUri);
Observable<RoomResponse> joinRoom(@Path("userId") String userId, @Field("id") String roomId);

@PUT("/rooms/{roomId}")
Observable<RoomResponse> updateRoom(@Path("roomId") String roomId, @Body UpdateRoomRequestParam param);
Expand Down
Expand Up @@ -68,6 +68,10 @@ public List<UserResponse> call(SearchUsersResponse searchUsersResponse) {
}

// Rooms API
public Observable<RoomResponse> getRoomById(String roomId) {
return api.getRoomById(roomId);
}

public Observable<List<RoomResponse>> getUserRooms(String userId) {
return api.getUserRooms(userId);
}
Expand All @@ -80,8 +84,8 @@ public Observable<List<UserResponse>> getRoomUsers(String roomId) {
return api.getRoomUsers(roomId);
}

public Observable<RoomResponse> joinRoom(String roomUri) {
return api.joinRoom(roomUri);
public Observable<RoomResponse> joinRoom(String userId, String roomId) {
return api.joinRoom(userId, roomId);
}

public Observable<RoomResponse> updateRoom(String roomId, UpdateRoomRequestParam params) {
Expand Down
Expand Up @@ -48,9 +48,12 @@ public interface SyncGitterApi {
SearchUsersResponse searchUsers(@Query("q") String searchTerm);

// Rooms API
@POST("/rooms")
@GET("/rooms/{roomId}")
RoomResponse getRoomById(@Path("roomId") String roomId);

@POST("/user/{userId}/rooms")
@FormUrlEncoded
RoomResponse joinRoom(@Field("uri") String roomUri);
RoomResponse joinRoom(@Path("userId") String userId, @Field("id") String roomId);

@GET("/rooms/{roomId}/users")
List<UserResponse> getRoomUsers(@Path("roomId") String roomId);
Expand Down
Expand Up @@ -70,8 +70,8 @@ public List<UserResponse> getRoomUsers(String roomId) {
return api.getRoomUsers(roomId);
}

public RoomResponse joinRoom(String roomUri) {
return api.joinRoom(roomUri);
public RoomResponse joinRoom(String userId, String roomId) {
return api.joinRoom(userId, roomId);
}

public RoomResponse updateRoom(String roomId, UpdateRoomRequestParam params) {
Expand Down
Expand Up @@ -37,28 +37,16 @@ public static void main(String[] args) {
// This is required only for authentication.
GitterDeveloperCredentials.init(new SimpleGitterCredentialsProvider(OAUTH_KEY, OAUTH_SECRET, REDIRECT_URL));

// getAccessTokenSample();
// getUserSample();
// getRoomChatMessages();
// roomMessagesStreamSample();
// leaveRoomSample();
// searchRoomsSample();
// searchUsersSample();
// markMessagesRead();
// getSuggestedRooms();
// roomEventsStreamSample();
testMethod();
}

private static void testMethod() {
RxGitterApiClient client = new RxGitterApiClient.Builder()
.withAccountToken("c2fc54dc5bc835317b7b29f389383611d8940987")
.build();

BooleanResponse result = client.deleteRooom("57edcee740f3a6eec068229e").toBlocking().first();
System.out.println(String.format("success : %s", result.success));

System.exit(0);
getAccessTokenSample();
getUserSample();
getRoomChatMessages();
roomMessagesStreamSample();
leaveRoomSample();
searchRoomsSample();
searchUsersSample();
markMessagesRead();
getSuggestedRooms();
roomEventsStreamSample();
}

private static void roomEventsStreamSample() {
Expand Down

0 comments on commit aea8b1c

Please sign in to comment.