mirror of https://github.com/CympleTech/ESSE.git
Sun
4 years ago
15 changed files with 64 additions and 362 deletions
@ -1,302 +0,0 @@
@@ -1,302 +0,0 @@
|
||||
import "dart:collection"; |
||||
|
||||
import 'package:flutter/material.dart'; |
||||
|
||||
import 'package:esse/rpc.dart'; |
||||
import 'package:esse/global.dart'; |
||||
|
||||
import 'package:esse/apps/primitives.dart'; |
||||
import 'package:esse/apps/group/models.dart'; |
||||
|
||||
class GroupChatProvider extends ChangeNotifier { |
||||
Map<int, GroupChat> groups = {}; |
||||
List<int> createKeys = []; |
||||
List<int> orderKeys = []; |
||||
SplayTreeMap<int, Request> requests = SplayTreeMap(); |
||||
|
||||
int? actived; |
||||
SplayTreeMap<int, Message> activedMessages = SplayTreeMap(); |
||||
SplayTreeMap<int, Member> activedMembers = SplayTreeMap(); |
||||
|
||||
GroupChat? get activedGroup => this.groups[this.actived]; |
||||
bool get isActivedGroupOwner => this.activedGroup != null ? this.activedGroup!.owner == Global.gid : false; |
||||
bool get isActivedGroupManager { |
||||
for (var m in this.activedMembers.values) { |
||||
if (m.mid == Global.gid) { |
||||
return m.isManager; |
||||
} |
||||
} |
||||
return false; |
||||
} |
||||
|
||||
List activedMemberOrder(String myId) { |
||||
int meId = 0; |
||||
bool meOwner = false; |
||||
bool meManager = false; |
||||
List<int> allKeys = []; |
||||
List<int> managers = []; |
||||
List<int> commons = []; |
||||
List<int> blocks = []; |
||||
this.activedMembers.forEach((i, m) { |
||||
if (m.mid == myId) { |
||||
meId = i; |
||||
if (m.isManager) { |
||||
meManager = true; |
||||
if (m.mid == this.activedGroup!.owner) { |
||||
meOwner = true; |
||||
} |
||||
} |
||||
} else { |
||||
if (m.isBlock) { |
||||
blocks.add(i); |
||||
} else { |
||||
if (m.isManager) { |
||||
if (m.mid == this.activedGroup!.owner) { |
||||
allKeys.add(i); |
||||
} else { |
||||
managers.add(i); |
||||
} |
||||
} else { |
||||
commons.add(i); |
||||
} |
||||
} |
||||
} |
||||
}); |
||||
return [allKeys + managers + commons + blocks, meId, meOwner, meManager]; |
||||
} |
||||
|
||||
GroupChatProvider() { |
||||
// rpc. |
||||
rpc.addListener('group-chat-list', _list, false); |
||||
rpc.addListener('group-chat-create', _create, false); |
||||
rpc.addListener('group-chat-result', _result, false); |
||||
rpc.addListener('group-chat-detail', _detail, true); |
||||
// rpc.addListener('group-chat-update', _update, false); |
||||
rpc.addListener('group-chat-join', _join, true); |
||||
rpc.addListener('group-chat-request-list', _requestList, false); |
||||
rpc.addListener('group-chat-request-handle', _requestHandle, false); |
||||
rpc.addListener('group-chat-member-join', _memberJoin, false); |
||||
rpc.addListener('group-chat-member-info', _memberInfo, false); |
||||
rpc.addListener('group-chat-member-leave', _memberLeave, false); |
||||
rpc.addListener('group-chat-member-online', _memberOnline, false); |
||||
rpc.addListener('group-chat-member-offline', _memberOffline, false); |
||||
rpc.addListener('group-chat-message-create', _messageCreate, true); |
||||
// rpc.addListener('group-chat-message-delete', _messageDelete, false); |
||||
// rpc.addListener('group-chat-message-delivery', _messageDelivery, false); |
||||
} |
||||
|
||||
clear() { |
||||
this.groups.clear(); |
||||
this.createKeys.clear(); |
||||
this.orderKeys.clear(); |
||||
this.requests.clear(); |
||||
this.activedMessages.clear(); |
||||
this.activedMembers.clear(); |
||||
} |
||||
|
||||
updateActived() { |
||||
this.clear(); |
||||
|
||||
// load groups. |
||||
rpc.send('group-chat-list', []); |
||||
} |
||||
|
||||
updateActivedGroup(int id) { |
||||
this.actived = id; |
||||
rpc.send('group-chat-detail', [id]); |
||||
} |
||||
|
||||
clearActivedGroup() { |
||||
this.activedMessages.clear(); |
||||
this.activedMembers.clear(); |
||||
} |
||||
|
||||
requestClear() { |
||||
this.requests.clear(); |
||||
} |
||||
|
||||
join(GroupType gtype, String gid, String gaddr, String name, String remark, [String proof = '', String key = '']) { |
||||
rpc.send('group-chat-join', [gtype.toInt(), gid, gaddr, name, remark, proof, key]); |
||||
} |
||||
|
||||
requestHandle(String gid, int id, int rid, bool ok) { |
||||
rpc.send('group-chat-request-handle', [gid, id, rid, ok]); |
||||
} |
||||
|
||||
requestBlock(String gid, String rgid) { |
||||
rpc.send('group-chat-request-block', [gid, rgid]); |
||||
} |
||||
|
||||
messageCreate(MessageType mtype, String content) { |
||||
final gcd = this.activedGroup!.gid; |
||||
rpc.send('group-chat-message-create', [gcd, mtype.toInt(), content]); |
||||
} |
||||
|
||||
close(int id) { |
||||
final gcd = this.activedGroup!.gid; |
||||
rpc.send('group-chat-close', [gcd, id]); |
||||
|
||||
this.activedGroup!.isClosed = true; |
||||
notifyListeners(); |
||||
} |
||||
|
||||
delete(int id) { |
||||
final gcd = this.activedGroup!.gid; |
||||
rpc.send('group-chat-delete', [gcd, id]); |
||||
|
||||
this.actived = 0; |
||||
this.groups.remove(id); |
||||
this.activedMessages.clear(); |
||||
this.activedMembers.clear(); |
||||
} |
||||
|
||||
memberUpdate(int id, bool isBlock) { |
||||
this.activedMembers[id]!.isBlock = isBlock; |
||||
rpc.send('group-chat-member-update', [id, isBlock]); |
||||
notifyListeners(); |
||||
} |
||||
|
||||
_list(List params) { |
||||
this.clear(); |
||||
params.forEach((params) { |
||||
final gc = GroupChat.fromList(params); |
||||
if (gc.isOk) { |
||||
this.orderKeys.add(gc.id); |
||||
} else { |
||||
this.createKeys.add(gc.id); |
||||
} |
||||
this.groups[gc.id] = gc; |
||||
}); |
||||
notifyListeners(); |
||||
} |
||||
|
||||
_create(List params) { |
||||
final gc = GroupChat.fromList(params); |
||||
if (gc.isOk) { |
||||
this.orderKeys.add(gc.id); |
||||
} else { |
||||
this.createKeys.add(gc.id); |
||||
} |
||||
this.groups[gc.id] = gc; |
||||
|
||||
notifyListeners(); |
||||
} |
||||
|
||||
_result(List params) { |
||||
final id = params[0]; |
||||
this.groups[id]!.isOk = params[1]; |
||||
if (params[1]) { |
||||
//this.createKeys.remove(id); |
||||
this.orderKeys.add(id); |
||||
} |
||||
notifyListeners(); |
||||
} |
||||
|
||||
_detail(List params) { |
||||
this.clearActivedGroup(); |
||||
params[0].forEach((param) { |
||||
this.activedMembers[param[0]] = Member.fromList(param); |
||||
}); |
||||
params[1].forEach((param) { |
||||
this.activedMessages[param[0]] = Message.fromList(param); |
||||
}); |
||||
notifyListeners(); |
||||
} |
||||
|
||||
_join(List params) { |
||||
this.requests[params[0]] = Request.fromList(params); |
||||
notifyListeners(); |
||||
} |
||||
|
||||
_requestHandle(List params) { |
||||
final id = params[1]; |
||||
final ok = params[2]; |
||||
//final _efficacy = params[3]; |
||||
if (this.actived == params[0] && this.requests.containsKey(id)) { |
||||
this.requests[id]!.overIt(ok); |
||||
notifyListeners(); |
||||
} |
||||
} |
||||
|
||||
_requestList(List params) { |
||||
this.requests.clear(); |
||||
params.forEach((param) { |
||||
this.requests[param[0]] = Request.fromList(param); |
||||
}); |
||||
notifyListeners(); |
||||
} |
||||
|
||||
_memberJoin(List params) { |
||||
final member = Member.fromList(params); |
||||
if (this.actived == member.fid) { |
||||
this.activedMembers[member.id] = member; |
||||
// TODO Better add UI member joined. |
||||
notifyListeners(); |
||||
} |
||||
} |
||||
|
||||
_memberLeave(List params) { |
||||
final id = params[0]; |
||||
if (this.actived == params[0] && this.activedMembers.containsKey(id)) { |
||||
this.activedMembers.remove(id); |
||||
notifyListeners(); |
||||
} |
||||
} |
||||
|
||||
_memberInfo(List params) { |
||||
final id = params[1]; |
||||
if (this.actived == params[0] && this.activedMembers.containsKey(id)) { |
||||
this.activedMembers[id]!.addr = params[2]; |
||||
this.activedMembers[id]!.name = params[3]; |
||||
notifyListeners(); |
||||
} |
||||
} |
||||
|
||||
_memberOnline(List params) { |
||||
final id = params[0]; |
||||
final mgid = params[1]; |
||||
final maddr = params[2]; |
||||
|
||||
if (this.actived == id) { |
||||
int mid = 0; |
||||
this.activedMembers.forEach((i, m) { |
||||
if (m.mid == mgid) { |
||||
mid = i; |
||||
} |
||||
}); |
||||
if (mid > 0) { |
||||
this.activedMembers[mid]!.addr = maddr; |
||||
this.activedMembers[mid]!.online = true; |
||||
notifyListeners(); |
||||
} |
||||
} |
||||
} |
||||
|
||||
_memberOffline(List params) { |
||||
final id = params[0]; |
||||
final mgid = params[1]; |
||||
if (this.actived == id) { |
||||
int mid = 0; |
||||
this.activedMembers.forEach((i, m) { |
||||
if (m.mid == mgid) { |
||||
mid = i; |
||||
} |
||||
}); |
||||
if (mid > 0) { |
||||
this.activedMembers[mid]!.online = false; |
||||
notifyListeners(); |
||||
} |
||||
} |
||||
} |
||||
|
||||
_messageCreate(List params) { |
||||
final msg = Message.fromList(params); |
||||
if (msg.fid == this.actived) { |
||||
if (!msg.isDelivery!) { |
||||
msg.isDelivery = null; // When message create, set is is none; |
||||
} |
||||
this.activedMessages[msg.id] = msg; |
||||
notifyListeners(); |
||||
} |
||||
} |
||||
} |
||||
Loading…
Reference in new issue