import 'dart:io'; import 'package:basic_utils/basic_utils.dart'; import 'package:device_info_plus/device_info_plus.dart'; import 'package:dio/dio.dart'; import 'package:easy_localization/easy_localization.dart'; import 'package:flutter/foundation.dart'; import 'package:hive/hive.dart'; import 'package:pub_semver/pub_semver.dart'; import 'package:selfprivacy/config/get_it_config.dart'; import 'package:selfprivacy/config/hive_config.dart'; import 'package:selfprivacy/logic/api_maps/rest_maps/api_controller.dart'; import 'package:selfprivacy/logic/api_maps/rest_maps/api_factory_settings.dart'; import 'package:selfprivacy/logic/api_maps/rest_maps/dns_providers/dns_provider.dart'; import 'package:selfprivacy/logic/api_maps/rest_maps/dns_providers/dns_provider_api_settings.dart'; import 'package:selfprivacy/logic/api_maps/graphql_maps/server_api/server_api.dart'; import 'package:selfprivacy/logic/api_maps/rest_maps/server_providers/server_provider.dart'; import 'package:selfprivacy/logic/cubit/server_installation/server_installation_cubit.dart'; import 'package:selfprivacy/logic/models/hive/backblaze_credential.dart'; import 'package:selfprivacy/logic/models/hive/server_details.dart'; import 'package:selfprivacy/logic/models/hive/server_domain.dart'; import 'package:selfprivacy/logic/models/hive/user.dart'; import 'package:selfprivacy/logic/models/json/device_token.dart'; import 'package:selfprivacy/logic/models/json/dns_records.dart'; import 'package:selfprivacy/logic/models/message.dart'; import 'package:selfprivacy/logic/models/server_basic_info.dart'; import 'package:selfprivacy/logic/models/server_type.dart'; import 'package:selfprivacy/ui/helpers/modals.dart'; import 'package:selfprivacy/utils/network_utils.dart'; class IpNotFoundException implements Exception { IpNotFoundException(this.message); final String message; } class ServerAuthorizationException implements Exception { ServerAuthorizationException(this.message); final String message; } class ServerInstallationRepository { Box box = Hive.box(BNames.serverInstallationBox); Box usersBox = Hive.box(BNames.usersBox); Future load() async { final String? providerApiToken = getIt().serverProviderKey; final String? location = getIt().serverLocation; final String? cloudflareToken = getIt().cloudFlareKey; final String? serverTypeIdentificator = getIt().serverType; final ServerDomain? serverDomain = getIt().serverDomain; final ServerProvider? serverProvider = getIt().serverProvider; final BackblazeCredential? backblazeCredential = getIt().backblazeCredential; final ServerHostingDetails? serverDetails = getIt().serverDetails; if (serverProvider != null || (serverDetails != null && serverDetails.provider != ServerProvider.unknown)) { ApiController.initServerProviderApiFactory( ServerProviderApiFactorySettings( provider: serverProvider ?? serverDetails!.provider, location: location, ), ); // All current providers support volumes // so it's safe to hardcode for now ApiController.initVolumeProviderApiFactory( ServerProviderApiFactorySettings( provider: serverProvider ?? serverDetails!.provider, location: location, ), ); } // No other DNS provider is supported for now, so it's fine. ApiController.initDnsProviderApiFactory( DnsProviderApiFactorySettings( provider: DnsProvider.cloudflare, ), ); if (box.get(BNames.hasFinalChecked, defaultValue: false)) { return ServerInstallationFinished( providerApiToken: providerApiToken!, serverTypeIdentificator: serverTypeIdentificator ?? '', cloudFlareKey: cloudflareToken!, serverDomain: serverDomain!, backblazeCredential: backblazeCredential!, serverDetails: serverDetails!, rootUser: box.get(BNames.rootUser), isServerStarted: box.get(BNames.isServerStarted, defaultValue: false), isServerResetedFirstTime: box.get(BNames.isServerResetedFirstTime, defaultValue: false), isServerResetedSecondTime: box.get(BNames.isServerResetedSecondTime, defaultValue: false), ); } if (box.get(BNames.isRecoveringServer, defaultValue: false) && serverDomain != null) { return ServerInstallationRecovery( providerApiToken: providerApiToken, cloudFlareKey: cloudflareToken, serverDomain: serverDomain, backblazeCredential: backblazeCredential, serverDetails: serverDetails, rootUser: box.get(BNames.rootUser), currentStep: _getCurrentRecoveryStep( providerApiToken, cloudflareToken, serverDomain, serverDetails, ), recoveryCapabilities: await getRecoveryCapabilities(serverDomain), ); } return ServerInstallationNotFinished( providerApiToken: providerApiToken, cloudFlareKey: cloudflareToken, serverDomain: serverDomain, backblazeCredential: backblazeCredential, serverDetails: serverDetails, rootUser: box.get(BNames.rootUser), isServerStarted: box.get(BNames.isServerStarted, defaultValue: false), isServerResetedFirstTime: box.get(BNames.isServerResetedFirstTime, defaultValue: false), isServerResetedSecondTime: box.get(BNames.isServerResetedSecondTime, defaultValue: false), isLoading: box.get(BNames.isLoading, defaultValue: false), dnsMatches: null, ); } RecoveryStep _getCurrentRecoveryStep( final String? serverProviderToken, final String? cloudflareToken, final ServerDomain serverDomain, final ServerHostingDetails? serverDetails, ) { if (serverDetails != null) { if (serverProviderToken != null) { if (serverDetails.provider != ServerProvider.unknown) { if (serverDomain.provider != DnsProvider.unknown) { return RecoveryStep.backblazeToken; } return RecoveryStep.cloudflareToken; } return RecoveryStep.serverSelection; } return RecoveryStep.serverProviderToken; } return RecoveryStep.selecting; } void clearAppConfig() { box.clear(); usersBox.clear(); } Future startServer( final ServerHostingDetails server, ) async { ServerHostingDetails serverDetails; serverDetails = await ApiController.currentServerProviderApiFactory! .getServerProvider() .powerOn(); return serverDetails; } Future getDomainId(final String token, final String domain) async { final DnsProviderApi dnsProviderApi = ApiController.currentDnsProviderApiFactory!.getDnsProvider( settings: DnsProviderApiSettings( isWithToken: false, customToken: token, ), ); final String? domainId = await dnsProviderApi.getZoneId(domain); return domainId; } Future> isDnsAddressesMatch( final String? domainName, final String? ip4, final Map skippedMatches, ) async { final List addresses = [ '$domainName', 'api.$domainName', 'cloud.$domainName', 'meet.$domainName', 'password.$domainName' ]; final Map matches = {}; for (final String address in addresses) { if (skippedMatches[address] ?? false) { matches[address] = true; continue; } final List? lookupRecordRes = await DnsUtils.lookupRecord( address, RRecordType.A, provider: DnsApiProvider.CLOUDFLARE, ); getIt.get().addMessage( Message( text: 'DnsLookup: address: $address, $RRecordType, provider: CLOUDFLARE, ip4: $ip4', ), ); getIt.get().addMessage( Message( text: 'DnsLookup: ${lookupRecordRes == null ? 'empty' : (lookupRecordRes[0].data != ip4 ? 'wrong ip4' : 'right ip4')}', ), ); if (lookupRecordRes == null || lookupRecordRes.isEmpty || lookupRecordRes[0].data != ip4) { matches[address] = false; } else { matches[address] = true; } } return matches; } Future createServer( final User rootUser, final String domainName, final String cloudFlareKey, final BackblazeCredential backblazeCredential, { required final void Function() onCancel, required final Future Function(ServerHostingDetails serverDetails) onSuccess, }) async { final ServerProviderApi api = ApiController.currentServerProviderApiFactory!.getServerProvider(); void showInstallationErrorPopUp() { showPopUpAlert( alertTitle: 'modals.unexpected_error'.tr(), description: 'modals.try_again'.tr(), actionButtonTitle: 'modals.yes'.tr(), actionButtonOnPressed: () async { ServerHostingDetails? serverDetails; try { final APIGenericResult createResult = await api.createServer( dnsApiToken: cloudFlareKey, rootUser: rootUser, domainName: domainName, serverType: getIt().serverType!, ); serverDetails = createResult.data; } catch (e) { print(e); } if (serverDetails == null) { print('Server is not initialized!'); return; } await saveServerDetails(serverDetails); onSuccess(serverDetails); }, cancelButtonOnPressed: onCancel, ); } try { final APIGenericResult createServerResult = await api.createServer( dnsApiToken: cloudFlareKey, rootUser: rootUser, domainName: domainName, serverType: getIt().serverType!, ); if (createServerResult.data == null) { const String e = 'Server is not initialized!'; print(e); } if (createServerResult.message == 'uniqueness_error') { showPopUpAlert( alertTitle: 'modals.already_exists'.tr(), description: 'modals.destroy_server'.tr(), actionButtonTitle: 'modals.yes'.tr(), actionButtonOnPressed: () async { await api.deleteServer( domainName: domainName, ); ServerHostingDetails? serverDetails; try { final APIGenericResult createResult = await api.createServer( dnsApiToken: cloudFlareKey, rootUser: rootUser, domainName: domainName, serverType: getIt().serverType!, ); serverDetails = createResult.data; } catch (e) { print(e); } if (serverDetails == null) { print('Server is not initialized!'); return; } await saveServerDetails(serverDetails); onSuccess(serverDetails); }, cancelButtonOnPressed: onCancel, ); return; } saveServerDetails(createServerResult.data!); onSuccess(createServerResult.data!); } catch (e) { print(e); showInstallationErrorPopUp(); } } Future createDnsRecords( final ServerHostingDetails serverDetails, final ServerDomain domain, { required final void Function() onCancel, }) async { final DnsProviderApi dnsProviderApi = ApiController.currentDnsProviderApiFactory!.getDnsProvider(); final ServerProviderApi serverApi = ApiController.currentServerProviderApiFactory!.getServerProvider(); void showDomainErrorPopUp(final String error) { showPopUpAlert( alertTitle: error, description: 'modals.delete_server_volume'.tr(), cancelButtonOnPressed: onCancel, actionButtonTitle: 'basis.delete'.tr(), actionButtonOnPressed: () async { await serverApi.deleteServer( domainName: domain.domainName, ); onCancel(); }, ); } final APIGenericResult removingResult = await dnsProviderApi.removeSimilarRecords( ip4: serverDetails.ip4, domain: domain, ); if (!removingResult.success) { showDomainErrorPopUp('domain.error'.tr()); return false; } bool createdSuccessfully = false; String errorMessage = 'domain.error'.tr(); try { final APIGenericResult createResult = await dnsProviderApi.createMultipleDnsRecords( ip4: serverDetails.ip4, domain: domain, ); createdSuccessfully = createResult.success; } on DioError catch (e) { if (e.response!.data['errors'][0]['code'] == 1038) { errorMessage = 'modals.you_cant_use_this_api'.tr(); } } if (!createdSuccessfully) { showDomainErrorPopUp(errorMessage); return false; } final APIGenericResult createReverseResult = await serverApi.createReverseDns( serverDetails: serverDetails, domain: domain, ); if (!createReverseResult.success) { showDomainErrorPopUp(errorMessage); return false; } return true; } Future createDkimRecord(final ServerDomain cloudFlareDomain) async { final DnsProviderApi dnsProviderApi = ApiController.currentDnsProviderApiFactory!.getDnsProvider(); final ServerApi api = ServerApi(); late DnsRecord record; try { record = extractDkimRecord(await api.getDnsRecords())!; } catch (e) { print(e); rethrow; } await dnsProviderApi.setDnsRecord(record, cloudFlareDomain); } Future isHttpServerWorking() async { final ServerApi api = ServerApi(); return api.isHttpServerWorking(); } Future restart() async => ApiController.currentServerProviderApiFactory! .getServerProvider() .restart(); Future powerOn() async => ApiController.currentServerProviderApiFactory! .getServerProvider() .powerOn(); Future getRecoveryCapabilities( final ServerDomain serverDomain, ) async { final ServerApi serverApi = ServerApi( isWithToken: false, overrideDomain: serverDomain.domainName, ); final String? serverApiVersion = await serverApi.getApiVersion(); if (serverApiVersion == null) { return ServerRecoveryCapabilities.none; } try { final Version parsedVersion = Version.parse(serverApiVersion); if (!VersionConstraint.parse('>=1.2.0').allows(parsedVersion)) { return ServerRecoveryCapabilities.legacy; } return ServerRecoveryCapabilities.loginTokens; } on FormatException { return ServerRecoveryCapabilities.none; } } Future getServerIpFromDomain(final ServerDomain serverDomain) async { final List? lookup = await DnsUtils.lookupRecord( serverDomain.domainName, RRecordType.A, provider: DnsApiProvider.CLOUDFLARE, ); if (lookup == null || lookup.isEmpty) { throw IpNotFoundException('No IP found for domain $serverDomain'); } return lookup[0].data; } Future getDeviceName() async { final DeviceInfoPlugin deviceInfo = DeviceInfoPlugin(); if (kIsWeb) { return deviceInfo.webBrowserInfo.then( (final WebBrowserInfo value) => '${value.browserName} ${value.platform}', ); } else { if (Platform.isAndroid) { return deviceInfo.androidInfo.then( (final AndroidDeviceInfo value) => '${value.model} ${value.version.release}', ); } else if (Platform.isIOS) { return deviceInfo.iosInfo.then( (final IosDeviceInfo value) => '${value.utsname.machine} ${value.systemName} ${value.systemVersion}', ); } else if (Platform.isLinux) { return deviceInfo.linuxInfo .then((final LinuxDeviceInfo value) => value.prettyName); } else if (Platform.isMacOS) { return deviceInfo.macOsInfo.then( (final MacOsDeviceInfo value) => '${value.hostName} ${value.computerName}', ); } else if (Platform.isWindows) { return deviceInfo.windowsInfo .then((final WindowsDeviceInfo value) => value.computerName); } } return 'Unidentified'; } Future authorizeByNewDeviceKey( final ServerDomain serverDomain, final String newDeviceKey, final ServerRecoveryCapabilities recoveryCapabilities, ) async { final ServerApi serverApi = ServerApi( isWithToken: false, overrideDomain: serverDomain.domainName, ); final String serverIp = await getServerIpFromDomain(serverDomain); final APIGenericResult result = await serverApi.authorizeDevice( DeviceToken(device: await getDeviceName(), token: newDeviceKey), ); if (result.success) { return ServerHostingDetails( apiToken: result.data, volume: ServerVolume( id: 0, name: '', sizeByte: 0, serverId: 0, linuxDevice: '', ), provider: ServerProvider.unknown, id: 0, ip4: serverIp, startTime: null, createTime: null, ); } throw ServerAuthorizationException( result.message ?? result.data, ); } Future authorizeByRecoveryKey( final ServerDomain serverDomain, final String recoveryKey, final ServerRecoveryCapabilities recoveryCapabilities, ) async { final ServerApi serverApi = ServerApi( isWithToken: false, overrideDomain: serverDomain.domainName, ); final String serverIp = await getServerIpFromDomain(serverDomain); final APIGenericResult result = await serverApi.useRecoveryToken( DeviceToken(device: await getDeviceName(), token: recoveryKey), ); if (result.success) { return ServerHostingDetails( apiToken: result.data, volume: ServerVolume( id: 0, name: '', sizeByte: 0, serverId: 0, linuxDevice: '', ), provider: ServerProvider.unknown, id: 0, ip4: serverIp, startTime: null, createTime: null, ); } throw ServerAuthorizationException( result.message ?? result.data, ); } Future authorizeByApiToken( final ServerDomain serverDomain, final String apiToken, final ServerRecoveryCapabilities recoveryCapabilities, ) async { final ServerApi serverApi = ServerApi( isWithToken: true, overrideDomain: serverDomain.domainName, customToken: apiToken, ); final String serverIp = await getServerIpFromDomain(serverDomain); if (recoveryCapabilities == ServerRecoveryCapabilities.legacy) { if (await serverApi.isHttpServerWorking()) { return ServerHostingDetails( apiToken: apiToken, volume: ServerVolume( id: 0, name: '', serverId: 0, sizeByte: 0, linuxDevice: '', ), provider: ServerProvider.unknown, id: 0, ip4: serverIp, startTime: null, createTime: null, ); } else { throw ServerAuthorizationException( "Couldn't connect to server with this token", ); } } final APIGenericResult deviceAuthKey = await serverApi.createDeviceToken(); final APIGenericResult result = await serverApi.authorizeDevice( DeviceToken(device: await getDeviceName(), token: deviceAuthKey.data), ); if (result.success) { return ServerHostingDetails( apiToken: result.data, volume: ServerVolume( id: 0, name: '', sizeByte: 0, serverId: 0, linuxDevice: '', ), provider: ServerProvider.unknown, id: 0, ip4: serverIp, startTime: null, createTime: null, ); } throw ServerAuthorizationException( result.message ?? result.data, ); } Future getMainUser() async { final ServerApi serverApi = ServerApi(); const User fallbackUser = User( isFoundOnServer: false, type: UserType.primary, note: "Couldn't find main user on server, API is outdated", login: 'UNKNOWN', sshKeys: [], ); final String? serverApiVersion = await serverApi.getApiVersion(); final users = await serverApi.getAllUsers(); if (serverApiVersion == null || users.isEmpty) { return fallbackUser; } try { final Version parsedVersion = Version.parse(serverApiVersion); if (!VersionConstraint.parse('>=1.2.5').allows(parsedVersion)) { return fallbackUser; } return users.firstWhere( (final User user) => user.type == UserType.primary, ); } on FormatException { return fallbackUser; } } Future> getServersOnProviderAccount() async => ApiController.currentServerProviderApiFactory! .getServerProvider() .getServers(); Future saveServerDetails( final ServerHostingDetails serverDetails, ) async { await getIt().storeServerDetails(serverDetails); } Future deleteServerDetails() async { await box.delete(BNames.serverDetails); getIt().init(); } Future saveServerProviderType(final ServerProvider type) async { await getIt().storeServerProviderType(type); } Future saveServerProviderKey(final String key) async { await getIt().storeServerProviderKey(key); } Future saveServerType(final ServerType serverType) async { await getIt().storeServerTypeIdentifier( serverType.identifier, ); await getIt().storeServerLocation( serverType.location.identifier, ); } Future deleteServerProviderKey() async { await box.delete(BNames.hetznerKey); getIt().init(); } Future saveBackblazeKey( final BackblazeCredential backblazeCredential, ) async { await getIt().storeBackblazeCredential(backblazeCredential); } Future deleteBackblazeKey() async { await box.delete(BNames.backblazeCredential); getIt().init(); } Future saveCloudFlareKey(final String key) async { await getIt().storeCloudFlareKey(key); } Future deleteCloudFlareKey() async { await box.delete(BNames.cloudFlareKey); getIt().init(); } Future saveDomain(final ServerDomain serverDomain) async { await getIt().storeServerDomain(serverDomain); } Future deleteDomain() async { await box.delete(BNames.serverDomain); getIt().init(); } Future saveIsServerStarted(final bool value) async { await box.put(BNames.isServerStarted, value); } Future saveIsServerResetedFirstTime(final bool value) async { await box.put(BNames.isServerResetedFirstTime, value); } Future saveIsServerResetedSecondTime(final bool value) async { await box.put(BNames.isServerResetedSecondTime, value); } Future saveRootUser(final User rootUser) async { await box.put(BNames.rootUser, rootUser); } Future saveIsRecoveringServer(final bool value) async { await box.put(BNames.isRecoveringServer, value); } Future saveHasFinalChecked(final bool value) async { await box.put(BNames.hasFinalChecked, value); } Future deleteServer(final ServerDomain serverDomain) async { final APIGenericResult deletionResult = await ApiController .currentServerProviderApiFactory! .getServerProvider() .deleteServer( domainName: serverDomain.domainName, ); if (!deletionResult.success) { getIt() .showSnackBar('modals.server_validators_error'.tr()); return false; } if (!deletionResult.data) { getIt() .showSnackBar('modals.server_deletion_error'.tr()); return false; } await box.put(BNames.hasFinalChecked, false); await box.put(BNames.isServerStarted, false); await box.put(BNames.isServerResetedFirstTime, false); await box.put(BNames.isServerResetedSecondTime, false); await box.put(BNames.isLoading, false); await box.put(BNames.serverDetails, null); final APIGenericResult removalResult = await ApiController .currentDnsProviderApiFactory! .getDnsProvider() .removeSimilarRecords(domain: serverDomain); if (!removalResult.success) { getIt().showSnackBar('modals.dns_removal_error'.tr()); } return true; } Future deleteServerRelatedRecords() async { await box.deleteAll([ BNames.serverDetails, BNames.isServerStarted, BNames.isServerResetedFirstTime, BNames.isServerResetedSecondTime, BNames.hasFinalChecked, BNames.isLoading, ]); getIt().init(); } }