Line data    Source code

       1              : // Copyright 2023 The terCAD team. All rights reserved.
       2              : // Use of this source code is governed by a CC BY-NC-ND 4.0 license that can be found in the LICENSE file.
       3              : 
       4              : import 'package:app_finance/_classes/herald/app_locale.dart';
       5              : import 'package:app_finance/_classes/storage/transaction_log/abstract_protocol.dart';
       6              : import 'package:app_finance/_classes/storage/transaction_log/interface_protocol.dart';
       7              : import 'package:app_finance/_classes/storage/transaction_log/web_dav_data.dart';
       8              : import 'package:flutter/foundation.dart';
       9              : import 'package:webdav_client/webdav_client.dart';
      10              : 
      11              : class WebDavProtocol extends AbstractProtocol implements InterfaceProtocol {
      12              :   @override
      13              :   final Function callbackMessage;
      14              :   @override
      15              :   final Function callbackProgress;
      16              :   String message = '';
      17              :   bool inProgress = false;
      18              : 
      19            0 :   WebDavProtocol({
      20              :     required this.callbackMessage,
      21              :     required this.callbackProgress,
      22              :   });
      23              : 
      24            0 :   Future<Client?> _connect(WebDavData data) async {
      25            0 :     if (data.isEmpty()) {
      26            0 :       callbackMessage(message = AppLocale.labels.isRequired);
      27              :       return null;
      28              :     }
      29            0 :     callbackProgress(inProgress = true);
      30            0 :     Client? client = newClient(data.link, user: data.username, password: data.password);
      31            0 :     client = await client.ping().then((_) => client).onError((error, _) {
      32            0 :       callbackMessage(message = AppLocale.labels.error(error.toString()));
      33            0 :       callbackProgress(inProgress = false);
      34              :       return null;
      35              :     });
      36              :     return client;
      37              :   }
      38              : 
      39            0 :   @override
      40              :   Future<void> save(data) async {
      41            0 :     final client = await _connect(data);
      42              :     if (client == null) {
      43              :       return;
      44              :     }
      45            0 :     final codeUnits = await exportTransactions();
      46            0 :     final Uint8List unit8List = Uint8List.fromList(codeUnits);
      47            0 :     callbackMessage(message = '');
      48            0 :     await client.write(data.path, unit8List).catchError((err) {
      49            0 :       callbackMessage(message = AppLocale.labels.error(err.toString()));
      50            0 :       callbackProgress(inProgress = false);
      51              :     });
      52            0 :     callbackProgress(inProgress = false);
      53            0 :     if (message == '') {
      54            0 :       callbackMessage(message = AppLocale.labels.success);
      55              :     }
      56              :   }
      57              : 
      58            0 :   @override
      59              :   Future<void> load(data, [bool isEncrypted = true, bool isCleaned = false]) async {
      60            0 :     final client = await _connect(data);
      61              :     if (client == null) {
      62              :       return;
      63              :     }
      64            0 :     final content = await client.read(data.path).catchError((err) {
      65            0 :       callbackMessage(message = AppLocale.labels.error(err.toString()));
      66            0 :       callbackProgress(inProgress = false);
      67            0 :       return Future<List<int>>.value([]);
      68              :     });
      69              :     if (isCleaned) {
      70            0 :       clearTransactions();
      71              :     }
      72            0 :     importTransactions(content, isEncrypted);
      73            0 :     callbackProgress(inProgress = false);
      74            0 :     if (message == '') {
      75            0 :       callbackMessage(message = AppLocale.labels.success);
      76              :     }
      77              :   }
      78              : }