Skip to content
This repository has been archived by the owner on Sep 14, 2024. It is now read-only.

Commit

Permalink
clean code
Browse files Browse the repository at this point in the history
  • Loading branch information
pasichDev committed May 10, 2024
1 parent b21530e commit 6d1e505
Show file tree
Hide file tree
Showing 7 changed files with 50 additions and 44 deletions.
31 changes: 15 additions & 16 deletions lib/blocs/app_data_bloc.dart
Original file line number Diff line number Diff line change
Expand Up @@ -73,11 +73,11 @@ class AppDataBloc extends Bloc<AppDataEvent, AppDataState> {
await loadConfig();

if (appBlocConfig.lastSeed != null) {
await _selectTargetNode(event, emit, InitialNodeAlgh.connectLastNode);
await _selectTargetNode(event, emit, InitialNodeAlgorithm.connectLastNode);
} else if (appBlocConfig.nodesList != null) {
await _selectTargetNode(event, emit, InitialNodeAlgh.listenUserNodes);
await _selectTargetNode(event, emit, InitialNodeAlgorithm.listenUserNodes);
} else {
await _selectTargetNode(event, emit, InitialNodeAlgh.listenDefaultNodes);
await _selectTargetNode(event, emit, InitialNodeAlgorithm.listenDefaultNodes);
}
}

