141 lines
4.2 KiB
Dart
141 lines
4.2 KiB
Dart
import 'dart:async';
|
|
|
|
import 'package:flutter/material.dart';
|
|
import 'package:photos/core/event_bus.dart';
|
|
import 'package:photos/events/sync_status_update_event.dart';
|
|
import 'package:photos/services/sync_service.dart';
|
|
import 'package:photos/ui/header/header_error_widget.dart';
|
|
|
|
class SyncIndicator extends StatefulWidget {
|
|
const SyncIndicator({Key key}) : super(key: key);
|
|
|
|
@override
|
|
_SyncIndicatorState createState() => _SyncIndicatorState();
|
|
}
|
|
|
|
class _SyncIndicatorState extends State<SyncIndicator> {
|
|
static const kSleepDuration = Duration(milliseconds: 3000);
|
|
SyncStatusUpdate _event;
|
|
double _containerHeight = 48;
|
|
StreamSubscription<SyncStatusUpdate> _subscription;
|
|
static const _inProgressIcon = CircularProgressIndicator(
|
|
strokeWidth: 2,
|
|
valueColor: AlwaysStoppedAnimation<Color>(Color.fromRGBO(45, 194, 98, 1.0)),
|
|
);
|
|
|
|
@override
|
|
void initState() {
|
|
_subscription = Bus.instance.on<SyncStatusUpdate>().listen((event) {
|
|
setState(() {
|
|
_event = event;
|
|
});
|
|
});
|
|
_event = SyncService.instance.getLastSyncStatusEvent();
|
|
super.initState();
|
|
}
|
|
|
|
@override
|
|
void dispose() {
|
|
_subscription.cancel();
|
|
super.dispose();
|
|
}
|
|
|
|
@override
|
|
Widget build(BuildContext context) {
|
|
bool isNotOutdatedEvent = _event != null &&
|
|
(_event.status == SyncStatus.completed_backup ||
|
|
_event.status == SyncStatus.completed_first_gallery_import) &&
|
|
(DateTime.now().microsecondsSinceEpoch - _event.timestamp >
|
|
kSleepDuration.inMicroseconds);
|
|
if (_event == null || isNotOutdatedEvent) {
|
|
return Container();
|
|
}
|
|
if (_event.status == SyncStatus.error) {
|
|
return HeaderErrorWidget(error: _event.error);
|
|
}
|
|
if (_event.status == SyncStatus.completed_first_gallery_import ||
|
|
_event.status == SyncStatus.completed_backup) {
|
|
Future.delayed(kSleepDuration, () {
|
|
if (mounted) {
|
|
setState(() {
|
|
_containerHeight = 0;
|
|
});
|
|
}
|
|
});
|
|
} else {
|
|
_containerHeight = 48;
|
|
}
|
|
final icon = _event.status == SyncStatus.completed_backup
|
|
? Icon(
|
|
Icons.cloud_done_outlined,
|
|
color: Theme.of(context).buttonColor,
|
|
)
|
|
: _inProgressIcon;
|
|
return AnimatedContainer(
|
|
duration: Duration(milliseconds: 300),
|
|
height: _containerHeight,
|
|
width: double.infinity,
|
|
padding: EdgeInsets.all(8),
|
|
alignment: Alignment.center,
|
|
child: SingleChildScrollView(
|
|
physics: NeverScrollableScrollPhysics(),
|
|
child: Column(
|
|
mainAxisAlignment: MainAxisAlignment.center,
|
|
crossAxisAlignment: CrossAxisAlignment.center,
|
|
children: [
|
|
Row(
|
|
mainAxisAlignment: MainAxisAlignment.center,
|
|
crossAxisAlignment: CrossAxisAlignment.center,
|
|
children: [
|
|
Container(
|
|
padding: EdgeInsets.all(2),
|
|
width: 22,
|
|
height: 22,
|
|
child: icon,
|
|
),
|
|
Padding(
|
|
padding: const EdgeInsets.fromLTRB(12, 4, 0, 0),
|
|
child: Text(_getRefreshingText()),
|
|
),
|
|
],
|
|
),
|
|
Padding(padding: EdgeInsets.all(4)),
|
|
Divider(),
|
|
],
|
|
),
|
|
),
|
|
);
|
|
}
|
|
|
|
String _getRefreshingText() {
|
|
if (_event.status == SyncStatus.started_first_gallery_import ||
|
|
_event.status == SyncStatus.completed_first_gallery_import) {
|
|
return "Loading gallery...";
|
|
}
|
|
if (_event.status == SyncStatus.applying_remote_diff) {
|
|
return "Syncing...";
|
|
}
|
|
if (_event.status == SyncStatus.preparing_for_upload) {
|
|
return "Encrypting backup...";
|
|
}
|
|
if (_event.status == SyncStatus.in_progress) {
|
|
return _event.completed.toString() +
|
|
"/" +
|
|
_event.total.toString() +
|
|
" Memories preserved";
|
|
}
|
|
if (_event.status == SyncStatus.paused) {
|
|
return _event.reason;
|
|
}
|
|
if (_event.status == SyncStatus.completed_backup) {
|
|
if (_event.wasStopped) {
|
|
return "Sync stopped";
|
|
} else {
|
|
return "All memories preserved";
|
|
}
|
|
}
|
|
// _event.status == SyncStatus.error
|
|
return _event.reason ?? "Upload failed";
|
|
}
|
|
}
|