wownero
/
cyberwow
Archived
4
0
Fork 1
Code Issues 3 Pull Requests Releases 9 Wiki Activity

add more final

Browse Source
pull/2/head
fuwa 5 years ago
parent 9c4b3e59f4
commit cbc6ca701c
9 changed files with 44 additions and 39 deletions
Show Stats Download Patch File Download Diff File

4
cyberwow/lib/controller/helper.dart
Unescape View File

@ -25,12 +25,12 @@ import 'dart:io';
import 'package:path_provider/path_provider.dart';
import 'package:flutter/foundation.dart';
Future<String> getBinaryPath(String name) async {
Future<String> getBinaryPath(final String name) async {
final tmpDir = await getTemporaryDirectory();
return tmpDir.path + '/' + name;
}
Future<bool> binaryExists(String name) async {
Future<bool> binaryExists(final String name) async {
final binPath = await getBinaryPath(name);
return new File(binPath).exists();
}

7
cyberwow/lib/controller/process/deploy.dart
Unescape View File

@ -27,7 +27,12 @@ import 'package:flutter/services.dart';
import '../helper.dart';
Stream<String> deployBinary (AssetBundle bundle, String path, String name) async* {
Stream<String> deployBinary
(
final AssetBundle bundle,
final String path,
final String name
) async* {
final binData = await bundle.load(path);
final newPath = await getBinaryPath(name);

2
cyberwow/lib/controller/process/run.dart
Unescape View File

@ -30,7 +30,7 @@ import '../helper.dart';
import '../../config.dart' as config;
import '../../logging.dart';
Stream<String> runBinary (String name, {Stream<String> input}) async* {
Stream<String> runBinary (final String name, {final Stream<String> input}) async* {
final newPath = await getBinaryPath(name);
final appDocDir = await getApplicationDocumentsDirectory();

2
cyberwow/lib/controller/refresh.dart
Unescape View File

@ -30,7 +30,7 @@ import '../logging.dart';
typedef GetNotificationFunc = AppLifecycleState Function();
Stream<Null> pull(GetNotificationFunc getNotification, String puller) async* {
Stream<Null> pull(GetNotificationFunc getNotification, final String puller) async* {
while (true) {
final _appState = getNotification();
log.finer('refresh pull by ${puller}: app state: ${_appState}');

8
cyberwow/lib/controller/rpc/rpc.dart
Unescape View File

@ -31,7 +31,7 @@ import '../../logging.dart';
int rpcID = 0;
Future<http.Response> rpcHTTP(String method) async {
Future<http.Response> rpcHTTP(final String method) async {
final url = 'http://${config.host}:${config.c.port}/json_rpc';
rpcID += 1;
@ -58,9 +58,9 @@ Future<http.Response> rpcHTTP(String method) async {
}
}
dynamic jsonDecode(String responseBody) => json.decode(responseBody);
dynamic jsonDecode(final String responseBody) => json.decode(responseBody);
Future<dynamic> rpc(String method, {String field}) async {
Future<dynamic> rpc(final String method, {final String field}) async {
final response = await rpcHTTP(method);
if (response == null) return null;
@ -76,7 +76,7 @@ Future<dynamic> rpc(String method, {String field}) async {
}
}
Future<String> rpcString(String method, {String field}) async {
Future<String> rpcString(final String method, {final String field}) async {
final _field = await rpc(method, field: field);
return pretty(_field);
}

6
cyberwow/lib/controller/rpc/rpc2.dart
Unescape View File

@ -29,7 +29,7 @@ import '../../config.dart' as config;
import '../../helper.dart';
import '../../logging.dart';
Future<http.Response> rpc2(String method) async {
Future<http.Response> rpc2(final String method) async {
final url = 'http://${config.host}:${config.c.port}/${method}';
try {
@ -44,9 +44,9 @@ Future<http.Response> rpc2(String method) async {
}
}
dynamic jsonDecode(String responseBody) => json.decode(responseBody);
dynamic jsonDecode(final String responseBody) => json.decode(responseBody);
Future<String> rpc2String(String method, {String field}) async {
Future<String> rpc2String(final String method, {final String field}) async {
final response = await rpc2(method);
if (response == null) return '';

8
cyberwow/lib/main.dart
Unescape View File

@ -110,11 +110,11 @@ class _CyberWOW_PageState extends State<CyberWOW_Page> with WidgetsBindingObserv
}
void _updateLoading(LoadingState state, String msg) {
void _updateLoading(LoadingState state, final String msg) {
log.fine('updateLoading: ' + msg);
}
Future<void> buildStateMachine(BlankState _blankState) async {
Future<void> buildStateMachine(final BlankState _blankState) async {
final loadingText = config.c.splash;
LoadingState _loadingState = await _blankState.next(loadingText);
@ -180,7 +180,7 @@ class _CyberWOW_PageState extends State<CyberWOW_Page> with WidgetsBindingObserv
SystemChrome.setEnabledSystemUIOverlays([SystemUiOverlay.bottom]);
BlankState _blankState = BlankState(_setState, _getNotification, _isExiting);
final BlankState _blankState = BlankState(_setState, _getNotification, _isExiting);
_state = _blankState;
buildStateMachine(_blankState);
@ -202,7 +202,7 @@ class _CyberWOW_PageState extends State<CyberWOW_Page> with WidgetsBindingObserv
@override
Widget build(BuildContext context) {
return new WillPopScope
return WillPopScope
(
onWillPop: () => _exitApp(context),
child: _state.use

44
cyberwow/lib/state.dart
Unescape View File

@ -100,12 +100,12 @@ class BlankState extends HookedState {
}
class LoadingState extends HookedState {
String banner;
final String banner;
String status = '';
LoadingState(f1, f2, f3, this.banner) : super (f1, f2, f3);
void append(String msg) {
void append(final String msg) {
this.status += msg;
syncState();
}
@ -149,12 +149,13 @@ class LoadingState extends HookedState {
}
class SyncingState extends HookedState {
Queue<String> stdout = Queue();
final Queue<String> stdout = Queue();
bool synced = false;
SyncingState(f1, f2, f3) : super (f1, f2, f3);
void append(String msg) {
void append(final String msg) {
stdout.addLast(msg);
while (stdout.length > config.stdoutLineBufferSize) {
stdout.removeFirst();
@ -225,20 +226,19 @@ class SyncingState extends HookedState {
}
class SyncedState extends HookedState {
Queue<String> stdout;
final Queue<String> stdout;
final StreamSink<String> processInput;
final Stream<String> processOutput;
final TextEditingController textController = TextEditingController();
int height;
StreamSink<String> processInput;
Stream<String> processOutput;
bool synced = true;
bool connected = true;
Map<String, dynamic> getInfo = {};
String syncInfo = 'syncInfo';
List<dynamic> getConnections = [];
List<dynamic> getTransactionPool = [];
int pageIndex;
final FocusNode focusNode = FocusNode();
final TextEditingController textController = TextEditingController();
String syncInfo = 'syncInfo';
PageController pageController;
SyncedState(f1, f2, f3, this.stdout, this.processInput, this.processOutput, this.pageIndex)
@ -246,12 +246,12 @@ class SyncedState extends HookedState {
pageController = PageController( initialPage: pageIndex );
}
void appendInput(String line) {
void appendInput(final String line) {
stdout.addLast('> ' + line + '\n');
processInput.add(line);
}
void append(String msg) {
void append(final String msg) {
stdout.addLast(msg);
while (stdout.length > config.stdoutLineBufferSize) {
stdout.removeFirst();
@ -293,7 +293,6 @@ class SyncedState extends HookedState {
height = await rpc.height();
connected = await daemon.isConnected();
getInfo = await rpc.getInfoSimple();
// syncInfo = await rpc.syncInfoString();
getConnections = await rpc.getConnectionsSimple();
// getTransactionPool = await rpc.getTransactionPoolString();
@ -328,16 +327,17 @@ class SyncedState extends HookedState {
class ReSyncingState extends HookedState {
Queue<String> stdout;
StreamSink<String> processInput;
Stream<String> processOutput;
bool synced = false;
final Queue<String> stdout;
final StreamSink<String> processInput;
final Stream<String> processOutput;
final int pageIndex;
bool synced = false;
ReSyncingState(f1, f2, f3, this.stdout, this.processInput, this.processOutput, this.pageIndex)
: super (f1, f2, f3);
void append(String msg) {
void append(final String msg) {
stdout.addLast(msg);
while (stdout.length > config.stdoutLineBufferSize) {
stdout.removeFirst();
@ -394,12 +394,12 @@ class ReSyncingState extends HookedState {
}
class ExitingState extends HookedState {
Queue<String> stdout;
Stream<String> processOutput;
final Queue<String> stdout;
final Stream<String> processOutput;
ExitingState(f1, f2, f3, this.stdout, this.processOutput) : super (f1, f2, f3);
void append(String msg) {
void append(final String msg) {
stdout.addLast(msg);
while (stdout.length > config.stdoutLineBufferSize) {
stdout.removeFirst();

2
cyberwow/lib/widget/synced.dart
Unescape View File

@ -170,7 +170,7 @@ Widget terminalView(BuildContext context, String title, SyncedState state) {
border: InputBorder.none,
),
onFieldSubmitted: (v) {
String autoReplace(String x) {
String autoReplace(final String x) {
final words = x.split(' ');
if (words.length == 0) {