Expand Down Expand Up @@ -116,16 +116,16 @@ class AppDataBloc extends Bloc<AppDataEvent, AppDataState> {
if (event.lastNodeRun) {
emit(state.copyWith(statusConnected: StatusConnectNodes.sync));
_debugBloc.add(AddStringDebug("Updating data from the last node"));
await _selectTargetNode(event, emit, InitialNodeAlgh.connectLastNode,
await _selectTargetNode(event, emit, InitialNodeAlgorithm.connectLastNode,
repeat: true);
} else {
_debugBloc.add(AddStringDebug("Reconnecting to new node"));
await _selectTargetNode(event, emit, getRandomAlgorithm());
await _selectTargetNode(event, emit, _getRandomAlgorithm());
}
}

/// This method implements the selection of the node to which we will connect in the future
Future<void> _selectTargetNode(event, emit, InitialNodeAlgh initAlgh,
Future<void> _selectTargetNode(event, emit, InitialNodeAlgorithm initAlgh,
{bool repeat = false}) async {
if (!repeat) {
emit(state.copyWith(statusConnected: StatusConnectNodes.searchNode));
Expand All @@ -145,32 +145,32 @@ class AppDataBloc extends Bloc<AppDataEvent, AppDataState> {
_debugBloc.add(AddStringDebug(
"The node did not respond properly -> ${responseTargetNode.seed.toTokenizer}"));
_debugBloc.add(AddStringDebug("Reconnecting to new node"));
await _selectTargetNode(event, emit, getRandomAlgorithm(), repeat: true);
await _selectTargetNode(event, emit, _getRandomAlgorithm(), repeat: true);
}
}

/// A method that selects a random algorithm type
InitialNodeAlgh getRandomAlgorithm() {
InitialNodeAlgorithm _getRandomAlgorithm() {
return Random().nextInt(2) == 0
? InitialNodeAlgh.listenDefaultNodes
: InitialNodeAlgh.listenUserNodes;
? InitialNodeAlgorithm.listenDefaultNodes
: InitialNodeAlgorithm.listenUserNodes;
}

/// A method that tests and returns the active node
Future<ResponseNode<List<int>>> _searchTargetNode(
InitialNodeAlgh initAlgh) async {
InitialNodeAlgorithm initAlgorithm) async {
var listUsersNodes = appBlocConfig.nodesList;
if ((listUsersNodes ?? "").isEmpty) {
initAlgh = InitialNodeAlgh.listenDefaultNodes;
initAlgorithm = InitialNodeAlgorithm.listenDefaultNodes;
}

switch (initAlgh) {
case InitialNodeAlgh.connectLastNode:
switch (initAlgorithm) {
case InitialNodeAlgorithm.connectLastNode:
return await _repositories.networkRepository.fetchNode(
NodeRequest.getNodeStatus,
Seed().tokenizer(NetworkConfig.getRandomNode(null),
rawString: appBlocConfig.lastSeed));
case InitialNodeAlgh.listenUserNodes:
case InitialNodeAlgorithm.listenUserNodes:
return await _repositories.networkRepository.fetchNode(
NodeRequest.getNodeStatus,
Seed().tokenizer(NetworkConfig.getRandomNode(listUsersNodes)));
Expand Down Expand Up @@ -335,7 +335,6 @@ class AppDataBloc extends Bloc<AppDataEvent, AppDataState> {
@override
Future<void> close() {
_stopTimerSyncNetwork();
// _stopSyncPriceHistory();
return super.close();
}

Expand Down
6 changes: 3 additions & 3 deletions lib/main.dart
Original file line number Diff line number Diff line change
Expand Up @@ -34,15 +34,15 @@ Future<void> main() async {
await windowManager.focus();
});
}
runApp(MyApp());
runApp(NosoSova());
}

class NavigationService {
static GlobalKey<NavigatorState> navigatorKey = GlobalKey<NavigatorState>();
}

class MyApp extends StatelessWidget {
MyApp({super.key});
class NosoSova extends StatelessWidget {
NosoSova({super.key});

final AppSettings _appSettings = locator<AppSettings>();

Expand Down
2 changes: 1 addition & 1 deletion lib/ui/common/responses_util/snackbar_message.dart
Original file line number Diff line number Diff line change
@@ -1,8 +1,8 @@
import 'package:flutter/material.dart';
import 'package:nososova/models/responses/response_page_listener.dart';
import 'package:nososova/ui/common/responses_util/responses_messages.dart';
import 'package:nososova/ui/config/responsive.dart';

import '../../config/responsive.dart';
import '../../theme/style/colors.dart';
import '../../theme/style/text_style.dart';

Expand Down
4 changes: 2 additions & 2 deletions lib/ui/dialogs/import_export/dialog_scanner_qr.dart
Original file line number Diff line number Diff line change
Expand Up @@ -10,6 +10,7 @@ import 'package:qr_code_scanner/qr_code_scanner.dart';
import '../../../blocs/events/wallet_events.dart';
import '../../../l10n/app_localizations.dart';
import '../../../models/address_wallet.dart';
import '../../../utils/enum.dart';
import '../../../utils/status_qr.dart';
import '../../common/route/page_router.dart';
import '../../theme/style/colors.dart';
Expand Down Expand Up @@ -75,8 +76,7 @@ class _ScannerQrWidgetState extends State<ScannerQrWidget> {
padding: const EdgeInsets.all(20),
child: Text(
AppLocalizations.of(context)!.cancel,
style:
AppTextStyles.buttonText,
style: AppTextStyles.buttonText,
)),
),
)
Expand Down
10 changes: 8 additions & 2 deletions lib/utils/enum.dart
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@ enum ApiStatus { connected, loading, error, result }

enum ConsensusStatus { sync, error }

enum InitialNodeAlgh { listenDefaultNodes, connectLastNode, listenUserNodes }
enum InitialNodeAlgorithm { listenDefaultNodes, connectLastNode, listenUserNodes }

enum ActionsFileWallet {
walletOpen,
Expand All @@ -20,4 +20,10 @@ enum ActionsFileWallet {

enum FormatWalletFile { pkw, nososova }

enum AddressTileStyle { sDefault, sCustom }
enum AddressTileStyle { sDefault, sCustom }

enum TypeQrCode {
qrAddress,
qrKeys,
none
}
8 changes: 3 additions & 5 deletions lib/utils/status_qr.dart
Original file line number Diff line number Diff line change
@@ -1,3 +1,5 @@
import 'enum.dart';

final class CheckQrCode {

static TypeQrCode checkQrScan(String dataScan) {
Expand All @@ -10,8 +12,4 @@ final class CheckQrCode {
}
}

enum TypeQrCode {
qrAddress,
qrKeys,
none
}

33 changes: 18 additions & 15 deletions sovarpc/lib/blocs/noso_network_bloc.dart
Original file line number Diff line number Diff line change
Expand Up @@ -62,9 +62,11 @@ class NosoNetworkBloc extends Bloc<NetworkNosoEvents, NosoNetworksState> {
await loadConfig();
_debugBloc.add(AddStringDebug("Init Noso-Network", StatusReport.Node));
if (appBlocConfig.nodesList != null) {
await _selectTargetNode(event, emit, InitialNodeAlgh.listenUserNodes);
await _selectTargetNode(
event, emit, InitialNodeAlgorithm.listenUserNodes);
} else {
await _selectTargetNode(event, emit, InitialNodeAlgh.listenDefaultNodes);
await _selectTargetNode(
event, emit, InitialNodeAlgorithm.listenDefaultNodes);
}
}

Expand All @@ -77,49 +79,50 @@ class NosoNetworkBloc extends Bloc<NetworkNosoEvents, NosoNetworksState> {
_stopTimerSyncNetwork();
if (event.lastNodeRun) {
emit(state.copyWith(statusConnected: StatusConnectNodes.sync));
await _selectTargetNode(event, emit, InitialNodeAlgh.connectLastNode,
await _selectTargetNode(event, emit, InitialNodeAlgorithm.connectLastNode,
repeat: true);
} else {
await _selectTargetNode(event, emit, getRandomAlgorithm());
await _selectTargetNode(event, emit, _getRandomAlgorithm());
}
}

/// This method implements the selection of the node to which we will connect in the future
Future<void> _selectTargetNode(event, emit, InitialNodeAlgh initAlgh,
Future<void> _selectTargetNode(
event, emit, InitialNodeAlgorithm initAlgorithm,
{bool repeat = false}) async {
if (!repeat) {
emit(state.copyWith(statusConnected: StatusConnectNodes.searchNode));
_debugBloc.add(AddStringDebug("Reconnect new node", StatusReport.Node));
}

ResponseNode<List<int>> responseTargetNode =
await _searchTargetNode(initAlgh);
await _searchTargetNode(initAlgorithm);
final Node? nodeOutput = DataParser.parseDataNode(
responseTargetNode.value, responseTargetNode.seed);
if (responseTargetNode.errors == null && nodeOutput != null) {
await _syncNetwork(event, emit, nodeOutput);
} else {
await _selectTargetNode(event, emit, getRandomAlgorithm(), repeat: true);
await _selectTargetNode(event, emit, _getRandomAlgorithm(), repeat: true);
}
}

/// A method that selects a random algorithm type
InitialNodeAlgh getRandomAlgorithm() {
InitialNodeAlgorithm _getRandomAlgorithm() {
return Random().nextInt(2) == 0
? InitialNodeAlgh.listenDefaultNodes
: InitialNodeAlgh.listenUserNodes;
? InitialNodeAlgorithm.listenDefaultNodes
: InitialNodeAlgorithm.listenUserNodes;
}

/// A method that tests and returns the active node
Future<ResponseNode<List<int>>> _searchTargetNode(
InitialNodeAlgh initAlgh) async {
InitialNodeAlgorithm initAlgorithm) async {
var listUsersNodes = appBlocConfig.nodesList;
if ((listUsersNodes ?? "").isEmpty) {
initAlgh = InitialNodeAlgh.listenDefaultNodes;
initAlgorithm = InitialNodeAlgorithm.listenDefaultNodes;
}

switch (initAlgh) {
case InitialNodeAlgh.connectLastNode:
switch (initAlgorithm) {
case InitialNodeAlgorithm.connectLastNode:
if (kDebugMode) {
_debugBloc.add(AddStringDebug(
"Receive information from the last active node",
Expand All @@ -129,7 +132,7 @@ class NosoNetworkBloc extends Bloc<NetworkNosoEvents, NosoNetworksState> {
NodeRequest.getNodeStatus,
Seed().tokenizer(NetworkConfig.getRandomNode(null),
rawString: appBlocConfig.lastSeed));
case InitialNodeAlgh.listenUserNodes:
case InitialNodeAlgorithm.listenUserNodes:
if (kDebugMode) {
_debugBloc
.add(AddStringDebug("Search target node", StatusReport.Node));
Expand Down

0 comments on commit 6d1e505

Please sign in to comment.