inex/famedlysdk
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

More tests for Client and Connection

Browse source
This commit is contained in:
Christian Pauly 2019-06-18 11:37:06 +02:00
parent ce64c110c8
commit e1352e0f9e
2 changed files with 268 additions and 256 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

199
test/Client_test.dart
View file

@ -24,6 +24,7 @@
import 'package:flutter_test/flutter_test.dart'; import 'package:flutter_test/flutter_test.dart';
import 'package:famedlysdk/src/Client.dart'; import 'package:famedlysdk/src/Client.dart';
import 'package:famedlysdk/src/Connection.dart'; import 'package:famedlysdk/src/Connection.dart';
import 'package:famedlysdk/src/User.dart';
import 'package:famedlysdk/src/sync/EventUpdate.dart'; import 'package:famedlysdk/src/sync/EventUpdate.dart';
import 'package:famedlysdk/src/sync/RoomUpdate.dart'; import 'package:famedlysdk/src/sync/RoomUpdate.dart';
import 'package:famedlysdk/src/sync/UserUpdate.dart'; import 'package:famedlysdk/src/sync/UserUpdate.dart';
@ -43,10 +44,8 @@ void main() {
/// Check if all Elements get created /// Check if all Elements get created
final create = (WidgetTester tester) { final create = (WidgetTester tester) {
matrix = Client("testclient", debug: true);
matrix = Client("testclient");
matrix.connection.httpClient = FakeMatrixApi(); matrix.connection.httpClient = FakeMatrixApi();
matrix.homeserver = "https://fakeServer.notExisting";
roomUpdateListFuture = matrix.connection.onRoomUpdate.stream.toList(); roomUpdateListFuture = matrix.connection.onRoomUpdate.stream.toList();
eventUpdateListFuture = matrix.connection.onEvent.stream.toList(); eventUpdateListFuture = matrix.connection.onEvent.stream.toList();
@ -54,33 +53,23 @@ void main() {
}; };
testWidgets('should get created', create); testWidgets('should get created', create);
test("Get version", () async { test('Login', () async {
final versionResp = Future<ErrorResponse> errorFuture =
await matrix.connection.jsonRequest(type: "GET", action: "/client/versions"); matrix.connection.onError.stream.first;
expect(versionResp is ErrorResponse, false);
expect(versionResp["versions"].indexOf("r0.4.0") != -1, true);
matrix.matrixVersions = List<String>.from(versionResp["versions"]);
matrix.lazyLoadMembers = true;
});
test("Get login types", () async { final bool checkResp1 =
final resp = await matrix.checkServer("https://fakeServer.wrongaddress");
await matrix.connection.jsonRequest(type: "GET", action: "/client/r0/login"); final bool checkResp2 =
expect(resp is ErrorResponse, false); await matrix.checkServer("https://fakeServer.notExisting");
expect(resp["flows"] is List<dynamic>, true);
bool hasMLoginType = false;
for (int i = 0; i < resp["flows"].length; i++)
if (resp["flows"][i]["type"] is String &&
resp["flows"][i]["type"] == "m.login.password") {
hasMLoginType = true;
break;
}
expect(hasMLoginType, true);
});
final loginText = () async{ ErrorResponse checkError = await errorFuture;
final resp = await matrix
.connection.jsonRequest(type: "POST", action: "/client/r0/login", data: { expect(checkResp1, false);
expect(checkResp2, true);
expect(checkError.errcode, "NO_RESPONSE");
final resp = await matrix.connection
.jsonRequest(type: "POST", action: "/client/r0/login", data: {
"type": "m.login.password", "type": "m.login.password",
"user": "test", "user": "test",
"password": "1234", "password": "1234",
@ -88,7 +77,8 @@ void main() {
}); });
expect(resp is ErrorResponse, false); expect(resp is ErrorResponse, false);
Future<LoginState> loginStateFuture = matrix.connection.onLoginStateChanged.stream.first; Future<LoginState> loginStateFuture =
matrix.connection.onLoginStateChanged.stream.first;
Future<bool> firstSyncFuture = matrix.connection.onFirstSync.stream.first; Future<bool> firstSyncFuture = matrix.connection.onFirstSync.stream.first;
Future<dynamic> syncFuture = matrix.connection.onSync.stream.first; Future<dynamic> syncFuture = matrix.connection.onSync.stream.first;
@ -113,22 +103,21 @@ void main() {
expect(loginState, LoginState.logged); expect(loginState, LoginState.logged);
expect(firstSync, true); expect(firstSync, true);
expect(sync["next_batch"] == matrix.prevBatch, true); expect(sync["next_batch"] == matrix.prevBatch, true);
}; });
test('Login', loginText); test('Try to get ErrorResponse', () async {
final resp = await matrix.connection
test('Try to get ErrorResponse', () async{ .jsonRequest(type: "PUT", action: "/non/existing/path");
final resp = await matrix
.connection.jsonRequest(type: "PUT", action: "/non/existing/path");
expect(resp is ErrorResponse, true); expect(resp is ErrorResponse, true);
}); });
test('Logout', () async{ test('Logout', () async {
final dynamic resp = await matrix final dynamic resp = await matrix.connection
.connection.jsonRequest(type: "POST", action: "/client/r0/logout"); .jsonRequest(type: "POST", action: "/client/r0/logout");
expect(resp is ErrorResponse, false); expect(resp is ErrorResponse, false);
Future<LoginState> loginStateFuture = matrix.connection.onLoginStateChanged.stream.first; Future<LoginState> loginStateFuture =
matrix.connection.onLoginStateChanged.stream.first;
matrix.connection.clear(); matrix.connection.clear();
@ -145,101 +134,119 @@ void main() {
expect(loginState, LoginState.loggedOut); expect(loginState, LoginState.loggedOut);
}); });
test('Room Update Test', () async{ test('Room Update Test', () async {
matrix.connection.onRoomUpdate.close(); matrix.connection.onRoomUpdate.close();
List<RoomUpdate> roomUpdateList = await roomUpdateListFuture; List<RoomUpdate> roomUpdateList = await roomUpdateListFuture;
expect(roomUpdateList.length,3); expect(roomUpdateList.length, 3);
expect(roomUpdateList[0].id=="!726s6s6q:example.com", true); expect(roomUpdateList[0].id == "!726s6s6q:example.com", true);
expect(roomUpdateList[0].membership=="join", true); expect(roomUpdateList[0].membership == "join", true);
expect(roomUpdateList[0].prev_batch=="t34-23535_0_0", true); expect(roomUpdateList[0].prev_batch == "t34-23535_0_0", true);
expect(roomUpdateList[0].limitedTimeline==true, true); expect(roomUpdateList[0].limitedTimeline == true, true);
expect(roomUpdateList[0].notification_count==2, true); expect(roomUpdateList[0].notification_count == 2, true);
expect(roomUpdateList[0].highlight_count==2, true); expect(roomUpdateList[0].highlight_count == 2, true);
expect(roomUpdateList[1].id=="!696r7674:example.com", true); expect(roomUpdateList[1].id == "!696r7674:example.com", true);
expect(roomUpdateList[1].membership=="invite", true); expect(roomUpdateList[1].membership == "invite", true);
expect(roomUpdateList[1].prev_batch=="", true); expect(roomUpdateList[1].prev_batch == "", true);
expect(roomUpdateList[1].limitedTimeline==false, true); expect(roomUpdateList[1].limitedTimeline == false, true);
expect(roomUpdateList[1].notification_count==0, true); expect(roomUpdateList[1].notification_count == 0, true);
expect(roomUpdateList[1].highlight_count==0, true); expect(roomUpdateList[1].highlight_count == 0, true);
expect(roomUpdateList[2].id=="!5345234234:example.com", true); expect(roomUpdateList[2].id == "!5345234234:example.com", true);
expect(roomUpdateList[2].membership=="leave", true); expect(roomUpdateList[2].membership == "leave", true);
expect(roomUpdateList[2].prev_batch=="", true); expect(roomUpdateList[2].prev_batch == "", true);
expect(roomUpdateList[2].limitedTimeline==false, true); expect(roomUpdateList[2].limitedTimeline == false, true);
expect(roomUpdateList[2].notification_count==0, true); expect(roomUpdateList[2].notification_count == 0, true);
expect(roomUpdateList[2].highlight_count==0, true); expect(roomUpdateList[2].highlight_count == 0, true);
}); });
test('Event Update Test', () async{ test('Event Update Test', () async {
matrix.connection.onEvent.close(); matrix.connection.onEvent.close();
List<EventUpdate> eventUpdateList = await eventUpdateListFuture; List<EventUpdate> eventUpdateList = await eventUpdateListFuture;
expect(eventUpdateList.length,7); expect(eventUpdateList.length, 7);
expect(eventUpdateList[0].eventType=="m.room.member", true); expect(eventUpdateList[0].eventType == "m.room.member", true);
expect(eventUpdateList[0].roomID=="!726s6s6q:example.com", true); expect(eventUpdateList[0].roomID == "!726s6s6q:example.com", true);
expect(eventUpdateList[0].type=="state", true); expect(eventUpdateList[0].type == "state", true);
expect(eventUpdateList[1].eventType=="m.room.member", true); expect(eventUpdateList[1].eventType == "m.room.member", true);
expect(eventUpdateList[1].roomID=="!726s6s6q:example.com", true); expect(eventUpdateList[1].roomID == "!726s6s6q:example.com", true);
expect(eventUpdateList[1].type=="timeline", true); expect(eventUpdateList[1].type == "timeline", true);
expect(eventUpdateList[2].eventType=="m.room.message", true); expect(eventUpdateList[2].eventType == "m.room.message", true);
expect(eventUpdateList[2].roomID=="!726s6s6q:example.com", true); expect(eventUpdateList[2].roomID == "!726s6s6q:example.com", true);
expect(eventUpdateList[2].type=="timeline", true); expect(eventUpdateList[2].type == "timeline", true);
expect(eventUpdateList[3].eventType=="m.tag", true); expect(eventUpdateList[3].eventType == "m.tag", true);
expect(eventUpdateList[3].roomID=="!726s6s6q:example.com", true); expect(eventUpdateList[3].roomID == "!726s6s6q:example.com", true);
expect(eventUpdateList[3].type=="account_data", true); expect(eventUpdateList[3].type == "account_data", true);
expect(eventUpdateList[4].eventType=="org.example.custom.room.config", true); expect(eventUpdateList[4].eventType == "org.example.custom.room.config",
expect(eventUpdateList[4].roomID=="!726s6s6q:example.com", true); true);
expect(eventUpdateList[4].type=="account_data", true); expect(eventUpdateList[4].roomID == "!726s6s6q:example.com", true);
expect(eventUpdateList[4].type == "account_data", true);
expect(eventUpdateList[5].eventType=="m.room.name", true); expect(eventUpdateList[5].eventType == "m.room.name", true);
expect(eventUpdateList[5].roomID=="!696r7674:example.com", true); expect(eventUpdateList[5].roomID == "!696r7674:example.com", true);
expect(eventUpdateList[5].type=="invite_state", true); expect(eventUpdateList[5].type == "invite_state", true);
expect(eventUpdateList[6].eventType=="m.room.member", true); expect(eventUpdateList[6].eventType == "m.room.member", true);
expect(eventUpdateList[6].roomID=="!696r7674:example.com", true); expect(eventUpdateList[6].roomID == "!696r7674:example.com", true);
expect(eventUpdateList[6].type=="invite_state", true); expect(eventUpdateList[6].type == "invite_state", true);
}); });
test('User Update Test', () async{ test('User Update Test', () async {
matrix.connection.onUserEvent.close(); matrix.connection.onUserEvent.close();
List<UserUpdate> eventUpdateList = await userUpdateListFuture; List<UserUpdate> eventUpdateList = await userUpdateListFuture;
expect(eventUpdateList.length,3); expect(eventUpdateList.length, 3);
expect(eventUpdateList[0].eventType=="m.presence", true); expect(eventUpdateList[0].eventType == "m.presence", true);
expect(eventUpdateList[0].type=="presence", true); expect(eventUpdateList[0].type == "presence", true);
expect(eventUpdateList[1].eventType=="org.example.custom.config", true); expect(eventUpdateList[1].eventType == "org.example.custom.config", true);
expect(eventUpdateList[1].type=="account_data", true); expect(eventUpdateList[1].type == "account_data", true);
expect(eventUpdateList[2].eventType=="m.new_device", true); expect(eventUpdateList[2].eventType == "m.new_device", true);
expect(eventUpdateList[2].type=="to_device", true); expect(eventUpdateList[2].type == "to_device", true);
}); });
testWidgets('should get created', create); testWidgets('should get created', create);
test('Login', loginText); test('Login', () async {
final bool checkResp =
await matrix.checkServer("https://fakeServer.notExisting");
test('Logout when token is unknown', () async{ final bool loginResp = await matrix.login("test", "1234");
Future<LoginState> loginStateFuture = matrix.connection.onLoginStateChanged.stream.first;
final resp = await matrix expect(checkResp, true);
.connection.jsonRequest(type: "DELETE", action: "/unknown/token"); expect(loginResp, true);
});
test('createGroup', () async {
final List<User> users = [
User("@alice:fakeServer.notExisting"),
User("@bob:fakeServer.notExisting")
];
final String newID = await matrix.createGroup(users);
expect(newID, "!1234:fakeServer.notExisting");
});
test('Logout when token is unknown', () async {
Future<LoginState> loginStateFuture =
matrix.connection.onLoginStateChanged.stream.first;
final resp = await matrix.connection
.jsonRequest(type: "DELETE", action: "/unknown/token");
LoginState state = await loginStateFuture; LoginState state = await loginStateFuture;
expect(state, LoginState.loggedOut); expect(state, LoginState.loggedOut);
expect(matrix.isLogged(), false); expect(matrix.isLogged(), false);
}); });
}); });
} }

