feat(server-api): Migrate all server endpoints to GraphQL
parent
19b45ac142
commit
1b94e14727
|
|
@ -112,25 +112,6 @@ class ServerApi extends ApiMap
|
|||
return usesBinds;
|
||||
}
|
||||
|
||||
Future<List<ApiToken>> getApiTokens() async {
|
||||
QueryResult response;
|
||||
List<ApiToken> tokens = [];
|
||||
|
||||
try {
|
||||
final GraphQLClient client = await getClient();
|
||||
response = await client.query$GetApiTokens();
|
||||
if (response.hasException) {
|
||||
print(response.exception.toString());
|
||||
}
|
||||
tokens = response.data!['api']['devices']
|
||||
.map<ApiToken>((final e) => ApiToken.fromJson(e))
|
||||
.toList();
|
||||
} catch (e) {
|
||||
print(e);
|
||||
}
|
||||
return tokens;
|
||||
}
|
||||
|
||||
Future<void> switchService(final String uid, final bool needTurnOn) async {
|
||||
try {
|
||||
final GraphQLClient client = await getClient();
|
||||
|
|
@ -283,17 +264,253 @@ class ServerApi extends ApiMap
|
|||
return key;
|
||||
}
|
||||
|
||||
Future<String?> getDkim() async {}
|
||||
Future<String?> getDkim() async {
|
||||
String? dkim;
|
||||
QueryResult<Query$DomainInfo> response;
|
||||
|
||||
Future<ApiResponse<List<ApiToken>>> getApiTokens() async {}
|
||||
try {
|
||||
final GraphQLClient client = await getClient();
|
||||
response = await client.query$DomainInfo();
|
||||
if (response.hasException) {
|
||||
print(response.exception.toString());
|
||||
}
|
||||
dkim = response.parsedData!.system.domainInfo.requiredDnsRecords
|
||||
.firstWhere(
|
||||
(
|
||||
final Query$DomainInfo$system$domainInfo$requiredDnsRecords
|
||||
dnsRecord,
|
||||
) =>
|
||||
dnsRecord.name == 'selector._domainkey' &&
|
||||
dnsRecord.recordType == 'TXT',
|
||||
)
|
||||
.content;
|
||||
} catch (e) {
|
||||
print(e);
|
||||
}
|
||||
|
||||
Future<ApiResponse<void>> deleteApiToken(final String name) async {}
|
||||
return dkim;
|
||||
}
|
||||
|
||||
Future<ApiResponse<String>> createDeviceToken() async {}
|
||||
Future<ApiResponse<List<ApiToken>>> getApiTokens() async {
|
||||
ApiResponse<List<ApiToken>> tokens;
|
||||
QueryResult<Query$GetApiTokens> response;
|
||||
|
||||
Future<BackupStatus> getBackupStatus() async {}
|
||||
try {
|
||||
final GraphQLClient client = await getClient();
|
||||
response = await client.query$GetApiTokens();
|
||||
if (response.hasException) {
|
||||
final message = response.exception.toString();
|
||||
print(message);
|
||||
tokens = ApiResponse<List<ApiToken>>(
|
||||
success: false,
|
||||
data: [],
|
||||
message: message,
|
||||
);
|
||||
}
|
||||
final List<ApiToken> parsed = response.parsedData!.api.devices
|
||||
.map(
|
||||
(
|
||||
final Query$GetApiTokens$api$devices device,
|
||||
) =>
|
||||
ApiToken.fromGraphQL(device),
|
||||
)
|
||||
.toList();
|
||||
tokens = ApiResponse<List<ApiToken>>(
|
||||
success: true,
|
||||
data: parsed,
|
||||
);
|
||||
} catch (e) {
|
||||
print(e);
|
||||
tokens = ApiResponse<List<ApiToken>>(
|
||||
success: false,
|
||||
data: [],
|
||||
message: e.toString(),
|
||||
);
|
||||
}
|
||||
|
||||
Future<List<Backup>> getBackups() async {}
|
||||
return tokens;
|
||||
}
|
||||
|
||||
Future<ApiResponse<void>> deleteApiToken(final String name) async {
|
||||
ApiResponse<void> returnable;
|
||||
QueryResult<Mutation$DeleteDeviceApiToken> response;
|
||||
|
||||
try {
|
||||
final GraphQLClient client = await getClient();
|
||||
|
||||
final variables = Variables$Mutation$DeleteDeviceApiToken(
|
||||
device: name,
|
||||
);
|
||||
final mutation = Options$Mutation$DeleteDeviceApiToken(
|
||||
variables: variables,
|
||||
);
|
||||
response = await client.mutate$DeleteDeviceApiToken(
|
||||
mutation,
|
||||
);
|
||||
if (response.hasException) {
|
||||
print(response.exception.toString());
|
||||
returnable = ApiResponse<void>(
|
||||
success: false,
|
||||
data: null,
|
||||
message: response.exception.toString(),
|
||||
);
|
||||
}
|
||||
returnable = ApiResponse<void>(
|
||||
success: true,
|
||||
data: null,
|
||||
);
|
||||
} catch (e) {
|
||||
print(e);
|
||||
returnable = ApiResponse<void>(
|
||||
success: false,
|
||||
data: null,
|
||||
message: e.toString(),
|
||||
);
|
||||
}
|
||||
|
||||
return returnable;
|
||||
}
|
||||
|
||||
Future<ApiResponse<String>> createDeviceToken() async {
|
||||
ApiResponse<String> token;
|
||||
QueryResult<Mutation$GetNewDeviceApiKey> response;
|
||||
|
||||
try {
|
||||
final GraphQLClient client = await getClient();
|
||||
|
||||
final mutation = Options$Mutation$GetNewDeviceApiKey();
|
||||
response = await client.mutate$GetNewDeviceApiKey(
|
||||
mutation,
|
||||
);
|
||||
if (response.hasException) {
|
||||
print(response.exception.toString());
|
||||
token = ApiResponse<String>(
|
||||
success: false,
|
||||
data: '',
|
||||
message: response.exception.toString(),
|
||||
);
|
||||
}
|
||||
token = ApiResponse<String>(
|
||||
success: true,
|
||||
data: response.parsedData!.getNewDeviceApiKey.key!,
|
||||
);
|
||||
} catch (e) {
|
||||
print(e);
|
||||
token = ApiResponse<String>(
|
||||
success: false,
|
||||
data: '',
|
||||
message: e.toString(),
|
||||
);
|
||||
}
|
||||
|
||||
return token;
|
||||
}
|
||||
|
||||
Future<bool> isHttpServerWorking() async => (await getApiVersion()) != null;
|
||||
|
||||
Future<ApiResponse<String>> authorizeDevice(
|
||||
final DeviceToken deviceToken,
|
||||
) async {
|
||||
ApiResponse<String> token;
|
||||
QueryResult<Mutation$AuthorizeWithNewDeviceApiKey> response;
|
||||
|
||||
try {
|
||||
final GraphQLClient client = await getClient();
|
||||
|
||||
final input = Input$UseNewDeviceKeyInput(
|
||||
deviceName: deviceToken.device,
|
||||
key: deviceToken.token,
|
||||
);
|
||||
|
||||
final variables = Variables$Mutation$AuthorizeWithNewDeviceApiKey(
|
||||
input: input,
|
||||
);
|
||||
final mutation = Options$Mutation$AuthorizeWithNewDeviceApiKey(
|
||||
variables: variables,
|
||||
);
|
||||
response = await client.mutate$AuthorizeWithNewDeviceApiKey(
|
||||
mutation,
|
||||
);
|
||||
if (response.hasException) {
|
||||
print(response.exception.toString());
|
||||
token = ApiResponse<String>(
|
||||
success: false,
|
||||
data: '',
|
||||
message: response.exception.toString(),
|
||||
);
|
||||
}
|
||||
token = ApiResponse<String>(
|
||||
success: true,
|
||||
data: response.parsedData!.authorizeWithNewDeviceApiKey.token!,
|
||||
);
|
||||
} catch (e) {
|
||||
print(e);
|
||||
token = ApiResponse<String>(
|
||||
success: false,
|
||||
data: '',
|
||||
message: e.toString(),
|
||||
);
|
||||
}
|
||||
|
||||
return token;
|
||||
}
|
||||
|
||||
Future<ApiResponse<String>> useRecoveryToken(
|
||||
final DeviceToken deviceToken,
|
||||
) async {
|
||||
ApiResponse<String> token;
|
||||
QueryResult<Mutation$UseRecoveryApiKey> response;
|
||||
|
||||
try {
|
||||
final GraphQLClient client = await getClient();
|
||||
|
||||
final input = Input$UseRecoveryKeyInput(
|
||||
deviceName: deviceToken.device,
|
||||
key: deviceToken.token,
|
||||
);
|
||||
|
||||
final variables = Variables$Mutation$UseRecoveryApiKey(
|
||||
input: input,
|
||||
);
|
||||
final mutation = Options$Mutation$UseRecoveryApiKey(
|
||||
variables: variables,
|
||||
);
|
||||
response = await client.mutate$UseRecoveryApiKey(
|
||||
mutation,
|
||||
);
|
||||
if (response.hasException) {
|
||||
print(response.exception.toString());
|
||||
token = ApiResponse<String>(
|
||||
success: false,
|
||||
data: '',
|
||||
message: response.exception.toString(),
|
||||
);
|
||||
}
|
||||
token = ApiResponse<String>(
|
||||
success: true,
|
||||
data: response.parsedData!.useRecoveryApiKey.token!,
|
||||
);
|
||||
} catch (e) {
|
||||
print(e);
|
||||
token = ApiResponse<String>(
|
||||
success: false,
|
||||
data: '',
|
||||
message: e.toString(),
|
||||
);
|
||||
}
|
||||
|
||||
return token;
|
||||
}
|
||||
|
||||
/// TODO: backups're not implemented on server side
|
||||
|
||||
Future<BackupStatus> getBackupStatus() async => BackupStatus(
|
||||
progress: 0.0,
|
||||
status: BackupStatusEnum.error,
|
||||
errorMessage: null,
|
||||
);
|
||||
|
||||
Future<List<Backup>> getBackups() async => [];
|
||||
|
||||
Future<void> uploadBackblazeConfig(final BackblazeBucket bucket) async {}
|
||||
|
||||
|
|
@ -302,16 +519,4 @@ class ServerApi extends ApiMap
|
|||
Future<void> startBackup() async {}
|
||||
|
||||
Future<void> restoreBackup(final String backupId) async {}
|
||||
|
||||
Future<bool> isHttpServerWorking() async {}
|
||||
|
||||
Future<ApiResponse<String>> authorizeDevice(final DeviceToken token) async {}
|
||||
|
||||
Future<ApiResponse<String>> useRecoveryToken(final DeviceToken token) async {}
|
||||
|
||||
Future<Map<String, bool>> servicesPowerCheck() async {}
|
||||
|
||||
Future<ApiResponse<List<String>>> getUsersList({
|
||||
required final bool withMainUser,
|
||||
}) async {}
|
||||
}
|
||||
|
|
|
|||
|
|
@ -1,870 +0,0 @@
|
|||
import 'dart:async';
|
||||
import 'dart:convert';
|
||||
import 'dart:io';
|
||||
|
||||
import 'package:dio/dio.dart';
|
||||
import 'package:selfprivacy/config/get_it_config.dart';
|
||||
import 'package:selfprivacy/logic/api_maps/rest_maps/api_map.dart';
|
||||
import 'package:selfprivacy/logic/common_enum/common_enum.dart';
|
||||
import 'package:selfprivacy/logic/models/hive/backblaze_bucket.dart';
|
||||
import 'package:selfprivacy/logic/models/hive/server_domain.dart';
|
||||
import 'package:selfprivacy/logic/models/hive/user.dart';
|
||||
import 'package:selfprivacy/logic/models/json/api_token.dart';
|
||||
import 'package:selfprivacy/logic/models/json/backup.dart';
|
||||
import 'package:selfprivacy/logic/models/json/device_token.dart';
|
||||
import 'package:selfprivacy/logic/models/json/recovery_token_status.dart';
|
||||
import 'package:selfprivacy/logic/models/service.dart';
|
||||
import 'package:selfprivacy/logic/models/timezone_settings.dart';
|
||||
|
||||
class ApiResponse<D> {
|
||||
ApiResponse({
|
||||
required this.statusCode,
|
||||
required this.data,
|
||||
this.errorMessage,
|
||||
});
|
||||
final int statusCode;
|
||||
final String? errorMessage;
|
||||
final D data;
|
||||
|
||||
bool get isSuccess => statusCode >= 200 && statusCode < 300;
|
||||
}
|
||||
|
||||
class ServerApi extends ApiMap {
|
||||
ServerApi({
|
||||
this.hasLogger = false,
|
||||
this.isWithToken = true,
|
||||
this.overrideDomain,
|
||||
this.customToken,
|
||||
});
|
||||
@override
|
||||
bool hasLogger;
|
||||
@override
|
||||
bool isWithToken;
|
||||
String? overrideDomain;
|
||||
String? customToken;
|
||||
|
||||
@override
|
||||
BaseOptions get options {
|
||||
BaseOptions options = BaseOptions(
|
||||
connectTimeout: 10000,
|
||||
receiveTimeout: 10000,
|
||||
);
|
||||
|
||||
if (isWithToken) {
|
||||
final ServerDomain? serverDomain = getIt<ApiConfigModel>().serverDomain;
|
||||
final String domainName = serverDomain!.domainName;
|
||||
final String? apiToken = getIt<ApiConfigModel>().serverDetails?.apiToken;
|
||||
|
||||
options = BaseOptions(
|
||||
baseUrl: 'https://api.$domainName',
|
||||
connectTimeout: 10000,
|
||||
receiveTimeout: 10000,
|
||||
headers: {
|
||||
'Authorization': 'Bearer $apiToken',
|
||||
},
|
||||
);
|
||||
}
|
||||
|
||||
if (overrideDomain != null) {
|
||||
options = BaseOptions(
|
||||
baseUrl: 'https://api.$overrideDomain',
|
||||
connectTimeout: 10000,
|
||||
receiveTimeout: 10000,
|
||||
headers: customToken != null
|
||||
? {'Authorization': 'Bearer $customToken'}
|
||||
: null,
|
||||
);
|
||||
}
|
||||
|
||||
return options;
|
||||
}
|
||||
|
||||
Future<String?> getApiVersion() async {
|
||||
Response response;
|
||||
|
||||
final Dio client = await getClient();
|
||||
String? apiVersion;
|
||||
|
||||
try {
|
||||
response = await client.get('/api/version');
|
||||
apiVersion = response.data['version'];
|
||||
} on DioError catch (e) {
|
||||
print(e.message);
|
||||
} finally {
|
||||
close(client);
|
||||
}
|
||||
return apiVersion;
|
||||
}
|
||||
|
||||
Future<bool> isHttpServerWorking() async {
|
||||
bool res = false;
|
||||
Response response;
|
||||
|
||||
final Dio client = await getClient();
|
||||
try {
|
||||
response = await client.get('/services/status');
|
||||
res = response.statusCode == HttpStatus.ok;
|
||||
} catch (e) {
|
||||
print(e);
|
||||
} finally {
|
||||
close(client);
|
||||
}
|
||||
return res;
|
||||
}
|
||||
|
||||
Future<ApiResponse<User>> createUser(final User user) async {
|
||||
Response response;
|
||||
|
||||
final Dio client = await getClient();
|
||||
try {
|
||||
response = await client.post(
|
||||
'/users',
|
||||
data: {
|
||||
'username': user.login,
|
||||
'password': user.password,
|
||||
},
|
||||
);
|
||||
} on DioError catch (e) {
|
||||
print(e.message);
|
||||
return ApiResponse(
|
||||
errorMessage: e.error.toString(),
|
||||
statusCode: e.response?.statusCode ?? HttpStatus.internalServerError,
|
||||
data: User(
|
||||
login: user.login,
|
||||
type: UserType.normal,
|
||||
password: user.password,
|
||||
isFoundOnServer: false,
|
||||
),
|
||||
);
|
||||
} finally {
|
||||
close(client);
|
||||
}
|
||||
|
||||
bool isFoundOnServer = false;
|
||||
int code = 0;
|
||||
|
||||
final bool isUserCreated = (response.statusCode != null) &&
|
||||
(response.statusCode == HttpStatus.created);
|
||||
|
||||
if (isUserCreated) {
|
||||
isFoundOnServer = true;
|
||||
code = response.statusCode!;
|
||||
} else {
|
||||
isFoundOnServer = false;
|
||||
code = HttpStatus.notAcceptable;
|
||||
}
|
||||
|
||||
return ApiResponse(
|
||||
statusCode: code,
|
||||
data: User(
|
||||
login: user.login,
|
||||
type: UserType.normal,
|
||||
password: user.password,
|
||||
isFoundOnServer: isFoundOnServer,
|
||||
),
|
||||
);
|
||||
}
|
||||
|
||||
Future<ApiResponse<List<String>>> getUsersList({
|
||||
final withMainUser = false,
|
||||
}) async {
|
||||
final List<String> res = [];
|
||||
Response response;
|
||||
|
||||
final Dio client = await getClient();
|
||||
try {
|
||||
response = await client.get(
|
||||
'/users',
|
||||
queryParameters: withMainUser ? {'withMainUser': 'true'} : null,
|
||||
);
|
||||
for (final user in response.data) {
|
||||
res.add(user.toString());
|
||||
}
|
||||
} on DioError catch (e) {
|
||||
print(e.message);
|
||||
return ApiResponse(
|
||||
errorMessage: e.message,
|
||||
statusCode: e.response?.statusCode ?? HttpStatus.internalServerError,
|
||||
data: [],
|
||||
);
|
||||
} catch (e) {
|
||||
print(e);
|
||||
return ApiResponse(
|
||||
errorMessage: e.toString(),
|
||||
statusCode: HttpStatus.internalServerError,
|
||||
data: [],
|
||||
);
|
||||
} finally {
|
||||
close(client);
|
||||
}
|
||||
|
||||
final int code = response.statusCode ?? HttpStatus.internalServerError;
|
||||
|
||||
return ApiResponse(
|
||||
statusCode: code,
|
||||
data: res,
|
||||
);
|
||||
}
|
||||
|
||||
Future<ApiResponse<void>> addUserSshKey(
|
||||
final User user,
|
||||
final String sshKey,
|
||||
) async {
|
||||
late Response response;
|
||||
|
||||
final Dio client = await getClient();
|
||||
try {
|
||||
response = await client.post(
|
||||
'/services/ssh/keys/${user.login}',
|
||||
data: {
|
||||
'public_key': sshKey,
|
||||
},
|
||||
);
|
||||
} on DioError catch (e) {
|
||||
print(e.message);
|
||||
return ApiResponse<void>(
|
||||
errorMessage: e.message,
|
||||
statusCode: e.response?.statusCode ?? HttpStatus.internalServerError,
|
||||
data: null,
|
||||
);
|
||||
} finally {
|
||||
close(client);
|
||||
}
|
||||
|
||||
final int code = response.statusCode ?? HttpStatus.internalServerError;
|
||||
|
||||
return ApiResponse<void>(
|
||||
statusCode: code,
|
||||
data: null,
|
||||
);
|
||||
}
|
||||
|
||||
Future<ApiResponse<void>> addRootSshKey(final String ssh) async {
|
||||
late Response response;
|
||||
|
||||
final Dio client = await getClient();
|
||||
try {
|
||||
response = await client.put(
|
||||
'/services/ssh/key/send',
|
||||
data: {'public_key': ssh},
|
||||
);
|
||||
} on DioError catch (e) {
|
||||
print(e.message);
|
||||
return ApiResponse<void>(
|
||||
errorMessage: e.message,
|
||||
statusCode: e.response?.statusCode ?? HttpStatus.internalServerError,
|
||||
data: null,
|
||||
);
|
||||
} finally {
|
||||
close(client);
|
||||
}
|
||||
|
||||
final int code = response.statusCode ?? HttpStatus.internalServerError;
|
||||
|
||||
return ApiResponse<void>(
|
||||
statusCode: code,
|
||||
data: null,
|
||||
);
|
||||
}
|
||||
|
||||
Future<ApiResponse<List<String>>> getUserSshKeys(final User user) async {
|
||||
List<String> res;
|
||||
Response response;
|
||||
|
||||
final Dio client = await getClient();
|
||||
try {
|
||||
response = await client.get('/services/ssh/keys/${user.login}');
|
||||
res = (response.data as List<dynamic>)
|
||||
.map((final e) => e as String)
|
||||
.toList();
|
||||
} on DioError catch (e) {
|
||||
print(e.message);
|
||||
return ApiResponse<List<String>>(
|
||||
errorMessage: e.message,
|
||||
statusCode: e.response?.statusCode ?? HttpStatus.internalServerError,
|
||||
data: [],
|
||||
);
|
||||
} catch (e) {
|
||||
return ApiResponse<List<String>>(
|
||||
errorMessage: e.toString(),
|
||||
statusCode: HttpStatus.internalServerError,
|
||||
data: [],
|
||||
);
|
||||
} finally {
|
||||
close(client);
|
||||
}
|
||||
|
||||
final int code = response.statusCode ?? HttpStatus.internalServerError;
|
||||
|
||||
return ApiResponse<List<String>>(
|
||||
statusCode: code,
|
||||
data: res,
|
||||
errorMessage: response.data is List
|
||||
? null
|
||||
: response.data?.containsKey('error') ?? false
|
||||
? response.data['error']
|
||||
: null,
|
||||
);
|
||||
}
|
||||
|
||||
Future<ApiResponse<void>> deleteUserSshKey(
|
||||
final User user,
|
||||
final String sshKey,
|
||||
) async {
|
||||
Response response;
|
||||
|
||||
final Dio client = await getClient();
|
||||
try {
|
||||
response = await client.delete(
|
||||
'/services/ssh/keys/${user.login}',
|
||||
data: {'public_key': sshKey},
|
||||
);
|
||||
} on DioError catch (e) {
|
||||
print(e.message);
|
||||
return ApiResponse<void>(
|
||||
errorMessage: e.message,
|
||||
statusCode: e.response?.statusCode ?? HttpStatus.internalServerError,
|
||||
data: null,
|
||||
);
|
||||
} finally {
|
||||
close(client);
|
||||
}
|
||||
|
||||
final int code = response.statusCode ?? HttpStatus.internalServerError;
|
||||
|
||||
return ApiResponse<void>(
|
||||
statusCode: code,
|
||||
data: null,
|
||||
errorMessage: response.data?.containsKey('error') ?? false
|
||||
? response.data['error']
|
||||
: null,
|
||||
);
|
||||
}
|
||||
|
||||
Future<bool> deleteUser(final User user) async {
|
||||
bool res = false;
|
||||
Response response;
|
||||
|
||||
final Dio client = await getClient();
|
||||
try {
|
||||
response = await client.delete('/users/${user.login}');
|
||||
res = response.statusCode == HttpStatus.ok ||
|
||||
response.statusCode == HttpStatus.notFound;
|
||||
} on DioError catch (e) {
|
||||
print(e.message);
|
||||
res = false;
|
||||
} finally {
|
||||
close(client);
|
||||
}
|
||||
return res;
|
||||
}
|
||||
|
||||
@override
|
||||
String get rootAddress =>
|
||||
throw UnimplementedError('not used in with implementation');
|
||||
|
||||
Future<bool> apply() async {
|
||||
bool res = false;
|
||||
Response response;
|
||||
|
||||
final Dio client = await getClient();
|
||||
try {
|
||||
response = await client.get('/system/configuration/apply');
|
||||
res = response.statusCode == HttpStatus.ok;
|
||||
} on DioError catch (e) {
|
||||
print(e.message);
|
||||
res = false;
|
||||
} finally {
|
||||
close(client);
|
||||
}
|
||||
return res;
|
||||
}
|
||||
|
||||
Future<void> switchService(
|
||||
final Service service,
|
||||
final bool needToTurnOn,
|
||||
) async {
|
||||
final Dio client = await getClient();
|
||||
try {
|
||||
client.post(
|
||||
'/services/${service.id}/${needToTurnOn ? 'enable' : 'disable'}',
|
||||
);
|
||||
} on DioError catch (e) {
|
||||
print(e.message);
|
||||
} finally {
|
||||
close(client);
|
||||
}
|
||||
}
|
||||
|
||||
Future<Map<String, bool>> servicesPowerCheck() async {
|
||||
Response response;
|
||||
|
||||
final Dio client = await getClient();
|
||||
try {
|
||||
response = await client.get('/services/status');
|
||||
} on DioError catch (e) {
|
||||
print(e.message);
|
||||
return {};
|
||||
} finally {
|
||||
close(client);
|
||||
}
|
||||
|
||||
return {
|
||||
'bitwarden': response.data['bitwarden'] == 0,
|
||||
'gitea': response.data['gitea'] == 0,
|
||||
'nextcloud': response.data['nextcloud'] == 0,
|
||||
'ocserv': response.data['ocserv'] == 0,
|
||||
'pleroma': response.data['pleroma'] == 0,
|
||||
};
|
||||
}
|
||||
|
||||
Future<void> uploadBackblazeConfig(final BackblazeBucket bucket) async {
|
||||
final Dio client = await getClient();
|
||||
try {
|
||||
client.put(
|
||||
'/services/restic/backblaze/config',
|
||||
data: {
|
||||
'accountId': bucket.applicationKeyId,
|
||||
'accountKey': bucket.applicationKey,
|
||||
'bucket': bucket.bucketName,
|
||||
},
|
||||
);
|
||||
} on DioError catch (e) {
|
||||
print(e.message);
|
||||
} finally {
|
||||
close(client);
|
||||
}
|
||||
}
|
||||
|
||||
Future<void> startBackup() async {
|
||||
final Dio client = await getClient();
|
||||
try {
|
||||
client.put('/services/restic/backup/create');
|
||||
} on DioError catch (e) {
|
||||
print(e.message);
|
||||
} finally {
|
||||
close(client);
|
||||
}
|
||||
}
|
||||
|
||||
Future<List<Backup>> getBackups() async {
|
||||
Response response;
|
||||
List<Backup> backups = [];
|
||||
|
||||
final Dio client = await getClient();
|
||||
try {
|
||||
response = await client.get('/services/restic/backup/list');
|
||||
backups =
|
||||
response.data.map<Backup>((final e) => Backup.fromJson(e)).toList();
|
||||
} on DioError catch (e) {
|
||||
print(e.message);
|
||||
} catch (e) {
|
||||
print(e);
|
||||
} finally {
|
||||
close(client);
|
||||
}
|
||||
return backups;
|
||||
}
|
||||
|
||||
Future<BackupStatus> getBackupStatus() async {
|
||||
Response response;
|
||||
BackupStatus status = BackupStatus(
|
||||
status: BackupStatusEnum.error,
|
||||
errorMessage: 'Network error',
|
||||
progress: 0,
|
||||
);
|
||||
|
||||
final Dio client = await getClient();
|
||||
try {
|
||||
response = await client.get('/services/restic/backup/status');
|
||||
status = BackupStatus.fromJson(response.data);
|
||||
} on DioError catch (e) {
|
||||
print(e.message);
|
||||
} finally {
|
||||
close(client);
|
||||
}
|
||||
return status;
|
||||
}
|
||||
|
||||
Future<void> forceBackupListReload() async {
|
||||
final Dio client = await getClient();
|
||||
try {
|
||||
client.get('/services/restic/backup/reload');
|
||||
} on DioError catch (e) {
|
||||
print(e.message);
|
||||
} finally {
|
||||
close(client);
|
||||
}
|
||||
}
|
||||
|
||||
Future<void> restoreBackup(final String backupId) async {
|
||||
final Dio client = await getClient();
|
||||
try {
|
||||
client.put(
|
||||
'/services/restic/backup/restore',
|
||||
data: {'backupId': backupId},
|
||||
);
|
||||
} on DioError catch (e) {
|
||||
print(e.message);
|
||||
} finally {
|
||||
close(client);
|
||||
}
|
||||
}
|
||||
|
||||
Future<bool> pullConfigurationUpdate() async {
|
||||
Response response;
|
||||
bool result = false;
|
||||
|
||||
final Dio client = await getClient();
|
||||
try {
|
||||
response = await client.get('/system/configuration/pull');
|
||||
result = (response.statusCode != null)
|
||||
? (response.statusCode == HttpStatus.ok)
|
||||
: false;
|
||||
} on DioError catch (e) {
|
||||
print(e.message);
|
||||
} finally {
|
||||
close(client);
|
||||
}
|
||||
return result;
|
||||
}
|
||||
|
||||
Future<bool> reboot() async {
|
||||
Response response;
|
||||
bool result = false;
|
||||
|
||||
final Dio client = await getClient();
|
||||
try {
|
||||
response = await client.get('/system/reboot');
|
||||
result = (response.statusCode != null)
|
||||
? (response.statusCode == HttpStatus.ok)
|
||||
: false;
|
||||
} on DioError catch (e) {
|
||||
print(e.message);
|
||||
} finally {
|
||||
close(client);
|
||||
}
|
||||
return result;
|
||||
}
|
||||
|
||||
Future<bool> upgrade() async {
|
||||
Response response;
|
||||
bool result = false;
|
||||
|
||||
final Dio client = await getClient();
|
||||
try {
|
||||
response = await client.get('/system/configuration/upgrade');
|
||||
result = (response.statusCode != null)
|
||||
? (response.statusCode == HttpStatus.ok)
|
||||
: false;
|
||||
} on DioError catch (e) {
|
||||
print(e.message);
|
||||
} finally {
|
||||
close(client);
|
||||
}
|
||||
return result;
|
||||
}
|
||||
|
||||
Future<TimeZoneSettings> getServerTimezone() async {
|
||||
TimeZoneSettings settings = TimeZoneSettings();
|
||||
final Dio client = await getClient();
|
||||
try {
|
||||
final Response response = await client.get(
|
||||
'/system/configuration/timezone',
|
||||
);
|
||||
settings = TimeZoneSettings.fromString(response.data);
|
||||
} catch (e) {
|
||||
print(e);
|
||||
} finally {
|
||||
close(client);
|
||||
}
|
||||
|
||||
return settings;
|
||||
}
|
||||
|
||||
Future<void> updateServerTimezone(final TimeZoneSettings settings) async {
|
||||
final Dio client = await getClient();
|
||||
try {
|
||||
await client.put(
|
||||
'/system/configuration/timezone',
|
||||
data: settings.toString(),
|
||||
);
|
||||
} on DioError catch (e) {
|
||||
print(e.message);
|
||||
} finally {
|
||||
close(client);
|
||||
}
|
||||
}
|
||||
|
||||
Future<String?> getDkim() async {
|
||||
Response response;
|
||||
String? dkim;
|
||||
final Dio client = await getClient();
|
||||
try {
|
||||
response = await client.get('/services/mailserver/dkim');
|
||||
final Codec<String, String> base64toString = utf8.fuse(base64);
|
||||
dkim = base64toString
|
||||
.decode(response.data)
|
||||
.split('(')[1]
|
||||
.split(')')[0]
|
||||
.replaceAll('"', '');
|
||||
} on DioError catch (e) {
|
||||
print(e.message);
|
||||
} finally {
|
||||
close(client);
|
||||
}
|
||||
|
||||
return dkim;
|
||||
}
|
||||
|
||||
Future<ApiResponse<RecoveryKeyStatus?>> getRecoveryTokenStatus() async {
|
||||
Response response;
|
||||
|
||||
final Dio client = await getClient();
|
||||
try {
|
||||
response = await client.get('/auth/recovery_token');
|
||||
} on DioError catch (e) {
|
||||
print(e.message);
|
||||
return ApiResponse(
|
||||
errorMessage: e.message,
|
||||
statusCode: e.response?.statusCode ?? HttpStatus.internalServerError,
|
||||
data: const RecoveryKeyStatus(exists: false, valid: false),
|
||||
);
|
||||
} finally {
|
||||
close(client);
|
||||
}
|
||||
|
||||
final int code = response.statusCode ?? HttpStatus.internalServerError;
|
||||
|
||||
return ApiResponse(
|
||||
statusCode: code,
|
||||
data: response.data != null
|
||||
? RecoveryKeyStatus.fromJson(response.data)
|
||||
: null,
|
||||
);
|
||||
}
|
||||
|
||||
Future<ApiResponse<String>> generateRecoveryToken(
|
||||
final DateTime? expiration,
|
||||
final int? uses,
|
||||
) async {
|
||||
Response response;
|
||||
|
||||
final Dio client = await getClient();
|
||||
final Map data = {};
|
||||
if (expiration != null) {
|
||||
data['expiration'] = '${expiration.toIso8601String()}Z';
|
||||
print(data['expiration']);
|
||||
}
|
||||
if (uses != null) {
|
||||
data['uses'] = uses;
|
||||
}
|
||||
try {
|
||||
response = await client.post(
|
||||
'/auth/recovery_token',
|
||||
data: data,
|
||||
);
|
||||
} on DioError catch (e) {
|
||||
print(e.message);
|
||||
return ApiResponse(
|
||||
errorMessage: e.message,
|
||||
statusCode: e.response?.statusCode ?? HttpStatus.internalServerError,
|
||||
data: '',
|
||||
);
|
||||
} finally {
|
||||
close(client);
|
||||
}
|
||||
|
||||
final int code = response.statusCode ?? HttpStatus.internalServerError;
|
||||
|
||||
return ApiResponse(
|
||||
statusCode: code,
|
||||
data: response.data != null ? response.data['token'] : '',
|
||||
);
|
||||
}
|
||||
|
||||
Future<ApiResponse<String>> useRecoveryToken(final DeviceToken token) async {
|
||||
Response response;
|
||||
|
||||
final Dio client = await getClient();
|
||||
try {
|
||||
response = await client.post(
|
||||
'/auth/recovery_token/use',
|
||||
data: {
|
||||
'token': token.token,
|
||||
'device': token.device,
|
||||
},
|
||||
);
|
||||
} on DioError catch (e) {
|
||||
print(e.message);
|
||||
return ApiResponse(
|
||||
errorMessage: e.message,
|
||||
statusCode: e.response?.statusCode ?? HttpStatus.internalServerError,
|
||||
data: '',
|
||||
);
|
||||
} finally {
|
||||
client.close();
|
||||
}
|
||||
|
||||
final int code = response.statusCode ?? HttpStatus.internalServerError;
|
||||
|
||||
return ApiResponse(
|
||||
statusCode: code,
|
||||
data: response.data != null ? response.data['token'] : '',
|
||||
);
|
||||
}
|
||||
|
||||
Future<ApiResponse<String>> authorizeDevice(final DeviceToken token) async {
|
||||
Response response;
|
||||
|
||||
final Dio client = await getClient();
|
||||
try {
|
||||
response = await client.post(
|
||||
'/auth/new_device/authorize',
|
||||
data: {
|
||||
'token': token.token,
|
||||
'device': token.device,
|
||||
},
|
||||
);
|
||||
} on DioError catch (e) {
|
||||
print(e.message);
|
||||
return ApiResponse(
|
||||
errorMessage: e.message,
|
||||
statusCode: e.response?.statusCode ?? HttpStatus.internalServerError,
|
||||
data: '',
|
||||
);
|
||||
} finally {
|
||||
client.close();
|
||||
}
|
||||
|
||||
final int code = response.statusCode ?? HttpStatus.internalServerError;
|
||||
|
||||
return ApiResponse(statusCode: code, data: response.data['token'] ?? '');
|
||||
}
|
||||
|
||||
Future<ApiResponse<String>> createDeviceToken() async {
|
||||
Response response;
|
||||
|
||||
final Dio client = await getClient();
|
||||
try {
|
||||
response = await client.post('/auth/new_device');
|
||||
} on DioError catch (e) {
|
||||
print(e.message);
|
||||
return ApiResponse(
|
||||
errorMessage: e.message,
|
||||
statusCode: e.response?.statusCode ?? HttpStatus.internalServerError,
|
||||
data: '',
|
||||
);
|
||||
} finally {
|
||||
client.close();
|
||||
}
|
||||
|
||||
final int code = response.statusCode ?? HttpStatus.internalServerError;
|
||||
|
||||
return ApiResponse(
|
||||
statusCode: code,
|
||||
data: response.data != null ? response.data['token'] : '',
|
||||
);
|
||||
}
|
||||
|
||||
Future<ApiResponse<String>> deleteDeviceToken() async {
|
||||
Response response;
|
||||
|
||||
final Dio client = await getClient();
|
||||
try {
|
||||
response = await client.delete('/auth/new_device');
|
||||
} on DioError catch (e) {
|
||||
print(e.message);
|
||||
return ApiResponse(
|
||||
errorMessage: e.message,
|
||||
statusCode: e.response?.statusCode ?? HttpStatus.internalServerError,
|
||||
data: '',
|
||||
);
|
||||
} finally {
|
||||
client.close();
|
||||
}
|
||||
|
||||
final int code = response.statusCode ?? HttpStatus.internalServerError;
|
||||
|
||||
return ApiResponse(statusCode: code, data: response.data ?? '');
|
||||
}
|
||||
|
||||
Future<ApiResponse<List<ApiToken>>> getApiTokens() async {
|
||||
Response response;
|
||||
|
||||
final Dio client = await getClient();
|
||||
try {
|
||||
response = await client.get('/auth/tokens');
|
||||
} on DioError catch (e) {
|
||||
print(e.message);
|
||||
return ApiResponse(
|
||||
errorMessage: e.message,
|
||||
statusCode: e.response?.statusCode ?? HttpStatus.internalServerError,
|
||||
data: [],
|
||||
);
|
||||
} finally {
|
||||
client.close();
|
||||
}
|
||||
|
||||
final int code = response.statusCode ?? HttpStatus.internalServerError;
|
||||
|
||||
return ApiResponse(
|
||||
statusCode: code,
|
||||
data: (response.data != null)
|
||||
? response.data
|
||||
.map<ApiToken>((final e) => ApiToken.fromJson(e))
|
||||
.toList()
|
||||
: [],
|
||||
);
|
||||
}
|
||||
|
||||
Future<ApiResponse<String>> refreshCurrentApiToken() async {
|
||||
Response response;
|
||||
|
||||
final Dio client = await getClient();
|
||||
try {
|
||||
response = await client.post('/auth/tokens');
|
||||
} on DioError catch (e) {
|
||||
print(e.message);
|
||||
return ApiResponse(
|
||||
errorMessage: e.message,
|
||||
statusCode: e.response?.statusCode ?? HttpStatus.internalServerError,
|
||||
data: '',
|
||||
);
|
||||
} finally {
|
||||
client.close();
|
||||
}
|
||||
|
||||
final int code = response.statusCode ?? HttpStatus.internalServerError;
|
||||
|
||||
return ApiResponse(
|
||||
statusCode: code,
|
||||
data: response.data != null ? response.data['token'] : '',
|
||||
);
|
||||
}
|
||||
|
||||
Future<ApiResponse<void>> deleteApiToken(final String device) async {
|
||||
Response response;
|
||||
final Dio client = await getClient();
|
||||
try {
|
||||
response = await client.delete(
|
||||
'/auth/tokens',
|
||||
data: {
|
||||
'token_name': device,
|
||||
},
|
||||
);
|
||||
} on DioError catch (e) {
|
||||
print(e.message);
|
||||
return ApiResponse(
|
||||
errorMessage: e.message,
|
||||
statusCode: e.response?.statusCode ?? HttpStatus.internalServerError,
|
||||
data: null,
|
||||
);
|
||||
} finally {
|
||||
client.close();
|
||||
}
|
||||
|
||||
final int code = response.statusCode ?? HttpStatus.internalServerError;
|
||||
return ApiResponse(statusCode: code, data: null);
|
||||
}
|
||||
}
|
||||
|
|
@ -570,9 +570,7 @@ class ServerInstallationRepository {
|
|||
);
|
||||
final String serverIp = await getServerIpFromDomain(serverDomain);
|
||||
if (recoveryCapabilities == ServerRecoveryCapabilities.legacy) {
|
||||
final Map<String, bool> apiResponse =
|
||||
await serverApi.servicesPowerCheck();
|
||||
if (apiResponse.isNotEmpty) {
|
||||
if (await serverApi.isHttpServerWorking()) {
|
||||
return ServerHostingDetails(
|
||||
apiToken: apiToken,
|
||||
volume: ServerVolume(
|
||||
|
|
@ -634,9 +632,8 @@ class ServerInstallationRepository {
|
|||
);
|
||||
|
||||
final String? serverApiVersion = await serverApi.getApiVersion();
|
||||
final ApiResponse<List<String>> users =
|
||||
await serverApi.getUsersList(withMainUser: true);
|
||||
if (serverApiVersion == null || !users.success) {
|
||||
final users = await serverApi.getAllUsers();
|
||||
if (serverApiVersion == null || users.isEmpty) {
|
||||
return fallbackUser;
|
||||
}
|
||||
try {
|
||||
|
|
@ -644,10 +641,8 @@ class ServerInstallationRepository {
|
|||
if (!VersionConstraint.parse('>=1.2.5').allows(parsedVersion)) {
|
||||
return fallbackUser;
|
||||
}
|
||||
return User(
|
||||
isFoundOnServer: true,
|
||||
login: users.data[0],
|
||||
type: UserType.primary,
|
||||
return users.firstWhere(
|
||||
(final User user) => user.type == UserType.primary,
|
||||
);
|
||||
} on FormatException {
|
||||
return fallbackUser;
|
||||
|
|
|
|||
|
|
@ -1,4 +1,5 @@
|
|||
import 'package:json_annotation/json_annotation.dart';
|
||||
import 'package:selfprivacy/logic/api_maps/graphql_maps/schema/server_api.graphql.dart';
|
||||
|
||||
part 'api_token.g.dart';
|
||||
|
||||
|
|
@ -12,6 +13,14 @@ class ApiToken {
|
|||
required this.isCaller,
|
||||
});
|
||||
|
||||
ApiToken.fromGraphQL(
|
||||
final Query$GetApiTokens$api$devices device,
|
||||
) : this(
|
||||
name: device.name,
|
||||
date: device.creationDate,
|
||||
isCaller: device.isCaller,
|
||||
);
|
||||
|
||||
final String name;
|
||||
final DateTime date;
|
||||
@JsonKey(name: 'is_caller')
|
||||
|
|
|
|||
Loading…
Reference in New Issue