103 lines
2.6 KiB
Dart
103 lines
2.6 KiB
Dart
import 'dart:async';
|
|
|
|
import 'package:flutter/foundation.dart';
|
|
import 'package:flutter/material.dart';
|
|
import 'package:rxdart/rxdart.dart';
|
|
import 'package:stream_chat/stream_chat.dart';
|
|
|
|
class StreamChat extends InheritedWidget {
|
|
final Client client;
|
|
final List<StreamSubscription> _subscriptions = [];
|
|
|
|
StreamChat({
|
|
Key key,
|
|
@required this.client,
|
|
@required Widget child,
|
|
}) : super(
|
|
key: key,
|
|
child: child,
|
|
) {
|
|
_subscriptions.add(client.on('message.new').listen((Event e) {
|
|
final index = channels.indexWhere((c) => c.cid == e.cid);
|
|
if (index > 0) {
|
|
final channel = channels.removeAt(index);
|
|
channels.insert(0, channel);
|
|
_channelsController.add(channels);
|
|
}
|
|
}));
|
|
}
|
|
|
|
User get user => client.state.user;
|
|
|
|
Stream<User> get userStream => client.state.userStream;
|
|
|
|
Stream<List<Channel>> get channelsStream => _channelsController.stream;
|
|
final BehaviorSubject<List<Channel>> _channelsController = BehaviorSubject();
|
|
final List<Channel> channels = [];
|
|
|
|
final BehaviorSubject<bool> _queryChannelsLoadingController =
|
|
BehaviorSubject.seeded(false);
|
|
|
|
Stream<bool> get queryChannelsLoading =>
|
|
_queryChannelsLoadingController.stream;
|
|
|
|
Future<void> queryChannels({
|
|
Map<String, dynamic> filter,
|
|
List<SortOption> sortOptions,
|
|
PaginationParams paginationParams,
|
|
Map<String, dynamic> options,
|
|
}) async {
|
|
if (_queryChannelsLoadingController.value) {
|
|
return;
|
|
}
|
|
_queryChannelsLoadingController.sink.add(true);
|
|
|
|
try {
|
|
final res = await client.queryChannels(
|
|
filter: filter,
|
|
sort: sortOptions,
|
|
options: options,
|
|
paginationParams: paginationParams,
|
|
);
|
|
channels.addAll(res);
|
|
_channelsController.sink.add(channels);
|
|
_queryChannelsLoadingController.sink.add(false);
|
|
} catch (e) {
|
|
_channelsController.sink.addError(e);
|
|
}
|
|
}
|
|
|
|
void clearChannels() {
|
|
channels.clear();
|
|
}
|
|
|
|
void dispose() {
|
|
client.dispose();
|
|
_subscriptions.forEach((s) => s.cancel());
|
|
_queryChannelsLoadingController.close();
|
|
_channelsController.close();
|
|
}
|
|
|
|
@override
|
|
bool updateShouldNotify(InheritedWidget oldWidget) {
|
|
return true;
|
|
}
|
|
|
|
static StreamChat of(BuildContext context, [bool listen = false]) {
|
|
StreamChat streamChat;
|
|
|
|
if (listen) {
|
|
streamChat = context.dependOnInheritedWidgetOfExactType<StreamChat>();
|
|
} else {
|
|
streamChat = context.findAncestorWidgetOfExactType<StreamChat>();
|
|
}
|
|
|
|
if (streamChat == null) {
|
|
throw Exception(
|
|
'You must have a StreamChat widget at the top of your widget tree');
|
|
}
|
|
|
|
return streamChat;
|
|
}
|
|
}
|