11
test/FakeMatrixApi.dart
View file

@ -44,6 +44,10 @@ class FakeMatrixApi extends MockClient {
await new Future.delayed(Duration(seconds: 5)); await new Future.delayed(Duration(seconds: 5));
} }
if (request.url.origin != "https://fakeserver.notexisting")
return Response(
"<html><head></head><body>Not found...</body></html>", 50);
// Call API // Call API
if (api.containsKey(method) && api[method].containsKey(action)) if (api.containsKey(method) && api[method].containsKey(action))
res = api[method][action](data); res = api[method][action](data);
@ -204,12 +208,13 @@ class FakeMatrixApi extends MockClient {
}, },
"/client/r0/logout": (var reqI) => {}, "/client/r0/logout": (var reqI) => {},
"/client/r0/logout/all": (var reqI) => {}, "/client/r0/logout/all": (var reqI) => {},
"/client/r0/createRoom": (var reqI) => {
"room_id": "!1234:fakeServer.notExisting",
}
}, },
"PUT": {}, "PUT": {},
"DELETE": { "DELETE": {
"/unknown/token": (var req) => { "/unknown/token": (var req) => {"errcode": "M_UNKNOWN_TOKEN"},
"errcode": "M_UNKNOWN_TOKEN"
},
}, },
}; };
} }