jld3103
1 year ago
14 changed files with 43 additions and 244 deletions
@ -1,196 +0,0 @@
|
||||
import 'dart:async'; |
||||
import 'dart:convert'; |
||||
import 'dart:math'; |
||||
|
||||
import 'package:nextcloud/core.dart' as core; |
||||
import 'package:nextcloud/nextcloud.dart'; |
||||
import 'package:process_run/cmd_run.dart'; |
||||
import 'package:test/test.dart'; |
||||
import 'package:universal_io/io.dart'; |
||||
|
||||
const retryCount = 3; |
||||
const timeout = Timeout(Duration(seconds: 30)); |
||||
|
||||
class DockerContainer { |
||||
DockerContainer({ |
||||
required this.id, |
||||
required this.port, |
||||
}); |
||||
|
||||
final String id; |
||||
|
||||
final int port; |
||||
|
||||
Future<void> runOccCommand(final List<String> args) async { |
||||
final result = await runExecutableArguments( |
||||
'docker', |
||||
[ |
||||
'exec', |
||||
id, |
||||
'php', |
||||
'-f', |
||||
'occ', |
||||
...args, |
||||
], |
||||
stdout: stdout, |
||||
stderr: stderr, |
||||
); |
||||
if (result.exitCode != 0) { |
||||
throw Exception('Failed to run occ command'); |
||||
} |
||||
} |
||||
|
||||
void destroy() => unawaited( |
||||
runExecutableArguments( |
||||
'docker', |
||||
[ |
||||
'kill', |
||||
id, |
||||
], |
||||
), |
||||
); |
||||
|
||||
Future<String> serverLogs() async => (await runExecutableArguments( |
||||
'docker', |
||||
[ |
||||
'logs', |
||||
id, |
||||
], |
||||
stdoutEncoding: utf8, |
||||
)) |
||||
.stdout as String; |
||||
|
||||
Future<String> nextcloudLogs() async => (await runExecutableArguments( |
||||
'docker', |
||||
[ |
||||
'exec', |
||||
id, |
||||
'cat', |
||||
'data/nextcloud.log', |
||||
], |
||||
stdoutEncoding: utf8, |
||||
)) |
||||
.stdout as String; |
||||
|
||||
Future<String> allLogs() async => '${await serverLogs()}\n\n${await nextcloudLogs()}'; |
||||
} |
||||
|
||||
Future<NextcloudClient> getTestClient( |
||||
final DockerContainer container, { |
||||
final String? username = 'user1', |
||||
final AppType appType = AppType.unknown, |
||||
final String? userAgentOverride, |
||||
}) async { |
||||
String? appPassword; |
||||
if (username != null) { |
||||
final inputStream = StreamController<List<int>>(); |
||||
final process = runExecutableArguments( |
||||
'docker', |
||||
[ |
||||
'exec', |
||||
'-i', |
||||
container.id, |
||||
'php', |
||||
'-f', |
||||
'occ', |
||||
'user:add-app-password', |
||||
username, |
||||
], |
||||
stdin: inputStream.stream, |
||||
); |
||||
inputStream.add(utf8.encode(username)); |
||||
await inputStream.close(); |
||||
|
||||
final result = await process; |
||||
if (result.exitCode != 0) { |
||||
throw Exception('Failed to run generate app password command\n${result.stderr}\n${result.stdout}'); |
||||
} |
||||
appPassword = (result.stdout as String).split('\n')[1]; |
||||
} |
||||
|
||||
final client = NextcloudClient( |
||||
Uri( |
||||
scheme: 'http', |
||||
host: 'localhost', |
||||
port: container.port, |
||||
), |
||||
loginName: username, |
||||
password: username, |
||||
appPassword: appPassword, |
||||
appType: appType, |
||||
userAgentOverride: userAgentOverride, |
||||
cookieJar: CookieJar(), |
||||
); |
||||
|
||||
var i = 0; |
||||
while (true) { |
||||
try { |
||||
await client.core.getStatus(); |
||||
break; |
||||
} catch (error) { |
||||
if (error is HttpException || error is DynamiteApiException) { |
||||
i++; |
||||
await Future<void>.delayed(const Duration(milliseconds: 100)); |
||||
if (i >= 300) { |
||||
throw TimeoutException('Failed to get the status of the Server. $error'); |
||||
} |
||||
} else { |
||||
rethrow; |
||||
} |
||||
} |
||||
} |
||||
|
||||
return client; |
||||
} |
||||
|
||||
Future<DockerContainer> getDockerContainer() async { |
||||
const dockerImageName = 'ghcr.io/nextcloud/neon/dev'; |
||||
|
||||
var result = await runExecutableArguments( |
||||
'docker', |
||||
[ |
||||
'images', |
||||
'-q', |
||||
dockerImageName, |
||||
], |
||||
); |
||||
if (result.exitCode != 0) { |
||||
throw Exception('Querying docker image failed: ${result.stderr}'); |
||||
} |
||||
if (result.stdout.toString().isEmpty) { |
||||
throw Exception('Missing docker image $dockerImageName. Please build it using ./tool/build-dev-container.sh'); |
||||
} |
||||
|
||||
late int port; |
||||
while (true) { |
||||
port = randomPort(); |
||||
result = await runExecutableArguments( |
||||
'docker', |
||||
[ |
||||
'run', |
||||
'--rm', |
||||
'-d', |
||||
'--add-host', |
||||
'host.docker.internal:host-gateway', |
||||
'-p', |
||||
'$port:80', |
||||
dockerImageName, |
||||
], |
||||
); |
||||
// 125 means the docker run command itself has failed which indicated the port is already used |
||||
if (result.exitCode != 125) { |
||||
break; |
||||
} |
||||
} |
||||
|
||||
if (result.exitCode != 0) { |
||||
throw Exception('Failed to run docker container: ${result.stderr}'); |
||||
} |
||||
|
||||
return DockerContainer( |
||||
id: result.stdout.toString().replaceAll('\n', ''), |
||||
port: port, |
||||
); |
||||
} |
||||
|
||||
int randomPort() => 1024 + Random().nextInt(65535 - 1024); |
||||
Loading…
Reference in new issue