feat: Initial commit
This commit is contained in:
cialloo
442
lib/control_page.dart
Normal file
442
lib/control_page.dart
Normal file
@@ -0,0 +1,442 @@
|
||||
import 'dart:convert';
|
||||
import 'dart:io';
|
||||
|
||||
import 'package:flutter/material.dart';
|
||||
import 'package:winui_n2n/edge_state.dart';
|
||||
import 'package:winui_n2n/saved_connection.dart';
|
||||
import 'package:winui_n2n/shared_pref_singleton.dart';
|
||||
|
||||
class ControlPage extends StatefulWidget {
|
||||
const ControlPage({super.key});
|
||||
|
||||
@override
|
||||
State<ControlPage> createState() => _ControlPageState();
|
||||
}
|
||||
|
||||
class _ControlPageState extends State<ControlPage> {
|
||||
late TextEditingController _supernodeController;
|
||||
late TextEditingController _communityController;
|
||||
late TextEditingController _keyController;
|
||||
late TextEditingController _selfAddressController;
|
||||
late TextEditingController _configNameController;
|
||||
|
||||
bool _edgeConnecting = false;
|
||||
|
||||
@override
|
||||
void initState() {
|
||||
super.initState();
|
||||
_supernodeController = TextEditingController();
|
||||
_communityController = TextEditingController();
|
||||
_keyController = TextEditingController();
|
||||
_selfAddressController = TextEditingController();
|
||||
_configNameController = TextEditingController();
|
||||
}
|
||||
|
||||
@override
|
||||
void dispose() {
|
||||
_supernodeController.dispose();
|
||||
_communityController.dispose();
|
||||
_keyController.dispose();
|
||||
_selfAddressController.dispose();
|
||||
_configNameController.dispose();
|
||||
|
||||
super.dispose();
|
||||
}
|
||||
|
||||
@override
|
||||
Widget build(BuildContext context) {
|
||||
return Column(
|
||||
mainAxisAlignment: MainAxisAlignment.center,
|
||||
children: [
|
||||
Padding(
|
||||
padding: const EdgeInsets.all(8.0),
|
||||
child: SizedBox(
|
||||
width: 300,
|
||||
child: TextField(
|
||||
controller: _supernodeController,
|
||||
decoration: const InputDecoration(
|
||||
border: OutlineInputBorder(),
|
||||
labelText: '主服务器',
|
||||
),
|
||||
),
|
||||
),
|
||||
),
|
||||
Padding(
|
||||
padding: const EdgeInsets.all(8.0),
|
||||
child: SizedBox(
|
||||
width: 300,
|
||||
child: TextField(
|
||||
controller: _communityController,
|
||||
decoration: const InputDecoration(
|
||||
border: OutlineInputBorder(),
|
||||
labelText: '网络社区',
|
||||
),
|
||||
),
|
||||
),
|
||||
),
|
||||
Padding(
|
||||
padding: const EdgeInsets.all(8.0),
|
||||
child: SizedBox(
|
||||
width: 300,
|
||||
child: TextField(
|
||||
controller: _keyController,
|
||||
obscureText: true,
|
||||
decoration: const InputDecoration(
|
||||
border: OutlineInputBorder(),
|
||||
labelText: '社区密码',
|
||||
),
|
||||
),
|
||||
),
|
||||
),
|
||||
Padding(
|
||||
padding: const EdgeInsets.all(8.0),
|
||||
child: SizedBox(
|
||||
width: 300,
|
||||
child: TextField(
|
||||
controller: _selfAddressController,
|
||||
decoration: const InputDecoration(
|
||||
border: OutlineInputBorder(),
|
||||
labelText: '我的地址',
|
||||
),
|
||||
),
|
||||
),
|
||||
),
|
||||
Padding(
|
||||
padding: const EdgeInsets.all(8.0),
|
||||
child: Row(
|
||||
mainAxisAlignment: MainAxisAlignment.center,
|
||||
children: [
|
||||
TextButton(
|
||||
onPressed: () => showDialog<String>(
|
||||
context: context,
|
||||
builder: (BuildContext context) => Dialog(
|
||||
child: Padding(
|
||||
padding: const EdgeInsets.all(8.0),
|
||||
child: Column(
|
||||
mainAxisSize: MainAxisSize.min,
|
||||
mainAxisAlignment: MainAxisAlignment.center,
|
||||
children: <Widget>[
|
||||
SizedBox(
|
||||
width: 350,
|
||||
child: TextField(
|
||||
controller: _configNameController,
|
||||
decoration: const InputDecoration(
|
||||
border: OutlineInputBorder(),
|
||||
labelText: '给这个配置备注一个名字',
|
||||
),
|
||||
),
|
||||
),
|
||||
const SizedBox(height: 15),
|
||||
Row(
|
||||
mainAxisAlignment: MainAxisAlignment.center,
|
||||
mainAxisSize: MainAxisSize.min,
|
||||
children: [
|
||||
TextButton(
|
||||
onPressed: () {
|
||||
List<dynamic> nodeList = jsonDecode(
|
||||
SharedPrefSingleton().savedConnection);
|
||||
List<SavedConnection> nodes = nodeList
|
||||
.cast<Map<String, dynamic>>()
|
||||
.map((nodeData) =>
|
||||
SavedConnection.fromJson(nodeData))
|
||||
.toList();
|
||||
nodes.add(SavedConnection(
|
||||
_configNameController.text,
|
||||
_supernodeController.text,
|
||||
_communityController.text,
|
||||
_keyController.text,
|
||||
_selfAddressController.text,
|
||||
));
|
||||
|
||||
List<Map<String, dynamic>> nodeMaps = nodes
|
||||
.map((node) => node.toJson())
|
||||
.toList();
|
||||
String jsonString = jsonEncode(nodeMaps);
|
||||
SharedPrefSingleton()
|
||||
.setSavedConnection(jsonString);
|
||||
|
||||
Navigator.pop(context);
|
||||
return;
|
||||
},
|
||||
child: const Text("保存")),
|
||||
TextButton(
|
||||
onPressed: () {
|
||||
Navigator.pop(context);
|
||||
return;
|
||||
},
|
||||
child: const Text('取消'),
|
||||
),
|
||||
],
|
||||
),
|
||||
],
|
||||
),
|
||||
),
|
||||
),
|
||||
),
|
||||
child: const Text('保存配置'),
|
||||
),
|
||||
ElevatedButton(
|
||||
onPressed: _edgeConnecting
|
||||
? null
|
||||
: () async {
|
||||
if (EdgeState.instance.isRunning) {
|
||||
// Turn on firewall
|
||||
if (SharedPrefSingleton().autoFirewall) {
|
||||
await Process.run(
|
||||
"netsh.exe",
|
||||
[
|
||||
"advfirewall",
|
||||
"set",
|
||||
"allprofiles",
|
||||
"state",
|
||||
"on",
|
||||
],
|
||||
);
|
||||
}
|
||||
|
||||
// Kill the edge process
|
||||
if (EdgeState.instance.process != null) {
|
||||
if (EdgeState.instance.process!.kill()) {
|
||||
EdgeState.instance.isRunning = false;
|
||||
EdgeState.instance.process = null;
|
||||
setState(() {});
|
||||
}
|
||||
}
|
||||
} else if (!EdgeState.instance.isRunning) {
|
||||
// Block user click
|
||||
setState(() {
|
||||
_edgeConnecting = true;
|
||||
});
|
||||
|
||||
// Check for tap device
|
||||
final findTapResult = await Process.run(
|
||||
"./tools/driver/devcon.exe",
|
||||
["hwids", "tap0901"],
|
||||
);
|
||||
if (findTapResult.stdout
|
||||
.toString()
|
||||
.contains('No matching devices found.')) {
|
||||
// Install tap device
|
||||
EdgeState.instance.logger
|
||||
.addLog("Tap device not found, installing tap");
|
||||
debugPrint("Tap device not found, installing tap");
|
||||
final installTapResult = await Process.run(
|
||||
"./tools/driver/devcon.exe",
|
||||
[
|
||||
"install",
|
||||
"./tools/driver/OemVista.inf",
|
||||
"tap0901",
|
||||
],
|
||||
);
|
||||
if (installTapResult.stdout.toString().contains(
|
||||
"Tap driver installed successfully.") ||
|
||||
installTapResult.stdout.toString().contains(
|
||||
"Drivers installed successfully.")) {
|
||||
EdgeState.instance.logger
|
||||
.addLog("Tap driver installed successfully.");
|
||||
debugPrint("Tap driver installed successfully.");
|
||||
} else {
|
||||
EdgeState.instance.logger
|
||||
.addLog("Tap driver install failed.");
|
||||
debugPrint("Tap driver install failed.");
|
||||
}
|
||||
} else {
|
||||
// Ignore.
|
||||
EdgeState.instance.logger
|
||||
.addLog("Tap device already installed");
|
||||
debugPrint("Tap device already installed");
|
||||
}
|
||||
|
||||
// Close firewall
|
||||
if (SharedPrefSingleton().autoFirewall) {
|
||||
await Process.run(
|
||||
"netsh.exe",
|
||||
[
|
||||
"advfirewall",
|
||||
"set",
|
||||
"allprofiles",
|
||||
"state",
|
||||
"off",
|
||||
],
|
||||
);
|
||||
}
|
||||
|
||||
// Start the edge
|
||||
// edge -c <community> -k <communityKey> -a <selfAddress> -r -l <remoteSuperNodeAddress>
|
||||
Process.start(
|
||||
"./tools/edge/edge.exe",
|
||||
[
|
||||
"-l",
|
||||
_supernodeController.text,
|
||||
"-c",
|
||||
_communityController.text,
|
||||
"-k",
|
||||
_keyController.text,
|
||||
"-a",
|
||||
_selfAddressController.text,
|
||||
"-r",
|
||||
],
|
||||
).then((process) async {
|
||||
EdgeState.instance.isRunning = true;
|
||||
EdgeState.instance.process = process;
|
||||
EdgeState.instance.logger
|
||||
.addLog("edge.exe starting");
|
||||
debugPrint("edge.exe starting");
|
||||
setState(() {
|
||||
_edgeConnecting = false;
|
||||
});
|
||||
process.stdout
|
||||
.transform(const SystemEncoding().decoder)
|
||||
.listen((data) {
|
||||
debugPrint('stdout: $data');
|
||||
EdgeState.instance.logger.addLog(data);
|
||||
});
|
||||
|
||||
await process.exitCode;
|
||||
EdgeState.instance.isRunning = false;
|
||||
EdgeState.instance.process = null;
|
||||
EdgeState.instance.logger
|
||||
.addLog("edge.exe closing");
|
||||
debugPrint("edge.exe closing");
|
||||
if (!mounted) return;
|
||||
setState(() {});
|
||||
});
|
||||
}
|
||||
},
|
||||
child: EdgeState.instance.isRunning
|
||||
? const Text("断开连接")
|
||||
: const Text("开始连接"),
|
||||
),
|
||||
TextButton(
|
||||
onPressed: () {
|
||||
SavedConnection? selectedSavedConnection;
|
||||
showDialog<String>(
|
||||
context: context,
|
||||
builder: (BuildContext context) => Dialog(
|
||||
child: Padding(
|
||||
padding: const EdgeInsets.all(8.0),
|
||||
child: Column(
|
||||
mainAxisSize: MainAxisSize.min,
|
||||
mainAxisAlignment: MainAxisAlignment.center,
|
||||
children: <Widget>[
|
||||
Builder(builder: (context) {
|
||||
String jsonString =
|
||||
SharedPrefSingleton().savedConnection;
|
||||
List<dynamic> nodeList = jsonDecode(jsonString);
|
||||
List<SavedConnection> nodes = nodeList
|
||||
.cast<Map<String, dynamic>>()
|
||||
.map((nodeData) =>
|
||||
SavedConnection.fromJson(nodeData))
|
||||
.toList();
|
||||
|
||||
return StatefulBuilder(builder:
|
||||
(BuildContext context,
|
||||
StateSetter setState) {
|
||||
return DropdownButton(
|
||||
value: selectedSavedConnection,
|
||||
items: nodes.map<
|
||||
DropdownMenuItem<
|
||||
SavedConnection>>(
|
||||
(SavedConnection value) {
|
||||
return DropdownMenuItem<
|
||||
SavedConnection>(
|
||||
value: value,
|
||||
child: Text(value.name),
|
||||
);
|
||||
}).toList(),
|
||||
onChanged: (value) {
|
||||
setState(
|
||||
() {
|
||||
selectedSavedConnection = value!;
|
||||
},
|
||||
);
|
||||
});
|
||||
});
|
||||
}),
|
||||
const SizedBox(height: 15),
|
||||
Row(
|
||||
mainAxisSize: MainAxisSize.min,
|
||||
mainAxisAlignment: MainAxisAlignment.center,
|
||||
children: [
|
||||
TextButton(
|
||||
onPressed: () {
|
||||
if (selectedSavedConnection != null) {
|
||||
_supernodeController.text =
|
||||
selectedSavedConnection!.supernode;
|
||||
_communityController.text =
|
||||
selectedSavedConnection!.community;
|
||||
_keyController.text =
|
||||
selectedSavedConnection!
|
||||
.communityKey;
|
||||
_selfAddressController.text =
|
||||
selectedSavedConnection!
|
||||
.selfAddress;
|
||||
}
|
||||
|
||||
Navigator.pop(context);
|
||||
return;
|
||||
},
|
||||
child: const Text('使用'),
|
||||
),
|
||||
TextButton(
|
||||
onPressed: () {
|
||||
if (selectedSavedConnection == null) {
|
||||
Navigator.pop(context);
|
||||
return;
|
||||
}
|
||||
|
||||
String jsonString =
|
||||
SharedPrefSingleton().savedConnection;
|
||||
List<dynamic> nodeList =
|
||||
jsonDecode(jsonString);
|
||||
List<SavedConnection> nodes = nodeList
|
||||
.cast<Map<String, dynamic>>()
|
||||
.map((nodeData) =>
|
||||
SavedConnection.fromJson(
|
||||
nodeData))
|
||||
.toList();
|
||||
|
||||
nodes.removeWhere(
|
||||
(element) {
|
||||
return element.name ==
|
||||
selectedSavedConnection!.name;
|
||||
},
|
||||
);
|
||||
|
||||
List<Map<String, dynamic>> nodeMaps =
|
||||
nodes
|
||||
.map((node) => node.toJson())
|
||||
.toList();
|
||||
SharedPrefSingleton()
|
||||
.setSavedConnection(
|
||||
jsonEncode(nodeMaps))
|
||||
.then((onValue) {
|
||||
Navigator.pop(context);
|
||||
return;
|
||||
});
|
||||
},
|
||||
child: const Text('删除'),
|
||||
),
|
||||
TextButton(
|
||||
onPressed: () {
|
||||
Navigator.pop(context);
|
||||
return;
|
||||
},
|
||||
child: const Text("取消"),
|
||||
),
|
||||
],
|
||||
),
|
||||
],
|
||||
),
|
||||
),
|
||||
),
|
||||
);
|
||||
},
|
||||
child: const Text("使用配置")),
|
||||
],
|
||||
),
|
||||
),
|
||||
],
|
||||
);
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user