80 lines
2.8 KiB
Dart
80 lines
2.8 KiB
Dart
import 'dart:io';
|
|
import 'dart:convert';
|
|
import 'package:http/http.dart' as http;
|
|
import 'package:waylume_server/config/supabase_config.dart';
|
|
import 'package:waylume_server/core/utils.dart';
|
|
import 'package:waylume_server/services/rolling_codes_service.dart';
|
|
|
|
class ServerService {
|
|
static Future<String> registerServer() async {
|
|
await RollingCodesService.initialize();
|
|
|
|
// Server always registers on startup to get fresh operational seed
|
|
|
|
GeolocationData? geolocationData;
|
|
try {
|
|
geolocationData = await getGeolocationData();
|
|
} catch (e) {
|
|
print('Warning: Failed to get geolocation data: $e');
|
|
print('Proceeding with registration without geolocation data');
|
|
}
|
|
|
|
// Generate registration rolling code
|
|
String registrationAuth = RollingCodesService.generateRegistrationCode();
|
|
print('Generated registration auth: $registrationAuth');
|
|
|
|
// Call server-manager registration endpoint
|
|
String serverManagerUrl = 'https://lsdrctuvnwdrzrdyoqzu.supabase.co/functions/v1/server-manager';
|
|
|
|
Map<String, dynamic> requestBody = {
|
|
'server_id': fromEnivronment('SERVER_ID')!,
|
|
"port": int.parse(fromEnivronment('EXTERNAL_PORT') ?? 3000),
|
|
'registration_auth': registrationAuth,
|
|
};
|
|
|
|
// Add geolocation data if available
|
|
if (geolocationData != null) {
|
|
requestBody['geolocation_data'] = {
|
|
"country": geolocationData.countryName,
|
|
"country_code": geolocationData.countryCode,
|
|
"city": geolocationData.city,
|
|
"coords": [
|
|
geolocationData.latitude,
|
|
geolocationData.longitude
|
|
],
|
|
};
|
|
}
|
|
|
|
try {
|
|
final response = await http.post(
|
|
Uri.parse(serverManagerUrl),
|
|
headers: {
|
|
'Content-Type': 'application/json',
|
|
},
|
|
body: jsonEncode(requestBody),
|
|
);
|
|
|
|
if (response.statusCode == 200) {
|
|
final responseData = jsonDecode(response.body);
|
|
if (responseData['success']) {
|
|
// Store operational seed in memory (no persistence needed)
|
|
RollingCodesService.setOperationalSeed(responseData['operational_seed']);
|
|
print('Server registered successfully with server-manager');
|
|
return responseData['operational_seed'];
|
|
} else {
|
|
throw Exception('Registration failed: ${responseData['error']}');
|
|
}
|
|
} else {
|
|
throw Exception('Registration request failed: ${response.statusCode}');
|
|
}
|
|
} catch (e) {
|
|
print('Error registering server: $e');
|
|
throw Exception('Failed to register server: $e');
|
|
}
|
|
}
|
|
|
|
static Future<void> isolatePeers() async {
|
|
await Process.run('iptables', ['-I', 'FORWARD', '-i', 'wg0', '-o', 'wg0', '-j', 'DROP']);
|
|
await Process.run('iptables', ['-I', 'FORWARD', '-i', 'wg0', '-o', 'wg0', '-m', 'state', '--state', 'ESTABLISHED,RELATED', '-j', 'ACCEPT']);
|
|
}
|
|
} |