148 lines
3.6 KiB
Dart
148 lines
3.6 KiB
Dart
import 'dart:async';
|
|
import 'dart:io';
|
|
|
|
import 'package:dio/dio.dart';
|
|
import 'package:selfprivacy/config/get_it_config.dart';
|
|
import 'package:selfprivacy/logic/common_enum/common_enum.dart';
|
|
import 'package:selfprivacy/logic/models/user.dart';
|
|
|
|
import 'api_map.dart';
|
|
|
|
class ServerApi extends ApiMap {
|
|
bool hasLoger;
|
|
bool isWithToken;
|
|
|
|
ServerApi({this.hasLoger = false, this.isWithToken = true});
|
|
|
|
BaseOptions get options {
|
|
var options = BaseOptions();
|
|
|
|
if (isWithToken) {
|
|
var cloudFlareDomain = getIt<ApiConfigModel>().cloudFlareDomain;
|
|
var domainName = cloudFlareDomain!.domainName;
|
|
|
|
options = BaseOptions(baseUrl: 'https://api.$domainName');
|
|
}
|
|
|
|
return options;
|
|
}
|
|
|
|
Future<bool> isHttpServerWorking() async {
|
|
bool res;
|
|
Response response;
|
|
|
|
var client = await getClient();
|
|
try {
|
|
response = await client.get('/services/status');
|
|
res = response.statusCode == HttpStatus.ok;
|
|
} catch (e) {
|
|
res = false;
|
|
}
|
|
close(client);
|
|
return res;
|
|
}
|
|
|
|
Future<bool> createUser(User user) async {
|
|
bool res;
|
|
Response response;
|
|
|
|
var client = await getClient();
|
|
try {
|
|
response = await client.post(
|
|
'/users/create',
|
|
options: Options(
|
|
headers: {
|
|
"X-User": user.login,
|
|
"X-Password": user.password,
|
|
"X-Domain": getIt<ApiConfigModel>().cloudFlareDomain!.domainName
|
|
},
|
|
),
|
|
);
|
|
res = response.statusCode == HttpStatus.ok;
|
|
} catch (e) {
|
|
print(e);
|
|
res = false;
|
|
}
|
|
|
|
close(client);
|
|
return res;
|
|
}
|
|
|
|
String get rootAddress =>
|
|
throw UnimplementedError('not used in with implementation');
|
|
|
|
Future<bool> apply() async {
|
|
bool res;
|
|
Response response;
|
|
|
|
var client = await getClient();
|
|
try {
|
|
response = await client.get(
|
|
'/system/configuration/apply',
|
|
);
|
|
|
|
res = response.statusCode == HttpStatus.ok;
|
|
} catch (e) {
|
|
print(e);
|
|
res = false;
|
|
}
|
|
|
|
close(client);
|
|
return res;
|
|
}
|
|
|
|
Future<void> switchService(ServiceTypes type, bool needToTurnOn) async {
|
|
var client = await getClient();
|
|
client.post('/services/${type.url}/${needToTurnOn ? 'enable' : 'disable'}');
|
|
client.close();
|
|
}
|
|
|
|
Future<void> sendSsh(String ssh) async {
|
|
var client = await getClient();
|
|
client.post(
|
|
'/services/ssh/enable',
|
|
data: {"public_key": ssh},
|
|
);
|
|
client.close();
|
|
}
|
|
|
|
Future<Map<ServiceTypes, bool>> servicesPowerCheck() async {
|
|
var client = await getClient();
|
|
Response response = await client.get('/services/status');
|
|
|
|
close(client);
|
|
return {
|
|
ServiceTypes.passwordManager: response.data['bitwarden'] == 0,
|
|
ServiceTypes.git: response.data['gitea'] == 0,
|
|
ServiceTypes.cloud: response.data['nextcloud'] == 0,
|
|
ServiceTypes.vpn: response.data['ocserv'] == 0,
|
|
ServiceTypes.socialNetwork: response.data['pleroma'] == 0,
|
|
};
|
|
}
|
|
}
|
|
|
|
extension UrlServerExt on ServiceTypes {
|
|
String get url {
|
|
switch (this) {
|
|
// case ServiceTypes.mail:
|
|
// return ''; // cannot be swithch off
|
|
// case ServiceTypes.messenger:
|
|
// return ''; // external service
|
|
// case ServiceTypes.video:
|
|
// return ''; // jeetsu meet not working
|
|
case ServiceTypes.passwordManager:
|
|
return 'bitwarden';
|
|
case ServiceTypes.cloud:
|
|
return 'nextcloud';
|
|
case ServiceTypes.socialNetwork:
|
|
return 'pleroma';
|
|
case ServiceTypes.git:
|
|
return 'gitea';
|
|
case ServiceTypes.vpn:
|
|
return 'ocserv';
|
|
default:
|
|
throw Exception('wrong state');
|
|
}
|
|
}
|
|
}
|