// Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved. // SPDX-License-Identifier: Apache-2.0 import 'dart:async'; import 'dart:convert'; import 'package:amplify_core/amplify_core.dart'; /// {@template amplify_integration_test.amplify_stub} /// A stub of [Amplify] that holds the config in memory and /// does nothing else to register plugins. /// {@endtemplate} class AmplifyStub extends AmplifyClass { /// {@macro amplify_integration_test.amplify_stub} AmplifyStub() : super.protected(); AmplifyConfig? _config; bool _isConfigured = false; final _configCompleter = Completer(); @override bool get isConfigured { return _isConfigured; } @override Future get asyncConfig { return _configCompleter.future; } @override Future addPluginPlatform(AmplifyPluginInterface plugin) async { try { if (plugin is AuthPluginInterface) { await Auth.addPlugin( plugin, authProviderRepo: AmplifyAuthProviderRepository(), ); } else { throw StateError( 'The type of plugin ${plugin.runtimeType} is not yet supported.', ); } } on Exception { throw StateError( 'Amplify plugin ${plugin.runtimeType} was not added successfully.', ); } } @override Future addPlugins(List plugins) => Future.wait(plugins.map(addPlugin)); @override Future configure(String configuration) async { try { jsonDecode(configuration); } on FormatException { throw Exception( 'The provided configuration is not a valid json.', ); } _isConfigured = true; if (_isConfigured && !_configCompleter.isCompleted) { _config = _parseConfigJson(configuration); _configCompleter.complete(_config); } } AmplifyConfig _parseConfigJson(String configuration) { try { return AmplifyConfig.fromJson( jsonDecode(configuration) as Map, ); } on Exception { return const AmplifyConfig(); } } }