git-touch-android-ios-app/lib/screens/notifications.dart

275 lines
7.1 KiB
Dart

import 'package:flutter/material.dart';
import 'package:flutter/cupertino.dart';
import '../scaffolds/refresh_stateless.dart';
import '../providers/notification.dart';
import '../providers/settings.dart';
import '../widgets/notification_item.dart';
import '../widgets/list_group.dart';
import '../widgets/link.dart';
import '../widgets/empty.dart';
import '../utils/utils.dart';
String getRepoKey(NotificationGroup group) {
// Add heading _ to fix number case
// - => __
// . => ___
return ('_' + group.owner + '_' + group.name)
.replaceAll('-', '__')
.replaceAll('.', '___');
}
String getItemKey(NotificationPayload item) {
return '_' + item.number.toString();
}
class NotificationGroup {
String owner;
String name;
get repo => owner + '/' + name;
List<NotificationPayload> items = [];
NotificationGroup(this.owner, this.name);
}
class NotificationScreen extends StatefulWidget {
@override
NotificationScreenState createState() => NotificationScreenState();
}
class NotificationScreenState extends State<NotificationScreen> {
String error = '';
int active = 0;
bool loading = false;
Map<String, NotificationGroup> groupMap = {};
@override
void initState() {
super.initState();
nextTick(_onSwitchTab);
}
Future<Map<String, NotificationGroup>> fetchNotifications(int index) async {
List items = await SettingsProvider.of(context).getWithCredentials(
'/notifications?all=${index == 2}&participating=${index == 1}');
var ns = items.map((item) => NotificationPayload.fromJson(item)).toList();
if (index == 0) {
NotificationProvider.of(context).setCount(ns.length);
}
Map<String, NotificationGroup> _groupMap = {};
ns.forEach((item) {
String repo = item.owner + '/' + item.name;
if (_groupMap[repo] == null) {
_groupMap[repo] = NotificationGroup(item.owner, item.name);
}
_groupMap[repo].items.add(item);
});
if (_groupMap.isNotEmpty) {
// query state of issues and pull requests
var schema = '{';
_groupMap.forEach((repo, group) {
var repoKey = getRepoKey(group);
schema +=
'$repoKey: repository(owner: "${group.owner}", name: "${group.name}") {';
group.items.forEach((item) {
var key = getItemKey(item);
switch (item.type) {
case 'Issue':
schema += '''
$key: issue(number: ${item.number}) {
state
}
''';
break;
case 'PullRequest':
schema += '''
$key: pullRequest(number: ${item.number}) {
state
}
''';
break;
}
});
schema += '}';
});
schema += '}';
// print(schema);
var data = await SettingsProvider.of(context).query(schema);
_groupMap.forEach((repo, group) {
group.items.forEach((item) {
var itemData = data[getRepoKey(group)][getItemKey(item)];
if (itemData != null) {
item.state = itemData['state'];
}
});
});
// print(data);
}
return _groupMap;
}
Widget _buildGroupItem(
BuildContext context,
MapEntry<String, NotificationGroup> entry,
) {
var group = entry.value;
var repo = group.repo;
return ListGroup(
title: Row(
mainAxisAlignment: MainAxisAlignment.spaceBetween,
children: <Widget>[
Text(
repo,
style: TextStyle(fontSize: 16, fontWeight: FontWeight.w600),
),
Link(
material: false,
onTap: () async {
await SettingsProvider.of(context)
.putWithCredentials('/repos/$repo/notifications');
await _onSwitchTab();
},
child: Icon(
Octicons.check,
color: Colors.black45,
size: 24,
),
),
],
),
items: group.items,
itemBuilder: (item, index) {
return NotificationItem(
payload: item,
markAsRead: () {
if (mounted) {
setState(() {
groupMap[entry.key].items[index].unread = false;
});
}
},
);
},
);
}
Future<void> _onSwitchTab([int index]) async {
if (loading) return;
setState(() {
error = '';
if (index != null) {
active = index;
}
loading = true;
});
try {
groupMap = await fetchNotifications(active);
} catch (err) {
error = err.toString();
throw err;
} finally {
if (mounted) {
setState(() {
loading = false;
});
}
}
}
var textMap = {
0: 'Unread',
1: 'Paticipating',
2: 'All',
};
Widget _buildTitle() {
switch (SettingsProvider.of(context).theme) {
case ThemeMap.cupertino:
// var textStyle = DefaultTextStyle.of(context).style;
return DefaultTextStyle(
style: TextStyle(fontSize: 16),
child: SizedBox.expand(
child: CupertinoSegmentedControl(
groupValue: active,
onValueChanged: _onSwitchTab,
children: textMap.map((key, text) => MapEntry(key, Text(text))),
),
),
);
default:
return Text('Notifications');
}
}
void _confirm() async {
var value = await showConfirm(context, 'Mark all as read?');
if (value) {
await SettingsProvider.of(context).putWithCredentials('/notifications');
await _onSwitchTab();
}
}
@override
Widget build(context) {
return RefreshStatelessScaffold(
title: _buildTitle(),
bottom: TabBar(
onTap: _onSwitchTab,
tabs: textMap.entries
.map((entry) => Tab(text: entry.value.toUpperCase()))
.toList(),
),
// trailing: GestureDetector(
// child: Icon(Icons.more_vert, size: 20),
// onTap: () async {
// int value = await showCupertinoDialog(
// context: context,
// builder: (context) {
// return CupertinoAlertDialog(
// title: Text('Select filter'),
// actions: textMap.entries.map((entry) {
// return CupertinoDialogAction(
// child: Text(entry.value),
// onPressed: () {
// Navigator.pop(context, entry.key);
// },
// );
// }).toList(),
// );
// },
// );
// _onSwitchTab(value);
// },
// ),
actions: <Widget>[
IconButton(
icon: Icon(Icons.done_all),
onPressed: _confirm,
)
],
onRefresh: _onSwitchTab,
loading: loading,
error: error,
bodyBuilder: () {
return groupMap.isEmpty
? EmptyWidget()
: Column(
children: [Padding(padding: EdgeInsets.only(top: 10))]..addAll(
groupMap.entries
.map((entry) => _buildGroupItem(context, entry))
.toList()));
},
);
}
}